v1alpha1

package
v0.0.0-...-6005cdf Latest Latest
Warning

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

 Go to latest Published: Jan 28, 2021 License: Apache-2.0 Imports: 5 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: neptune.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      modelRefer            `json:"model"`
	NodeName   string                `json:"nodeName"`
	WorkerSpec AggregationWorkerSpec `json:"workerSpec"`
}

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 AggregationWorkerSpec 

type AggregationWorkerSpec struct {
	CommonWorkerSpec
}

AggregationWorkerSpec is a description of a aggregationworker

func (*AggregationWorkerSpec) DeepCopy 

func (in *AggregationWorkerSpec) DeepCopy() *AggregationWorkerSpec

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

func (*AggregationWorkerSpec) DeepCopyInto 

func (in *AggregationWorkerSpec) DeepCopyInto(out *AggregationWorkerSpec)

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"`
	NodeName   string           `json:"nodeName"`
	WorkerSpec CommonWorkerSpec `json:"workerSpec"`
}

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 CommonWorkerSpec 

type CommonWorkerSpec struct {
	ScriptDir        string     `json:"scriptDir"`
	ScriptBootFile   string     `json:"scriptBootFile"`
	FrameworkType    string     `json:"frameworkType"`
	FrameworkVersion string     `json:"frameworkVersion"`
	Parameters       []ParaSpec `json:"parameters"`
}

CommonWorkerSpec is a description of a worker both for edge and cloud

func (*CommonWorkerSpec) DeepCopy 

func (in *CommonWorkerSpec) DeepCopy() *CommonWorkerSpec

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

func (*CommonWorkerSpec) DeepCopyInto 

func (in *CommonWorkerSpec) DeepCopyInto(out *CommonWorkerSpec)

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"`
}

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"`
}

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"`
}

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"`
	NodeName          string            `json:"nodeName"`
	WorkerSpec        CommonWorkerSpec  `json:"workerSpec"`
	HardExampleMining HardExampleMining `json:"hardExampleMining"`
}

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"`
	NodeName          string            `json:"nodeName"`
	HardExampleMining HardExampleMining `json:"hardExampleMining"`
	WorkerSpec        CommonWorkerSpec  `json:"workerSpec"`
}

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 {
	WorkerSpec CommonWorkerSpec `json:"workerSpec"`
}

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"`
}

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"`
}

+genclient +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object 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"`
}

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"`
	OutputDir    string       `json:"outputDir"`
	NodeName     string       `json:"nodeName"`
	InitialModel InitialModel `json:"initialModel"`
	TrainSpec    TrainSpec    `json:"trainSpec"`
	EvalSpec     EvalSpec     `json:"evalSpec"`
	DeploySpec   DeploySpec   `json:"deploySpec"`
}

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"`
}

+genclient +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object 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 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"`
}

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"`
}

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 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 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 TrainSpec 

type TrainSpec struct {
	WorkerSpec CommonWorkerSpec `json:"workerSpec"`
	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 {
	NodeName   string             `json:"nodeName"`
	WorkerSpec TrainingWorkerSpec `json:"workerSpec"`
	Dataset    datasetRefer       `json:"dataset"`
}

TrrainingWorker 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 TrainingWorkerSpec 

type TrainingWorkerSpec struct {
	CommonWorkerSpec
}

TrainingWorkerSpec is a description of a trainingworker

func (*TrainingWorkerSpec) DeepCopy 

func (in *TrainingWorkerSpec) DeepCopy() *TrainingWorkerSpec

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

func (*TrainingWorkerSpec) DeepCopyInto 

func (in *TrainingWorkerSpec) DeepCopyInto(out *TrainingWorkerSpec)

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.

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.