executor

Documentation

Index

• func NewArchivesHandler(e *Executor) *archivesHandler
• func NewLogsHandler(log zerolog.Logger, e *Executor) *logsHandler
• func NewTaskSubmissionHandler(c chan<- *rsapitypes.ExecutorTask) *taskSubmissionHandler
• type Executor
  • func NewExecutor(ctx context.Context, log zerolog.Logger, c *config.Executor) (*Executor, error)
  • func (e *Executor) Run(ctx context.Context) error
  • func (e *Executor) SendCache(ctx context.Context, fullCacheKey, cacheArchivePath string) error

Functions

func NewArchivesHandler

func NewArchivesHandler(e *Executor) *archivesHandler

func NewLogsHandler

func NewLogsHandler(log zerolog.Logger, e *Executor) *logsHandler

func NewTaskSubmissionHandler

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

Types

type Executor

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

func NewExecutor

func NewExecutor(ctx context.Context, log zerolog.Logger, c *config.Executor) (*Executor, error)

func (*Executor) Run

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

func (*Executor) SendCache

func (e *Executor) SendCache(ctx context.Context, fullCacheKey, cacheArchivePath string) error