cache

Documentation

Index

• func DownloadFile(file *cwl.File, download_path string, base_path string, ...) (err error)
• func MoveInputData(work *core.Workunit) (size int64, err error)
• func MoveInputIO(work *core.Workunit, io *core.IO, work_path string) (size int64, err error)
• func ProcessIOData(native interface{}, current_path string, base_path string, io_type string, ...) (count int, err error)
• func StatCacheFilePath(id string) (file_path string, err error)
• func UploadDirectory(dir *cwl.Directory, current_path string, shock_client *shock.ShockClient) (count int, err error)
• func UploadFile(file *cwl.File, inputfile_path string, shock_client *shock.ShockClient) (count int, err error)
• func UploadOutputData(work *core.Workunit, shock_client *shock.ShockClient) (size int64, err error)
• func UploadOutputIO(work *core.Workunit, io *core.IO) (size int64, new_node_id string, err error)

Functions

func DownloadFile

func DownloadFile(file *cwl.File, download_path string, base_path string, shock_client *shock.ShockClient) (err error)

func MoveInputData

func MoveInputData(work *core.Workunit) (size int64, err error)

fetch input data

func MoveInputIO

func MoveInputIO(work *core.Workunit, io *core.IO, work_path string) (size int64, err error)

func ProcessIOData

func ProcessIOData(native interface{}, current_path string, base_path string, io_type string, shock_client *shock.ShockClient) (count int, err error)

func StatCacheFilePath

func StatCacheFilePath(id string) (file_path string, err error)

func UploadDirectory

func UploadDirectory(dir *cwl.Directory, current_path string, shock_client *shock.ShockClient) (count int, err error)

func UploadFile

func UploadFile(file *cwl.File, inputfile_path string, shock_client *shock.ShockClient) (count int, err error)

func UploadOutputData

func UploadOutputData(work *core.Workunit, shock_client *shock.ShockClient) (size int64, err error)

func UploadOutputIO

func UploadOutputIO(work *core.Workunit, io *core.IO) (size int64, new_node_id string, err error)