v1beta1

package
v0.0.0-...-e83682a Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 9, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package v1beta1 contains API Schema definitions for the app v1beta1 API group +kubebuilder:object:generate=true +groupName=app.kubefate.net

Index

Constants

View Source 
const (
	//Pending status
	Pending string = "Pending"
	// Running status
	Running string = "Running"
	// Creating status
	Creating string = "Creating"
	// Updating status
	Updating string = "Updating"
	// Deleted status
	Deleted string = "Deleted"
	// Faild kubefate status
	Faild string = "Faild"
)

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "app.kubefate.net", Version: "v1beta1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

This section is empty.

Types

type ClusterSpec 

type ClusterSpec struct {
	Name                  string             `json:"name,omitempty"`
	Namespace             string             `json:"namespace,omitempty"`
	ChartName             string             `json:"chartName"`
	ChartVersion          string             `json:"chartVersion"`
	PartyID               int32              `json:"partyId"`
	Registry              string             `json:"registry,omitempty"`
	ImageTag              string             `json:"imageTag,omitempty"`
	PullPolicy            string             `json:"pullPolicy,omitempty"`
	ImagePullSecrets      []ImagePullSecrets `json:"imagePullSecrets,omitempty"`
	Persistence           bool               `json:"persistence,omitempty"`
	Istio                 Istio              `json:"istio,omitempty"`
	Modules               []string           `json:"modules,omitempty"`
	Backend               string             `json:"backend,omitempty"`
	Host                  *Host              `json:"bachostkend,omitempty"`
	Rollsite              *Rollsite          `json:"rollsite,omitempty"`
	Lbrollsite            *Lbrollsite        `json:"lbrollsite,omitempty"`
	Nodemanager           *Nodemanager       `json:"nodemanager"`
	Python                *Python            `json:"python,omitempty"`
	Mysql                 *Mysql             `json:"mysql,omitempty"`
	ExternalMysqlIP       string             `json:"externalMysqlIp,omitempty"`
	ExternalMysqlPort     string             `json:"externalMysqlPort,omitempty"`
	ExternalMysqlDatabase string             `json:"externalMysqlDatabase,omitempty"`
	ExternalMysqlUser     string             `json:"externalMysqlUser,omitempty"`
	ExternalMysqlPassword string             `json:"externalMysqlPassword,omitempty"`
	ServingIP             string             `json:"servingIp,omitempty"`
	ServingPort           int32              `json:"servingPort,omitempty"`
	Spark                 *Spark             `json:"spark,omitempty"`
	Hdfs                  *Hdfs              `json:"hdfs,omitempty"`
	Nginx                 *Nginx             `json:"nginx,omitempty"`
	Rabbitmq              *Rabbitmq          `json:"rabbitmq,omitempty"`
}

ClusterSpec

func (*ClusterSpec) DeepCopy 

func (in *ClusterSpec) DeepCopy() *ClusterSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpec.

func (*ClusterSpec) DeepCopyInto 

func (in *ClusterSpec) DeepCopyInto(out *ClusterSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Datanode 

type Datanode struct {
	NodeSelector NodeSelector `json:"nodeSelector,omitempty"`
	Type         string       `json:"type,omitempty"`
}

func (*Datanode) DeepCopy 

func (in *Datanode) DeepCopy() *Datanode

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Datanode.

func (*Datanode) DeepCopyInto 

func (in *Datanode) DeepCopyInto(out *Datanode)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Exchange 

type Exchange struct {
	Id   int32  `json:"id,omitempty"`
	IP   string `json:"ip,omitempty"`
	Port int32  `json:"port,omitempty"`
}

func (*Exchange) DeepCopy 

func (in *Exchange) DeepCopy() *Exchange

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Exchange.

func (*Exchange) DeepCopyInto 

func (in *Exchange) DeepCopyInto(out *Exchange)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FateCluster 

type FateCluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   FateClusterSpec   `json:"spec,omitempty"`
	Status FateClusterStatus `json:"status,omitempty"`
}

FateCluster is the Schema for the fateclusters API

func (*FateCluster) DeepCopy 

func (in *FateCluster) DeepCopy() *FateCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FateCluster.

func (*FateCluster) DeepCopyInto 

func (in *FateCluster) DeepCopyInto(out *FateCluster)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*FateCluster) DeepCopyObject 

func (in *FateCluster) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type FateClusterList 

type FateClusterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []FateCluster `json:"items"`
}

FateClusterList contains a list of FateCluster

func (*FateClusterList) DeepCopy 

func (in *FateClusterList) DeepCopy() *FateClusterList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FateClusterList.

func (*FateClusterList) DeepCopyInto 

func (in *FateClusterList) DeepCopyInto(out *FateClusterList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*FateClusterList) DeepCopyObject 

func (in *FateClusterList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type FateClusterSpec 

type FateClusterSpec struct {
	ClusterSpec *ClusterSpec           `json:"clusterSpec,omitempty"`
	Kubefate    KubefateNamespacedName `json:"kubefate,omitempty"`
	ClusterData string                 `json:"clusterData,omitempty"`
}

FateClusterSpec defines the desired state of FateCluster

func (*FateClusterSpec) DeepCopy 

func (in *FateClusterSpec) DeepCopy() *FateClusterSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FateClusterSpec.

func (*FateClusterSpec) DeepCopyInto 

func (in *FateClusterSpec) DeepCopyInto(out *FateClusterSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FateClusterStatus 

type FateClusterStatus struct {
	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
	// Important: Run "make" to regenerate code after modifying this file
	Status            string `json:"status,omitempty"`
	KubefateJobId     string `json:"jobId,omitempty"`
	KubefateClusterId string `json:"clusterId,omitempty"`
}

FateClusterStatus defines the observed state of FateCluster

func (*FateClusterStatus) DeepCopy 

func (in *FateClusterStatus) DeepCopy() *FateClusterStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FateClusterStatus.

func (*FateClusterStatus) DeepCopyInto 

func (in *FateClusterStatus) DeepCopyInto(out *FateClusterStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FateJob 

type FateJob struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   FateJobSpec   `json:"spec,omitempty"`
	Status FateJobStatus `json:"status,omitempty"`
}

FateJob is the Schema for the fatejobs API

func (*FateJob) DeepCopy 

func (in *FateJob) DeepCopy() *FateJob

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FateJob.

func (*FateJob) DeepCopyInto 

func (in *FateJob) DeepCopyInto(out *FateJob)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*FateJob) DeepCopyObject 

func (in *FateJob) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type FateJobList 

type FateJobList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []FateJob `json:"items"`
}

FateJobList contains a list of FateJob

func (*FateJobList) DeepCopy 

func (in *FateJobList) DeepCopy() *FateJobList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FateJobList.

func (*FateJobList) DeepCopyInto 

func (in *FateJobList) DeepCopyInto(out *FateJobList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*FateJobList) DeepCopyObject 

func (in *FateJobList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type FateJobSpec 

type FateJobSpec struct {
	Image          string                 `json:"image,omitempty"`
	FateClusterRef corev1.ObjectReference `json:"fateClusterRef"`
	JobConf        JobConf                `json:"jobConf,omitempty"`
}

FateJobSpec defines the desired state of FateJob

func (*FateJobSpec) DeepCopy 

func (in *FateJobSpec) DeepCopy() *FateJobSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FateJobSpec.

func (*FateJobSpec) DeepCopyInto 

func (in *FateJobSpec) DeepCopyInto(out *FateJobSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FateJobStatus 

type FateJobStatus struct {
	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
	// Important: Run "make" to regenerate code after modifying this file
	Status string `json:"status,omitempty"`

	JobStatus batchv1.JobStatus `json:"jobStatus,omitempty"`
}

FateJobStatus defines the observed state of FateJob

func (*FateJobStatus) DeepCopy 

func (in *FateJobStatus) DeepCopy() *FateJobStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FateJobStatus.

func (*FateJobStatus) DeepCopyInto 

func (in *FateJobStatus) DeepCopyInto(out *FateJobStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Fateflow 

type Fateflow struct {
	Host         string `json:"host,omitempty"`
	HTTPNodePort int32  `json:"httpNodePort,omitempty"`
	GrpcNodePort int32  `json:"grpcNodePort,omitempty"`
}

func (*Fateflow) DeepCopy 

func (in *Fateflow) DeepCopy() *Fateflow

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Fateflow.

func (*Fateflow) DeepCopyInto 

func (in *Fateflow) DeepCopyInto(out *Fateflow)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Hdfs 

type Hdfs struct {
	Namenode *Namenode `json:"namenode,omitempty"`
	Datanode *Datanode `json:"datanode,omitempty"`
}

func (*Hdfs) DeepCopy 

func (in *Hdfs) DeepCopy() *Hdfs

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Hdfs.

func (*Hdfs) DeepCopyInto 

func (in *Hdfs) DeepCopyInto(out *Hdfs)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Host 

type Host struct {
	Fateboard  string `json:"fateboard,omitempty"`
	Client     string `json:"client,omitempty"`
	SparkUI    string `json:"sparkUI,omitempty"`
	RabbitmqUI string `json:"rabbitmqUI,omitempty"`
}

func (*Host) DeepCopy 

func (in *Host) DeepCopy() *Host

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Host.

func (*Host) DeepCopyInto 

func (in *Host) DeepCopyInto(out *Host)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ImagePullSecrets 

type ImagePullSecrets struct {
	Name string `json:"name,omitempty"`
}

func (*ImagePullSecrets) DeepCopy 

func (in *ImagePullSecrets) DeepCopy() *ImagePullSecrets

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ImagePullSecrets.

func (*ImagePullSecrets) DeepCopyInto 

func (in *ImagePullSecrets) DeepCopyInto(out *ImagePullSecrets)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Istio 

type Istio struct {
	Enabled bool `json:"enabled,omitempty"`
}

func (*Istio) DeepCopy 

func (in *Istio) DeepCopy() *Istio

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Istio.

func (*Istio) DeepCopyInto 

func (in *Istio) DeepCopyInto(out *Istio)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type JobConf 

type JobConf struct {
	Pipeline    string `json:"pipeline,omitempty"`
	ModulesConf string `json:"modulesConf,omitempty"`
}

func (*JobConf) DeepCopy 

func (in *JobConf) DeepCopy() *JobConf

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobConf.

func (*JobConf) DeepCopyInto 

func (in *JobConf) DeepCopyInto(out *JobConf)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Kubefate 

type Kubefate struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   KubefateSpec   `json:"spec,omitempty"`
	Status KubefateStatus `json:"status,omitempty"`
}

Kubefate is the Schema for the kubefates API

func (*Kubefate) DeepCopy 

func (in *Kubefate) DeepCopy() *Kubefate

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Kubefate.

func (*Kubefate) DeepCopyInto 

func (in *Kubefate) DeepCopyInto(out *Kubefate)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Kubefate) DeepCopyObject 

func (in *Kubefate) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type KubefateList 

type KubefateList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Kubefate `json:"items"`
}

KubefateList contains a list of Kubefate

func (*KubefateList) DeepCopy 

func (in *KubefateList) DeepCopy() *KubefateList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KubefateList.

func (*KubefateList) DeepCopyInto 

func (in *KubefateList) DeepCopyInto(out *KubefateList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*KubefateList) DeepCopyObject 

func (in *KubefateList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type KubefateNamespacedName 

type KubefateNamespacedName struct {
	Name      string `json:"name,omitempty"`
	Namespace string `json:"namespace,omitempty"`
}

func (*KubefateNamespacedName) DeepCopy 

func (in *KubefateNamespacedName) DeepCopy() *KubefateNamespacedName

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KubefateNamespacedName.

func (*KubefateNamespacedName) DeepCopyInto 

func (in *KubefateNamespacedName) DeepCopyInto(out *KubefateNamespacedName)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type KubefateSpec 

type KubefateSpec struct {
	Image              string              `json:"image,omitempty"`
	IngressDomain      string              `json:"ingressDomain,omitempty"`
	ServiceAccountName string              `json:"serviceAccountName,omitempty"`
	VolumeSource       corev1.VolumeSource `json:"volumeSource,omitempty"`
	Config             []corev1.EnvVar     `json:"config,omitempty"`
}

KubefateSpec defines the desired state of Kubefate

func (*KubefateSpec) DeepCopy 

func (in *KubefateSpec) DeepCopy() *KubefateSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KubefateSpec.

func (*KubefateSpec) DeepCopyInto 

func (in *KubefateSpec) DeepCopyInto(out *KubefateSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type KubefateStatus 

type KubefateStatus struct {
	Status string `json:"status,omitempty"`

	Namespace       string `json:"namespace,omitempty"`
	KubefateDeploy  string `json:"kubefateDeploy,omitempty"`
	MariadbDeploy   string `json:"mariadbDeploy,omitempty"`
	KubefateService string `json:"kubefateService,omitempty"`
	MariadbService  string `json:"mariadbService,omitempty"`
	Ingress         string `json:"ingress,omitempty"`
}

KubefateStatus defines the observed state of Kubefate

func (*KubefateStatus) DeepCopy 

func (in *KubefateStatus) DeepCopy() *KubefateStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KubefateStatus.

func (*KubefateStatus) DeepCopyInto 

func (in *KubefateStatus) DeepCopyInto(out *KubefateStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Lbrollsite 

type Lbrollsite struct {
	Type         string       `json:"type,omitempty"`
	NodePort     int32        `json:"nodePort,omitempty"`
	Size         string       `json:"size,omitempty"`
	Exchange     *Exchange    `json:"exchange,omitempty"`
	PartyList    []PartyList  `json:"partyList,omitempty"`
	NodeSelector NodeSelector `json:"nodeSelector,omitempty"`
}

func (*Lbrollsite) DeepCopy 

func (in *Lbrollsite) DeepCopy() *Lbrollsite

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Lbrollsite.

func (*Lbrollsite) DeepCopyInto 

func (in *Lbrollsite) DeepCopyInto(out *Lbrollsite)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type List 

type List struct {
	Name                     string       `json:"name,omitempty"`
	NodeSelector             NodeSelector `json:"nodeSelector,omitempty"`
	SessionProcessorsPerNode int32        `json:"sessionProcessorsPerNode,omitempty"`
	SubPath                  string       `json:"subPath,omitempty"`
	ExistingClaim            string       `json:"existingClaim,omitempty"`
	StorageClass             string       `json:"storageClass,omitempty"`
	AccessMode               string       `json:"accessMode,omitempty"`
	Size                     string       `json:"size,omitempty"`
}

func (*List) DeepCopy 

func (in *List) DeepCopy() *List

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new List.

func (*List) DeepCopyInto 

func (in *List) DeepCopyInto(out *List)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Master 

type Master struct {
	Image        string       `json:"Image,omitempty"`
	ImageTag     string       `json:"ImageTag,omitempty"`
	Replicas     int32        `json:"replicas,omitempty"`
	CPU          string       `json:"cpu,omitempty"`
	Memory       string       `json:"memory,omitempty"`
	NodeSelector NodeSelector `json:"nodeSelector,omitempty"`
	Type         string       `json:"type,omitempty"`
}

func (*Master) DeepCopy 

func (in *Master) DeepCopy() *Master

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Master.

func (*Master) DeepCopyInto 

func (in *Master) DeepCopyInto(out *Master)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Mysql 

type Mysql struct {
	NodeSelector  NodeSelector `json:"nodeSelector,omitempty"`
	IP            string       `json:"ip,omitempty"`
	Port          int32        `json:"port,omitempty"`
	Database      string       `json:"database,omitempty"`
	User          string       `json:"user,omitempty"`
	Password      string       `json:"password,omitempty"`
	SubPath       string       `json:"subPath,omitempty"`
	ExistingClaim string       `json:"existingClaim,omitempty"`
	StorageClass  string       `json:"storageClass,omitempty"`
	AccessMode    string       `json:"accessMode,omitempty"`
	Size          string       `json:"size,omitempty"`
}

func (*Mysql) DeepCopy 

func (in *Mysql) DeepCopy() *Mysql

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Mysql.

func (*Mysql) DeepCopyInto 

func (in *Mysql) DeepCopyInto(out *Mysql)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NGRouteTable 

type NGRouteTable map[string]PartyInfo

func (NGRouteTable) DeepCopy 

func (in NGRouteTable) DeepCopy() NGRouteTable

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NGRouteTable.

func (NGRouteTable) DeepCopyInto 

func (in NGRouteTable) DeepCopyInto(out *NGRouteTable)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Namenode 

type Namenode struct {
	NodeSelector NodeSelector `json:"nodeSelector,omitempty"`
	Type         string       `json:"type,omitempty"`
}

func (*Namenode) DeepCopy 

func (in *Namenode) DeepCopy() *Namenode

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Namenode.

func (*Namenode) DeepCopyInto 

func (in *Namenode) DeepCopyInto(out *Namenode)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Nginx 

type Nginx struct {
	NodeSelector NodeSelector `json:"nodeSelector,omitempty"`
	Type         string       `json:"type,omitempty"`
	HTTPNodePort int32        `json:"httpNodePort,omitempty"`
	GrpcNodePort int32        `json:"grpcNodePort,omitempty"`
	RouteTable   NGRouteTable `json:"route_table,omitempty"`
}

func (*Nginx) DeepCopy 

func (in *Nginx) DeepCopy() *Nginx

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Nginx.

func (*Nginx) DeepCopyInto 

func (in *Nginx) DeepCopyInto(out *Nginx)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NodeSelector 

type NodeSelector map[string]string

func (NodeSelector) DeepCopy 

func (in NodeSelector) DeepCopy() NodeSelector

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeSelector.

func (NodeSelector) DeepCopyInto 

func (in NodeSelector) DeepCopyInto(out *NodeSelector)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Nodemanager 

type Nodemanager struct {
	Count                    int32  `json:"count,omitempty"`
	SessionProcessorsPerNode int32  `json:"sessionProcessorsPerNode"`
	StorageClass             string `json:"storageClass,omitempty"`
	AccessMode               string `json:"accessMode,omitempty"`
	List                     []List `json:"list,omitempty"`
}

func (*Nodemanager) DeepCopy 

func (in *Nodemanager) DeepCopy() *Nodemanager

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Nodemanager.

func (*Nodemanager) DeepCopyInto 

func (in *Nodemanager) DeepCopyInto(out *Nodemanager)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Party 

type Party struct {
	Host string `json:"host,omitempty"`
	Port int32  `json:"port,omitempty"`
}

func (*Party) DeepCopy 

func (in *Party) DeepCopy() *Party

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Party.

func (*Party) DeepCopyInto 

func (in *Party) DeepCopyInto(out *Party)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PartyInfo 

type PartyInfo struct {
	Proxy    []Proxy    `json:"proxy,omitempty"`
	Fateflow []Fateflow `json:"fateflow,omitempty"`
}

func (*PartyInfo) DeepCopy 

func (in *PartyInfo) DeepCopy() *PartyInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PartyInfo.

func (*PartyInfo) DeepCopyInto 

func (in *PartyInfo) DeepCopyInto(out *PartyInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PartyList 

type PartyList struct {
	PartyID   int32  `json:"partyId,omitempty"`
	PartyIP   string `json:"partyIp,omitempty"`
	PartyPort int32  `json:"partyPort,omitempty"`
}

func (*PartyList) DeepCopy 

func (in *PartyList) DeepCopy() *PartyList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PartyList.

func (*PartyList) DeepCopyInto 

func (in *PartyList) DeepCopyInto(out *PartyList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Proxy 

type Proxy struct {
	Host         string `json:"host,omitempty"`
	HTTPNodePort int32  `json:"httpNodePort,omitempty"`
	GrpcNodePort int32  `json:"grpcNodePort,omitempty"`
}

func (*Proxy) DeepCopy 

func (in *Proxy) DeepCopy() *Proxy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Proxy.

func (*Proxy) DeepCopyInto 

func (in *Proxy) DeepCopyInto(out *Proxy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Python 

type Python struct {
	Type         string          `json:"type,omitempty"`
	HTTPNodePort int32           `json:"httpNodePort,omitempty"`
	GrpcNodePort int32           `json:"grpcNodePort,omitempty"`
	NodeSelector NodeSelector    `json:"nodeSelector,omitempty"`
	EnabledNN    bool            `json:"enabledNN,omitempty"`
	Spark        *PythonSpark    `json:"spark,omitempty"`
	Hdfs         *PythonHdfs     `json:"hdfs,omitempty"`
	Rabbitmq     *PythonRabbitmq `json:"rabbitmq,omitempty"`
	Nginx        *PythonNginx    `json:"nginx,omitempty"`
}

func (*Python) DeepCopy 

func (in *Python) DeepCopy() *Python

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Python.

func (*Python) DeepCopyInto 

func (in *Python) DeepCopyInto(out *Python)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PythonHdfs 

type PythonHdfs struct {
	NameNode   string `json:"name_node,omitempty"`
	PathPrefix string `json:"path_prefix,omitempty"`
}

func (*PythonHdfs) DeepCopy 

func (in *PythonHdfs) DeepCopy() *PythonHdfs

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PythonHdfs.

func (*PythonHdfs) DeepCopyInto 

func (in *PythonHdfs) DeepCopyInto(out *PythonHdfs)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PythonNginx 

type PythonNginx struct {
	Host     string `json:"host,omitempty"`
	HTTPPort string `json:"http_port,omitempty"`
	GrpcPort string `json:"grpc_port,omitempty"`
}

func (*PythonNginx) DeepCopy 

func (in *PythonNginx) DeepCopy() *PythonNginx

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PythonNginx.

func (*PythonNginx) DeepCopyInto 

func (in *PythonNginx) DeepCopyInto(out *PythonNginx)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PythonRabbitmq 

type PythonRabbitmq struct {
	Host       string `json:"host,omitempty"`
	MngPort    string `json:"mng_port,omitempty"`
	Port       string `json:"port,omitempty"`
	User       string `json:"user,omitempty"`
	Password   string `json:"password,omitempty"`
	RouteTable string `json:"route_table,omitempty"`
}

func (*PythonRabbitmq) DeepCopy 

func (in *PythonRabbitmq) DeepCopy() *PythonRabbitmq

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PythonRabbitmq.

func (*PythonRabbitmq) DeepCopyInto 

func (in *PythonRabbitmq) DeepCopyInto(out *PythonRabbitmq)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PythonSpark 

type PythonSpark struct {
	Master       string `json:"master,omitempty"`
	Home         string `json:"home,omitempty"`
	CoresPerNode string `json:"cores_per_node,omitempty"`
	Nodes        string `json:"nodes,omitempty"`
}

func (*PythonSpark) DeepCopy 

func (in *PythonSpark) DeepCopy() *PythonSpark

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PythonSpark.

func (*PythonSpark) DeepCopyInto 

func (in *PythonSpark) DeepCopyInto(out *PythonSpark)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type RBRouteTable 

type RBRouteTable map[string]Party

func (RBRouteTable) DeepCopy 

func (in RBRouteTable) DeepCopy() RBRouteTable

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RBRouteTable.

func (RBRouteTable) DeepCopyInto 

func (in RBRouteTable) DeepCopyInto(out *RBRouteTable)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Rabbitmq 

type Rabbitmq struct {
	NodeSelector NodeSelector `json:"nodeSelector,omitempty"`
	Type         string       `json:"type,omitempty"`
	NodePort     int32        `json:"nodePort,omitempty"`
	DefaultUser  string       `json:"default_user,omitempty"`
	DefaultPass  string       `json:"default_pass,omitempty"`
	User         string       `json:"user,omitempty"`
	Password     string       `json:"password,omitempty"`
	RouteTable   RBRouteTable `json:"route_table,omitempty"`
}

func (*Rabbitmq) DeepCopy 

func (in *Rabbitmq) DeepCopy() *Rabbitmq

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Rabbitmq.

func (*Rabbitmq) DeepCopyInto 

func (in *Rabbitmq) DeepCopyInto(out *Rabbitmq)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Rollsite 

type Rollsite struct {
	Type         string       `json:"type,omitempty"`
	NodePort     int32        `json:"nodePort,omitempty"`
	Exchange     *Exchange    `json:"exchange,omitempty"`
	PartyList    []PartyList  `json:"partyList,omitempty"`
	NodeSelector NodeSelector `json:"nodeSelector,omitempty"`
}

func (*Rollsite) DeepCopy 

func (in *Rollsite) DeepCopy() *Rollsite

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Rollsite.

func (*Rollsite) DeepCopyInto 

func (in *Rollsite) DeepCopyInto(out *Rollsite)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Spark 

type Spark struct {
	Master Master `json:"Master,omitempty"`
	Worker Worker `json:"Worker,omitempty"`
}

func (*Spark) DeepCopy 

func (in *Spark) DeepCopy() *Spark

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Spark.

func (*Spark) DeepCopyInto 

func (in *Spark) DeepCopyInto(out *Spark)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Worker 

type Worker struct {
	Image        string       `json:"Image,omitempty"`
	ImageTag     string       `json:"ImageTag,omitempty"`
	Replicas     int32        `json:"replicas,omitempty"`
	CPU          string       `json:"cpu,omitempty"`
	Memory       string       `json:"memory,omitempty"`
	NodeSelector NodeSelector `json:"nodeSelector,omitempty"`
	Type         string       `json:"type,omitempty"`
}

func (*Worker) DeepCopy 

func (in *Worker) DeepCopy() *Worker

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Worker.

func (*Worker) DeepCopyInto 

func (in *Worker) DeepCopyInto(out *Worker)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.