jobs

package
v0.20240118.1175416 Latest Latest
Warning

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

 Go to latest Published: Jan 18, 2024 License: MPL-2.0 Imports: 14 Imported by: 0

README

github.com/hashicorp/go-azure-sdk/resource-manager/containerapps/2023-05-01/jobs Documentation

The jobs SDK allows for interaction with the Azure Resource Manager Service containerapps (API Version 2023-05-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/containerapps/2023-05-01/jobs"

Client Initialization

client := jobs.NewJobsClientWithBaseURI("https://management.azure.com")
client.Client.Authorizer = authorizer

Example Usage: JobsClient.CreateOrUpdate

ctx := context.TODO()
id := jobs.NewJobID("12345678-1234-9876-4563-123456789012", "example-resource-group", "jobValue")

payload := jobs.Job{
	// ...
}


if err := client.CreateOrUpdateThenPoll(ctx, id, payload); err != nil {
	// handle the error
}

Example Usage: JobsClient.Delete

ctx := context.TODO()
id := jobs.NewJobID("12345678-1234-9876-4563-123456789012", "example-resource-group", "jobValue")

if err := client.DeleteThenPoll(ctx, id); err != nil {
	// handle the error
}

Example Usage: JobsClient.ExecutionsList

ctx := context.TODO()
id := jobs.NewJobID("12345678-1234-9876-4563-123456789012", "example-resource-group", "jobValue")

// alternatively `client.ExecutionsList(ctx, id, jobs.DefaultExecutionsListOperationOptions())` can be used to do batched pagination
items, err := client.ExecutionsListComplete(ctx, id, jobs.DefaultExecutionsListOperationOptions())
if err != nil {
	// handle the error
}
for _, item := range items {
	// do something
}

Example Usage: JobsClient.Get

ctx := context.TODO()
id := jobs.NewJobID("12345678-1234-9876-4563-123456789012", "example-resource-group", "jobValue")

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

Example Usage: JobsClient.JobExecution

ctx := context.TODO()
id := jobs.NewExecutionID("12345678-1234-9876-4563-123456789012", "example-resource-group", "jobValue", "executionValue")

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

Example Usage: JobsClient.ListByResourceGroup

ctx := context.TODO()
id := jobs.NewResourceGroupID("12345678-1234-9876-4563-123456789012", "example-resource-group")

// alternatively `client.ListByResourceGroup(ctx, id)` can be used to do batched pagination
items, err := client.ListByResourceGroupComplete(ctx, id)
if err != nil {
	// handle the error
}
for _, item := range items {
	// do something
}

Example Usage: JobsClient.ListBySubscription

ctx := context.TODO()
id := jobs.NewSubscriptionID("12345678-1234-9876-4563-123456789012")

// alternatively `client.ListBySubscription(ctx, id)` can be used to do batched pagination
items, err := client.ListBySubscriptionComplete(ctx, id)
if err != nil {
	// handle the error
}
for _, item := range items {
	// do something
}

Example Usage: JobsClient.ListSecrets

ctx := context.TODO()
id := jobs.NewJobID("12345678-1234-9876-4563-123456789012", "example-resource-group", "jobValue")

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

Example Usage: JobsClient.Start

ctx := context.TODO()
id := jobs.NewJobID("12345678-1234-9876-4563-123456789012", "example-resource-group", "jobValue")

payload := jobs.JobExecutionTemplate{
	// ...
}


if err := client.StartThenPoll(ctx, id, payload); err != nil {
	// handle the error
}

Example Usage: JobsClient.StopExecution

ctx := context.TODO()
id := jobs.NewExecutionID("12345678-1234-9876-4563-123456789012", "example-resource-group", "jobValue", "executionValue")

if err := client.StopExecutionThenPoll(ctx, id); err != nil {
	// handle the error
}

Example Usage: JobsClient.StopMultipleExecutions

ctx := context.TODO()
id := jobs.NewJobID("12345678-1234-9876-4563-123456789012", "example-resource-group", "jobValue")

if err := client.StopMultipleExecutionsThenPoll(ctx, id); err != nil {
	// handle the error
}

Example Usage: JobsClient.Update

ctx := context.TODO()
id := jobs.NewJobID("12345678-1234-9876-4563-123456789012", "example-resource-group", "jobValue")

payload := jobs.JobPatchProperties{
	// ...
}


if err := client.UpdateThenPoll(ctx, id, payload); err != nil {
	// handle the error
}

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PossibleValuesForJobExecutionRunningState 

func PossibleValuesForJobExecutionRunningState() []string

func PossibleValuesForJobProvisioningState 

func PossibleValuesForJobProvisioningState() []string

func PossibleValuesForScheme 

func PossibleValuesForScheme() []string

func PossibleValuesForStorageType 

func PossibleValuesForStorageType() []string

func PossibleValuesForTriggerType 

func PossibleValuesForTriggerType() []string

func PossibleValuesForType 

func PossibleValuesForType() []string

func ValidateExecutionID 

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

ValidateExecutionID checks that 'input' can be parsed as a Execution ID

func ValidateJobID 

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

ValidateJobID checks that 'input' can be parsed as a Job ID

Types

type BaseContainer 

type BaseContainer struct {
	Args         *[]string           `json:"args,omitempty"`
	Command      *[]string           `json:"command,omitempty"`
	Env          *[]EnvironmentVar   `json:"env,omitempty"`
	Image        *string             `json:"image,omitempty"`
	Name         *string             `json:"name,omitempty"`
	Resources    *ContainerResources `json:"resources,omitempty"`
	VolumeMounts *[]VolumeMount      `json:"volumeMounts,omitempty"`
}

type Container 

type Container struct {
	Args         *[]string            `json:"args,omitempty"`
	Command      *[]string            `json:"command,omitempty"`
	Env          *[]EnvironmentVar    `json:"env,omitempty"`
	Image        *string              `json:"image,omitempty"`
	Name         *string              `json:"name,omitempty"`
	Probes       *[]ContainerAppProbe `json:"probes,omitempty"`
	Resources    *ContainerResources  `json:"resources,omitempty"`
	VolumeMounts *[]VolumeMount       `json:"volumeMounts,omitempty"`
}

type ContainerAppJobExecutions 

type ContainerAppJobExecutions struct {
	NextLink *string        `json:"nextLink,omitempty"`
	Value    []JobExecution `json:"value"`
}

type ContainerAppProbe 

type ContainerAppProbe struct {
	FailureThreshold              *int64                      `json:"failureThreshold,omitempty"`
	HTTPGet                       *ContainerAppProbeHTTPGet   `json:"httpGet,omitempty"`
	InitialDelaySeconds           *int64                      `json:"initialDelaySeconds,omitempty"`
	PeriodSeconds                 *int64                      `json:"periodSeconds,omitempty"`
	SuccessThreshold              *int64                      `json:"successThreshold,omitempty"`
	TcpSocket                     *ContainerAppProbeTcpSocket `json:"tcpSocket,omitempty"`
	TerminationGracePeriodSeconds *int64                      `json:"terminationGracePeriodSeconds,omitempty"`
	TimeoutSeconds                *int64                      `json:"timeoutSeconds,omitempty"`
	Type                          *Type                       `json:"type,omitempty"`
}

type ContainerAppProbeHTTPGet 

type ContainerAppProbeHTTPGet struct {
	HTTPHeaders *[]ContainerAppProbeHTTPGetHTTPHeadersInlined `json:"httpHeaders,omitempty"`
	Host        *string                                       `json:"host,omitempty"`
	Path        *string                                       `json:"path,omitempty"`
	Port        int64                                         `json:"port"`
	Scheme      *Scheme                                       `json:"scheme,omitempty"`
}

type ContainerAppProbeHTTPGetHTTPHeadersInlined 

type ContainerAppProbeHTTPGetHTTPHeadersInlined struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

type ContainerAppProbeTcpSocket 

type ContainerAppProbeTcpSocket struct {
	Host *string `json:"host,omitempty"`
	Port int64   `json:"port"`
}

type ContainerResources 

type ContainerResources struct {
	Cpu              *float64 `json:"cpu,omitempty"`
	EphemeralStorage *string  `json:"ephemeralStorage,omitempty"`
	Memory           *string  `json:"memory,omitempty"`
}

type CreateOrUpdateOperationResponse 

type CreateOrUpdateOperationResponse struct {
	Poller       polling.LongRunningPoller
	HttpResponse *http.Response
}

type DeleteOperationResponse 

type DeleteOperationResponse struct {
	Poller       polling.LongRunningPoller
	HttpResponse *http.Response
}

type EnvironmentVar 

type EnvironmentVar struct {
	Name      *string `json:"name,omitempty"`
	SecretRef *string `json:"secretRef,omitempty"`
	Value     *string `json:"value,omitempty"`
}

type ExecutionId 

type ExecutionId struct {
	SubscriptionId    string
	ResourceGroupName string
	JobName           string
	ExecutionName     string
}

ExecutionId is a struct representing the Resource ID for a Execution

func NewExecutionID 

func NewExecutionID(subscriptionId string, resourceGroupName string, jobName string, executionName string) ExecutionId

NewExecutionID returns a new ExecutionId struct

func ParseExecutionID 

func ParseExecutionID(input string) (*ExecutionId, error)

ParseExecutionID parses 'input' into a ExecutionId

func ParseExecutionIDInsensitively 

func ParseExecutionIDInsensitively(input string) (*ExecutionId, error)

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

func (*ExecutionId) FromParseResult added in v0.20231127.1171502 

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

func (ExecutionId) ID 

func (id ExecutionId) ID() string

ID returns the formatted Execution ID

func (ExecutionId) Segments 

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

Segments returns a slice of Resource ID Segments which comprise this Execution ID

func (ExecutionId) String 

func (id ExecutionId) String() string

String returns a human-readable description of this Execution ID

type ExecutionsListCompleteResult 

type ExecutionsListCompleteResult struct {
	Items []JobExecution
}

type ExecutionsListOperationOptions 

type ExecutionsListOperationOptions struct {
	Filter *string
}

func DefaultExecutionsListOperationOptions 

func DefaultExecutionsListOperationOptions() ExecutionsListOperationOptions

type ExecutionsListOperationResponse 

type ExecutionsListOperationResponse struct {
	HttpResponse *http.Response
	Model        *[]JobExecution
	// contains filtered or unexported fields
}

func (ExecutionsListOperationResponse) HasMore 

func (r ExecutionsListOperationResponse) HasMore() bool

func (ExecutionsListOperationResponse) LoadMore 

func (r ExecutionsListOperationResponse) LoadMore(ctx context.Context) (resp ExecutionsListOperationResponse, err error)

type GetOperationResponse 

type GetOperationResponse struct {
	HttpResponse *http.Response
	Model        *Job
}

type Job 

type Job struct {
	Id         *string                                  `json:"id,omitempty"`
	Identity   *identity.LegacySystemAndUserAssignedMap `json:"identity,omitempty"`
	Location   string                                   `json:"location"`
	Name       *string                                  `json:"name,omitempty"`
	Properties *JobProperties                           `json:"properties,omitempty"`
	SystemData *systemdata.SystemData                   `json:"systemData,omitempty"`
	Tags       *map[string]string                       `json:"tags,omitempty"`
	Type       *string                                  `json:"type,omitempty"`
}

type JobConfiguration 

type JobConfiguration struct {
	EventTriggerConfig    *JobConfigurationEventTriggerConfig    `json:"eventTriggerConfig,omitempty"`
	ManualTriggerConfig   *JobConfigurationManualTriggerConfig   `json:"manualTriggerConfig,omitempty"`
	Registries            *[]RegistryCredentials                 `json:"registries,omitempty"`
	ReplicaRetryLimit     *int64                                 `json:"replicaRetryLimit,omitempty"`
	ReplicaTimeout        int64                                  `json:"replicaTimeout"`
	ScheduleTriggerConfig *JobConfigurationScheduleTriggerConfig `json:"scheduleTriggerConfig,omitempty"`
	Secrets               *[]Secret                              `json:"secrets,omitempty"`
	TriggerType           TriggerType                            `json:"triggerType"`
}

type JobConfigurationEventTriggerConfig 

type JobConfigurationEventTriggerConfig struct {
	Parallelism            *int64    `json:"parallelism,omitempty"`
	ReplicaCompletionCount *int64    `json:"replicaCompletionCount,omitempty"`
	Scale                  *JobScale `json:"scale,omitempty"`
}

type JobConfigurationManualTriggerConfig 

type JobConfigurationManualTriggerConfig struct {
	Parallelism            *int64 `json:"parallelism,omitempty"`
	ReplicaCompletionCount *int64 `json:"replicaCompletionCount,omitempty"`
}

type JobConfigurationScheduleTriggerConfig 

type JobConfigurationScheduleTriggerConfig struct {
	CronExpression         string `json:"cronExpression"`
	Parallelism            *int64 `json:"parallelism,omitempty"`
	ReplicaCompletionCount *int64 `json:"replicaCompletionCount,omitempty"`
}

type JobExecution 

type JobExecution struct {
	Id         *string                 `json:"id,omitempty"`
	Name       *string                 `json:"name,omitempty"`
	Properties *JobExecutionProperties `json:"properties,omitempty"`
	Type       *string                 `json:"type,omitempty"`
}

type JobExecutionBase 

type JobExecutionBase struct {
	Id   *string `json:"id,omitempty"`
	Name *string `json:"name,omitempty"`
}

type JobExecutionContainer 

type JobExecutionContainer struct {
	Args      *[]string           `json:"args,omitempty"`
	Command   *[]string           `json:"command,omitempty"`
	Env       *[]EnvironmentVar   `json:"env,omitempty"`
	Image     *string             `json:"image,omitempty"`
	Name      *string             `json:"name,omitempty"`
	Resources *ContainerResources `json:"resources,omitempty"`
}

type JobExecutionOperationPredicate 

type JobExecutionOperationPredicate struct {
	Id   *string
	Name *string
	Type *string
}

func (JobExecutionOperationPredicate) Matches 

func (p JobExecutionOperationPredicate) Matches(input JobExecution) bool

type JobExecutionOperationResponse 

type JobExecutionOperationResponse struct {
	HttpResponse *http.Response
	Model        *JobExecution
}

type JobExecutionProperties added in v0.20231211.1135715 

type JobExecutionProperties struct {
	EndTime   *string                   `json:"endTime,omitempty"`
	StartTime *string                   `json:"startTime,omitempty"`
	Status    *JobExecutionRunningState `json:"status,omitempty"`
	Template  *JobExecutionTemplate     `json:"template,omitempty"`
}

func (*JobExecutionProperties) GetEndTimeAsTime added in v0.20231211.1135715 

func (o *JobExecutionProperties) GetEndTimeAsTime() (*time.Time, error)

func (*JobExecutionProperties) GetStartTimeAsTime added in v0.20231211.1135715 

func (o *JobExecutionProperties) GetStartTimeAsTime() (*time.Time, error)

func (*JobExecutionProperties) SetEndTimeAsTime added in v0.20231211.1135715 

func (o *JobExecutionProperties) SetEndTimeAsTime(input time.Time)

func (*JobExecutionProperties) SetStartTimeAsTime added in v0.20231211.1135715 

func (o *JobExecutionProperties) SetStartTimeAsTime(input time.Time)

type JobExecutionRunningState 

type JobExecutionRunningState string
const (
	JobExecutionRunningStateDegraded   JobExecutionRunningState = "Degraded"
	JobExecutionRunningStateFailed     JobExecutionRunningState = "Failed"
	JobExecutionRunningStateProcessing JobExecutionRunningState = "Processing"
	JobExecutionRunningStateRunning    JobExecutionRunningState = "Running"
	JobExecutionRunningStateStopped    JobExecutionRunningState = "Stopped"
	JobExecutionRunningStateSucceeded  JobExecutionRunningState = "Succeeded"
	JobExecutionRunningStateUnknown    JobExecutionRunningState = "Unknown"
)

type JobExecutionTemplate 

type JobExecutionTemplate struct {
	Containers     *[]JobExecutionContainer `json:"containers,omitempty"`
	InitContainers *[]JobExecutionContainer `json:"initContainers,omitempty"`
}

type JobId 

type JobId struct {
	SubscriptionId    string
	ResourceGroupName string
	JobName           string
}

JobId is a struct representing the Resource ID for a Job

func NewJobID 

func NewJobID(subscriptionId string, resourceGroupName string, jobName string) JobId

NewJobID returns a new JobId struct

func ParseJobID 

func ParseJobID(input string) (*JobId, error)

ParseJobID parses 'input' into a JobId

func ParseJobIDInsensitively 

func ParseJobIDInsensitively(input string) (*JobId, error)

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

func (*JobId) FromParseResult added in v0.20231127.1171502 

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

func (JobId) ID 

func (id JobId) ID() string

ID returns the formatted Job ID

func (JobId) Segments 

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

Segments returns a slice of Resource ID Segments which comprise this Job ID

func (JobId) String 

func (id JobId) String() string

String returns a human-readable description of this Job ID

type JobOperationPredicate 

type JobOperationPredicate struct {
	Id       *string
	Location *string
	Name     *string
	Type     *string
}

func (JobOperationPredicate) Matches 

func (p JobOperationPredicate) Matches(input Job) bool

type JobPatchProperties 

type JobPatchProperties struct {
	Identity   *identity.LegacySystemAndUserAssignedMap `json:"identity,omitempty"`
	Properties *JobPatchPropertiesProperties            `json:"properties,omitempty"`
	Tags       *map[string]string                       `json:"tags,omitempty"`
}

type JobPatchPropertiesProperties 

type JobPatchPropertiesProperties struct {
	Configuration       *JobConfiguration `json:"configuration,omitempty"`
	EnvironmentId       *string           `json:"environmentId,omitempty"`
	EventStreamEndpoint *string           `json:"eventStreamEndpoint,omitempty"`
	OutboundIPAddresses *[]string         `json:"outboundIpAddresses,omitempty"`
	Template            *JobTemplate      `json:"template,omitempty"`
}

type JobProperties 

type JobProperties struct {
	Configuration       *JobConfiguration     `json:"configuration,omitempty"`
	EnvironmentId       *string               `json:"environmentId,omitempty"`
	EventStreamEndpoint *string               `json:"eventStreamEndpoint,omitempty"`
	OutboundIPAddresses *[]string             `json:"outboundIpAddresses,omitempty"`
	ProvisioningState   *JobProvisioningState `json:"provisioningState,omitempty"`
	Template            *JobTemplate          `json:"template,omitempty"`
	WorkloadProfileName *string               `json:"workloadProfileName,omitempty"`
}

type JobProvisioningState 

type JobProvisioningState string
const (
	JobProvisioningStateCanceled   JobProvisioningState = "Canceled"
	JobProvisioningStateDeleting   JobProvisioningState = "Deleting"
	JobProvisioningStateFailed     JobProvisioningState = "Failed"
	JobProvisioningStateInProgress JobProvisioningState = "InProgress"
	JobProvisioningStateSucceeded  JobProvisioningState = "Succeeded"
)

type JobScale 

type JobScale struct {
	MaxExecutions   *int64          `json:"maxExecutions,omitempty"`
	MinExecutions   *int64          `json:"minExecutions,omitempty"`
	PollingInterval *int64          `json:"pollingInterval,omitempty"`
	Rules           *[]JobScaleRule `json:"rules,omitempty"`
}

type JobScaleRule 

type JobScaleRule struct {
	Auth     *[]ScaleRuleAuth `json:"auth,omitempty"`
	Metadata *interface{}     `json:"metadata,omitempty"`
	Name     *string          `json:"name,omitempty"`
	Type     *string          `json:"type,omitempty"`
}

type JobSecretsCollection 

type JobSecretsCollection struct {
	Value []Secret `json:"value"`
}

type JobTemplate 

type JobTemplate struct {
	Containers     *[]Container     `json:"containers,omitempty"`
	InitContainers *[]BaseContainer `json:"initContainers,omitempty"`
	Volumes        *[]Volume        `json:"volumes,omitempty"`
}

type JobsClient 

type JobsClient struct {
	Client autorest.Client
	// contains filtered or unexported fields
}

func NewJobsClientWithBaseURI 

func NewJobsClientWithBaseURI(endpoint string) JobsClient

func (JobsClient) CreateOrUpdate 

func (c JobsClient) CreateOrUpdate(ctx context.Context, id JobId, input Job) (result CreateOrUpdateOperationResponse, err error)

CreateOrUpdate ...

func (JobsClient) CreateOrUpdateThenPoll 

func (c JobsClient) CreateOrUpdateThenPoll(ctx context.Context, id JobId, input Job) error

CreateOrUpdateThenPoll performs CreateOrUpdate then polls until it's completed

func (JobsClient) Delete 

func (c JobsClient) Delete(ctx context.Context, id JobId) (result DeleteOperationResponse, err error)

Delete ...

func (JobsClient) DeleteThenPoll 

func (c JobsClient) DeleteThenPoll(ctx context.Context, id JobId) error

DeleteThenPoll performs Delete then polls until it's completed

func (JobsClient) ExecutionsList 

func (c JobsClient) ExecutionsList(ctx context.Context, id JobId, options ExecutionsListOperationOptions) (resp ExecutionsListOperationResponse, err error)

ExecutionsList ...

func (JobsClient) ExecutionsListComplete 

func (c JobsClient) ExecutionsListComplete(ctx context.Context, id JobId, options ExecutionsListOperationOptions) (ExecutionsListCompleteResult, error)

ExecutionsListComplete retrieves all of the results into a single object

func (JobsClient) ExecutionsListCompleteMatchingPredicate 

func (c JobsClient) ExecutionsListCompleteMatchingPredicate(ctx context.Context, id JobId, options ExecutionsListOperationOptions, predicate JobExecutionOperationPredicate) (resp ExecutionsListCompleteResult, err error)

ExecutionsListCompleteMatchingPredicate retrieves all of the results and then applied the predicate

func (JobsClient) Get 

func (c JobsClient) Get(ctx context.Context, id JobId) (result GetOperationResponse, err error)

Get ...

func (JobsClient) JobExecution 

func (c JobsClient) JobExecution(ctx context.Context, id ExecutionId) (result JobExecutionOperationResponse, err error)

JobExecution ...

func (JobsClient) ListByResourceGroup 

func (c JobsClient) ListByResourceGroup(ctx context.Context, id commonids.ResourceGroupId) (resp ListByResourceGroupOperationResponse, err error)

ListByResourceGroup ...

func (JobsClient) ListByResourceGroupComplete 

func (c JobsClient) ListByResourceGroupComplete(ctx context.Context, id commonids.ResourceGroupId) (ListByResourceGroupCompleteResult, error)

ListByResourceGroupComplete retrieves all of the results into a single object

func (JobsClient) ListByResourceGroupCompleteMatchingPredicate 

func (c JobsClient) ListByResourceGroupCompleteMatchingPredicate(ctx context.Context, id commonids.ResourceGroupId, predicate JobOperationPredicate) (resp ListByResourceGroupCompleteResult, err error)

ListByResourceGroupCompleteMatchingPredicate retrieves all of the results and then applied the predicate

func (JobsClient) ListBySubscription 

func (c JobsClient) ListBySubscription(ctx context.Context, id commonids.SubscriptionId) (resp ListBySubscriptionOperationResponse, err error)

ListBySubscription ...

func (JobsClient) ListBySubscriptionComplete 

func (c JobsClient) ListBySubscriptionComplete(ctx context.Context, id commonids.SubscriptionId) (ListBySubscriptionCompleteResult, error)

ListBySubscriptionComplete retrieves all of the results into a single object

func (JobsClient) ListBySubscriptionCompleteMatchingPredicate 

func (c JobsClient) ListBySubscriptionCompleteMatchingPredicate(ctx context.Context, id commonids.SubscriptionId, predicate JobOperationPredicate) (resp ListBySubscriptionCompleteResult, err error)

ListBySubscriptionCompleteMatchingPredicate retrieves all of the results and then applied the predicate

func (JobsClient) ListSecrets 

func (c JobsClient) ListSecrets(ctx context.Context, id JobId) (result ListSecretsOperationResponse, err error)

ListSecrets ...

func (JobsClient) Start 

func (c JobsClient) Start(ctx context.Context, id JobId, input JobExecutionTemplate) (result StartOperationResponse, err error)

Start ...

func (JobsClient) StartThenPoll 

func (c JobsClient) StartThenPoll(ctx context.Context, id JobId, input JobExecutionTemplate) error

StartThenPoll performs Start then polls until it's completed

func (JobsClient) StopExecution 

func (c JobsClient) StopExecution(ctx context.Context, id ExecutionId) (result StopExecutionOperationResponse, err error)

StopExecution ...

func (JobsClient) StopExecutionThenPoll 

func (c JobsClient) StopExecutionThenPoll(ctx context.Context, id ExecutionId) error

StopExecutionThenPoll performs StopExecution then polls until it's completed

func (JobsClient) StopMultipleExecutions 

func (c JobsClient) StopMultipleExecutions(ctx context.Context, id JobId) (result StopMultipleExecutionsOperationResponse, err error)

StopMultipleExecutions ...

func (JobsClient) StopMultipleExecutionsThenPoll 

func (c JobsClient) StopMultipleExecutionsThenPoll(ctx context.Context, id JobId) error

StopMultipleExecutionsThenPoll performs StopMultipleExecutions then polls until it's completed

func (JobsClient) Update 

func (c JobsClient) Update(ctx context.Context, id JobId, input JobPatchProperties) (result UpdateOperationResponse, err error)

Update ...

func (JobsClient) UpdateThenPoll 

func (c JobsClient) UpdateThenPoll(ctx context.Context, id JobId, input JobPatchProperties) error

UpdateThenPoll performs Update then polls until it's completed

type ListByResourceGroupCompleteResult 

type ListByResourceGroupCompleteResult struct {
	Items []Job
}

type ListByResourceGroupOperationResponse 

type ListByResourceGroupOperationResponse struct {
	HttpResponse *http.Response
	Model        *[]Job
	// contains filtered or unexported fields
}

func (ListByResourceGroupOperationResponse) HasMore 

func (r ListByResourceGroupOperationResponse) HasMore() bool

func (ListByResourceGroupOperationResponse) LoadMore 

func (r ListByResourceGroupOperationResponse) LoadMore(ctx context.Context) (resp ListByResourceGroupOperationResponse, err error)

type ListBySubscriptionCompleteResult 

type ListBySubscriptionCompleteResult struct {
	Items []Job
}

type ListBySubscriptionOperationResponse 

type ListBySubscriptionOperationResponse struct {
	HttpResponse *http.Response
	Model        *[]Job
	// contains filtered or unexported fields
}

func (ListBySubscriptionOperationResponse) HasMore 

func (r ListBySubscriptionOperationResponse) HasMore() bool

func (ListBySubscriptionOperationResponse) LoadMore 

func (r ListBySubscriptionOperationResponse) LoadMore(ctx context.Context) (resp ListBySubscriptionOperationResponse, err error)

type ListSecretsOperationResponse 

type ListSecretsOperationResponse struct {
	HttpResponse *http.Response
	Model        *JobSecretsCollection
}

type RegistryCredentials 

type RegistryCredentials struct {
	Identity          *string `json:"identity,omitempty"`
	PasswordSecretRef *string `json:"passwordSecretRef,omitempty"`
	Server            *string `json:"server,omitempty"`
	Username          *string `json:"username,omitempty"`
}

type ScaleRuleAuth 

type ScaleRuleAuth struct {
	SecretRef        *string `json:"secretRef,omitempty"`
	TriggerParameter *string `json:"triggerParameter,omitempty"`
}

type Scheme 

type Scheme string
const (
	SchemeHTTP  Scheme = "HTTP"
	SchemeHTTPS Scheme = "HTTPS"
)

type Secret 

type Secret struct {
	Identity    *string `json:"identity,omitempty"`
	KeyVaultUrl *string `json:"keyVaultUrl,omitempty"`
	Name        *string `json:"name,omitempty"`
	Value       *string `json:"value,omitempty"`
}

type SecretVolumeItem 

type SecretVolumeItem struct {
	Path      *string `json:"path,omitempty"`
	SecretRef *string `json:"secretRef,omitempty"`
}

type StartOperationResponse 

type StartOperationResponse struct {
	Poller       polling.LongRunningPoller
	HttpResponse *http.Response
}

type StopExecutionOperationResponse 

type StopExecutionOperationResponse struct {
	Poller       polling.LongRunningPoller
	HttpResponse *http.Response
}

type StopMultipleExecutionsOperationResponse 

type StopMultipleExecutionsOperationResponse struct {
	Poller       polling.LongRunningPoller
	HttpResponse *http.Response
}

type StorageType 

type StorageType string
const (
	StorageTypeAzureFile StorageType = "AzureFile"
	StorageTypeEmptyDir  StorageType = "EmptyDir"
	StorageTypeSecret    StorageType = "Secret"
)

type TriggerType 

type TriggerType string
const (
	TriggerTypeEvent    TriggerType = "Event"
	TriggerTypeManual   TriggerType = "Manual"
	TriggerTypeSchedule TriggerType = "Schedule"
)

type Type 

type Type string
const (
	TypeLiveness  Type = "Liveness"
	TypeReadiness Type = "Readiness"
	TypeStartup   Type = "Startup"
)

type UpdateOperationResponse 

type UpdateOperationResponse struct {
	Poller       polling.LongRunningPoller
	HttpResponse *http.Response
}

type Volume 

type Volume struct {
	MountOptions *string             `json:"mountOptions,omitempty"`
	Name         *string             `json:"name,omitempty"`
	Secrets      *[]SecretVolumeItem `json:"secrets,omitempty"`
	StorageName  *string             `json:"storageName,omitempty"`
	StorageType  *StorageType        `json:"storageType,omitempty"`
}

type VolumeMount 

type VolumeMount struct {
	MountPath  *string `json:"mountPath,omitempty"`
	SubPath    *string `json:"subPath,omitempty"`
	VolumeName *string `json:"volumeName,omitempty"`
}

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.