jobtransform

Documentation

Index

• type PostTransformer
  • func NewWasmStorageSpecConverter() PostTransformer
• type Transformer
  • func NewEngineMigrator() Transformer
  • func NewPublisherMigrator(defaultPublisher string) Transformer
  • func NewRequesterInfo(requesterNodeID string) Transformer
  • func NewTimeoutApplier(minTimeout, defaultTimeout time.Duration) Transformer

Types

type PostTransformer

type PostTransformer func(context.Context, *models.Job) (modified bool, err error)

PostTransformer is a function that can be used to modify a job after it has been migrated to a new version.

func NewWasmStorageSpecConverter

func NewWasmStorageSpecConverter() PostTransformer

NewWasmStorageSpecConverter returns a job transformer that converts the entry and import modules of wasm engine spec from the legacy storage spec to input source definitions.

type Transformer

type Transformer func(context.Context, *model.Job) (modified bool, err error)

Transformer is a function that can be used to modify a job before it is migrated to a new version.

func NewEngineMigrator

func NewEngineMigrator() Transformer

NewEngineMigrator maintains backward compatibility for jobs that were defined with Engine/Wasm/Docker and EngineSpec.

func NewPublisherMigrator

func NewPublisherMigrator(defaultPublisher string) Transformer

Maintains backward compatibility for jobs that were defined with Publisher and PublisherSpec

func NewRequesterInfo

func NewRequesterInfo(requesterNodeID string) Transformer

func NewTimeoutApplier

func NewTimeoutApplier(minTimeout, defaultTimeout time.Duration) Transformer

Sets a default timeout value if one is not passed or below an acceptable value