scheduler

package
v0.1.10 Latest Latest
Warning

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

 Go to latest Published: Nov 20, 2015 License: MIT, Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ApiVersion     = "2014-08-01-preview"
	DefaultBaseUri = "https://management.azure.com"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type DayOfWeek 

type DayOfWeek string
const (
	DayOfWeekFriday    DayOfWeek = "Friday"
	DayOfWeekMonday    DayOfWeek = "Monday"
	DayOfWeekSaturday  DayOfWeek = "Saturday"
	DayOfWeekSunday    DayOfWeek = "Sunday"
	DayOfWeekThursday  DayOfWeek = "Thursday"
	DayOfWeekTuesday   DayOfWeek = "Tuesday"
	DayOfWeekWednesday DayOfWeek = "Wednesday"
)

type HttpAuthenticationType 

type HttpAuthenticationType string
const (
	ActiveDirectoryOAuth HttpAuthenticationType = "ActiveDirectoryOAuth"
	Basic                HttpAuthenticationType = "Basic"
	ClientCertificate    HttpAuthenticationType = "ClientCertificate"
	NotSpecified         HttpAuthenticationType = "NotSpecified"
)

type JobActionType 

type JobActionType string
const (
	Http         JobActionType = "Http"
	Https        JobActionType = "Https"
	StorageQueue JobActionType = "StorageQueue"
)

type JobCollectionDefinition 

type JobCollectionDefinition struct {
	autorest.Response `json:"-"`
	Id                string            `json:"id,omitempty"`
	Type              string            `json:"type,omitempty"`
	Name              string            `json:"name,omitempty"`
	Location          string            `json:"location,omitempty"`
	Tags              map[string]string `json:"tags,omitempty"`
	Properties        struct {
		Sku struct {
			Name SkuDefinition `json:"name,omitempty"`
		} `json:"sku,omitempty"`
		State JobCollectionState `json:"state,omitempty"`
		Quota struct {
			MaxJobCount      int `json:"maxJobCount,omitempty"`
			MaxJobOccurrence int `json:"maxJobOccurrence,omitempty"`
			MaxRecurrence    struct {
				Frequency RecurrenceFrequency `json:"frequency,omitempty"`
				Interval  int                 `json:"interval,omitempty"`
			} `json:"maxRecurrence,omitempty"`
		} `json:"quota,omitempty"`
	} `json:"properties,omitempty"`
}

type JobCollectionListResult 

type JobCollectionListResult struct {
	autorest.Response `json:"-"`
	Value             []JobCollectionDefinition `json:"value,omitempty"`
	NextLink          string                    `json:"nextLink,omitempty"`
}

type JobCollectionState 

type JobCollectionState string
const (
	JobCollectionStateDeleted   JobCollectionState = "Deleted"
	JobCollectionStateDisabled  JobCollectionState = "Disabled"
	JobCollectionStateEnabled   JobCollectionState = "Enabled"
	JobCollectionStateSuspended JobCollectionState = "Suspended"
)

type JobCollectionsClient 

type JobCollectionsClient struct {
	SchedulerManagementClient
}

JobCollections Client

func NewJobCollectionsClient 

func NewJobCollectionsClient(subscriptionId string) JobCollectionsClient

func NewJobCollectionsClientWithBaseUri 

func NewJobCollectionsClientWithBaseUri(baseUri string, subscriptionId string) JobCollectionsClient

func (JobCollectionsClient) CreateOrUpdate 

func (client JobCollectionsClient) CreateOrUpdate(resourceGroupName string, jobCollectionName string, jobCollection JobCollectionDefinition) (result JobCollectionDefinition, ae autorest.Error)

CreateOrUpdate provisions a new job collection or updates an existing job collection.

resourceGroupName is the resource group name. jobCollectionName is the job collection name. jobCollection is the job collection definition.

func (JobCollectionsClient) CreateOrUpdateRequestPreparer 

func (client JobCollectionsClient) CreateOrUpdateRequestPreparer() autorest.Preparer

Create a Preparer by which to prepare the CreateOrUpdate request.

func (JobCollectionsClient) Delete 

func (client JobCollectionsClient) Delete(resourceGroupName string, jobCollectionName string) (result autorest.Response, ae autorest.Error)

Delete deletes a job collection.

resourceGroupName is the resource group name. jobCollectionName is the job collection name.

func (JobCollectionsClient) DeleteRequestPreparer 

func (client JobCollectionsClient) DeleteRequestPreparer() autorest.Preparer

Create a Preparer by which to prepare the Delete request.

func (JobCollectionsClient) Disable 

func (client JobCollectionsClient) Disable(resourceGroupName string, jobCollectionName string) (result autorest.Response, ae autorest.Error)

Disable disables all of the jobs in the job collection.

resourceGroupName is the resource group name. jobCollectionName is the job collection name.

func (JobCollectionsClient) DisableRequestPreparer 

func (client JobCollectionsClient) DisableRequestPreparer() autorest.Preparer

Create a Preparer by which to prepare the Disable request.

func (JobCollectionsClient) Enable 

func (client JobCollectionsClient) Enable(resourceGroupName string, jobCollectionName string) (result autorest.Response, ae autorest.Error)

Enable enables all of the jobs in the job collection.

resourceGroupName is the resource group name. jobCollectionName is the job collection name.

func (JobCollectionsClient) EnableRequestPreparer 

func (client JobCollectionsClient) EnableRequestPreparer() autorest.Preparer

Create a Preparer by which to prepare the Enable request.

func (JobCollectionsClient) Get 

func (client JobCollectionsClient) Get(resourceGroupName string, jobCollectionName string) (result JobCollectionDefinition, ae autorest.Error)

Get gets a job collection.

resourceGroupName is the resource group name. jobCollectionName is the job collection name.

func (JobCollectionsClient) GetRequestPreparer 

func (client JobCollectionsClient) GetRequestPreparer() autorest.Preparer

Create a Preparer by which to prepare the Get request.

func (JobCollectionsClient) ListByResourceGroup 

func (client JobCollectionsClient) ListByResourceGroup(resourceGroupName string) (result JobCollectionListResult, ae autorest.Error)

ListByResourceGroup gets all job collections under specified resource group.

resourceGroupName is the resource group name.

func (JobCollectionsClient) ListByResourceGroupRequestPreparer 

func (client JobCollectionsClient) ListByResourceGroupRequestPreparer() autorest.Preparer

Create a Preparer by which to prepare the ListByResourceGroup request.

func (JobCollectionsClient) ListBySubscription 

func (client JobCollectionsClient) ListBySubscription() (result JobCollectionListResult, ae autorest.Error)

ListBySubscription gets all job collections under specified subscription.

func (JobCollectionsClient) ListBySubscriptionRequestPreparer 

func (client JobCollectionsClient) ListBySubscriptionRequestPreparer() autorest.Preparer

Create a Preparer by which to prepare the ListBySubscription request.

func (JobCollectionsClient) NewCreateOrUpdateRequest 

func (client JobCollectionsClient) NewCreateOrUpdateRequest(resourceGroupName string, jobCollectionName string, jobCollection JobCollectionDefinition) (*http.Request, error)

Create the CreateOrUpdate request.

func (JobCollectionsClient) NewDeleteRequest 

func (client JobCollectionsClient) NewDeleteRequest(resourceGroupName string, jobCollectionName string) (*http.Request, error)

Create the Delete request.

func (JobCollectionsClient) NewDisableRequest 

func (client JobCollectionsClient) NewDisableRequest(resourceGroupName string, jobCollectionName string) (*http.Request, error)

Create the Disable request.

func (JobCollectionsClient) NewEnableRequest 

func (client JobCollectionsClient) NewEnableRequest(resourceGroupName string, jobCollectionName string) (*http.Request, error)

Create the Enable request.

func (JobCollectionsClient) NewGetRequest 

func (client JobCollectionsClient) NewGetRequest(resourceGroupName string, jobCollectionName string) (*http.Request, error)

Create the Get request.

func (JobCollectionsClient) NewListByResourceGroupRequest 

func (client JobCollectionsClient) NewListByResourceGroupRequest(resourceGroupName string) (*http.Request, error)

Create the ListByResourceGroup request.

func (JobCollectionsClient) NewListBySubscriptionRequest 

func (client JobCollectionsClient) NewListBySubscriptionRequest() (*http.Request, error)

Create the ListBySubscription request.

func (JobCollectionsClient) NewPatchRequest 

func (client JobCollectionsClient) NewPatchRequest(resourceGroupName string, jobCollectionName string, jobCollection JobCollectionDefinition) (*http.Request, error)

Create the Patch request.

func (JobCollectionsClient) Patch 

func (client JobCollectionsClient) Patch(resourceGroupName string, jobCollectionName string, jobCollection JobCollectionDefinition) (result JobCollectionDefinition, ae autorest.Error)

Patch patches an existing job collection.

resourceGroupName is the resource group name. jobCollectionName is the job collection name. jobCollection is the job collection definition.

func (JobCollectionsClient) PatchRequestPreparer 

func (client JobCollectionsClient) PatchRequestPreparer() autorest.Preparer

Create a Preparer by which to prepare the Patch request.

type JobDefinition 

type JobDefinition struct {
	autorest.Response `json:"-"`
	Id                string `json:"id,omitempty"`
	Type              string `json:"type,omitempty"`
	Name              string `json:"name,omitempty"`
	Properties        struct {
		StartTime date.Time `json:"startTime,omitempty"`
		Action    struct {
			Type    JobActionType `json:"type,omitempty"`
			Request struct {
				HttpAuthentication struct {
					Type HttpAuthenticationType `json:"type,omitempty"`
				} `json:"httpAuthentication,omitempty"`
				Uri     string            `json:"uri,omitempty"`
				Method  string            `json:"method,omitempty"`
				Body    string            `json:"body,omitempty"`
				Headers map[string]string `json:"headers,omitempty"`
			} `json:"request,omitempty"`
			QueueMessage struct {
				StorageAccount string `json:"storageAccount,omitempty"`
				QueueName      string `json:"queueName,omitempty"`
				SasToken       string `json:"sasToken,omitempty"`
				Message        string `json:"message,omitempty"`
			} `json:"queueMessage,omitempty"`
			RetryPolicy struct {
				RetryType     RetryType `json:"retryType,omitempty"`
				RetryInterval int       `json:"retryInterval,omitempty"`
				RetryCount    int       `json:"retryCount,omitempty"`
			} `json:"retryPolicy,omitempty"`
			ErrorAction struct {
				Type    JobActionType `json:"type,omitempty"`
				Request struct {
					HttpAuthentication struct {
						Type HttpAuthenticationType `json:"type,omitempty"`
					} `json:"httpAuthentication,omitempty"`
					Uri     string            `json:"uri,omitempty"`
					Method  string            `json:"method,omitempty"`
					Body    string            `json:"body,omitempty"`
					Headers map[string]string `json:"headers,omitempty"`
				} `json:"request,omitempty"`
				QueueMessage struct {
					StorageAccount string `json:"storageAccount,omitempty"`
					QueueName      string `json:"queueName,omitempty"`
					SasToken       string `json:"sasToken,omitempty"`
					Message        string `json:"message,omitempty"`
				} `json:"queueMessage,omitempty"`
				RetryPolicy struct {
					RetryType     RetryType `json:"retryType,omitempty"`
					RetryInterval int       `json:"retryInterval,omitempty"`
					RetryCount    int       `json:"retryCount,omitempty"`
				} `json:"retryPolicy,omitempty"`
			} `json:"errorAction,omitempty"`
		} `json:"action,omitempty"`
		Recurrence struct {
			Frequency RecurrenceFrequency `json:"frequency,omitempty"`
			Interval  int                 `json:"interval,omitempty"`
			Count     int                 `json:"count,omitempty"`
			EndTime   date.Time           `json:"endTime,omitempty"`
			Schedule  struct {
				WeekDays           []DayOfWeek                              `json:"weekDays,omitempty"`
				Hours              []int                                    `json:"hours,omitempty"`
				Minutes            []int                                    `json:"minutes,omitempty"`
				MonthDays          []int                                    `json:"monthDays,omitempty"`
				MonthlyOccurrences []JobRecurrenceScheduleMonthlyOccurrence `json:"monthlyOccurrences,omitempty"`
			} `json:"schedule,omitempty"`
		} `json:"recurrence,omitempty"`
		State  JobState `json:"state,omitempty"`
		Status struct {
			ExecutionCount    int       `json:"executionCount,omitempty"`
			FailureCount      int       `json:"failureCount,omitempty"`
			FaultedCount      int       `json:"faultedCount,omitempty"`
			LastExecutionTime date.Time `json:"lastExecutionTime,omitempty"`
			NextExecutionTime date.Time `json:"nextExecutionTime,omitempty"`
		} `json:"status,omitempty"`
	} `json:"properties,omitempty"`
}

type JobExecutionStatus 

type JobExecutionStatus string
const (
	JobExecutionStatusCallbackNotFound JobExecutionStatus = "CallbackNotFound"
	JobExecutionStatusCancelled        JobExecutionStatus = "Cancelled"
	JobExecutionStatusCompleted        JobExecutionStatus = "Completed"
	JobExecutionStatusFailed           JobExecutionStatus = "Failed"
	JobExecutionStatusPostponed        JobExecutionStatus = "Postponed"
)

type JobHistoryActionName 

type JobHistoryActionName string
const (
	ErrorAction JobHistoryActionName = "ErrorAction"
	MainAction  JobHistoryActionName = "MainAction"
)

type JobHistoryDefinition 

type JobHistoryDefinition struct {
	Id         string `json:"id,omitempty"`
	Type       string `json:"type,omitempty"`
	Name       string `json:"name,omitempty"`
	Properties struct {
		StartTime             date.Time            `json:"startTime,omitempty"`
		EndTime               date.Time            `json:"endTime,omitempty"`
		ExpectedExecutionTime date.Time            `json:"expectedExecutionTime,omitempty"`
		ActionName            JobHistoryActionName `json:"actionName,omitempty"`
		Status                JobExecutionStatus   `json:"status,omitempty"`
		Message               string               `json:"message,omitempty"`
		RetryCount            int                  `json:"retryCount,omitempty"`
		RepeatCount           int                  `json:"repeatCount,omitempty"`
	} `json:"properties,omitempty"`
}

type JobHistoryListResult 

type JobHistoryListResult struct {
	autorest.Response `json:"-"`
	Value             []JobHistoryDefinition `json:"value,omitempty"`
	NextLink          string                 `json:"nextLink,omitempty"`
}

type JobListResult 

type JobListResult struct {
	autorest.Response `json:"-"`
	Value             []JobDefinition `json:"value,omitempty"`
	NextLink          string          `json:"nextLink,omitempty"`
}

type JobRecurrenceScheduleMonthlyOccurrence 

type JobRecurrenceScheduleMonthlyOccurrence struct {
	Day        JobScheduleDay `json:"day,omitempty"`
	Occurrence int            `json:"Occurrence,omitempty"`
}

type JobScheduleDay 

type JobScheduleDay string
const (
	JobScheduleDayFriday    JobScheduleDay = "Friday"
	JobScheduleDayMonday    JobScheduleDay = "Monday"
	JobScheduleDaySaturday  JobScheduleDay = "Saturday"
	JobScheduleDaySunday    JobScheduleDay = "Sunday"
	JobScheduleDayThursday  JobScheduleDay = "Thursday"
	JobScheduleDayTuesday   JobScheduleDay = "Tuesday"
	JobScheduleDayWednesday JobScheduleDay = "Wednesday"
)

type JobState 

type JobState string
const (
	JobStateCompleted JobState = "Completed"
	JobStateDisabled  JobState = "Disabled"
	JobStateEnabled   JobState = "Enabled"
	JobStateFaulted   JobState = "Faulted"
)

type JobsClient 

type JobsClient struct {
	SchedulerManagementClient
}

Jobs Client

func NewJobsClient 

func NewJobsClient(subscriptionId string) JobsClient

func NewJobsClientWithBaseUri 

func NewJobsClientWithBaseUri(baseUri string, subscriptionId string) JobsClient

func (JobsClient) CreateOrUpdate 

func (client JobsClient) CreateOrUpdate(resourceGroupName string, jobCollectionName string, jobName string, job JobDefinition) (result JobDefinition, ae autorest.Error)

CreateOrUpdate provisions a new job or updates an existing job.

resourceGroupName is the resource group name. jobCollectionName is the job collection name. jobName is the job name. job is the job definition.

func (JobsClient) CreateOrUpdateRequestPreparer 

func (client JobsClient) CreateOrUpdateRequestPreparer() autorest.Preparer

Create a Preparer by which to prepare the CreateOrUpdate request.

func (JobsClient) Delete 

func (client JobsClient) Delete(resourceGroupName string, jobCollectionName string, jobName string) (result autorest.Response, ae autorest.Error)

Delete deletes a job.

resourceGroupName is the resource group name. jobCollectionName is the job collection name. jobName is the job name.

func (JobsClient) DeleteRequestPreparer 

func (client JobsClient) DeleteRequestPreparer() autorest.Preparer

Create a Preparer by which to prepare the Delete request.

func (JobsClient) Get 

func (client JobsClient) Get(resourceGroupName string, jobCollectionName string, jobName string) (result JobDefinition, ae autorest.Error)

Get gets a job.

resourceGroupName is the resource group name. jobCollectionName is the job collection name. jobName is the job name.

func (JobsClient) GetRequestPreparer 

func (client JobsClient) GetRequestPreparer() autorest.Preparer

Create a Preparer by which to prepare the Get request.

func (JobsClient) List 

func (client JobsClient) List(resourceGroupName string, jobCollectionName string, top int, skip int) (result JobListResult, ae autorest.Error)

List lists all jobs under the specified job collection.

resourceGroupName is the resource group name. jobCollectionName is the job collection name. top is the number of jobs to request, in the of range [1..100]. skip is the (0-based) index of the job history list from which to begin requesting entries.

func (JobsClient) ListJobHistory 

func (client JobsClient) ListJobHistory(resourceGroupName string, jobCollectionName string, jobName string, top int, skip int) (result JobHistoryListResult, ae autorest.Error)

ListJobHistory lists job history.

resourceGroupName is the resource group name. jobCollectionName is the job collection name. jobName is the job name. top is the number of job history to request, in the of range [1..100]. skip is the (0-based) index of the job history list from which to begin requesting entries.

func (JobsClient) ListJobHistoryRequestPreparer 

func (client JobsClient) ListJobHistoryRequestPreparer() autorest.Preparer

Create a Preparer by which to prepare the ListJobHistory request.

func (JobsClient) ListRequestPreparer 

func (client JobsClient) ListRequestPreparer() autorest.Preparer

Create a Preparer by which to prepare the List request.

func (JobsClient) NewCreateOrUpdateRequest 

func (client JobsClient) NewCreateOrUpdateRequest(resourceGroupName string, jobCollectionName string, jobName string, job JobDefinition) (*http.Request, error)

Create the CreateOrUpdate request.

func (JobsClient) NewDeleteRequest 

func (client JobsClient) NewDeleteRequest(resourceGroupName string, jobCollectionName string, jobName string) (*http.Request, error)

Create the Delete request.

func (JobsClient) NewGetRequest 

func (client JobsClient) NewGetRequest(resourceGroupName string, jobCollectionName string, jobName string) (*http.Request, error)

Create the Get request.

func (JobsClient) NewListJobHistoryRequest 

func (client JobsClient) NewListJobHistoryRequest(resourceGroupName string, jobCollectionName string, jobName string, top int, skip int) (*http.Request, error)

Create the ListJobHistory request.

func (JobsClient) NewListRequest 

func (client JobsClient) NewListRequest(resourceGroupName string, jobCollectionName string, top int, skip int) (*http.Request, error)

Create the List request.

func (JobsClient) NewPatchRequest 

func (client JobsClient) NewPatchRequest(resourceGroupName string, jobCollectionName string, jobName string, job JobDefinition) (*http.Request, error)

Create the Patch request.

func (JobsClient) NewRunRequest 

func (client JobsClient) NewRunRequest(resourceGroupName string, jobCollectionName string, jobName string) (*http.Request, error)

Create the Run request.

func (JobsClient) Patch 

func (client JobsClient) Patch(resourceGroupName string, jobCollectionName string, jobName string, job JobDefinition) (result JobDefinition, ae autorest.Error)

Patch patches an existing job.

resourceGroupName is the resource group name. jobCollectionName is the job collection name. jobName is the job name. job is the job definition.

func (JobsClient) PatchRequestPreparer 

func (client JobsClient) PatchRequestPreparer() autorest.Preparer

Create a Preparer by which to prepare the Patch request.

func (JobsClient) Run 

func (client JobsClient) Run(resourceGroupName string, jobCollectionName string, jobName string) (result autorest.Response, ae autorest.Error)

Run runs a job.

resourceGroupName is the resource group name. jobCollectionName is the job collection name. jobName is the job name.

func (JobsClient) RunRequestPreparer 

func (client JobsClient) RunRequestPreparer() autorest.Preparer

Create a Preparer by which to prepare the Run request.

type RecurrenceFrequency 

type RecurrenceFrequency string
const (
	Day    RecurrenceFrequency = "Day"
	Hour   RecurrenceFrequency = "Hour"
	Minute RecurrenceFrequency = "Minute"
	Month  RecurrenceFrequency = "Month"
	Week   RecurrenceFrequency = "Week"
)

type RetryType 

type RetryType string
const (
	Fixed RetryType = "Fixed"
	None  RetryType = "None"
)

type SchedulerManagementClient 

type SchedulerManagementClient struct {
	autorest.Client
	BaseUri        string
	SubscriptionId string
}

func New 

func New(subscriptionId string) SchedulerManagementClient

func NewWithBaseUri 

func NewWithBaseUri(baseUri string, subscriptionId string) SchedulerManagementClient

type SkuDefinition 

type SkuDefinition string
const (
	Free     SkuDefinition = "Free"
	Premium  SkuDefinition = "Premium"
	Standard SkuDefinition = "Standard"
)

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.