k8sflink

Documentation

Index

• Constants
• Variables
• func ComposeFlinkCluster(data apistructs.BigdataConf, hostURL string) *flinkoperatorv1beta1.FlinkCluster
• type K8sFlink
  • func New(name types.Name, clusterName string, cluster apistructs.ClusterInfo) (*K8sFlink, error)
  • func (k *K8sFlink) BatchDelete(ctx context.Context, tasks []*spec.PipelineTask) (interface{}, error)
  • func (k *K8sFlink) Create(ctx context.Context, task *spec.PipelineTask) (interface{}, error)
  • func (k *K8sFlink) GetClusterInfo(name string) (map[string]string, 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) Remove(ctx context.Context, task *spec.PipelineTask) (interface{}, error)
  • func (k *K8sFlink) Status(ctx context.Context, task *spec.PipelineTask) (apistructs.StatusDesc, error)

Constants

const (
	DiceRootDomain    = "DICE_ROOT_DOMAIN"
	DiceClusterInfo   = "dice-cluster-info"
	K8SFlinkLogPrefix = "[k8sflink]"
)

const (
	FlinkIngressPrefix = "flinkcluster"
)

Variables

var Kind = types.Kind("k8sflink")

Functions

func ComposeFlinkCluster

func ComposeFlinkCluster(data apistructs.BigdataConf, hostURL string) *flinkoperatorv1beta1.FlinkCluster

Types

type K8sFlink

type K8sFlink struct {
	// contains filtered or unexported fields
}

func New

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

func (*K8sFlink) BatchDelete

func (k *K8sFlink) BatchDelete(ctx context.Context, tasks []*spec.PipelineTask) (interface{}, error)

func (*K8sFlink) Create

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

func (*K8sFlink) GetClusterInfo

func (k *K8sFlink) GetClusterInfo(name string) (map[string]string, 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) Remove

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

func (*K8sFlink) Status

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