k8sspark

Documentation

Index

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

Constants

const (
	K8SLabelPrefix = "dice/"
)

const (
	K8SSparkLogPrefix = "[k8sspark]"
)

Variables

var Kind = types.Kind("k8sspark")

Types

type K8sSpark

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

func New

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

func (*K8sSpark) BatchDelete

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

func (*K8sSpark) Create

func (k *K8sSpark) Create(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) Remove

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

func (*K8sSpark) Status

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