transformer

package

v1.1.2-rc1 Latest Latest Go to latest Published: Oct 20, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

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

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

type ChainedJobTransformer []JobTransformer

ChainedJobTransformer is a slice of Transformers that runs in sequence

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

Transform runs all transformers in sequence.

type JobDefaults struct {
	ExecutionTimeout time.Duration
}

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

JobFn is a function that implements JobTransformer transform interface.

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

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

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

func DefaultsApplier(defaults JobDefaults) JobTransformer

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

func NameOptional() JobTransformer

NameOptional is a transformer that sets the job name to the job ID if it is empty.

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

RequesterInfo is a transformer that sets the requester ID and public key in the job meta.