jobtransform

Documentation

Index

• type PostTransformer
  • func NewInlineStoragePinner(provider storage.StorageProvider) PostTransformer
  • func NewWasmStorageSpecConverter() PostTransformer
• type Transformer
  • func DockerImageDigest() Transformer
  • func NewEngineMigrator() Transformer
  • func NewPublisherMigrator() Transformer
  • func NewRequesterInfo(requesterNodeID string, requesterPubKey model.PublicKey) Transformer
  • func NewTimeoutApplier(minTimeout, defaultTimeout time.Duration) Transformer
  • func RepoExistsOnIPFS(provider storage.StorageProvider) 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 NewInlineStoragePinner

func NewInlineStoragePinner(provider storage.StorageProvider) PostTransformer

NewInlineStoragePinner returns a job transformer that limits the inline space taken up by inline data. It will scan a job for StorageSpec objects that store their data inline and move any that are too large into IPFS storage. It also limits the total size taken up by inline specs and if this value is exceeded it will move the largest specs into IPFS.

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 DockerImageDigest

func DockerImageDigest() Transformer

func NewEngineMigrator

func NewEngineMigrator() Transformer

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

func NewPublisherMigrator

func NewPublisherMigrator() Transformer

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

func NewRequesterInfo

func NewRequesterInfo(requesterNodeID string, requesterPubKey model.PublicKey) 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

func RepoExistsOnIPFS

func RepoExistsOnIPFS(provider storage.StorageProvider) Transformer