k8sflink

Documentation

Index

• Constants
• Variables
• type K8sFlink
  • func New(name types.Name, clusterName string, cluster apistructs.ClusterInfo) (*K8sFlink, error)
  • func (k *K8sFlink) CleanUp(ctx context.Context, namespace string) error
  • func (k *K8sFlink) ComposeFlinkCluster(job apistructs.JobFromUser, data apistructs.BigdataConf, hostURL string) *flinkoperatorv1beta1.FlinkCluster
  • func (k *K8sFlink) Delete(ctx context.Context, task *spec.PipelineTask) (data interface{}, err error)
  • func (k *K8sFlink) GetFlinkClusterInfo(ctx context.Context, data apistructs.BigdataConf) (*flinkoperatorv1beta1.FlinkCluster, error)
  • func (k *K8sFlink) Inspect(ctx context.Context, task *spec.PipelineTask) (apistructs.TaskInspect, error)
  • func (k *K8sFlink) Kind() types.Kind
  • func (k *K8sFlink) Name() types.Name
  • func (k *K8sFlink) Start(ctx context.Context, task *spec.PipelineTask) (data interface{}, err error)
  • func (k *K8sFlink) Status(ctx context.Context, task *spec.PipelineTask) (statusDesc apistructs.PipelineStatusDesc, err error)

Constants

const (
	DiceRootDomain    = "DICE_ROOT_DOMAIN"
	K8SFlinkLogPrefix = "[k8sflink]"
)

const (
	FlinkIngressPrefix = "flinkcluster"
)

Variables

var Kind = types.Kind(spec.PipelineTaskExecutorKindK8sFlink)

Types

type K8sFlink

type K8sFlink struct {
	*types.K8sExecutor
	// contains filtered or unexported fields
}

func New

func New(name types.Name, clusterName string, cluster apistructs.ClusterInfo) (*K8sFlink, error)

func (*K8sFlink) CleanUp

func (k *K8sFlink) CleanUp(ctx context.Context, namespace string) error

func (*K8sFlink) ComposeFlinkCluster

func (k *K8sFlink) ComposeFlinkCluster(job apistructs.JobFromUser, data apistructs.BigdataConf, hostURL string) *flinkoperatorv1beta1.FlinkCluster

func (*K8sFlink) Delete

func (k *K8sFlink) Delete(ctx context.Context, task *spec.PipelineTask) (data interface{}, err error)

func (*K8sFlink) GetFlinkClusterInfo

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

func (*K8sFlink) Inspect

func (k *K8sFlink) Inspect(ctx context.Context, task *spec.PipelineTask) (apistructs.TaskInspect, error)

Inspect k8sflink doesn`t support inspect, flinkcluster`s logs are too long

func (*K8sFlink) Kind

func (k *K8sFlink) Kind() types.Kind

func (*K8sFlink) Name

func (k *K8sFlink) Name() types.Name

func (*K8sFlink) Start

func (k *K8sFlink) Start(ctx context.Context, task *spec.PipelineTask) (data interface{}, err error)

func (*K8sFlink) Status

func (k *K8sFlink) Status(ctx context.Context, task *spec.PipelineTask) (statusDesc apistructs.PipelineStatusDesc, err error)