types

Documentation

Index

• Variables
• func MustRegister(kind Kind, create CreateFn)
• func Register(kind Kind, create CreateFn) error
• type ActionExecutor
• type CreateFn
• type Kind
  • func (s Kind) String() string
  • func (s Kind) Validate() bool
• type Name
  • func (s Name) String() string
  • func (s Name) Validate() bool

Variables

var Factory = map[Kind]CreateFn{}

Functions

func MustRegister

func MustRegister(kind Kind, create CreateFn)

MustRegister panic if register failed.

func Register

func Register(kind Kind, create CreateFn) error

Register add an executor's create function.

Types

type ActionExecutor

type ActionExecutor interface {
	Kind() Kind
	Name() Name

	// Exist 返回 created, started, error
	Exist(ctx context.Context, action *spec.PipelineTask) (created bool, started bool, err error)
	// Create 保证幂等
	Create(ctx context.Context, action *spec.PipelineTask) (interface{}, error)
	// Start 保证幂等
	Start(ctx context.Context, action *spec.PipelineTask) (interface{}, error)
	Update(ctx context.Context, action *spec.PipelineTask) (interface{}, error)

	// Status 只做简单重试
	Status(ctx context.Context, action *spec.PipelineTask) (apistructs.PipelineStatusDesc, error)
	Inspect(ctx context.Context, action *spec.PipelineTask) (apistructs.TaskInspect, error)

	Cancel(ctx context.Context, action *spec.PipelineTask) (interface{}, error)
	Remove(ctx context.Context, action *spec.PipelineTask) (interface{}, error)
	BatchDelete(ctx context.Context, actions []*spec.PipelineTask) (interface{}, error)
}

type CreateFn

type CreateFn func(name Name, options map[string]string) (ActionExecutor, error)

Create be used to create an action executor instance.

type Kind

type Kind string

Kind represents an executor's type.

func (Kind) String

func (s Kind) String() string

func (Kind) Validate

func (s Kind) Validate() bool

type Name

type Name string

Name represents an executor's name.

func (Name) String

func (s Name) String() string

func (Name) Validate

func (s Name) Validate() bool