Documentation ¶
Index ¶
- Constants
- type BlobServiceClient
- type Client
- type ConnectionString
- type InputConfig
- type NewWorkflow
- type NewWorkflowInputArgs
- type NewWorkflowOptionalArgs
- type NewWorkflowOutputArgs
- type OptionalArgsConfig
- type OutputConfig
- type ProcessConfig
- type ReferenceConfidenceMode
- type ServiceConfig
- type Status
- type StorageConfig
- type StorageKind
- type SubmitConfig
- type Workflow
- type WorkflowID
Constants ¶
View Source
const ( StatusQueued = 1000 StatusWorking = 10000 StatusSuccess = 20000 StatusFailed = 50000 StatusCancelling = 58000 StatusCancelled = 60000 )
View Source
const ( ReferenceConfidenceModeNone = "NONE" ReferenceConfidenceModeBPResolution = "BP_RESOLUTION" ReferenceConfidenceModeGVCF = "GVCF" )
View Source
const StorageKindAzureBlockBlob = "AZURE_BLOCK_BLOB"
View Source
const Version = "0.4.0"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BlobServiceClient ¶
type BlobServiceClient struct {
// contains filtered or unexported fields
}
func NewBlobServiceClient ¶
func NewBlobServiceClient(accountName string, accountKey string) (BlobServiceClient, error)
func (*BlobServiceClient) GenerateBlobSAS ¶
func (c *BlobServiceClient) GenerateBlobSAS( containerName string, blobName string, permissions sas.BlobPermissions, ) (string, error)
func (*BlobServiceClient) GenerateContainerSAS ¶
func (c *BlobServiceClient) GenerateContainerSAS( containerName string, permissions sas.ContainerPermissions, ) (string, error)
type ConnectionString ¶
func ParseConnectionString ¶
func ParseConnectionString(s string) (ConnectionString, error)
type InputConfig ¶
type InputConfig struct { Storage StorageConfig BlobName string }
type NewWorkflow ¶
type NewWorkflow struct { WorkflowClass string Process string ProcessArgs string Description string InputStorageType StorageKind InputArgs NewWorkflowInputArgs OutputStorageType StorageKind OutputArgs NewWorkflowOutputArgs OptionalArgs NewWorkflowOptionalArgs IgnoreAzureRegion bool }
type NewWorkflowInputArgs ¶
type NewWorkflowOptionalArgs ¶
type NewWorkflowOptionalArgs struct { GATKEmitRefConfidence ReferenceConfidenceMode `json:"GatkEmitRefConfidence"` BgzipOutput bool }
type NewWorkflowOutputArgs ¶
type OptionalArgsConfig ¶
type OptionalArgsConfig struct { EmitRefConfidence ReferenceConfidenceMode BgzipOutput bool }
type OutputConfig ¶
type OutputConfig struct { Storage StorageConfig Basename string Overwrite bool IncludeLog bool }
type ProcessConfig ¶
type ReferenceConfidenceMode ¶
type ReferenceConfidenceMode string
func ParseReferenceConfidenceMode ¶
func ParseReferenceConfidenceMode(s string) (ReferenceConfidenceMode, error)
type ServiceConfig ¶
func ServiceConfigFromFlags ¶
func ServiceConfigFromFlags(flags *pflag.FlagSet) (ServiceConfig, error)
type StorageConfig ¶
type StorageKind ¶
type StorageKind string
type SubmitConfig ¶
type SubmitConfig struct { Service ServiceConfig Input InputConfig Process ProcessConfig Description string Output OutputConfig OptionalArgs OptionalArgsConfig IgnoreAzureRegion bool }
func SubmitConfigFromFlags ¶
func SubmitConfigFromFlags(flags *pflag.FlagSet) (SubmitConfig, error)
type Workflow ¶
type Workflow struct { ID WorkflowID `json:"Id"` TenantID int `json:"TenantId"` Status Status CreatedDate time.Time EndDate *time.Time FailureCode int Message string Description string Process string BasesProcessed uint64 }
func CancelWorkflow ¶
func CancelWorkflow(client Client, ID WorkflowID) (Workflow, error)
func FetchWorkflow ¶
func FetchWorkflow(client Client, ID WorkflowID) (Workflow, error)
func FetchWorkflows ¶
func SubmitWorkflow ¶
func SubmitWorkflow(client Client, config SubmitConfig) (Workflow, error)
type WorkflowID ¶
type WorkflowID int
Click to show internal directories.
Click to hide internal directories.