internal

package
v0.4.0 Latest Latest
Warning

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

Go to latest
Published: Jul 17, 2023 License: MIT Imports: 15 Imported by: 0

Documentation

Index

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"
)

/ https://gatk.broadinstitute.org/hc/en-us/articles/4404604697243-HaplotypeCaller#--emit-ref-confidence

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 Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(baseURL string, accessKey string) Client

func (*Client) Delete

func (c *Client) Delete(endpoint string) (*http.Response, error)

func (*Client) Get

func (c *Client) Get(endpoint string) (*http.Response, error)

func (*Client) Post

func (c *Client) Post(endpoint string, data interface{}) (*http.Response, error)

type ConnectionString

type ConnectionString struct {
	AccountName string
	AccountKey  string
}

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 NewWorkflowInputArgs struct {
	AccountName      string `json:"ACCOUNT"`
	ContainerName    string `json:"CONTAINER"`
	BlobNames        string `json:"BLOBNAMES"`
	BlobNamesWithSAS string `json:"BLOBNAMES_WITH_SAS"`
}

type NewWorkflowOptionalArgs

type NewWorkflowOptionalArgs struct {
	GATKEmitRefConfidence ReferenceConfidenceMode `json:"GatkEmitRefConfidence"`
	BgzipOutput           bool
}

type NewWorkflowOutputArgs

type NewWorkflowOutputArgs struct {
	AccountName           string `json:"ACCOUNT"`
	ContainerName         string `json:"CONTAINER"`
	ContainerSAS          string `json:"CONTAINER_SAS"`
	Basename              string `json:"OUTPUT_FILENAME_BASE"`
	Overwrite             bool   `json:"OVERWRITE"`
	OutputIncludeLogfiles bool   `json:"OUTPUT_INCLUDE_LOGFILES"`
}

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 ProcessConfig struct {
	Name string
	Args string
}

type ReferenceConfidenceMode

type ReferenceConfidenceMode string

func ParseReferenceConfidenceMode

func ParseReferenceConfidenceMode(s string) (ReferenceConfidenceMode, error)

type ServiceConfig

type ServiceConfig struct {
	BaseURL   string
	AccessKey string
}

func ServiceConfigFromFlags

func ServiceConfigFromFlags(flags *pflag.FlagSet) (ServiceConfig, error)

type Status

type Status int

func (Status) String

func (s Status) String() string

type StorageConfig

type StorageConfig struct {
	AccountName   string
	AccountKey    string
	ContainerName string
}

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 FetchWorkflows(client Client) ([]Workflow, error)

func SubmitWorkflow

func SubmitWorkflow(client Client, config SubmitConfig) (Workflow, error)

func (*Workflow) Duration

func (w *Workflow) Duration() time.Duration

type WorkflowID

type WorkflowID int

Jump to

Keyboard shortcuts

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