cache

package
v0.9.68 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 6, 2018 License: BSD-2-Clause Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CWL_File_2_AWE_IO_deprecated added in v0.9.67

func CWL_File_2_AWE_IO_deprecated(file *cwl.File) (io *core.IO, err error)

func DownloadFile added in v0.9.67

func DownloadFile(file *cwl.File, download_path string) (err error)

func MoveInputData

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

fetch input data

func MoveInputIO added in v0.9.62

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

func ProcessIOData added in v0.9.67

func ProcessIOData(native interface{}, 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 UploadFile added in v0.9.67

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

func UploadOutputData

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

func UploadOutputIO added in v0.9.62

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

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL