v1beta1

package
v0.5.2 Latest Latest
Warning

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

 Go to latest Published: Jun 25, 2022 License: MIT Imports: 5 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

This section is empty.

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

	FlinkVersion string `json:"flinkVersion"`

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

	ServiceAccount string `json:"serviceAccount"`

	JobManager JobManagerSpec `json:"jobManager"`

	TaskManager TaskManagerSpec `json:"taskManager"`

	JobSpec JobSpec `json:"job,omitempty"`

	PodTemplate corev1.PodTemplate `json:"podTemplate,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 {
	JobManagerStatus string `json:"jobManagerDeploymentStatus"`
}

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

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

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.

type FlinkSessionJobStatus 

type FlinkSessionJobStatus struct {
	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"`
}

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

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.

type ResourceSpec 

type ResourceSpec struct {
	Memory string  `json:"memory"`
	CPU    float32 `json:"cpu"`
}

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 TaskManagerSpec 

type TaskManagerSpec struct {
	Resource ResourceSpec `json:"resource"`
}

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.