jobtransform

Documentation

Index

• type Transformer
  • func NewInlineStoragePinner(provider storage.StorageProvider) 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 Transformer

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

func NewInlineStoragePinner

func NewInlineStoragePinner(provider storage.StorageProvider) Transformer

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