v1beta1

package
v0.8.3 Latest Latest
Warning

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

 Go to latest Published: May 31, 2023 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

Package v1beta1 contains API Schema definitions for the Apache Flink Operator v1beta1 API group +kubebuilder:object:generate=true +groupName=flink.apache.org

Index

Constants

View Source 
const (
	JobManagerStatusReady = "READY"

	JobManagerStatusDeployedNotReady = "DEPLOYED_NOT_READY"

	JobManagerStatusDeploying = "DEPLOYING"

	// TODO: currently a mix of SUSPENDED and ERROR, needs cleanup
	JobManagerStatusMissing = "MISSING"

	JobManagerStatusError = "ERROR"
)
View Source 
const (
	UpgradeModeSavepoint = "savepoint"
	UpgradeModeLastState = "last-state"
	UpgradeModeStateless = "stateless"
)
View Source 
const (
	SessionJobStateRunning   = "running"
	SessionJobStateSuspended = "suspended"
)
View Source 
const (
	FlinkJobStateRunning = "RUNNING"
)

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "flink.apache.org", 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

func IsArgsEqual added in v0.6.0 

func IsArgsEqual(first []string, second []string) bool

Types

type FlinkDeployment 

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

	Spec   FlinkDeploymentSpec   `json:"spec"`
	Status FlinkDeploymentStatus `json:"status"`
}

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"`
}

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 {
	Image string `json:"image"`

	ImagePullPolicy string `json:"imagePullPolicy,omitempty"`

	FlinkVersion string `json:"flinkVersion"`

	FlinkConfiguration map[string]string `json:"flinkConfiguration,omitempty"`

	LogConfiguration map[string]string `json:"logConfiguration,omitempty"`

	ServiceAccount string `json:"serviceAccount"`

	JobManager JobManagerSpec `json:"jobManager"`

	TaskManager TaskManagerSpec `json:"taskManager"`

	JobSpec JobSpec `json:"job,omitempty"`

	PodTemplate corev1.PodTemplate `json:"podTemplate,omitempty"`

	RestartNonce int64 `json:"restartNonce,omitempty"`
}

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 {
	// ReconciliationStatus string            `json:"reconciliationStatus,omitempty"`
	JobManagerStatus string            `json:"jobManagerDeploymentStatus"`
	ClusterInfo      map[string]string `json:"clusterInfo"`
	TaskManager      TaskManagerInfo   `json:"taskManager"`
}

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 FlinkJobStatusSpec added in v0.2.1 

type FlinkJobStatusSpec struct {
	JobId      string `json:"jobId"`
	JobName    string `json:"jobName"`
	State      string `json:"state"`
	StartTime  string `json:"startTime"`
	UpdateTime string `json:"updateTime"`
}

func (*FlinkJobStatusSpec) DeepCopy added in v0.2.1 

func (in *FlinkJobStatusSpec) DeepCopy() *FlinkJobStatusSpec

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

func (*FlinkJobStatusSpec) DeepCopyInto added in v0.2.1 

func (in *FlinkJobStatusSpec) DeepCopyInto(out *FlinkJobStatusSpec)

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

type FlinkSessionJob 

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

	Spec   FlinkSessionJobSpec   `json:"spec"`
	Status FlinkSessionJobStatus `json:"status"`
}

func (*FlinkSessionJob) DeepCopy 

func (in *FlinkSessionJob) DeepCopy() *FlinkSessionJob

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

func (*FlinkSessionJob) DeepCopyInto 

func (in *FlinkSessionJob) DeepCopyInto(out *FlinkSessionJob)

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

func (*FlinkSessionJob) DeepCopyObject 

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

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

type FlinkSessionJobList 

type FlinkSessionJobList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`

	Items []FlinkSessionJob `json:"items"`
}

func (*FlinkSessionJobList) DeepCopy 

func (in *FlinkSessionJobList) DeepCopy() *FlinkSessionJobList

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

func (*FlinkSessionJobList) DeepCopyInto 

func (in *FlinkSessionJobList) DeepCopyInto(out *FlinkSessionJobList)

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

func (*FlinkSessionJobList) DeepCopyObject 

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

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

type FlinkSessionJobSpec 

type FlinkSessionJobSpec struct {
	DeploymentName     string            `json:"deploymentName"`
	Job                JobSpec           `json:"job"`
	RestartNonce       int64             `json:"restartNonce,omitempty"`
	FlinkConfiguration map[string]string `json:"flinkConfiguration,omitempty"`
}

func (*FlinkSessionJobSpec) DeepCopy 

func (in *FlinkSessionJobSpec) DeepCopy() *FlinkSessionJobSpec

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

func (*FlinkSessionJobSpec) DeepCopyInto 

func (in *FlinkSessionJobSpec) DeepCopyInto(out *FlinkSessionJobSpec)

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

func (*FlinkSessionJobSpec) Equals added in v0.6.0 

func (sessionJob *FlinkSessionJobSpec) Equals(other *FlinkSessionJobSpec) bool

type FlinkSessionJobStatus 

type FlinkSessionJobStatus struct {
	// reconciliationStatus string `json:"reconciliationStatus"`
	LifecycleState string             `json:"lifecycleState"`
	Error          string             `json:"error"`
	FlinkJobStatus FlinkJobStatusSpec `json:"jobStatus"`
}

func (*FlinkSessionJobStatus) DeepCopy 

func (in *FlinkSessionJobStatus) DeepCopy() *FlinkSessionJobStatus

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

func (*FlinkSessionJobStatus) DeepCopyInto 

func (in *FlinkSessionJobStatus) DeepCopyInto(out *FlinkSessionJobStatus)

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

type JobManagerSpec 

type JobManagerSpec struct {
	Replicas    int32              `json:"replicas"`
	Resource    ResourceSpec       `json:"resource"`
	PodTemplate corev1.PodTemplate `json:"podTemplate,omitempty"`
}

func (*JobManagerSpec) DeepCopy 

func (in *JobManagerSpec) DeepCopy() *JobManagerSpec

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

func (*JobManagerSpec) DeepCopyInto 

func (in *JobManagerSpec) DeepCopyInto(out *JobManagerSpec)

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

type JobSpec 

type JobSpec struct {
	JarURI                string   `json:"jarURI"`
	EntryClass            string   `json:"entryClass"`
	Args                  []string `json:"args,omitempty"`
	Parallelism           int32    `json:"parallelism"`
	State                 string   `json:"state"`
	UpgradeMode           string   `json:"upgradeMode"`
	SavepointTriggerNonce int64    `json:"savepointTriggerNonce,omitempty"`
	InitialSavepointPath  string   `json:"initialSavepointPath,omitempty"`
	AllowNonRestoredState bool     `json:"allowNonRestoredState,omitempty"`
}

func (*JobSpec) DeepCopy 

func (in *JobSpec) DeepCopy() *JobSpec

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

func (*JobSpec) DeepCopyInto 

func (in *JobSpec) DeepCopyInto(out *JobSpec)

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

func (*JobSpec) Equals added in v0.6.0 

func (job *JobSpec) Equals(other *JobSpec) bool

type ResourceSpec 

type ResourceSpec struct {
	Memory           string  `json:"memory"`
	CPU              float32 `json:"cpu"`
	EphemeralStorage string  `json:"ephemeralStorage,omitempty"`
}

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 TaskManagerInfo added in v0.8.0 

type TaskManagerInfo struct {
	Replicas      int32  `json:"replicas"`
	LabelSelector string `json:"labelSelector"`
}

func (*TaskManagerInfo) DeepCopy added in v0.8.0 

func (in *TaskManagerInfo) DeepCopy() *TaskManagerInfo

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

func (*TaskManagerInfo) DeepCopyInto added in v0.8.0 

func (in *TaskManagerInfo) DeepCopyInto(out *TaskManagerInfo)

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

type TaskManagerSpec 

type TaskManagerSpec struct {
	Resource    ResourceSpec       `json:"resource"`
	Replicas    int32              `json:"replicas,omitempty"`
	PodTemplate corev1.PodTemplate `json:"podTemplate,omitempty"`
}

func (*TaskManagerSpec) DeepCopy 

func (in *TaskManagerSpec) DeepCopy() *TaskManagerSpec

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

func (*TaskManagerSpec) DeepCopyInto 

func (in *TaskManagerSpec) DeepCopyInto(out *TaskManagerSpec)

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.