Add MultiEdgeInference CRD Definition.

Signed-off-by: Jie Pu <pujie2@huawei.com>
Signed-off-by: Vittorio Cozzolino <vittorio.cozzolino@huawei.com>

pkg/apis/sedna/v1alpha1/featureextractionservice_types.go

@@ -0,0 +1,119 @@
+/*
+Copyright 2021 The KubeEdge Authors.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package v1alpha1
+
+import (
+	appsv1 "k8s.io/api/apps/v1"
+	v1 "k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+// +genclient
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+// +kubebuilder:resource:shortName=fe
+// +kubebuilder:subresource:status
+
+type FeatureExtractionService struct {
+	metav1.TypeMeta `json:",inline"`
+
+	metav1.ObjectMeta `json:"metadata"`
+
+	Spec   FeatureExtractionServiceSpec   `json:"spec"`
+	Status FeatureExtractionServiceStatus `json:"status,omitempty"`
+}
+
+// FeatureExtractionServiceSpec is a description of a FeatureExtractionService
+type FeatureExtractionServiceSpec struct {
+	KafkaSupport          bool    `json:"kafkaSupport,omitempty"`
+	Model                 FEModel `json:"model"`
+	appsv1.DeploymentSpec `json:",inline"`
+}
+
+// Describes the feature extraction model
+type FEModel struct {
+	Name string `json:"name"`
+}
+
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+
+// FeatureExtractionServiceList is a list of FeatureExtractionService.
+type FeatureExtractionServiceList struct {
+	metav1.TypeMeta `json:",inline"`
+	metav1.ListMeta `json:"metadata"`
+	Items           []FeatureExtractionService `json:"items"`
+}
+
+// FeatureExtractionServiceStatus represents the current state of a feature extraction service.
+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"`
+}
+
+// FeatureExtractionServiceConditionType defines the condition type
+type FeatureExtractionServiceConditionType string
+
+// These are valid conditions of a service.
+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"
+)
+
+// 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.
+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"`
+}

pkg/apis/sedna/v1alpha1/reidjob_types.go

@@ -0,0 +1,143 @@
+/*
+Copyright 2021 The KubeEdge Authors.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package v1alpha1
+
+import (
+	batchv1 "k8s.io/api/batch/v1"
+	v1 "k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+// +genclient
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+// +kubebuilder:resource:shortName=reid
+// +kubebuilder:subresource:status
+
+type ReidJob struct {
+	metav1.TypeMeta `json:",inline"`
+
+	metav1.ObjectMeta `json:"metadata"`
+
+	Spec   ReidJobSpec   `json:"spec"`
+	Status ReidJobStatus `json:"status,omitempty"`
+}
+
+// ReidJobSpec is a description of a ReidJob
+type ReidJobSpec struct {
+	batchv1.JobSpec `json:",inline"`
+	KafkaSupport    bool `json:"kafkaSupport,omitempty"`
+}
+
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+
+// ReidJobList is a list of ReidJob.
+type ReidJobList struct {
+	metav1.TypeMeta `json:",inline"`
+	metav1.ListMeta `json:"metadata"`
+	Items           []ReidJob `json:"items"`
+}
+
+// ReidJobStatus represents the current state of a reid job
+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"`
+}
+
+type ReidJobConditionType string
+
+// These are valid stage conditions of a job.
+const (
+	ReidJobCondWaiting   ReidJobConditionType = "Waiting"
+	ReidJobCondReady     ReidJobConditionType = "Ready"
+	ReidJobCondStarting  ReidJobConditionType = "Starting"
+	ReidJobCondRunning   ReidJobConditionType = "Running"
+	ReidJobCondCompleted ReidJobConditionType = "Completed"
+	ReidJobCondFailed    ReidJobConditionType = "Failed"
+)
+
+// 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.
+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"`
+}
+
+// ReidJobPhase is a label for the condition of a job at the current time.
+type ReidJobPhase string
+
+// These are the valid statuses of jobs.
+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"
+)

pkg/apis/sedna/v1alpha1/videoanalyticsjob_types.go

@@ -0,0 +1,149 @@
+/*
+Copyright 2021 The KubeEdge Authors.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package v1alpha1
+
+import (
+	batchv1 "k8s.io/api/batch/v1"
+	v1 "k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+// +genclient
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+// +kubebuilder:resource:shortName=va
+// +kubebuilder:subresource:status
+
+type VideoAnalyticsJob struct {
+	metav1.TypeMeta `json:",inline"`
+
+	metav1.ObjectMeta `json:"metadata"`
+
+	Spec   VideoAnalyticsJobSpec   `json:"spec"`
+	Status VideoAnalyticsJobStatus `json:"status,omitempty"`
+}
+
+// VideoAnalyticsJobSpec is a description of a VideoAnalyticsJob
+type VideoAnalyticsJobSpec struct {
+	batchv1.JobSpec `json:",inline"`
+	KafkaSupport    bool                `json:"kafkaSupport,omitempty"`
+	Model           VideoAnalyticsModel `json:"model"`
+}
+
+// VideoAnalyticsModel describes the detection model
+type VideoAnalyticsModel struct {
+	Name string `json:"name"`
+}
+
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+
+// VideoAnalyticsJobList is a list of VideoAnalyticsJob.
+type VideoAnalyticsJobList struct {
+	metav1.TypeMeta `json:",inline"`
+	metav1.ListMeta `json:"metadata"`
+	Items           []VideoAnalyticsJob `json:"items"`
+}
+
+// VideoAnalyticsJobStatus represents the current state of a videoanalytics job
+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"`
+}
+
+type VideoAnalyticsJobConditionType string
+
+// These are valid stage conditions of a job.
+const (
+	VideoAnalyticsJobCondWaiting   VideoAnalyticsJobConditionType = "Waiting"
+	VideoAnalyticsJobCondReady     VideoAnalyticsJobConditionType = "Ready"
+	VideoAnalyticsJobCondStarting  VideoAnalyticsJobConditionType = "Starting"
+	VideoAnalyticsJobCondRunning   VideoAnalyticsJobConditionType = "Running"
+	VideoAnalyticsJobCondCompleted VideoAnalyticsJobConditionType = "Completed"
+	VideoAnalyticsJobCondFailed    VideoAnalyticsJobConditionType = "Failed"
+)
+
+// 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.
+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"`
+}
+
+// VideoAnalyticsJobPhase is a label for the condition of a job at the current time.
+type VideoAnalyticsJobPhase string
+
+// These are the valid statuses of jobs.
+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"
+)