k8sspark

Documentation

Index

• Constants
• Variables
• type K8sSpark
  • func New(name types.Name, clusterName string, cluster apistructs.ClusterInfo) (*K8sSpark, error)
  • func (k *K8sSpark) CleanUp(ctx context.Context, namespace string) error
  • func (k *K8sSpark) Delete(ctx context.Context, task *spec.PipelineTask) (interface{}, error)
  • func (k *K8sSpark) Inspect(ctx context.Context, task *spec.PipelineTask) (apistructs.TaskInspect, error)
  • func (k *K8sSpark) Kind() types.Kind
  • func (k *K8sSpark) Name() types.Name
  • func (k *K8sSpark) Start(ctx context.Context, task *spec.PipelineTask) (data interface{}, err error)
  • func (k *K8sSpark) Status(ctx context.Context, task *spec.PipelineTask) (desc apistructs.PipelineStatusDesc, err error)

Constants

const (
	K8SLabelPrefix = "dice/"
)

const (
	K8SSparkLogPrefix = "[k8sspark]"
)

Variables

var Kind = types.Kind(spec.PipelineTaskExecutorKindK8sSpark)

Types

type K8sSpark

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

func New

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

func (*K8sSpark) CleanUp

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

func (*K8sSpark) Delete

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

func (*K8sSpark) Inspect

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

Inspect k8sspark doesn`t support inspect, sparkapp`s logs are too long

func (*K8sSpark) Kind

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

func (*K8sSpark) Name

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

func (*K8sSpark) Start

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

func (*K8sSpark) Status

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