v1alpha1

package
v0.4.1 Latest Latest
Warning

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

 Go to latest Published: Sep 18, 2021 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package v1alpha1 is the v1alpha1 version of the API.

Index

Constants

This section is empty.

Variables

View Source 
var (
	// SchemeBuilder initializes a scheme builder
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	// AddToScheme is a global function that registers this API group & version to a scheme
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: sedna.GroupName, Version: "v1alpha1"}

SchemeGroupVersion is group version used to register these objects

Functions

func Kind 

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns back a Group qualified GroupKind

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type AggregationWorker 

type AggregationWorker struct {
	// Model defines train model of federated learning job
	Model    TrainModel         `json:"model"`
	Template v1.PodTemplateSpec `json:"template"`
}

AggregationWorker describes the data an aggregation worker should have

func (*AggregationWorker) DeepCopy 

func (in *AggregationWorker) DeepCopy() *AggregationWorker

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

func (*AggregationWorker) DeepCopyInto 

func (in *AggregationWorker) DeepCopyInto(out *AggregationWorker)

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

type BigModel 

type BigModel struct {
	Name string `json:"name"`
}

BigModel describes the big model

func (*BigModel) DeepCopy 

func (in *BigModel) DeepCopy() *BigModel

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

func (*BigModel) DeepCopyInto 

func (in *BigModel) DeepCopyInto(out *BigModel)

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

type CloudWorker 

type CloudWorker struct {
	Model    BigModel           `json:"model"`
	Template v1.PodTemplateSpec `json:"template"`
}

CloudWorker describes the data a cloud worker should have

func (*CloudWorker) DeepCopy 

func (in *CloudWorker) DeepCopy() *CloudWorker

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

func (*CloudWorker) DeepCopyInto 

func (in *CloudWorker) DeepCopyInto(out *CloudWorker)

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

type Condition 

type Condition struct {
	Operator  string  `json:"operator"`
	Threshold float64 `json:"threshold"`
	Metric    string  `json:"metric"`
}

func (*Condition) DeepCopy 

func (in *Condition) DeepCopy() *Condition

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

func (*Condition) DeepCopyInto 

func (in *Condition) DeepCopyInto(out *Condition)

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

type Dataset 

type Dataset struct {
	metav1.TypeMeta `json:",inline"`

	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   DatasetSpec   `json:"spec"`
	Status DatasetStatus `json:"status,omitempty"`
}

Dataset describes the data that a dataset resource should have

func (*Dataset) DeepCopy 

func (in *Dataset) DeepCopy() *Dataset

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

func (*Dataset) DeepCopyInto 

func (in *Dataset) DeepCopyInto(out *Dataset)

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

func (*Dataset) DeepCopyObject 

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

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

type DatasetList 

type DatasetList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`

	Items []Dataset `json:"items"`
}

DatasetList is a list of Datasets

func (*DatasetList) DeepCopy 

func (in *DatasetList) DeepCopy() *DatasetList

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

func (*DatasetList) DeepCopyInto 

func (in *DatasetList) DeepCopyInto(out *DatasetList)

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

func (*DatasetList) DeepCopyObject 

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

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

type DatasetSpec 

type DatasetSpec struct {
	URL      string `json:"url"`
	Format   string `json:"format"`
	NodeName string `json:"nodeName"`

	CredentialName string `json:"credentialName,omitempty"`
}

DatasetSpec is a description of a dataset

func (*DatasetSpec) DeepCopy 

func (in *DatasetSpec) DeepCopy() *DatasetSpec

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

func (*DatasetSpec) DeepCopyInto 

func (in *DatasetSpec) DeepCopyInto(out *DatasetSpec)

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

type DatasetStatus 

type DatasetStatus struct {
	UpdateTime      *metav1.Time `json:"updateTime,omitempty" protobuf:"bytes,1,opt,name=updateTime"`
	NumberOfSamples int          `json:"numberOfSamples"`
}

DatasetStatus represents information about the status of a dataset including the time a dataset updated, and number of samples in a dataset

func (*DatasetStatus) DeepCopy 

func (in *DatasetStatus) DeepCopy() *DatasetStatus

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

func (*DatasetStatus) DeepCopyInto 

func (in *DatasetStatus) DeepCopyInto(out *DatasetStatus)

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

type DeployModel 

type DeployModel struct {
	Name string `json:"name"`
	// HotUpdateEnabled will enable the model hot update feature if its value is true.
	// Default value is false.
	HotUpdateEnabled bool `json:"hotUpdateEnabled,omitempty"`
	// PollPeriodSeconds is interval in seconds between echo poll of the deploy model config file.
	// PollPeriodSeconds must be greater than zero and the default value is 60.
	// It will be used only when HotUpdateEnabled is true.
	// +kubebuilder:validation:Minimum:=1
	// +kubebuilder:default:=60
	PollPeriodSeconds int64 `json:"pollPeriodSeconds,omitempty"`
}

func (*DeployModel) DeepCopy 

func (in *DeployModel) DeepCopy() *DeployModel

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

func (*DeployModel) DeepCopyInto 

func (in *DeployModel) DeepCopyInto(out *DeployModel)

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

type DeploySpec 

type DeploySpec struct {
	Model             DeployModel        `json:"model"`
	Trigger           Trigger            `json:"trigger"`
	HardExampleMining HardExampleMining  `json:"hardExampleMining"`
	Template          v1.PodTemplateSpec `json:"template"`
}

DeploySpec describes the deploy model to be updated

func (*DeploySpec) DeepCopy 

func (in *DeploySpec) DeepCopy() *DeploySpec

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

func (*DeploySpec) DeepCopyInto 

func (in *DeploySpec) DeepCopyInto(out *DeploySpec)

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

type EdgeWorker 

type EdgeWorker struct {
	Model             SmallModel         `json:"model"`
	HardExampleMining HardExampleMining  `json:"hardExampleMining"`
	Template          v1.PodTemplateSpec `json:"template"`
}

EdgeWorker describes the data a edge worker should have

func (*EdgeWorker) DeepCopy 

func (in *EdgeWorker) DeepCopy() *EdgeWorker

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

func (*EdgeWorker) DeepCopyInto 

func (in *EdgeWorker) DeepCopyInto(out *EdgeWorker)

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

type EvalSpec 

type EvalSpec struct {
	Template v1.PodTemplateSpec `json:"template"`
}

EvalSpec describes the data an eval worker should have

func (*EvalSpec) DeepCopy 

func (in *EvalSpec) DeepCopy() *EvalSpec

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

func (*EvalSpec) DeepCopyInto 

func (in *EvalSpec) DeepCopyInto(out *EvalSpec)

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

type FLJobCondition 

type FLJobCondition struct {
	// Type of job condition, Complete or Failed.
	Type FLJobConditionType `json:"type"`
	// Status of the condition, one of True, False, Unknown.
	Status v1.ConditionStatus `json:"status"`
	// Last time the condition was checked.
	// +optional
	LastProbeTime metav1.Time `json:"lastProbeTime,omitempty"`
	// Last time the condition transit from one status to another.
	// +optional
	LastHeartbeatTime metav1.Time `json:"lastHeartbeatTime,omitempty"`
	// (brief) reason for the condition's last transition.
	// +optional
	Reason string `json:"reason,omitempty"`
	// Human readable message indicating details about last transition.
	// +optional
	Message string `json:"message,omitempty"`
}

FLJobCondition describes current state of a job.

func (*FLJobCondition) DeepCopy 

func (in *FLJobCondition) DeepCopy() *FLJobCondition

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

func (*FLJobCondition) DeepCopyInto 

func (in *FLJobCondition) DeepCopyInto(out *FLJobCondition)

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

type FLJobConditionType 

type FLJobConditionType string
const (
	// FLJobComplete means the job has completed its execution.
	FLJobCondComplete FLJobConditionType = "Complete"
	// FLJobFailed means the job has failed its execution.
	FLJobCondFailed FLJobConditionType = "Failed"
	// FLJobCondTraining means the job has been training.
	FLJobCondTraining FLJobConditionType = "Training"
)

These are valid conditions of a job.

type FLJobPhase 

type FLJobPhase string

FLJobPhase is a label for the condition of a job at the current time. 

const (
	// FLJobPending means the job has been accepted by the system, but one or more of the pods
	// has not been started. This includes time before being bound to a node, as well as time spent
	// pulling images onto the host.
	FLJobPending FLJobPhase = "Pending"
	// FLJobRunning means the job has been bound to a node and all of the pods have been started.
	// At least one container is still running or is in the process of being restarted.
	FLJobRunning FLJobPhase = "Running"
	// FLJobSucceeded means that all pods in the job have voluntarily terminated
	// with a container exit code of 0, and the system is not going to restart any of these pods.
	FLJobSucceeded FLJobPhase = "Succeeded"
	// FLJobFailed means that all pods in the job have terminated, and at least one container has
	// terminated in a failure (exited with a non-zero exit code or was stopped by the system).
	FLJobFailed FLJobPhase = "Failed"
)

These are the valid statuses of jobs.

type FLJobSpec 

type FLJobSpec struct {
	AggregationWorker AggregationWorker `json:"aggregationWorker"`
	TrainingWorkers   []TrainingWorker  `json:"trainingWorkers"`
	PretrainedModel   PretrainedModel   `json:"pretrainedModel,omitempty"`
	Transmitter       Transmitter       `json:"transmitter,omitempty"`
}

FLJobSpec is a description of a federatedlearning job

func (*FLJobSpec) DeepCopy 

func (in *FLJobSpec) DeepCopy() *FLJobSpec

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

func (*FLJobSpec) DeepCopyInto 

func (in *FLJobSpec) DeepCopyInto(out *FLJobSpec)

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

type FLJobStatus 

type FLJobStatus struct {

	// The latest available observations of a federated job's current state.
	// +optional
	Conditions []FLJobCondition `json:"conditions,omitempty"`

	// Represents time when the job was acknowledged by the job controller.
	// It is not guaranteed to be set in happens-before order across separate operations.
	// It is represented in RFC3339 form and is in UTC.
	// +optional
	StartTime *metav1.Time `json:"startTime,omitempty"`

	// Represents time when the job was completed. It is not guaranteed to
	// be set in happens-before order across separate operations.
	// It is represented in RFC3339 form and is in UTC.
	// +optional
	CompletionTime *metav1.Time `json:"completionTime,omitempty"`

	// The number of actively running pods.
	// +optional
	Active int32 `json:"active"`

	// The number of pods which reached phase Succeeded.
	// +optional
	Succeeded int32 `json:"succeeded"`

	// The number of pods which reached phase Failed.
	// +optional
	Failed int32 `json:"failed"`

	// The phase of the federatedlearning job.
	// +optional
	Phase FLJobPhase `json:"phase,omitempty"`
}

FLJobStatus represents the current state of a federatedlearning job.

func (*FLJobStatus) DeepCopy 

func (in *FLJobStatus) DeepCopy() *FLJobStatus

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

func (*FLJobStatus) DeepCopyInto 

func (in *FLJobStatus) DeepCopyInto(out *FLJobStatus)

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

type FederatedLearningJob 

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

	Spec   FLJobSpec   `json:"spec"`
	Status FLJobStatus `json:"status,omitempty"`
}

FederatedLearningJob describes the data that a FederatedLearningJob resource should have

func (*FederatedLearningJob) DeepCopy 

func (in *FederatedLearningJob) DeepCopy() *FederatedLearningJob

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

func (*FederatedLearningJob) DeepCopyInto 

func (in *FederatedLearningJob) DeepCopyInto(out *FederatedLearningJob)

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

func (*FederatedLearningJob) DeepCopyObject 

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

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

type FederatedLearningJobList 

type FederatedLearningJobList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`
	Items           []FederatedLearningJob `json:"items"`
}

FederatedLearningJobList is a list of FederatedLearningJobs.

func (*FederatedLearningJobList) DeepCopy 

func (in *FederatedLearningJobList) DeepCopy() *FederatedLearningJobList

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

func (*FederatedLearningJobList) DeepCopyInto 

func (in *FederatedLearningJobList) DeepCopyInto(out *FederatedLearningJobList)

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

func (*FederatedLearningJobList) DeepCopyObject 

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

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

type HardExampleMining 

type HardExampleMining struct {
	Name       string     `json:"name"`
	Parameters []ParaSpec `json:"parameters,omitempty"`
}

HardExampleMining describes the hard example algorithm to be used

func (*HardExampleMining) DeepCopy 

func (in *HardExampleMining) DeepCopy() *HardExampleMining

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

func (*HardExampleMining) DeepCopyInto 

func (in *HardExampleMining) DeepCopyInto(out *HardExampleMining)

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

type ILDataset 

type ILDataset struct {
	Name      string  `json:"name"`
	TrainProb float64 `json:"trainProb"`
}

func (*ILDataset) DeepCopy 

func (in *ILDataset) DeepCopy() *ILDataset

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

func (*ILDataset) DeepCopyInto 

func (in *ILDataset) DeepCopyInto(out *ILDataset)

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

type ILJobCondition 

type ILJobCondition struct {
	// Type of job condition, Complete or Failed.
	Type ILJobStageConditionType `json:"type"`
	// Status of the condition, one of True, False, Unknown.
	Status v1.ConditionStatus `json:"status"`
	// Stage of the condition
	Stage ILJobStage `json:"stage"`
	// last time we got an update on a given condition
	// +optional
	LastHeartbeatTime metav1.Time `json:"lastHeartbeatTime,omitempty"`
	// Last time the condition transit from one status to another.
	// +optional
	LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"`
	// (brief) reason for the condition's last transition.
	// +optional
	Reason string `json:"reason,omitempty"`
	// Human readable message indicating details about last transition.
	// +optional
	Message string `json:"message,omitempty"`
	// The json data related to this condition
	// +optional
	Data string `json:"data,omitempty"`
}

ILJobCondition describes current state of a job. see https://github.com/kubernetes/community/blob/master/contributors/devel/sig-architecture/api-conventions.md#typical-status-properties for details.

func (*ILJobCondition) DeepCopy 

func (in *ILJobCondition) DeepCopy() *ILJobCondition

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

func (*ILJobCondition) DeepCopyInto 

func (in *ILJobCondition) DeepCopyInto(out *ILJobCondition)

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

type ILJobSpec 

type ILJobSpec struct {
	Dataset      ILDataset    `json:"dataset"`
	InitialModel InitialModel `json:"initialModel"`
	TrainSpec    TrainSpec    `json:"trainSpec"`
	EvalSpec     EvalSpec     `json:"evalSpec"`
	DeploySpec   DeploySpec   `json:"deploySpec"`

	// the credential referer for OutputDir
	CredentialName string `json:"credentialName,omitempty"`
	OutputDir      string `json:"outputDir"`
}

ILJobSpec is a description of a incrementallearningjob

func (*ILJobSpec) DeepCopy 

func (in *ILJobSpec) DeepCopy() *ILJobSpec

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

func (*ILJobSpec) DeepCopyInto 

func (in *ILJobSpec) DeepCopyInto(out *ILJobSpec)

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

type ILJobStage 

type ILJobStage string

ILJobStage is a label for the stage of a job at the current time. 

const (
	ILJobTrain  ILJobStage = "Train"
	ILJobEval   ILJobStage = "Eval"
	ILJobDeploy ILJobStage = "Deploy"
)

type ILJobStageConditionType 

type ILJobStageConditionType string
const (
	ILJobStageCondWaiting   ILJobStageConditionType = "Waiting"
	ILJobStageCondReady     ILJobStageConditionType = "Ready"
	ILJobStageCondStarting  ILJobStageConditionType = "Starting"
	ILJobStageCondRunning   ILJobStageConditionType = "Running"
	ILJobStageCondCompleted ILJobStageConditionType = "Completed"
	ILJobStageCondFailed    ILJobStageConditionType = "Failed"
)

These are valid stage conditions of a job.

type ILJobStatus 

type ILJobStatus struct {
	// The latest available observations of a incrementllearning job's current state.
	// +optional
	Conditions []ILJobCondition `json:"conditions,omitempty"`

	// Represents time when the job was acknowledged by the job controller.
	// It is not guaranteed to be set in happens-before order across separate operations.
	// It is represented in RFC3339 form and is in UTC.
	// +optional
	StartTime *metav1.Time `json:"startTime,omitempty"`

	// Represents time when the job was completed. It is not guaranteed to
	// be set in happens-before order across separate operations.
	// It is represented in RFC3339 form and is in UTC.
	// +optional
	CompletionTime *metav1.Time `json:"completionTime,omitempty"`
}

ILJobStatus represents the current state of a incrementallearning job

func (*ILJobStatus) DeepCopy 

func (in *ILJobStatus) DeepCopy() *ILJobStatus

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

func (*ILJobStatus) DeepCopyInto 

func (in *ILJobStatus) DeepCopyInto(out *ILJobStatus)

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

type IncrementalLearningJob 

type IncrementalLearningJob struct {
	metav1.TypeMeta `json:",inline"`

	metav1.ObjectMeta `json:"metadata"`

	Spec   ILJobSpec   `json:"spec"`
	Status ILJobStatus `json:"status,omitempty"`
}

IncrementalLearningJob describes the data that a incrementallearningjob resource should have

func (*IncrementalLearningJob) DeepCopy 

func (in *IncrementalLearningJob) DeepCopy() *IncrementalLearningJob

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

func (*IncrementalLearningJob) DeepCopyInto 

func (in *IncrementalLearningJob) DeepCopyInto(out *IncrementalLearningJob)

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

func (*IncrementalLearningJob) DeepCopyObject 

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

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

type IncrementalLearningJobList 

type IncrementalLearningJobList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`
	Items           []IncrementalLearningJob `json:"items"`
}

IncrementalLearningJobList is a list of IncrementalLearningJobs.

func (*IncrementalLearningJobList) DeepCopy 

func (in *IncrementalLearningJobList) DeepCopy() *IncrementalLearningJobList

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

func (*IncrementalLearningJobList) DeepCopyInto 

func (in *IncrementalLearningJobList) DeepCopyInto(out *IncrementalLearningJobList)

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

func (*IncrementalLearningJobList) DeepCopyObject 

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

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

type InitialModel 

type InitialModel struct {
	Name string `json:"name"`
}

func (*InitialModel) DeepCopy 

func (in *InitialModel) DeepCopy() *InitialModel

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

func (*InitialModel) DeepCopyInto 

func (in *InitialModel) DeepCopyInto(out *InitialModel)

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

type JointInferenceService 

type JointInferenceService struct {
	metav1.TypeMeta `json:",inline"`

	metav1.ObjectMeta `json:"metadata"`

	Spec   JointInferenceServiceSpec   `json:"spec"`
	Status JointInferenceServiceStatus `json:"status,omitempty"`
}

JointInferenceService describes the data that a jointinferenceservice resource should have

func (*JointInferenceService) DeepCopy 

func (in *JointInferenceService) DeepCopy() *JointInferenceService

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

func (*JointInferenceService) DeepCopyInto 

func (in *JointInferenceService) DeepCopyInto(out *JointInferenceService)

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

func (*JointInferenceService) DeepCopyObject 

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

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

type JointInferenceServiceCondition 

type JointInferenceServiceCondition struct {
	// Type of service condition, Complete or Failed.
	Type JointInferenceServiceConditionType `json:"type"`
	// Status of the condition, one of True, False, Unknown.
	Status v1.ConditionStatus `json:"status"`
	// last time we got an update on a given condition
	// +optional
	LastHeartbeatTime metav1.Time `json:"lastHeartbeatTime,omitempty"`
	// Last time the condition transit from one status to another.
	// +optional
	LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"`
	// (brief) reason for the condition's last transition,
	// one-word CamelCase reason for the condition's last transition.
	// +optional
	Reason string `json:"reason,omitempty"`
	// Human readable message indicating details about last transition.
	// +optional
	Message string `json:"message,omitempty"`
}

JointInferenceServiceCondition describes current state of a service. see https://github.com/kubernetes/community/blob/master/contributors/devel/sig-architecture/api-conventions.md#typical-status-properties for details.

func (*JointInferenceServiceCondition) DeepCopy 

func (in *JointInferenceServiceCondition) DeepCopy() *JointInferenceServiceCondition

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

func (*JointInferenceServiceCondition) DeepCopyInto 

func (in *JointInferenceServiceCondition) DeepCopyInto(out *JointInferenceServiceCondition)

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

type JointInferenceServiceConditionType 

type JointInferenceServiceConditionType string

JointInferenceServiceConditionType defines the condition type 

const (
	// JointInferenceServiceCondPending means the service has been accepted by the system,
	// but one or more of the workers has not been started.
	JointInferenceServiceCondPending JointInferenceServiceConditionType = "Pending"
	// JointInferenceServiceCondFailed means the service has failed its execution.
	JointInferenceServiceCondFailed JointInferenceServiceConditionType = "Failed"
	// JointInferenceServiceReady means the service has been ready.
	JointInferenceServiceCondRunning JointInferenceServiceConditionType = "Running"
)

These are valid conditions of a service.

type JointInferenceServiceList 

type JointInferenceServiceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`
	Items           []JointInferenceService `json:"items"`
}

JointInferenceServiceList is a list of JointInferenceServices.

func (*JointInferenceServiceList) DeepCopy 

func (in *JointInferenceServiceList) DeepCopy() *JointInferenceServiceList

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

func (*JointInferenceServiceList) DeepCopyInto 

func (in *JointInferenceServiceList) DeepCopyInto(out *JointInferenceServiceList)

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

func (*JointInferenceServiceList) DeepCopyObject 

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

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

type JointInferenceServiceSpec 

type JointInferenceServiceSpec struct {
	EdgeWorker  EdgeWorker  `json:"edgeWorker"`
	CloudWorker CloudWorker `json:"cloudWorker"`
}

JointInferenceServiceSpec is a description of a jointinferenceservice

func (*JointInferenceServiceSpec) DeepCopy 

func (in *JointInferenceServiceSpec) DeepCopy() *JointInferenceServiceSpec

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

func (*JointInferenceServiceSpec) DeepCopyInto 

func (in *JointInferenceServiceSpec) DeepCopyInto(out *JointInferenceServiceSpec)

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

type JointInferenceServiceStatus 

type JointInferenceServiceStatus struct {

	// The latest available observations of a joint inference service's current state.
	// +optional
	Conditions []JointInferenceServiceCondition `json:"conditions,omitempty"`

	// Represents time when the service was acknowledged by the service controller.
	// It is not guaranteed to be set in happens-before order across separate operations.
	// It is represented in RFC3339 form and is in UTC.
	// +optional
	StartTime *metav1.Time `json:"startTime,omitempty"`

	// The number of actively running workers.
	// +optional
	Active int32 `json:"active"`

	// The number of workers which reached to Failed.
	// +optional
	Failed int32 `json:"failed"`

	// Metrics of the joint inference service.
	Metrics []Metric `json:"metrics,omitempty"`
}

JointInferenceServiceStatus represents the current state of a joint inference service.

func (*JointInferenceServiceStatus) DeepCopy 

func (in *JointInferenceServiceStatus) DeepCopy() *JointInferenceServiceStatus

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

func (*JointInferenceServiceStatus) DeepCopyInto 

func (in *JointInferenceServiceStatus) DeepCopyInto(out *JointInferenceServiceStatus)

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

type LLCondition added in v0.3.0 

type LLCondition struct {
	Operator  string  `json:"operator"`
	Threshold float64 `json:"threshold"`
	Metric    string  `json:"metric"`
}

func (*LLCondition) DeepCopy added in v0.3.0 

func (in *LLCondition) DeepCopy() *LLCondition

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

func (*LLCondition) DeepCopyInto added in v0.3.0 

func (in *LLCondition) DeepCopyInto(out *LLCondition)

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

type LLDataset added in v0.3.0 

type LLDataset struct {
	Name      string  `json:"name"`
	TrainProb float64 `json:"trainProb"`
}

func (*LLDataset) DeepCopy added in v0.3.0 

func (in *LLDataset) DeepCopy() *LLDataset

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

func (*LLDataset) DeepCopyInto added in v0.3.0 

func (in *LLDataset) DeepCopyInto(out *LLDataset)

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

type LLDeploySpec added in v0.3.0 

type LLDeploySpec struct {
	Template v1.PodTemplateSpec `json:"template"`
}

LLDeploySpec describes the deploy model to be updated

func (*LLDeploySpec) DeepCopy added in v0.3.0 

func (in *LLDeploySpec) DeepCopy() *LLDeploySpec

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

func (*LLDeploySpec) DeepCopyInto added in v0.3.0 

func (in *LLDeploySpec) DeepCopyInto(out *LLDeploySpec)

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

type LLEvalSpec added in v0.3.0 

type LLEvalSpec struct {
	Template v1.PodTemplateSpec `json:"template"`
}

LLEvalSpec describes the data an eval worker should have

func (*LLEvalSpec) DeepCopy added in v0.3.0 

func (in *LLEvalSpec) DeepCopy() *LLEvalSpec

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

func (*LLEvalSpec) DeepCopyInto added in v0.3.0 

func (in *LLEvalSpec) DeepCopyInto(out *LLEvalSpec)

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

type LLJobCondition added in v0.3.0 

type LLJobCondition struct {
	// Type of job condition, Complete or Failed.
	Type LLJobStageConditionType `json:"type"`
	// Status of the condition, one of True, False, Unknown.
	Status v1.ConditionStatus `json:"status"`
	// Stage of the condition
	Stage LLJobStage `json:"stage"`
	// last time we got an update on a given condition
	// +optional
	LastHeartbeatTime metav1.Time `json:"lastHeartbeatTime,omitempty"`
	// Last time the condition transit from one status to another.
	// +optional
	LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"`
	// (brief) reason for the condition's last transition.
	// +optional
	Reason string `json:"reason,omitempty"`
	// Human readable message indicating details about last transition.
	// +optional
	Message string `json:"message,omitempty"`
	// The json data related to this condition
	// +optional
	Data string `json:"data,omitempty"`
}

LLJobCondition describes current state of a job. see https://github.com/kubernetes/community/blob/master/contributors/devel/sig-architecture/api-conventions.md#typical-status-properties for details.

func (*LLJobCondition) DeepCopy added in v0.3.0 

func (in *LLJobCondition) DeepCopy() *LLJobCondition

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

func (*LLJobCondition) DeepCopyInto added in v0.3.0 

func (in *LLJobCondition) DeepCopyInto(out *LLJobCondition)

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

type LLJobSpec added in v0.3.0 

type LLJobSpec struct {
	Dataset    LLDataset    `json:"dataset"`
	TrainSpec  LLTrainSpec  `json:"trainSpec"`
	EvalSpec   LLEvalSpec   `json:"evalSpec"`
	DeploySpec LLDeploySpec `json:"deploySpec"`

	// the credential referer for OutputDir
	CredentialName string `json:"credentialName,omitempty"`
	OutputDir      string `json:"outputDir"`
}

func (*LLJobSpec) DeepCopy added in v0.3.0 

func (in *LLJobSpec) DeepCopy() *LLJobSpec

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

func (*LLJobSpec) DeepCopyInto added in v0.3.0 

func (in *LLJobSpec) DeepCopyInto(out *LLJobSpec)

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

type LLJobStage added in v0.3.0 

type LLJobStage string

LLJobStage is a label for the stage of a job at the current time. 

const (
	LLJobTrain  LLJobStage = "Train"
	LLJobEval   LLJobStage = "Eval"
	LLJobDeploy LLJobStage = "Deploy"
)

type LLJobStageConditionType added in v0.3.0 

type LLJobStageConditionType string
const (
	LLJobStageCondWaiting   LLJobStageConditionType = "Waiting"
	LLJobStageCondReady     LLJobStageConditionType = "Ready"
	LLJobStageCondStarting  LLJobStageConditionType = "Starting"
	LLJobStageCondRunning   LLJobStageConditionType = "Running"
	LLJobStageCondCompleted LLJobStageConditionType = "Completed"
	LLJobStageCondFailed    LLJobStageConditionType = "Failed"
)

These are valid stage conditions of a job.

type LLJobStatus added in v0.3.0 

type LLJobStatus struct {
	// The latest available observations of a lifelonglearning job's current state.
	// +optional
	Conditions []LLJobCondition `json:"conditions,omitempty"`

	// Represents time when the job was acknowledged by the job controller.
	// It is not guaranteed to be set in happens-before order across separate operations.
	// It is represented in RFC3339 form and is in UTC.
	// +optional
	StartTime *metav1.Time `json:"startTime,omitempty"`

	// Represents time when the job was completed. It is not guaranteed to
	// be set in happens-before order across separate operations.
	// It is represented in RFC3339 form and is in UTC.
	// +optional
	CompletionTime *metav1.Time `json:"completionTime,omitempty"`
}

LLJobStatus represents the current state of a lifelonglearning job

func (*LLJobStatus) DeepCopy added in v0.3.0 

func (in *LLJobStatus) DeepCopy() *LLJobStatus

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

func (*LLJobStatus) DeepCopyInto added in v0.3.0 

func (in *LLJobStatus) DeepCopyInto(out *LLJobStatus)

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

type LLTimer added in v0.3.0 

type LLTimer struct {
	Start string `json:"start"`
	End   string `json:"end"`
}

func (*LLTimer) DeepCopy added in v0.3.0 

func (in *LLTimer) DeepCopy() *LLTimer

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

func (*LLTimer) DeepCopyInto added in v0.3.0 

func (in *LLTimer) DeepCopyInto(out *LLTimer)

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

type LLTrainSpec added in v0.3.0 

type LLTrainSpec struct {
	Template v1.PodTemplateSpec `json:"template"`
	Trigger  LLTrigger          `json:"trigger"`
}

LLTrainSpec describes the data an train worker should have

func (*LLTrainSpec) DeepCopy added in v0.3.0 

func (in *LLTrainSpec) DeepCopy() *LLTrainSpec

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

func (*LLTrainSpec) DeepCopyInto added in v0.3.0 

func (in *LLTrainSpec) DeepCopyInto(out *LLTrainSpec)

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

type LLTrigger added in v0.3.0 

type LLTrigger struct {
	CheckPeriodSeconds int         `json:"checkPeriodSeconds,omitempty"`
	Timer              *LLTimer    `json:"timer,omitempty"`
	Condition          LLCondition `json:"condition"`
}

func (*LLTrigger) DeepCopy added in v0.3.0 

func (in *LLTrigger) DeepCopy() *LLTrigger

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

func (*LLTrigger) DeepCopyInto added in v0.3.0 

func (in *LLTrigger) DeepCopyInto(out *LLTrigger)

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

type LifelongLearningJob added in v0.3.0 

type LifelongLearningJob struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              LLJobSpec   `json:"spec"`
	Status            LLJobStatus `json:"status,omitempty"`
}

func (*LifelongLearningJob) DeepCopy added in v0.3.0 

func (in *LifelongLearningJob) DeepCopy() *LifelongLearningJob

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

func (*LifelongLearningJob) DeepCopyInto added in v0.3.0 

func (in *LifelongLearningJob) DeepCopyInto(out *LifelongLearningJob)

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

func (*LifelongLearningJob) DeepCopyObject added in v0.3.0 

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

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

type LifelongLearningJobList added in v0.3.0 

type LifelongLearningJobList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`
	Items           []LifelongLearningJob `json:"items"`
}

LifelongLearningJobList is a list of LifelongLearningJobs.

func (*LifelongLearningJobList) DeepCopy added in v0.3.0 

func (in *LifelongLearningJobList) DeepCopy() *LifelongLearningJobList

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

func (*LifelongLearningJobList) DeepCopyInto added in v0.3.0 

func (in *LifelongLearningJobList) DeepCopyInto(out *LifelongLearningJobList)

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

func (*LifelongLearningJobList) DeepCopyObject added in v0.3.0 

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

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

type Metric 

type Metric struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

Metric describes the data that a resource model metric should have

func (*Metric) DeepCopy 

func (in *Metric) DeepCopy() *Metric

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

func (*Metric) DeepCopyInto 

func (in *Metric) DeepCopyInto(out *Metric)

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

type Model 

type Model struct {
	metav1.TypeMeta `json:",inline"`

	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   ModelSpec   `json:"spec"`
	Status ModelStatus `json:"status,omitempty"`
}

Model describes the data that a model resource should have

func (*Model) DeepCopy 

func (in *Model) DeepCopy() *Model

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

func (*Model) DeepCopyInto 

func (in *Model) DeepCopyInto(out *Model)

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

func (*Model) DeepCopyObject 

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

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

type ModelList 

type ModelList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`

	Items []Model `json:"items"`
}

ModelList is a list of Models

func (*ModelList) DeepCopy 

func (in *ModelList) DeepCopy() *ModelList

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

func (*ModelList) DeepCopyInto 

func (in *ModelList) DeepCopyInto(out *ModelList)

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

func (*ModelList) DeepCopyObject 

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

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

type ModelSpec 

type ModelSpec struct {
	URL    string `json:"url"`
	Format string `json:"format"`

	CredentialName string `json:"credentialName,omitempty"`
}

ModelSpec is a description of a model

func (*ModelSpec) DeepCopy 

func (in *ModelSpec) DeepCopy() *ModelSpec

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

func (*ModelSpec) DeepCopyInto 

func (in *ModelSpec) DeepCopyInto(out *ModelSpec)

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

type ModelStatus 

type ModelStatus struct {
	UpdateTime *metav1.Time `json:"updateTime,omitempty" protobuf:"bytes,1,opt,name=updateTime"`
	Metrics    []Metric     `json:"metrics,omitempty" protobuf:"bytes,2,rep,name=metrics"`
}

ModelStatus represents information about the status of a model including the time a model updated, and metrics in a model

func (*ModelStatus) DeepCopy 

func (in *ModelStatus) DeepCopy() *ModelStatus

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

func (*ModelStatus) DeepCopyInto 

func (in *ModelStatus) DeepCopyInto(out *ModelStatus)

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

type ObjectSearchService added in v0.3.1 

type ObjectSearchService struct {
	metav1.TypeMeta `json:",inline"`

	metav1.ObjectMeta `json:"metadata"`

	Spec   ObjectSearchServiceSpec   `json:"spec"`
	Status ObjectSearchServiceStatus `json:"status,omitempty"`
}

ObjectSearchService describes the data that a objectsearchservice resource should have

func (*ObjectSearchService) DeepCopy added in v0.4.0 

func (in *ObjectSearchService) DeepCopy() *ObjectSearchService

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

func (*ObjectSearchService) DeepCopyInto added in v0.4.0 

func (in *ObjectSearchService) DeepCopyInto(out *ObjectSearchService)

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

func (*ObjectSearchService) DeepCopyObject added in v0.4.0 

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

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

type ObjectSearchServiceCondition added in v0.3.1 

type ObjectSearchServiceCondition struct {
	// Type of service condition, Complete or Failed.
	Type ObjectSearchServiceConditionType `json:"type"`
	// Status of the condition, one of True, False, Unknown.
	Status v1.ConditionStatus `json:"status"`
	// last time we got an update on a given condition
	// +optional
	LastHeartbeatTime metav1.Time `json:"lastHeartbeatTime,omitempty"`
	// Last time the condition transit from one status to another.
	// +optional
	LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"`
	// (brief) reason for the condition's last transition,
	// one-word CamelCase reason for the condition's last transition.
	// +optional
	Reason string `json:"reason,omitempty"`
	// Human readable message indicating details about last transition.
	// +optional
	Message string `json:"message,omitempty"`
}

ObjectSearchServiceCondition describes current state of a service. see https://github.com/kubernetes/community/blob/master/contributors/devel/sig-architecture/api-conventions.md#typical-status-properties for details.

func (*ObjectSearchServiceCondition) DeepCopy added in v0.4.0 

func (in *ObjectSearchServiceCondition) DeepCopy() *ObjectSearchServiceCondition

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

func (*ObjectSearchServiceCondition) DeepCopyInto added in v0.4.0 

func (in *ObjectSearchServiceCondition) DeepCopyInto(out *ObjectSearchServiceCondition)

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

type ObjectSearchServiceConditionType added in v0.3.1 

type ObjectSearchServiceConditionType string

ObjectSearchServiceConditionType defines the condition type 

const (
	// ObjectSearchServiceCondPending means the service has been accepted by the system,
	// but one or more of the workers has not been started.
	ObjectSearchServiceCondPending ObjectSearchServiceConditionType = "Pending"
	// ObjectSearchServiceCondFailed means the service has failed its execution.
	ObjectSearchServiceCondFailed ObjectSearchServiceConditionType = "Failed"
	// ObjectSearchServiceReady means the service has been ready.
	ObjectSearchServiceCondRunning ObjectSearchServiceConditionType = "Running"
)

These are valid conditions of a service.

type ObjectSearchServiceList added in v0.3.1 

type ObjectSearchServiceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`
	Items           []ObjectSearchService `json:"items"`
}

ObjectSearchServiceList is a list of ObjectSearchServices.

func (*ObjectSearchServiceList) DeepCopy added in v0.4.0 

func (in *ObjectSearchServiceList) DeepCopy() *ObjectSearchServiceList

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

func (*ObjectSearchServiceList) DeepCopyInto added in v0.4.0 

func (in *ObjectSearchServiceList) DeepCopyInto(out *ObjectSearchServiceList)

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

func (*ObjectSearchServiceList) DeepCopyObject added in v0.4.0 

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

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

type ObjectSearchServiceSpec added in v0.3.1 

type ObjectSearchServiceSpec struct {
	UserWorker      UserWorker       `json:"userWorker"`
	TrackingWorkers []TrackingWorker `json:"trackingWorkers"`
	ReidWorkers     ReidWorkers      `json:"reidWorkers"`
}

ObjectSearchServiceSpec is a description of a objectsearchservice

func (*ObjectSearchServiceSpec) DeepCopy added in v0.4.0 

func (in *ObjectSearchServiceSpec) DeepCopy() *ObjectSearchServiceSpec

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

func (*ObjectSearchServiceSpec) DeepCopyInto added in v0.4.0 

func (in *ObjectSearchServiceSpec) DeepCopyInto(out *ObjectSearchServiceSpec)

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

type ObjectSearchServiceStatus added in v0.3.1 

type ObjectSearchServiceStatus struct {

	// The latest available observations of a object search service's current state.
	// +optional
	Conditions []ObjectSearchServiceCondition `json:"conditions,omitempty"`

	// Represents time when the service was acknowledged by the service controller.
	// It is not guaranteed to be set in happens-before order across separate operations.
	// It is represented in RFC3339 form and is in UTC.
	// +optional
	StartTime *metav1.Time `json:"startTime,omitempty"`

	// The number of actively running workers.
	// +optional
	Active int32 `json:"active"`

	// The number of workers which reached to Failed.
	// +optional
	Failed int32 `json:"failed"`
}

ObjectSearchServiceStatus represents the current state of a object search service.

func (*ObjectSearchServiceStatus) DeepCopy added in v0.4.0 

func (in *ObjectSearchServiceStatus) DeepCopy() *ObjectSearchServiceStatus

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

func (*ObjectSearchServiceStatus) DeepCopyInto added in v0.4.0 

func (in *ObjectSearchServiceStatus) DeepCopyInto(out *ObjectSearchServiceStatus)

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

type ObjectTrackingService added in v0.3.1 

type ObjectTrackingService struct {
	metav1.TypeMeta `json:",inline"`

	metav1.ObjectMeta `json:"metadata"`

	Spec   ObjectTrackingServiceSpec   `json:"spec"`
	Status ObjectTrackingServiceStatus `json:"status,omitempty"`
}

ObjectTrackingService describes the data that a objecttrackingservice resource should have

func (*ObjectTrackingService) DeepCopy added in v0.4.0 

func (in *ObjectTrackingService) DeepCopy() *ObjectTrackingService

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

func (*ObjectTrackingService) DeepCopyInto added in v0.4.0 

func (in *ObjectTrackingService) DeepCopyInto(out *ObjectTrackingService)

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

func (*ObjectTrackingService) DeepCopyObject added in v0.4.0 

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

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

type ObjectTrackingServiceCondition added in v0.3.1 

type ObjectTrackingServiceCondition struct {
	// Type of service condition, Complete or Failed.
	Type ObjectTrackingServiceConditionType `json:"type"`
	// Status of the condition, one of True, False, Unknown.
	Status v1.ConditionStatus `json:"status"`
	// last time we got an update on a given condition
	// +optional
	LastHeartbeatTime metav1.Time `json:"lastHeartbeatTime,omitempty"`
	// Last time the condition transit from one status to another.
	// +optional
	LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"`
	// (brief) reason for the condition's last transition,
	// one-word CamelCase reason for the condition's last transition.
	// +optional
	Reason string `json:"reason,omitempty"`
	// Human readable message indicating details about last transition.
	// +optional
	Message string `json:"message,omitempty"`
}

ObjectTrackingServiceCondition describes current state of a service. see https://github.com/kubernetes/community/blob/master/contributors/devel/sig-architecture/api-conventions.md#typical-status-properties for details.

func (*ObjectTrackingServiceCondition) DeepCopy added in v0.4.0 

func (in *ObjectTrackingServiceCondition) DeepCopy() *ObjectTrackingServiceCondition

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

func (*ObjectTrackingServiceCondition) DeepCopyInto added in v0.4.0 

func (in *ObjectTrackingServiceCondition) DeepCopyInto(out *ObjectTrackingServiceCondition)

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

type ObjectTrackingServiceConditionType added in v0.3.1 

type ObjectTrackingServiceConditionType string

ObjectTrackingServiceConditionType defines the condition type 

const (
	// ObjectTrackingServiceCondPending means the service has been accepted by the system,
	// but one or more of the workers has not been started.
	ObjectTrackingServiceCondPending ObjectTrackingServiceConditionType = "Pending"
	// ObjectTrackingServiceCondFailed means the service has failed its execution.
	ObjectTrackingServiceCondFailed ObjectTrackingServiceConditionType = "Failed"
	// ObjectTrackingServiceReady means the service has been ready.
	ObjectTrackingServiceCondRunning ObjectTrackingServiceConditionType = "Running"
)

These are valid conditions of a service.

type ObjectTrackingServiceList added in v0.3.1 

type ObjectTrackingServiceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`
	Items           []ObjectTrackingService `json:"items"`
}

ObjectTrackingServiceList is a list of ObjectTrackingServices.

func (*ObjectTrackingServiceList) DeepCopy added in v0.4.0 

func (in *ObjectTrackingServiceList) DeepCopy() *ObjectTrackingServiceList

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

func (*ObjectTrackingServiceList) DeepCopyInto added in v0.4.0 

func (in *ObjectTrackingServiceList) DeepCopyInto(out *ObjectTrackingServiceList)

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

func (*ObjectTrackingServiceList) DeepCopyObject added in v0.4.0 

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

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

type ObjectTrackingServiceSpec added in v0.3.1 

type ObjectTrackingServiceSpec struct {
	TrackingWorkers []TrackingWorker `json:"trackingWorkers"`
	ReidWorkers     ReidWorkers      `json:"reidWorkers"`
}

ObjectTrackingServiceSpec is a description of a objecttrackingservice

func (*ObjectTrackingServiceSpec) DeepCopy added in v0.4.0 

func (in *ObjectTrackingServiceSpec) DeepCopy() *ObjectTrackingServiceSpec

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

func (*ObjectTrackingServiceSpec) DeepCopyInto added in v0.4.0 

func (in *ObjectTrackingServiceSpec) DeepCopyInto(out *ObjectTrackingServiceSpec)

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

type ObjectTrackingServiceStatus added in v0.3.1 

type ObjectTrackingServiceStatus struct {

	// The latest available observations of a object tracking service's current state.
	// +optional
	Conditions []ObjectTrackingServiceCondition `json:"conditions,omitempty"`

	// Represents time when the service was acknowledged by the service controller.
	// It is not guaranteed to be set in happens-before order across separate operations.
	// It is represented in RFC3339 form and is in UTC.
	// +optional
	StartTime *metav1.Time `json:"startTime,omitempty"`

	// The number of actively running workers.
	// +optional
	Active int32 `json:"active"`

	// The number of workers which reached to Failed.
	// +optional
	Failed int32 `json:"failed"`
}

ObjectTrackingServiceStatus represents the current state of a object tracking service.

func (*ObjectTrackingServiceStatus) DeepCopy added in v0.4.0 

func (in *ObjectTrackingServiceStatus) DeepCopy() *ObjectTrackingServiceStatus

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

func (*ObjectTrackingServiceStatus) DeepCopyInto added in v0.4.0 

func (in *ObjectTrackingServiceStatus) DeepCopyInto(out *ObjectTrackingServiceStatus)

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

type ParaSpec 

type ParaSpec struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

ParaSpec is a description of a parameter

func (*ParaSpec) DeepCopy 

func (in *ParaSpec) DeepCopy() *ParaSpec

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

func (*ParaSpec) DeepCopyInto 

func (in *ParaSpec) DeepCopyInto(out *ParaSpec)

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

type PretrainedModel added in v0.4.0 

type PretrainedModel struct {
	Name string `json:"name"`
}

PretrainedModel defines pretrained model of federated learning job

func (*PretrainedModel) DeepCopy added in v0.4.0 

func (in *PretrainedModel) DeepCopy() *PretrainedModel

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

func (*PretrainedModel) DeepCopyInto added in v0.4.0 

func (in *PretrainedModel) DeepCopyInto(out *PretrainedModel)

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

type ReidWorkers added in v0.3.1 

type ReidWorkers struct {
	appsv1.DeploymentSpec `json:",inline"`
}

ReidWorkers describes the data reid workers should have

func (*ReidWorkers) DeepCopy added in v0.4.0 

func (in *ReidWorkers) DeepCopy() *ReidWorkers

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

func (*ReidWorkers) DeepCopyInto added in v0.4.0 

func (in *ReidWorkers) DeepCopyInto(out *ReidWorkers)

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

type S3Transmitter added in v0.4.0 

type S3Transmitter struct {
	AggregationDataPath string `json:"aggDataPath"`
	CredentialName      string `json:"credentialName,omitempty"`
}

S3Transmitter describes the s3 transmitter

func (*S3Transmitter) DeepCopy added in v0.4.0 

func (in *S3Transmitter) DeepCopy() *S3Transmitter

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

func (*S3Transmitter) DeepCopyInto added in v0.4.0 

func (in *S3Transmitter) DeepCopyInto(out *S3Transmitter)

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

type SmallModel 

type SmallModel struct {
	Name string `json:"name"`
}

SmallModel describes the small model

func (*SmallModel) DeepCopy 

func (in *SmallModel) DeepCopy() *SmallModel

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

func (*SmallModel) DeepCopyInto 

func (in *SmallModel) DeepCopyInto(out *SmallModel)

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

type Timer 

type Timer struct {
	Start string `json:"start"`
	End   string `json:"end"`
}

func (*Timer) DeepCopy 

func (in *Timer) DeepCopy() *Timer

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

func (*Timer) DeepCopyInto 

func (in *Timer) DeepCopyInto(out *Timer)

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

type TrackingWorker added in v0.3.1 

type TrackingWorker struct {
	Template v1.PodTemplateSpec `json:"template"`
}

TrackingWorker describes the data a tracking worker should have

func (*TrackingWorker) DeepCopy added in v0.4.0 

func (in *TrackingWorker) DeepCopy() *TrackingWorker

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

func (*TrackingWorker) DeepCopyInto added in v0.4.0 

func (in *TrackingWorker) DeepCopyInto(out *TrackingWorker)

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

type TrainDataset added in v0.4.0 

type TrainDataset struct {
	Name string `json:"name"`
}

TrainDataset defines dataset of federated learning job

func (*TrainDataset) DeepCopy added in v0.4.0 

func (in *TrainDataset) DeepCopy() *TrainDataset

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

func (*TrainDataset) DeepCopyInto added in v0.4.0 

func (in *TrainDataset) DeepCopyInto(out *TrainDataset)

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

type TrainModel added in v0.4.0 

type TrainModel struct {
	Name string `json:"name"`
}

func (*TrainModel) DeepCopy added in v0.4.0 

func (in *TrainModel) DeepCopy() *TrainModel

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

func (*TrainModel) DeepCopyInto added in v0.4.0 

func (in *TrainModel) DeepCopyInto(out *TrainModel)

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

type TrainSpec 

type TrainSpec struct {
	Template v1.PodTemplateSpec `json:"template"`
	Trigger  Trigger            `json:"trigger"`
}

TrainSpec describes the data an train worker should have

func (*TrainSpec) DeepCopy 

func (in *TrainSpec) DeepCopy() *TrainSpec

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

func (*TrainSpec) DeepCopyInto 

func (in *TrainSpec) DeepCopyInto(out *TrainSpec)

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

type TrainingWorker 

type TrainingWorker struct {
	Dataset  TrainDataset       `json:"dataset"`
	Template v1.PodTemplateSpec `json:"template"`
}

TrainingWorker describes the data a training worker should have

func (*TrainingWorker) DeepCopy 

func (in *TrainingWorker) DeepCopy() *TrainingWorker

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

func (*TrainingWorker) DeepCopyInto 

func (in *TrainingWorker) DeepCopyInto(out *TrainingWorker)

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

type Transmitter added in v0.4.0 

type Transmitter struct {
	S3 *S3Transmitter `json:"s3,omitempty"`
	WS *WSTransmitter `json:"ws,omitempty"`
}

Transmitter describes the transmitter of data plane between training workers and aggregation worker

func (*Transmitter) DeepCopy added in v0.4.0 

func (in *Transmitter) DeepCopy() *Transmitter

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

func (*Transmitter) DeepCopyInto added in v0.4.0 

func (in *Transmitter) DeepCopyInto(out *Transmitter)

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

type Trigger 

type Trigger struct {
	CheckPeriodSeconds int       `json:"checkPeriodSeconds,omitempty"`
	Timer              *Timer    `json:"timer,omitempty"`
	Condition          Condition `json:"condition"`
}

func (*Trigger) DeepCopy 

func (in *Trigger) DeepCopy() *Trigger

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

func (*Trigger) DeepCopyInto 

func (in *Trigger) DeepCopyInto(out *Trigger)

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

type UserWorker added in v0.3.1 

type UserWorker struct {
	Template v1.PodTemplateSpec `json:"template"`
}

UserWorker describes the data a user worker should have

func (*UserWorker) DeepCopy added in v0.4.0 

func (in *UserWorker) DeepCopy() *UserWorker

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

func (*UserWorker) DeepCopyInto added in v0.4.0 

func (in *UserWorker) DeepCopyInto(out *UserWorker)

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

type WSTransmitter added in v0.4.0 

type WSTransmitter struct{}

WSTransmitter describes the websocket transmitter

func (*WSTransmitter) DeepCopy added in v0.4.0 

func (in *WSTransmitter) DeepCopy() *WSTransmitter

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

func (*WSTransmitter) DeepCopyInto added in v0.4.0 

func (in *WSTransmitter) DeepCopyInto(out *WSTransmitter)

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.