types

Documentation

Index

• type BackendConfig
• type BackendLogs
• type CallCaching
• type CallCachingData
• type CallItem
• type CallItemSet
• type Config
• type Database
• type Docker
• type Engine
• type ErrorResponse
• type ExecutionEvents
• type Failure
• type Filesystems
• type GcsFilesystem
• type Label
• type LocalFilesystem
• type MetadataResponse
• type MetadataTableResponse
  • func (MetadataTableResponse) Header() []string
  • func (mtr MetadataTableResponse) Rows() [][]string
• type OutputsResponse
• type ParamsMetadataGet
• type ParamsQueryGet
• type ParsedCallAttributes
• type ProviderConfig
• type ProviderSettings
• type QueryResponse
• type QueryResponseWorkflow
• type QueryTableResponse
  • func (QueryTableResponse) Header() []string
  • func (qtr QueryTableResponse) Rows() [][]string
• type ResourceTableResponse
  • func (ResourceTableResponse) Header() []string
  • func (rtr ResourceTableResponse) Rows() [][]string
• type RuntimeAttributes
• type SubmitRequest
• type SubmitResponse
• type SubmittedFiles
• type Table
• type TotalResources

Types

type BackendConfig

type BackendConfig struct {
	Default   string
	Providers []ProviderConfig
}

type BackendLogs

type BackendLogs struct {
	Log string
}

type CallCaching

type CallCaching struct {
	Enabled                   bool
	InvalidateBadCacheResults bool
}

type CallCachingData

type CallCachingData struct {
	Result string
	Hit    bool
}

type CallItem

type CallItem struct {
	ExecutionStatus     string
	Stdout              string
	Stderr              string
	Attempt             int
	ShardIndex          int
	Start               time.Time
	End                 time.Time
	Labels              Label
	MonitoringLog       string
	CommandLine         string
	DockerImageUsed     string
	SubWorkflowID       string
	SubWorkflowMetadata MetadataResponse
	RuntimeAttributes   RuntimeAttributes
	CallCaching         CallCachingData
	ExecutionEvents     []ExecutionEvents
	BackendLogs         BackendLogs
}

type CallItemSet

type CallItemSet map[string][]CallItem

type Config

type Config struct {
	Override      bool
	BackendConfig BackendConfig
	Database      Database
	CallCaching   CallCaching
	Docker        Docker
	Engine        Engine
}

type Database

type Database struct {
	Profile           string
	Driver            string
	URL               string
	Host              string
	Port              int
	User              string
	Password          string
	ConnectionTimeout int
}

type Docker

type Docker struct {
	PerformRegistryLookupIfDigestIsProvided bool
}

type Engine

type Engine struct {
	Filesystems
}

type ErrorResponse

type ErrorResponse struct {
	HTTPStatus string
	Status     string
	Message    string
}

type ExecutionEvents

type ExecutionEvents struct {
	StartTime   time.Time
	Description string
	EndTime     time.Time
}

type Failure

type Failure struct {
	CausedBy []Failure
	Message  string
}

type Filesystems

type Filesystems struct {
	GcsFilesystem   GcsFilesystem
	HTTP            struct{}
	LocalFilesystem LocalFilesystem
}

type GcsFilesystem

type GcsFilesystem struct {
	Auth    string
	Enabled bool
}

type Label

type Label struct {
	CromwellWorkflowID string `json:"cromwell-workflow-id"`
	WdlTaskName        string `json:"wdl-task-name"`
}

type LocalFilesystem

type LocalFilesystem struct {
	Localization []string
}

type MetadataResponse

type MetadataResponse struct {
	WorkflowName   string
	SubmittedFiles SubmittedFiles
	RootWorkflowID string
	Calls          CallItemSet
	Inputs         map[string]interface{}
	Outputs        map[string]interface{}
	Start          time.Time
	End            time.Time
	Status         string
	Failures       []Failure
}

type MetadataTableResponse

type MetadataTableResponse struct {
	Metadata MetadataResponse
}

func (MetadataTableResponse) Header

func (MetadataTableResponse) Header() []string

func (MetadataTableResponse) Rows

func (mtr MetadataTableResponse) Rows() [][]string

type OutputsResponse

type OutputsResponse struct {
	ID      string
	Outputs map[string]interface{}
}

type ParamsMetadataGet

type ParamsMetadataGet struct {
	IncludeKey         []string `url:"includeKey,omitempty"`
	ExcludeKey         []string `url:"excludeKey,omitempty"`
	ExpandSubWorkflows bool     `url:"expandSubWorkflows,omitempty"`
}

type ParamsQueryGet

type ParamsQueryGet struct {
	Submission          time.Time `url:"submission,omitempty" layout:"2006-01-02T15:04:05.000Z"`
	Start               time.Time `url:"start,omitempty" layout:"2006-01-02T15:04:05.000Z"`
	End                 time.Time `url:"end,omitempty" layout:"2006-01-02T15:04:05.000Z"`
	Status              string    `url:"status,omitempty"`
	Name                string    `url:"name,omitempty"`
	Id                  string    `url:"id,omitempty"`
	IncludeSubworkflows bool      `url:"includeSubworkflows,omitempty"`
}

type ParsedCallAttributes

type ParsedCallAttributes struct {
	Hdd      float64
	Preempt  bool
	Ssd      float64
	Memory   float64
	CPU      float64
	Elapsed  time.Duration
	HitCache bool
}

type ProviderConfig

type ProviderConfig struct {
	Name        string
	ActorFactor string
	Config      ProviderSettings
}

type ProviderSettings

type ProviderSettings struct {
	MaxConcurrentWorkflows int
	ConcurrentJobLimit     int
	FileSystems            Engine
}

type QueryResponse

type QueryResponse struct {
	Results           []QueryResponseWorkflow
	TotalResultsCount int
}

type QueryResponseWorkflow

type QueryResponseWorkflow struct {
	ID                    string
	Name                  string
	Status                string
	Submission            string
	Start                 time.Time
	End                   time.Time
	MetadataArchiveStatus string
}

type QueryTableResponse

type QueryTableResponse struct {
	Results           []QueryResponseWorkflow
	TotalResultsCount int
}

func (QueryTableResponse) Header

func (QueryTableResponse) Header() []string

func (QueryTableResponse) Rows

func (qtr QueryTableResponse) Rows() [][]string

type ResourceTableResponse

type ResourceTableResponse struct {
	Total TotalResources
}

func (ResourceTableResponse) Header

func (ResourceTableResponse) Header() []string

func (ResourceTableResponse) Rows

func (rtr ResourceTableResponse) Rows() [][]string

type RuntimeAttributes

type RuntimeAttributes struct {
	BootDiskSizeGb string
	CPU            string
	Disks          string
	Docker         string
	Memory         string
	Preemptible    string
}

type SubmitRequest

type SubmitRequest struct {
	WorkflowSource       string
	WorkflowInputs       string
	WorkflowDependencies string
	WorkflowOptions      string
}

type SubmitResponse

type SubmitResponse struct {
	ID     string
	Status string
}

type SubmittedFiles

type SubmittedFiles struct {
	Options string
}

type Table

type Table interface {
	Header() []string
	Rows() [][]string
}

type TotalResources

type TotalResources struct {
	PreemptHdd    float64
	PreemptSsd    float64
	PreemptCPU    float64
	PreemptMemory float64
	Hdd           float64
	Ssd           float64
	CPU           float64
	Memory        float64
	CachedCalls   int
	TotalTime     time.Duration
}