job

Documentation

Index

• func GetJobOptions(request types.JobSpec, withModule bool) (jobcreator.JobCreatorOptions, error)
• func GetModule(id string) (types.Module, error)
• func GetModules() ([]types.Module, error)
• func ProcessJobCreatorOptions(options jobcreator.JobCreatorOptions, request types.JobSpec, withModule bool) (jobcreator.JobCreatorOptions, error)
• type JobRunner
  • func NewJobRunner(ctx context.Context) (*JobRunner, error)
  • func (runner *JobRunner) GetJobContainer(ctx context.Context, request types.JobSpec) (data.JobOfferContainer, error)
  • func (runner *JobRunner) GetJobOffer(ctx context.Context, request types.JobSpec) (data.JobOffer, error)
  • func (runner *JobRunner) RunJobAsync(ctx context.Context, request types.JobSpec) (string, error)
  • func (runner *JobRunner) RunJobSync(ctx context.Context, request types.JobSpec, ...) (*jobcreator.RunJobResults, error)
  • func (runner *JobRunner) Subscribe(ctx context.Context, callback jobcreator.JobOfferSubscriber)

Functions

func GetJobOptions

func GetJobOptions(request types.JobSpec, withModule bool) (jobcreator.JobCreatorOptions, error)

func GetModule

func GetModule(id string) (types.Module, error)

func GetModules

func GetModules() ([]types.Module, error)

func ProcessJobCreatorOptions

func ProcessJobCreatorOptions(options jobcreator.JobCreatorOptions, request types.JobSpec, withModule bool) (jobcreator.JobCreatorOptions, error)

Types

type JobRunner

type JobRunner struct {
	Ctx        context.Context
	Options    jobcreator.JobCreatorOptions
	Web3SDK    *web3.Web3SDK
	JobCreator *jobcreator.JobCreator
	ErrorChan  chan error
}

func NewJobRunner

func NewJobRunner(ctx context.Context) (*JobRunner, error)

func (*JobRunner) GetJobContainer

func (runner *JobRunner) GetJobContainer(ctx context.Context, request types.JobSpec) (data.JobOfferContainer, error)

func (*JobRunner) GetJobOffer

func (runner *JobRunner) GetJobOffer(ctx context.Context, request types.JobSpec) (data.JobOffer, error)

func (*JobRunner) RunJobAsync

func (runner *JobRunner) RunJobAsync(ctx context.Context, request types.JobSpec) (string, error)

func (*JobRunner) RunJobSync

func (runner *JobRunner) RunJobSync(ctx context.Context, request types.JobSpec, handler func(evOffer data.JobOfferContainer)) (*jobcreator.RunJobResults, error)

func (*JobRunner) Subscribe

func (runner *JobRunner) Subscribe(ctx context.Context, callback jobcreator.JobOfferSubscriber)