v1alpha1

package
v0.0.0-...-a1208dc Latest Latest
Warning

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

 Go to latest Published: Dec 30, 2024 License: Apache-2.0 Imports: 5 Imported by: 1

Documentation

Overview

Package v1alpha1 is the v1alpha1 version of the API. +k8s:deepcopy-gen=package +groupName=kuscia.secretflow

Index

Constants

View Source 
const (
	DomainDataTableType  = "table"
	DomainDataModelType  = "model"
	DomainDataRuleType   = "rule"
	DomainDataReportType = "report"
)
View Source 
const (
	// TokenGenMethodRSA means tokens are generated by negotiation like TLS handshake protocol.
	TokenGenMethodRSA = "RSA-GEN"
	// TokenGenUIDRSA means tokens are generated by destination uid rsa.
	TokenGenUIDRSA = "UID-RSA-GEN"
)
View Source 
const GroupName = "kuscia.secretflow"

GroupName is the group name use in this package

View Source 
const (
	RetryReserveResourceReason = "Last reserved resources and need retry since partners doesn't reserve resources"
)
View Source 
const TaskResourceKey = GroupName + "/task-resource"
View Source 
const TaskResourceUID = GroupName + "/task-resource-uid"

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: 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 AppImage 

type AppImage struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              AppImageSpec `json:"spec"`
}

AppImage is the Schema for the app image API.

func (*AppImage) DeepCopy 

func (in *AppImage) DeepCopy() *AppImage

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

func (*AppImage) DeepCopyInto 

func (in *AppImage) DeepCopyInto(out *AppImage)

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

func (*AppImage) DeepCopyObject 

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

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

type AppImageInfo 

type AppImageInfo struct {
	Name string `json:"name"`
	Tag  string `json:"tag"`
	// ID of the image. e.g. sha256:f1c20d8cb5c4c69d3997527e4912e794ba3cd7fa26bfaf6afa1383697c80ea9a
	// If the ID is not empty, domain will verify whether the local image ID matches this value before starting a container.
	// +optional
	ID string `json:"id,omitempty"`
	// +optional
	Sign string `json:"sign,omitempty"`
}

AppImageInfo defines the basic app image info.

func (*AppImageInfo) DeepCopy 

func (in *AppImageInfo) DeepCopy() *AppImageInfo

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

func (*AppImageInfo) DeepCopyInto 

func (in *AppImageInfo) DeepCopyInto(out *AppImageInfo)

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

type AppImageList 

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

AppImageList contains a list of app images.

func (*AppImageList) DeepCopy 

func (in *AppImageList) DeepCopy() *AppImageList

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

func (*AppImageList) DeepCopyInto 

func (in *AppImageList) DeepCopyInto(out *AppImageList)

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

func (*AppImageList) DeepCopyObject 

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

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

type AppImageSpec 

type AppImageSpec struct {
	Image AppImageInfo `json:"image"`
	// +optional
	ConfigTemplates map[string]string `json:"configTemplates,omitempty"`
	DeployTemplates []DeployTemplate  `json:"deployTemplates"`
}

AppImageSpec defines the details of app image.

func (*AppImageSpec) DeepCopy 

func (in *AppImageSpec) DeepCopy() *AppImageSpec

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

func (*AppImageSpec) DeepCopyInto 

func (in *AppImageSpec) DeepCopyInto(out *AppImageSpec)

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

type AuthCenter 

type AuthCenter struct {
	// AuthenticationType describes how master authenticates the source's domain nodes request.
	// +kubebuilder:validation:Enum=Token;MTLS;None
	AuthenticationType DomainAuthenticationType `json:"authenticationType"`
	// Token generation method.
	// +kubebuilder:validation:Enum=RSA-GEN;RAND-GEN;UID-RSA-GEN
	// +optional
	TokenGenMethod TokenGenMethodType `json:"tokenGenMethod"`
}

func (*AuthCenter) DeepCopy 

func (in *AuthCenter) DeepCopy() *AuthCenter

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

func (*AuthCenter) DeepCopyInto 

func (in *AuthCenter) DeepCopyInto(out *AuthCenter)

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

type BandwidthLimit 

type BandwidthLimit struct {
	// +required
	DestinationID string `json:"destinationID"`
	// +required
	LimitKBps uint64 `json:"limitKBps"`
}

The upstream bandwidth limit of the party to given party by KiB/s.

func (*BandwidthLimit) DeepCopy 

func (in *BandwidthLimit) DeepCopy() *BandwidthLimit

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

func (*BandwidthLimit) DeepCopyInto 

func (in *BandwidthLimit) DeepCopyInto(out *BandwidthLimit)

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

type BodyEncryption 

type BodyEncryption struct {
	// +kubebuilder:validation:Enum=AES;SM4
	Algorithm BodyEncryptionAlgorithmType `json:"algorithm"`
}

BodyEncryption defines detailed parameters for body encryption.

func (*BodyEncryption) DeepCopy 

func (in *BodyEncryption) DeepCopy() *BodyEncryption

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

func (*BodyEncryption) DeepCopyInto 

func (in *BodyEncryption) DeepCopyInto(out *BodyEncryption)

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

type BodyEncryptionAlgorithmType 

type BodyEncryptionAlgorithmType string
const (
	BodyEncryptionAlgorithmAES BodyEncryptionAlgorithmType = "AES"
	BodyEncryptionAlgorithmSM4 BodyEncryptionAlgorithmType = "SM4"
)

type ClusterDomainRoute 

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

	// +optional
	Spec ClusterDomainRouteSpec `json:"spec,omitempty"`

	// +optional
	Status ClusterDomainRouteStatus `json:"status,omitempty"`
}

ClusterDomainRoute defines the routing rules between domains on the center side.

func (*ClusterDomainRoute) DeepCopy 

func (in *ClusterDomainRoute) DeepCopy() *ClusterDomainRoute

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

func (*ClusterDomainRoute) DeepCopyInto 

func (in *ClusterDomainRoute) DeepCopyInto(out *ClusterDomainRoute)

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

func (*ClusterDomainRoute) DeepCopyObject 

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

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

type ClusterDomainRouteCondition 

type ClusterDomainRouteCondition struct {
	// Type of ClusterDomainRoute condition.
	Type ClusterDomainRouteConditionType `json:"type"`
	// Status of the condition, one of True, False, Unknown.
	Status corev1.ConditionStatus `json:"status"`
	// The last time this condition was updated.
	// +optional
	LastUpdateTime metav1.Time `json:"lastUpdateTime,omitempty"`
	// +optional
	// Last time the condition transitioned from one status to another.
	LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"`
	// The reason for the condition's last transition.
	// +optional
	Reason string `json:"reason,omitempty"`
	// A human-readable message indicating details about the transition.
	// +optional
	Message string `json:"message,omitempty"`
}

ClusterDomainRouteCondition describes the state of a ClusterDomainRoute at a certain point.

func (*ClusterDomainRouteCondition) DeepCopy 

func (in *ClusterDomainRouteCondition) DeepCopy() *ClusterDomainRouteCondition

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

func (*ClusterDomainRouteCondition) DeepCopyInto 

func (in *ClusterDomainRouteCondition) DeepCopyInto(out *ClusterDomainRouteCondition)

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

type ClusterDomainRouteConditionType 

type ClusterDomainRouteConditionType string

ClusterDomainRouteConditionType defines condition types for ClusterDomainRoute. 

const (
	// ClusterDomainRouteRunning means source and destination gateway are negotiating next token, RSA-GEN only.
	ClusterDomainRouteRunning ClusterDomainRouteConditionType = "Running"
	// ClusterDomainRoutePending means token has generated and waiting for next rolling update.
	ClusterDomainRoutePending ClusterDomainRouteConditionType = "Pending"
	// ClusterDomainRouteFailure means for some reason token can't be generated, typically due to network error
	// that no gateway available in source or destination namespace.
	ClusterDomainRouteFailure ClusterDomainRouteConditionType = "Failure"
	// ClusterDomainRouteReady means at least one token has been generated.
	ClusterDomainRouteReady ClusterDomainRouteConditionType = "Ready"
)

These are valid conditions of a ClusterDomainRoute.

type ClusterDomainRouteEndpointStatus 

type ClusterDomainRouteEndpointStatus struct {
	// Whether the connection state from the gateway instance of the source node to the endpoint is healthy.
	EndpointHealthy bool `json:"endpointHealthy"`
}

ClusterDomainRouteEndpointStatus describes the health status of the endpoint.

func (*ClusterDomainRouteEndpointStatus) DeepCopy 

func (in *ClusterDomainRouteEndpointStatus) DeepCopy() *ClusterDomainRouteEndpointStatus

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

func (*ClusterDomainRouteEndpointStatus) DeepCopyInto 

func (in *ClusterDomainRouteEndpointStatus) DeepCopyInto(out *ClusterDomainRouteEndpointStatus)

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

type ClusterDomainRouteList 

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

ClusterDomainRouteList is a list of ClusterDomainRoutes.

func (*ClusterDomainRouteList) DeepCopy 

func (in *ClusterDomainRouteList) DeepCopy() *ClusterDomainRouteList

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

func (*ClusterDomainRouteList) DeepCopyInto 

func (in *ClusterDomainRouteList) DeepCopyInto(out *ClusterDomainRouteList)

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

func (*ClusterDomainRouteList) DeepCopyObject 

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

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

type ClusterDomainRouteSpec 

type ClusterDomainRouteSpec struct {
	DomainRouteSpec `json:",inline"`
}

ClusterDomainRouteSpec is a description of ClusterDomainRoute.

func (*ClusterDomainRouteSpec) DeepCopy 

func (in *ClusterDomainRouteSpec) DeepCopy() *ClusterDomainRouteSpec

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

func (*ClusterDomainRouteSpec) DeepCopyInto 

func (in *ClusterDomainRouteSpec) DeepCopyInto(out *ClusterDomainRouteSpec)

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

type ClusterDomainRouteStatus 

type ClusterDomainRouteStatus struct {
	// +optional
	TokenStatus ClusterDomainRouteTokenStatus `json:"tokenStatus"`
	// Conditions is an array of current observed ClusterDomainRoute conditions.
	// +optional
	Conditions []ClusterDomainRouteCondition `json:"conditions,omitempty"`
	// EndpointStatuses shows the health status from all gateway instance of the source domain to the endpoint.
	// +optional
	EndpointStatuses map[string]ClusterDomainRouteEndpointStatus `json:"endpointStatuses,omitempty"`
}

ClusterDomainRouteStatus defines the observed state of ClusterDomainRoute

func (*ClusterDomainRouteStatus) DeepCopy 

func (in *ClusterDomainRouteStatus) DeepCopy() *ClusterDomainRouteStatus

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

func (*ClusterDomainRouteStatus) DeepCopyInto 

func (in *ClusterDomainRouteStatus) DeepCopyInto(out *ClusterDomainRouteStatus)

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

type ClusterDomainRouteTokenStatus 

type ClusterDomainRouteTokenStatus struct {
	// A sequence number representing a specific generation.
	// +optional
	Revision int64 `json:"revision,omitempty"`
	// Timestamp representing the time when this revision created.
	// +optional
	RevisionTime metav1.Time `json:"revisionTime,omitempty"`
	// SourceTokens keeps the most recently two generated tokens.
	// +optional
	SourceTokens []DomainRouteToken `json:"sourceTokens,omitempty"`
	// DestinationTokens keeps the most recently two generated tokens.
	// +optional
	DestinationTokens []DomainRouteToken `json:"destinationTokens,omitempty"`
}

ClusterDomainRouteTokenStatus represents the status information related to token authentication.

func (*ClusterDomainRouteTokenStatus) DeepCopy 

func (in *ClusterDomainRouteTokenStatus) DeepCopy() *ClusterDomainRouteTokenStatus

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

func (*ClusterDomainRouteTokenStatus) DeepCopyInto 

func (in *ClusterDomainRouteTokenStatus) DeepCopyInto(out *ClusterDomainRouteTokenStatus)

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

type ConfigVolumeMount 

type ConfigVolumeMount struct {
	MountPath string `json:"mountPath"`
	SubPath   string `json:"subPath"`
}

ConfigVolumeMount defines config volume mount info.

func (*ConfigVolumeMount) DeepCopy 

func (in *ConfigVolumeMount) DeepCopy() *ConfigVolumeMount

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

func (*ConfigVolumeMount) DeepCopyInto 

func (in *ConfigVolumeMount) DeepCopyInto(out *ConfigVolumeMount)

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

type Container 

type Container struct {
	Name string `json:"name"`
	// +optional
	Command []string `json:"command,omitempty"`
	// +optional
	Args       []string `json:"args,omitempty"`
	WorkingDir string   `json:"workingDir"`
	// +optional
	ConfigVolumeMounts []ConfigVolumeMount `json:"configVolumeMounts,omitempty"`
	// +optional
	Ports []ContainerPort `json:"ports"`
	// +optional
	EnvFrom []corev1.EnvFromSource `json:"envFrom,omitempty"`
	// +optional
	Env []corev1.EnvVar `json:"env,omitempty"`
	// +optional
	Resources corev1.ResourceRequirements `json:"resources,omitempty"`
	// +optional
	LivenessProbe *corev1.Probe `json:"livenessProbe,omitempty"`
	// +optional
	ReadinessProbe *corev1.Probe `json:"readinessProbe,omitempty"`
	// +optional
	StartupProbe *corev1.Probe `json:"startupProbe,omitempty"`
	// +optional
	MetricProbe *MetricProbe `json:"metricProbe,omitempty"`
	// +optional
	ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy,omitempty"`
	// SecurityContext only privileged works now.
	// +optional
	SecurityContext *corev1.SecurityContext `json:"securityContext,omitempty"`
}

Container defines the container info.

func (*Container) DeepCopy 

func (in *Container) DeepCopy() *Container

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

func (*Container) DeepCopyInto 

func (in *Container) DeepCopyInto(out *Container)

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

type ContainerPort 

type ContainerPort struct {
	Name string `json:"name"`
	// +optional
	Port int32 `json:"port,omitempty"`
	// +kubebuilder:validation:Enum=HTTP;GRPC
	// +kubebuilder:default:=HTTP
	// +optional
	Protocol PortProtocol `json:"protocol,omitempty"`
	// +kubebuilder:validation:Enum=Cluster;Domain;Local
	// +kubebuilder:default:=Local
	// +optional
	Scope PortScope `json:"scope,omitempty"`
}

ContainerPort describes container port info.

func (*ContainerPort) DeepCopy 

func (in *ContainerPort) DeepCopy() *ContainerPort

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

func (*ContainerPort) DeepCopyInto 

func (in *ContainerPort) DeepCopyInto(out *ContainerPort)

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

type DataColumn 

type DataColumn struct {
	Name string `json:"name"`
	Type string `json:"type"`
	// +optional
	Comment string `json:"comment"`
	// +optional
	NotNullable bool `json:"notNullable,omitempty"`
}

DataColumn defines the column of data.

func (*DataColumn) DeepCopy 

func (in *DataColumn) DeepCopy() *DataColumn

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

func (*DataColumn) DeepCopyInto 

func (in *DataColumn) DeepCopyInto(out *DataColumn)

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

type DataCondition 

type DataCondition struct {
	Status corev1.ConditionStatus `json:"status"`
	// +optional
	Message        string      `json:"message,omitempty"`
	Reason         string      `json:"reason"`
	LastUpdateTime metav1.Time `json:"lastUpdateTime"`
}

DataCondition defines current state of data.

func (*DataCondition) DeepCopy 

func (in *DataCondition) DeepCopy() *DataCondition

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

func (*DataCondition) DeepCopyInto 

func (in *DataCondition) DeepCopyInto(out *DataCondition)

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

type DataPhase 

type DataPhase string

DataPhase is a label for the condition of data at the current time. 

const (
	AvailablePhase   DataPhase = "Available"
	UnavailablePhase DataPhase = "Unavailable"
	UnknownPhase     DataPhase = "Unknown"
)

type DataSchema 

type DataSchema struct {
	// +optional
	Attributes map[string]string `json:"attributes,omitempty"`
	// +optional
	Partition *Partition `json:"partitions,omitempty"`
	// +optional
	Columns []DataColumn `json:"columns,omitempty"`
	// +optional ,The vendor is the one who outputs the domain data, which may be done by the secretFlow engine,
	// another vendor's engine, or manually registered.
	Vendor string `json:"vendor,omitempty"`
}

func (*DataSchema) DeepCopy 

func (in *DataSchema) DeepCopy() *DataSchema

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

func (*DataSchema) DeepCopyInto 

func (in *DataSchema) DeepCopyInto(out *DataSchema)

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

type DataStatus 

type DataStatus struct {
	// +kubebuilder:validation:Enum=Available;Unavailable;Unknown
	Phase      DataPhase       `json:"phase"`
	Conditions []DataCondition `json:"conditions"`
}

DataStatus defines current data status.

func (*DataStatus) DeepCopy 

func (in *DataStatus) DeepCopy() *DataStatus

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

func (*DataStatus) DeepCopyInto 

func (in *DataStatus) DeepCopyInto(out *DataStatus)

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

type DeployTemplate 

type DeployTemplate struct {
	Name string `json:"name"`
	// +optional
	Role string `json:"role,omitempty"`
	// +optional
	Replicas *int32 `json:"replicas,omitempty"`
	// +optional
	NetworkPolicy *NetworkPolicy `json:"networkPolicy,omitempty"`
	Spec          PodSpec        `json:"spec"`
}

DeployTemplate defines the app deploy template.

func (*DeployTemplate) DeepCopy 

func (in *DeployTemplate) DeepCopy() *DeployTemplate

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

func (*DeployTemplate) DeepCopyInto 

func (in *DeployTemplate) DeepCopyInto(out *DeployTemplate)

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

type DeployTokenStatus 

type DeployTokenStatus struct {
	Token string `json:"token"`
	// Token state, used or unused
	State string `json:"state"`
	// +optional
	LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"`
}

DeployTokenStatus defines csr token status under domain.

func (*DeployTokenStatus) DeepCopy 

func (in *DeployTokenStatus) DeepCopy() *DeployTokenStatus

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

func (*DeployTokenStatus) DeepCopyInto 

func (in *DeployTokenStatus) DeepCopyInto(out *DeployTokenStatus)

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

type Domain 

type Domain struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              DomainSpec `json:"spec"`
	// +optional
	Status *DomainStatus `json:"status,omitempty"`
}

Domain is the Schema for the domain API.

func (*Domain) DeepCopy 

func (in *Domain) DeepCopy() *Domain

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

func (*Domain) DeepCopyInto 

func (in *Domain) DeepCopyInto(out *Domain)

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

func (*Domain) DeepCopyObject 

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

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

type DomainAppImage 

type DomainAppImage struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              DomainAppImageSpec `json:"spec"`
}

DomainAppImage is the Schema for the domain app image API.

func (*DomainAppImage) DeepCopy 

func (in *DomainAppImage) DeepCopy() *DomainAppImage

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

func (*DomainAppImage) DeepCopyInto 

func (in *DomainAppImage) DeepCopyInto(out *DomainAppImage)

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

func (*DomainAppImage) DeepCopyObject 

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

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

type DomainAppImageInfo 

type DomainAppImageInfo struct {
	Tag  string `json:"tag"`
	ID   string `json:"id"`
	Sign string `json:"sign"`
}

DomainAppImageInfo defines the basic info of domain app image.

func (*DomainAppImageInfo) DeepCopy 

func (in *DomainAppImageInfo) DeepCopy() *DomainAppImageInfo

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

func (*DomainAppImageInfo) DeepCopyInto 

func (in *DomainAppImageInfo) DeepCopyInto(out *DomainAppImageInfo)

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

type DomainAppImageList 

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

DomainAppImageList contains a list of domain app images.

func (*DomainAppImageList) DeepCopy 

func (in *DomainAppImageList) DeepCopy() *DomainAppImageList

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

func (*DomainAppImageList) DeepCopyInto 

func (in *DomainAppImageList) DeepCopyInto(out *DomainAppImageList)

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

func (*DomainAppImageList) DeepCopyObject 

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

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

type DomainAppImageSpec 

type DomainAppImageSpec struct {
	// +optional
	Images []DomainAppImageInfo `json:"images,omitempty"`
}

DomainAppImageSpec defines details of domain app images.

func (*DomainAppImageSpec) DeepCopy 

func (in *DomainAppImageSpec) DeepCopy() *DomainAppImageSpec

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

func (*DomainAppImageSpec) DeepCopyInto 

func (in *DomainAppImageSpec) DeepCopyInto(out *DomainAppImageSpec)

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

type DomainAuthenticationType 

type DomainAuthenticationType string

DomainAuthenticationType defines the type of authentication between domains. 

const (
	DomainAuthenticationToken DomainAuthenticationType = "Token"
	DomainAuthenticationMTLS  DomainAuthenticationType = "MTLS"
	DomainAuthenticationNone  DomainAuthenticationType = "None"
)

type DomainData 

type DomainData struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              DomainDataSpec `json:"spec"`
	// +optional
	Status DataStatus `json:"status,omitempty"`
}

DomainData include feature table,model,rule,report .etc

func (*DomainData) DeepCopy 

func (in *DomainData) DeepCopy() *DomainData

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

func (*DomainData) DeepCopyInto 

func (in *DomainData) DeepCopyInto(out *DomainData)

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

func (*DomainData) DeepCopyObject 

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

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

type DomainDataGrant 

type DomainDataGrant struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              DomainDataGrantSpec `json:"spec"`
	// +optional
	Status DomainDataGrantStatus `json:"status,omitempty"`
}

DomainDataGrant is the Schema for the data object API.

func (*DomainDataGrant) DeepCopy 

func (in *DomainDataGrant) DeepCopy() *DomainDataGrant

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

func (*DomainDataGrant) DeepCopyInto 

func (in *DomainDataGrant) DeepCopyInto(out *DomainDataGrant)

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

func (*DomainDataGrant) DeepCopyObject 

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

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

type DomainDataGrantList 

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

DomainDataGrantList contains a list of domain data grant.

func (*DomainDataGrantList) DeepCopy 

func (in *DomainDataGrantList) DeepCopy() *DomainDataGrantList

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

func (*DomainDataGrantList) DeepCopyInto 

func (in *DomainDataGrantList) DeepCopyInto(out *DomainDataGrantList)

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

func (*DomainDataGrantList) DeepCopyObject 

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

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

type DomainDataGrantSpec 

type DomainDataGrantSpec struct {
	Author       string `json:"author"`
	DomainDataID string `json:"domainDataID"`
	// +optional
	Signature   string `json:"signature,omitempty"`
	GrantDomain string `json:"grantDomain"`
	// +optional
	Limit *GrantLimit `json:"limit,omitempty"`
	// +optional
	Description map[string]string `json:"description,omitempty"`
}

DomainDataGrantSpec defines the spec of data grant info.

func (*DomainDataGrantSpec) DeepCopy 

func (in *DomainDataGrantSpec) DeepCopy() *DomainDataGrantSpec

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

func (*DomainDataGrantSpec) DeepCopyInto 

func (in *DomainDataGrantSpec) DeepCopyInto(out *DomainDataGrantSpec)

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

type DomainDataGrantStatus 

type DomainDataGrantStatus struct {
	Phase   GrantPhase `json:"phase"`
	Message string     `json:"message"`
	// +optional
	UseRecords []UseRecord `json:"use_records"`
}

DomainDataGrantStatus defines current data status.

func (*DomainDataGrantStatus) DeepCopy 

func (in *DomainDataGrantStatus) DeepCopy() *DomainDataGrantStatus

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

func (*DomainDataGrantStatus) DeepCopyInto 

func (in *DomainDataGrantStatus) DeepCopyInto(out *DomainDataGrantStatus)

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

type DomainDataList 

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

DomainDataList contains a list of domain data.

func (*DomainDataList) DeepCopy 

func (in *DomainDataList) DeepCopy() *DomainDataList

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

func (*DomainDataList) DeepCopyInto 

func (in *DomainDataList) DeepCopyInto(out *DomainDataList)

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

func (*DomainDataList) DeepCopyObject 

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

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

type DomainDataSource 

type DomainDataSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              DomainDataSourceSpec `json:"spec"`
	// +optional
	Status DataStatus `json:"status,omitempty"`
}

DomainDataSource is the Schema for the data source API.

func (*DomainDataSource) DeepCopy 

func (in *DomainDataSource) DeepCopy() *DomainDataSource

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

func (*DomainDataSource) DeepCopyInto 

func (in *DomainDataSource) DeepCopyInto(out *DomainDataSource)

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

func (*DomainDataSource) DeepCopyObject 

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

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

type DomainDataSourceList 

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

DomainDataSourceList contains a list of data sources.

func (*DomainDataSourceList) DeepCopy 

func (in *DomainDataSourceList) DeepCopy() *DomainDataSourceList

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

func (*DomainDataSourceList) DeepCopyInto 

func (in *DomainDataSourceList) DeepCopyInto(out *DomainDataSourceList)

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

func (*DomainDataSourceList) DeepCopyObject 

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

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

type DomainDataSourceSpec 

type DomainDataSourceSpec struct {
	// +optional
	URI  string `json:"uri"`
	Name string `json:"name"`
	// +optional
	Data map[string]string `json:"data,omitempty"`
	Type string            `json:"type"`
	// +optional
	InfoKey string `json:"infoKey,omitempty"`
	// +optional
	AccessDirectly bool `json:"accessDirectly,omitempty"`
}

DomainDataSourceSpec defines the spec of data source.

func (*DomainDataSourceSpec) DeepCopy 

func (in *DomainDataSourceSpec) DeepCopy() *DomainDataSourceSpec

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

func (*DomainDataSourceSpec) DeepCopyInto 

func (in *DomainDataSourceSpec) DeepCopyInto(out *DomainDataSourceSpec)

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

type DomainDataSpec 

type DomainDataSpec struct {
	// the URI of domaindata, the relative URI to the datasource
	RelativeURI string `json:"relativeURI"`
	Author      string `json:"author"`
	Name        string `json:"name"`
	Type        string `json:"type"`
	DataSource  string `json:"dataSource"`
	// +optional
	Attributes map[string]string `json:"attributes,omitempty"`
	// +optional
	Partition *Partition `json:"partitions,omitempty"`
	// +optional
	Columns []DataColumn `json:"columns,omitempty"`
	// +optional ,The vendor is the one who outputs the domain data, which may be done by the secretFlow engine,
	// another vendor's engine, or manually registered.
	Vendor string `json:"vendor,omitempty"`
	// +optional
	FileFormat string `json:"fileFormat,omitempty"`
}

DomainDataSpec defines the spec of data object.

func (*DomainDataSpec) DeepCopy 

func (in *DomainDataSpec) DeepCopy() *DomainDataSpec

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

func (*DomainDataSpec) DeepCopyInto 

func (in *DomainDataSpec) DeepCopyInto(out *DomainDataSpec)

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

type DomainEndpoint 

type DomainEndpoint struct {
	// +optional
	Host string `json:"host,omitempty"`
	// +optional
	Ports []DomainPort `json:"ports,omitempty"`
}

DomainEndpoint defines destination access address.

func (*DomainEndpoint) DeepCopy 

func (in *DomainEndpoint) DeepCopy() *DomainEndpoint

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

func (*DomainEndpoint) DeepCopyInto 

func (in *DomainEndpoint) DeepCopyInto(out *DomainEndpoint)

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

type DomainList 

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

DomainList contains a list of domains.

func (*DomainList) DeepCopy 

func (in *DomainList) DeepCopy() *DomainList

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

func (*DomainList) DeepCopyInto 

func (in *DomainList) DeepCopyInto(out *DomainList)

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

func (*DomainList) DeepCopyObject 

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

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

type DomainPort 

type DomainPort struct {
	Name string `json:"name"`
	// +kubebuilder:validation:Enum=HTTP;GRPC
	Protocol DomainRouteProtocolType `json:"protocol"`
	// +optional
	PathPrefix string `json:"pathPrefix,omitempty"`
	IsTLS      bool   `json:"isTLS,omitempty"`
	Port       int    `json:"port"`
}

DomainPort defines the port information of domain.

func (*DomainPort) DeepCopy 

func (in *DomainPort) DeepCopy() *DomainPort

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

func (*DomainPort) DeepCopyInto 

func (in *DomainPort) DeepCopyInto(out *DomainPort)

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

type DomainResourceQuota 

type DomainResourceQuota struct {
	// +optional
	// +kubebuilder:validation:Minimum=0
	PodMaxCount *int `json:"podMaxCount,omitempty"`
}

DomainResourceQuota defines domain resource quota.

func (*DomainResourceQuota) DeepCopy 

func (in *DomainResourceQuota) DeepCopy() *DomainResourceQuota

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

func (*DomainResourceQuota) DeepCopyInto 

func (in *DomainResourceQuota) DeepCopyInto(out *DomainResourceQuota)

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

type DomainRole 

type DomainRole string
const (
	Partner DomainRole = "partner"
)

type DomainRoute 

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

	// +optional
	Spec DomainRouteSpec `json:"spec,omitempty"`
	// +optional
	Status DomainRouteStatus `json:"status,omitempty"`
}

DomainRoute defines the routing rules between domains on the center side.

func (*DomainRoute) DeepCopy 

func (in *DomainRoute) DeepCopy() *DomainRoute

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

func (*DomainRoute) DeepCopyInto 

func (in *DomainRoute) DeepCopyInto(out *DomainRoute)

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

func (*DomainRoute) DeepCopyObject 

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

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

type DomainRouteList 

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

DomainRouteList is a list of DomainRoutes.

func (*DomainRouteList) DeepCopy 

func (in *DomainRouteList) DeepCopy() *DomainRouteList

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

func (*DomainRouteList) DeepCopyInto 

func (in *DomainRouteList) DeepCopyInto(out *DomainRouteList)

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

func (*DomainRouteList) DeepCopyObject 

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

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

type DomainRouteMTLSConfig 

type DomainRouteMTLSConfig struct {
	// The tls certificate is used to verify the https server.
	// Must be base64 encoded.
	// +optional
	TLSCA string `json:"tlsCA,omitempty"`
	// When MTLS is only used as the communication layer, the public and private keys can be randomly generated
	// by the destination. The public key is ultimately used to generate the MTLS certificate, and the private key
	// needs to be given to the source.
	// When MTLS is used for authentication, the sourceClientKey should be the local private key of the source.
	// There is no need to specify it here.
	// Must be base64 encoded.
	// +optional
	SourceClientPrivateKey string `json:"sourceClientPrivateKey,omitempty"`
	// SourceClientCert is issued by the local self-signed CA of destination.
	// When MTLS is only used as the communication layer, it can be generated based on the randomly generated public key.
	// When MTLS is used for authentication, it needs to be generated based on the authorized public key of the source.
	// Must be base64 encoded.
	// +optional
	SourceClientCert string `json:"sourceClientCert,omitempty"`
}

DomainRouteMTLSConfig defines the configuration required by mTLS.

func (*DomainRouteMTLSConfig) DeepCopy 

func (in *DomainRouteMTLSConfig) DeepCopy() *DomainRouteMTLSConfig

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

func (*DomainRouteMTLSConfig) DeepCopyInto 

func (in *DomainRouteMTLSConfig) DeepCopyInto(out *DomainRouteMTLSConfig)

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

type DomainRouteProtocolType 

type DomainRouteProtocolType string

DomainRouteProtocolType defines protocol type supported by the port. 

const (
	DomainRouteProtocolHTTP DomainRouteProtocolType = "HTTP"
	DomainRouteProtocolGRPC DomainRouteProtocolType = "GRPC"
)

type DomainRouteSpec 

type DomainRouteSpec struct {
	// Source namespace.
	Source string `json:"source"`
	// Destination namespace.
	Destination string `json:"destination"`
	// Interconnection Protocol
	InterConnProtocol InterConnProtocolType `json:"interConnProtocol,omitempty"`
	// Endpoint defines address for the source to access destination.
	// +optional
	Endpoint DomainEndpoint `json:"endpoint,omitempty"`
	// Transit entity. If transitMethod is THIRD-DOMAIN,
	// requests from source to destination need to be transferred through
	// a third party, domain field must be set. If transitMethod is
	// REVERSE-TUNNEL, requests from source to destination need to be
	// transferred through local gateway chunked transfer encoding.
	// +optional
	Transit *Transit `json:"transit,omitempty"`
	// AuthenticationType describes how destination authenticates the source's request.
	AuthenticationType DomainAuthenticationType `json:"authenticationType"`
	// +optional
	TokenConfig *TokenConfig `json:"tokenConfig,omitempty"`
	// +optional
	BodyEncryption *BodyEncryption `json:"bodyEncryption,omitempty"`
	// +optional
	MTLSConfig *DomainRouteMTLSConfig `json:"mTLSConfig,omitempty"`
	// Whitelist of source IP address or CIDR. If it is empty, the source ip will not be checked.
	// +optional
	SourceWhiteIPList []string `json:"sourceWhiteIPList,omitempty"`
	// add specified headers to requests from source.
	// +optional
	RequestHeadersToAdd map[string]string `json:"requestHeadersToAdd,omitempty"`
}

DomainRouteSpec is a description of DomainRoute.

func (*DomainRouteSpec) DeepCopy 

func (in *DomainRouteSpec) DeepCopy() *DomainRouteSpec

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

func (*DomainRouteSpec) DeepCopyInto 

func (in *DomainRouteSpec) DeepCopyInto(out *DomainRouteSpec)

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

type DomainRouteStatus 

type DomainRouteStatus struct {
	IsDestinationAuthorized  bool `json:"isDestinationAuthorized"`
	IsDestinationUnreachable bool `json:"isDestinationUnreachable"`
	// +optional
	TokenStatus DomainRouteTokenStatus `json:"tokenStatus,omitempty"`
}

DomainRouteStatus represents information about the status of DomainRoute.

func (*DomainRouteStatus) DeepCopy 

func (in *DomainRouteStatus) DeepCopy() *DomainRouteStatus

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

func (*DomainRouteStatus) DeepCopyInto 

func (in *DomainRouteStatus) DeepCopyInto(out *DomainRouteStatus)

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

type DomainRouteToken 

type DomainRouteToken struct {
	// Token is ready to use
	IsReady bool `json:"isReady"`
	// Generated token.
	// +optional
	Token string `json:"token"`
	// A sequence number representing a specific generation.
	// +optional
	Revision int64 `json:"revision"`
	// Timestamp representing the time when this revision created.
	// +optional
	RevisionTime metav1.Time `json:"revisionTime,omitempty"`
	// Timestamp representing the time when this revision expired.
	// +optional
	ExpirationTime metav1.Time `json:"expirationTime,omitempty"`
	// Timestamp representing the time when this revision heartbeat.
	// +optional
	HeartBeatTime metav1.Time `json:"heartBeatTime,omitempty"`
	// Record effective instances
	// +optional
	EffectiveInstances []string `json:"effectiveInstances,omitempty"`
}

DomainRouteToken represents a generated token.

func (*DomainRouteToken) DeepCopy 

func (in *DomainRouteToken) DeepCopy() *DomainRouteToken

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

func (*DomainRouteToken) DeepCopyInto 

func (in *DomainRouteToken) DeepCopyInto(out *DomainRouteToken)

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

type DomainRouteTokenStatus 

type DomainRouteTokenStatus struct {
	// Initializer in source namespace that will start negotiation in this revision, RSA-GEN only.
	// +optional
	RevisionInitializer string `json:"revisionInitializer,omitempty"`
	// Token generated in specific revision, RSA-GEN only.
	// +optional
	RevisionToken DomainRouteToken `json:"revisionToken,omitempty"`
	// Tokens keeps the most recently two generated tokens.
	// +optional
	Tokens []DomainRouteToken `json:"tokens,omitempty"`
}

DomainRouteTokenStatus represents information about the token in DomainRoute.

func (*DomainRouteTokenStatus) DeepCopy 

func (in *DomainRouteTokenStatus) DeepCopy() *DomainRouteTokenStatus

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

func (*DomainRouteTokenStatus) DeepCopyInto 

func (in *DomainRouteTokenStatus) DeepCopyInto(out *DomainRouteTokenStatus)

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

type DomainSpec 

type DomainSpec struct {
	// Role is used to represent the role of domain. Default is omit empty.
	// When the domain is for partner, please set the value to partner.
	// +optional
	Role DomainRole `json:"role,omitempty"`

	// MasterDomain is used to represent the master domain id of current domain.
	// For a omit domain, MasterDomain is exactly local cluster's master
	// For a partner domain, the default MasterDomain is the domain itself
	// Only for a partner domain which is not an autonomy domain, you need to specify its master domain explicitly
	// +optional
	MasterDomain string `json:"master,omitempty"`

	// Interconnection Protocols
	// If multiple protocols are specified, select the protocols in the order of configuration.
	// +optional
	InterConnProtocols []InterConnProtocolType `json:"interConnProtocols,omitempty"`

	// +optional
	Cert string `json:"cert,omitempty"`
	// +optional
	AuthCenter *AuthCenter `json:"authCenter"`
	// +optional
	ResourceQuota *DomainResourceQuota `json:"resourceQuota,omitempty"`
}

DomainSpec defines the details of domain.

func (*DomainSpec) DeepCopy 

func (in *DomainSpec) DeepCopy() *DomainSpec

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

func (*DomainSpec) DeepCopyInto 

func (in *DomainSpec) DeepCopyInto(out *DomainSpec)

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

type DomainStatus 

type DomainStatus struct {
	// +optional
	NodeStatuses []NodeStatus `json:"nodeStatuses,omitempty"`
	// +optional
	DeployTokenStatuses []DeployTokenStatus `json:"deployTokenStatuses"`
}

DomainStatus defines domain status.

func (*DomainStatus) DeepCopy 

func (in *DomainStatus) DeepCopy() *DomainStatus

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

func (*DomainStatus) DeepCopyInto 

func (in *DomainStatus) DeepCopyInto(out *DomainStatus)

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

type DomainTransit 

type DomainTransit struct {
	DomainID string `json:"domainID"`
}

DomainTransit defines the information of the transit domain.

func (*DomainTransit) DeepCopy 

func (in *DomainTransit) DeepCopy() *DomainTransit

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

func (*DomainTransit) DeepCopyInto 

func (in *DomainTransit) DeepCopyInto(out *DomainTransit)

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

type Gateway 

type Gateway struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Status            GatewayStatus `json:"status,omitempty"`
}

Gateway is a proxy for communication between domains.

func (*Gateway) DeepCopy 

func (in *Gateway) DeepCopy() *Gateway

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

func (*Gateway) DeepCopyInto 

func (in *Gateway) DeepCopyInto(out *Gateway)

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

func (*Gateway) DeepCopyObject 

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

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

type GatewayEndpointStatus 

type GatewayEndpointStatus struct {
	Name                  string `json:"name"`
	Type                  string `json:"type"`
	TotalEndpointsCount   int    `json:"totalEndpointsCount"`
	HealthyEndpointsCount int    `json:"healthyEndpointsCount"`
}

func (*GatewayEndpointStatus) DeepCopy 

func (in *GatewayEndpointStatus) DeepCopy() *GatewayEndpointStatus

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

func (*GatewayEndpointStatus) DeepCopyInto 

func (in *GatewayEndpointStatus) DeepCopyInto(out *GatewayEndpointStatus)

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

type GatewayList 

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

GatewayList is a list of Gateway resources.

func (*GatewayList) DeepCopy 

func (in *GatewayList) DeepCopy() *GatewayList

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

func (*GatewayList) DeepCopyInto 

func (in *GatewayList) DeepCopyInto(out *GatewayList)

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

func (*GatewayList) DeepCopyObject 

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

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

type GatewayStatus 

type GatewayStatus struct {
	Address       string      `json:"address"`
	UpTime        metav1.Time `json:"uptime"`
	HeartbeatTime metav1.Time `json:"heartbeatTime"`
	// PublicKey is RSA public key used by domain, base64 encoded.
	PublicKey     string                  `json:"publicKey"`
	Version       string                  `json:"version"`
	NetworkStatus []GatewayEndpointStatus `json:"networkStatus,omitempty"`
}

GatewayStatus represents the current state of a Gateway.

func (*GatewayStatus) DeepCopy 

func (in *GatewayStatus) DeepCopy() *GatewayStatus

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

func (*GatewayStatus) DeepCopyInto 

func (in *GatewayStatus) DeepCopyInto(out *GatewayStatus)

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

type GrantLimit 

type GrantLimit struct {
	// +optional
	ExpirationTime *metav1.Time `json:"expirationTime,omitempty"`
	// +optional
	UseCount int `json:"useCount,omitempty"`
	// +optional
	GrantMode []GrantType `json:"grantMode,omitempty"`
	// +optional
	FlowID string `json:"flowID,omitempty"`
	// +optional
	Components []string `json:"components,omitempty"`
	// +optional
	Initiator string `json:"initiator,omitempty"`
	// +optional
	InputConfig string `json:"inputConfig,omitempty"`
}

func (*GrantLimit) DeepCopy 

func (in *GrantLimit) DeepCopy() *GrantLimit

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

func (*GrantLimit) DeepCopyInto 

func (in *GrantLimit) DeepCopyInto(out *GrantLimit)

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

type GrantPhase 

type GrantPhase string

GrantPhase is phase of data grant at the current time. +kubebuilder:validation:Enum=Ready;Unavailable;Unknown 

const (
	GrantReady       GrantPhase = "Ready"
	GrantUnavailable GrantPhase = "Unavailable"
	GrantUnknown     GrantPhase = "Unknown"
)

type GrantType 

type GrantType string

GrantLevel +kubebuilder:validation:Enum=normal;metadata;file

type Ingress 

type Ingress struct {
	From  IngressFrom   `json:"from"`
	Ports []IngressPort `json:"ports"`
}

Ingress defines the ingress information.

func (*Ingress) DeepCopy 

func (in *Ingress) DeepCopy() *Ingress

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

func (*Ingress) DeepCopyInto 

func (in *Ingress) DeepCopyInto(out *Ingress)

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

type IngressFrom 

type IngressFrom struct {
	Roles []string `json:"roles"`
}

IngressFrom defines the requester info.

func (*IngressFrom) DeepCopy 

func (in *IngressFrom) DeepCopy() *IngressFrom

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

func (*IngressFrom) DeepCopyInto 

func (in *IngressFrom) DeepCopyInto(out *IngressFrom)

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

type IngressPort 

type IngressPort struct {
	Port string `json:"port"`
}

IngressPort defines the port that is allowed to access.

func (*IngressPort) DeepCopy 

func (in *IngressPort) DeepCopy() *IngressPort

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

func (*IngressPort) DeepCopyInto 

func (in *IngressPort) DeepCopyInto(out *IngressPort)

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

type InterConnProtocolType 

type InterConnProtocolType string
const (
	InterConnKuscia InterConnProtocolType = "kuscia"
	InterConnBFIA   InterConnProtocolType = "bfia" // Beijing FinTech Industry Alliance
)

type InteropConfig 

type InteropConfig struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              InteropConfigSpec `json:"spec"`
}

InteropConfig is the Schema for the Interop config API.

func (*InteropConfig) DeepCopy 

func (in *InteropConfig) DeepCopy() *InteropConfig

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

func (*InteropConfig) DeepCopyInto 

func (in *InteropConfig) DeepCopyInto(out *InteropConfig)

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

func (*InteropConfig) DeepCopyObject 

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

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

type InteropConfigList 

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

InteropConfigList contains a list of Interop config.

func (*InteropConfigList) DeepCopy 

func (in *InteropConfigList) DeepCopy() *InteropConfigList

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

func (*InteropConfigList) DeepCopyInto 

func (in *InteropConfigList) DeepCopyInto(out *InteropConfigList)

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

func (*InteropConfigList) DeepCopyObject 

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

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

type InteropConfigSpec 

type InteropConfigSpec struct {
	Host    string   `json:"host"`
	Members []string `json:"members"`
}

InteropConfigSpec defines the details of Interop config.

func (*InteropConfigSpec) DeepCopy 

func (in *InteropConfigSpec) DeepCopy() *InteropConfigSpec

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

func (*InteropConfigSpec) DeepCopyInto 

func (in *InteropConfigSpec) DeepCopyInto(out *InteropConfigSpec)

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

type JobApprovePhase 

type JobApprovePhase string
const (
	JobRejected JobApprovePhase = "JobRejected"
	JobAccepted JobApprovePhase = "JobAccepted"
)

type JobStage 

type JobStage string
const (
	JobCreateStage  JobStage = "Create"
	JobStartStage   JobStage = "Start"
	JobStopStage    JobStage = "Stop"
	JobCancelStage  JobStage = "Cancel"
	JobRestartStage JobStage = "Restart"
	JobSuspendStage JobStage = "Suspend"
)

type JobStagePhase 

type JobStagePhase string
const (
	JobCreateStageSucceeded JobStagePhase = "JobCreateStageSucceeded"
	JobCreateStageFailed    JobStagePhase = "JobCreateStageFailed"

	JobStartStageSucceeded JobStagePhase = "JobStartStageSucceeded"
	JobStartStageFailed    JobStagePhase = "JobStartStageFailed"

	JobRestartStageSucceeded JobStagePhase = "JobRestartStageSucceeded"
	JobRestartStageFailed    JobStagePhase = "JobRestartStageFailed"

	JobStopStageSucceeded JobStagePhase = "JobStopStageSucceeded"
	JobStopStageFailed    JobStagePhase = "JobStopStageFailed"

	JobCancelStageSucceeded JobStagePhase = "JobCancelStageSucceeded"
	JobCancelStageFailed    JobStagePhase = "JobCancelStageFailed"

	JobSuspendStageSucceeded JobStagePhase = "JobSuspendStageSucceeded"
	JobSuspendStageFailed    JobStagePhase = "JobSuspendStageFailed"
)

type KusciaDeployment 

type KusciaDeployment struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              KusciaDeploymentSpec `json:"spec"`
	// +optional
	Status KusciaDeploymentStatus `json:"status,omitempty"`
}

KusciaDeployment is the Schema for the kuscia deployment API.

func (*KusciaDeployment) DeepCopy 

func (in *KusciaDeployment) DeepCopy() *KusciaDeployment

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

func (*KusciaDeployment) DeepCopyInto 

func (in *KusciaDeployment) DeepCopyInto(out *KusciaDeployment)

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

func (*KusciaDeployment) DeepCopyObject 

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

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

type KusciaDeploymentList 

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

KusciaDeploymentList contains a list of kuscia deployments.

func (*KusciaDeploymentList) DeepCopy 

func (in *KusciaDeploymentList) DeepCopy() *KusciaDeploymentList

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

func (*KusciaDeploymentList) DeepCopyInto 

func (in *KusciaDeploymentList) DeepCopyInto(out *KusciaDeploymentList)

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

func (*KusciaDeploymentList) DeepCopyObject 

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

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

type KusciaDeploymentParty 

type KusciaDeploymentParty struct {
	DomainID    string `json:"domainID"`
	AppImageRef string `json:"appImageRef"`
	// +optional
	Role string `json:"role,omitempty"`
	// +optional
	Template KusciaDeploymentPartyTemplate `json:"template,omitempty"`
	// +optional
	ServiceNamePrefix string `json:"serviceNamePrefix,omitempty"`
}

KusciaDeploymentParty defines the kuscia deployment party info.

func (*KusciaDeploymentParty) DeepCopy 

func (in *KusciaDeploymentParty) DeepCopy() *KusciaDeploymentParty

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

func (*KusciaDeploymentParty) DeepCopyInto 

func (in *KusciaDeploymentParty) DeepCopyInto(out *KusciaDeploymentParty)

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

type KusciaDeploymentPartyStatus 

type KusciaDeploymentPartyStatus struct {
	// The party deployment phase.
	// +optional
	Phase KusciaDeploymentPhase `json:"phase,omitempty"`
	// +optional
	Role string `json:"role,omitempty"`
	// Total number of non-terminated pods targeted by this deployment (their labels match the selector).
	Replicas int32 `json:"replicas"`
	// Total number of non-terminated pods targeted by this deployment that have the desired template spec.
	UpdatedReplicas int32 `json:"updatedReplicas"`
	// Total number of available pods (ready for at least minReadySeconds) targeted by this deployment.
	AvailableReplicas int32 `json:"availableReplicas"`
	// Total number of unavailable pods targeted by this deployment. This is the total number of
	// pods that are still required for the deployment to have 100% available capacity. They may
	// either be pods that are running but not yet available or pods that still have not been created.
	UnavailableReplicas int32 `json:"unavailableReplicas"`
	// Represents the latest available observations of a deployment's current state.
	// +optional
	Conditions []v1.DeploymentCondition `json:"conditions,omitempty"`
	// +optional
	CreationTimestamp *metav1.Time `json:"creationTimestamp,omitempty"`
}

KusciaDeploymentPartyStatus defines party status of kuscia deployment.

func (*KusciaDeploymentPartyStatus) DeepCopy 

func (in *KusciaDeploymentPartyStatus) DeepCopy() *KusciaDeploymentPartyStatus

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

func (*KusciaDeploymentPartyStatus) DeepCopyInto 

func (in *KusciaDeploymentPartyStatus) DeepCopyInto(out *KusciaDeploymentPartyStatus)

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

type KusciaDeploymentPartyTemplate 

type KusciaDeploymentPartyTemplate struct {
	// Number of desired pods. This is a pointer to distinguish between explicit
	// zero and not specified. Defaults to 1.
	// +optional
	Replicas *int32 `json:"replicas,omitempty"`
	// The deployment strategy to use to replace existing pods with new ones.
	// +optional
	Strategy *v1.DeploymentStrategy `json:"strategy,omitempty"`
	// +optional
	Spec PodSpec `json:"spec,omitempty"`
}

KusciaDeploymentPartyTemplate defines the template info for party.

func (*KusciaDeploymentPartyTemplate) DeepCopy 

func (in *KusciaDeploymentPartyTemplate) DeepCopy() *KusciaDeploymentPartyTemplate

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

func (*KusciaDeploymentPartyTemplate) DeepCopyInto 

func (in *KusciaDeploymentPartyTemplate) DeepCopyInto(out *KusciaDeploymentPartyTemplate)

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

type KusciaDeploymentPhase 

type KusciaDeploymentPhase string

KusciaDeploymentPhase defines the phase for deployment. 

const (
	// KusciaDeploymentPhaseProgressing means the deployments are progressing.
	KusciaDeploymentPhaseProgressing KusciaDeploymentPhase = "Progressing"

	// KusciaDeploymentPhasePartialAvailable means the deployments are partial available.
	KusciaDeploymentPhasePartialAvailable KusciaDeploymentPhase = "PartialAvailable"

	// KusciaDeploymentPhaseAvailable means the deployments are available.
	KusciaDeploymentPhaseAvailable KusciaDeploymentPhase = "Available"

	// KusciaDeploymentPhaseFailed means failed to parse and create deployment.
	KusciaDeploymentPhaseFailed KusciaDeploymentPhase = "Failed"
)

type KusciaDeploymentSpec 

type KusciaDeploymentSpec struct {
	Initiator   string                  `json:"initiator"`
	InputConfig string                  `json:"inputConfig"`
	Parties     []KusciaDeploymentParty `json:"parties"`
}

KusciaDeploymentSpec defines the information of kuscia deployment spec.

func (*KusciaDeploymentSpec) DeepCopy 

func (in *KusciaDeploymentSpec) DeepCopy() *KusciaDeploymentSpec

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

func (*KusciaDeploymentSpec) DeepCopyInto 

func (in *KusciaDeploymentSpec) DeepCopyInto(out *KusciaDeploymentSpec)

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

type KusciaDeploymentStatus 

type KusciaDeploymentStatus struct {
	// The phase of a KusciaDeployment is a simple, high-level summary of
	// where the deployment is in its lifecycle.
	// +optional
	Phase KusciaDeploymentPhase `json:"phase,omitempty"`
	// A brief CamelCase message indicating details about why it is in this state.
	// +optional
	Reason string `json:"reason,omitempty"`
	// A readable message indicating details about why it is in this condition.
	// +optional
	Message string `json:"message,omitempty"`
	// Total number of parties.
	TotalParties int `json:"totalParties"`
	// Total number of available parties.
	AvailableParties int `json:"availableParties"`
	// PartyDeploymentStatuses defines deployment status for all party.
	// +optional
	PartyDeploymentStatuses map[string]map[string]*KusciaDeploymentPartyStatus `json:"partyDeploymentStatuses,omitempty"`
	// Represents last time when the deployment was reconciled. 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
	LastReconcileTime *metav1.Time `json:"lastReconcileTime,omitempty"`
}

KusciaDeploymentStatus defines the observed state of kuscia deployment.

func (*KusciaDeploymentStatus) DeepCopy 

func (in *KusciaDeploymentStatus) DeepCopy() *KusciaDeploymentStatus

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

func (*KusciaDeploymentStatus) DeepCopyInto 

func (in *KusciaDeploymentStatus) DeepCopyInto(out *KusciaDeploymentStatus)

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

type KusciaDeploymentSummary 

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

	// +optional
	Status KusciaDeploymentStatus `json:"status,omitempty"`
}

KusciaDeploymentSummary is used to sync deployment status between clusters

func (*KusciaDeploymentSummary) DeepCopy 

func (in *KusciaDeploymentSummary) DeepCopy() *KusciaDeploymentSummary

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

func (*KusciaDeploymentSummary) DeepCopyInto 

func (in *KusciaDeploymentSummary) DeepCopyInto(out *KusciaDeploymentSummary)

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

func (*KusciaDeploymentSummary) DeepCopyObject 

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

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

type KusciaDeploymentSummaryList 

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

KusciaDeploymentSummaryList contains a list of kuscia deployments.

func (*KusciaDeploymentSummaryList) DeepCopy 

func (in *KusciaDeploymentSummaryList) DeepCopy() *KusciaDeploymentSummaryList

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

func (*KusciaDeploymentSummaryList) DeepCopyInto 

func (in *KusciaDeploymentSummaryList) DeepCopyInto(out *KusciaDeploymentSummaryList)

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

func (*KusciaDeploymentSummaryList) DeepCopyObject 

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

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

type KusciaJob 

type KusciaJob struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              KusciaJobSpec `json:"spec"`
	// +optional
	Status KusciaJobStatus `json:"status,omitempty"`
}

KusciaJob is the Schema for the kuscia job API.

func (*KusciaJob) DeepCopy 

func (in *KusciaJob) DeepCopy() *KusciaJob

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

func (*KusciaJob) DeepCopyInto 

func (in *KusciaJob) DeepCopyInto(out *KusciaJob)

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

func (*KusciaJob) DeepCopyObject 

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

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

type KusciaJobCondition 

type KusciaJobCondition struct {
	// Type of job condition.
	Type KusciaJobConditionType `json:"type"`
	// Status of the condition, one of True, False, Unknown.
	Status corev1.ConditionStatus `json:"status"`
	// The reason for the condition's last transition.
	// +optional
	Reason string `json:"reason,omitempty"`
	// A human-readable message indicating details about the transition.
	// +optional
	Message string `json:"message,omitempty"`
	// Last time the condition transitioned from one status to another.
	// +optional
	LastTransitionTime *metav1.Time `json:"lastTransitionTime,omitempty"`
}

KusciaJobCondition describes current state of a kuscia job.

func (*KusciaJobCondition) DeepCopy 

func (in *KusciaJobCondition) DeepCopy() *KusciaJobCondition

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

func (*KusciaJobCondition) DeepCopyInto 

func (in *KusciaJobCondition) DeepCopyInto(out *KusciaJobCondition)

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

type KusciaJobConditionType 

type KusciaJobConditionType string

KusciaJobConditionType is a valid value for a kuscia job condition type. 

const (
	// JobValidated represents job is validated.
	JobValidated KusciaJobConditionType = "JobValidated"
	// JobCreateInitialized represents job-create stage is initialized.
	JobCreateInitialized KusciaJobConditionType = "JobCreateInitialized"
	// JobCreateSucceeded represents job-create stage is succeeded.
	JobCreateSucceeded KusciaJobConditionType = "JobCreateSucceeded"
	// JobStartInitialized represents job-start stage is initialized.
	JobStartInitialized KusciaJobConditionType = "JobStartInitialized"
	// JobStartSucceeded represents job-start stage is succeeded.
	JobStartSucceeded KusciaJobConditionType = "JobStartSucceeded"
	// JobStopInitialized represents job-stop stage is initialized.
	JobStopInitialized KusciaJobConditionType = "JobStopInitialized"
	// JobStopSucceeded represents job-stop stage is succeeded.
	JobStopSucceeded KusciaJobConditionType = "JobStopSucceeded"
	// TaskStopped represents condition of stopping task.
	TaskStopped KusciaJobConditionType = "TaskStopped"
	// JobStatusSynced represents condition of syncing job status.
	JobStatusSynced KusciaJobConditionType = "JobStatusSynced"
)

These are built-in conditions of kuscia job.

type KusciaJobList 

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

KusciaJobList contains a list of kuscia jobs.

func (*KusciaJobList) DeepCopy 

func (in *KusciaJobList) DeepCopy() *KusciaJobList

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

func (*KusciaJobList) DeepCopyInto 

func (in *KusciaJobList) DeepCopyInto(out *KusciaJobList)

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

func (*KusciaJobList) DeepCopyObject 

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

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

type KusciaJobPhase 

type KusciaJobPhase string

KusciaJobPhase defines current status of this kuscia job. 

const (

	// KusciaJobInitialized means the job is initialized, just be created soon.
	KusciaJobInitialized KusciaJobPhase = "initialized"

	// KusciaJobAwaitingApproval means the job is waiting for approval by some parties
	KusciaJobAwaitingApproval KusciaJobPhase = "AwaitingApproval"

	// KusciaJobPending means the job has been accepted by the controller,
	// but no kuscia task has not been created.
	KusciaJobPending KusciaJobPhase = "Pending"

	// KusciaJobRunning means least one tasks has created, and some kuscia task are running.
	KusciaJobRunning KusciaJobPhase = "Running"

	// KusciaJobSucceeded means all tasks are finished and all non-tolerable tasks are succeeded.
	KusciaJobSucceeded KusciaJobPhase = "Succeeded"

	// KusciaJobFailed means least one non-tolerable tasks are failed and kuscia job scheduling is stopped.
	KusciaJobFailed KusciaJobPhase = "Failed"

	// KusciaJobCancelled means the job is cancelled and cannot to be restarted.
	KusciaJobCancelled KusciaJobPhase = "Cancelled"

	// KusciaJobApprovalReject means the job is rejected by some parties.
	KusciaJobApprovalReject KusciaJobPhase = "ApprovalReject"

	// KusciaJobSuspended means the job has been suspended by some parties.
	KusciaJobSuspended KusciaJobPhase = "Suspended"
)

These are valid statuses of kuscia job.

type KusciaJobReason 

type KusciaJobReason string
const (
	ValidateFailed   KusciaJobReason = "ValidateFailed"
	CreateTaskFailed KusciaJobReason = "CreateTaskFailed"
)

type KusciaJobScheduleMode 

type KusciaJobScheduleMode string

KusciaJobScheduleMode defines how this job will be scheduled. 

const (
	// KusciaJobScheduleModeStrict means If any non-tolerable subtasks failed, Scheduling for this task stops immediately,
	// and it immediately enters the final Failed state.
	KusciaJobScheduleModeStrict KusciaJobScheduleMode = "Strict"
	// KusciaJobScheduleModeBestEffort means that If nay non-tolerable subtasks failed, Scheduling for this job will continue.
	// But the successor subtask of the failed subtask stops scheduling, and the current state will be running.
	// When all subtasks succeed or fail, the job will enter the Failed state.
	KusciaJobScheduleModeBestEffort KusciaJobScheduleMode = "BestEffort"
)

type KusciaJobSpec 

type KusciaJobSpec struct {
	// FlowID defines the id of flow
	FlowID string `json:"flowID,omitempty"`
	// Initiator who schedule this KusciaJob.
	Initiator string `json:"initiator"`
	// ScheduleMode defines how this job will be scheduled.
	// In Strict, if any non-tolerable subtasks failed, Scheduling for this task stops immediately, and it immediately enters the final Failed state.
	// In BestEffort, if any non-tolerable subtasks failed, Scheduling for this job will continue.
	// But the successor subtask of the failed subtask stops scheduling, and the current state will be running.
	// When all subtasks succeed or fail, the job will enter the Failed state.
	// +optional
	// +kubebuilder:validation:Enum=Strict;BestEffort
	// +kubebuilder:default=Strict
	ScheduleMode KusciaJobScheduleMode `json:"scheduleMode,omitempty"`
	// MaxParallelism max parallelism of tasks, default 1.
	// At a certain moment, there may be multiple subtasks that can be scheduled.
	// this field defines the maximum number of tasks in the Running state.
	// +optional
	// +kubebuilder:default=1
	// +kubebuilder:validation:Minimum=1
	// +kubebuilder:validation:Maximum=128
	MaxParallelism *int `json:"maxParallelism,omitempty"`
	// Tasks defines the subtasks participating in scheduling and their dependencies,
	// and the subtasks and dependencies should constitute a directed acyclic graph.
	// During runtime, each subtask will be created as a KusciaTask.
	// +kubebuilder:validation:MaxItems=128
	// +kubebuilder:validation:MinItems=1
	Tasks []KusciaTaskTemplate `json:"tasks"`
}

KusciaJobSpec defines the information of kuscia job spec.

func (*KusciaJobSpec) DeepCopy 

func (in *KusciaJobSpec) DeepCopy() *KusciaJobSpec

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

func (*KusciaJobSpec) DeepCopyInto 

func (in *KusciaJobSpec) DeepCopyInto(out *KusciaJobSpec)

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

type KusciaJobStatus 

type KusciaJobStatus struct {
	// The phase of a KusciaJob is a simple, high-level summary of
	// where the job is in its lifecycle.
	// +optional
	Phase KusciaJobPhase `json:"phase,omitempty"`

	// job approve status of each party, if job controller is configured with "AutoApproved",
	// the party's approved status will be initiated with "JobAccepted"
	// +optional
	ApproveStatus map[string]JobApprovePhase `json:"approveStatus,omitempty"`

	// job stage status of each party,
	// +optional
	StageStatus map[string]JobStagePhase `json:"stageStatus,omitempty"`

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

	// A brief CamelCase message indicating details about why the job is in this state.
	// +optional
	Reason string `json:"reason,omitempty"`

	// A human-readable message indicating details about why the job is in this condition.
	// +optional
	Message string `json:"message,omitempty"`

	// PartyTaskCreateStatus describes the created status of party task.
	// +optional
	PartyTaskCreateStatus map[string][]PartyTaskCreateStatus `json:"partyTaskCreateStatus,omitempty"`

	// TaskStatus describes subtasks state. The key is taskId.
	// Uncreated subtasks will not appear here.
	// +optional
	TaskStatus map[string]KusciaTaskPhase `json:"taskStatus,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"`

	// Represents last time when the job was reconciled. 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
	LastReconcileTime *metav1.Time `json:"lastReconcileTime,omitempty"`
}

KusciaJobStatus defines the observed state of kuscia job.

func (*KusciaJobStatus) DeepCopy 

func (in *KusciaJobStatus) DeepCopy() *KusciaJobStatus

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

func (*KusciaJobStatus) DeepCopyInto 

func (in *KusciaJobStatus) DeepCopyInto(out *KusciaJobStatus)

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

type KusciaJobSummary 

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

	Spec KusciaJobSummarySpec `json:"spec"`
	// +optional
	Status KusciaJobStatus `json:"status,omitempty"`
}

KusciaJobSummary is used to sync job status between clusters

func (*KusciaJobSummary) DeepCopy 

func (in *KusciaJobSummary) DeepCopy() *KusciaJobSummary

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

func (*KusciaJobSummary) DeepCopyInto 

func (in *KusciaJobSummary) DeepCopyInto(out *KusciaJobSummary)

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

func (*KusciaJobSummary) DeepCopyObject 

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

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

type KusciaJobSummaryList 

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

KusciaJobSummaryList contains a list of kuscia tasks.

func (*KusciaJobSummaryList) DeepCopy 

func (in *KusciaJobSummaryList) DeepCopy() *KusciaJobSummaryList

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

func (*KusciaJobSummaryList) DeepCopyInto 

func (in *KusciaJobSummaryList) DeepCopyInto(out *KusciaJobSummaryList)

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

func (*KusciaJobSummaryList) DeepCopyObject 

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

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

type KusciaJobSummarySpec 

type KusciaJobSummarySpec struct {
	// Stage defines the current situation of a job.
	// +optional
	// +kubebuilder:default=Create
	Stage JobStage `json:"stage,omitempty"`

	// StageTrigger refers to the party who trigger current stage
	// +optional
	StageTrigger string `json:"stageTrigger,omitempty"`
}

func (*KusciaJobSummarySpec) DeepCopy 

func (in *KusciaJobSummarySpec) DeepCopy() *KusciaJobSummarySpec

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

func (*KusciaJobSummarySpec) DeepCopyInto 

func (in *KusciaJobSummarySpec) DeepCopyInto(out *KusciaJobSummarySpec)

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

type KusciaTask 

type KusciaTask struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              KusciaTaskSpec `json:"spec"`
	// +optional
	Status KusciaTaskStatus `json:"status,omitempty"`
}

KusciaTask is the Schema for the namespace kuscia task API.

func (*KusciaTask) DeepCopy 

func (in *KusciaTask) DeepCopy() *KusciaTask

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

func (*KusciaTask) DeepCopyInto 

func (in *KusciaTask) DeepCopyInto(out *KusciaTask)

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

func (*KusciaTask) DeepCopyObject 

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

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

type KusciaTaskCondition 

type KusciaTaskCondition struct {
	// Type of task condition.
	Type KusciaTaskConditionType `json:"type"`
	// Status of the condition, one of True, False, Unknown.
	Status corev1.ConditionStatus `json:"status"`
	// The reason for the condition's last transition.
	// +optional
	Reason string `json:"reason,omitempty"`
	// A human-readable message indicating details about the transition.
	// +optional
	Message string `json:"message,omitempty"`
	// Last time the condition transitioned from one status to another.
	// +optional
	LastTransitionTime *metav1.Time `json:"lastTransitionTime,omitempty"`
}

KusciaTaskCondition describes current state of a kuscia task.

func (*KusciaTaskCondition) DeepCopy 

func (in *KusciaTaskCondition) DeepCopy() *KusciaTaskCondition

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

func (*KusciaTaskCondition) DeepCopyInto 

func (in *KusciaTaskCondition) DeepCopyInto(out *KusciaTaskCondition)

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

type KusciaTaskConditionType 

type KusciaTaskConditionType string

KusciaTaskConditionType is a valid value for a kuscia task condition type. 

const (
	// KusciaTaskCondPortsAllocated means pods have beed allocated.
	KusciaTaskCondPortsAllocated KusciaTaskConditionType = "PortsAllocated"
	// KusciaTaskCondResourceCreated means all sub-resources (e.g. services/pods) of the task has been created.
	KusciaTaskCondResourceCreated KusciaTaskConditionType = "ResourceCreated"
	// KusciaTaskCondRunning means task is running.
	KusciaTaskCondRunning KusciaTaskConditionType = "Running"
	// KusciaTaskCondSuccess means task run success.
	KusciaTaskCondSuccess KusciaTaskConditionType = "Success"
	// KusciaTaskCondStatusSynced represents condition of syncing task status.
	KusciaTaskCondStatusSynced KusciaTaskConditionType = "StatusSynced"
)

These are built-in conditions of kuscia task.

type KusciaTaskCreatePhase 

type KusciaTaskCreatePhase string
const (
	KusciaTaskCreateSucceeded KusciaTaskCreatePhase = "Succeeded"
	KusciaTaskCreateFailed    KusciaTaskCreatePhase = "Failed"
)

type KusciaTaskList 

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

KusciaTaskList contains a list of kuscia tasks.

func (*KusciaTaskList) DeepCopy 

func (in *KusciaTaskList) DeepCopy() *KusciaTaskList

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

func (*KusciaTaskList) DeepCopyInto 

func (in *KusciaTaskList) DeepCopyInto(out *KusciaTaskList)

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

func (*KusciaTaskList) DeepCopyObject 

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

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

type KusciaTaskPhase 

type KusciaTaskPhase string

KusciaTaskPhase is a label for the condition of a kuscia task at the current time. 

const (
	// TaskPending means the task has been accepted by the controller,
	// but some initialization work has not yet been completed.
	TaskPending KusciaTaskPhase = "Pending"

	// TaskRunning means all sub-resources (e.g. services/pods) of this task
	// have been successfully scheduled and launched.
	TaskRunning KusciaTaskPhase = "Running"

	// TaskSucceeded means all sub-resources (e.g. services/pods) of this task
	// reached phase have terminated in success.
	TaskSucceeded KusciaTaskPhase = "Succeeded"

	// TaskFailed means one or more sub-resources (e.g. services/pods) of this task
	// reached phase failed with no restarting.
	TaskFailed KusciaTaskPhase = "Failed"
)

These are valid statuses of kuscia task.

type KusciaTaskSpec 

type KusciaTaskSpec struct {
	Initiator       string `json:"initiator"`
	TaskInputConfig string `json:"taskInputConfig"`
	// +optional
	ScheduleConfig ScheduleConfig `json:"scheduleConfig,omitempty"`
	Parties        []PartyInfo    `json:"parties"`
}

KusciaTaskSpec defines the information of kuscia task spec.

func (*KusciaTaskSpec) DeepCopy 

func (in *KusciaTaskSpec) DeepCopy() *KusciaTaskSpec

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

func (*KusciaTaskSpec) DeepCopyInto 

func (in *KusciaTaskSpec) DeepCopyInto(out *KusciaTaskSpec)

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

type KusciaTaskStatus 

type KusciaTaskStatus struct {
	// The phase of a KusciaTask is a simple, high-level summary of
	// where the task is in its lifecycle.
	// +optional
	Phase KusciaTaskPhase `json:"phase,omitempty"`

	// The progress of a KusciaTask is the percentage of a task's progress
	// when it is in phase of TaskRunning.
	// +optional
	Progress float32 `json:"progress,omitempty"`

	// PartyTaskStatus defines task status for all party.
	// +optional
	PartyTaskStatus []PartyTaskStatus `json:"partyTaskStatus,omitempty"`

	// A brief CamelCase message indicating details about why the task is in this state.
	// +optional
	Reason string `json:"reason,omitempty"`

	// A human-readable message indicating details about why the task is in this condition.
	// +optional
	Message string `json:"message,omitempty"`

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

	// PodStatuses is map of ns/name and PodStatus,
	// specifies the status of each pod.
	// +optional
	PodStatuses map[string]*PodStatus `json:"podStatuses,omitempty"`

	// ServiceStatuses is map of ns/name and ServiceStatus,
	// specifies the status of each service.
	// +optional
	ServiceStatuses map[string]*ServiceStatus `json:"serviceStatuses,omitempty"`

	// AllocatedPorts defines the allocated ports to all parties.
	// +optional
	AllocatedPorts []PartyAllocatedPorts `json:"allocatedPorts,omitempty"`

	// Represents time when the task was acknowledged by the task 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 task 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"`

	// Represents last time when the task was reconciled. 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
	LastReconcileTime *metav1.Time `json:"lastReconcileTime,omitempty"`
}

KusciaTaskStatus defines the observed state of kuscia task.

func (*KusciaTaskStatus) DeepCopy 

func (in *KusciaTaskStatus) DeepCopy() *KusciaTaskStatus

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

func (*KusciaTaskStatus) DeepCopyInto 

func (in *KusciaTaskStatus) DeepCopyInto(out *KusciaTaskStatus)

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

type KusciaTaskSummary 

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

	Spec KusciaTaskSummarySpec `json:"spec"`

	// +optional
	Status KusciaTaskSummaryStatus `json:"status,omitempty"`
}

KusciaTaskSummary is used to sync task status between clusters

func (*KusciaTaskSummary) DeepCopy 

func (in *KusciaTaskSummary) DeepCopy() *KusciaTaskSummary

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

func (*KusciaTaskSummary) DeepCopyInto 

func (in *KusciaTaskSummary) DeepCopyInto(out *KusciaTaskSummary)

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

func (*KusciaTaskSummary) DeepCopyObject 

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

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

type KusciaTaskSummaryList 

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

KusciaTaskSummaryList contains a list of kuscia tasks.

func (*KusciaTaskSummaryList) DeepCopy 

func (in *KusciaTaskSummaryList) DeepCopy() *KusciaTaskSummaryList

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

func (*KusciaTaskSummaryList) DeepCopyInto 

func (in *KusciaTaskSummaryList) DeepCopyInto(out *KusciaTaskSummaryList)

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

func (*KusciaTaskSummaryList) DeepCopyObject 

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

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

type KusciaTaskSummarySpec 

type KusciaTaskSummarySpec struct {
	Alias string `json:"alias"`
	JobID string `json:"jobID"`
}

KusciaTaskSummarySpec defines the information of kuscia task spec.

func (*KusciaTaskSummarySpec) DeepCopy 

func (in *KusciaTaskSummarySpec) DeepCopy() *KusciaTaskSummarySpec

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

func (*KusciaTaskSummarySpec) DeepCopyInto 

func (in *KusciaTaskSummarySpec) DeepCopyInto(out *KusciaTaskSummarySpec)

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

type KusciaTaskSummaryStatus 

type KusciaTaskSummaryStatus struct {
	KusciaTaskStatus `json:",inline"`

	// resourceStatus refers to each party resource status
	// +optional
	ResourceStatus map[string][]*TaskSummaryResourceStatus `json:"resourceStatus,omitempty"`
}

func (*KusciaTaskSummaryStatus) DeepCopy 

func (in *KusciaTaskSummaryStatus) DeepCopy() *KusciaTaskSummaryStatus

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

func (*KusciaTaskSummaryStatus) DeepCopyInto 

func (in *KusciaTaskSummaryStatus) DeepCopyInto(out *KusciaTaskSummaryStatus)

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

type KusciaTaskTemplate 

type KusciaTaskTemplate struct {
	// Alias represents KusciaTask alias.
	Alias string `json:"alias"`
	// TaskID represents KusciaTask id, it should match rfc1123 DNS_LABEL pattern.
	// It will be used in Dependencies.
	// +optional
	// +kubebuilder:validation:Pattern=[a-z0-9]([-a-z0-9]*[a-z0-9])?
	TaskID string `json:"taskID,omitempty"`
	// Dependencies defines the dependencies of this subtask.
	// Only when the dependencies of this subtask are all in the Succeeded state, this subtask can be scheduled.
	// +kubebuilder:validation:MaxItems=128
	// +kubebuilder:validation:MinItems=1
	// +optional
	Dependencies []string `json:"dependencies,omitempty"`
	// Tolerable default false. If this sub-task failed, job will not be failed.
	// tolerable sub-task can not be other sub-tasks dependencies.
	// +kubebuilder:default=false
	// +optional
	Tolerable *bool `json:"tolerable,omitempty"`
	// AppImage defines image be used in KusciaTask
	AppImage string `json:"appImage"`
	// TaskInputConfig defines input config for KusciaTask.
	TaskInputConfig string `json:"taskInputConfig"`
	// ScheduleConfig defines the schedule config for KusciaTask.
	// +optional
	ScheduleConfig *ScheduleConfig `json:"scheduleConfig,omitempty"`
	// Priority defines priority of ready subtask.
	// When multiple subtasks are ready, which one is scheduled first.
	// The larger the value of this field, the higher the priority.
	// +optional
	Priority int `json:"priority,omitempty"`
	// Parties defines participants and role in this KusciaTask
	Parties []Party `json:"parties"`
}

func (*KusciaTaskTemplate) DeepCopy 

func (in *KusciaTaskTemplate) DeepCopy() *KusciaTaskTemplate

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

func (*KusciaTaskTemplate) DeepCopyInto 

func (in *KusciaTaskTemplate) DeepCopyInto(out *KusciaTaskTemplate)

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

type MetricProbe 

type MetricProbe struct {
	Path string `json:"path,omitempty"`
	Port string `json:"port,omitempty"`
}

type NetworkPolicy 

type NetworkPolicy struct {
	Ingresses []Ingress `json:"ingresses"`
}

NetworkPolicy defines the network policy.

func (*NetworkPolicy) DeepCopy 

func (in *NetworkPolicy) DeepCopy() *NetworkPolicy

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

func (*NetworkPolicy) DeepCopyInto 

func (in *NetworkPolicy) DeepCopyInto(out *NetworkPolicy)

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

type NodeStatus 

type NodeStatus struct {
	Name    string `json:"name"`
	Version string `json:"version"`
	Status  string `json:"status"`
	// +optional
	LastHeartbeatTime metav1.Time `json:"lastHeartbeatTime,omitempty"`
	// +optional
	LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"`
}

NodeStatus defines node status under domain.

func (*NodeStatus) DeepCopy 

func (in *NodeStatus) DeepCopy() *NodeStatus

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

func (*NodeStatus) DeepCopyInto 

func (in *NodeStatus) DeepCopyInto(out *NodeStatus)

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

type Partition 

type Partition struct {
	// enum path, odps
	Type string `json:"type"`
	// +optional
	Fields []DataColumn `json:"fields"`
}

func (*Partition) DeepCopy 

func (in *Partition) DeepCopy() *Partition

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

func (*Partition) DeepCopyInto 

func (in *Partition) DeepCopyInto(out *Partition)

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

type Party 

type Party struct {
	DomainID string `json:"domainID"`
	// +optional
	Role string `json:"role,omitempty"`
	// +optional
	Resources *corev1.ResourceRequirements `json:"resources,omitempty"`
	// +optional
	BandwidthLimit []BandwidthLimit `json:"bandwidthLimits,omitempty"`
}

func (*Party) DeepCopy 

func (in *Party) DeepCopy() *Party

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

func (*Party) DeepCopyInto 

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

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

type PartyAllocatedPorts 

type PartyAllocatedPorts struct {
	DomainID string `json:"domainID"`
	// +optional
	Role string `json:"role,omitempty"`
	// +optional
	NamedPort map[string]int32 `json:"namedPort,omitempty"`
}

PartyAllocatedPorts defines the ports allocated to the party.

func (*PartyAllocatedPorts) DeepCopy 

func (in *PartyAllocatedPorts) DeepCopy() *PartyAllocatedPorts

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

func (*PartyAllocatedPorts) DeepCopyInto 

func (in *PartyAllocatedPorts) DeepCopyInto(out *PartyAllocatedPorts)

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

type PartyInfo 

type PartyInfo struct {
	DomainID    string `json:"domainID"`
	AppImageRef string `json:"appImageRef"`
	// +optional
	Role string `json:"role,omitempty"`
	// +optional
	MinReservedPods int `json:"minReservedPods,omitempty"`
	// +optional
	Template PartyTemplate `json:"template,omitempty"`
	// +optional
	BandwidthLimit []BandwidthLimit `json:"bandwidthLimits,omitempty"`
}

PartyInfo defines the basic party info.

func (*PartyInfo) DeepCopy 

func (in *PartyInfo) DeepCopy() *PartyInfo

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

func (*PartyInfo) DeepCopyInto 

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

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

type PartyTaskCreateStatus 

type PartyTaskCreateStatus struct {
	DomainID string `json:"domainID"`
	// +optional
	Role string `json:"role,omitempty"`
	// +optional
	Phase KusciaTaskCreatePhase `json:"phase,omitempty"`
	// +optional
	Message string `json:"message,omitempty"`
}

PartyTaskCreateStatus defines party task create status.

func (*PartyTaskCreateStatus) DeepCopy 

func (in *PartyTaskCreateStatus) DeepCopy() *PartyTaskCreateStatus

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

func (*PartyTaskCreateStatus) DeepCopyInto 

func (in *PartyTaskCreateStatus) DeepCopyInto(out *PartyTaskCreateStatus)

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

type PartyTaskStatus 

type PartyTaskStatus struct {
	DomainID string `json:"domainID"`
	// +optional
	Role string `json:"role,omitempty"`
	// +optional
	Phase KusciaTaskPhase `json:"phase,omitempty"`
	// +optional
	Message string `json:"message,omitempty"`
}

PartyTaskStatus defines party task status.

func (*PartyTaskStatus) DeepCopy 

func (in *PartyTaskStatus) DeepCopy() *PartyTaskStatus

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

func (*PartyTaskStatus) DeepCopyInto 

func (in *PartyTaskStatus) DeepCopyInto(out *PartyTaskStatus)

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

type PartyTemplate 

type PartyTemplate struct {
	// +optional
	Replicas *int32 `json:"replicas,omitempty"`
	// +optional
	Spec PodSpec `json:"spec,omitempty"`
}

PartyTemplate defines the specific info for party.

func (*PartyTemplate) DeepCopy 

func (in *PartyTemplate) DeepCopy() *PartyTemplate

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

func (*PartyTemplate) DeepCopyInto 

func (in *PartyTemplate) DeepCopyInto(out *PartyTemplate)

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

type PodSpec 

type PodSpec struct {
	// Restart policy for all containers within the pod.
	// One of Always, OnFailure, Never.
	// Default to Never.
	// More info: https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle/#restart-policy
	// +optional
	RestartPolicy corev1.RestartPolicy `json:"restartPolicy,omitempty"`
	// +optional
	Containers []Container `json:"containers,omitempty"`
	// If specified, the pod's scheduling constraints
	// +optional
	Affinity *corev1.Affinity `json:"affinity,omitempty"`
}

PodSpec defines the spec info of pod.

func (*PodSpec) DeepCopy 

func (in *PodSpec) DeepCopy() *PodSpec

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

func (*PodSpec) DeepCopyInto 

func (in *PodSpec) DeepCopyInto(out *PodSpec)

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

type PodStatus 

type PodStatus struct {
	// Pod name.
	PodName string `json:"podName"`
	// The phase of a Pod is a simple, high-level summary of where the Pod is in its lifecycle.
	PodPhase corev1.PodPhase `json:"podPhase"`
	// Pod's namespace.
	Namespace string `json:"namespace"`
	// Pod's node name.
	// +optional
	NodeName string `json:"nodeName,omitempty"`
	// A human-readable message indicating details about why the pod is in this condition.
	// +optional
	Message string `json:"message,omitempty"`
	// The latest stdout/stderr message if app exit fail.
	TerminationLog string `json:"terminationLog,omitempty"`
	// A brief CamelCase message indicating details about why the pod is in this state.
	// e.g. 'Evicted'
	// +optional
	Reason string `json:"reason,omitempty"`

	// Represents time when the pod was created.
	// It is represented in RFC3339 form and is in UTC.
	// +optional
	CreateTime *metav1.Time `json:"createTime,omitempty"`

	// Represents time when the pod was scheduled.
	// It is represented in RFC3339 form and is in UTC.
	// +optional
	ScheduleTime *metav1.Time `json:"scheduleTime,omitempty"`

	// Represents time when the pod was accepted by the agent.
	// It is represented in RFC3339 form and is in UTC.
	// +optional
	StartTime *metav1.Time `json:"startTime,omitempty"`

	// Represents time when the pod was ready.
	// It is represented in RFC3339 form and is in UTC.
	// +optional
	ReadyTime *metav1.Time `json:"readyTime,omitempty"`
}

PodStatus describes pod status.

func (*PodStatus) DeepCopy 

func (in *PodStatus) DeepCopy() *PodStatus

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

func (*PodStatus) DeepCopyInto 

func (in *PodStatus) DeepCopyInto(out *PodStatus)

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

type PortProtocol 

type PortProtocol string

PortProtocol defines the network protocols. 

const (
	// ProtocolHTTP is the HTTP protocol.
	ProtocolHTTP PortProtocol = "HTTP"
	// ProtocolGRPC is the GRPC protocol.
	ProtocolGRPC PortProtocol = "GRPC"
)

type PortScope 

type PortScope string

PortScope defines the port usage scope. 

const (
	// ScopeCluster allows to access inside and outside the cluster.
	ScopeCluster PortScope = "Cluster"
	// ScopeDomain allows to access inside the cluster.
	ScopeDomain PortScope = "Domain"
	// ScopeLocal allows to access inside the pod containers.
	ScopeLocal PortScope = "Local"
)

type ScheduleConfig 

type ScheduleConfig struct {
	// +kubebuilder:validation:Minimum:=1
	// +optional
	MinReservedMembers int `json:"minReservedMembers,omitempty"`
	// +optional
	ResourceReservedSeconds int `json:"resourceReservedSeconds,omitempty"`
	// +optional
	LifecycleSeconds int `json:"lifecycleSeconds,omitempty"`
	// +optional
	RetryIntervalSeconds int `json:"retryIntervalSeconds,omitempty"`
}

ScheduleConfig defines the config for scheduling.

func (*ScheduleConfig) DeepCopy 

func (in *ScheduleConfig) DeepCopy() *ScheduleConfig

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

func (*ScheduleConfig) DeepCopyInto 

func (in *ScheduleConfig) DeepCopyInto(out *ScheduleConfig)

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

type SchedulerPluginArgs 

type SchedulerPluginArgs struct {
	// ResourceReservedSeconds is the waiting timeout in seconds.
	// +optional
	ResourceReservedSeconds int `json:"resourceReservedSeconds,omitempty"`
}

SchedulerPluginArgs defines the parameters for scheduler plugin.

func (*SchedulerPluginArgs) DeepCopy 

func (in *SchedulerPluginArgs) DeepCopy() *SchedulerPluginArgs

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

func (*SchedulerPluginArgs) DeepCopyInto 

func (in *SchedulerPluginArgs) DeepCopyInto(out *SchedulerPluginArgs)

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

type ServiceStatus 

type ServiceStatus struct {
	// Service's namespace.
	Namespace string `json:"namespace"`
	// Service name.
	ServiceName string `json:"serviceName"`
	// Service's port name which defined in AppImage container port.
	// +optional
	PortName string `json:"portName,omitempty"`
	// Service's port number which defined in AppImage container port.
	// +optional
	PortNumber int32 `json:"portNumber,omitempty"`
	// Service's port scope which defined in AppImage container port.
	// +optional
	Scope PortScope `json:"scope,omitempty"`
	// A brief CamelCase message indicating details about why the service is in this state.
	// e.g. 'Evicted'
	// +optional
	Reason string `json:"reason,omitempty"`
	// A human-readable message indicating details about why the service is in this condition.
	// +optional
	Message string `json:"message,omitempty"`
	// Represents time when the service was created.
	// It is represented in RFC3339 form and is in UTC.
	// +optional
	CreateTime *metav1.Time `json:"createTime,omitempty"`

	// Represents time when the service was ready.
	// It is represented in RFC3339 form and is in UTC.
	// +optional
	ReadyTime *metav1.Time `json:"readyTime,omitempty"`
}

ServiceStatus describes service status.

func (*ServiceStatus) DeepCopy 

func (in *ServiceStatus) DeepCopy() *ServiceStatus

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

func (*ServiceStatus) DeepCopyInto 

func (in *ServiceStatus) DeepCopyInto(out *ServiceStatus)

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

type TaskResource 

type TaskResource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              TaskResourceSpec `json:"spec"`
	// +optional
	Status TaskResourceStatus `json:"status,omitempty"`
}

TaskResource is the Schema for the task resource API.

func (*TaskResource) DeepCopy 

func (in *TaskResource) DeepCopy() *TaskResource

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

func (*TaskResource) DeepCopyInto 

func (in *TaskResource) DeepCopyInto(out *TaskResource)

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

func (*TaskResource) DeepCopyObject 

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

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

type TaskResourceCondition 

type TaskResourceCondition struct {
	LastTransitionTime *metav1.Time           `json:"lastTransitionTime,omitempty"`
	Status             corev1.ConditionStatus `json:"status"`
	// +optional
	Reason string                    `json:"reason,omitempty"`
	Type   TaskResourceConditionType `json:"type"`
}

TaskResourceCondition defines the details of task resource condition.

func (*TaskResourceCondition) DeepCopy 

func (in *TaskResourceCondition) DeepCopy() *TaskResourceCondition

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

func (*TaskResourceCondition) DeepCopyInto 

func (in *TaskResourceCondition) DeepCopyInto(out *TaskResourceCondition)

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

type TaskResourceConditionType 

type TaskResourceConditionType string

TaskResourceConditionType is a valid value for a task resource condition type. 

const (
	TaskResourceCondPending     TaskResourceConditionType = "Pending"
	TaskResourceCondReserving   TaskResourceConditionType = "Reserving"
	TaskResourceCondFailed      TaskResourceConditionType = "Failed"
	TaskResourceCondReserved    TaskResourceConditionType = "Reserved"
	TaskResourceCondSchedulable TaskResourceConditionType = "Schedulable"
)

type TaskResourceGroup 

type TaskResourceGroup struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              TaskResourceGroupSpec `json:"spec"`
	// +optional
	Status TaskResourceGroupStatus `json:"status,omitempty"`
}

TaskResourceGroup is the Schema for the task resource group API.

func (*TaskResourceGroup) DeepCopy 

func (in *TaskResourceGroup) DeepCopy() *TaskResourceGroup

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

func (*TaskResourceGroup) DeepCopyInto 

func (in *TaskResourceGroup) DeepCopyInto(out *TaskResourceGroup)

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

func (*TaskResourceGroup) DeepCopyObject 

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

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

type TaskResourceGroupCondition 

type TaskResourceGroupCondition struct {
	LastTransitionTime *metav1.Time           `json:"lastTransitionTime,omitempty"`
	Status             corev1.ConditionStatus `json:"status"`
	// +optional
	Reason string                         `json:"reason,omitempty"`
	Type   TaskResourceGroupConditionType `json:"type"`
}

TaskResourceGroupCondition defines the details of task resource group condition.

func (*TaskResourceGroupCondition) DeepCopy 

func (in *TaskResourceGroupCondition) DeepCopy() *TaskResourceGroupCondition

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

func (*TaskResourceGroupCondition) DeepCopyInto 

func (in *TaskResourceGroupCondition) DeepCopyInto(out *TaskResourceGroupCondition)

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

type TaskResourceGroupConditionType 

type TaskResourceGroupConditionType string

TaskResourceGroupConditionType is a valid value for a task resource group condition type. 

const (
	TaskResourceGroupValidated TaskResourceGroupConditionType = "TaskResourceGroupValidated"
	TaskResourceNameGenerated  TaskResourceGroupConditionType = "TaskResourceNameGenerated"
	TaskResourcesCreated       TaskResourceGroupConditionType = "TaskResourcesCreated"
	PodAnnotationUpdated       TaskResourceGroupConditionType = "PodAnnotationUpdated"
	TaskResourcesListed        TaskResourceGroupConditionType = "TaskResourcesListed"
	TaskResourcesReserved      TaskResourceGroupConditionType = "TaskResourcesReserved"
	TaskResourceGroupExpired   TaskResourceGroupConditionType = "TaskResourceGroupExpired"
	TaskResourcesScheduled     TaskResourceGroupConditionType = "TaskResourcesScheduled"
	TaskResourceGroupFailed    TaskResourceGroupConditionType = "TaskResourceGroupFailed"
	DependentTaskFailed        TaskResourceGroupConditionType = "DependentTaskFailed"
)

type TaskResourceGroupList 

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

TaskResourceGroupList contains a list of TaskResourceGroup.

func (*TaskResourceGroupList) DeepCopy 

func (in *TaskResourceGroupList) DeepCopy() *TaskResourceGroupList

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

func (*TaskResourceGroupList) DeepCopyInto 

func (in *TaskResourceGroupList) DeepCopyInto(out *TaskResourceGroupList)

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

func (*TaskResourceGroupList) DeepCopyObject 

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

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

type TaskResourceGroupParty 

type TaskResourceGroupParty struct {
	// +optional
	Role     string `json:"role,omitempty"`
	DomainID string `json:"domainID"`
	// +optional
	MinReservedPods int `json:"minReservedPods,omitempty"`
	// +optional
	Pods []TaskResourceGroupPartyPod `json:"pods,omitempty"`
	// +optional
	TaskResourceName string `json:"taskResourceName,omitempty"`
}

TaskResourceGroupParty defines the details of task resource group party.

func (*TaskResourceGroupParty) DeepCopy 

func (in *TaskResourceGroupParty) DeepCopy() *TaskResourceGroupParty

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

func (*TaskResourceGroupParty) DeepCopyInto 

func (in *TaskResourceGroupParty) DeepCopyInto(out *TaskResourceGroupParty)

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

type TaskResourceGroupPartyPod 

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

TaskResourceGroupPartyPod defines the details of task resource group party pod.

func (*TaskResourceGroupPartyPod) DeepCopy 

func (in *TaskResourceGroupPartyPod) DeepCopy() *TaskResourceGroupPartyPod

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

func (*TaskResourceGroupPartyPod) DeepCopyInto 

func (in *TaskResourceGroupPartyPod) DeepCopyInto(out *TaskResourceGroupPartyPod)

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

type TaskResourceGroupPhase 

type TaskResourceGroupPhase string

TaskResourceGroupPhase is a label for the condition of a task resource group at the current time. 

const (
	// TaskResourceGroupPhasePending means TaskResourceGroup resource is created.
	TaskResourceGroupPhasePending TaskResourceGroupPhase = "Pending"
	// TaskResourceGroupPhaseCreating means create TaskResource.
	TaskResourceGroupPhaseCreating TaskResourceGroupPhase = "Creating"
	// TaskResourceGroupPhaseReserving means resources are reserving by parties.
	TaskResourceGroupPhaseReserving TaskResourceGroupPhase = "Reserving"
	// TaskResourceGroupPhaseReserved means resources are reserved by parties.
	TaskResourceGroupPhaseReserved TaskResourceGroupPhase = "Reserved"
	// TaskResourceGroupPhaseReserveFailed means parties which successfully reserved resources do not meet the minimum reserved count.
	TaskResourceGroupPhaseReserveFailed TaskResourceGroupPhase = "ReserveFailed"
	// TaskResourceGroupPhaseFailed means no resources are reserved in the whole task resource group life cycle
	TaskResourceGroupPhaseFailed TaskResourceGroupPhase = "Failed"
)

type TaskResourceGroupSpec 

type TaskResourceGroupSpec struct {
	// MinReservedMembers represents the number of minimum reserved resource parties.
	// This field is used for parties level co-scheduling.
	// +kubebuilder:validation:Minimum:=1
	MinReservedMembers int `json:"minReservedMembers"`
	// ResourceReservedSeconds represents resource reserved time.
	// This field is used for the waiting time after the scheduler has reserved resources.
	// +optional
	ResourceReservedSeconds int `json:"resourceReservedSeconds,omitempty"`
	// RetryIntervalSeconds represents retry waiting time for next scheduling.
	// +optional
	RetryIntervalSeconds int `json:"retryIntervalSeconds,omitempty"`
	// LifecycleSeconds represents task resource group lifecycle.
	// If the task has not been scheduled successfully in the lifecycle, the task resource group is set to failed.
	// +optional
	LifecycleSeconds int `json:"lifecycleSeconds,omitempty"`
	// Initiator represents who initiated the task.
	Initiator string `json:"initiator"`
	// Parties represents the parties' whose task resource is controlled by self cluster.
	Parties []TaskResourceGroupParty `json:"parties,omitempty"`
	// Out Of Controlled Parties, namely all partner parties in participant cluster
	OutOfControlledParties []TaskResourceGroupParty `json:"outOfControlledParties,omitempty"`
}

TaskResourceGroupSpec defines the details of TaskResourceGroup.

func (*TaskResourceGroupSpec) DeepCopy 

func (in *TaskResourceGroupSpec) DeepCopy() *TaskResourceGroupSpec

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

func (*TaskResourceGroupSpec) DeepCopyInto 

func (in *TaskResourceGroupSpec) DeepCopyInto(out *TaskResourceGroupSpec)

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

type TaskResourceGroupStatus 

type TaskResourceGroupStatus struct {
	Phase TaskResourceGroupPhase `json:"phase"`
	// +optional
	RetryCount int `json:"retryCount,omitempty"`
	// +optional
	Conditions []TaskResourceGroupCondition `json:"conditions,omitempty"`
	// +optional
	StartTime *metav1.Time `json:"startTime,omitempty"`
	// +optional
	CompletionTime *metav1.Time `json:"completionTime,omitempty"`
	// +optional
	LastTransitionTime *metav1.Time `json:"lastTransitionTime,omitempty"`
}

TaskResourceGroupStatus defines the details of task group resource status.

func (*TaskResourceGroupStatus) DeepCopy 

func (in *TaskResourceGroupStatus) DeepCopy() *TaskResourceGroupStatus

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

func (*TaskResourceGroupStatus) DeepCopyInto 

func (in *TaskResourceGroupStatus) DeepCopyInto(out *TaskResourceGroupStatus)

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

type TaskResourceList 

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

TaskResourceList contains a list of TaskResource.

func (*TaskResourceList) DeepCopy 

func (in *TaskResourceList) DeepCopy() *TaskResourceList

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

func (*TaskResourceList) DeepCopyInto 

func (in *TaskResourceList) DeepCopyInto(out *TaskResourceList)

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

func (*TaskResourceList) DeepCopyObject 

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

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

type TaskResourcePhase 

type TaskResourcePhase string

TaskResourcePhase is a label for the condition of a task resource at the current time. 

const (
	// TaskResourcePhasePending means task resource is created.
	TaskResourcePhasePending TaskResourcePhase = "Pending"
	// TaskResourcePhaseReserving means resources are reserving.
	TaskResourcePhaseReserving TaskResourcePhase = "Reserving"
	// TaskResourcePhaseReserved means resources are reserved.
	TaskResourcePhaseReserved TaskResourcePhase = "Reserved"
	// TaskResourcePhaseSchedulable means pod related to the task resource can continue the subsequent scheduling process.
	TaskResourcePhaseSchedulable TaskResourcePhase = "Schedulable"
	// TaskResourcePhaseFailed means resources are reserved failed or task failed.
	TaskResourcePhaseFailed TaskResourcePhase = "Failed"
)

type TaskResourcePod 

type TaskResourcePod struct {
	Name string `json:"name"`
	// +optional
	Resources corev1.ResourceRequirements `json:"resources,omitempty"`
}

TaskResourcePod defines the details of task resource pod info.

func (*TaskResourcePod) DeepCopy 

func (in *TaskResourcePod) DeepCopy() *TaskResourcePod

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

func (*TaskResourcePod) DeepCopyInto 

func (in *TaskResourcePod) DeepCopyInto(out *TaskResourcePod)

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

type TaskResourceSpec 

type TaskResourceSpec struct {
	// +optional
	Role string `json:"role,omitempty"`
	// +kubebuilder:validation:Minimum:=1
	MinReservedPods int `json:"minReservedPods"`
	// +optional
	ResourceReservedSeconds int `json:"resourceReservedSeconds,omitempty"`
	// +optional
	Initiator string `json:"initiator,omitempty"`
	// +optional
	Pods []TaskResourcePod `json:"pods,omitempty"`
}

TaskResourceSpec defines the details of TaskResource.

func (*TaskResourceSpec) DeepCopy 

func (in *TaskResourceSpec) DeepCopy() *TaskResourceSpec

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

func (*TaskResourceSpec) DeepCopyInto 

func (in *TaskResourceSpec) DeepCopyInto(out *TaskResourceSpec)

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

type TaskResourceStatus 

type TaskResourceStatus struct {
	Phase TaskResourcePhase `json:"phase"`
	// +optional
	Conditions []TaskResourceCondition `json:"conditions,omitempty"`
	// +optional
	StartTime *metav1.Time `json:"startTime,omitempty"`
	// +optional
	CompletionTime *metav1.Time `json:"completionTime,omitempty"`
	// +optional
	LastTransitionTime *metav1.Time `json:"lastTransitionTime,omitempty"`
}

TaskResourceStatus defines the details of task resource status.

func (*TaskResourceStatus) DeepCopy 

func (in *TaskResourceStatus) DeepCopy() *TaskResourceStatus

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

func (*TaskResourceStatus) DeepCopyInto 

func (in *TaskResourceStatus) DeepCopyInto(out *TaskResourceStatus)

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

type TaskSummaryResourceStatus 

type TaskSummaryResourceStatus struct {
	// +optional
	Role string `json:"role,omitempty"`
	// +optional
	HostTaskResourceName string `json:"hostTaskResourceName,omitempty"`
	// +optional
	HostTaskResourceVersion string `json:"hostTaskResourceVersion,omitempty"`
	// +optional
	MemberTaskResourceName string `json:"memberTaskResourceName,omitempty"`
	// +optional
	MemberTaskResourceVersion string `json:"memberTaskResourceVersion,omitempty"`
	TaskResourceStatus        `json:",inline"`
}

func (*TaskSummaryResourceStatus) DeepCopy 

func (in *TaskSummaryResourceStatus) DeepCopy() *TaskSummaryResourceStatus

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

func (*TaskSummaryResourceStatus) DeepCopyInto 

func (in *TaskSummaryResourceStatus) DeepCopyInto(out *TaskSummaryResourceStatus)

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

type TokenConfig 

type TokenConfig struct {
	// Source namespace RSA public key, must be base64 encoded.
	// +optional
	SourcePublicKey string `json:"sourcePublicKey,omitempty"`
	// Destination namespace RSA public key, must be base64 encoded.
	// +optional
	DestinationPublicKey string `json:"destinationPublicKey,omitempty"`
	// Token periodic rolling update interval in seconds, 0 means no update.
	// It is recommended that this value not be less than 300,
	// otherwise the controller may have problems processing it.
	// +kubebuilder:validation:Minimum=0
	// +optional
	RollingUpdatePeriod int `json:"rollingUpdatePeriod"`
	// Token generation method.
	// +kubebuilder:validation:Enum=RSA-GEN;UID-RSA-GEN
	TokenGenMethod TokenGenMethodType `json:"tokenGenMethod"`
}

TokenConfig is used to realize authentication by negotiating token.

func (*TokenConfig) DeepCopy 

func (in *TokenConfig) DeepCopy() *TokenConfig

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

func (*TokenConfig) DeepCopyInto 

func (in *TokenConfig) DeepCopyInto(out *TokenConfig)

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

type TokenGenMethodType 

type TokenGenMethodType string

TokenGenMethodType defines he method type for generating token.

type Transit 

type Transit struct {
	// TransitMethod means to forward the request through a specific entity, THIRD-DOMAIN by default.
	// +kubebuilder:validation:Enum=THIRD-DOMAIN;REVERSE-TUNNEL
	// +optional
	TransitMethod TransitMethodType `json:"transitMethod"`
	// DomainTransit defines the information of the third domain.
	// +optional
	Domain *DomainTransit `json:"domain,omitempty"`
}

Transit defines the information of the transit entity used to forward the request.

func (*Transit) DeepCopy 

func (in *Transit) DeepCopy() *Transit

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

func (*Transit) DeepCopyInto 

func (in *Transit) DeepCopyInto(out *Transit)

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

type TransitMethodType 

type TransitMethodType string
const (
	// TransitMethodThirdDomain means to forward the request through the third domain.
	TransitMethodThirdDomain TransitMethodType = "THIRD-DOMAIN"
	// TransitMethodReverseTunnel means to forward the request through reverse tunneling between envoys.
	TransitMethodReverseTunnel TransitMethodType = "REVERSE-TUNNEL"
)

type UseRecord 

type UseRecord struct {
	UseTime     metav1.Time `json:"use_time"`
	GrantDomain string      `json:"grant_domain"`
	// +optional
	Component string `json:"componet,omitempty"`
	// +optional
	Output string `json:"output,omitempty"`
}

func (*UseRecord) DeepCopy 

func (in *UseRecord) DeepCopy() *UseRecord

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

func (*UseRecord) DeepCopyInto 

func (in *UseRecord) DeepCopyInto(out *UseRecord)

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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