Documentation ¶
Index ¶
- func PossibleValuesForParameterType() []string
- func PossibleValuesForWorkflowStatus() []string
- func ValidateRunID(input interface{}, key string) (warnings []string, errors []error)
- func ValidateWorkflowID(input interface{}, key string) (warnings []string, errors []error)
- type CancelOperationResponse
- type ContentHash
- type ContentLink
- type Correlation
- type GetOperationResponse
- type ListCompleteResult
- type ListCustomPager
- type ListOperationOptions
- type ListOperationResponse
- type ParameterType
- type ResourceReference
- type RunId
- type WorkflowId
- type WorkflowOutputParameter
- type WorkflowRun
- type WorkflowRunOperationPredicate
- type WorkflowRunProperties
- func (o *WorkflowRunProperties) GetEndTimeAsTime() (*time.Time, error)
- func (o *WorkflowRunProperties) GetStartTimeAsTime() (*time.Time, error)
- func (o *WorkflowRunProperties) GetWaitEndTimeAsTime() (*time.Time, error)
- func (o *WorkflowRunProperties) SetEndTimeAsTime(input time.Time)
- func (o *WorkflowRunProperties) SetStartTimeAsTime(input time.Time)
- func (o *WorkflowRunProperties) SetWaitEndTimeAsTime(input time.Time)
- type WorkflowRunTrigger
- func (o *WorkflowRunTrigger) GetEndTimeAsTime() (*time.Time, error)
- func (o *WorkflowRunTrigger) GetScheduledTimeAsTime() (*time.Time, error)
- func (o *WorkflowRunTrigger) GetStartTimeAsTime() (*time.Time, error)
- func (o *WorkflowRunTrigger) SetEndTimeAsTime(input time.Time)
- func (o *WorkflowRunTrigger) SetScheduledTimeAsTime(input time.Time)
- func (o *WorkflowRunTrigger) SetStartTimeAsTime(input time.Time)
- type WorkflowRunsClient
- func (c WorkflowRunsClient) Cancel(ctx context.Context, id RunId) (result CancelOperationResponse, err error)
- func (c WorkflowRunsClient) Get(ctx context.Context, id RunId) (result GetOperationResponse, err error)
- func (c WorkflowRunsClient) List(ctx context.Context, id WorkflowId, options ListOperationOptions) (result ListOperationResponse, err error)
- func (c WorkflowRunsClient) ListComplete(ctx context.Context, id WorkflowId, options ListOperationOptions) (ListCompleteResult, error)
- func (c WorkflowRunsClient) ListCompleteMatchingPredicate(ctx context.Context, id WorkflowId, options ListOperationOptions, ...) (result ListCompleteResult, err error)
- type WorkflowStatus
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PossibleValuesForParameterType ¶
func PossibleValuesForParameterType() []string
func PossibleValuesForWorkflowStatus ¶
func PossibleValuesForWorkflowStatus() []string
func ValidateRunID ¶
ValidateRunID checks that 'input' can be parsed as a Run ID
func ValidateWorkflowID ¶
ValidateWorkflowID checks that 'input' can be parsed as a Workflow ID
Types ¶
type CancelOperationResponse ¶
type ContentHash ¶
type ContentLink ¶
type ContentLink struct { ContentHash *ContentHash `json:"contentHash,omitempty"` ContentSize *int64 `json:"contentSize,omitempty"` ContentVersion *string `json:"contentVersion,omitempty"` Metadata *interface{} `json:"metadata,omitempty"` Uri *string `json:"uri,omitempty"` }
type Correlation ¶
type Correlation struct {
ClientTrackingId *string `json:"clientTrackingId,omitempty"`
}
type GetOperationResponse ¶
type GetOperationResponse struct { HttpResponse *http.Response OData *odata.OData Model *WorkflowRun }
type ListCompleteResult ¶
type ListCompleteResult struct { LatestHttpResponse *http.Response Items []WorkflowRun }
type ListCustomPager ¶ added in v0.20240628.1153531
func (*ListCustomPager) NextPageLink ¶ added in v0.20240628.1153531
func (p *ListCustomPager) NextPageLink() *odata.Link
type ListOperationOptions ¶
func DefaultListOperationOptions ¶
func DefaultListOperationOptions() ListOperationOptions
func (ListOperationOptions) ToHeaders ¶
func (o ListOperationOptions) ToHeaders() *client.Headers
func (ListOperationOptions) ToOData ¶
func (o ListOperationOptions) ToOData() *odata.Query
func (ListOperationOptions) ToQuery ¶
func (o ListOperationOptions) ToQuery() *client.QueryParams
type ListOperationResponse ¶
type ListOperationResponse struct { HttpResponse *http.Response OData *odata.OData Model *[]WorkflowRun }
type ParameterType ¶
type ParameterType string
const ( ParameterTypeArray ParameterType = "Array" ParameterTypeBool ParameterType = "Bool" ParameterTypeFloat ParameterType = "Float" ParameterTypeInt ParameterType = "Int" ParameterTypeNotSpecified ParameterType = "NotSpecified" ParameterTypeObject ParameterType = "Object" ParameterTypeSecureObject ParameterType = "SecureObject" ParameterTypeSecureString ParameterType = "SecureString" ParameterTypeString ParameterType = "String" )
func (*ParameterType) UnmarshalJSON ¶
func (s *ParameterType) UnmarshalJSON(bytes []byte) error
type ResourceReference ¶
type RunId ¶
type RunId struct { SubscriptionId string ResourceGroupName string WorkflowName string RunName string }
RunId is a struct representing the Resource ID for a Run
func NewRunID ¶
func NewRunID(subscriptionId string, resourceGroupName string, workflowName string, runName string) RunId
NewRunID returns a new RunId struct
func ParseRunID ¶
ParseRunID parses 'input' into a RunId
func ParseRunIDInsensitively ¶
ParseRunIDInsensitively parses 'input' case-insensitively into a RunId note: this method should only be used for API response data and not user input
func (*RunId) FromParseResult ¶
func (id *RunId) FromParseResult(input resourceids.ParseResult) error
func (RunId) Segments ¶
func (id RunId) Segments() []resourceids.Segment
Segments returns a slice of Resource ID Segments which comprise this Run ID
type WorkflowId ¶
WorkflowId is a struct representing the Resource ID for a Workflow
func NewWorkflowID ¶
func NewWorkflowID(subscriptionId string, resourceGroupName string, workflowName string) WorkflowId
NewWorkflowID returns a new WorkflowId struct
func ParseWorkflowID ¶
func ParseWorkflowID(input string) (*WorkflowId, error)
ParseWorkflowID parses 'input' into a WorkflowId
func ParseWorkflowIDInsensitively ¶
func ParseWorkflowIDInsensitively(input string) (*WorkflowId, error)
ParseWorkflowIDInsensitively parses 'input' case-insensitively into a WorkflowId note: this method should only be used for API response data and not user input
func (*WorkflowId) FromParseResult ¶
func (id *WorkflowId) FromParseResult(input resourceids.ParseResult) error
func (WorkflowId) Segments ¶
func (id WorkflowId) Segments() []resourceids.Segment
Segments returns a slice of Resource ID Segments which comprise this Workflow ID
func (WorkflowId) String ¶
func (id WorkflowId) String() string
String returns a human-readable description of this Workflow ID
type WorkflowOutputParameter ¶
type WorkflowOutputParameter struct { Description *string `json:"description,omitempty"` Error *interface{} `json:"error,omitempty"` Metadata *interface{} `json:"metadata,omitempty"` Type *ParameterType `json:"type,omitempty"` Value *interface{} `json:"value,omitempty"` }
type WorkflowRun ¶
type WorkflowRun struct { Id *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Properties *WorkflowRunProperties `json:"properties,omitempty"` Type *string `json:"type,omitempty"` }
type WorkflowRunOperationPredicate ¶
func (WorkflowRunOperationPredicate) Matches ¶
func (p WorkflowRunOperationPredicate) Matches(input WorkflowRun) bool
type WorkflowRunProperties ¶
type WorkflowRunProperties struct { Code *string `json:"code,omitempty"` Correlation *Correlation `json:"correlation,omitempty"` CorrelationId *string `json:"correlationId,omitempty"` EndTime *string `json:"endTime,omitempty"` Error *interface{} `json:"error,omitempty"` Outputs *map[string]WorkflowOutputParameter `json:"outputs,omitempty"` Response *WorkflowRunTrigger `json:"response,omitempty"` StartTime *string `json:"startTime,omitempty"` Status *WorkflowStatus `json:"status,omitempty"` Trigger *WorkflowRunTrigger `json:"trigger,omitempty"` WaitEndTime *string `json:"waitEndTime,omitempty"` Workflow *ResourceReference `json:"workflow,omitempty"` }
func (*WorkflowRunProperties) GetEndTimeAsTime ¶
func (o *WorkflowRunProperties) GetEndTimeAsTime() (*time.Time, error)
func (*WorkflowRunProperties) GetStartTimeAsTime ¶
func (o *WorkflowRunProperties) GetStartTimeAsTime() (*time.Time, error)
func (*WorkflowRunProperties) GetWaitEndTimeAsTime ¶
func (o *WorkflowRunProperties) GetWaitEndTimeAsTime() (*time.Time, error)
func (*WorkflowRunProperties) SetEndTimeAsTime ¶
func (o *WorkflowRunProperties) SetEndTimeAsTime(input time.Time)
func (*WorkflowRunProperties) SetStartTimeAsTime ¶
func (o *WorkflowRunProperties) SetStartTimeAsTime(input time.Time)
func (*WorkflowRunProperties) SetWaitEndTimeAsTime ¶
func (o *WorkflowRunProperties) SetWaitEndTimeAsTime(input time.Time)
type WorkflowRunTrigger ¶
type WorkflowRunTrigger struct { Code *string `json:"code,omitempty"` Correlation *Correlation `json:"correlation,omitempty"` EndTime *string `json:"endTime,omitempty"` Error *interface{} `json:"error,omitempty"` Inputs *interface{} `json:"inputs,omitempty"` InputsLink *ContentLink `json:"inputsLink,omitempty"` Name *string `json:"name,omitempty"` Outputs *interface{} `json:"outputs,omitempty"` OutputsLink *ContentLink `json:"outputsLink,omitempty"` ScheduledTime *string `json:"scheduledTime,omitempty"` StartTime *string `json:"startTime,omitempty"` Status *WorkflowStatus `json:"status,omitempty"` TrackedProperties *interface{} `json:"trackedProperties,omitempty"` TrackingId *string `json:"trackingId,omitempty"` }
func (*WorkflowRunTrigger) GetEndTimeAsTime ¶
func (o *WorkflowRunTrigger) GetEndTimeAsTime() (*time.Time, error)
func (*WorkflowRunTrigger) GetScheduledTimeAsTime ¶
func (o *WorkflowRunTrigger) GetScheduledTimeAsTime() (*time.Time, error)
func (*WorkflowRunTrigger) GetStartTimeAsTime ¶
func (o *WorkflowRunTrigger) GetStartTimeAsTime() (*time.Time, error)
func (*WorkflowRunTrigger) SetEndTimeAsTime ¶
func (o *WorkflowRunTrigger) SetEndTimeAsTime(input time.Time)
func (*WorkflowRunTrigger) SetScheduledTimeAsTime ¶
func (o *WorkflowRunTrigger) SetScheduledTimeAsTime(input time.Time)
func (*WorkflowRunTrigger) SetStartTimeAsTime ¶
func (o *WorkflowRunTrigger) SetStartTimeAsTime(input time.Time)
type WorkflowRunsClient ¶
type WorkflowRunsClient struct {
Client *resourcemanager.Client
}
func NewWorkflowRunsClientWithBaseURI ¶
func NewWorkflowRunsClientWithBaseURI(sdkApi sdkEnv.Api) (*WorkflowRunsClient, error)
func (WorkflowRunsClient) Cancel ¶
func (c WorkflowRunsClient) Cancel(ctx context.Context, id RunId) (result CancelOperationResponse, err error)
Cancel ...
func (WorkflowRunsClient) Get ¶
func (c WorkflowRunsClient) Get(ctx context.Context, id RunId) (result GetOperationResponse, err error)
Get ...
func (WorkflowRunsClient) List ¶
func (c WorkflowRunsClient) List(ctx context.Context, id WorkflowId, options ListOperationOptions) (result ListOperationResponse, err error)
List ...
func (WorkflowRunsClient) ListComplete ¶
func (c WorkflowRunsClient) ListComplete(ctx context.Context, id WorkflowId, options ListOperationOptions) (ListCompleteResult, error)
ListComplete retrieves all the results into a single object
func (WorkflowRunsClient) ListCompleteMatchingPredicate ¶
func (c WorkflowRunsClient) ListCompleteMatchingPredicate(ctx context.Context, id WorkflowId, options ListOperationOptions, predicate WorkflowRunOperationPredicate) (result ListCompleteResult, err error)
ListCompleteMatchingPredicate retrieves all the results and then applies the predicate
type WorkflowStatus ¶
type WorkflowStatus string
const ( WorkflowStatusAborted WorkflowStatus = "Aborted" WorkflowStatusCancelled WorkflowStatus = "Cancelled" WorkflowStatusFailed WorkflowStatus = "Failed" WorkflowStatusFaulted WorkflowStatus = "Faulted" WorkflowStatusIgnored WorkflowStatus = "Ignored" WorkflowStatusNotSpecified WorkflowStatus = "NotSpecified" WorkflowStatusPaused WorkflowStatus = "Paused" WorkflowStatusRunning WorkflowStatus = "Running" WorkflowStatusSkipped WorkflowStatus = "Skipped" WorkflowStatusSucceeded WorkflowStatus = "Succeeded" WorkflowStatusSuspended WorkflowStatus = "Suspended" WorkflowStatusTimedOut WorkflowStatus = "TimedOut" WorkflowStatusWaiting WorkflowStatus = "Waiting" )
func (*WorkflowStatus) UnmarshalJSON ¶
func (s *WorkflowStatus) UnmarshalJSON(bytes []byte) error
Source Files ¶
- client.go
- constants.go
- id_run.go
- id_workflow.go
- method_cancel.go
- method_get.go
- method_list.go
- model_contenthash.go
- model_contentlink.go
- model_correlation.go
- model_resourcereference.go
- model_workflowoutputparameter.go
- model_workflowrun.go
- model_workflowrunproperties.go
- model_workflowruntrigger.go
- predicates.go
- version.go