v1

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: May 31, 2022 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Overview

Package v1 contains API Schema definitions for the flink v1 API group +kubebuilder:object:generate=true +groupName=flink.shang12360.cn

Index

Constants

View Source 
const (
	DefaultTopologyKey string = `kubernetes.io/hostname`
	FlinkNativeType    string = `flink-native-kubernetes`
)
View Source 
const (
	RequiredDuringScheduling  string = `Required`
	PreferredDuringScheduling string = `Preferred`
	NoneScheduling            string = `None`
)

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "flink.shang12360.cn", Version: "v1"}

	// 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 FlinkConfig added in v0.2.0 

type FlinkConfig struct {
	// 对应 $FLINK_HOME/conf/flink-conf.yaml ，不写使用镜像内预制配置文件
	//+nullable
	FlinkConf string `json:"flink-conf.yaml,omitempty"`
	// 对应 $FLINK_HOME/conf/log4j-console.properties ，不写使用镜像内预制配置文件
	//+nullable
	Log4j string `json:"log4j-console.properties,omitempty"`
	// 对应 $FLINK_HOME/conf/logback-console.xml ，不写使用镜像内预制配置文件
	//+nullable
	LogBack string `json:"logback-console.xml,omitempty"`
}

func (*FlinkConfig) DeepCopy added in v0.2.0 

func (in *FlinkConfig) DeepCopy() *FlinkConfig

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

func (*FlinkConfig) DeepCopyInto added in v0.2.0 

func (in *FlinkConfig) DeepCopyInto(out *FlinkConfig)

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

type FlinkHA added in v0.0.10 

type FlinkHA struct {
	// ha 类型，允许值 zookeeper  kubernetes none
	//+kubebuilder:validation:Enum={zookeeper,kubernetes,none}
	Typ FlinkHAType `json:"type,omitempty"`

	// 仅 zookeeper ha 生效，配置 zk 地址
	//+nullable
	Quorum string `json:"quorum,omitempty"`
	// 仅 zookeeper ha 生效，配置 ha 路径前缀
	//+nullable
	Path string `json:"path,omitempty"`
}

func (*FlinkHA) DeepCopy added in v0.0.10 

func (in *FlinkHA) DeepCopy() *FlinkHA

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

func (*FlinkHA) DeepCopyInto added in v0.0.10 

func (in *FlinkHA) DeepCopyInto(out *FlinkHA)

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

type FlinkHAType added in v0.0.10 

type FlinkHAType string
const (
	ZKHA        FlinkHAType = "zookeeper"
	CONFIGMAPHA FlinkHAType = "kubernetes"
	NONE        FlinkHAType = "none"
)

type FlinkResource added in v0.0.10 

type FlinkResource struct {
	// jobmanager 资源配置
	JobManager JobManagerFlinkResource `json:"jobManager,omitempty"`

	// taskmanager 资源配置
	TaskManager TaskManagerFlinkResource `json:"taskManager,omitempty"`
}

func (*FlinkResource) DeepCopy added in v0.0.10 

func (in *FlinkResource) DeepCopy() *FlinkResource

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

func (*FlinkResource) DeepCopyInto added in v0.0.10 

func (in *FlinkResource) DeepCopyInto(out *FlinkResource)

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

type FlinkS3 added in v0.0.10 

type FlinkS3 struct {
	// s3.endpoint
	//+kubebuilder:validation:MinLength=1
	EndPoint string `json:"endPoint,omitempty"`
	// s3.access-key
	//+kubebuilder:validation:MinLength=1
	AccessKey string `json:"accessKey,omitempty"`
	// s3.secret-key
	//+kubebuilder:validation:MinLength=1
	SecretKey string `json:"secretKey,omitempty"`
	// 部署 bucket
	//+kubebuilder:validation:MinLength=1
	Bucket string `json:"bucket"`
}

func (*FlinkS3) DeepCopy added in v0.0.10 

func (in *FlinkS3) DeepCopy() *FlinkS3

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

func (*FlinkS3) DeepCopyInto added in v0.0.10 

func (in *FlinkS3) DeepCopyInto(out *FlinkS3)

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

type FlinkSession 

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

	Spec   FlinkSessionSpec   `json:"spec,omitempty"`
	Status FlinkSessionStatus `json:"status,omitempty"`
}

FlinkSession is the Schema for the flinksessions API +kubebuilder:printcolumn:name="Ready",type="boolean",JSONPath=".status.ready" +kubebuilder:printcolumn:name="Port",type="integer",JSONPath=".status.port" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp"

func (*FlinkSession) DeepCopy 

func (in *FlinkSession) DeepCopy() *FlinkSession

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

func (*FlinkSession) DeepCopyInto 

func (in *FlinkSession) DeepCopyInto(out *FlinkSession)

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

func (*FlinkSession) DeepCopyObject 

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

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

func (*FlinkSession) Default added in v0.0.8 

func (r *FlinkSession) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*FlinkSession) GenerateCommand added in v0.0.10 

func (f *FlinkSession) GenerateCommand() (string, error)

func (*FlinkSession) GeneratePodTemplate added in v0.2.2 

func (f *FlinkSession) GeneratePodTemplate() string

func (*FlinkSession) SetupWebhookWithManager added in v0.0.8 

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

func (*FlinkSession) ValidateCreate added in v0.0.8 

func (r *FlinkSession) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*FlinkSession) ValidateDelete added in v0.0.8 

func (r *FlinkSession) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*FlinkSession) ValidateUpdate added in v0.0.8 

func (r *FlinkSession) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type FlinkSessionList 

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

FlinkSessionList contains a list of FlinkSession

func (*FlinkSessionList) DeepCopy 

func (in *FlinkSessionList) DeepCopy() *FlinkSessionList

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

func (*FlinkSessionList) DeepCopyInto 

func (in *FlinkSessionList) DeepCopyInto(out *FlinkSessionList)

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

func (*FlinkSessionList) DeepCopyObject 

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

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

type FlinkSessionSpec 

type FlinkSessionSpec struct {

	// 填写 flink 运行镜像 ,这个镜像为 flink taskmanager 以及 jobmanager 共用，不支持双镜像，必填
	//+kubebuilder:validation:MinLength=1
	Image string `json:"image,omitempty"`

	// 填写 flink 镜像拉取 secret
	//+nullable
	ImageSecret *string `json:"imageSecret,omitempty"`

	// 是否在修改配置重启flink时自动清除ha信息，必填
	AutoClean bool `json:"autoClean,omitempty"`

	// SA，填写集群运行的 k8s service account 配置
	//+kubebuilder:validation:MinLength=1
	Sa string `json:"sa,omitempty"`

	// flink 运行资源配置
	Resource FlinkResource `json:"resource,omitempty"`

	// taskmanager 可用槽位，对应 taskmanager.numberOfTaskSlots
	//+kubebuilder:validation:Minimum=1
	NumberOfTaskSlots int32 `json:"numberOfTaskSlots,omitempty"`

	// S3 配置
	S3 FlinkS3 `json:"s3,omitempty"`

	// flink ha 配置
	HA FlinkHA `json:"ha,omitempty"`

	// 自定义配置项
	//+nullable
	Config FlinkConfig `json:"config,omitempty"`

	// NodeSelector
	//+nullable
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`

	// 均衡调度策略 ，可选值： Required 必须每个节点调度一个 Preferred 尽可能每个节点调度一个 None 不设置均衡调度
	//+kubebuilder:validation:MinLength=1
	//+kubebuilder:validation:Enum={Required,Preferred,None}
	BalancedSchedule string `json:"balancedSchedule,omitempty"`

	Volumes []apiv1.Volume `json:"volumes,omitempty"`

	VolumeMounts []apiv1.VolumeMount `json:"volumeMounts,omitempty"`
}

FlinkSessionSpec defines the desired state of FlinkSession

func (*FlinkSessionSpec) DeepCopy 

func (in *FlinkSessionSpec) DeepCopy() *FlinkSessionSpec

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

func (*FlinkSessionSpec) DeepCopyInto 

func (in *FlinkSessionSpec) DeepCopyInto(out *FlinkSessionSpec)

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

type FlinkSessionStatus 

type FlinkSessionStatus struct {
	Ready bool  `json:"ready,omitempty"`
	Port  int32 `json:"port,omitempty"`
}

FlinkSessionStatus defines the observed state of FlinkSession

func (*FlinkSessionStatus) DeepCopy 

func (in *FlinkSessionStatus) DeepCopy() *FlinkSessionStatus

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

func (*FlinkSessionStatus) DeepCopyInto 

func (in *FlinkSessionStatus) DeepCopyInto(out *FlinkSessionStatus)

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

type JobManagerFlinkResource added in v0.0.10 

type JobManagerFlinkResource struct {
	// kubernetes.jobmanager.cpu
	CPU string `json:"cpu,omitempty"`
	// jobmanager.memory.process.size
	Memory string `json:"memory,omitempty"`
	// jobmanager.memory.jvm-metaspace.size
	JvmMetaspace string `json:"jvm-metaspace,omitempty"`
	// jobmanager.memory.off-heap.size
	OffHeap string `json:"off-heap,omitempty"`
}

JobManagerFlinkResource job manager 资源配置

func (*JobManagerFlinkResource) DeepCopy added in v0.0.10 

func (in *JobManagerFlinkResource) DeepCopy() *JobManagerFlinkResource

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

func (*JobManagerFlinkResource) DeepCopyInto added in v0.0.10 

func (in *JobManagerFlinkResource) DeepCopyInto(out *JobManagerFlinkResource)

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

type TaskManagerFlinkResource added in v0.0.10 

type TaskManagerFlinkResource struct {
	// kubernetes.taskmanager.cpu
	CPU string `json:"cpu,omitempty"`
	// taskmanager.memory.process.size
	Memory string `json:"memory,omitempty"`
	// taskmanager.memory.jvm-metaspace.size
	JvmMetaspace string `json:"jvm-metaspace,omitempty"`

	Framework TaskManagerFrameworkFlinkResource `json:"framework,omitempty"`
	Task      TaskManagerTaskFlinkResource      `json:"task,omitempty"`
	NetWork   TaskManagerNetWorkFlinkResource   `json:"netWork,omitempty"`
	Managed   TaskManagerManagedFlinkResource   `json:"managed,omitempty"`
}

TaskManagerFlinkResource task manager 资源配置

func (*TaskManagerFlinkResource) DeepCopy added in v0.0.10 

func (in *TaskManagerFlinkResource) DeepCopy() *TaskManagerFlinkResource

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

func (*TaskManagerFlinkResource) DeepCopyInto added in v0.0.10 

func (in *TaskManagerFlinkResource) DeepCopyInto(out *TaskManagerFlinkResource)

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

type TaskManagerFrameworkFlinkResource added in v0.0.10 

type TaskManagerFrameworkFlinkResource struct {
	// taskmanager.memory.framework.heap.size
	Heap string `json:"heap,omitempty"`
	// taskmanager.memory.framework.off-heap.size
	OffHeap string `json:"off-heap,omitempty"`
}

func (*TaskManagerFrameworkFlinkResource) DeepCopy added in v0.0.10 

func (in *TaskManagerFrameworkFlinkResource) DeepCopy() *TaskManagerFrameworkFlinkResource

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

func (*TaskManagerFrameworkFlinkResource) DeepCopyInto added in v0.0.10 

func (in *TaskManagerFrameworkFlinkResource) DeepCopyInto(out *TaskManagerFrameworkFlinkResource)

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

type TaskManagerManagedFlinkResource added in v0.0.10 

type TaskManagerManagedFlinkResource struct {
	// taskmanager.memory.managed.fraction ， 与 max min 仅其中一个配置生效，默认走max min
	Fraction string `json:"fraction,omitempty"`
	// taskmanager.memory.managed.min， 与 max min 仅其中一个配置生效，默认走max min
	Min string `json:"min,omitempty"`
	// taskmanager.memory.managed.max ， 与 max min 仅其中一个配置生效，默认走max min
	Max string `json:"max,omitempty"`
}

func (*TaskManagerManagedFlinkResource) DeepCopy added in v0.0.10 

func (in *TaskManagerManagedFlinkResource) DeepCopy() *TaskManagerManagedFlinkResource

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

func (*TaskManagerManagedFlinkResource) DeepCopyInto added in v0.0.10 

func (in *TaskManagerManagedFlinkResource) DeepCopyInto(out *TaskManagerManagedFlinkResource)

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

type TaskManagerNetWorkFlinkResource added in v0.0.10 

type TaskManagerNetWorkFlinkResource struct {
	// taskmanager.memory.network.fraction ， 与 max min 仅其中一个配置生效，默认走max min
	Fraction string `json:"fraction,omitempty"`
	// taskmanager.memory.network.min， 与 max min 仅其中一个配置生效，默认走max min
	Min string `json:"min,omitempty"`
	// taskmanager.memory.network.max ， 与 max min 仅其中一个配置生效，默认走max min
	Max string `json:"max,omitempty"`
}

func (*TaskManagerNetWorkFlinkResource) DeepCopy added in v0.0.10 

func (in *TaskManagerNetWorkFlinkResource) DeepCopy() *TaskManagerNetWorkFlinkResource

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

func (*TaskManagerNetWorkFlinkResource) DeepCopyInto added in v0.0.10 

func (in *TaskManagerNetWorkFlinkResource) DeepCopyInto(out *TaskManagerNetWorkFlinkResource)

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

type TaskManagerTaskFlinkResource added in v0.0.10 

type TaskManagerTaskFlinkResource struct {
	// taskmanager.memory.task.off-heap.size
	OffHeap string `json:"off-heap,omitempty"`
}

func (*TaskManagerTaskFlinkResource) DeepCopy added in v0.0.10 

func (in *TaskManagerTaskFlinkResource) DeepCopy() *TaskManagerTaskFlinkResource

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

func (*TaskManagerTaskFlinkResource) DeepCopyInto added in v0.0.10 

func (in *TaskManagerTaskFlinkResource) DeepCopyInto(out *TaskManagerTaskFlinkResource)

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.