functions

Documentation

Index

• func CreateAndMonitorWorkflow(rClient *httpd.RequestClient, scheme ConfigHandler.Scheme, ...)
• func CreateRemoteScheme(name, yamlFile string, rclient *httpd.RequestClient)
• func DeleteScheme(cHandler *ConfigHandler.ConfigHandler, schemeName string)
• func DeleteWorkflows(wf, project string, rClient *httpd.RequestClient)
• func GetResults(name string, rClient *httpd.RequestClient)
• func GetScheme(name string, local bool, cHandler *ConfigHandler.ConfigHandler, ...)
• func GetWorkflowStatus(project, wf string, rClient *httpd.RequestClient)
• func SplitInChunks(buf []byte, lim int) [][]byte
• func UploadToS3(filename string, rclient *httpd.RequestClient) (url string, err error)
• func ValidateParams(scheme ConfigHandler.Scheme, params []string) (missing []string, infilecount int)

Functions

func CreateAndMonitorWorkflow

func CreateAndMonitorWorkflow(rClient *httpd.RequestClient, scheme ConfigHandler.Scheme, wfParameter, wfInputFiles []string, watch bool, output []string)

func CreateRemoteScheme

func CreateRemoteScheme(name, yamlFile string, rclient *httpd.RequestClient)

func DeleteScheme

func DeleteScheme(cHandler *ConfigHandler.ConfigHandler, schemeName string)

func DeleteWorkflows

func DeleteWorkflows(wf, project string, rClient *httpd.RequestClient)

func GetResults

func GetResults(name string, rClient *httpd.RequestClient)

func GetScheme

func GetScheme(name string, local bool, cHandler *ConfigHandler.ConfigHandler, rClient *httpd.RequestClient)

func GetWorkflowStatus

func GetWorkflowStatus(project, wf string, rClient *httpd.RequestClient)

func SplitInChunks

func SplitInChunks(buf []byte, lim int) [][]byte

func UploadToS3

func UploadToS3(filename string, rclient *httpd.RequestClient) (url string, err error)

func ValidateParams

func ValidateParams(scheme ConfigHandler.Scheme, params []string) (missing []string, infilecount int)