transformer

Documentation

Index

• func IDGenerator(_ context.Context, job *models.Job) error
• type ChainedTransformer
  • func (ct ChainedTransformer[T]) Transform(ctx context.Context, obj T) error
• type GenericTransformer
• type JobFn
  • func (fn JobFn) Transform(ctx context.Context, job *models.Job) error
• type JobTransformer
  • func DefaultPublisher(publisherConfig *models.SpecConfig) JobTransformer
  • func DefaultsApplier(defaults types.JobDefaults) JobTransformer
  • func NameOptional() JobTransformer
  • func OrchestratorInstallationID(installationID string) JobTransformer
  • func OrchestratorInstanceID(instanceID string) JobTransformer
  • func RequesterInfo(requesterNodeID string) JobTransformer
• type ResultFn
  • func (fn ResultFn) Transform(ctx context.Context, result *models.SpecConfig) error
• type ResultTransformer

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 ChainedTransformer

type ChainedTransformer[T any] []GenericTransformer[T]

ChainedTransformer is a slice of Transformers that runs in sequence

func (ChainedTransformer[T]) Transform

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

Transform runs all transformers in sequence.

type GenericTransformer

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 JobFn

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

JobFn is a function that implements JobTransformer transform interface.

func (JobFn) Transform

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

type JobTransformer

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

func DefaultPublisher(publisherConfig *models.SpecConfig) JobTransformer

func DefaultsApplier

func DefaultsApplier(defaults types.JobDefaults) JobTransformer

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

func NameOptional

func NameOptional() JobTransformer

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

func OrchestratorInstallationID

func OrchestratorInstallationID(installationID string) JobTransformer

func OrchestratorInstanceID

func OrchestratorInstanceID(instanceID string) JobTransformer

func RequesterInfo

func RequesterInfo(requesterNodeID string) JobTransformer

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

type ResultFn

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

ResultFn is a function that implements ResultTransformer transform interface.

func (ResultFn) Transform

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

type ResultTransformer

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

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