utils

Documentation

Index

• func AllInputSources(job *models.Job) []*models.InputSource
• func AllInputSourcesTypes(job *models.Job) []string

Functions

func AllInputSources

func AllInputSources(job *models.Job) []*models.InputSource

AllInputSources returns all storage types used by the job spec. TODO: this is a temporary hack to get the storage type from the job spec, including remote sources defined inside the wasm spec. Long term solution to move remote sources from wasm spec to outer task spec.

func AllInputSourcesTypes

func AllInputSourcesTypes(job *models.Job) []string

AllInputSourcesTypes returns all storage types used by the job spec.