v1beta1

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: Apr 18, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package v1beta1 contains API Schema definitions for the ververicaplatform v1beta1 API group +kubebuilder:object:generate=true +groupName=ververicaplatform.fintechstudios.com

Index

Constants

View Source 
const (
	CancelledState     = DeploymentState("CANCELLED") // non-US spelling intentional
	RunningState       = DeploymentState("RUNNING")
	TransitioningState = DeploymentState("TRANSITIONING")
	SuspendedState     = DeploymentState("SUSPENDED")
	FailedState        = DeploymentState("FAILED")
)

All the allowed DeploymentStates

View Source 
const (
	InvalidNamespaceLifecyclePhase      = NamespaceLifecyclePhase("LIFECYCLE_PHASE_INVALID")
	ActiveNamespaceLifecyclePhase       = NamespaceLifecyclePhase("LIFECYCLE_PHASE_ACTIVE")
	TerminatingNamespaceLifecyclePhase  = NamespaceLifecyclePhase("LIFECYCLE_PHASE_TERMINATING")
	UnrecognizedNamespaceLifecyclePhase = NamespaceLifecyclePhase("UNRECOGNIZED")
)
View Source 
const (
	UserRequestOrigin       = SavepointOrigin("USER_REQUEST")
	SuspendAndUpgradeOrigin = SavepointOrigin("SUSPEND_AND_UPGRADE")
	SuspendOrigin           = SavepointOrigin("SUSPEND")
	CopiedOrigin            = SavepointOrigin("COPIED")
)
View Source 
const (
	StartedSavepointState   = SavepointState("STARTED")
	CompletedSavepointState = SavepointState("COMPLETED")
	FailedSavepointState    = SavepointState("FAILED")
)

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "ververicaplatform.fintechstudios.com", Version: "v1beta1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

This section is empty.

Types

type DeploymentState 

type DeploymentState string

DeploymentState is the enum of all possible deployment states Only one of the following states may be specified. +kubebuilder:validation:Enum=CANCELLED;RUNNING;TRANSITIONING;SUSPENDED;FAILED

type JSONPatchGeneric 

type JSONPatchGeneric struct {
	Op   string `json:"op"`
	Path string `json:"path"`

	// +optional
	Value *string `json:"value,omitempty"`
	// +optional
	From string `json:"from,omitempty"`
}

JSONPatchGeneric is a generic JSON-Patch object

func (*JSONPatchGeneric) DeepCopy 

func (in *JSONPatchGeneric) DeepCopy() *JSONPatchGeneric

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

func (*JSONPatchGeneric) DeepCopyInto 

func (in *JSONPatchGeneric) DeepCopyInto(out *JSONPatchGeneric)

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

type NamespaceLifecyclePhase 

type NamespaceLifecyclePhase string

NamespaceLifecyclePhase is the enum of all possible namespace lifecycle phase Only one of the following states may be specified. +kubebuilder:validation:Enum=LIFECYCLE_PHASE_INVALID;LIFECYCLE_PHASE_ACTIVE;LIFECYCLE_PHASE_TERMINATING;UNRECOGNIZED

type NamespaceRoleBinding 

type NamespaceRoleBinding struct {
	// +optional
	Members []string `json:"members,omitempty"`
	// +optional
	Role string `json:"role,omitempty"`
}

func (*NamespaceRoleBinding) DeepCopy 

func (in *NamespaceRoleBinding) DeepCopy() *NamespaceRoleBinding

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

func (*NamespaceRoleBinding) DeepCopyInto 

func (in *NamespaceRoleBinding) DeepCopyInto(out *NamespaceRoleBinding)

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

type SavepointOrigin 

type SavepointOrigin string

+kubebuilder:validation:Enum=USER_REQUEST;SUSPEND_AND_UPGRADE;SUSPEND;COPIED

type SavepointState 

type SavepointState string

+kubebuilder:validation:Enum=STARTED;COMPLETED;FAILED

type VpArtifact 

type VpArtifact struct {
	Kind string `json:"kind"`

	JarURI string `json:"jarUri"`
	// +optional
	MainArgs string `json:"mainArgs,omitempty"`
	// +optional
	EntryClass string `json:"entryClass,omitempty"`
	// +optional
	FlinkVersion string `json:"flinkVersion,omitempty"`
	// +optional
	FlinkImageRegistry string `json:"flinkImageRegistry,omitempty"`
	// +optional
	FlinkImageRepository string `json:"flinkImageRepository,omitempty"`
	// +optional
	FlinkImageTag string `json:"flinkImageTag,omitempty"`
}

VpArtifact describes a jar to run along with the Flink requirements

func (*VpArtifact) DeepCopy 

func (in *VpArtifact) DeepCopy() *VpArtifact

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

func (*VpArtifact) DeepCopyInto 

func (in *VpArtifact) DeepCopyInto(out *VpArtifact)

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

type VpDeployment 

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

	Spec   VpDeploymentObjectSpec `json:"spec"`
	Status VpDeploymentStatus     `json:"status,omitempty"`
}

VpDeployment is the Schema for the vpdeployments API

func (*VpDeployment) DeepCopy 

func (in *VpDeployment) DeepCopy() *VpDeployment

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

func (*VpDeployment) DeepCopyInto 

func (in *VpDeployment) DeepCopyInto(out *VpDeployment)

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

func (*VpDeployment) DeepCopyObject 

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

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

func (*VpDeployment) Hub added in v0.7.0 

func (*VpDeployment) Hub()

func (*VpDeployment) SetupWebhookWithManager added in v0.7.0 

func (r *VpDeployment) SetupWebhookWithManager(mgr ctrl.Manager) error

type VpDeploymentList 

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

VpDeploymentList contains a list of VpDeployment

func (*VpDeploymentList) DeepCopy 

func (in *VpDeploymentList) DeepCopy() *VpDeploymentList

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

func (*VpDeploymentList) DeepCopyInto 

func (in *VpDeploymentList) DeepCopyInto(out *VpDeploymentList)

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

func (*VpDeploymentList) DeepCopyObject 

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

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

type VpDeploymentObjectSpec 

type VpDeploymentObjectSpec struct {

	// VP
	Metadata VpMetadata       `json:"metadata"`
	Spec     VpDeploymentSpec `json:"spec"`

	// DeploymentTargetName is an extension on the VP API
	// Must provide a spec.deploymentTargetId if not set
	// +optional
	DeploymentTargetName string `json:"deploymentTargetName,omitempty"`
}

VpDeploymentObjectSpec defines the desired state of VpDeployment

func (*VpDeploymentObjectSpec) DeepCopy 

func (in *VpDeploymentObjectSpec) DeepCopy() *VpDeploymentObjectSpec

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

func (*VpDeploymentObjectSpec) DeepCopyInto 

func (in *VpDeploymentObjectSpec) DeepCopyInto(out *VpDeploymentObjectSpec)

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

type VpDeploymentRestoreStrategy 

type VpDeploymentRestoreStrategy struct {
	// +optional
	Kind string `json:"kind,omitempty"`
	// +optional
	AllowNonRestoredState bool `json:"allowNonRestoredState,omitempty"`
}

VpDeploymentRestoreStrategy describes how to restore a job

func (*VpDeploymentRestoreStrategy) DeepCopy 

func (in *VpDeploymentRestoreStrategy) DeepCopy() *VpDeploymentRestoreStrategy

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

func (*VpDeploymentRestoreStrategy) DeepCopyInto 

func (in *VpDeploymentRestoreStrategy) DeepCopyInto(out *VpDeploymentRestoreStrategy)

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

type VpDeploymentSpec 

type VpDeploymentSpec struct {
	State DeploymentState `json:"state"`

	UpgradeStrategy *VpDeploymentUpgradeStrategy `json:"upgradeStrategy"`
	// +optional
	RestoreStrategy *VpDeploymentRestoreStrategy `json:"restoreStrategy,omitempty"`
	// +optional
	StartFromSavepoint *VpDeploymentStartFromSavepoint `json:"startFromSavepoint,omitempty"`
	// +optional
	DeploymentTargetID string `json:"deploymentTargetId,omitempty"`
	// +optional
	MaxSavepointCreationAttempts *int32 `json:"maxSavepointCreationAttempts,omitempty"`
	// +optional
	MaxJobCreationAttempts *int32 `json:"maxJobCreationAttempts,omitempty"`

	Template *VpDeploymentTemplate `json:"template"`
}

VpDeploymentSpec is the spec in the Ververica Platform

func (*VpDeploymentSpec) DeepCopy 

func (in *VpDeploymentSpec) DeepCopy() *VpDeploymentSpec

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

func (*VpDeploymentSpec) DeepCopyInto 

func (in *VpDeploymentSpec) DeepCopyInto(out *VpDeploymentSpec)

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

type VpDeploymentStartFromSavepoint 

type VpDeploymentStartFromSavepoint struct {
	// +optional
	Kind string `json:"kind,omitempty"`
}

VpDeploymentStartFromSavepoint describes which savepoint, if any, to start the job with

func (*VpDeploymentStartFromSavepoint) DeepCopy 

func (in *VpDeploymentStartFromSavepoint) DeepCopy() *VpDeploymentStartFromSavepoint

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

func (*VpDeploymentStartFromSavepoint) DeepCopyInto 

func (in *VpDeploymentStartFromSavepoint) DeepCopyInto(out *VpDeploymentStartFromSavepoint)

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

type VpDeploymentStatus 

type VpDeploymentStatus struct {

	// +optional
	State DeploymentState `json:"state,omitempty"`
}

VpDeploymentStatus defines the observed state of VpDeployment

func (*VpDeploymentStatus) DeepCopy 

func (in *VpDeploymentStatus) DeepCopy() *VpDeploymentStatus

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

func (*VpDeploymentStatus) DeepCopyInto 

func (in *VpDeploymentStatus) DeepCopyInto(out *VpDeploymentStatus)

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

type VpDeploymentTarget 

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

	Spec VpDeploymentTargetObjectSpec `json:"spec,omitempty"`
}

VpDeploymentTarget is the Schema for the vpdeploymenttargets API

func (*VpDeploymentTarget) DeepCopy 

func (in *VpDeploymentTarget) DeepCopy() *VpDeploymentTarget

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

func (*VpDeploymentTarget) DeepCopyInto 

func (in *VpDeploymentTarget) DeepCopyInto(out *VpDeploymentTarget)

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

func (*VpDeploymentTarget) DeepCopyObject 

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

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

func (*VpDeploymentTarget) Hub added in v0.7.0 

func (*VpDeploymentTarget) Hub()

func (*VpDeploymentTarget) SetupWebhookWithManager added in v0.7.0 

func (r *VpDeploymentTarget) SetupWebhookWithManager(mgr ctrl.Manager) error

type VpDeploymentTargetList 

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

VpDeploymentTargetList contains a list of VpDeploymentTarget

func (*VpDeploymentTargetList) DeepCopy 

func (in *VpDeploymentTargetList) DeepCopy() *VpDeploymentTargetList

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

func (*VpDeploymentTargetList) DeepCopyInto 

func (in *VpDeploymentTargetList) DeepCopyInto(out *VpDeploymentTargetList)

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

func (*VpDeploymentTargetList) DeepCopyObject 

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

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

type VpDeploymentTargetObjectSpec 

type VpDeploymentTargetObjectSpec struct {

	// +optional
	Metadata VpMetadata `json:"metadata,omitempty"`
	// +optional
	Spec VpDeploymentTargetSpec `json:"spec,omitempty"`
}

VpDeploymentTargetObjectSpec defines the desired state of VpDeploymentTarget

func (*VpDeploymentTargetObjectSpec) DeepCopy 

func (in *VpDeploymentTargetObjectSpec) DeepCopy() *VpDeploymentTargetObjectSpec

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

func (*VpDeploymentTargetObjectSpec) DeepCopyInto 

func (in *VpDeploymentTargetObjectSpec) DeepCopyInto(out *VpDeploymentTargetObjectSpec)

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

type VpDeploymentTargetSpec 

type VpDeploymentTargetSpec struct {
	Kubernetes VpKubernetesTarget `json:"kubernetes"`
	// +optional
	DeploymentPatchSet []JSONPatchGeneric `json:"deploymentPatchSet,omitempty"`
}

VpDeploymentTargetSpec allows a users to set defaults for deployments and configure K8s

func (*VpDeploymentTargetSpec) DeepCopy 

func (in *VpDeploymentTargetSpec) DeepCopy() *VpDeploymentTargetSpec

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

func (*VpDeploymentTargetSpec) DeepCopyInto 

func (in *VpDeploymentTargetSpec) DeepCopyInto(out *VpDeploymentTargetSpec)

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

type VpDeploymentTemplate 

type VpDeploymentTemplate struct {
	// +optional
	Metadata *VpDeploymentTemplateMetadata `json:"metadata,omitempty"`

	Spec *VpDeploymentTemplateSpec `json:"spec"`
}

VpDeploymentTemplate is the template for Deployment jobs

func (*VpDeploymentTemplate) DeepCopy 

func (in *VpDeploymentTemplate) DeepCopy() *VpDeploymentTemplate

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

func (*VpDeploymentTemplate) DeepCopyInto 

func (in *VpDeploymentTemplate) DeepCopyInto(out *VpDeploymentTemplate)

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

type VpDeploymentTemplateMetadata 

type VpDeploymentTemplateMetadata struct {
	// +optional
	Annotations map[string]string `json:"annotations,omitempty"`
}

VpDeploymentTemplateMetadata

func (*VpDeploymentTemplateMetadata) DeepCopy 

func (in *VpDeploymentTemplateMetadata) DeepCopy() *VpDeploymentTemplateMetadata

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

func (*VpDeploymentTemplateMetadata) DeepCopyInto 

func (in *VpDeploymentTemplateMetadata) DeepCopyInto(out *VpDeploymentTemplateMetadata)

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

type VpDeploymentTemplateSpec 

type VpDeploymentTemplateSpec struct {
	Artifact *VpArtifact `json:"artifact"`
	// +optional
	// +kubebuilder:validation:Minimum=1
	Parallelism *int32 `json:"parallelism,omitempty"`
	// +optional
	// +kubebuilder:validation:Minimum=1
	NumberOfTaskManagers *int32 `json:"numberOfTaskManagers,omitempty"`
	// +optional
	Resources map[string]VpResourceSpec `json:"resources,omitempty"`
	// +optional
	FlinkConfiguration map[string]string `json:"flinkConfiguration,omitempty"`
	// +optional
	Logging *VpLogging `json:"logging,omitempty"`
	// +optional
	Kubernetes *VpKubernetesOptions `json:"kubernetes,omitempty"`
}

VpDeploymentTemplateSpec is the base spec for Deployment jobs

func (*VpDeploymentTemplateSpec) DeepCopy 

func (in *VpDeploymentTemplateSpec) DeepCopy() *VpDeploymentTemplateSpec

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

func (*VpDeploymentTemplateSpec) DeepCopyInto 

func (in *VpDeploymentTemplateSpec) DeepCopyInto(out *VpDeploymentTemplateSpec)

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

type VpDeploymentUpgradeStrategy 

type VpDeploymentUpgradeStrategy struct {
	// +optional
	Kind string `json:"kind,omitempty"`
}

VpDeploymentUpgradeStrategy describes how to upgrade a job

func (*VpDeploymentUpgradeStrategy) DeepCopy 

func (in *VpDeploymentUpgradeStrategy) DeepCopy() *VpDeploymentUpgradeStrategy

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

func (*VpDeploymentUpgradeStrategy) DeepCopyInto 

func (in *VpDeploymentUpgradeStrategy) DeepCopyInto(out *VpDeploymentUpgradeStrategy)

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

type VpKubernetesOptions 

type VpKubernetesOptions struct {
	Pods *VpPodSpec `json:"pods,omitempty"`
}

VpKubernetesOptions allows users to configure K8s pods for Deployments

func (*VpKubernetesOptions) DeepCopy 

func (in *VpKubernetesOptions) DeepCopy() *VpKubernetesOptions

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

func (*VpKubernetesOptions) DeepCopyInto 

func (in *VpKubernetesOptions) DeepCopyInto(out *VpKubernetesOptions)

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

type VpKubernetesTarget 

type VpKubernetesTarget struct {
	// +optional
	Namespace string `json:"namespace,omitempty"`
}

VpKubernetesTarget allows a user to configure k8s specific options

func (*VpKubernetesTarget) DeepCopy 

func (in *VpKubernetesTarget) DeepCopy() *VpKubernetesTarget

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

func (*VpKubernetesTarget) DeepCopyInto 

func (in *VpKubernetesTarget) DeepCopyInto(out *VpKubernetesTarget)

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

type VpLogging 

type VpLogging struct {
	// +optional
	Log4jLoggers map[string]string `json:"log4jLoggers,omitempty"`
}

VpLogging configures various loggers

func (*VpLogging) DeepCopy 

func (in *VpLogging) DeepCopy() *VpLogging

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

func (*VpLogging) DeepCopyInto 

func (in *VpLogging) DeepCopyInto(out *VpLogging)

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

type VpMetadata 

type VpMetadata struct {
	// +optional
	Namespace string `json:"namespace,omitempty"`
	// +optional
	Labels map[string]string `json:"labels,omitempty"`
	// +optional
	Annotations map[string]string `json:"annotations,omitempty"`
}

VpMetadata represents the base metadata for VP resources

func (*VpMetadata) DeepCopy 

func (in *VpMetadata) DeepCopy() *VpMetadata

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

func (*VpMetadata) DeepCopyInto 

func (in *VpMetadata) DeepCopyInto(out *VpMetadata)

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

type VpNamespace 

type VpNamespace struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              VpNamespaceSpec   `json:"spec,omitempty"`
	Status            VpNamespaceStatus `json:"status,omitempty"`
}

VpNamespace is the Schema for the vpnamespaces API

func (*VpNamespace) DeepCopy 

func (in *VpNamespace) DeepCopy() *VpNamespace

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

func (*VpNamespace) DeepCopyInto 

func (in *VpNamespace) DeepCopyInto(out *VpNamespace)

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

func (*VpNamespace) DeepCopyObject 

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

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

type VpNamespaceList 

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

VpNamespaceList contains a list of VpNamespace

func (*VpNamespaceList) DeepCopy 

func (in *VpNamespaceList) DeepCopy() *VpNamespaceList

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

func (*VpNamespaceList) DeepCopyInto 

func (in *VpNamespaceList) DeepCopyInto(out *VpNamespaceList)

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

func (*VpNamespaceList) DeepCopyObject 

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

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

type VpNamespaceSpec 

type VpNamespaceSpec struct {

	// +optional
	RoleBindings []NamespaceRoleBinding `json:"roleBindings,omitempty"`
}

VpNamespaceSpec defines the desired state of VpNamespace

func (*VpNamespaceSpec) DeepCopy 

func (in *VpNamespaceSpec) DeepCopy() *VpNamespaceSpec

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

func (*VpNamespaceSpec) DeepCopyInto 

func (in *VpNamespaceSpec) DeepCopyInto(out *VpNamespaceSpec)

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

type VpNamespaceStatus 

type VpNamespaceStatus struct {

	// +optional
	LifecyclePhase NamespaceLifecyclePhase `json:"lifecyclePhase,omitempty"`
}

VpNamespaceStatus defines the observed state of VpNamespace

func (*VpNamespaceStatus) DeepCopy 

func (in *VpNamespaceStatus) DeepCopy() *VpNamespaceStatus

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

func (*VpNamespaceStatus) DeepCopyInto 

func (in *VpNamespaceStatus) DeepCopyInto(out *VpNamespaceStatus)

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

type VpPodSpec 

type VpPodSpec struct {
	// +optional
	Annotations map[string]string `json:"annotations,omitempty"`
	// List of environment variables to set in the container.
	// Cannot be updated.
	// +optional
	// +patchMergeKey=name
	// +patchStrategy=merge
	EnvVars []core.EnvVar `json:"envVars,omitempty" patchStrategy:"merge" patchMergeKey:"name"`

	// +optional
	VolumeMounts []VpVolumeAndMount `json:"volumeMounts,omitempty"`

	// NodeSelector is a selector which must be true for the pod to fit on a node.
	// Selector which must match a node's labels for the pod to be scheduled on that node.
	// More info: https://kubernetes.io/docs/concepts/configuration/assign-pod-node/
	// +optional
	NodeSelector map[string]string `json:"nodeSelector,omitempty" protobuf:"bytes,7,rep,name=nodeSelector"`
	// SecurityContext holds pod-level security attributes and common container settings.
	// Optional: Defaults to empty.  See type description for default values of each field.
	// +optional
	SecurityContext *core.PodSecurityContext `json:"securityContext,omitempty" protobuf:"bytes,14,opt,name=securityContext"`
	// ImagePullSecrets is an optional list of references to secrets in the same namespace to use for pulling any of the images used by this PodSpec.
	// If specified, these secrets will be passed to individual puller implementations for them to use. For example,
	// in the case of docker, only DockerConfig type secrets are honored.
	// More info: https://kubernetes.io/docs/concepts/containers/images#specifying-imagepullsecrets-on-a-pod
	// +optional
	// +patchMergeKey=name
	// +patchStrategy=merge
	ImagePullSecrets []core.LocalObjectReference `json:"imagePullSecrets,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,15,rep,name=imagePullSecrets"`
	// If specified, the pod's scheduling constraints
	// +optional
	Affinity *core.Affinity `json:"affinity,omitempty" protobuf:"bytes,18,opt,name=affinity"`
	// If specified, the pod's tolerations.
	// +optional
	Tolerations []core.Toleration `json:"tolerations,omitempty" protobuf:"bytes,22,opt,name=tolerations"`
}

VpPodSpec is a subset of core.PodSpec, with annotations, env => envVars, and volume mounts

func (*VpPodSpec) DeepCopy 

func (in *VpPodSpec) DeepCopy() *VpPodSpec

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

func (*VpPodSpec) DeepCopyInto 

func (in *VpPodSpec) DeepCopyInto(out *VpPodSpec)

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

type VpResourceSpec 

type VpResourceSpec struct {
	// +optional
	CPU resource.Quantity `json:"cpu,omitempty"`
	// +optional
	// +kubebuilder:validation:minLength=2
	Memory *string `json:"memory,omitempty"`
}

VpResourceSpec represents the resource requirements for components like the job and task managers

func (*VpResourceSpec) DeepCopy 

func (in *VpResourceSpec) DeepCopy() *VpResourceSpec

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

func (*VpResourceSpec) DeepCopyInto 

func (in *VpResourceSpec) DeepCopyInto(out *VpResourceSpec)

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

type VpSavepoint 

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

	Spec   VpSavepointObjectSpec `json:"spec,omitempty"`
	Status VpSavepointStatus     `json:"status,omitempty"`
}

VpSavepoint is the Schema for the vpsavepoints API

func (*VpSavepoint) DeepCopy 

func (in *VpSavepoint) DeepCopy() *VpSavepoint

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

func (*VpSavepoint) DeepCopyInto 

func (in *VpSavepoint) DeepCopyInto(out *VpSavepoint)

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

func (*VpSavepoint) DeepCopyObject 

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

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

type VpSavepointFailure 

type VpSavepointFailure struct {
	// +optional
	FailedAt string `json:"failedAt,omitempty"`
	// +optional
	Message string `json:"message,omitempty"`
	// +optional
	Reason string `json:"reason,omitempty"`
}

func (*VpSavepointFailure) DeepCopy 

func (in *VpSavepointFailure) DeepCopy() *VpSavepointFailure

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

func (*VpSavepointFailure) DeepCopyInto 

func (in *VpSavepointFailure) DeepCopyInto(out *VpSavepointFailure)

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

type VpSavepointList 

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

VpSavepointList contains a list of VpSavepoint

func (*VpSavepointList) DeepCopy 

func (in *VpSavepointList) DeepCopy() *VpSavepointList

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

func (*VpSavepointList) DeepCopyInto 

func (in *VpSavepointList) DeepCopyInto(out *VpSavepointList)

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

func (*VpSavepointList) DeepCopyObject 

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

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

type VpSavepointMetadata 

type VpSavepointMetadata struct {
	// +optional
	VpMetadata `json:",inline"`

	// Can be specified through the .spec.deploymentName
	// +optional
	DeploymentID string `json:"deploymentId,omitempty"`
}

func (*VpSavepointMetadata) DeepCopy 

func (in *VpSavepointMetadata) DeepCopy() *VpSavepointMetadata

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

func (*VpSavepointMetadata) DeepCopyInto 

func (in *VpSavepointMetadata) DeepCopyInto(out *VpSavepointMetadata)

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

type VpSavepointObjectSpec 

type VpSavepointObjectSpec struct {
	// +optional
	Metadata VpSavepointMetadata `json:"metadata,omitempty"`

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

	// DeploymentName is an extension on the VP API
	// Must provide a spec.metadata.deploymentId if not set
	// +optional
	DeploymentName string `json:"deploymentName,omitempty"`
}

VpSavepointSpec defines the desired state of VpSavepoint

func (*VpSavepointObjectSpec) DeepCopy 

func (in *VpSavepointObjectSpec) DeepCopy() *VpSavepointObjectSpec

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

func (*VpSavepointObjectSpec) DeepCopyInto 

func (in *VpSavepointObjectSpec) DeepCopyInto(out *VpSavepointObjectSpec)

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

type VpSavepointSpec 

type VpSavepointSpec struct {
	SavepointLocation string `json:"savepointLocation"`
	FlinkSavepointID  string `json:"flinkSavepointId"`
}

func (*VpSavepointSpec) DeepCopy 

func (in *VpSavepointSpec) DeepCopy() *VpSavepointSpec

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

func (*VpSavepointSpec) DeepCopyInto 

func (in *VpSavepointSpec) DeepCopyInto(out *VpSavepointSpec)

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

type VpSavepointStatus 

type VpSavepointStatus struct {
	State SavepointState `json:"state"`
	// +optional
	Failure VpSavepointFailure `json:"failure,omitempty"`
}

VpSavepointStatus defines the observed state of VpSavepoint

func (*VpSavepointStatus) DeepCopy 

func (in *VpSavepointStatus) DeepCopy() *VpSavepointStatus

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

func (*VpSavepointStatus) DeepCopyInto 

func (in *VpSavepointStatus) DeepCopyInto(out *VpSavepointStatus)

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

type VpVolumeAndMount 

type VpVolumeAndMount struct {
	Name        string            `json:"name"`
	Volume      *core.Volume      `json:"volume"`
	VolumeMount *core.VolumeMount `json:"volumeMount"`
}

VpVolumeAndMount is a wrapper around both core.Volume and core.VolumeMount

func (*VpVolumeAndMount) DeepCopy 

func (in *VpVolumeAndMount) DeepCopy() *VpVolumeAndMount

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

func (*VpVolumeAndMount) DeepCopyInto 

func (in *VpVolumeAndMount) DeepCopyInto(out *VpVolumeAndMount)

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.