executor

Documentation

Index

• func NewArchivesHandler(e *Executor) *archivesHandler
• func NewLogsHandler(logger *zap.Logger, e *Executor) *logsHandler
• func NewTaskSubmissionHandler(c chan<- *types.ExecutorTask) *taskSubmissionHandler
• type Executor
  • func NewExecutor(c *config.Executor) (*Executor, error)
  • func (e *Executor) Run(ctx context.Context) error

Functions

func NewArchivesHandler

func NewArchivesHandler(e *Executor) *archivesHandler

func NewLogsHandler

func NewLogsHandler(logger *zap.Logger, e *Executor) *logsHandler

func NewTaskSubmissionHandler

func NewTaskSubmissionHandler(c chan<- *types.ExecutorTask) *taskSubmissionHandler

Types

type Executor

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

func NewExecutor

func NewExecutor(c *config.Executor) (*Executor, error)

func (*Executor) Run

func (e *Executor) Run(ctx context.Context) error