executor

Documentation

Overview

Package executor provides an abstraction of a job executor.

Index

• Variables
• type BacalhauExecutor
  • func (b *BacalhauExecutor) Execute(ctx context.Context, job config.Job, rawJob interface{}) (Result, error)
  • func (b *BacalhauExecutor) Render(job config.Job, inputs []ExecutorIOSpec, outputs []ExecutorIOSpec) (interface{}, error)
• type Executor
  • func NewBacalhauExecutor() Executor
  • func NewInternalExecutor() Executor
• type ExecutorIOSpec
• type InternalJob
• type Result

Variables

var (
	ErrCIDIsNotValid    = fmt.Errorf("cid is not valid")
	ErrJobNotSuccessful = fmt.Errorf("job was not successful")
)

var (
	ErrInternalJobNotFound = fmt.Errorf("internal job not found")
	ErrOnlyOneInput        = fmt.Errorf("must only be one input")
	ErrFailJobError        = fmt.Errorf("this is a test job that always fails")
)

Types

type BacalhauExecutor

type BacalhauExecutor struct {
	Client *publicapi.RequesterAPIClient
}

func (*BacalhauExecutor) Execute

func (b *BacalhauExecutor) Execute(ctx context.Context, job config.Job, rawJob interface{}) (Result, error)

func (*BacalhauExecutor) Render

func (b *BacalhauExecutor) Render(job config.Job, inputs []ExecutorIOSpec, outputs []ExecutorIOSpec) (interface{}, error)

type Executor

type Executor interface {
	Execute(context.Context, config.Job, interface{}) (Result, error)
	Render(config.Job, []ExecutorIOSpec, []ExecutorIOSpec) (interface{}, error)
}

Executor abstracts the execution of a job

func NewBacalhauExecutor

func NewBacalhauExecutor() Executor

func NewInternalExecutor

func NewInternalExecutor() Executor

type ExecutorIOSpec

type ExecutorIOSpec struct {
	Name string
	Ref  string
	Path string
}

type InternalJob

type InternalJob interface {
	Execute(context.Context) (Result, error)
}

type Result

type Result struct {
	ID     string
	CID    string
	StdErr string
	StdOut string
	Status string
}

Result is an Amplify abstraction of a job result