executor

Documentation

Overview

Package executor provides an abstraction of a job executor.

Index

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

Types

type BacalhauExecutor

type BacalhauExecutor struct {
	Client *publicapi.RequesterAPIClient
}

func (*BacalhauExecutor) Execute

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

func (*BacalhauExecutor) Render

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

type Executor

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

Executor abstracts the execution of a job

func NewBacalhauExecutor

func NewBacalhauExecutor() Executor

type ExecutorIOSpec

type ExecutorIOSpec struct {
	Name string
	Ref  string
	Path string
}

type Result

type Result struct {
	ID     string
	CID    cid.Cid
	StdErr string
	StdOut string
	Status string
}

Result is an Amplify abstraction of a job result