k8sflink

func (*Flink) Cancel ¶

func (f *Flink) Cancel(ctx context.Context, spec interface{}) (interface{}, error)

Cancel method cancel flinkcluster job mod and job state must is running

func (*Flink) CapacityInfo ¶

func (f *Flink) CapacityInfo() apistructs.CapacityInfoData

func (*Flink) CleanUpBeforeDelete ¶

func (f *Flink) CleanUpBeforeDelete()

func (*Flink) Create ¶

func (f *Flink) Create(ctx context.Context, spec interface{}) (interface{}, error)

Create method create flinkcluster cr to flink-operator by controller-runtime client

func (*Flink) Destroy ¶

func (f *Flink) Destroy(ctx context.Context, spec interface{}) error

Destroy method delete flinkcluster cr by Remove method

func (*Flink) GetClusterInfo ¶

func (f *Flink) GetClusterInfo(name string) (map[string]string, error)

func (*Flink) GetFlinkClusterInfo ¶

func (f *Flink) GetFlinkClusterInfo(ctx context.Context, data apistructs.BigdataConf) (*flinkoperatorv1beta1.FlinkCluster, error)

GetFlinkClusterInfo get flinkcluster info from controller-runtime client

func (*Flink) Inspect ¶

func (f *Flink) Inspect(ctx context.Context, spec interface{}) (interface{}, error)

Inspect method get flinkCluster cr by controller-runtime client

func (*Flink) JobVolumeCreate ¶

func (f *Flink) JobVolumeCreate(ctx context.Context, spec interface{}) (string, error)

func (*Flink) KillPod ¶

func (f *Flink) KillPod(podname string) error

func (*Flink) Kind ¶

func (f *Flink) Kind() executortypes.Kind

Kind implements executortypes.Executor interface

func (*Flink) Name ¶

func (f *Flink) Name() executortypes.Name

Name implements executortypes.Executor interface

func (*Flink) Precheck ¶

func (f *Flink) Precheck(ctx context.Context, spec interface{}) (apistructs.ServiceGroupPrecheckData, error)

func (*Flink) Remove ¶

func (f *Flink) Remove(ctx context.Context, spec interface{}) error

Remove method delete flinkcluster cr by controller-runtime client

func (*Flink) ResourceInfo ¶

func (f *Flink) ResourceInfo(brief bool) (apistructs.ClusterResourceInfoData, error)

func (*Flink) Scale ¶ added in v1.0.1

func (f *Flink) Scale(ctx context.Context, spec interface{}) (interface{}, error)

func (*Flink) SetNodeLabels ¶

func (f *Flink) SetNodeLabels(setting executortypes.NodeLabelSetting, hosts []string, labels map[string]string) error

func (*Flink) Status ¶

func (f *Flink) Status(ctx context.Context, spec interface{}) (apistructs.StatusDesc, error)

Status method get status from flinkcluster cr by controller-runtime client

func (*Flink) Update ¶

func (f *Flink) Update(ctx context.Context, spec interface{}) (interface{}, error)

Update method update flinkcluster cr by controller-runtime client. and Update method is not used in Dice 3.21