activityruns

package
v0.20240617.1095803 Latest Latest
Warning

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

 Go to latest Published: Jun 17, 2024 License: MPL-2.0 Imports: 13 Imported by: 1

README

github.com/hashicorp/go-azure-sdk/resource-manager/datafactory/2018-06-01/activityruns Documentation

The activityruns SDK allows for interaction with the Azure Resource Manager Service datafactory (API Version 2018-06-01).

This readme covers example usages, but further information on using this SDK can be found in the project root.

Import Path

import "github.com/hashicorp/go-azure-sdk/resource-manager/datafactory/2018-06-01/activityruns"

Client Initialization

client := activityruns.NewActivityrunsClientWithBaseURI("https://management.azure.com")
client.Client.Authorizer = authorizer

Example Usage: ActivityrunsClient.QueryByPipelineRun

ctx := context.TODO()
id := activityruns.NewPipelineRunID("12345678-1234-9876-4563-123456789012", "example-resource-group", "factoryValue", "runIdValue")

payload := activityruns.RunFilterParameters{
	// ...
}


read, err := client.QueryByPipelineRun(ctx, id, payload)
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PossibleValuesForRunQueryFilterOperand 

func PossibleValuesForRunQueryFilterOperand() []string

func PossibleValuesForRunQueryFilterOperator 

func PossibleValuesForRunQueryFilterOperator() []string

func PossibleValuesForRunQueryOrder 

func PossibleValuesForRunQueryOrder() []string

func PossibleValuesForRunQueryOrderByField 

func PossibleValuesForRunQueryOrderByField() []string

func ValidatePipelineRunID 

func ValidatePipelineRunID(input interface{}, key string) (warnings []string, errors []error)

ValidatePipelineRunID checks that 'input' can be parsed as a Pipeline Run ID

Types

type ActivityRun 

type ActivityRun struct {
	ActivityName      *string      `json:"activityName,omitempty"`
	ActivityRunEnd    *string      `json:"activityRunEnd,omitempty"`
	ActivityRunId     *string      `json:"activityRunId,omitempty"`
	ActivityRunStart  *string      `json:"activityRunStart,omitempty"`
	ActivityType      *string      `json:"activityType,omitempty"`
	DurationInMs      *int64       `json:"durationInMs,omitempty"`
	Error             *interface{} `json:"error,omitempty"`
	Input             *interface{} `json:"input,omitempty"`
	LinkedServiceName *string      `json:"linkedServiceName,omitempty"`
	Output            *interface{} `json:"output,omitempty"`
	PipelineName      *string      `json:"pipelineName,omitempty"`
	PipelineRunId     *string      `json:"pipelineRunId,omitempty"`
	Status            *string      `json:"status,omitempty"`
}

func (*ActivityRun) GetActivityRunEndAsTime 

func (o *ActivityRun) GetActivityRunEndAsTime() (*time.Time, error)

func (*ActivityRun) GetActivityRunStartAsTime 

func (o *ActivityRun) GetActivityRunStartAsTime() (*time.Time, error)

func (*ActivityRun) SetActivityRunEndAsTime 

func (o *ActivityRun) SetActivityRunEndAsTime(input time.Time)

func (*ActivityRun) SetActivityRunStartAsTime 

func (o *ActivityRun) SetActivityRunStartAsTime(input time.Time)

type ActivityRunsQueryResponse 

type ActivityRunsQueryResponse struct {
	ContinuationToken *string       `json:"continuationToken,omitempty"`
	Value             []ActivityRun `json:"value"`
}

type ActivityrunsClient 

type ActivityrunsClient struct {
	Client *resourcemanager.Client
}

func NewActivityrunsClientWithBaseURI 

func NewActivityrunsClientWithBaseURI(sdkApi sdkEnv.Api) (*ActivityrunsClient, error)

func (ActivityrunsClient) QueryByPipelineRun 

func (c ActivityrunsClient) QueryByPipelineRun(ctx context.Context, id PipelineRunId, input RunFilterParameters) (result QueryByPipelineRunOperationResponse, err error)

QueryByPipelineRun ...

type PipelineRunId 

type PipelineRunId struct {
	SubscriptionId    string
	ResourceGroupName string
	FactoryName       string
	RunId             string
}

PipelineRunId is a struct representing the Resource ID for a Pipeline Run

func NewPipelineRunID 

func NewPipelineRunID(subscriptionId string, resourceGroupName string, factoryName string, runId string) PipelineRunId

NewPipelineRunID returns a new PipelineRunId struct

func ParsePipelineRunID 

func ParsePipelineRunID(input string) (*PipelineRunId, error)

ParsePipelineRunID parses 'input' into a PipelineRunId

func ParsePipelineRunIDInsensitively 

func ParsePipelineRunIDInsensitively(input string) (*PipelineRunId, error)

ParsePipelineRunIDInsensitively parses 'input' case-insensitively into a PipelineRunId note: this method should only be used for API response data and not user input

func (*PipelineRunId) FromParseResult 

func (id *PipelineRunId) FromParseResult(input resourceids.ParseResult) error

func (PipelineRunId) ID 

func (id PipelineRunId) ID() string

ID returns the formatted Pipeline Run ID

func (PipelineRunId) Segments 

func (id PipelineRunId) Segments() []resourceids.Segment

Segments returns a slice of Resource ID Segments which comprise this Pipeline Run ID

func (PipelineRunId) String 

func (id PipelineRunId) String() string

String returns a human-readable description of this Pipeline Run ID

type QueryByPipelineRunOperationResponse 

type QueryByPipelineRunOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *ActivityRunsQueryResponse
}

type RunFilterParameters 

type RunFilterParameters struct {
	ContinuationToken *string            `json:"continuationToken,omitempty"`
	Filters           *[]RunQueryFilter  `json:"filters,omitempty"`
	LastUpdatedAfter  string             `json:"lastUpdatedAfter"`
	LastUpdatedBefore string             `json:"lastUpdatedBefore"`
	OrderBy           *[]RunQueryOrderBy `json:"orderBy,omitempty"`
}

func (*RunFilterParameters) GetLastUpdatedAfterAsTime 

func (o *RunFilterParameters) GetLastUpdatedAfterAsTime() (*time.Time, error)

func (*RunFilterParameters) GetLastUpdatedBeforeAsTime 

func (o *RunFilterParameters) GetLastUpdatedBeforeAsTime() (*time.Time, error)

func (*RunFilterParameters) SetLastUpdatedAfterAsTime 

func (o *RunFilterParameters) SetLastUpdatedAfterAsTime(input time.Time)

func (*RunFilterParameters) SetLastUpdatedBeforeAsTime 

func (o *RunFilterParameters) SetLastUpdatedBeforeAsTime(input time.Time)

type RunQueryFilter 

type RunQueryFilter struct {
	Operand  RunQueryFilterOperand  `json:"operand"`
	Operator RunQueryFilterOperator `json:"operator"`
	Values   []string               `json:"values"`
}

type RunQueryFilterOperand 

type RunQueryFilterOperand string
const (
	RunQueryFilterOperandActivityName        RunQueryFilterOperand = "ActivityName"
	RunQueryFilterOperandActivityRunEnd      RunQueryFilterOperand = "ActivityRunEnd"
	RunQueryFilterOperandActivityRunStart    RunQueryFilterOperand = "ActivityRunStart"
	RunQueryFilterOperandActivityType        RunQueryFilterOperand = "ActivityType"
	RunQueryFilterOperandLatestOnly          RunQueryFilterOperand = "LatestOnly"
	RunQueryFilterOperandPipelineName        RunQueryFilterOperand = "PipelineName"
	RunQueryFilterOperandRunEnd              RunQueryFilterOperand = "RunEnd"
	RunQueryFilterOperandRunGroupId          RunQueryFilterOperand = "RunGroupId"
	RunQueryFilterOperandRunStart            RunQueryFilterOperand = "RunStart"
	RunQueryFilterOperandStatus              RunQueryFilterOperand = "Status"
	RunQueryFilterOperandTriggerName         RunQueryFilterOperand = "TriggerName"
	RunQueryFilterOperandTriggerRunTimestamp RunQueryFilterOperand = "TriggerRunTimestamp"
)

func (*RunQueryFilterOperand) UnmarshalJSON 

func (s *RunQueryFilterOperand) UnmarshalJSON(bytes []byte) error

type RunQueryFilterOperator 

type RunQueryFilterOperator string
const (
	RunQueryFilterOperatorEquals    RunQueryFilterOperator = "Equals"
	RunQueryFilterOperatorIn        RunQueryFilterOperator = "In"
	RunQueryFilterOperatorNotEquals RunQueryFilterOperator = "NotEquals"
	RunQueryFilterOperatorNotIn     RunQueryFilterOperator = "NotIn"
)

func (*RunQueryFilterOperator) UnmarshalJSON 

func (s *RunQueryFilterOperator) UnmarshalJSON(bytes []byte) error

type RunQueryOrder 

type RunQueryOrder string
const (
	RunQueryOrderASC  RunQueryOrder = "ASC"
	RunQueryOrderDESC RunQueryOrder = "DESC"
)

func (*RunQueryOrder) UnmarshalJSON 

func (s *RunQueryOrder) UnmarshalJSON(bytes []byte) error

type RunQueryOrderBy 

type RunQueryOrderBy struct {
	Order   RunQueryOrder        `json:"order"`
	OrderBy RunQueryOrderByField `json:"orderBy"`
}

type RunQueryOrderByField 

type RunQueryOrderByField string
const (
	RunQueryOrderByFieldActivityName        RunQueryOrderByField = "ActivityName"
	RunQueryOrderByFieldActivityRunEnd      RunQueryOrderByField = "ActivityRunEnd"
	RunQueryOrderByFieldActivityRunStart    RunQueryOrderByField = "ActivityRunStart"
	RunQueryOrderByFieldPipelineName        RunQueryOrderByField = "PipelineName"
	RunQueryOrderByFieldRunEnd              RunQueryOrderByField = "RunEnd"
	RunQueryOrderByFieldRunStart            RunQueryOrderByField = "RunStart"
	RunQueryOrderByFieldStatus              RunQueryOrderByField = "Status"
	RunQueryOrderByFieldTriggerName         RunQueryOrderByField = "TriggerName"
	RunQueryOrderByFieldTriggerRunTimestamp RunQueryOrderByField = "TriggerRunTimestamp"
)

func (*RunQueryOrderByField) UnmarshalJSON 

func (s *RunQueryOrderByField) UnmarshalJSON(bytes []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.