jobtransform

Documentation

Index

• type Transformer
  • func NewExecutionPlanner(provider storage.StorageProvider) Transformer
  • func NewInlineStoragePinner(provider storage.StorageProvider) Transformer
  • func NewRequesterInfo(requesterNodeID string, requesterPubKey model.PublicKey) Transformer
  • func NewTimeoutApplier(minTimeout, defaultTimeout time.Duration) Transformer

Types

type Transformer

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

func NewExecutionPlanner

func NewExecutionPlanner(provider storage.StorageProvider) Transformer

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