transformer

Documentation

Index

• func IDGenerator(_ context.Context, job *models.Job) error
• type ChainedJobTransformer
  • func (ct ChainedJobTransformer) Transform(ctx context.Context, job *models.Job) error
• type Job
  • func DefaultsApplier(defaults JobDefaults) Job
  • func RequesterInfo(requesterNodeID string, requesterPubKey model.PublicKey) Job
• type JobDefaults
• type JobFn
  • func (fn JobFn) Transform(ctx context.Context, job *models.Job) error

Functions

func IDGenerator

func IDGenerator(_ context.Context, job *models.Job) error

IDGenerator is a transformer that generates a new ID for the job if it is empty.

Types

type ChainedJobTransformer

type ChainedJobTransformer []Job

ChainedJobTransformer is a slice of Transformers that runs in sequence

func (ChainedJobTransformer) Transform

func (ct ChainedJobTransformer) Transform(ctx context.Context, job *models.Job) error

Transform runs all transformers in sequence.

type Job

type Job interface {
	Transform(context.Context, *models.Job) error
}

Job is an interface that can be used to modify a job in place, such as setting default values or migrating.

func DefaultsApplier

func DefaultsApplier(defaults JobDefaults) Job

DefaultsApplier is a transformer that applies default values to the job.

func RequesterInfo

func RequesterInfo(requesterNodeID string, requesterPubKey model.PublicKey) Job

type JobDefaults

type JobDefaults struct {
	ExecutionTimeout time.Duration
}

type JobFn

type JobFn func(context.Context, *models.Job) error

JobFn is a function that implements Job transform interface.

func (JobFn) Transform

func (fn JobFn) Transform(ctx context.Context, job *models.Job) error