executor

Documentation

Index

• func GetJobExecutorKindByName(name string) string
• type Empty
  • func (e *Empty) Cancel(ctx context.Context, spec interface{}) (interface{}, error)
  • func (e *Empty) Create(ctx context.Context, specObj interface{}) (interface{}, error)
  • func (e *Empty) Destroy(ctx context.Context, spec interface{}) error
  • func (e *Empty) Inspect(ctx context.Context, spec interface{}) (interface{}, error)
  • func (e *Empty) Kind() executortypes.Kind
  • func (e *Empty) Name() executortypes.Name
  • func (e *Empty) Remove(ctx context.Context, spec interface{}) error
  • func (e *Empty) Status(ctx context.Context, specObj interface{}) (apistructs.StatusDesc, error)
  • func (e *Empty) Update(ctx context.Context, specObj interface{}) (interface{}, error)
• type Manager
  • func GetManager() *Manager
  • func (m *Manager) Get(name executortypes.Name) (executortypes.Executor, error)
  • func (m *Manager) GetByKind(kind executortypes.Kind) []executortypes.Executor
  • func (m *Manager) GetExecutorConfigs(name executortypes.Name) (*executortypes.ExecutorWholeConfigs, error)
  • func (m *Manager) ListExecutors() []executortypes.Executor
  • func (m *Manager) Pool(name executortypes.Name) *goroutinepool.GoroutinePool
  • func (m *Manager) PrintPoolUsage()

Functions

func GetJobExecutorKindByName

func GetJobExecutorKindByName(name string) string

GetJobExecutorKindByName return executor Kind, e.g. METRONOME, according to user-defined job specification.

Types

type Empty

type Empty struct {
	ExecutorName executortypes.Name `json:"name,omitempty"`
	ExecutorKind executortypes.Kind `json:"kind,omitempty"`
}

func (*Empty) Cancel

func (e *Empty) Cancel(ctx context.Context, spec interface{}) (interface{}, error)

func (*Empty) Create

func (e *Empty) Create(ctx context.Context, specObj interface{}) (interface{}, error)

func (*Empty) Destroy

func (e *Empty) Destroy(ctx context.Context, spec interface{}) error

func (*Empty) Inspect

func (e *Empty) Inspect(ctx context.Context, spec interface{}) (interface{}, error)

func (*Empty) Kind

func (e *Empty) Kind() executortypes.Kind

func (*Empty) Name

func (e *Empty) Name() executortypes.Name

func (*Empty) Remove

func (e *Empty) Remove(ctx context.Context, spec interface{}) error

func (*Empty) Status

func (e *Empty) Status(ctx context.Context, specObj interface{}) (apistructs.StatusDesc, error)

func (*Empty) Update

func (e *Empty) Update(ctx context.Context, specObj interface{}) (interface{}, error)

type Manager

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

Manager is a executor manager, it holds the all executor instances.

func GetManager

func GetManager() *Manager

func (*Manager) Get

func (m *Manager) Get(name executortypes.Name) (executortypes.Executor, error)

Get returns the executor with name.

func (*Manager) GetByKind

func (m *Manager) GetByKind(kind executortypes.Kind) []executortypes.Executor

GetByKind returns the executor instances with specify kind.

func (*Manager) GetExecutorConfigs

func (m *Manager) GetExecutorConfigs(name executortypes.Name) (*executortypes.ExecutorWholeConfigs, error)

func (*Manager) ListExecutors

func (m *Manager) ListExecutors() []executortypes.Executor

ListExecutors returns the all executor instances.

func (*Manager) Pool

func (m *Manager) Pool(name executortypes.Name) *goroutinepool.GoroutinePool

func (*Manager) PrintPoolUsage

func (m *Manager) PrintPoolUsage()