v1alpha1

package
v0.16.2 Latest Latest
Warning

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

 Go to latest Published: Dec 4, 2025 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Overview

+k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:conversion-gen=github.com/streamnative/pulsar-resources-operator/pkg/streamnativecloud/apis/compute +k8s:defaulter-gen=TypeMeta +k8s:protobuf-gen=package +groupName=compute.streamnative.io

Index

Constants

View Source 
const (
	ConditionTypeReady ConditionType = "Ready"

	ConditionReasonReady    ConditionReason = "Ready"
	ConditionReasonNotReady ConditionReason = "NotReady"
)
View Source 
const (
	VvpDeploymentStatusStateRunning       VvpDeploymentStatusState = "RUNNING"
	VvpDeploymentStatusStateSuspended     VvpDeploymentStatusState = "SUSPENDED"
	VvpDeploymentStatusStateCancelled     VvpDeploymentStatusState = "CANCELLED"
	VvpDeploymentStatusStateTransitioning VvpDeploymentStatusState = "TRANSITIONING"
	VvpDeploymentStatusStateFailed        VvpDeploymentStatusState = "FAILED"
	VvpDeploymentStatusStateFinished      VvpDeploymentStatusState = "FINISHED"

	VvpDeploymentCustomResourceStateSyncing                     VvpDeploymentCustomResourceState = "SYNCING"
	VvpDeploymentCustomResourceStateIdling                      VvpDeploymentCustomResourceState = "IDLING"
	VvpDeploymentCustomResourceStateDeleting                    VvpDeploymentCustomResourceState = "DELETING"
	VvpDeploymentCustomResourceStateRefEntityManagedByAnotherCr VvpDeploymentCustomResourceState = "REF_ENTITY_MANAGED_BY_ANOTHER_CR"
	VvpDeploymentCustomResourceStateSyncingModeInconsistent     VvpDeploymentCustomResourceState = "SYNCING_MODE_INCONSISTENT"
	VvpDeploymentCustomResourceStateRefNamespaceUnavailable     VvpDeploymentCustomResourceState = "REF_NAMESPACE_UNAVAILABLE"
	VvpDeploymentCustomResourceStateConcurrentReconciliation    VvpDeploymentCustomResourceState = "CONCURRENT_RECONCILIATION"
	VvpDeploymentCustomResourceStateError                       VvpDeploymentCustomResourceState = "ERROR"
)
View Source 
const GroupName = "compute.streamnative.io"

GroupName specifies the group name used to register the objects.

Variables

View Source 
var (
	// localSchemeBuilder and AddToScheme will stay in k8s.io/kubernetes.
	SchemeBuilder runtime.SchemeBuilder

	// Deprecated: use Install instead
	AddToScheme = localSchemeBuilder.AddToScheme
	Install     = localSchemeBuilder.AddToScheme
)
View Source 
var GroupVersion = v1.GroupVersion{Group: GroupName, Version: "v1alpha1"}

GroupVersion specifies the group and the version used to register the objects.

View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: GroupName, Version: "v1alpha1"}

SchemeGroupVersion is group version used to register these objects Deprecated: use GroupVersion instead.

Functions

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type Artifact 

type Artifact struct {
	// +optional
	//nolint:stylecheck
	JarUri string `json:"jarUri,omitempty" protobuf:"bytes,1,opt,name=jarUri"`

	// +kubebuilder:validation:Enum=JAR;PYTHON;sqlscript
	// +kubebuilder:validation:Required
	Kind string `json:"kind,omitempty" protobuf:"bytes,2,req,name=kind"`

	// +optional
	//nolint:stylecheck
	PythonArtifactUri string `json:"pythonArtifactUri,omitempty" protobuf:"bytes,3,opt,name=pythonArtifactUri"`

	// +optional
	//nolint:stylecheck
	SqlScript string `json:"sqlScript,omitempty" protobuf:"bytes,4,opt,name=sqlScript"`

	// +optional
	AdditionalDependencies []string `json:"additionalDependencies,omitempty" protobuf:"bytes,5,opt,name=additionalDependencies"`

	// +optional
	AdditionalPythonArchives []string `json:"additionalPythonArchives,omitempty" protobuf:"bytes,6,opt,name=additionalPythonArchives"`

	// +optional
	AdditionalPythonLibraries []string `json:"additionalPythonLibraries,omitempty" protobuf:"bytes,7,opt,name=additionalPythonLibraries"`

	// +optional
	// +kubebuilder:validation:Enum=PYTHON;SQLSCRIPT;JAR;UNKNOWN
	ArtifactKind string `json:"artifactKind,omitempty" protobuf:"bytes,8,opt,name=artifactKind"`

	// +optional
	EntryClass string `json:"entryClass,omitempty" protobuf:"bytes,9,opt,name=entryClass"`

	// +optional
	EntryModule string `json:"entryModule,omitempty" protobuf:"bytes,10,opt,name=entryModule"`

	// +optional
	FlinkImageRegistry string `json:"flinkImageRegistry,omitempty" protobuf:"bytes,11,opt,name=flinkImageRegistry"`

	// +optional
	FlinkImageRepository string `json:"flinkImageRepository,omitempty" protobuf:"bytes,12,opt,name=flinkImageRepository"`

	// +optional
	FlinkImageTag string `json:"flinkImageTag,omitempty" protobuf:"bytes,13,opt,name=flinkImageTag"`

	// +optional
	FlinkVersion string `json:"flinkVersion,omitempty" protobuf:"bytes,14,opt,name=flinkVersion"`

	// +optional
	MainArgs string `json:"mainArgs,omitempty" protobuf:"bytes,15,opt,name=mainArgs"`

	// +optional
	//nolint:stylecheck
	Uri string `json:"uri,omitempty" protobuf:"bytes,16,opt,name=uri"`

	// +optional
	ArtifactImage string `json:"artifactImage,omitempty" protobuf:"bytes,17,opt,name=artifactImage"`
}

Artifact is the artifact configs to deploy.

func (*Artifact) DeepCopy 

func (in *Artifact) DeepCopy() *Artifact

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

func (*Artifact) DeepCopyInto 

func (in *Artifact) DeepCopyInto(out *Artifact)

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

type CommunityDeploymentTemplate 

type CommunityDeploymentTemplate struct {
}

CommunityDeploymentTemplate defines the desired state of CommunityDeployment

func (*CommunityDeploymentTemplate) DeepCopy 

func (in *CommunityDeploymentTemplate) DeepCopy() *CommunityDeploymentTemplate

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

func (*CommunityDeploymentTemplate) DeepCopyInto 

func (in *CommunityDeploymentTemplate) DeepCopyInto(out *CommunityDeploymentTemplate)

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

type Condition 

type Condition struct {
	Type               ConditionType          `json:"type" protobuf:"bytes,1,opt,name=type,casttype=ConditionType"`
	Status             metav1.ConditionStatus `json:"status" protobuf:"bytes,2,opt,name=status,casttype=k8s.io/apimachinery/pkg/apis/meta/v1.ConditionStatus"`
	Reason             ConditionReason        `json:"reason,omitempty" protobuf:"bytes,3,opt,name=reason,casttype=ConditionReason"`
	Message            string                 `json:"message,omitempty" protobuf:"bytes,4,opt,name=message"`
	LastTransitionTime metav1.Time            `json:"lastTransitionTime,omitempty" protobuf:"bytes,5,opt,name=lastTransitionTime"`
	// observedGeneration represents the .metadata.generation that the condition was set based upon.
	// For instance, if .metadata.generation is currently 12, but the .status.conditions[x].observedGeneration is 9, the condition is out of date
	// with respect to the current state of the instance.
	// +optional
	// +kubebuilder:validation:Minimum=0
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,6,opt,name=observedGeneration"`
}

Condition represents an observation of an object's state. Conditions are an extension mechanism intended to be used when the details of an observation are not a priori known or would not apply to all instances of a given Kind.

Conditions should be added to explicitly convey properties that users and components care about rather than requiring those properties to be inferred from other observations. Once defined, the meaning of a Condition can not be changed arbitrarily - it becomes part of the API, and has the same backwards- and forwards-compatibility concerns of any other part of the API.

func (*Condition) DeepCopy 

func (in *Condition) DeepCopy() *Condition

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

func (*Condition) DeepCopyInto 

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

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

type ConditionReason 

type ConditionReason string

ConditionReason is intended to be a one-word, CamelCase representation of the category of cause of the current status. It is intended to be used in concise output, such as one-line kubectl get output, and in summarizing occurrences of causes.

type ConditionType 

type ConditionType string

ConditionType is the type of the condition and is typically a CamelCased word or short phrase.

Condition types should indicate state in the "abnormal-true" polarity. For example, if the condition indicates when a policy is invalid, the "is valid" case is probably the norm, so the condition should be called "Invalid".

type Configuration 

type Configuration struct {
	// Envs is the list of environment variables to set in the Flink deployment.
	// +optional
	Envs []EnvVar `json:"envs,omitempty" protobuf:"bytes,1,opt,name=envs"`

	// Secrets is the list of secrets referenced to deploy with the Flink deployment.
	// +optional
	Secrets []SecretReference `json:"secrets,omitempty" protobuf:"bytes,2,opt,name=secrets"`
}

Configuration defines the additional configuration for the Flink deployment

func (*Configuration) DeepCopy 

func (in *Configuration) DeepCopy() *Configuration

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

func (*Configuration) DeepCopyInto 

func (in *Configuration) DeepCopyInto(out *Configuration)

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

type Container 

type Container struct {
	// Name of the container specified as a DNS_LABEL.
	// Each container in a pod must have a unique name (DNS_LABEL).
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`

	// Docker image name.
	// +optional
	Image string `json:"image,omitempty" protobuf:"bytes,2,opt,name=image"`

	// Entrypoint array. Not executed within a shell.
	// +optional
	Command []string `json:"command,omitempty" protobuf:"bytes,3,rep,name=command"`

	// Arguments to the entrypoint.
	// +optional
	Args []string `json:"args,omitempty" protobuf:"bytes,4,rep,name=args"`

	// Container's working directory.
	// +optional
	WorkingDir string `json:"workingDir,omitempty" protobuf:"bytes,5,opt,name=workingDir"`

	// List of sources to populate environment variables in the container.
	// +optional
	EnvFrom []corev1.EnvFromSource `json:"envFrom,omitempty" protobuf:"bytes,6,rep,name=envFrom"`

	// List of environment variables to set in the container.
	// +optional
	// +patchMergeKey=name
	// +patchStrategy=merge
	Env []corev1.EnvVar `json:"env,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,7,rep,name=env"`

	// Compute Resources required by this container.
	// +optional
	Resources corev1.ResourceRequirements `json:"resources,omitempty" protobuf:"bytes,8,opt,name=resources"`

	// Pod volumes to mount into the container's filesystem.
	// +optional
	// +patchMergeKey=mountPath
	// +patchStrategy=merge
	VolumeMounts []corev1.VolumeMount `json:"volumeMounts,omitempty" patchStrategy:"merge" patchMergeKey:"mountPath" protobuf:"bytes,9,rep,name=volumeMounts"`

	// Periodic probe of container liveness.
	// +optional
	LivenessProbe *corev1.Probe `json:"livenessProbe,omitempty" protobuf:"bytes,10,opt,name=livenessProbe"`

	// Periodic probe of container service readiness.
	// More info: https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle#container-probes
	// +optional
	ReadinessProbe *corev1.Probe `json:"readinessProbe,omitempty" protobuf:"bytes,11,opt,name=readinessProbe"`

	// StartupProbe indicates that the Pod has successfully initialized.
	// +optional
	StartupProbe *corev1.Probe `json:"startupProbe,omitempty" protobuf:"bytes,12,opt,name=startupProbe"`

	// Image pull policy.
	// +optional
	ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy,omitempty" protobuf:"bytes,13,opt,name=imagePullPolicy,casttype=k8s.io/api/core/v1.PullPolicy"`

	// SecurityContext holds pod-level security attributes and common container settings.
	// +optional
	SecurityContext *SecurityContext `json:"securityContext,omitempty" protobuf:"bytes,14,opt,name=securityContext"`
}

Container A single application container that you want to run within a pod. The Container API from the core group is not used directly to avoid unneeded fields and reduce the size of the CRD. New fields could be added as needed.

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 EnvVar 

type EnvVar struct {
	// Name of the environment variable.
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`

	// Value of the environment variable.
	Value string `json:"value" protobuf:"bytes,2,opt,name=value"`
}

EnvVar defines an environment variable.

func (*EnvVar) DeepCopy 

func (in *EnvVar) DeepCopy() *EnvVar

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

func (*EnvVar) DeepCopyInto 

func (in *EnvVar) DeepCopyInto(out *EnvVar)

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

type FlinkBlobStorage 

type FlinkBlobStorage struct {
	// Bucket is required if you want to use cloud storage.
	Bucket string `json:"bucket,omitempty" protobuf:"bytes,1,opt,name=bucket"`

	// Path is the sub path in the bucket. Leave it empty if you want to use the whole bucket.
	// +optional
	Path string `json:"path,omitempty" protobuf:"bytes,2,opt,name=path"`
}

FlinkBlobStorage defines the configuration for the Flink blob storage.

func (*FlinkBlobStorage) DeepCopy 

func (in *FlinkBlobStorage) DeepCopy() *FlinkBlobStorage

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

func (*FlinkBlobStorage) DeepCopyInto 

func (in *FlinkBlobStorage) DeepCopyInto(out *FlinkBlobStorage)

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

type FlinkBlobStorageCredentials 

type FlinkBlobStorageCredentials struct {
	// ExistingSecret is the reference to the existing secret that contains the credentials for the Flink blob storage.
	// Use an existing Kubernetes secret instead of providing credentials in this file. The keys
	// within the secret must follow the format: `<provider>.<credential>`
	// For example: `s3.accessKeyId` or `azure.connectionString`
	// +optional
	ExistingSecret *corev1.SecretReference `json:"existingSecret,omitempty" protobuf:"bytes,1,opt,name=existingSecret"`
}

FlinkBlobStorageCredentials defines the credentials for the Flink blob storage.

func (*FlinkBlobStorageCredentials) DeepCopy 

func (in *FlinkBlobStorageCredentials) DeepCopy() *FlinkBlobStorageCredentials

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

func (*FlinkBlobStorageCredentials) DeepCopyInto 

func (in *FlinkBlobStorageCredentials) DeepCopyInto(out *FlinkBlobStorageCredentials)

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

type FlinkBlobStorageOSSConfig 

type FlinkBlobStorageOSSConfig struct {
	// Endpoint is the endpoint for the OSS blob storage.
	// +optional
	Endpoint string `json:"endpoint,omitempty" protobuf:"bytes,1,opt,name=endpoint"`
}

FlinkBlobStorageOSSConfig defines the configuration for the OSS blob storage.

func (*FlinkBlobStorageOSSConfig) DeepCopy 

func (in *FlinkBlobStorageOSSConfig) DeepCopy() *FlinkBlobStorageOSSConfig

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

func (*FlinkBlobStorageOSSConfig) DeepCopyInto 

func (in *FlinkBlobStorageOSSConfig) DeepCopyInto(out *FlinkBlobStorageOSSConfig)

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

type FlinkBlobStorageS3Config 

type FlinkBlobStorageS3Config struct {
	// Endpoint is the endpoint for the S3 blob storage.
	// +optional
	Endpoint string `json:"endpoint,omitempty" protobuf:"bytes,1,opt,name=endpoint"`

	// Region is the region for the S3 blob storage.
	// +optional
	Region string `json:"region,omitempty" protobuf:"bytes,2,opt,name=region"`
}

FlinkBlobStorageS3Config defines the configuration for the S3 blob storage.

func (*FlinkBlobStorageS3Config) DeepCopy 

func (in *FlinkBlobStorageS3Config) DeepCopy() *FlinkBlobStorageS3Config

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

func (*FlinkBlobStorageS3Config) DeepCopyInto 

func (in *FlinkBlobStorageS3Config) DeepCopyInto(out *FlinkBlobStorageS3Config)

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

type FlinkDeployment 

type FlinkDeployment struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Spec   FlinkDeploymentSpec   `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
	Status FlinkDeploymentStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

FlinkDeployment is the Schema for the flinkdeployments API +k8s:openapi-gen=true +resource:path=flinkdeployments,strategy=FlinkDeploymentStrategy +kubebuilder:categories=all,compute

func (*FlinkDeployment) DeepCopy 

func (in *FlinkDeployment) DeepCopy() *FlinkDeployment

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

func (*FlinkDeployment) DeepCopyInto 

func (in *FlinkDeployment) DeepCopyInto(out *FlinkDeployment)

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

func (*FlinkDeployment) DeepCopyObject 

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

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

type FlinkDeploymentList 

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

FlinkDeploymentList contains a list of FlinkDeployments

func (*FlinkDeploymentList) DeepCopy 

func (in *FlinkDeploymentList) DeepCopy() *FlinkDeploymentList

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

func (*FlinkDeploymentList) DeepCopyInto 

func (in *FlinkDeploymentList) DeepCopyInto(out *FlinkDeploymentList)

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

func (*FlinkDeploymentList) DeepCopyObject 

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

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

type FlinkDeploymentSpec 

type FlinkDeploymentSpec struct {
	// WorkspaceName is the reference to the workspace, and is required
	// +kubebuilder:validation:Required
	WorkspaceName string `json:"workspaceName" protobuf:"bytes,1,opt,name=workspaceName"`

	// PoolMemberRef is the pool member to deploy the cluster.
	// admission controller will infer this information automatically
	// if not provided, the controller will use PoolMember from the workspace
	// +optional
	PoolMemberRef *PoolMemberReference `json:"poolMemberRef,omitempty" protobuf:"bytes,2,opt,name=poolMemberRef"`

	// +optional
	Labels map[string]string `json:"labels,omitempty" protobuf:"bytes,3,opt,name=labels"`

	// +optional
	Annotations map[string]string `json:"annotations,omitempty" protobuf:"bytes,4,opt,name=annotations"`

	// ververica-platform: https://docs.ververica.com/vvp/platform-operations/k8s-operator/op-configs
	// opensource: https://nightlies.apache.org/flink/flink-docs-stable/docs/deployment/config/
	// +kubebuilder:validation:Required
	FlinkDeploymentTemplate `json:",inline" protobuf:"bytes,5,req"`

	// DefaultPulsarCluster is the default pulsar cluster to use. If not provided, the controller will use the first pulsar cluster from the workspace.
	// +optional
	DefaultPulsarCluster *string `json:"defaultPulsarCluster,omitempty" protobuf:"bytes,6,opt,name=defaultPulsarCluster"`

	// Configuration is the list of configurations to deploy with the Flink deployment.
	// +optional
	Configuration *Configuration `json:"configuration,omitempty" protobuf:"bytes,7,opt,name=configuration"`
}

FlinkDeploymentSpec defines the desired state of FlinkDeployment

func (*FlinkDeploymentSpec) DeepCopy 

func (in *FlinkDeploymentSpec) DeepCopy() *FlinkDeploymentSpec

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

func (*FlinkDeploymentSpec) DeepCopyInto 

func (in *FlinkDeploymentSpec) DeepCopyInto(out *FlinkDeploymentSpec)

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

type FlinkDeploymentStatus 

type FlinkDeploymentStatus struct {
	// Conditions is an array of current observed conditions.
	// +optional
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=type
	Conditions []Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,1,name=conditions"`

	// DeploymentStatus is the status of the vvp deployment.
	// +optional
	DeploymentStatus *VvpDeploymentStatus `json:"deploymentStatus,omitempty" protobuf:"bytes,2,opt,name=deploymentStatus"`

	// observedGeneration represents the .metadata.generation that the condition was set based upon.
	// For instance, if .metadata.generation is currently 12, but the .status.conditions[x].observedGeneration is 9, the condition is out of date
	// with respect to the current state of the instance.
	// +optional
	// +kubebuilder:validation:Minimum=0
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,3,opt,name=observedGeneration"`
}

FlinkDeploymentStatus defines the observed state of FlinkDeployment

func (*FlinkDeploymentStatus) DeepCopy 

func (in *FlinkDeploymentStatus) DeepCopy() *FlinkDeploymentStatus

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

func (*FlinkDeploymentStatus) DeepCopyInto 

func (in *FlinkDeploymentStatus) DeepCopyInto(out *FlinkDeploymentStatus)

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

type FlinkDeploymentTemplate 

type FlinkDeploymentTemplate struct {
	// +optional
	Template *VvpDeploymentTemplate `json:"template,omitempty" protobuf:"bytes,1,opt,name=template"`

	// +optional
	CommunityTemplate *CommunityDeploymentTemplate `json:"communityTemplate,omitempty" protobuf:"bytes,2,opt,name=communityTemplate"`
}

func (*FlinkDeploymentTemplate) DeepCopy 

func (in *FlinkDeploymentTemplate) DeepCopy() *FlinkDeploymentTemplate

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

func (*FlinkDeploymentTemplate) DeepCopyInto 

func (in *FlinkDeploymentTemplate) DeepCopyInto(out *FlinkDeploymentTemplate)

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

type Logging 

type Logging struct {
	// +optional
	Log4j2ConfigurationTemplate string `json:"log4j2ConfigurationTemplate,omitempty" protobuf:"bytes,1,opt,name=log4j2ConfigurationTemplate"`

	// +optional
	Log4jLoggers map[string]string `json:"log4jLoggers,omitempty" protobuf:"bytes,2,opt,name=log4jLoggers"`

	// +optional
	LoggingProfile string `json:"loggingProfile,omitempty" protobuf:"bytes,3,opt,name=loggingProfile"`
}

Logging defines the logging configuration for the Flink deployment.

func (*Logging) DeepCopy 

func (in *Logging) DeepCopy() *Logging

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

func (*Logging) DeepCopyInto 

func (in *Logging) DeepCopyInto(out *Logging)

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

type ObjectMeta 

type ObjectMeta struct {
	// Name of the resource within a namespace. It must be unique.
	// +optional
	Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`

	// Namespace of the resource.
	// +optional
	Namespace string `json:"namespace,omitempty" protobuf:"bytes,2,opt,name=namespace"`

	// Labels of the resource.
	// +optional
	// +nullable
	Labels map[string]string `json:"labels,omitempty" protobuf:"bytes,3,rep,name=labels"`

	// Annotations of the resource.
	// +optional
	// +nullable
	Annotations map[string]string `json:"annotations,omitempty" protobuf:"bytes,4,rep,name=annotations"`
}

func (*ObjectMeta) DeepCopy 

func (in *ObjectMeta) DeepCopy() *ObjectMeta

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

func (*ObjectMeta) DeepCopyInto 

func (in *ObjectMeta) DeepCopyInto(out *ObjectMeta)

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

type PodTemplate 

type PodTemplate struct {
	// Metadata of the pod.
	// +optional
	Metadata ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// Spec of the pod.
	// +optional
	Spec PodTemplateSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
}

PodTemplate defines the common pod configuration for Pods, including when used in StatefulSets.

func (*PodTemplate) DeepCopy 

func (in *PodTemplate) DeepCopy() *PodTemplate

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

func (*PodTemplate) DeepCopyInto 

func (in *PodTemplate) DeepCopyInto(out *PodTemplate)

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

type PodTemplateSpec 

type PodTemplateSpec struct {
	// +optional
	Volumes []Volume `json:"volumes,omitempty" protobuf:"bytes,1,rep,name=volumes"`

	// +optional
	InitContainers []Container `json:"initContainers,omitempty" protobuf:"bytes,2,rep,name=initContainers"`

	Containers []Container `json:"containers,omitempty" protobuf:"bytes,3,rep,name=containers"`

	// +optional
	ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,4,opt,name=serviceAccountName"`

	// +optional
	NodeSelector map[string]string `json:"nodeSelector,omitempty" protobuf:"bytes,5,rep,name=nodeSelector"`

	// +optional
	Affinity *corev1.Affinity `json:"affinity,omitempty" protobuf:"bytes,6,opt,name=affinity"`

	// +optional
	Tolerations []corev1.Toleration `json:"tolerations,omitempty" protobuf:"bytes,7,rep,name=tolerations"`

	// +optional
	SecurityContext *SecurityContext `json:"securityContext,omitempty" protobuf:"bytes,8,opt,name=securityContext"`

	// +optional
	ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty" protobuf:"bytes,9,rep,name=imagePullSecrets"`

	// +optional
	ShareProcessNamespace *bool `json:"shareProcessNamespace,omitempty" protobuf:"bytes,10,opt,name=shareProcessNamespace"`
}

func (*PodTemplateSpec) DeepCopy 

func (in *PodTemplateSpec) DeepCopy() *PodTemplateSpec

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

func (*PodTemplateSpec) DeepCopyInto 

func (in *PodTemplateSpec) DeepCopyInto(out *PodTemplateSpec)

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

type PoolMemberReference 

type PoolMemberReference struct {
	Namespace string `json:"namespace" protobuf:"bytes,1,opt,name=namespace"`
	Name      string `json:"name" protobuf:"bytes,2,opt,name=name"`
}

PoolMemberReference is a reference to a pool member with a given name.

func (*PoolMemberReference) DeepCopy 

func (in *PoolMemberReference) DeepCopy() *PoolMemberReference

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

func (*PoolMemberReference) DeepCopyInto 

func (in *PoolMemberReference) DeepCopyInto(out *PoolMemberReference)

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

type PoolRef 

type PoolRef struct {
	Namespace string `json:"namespace" protobuf:"bytes,1,opt,name=namespace"`
	Name      string `json:"name" protobuf:"bytes,2,opt,name=name"`
}

func (*PoolRef) DeepCopy 

func (in *PoolRef) DeepCopy() *PoolRef

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

func (*PoolRef) DeepCopyInto 

func (in *PoolRef) DeepCopyInto(out *PoolRef)

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

type ResourceSpec 

type ResourceSpec struct {
	// CPU represents the minimum amount of CPU required.
	// +kubebuilder:validation:Required
	//nolint:stylecheck
	Cpu string `json:"cpu" protobuf:"bytes,1,req,name=cpu"`

	// Memory represents the minimum amount of memory required.
	// +kubebuilder:validation:Required
	Memory string `json:"memory" protobuf:"bytes,2,req,name=memory"`
}

ResourceSpec defines the resource requirements for a component.

func (*ResourceSpec) DeepCopy 

func (in *ResourceSpec) DeepCopy() *ResourceSpec

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

func (*ResourceSpec) DeepCopyInto 

func (in *ResourceSpec) DeepCopyInto(out *ResourceSpec)

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

type SecretReference 

type SecretReference struct {
	// Name of the ENV variable.
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`

	// ValueFrom references a secret in the same namespace.
	ValueFrom *corev1.SecretKeySelector `json:"valueFrom,omitempty" protobuf:"bytes,2,opt,name=valueFrom"`
}

SecretReference references a StreamNative Cloud secret.

func (*SecretReference) DeepCopy 

func (in *SecretReference) DeepCopy() *SecretReference

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

func (*SecretReference) DeepCopyInto 

func (in *SecretReference) DeepCopyInto(out *SecretReference)

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

type SecurityContext 

type SecurityContext struct {
	// +optional
	RunAsUser *int64 `json:"runAsUser,omitempty" protobuf:"varint,1,opt,name=runAsUser"`
	// +optional
	RunAsGroup *int64 `json:"runAsGroup,omitempty" protobuf:"varint,2,opt,name=runAsGroup"`
	// +optional
	RunAsNonRoot *bool `json:"runAsNonRoot,omitempty" protobuf:"varint,3,opt,name=runAsNonRoot"`
	// +optional
	FSGroup *int64 `json:"fsGroup,omitempty" protobuf:"varint,4,opt,name=fsGroup"`

	// ReadOnlyRootFilesystem specifies whether the container use a read-only filesystem.
	// +optional
	ReadOnlyRootFilesystem *bool `json:"readOnlyRootFilesystem,omitempty" protobuf:"varint,5,opt,name=readOnlyRootFilesystem"`
}

func (*SecurityContext) DeepCopy 

func (in *SecurityContext) DeepCopy() *SecurityContext

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

func (*SecurityContext) DeepCopyInto 

func (in *SecurityContext) DeepCopyInto(out *SecurityContext)

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

type StreamNativeCloudProtocolIntegration 

type StreamNativeCloudProtocolIntegration struct {
	Pulsar *bool `json:"pulsar,omitempty" protobuf:"bytes,1,opt,name=pulsar"`
	Kafka  *bool `json:"kafka,omitempty" protobuf:"bytes,2,opt,name=kafka"`
}

func (*StreamNativeCloudProtocolIntegration) DeepCopy 

func (in *StreamNativeCloudProtocolIntegration) DeepCopy() *StreamNativeCloudProtocolIntegration

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

func (*StreamNativeCloudProtocolIntegration) DeepCopyInto 

func (in *StreamNativeCloudProtocolIntegration) DeepCopyInto(out *StreamNativeCloudProtocolIntegration)

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

type UserMetadata 

type UserMetadata struct {
	// +optional
	Annotations map[string]string `json:"annotations,omitempty" protobuf:"bytes,1,opt,name=annotations"`

	// +optional
	DisplayName string `json:"displayName,omitempty" protobuf:"bytes,2,opt,name=displayName"`

	// +optional
	Labels map[string]string `json:"labels,omitempty" protobuf:"bytes,3,opt,name=labels"`

	// +optional
	Name string `json:"name,omitempty" protobuf:"bytes,4,opt,name=name"`

	// +optional
	Namespace string `json:"namespace,omitempty" protobuf:"bytes,5,opt,name=namespace"`
}

UserMetadata Specify the metadata for the resource we are deploying.

func (*UserMetadata) DeepCopy 

func (in *UserMetadata) DeepCopy() *UserMetadata

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

func (*UserMetadata) DeepCopyInto 

func (in *UserMetadata) DeepCopyInto(out *UserMetadata)

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

type Volume 

type Volume struct {
	// Volume's name.
	// Must be a DNS_LABEL and unique within the pod.
	// More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#names
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`

	// VolumeSource represents the location and type of the mounted volume.
	// If not specified, the Volume is implied to be an EmptyDir.
	// This implied behavior is deprecated and will be removed in a future version.
	VolumeSource `json:",inline" protobuf:"bytes,2,opt,name=volumeSource"`
}

Volume represents a named volume in a pod that may be accessed by any container in the pod. The Volume API from the core group is not used directly to avoid unneeded fields defined in `VolumeSource` and reduce the size of the CRD. New fields in VolumeSource could be added as needed.

func (*Volume) DeepCopy 

func (in *Volume) DeepCopy() *Volume

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

func (*Volume) DeepCopyInto 

func (in *Volume) DeepCopyInto(out *Volume)

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

type VolumeSource 

type VolumeSource struct {
	// ConfigMap represents a configMap that should populate this volume
	// +optional
	ConfigMap *corev1.ConfigMapVolumeSource `json:"configMap,omitempty" protobuf:"bytes,1,opt,name=configMap"`

	// Secret represents a secret that should populate this volume.
	// +optional
	Secret *corev1.SecretVolumeSource `json:"secret,omitempty" protobuf:"bytes,2,opt,name=secret"`
}

VolumeSource Represents the source of a volume to mount. Only one of its members may be specified.

func (*VolumeSource) DeepCopy 

func (in *VolumeSource) DeepCopy() *VolumeSource

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

func (*VolumeSource) DeepCopyInto 

func (in *VolumeSource) DeepCopyInto(out *VolumeSource)

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

type VvpCustomResourceStatus 

type VvpCustomResourceStatus struct {
	// +kubebuilder:validation:Enum=SYNCING;IDLING;DELETING;REF_ENTITY_MANAGED_BY_ANOTHER_CR;SYNCING_MODE_INCONSISTENT;REF_NAMESPACE_UNAVAILABLE;CONCURRENT_RECONCILIATION;ERROR
	CustomResourceState VvpDeploymentCustomResourceState `json:"customResourceState,omitempty" protobuf:"bytes,1,opt,name=customResourceState"`
	//nolint:stylecheck
	DeploymentId      string `json:"deploymentId,omitempty" protobuf:"bytes,2,opt,name=deploymentId"`
	ObservedSpecState string `json:"observedSpecState,omitempty" protobuf:"bytes,3,opt,name=observedSpecState"`
	// +kubebuilder:validation:Enum=RUNNING;SUSPENDED;CANCELLED;TRANSITIONING;FAILED;FINISHED
	StatusState         VvpDeploymentStatusState `json:"statusState,omitempty" protobuf:"bytes,4,opt,name=statusState"`
	DeploymentNamespace string                   `json:"deploymentNamespace,omitempty" protobuf:"bytes,5,opt,name=deploymentNamespace"`
}

VvpCustomResourceStatus defines the observed state of VvpCustomResource

func (*VvpCustomResourceStatus) DeepCopy 

func (in *VvpCustomResourceStatus) DeepCopy() *VvpCustomResourceStatus

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

func (*VvpCustomResourceStatus) DeepCopyInto 

func (in *VvpCustomResourceStatus) DeepCopyInto(out *VvpCustomResourceStatus)

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

type VvpDeploymentCustomResourceState 

type VvpDeploymentCustomResourceState string

type VvpDeploymentDetails 

type VvpDeploymentDetails struct {
	DeploymentTargetName     *string `json:"deploymentTargetName,omitempty" protobuf:"bytes,1,opt,name=deploymentTargetName"`
	JobFailureExpirationTime *string `json:"jobFailureExpirationTime,omitempty" protobuf:"bytes,2,opt,name=jobFailureExpirationTime"`

	// +kubebuilder:validation:Minimum=1
	MaxJobCreationAttempts *int32 `json:"maxJobCreationAttempts,omitempty" protobuf:"varint,3,opt,name=maxJobCreationAttempts"`

	// +kubebuilder:validation:Minimum=1
	MaxSavepointCreationAttempts *int32 `json:"maxSavepointCreationAttempts,omitempty" protobuf:"varint,4,opt,name=maxSavepointCreationAttempts"`

	RestoreStrategy    *VvpRestoreStrategy `json:"restoreStrategy,omitempty" protobuf:"bytes,5,opt,name=restoreStrategy"`
	SessionClusterName *string             `json:"sessionClusterName,omitempty" protobuf:"bytes,6,opt,name=sessionClusterName"`

	// +kubebuilder:validation:Enum=RUNNING;SUSPENDED;CANCELLED
	State string `json:"state,omitempty" protobuf:"bytes,7,opt,name=state"`

	// +kubebuilder:validation:Required
	Template VvpDeploymentDetailsTemplate `json:"template" protobuf:"bytes,8,req,name=template"`
}

VvpDeploymentDetails defines the desired state of VvpDeploymentDetails

func (*VvpDeploymentDetails) DeepCopy 

func (in *VvpDeploymentDetails) DeepCopy() *VvpDeploymentDetails

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

func (*VvpDeploymentDetails) DeepCopyInto 

func (in *VvpDeploymentDetails) DeepCopyInto(out *VvpDeploymentDetails)

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

type VvpDeploymentDetailsTemplate 

type VvpDeploymentDetailsTemplate struct {
	Metadata *VvpDeploymentDetailsTemplateMetadata `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// +kubebuilder:validation:Required
	Spec VvpDeploymentDetailsTemplateSpec `json:"spec" protobuf:"bytes,2,req,name=spec"`
}

VvpDeploymentDetailsTemplate defines the desired state of VvpDeploymentDetails

func (*VvpDeploymentDetailsTemplate) DeepCopy 

func (in *VvpDeploymentDetailsTemplate) DeepCopy() *VvpDeploymentDetailsTemplate

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

func (*VvpDeploymentDetailsTemplate) DeepCopyInto 

func (in *VvpDeploymentDetailsTemplate) DeepCopyInto(out *VvpDeploymentDetailsTemplate)

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

type VvpDeploymentDetailsTemplateMetadata 

type VvpDeploymentDetailsTemplateMetadata struct {
	Annotations map[string]string `json:"annotations,omitempty" protobuf:"bytes,1,rep,name=annotations"`
}

VvpDeploymentDetailsTemplateMetadata defines the desired state of VvpDeploymentDetailsTemplateMetadata

func (*VvpDeploymentDetailsTemplateMetadata) DeepCopy 

func (in *VvpDeploymentDetailsTemplateMetadata) DeepCopy() *VvpDeploymentDetailsTemplateMetadata

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

func (*VvpDeploymentDetailsTemplateMetadata) DeepCopyInto 

func (in *VvpDeploymentDetailsTemplateMetadata) DeepCopyInto(out *VvpDeploymentDetailsTemplateMetadata)

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

type VvpDeploymentDetailsTemplateSpec 

type VvpDeploymentDetailsTemplateSpec struct {
	// +kubebuilder:validation:Required
	Artifact *Artifact `json:"artifact" protobuf:"bytes,1,req,name=artifact"`

	// +optional
	FlinkConfiguration map[string]string `json:"flinkConfiguration,omitempty" protobuf:"bytes,2,rep,name=flinkConfiguration"`

	// +optional
	Kubernetes *VvpDeploymentDetailsTemplateSpecKubernetesSpec `json:"kubernetes,omitempty" protobuf:"bytes,3,opt,name=kubernetes"`

	// +optional
	LatestCheckpointFetchInterval *int32 `json:"latestCheckpointFetchInterval,omitempty" protobuf:"varint,4,opt,name=latestCheckpointFetchInterval"`

	// +optional
	Logging *Logging `json:"logging,omitempty" protobuf:"bytes,5,opt,name=logging"`

	// +optional
	NumberOfTaskManagers *int32 `json:"numberOfTaskManagers,omitempty" protobuf:"varint,6,opt,name=numberOfTaskManagers"`

	// +optional
	Parallelism *int32 `json:"parallelism,omitempty" protobuf:"varint,7,opt,name=parallelism"`

	// +optional
	Resources *VvpDeploymentKubernetesResources `json:"resources,omitempty" protobuf:"bytes,8,opt,name=resources"`
}

VvpDeploymentDetailsTemplateSpec defines the desired state of VvpDeploymentDetails

func (*VvpDeploymentDetailsTemplateSpec) DeepCopy 

func (in *VvpDeploymentDetailsTemplateSpec) DeepCopy() *VvpDeploymentDetailsTemplateSpec

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

func (*VvpDeploymentDetailsTemplateSpec) DeepCopyInto 

func (in *VvpDeploymentDetailsTemplateSpec) DeepCopyInto(out *VvpDeploymentDetailsTemplateSpec)

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

type VvpDeploymentDetailsTemplateSpecKubernetesSpec 

type VvpDeploymentDetailsTemplateSpecKubernetesSpec struct {
	// +optional
	JobManagerPodTemplate *PodTemplate `json:"jobManagerPodTemplate,omitempty" protobuf:"bytes,1,opt,name=jobManagerPodTemplate"`

	// +optional
	TaskManagerPodTemplate *PodTemplate `json:"taskManagerPodTemplate,omitempty" protobuf:"bytes,2,opt,name=taskManagerPodTemplate"`

	// +optional
	Labels map[string]string `json:"labels,omitempty" protobuf:"bytes,3,opt,name=labels"`
}

VvpDeploymentDetailsTemplateSpecKubernetesSpec defines the desired state of VvpDeploymentDetails

func (*VvpDeploymentDetailsTemplateSpecKubernetesSpec) DeepCopy 

func (in *VvpDeploymentDetailsTemplateSpecKubernetesSpec) DeepCopy() *VvpDeploymentDetailsTemplateSpecKubernetesSpec

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

func (*VvpDeploymentDetailsTemplateSpecKubernetesSpec) DeepCopyInto 

func (in *VvpDeploymentDetailsTemplateSpecKubernetesSpec) DeepCopyInto(out *VvpDeploymentDetailsTemplateSpecKubernetesSpec)

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

type VvpDeploymentKubernetesResources 

type VvpDeploymentKubernetesResources struct {
	// +optional
	Jobmanager *ResourceSpec `json:"jobmanager,omitempty" protobuf:"bytes,1,opt,name=jobmanager"`

	// +optional
	Taskmanager *ResourceSpec `json:"taskmanager,omitempty" protobuf:"bytes,2,opt,name=taskmanager"`
}

VvpDeploymentKubernetesResources defines the Kubernetes resources for the VvpDeployment.

func (*VvpDeploymentKubernetesResources) DeepCopy 

func (in *VvpDeploymentKubernetesResources) DeepCopy() *VvpDeploymentKubernetesResources

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

func (*VvpDeploymentKubernetesResources) DeepCopyInto 

func (in *VvpDeploymentKubernetesResources) DeepCopyInto(out *VvpDeploymentKubernetesResources)

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

type VvpDeploymentRunningStatus 

type VvpDeploymentRunningStatus struct {
	//nolint:stylecheck
	JobId          string      `json:"jobId,omitempty" protobuf:"bytes,1,opt,name=jobId"`
	TransitionTime metav1.Time `json:"transitionTime,omitempty" protobuf:"bytes,2,opt,name=transitionTime"`
	// Conditions is an array of current observed conditions.
	// +optional
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=type
	Conditions []VvpDeploymentStatusCondition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,3,name=conditions"`
}

VvpDeploymentRunningStatus defines the observed state of VvpDeployment

func (*VvpDeploymentRunningStatus) DeepCopy 

func (in *VvpDeploymentRunningStatus) DeepCopy() *VvpDeploymentRunningStatus

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

func (*VvpDeploymentRunningStatus) DeepCopyInto 

func (in *VvpDeploymentRunningStatus) DeepCopyInto(out *VvpDeploymentRunningStatus)

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

type VvpDeploymentStatus 

type VvpDeploymentStatus struct {
	CustomResourceStatus     VvpCustomResourceStatus             `json:"customResourceStatus,omitempty" protobuf:"bytes,1,opt,name=customResourceStatus"`
	DeploymentStatus         VvpDeploymentStatusDeploymentStatus `json:"deploymentStatus,omitempty" protobuf:"bytes,2,opt,name=deploymentStatus"`
	DeploymentSystemMetadata VvpDeploymentSystemMetadata         `json:"deploymentSystemMetadata,omitempty" protobuf:"bytes,3,opt,name=deploymentSystemMetadata"`
}

VvpDeploymentStatus defines the observed state of VvpDeployment

func (*VvpDeploymentStatus) DeepCopy 

func (in *VvpDeploymentStatus) DeepCopy() *VvpDeploymentStatus

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

func (*VvpDeploymentStatus) DeepCopyInto 

func (in *VvpDeploymentStatus) DeepCopyInto(out *VvpDeploymentStatus)

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

type VvpDeploymentStatusCondition 

type VvpDeploymentStatusCondition struct {
	Type               string                 `json:"type" protobuf:"bytes,1,opt,name=type"`
	Status             metav1.ConditionStatus `json:"status" protobuf:"bytes,2,opt,name=status,casttype=k8s.io/apimachinery/pkg/apis/meta/v1.ConditionStatus"`
	Reason             string                 `json:"reason,omitempty" protobuf:"bytes,3,opt,name=reason"`
	Message            string                 `json:"message,omitempty" protobuf:"bytes,4,opt,name=message"`
	LastTransitionTime metav1.Time            `json:"lastTransitionTime,omitempty" protobuf:"bytes,5,opt,name=lastTransitionTime"`
	// observedGeneration represents the .metadata.generation that the condition was set based upon.
	// For instance, if .metadata.generation is currently 12, but the .status.conditions[x].observedGeneration is 9, the condition is out of date
	// with respect to the current state of the instance.
	// +optional
	// +kubebuilder:validation:Minimum=0
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,6,opt,name=observedGeneration"`
}

func (*VvpDeploymentStatusCondition) DeepCopy 

func (in *VvpDeploymentStatusCondition) DeepCopy() *VvpDeploymentStatusCondition

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

func (*VvpDeploymentStatusCondition) DeepCopyInto 

func (in *VvpDeploymentStatusCondition) DeepCopyInto(out *VvpDeploymentStatusCondition)

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

type VvpDeploymentStatusDeploymentStatus 

type VvpDeploymentStatusDeploymentStatus struct {
	Running VvpDeploymentRunningStatus `json:"running,omitempty" protobuf:"bytes,1,opt,name=running"`

	// +kubebuilder:validation:Enum=RUNNING;SUSPENDED;CANCELLED
	State string `json:"state,omitempty" protobuf:"bytes,2,opt,name=state"`
}

VvpDeploymentStatusDeploymentStatus defines the observed state of VvpDeployment

func (*VvpDeploymentStatusDeploymentStatus) DeepCopy 

func (in *VvpDeploymentStatusDeploymentStatus) DeepCopy() *VvpDeploymentStatusDeploymentStatus

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

func (*VvpDeploymentStatusDeploymentStatus) DeepCopyInto 

func (in *VvpDeploymentStatusDeploymentStatus) DeepCopyInto(out *VvpDeploymentStatusDeploymentStatus)

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

type VvpDeploymentStatusState 

type VvpDeploymentStatusState string

type VvpDeploymentSystemMetadata 

type VvpDeploymentSystemMetadata struct {
	// +optional
	Annotations map[string]string `json:"annotations,omitempty" protobuf:"bytes,1,opt,name=annotations"`

	// +optional
	Labels map[string]string `json:"labels,omitempty" protobuf:"bytes,2,opt,name=labels"`

	// +optional
	//nolint:stylecheck
	Id string `json:"name,omitempty" protobuf:"bytes,3,opt,name=name"`

	// +optional
	ResourceVersion int32 `json:"resourceVersion,omitempty" protobuf:"bytes,4,opt,name=resourceVersion"`

	// +optional
	CreatedAt metav1.Time `json:"createdAt,omitempty" protobuf:"bytes,5,opt,name=createdAt"`

	// +optional
	ModifiedAt metav1.Time `json:"modifiedAt,omitempty" protobuf:"bytes,6,opt,name=modifiedAt"`
}

VvpDeploymentSystemMetadata defines the observed state of VvpDeployment

func (*VvpDeploymentSystemMetadata) DeepCopy 

func (in *VvpDeploymentSystemMetadata) DeepCopy() *VvpDeploymentSystemMetadata

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

func (*VvpDeploymentSystemMetadata) DeepCopyInto 

func (in *VvpDeploymentSystemMetadata) DeepCopyInto(out *VvpDeploymentSystemMetadata)

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

type VvpDeploymentTemplate 

type VvpDeploymentTemplate struct {
	// +optional
	// +kubebuilder:validation:Enum=PUT;PATCH
	SyncingMode string `json:"syncingMode,omitempty" protobuf:"bytes,1,opt,name=syncingMode"`

	// +kubebuilder:validation:Required
	Deployment VvpDeploymentTemplateSpec `json:"deployment" protobuf:"bytes,2,req,name=deployment"`
}

VvpDeploymentTemplate defines the desired state of VvpDeployment

func (*VvpDeploymentTemplate) DeepCopy 

func (in *VvpDeploymentTemplate) DeepCopy() *VvpDeploymentTemplate

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

func (*VvpDeploymentTemplate) DeepCopyInto 

func (in *VvpDeploymentTemplate) DeepCopyInto(out *VvpDeploymentTemplate)

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

type VvpDeploymentTemplateSpec 

type VvpDeploymentTemplateSpec struct {
	// +kubebuilder:validation:Required
	UserMetadata *UserMetadata `json:"userMetadata" protobuf:"bytes,1,req,name=userMetadata"`

	// +kubebuilder:validation:Required
	Spec VvpDeploymentDetails `json:"spec" protobuf:"bytes,2,req,name=spec"`
}

VvpDeploymentTemplateSpec defines the desired state of VvpDeployment

func (*VvpDeploymentTemplateSpec) DeepCopy 

func (in *VvpDeploymentTemplateSpec) DeepCopy() *VvpDeploymentTemplateSpec

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

func (*VvpDeploymentTemplateSpec) DeepCopyInto 

func (in *VvpDeploymentTemplateSpec) DeepCopyInto(out *VvpDeploymentTemplateSpec)

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

type VvpRestoreStrategy 

type VvpRestoreStrategy struct {
	AllowNonRestoredState bool `json:"allowNonRestoredState,omitempty" protobuf:"varint,1,opt,name=allowNonRestoredState"`

	Kind string `json:"kind,omitempty" protobuf:"bytes,2,opt,name=kind"`
}

VvpRestoreStrategy defines the restore strategy of the deployment

func (*VvpRestoreStrategy) DeepCopy 

func (in *VvpRestoreStrategy) DeepCopy() *VvpRestoreStrategy

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

func (*VvpRestoreStrategy) DeepCopyInto 

func (in *VvpRestoreStrategy) DeepCopyInto(out *VvpRestoreStrategy)

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

type Workspace 

type Workspace struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Spec   WorkspaceSpec   `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
	Status WorkspaceStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

Workspace is the Schema for the workspaces API +k8s:openapi-gen=true +resource:path=workspaces,strategy=WorkspaceStrategy +kubebuilder:categories=all,compute

func (*Workspace) DeepCopy 

func (in *Workspace) DeepCopy() *Workspace

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

func (*Workspace) DeepCopyInto 

func (in *Workspace) DeepCopyInto(out *Workspace)

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

func (*Workspace) DeepCopyObject 

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

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

type WorkspaceList 

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

WorkspaceList contains a list of Workspaces

func (*WorkspaceList) DeepCopy 

func (in *WorkspaceList) DeepCopy() *WorkspaceList

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

func (*WorkspaceList) DeepCopyInto 

func (in *WorkspaceList) DeepCopyInto(out *WorkspaceList)

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

func (*WorkspaceList) DeepCopyObject 

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

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

type WorkspaceReference 

type WorkspaceReference struct {
	// +kubebuilder:validation:Required
	Namespace string `json:"namespace" protobuf:"bytes,1,req,name=namespace"`
	// +kubebuilder:validation:Required
	Name string `json:"name" protobuf:"bytes,2,req,name=name"`
}

WorkspaceReference is a reference to a workspace with a given name.

func (*WorkspaceReference) DeepCopy 

func (in *WorkspaceReference) DeepCopy() *WorkspaceReference

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

func (*WorkspaceReference) DeepCopyInto 

func (in *WorkspaceReference) DeepCopyInto(out *WorkspaceReference)

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

type WorkspaceSpec 

type WorkspaceSpec struct {
	// PulsarClusterNames is the list of Pulsar clusters that the workspace will have access to.
	PulsarClusterNames []string `json:"pulsarClusterNames" protobuf:"bytes,1,rep,name=pulsarClusterNames"`

	// PoolRef is the reference to the pool that the workspace will be access to.
	PoolRef *PoolRef `json:"poolRef" protobuf:"bytes,2,opt,name=poolRef"`

	// UseExternalAccess is the flag to indicate whether the workspace will use external access.
	// +optional
	UseExternalAccess *bool `json:"useExternalAccess,omitempty" protobuf:"bytes,3,opt,name=useExternalAccess"`

	// FlinkBlobStorage is the configuration for the Flink blob storage.
	// +optional
	FlinkBlobStorage *FlinkBlobStorage `json:"flinkBlobStorage" protobuf:"bytes,4,opt,name=flinkBlobStorage"`
}

WorkspaceSpec defines the desired state of Workspace

func (*WorkspaceSpec) DeepCopy 

func (in *WorkspaceSpec) DeepCopy() *WorkspaceSpec

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

func (*WorkspaceSpec) DeepCopyInto 

func (in *WorkspaceSpec) DeepCopyInto(out *WorkspaceSpec)

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

type WorkspaceStatus 

type WorkspaceStatus struct {
	// Conditions is an array of current observed pool conditions.
	// +optional
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=type
	Conditions []Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,1,rep,name=conditions"`
}

WorkspaceStatus defines the observed state of Workspace

func (*WorkspaceStatus) DeepCopy 

func (in *WorkspaceStatus) DeepCopy() *WorkspaceStatus

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

func (*WorkspaceStatus) DeepCopyInto 

func (in *WorkspaceStatus) DeepCopyInto(out *WorkspaceStatus)

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.