transformer

package

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

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

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.