v1alpha1

package
v0.0.0-...-67dfe03 Latest Latest
Warning

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

Go to latest
Published: Nov 24, 2023 License: Apache-2.0 Imports: 7 Imported by: 5

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 AIClasses

type AIClasses struct {
	NumberOfAIClasses int      `json:"numberOfAIClasses"`
	ListOfAIClasses   []string `json:"listOfAIClasses,omitempty"`
}

func (*AIClasses) DeepCopy

func (in *AIClasses) DeepCopy() *AIClasses

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

func (*AIClasses) DeepCopyInto

func (in *AIClasses) DeepCopyInto(out *AIClasses)

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

type AIModel

type AIModel struct {
	ModelID              string  `json:"modelID"`
	AveragePrecision     float32 `json:"averagePrecision"`
	NumberOfTrainSamples int     `json:"numberOfTrainSamples"`
}

func (*AIModel) DeepCopy

func (in *AIModel) DeepCopy() *AIModel

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

func (*AIModel) DeepCopyInto

func (in *AIModel) DeepCopyInto(out *AIModel)

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

type AIModels

type AIModels struct {
	NumberOfAIModels int       `json:"numberOfAIModels"`
	ListOfAIModels   []AIModel `json:"listOfAIModels,omitempty"`
}

func (*AIModels) DeepCopy

func (in *AIModels) DeepCopy() *AIModels

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

func (*AIModels) DeepCopyInto

func (in *AIModels) DeepCopyInto(out *AIModels)

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

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 DeepCopyEdgeWorkerSlice

func DeepCopyEdgeWorkerSlice(in []EdgeWorker) []EdgeWorker

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 {
	InitialModel *InitialEvalModel  `json:"initialEvalModel,omitempty"`
	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 FEModel

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

Describes the feature extraction model

func (*FEModel) DeepCopy

func (in *FEModel) DeepCopy() *FEModel

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

func (*FEModel) DeepCopyInto

func (in *FEModel) DeepCopyInto(out *FEModel)

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 (
	// FLJobCondComplete means the job has completed its execution.
	FLJobCondComplete FLJobConditionType = "Complete"
	// FLJobCondFailed 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 FeatureExtractionService

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

	metav1.ObjectMeta `json:"metadata"`

	Spec   FeatureExtractionServiceSpec   `json:"spec"`
	Status FeatureExtractionServiceStatus `json:"status,omitempty"`
}

func (*FeatureExtractionService) DeepCopy

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

func (*FeatureExtractionService) DeepCopyInto

func (in *FeatureExtractionService) DeepCopyInto(out *FeatureExtractionService)

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

func (*FeatureExtractionService) DeepCopyObject

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

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

type FeatureExtractionServiceCondition

type FeatureExtractionServiceCondition struct {
	// Type of service condition, Complete or Failed.
	Type FeatureExtractionServiceConditionType `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"`
}

FeatureExtractionServiceCondition 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 (*FeatureExtractionServiceCondition) DeepCopy

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

func (*FeatureExtractionServiceCondition) DeepCopyInto

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

type FeatureExtractionServiceConditionType

type FeatureExtractionServiceConditionType string

FeatureExtractionServiceConditionType defines the condition type

const (
	// FeatureExtractionServiceCondPending means the service has been accepted by the system,
	// but one or more of the workers has not been started.
	FeatureExtractionServiceCondPending FeatureExtractionServiceConditionType = "Pending"
	// FeatureExtractionServiceCondFailed means the service has failed its execution.
	FeatureExtractionServiceCondFailed FeatureExtractionServiceConditionType = "Failed"
	// FeatureExtractionServiceCondRunning means the service has been ready.
	FeatureExtractionServiceCondRunning FeatureExtractionServiceConditionType = "Running"
)

These are valid conditions of a service.

type FeatureExtractionServiceList

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

FeatureExtractionServiceList is a list of FeatureExtractionService.

func (*FeatureExtractionServiceList) DeepCopy

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

func (*FeatureExtractionServiceList) DeepCopyInto

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

func (*FeatureExtractionServiceList) DeepCopyObject

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

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

type FeatureExtractionServiceSpec

type FeatureExtractionServiceSpec struct {
	KafkaSupport          bool    `json:"kafkaSupport,omitempty"`
	Model                 FEModel `json:"model"`
	appsv1.DeploymentSpec `json:",inline"`
}

FeatureExtractionServiceSpec is a description of a FeatureExtractionService

func (*FeatureExtractionServiceSpec) DeepCopy

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

func (*FeatureExtractionServiceSpec) DeepCopyInto

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

type FeatureExtractionServiceStatus

type FeatureExtractionServiceStatus struct {

	// The latest available observations of a joint inference service's current state.
	// +optional
	Conditions []FeatureExtractionServiceCondition `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 feature extraction service.
	Metrics []Metric `json:"metrics,omitempty"`
}

FeatureExtractionServiceStatus represents the current state of a feature extraction service.

func (*FeatureExtractionServiceStatus) DeepCopy

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

func (*FeatureExtractionServiceStatus) DeepCopyInto

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

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

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

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

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

func (*IncrementalLearningJobList) DeepCopyInto

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 InitialEvalModel

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

func (*InitialEvalModel) DeepCopy

func (in *InitialEvalModel) DeepCopy() *InitialEvalModel

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

func (*InitialEvalModel) DeepCopyInto

func (in *InitialEvalModel) DeepCopyInto(out *InitialEvalModel)

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

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

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

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

func (*JointInferenceServiceCondition) DeepCopyInto

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"
	// JointInferenceServiceCondRunning means the service is running.
	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

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

func (*JointInferenceServiceList) DeepCopyInto

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

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

func (*JointInferenceServiceSpec) DeepCopyInto

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

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

func (*JointInferenceServiceStatus) DeepCopyInto

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

type JointMultiEdgeService

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

	metav1.ObjectMeta `json:"metadata"`

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

JointInferenceService describes the data that a jointinferenceservice resource should have

func (*JointMultiEdgeService) DeepCopy

func (*JointMultiEdgeService) DeepCopyInto

func (in *JointMultiEdgeService) DeepCopyInto(out *JointMultiEdgeService)

func (*JointMultiEdgeService) DeepCopyObject

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

type JointMultiEdgeServiceCondition

type JointMultiEdgeServiceCondition struct {
	// Type of service condition, Complete or Failed.
	Type JointMultiEdgeServiceConditionType `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 (*JointMultiEdgeServiceCondition) DeepCopy

func (*JointMultiEdgeServiceCondition) DeepCopyInto

type JointMultiEdgeServiceConditionType

type JointMultiEdgeServiceConditionType string

JointInferenceServiceConditionType defines the condition type type JointInferenceServiceConditionType string

const (
	// JointInferenceServiceCondPending means the service has been accepted by the system,
	// but one or more of the workers has not been started.
	JointMultiEdgeServiceCondPending JointMultiEdgeServiceConditionType = "Pending"
	// JointInferenceServiceCondFailed means the service has failed its execution.
	JointMultiEdgeServiceCondFailed JointMultiEdgeServiceConditionType = "Failed"
	// JointInferenceServiceCondRunning means the service is running.
	JointMultiEdgeServiceCondRunning JointMultiEdgeServiceConditionType = "Running"
)

These are valid conditions of a service.

type JointMultiEdgeServiceList

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

JointInferenceServiceList is a list of JointInferenceServices. type JointInferenceServiceList struct {

func (*JointMultiEdgeServiceList) DeepCopy

func (*JointMultiEdgeServiceList) DeepCopyInto

func (*JointMultiEdgeServiceList) DeepCopyObject

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

type JointMultiEdgeServiceSpec

type JointMultiEdgeServiceSpec struct {
	// modified: edgeworker -> array of edgeworkers
	EdgeWorker  []EdgeWorker `json:"edgeWorker"`
	CloudWorker CloudWorker  `json:"cloudWorker"`
}

JointMultiEdgeServiceSpec is a description of a jointinferenceservice

func (*JointMultiEdgeServiceSpec) DeepCopy

func (*JointMultiEdgeServiceSpec) DeepCopyInto

type JointMultiEdgeServiceStatus

type JointMultiEdgeServiceStatus struct {

	// The latest available observations of a joint inference service's current state.
	// +optional
	// Conditions []JointInferenceServiceCondition `json:"conditions,omitempty"`
	Conditions []JointMultiEdgeServiceCondition `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"`
}

JointMultiEdgeServiceStatus represents the current state of a joint inference service.

func (*JointMultiEdgeServiceStatus) DeepCopy

func (*JointMultiEdgeServiceStatus) DeepCopyInto

type KnowledgeBase

type KnowledgeBase struct {
	AIModels  AIModels  `json:"AIModels"`
	AIClasses AIClasses `json:"AIClasses"`
	Samples   Samples   `json:"samples"`
}

func (*KnowledgeBase) DeepCopy

func (in *KnowledgeBase) DeepCopy() *KnowledgeBase

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

func (*KnowledgeBase) DeepCopyInto

func (in *KnowledgeBase) DeepCopyInto(out *KnowledgeBase)

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

type LLCondition

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

func (*LLCondition) DeepCopy

func (in *LLCondition) DeepCopy() *LLCondition

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

func (*LLCondition) DeepCopyInto

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

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

func (*LLDataset) DeepCopy

func (in *LLDataset) DeepCopy() *LLDataset

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

func (*LLDataset) DeepCopyInto

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

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

LLDeploySpec describes the deploy model to be updated

func (*LLDeploySpec) DeepCopy

func (in *LLDeploySpec) DeepCopy() *LLDeploySpec

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

func (*LLDeploySpec) DeepCopyInto

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

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

LLEvalSpec describes the data an eval worker should have

func (*LLEvalSpec) DeepCopy

func (in *LLEvalSpec) DeepCopy() *LLEvalSpec

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

func (*LLEvalSpec) DeepCopyInto

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

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

func (in *LLJobCondition) DeepCopy() *LLJobCondition

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

func (*LLJobCondition) DeepCopyInto

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

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

func (in *LLJobSpec) DeepCopy() *LLJobSpec

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

func (*LLJobSpec) DeepCopyInto

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

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

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

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

	KnowledgeBase KnowledgeBase `json:"knowledgeBase,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

func (in *LLJobStatus) DeepCopy() *LLJobStatus

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

func (*LLJobStatus) DeepCopyInto

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

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

func (*LLTimer) DeepCopy

func (in *LLTimer) DeepCopy() *LLTimer

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

func (*LLTimer) DeepCopyInto

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

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

LLTrainSpec describes the data an train worker should have

func (*LLTrainSpec) DeepCopy

func (in *LLTrainSpec) DeepCopy() *LLTrainSpec

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

func (*LLTrainSpec) DeepCopyInto

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

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

func (*LLTrigger) DeepCopy

func (in *LLTrigger) DeepCopy() *LLTrigger

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

func (*LLTrigger) DeepCopyInto

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

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

func (*LifelongLearningJob) DeepCopy

func (in *LifelongLearningJob) DeepCopy() *LifelongLearningJob

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

func (*LifelongLearningJob) DeepCopyInto

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

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

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

type LifelongLearningJobList

type LifelongLearningJobList struct {
	metav1.TypeMeta  `json:",inline"`
	metav1.ListMeta  `json:"metadata"`
	Items            []LifelongLearningJob `json:"items"`
	OverallKBStatus  OverallStatus         `json:"overallStatus"`
	OverallKBDetails KnowledgeBase         `json:"overallKBStatus"`
}

LifelongLearningJobList is a list of LifelongLearningJobs.

func (*LifelongLearningJobList) DeepCopy

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

func (*LifelongLearningJobList) DeepCopyInto

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

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"`
	Devices []string `json:"device_soc_versions,omitempty"`

	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

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

func (in *ObjectSearchService) DeepCopy() *ObjectSearchService

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

func (*ObjectSearchService) DeepCopyInto

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

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

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

type ObjectSearchServiceCondition

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

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

func (*ObjectSearchServiceCondition) DeepCopyInto

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

type ObjectSearchServiceConditionType

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"
	// ObjectSearchServiceCondRunning means the service is running.
	ObjectSearchServiceCondRunning ObjectSearchServiceConditionType = "Running"
)

These are valid conditions of a service.

type ObjectSearchServiceList

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

ObjectSearchServiceList is a list of ObjectSearchServices.

func (*ObjectSearchServiceList) DeepCopy

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

func (*ObjectSearchServiceList) DeepCopyInto

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

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

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

type ObjectSearchServiceSpec

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

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

func (*ObjectSearchServiceSpec) DeepCopyInto

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

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

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

func (*ObjectSearchServiceStatus) DeepCopyInto

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

type ObjectTrackingService

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

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

func (*ObjectTrackingService) DeepCopyInto

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

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

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

type ObjectTrackingServiceCondition

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

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

func (*ObjectTrackingServiceCondition) DeepCopyInto

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

type ObjectTrackingServiceConditionType

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"
	// ObjectTrackingServiceCondRunning means the service is running.
	ObjectTrackingServiceCondRunning ObjectTrackingServiceConditionType = "Running"
)

These are valid conditions of a service.

type ObjectTrackingServiceList

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

ObjectTrackingServiceList is a list of ObjectTrackingServices.

func (*ObjectTrackingServiceList) DeepCopy

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

func (*ObjectTrackingServiceList) DeepCopyInto

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

func (*ObjectTrackingServiceList) DeepCopyObject

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

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

type ObjectTrackingServiceSpec

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

ObjectTrackingServiceSpec is a description of a objecttrackingservice

func (*ObjectTrackingServiceSpec) DeepCopy

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

func (*ObjectTrackingServiceSpec) DeepCopyInto

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

type ObjectTrackingServiceStatus

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

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

func (*ObjectTrackingServiceStatus) DeepCopyInto

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

type OverallStatus

type OverallStatus struct {
	NumberOfUnseenSample    int     `json:"numberOfUnseenSample"`
	NumberOfNewUnseenSample int     `json:"numberOfNewUnseenSample"`
	NumberOfAIModels        int     `json:"numberOfAIModels"`
	PercentOfNewAIModels    float32 `json:"percentOfNewAIModels"`
	NumberOfClasses         int     `json:"numberOfClasses"`
	PercentOfNewClasses     float32 `json:"percentOfNewClasses"`
}

func (*OverallStatus) DeepCopy

func (in *OverallStatus) DeepCopy() *OverallStatus

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

func (*OverallStatus) DeepCopyInto

func (in *OverallStatus) DeepCopyInto(out *OverallStatus)

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

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

PretrainedModel defines pretrained model of federated learning job

func (*PretrainedModel) DeepCopy

func (in *PretrainedModel) DeepCopy() *PretrainedModel

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

func (*PretrainedModel) DeepCopyInto

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

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

type ReidJob

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

	metav1.ObjectMeta `json:"metadata"`

	Spec   ReidJobSpec   `json:"spec"`
	Status ReidJobStatus `json:"status,omitempty"`
}

func (*ReidJob) DeepCopy

func (in *ReidJob) DeepCopy() *ReidJob

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

func (*ReidJob) DeepCopyInto

func (in *ReidJob) DeepCopyInto(out *ReidJob)

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

func (*ReidJob) DeepCopyObject

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

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

type ReidJobCondition

type ReidJobCondition struct {
	// Type of job condition, Complete or Failed.
	Type ReidJobConditionType `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.
	// +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"`
}

ReidJobCondition 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 (*ReidJobCondition) DeepCopy

func (in *ReidJobCondition) DeepCopy() *ReidJobCondition

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

func (*ReidJobCondition) DeepCopyInto

func (in *ReidJobCondition) DeepCopyInto(out *ReidJobCondition)

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

type ReidJobConditionType

type ReidJobConditionType string
const (
	ReidJobCondWaiting   ReidJobConditionType = "Waiting"
	ReidJobCondReady     ReidJobConditionType = "Ready"
	ReidJobCondStarting  ReidJobConditionType = "Starting"
	ReidJobCondRunning   ReidJobConditionType = "Running"
	ReidJobCondCompleted ReidJobConditionType = "Completed"
	ReidJobCondFailed    ReidJobConditionType = "Failed"
)

These are valid stage conditions of a job.

type ReidJobList

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

ReidJobList is a list of ReidJob.

func (*ReidJobList) DeepCopy

func (in *ReidJobList) DeepCopy() *ReidJobList

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

func (*ReidJobList) DeepCopyInto

func (in *ReidJobList) DeepCopyInto(out *ReidJobList)

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

func (*ReidJobList) DeepCopyObject

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

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

type ReidJobPhase

type ReidJobPhase string

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

const (
	// ReidJobPending 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.
	ReidJobPending ReidJobPhase = "Pending"
	// ReidJobRunning 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.
	ReidJobRunning ReidJobPhase = "Running"
	// ReidJobSucceeded 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.
	ReidJobSucceeded ReidJobPhase = "Succeeded"
	// ReidJobFailed 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).
	ReidJobFailed ReidJobPhase = "Failed"
)

These are the valid statuses of jobs.

type ReidJobSpec

type ReidJobSpec struct {
	batchv1.JobSpec `json:",inline"`
	KafkaSupport    bool `json:"kafkaSupport,omitempty"`
}

ReidJobSpec is a description of a ReidJob

func (*ReidJobSpec) DeepCopy

func (in *ReidJobSpec) DeepCopy() *ReidJobSpec

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

func (*ReidJobSpec) DeepCopyInto

func (in *ReidJobSpec) DeepCopyInto(out *ReidJobSpec)

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

type ReidJobStatus

type ReidJobStatus struct {
	// The latest available observations of a reid job's current state.
	// +optional
	Conditions []ReidJobCondition `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 reid job.
	// +optional
	Phase ReidJobPhase `json:"phase,omitempty"`
}

ReidJobStatus represents the current state of a reid job

func (*ReidJobStatus) DeepCopy

func (in *ReidJobStatus) DeepCopy() *ReidJobStatus

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

func (*ReidJobStatus) DeepCopyInto

func (in *ReidJobStatus) DeepCopyInto(out *ReidJobStatus)

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

type ReidWorkers

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

ReidWorkers describes the data reid workers should have

func (*ReidWorkers) DeepCopy

func (in *ReidWorkers) DeepCopy() *ReidWorkers

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

func (*ReidWorkers) DeepCopyInto

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

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

S3Transmitter describes the s3 transmitter

func (*S3Transmitter) DeepCopy

func (in *S3Transmitter) DeepCopy() *S3Transmitter

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

func (*S3Transmitter) DeepCopyInto

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

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

type Samples

type Samples struct {
	NumberOfLabeledUnseenSample int `json:"numberOfLabeledUnseenSample"`
	NumberOfUnseenSample        int `json:"numberOfUnseenSample"`
}

func (*Samples) DeepCopy

func (in *Samples) DeepCopy() *Samples

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

func (*Samples) DeepCopyInto

func (in *Samples) DeepCopyInto(out *Samples)

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

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

TrackingWorker describes the data a tracking worker should have

func (*TrackingWorker) DeepCopy

func (in *TrackingWorker) DeepCopy() *TrackingWorker

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

func (*TrackingWorker) DeepCopyInto

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

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

TrainDataset defines dataset of federated learning job

func (*TrainDataset) DeepCopy

func (in *TrainDataset) DeepCopy() *TrainDataset

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

func (*TrainDataset) DeepCopyInto

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

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

func (*TrainModel) DeepCopy

func (in *TrainModel) DeepCopy() *TrainModel

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

func (*TrainModel) DeepCopyInto

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

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

func (in *Transmitter) DeepCopy() *Transmitter

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

func (*Transmitter) DeepCopyInto

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

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

UserWorker describes the data a user worker should have

func (*UserWorker) DeepCopy

func (in *UserWorker) DeepCopy() *UserWorker

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

func (*UserWorker) DeepCopyInto

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

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

type VideoAnalyticsJob

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

	metav1.ObjectMeta `json:"metadata"`

	Spec   VideoAnalyticsJobSpec   `json:"spec"`
	Status VideoAnalyticsJobStatus `json:"status,omitempty"`
}

func (*VideoAnalyticsJob) DeepCopy

func (in *VideoAnalyticsJob) DeepCopy() *VideoAnalyticsJob

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

func (*VideoAnalyticsJob) DeepCopyInto

func (in *VideoAnalyticsJob) DeepCopyInto(out *VideoAnalyticsJob)

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

func (*VideoAnalyticsJob) DeepCopyObject

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

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

type VideoAnalyticsJobCondition

type VideoAnalyticsJobCondition struct {
	// Type of job condition, Complete or Failed.
	Type VideoAnalyticsJobConditionType `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.
	// +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"`
}

VideoAnalyticsJobCondition 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 (*VideoAnalyticsJobCondition) DeepCopy

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

func (*VideoAnalyticsJobCondition) DeepCopyInto

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

type VideoAnalyticsJobConditionType

type VideoAnalyticsJobConditionType string
const (
	VideoAnalyticsJobCondWaiting   VideoAnalyticsJobConditionType = "Waiting"
	VideoAnalyticsJobCondReady     VideoAnalyticsJobConditionType = "Ready"
	VideoAnalyticsJobCondStarting  VideoAnalyticsJobConditionType = "Starting"
	VideoAnalyticsJobCondRunning   VideoAnalyticsJobConditionType = "Running"
	VideoAnalyticsJobCondCompleted VideoAnalyticsJobConditionType = "Completed"
	VideoAnalyticsJobCondFailed    VideoAnalyticsJobConditionType = "Failed"
)

These are valid stage conditions of a job.

type VideoAnalyticsJobList

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

VideoAnalyticsJobList is a list of VideoAnalyticsJob.

func (*VideoAnalyticsJobList) DeepCopy

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

func (*VideoAnalyticsJobList) DeepCopyInto

func (in *VideoAnalyticsJobList) DeepCopyInto(out *VideoAnalyticsJobList)

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

func (*VideoAnalyticsJobList) DeepCopyObject

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

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

type VideoAnalyticsJobPhase

type VideoAnalyticsJobPhase string

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

const (
	// VideoAnalyticsJobPending 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.
	VideoAnalyticsJobPending VideoAnalyticsJobPhase = "Pending"
	// VideoAnalyticsJobRunning 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.
	VideoAnalyticsJobRunning VideoAnalyticsJobPhase = "Running"
	// VideoAnalyticsJobSucceeded 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.
	VideoAnalyticsJobSucceeded VideoAnalyticsJobPhase = "Succeeded"
	// VideoAnalyticsJobFailed 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).
	VideoAnalyticsJobFailed VideoAnalyticsJobPhase = "Failed"
)

These are the valid statuses of jobs.

type VideoAnalyticsJobSpec

type VideoAnalyticsJobSpec struct {
	batchv1.JobSpec `json:",inline"`
	KafkaSupport    bool                `json:"kafkaSupport,omitempty"`
	Model           VideoAnalyticsModel `json:"model"`
}

VideoAnalyticsJobSpec is a description of a VideoAnalyticsJob

func (*VideoAnalyticsJobSpec) DeepCopy

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

func (*VideoAnalyticsJobSpec) DeepCopyInto

func (in *VideoAnalyticsJobSpec) DeepCopyInto(out *VideoAnalyticsJobSpec)

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

type VideoAnalyticsJobStatus

type VideoAnalyticsJobStatus struct {
	// The latest available observations of a videoanalytics job's current state.
	// +optional
	Conditions []VideoAnalyticsJobCondition `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 videoanalytics job.
	// +optional
	Phase VideoAnalyticsJobPhase `json:"phase,omitempty"`
}

VideoAnalyticsJobStatus represents the current state of a videoanalytics job

func (*VideoAnalyticsJobStatus) DeepCopy

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

func (*VideoAnalyticsJobStatus) DeepCopyInto

func (in *VideoAnalyticsJobStatus) DeepCopyInto(out *VideoAnalyticsJobStatus)

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

type VideoAnalyticsModel

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

VideoAnalyticsModel describes the detection model

func (*VideoAnalyticsModel) DeepCopy

func (in *VideoAnalyticsModel) DeepCopy() *VideoAnalyticsModel

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

func (*VideoAnalyticsModel) DeepCopyInto

func (in *VideoAnalyticsModel) DeepCopyInto(out *VideoAnalyticsModel)

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

type WSTransmitter

type WSTransmitter struct{}

WSTransmitter describes the websocket transmitter

func (*WSTransmitter) DeepCopy

func (in *WSTransmitter) DeepCopy() *WSTransmitter

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

func (*WSTransmitter) DeepCopyInto

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL