types

Documentation

Index

• Variables
• func MustRegister(kind Kind, create CreateFn)
• func Register(kind Kind, create CreateFn) error
• type CreateFn
• type Kind
  • func (k Kind) String() string
• type Name
  • func (n Name) String() string
• type TaskExecutor

Variables

var Factory = map[Kind]CreateFn{}

Functions

func MustRegister

func MustRegister(kind Kind, create CreateFn)

func Register

func Register(kind Kind, create CreateFn) error

Types

type CreateFn

type CreateFn func(name Name, clusterName string, cluster apistructs.ClusterInfo) (TaskExecutor, error)

type Kind

type Kind string

Kind return the task executor type

func (Kind) String

func (k Kind) String() string

type Name

type Name string

Name return the task executor name

func (Name) String

func (n Name) String() string

type TaskExecutor

type TaskExecutor interface {
	Kind() Kind
	Name() Name

	Status(ctx context.Context, task *spec.PipelineTask) (apistructs.StatusDesc, error)
	Create(ctx context.Context, task *spec.PipelineTask) (interface{}, error)
	Remove(ctx context.Context, task *spec.PipelineTask) (interface{}, error)
	BatchDelete(ctx context.Context, tasks []*spec.PipelineTask) (interface{}, error)
	Inspect(ctx context.Context, task *spec.PipelineTask) (apistructs.TaskInspect, error)
}