transformer

package

v1.5.0-dev2 Latest Latest Go to latest Published: Sep 2, 2024 License: Apache-2.0 Imports: 4 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 ChainedTransformer[T any] []GenericTransformer[T]

ChainedTransformer is a slice of Transformers that runs in sequence

func (ct ChainedTransformer[T]) Transform(ctx context.Context, obj T) error

Transform runs all transformers in sequence.

type GenericTransformer[T any] interface {
	Transform(context.Context, T) error
}

GenericTransformer is an interface that can be used to modify an object in place.

type JobDefaults struct {
	TotalTimeout     time.Duration
	ExecutionTimeout time.Duration
	QueueTimeout     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 {
	GenericTransformer[*models.Job]
}

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

func DefaultPublisher(publisherConfig *models.SpecConfig) JobTransformer

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) JobTransformer

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

type ResultFn func(context.Context, *models.SpecConfig) error

ResultFn is a function that implements ResultTransformer transform interface.

func (fn ResultFn) Transform(ctx context.Context, result *models.SpecConfig) error

type ResultTransformer interface {
	GenericTransformer[*models.SpecConfig]
}

ResultTransformer is an interface that can be used to modify a result in place.