Documentation ¶
Overview ¶
Package batch implements the Azure ARM Batch service API version 2015-12-01.2.2.
A client for issuing REST requests to the Azure Batch service.
Index ¶
- Constants
- func UserAgent() string
- func Version() string
- type AffinityInformation
- type AllocationState
- type ApplicationClient
- func (client ApplicationClient) Get(ctx context.Context, applicationID string, timeout *int32, ...) (result ApplicationSummary, err error)
- func (client ApplicationClient) GetPreparer(ctx context.Context, applicationID string, timeout *int32, ...) (*http.Request, error)
- func (client ApplicationClient) GetResponder(resp *http.Response) (result ApplicationSummary, err error)
- func (client ApplicationClient) GetSender(req *http.Request) (*http.Response, error)
- func (client ApplicationClient) List(ctx context.Context, maxResults *int32, timeout *int32, clientRequestID string, ...) (result ApplicationListResultPage, err error)
- func (client ApplicationClient) ListComplete(ctx context.Context, maxResults *int32, timeout *int32, clientRequestID string, ...) (result ApplicationListResultIterator, err error)
- func (client ApplicationClient) ListPreparer(ctx context.Context, maxResults *int32, timeout *int32, clientRequestID string, ...) (*http.Request, error)
- func (client ApplicationClient) ListResponder(resp *http.Response) (result ApplicationListResult, err error)
- func (client ApplicationClient) ListSender(req *http.Request) (*http.Response, error)
- type ApplicationListResult
- type ApplicationListResultIterator
- type ApplicationListResultPage
- type ApplicationPackageReference
- type ApplicationSummary
- type AutoPoolSpecification
- type AutoScaleRun
- type AutoScaleRunError
- type BaseClient
- type Certificate
- type CertificateAddParameter
- type CertificateClient
- func (client CertificateClient) Add(ctx context.Context, certificate CertificateAddParameter, timeout *int32, ...) (result autorest.Response, err error)
- func (client CertificateClient) AddPreparer(ctx context.Context, certificate CertificateAddParameter, timeout *int32, ...) (*http.Request, error)
- func (client CertificateClient) AddResponder(resp *http.Response) (result autorest.Response, err error)
- func (client CertificateClient) AddSender(req *http.Request) (*http.Response, error)
- func (client CertificateClient) CancelDeletion(ctx context.Context, thumbprintAlgorithm string, thumbprint string, ...) (result autorest.Response, err error)
- func (client CertificateClient) CancelDeletionPreparer(ctx context.Context, thumbprintAlgorithm string, thumbprint string, ...) (*http.Request, error)
- func (client CertificateClient) CancelDeletionResponder(resp *http.Response) (result autorest.Response, err error)
- func (client CertificateClient) CancelDeletionSender(req *http.Request) (*http.Response, error)
- func (client CertificateClient) Delete(ctx context.Context, thumbprintAlgorithm string, thumbprint string, ...) (result autorest.Response, err error)
- func (client CertificateClient) DeletePreparer(ctx context.Context, thumbprintAlgorithm string, thumbprint string, ...) (*http.Request, error)
- func (client CertificateClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client CertificateClient) DeleteSender(req *http.Request) (*http.Response, error)
- func (client CertificateClient) Get(ctx context.Context, thumbprintAlgorithm string, thumbprint string, ...) (result Certificate, err error)
- func (client CertificateClient) GetPreparer(ctx context.Context, thumbprintAlgorithm string, thumbprint string, ...) (*http.Request, error)
- func (client CertificateClient) GetResponder(resp *http.Response) (result Certificate, err error)
- func (client CertificateClient) GetSender(req *http.Request) (*http.Response, error)
- func (client CertificateClient) List(ctx context.Context, filter string, selectParameter string, maxResults *int32, ...) (result CertificateListResultPage, err error)
- func (client CertificateClient) ListComplete(ctx context.Context, filter string, selectParameter string, maxResults *int32, ...) (result CertificateListResultIterator, err error)
- func (client CertificateClient) ListPreparer(ctx context.Context, filter string, selectParameter string, maxResults *int32, ...) (*http.Request, error)
- func (client CertificateClient) ListResponder(resp *http.Response) (result CertificateListResult, err error)
- func (client CertificateClient) ListSender(req *http.Request) (*http.Response, error)
- type CertificateFormat
- type CertificateListResult
- type CertificateListResultIterator
- type CertificateListResultPage
- type CertificateReference
- type CertificateState
- type CertificateStoreLocation
- type CloudJob
- type CloudJobListPreparationAndReleaseTaskStatusResult
- type CloudJobListPreparationAndReleaseTaskStatusResultIterator
- func (iter *CloudJobListPreparationAndReleaseTaskStatusResultIterator) Next() error
- func (iter CloudJobListPreparationAndReleaseTaskStatusResultIterator) NotDone() bool
- func (iter CloudJobListPreparationAndReleaseTaskStatusResultIterator) Response() CloudJobListPreparationAndReleaseTaskStatusResult
- func (iter CloudJobListPreparationAndReleaseTaskStatusResultIterator) Value() JobPreparationAndReleaseTaskExecutionInformation
- type CloudJobListPreparationAndReleaseTaskStatusResultPage
- func (page *CloudJobListPreparationAndReleaseTaskStatusResultPage) Next() error
- func (page CloudJobListPreparationAndReleaseTaskStatusResultPage) NotDone() bool
- func (page CloudJobListPreparationAndReleaseTaskStatusResultPage) Response() CloudJobListPreparationAndReleaseTaskStatusResult
- func (page CloudJobListPreparationAndReleaseTaskStatusResultPage) Values() []JobPreparationAndReleaseTaskExecutionInformation
- type CloudJobListResult
- type CloudJobListResultIterator
- type CloudJobListResultPage
- type CloudJobSchedule
- type CloudJobScheduleListResult
- type CloudJobScheduleListResultIterator
- type CloudJobScheduleListResultPage
- type CloudPool
- type CloudPoolListResult
- type CloudPoolListResultIterator
- type CloudPoolListResultPage
- type CloudTask
- type CloudTaskListResult
- type CloudTaskListResultIterator
- type CloudTaskListResultPage
- type CloudTaskListSubtasksResult
- type ComputeNode
- type ComputeNodeClient
- func (client ComputeNodeClient) AddUser(ctx context.Context, poolID string, nodeID string, ...) (result autorest.Response, err error)
- func (client ComputeNodeClient) AddUserPreparer(ctx context.Context, poolID string, nodeID string, ...) (*http.Request, error)
- func (client ComputeNodeClient) AddUserResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ComputeNodeClient) AddUserSender(req *http.Request) (*http.Response, error)
- func (client ComputeNodeClient) DeleteUser(ctx context.Context, poolID string, nodeID string, userName string, ...) (result autorest.Response, err error)
- func (client ComputeNodeClient) DeleteUserPreparer(ctx context.Context, poolID string, nodeID string, userName string, ...) (*http.Request, error)
- func (client ComputeNodeClient) DeleteUserResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ComputeNodeClient) DeleteUserSender(req *http.Request) (*http.Response, error)
- func (client ComputeNodeClient) DisableScheduling(ctx context.Context, poolID string, nodeID string, ...) (result autorest.Response, err error)
- func (client ComputeNodeClient) DisableSchedulingPreparer(ctx context.Context, poolID string, nodeID string, ...) (*http.Request, error)
- func (client ComputeNodeClient) DisableSchedulingResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ComputeNodeClient) DisableSchedulingSender(req *http.Request) (*http.Response, error)
- func (client ComputeNodeClient) EnableScheduling(ctx context.Context, poolID string, nodeID string, timeout *int32, ...) (result autorest.Response, err error)
- func (client ComputeNodeClient) EnableSchedulingPreparer(ctx context.Context, poolID string, nodeID string, timeout *int32, ...) (*http.Request, error)
- func (client ComputeNodeClient) EnableSchedulingResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ComputeNodeClient) EnableSchedulingSender(req *http.Request) (*http.Response, error)
- func (client ComputeNodeClient) Get(ctx context.Context, poolID string, nodeID string, selectParameter string, ...) (result ComputeNode, err error)
- func (client ComputeNodeClient) GetPreparer(ctx context.Context, poolID string, nodeID string, selectParameter string, ...) (*http.Request, error)
- func (client ComputeNodeClient) GetRemoteDesktop(ctx context.Context, poolID string, nodeID string, timeout *int32, ...) (result ReadCloser, err error)
- func (client ComputeNodeClient) GetRemoteDesktopPreparer(ctx context.Context, poolID string, nodeID string, timeout *int32, ...) (*http.Request, error)
- func (client ComputeNodeClient) GetRemoteDesktopResponder(resp *http.Response) (result ReadCloser, err error)
- func (client ComputeNodeClient) GetRemoteDesktopSender(req *http.Request) (*http.Response, error)
- func (client ComputeNodeClient) GetResponder(resp *http.Response) (result ComputeNode, err error)
- func (client ComputeNodeClient) GetSender(req *http.Request) (*http.Response, error)
- func (client ComputeNodeClient) List(ctx context.Context, poolID string, filter string, selectParameter string, ...) (result ComputeNodeListResultPage, err error)
- func (client ComputeNodeClient) ListComplete(ctx context.Context, poolID string, filter string, selectParameter string, ...) (result ComputeNodeListResultIterator, err error)
- func (client ComputeNodeClient) ListPreparer(ctx context.Context, poolID string, filter string, selectParameter string, ...) (*http.Request, error)
- func (client ComputeNodeClient) ListResponder(resp *http.Response) (result ComputeNodeListResult, err error)
- func (client ComputeNodeClient) ListSender(req *http.Request) (*http.Response, error)
- func (client ComputeNodeClient) Reboot(ctx context.Context, poolID string, nodeID string, ...) (result autorest.Response, err error)
- func (client ComputeNodeClient) RebootPreparer(ctx context.Context, poolID string, nodeID string, ...) (*http.Request, error)
- func (client ComputeNodeClient) RebootResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ComputeNodeClient) RebootSender(req *http.Request) (*http.Response, error)
- func (client ComputeNodeClient) Reimage(ctx context.Context, poolID string, nodeID string, ...) (result autorest.Response, err error)
- func (client ComputeNodeClient) ReimagePreparer(ctx context.Context, poolID string, nodeID string, ...) (*http.Request, error)
- func (client ComputeNodeClient) ReimageResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ComputeNodeClient) ReimageSender(req *http.Request) (*http.Response, error)
- func (client ComputeNodeClient) UpdateUser(ctx context.Context, poolID string, nodeID string, userName string, ...) (result autorest.Response, err error)
- func (client ComputeNodeClient) UpdateUserPreparer(ctx context.Context, poolID string, nodeID string, userName string, ...) (*http.Request, error)
- func (client ComputeNodeClient) UpdateUserResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ComputeNodeClient) UpdateUserSender(req *http.Request) (*http.Response, error)
- type ComputeNodeDeallocationOption
- type ComputeNodeError
- type ComputeNodeFillType
- type ComputeNodeInformation
- type ComputeNodeListResult
- type ComputeNodeListResultIterator
- type ComputeNodeListResultPage
- type ComputeNodeRebootOption
- type ComputeNodeReimageOption
- type ComputeNodeState
- type ComputeNodeUser
- type DeleteCertificateError
- type DisableComputeNodeSchedulingOption
- type DisableJobOption
- type EnvironmentSetting
- type Error
- type ErrorDetail
- type ErrorMessage
- type FileClient
- func (client FileClient) DeleteFromComputeNode(ctx context.Context, poolID string, nodeID string, fileName string, ...) (result autorest.Response, err error)
- func (client FileClient) DeleteFromComputeNodePreparer(ctx context.Context, poolID string, nodeID string, fileName string, ...) (*http.Request, error)
- func (client FileClient) DeleteFromComputeNodeResponder(resp *http.Response) (result autorest.Response, err error)
- func (client FileClient) DeleteFromComputeNodeSender(req *http.Request) (*http.Response, error)
- func (client FileClient) DeleteFromTask(ctx context.Context, jobID string, taskID string, fileName string, ...) (result autorest.Response, err error)
- func (client FileClient) DeleteFromTaskPreparer(ctx context.Context, jobID string, taskID string, fileName string, ...) (*http.Request, error)
- func (client FileClient) DeleteFromTaskResponder(resp *http.Response) (result autorest.Response, err error)
- func (client FileClient) DeleteFromTaskSender(req *http.Request) (*http.Response, error)
- func (client FileClient) GetFromComputeNode(ctx context.Context, poolID string, nodeID string, fileName string, ...) (result ReadCloser, err error)
- func (client FileClient) GetFromComputeNodePreparer(ctx context.Context, poolID string, nodeID string, fileName string, ...) (*http.Request, error)
- func (client FileClient) GetFromComputeNodeResponder(resp *http.Response) (result ReadCloser, err error)
- func (client FileClient) GetFromComputeNodeSender(req *http.Request) (*http.Response, error)
- func (client FileClient) GetFromTask(ctx context.Context, jobID string, taskID string, fileName string, ...) (result ReadCloser, err error)
- func (client FileClient) GetFromTaskPreparer(ctx context.Context, jobID string, taskID string, fileName string, ...) (*http.Request, error)
- func (client FileClient) GetFromTaskResponder(resp *http.Response) (result ReadCloser, err error)
- func (client FileClient) GetFromTaskSender(req *http.Request) (*http.Response, error)
- func (client FileClient) GetNodeFilePropertiesFromComputeNode(ctx context.Context, poolID string, nodeID string, fileName string, ...) (result autorest.Response, err error)
- func (client FileClient) GetNodeFilePropertiesFromComputeNodePreparer(ctx context.Context, poolID string, nodeID string, fileName string, ...) (*http.Request, error)
- func (client FileClient) GetNodeFilePropertiesFromComputeNodeResponder(resp *http.Response) (result autorest.Response, err error)
- func (client FileClient) GetNodeFilePropertiesFromComputeNodeSender(req *http.Request) (*http.Response, error)
- func (client FileClient) GetNodeFilePropertiesFromTask(ctx context.Context, jobID string, taskID string, fileName string, ...) (result autorest.Response, err error)
- func (client FileClient) GetNodeFilePropertiesFromTaskPreparer(ctx context.Context, jobID string, taskID string, fileName string, ...) (*http.Request, error)
- func (client FileClient) GetNodeFilePropertiesFromTaskResponder(resp *http.Response) (result autorest.Response, err error)
- func (client FileClient) GetNodeFilePropertiesFromTaskSender(req *http.Request) (*http.Response, error)
- func (client FileClient) ListFromComputeNode(ctx context.Context, poolID string, nodeID string, filter string, ...) (result NodeFileListResultPage, err error)
- func (client FileClient) ListFromComputeNodeComplete(ctx context.Context, poolID string, nodeID string, filter string, ...) (result NodeFileListResultIterator, err error)
- func (client FileClient) ListFromComputeNodePreparer(ctx context.Context, poolID string, nodeID string, filter string, ...) (*http.Request, error)
- func (client FileClient) ListFromComputeNodeResponder(resp *http.Response) (result NodeFileListResult, err error)
- func (client FileClient) ListFromComputeNodeSender(req *http.Request) (*http.Response, error)
- func (client FileClient) ListFromTask(ctx context.Context, jobID string, taskID string, filter string, ...) (result NodeFileListResultPage, err error)
- func (client FileClient) ListFromTaskComplete(ctx context.Context, jobID string, taskID string, filter string, ...) (result NodeFileListResultIterator, err error)
- func (client FileClient) ListFromTaskPreparer(ctx context.Context, jobID string, taskID string, filter string, ...) (*http.Request, error)
- func (client FileClient) ListFromTaskResponder(resp *http.Response) (result NodeFileListResult, err error)
- func (client FileClient) ListFromTaskSender(req *http.Request) (*http.Response, error)
- type FileProperties
- type JobAddParameter
- type JobClient
- func (client JobClient) Add(ctx context.Context, job JobAddParameter, timeout *int32, ...) (result autorest.Response, err error)
- func (client JobClient) AddPreparer(ctx context.Context, job JobAddParameter, timeout *int32, ...) (*http.Request, error)
- func (client JobClient) AddResponder(resp *http.Response) (result autorest.Response, err error)
- func (client JobClient) AddSender(req *http.Request) (*http.Response, error)
- func (client JobClient) Delete(ctx context.Context, jobID string, timeout *int32, clientRequestID string, ...) (result autorest.Response, err error)
- func (client JobClient) DeletePreparer(ctx context.Context, jobID string, timeout *int32, clientRequestID string, ...) (*http.Request, error)
- func (client JobClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client JobClient) DeleteSender(req *http.Request) (*http.Response, error)
- func (client JobClient) Disable(ctx context.Context, jobID string, jobDisableParameter JobDisableParameter, ...) (result autorest.Response, err error)
- func (client JobClient) DisablePreparer(ctx context.Context, jobID string, jobDisableParameter JobDisableParameter, ...) (*http.Request, error)
- func (client JobClient) DisableResponder(resp *http.Response) (result autorest.Response, err error)
- func (client JobClient) DisableSender(req *http.Request) (*http.Response, error)
- func (client JobClient) Enable(ctx context.Context, jobID string, timeout *int32, clientRequestID string, ...) (result autorest.Response, err error)
- func (client JobClient) EnablePreparer(ctx context.Context, jobID string, timeout *int32, clientRequestID string, ...) (*http.Request, error)
- func (client JobClient) EnableResponder(resp *http.Response) (result autorest.Response, err error)
- func (client JobClient) EnableSender(req *http.Request) (*http.Response, error)
- func (client JobClient) Get(ctx context.Context, jobID string, selectParameter string, expand string, ...) (result CloudJob, err error)
- func (client JobClient) GetAllJobsLifetimeStatistics(ctx context.Context, timeout *int32, clientRequestID string, ...) (result JobStatistics, err error)
- func (client JobClient) GetAllJobsLifetimeStatisticsPreparer(ctx context.Context, timeout *int32, clientRequestID string, ...) (*http.Request, error)
- func (client JobClient) GetAllJobsLifetimeStatisticsResponder(resp *http.Response) (result JobStatistics, err error)
- func (client JobClient) GetAllJobsLifetimeStatisticsSender(req *http.Request) (*http.Response, error)
- func (client JobClient) GetPreparer(ctx context.Context, jobID string, selectParameter string, expand string, ...) (*http.Request, error)
- func (client JobClient) GetResponder(resp *http.Response) (result CloudJob, err error)
- func (client JobClient) GetSender(req *http.Request) (*http.Response, error)
- func (client JobClient) List(ctx context.Context, filter string, selectParameter string, expand string, ...) (result CloudJobListResultPage, err error)
- func (client JobClient) ListComplete(ctx context.Context, filter string, selectParameter string, expand string, ...) (result CloudJobListResultIterator, err error)
- func (client JobClient) ListFromJobSchedule(ctx context.Context, jobScheduleID string, filter string, ...) (result CloudJobListResultPage, err error)
- func (client JobClient) ListFromJobScheduleComplete(ctx context.Context, jobScheduleID string, filter string, ...) (result CloudJobListResultIterator, err error)
- func (client JobClient) ListFromJobSchedulePreparer(ctx context.Context, jobScheduleID string, filter string, ...) (*http.Request, error)
- func (client JobClient) ListFromJobScheduleResponder(resp *http.Response) (result CloudJobListResult, err error)
- func (client JobClient) ListFromJobScheduleSender(req *http.Request) (*http.Response, error)
- func (client JobClient) ListPreparationAndReleaseTaskStatus(ctx context.Context, jobID string, filter string, selectParameter string, ...) (result CloudJobListPreparationAndReleaseTaskStatusResultPage, err error)
- func (client JobClient) ListPreparationAndReleaseTaskStatusComplete(ctx context.Context, jobID string, filter string, selectParameter string, ...) (result CloudJobListPreparationAndReleaseTaskStatusResultIterator, err error)
- func (client JobClient) ListPreparationAndReleaseTaskStatusPreparer(ctx context.Context, jobID string, filter string, selectParameter string, ...) (*http.Request, error)
- func (client JobClient) ListPreparationAndReleaseTaskStatusResponder(resp *http.Response) (result CloudJobListPreparationAndReleaseTaskStatusResult, err error)
- func (client JobClient) ListPreparationAndReleaseTaskStatusSender(req *http.Request) (*http.Response, error)
- func (client JobClient) ListPreparer(ctx context.Context, filter string, selectParameter string, expand string, ...) (*http.Request, error)
- func (client JobClient) ListResponder(resp *http.Response) (result CloudJobListResult, err error)
- func (client JobClient) ListSender(req *http.Request) (*http.Response, error)
- func (client JobClient) Patch(ctx context.Context, jobID string, jobPatchParameter JobPatchParameter, ...) (result autorest.Response, err error)
- func (client JobClient) PatchPreparer(ctx context.Context, jobID string, jobPatchParameter JobPatchParameter, ...) (*http.Request, error)
- func (client JobClient) PatchResponder(resp *http.Response) (result autorest.Response, err error)
- func (client JobClient) PatchSender(req *http.Request) (*http.Response, error)
- func (client JobClient) Terminate(ctx context.Context, jobID string, ...) (result autorest.Response, err error)
- func (client JobClient) TerminatePreparer(ctx context.Context, jobID string, ...) (*http.Request, error)
- func (client JobClient) TerminateResponder(resp *http.Response) (result autorest.Response, err error)
- func (client JobClient) TerminateSender(req *http.Request) (*http.Response, error)
- func (client JobClient) Update(ctx context.Context, jobID string, jobUpdateParameter JobUpdateParameter, ...) (result autorest.Response, err error)
- func (client JobClient) UpdatePreparer(ctx context.Context, jobID string, jobUpdateParameter JobUpdateParameter, ...) (*http.Request, error)
- func (client JobClient) UpdateResponder(resp *http.Response) (result autorest.Response, err error)
- func (client JobClient) UpdateSender(req *http.Request) (*http.Response, error)
- type JobConstraints
- type JobDisableParameter
- type JobExecutionInformation
- type JobManagerTask
- type JobPatchParameter
- type JobPreparationAndReleaseTaskExecutionInformation
- type JobPreparationTask
- type JobPreparationTaskExecutionInformation
- type JobPreparationTaskState
- type JobReleaseTask
- type JobReleaseTaskExecutionInformation
- type JobReleaseTaskState
- type JobScheduleAddParameter
- type JobScheduleClient
- func (client JobScheduleClient) Add(ctx context.Context, cloudJobSchedule JobScheduleAddParameter, timeout *int32, ...) (result autorest.Response, err error)
- func (client JobScheduleClient) AddPreparer(ctx context.Context, cloudJobSchedule JobScheduleAddParameter, timeout *int32, ...) (*http.Request, error)
- func (client JobScheduleClient) AddResponder(resp *http.Response) (result autorest.Response, err error)
- func (client JobScheduleClient) AddSender(req *http.Request) (*http.Response, error)
- func (client JobScheduleClient) Delete(ctx context.Context, jobScheduleID string, timeout *int32, ...) (result autorest.Response, err error)
- func (client JobScheduleClient) DeletePreparer(ctx context.Context, jobScheduleID string, timeout *int32, ...) (*http.Request, error)
- func (client JobScheduleClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client JobScheduleClient) DeleteSender(req *http.Request) (*http.Response, error)
- func (client JobScheduleClient) Disable(ctx context.Context, jobScheduleID string, timeout *int32, ...) (result autorest.Response, err error)
- func (client JobScheduleClient) DisablePreparer(ctx context.Context, jobScheduleID string, timeout *int32, ...) (*http.Request, error)
- func (client JobScheduleClient) DisableResponder(resp *http.Response) (result autorest.Response, err error)
- func (client JobScheduleClient) DisableSender(req *http.Request) (*http.Response, error)
- func (client JobScheduleClient) Enable(ctx context.Context, jobScheduleID string, timeout *int32, ...) (result autorest.Response, err error)
- func (client JobScheduleClient) EnablePreparer(ctx context.Context, jobScheduleID string, timeout *int32, ...) (*http.Request, error)
- func (client JobScheduleClient) EnableResponder(resp *http.Response) (result autorest.Response, err error)
- func (client JobScheduleClient) EnableSender(req *http.Request) (*http.Response, error)
- func (client JobScheduleClient) Exists(ctx context.Context, jobScheduleID string, selectParameter string, ...) (result autorest.Response, err error)
- func (client JobScheduleClient) ExistsPreparer(ctx context.Context, jobScheduleID string, selectParameter string, ...) (*http.Request, error)
- func (client JobScheduleClient) ExistsResponder(resp *http.Response) (result autorest.Response, err error)
- func (client JobScheduleClient) ExistsSender(req *http.Request) (*http.Response, error)
- func (client JobScheduleClient) Get(ctx context.Context, jobScheduleID string, selectParameter string, ...) (result CloudJobSchedule, err error)
- func (client JobScheduleClient) GetPreparer(ctx context.Context, jobScheduleID string, selectParameter string, ...) (*http.Request, error)
- func (client JobScheduleClient) GetResponder(resp *http.Response) (result CloudJobSchedule, err error)
- func (client JobScheduleClient) GetSender(req *http.Request) (*http.Response, error)
- func (client JobScheduleClient) List(ctx context.Context, filter string, selectParameter string, expand string, ...) (result CloudJobScheduleListResultPage, err error)
- func (client JobScheduleClient) ListComplete(ctx context.Context, filter string, selectParameter string, expand string, ...) (result CloudJobScheduleListResultIterator, err error)
- func (client JobScheduleClient) ListPreparer(ctx context.Context, filter string, selectParameter string, expand string, ...) (*http.Request, error)
- func (client JobScheduleClient) ListResponder(resp *http.Response) (result CloudJobScheduleListResult, err error)
- func (client JobScheduleClient) ListSender(req *http.Request) (*http.Response, error)
- func (client JobScheduleClient) Patch(ctx context.Context, jobScheduleID string, ...) (result autorest.Response, err error)
- func (client JobScheduleClient) PatchPreparer(ctx context.Context, jobScheduleID string, ...) (*http.Request, error)
- func (client JobScheduleClient) PatchResponder(resp *http.Response) (result autorest.Response, err error)
- func (client JobScheduleClient) PatchSender(req *http.Request) (*http.Response, error)
- func (client JobScheduleClient) Terminate(ctx context.Context, jobScheduleID string, timeout *int32, ...) (result autorest.Response, err error)
- func (client JobScheduleClient) TerminatePreparer(ctx context.Context, jobScheduleID string, timeout *int32, ...) (*http.Request, error)
- func (client JobScheduleClient) TerminateResponder(resp *http.Response) (result autorest.Response, err error)
- func (client JobScheduleClient) TerminateSender(req *http.Request) (*http.Response, error)
- func (client JobScheduleClient) Update(ctx context.Context, jobScheduleID string, ...) (result autorest.Response, err error)
- func (client JobScheduleClient) UpdatePreparer(ctx context.Context, jobScheduleID string, ...) (*http.Request, error)
- func (client JobScheduleClient) UpdateResponder(resp *http.Response) (result autorest.Response, err error)
- func (client JobScheduleClient) UpdateSender(req *http.Request) (*http.Response, error)
- type JobScheduleExecutionInformation
- type JobSchedulePatchParameter
- type JobScheduleState
- type JobScheduleStatistics
- type JobScheduleUpdateParameter
- type JobSchedulingError
- type JobSpecification
- type JobState
- type JobStatistics
- type JobTerminateParameter
- type JobUpdateParameter
- type MetadataItem
- type MultiInstanceSettings
- type NameValuePair
- type NodeDisableSchedulingParameter
- type NodeFile
- type NodeFileListResult
- type NodeFileListResultIterator
- type NodeFileListResultPage
- type NodeRebootParameter
- type NodeReimageParameter
- type NodeRemoveParameter
- type NodeUpdateUserParameter
- type PoolAddParameter
- type PoolClient
- func (client PoolClient) Add(ctx context.Context, pool PoolAddParameter, timeout *int32, ...) (result autorest.Response, err error)
- func (client PoolClient) AddPreparer(ctx context.Context, pool PoolAddParameter, timeout *int32, ...) (*http.Request, error)
- func (client PoolClient) AddResponder(resp *http.Response) (result autorest.Response, err error)
- func (client PoolClient) AddSender(req *http.Request) (*http.Response, error)
- func (client PoolClient) Delete(ctx context.Context, poolID string, timeout *int32, clientRequestID string, ...) (result autorest.Response, err error)
- func (client PoolClient) DeletePreparer(ctx context.Context, poolID string, timeout *int32, clientRequestID string, ...) (*http.Request, error)
- func (client PoolClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client PoolClient) DeleteSender(req *http.Request) (*http.Response, error)
- func (client PoolClient) DisableAutoScale(ctx context.Context, poolID string, timeout *int32, clientRequestID string, ...) (result autorest.Response, err error)
- func (client PoolClient) DisableAutoScalePreparer(ctx context.Context, poolID string, timeout *int32, clientRequestID string, ...) (*http.Request, error)
- func (client PoolClient) DisableAutoScaleResponder(resp *http.Response) (result autorest.Response, err error)
- func (client PoolClient) DisableAutoScaleSender(req *http.Request) (*http.Response, error)
- func (client PoolClient) EnableAutoScale(ctx context.Context, poolID string, ...) (result autorest.Response, err error)
- func (client PoolClient) EnableAutoScalePreparer(ctx context.Context, poolID string, ...) (*http.Request, error)
- func (client PoolClient) EnableAutoScaleResponder(resp *http.Response) (result autorest.Response, err error)
- func (client PoolClient) EnableAutoScaleSender(req *http.Request) (*http.Response, error)
- func (client PoolClient) EvaluateAutoScale(ctx context.Context, poolID string, ...) (result AutoScaleRun, err error)
- func (client PoolClient) EvaluateAutoScalePreparer(ctx context.Context, poolID string, ...) (*http.Request, error)
- func (client PoolClient) EvaluateAutoScaleResponder(resp *http.Response) (result AutoScaleRun, err error)
- func (client PoolClient) EvaluateAutoScaleSender(req *http.Request) (*http.Response, error)
- func (client PoolClient) Exists(ctx context.Context, poolID string, selectParameter string, timeout *int32, ...) (result autorest.Response, err error)
- func (client PoolClient) ExistsPreparer(ctx context.Context, poolID string, selectParameter string, timeout *int32, ...) (*http.Request, error)
- func (client PoolClient) ExistsResponder(resp *http.Response) (result autorest.Response, err error)
- func (client PoolClient) ExistsSender(req *http.Request) (*http.Response, error)
- func (client PoolClient) Get(ctx context.Context, poolID string, selectParameter string, expand string, ...) (result CloudPool, err error)
- func (client PoolClient) GetAllPoolsLifetimeStatistics(ctx context.Context, timeout *int32, clientRequestID string, ...) (result PoolStatistics, err error)
- func (client PoolClient) GetAllPoolsLifetimeStatisticsPreparer(ctx context.Context, timeout *int32, clientRequestID string, ...) (*http.Request, error)
- func (client PoolClient) GetAllPoolsLifetimeStatisticsResponder(resp *http.Response) (result PoolStatistics, err error)
- func (client PoolClient) GetAllPoolsLifetimeStatisticsSender(req *http.Request) (*http.Response, error)
- func (client PoolClient) GetPreparer(ctx context.Context, poolID string, selectParameter string, expand string, ...) (*http.Request, error)
- func (client PoolClient) GetResponder(resp *http.Response) (result CloudPool, err error)
- func (client PoolClient) GetSender(req *http.Request) (*http.Response, error)
- func (client PoolClient) List(ctx context.Context, filter string, selectParameter string, expand string, ...) (result CloudPoolListResultPage, err error)
- func (client PoolClient) ListComplete(ctx context.Context, filter string, selectParameter string, expand string, ...) (result CloudPoolListResultIterator, err error)
- func (client PoolClient) ListPoolUsageMetrics(ctx context.Context, startTime *date.Time, endTime *date.Time, filter string, ...) (result PoolListPoolUsageMetricsResultPage, err error)
- func (client PoolClient) ListPoolUsageMetricsComplete(ctx context.Context, startTime *date.Time, endTime *date.Time, filter string, ...) (result PoolListPoolUsageMetricsResultIterator, err error)
- func (client PoolClient) ListPoolUsageMetricsPreparer(ctx context.Context, startTime *date.Time, endTime *date.Time, filter string, ...) (*http.Request, error)
- func (client PoolClient) ListPoolUsageMetricsResponder(resp *http.Response) (result PoolListPoolUsageMetricsResult, err error)
- func (client PoolClient) ListPoolUsageMetricsSender(req *http.Request) (*http.Response, error)
- func (client PoolClient) ListPreparer(ctx context.Context, filter string, selectParameter string, expand string, ...) (*http.Request, error)
- func (client PoolClient) ListResponder(resp *http.Response) (result CloudPoolListResult, err error)
- func (client PoolClient) ListSender(req *http.Request) (*http.Response, error)
- func (client PoolClient) Patch(ctx context.Context, poolID string, poolPatchParameter PoolPatchParameter, ...) (result autorest.Response, err error)
- func (client PoolClient) PatchPreparer(ctx context.Context, poolID string, poolPatchParameter PoolPatchParameter, ...) (*http.Request, error)
- func (client PoolClient) PatchResponder(resp *http.Response) (result autorest.Response, err error)
- func (client PoolClient) PatchSender(req *http.Request) (*http.Response, error)
- func (client PoolClient) RemoveNodes(ctx context.Context, poolID string, nodeRemoveParameter NodeRemoveParameter, ...) (result autorest.Response, err error)
- func (client PoolClient) RemoveNodesPreparer(ctx context.Context, poolID string, nodeRemoveParameter NodeRemoveParameter, ...) (*http.Request, error)
- func (client PoolClient) RemoveNodesResponder(resp *http.Response) (result autorest.Response, err error)
- func (client PoolClient) RemoveNodesSender(req *http.Request) (*http.Response, error)
- func (client PoolClient) Resize(ctx context.Context, poolID string, poolResizeParameter PoolResizeParameter, ...) (result autorest.Response, err error)
- func (client PoolClient) ResizePreparer(ctx context.Context, poolID string, poolResizeParameter PoolResizeParameter, ...) (*http.Request, error)
- func (client PoolClient) ResizeResponder(resp *http.Response) (result autorest.Response, err error)
- func (client PoolClient) ResizeSender(req *http.Request) (*http.Response, error)
- func (client PoolClient) StopResize(ctx context.Context, poolID string, timeout *int32, clientRequestID string, ...) (result autorest.Response, err error)
- func (client PoolClient) StopResizePreparer(ctx context.Context, poolID string, timeout *int32, clientRequestID string, ...) (*http.Request, error)
- func (client PoolClient) StopResizeResponder(resp *http.Response) (result autorest.Response, err error)
- func (client PoolClient) StopResizeSender(req *http.Request) (*http.Response, error)
- func (client PoolClient) UpdateProperties(ctx context.Context, poolID string, ...) (result autorest.Response, err error)
- func (client PoolClient) UpdatePropertiesPreparer(ctx context.Context, poolID string, ...) (*http.Request, error)
- func (client PoolClient) UpdatePropertiesResponder(resp *http.Response) (result autorest.Response, err error)
- func (client PoolClient) UpdatePropertiesSender(req *http.Request) (*http.Response, error)
- func (client PoolClient) UpgradeOS(ctx context.Context, poolID string, ...) (result autorest.Response, err error)
- func (client PoolClient) UpgradeOSPreparer(ctx context.Context, poolID string, ...) (*http.Request, error)
- func (client PoolClient) UpgradeOSResponder(resp *http.Response) (result autorest.Response, err error)
- func (client PoolClient) UpgradeOSSender(req *http.Request) (*http.Response, error)
- type PoolEnableAutoScaleParameter
- type PoolEvaluateAutoScaleParameter
- type PoolInformation
- type PoolLifetimeOption
- type PoolListPoolUsageMetricsResult
- type PoolListPoolUsageMetricsResultIterator
- type PoolListPoolUsageMetricsResultPage
- type PoolPatchParameter
- type PoolResizeParameter
- type PoolSpecification
- type PoolState
- type PoolStatistics
- type PoolUpdatePropertiesParameter
- type PoolUpgradeOSParameter
- type PoolUsageMetrics
- type ReadCloser
- type RecentJob
- type ResizeError
- type ResourceFile
- type ResourceStatistics
- type Schedule
- type SchedulingErrorCategory
- type SchedulingState
- type StartTask
- type StartTaskInformation
- type StartTaskState
- type SubtaskInformation
- type TaskAddParameter
- type TaskClient
- func (client TaskClient) Add(ctx context.Context, jobID string, task TaskAddParameter, timeout *int32, ...) (result autorest.Response, err error)
- func (client TaskClient) AddPreparer(ctx context.Context, jobID string, task TaskAddParameter, timeout *int32, ...) (*http.Request, error)
- func (client TaskClient) AddResponder(resp *http.Response) (result autorest.Response, err error)
- func (client TaskClient) AddSender(req *http.Request) (*http.Response, error)
- func (client TaskClient) Delete(ctx context.Context, jobID string, taskID string, timeout *int32, ...) (result autorest.Response, err error)
- func (client TaskClient) DeletePreparer(ctx context.Context, jobID string, taskID string, timeout *int32, ...) (*http.Request, error)
- func (client TaskClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client TaskClient) DeleteSender(req *http.Request) (*http.Response, error)
- func (client TaskClient) Get(ctx context.Context, jobID string, taskID string, selectParameter string, ...) (result CloudTask, err error)
- func (client TaskClient) GetPreparer(ctx context.Context, jobID string, taskID string, selectParameter string, ...) (*http.Request, error)
- func (client TaskClient) GetResponder(resp *http.Response) (result CloudTask, err error)
- func (client TaskClient) GetSender(req *http.Request) (*http.Response, error)
- func (client TaskClient) List(ctx context.Context, jobID string, filter string, selectParameter string, ...) (result CloudTaskListResultPage, err error)
- func (client TaskClient) ListComplete(ctx context.Context, jobID string, filter string, selectParameter string, ...) (result CloudTaskListResultIterator, err error)
- func (client TaskClient) ListPreparer(ctx context.Context, jobID string, filter string, selectParameter string, ...) (*http.Request, error)
- func (client TaskClient) ListResponder(resp *http.Response) (result CloudTaskListResult, err error)
- func (client TaskClient) ListSender(req *http.Request) (*http.Response, error)
- func (client TaskClient) ListSubtasks(ctx context.Context, jobID string, taskID string, selectParameter string, ...) (result CloudTaskListSubtasksResult, err error)
- func (client TaskClient) ListSubtasksPreparer(ctx context.Context, jobID string, taskID string, selectParameter string, ...) (*http.Request, error)
- func (client TaskClient) ListSubtasksResponder(resp *http.Response) (result CloudTaskListSubtasksResult, err error)
- func (client TaskClient) ListSubtasksSender(req *http.Request) (*http.Response, error)
- func (client TaskClient) Terminate(ctx context.Context, jobID string, taskID string, timeout *int32, ...) (result autorest.Response, err error)
- func (client TaskClient) TerminatePreparer(ctx context.Context, jobID string, taskID string, timeout *int32, ...) (*http.Request, error)
- func (client TaskClient) TerminateResponder(resp *http.Response) (result autorest.Response, err error)
- func (client TaskClient) TerminateSender(req *http.Request) (*http.Response, error)
- func (client TaskClient) Update(ctx context.Context, jobID string, taskID string, ...) (result autorest.Response, err error)
- func (client TaskClient) UpdatePreparer(ctx context.Context, jobID string, taskID string, ...) (*http.Request, error)
- func (client TaskClient) UpdateResponder(resp *http.Response) (result autorest.Response, err error)
- func (client TaskClient) UpdateSender(req *http.Request) (*http.Response, error)
- type TaskConstraints
- type TaskDependencies
- type TaskExecutionInformation
- type TaskIDRange
- type TaskInformation
- type TaskSchedulingError
- type TaskSchedulingPolicy
- type TaskState
- type TaskStatistics
- type TaskUpdateParameter
- type UsageStatistics
Constants ¶
const (
// DefaultBaseURI is the default URI used for the service Batch
DefaultBaseURI = "https://batch.core.windows.net"
)
Variables ¶
This section is empty.
Functions ¶
func UserAgent ¶
func UserAgent() string
UserAgent returns the UserAgent string to use when sending http.Requests.
func Version ¶
func Version() string
Version returns the semantic version (see http://semver.org) of the client.
Types ¶
type AffinityInformation ¶
type AffinityInformation struct { // AffinityID - Gets or sets an opaque string representing the location of a compute node or a task that has run previously. You can pass the AffinityId of a compute node or task to indicate that this task needs to be placed close to the node or task. AffinityID *string `json:"affinityId,omitempty"` }
AffinityInformation a locality hint that can be used by the Batch service to select a compute node on which to start a task.
type AllocationState ¶
type AllocationState string
AllocationState enumerates the values for allocation state.
const ( // Resizing ... Resizing AllocationState = "resizing" // Steady ... Steady AllocationState = "steady" // Stopping ... Stopping AllocationState = "stopping" )
type ApplicationClient ¶
type ApplicationClient struct {
BaseClient
}
ApplicationClient is the a client for issuing REST requests to the Azure Batch service.
func NewApplicationClient ¶
func NewApplicationClient() ApplicationClient
NewApplicationClient creates an instance of the ApplicationClient client.
func NewApplicationClientWithBaseURI ¶
func NewApplicationClientWithBaseURI(baseURI string) ApplicationClient
NewApplicationClientWithBaseURI creates an instance of the ApplicationClient client.
func (ApplicationClient) Get ¶
func (client ApplicationClient) Get(ctx context.Context, applicationID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result ApplicationSummary, err error)
Get gets information about the specified application.
applicationID is the id of the application. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (ApplicationClient) GetPreparer ¶
func (client ApplicationClient) GetPreparer(ctx context.Context, applicationID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
GetPreparer prepares the Get request.
func (ApplicationClient) GetResponder ¶
func (client ApplicationClient) GetResponder(resp *http.Response) (result ApplicationSummary, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (ApplicationClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (ApplicationClient) List ¶
func (client ApplicationClient) List(ctx context.Context, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result ApplicationListResultPage, err error)
List lists all of the applications available in the specified account.
maxResults is sets the maximum number of items to return in the response. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (ApplicationClient) ListComplete ¶
func (client ApplicationClient) ListComplete(ctx context.Context, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result ApplicationListResultIterator, err error)
ListComplete enumerates all values, automatically crossing page boundaries as required.
func (ApplicationClient) ListPreparer ¶
func (client ApplicationClient) ListPreparer(ctx context.Context, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
ListPreparer prepares the List request.
func (ApplicationClient) ListResponder ¶
func (client ApplicationClient) ListResponder(resp *http.Response) (result ApplicationListResult, err error)
ListResponder handles the response to the List request. The method always closes the http.Response Body.
func (ApplicationClient) ListSender ¶
ListSender sends the List request. The method will close the http.Response Body if it receives an error.
type ApplicationListResult ¶
type ApplicationListResult struct { autorest.Response `json:"-"` // Value - Gets or sets the list of applications available in the account. Value *[]ApplicationSummary `json:"value,omitempty"` // OdataNextLink - Gets or sets the URL to get the next set of results. OdataNextLink *string `json:"odata.nextLink,omitempty"` }
ApplicationListResult response to a ApplicationOperations.List request.
func (ApplicationListResult) IsEmpty ¶
func (alr ApplicationListResult) IsEmpty() bool
IsEmpty returns true if the ListResult contains no values.
type ApplicationListResultIterator ¶
type ApplicationListResultIterator struct {
// contains filtered or unexported fields
}
ApplicationListResultIterator provides access to a complete listing of ApplicationSummary values.
func (*ApplicationListResultIterator) Next ¶
func (iter *ApplicationListResultIterator) Next() error
Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.
func (ApplicationListResultIterator) NotDone ¶
func (iter ApplicationListResultIterator) NotDone() bool
NotDone returns true if the enumeration should be started or is not yet complete.
func (ApplicationListResultIterator) Response ¶
func (iter ApplicationListResultIterator) Response() ApplicationListResult
Response returns the raw server response from the last page request.
func (ApplicationListResultIterator) Value ¶
func (iter ApplicationListResultIterator) Value() ApplicationSummary
Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.
type ApplicationListResultPage ¶
type ApplicationListResultPage struct {
// contains filtered or unexported fields
}
ApplicationListResultPage contains a page of ApplicationSummary values.
func (*ApplicationListResultPage) Next ¶
func (page *ApplicationListResultPage) Next() error
Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.
func (ApplicationListResultPage) NotDone ¶
func (page ApplicationListResultPage) NotDone() bool
NotDone returns true if the page enumeration should be started or is not yet complete.
func (ApplicationListResultPage) Response ¶
func (page ApplicationListResultPage) Response() ApplicationListResult
Response returns the raw server response from the last page request.
func (ApplicationListResultPage) Values ¶
func (page ApplicationListResultPage) Values() []ApplicationSummary
Values returns the slice of values for the current page or nil if there are no values.
type ApplicationPackageReference ¶
type ApplicationPackageReference struct { // ApplicationID - Gets or sets the application package id. ApplicationID *string `json:"applicationId,omitempty"` // Version - Gets or sets the application package version. If not specified, the default is used. Version *string `json:"version,omitempty"` }
ApplicationPackageReference a reference to an application package to be installed on compute nodes in a pool.
type ApplicationSummary ¶
type ApplicationSummary struct { autorest.Response `json:"-"` // ID - Gets or sets a string that uniquely identifies the application within the account. ID *string `json:"id,omitempty"` // DisplayName - Gets or sets the display name for the application. DisplayName *string `json:"displayName,omitempty"` Versions *[]string `json:"versions,omitempty"` }
ApplicationSummary contains information about an application in an Azure Batch account.
type AutoPoolSpecification ¶
type AutoPoolSpecification struct { // AutoPoolIDPrefix - Gets or sets a prefix to be added to the unique identifier when a pool is automatically created. The prefix can be up to 20 characters long. AutoPoolIDPrefix *string `json:"autoPoolIdPrefix,omitempty"` // PoolLifetimeOption - Gets or sets the minimum lifetime of created auto pools, and how multiple jobs on a schedule are assigned to pools. Possible values include: 'PoolLifetimeOptionJobschedule', 'PoolLifetimeOptionJob', 'PoolLifetimeOptionUnmapped' PoolLifetimeOption PoolLifetimeOption `json:"poolLifetimeOption,omitempty"` // KeepAlive - Gets or sets whether to keep an auto pool alive after its lifetime expires. KeepAlive *bool `json:"keepAlive,omitempty"` // Pool - Gets or sets the pool specification for the auto pool. Pool *PoolSpecification `json:"pool,omitempty"` }
AutoPoolSpecification specifies characteristics for a temporary 'auto pool'. The Batch service will create this auto pool, run all the tasks for the job on it, and will delete the pool once the job has completed.
type AutoScaleRun ¶
type AutoScaleRun struct { autorest.Response `json:"-"` // Timestamp - Gets or sets the time at which the autoscale formula was last evaluated. Timestamp *date.Time `json:"timestamp,omitempty"` // Results - Gets or sets the final values of all variables used in the evaluation of the autoscale formula. Each variable value is returned in the form $variable=value, and variables are separated by semicolons. Results *string `json:"results,omitempty"` // Error - Gets or sets details of the error encountered evaluating the autoscale formula on the pool, if the evaluation was unsuccessful. Error *AutoScaleRunError `json:"error,omitempty"` }
AutoScaleRun the results and errors from an execution of a pool autoscale formula.
type AutoScaleRunError ¶
type AutoScaleRunError struct { // Code - Gets or sets an identifier for the autoscale error. Codes are invariant and are intended to be consumed programmatically. Code *string `json:"code,omitempty"` // Message - Gets or sets a message describing the autoscale error, intended to be suitable for display in a user interface. Message *string `json:"message,omitempty"` // Values - Gets or sets a list of additional error details related to the autoscale error. Values *[]NameValuePair `json:"values,omitempty"` }
AutoScaleRunError an error that occurred when executing or evaluating a pool autoscale formula.
type BaseClient ¶
BaseClient is the base client for Batch.
func NewWithBaseURI ¶
func NewWithBaseURI(baseURI string) BaseClient
NewWithBaseURI creates an instance of the BaseClient client.
type Certificate ¶
type Certificate struct { autorest.Response `json:"-"` // Thumbprint - Get or sets the X.509 thumbprint of the certificate. This is a sequence of up to 40 hex digits (it may include spaces but these are removed). Thumbprint *string `json:"thumbprint,omitempty"` // ThumbprintAlgorithm - Gets or sets the algorithm used to derive the thumbprint. This must be sha1. ThumbprintAlgorithm *string `json:"thumbprintAlgorithm,omitempty"` // URL - Gets or sets the URL of the certificate. URL *string `json:"url,omitempty"` // State - Gets or sets the current state of the certificate. Possible values include: 'Active', 'Deleting', 'Deletefailed' State CertificateState `json:"state,omitempty"` // StateTransitionTime - Gets or sets the time at which the certificate entered its current state. StateTransitionTime *date.Time `json:"stateTransitionTime,omitempty"` // PreviousState - Gets or sets the previous state of the certificate. This property is not set if the certificate is in its initial Active state. Possible values include: 'Active', 'Deleting', 'Deletefailed' PreviousState CertificateState `json:"previousState,omitempty"` // PreviousStateTransitionTime - Gets or sets the time at which the certificate entered its previous state. This property is not set if the certificate is in its initial Active state. PreviousStateTransitionTime *date.Time `json:"previousStateTransitionTime,omitempty"` // PublicData - Gets or sets the public part of the certificate as a base-64 encoded .cer file. PublicData *string `json:"publicData,omitempty"` // DeleteCertificateError - Gets or sets the error that occurred on the last attempt to delete this certificate. This property is set only if the certificate is in the deletefailed state. DeleteCertificateError *DeleteCertificateError `json:"deleteCertificateError,omitempty"` }
Certificate a certificate that can be installed on compute nodes and can be used to authenticate operations on the machine.
type CertificateAddParameter ¶
type CertificateAddParameter struct { // Thumbprint - Get or sets the X.509 thumbprint of the certificate. This is a sequence of up to 40 hex digits (it may include spaces but these are removed). Thumbprint *string `json:"thumbprint,omitempty"` // ThumbprintAlgorithm - Gets or sets the algorithm used to derive the thumbprint. This must be sha1. ThumbprintAlgorithm *string `json:"thumbprintAlgorithm,omitempty"` // Data - Gets or sets the base64-encoded contents of the .pfx file containing the certificate. The maximum size is 10KB. This property is not populated by the Get Certificate operation. Data *string `json:"data,omitempty"` // CertificateFormat - Gets or sets the format of the certificate data. This must be pfx. Possible values include: 'Pfx', 'Cer', 'Unmapped' CertificateFormat CertificateFormat `json:"certificateFormat,omitempty"` // Password - Gets or sets the password to access the certificate's private key. This property is not populated by the Get Certificate operation. Password *string `json:"password,omitempty"` }
CertificateAddParameter a certificate that can be installed on compute nodes and can be used to authenticate operations on the machine.
type CertificateClient ¶
type CertificateClient struct {
BaseClient
}
CertificateClient is the a client for issuing REST requests to the Azure Batch service.
func NewCertificateClient ¶
func NewCertificateClient() CertificateClient
NewCertificateClient creates an instance of the CertificateClient client.
func NewCertificateClientWithBaseURI ¶
func NewCertificateClientWithBaseURI(baseURI string) CertificateClient
NewCertificateClientWithBaseURI creates an instance of the CertificateClient client.
func (CertificateClient) Add ¶
func (client CertificateClient) Add(ctx context.Context, certificate CertificateAddParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result autorest.Response, err error)
Add adds a certificate to the specified account.
certificate is specifies the certificate to be added. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (CertificateClient) AddPreparer ¶
func (client CertificateClient) AddPreparer(ctx context.Context, certificate CertificateAddParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
AddPreparer prepares the Add request.
func (CertificateClient) AddResponder ¶
func (client CertificateClient) AddResponder(resp *http.Response) (result autorest.Response, err error)
AddResponder handles the response to the Add request. The method always closes the http.Response Body.
func (CertificateClient) AddSender ¶
AddSender sends the Add request. The method will close the http.Response Body if it receives an error.
func (CertificateClient) CancelDeletion ¶
func (client CertificateClient) CancelDeletion(ctx context.Context, thumbprintAlgorithm string, thumbprint string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result autorest.Response, err error)
CancelDeletion cancels a failed deletion of a certificate from the specified account.
thumbprintAlgorithm is the algorithm used to derive the thumbprint parameter. This must be sha1. thumbprint is the thumbprint of the certificate being deleted. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (CertificateClient) CancelDeletionPreparer ¶
func (client CertificateClient) CancelDeletionPreparer(ctx context.Context, thumbprintAlgorithm string, thumbprint string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
CancelDeletionPreparer prepares the CancelDeletion request.
func (CertificateClient) CancelDeletionResponder ¶
func (client CertificateClient) CancelDeletionResponder(resp *http.Response) (result autorest.Response, err error)
CancelDeletionResponder handles the response to the CancelDeletion request. The method always closes the http.Response Body.
func (CertificateClient) CancelDeletionSender ¶
CancelDeletionSender sends the CancelDeletion request. The method will close the http.Response Body if it receives an error.
func (CertificateClient) Delete ¶
func (client CertificateClient) Delete(ctx context.Context, thumbprintAlgorithm string, thumbprint string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result autorest.Response, err error)
Delete deletes a certificate from the specified account.
thumbprintAlgorithm is the algorithm used to derive the thumbprint parameter. This must be sha1. thumbprint is the thumbprint of the certificate to be deleted. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (CertificateClient) DeletePreparer ¶
func (client CertificateClient) DeletePreparer(ctx context.Context, thumbprintAlgorithm string, thumbprint string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (CertificateClient) DeleteResponder ¶
func (client CertificateClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (CertificateClient) DeleteSender ¶
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (CertificateClient) Get ¶
func (client CertificateClient) Get(ctx context.Context, thumbprintAlgorithm string, thumbprint string, selectParameter string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result Certificate, err error)
Get gets information about the specified certificate.
thumbprintAlgorithm is the algorithm used to derive the thumbprint parameter. This must be sha1. thumbprint is the thumbprint of the certificate to get. selectParameter is sets an OData $select clause. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (CertificateClient) GetPreparer ¶
func (client CertificateClient) GetPreparer(ctx context.Context, thumbprintAlgorithm string, thumbprint string, selectParameter string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
GetPreparer prepares the Get request.
func (CertificateClient) GetResponder ¶
func (client CertificateClient) GetResponder(resp *http.Response) (result Certificate, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (CertificateClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (CertificateClient) List ¶
func (client CertificateClient) List(ctx context.Context, filter string, selectParameter string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result CertificateListResultPage, err error)
List lists all of the certificates that have been added to the specified account.
filter is sets an OData $filter clause. selectParameter is sets an OData $select clause. maxResults is sets the maximum number of items to return in the response. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (CertificateClient) ListComplete ¶
func (client CertificateClient) ListComplete(ctx context.Context, filter string, selectParameter string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result CertificateListResultIterator, err error)
ListComplete enumerates all values, automatically crossing page boundaries as required.
func (CertificateClient) ListPreparer ¶
func (client CertificateClient) ListPreparer(ctx context.Context, filter string, selectParameter string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
ListPreparer prepares the List request.
func (CertificateClient) ListResponder ¶
func (client CertificateClient) ListResponder(resp *http.Response) (result CertificateListResult, err error)
ListResponder handles the response to the List request. The method always closes the http.Response Body.
func (CertificateClient) ListSender ¶
ListSender sends the List request. The method will close the http.Response Body if it receives an error.
type CertificateFormat ¶
type CertificateFormat string
CertificateFormat enumerates the values for certificate format.
const ( // Cer ... Cer CertificateFormat = "cer" // Pfx ... Pfx CertificateFormat = "pfx" // Unmapped ... Unmapped CertificateFormat = "unmapped" )
type CertificateListResult ¶
type CertificateListResult struct { autorest.Response `json:"-"` // Value - Gets or sets the list of certificates. Value *[]Certificate `json:"value,omitempty"` // OdataNextLink - Gets or sets the URL to get the next set of results. OdataNextLink *string `json:"odata.nextLink,omitempty"` }
CertificateListResult response to a CertificateOperations.List request.
func (CertificateListResult) IsEmpty ¶
func (clr CertificateListResult) IsEmpty() bool
IsEmpty returns true if the ListResult contains no values.
type CertificateListResultIterator ¶
type CertificateListResultIterator struct {
// contains filtered or unexported fields
}
CertificateListResultIterator provides access to a complete listing of Certificate values.
func (*CertificateListResultIterator) Next ¶
func (iter *CertificateListResultIterator) Next() error
Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.
func (CertificateListResultIterator) NotDone ¶
func (iter CertificateListResultIterator) NotDone() bool
NotDone returns true if the enumeration should be started or is not yet complete.
func (CertificateListResultIterator) Response ¶
func (iter CertificateListResultIterator) Response() CertificateListResult
Response returns the raw server response from the last page request.
func (CertificateListResultIterator) Value ¶
func (iter CertificateListResultIterator) Value() Certificate
Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.
type CertificateListResultPage ¶
type CertificateListResultPage struct {
// contains filtered or unexported fields
}
CertificateListResultPage contains a page of Certificate values.
func (*CertificateListResultPage) Next ¶
func (page *CertificateListResultPage) Next() error
Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.
func (CertificateListResultPage) NotDone ¶
func (page CertificateListResultPage) NotDone() bool
NotDone returns true if the page enumeration should be started or is not yet complete.
func (CertificateListResultPage) Response ¶
func (page CertificateListResultPage) Response() CertificateListResult
Response returns the raw server response from the last page request.
func (CertificateListResultPage) Values ¶
func (page CertificateListResultPage) Values() []Certificate
Values returns the slice of values for the current page or nil if there are no values.
type CertificateReference ¶
type CertificateReference struct { // Thumbprint - Gets or sets the thumbprint of the certificate. Thumbprint *string `json:"thumbprint,omitempty"` // ThumbprintAlgorithm - Gets or sets the algorithm with which the thumbprint is associated. This must be sha1. ThumbprintAlgorithm *string `json:"thumbprintAlgorithm,omitempty"` // StoreLocation - Gets or sets the location of the certificate store on the compute node into which to install the certificate. The default value is CurrentUser. Possible values include: 'CertificateStoreLocationCurrentuser', 'CertificateStoreLocationLocalmachine', 'CertificateStoreLocationUnmapped' StoreLocation CertificateStoreLocation `json:"storeLocation,omitempty"` // StoreName - Gets or sets the name of the certificate store on the compute node into which to install the certificate. The default value is My. StoreName *string `json:"storeName,omitempty"` // Visibility - Gets or sets which user accounts on the compute node should have access to the private data of the certificate. This may be any subset of the values 'starttask', 'task' and 'rdp', separated by commas. The default is all accounts, corresponding to the string 'starttask,task,rdp'. Visibility *string `json:"visibility,omitempty"` }
CertificateReference a reference to a certificate to be installed on compute nodes in a pool.
type CertificateState ¶
type CertificateState string
CertificateState enumerates the values for certificate state.
const ( // Active ... Active CertificateState = "active" // Deletefailed ... Deletefailed CertificateState = "deletefailed" // Deleting ... Deleting CertificateState = "deleting" )
type CertificateStoreLocation ¶
type CertificateStoreLocation string
CertificateStoreLocation enumerates the values for certificate store location.
const ( // CertificateStoreLocationCurrentuser ... CertificateStoreLocationCurrentuser CertificateStoreLocation = "currentuser" // CertificateStoreLocationLocalmachine ... CertificateStoreLocationLocalmachine CertificateStoreLocation = "localmachine" // CertificateStoreLocationUnmapped ... CertificateStoreLocationUnmapped CertificateStoreLocation = "unmapped" )
type CloudJob ¶
type CloudJob struct { autorest.Response `json:"-"` // ID - Gets or sets a string that uniquely identifies the job within the account. The id can contain any combination of alphanumeric characters including hyphens and underscores, and cannot contain more than 64 characters. It is common to use a GUID for the id. ID *string `json:"id,omitempty"` // DisplayName - Gets or sets the display name for the job. DisplayName *string `json:"displayName,omitempty"` // UsesTaskDependencies - Gets or sets the flag that determines if this job will use tasks with dependencies. UsesTaskDependencies *bool `json:"usesTaskDependencies,omitempty"` // URL - Gets or sets the URL of the job. URL *string `json:"url,omitempty"` // ETag - Gets or sets the ETag of the job. ETag *string `json:"eTag,omitempty"` // LastModified - Gets or sets the last modified time of the job. LastModified *date.Time `json:"lastModified,omitempty"` // CreationTime - Gets or sets the creation time of the job. CreationTime *date.Time `json:"creationTime,omitempty"` // State - Gets or sets the current state of the job. Possible values include: 'JobStateActive', 'JobStateDisabling', 'JobStateDisabled', 'JobStateEnabling', 'JobStateTerminating', 'JobStateCompleted', 'JobStateDeleting' State JobState `json:"state,omitempty"` // StateTransitionTime - Gets or sets the time at which the job entered its current state. StateTransitionTime *date.Time `json:"stateTransitionTime,omitempty"` // PreviousState - Gets or sets the previous state of the job. This property is not set if the job is in its initial Active state. Possible values include: 'JobStateActive', 'JobStateDisabling', 'JobStateDisabled', 'JobStateEnabling', 'JobStateTerminating', 'JobStateCompleted', 'JobStateDeleting' PreviousState JobState `json:"previousState,omitempty"` // PreviousStateTransitionTime - Gets or sets the time at which the job entered its previous state. This property is not set if the job is in its initial Active state. PreviousStateTransitionTime *date.Time `json:"previousStateTransitionTime,omitempty"` // Priority - Gets or sets the priority of the job. Priority values can range from -1000 to 1000, with -1000 being the lowest priority and 1000 being the highest priority. The default value is 0. Priority *int32 `json:"priority,omitempty"` // Constraints - Gets or sets the execution constraints for the job. Constraints *JobConstraints `json:"constraints,omitempty"` // JobManagerTask - Gets or sets details of a Job Manager task to be launched when the job is started. JobManagerTask *JobManagerTask `json:"jobManagerTask,omitempty"` // JobPreparationTask - Gets or sets the Job Preparation task. JobPreparationTask *JobPreparationTask `json:"jobPreparationTask,omitempty"` // JobReleaseTask - Gets or sets the Job Release task. JobReleaseTask *JobReleaseTask `json:"jobReleaseTask,omitempty"` // CommonEnvironmentSettings - Gets or sets the list of common environment variable settings. These environment variables are set for all tasks in the job (including the Job Manager, Job Preparation and Job Release tasks). CommonEnvironmentSettings *[]EnvironmentSetting `json:"commonEnvironmentSettings,omitempty"` // PoolInfo - Gets or sets the pool on which the Batch service runs the job’s tasks. PoolInfo *PoolInformation `json:"poolInfo,omitempty"` // Metadata - Gets or sets a list of name-value pairs associated with the job as metadata. Metadata *[]MetadataItem `json:"metadata,omitempty"` // ExecutionInfo - Gets or sets the execution information for the job. ExecutionInfo *JobExecutionInformation `json:"executionInfo,omitempty"` // Stats - Gets or sets resource usage statistics for the entire lifetime of the job. Stats *JobStatistics `json:"stats,omitempty"` }
CloudJob an Azure Batch job.
type CloudJobListPreparationAndReleaseTaskStatusResult ¶
type CloudJobListPreparationAndReleaseTaskStatusResult struct { autorest.Response `json:"-"` // Value - Gets or sets a list of Job Preparation and Job Release task execution information. Value *[]JobPreparationAndReleaseTaskExecutionInformation `json:"value,omitempty"` // OdataNextLink - Gets or sets the URL to get the next set of results. OdataNextLink *string `json:"odata.nextLink,omitempty"` }
CloudJobListPreparationAndReleaseTaskStatusResult response to a CloudJobOperations.ListPreparationAndReleaseTaskStatus request.
func (CloudJobListPreparationAndReleaseTaskStatusResult) IsEmpty ¶
func (cjlpartsr CloudJobListPreparationAndReleaseTaskStatusResult) IsEmpty() bool
IsEmpty returns true if the ListResult contains no values.
type CloudJobListPreparationAndReleaseTaskStatusResultIterator ¶
type CloudJobListPreparationAndReleaseTaskStatusResultIterator struct {
// contains filtered or unexported fields
}
CloudJobListPreparationAndReleaseTaskStatusResultIterator provides access to a complete listing of JobPreparationAndReleaseTaskExecutionInformation values.
func (*CloudJobListPreparationAndReleaseTaskStatusResultIterator) Next ¶
func (iter *CloudJobListPreparationAndReleaseTaskStatusResultIterator) Next() error
Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.
func (CloudJobListPreparationAndReleaseTaskStatusResultIterator) NotDone ¶
func (iter CloudJobListPreparationAndReleaseTaskStatusResultIterator) NotDone() bool
NotDone returns true if the enumeration should be started or is not yet complete.
func (CloudJobListPreparationAndReleaseTaskStatusResultIterator) Response ¶
func (iter CloudJobListPreparationAndReleaseTaskStatusResultIterator) Response() CloudJobListPreparationAndReleaseTaskStatusResult
Response returns the raw server response from the last page request.
func (CloudJobListPreparationAndReleaseTaskStatusResultIterator) Value ¶
func (iter CloudJobListPreparationAndReleaseTaskStatusResultIterator) Value() JobPreparationAndReleaseTaskExecutionInformation
Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.
type CloudJobListPreparationAndReleaseTaskStatusResultPage ¶
type CloudJobListPreparationAndReleaseTaskStatusResultPage struct {
// contains filtered or unexported fields
}
CloudJobListPreparationAndReleaseTaskStatusResultPage contains a page of JobPreparationAndReleaseTaskExecutionInformation values.
func (*CloudJobListPreparationAndReleaseTaskStatusResultPage) Next ¶
func (page *CloudJobListPreparationAndReleaseTaskStatusResultPage) Next() error
Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.
func (CloudJobListPreparationAndReleaseTaskStatusResultPage) NotDone ¶
func (page CloudJobListPreparationAndReleaseTaskStatusResultPage) NotDone() bool
NotDone returns true if the page enumeration should be started or is not yet complete.
func (CloudJobListPreparationAndReleaseTaskStatusResultPage) Response ¶
func (page CloudJobListPreparationAndReleaseTaskStatusResultPage) Response() CloudJobListPreparationAndReleaseTaskStatusResult
Response returns the raw server response from the last page request.
func (CloudJobListPreparationAndReleaseTaskStatusResultPage) Values ¶
func (page CloudJobListPreparationAndReleaseTaskStatusResultPage) Values() []JobPreparationAndReleaseTaskExecutionInformation
Values returns the slice of values for the current page or nil if there are no values.
type CloudJobListResult ¶
type CloudJobListResult struct { autorest.Response `json:"-"` // Value - Gets or sets the list of jobs. Value *[]CloudJob `json:"value,omitempty"` // OdataNextLink - Gets or sets the URL to get the next set of results. OdataNextLink *string `json:"odata.nextLink,omitempty"` }
CloudJobListResult response to a CloudJobOperations.List or ListFromJobSchedule request.
func (CloudJobListResult) IsEmpty ¶
func (cjlr CloudJobListResult) IsEmpty() bool
IsEmpty returns true if the ListResult contains no values.
type CloudJobListResultIterator ¶
type CloudJobListResultIterator struct {
// contains filtered or unexported fields
}
CloudJobListResultIterator provides access to a complete listing of CloudJob values.
func (*CloudJobListResultIterator) Next ¶
func (iter *CloudJobListResultIterator) Next() error
Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.
func (CloudJobListResultIterator) NotDone ¶
func (iter CloudJobListResultIterator) NotDone() bool
NotDone returns true if the enumeration should be started or is not yet complete.
func (CloudJobListResultIterator) Response ¶
func (iter CloudJobListResultIterator) Response() CloudJobListResult
Response returns the raw server response from the last page request.
func (CloudJobListResultIterator) Value ¶
func (iter CloudJobListResultIterator) Value() CloudJob
Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.
type CloudJobListResultPage ¶
type CloudJobListResultPage struct {
// contains filtered or unexported fields
}
CloudJobListResultPage contains a page of CloudJob values.
func (*CloudJobListResultPage) Next ¶
func (page *CloudJobListResultPage) Next() error
Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.
func (CloudJobListResultPage) NotDone ¶
func (page CloudJobListResultPage) NotDone() bool
NotDone returns true if the page enumeration should be started or is not yet complete.
func (CloudJobListResultPage) Response ¶
func (page CloudJobListResultPage) Response() CloudJobListResult
Response returns the raw server response from the last page request.
func (CloudJobListResultPage) Values ¶
func (page CloudJobListResultPage) Values() []CloudJob
Values returns the slice of values for the current page or nil if there are no values.
type CloudJobSchedule ¶
type CloudJobSchedule struct { autorest.Response `json:"-"` // ID - Gets or sets a string that uniquely identifies the schedule within the account. A GUID is recommended. ID *string `json:"id,omitempty"` // DisplayName - Gets or sets the display name for the schedule. DisplayName *string `json:"displayName,omitempty"` // URL - Gets or sets the URL of the job schedule. URL *string `json:"url,omitempty"` // ETag - Gets or sets the ETag of the job schedule. ETag *string `json:"eTag,omitempty"` // LastModified - Gets or sets the last modified time of the job schedule. LastModified *date.Time `json:"lastModified,omitempty"` // CreationTime - Gets or sets the creation time of the job schedule. CreationTime *date.Time `json:"creationTime,omitempty"` // State - Gets or sets the current state of the job schedule. Possible values include: 'JobScheduleStateActive', 'JobScheduleStateCompleted', 'JobScheduleStateDisabled', 'JobScheduleStateTerminating', 'JobScheduleStateDeleting' State JobScheduleState `json:"state,omitempty"` // StateTransitionTime - Gets or sets the time at which the job schedule entered the current state. StateTransitionTime *date.Time `json:"stateTransitionTime,omitempty"` // PreviousState - Gets or sets the previous state of the job schedule. Possible values include: 'JobScheduleStateActive', 'JobScheduleStateCompleted', 'JobScheduleStateDisabled', 'JobScheduleStateTerminating', 'JobScheduleStateDeleting' PreviousState JobScheduleState `json:"previousState,omitempty"` // PreviousStateTransitionTime - Gets or sets the time at which the job schedule entered its previous state. PreviousStateTransitionTime *date.Time `json:"previousStateTransitionTime,omitempty"` // Schedule - Gets or sets the schedule according to which jobs will be created. Schedule *Schedule `json:"schedule,omitempty"` // JobSpecification - Gets or sets the details of the jobs to be created on this schedule. JobSpecification *JobSpecification `json:"jobSpecification,omitempty"` // ExecutionInfo - Gets or sets information about jobs that have been and will be run under this schedule. ExecutionInfo *JobScheduleExecutionInformation `json:"executionInfo,omitempty"` // Metadata - Gets or sets a list of name-value pairs associated with the schedule as metadata. Metadata *[]MetadataItem `json:"metadata,omitempty"` // Stats - Gets or sets the lifetime resource usage statistics for the job schedule. Stats *JobScheduleStatistics `json:"stats,omitempty"` }
CloudJobSchedule a job schedule that allows recurring jobs by specifying when to run jobs and a specification used to create each job.
type CloudJobScheduleListResult ¶
type CloudJobScheduleListResult struct { autorest.Response `json:"-"` // Value - Gets or sets the list of job schedules. Value *[]CloudJobSchedule `json:"value,omitempty"` // OdataNextLink - Gets or sets the URL to get the next set of results. OdataNextLink *string `json:"odata.nextLink,omitempty"` }
CloudJobScheduleListResult response to a CloudJobScheduleOperations.List request.
func (CloudJobScheduleListResult) IsEmpty ¶
func (cjslr CloudJobScheduleListResult) IsEmpty() bool
IsEmpty returns true if the ListResult contains no values.
type CloudJobScheduleListResultIterator ¶
type CloudJobScheduleListResultIterator struct {
// contains filtered or unexported fields
}
CloudJobScheduleListResultIterator provides access to a complete listing of CloudJobSchedule values.
func (*CloudJobScheduleListResultIterator) Next ¶
func (iter *CloudJobScheduleListResultIterator) Next() error
Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.
func (CloudJobScheduleListResultIterator) NotDone ¶
func (iter CloudJobScheduleListResultIterator) NotDone() bool
NotDone returns true if the enumeration should be started or is not yet complete.
func (CloudJobScheduleListResultIterator) Response ¶
func (iter CloudJobScheduleListResultIterator) Response() CloudJobScheduleListResult
Response returns the raw server response from the last page request.
func (CloudJobScheduleListResultIterator) Value ¶
func (iter CloudJobScheduleListResultIterator) Value() CloudJobSchedule
Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.
type CloudJobScheduleListResultPage ¶
type CloudJobScheduleListResultPage struct {
// contains filtered or unexported fields
}
CloudJobScheduleListResultPage contains a page of CloudJobSchedule values.
func (*CloudJobScheduleListResultPage) Next ¶
func (page *CloudJobScheduleListResultPage) Next() error
Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.
func (CloudJobScheduleListResultPage) NotDone ¶
func (page CloudJobScheduleListResultPage) NotDone() bool
NotDone returns true if the page enumeration should be started or is not yet complete.
func (CloudJobScheduleListResultPage) Response ¶
func (page CloudJobScheduleListResultPage) Response() CloudJobScheduleListResult
Response returns the raw server response from the last page request.
func (CloudJobScheduleListResultPage) Values ¶
func (page CloudJobScheduleListResultPage) Values() []CloudJobSchedule
Values returns the slice of values for the current page or nil if there are no values.
type CloudPool ¶
type CloudPool struct { autorest.Response `json:"-"` // ID - Gets or sets a string that uniquely identifies the pool within the account. The id can contain any combination of alphanumeric characters including hyphens and underscores, and cannot contain more than 64 characters. ID *string `json:"id,omitempty"` // DisplayName - Gets or sets the display name for the pool. DisplayName *string `json:"displayName,omitempty"` // URL - Gets or sets the URL of the pool. URL *string `json:"url,omitempty"` // ETag - Gets or sets the ETag of the pool. ETag *string `json:"eTag,omitempty"` // LastModified - Gets or sets the last modified time of the pool. LastModified *date.Time `json:"lastModified,omitempty"` // CreationTime - Gets or sets the creation time of the pool. CreationTime *date.Time `json:"creationTime,omitempty"` // State - Gets or sets the current state of the pool. Possible values include: 'PoolStateActive', 'PoolStateDeleting', 'PoolStateUpgrading' State PoolState `json:"state,omitempty"` // StateTransitionTime - Gets or sets the time at which the pool entered its current state. StateTransitionTime *date.Time `json:"stateTransitionTime,omitempty"` // AllocationState - Gets or sets whether the pool is resizing. Possible values include: 'Steady', 'Resizing', 'Stopping' AllocationState AllocationState `json:"allocationState,omitempty"` // AllocationStateTransitionTime - Gets or sets the time at which the pool entered its current allocation state. AllocationStateTransitionTime *date.Time `json:"allocationStateTransitionTime,omitempty"` // VMSize - Gets or sets the size of virtual machines in the pool. All VMs in a pool are the same size. VMSize *string `json:"vmSize,omitempty"` // OsFamily - Gets or sets the Azure Guest OS family to be installed on the virtual machines in the pool. OsFamily *string `json:"osFamily,omitempty"` // TargetOSVersion - Gets or sets the Azure Guest OS version to be installed on the virtual machines in the pool. The default value is * which specifies the latest operating system version for the specified family. TargetOSVersion *string `json:"targetOSVersion,omitempty"` // CurrentOSVersion - Gets or sets the Azure Guest OS Version currently installed on the virtual machines in the pool. This may differ from TargetOSVersion if the pool state is Upgrading. CurrentOSVersion *string `json:"currentOSVersion,omitempty"` // ResizeTimeout - Gets or sets the timeout for allocation of compute nodes to the pool. In a Get Pool operation, this is the timeout for the most recent resize operation. The default value is 10 minutes. ResizeTimeout *string `json:"resizeTimeout,omitempty"` // ResizeError - Gets or sets details of any error encountered while performing the last resize on the pool. This property is set only if an error occurred during the last pool resize, and only when the pool AllocationState is Steady. ResizeError *ResizeError `json:"resizeError,omitempty"` // CurrentDedicated - Gets or sets the number of compute nodes currently in the pool. CurrentDedicated *int32 `json:"currentDedicated,omitempty"` // TargetDedicated - Gets or sets the desired number of compute nodes in the pool. This property must have the default value if EnableAutoScale is true. It is required if EnableAutoScale is false. TargetDedicated *int32 `json:"targetDedicated,omitempty"` // EnableAutoScale - Gets or sets whether the pool size should automatically adjust over time. If true, the AutoScaleFormula property must be set. If false, the TargetDedicated property must be set. EnableAutoScale *bool `json:"enableAutoScale,omitempty"` // AutoScaleFormula - Gets or sets a formula for the desired number of compute nodes in the pool. AutoScaleFormula *string `json:"autoScaleFormula,omitempty"` // AutoScaleEvaluationInterval - Gets or sets a time interval for the desired AutoScale evaluation period in the pool. AutoScaleEvaluationInterval *string `json:"autoScaleEvaluationInterval,omitempty"` // AutoScaleRun - Gets or sets the results and errors from the last execution of the autoscale formula. AutoScaleRun *AutoScaleRun `json:"autoScaleRun,omitempty"` // EnableInterNodeCommunication - Gets or sets whether the pool permits direct communication between nodes. EnableInterNodeCommunication *bool `json:"enableInterNodeCommunication,omitempty"` // StartTask - Gets or sets a task specified to run on each compute node as it joins the pool. StartTask *StartTask `json:"startTask,omitempty"` // CertificateReferences - Gets or sets the list of certificates to be installed on each compute node in the pool. CertificateReferences *[]CertificateReference `json:"certificateReferences,omitempty"` // ApplicationPackageReferences - Gets or sets the list of application packages to be installed on each compute node in the pool. ApplicationPackageReferences *[]ApplicationPackageReference `json:"applicationPackageReferences,omitempty"` // MaxTasksPerNode - Gets or sets the maximum number of tasks that can run concurrently on a single compute node in the pool. MaxTasksPerNode *int32 `json:"maxTasksPerNode,omitempty"` // TaskSchedulingPolicy - Gets or sets how the Batch service distributes tasks between compute nodes in the pool. TaskSchedulingPolicy *TaskSchedulingPolicy `json:"taskSchedulingPolicy,omitempty"` // Metadata - Gets or sets a list of name-value pairs associated with the pool as metadata. Metadata *[]MetadataItem `json:"metadata,omitempty"` // Stats - Gets or sets utilization and resource usage statistics for the entire lifetime of the pool. Stats *PoolStatistics `json:"stats,omitempty"` }
CloudPool a pool in the Azure Batch service.
type CloudPoolListResult ¶
type CloudPoolListResult struct { autorest.Response `json:"-"` // Value - Gets or sets the list of pools. Value *[]CloudPool `json:"value,omitempty"` // OdataNextLink - Gets or sets the URL to get the next set of results. OdataNextLink *string `json:"odata.nextLink,omitempty"` }
CloudPoolListResult response to a CloudPoolOperations.List request.
func (CloudPoolListResult) IsEmpty ¶
func (cplr CloudPoolListResult) IsEmpty() bool
IsEmpty returns true if the ListResult contains no values.
type CloudPoolListResultIterator ¶
type CloudPoolListResultIterator struct {
// contains filtered or unexported fields
}
CloudPoolListResultIterator provides access to a complete listing of CloudPool values.
func (*CloudPoolListResultIterator) Next ¶
func (iter *CloudPoolListResultIterator) Next() error
Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.
func (CloudPoolListResultIterator) NotDone ¶
func (iter CloudPoolListResultIterator) NotDone() bool
NotDone returns true if the enumeration should be started or is not yet complete.
func (CloudPoolListResultIterator) Response ¶
func (iter CloudPoolListResultIterator) Response() CloudPoolListResult
Response returns the raw server response from the last page request.
func (CloudPoolListResultIterator) Value ¶
func (iter CloudPoolListResultIterator) Value() CloudPool
Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.
type CloudPoolListResultPage ¶
type CloudPoolListResultPage struct {
// contains filtered or unexported fields
}
CloudPoolListResultPage contains a page of CloudPool values.
func (*CloudPoolListResultPage) Next ¶
func (page *CloudPoolListResultPage) Next() error
Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.
func (CloudPoolListResultPage) NotDone ¶
func (page CloudPoolListResultPage) NotDone() bool
NotDone returns true if the page enumeration should be started or is not yet complete.
func (CloudPoolListResultPage) Response ¶
func (page CloudPoolListResultPage) Response() CloudPoolListResult
Response returns the raw server response from the last page request.
func (CloudPoolListResultPage) Values ¶
func (page CloudPoolListResultPage) Values() []CloudPool
Values returns the slice of values for the current page or nil if there are no values.
type CloudTask ¶
type CloudTask struct { autorest.Response `json:"-"` // ID - Gets or sets a string that uniquely identifies the task within the job. The id can contain any combination of alphanumeric characters including hyphens and underscores, and cannot contain more than 64 characters. ID *string `json:"id,omitempty"` // DisplayName - Gets or sets a display name for the task. DisplayName *string `json:"displayName,omitempty"` // URL - Gets or sets the URL of the task. URL *string `json:"url,omitempty"` // ETag - Gets or sets the ETag of the task. ETag *string `json:"eTag,omitempty"` // LastModified - Gets or sets the last modified time of the task. LastModified *date.Time `json:"lastModified,omitempty"` // CreationTime - Gets or sets the creation time of the task. CreationTime *date.Time `json:"creationTime,omitempty"` // State - Gets or sets the current state of the task. Possible values include: 'TaskStateActive', 'TaskStatePreparing', 'TaskStateRunning', 'TaskStateCompleted' State TaskState `json:"state,omitempty"` // StateTransitionTime - Gets or sets the time at which the task entered its current state. StateTransitionTime *date.Time `json:"stateTransitionTime,omitempty"` // PreviousState - Gets or sets the previous state of the task. This property is not set if the task is in its initial Active state. Possible values include: 'TaskStateActive', 'TaskStatePreparing', 'TaskStateRunning', 'TaskStateCompleted' PreviousState TaskState `json:"previousState,omitempty"` // PreviousStateTransitionTime - Gets or sets the time at which the task entered its previous state. This property is not set if the task is in its initial Active state. PreviousStateTransitionTime *date.Time `json:"previousStateTransitionTime,omitempty"` // CommandLine - Gets or sets the command line of the task. For multi-instance tasks, the command line is executed on the primary subtask after all the subtasks have finished executing the coordianation command line. CommandLine *string `json:"commandLine,omitempty"` // ResourceFiles - Gets or sets a list of files that Batch will download to the compute node before running the command line. For multi-instance tasks, the resource files will only be downloaded to the compute node on which the primary subtask is executed. ResourceFiles *[]ResourceFile `json:"resourceFiles,omitempty"` // EnvironmentSettings - Gets or sets a list of environment variable settings for the task. EnvironmentSettings *[]EnvironmentSetting `json:"environmentSettings,omitempty"` // AffinityInfo - Gets or sets a locality hint that can be used by the Batch service to select a compute node on which to start the new task. AffinityInfo *AffinityInformation `json:"affinityInfo,omitempty"` // Constraints - Gets or sets the execution constraints that apply to this task. Constraints *TaskConstraints `json:"constraints,omitempty"` // RunElevated - Gets or sets whether to run the task in elevated mode. RunElevated *bool `json:"runElevated,omitempty"` // ExecutionInfo - Gets or sets information about the execution of the task. ExecutionInfo *TaskExecutionInformation `json:"executionInfo,omitempty"` // NodeInfo - Gets or sets information about the compute node on which the task ran. NodeInfo *ComputeNodeInformation `json:"nodeInfo,omitempty"` // MultiInstanceSettings - Gets or sets information about how to run the multi-instance task. MultiInstanceSettings *MultiInstanceSettings `json:"multiInstanceSettings,omitempty"` // Stats - Gets or sets resource usage statistics for the task. Stats *TaskStatistics `json:"stats,omitempty"` // DependsOn - Gets or sets any dependencies this task has. DependsOn *TaskDependencies `json:"dependsOn,omitempty"` }
CloudTask an Azure Batch task.
type CloudTaskListResult ¶
type CloudTaskListResult struct { autorest.Response `json:"-"` // Value - Gets or sets the list of tasks. Value *[]CloudTask `json:"value,omitempty"` // OdataNextLink - Gets or sets the URL to get the next set of results. OdataNextLink *string `json:"odata.nextLink,omitempty"` }
CloudTaskListResult response to a CloudTaskOperations.List request.
func (CloudTaskListResult) IsEmpty ¶
func (ctlr CloudTaskListResult) IsEmpty() bool
IsEmpty returns true if the ListResult contains no values.
type CloudTaskListResultIterator ¶
type CloudTaskListResultIterator struct {
// contains filtered or unexported fields
}
CloudTaskListResultIterator provides access to a complete listing of CloudTask values.
func (*CloudTaskListResultIterator) Next ¶
func (iter *CloudTaskListResultIterator) Next() error
Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.
func (CloudTaskListResultIterator) NotDone ¶
func (iter CloudTaskListResultIterator) NotDone() bool
NotDone returns true if the enumeration should be started or is not yet complete.
func (CloudTaskListResultIterator) Response ¶
func (iter CloudTaskListResultIterator) Response() CloudTaskListResult
Response returns the raw server response from the last page request.
func (CloudTaskListResultIterator) Value ¶
func (iter CloudTaskListResultIterator) Value() CloudTask
Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.
type CloudTaskListResultPage ¶
type CloudTaskListResultPage struct {
// contains filtered or unexported fields
}
CloudTaskListResultPage contains a page of CloudTask values.
func (*CloudTaskListResultPage) Next ¶
func (page *CloudTaskListResultPage) Next() error
Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.
func (CloudTaskListResultPage) NotDone ¶
func (page CloudTaskListResultPage) NotDone() bool
NotDone returns true if the page enumeration should be started or is not yet complete.
func (CloudTaskListResultPage) Response ¶
func (page CloudTaskListResultPage) Response() CloudTaskListResult
Response returns the raw server response from the last page request.
func (CloudTaskListResultPage) Values ¶
func (page CloudTaskListResultPage) Values() []CloudTask
Values returns the slice of values for the current page or nil if there are no values.
type CloudTaskListSubtasksResult ¶
type CloudTaskListSubtasksResult struct { autorest.Response `json:"-"` // Value - Gets or sets the list of information of subtasks. Value *[]SubtaskInformation `json:"value,omitempty"` }
CloudTaskListSubtasksResult response to a CloudTaskOperations.ListSubtasks request.
type ComputeNode ¶
type ComputeNode struct { autorest.Response `json:"-"` // ID - Gets or sets the id of the compute node. ID *string `json:"id,omitempty"` // URL - Gets or sets the URL of the compute node. URL *string `json:"url,omitempty"` // State - Gets or sets the current state of the compute node. Possible values include: 'Idle', 'Rebooting', 'Reimaging', 'Running', 'Unusable', 'Creating', 'Starting', 'Waitingforstarttask', 'Starttaskfailed', 'Unknown', 'Leavingpool', 'Offline' State ComputeNodeState `json:"state,omitempty"` // SchedulingState - Gets or sets whether the compute node should be available for task scheduling. Possible values include: 'Enabled', 'Disabled' SchedulingState SchedulingState `json:"schedulingState,omitempty"` // StateTransitionTime - Gets or sets the time at which the compute node entered its current state. StateTransitionTime *date.Time `json:"stateTransitionTime,omitempty"` // LastBootTime - Gets or sets the time at which the compute node was started. LastBootTime *date.Time `json:"lastBootTime,omitempty"` // AllocationTime - Gets or sets the time at which this compute node was allocated to the pool. AllocationTime *date.Time `json:"allocationTime,omitempty"` // IPAddress - Gets or sets the IP address that other compute nodes can use to communicate with this compute node. IPAddress *string `json:"ipAddress,omitempty"` // AffinityID - Gets or sets an identifier which can be passed in the Add Task API to request that the task be scheduled close to this compute node. AffinityID *string `json:"affinityId,omitempty"` // VMSize - Gets or sets the size of the virtual machine hosting the compute node. VMSize *string `json:"vmSize,omitempty"` // TotalTasksRun - Gets or sets the total number of job tasks completed on the compute node. This includes Job Preparation, Job Release and Job Manager tasks, but not the pool start task. TotalTasksRun *int32 `json:"totalTasksRun,omitempty"` // RecentTasks - Gets or sets the list of tasks that are currently running on the compute node. RecentTasks *[]TaskInformation `json:"recentTasks,omitempty"` // StartTask - Gets or sets the task specified to run on the compute node as it joins the pool. StartTask *StartTask `json:"startTask,omitempty"` // StartTaskInfo - Gets or sets runtime information about the execution of the start task on the compute node. StartTaskInfo *StartTaskInformation `json:"startTaskInfo,omitempty"` // CertificateReferences - Gets or sets the list of certificates installed on the compute node. CertificateReferences *[]CertificateReference `json:"certificateReferences,omitempty"` // Errors - Gets or sets the list of errors that are currently being encountered by the compute node. Errors *[]ComputeNodeError `json:"errors,omitempty"` }
ComputeNode a compute node in the Batch service.
type ComputeNodeClient ¶
type ComputeNodeClient struct {
BaseClient
}
ComputeNodeClient is the a client for issuing REST requests to the Azure Batch service.
func NewComputeNodeClient ¶
func NewComputeNodeClient() ComputeNodeClient
NewComputeNodeClient creates an instance of the ComputeNodeClient client.
func NewComputeNodeClientWithBaseURI ¶
func NewComputeNodeClientWithBaseURI(baseURI string) ComputeNodeClient
NewComputeNodeClientWithBaseURI creates an instance of the ComputeNodeClient client.
func (ComputeNodeClient) AddUser ¶
func (client ComputeNodeClient) AddUser(ctx context.Context, poolID string, nodeID string, userParameter ComputeNodeUser, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result autorest.Response, err error)
AddUser adds a user account to the specified compute node.
poolID is the id of the pool that contains the compute node. nodeID is the id of the machine on which you want to create a user account. userParameter is specifies the user account to be created. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (ComputeNodeClient) AddUserPreparer ¶
func (client ComputeNodeClient) AddUserPreparer(ctx context.Context, poolID string, nodeID string, userParameter ComputeNodeUser, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
AddUserPreparer prepares the AddUser request.
func (ComputeNodeClient) AddUserResponder ¶
func (client ComputeNodeClient) AddUserResponder(resp *http.Response) (result autorest.Response, err error)
AddUserResponder handles the response to the AddUser request. The method always closes the http.Response Body.
func (ComputeNodeClient) AddUserSender ¶
AddUserSender sends the AddUser request. The method will close the http.Response Body if it receives an error.
func (ComputeNodeClient) DeleteUser ¶
func (client ComputeNodeClient) DeleteUser(ctx context.Context, poolID string, nodeID string, userName string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result autorest.Response, err error)
DeleteUser deletes a user account from the specified compute node.
poolID is the id of the pool that contains the compute node. nodeID is the id of the machine on which you want to delete a user account. userName is the name of the user account to delete. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (ComputeNodeClient) DeleteUserPreparer ¶
func (client ComputeNodeClient) DeleteUserPreparer(ctx context.Context, poolID string, nodeID string, userName string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
DeleteUserPreparer prepares the DeleteUser request.
func (ComputeNodeClient) DeleteUserResponder ¶
func (client ComputeNodeClient) DeleteUserResponder(resp *http.Response) (result autorest.Response, err error)
DeleteUserResponder handles the response to the DeleteUser request. The method always closes the http.Response Body.
func (ComputeNodeClient) DeleteUserSender ¶
DeleteUserSender sends the DeleteUser request. The method will close the http.Response Body if it receives an error.
func (ComputeNodeClient) DisableScheduling ¶
func (client ComputeNodeClient) DisableScheduling(ctx context.Context, poolID string, nodeID string, nodeDisableSchedulingParameter *NodeDisableSchedulingParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result autorest.Response, err error)
DisableScheduling disable task scheduling of the specified compute node.
poolID is the id of the pool that contains the compute node. nodeID is the id of the compute node that you want to disable task scheduling. nodeDisableSchedulingParameter is the parameters for the request. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (ComputeNodeClient) DisableSchedulingPreparer ¶
func (client ComputeNodeClient) DisableSchedulingPreparer(ctx context.Context, poolID string, nodeID string, nodeDisableSchedulingParameter *NodeDisableSchedulingParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
DisableSchedulingPreparer prepares the DisableScheduling request.
func (ComputeNodeClient) DisableSchedulingResponder ¶
func (client ComputeNodeClient) DisableSchedulingResponder(resp *http.Response) (result autorest.Response, err error)
DisableSchedulingResponder handles the response to the DisableScheduling request. The method always closes the http.Response Body.
func (ComputeNodeClient) DisableSchedulingSender ¶
DisableSchedulingSender sends the DisableScheduling request. The method will close the http.Response Body if it receives an error.
func (ComputeNodeClient) EnableScheduling ¶
func (client ComputeNodeClient) EnableScheduling(ctx context.Context, poolID string, nodeID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result autorest.Response, err error)
EnableScheduling enable task scheduling of the specified compute node.
poolID is the id of the pool that contains the compute node. nodeID is the id of the compute node that you want to enable task scheduling. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (ComputeNodeClient) EnableSchedulingPreparer ¶
func (client ComputeNodeClient) EnableSchedulingPreparer(ctx context.Context, poolID string, nodeID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
EnableSchedulingPreparer prepares the EnableScheduling request.
func (ComputeNodeClient) EnableSchedulingResponder ¶
func (client ComputeNodeClient) EnableSchedulingResponder(resp *http.Response) (result autorest.Response, err error)
EnableSchedulingResponder handles the response to the EnableScheduling request. The method always closes the http.Response Body.
func (ComputeNodeClient) EnableSchedulingSender ¶
EnableSchedulingSender sends the EnableScheduling request. The method will close the http.Response Body if it receives an error.
func (ComputeNodeClient) Get ¶
func (client ComputeNodeClient) Get(ctx context.Context, poolID string, nodeID string, selectParameter string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result ComputeNode, err error)
Get gets information about the specified compute node.
poolID is the id of the pool that contains the compute node. nodeID is the id of the compute node that you want to get information about. selectParameter is sets an OData $select clause. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (ComputeNodeClient) GetPreparer ¶
func (client ComputeNodeClient) GetPreparer(ctx context.Context, poolID string, nodeID string, selectParameter string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
GetPreparer prepares the Get request.
func (ComputeNodeClient) GetRemoteDesktop ¶
func (client ComputeNodeClient) GetRemoteDesktop(ctx context.Context, poolID string, nodeID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result ReadCloser, err error)
GetRemoteDesktop gets the Remote Desktop Protocol file for the specified compute node.
poolID is the id of the pool that contains the compute node. nodeID is the id of the compute node for which you want to get the Remote Desktop Protocol file. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (ComputeNodeClient) GetRemoteDesktopPreparer ¶
func (client ComputeNodeClient) GetRemoteDesktopPreparer(ctx context.Context, poolID string, nodeID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
GetRemoteDesktopPreparer prepares the GetRemoteDesktop request.
func (ComputeNodeClient) GetRemoteDesktopResponder ¶
func (client ComputeNodeClient) GetRemoteDesktopResponder(resp *http.Response) (result ReadCloser, err error)
GetRemoteDesktopResponder handles the response to the GetRemoteDesktop request. The method always closes the http.Response Body.
func (ComputeNodeClient) GetRemoteDesktopSender ¶
GetRemoteDesktopSender sends the GetRemoteDesktop request. The method will close the http.Response Body if it receives an error.
func (ComputeNodeClient) GetResponder ¶
func (client ComputeNodeClient) GetResponder(resp *http.Response) (result ComputeNode, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (ComputeNodeClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (ComputeNodeClient) List ¶
func (client ComputeNodeClient) List(ctx context.Context, poolID string, filter string, selectParameter string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result ComputeNodeListResultPage, err error)
List lists the compute nodes in the specified pool.
poolID is the id of the pool from which you want to list nodes. filter is sets an OData $filter clause. selectParameter is sets an OData $select clause. maxResults is sets the maximum number of items to return in the response. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (ComputeNodeClient) ListComplete ¶
func (client ComputeNodeClient) ListComplete(ctx context.Context, poolID string, filter string, selectParameter string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result ComputeNodeListResultIterator, err error)
ListComplete enumerates all values, automatically crossing page boundaries as required.
func (ComputeNodeClient) ListPreparer ¶
func (client ComputeNodeClient) ListPreparer(ctx context.Context, poolID string, filter string, selectParameter string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
ListPreparer prepares the List request.
func (ComputeNodeClient) ListResponder ¶
func (client ComputeNodeClient) ListResponder(resp *http.Response) (result ComputeNodeListResult, err error)
ListResponder handles the response to the List request. The method always closes the http.Response Body.
func (ComputeNodeClient) ListSender ¶
ListSender sends the List request. The method will close the http.Response Body if it receives an error.
func (ComputeNodeClient) Reboot ¶
func (client ComputeNodeClient) Reboot(ctx context.Context, poolID string, nodeID string, nodeRebootParameter *NodeRebootParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result autorest.Response, err error)
Reboot restarts the specified compute node.
poolID is the id of the pool that contains the compute node. nodeID is the id of the compute node that you want to restart. nodeRebootParameter is the parameters for the request. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (ComputeNodeClient) RebootPreparer ¶
func (client ComputeNodeClient) RebootPreparer(ctx context.Context, poolID string, nodeID string, nodeRebootParameter *NodeRebootParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
RebootPreparer prepares the Reboot request.
func (ComputeNodeClient) RebootResponder ¶
func (client ComputeNodeClient) RebootResponder(resp *http.Response) (result autorest.Response, err error)
RebootResponder handles the response to the Reboot request. The method always closes the http.Response Body.
func (ComputeNodeClient) RebootSender ¶
RebootSender sends the Reboot request. The method will close the http.Response Body if it receives an error.
func (ComputeNodeClient) Reimage ¶
func (client ComputeNodeClient) Reimage(ctx context.Context, poolID string, nodeID string, nodeReimageParameter *NodeReimageParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result autorest.Response, err error)
Reimage reinstalls the operating system on the specified compute node.
poolID is the id of the pool that contains the compute node. nodeID is the id of the compute node that you want to restart. nodeReimageParameter is the parameters for the request. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (ComputeNodeClient) ReimagePreparer ¶
func (client ComputeNodeClient) ReimagePreparer(ctx context.Context, poolID string, nodeID string, nodeReimageParameter *NodeReimageParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
ReimagePreparer prepares the Reimage request.
func (ComputeNodeClient) ReimageResponder ¶
func (client ComputeNodeClient) ReimageResponder(resp *http.Response) (result autorest.Response, err error)
ReimageResponder handles the response to the Reimage request. The method always closes the http.Response Body.
func (ComputeNodeClient) ReimageSender ¶
ReimageSender sends the Reimage request. The method will close the http.Response Body if it receives an error.
func (ComputeNodeClient) UpdateUser ¶
func (client ComputeNodeClient) UpdateUser(ctx context.Context, poolID string, nodeID string, userName string, nodeUpdateUserParameter NodeUpdateUserParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result autorest.Response, err error)
UpdateUser updates the password or expiration time of a user account on the specified compute node.
poolID is the id of the pool that contains the compute node. nodeID is the id of the machine on which you want to update a user account. userName is the name of the user account to update. nodeUpdateUserParameter is the parameters for the request. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (ComputeNodeClient) UpdateUserPreparer ¶
func (client ComputeNodeClient) UpdateUserPreparer(ctx context.Context, poolID string, nodeID string, userName string, nodeUpdateUserParameter NodeUpdateUserParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
UpdateUserPreparer prepares the UpdateUser request.
func (ComputeNodeClient) UpdateUserResponder ¶
func (client ComputeNodeClient) UpdateUserResponder(resp *http.Response) (result autorest.Response, err error)
UpdateUserResponder handles the response to the UpdateUser request. The method always closes the http.Response Body.
func (ComputeNodeClient) UpdateUserSender ¶
UpdateUserSender sends the UpdateUser request. The method will close the http.Response Body if it receives an error.
type ComputeNodeDeallocationOption ¶
type ComputeNodeDeallocationOption string
ComputeNodeDeallocationOption enumerates the values for compute node deallocation option.
const ( // Requeue ... Requeue ComputeNodeDeallocationOption = "requeue" // Retaineddata ... Retaineddata ComputeNodeDeallocationOption = "retaineddata" // Taskcompletion ... Taskcompletion ComputeNodeDeallocationOption = "taskcompletion" // Terminate ... Terminate ComputeNodeDeallocationOption = "terminate" )
type ComputeNodeError ¶
type ComputeNodeError struct { // Code - Gets or sets an identifier for the compute node error. Codes are invariant and are intended to be consumed programmatically. Code *string `json:"code,omitempty"` // Message - Gets or sets a message describing the compute node error, intended to be suitable for display in a user interface. Message *string `json:"message,omitempty"` // ErrorDetails - Gets or sets the list of additional error details related to the compute node error. ErrorDetails *[]NameValuePair `json:"errorDetails,omitempty"` }
ComputeNodeError an error encountered by a compute node.
type ComputeNodeFillType ¶
type ComputeNodeFillType string
ComputeNodeFillType enumerates the values for compute node fill type.
const ( // ComputeNodeFillTypePack ... ComputeNodeFillTypePack ComputeNodeFillType = "pack" // ComputeNodeFillTypeSpread ... ComputeNodeFillTypeSpread ComputeNodeFillType = "spread" // ComputeNodeFillTypeUnmapped ... ComputeNodeFillTypeUnmapped ComputeNodeFillType = "unmapped" )
type ComputeNodeInformation ¶
type ComputeNodeInformation struct { // AffinityID - Gets or sets an identifier for the compute node on which the task ran, which can be passed when adding a task to request that the task be scheduled close to this compute node. AffinityID *string `json:"affinityId,omitempty"` // NodeURL - Gets or sets the URL of the node on which the task ran. NodeURL *string `json:"nodeUrl,omitempty"` // PoolID - Gets or sets the id of the pool on which the task ran. PoolID *string `json:"poolId,omitempty"` // NodeID - Gets or sets the id of the node on which the task ran. NodeID *string `json:"nodeId,omitempty"` // TaskRootDirectory - Gets or sets the root directory of the task on the compute node. TaskRootDirectory *string `json:"taskRootDirectory,omitempty"` // TaskRootDirectoryURL - Gets or sets the URL to the root directory of the task on the compute node. TaskRootDirectoryURL *string `json:"taskRootDirectoryUrl,omitempty"` }
ComputeNodeInformation information about the compute node on which a task ran.
type ComputeNodeListResult ¶
type ComputeNodeListResult struct { autorest.Response `json:"-"` // Value - Gets or sets the list of compute nodes. Value *[]ComputeNode `json:"value,omitempty"` // OdataNextLink - Gets or sets the URL to get the next set of results. OdataNextLink *string `json:"odata.nextLink,omitempty"` }
ComputeNodeListResult response to a ComputeNodeOperations.List request.
func (ComputeNodeListResult) IsEmpty ¶
func (cnlr ComputeNodeListResult) IsEmpty() bool
IsEmpty returns true if the ListResult contains no values.
type ComputeNodeListResultIterator ¶
type ComputeNodeListResultIterator struct {
// contains filtered or unexported fields
}
ComputeNodeListResultIterator provides access to a complete listing of ComputeNode values.
func (*ComputeNodeListResultIterator) Next ¶
func (iter *ComputeNodeListResultIterator) Next() error
Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.
func (ComputeNodeListResultIterator) NotDone ¶
func (iter ComputeNodeListResultIterator) NotDone() bool
NotDone returns true if the enumeration should be started or is not yet complete.
func (ComputeNodeListResultIterator) Response ¶
func (iter ComputeNodeListResultIterator) Response() ComputeNodeListResult
Response returns the raw server response from the last page request.
func (ComputeNodeListResultIterator) Value ¶
func (iter ComputeNodeListResultIterator) Value() ComputeNode
Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.
type ComputeNodeListResultPage ¶
type ComputeNodeListResultPage struct {
// contains filtered or unexported fields
}
ComputeNodeListResultPage contains a page of ComputeNode values.
func (*ComputeNodeListResultPage) Next ¶
func (page *ComputeNodeListResultPage) Next() error
Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.
func (ComputeNodeListResultPage) NotDone ¶
func (page ComputeNodeListResultPage) NotDone() bool
NotDone returns true if the page enumeration should be started or is not yet complete.
func (ComputeNodeListResultPage) Response ¶
func (page ComputeNodeListResultPage) Response() ComputeNodeListResult
Response returns the raw server response from the last page request.
func (ComputeNodeListResultPage) Values ¶
func (page ComputeNodeListResultPage) Values() []ComputeNode
Values returns the slice of values for the current page or nil if there are no values.
type ComputeNodeRebootOption ¶
type ComputeNodeRebootOption string
ComputeNodeRebootOption enumerates the values for compute node reboot option.
const ( // ComputeNodeRebootOptionRequeue ... ComputeNodeRebootOptionRequeue ComputeNodeRebootOption = "requeue" // ComputeNodeRebootOptionRetaineddata ... ComputeNodeRebootOptionRetaineddata ComputeNodeRebootOption = "retaineddata" // ComputeNodeRebootOptionTaskcompletion ... ComputeNodeRebootOptionTaskcompletion ComputeNodeRebootOption = "taskcompletion" // ComputeNodeRebootOptionTerminate ... ComputeNodeRebootOptionTerminate ComputeNodeRebootOption = "terminate" )
type ComputeNodeReimageOption ¶
type ComputeNodeReimageOption string
ComputeNodeReimageOption enumerates the values for compute node reimage option.
const ( // ComputeNodeReimageOptionRequeue ... ComputeNodeReimageOptionRequeue ComputeNodeReimageOption = "requeue" // ComputeNodeReimageOptionRetaineddata ... ComputeNodeReimageOptionRetaineddata ComputeNodeReimageOption = "retaineddata" // ComputeNodeReimageOptionTaskcompletion ... ComputeNodeReimageOptionTaskcompletion ComputeNodeReimageOption = "taskcompletion" // ComputeNodeReimageOptionTerminate ... ComputeNodeReimageOptionTerminate ComputeNodeReimageOption = "terminate" )
type ComputeNodeState ¶
type ComputeNodeState string
ComputeNodeState enumerates the values for compute node state.
const ( // Creating ... Creating ComputeNodeState = "creating" // Idle ... Idle ComputeNodeState = "idle" // Leavingpool ... Leavingpool ComputeNodeState = "leavingpool" // Offline ... Offline ComputeNodeState = "offline" // Rebooting ... Rebooting ComputeNodeState = "rebooting" // Reimaging ... Reimaging ComputeNodeState = "reimaging" // Running ... Running ComputeNodeState = "running" // Starting ... Starting ComputeNodeState = "starting" // Starttaskfailed ... Starttaskfailed ComputeNodeState = "starttaskfailed" // Unknown ... Unknown ComputeNodeState = "unknown" // Unusable ... Unusable ComputeNodeState = "unusable" // Waitingforstarttask ... Waitingforstarttask ComputeNodeState = "waitingforstarttask" )
type ComputeNodeUser ¶
type ComputeNodeUser struct { // Name - Gets or sets the user name of the account. Name *string `json:"name,omitempty"` // IsAdmin - Gets or sets whether the account should be an administrator on the compute node. IsAdmin *bool `json:"isAdmin,omitempty"` // ExpiryTime - Gets or sets the time at which the account should expire. If omitted, the default is 1 day from the current time. ExpiryTime *date.Time `json:"expiryTime,omitempty"` // Password - Gets or sets the password of the account. Password *string `json:"password,omitempty"` }
ComputeNodeUser an user account on a compute node.
type DeleteCertificateError ¶
type DeleteCertificateError struct { // Code - Gets or sets an identifier for the certificate deletion error. Codes are invariant and are intended to be consumed programmatically. Code *string `json:"code,omitempty"` // Message - Gets or sets a message describing the certificate deletion error, intended to be suitable for display in a user interface. Message *string `json:"message,omitempty"` // Values - Gets or sets a list of additional error details related to the certificate deletion error. Values *[]NameValuePair `json:"values,omitempty"` }
DeleteCertificateError an error encountered by the Batch service when deleting a certificate.
type DisableComputeNodeSchedulingOption ¶
type DisableComputeNodeSchedulingOption string
DisableComputeNodeSchedulingOption enumerates the values for disable compute node scheduling option.
const ( // DisableComputeNodeSchedulingOptionRequeue ... DisableComputeNodeSchedulingOptionRequeue DisableComputeNodeSchedulingOption = "requeue" // DisableComputeNodeSchedulingOptionTaskcompletion ... DisableComputeNodeSchedulingOptionTaskcompletion DisableComputeNodeSchedulingOption = "taskcompletion" // DisableComputeNodeSchedulingOptionTerminate ... DisableComputeNodeSchedulingOptionTerminate DisableComputeNodeSchedulingOption = "terminate" )
type DisableJobOption ¶
type DisableJobOption string
DisableJobOption enumerates the values for disable job option.
const ( // DisableJobOptionRequeue ... DisableJobOptionRequeue DisableJobOption = "requeue" // DisableJobOptionTerminate ... DisableJobOptionTerminate DisableJobOption = "terminate" // DisableJobOptionWait ... DisableJobOptionWait DisableJobOption = "wait" )
type EnvironmentSetting ¶
type EnvironmentSetting struct { // Name - Gets or sets the name of the environment variable. Name *string `json:"name,omitempty"` // Value - Gets or sets the value of the environment variable. Value *string `json:"value,omitempty"` }
EnvironmentSetting an environment variable to be set on a task process.
type Error ¶
type Error struct { // Code - Gets or sets an identifier for the error. Codes are invariant and are intended to be consumed programmatically. Code *string `json:"code,omitempty"` // Message - Gets or sets a message describing the error, intended to be suitable for display in a user interface. Message *ErrorMessage `json:"message,omitempty"` // Values - Gets or sets a collection of key-value pairs containing additional details about the error. Values *[]ErrorDetail `json:"values,omitempty"` }
Error an error response received from the Azure Batch service.
type ErrorDetail ¶
type ErrorDetail struct { // Key - Gets or sets an identifier specifying the meaning of the Value property. Key *string `json:"key,omitempty"` // Value - Gets or sets the additional information included with the error response. Value *string `json:"value,omitempty"` }
ErrorDetail an item of additional information included in an Azure Batch error response.
type ErrorMessage ¶
type ErrorMessage struct { // Lang - Gets or sets the language code of the error message Lang *string `json:"lang,omitempty"` // Value - Gets or sets the text of the message. Value *string `json:"value,omitempty"` }
ErrorMessage an error message received in an Azure Batch error response.
type FileClient ¶
type FileClient struct {
BaseClient
}
FileClient is the a client for issuing REST requests to the Azure Batch service.
func NewFileClient ¶
func NewFileClient() FileClient
NewFileClient creates an instance of the FileClient client.
func NewFileClientWithBaseURI ¶
func NewFileClientWithBaseURI(baseURI string) FileClient
NewFileClientWithBaseURI creates an instance of the FileClient client.
func (FileClient) DeleteFromComputeNode ¶
func (client FileClient) DeleteFromComputeNode(ctx context.Context, poolID string, nodeID string, fileName string, recursive *bool, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result autorest.Response, err error)
DeleteFromComputeNode deletes the specified task file from the compute node.
poolID is the id of the pool that contains the compute node. nodeID is the id of the compute node from which you want to delete the file. fileName is the path to the file that you want to delete. recursive is sets whether to delete children of a directory. If the fileName parameter represents a directory instead of a file, you can set Recursive to true to delete the directory and all of the files and subdirectories in it. If Recursive is false then the directory must be empty or deletion will fail. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (FileClient) DeleteFromComputeNodePreparer ¶
func (client FileClient) DeleteFromComputeNodePreparer(ctx context.Context, poolID string, nodeID string, fileName string, recursive *bool, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
DeleteFromComputeNodePreparer prepares the DeleteFromComputeNode request.
func (FileClient) DeleteFromComputeNodeResponder ¶
func (client FileClient) DeleteFromComputeNodeResponder(resp *http.Response) (result autorest.Response, err error)
DeleteFromComputeNodeResponder handles the response to the DeleteFromComputeNode request. The method always closes the http.Response Body.
func (FileClient) DeleteFromComputeNodeSender ¶
DeleteFromComputeNodeSender sends the DeleteFromComputeNode request. The method will close the http.Response Body if it receives an error.
func (FileClient) DeleteFromTask ¶
func (client FileClient) DeleteFromTask(ctx context.Context, jobID string, taskID string, fileName string, recursive *bool, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result autorest.Response, err error)
DeleteFromTask deletes the specified task file from the compute node where the task ran.
jobID is the id of the job that contains the task. taskID is the id of the task whose file you want to delete. fileName is the path to the task file that you want to delete. recursive is sets whether to delete children of a directory. If the fileName parameter represents a directory instead of a file, you can set Recursive to true to delete the directory and all of the files and subdirectories in it. If Recursive is false then the directory must be empty or deletion will fail. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (FileClient) DeleteFromTaskPreparer ¶
func (client FileClient) DeleteFromTaskPreparer(ctx context.Context, jobID string, taskID string, fileName string, recursive *bool, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
DeleteFromTaskPreparer prepares the DeleteFromTask request.
func (FileClient) DeleteFromTaskResponder ¶
func (client FileClient) DeleteFromTaskResponder(resp *http.Response) (result autorest.Response, err error)
DeleteFromTaskResponder handles the response to the DeleteFromTask request. The method always closes the http.Response Body.
func (FileClient) DeleteFromTaskSender ¶
DeleteFromTaskSender sends the DeleteFromTask request. The method will close the http.Response Body if it receives an error.
func (FileClient) GetFromComputeNode ¶
func (client FileClient) GetFromComputeNode(ctx context.Context, poolID string, nodeID string, fileName string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ocpRange string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result ReadCloser, err error)
GetFromComputeNode gets the content of the specified task file.
poolID is the id of the pool that contains the compute node. nodeID is the id of the compute node that contains the file. fileName is the path to the task file that you want to get the content of. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ocpRange is specifies the byte range to be retrieved. The default is to retrieve the entire file. The format is startRange-endRange. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (FileClient) GetFromComputeNodePreparer ¶
func (client FileClient) GetFromComputeNodePreparer(ctx context.Context, poolID string, nodeID string, fileName string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ocpRange string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
GetFromComputeNodePreparer prepares the GetFromComputeNode request.
func (FileClient) GetFromComputeNodeResponder ¶
func (client FileClient) GetFromComputeNodeResponder(resp *http.Response) (result ReadCloser, err error)
GetFromComputeNodeResponder handles the response to the GetFromComputeNode request. The method always closes the http.Response Body.
func (FileClient) GetFromComputeNodeSender ¶
GetFromComputeNodeSender sends the GetFromComputeNode request. The method will close the http.Response Body if it receives an error.
func (FileClient) GetFromTask ¶
func (client FileClient) GetFromTask(ctx context.Context, jobID string, taskID string, fileName string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ocpRange string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result ReadCloser, err error)
GetFromTask gets the content of the specified task file.
jobID is the id of the job that contains the task. taskID is the id of the task whose file you want to retrieve. fileName is the path to the task file that you want to get the content of. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ocpRange is specifies the byte range to be retrieved. The default is to retrieve the entire file. The format is startRange-endRange. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (FileClient) GetFromTaskPreparer ¶
func (client FileClient) GetFromTaskPreparer(ctx context.Context, jobID string, taskID string, fileName string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ocpRange string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
GetFromTaskPreparer prepares the GetFromTask request.
func (FileClient) GetFromTaskResponder ¶
func (client FileClient) GetFromTaskResponder(resp *http.Response) (result ReadCloser, err error)
GetFromTaskResponder handles the response to the GetFromTask request. The method always closes the http.Response Body.
func (FileClient) GetFromTaskSender ¶
GetFromTaskSender sends the GetFromTask request. The method will close the http.Response Body if it receives an error.
func (FileClient) GetNodeFilePropertiesFromComputeNode ¶
func (client FileClient) GetNodeFilePropertiesFromComputeNode(ctx context.Context, poolID string, nodeID string, fileName string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
GetNodeFilePropertiesFromComputeNode gets the properties of the specified compute node file.
poolID is the id of the pool that contains the compute node. nodeID is the id of the compute node that contains the file. fileName is the path to the compute node file that you want to get the properties of. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (FileClient) GetNodeFilePropertiesFromComputeNodePreparer ¶
func (client FileClient) GetNodeFilePropertiesFromComputeNodePreparer(ctx context.Context, poolID string, nodeID string, fileName string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
GetNodeFilePropertiesFromComputeNodePreparer prepares the GetNodeFilePropertiesFromComputeNode request.
func (FileClient) GetNodeFilePropertiesFromComputeNodeResponder ¶
func (client FileClient) GetNodeFilePropertiesFromComputeNodeResponder(resp *http.Response) (result autorest.Response, err error)
GetNodeFilePropertiesFromComputeNodeResponder handles the response to the GetNodeFilePropertiesFromComputeNode request. The method always closes the http.Response Body.
func (FileClient) GetNodeFilePropertiesFromComputeNodeSender ¶
func (client FileClient) GetNodeFilePropertiesFromComputeNodeSender(req *http.Request) (*http.Response, error)
GetNodeFilePropertiesFromComputeNodeSender sends the GetNodeFilePropertiesFromComputeNode request. The method will close the http.Response Body if it receives an error.
func (FileClient) GetNodeFilePropertiesFromTask ¶
func (client FileClient) GetNodeFilePropertiesFromTask(ctx context.Context, jobID string, taskID string, fileName string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
GetNodeFilePropertiesFromTask gets the properties of the specified task file.
jobID is the id of the job that contains the task. taskID is the id of the task whose file you want to get the properties of. fileName is the path to the task file that you want to get the properties of. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (FileClient) GetNodeFilePropertiesFromTaskPreparer ¶
func (client FileClient) GetNodeFilePropertiesFromTaskPreparer(ctx context.Context, jobID string, taskID string, fileName string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
GetNodeFilePropertiesFromTaskPreparer prepares the GetNodeFilePropertiesFromTask request.
func (FileClient) GetNodeFilePropertiesFromTaskResponder ¶
func (client FileClient) GetNodeFilePropertiesFromTaskResponder(resp *http.Response) (result autorest.Response, err error)
GetNodeFilePropertiesFromTaskResponder handles the response to the GetNodeFilePropertiesFromTask request. The method always closes the http.Response Body.
func (FileClient) GetNodeFilePropertiesFromTaskSender ¶
func (client FileClient) GetNodeFilePropertiesFromTaskSender(req *http.Request) (*http.Response, error)
GetNodeFilePropertiesFromTaskSender sends the GetNodeFilePropertiesFromTask request. The method will close the http.Response Body if it receives an error.
func (FileClient) ListFromComputeNode ¶
func (client FileClient) ListFromComputeNode(ctx context.Context, poolID string, nodeID string, filter string, recursive *bool, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result NodeFileListResultPage, err error)
ListFromComputeNode lists all of the files in task directories on the specified compute node.
poolID is the id of the pool that contains the compute node. nodeID is the id of the compute node whose files you want to list. filter is sets an OData $filter clause. recursive is sets whether to list children of a directory. maxResults is sets the maximum number of items to return in the response. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (FileClient) ListFromComputeNodeComplete ¶
func (client FileClient) ListFromComputeNodeComplete(ctx context.Context, poolID string, nodeID string, filter string, recursive *bool, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result NodeFileListResultIterator, err error)
ListFromComputeNodeComplete enumerates all values, automatically crossing page boundaries as required.
func (FileClient) ListFromComputeNodePreparer ¶
func (client FileClient) ListFromComputeNodePreparer(ctx context.Context, poolID string, nodeID string, filter string, recursive *bool, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
ListFromComputeNodePreparer prepares the ListFromComputeNode request.
func (FileClient) ListFromComputeNodeResponder ¶
func (client FileClient) ListFromComputeNodeResponder(resp *http.Response) (result NodeFileListResult, err error)
ListFromComputeNodeResponder handles the response to the ListFromComputeNode request. The method always closes the http.Response Body.
func (FileClient) ListFromComputeNodeSender ¶
ListFromComputeNodeSender sends the ListFromComputeNode request. The method will close the http.Response Body if it receives an error.
func (FileClient) ListFromTask ¶
func (client FileClient) ListFromTask(ctx context.Context, jobID string, taskID string, filter string, recursive *bool, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result NodeFileListResultPage, err error)
ListFromTask lists the files in a task's directory on its compute node.
jobID is the id of the job that contains the task. taskID is the id of the task whose files you want to list. filter is sets an OData $filter clause. recursive is sets whether to list children of a directory. maxResults is sets the maximum number of items to return in the response. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (FileClient) ListFromTaskComplete ¶
func (client FileClient) ListFromTaskComplete(ctx context.Context, jobID string, taskID string, filter string, recursive *bool, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result NodeFileListResultIterator, err error)
ListFromTaskComplete enumerates all values, automatically crossing page boundaries as required.
func (FileClient) ListFromTaskPreparer ¶
func (client FileClient) ListFromTaskPreparer(ctx context.Context, jobID string, taskID string, filter string, recursive *bool, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
ListFromTaskPreparer prepares the ListFromTask request.
func (FileClient) ListFromTaskResponder ¶
func (client FileClient) ListFromTaskResponder(resp *http.Response) (result NodeFileListResult, err error)
ListFromTaskResponder handles the response to the ListFromTask request. The method always closes the http.Response Body.
func (FileClient) ListFromTaskSender ¶
ListFromTaskSender sends the ListFromTask request. The method will close the http.Response Body if it receives an error.
type FileProperties ¶
type FileProperties struct { // CreationTime - Gets or sets the file creation time. CreationTime *date.Time `json:"creationTime,omitempty"` // LastModified - Gets or sets the time at which the file was last modified. LastModified *date.Time `json:"lastModified,omitempty"` // ContentLength - Gets or sets the length of the file. ContentLength *int64 `json:"contentLength,omitempty"` // ContentType - Gets or sets the content type of the file. ContentType *string `json:"contentType,omitempty"` }
FileProperties the properties of a file on a compute node.
type JobAddParameter ¶
type JobAddParameter struct { // ID - Gets or sets a string that uniquely identifies the job within the account. The id can contain any combination of alphanumeric characters including hyphens and underscores, and cannot contain more than 64 characters. It is common to use a GUID for the id. ID *string `json:"id,omitempty"` // DisplayName - Gets or sets the display name for the job. DisplayName *string `json:"displayName,omitempty"` // Priority - Gets or sets the priority of the job. Priority values can range from -1000 to 1000, with -1000 being the lowest priority and 1000 being the highest priority. The default value is 0. Priority *int32 `json:"priority,omitempty"` // Constraints - Gets or sets the execution constraints for the job. Constraints *JobConstraints `json:"constraints,omitempty"` // JobManagerTask - Gets or sets details of a Job Manager task to be launched when the job is started. JobManagerTask *JobManagerTask `json:"jobManagerTask,omitempty"` // JobPreparationTask - Gets or sets the Job Preparation task. JobPreparationTask *JobPreparationTask `json:"jobPreparationTask,omitempty"` // JobReleaseTask - Gets or sets the Job Release task. JobReleaseTask *JobReleaseTask `json:"jobReleaseTask,omitempty"` // CommonEnvironmentSettings - Gets or sets the list of common environment variable settings. These environment variables are set for all tasks in the job (including the Job Manager, Job Preparation and Job Release tasks). CommonEnvironmentSettings *[]EnvironmentSetting `json:"commonEnvironmentSettings,omitempty"` // PoolInfo - Gets or sets the pool on which the Batch service runs the job’s tasks. PoolInfo *PoolInformation `json:"poolInfo,omitempty"` // Metadata - Gets or sets a list of name-value pairs associated with the job as metadata. Metadata *[]MetadataItem `json:"metadata,omitempty"` // UsesTaskDependencies - Gets or sets the flag that determines if this job will use tasks with dependencies. UsesTaskDependencies *bool `json:"usesTaskDependencies,omitempty"` }
JobAddParameter an Azure Batch job to add.
type JobClient ¶
type JobClient struct {
BaseClient
}
JobClient is the a client for issuing REST requests to the Azure Batch service.
func NewJobClient ¶
func NewJobClient() JobClient
NewJobClient creates an instance of the JobClient client.
func NewJobClientWithBaseURI ¶
NewJobClientWithBaseURI creates an instance of the JobClient client.
func (JobClient) Add ¶
func (client JobClient) Add(ctx context.Context, job JobAddParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result autorest.Response, err error)
Add adds a job to the specified account.
job is specifies the job to be added. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (JobClient) AddPreparer ¶
func (client JobClient) AddPreparer(ctx context.Context, job JobAddParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
AddPreparer prepares the Add request.
func (JobClient) AddResponder ¶
AddResponder handles the response to the Add request. The method always closes the http.Response Body.
func (JobClient) AddSender ¶
AddSender sends the Add request. The method will close the http.Response Body if it receives an error.
func (JobClient) Delete ¶
func (client JobClient) Delete(ctx context.Context, jobID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
Delete deletes a job.
jobID is the id of the job to delete. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (JobClient) DeletePreparer ¶
func (client JobClient) DeletePreparer(ctx context.Context, jobID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (JobClient) DeleteResponder ¶
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (JobClient) DeleteSender ¶
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (JobClient) Disable ¶
func (client JobClient) Disable(ctx context.Context, jobID string, jobDisableParameter JobDisableParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
Disable disables the specified job, preventing new tasks from running.
jobID is the id of the job to disable. jobDisableParameter is the parameters for the request. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (JobClient) DisablePreparer ¶
func (client JobClient) DisablePreparer(ctx context.Context, jobID string, jobDisableParameter JobDisableParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
DisablePreparer prepares the Disable request.
func (JobClient) DisableResponder ¶
DisableResponder handles the response to the Disable request. The method always closes the http.Response Body.
func (JobClient) DisableSender ¶
DisableSender sends the Disable request. The method will close the http.Response Body if it receives an error.
func (JobClient) Enable ¶
func (client JobClient) Enable(ctx context.Context, jobID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
Enable enables the specified job, allowing new tasks to run.
jobID is the id of the job to enable. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (JobClient) EnablePreparer ¶
func (client JobClient) EnablePreparer(ctx context.Context, jobID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
EnablePreparer prepares the Enable request.
func (JobClient) EnableResponder ¶
EnableResponder handles the response to the Enable request. The method always closes the http.Response Body.
func (JobClient) EnableSender ¶
EnableSender sends the Enable request. The method will close the http.Response Body if it receives an error.
func (JobClient) Get ¶
func (client JobClient) Get(ctx context.Context, jobID string, selectParameter string, expand string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result CloudJob, err error)
Get gets information about the specified job.
jobID is the id of the job. selectParameter is sets an OData $select clause. expand is sets an OData $expand clause. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (JobClient) GetAllJobsLifetimeStatistics ¶
func (client JobClient) GetAllJobsLifetimeStatistics(ctx context.Context, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result JobStatistics, err error)
GetAllJobsLifetimeStatistics gets lifetime summary statistics for all of the jobs in the specified account. Statistics are aggregated across all jobs that have ever existed in the account, from account creation to the last update time of the statistics.
timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (JobClient) GetAllJobsLifetimeStatisticsPreparer ¶
func (client JobClient) GetAllJobsLifetimeStatisticsPreparer(ctx context.Context, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
GetAllJobsLifetimeStatisticsPreparer prepares the GetAllJobsLifetimeStatistics request.
func (JobClient) GetAllJobsLifetimeStatisticsResponder ¶
func (client JobClient) GetAllJobsLifetimeStatisticsResponder(resp *http.Response) (result JobStatistics, err error)
GetAllJobsLifetimeStatisticsResponder handles the response to the GetAllJobsLifetimeStatistics request. The method always closes the http.Response Body.
func (JobClient) GetAllJobsLifetimeStatisticsSender ¶
func (client JobClient) GetAllJobsLifetimeStatisticsSender(req *http.Request) (*http.Response, error)
GetAllJobsLifetimeStatisticsSender sends the GetAllJobsLifetimeStatistics request. The method will close the http.Response Body if it receives an error.
func (JobClient) GetPreparer ¶
func (client JobClient) GetPreparer(ctx context.Context, jobID string, selectParameter string, expand string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
GetPreparer prepares the Get request.
func (JobClient) GetResponder ¶
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (JobClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (JobClient) List ¶
func (client JobClient) List(ctx context.Context, filter string, selectParameter string, expand string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result CloudJobListResultPage, err error)
List lists all of the jobs in the specified account.
filter is sets an OData $filter clause. selectParameter is sets an OData $select clause. expand is sets an OData $expand clause. maxResults is sets the maximum number of items to return in the response. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (JobClient) ListComplete ¶
func (client JobClient) ListComplete(ctx context.Context, filter string, selectParameter string, expand string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result CloudJobListResultIterator, err error)
ListComplete enumerates all values, automatically crossing page boundaries as required.
func (JobClient) ListFromJobSchedule ¶
func (client JobClient) ListFromJobSchedule(ctx context.Context, jobScheduleID string, filter string, selectParameter string, expand string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result CloudJobListResultPage, err error)
ListFromJobSchedule lists the jobs that have been created under the specified job schedule.
jobScheduleID is the id of the job schedule from which you want to get a list of jobs. filter is sets an OData $filter clause. selectParameter is sets an OData $select clause. expand is sets an OData $expand clause. maxResults is sets the maximum number of items to return in the response. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (JobClient) ListFromJobScheduleComplete ¶
func (client JobClient) ListFromJobScheduleComplete(ctx context.Context, jobScheduleID string, filter string, selectParameter string, expand string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result CloudJobListResultIterator, err error)
ListFromJobScheduleComplete enumerates all values, automatically crossing page boundaries as required.
func (JobClient) ListFromJobSchedulePreparer ¶
func (client JobClient) ListFromJobSchedulePreparer(ctx context.Context, jobScheduleID string, filter string, selectParameter string, expand string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
ListFromJobSchedulePreparer prepares the ListFromJobSchedule request.
func (JobClient) ListFromJobScheduleResponder ¶
func (client JobClient) ListFromJobScheduleResponder(resp *http.Response) (result CloudJobListResult, err error)
ListFromJobScheduleResponder handles the response to the ListFromJobSchedule request. The method always closes the http.Response Body.
func (JobClient) ListFromJobScheduleSender ¶
ListFromJobScheduleSender sends the ListFromJobSchedule request. The method will close the http.Response Body if it receives an error.
func (JobClient) ListPreparationAndReleaseTaskStatus ¶
func (client JobClient) ListPreparationAndReleaseTaskStatus(ctx context.Context, jobID string, filter string, selectParameter string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result CloudJobListPreparationAndReleaseTaskStatusResultPage, err error)
ListPreparationAndReleaseTaskStatus lists the execution status of the Job Preparation and Job Release task for the specified job across the compute nodes where the job has run.
jobID is the id of the job. filter is sets an OData $filter clause. selectParameter is sets an OData $select clause. maxResults is sets the maximum number of items to return in the response. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (JobClient) ListPreparationAndReleaseTaskStatusComplete ¶
func (client JobClient) ListPreparationAndReleaseTaskStatusComplete(ctx context.Context, jobID string, filter string, selectParameter string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result CloudJobListPreparationAndReleaseTaskStatusResultIterator, err error)
ListPreparationAndReleaseTaskStatusComplete enumerates all values, automatically crossing page boundaries as required.
func (JobClient) ListPreparationAndReleaseTaskStatusPreparer ¶
func (client JobClient) ListPreparationAndReleaseTaskStatusPreparer(ctx context.Context, jobID string, filter string, selectParameter string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
ListPreparationAndReleaseTaskStatusPreparer prepares the ListPreparationAndReleaseTaskStatus request.
func (JobClient) ListPreparationAndReleaseTaskStatusResponder ¶
func (client JobClient) ListPreparationAndReleaseTaskStatusResponder(resp *http.Response) (result CloudJobListPreparationAndReleaseTaskStatusResult, err error)
ListPreparationAndReleaseTaskStatusResponder handles the response to the ListPreparationAndReleaseTaskStatus request. The method always closes the http.Response Body.
func (JobClient) ListPreparationAndReleaseTaskStatusSender ¶
func (client JobClient) ListPreparationAndReleaseTaskStatusSender(req *http.Request) (*http.Response, error)
ListPreparationAndReleaseTaskStatusSender sends the ListPreparationAndReleaseTaskStatus request. The method will close the http.Response Body if it receives an error.
func (JobClient) ListPreparer ¶
func (client JobClient) ListPreparer(ctx context.Context, filter string, selectParameter string, expand string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
ListPreparer prepares the List request.
func (JobClient) ListResponder ¶
func (client JobClient) ListResponder(resp *http.Response) (result CloudJobListResult, err error)
ListResponder handles the response to the List request. The method always closes the http.Response Body.
func (JobClient) ListSender ¶
ListSender sends the List request. The method will close the http.Response Body if it receives an error.
func (JobClient) Patch ¶
func (client JobClient) Patch(ctx context.Context, jobID string, jobPatchParameter JobPatchParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
Patch updates the properties of a job.
jobID is the id of the job whose properties you want to update. jobPatchParameter is the parameters for the request. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (JobClient) PatchPreparer ¶
func (client JobClient) PatchPreparer(ctx context.Context, jobID string, jobPatchParameter JobPatchParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
PatchPreparer prepares the Patch request.
func (JobClient) PatchResponder ¶
PatchResponder handles the response to the Patch request. The method always closes the http.Response Body.
func (JobClient) PatchSender ¶
PatchSender sends the Patch request. The method will close the http.Response Body if it receives an error.
func (JobClient) Terminate ¶
func (client JobClient) Terminate(ctx context.Context, jobID string, jobTerminateParameter *JobTerminateParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
Terminate terminates the specified job, marking it as completed.
jobID is the id of the job to terminate. jobTerminateParameter is the parameters for the request. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (JobClient) TerminatePreparer ¶
func (client JobClient) TerminatePreparer(ctx context.Context, jobID string, jobTerminateParameter *JobTerminateParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
TerminatePreparer prepares the Terminate request.
func (JobClient) TerminateResponder ¶
func (client JobClient) TerminateResponder(resp *http.Response) (result autorest.Response, err error)
TerminateResponder handles the response to the Terminate request. The method always closes the http.Response Body.
func (JobClient) TerminateSender ¶
TerminateSender sends the Terminate request. The method will close the http.Response Body if it receives an error.
func (JobClient) Update ¶
func (client JobClient) Update(ctx context.Context, jobID string, jobUpdateParameter JobUpdateParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
Update updates the properties of a job.
jobID is the id of the job whose properties you want to update. jobUpdateParameter is the parameters for the request. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (JobClient) UpdatePreparer ¶
func (client JobClient) UpdatePreparer(ctx context.Context, jobID string, jobUpdateParameter JobUpdateParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
UpdatePreparer prepares the Update request.
func (JobClient) UpdateResponder ¶
UpdateResponder handles the response to the Update request. The method always closes the http.Response Body.
type JobConstraints ¶
type JobConstraints struct { // MaxWallClockTime - Gets or sets the maximum elapsed time that the job may run, measured from the time the job starts. If the job does not complete within the time limit, the Batch service terminates it and any tasks that are still running. MaxWallClockTime *string `json:"maxWallClockTime,omitempty"` // MaxTaskRetryCount - Gets or sets the maximum number of times each task may be retried. The Batch service retries a task if its exit code is nonzero. MaxTaskRetryCount *int32 `json:"maxTaskRetryCount,omitempty"` }
JobConstraints specifies the execution constraints for jobs created on a schedule.
type JobDisableParameter ¶
type JobDisableParameter struct { // DisableTasks - Sets what to do with active tasks associated with the job. Possible values include: 'DisableJobOptionRequeue', 'DisableJobOptionTerminate', 'DisableJobOptionWait' DisableTasks DisableJobOption `json:"disableTasks,omitempty"` }
JobDisableParameter parameters for a CloudJobOperations.Disable request.
type JobExecutionInformation ¶
type JobExecutionInformation struct { // StartTime - Gets or sets the start time of the job. StartTime *date.Time `json:"startTime,omitempty"` // EndTime - Gets or sets the completion time of the job. This property is set only if the job is in the completed state. EndTime *date.Time `json:"endTime,omitempty"` // PoolID - Gets or sets the id of the pool to which this job is assigned. PoolID *string `json:"poolId,omitempty"` // SchedulingError - Gets or sets details of any error encountered by the service in starting the job. SchedulingError *JobSchedulingError `json:"schedulingError,omitempty"` // TerminateReason - Gets or sets a string describing the reason the job ended. TerminateReason *string `json:"terminateReason,omitempty"` }
JobExecutionInformation contains information about the execution of a job in the Azure Batch service.
type JobManagerTask ¶
type JobManagerTask struct { // ID - Gets or sets a string that uniquely identifies the Job Manager task. A GUID is recommended. ID *string `json:"id,omitempty"` // DisplayName - Gets or sets the display name of the Job Manager task. DisplayName *string `json:"displayName,omitempty"` // CommandLine - Gets or sets the command line of the Job Manager task. CommandLine *string `json:"commandLine,omitempty"` // ResourceFiles - Gets or sets a list of files that Batch will download to the compute node before running the command line. ResourceFiles *[]ResourceFile `json:"resourceFiles,omitempty"` // EnvironmentSettings - Gets or sets a list of environment variable settings for the Job Manager task. EnvironmentSettings *[]EnvironmentSetting `json:"environmentSettings,omitempty"` // Constraints - Gets or sets constraints that apply to the Job Manager task. Constraints *TaskConstraints `json:"constraints,omitempty"` // KillJobOnCompletion - Gets or sets whether completion of the Job Manager task signifies completion of the entire job. KillJobOnCompletion *bool `json:"killJobOnCompletion,omitempty"` // RunElevated - Gets or sets whether to run the Job Manager task in elevated mode. The default value is false. RunElevated *bool `json:"runElevated,omitempty"` // RunExclusive - Gets or sets whether the Job Manager task requires exclusive use of the compute node where it runs. RunExclusive *bool `json:"runExclusive,omitempty"` }
JobManagerTask specifies details of a Job Manager task.
type JobPatchParameter ¶
type JobPatchParameter struct { // Priority - Sets the priority of the job. Priority values can range from -1000 to 1000, with -1000 being the lowest priority and 1000 being the highest priority. If omitted, the priority of the job is left unchanged. Priority *int32 `json:"priority,omitempty"` // Constraints - Sets the execution constraints for the job. If omitted, the existing execution constraints are left unchanged. Constraints *JobConstraints `json:"constraints,omitempty"` // PoolInfo - Sets the pool on which the Batch service runs the job's tasks. If omitted, the job continues to run on its current pool. PoolInfo *PoolInformation `json:"poolInfo,omitempty"` // Metadata - Sets a list of name-value pairs associated with the job as metadata. If omitted, the existing job metadata is left unchanged. Metadata *[]MetadataItem `json:"metadata,omitempty"` }
JobPatchParameter parameters for a CloudJobOperations.Patch request.
type JobPreparationAndReleaseTaskExecutionInformation ¶
type JobPreparationAndReleaseTaskExecutionInformation struct { // PoolID - Gets or sets the id of the pool containing the compute node to which this entry refers. PoolID *string `json:"poolId,omitempty"` // NodeID - Gets or sets the id of the compute node to which this entry refers. NodeID *string `json:"nodeId,omitempty"` // NodeURL - Gets or sets the URL of the compute node to which this entry refers. NodeURL *string `json:"nodeUrl,omitempty"` // JobPreparationTaskExecutionInfo - Gets or sets information about the execution status of the Job Preparation task on this compute node. JobPreparationTaskExecutionInfo *JobPreparationTaskExecutionInformation `json:"jobPreparationTaskExecutionInfo,omitempty"` // JobReleaseTaskExecutionInfo - Gets or sets information about the execution status of the Job Release task on this compute node. This property is set only if the Job Release task has run on the node. JobReleaseTaskExecutionInfo *JobReleaseTaskExecutionInformation `json:"jobReleaseTaskExecutionInfo,omitempty"` }
JobPreparationAndReleaseTaskExecutionInformation the status of the Job Preparation and Job Release tasks on a particular compute node.
type JobPreparationTask ¶
type JobPreparationTask struct { // ID - Gets or sets a string that uniquely identifies the job preparation task within the job. The id can contain any combination of alphanumeric characters including hyphens and underscores and cannot contain more than 64 characters. ID *string `json:"id,omitempty"` // CommandLine - Gets or sets the command line of the Job Preparation task. CommandLine *string `json:"commandLine,omitempty"` // ResourceFiles - Gets or sets a list of files that Batch will download to the compute node before running the command line. ResourceFiles *[]ResourceFile `json:"resourceFiles,omitempty"` // EnvironmentSettings - Gets or sets a list of environment variable settings for the Job Preparation task. EnvironmentSettings *[]EnvironmentSetting `json:"environmentSettings,omitempty"` // Constraints - Gets or sets constraints that apply to the Job Preparation task.. Constraints *TaskConstraints `json:"constraints,omitempty"` // WaitForSuccess - Gets or sets whether the Batch Service should wait for the Job Preparation task to complete successfully before scheduling any other tasks of the job on the compute node. WaitForSuccess *bool `json:"waitForSuccess,omitempty"` // RunElevated - Gets or sets whether to run the Job Preparation task in elevated mode. The default value is false. RunElevated *bool `json:"runElevated,omitempty"` // RerunOnNodeRebootAfterSuccess - Gets or sets whether the Batch service should rerun the Job Preparation task after a compute node reboots. The default value is true. RerunOnNodeRebootAfterSuccess *bool `json:"rerunOnNodeRebootAfterSuccess,omitempty"` }
JobPreparationTask a Job Preparation task to run before any tasks of the job on any given compute node.
type JobPreparationTaskExecutionInformation ¶
type JobPreparationTaskExecutionInformation struct { // StartTime - Gets or sets the time at which the Job Preparation task started running. StartTime *date.Time `json:"startTime,omitempty"` // EndTime - Gets or sets the time at which the Job Preparation task completed. This property is set only if the task is in the Completed state. EndTime *date.Time `json:"endTime,omitempty"` // State - Gets or sets the current running state of the Job Preparation task on the compute node. Possible values include: 'JobPreparationTaskStateRunning', 'JobPreparationTaskStateCompleted' State JobPreparationTaskState `json:"state,omitempty"` // TaskRootDirectory - Gets or sets the root directory of the Job Preparation task on the compute node. TaskRootDirectory *string `json:"taskRootDirectory,omitempty"` // TaskRootDirectoryURL - Gets or sets the URL to the root directory of the Job Preparation task on the compute node. TaskRootDirectoryURL *string `json:"taskRootDirectoryUrl,omitempty"` // ExitCode - Gets or sets the exit code of the Job Preparation task. This property is set only if the task is in the Completed state. ExitCode *int32 `json:"exitCode,omitempty"` // SchedulingError - Gets or sets any error starting the Job Preparation task. SchedulingError *TaskSchedulingError `json:"schedulingError,omitempty"` // RetryCount - Gets or sets the number of times the Job Preparation task has been retried by the Batch service. RetryCount *int32 `json:"retryCount,omitempty"` // LastRetryTime - Gets or sets the most recent time at which a retry of the Job Preparation task started running. This property is set only if the task was retried (i.e. retryCount is nonzero). LastRetryTime *date.Time `json:"lastRetryTime,omitempty"` }
JobPreparationTaskExecutionInformation contains information about the execution of a Job Preparation task on a compute node.
type JobPreparationTaskState ¶
type JobPreparationTaskState string
JobPreparationTaskState enumerates the values for job preparation task state.
const ( // JobPreparationTaskStateCompleted ... JobPreparationTaskStateCompleted JobPreparationTaskState = "completed" // JobPreparationTaskStateRunning ... JobPreparationTaskStateRunning JobPreparationTaskState = "running" )
type JobReleaseTask ¶
type JobReleaseTask struct { // ID - Gets or sets a string that uniquely identifies the Job Release task within the job. The id can contain any combination of alphanumeric characters including hyphens and underscores and cannot contain more than 64 characters. ID *string `json:"id,omitempty"` // CommandLine - Gets or sets the command line of the Job Release task. CommandLine *string `json:"commandLine,omitempty"` // ResourceFiles - Gets or sets a list of files that Batch will download to the compute node before running the command line. ResourceFiles *[]ResourceFile `json:"resourceFiles,omitempty"` // EnvironmentSettings - Gets or sets a list of environment variable settings for the Job Release task. EnvironmentSettings *[]EnvironmentSetting `json:"environmentSettings,omitempty"` // MaxWallClockTime - Gets or sets the maximum elapsed time that the Job Release task may run on a given compute node, measured from the time the task starts. If the task does not complete within the time limit, the Batch service terminates it. The default value is 15 minutes. MaxWallClockTime *string `json:"maxWallClockTime,omitempty"` // RetentionTime - Gets or sets the minimum time to retain the working directory for the Job Release task on the compute node. After this time, the Batch service may delete the working directory and all its contents. The default is infinite. RetentionTime *string `json:"retentionTime,omitempty"` // RunElevated - Gets or sets whether to run the Job Release task in elevated mode. The default value is false. RunElevated *bool `json:"runElevated,omitempty"` }
JobReleaseTask a Job Release task to run on job completion on any compute node where the job has run.
type JobReleaseTaskExecutionInformation ¶
type JobReleaseTaskExecutionInformation struct { // StartTime - Gets or sets the time at which the Job Release task started running. StartTime *date.Time `json:"startTime,omitempty"` // EndTime - Gets or sets the time at which the Job Release task completed. This property is set only if the task is in the Completed state. EndTime *date.Time `json:"endTime,omitempty"` // State - Gets or sets the current running state of the Job Release task on the compute node. Possible values include: 'JobReleaseTaskStateRunning', 'JobReleaseTaskStateCompleted' State JobReleaseTaskState `json:"state,omitempty"` // TaskRootDirectory - Gets or sets the root directory of the Job Release task on the compute node. TaskRootDirectory *string `json:"taskRootDirectory,omitempty"` // TaskRootDirectoryURL - Gets or sets the URL to the root directory of the Job Release task on the compute node. TaskRootDirectoryURL *string `json:"taskRootDirectoryUrl,omitempty"` // ExitCode - Gets or sets the exit code of the Job Release task. This property is set only if the task is in the Completed state. ExitCode *int32 `json:"exitCode,omitempty"` // SchedulingError - Gets or sets any error starting the Job Release task. SchedulingError *TaskSchedulingError `json:"schedulingError,omitempty"` }
JobReleaseTaskExecutionInformation contains information about the execution of a Job Release task on a compute node.
type JobReleaseTaskState ¶
type JobReleaseTaskState string
JobReleaseTaskState enumerates the values for job release task state.
const ( // JobReleaseTaskStateCompleted ... JobReleaseTaskStateCompleted JobReleaseTaskState = "completed" // JobReleaseTaskStateRunning ... JobReleaseTaskStateRunning JobReleaseTaskState = "running" )
type JobScheduleAddParameter ¶
type JobScheduleAddParameter struct { // ID - Gets or sets a string that uniquely identifies the schedule within the account. A GUID is recommended. ID *string `json:"id,omitempty"` // DisplayName - Gets or sets the display name for the schedule. DisplayName *string `json:"displayName,omitempty"` // Schedule - Gets or sets the schedule according to which jobs will be created. Schedule *Schedule `json:"schedule,omitempty"` // JobSpecification - Gets or sets the details of the jobs to be created on this schedule. JobSpecification *JobSpecification `json:"jobSpecification,omitempty"` // Metadata - Gets or sets a list of name-value pairs associated with the schedule as metadata. Metadata *[]MetadataItem `json:"metadata,omitempty"` }
JobScheduleAddParameter a job schedule that allows recurring jobs by specifying when to run jobs and a specification used to create each job.
type JobScheduleClient ¶
type JobScheduleClient struct {
BaseClient
}
JobScheduleClient is the a client for issuing REST requests to the Azure Batch service.
func NewJobScheduleClient ¶
func NewJobScheduleClient() JobScheduleClient
NewJobScheduleClient creates an instance of the JobScheduleClient client.
func NewJobScheduleClientWithBaseURI ¶
func NewJobScheduleClientWithBaseURI(baseURI string) JobScheduleClient
NewJobScheduleClientWithBaseURI creates an instance of the JobScheduleClient client.
func (JobScheduleClient) Add ¶
func (client JobScheduleClient) Add(ctx context.Context, cloudJobSchedule JobScheduleAddParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result autorest.Response, err error)
Add adds a job schedule to the specified account.
cloudJobSchedule is specifies the job schedule to be added. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (JobScheduleClient) AddPreparer ¶
func (client JobScheduleClient) AddPreparer(ctx context.Context, cloudJobSchedule JobScheduleAddParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
AddPreparer prepares the Add request.
func (JobScheduleClient) AddResponder ¶
func (client JobScheduleClient) AddResponder(resp *http.Response) (result autorest.Response, err error)
AddResponder handles the response to the Add request. The method always closes the http.Response Body.
func (JobScheduleClient) AddSender ¶
AddSender sends the Add request. The method will close the http.Response Body if it receives an error.
func (JobScheduleClient) Delete ¶
func (client JobScheduleClient) Delete(ctx context.Context, jobScheduleID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
Delete deletes a job schedule from the specified account.
jobScheduleID is the id of the job schedule to delete. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (JobScheduleClient) DeletePreparer ¶
func (client JobScheduleClient) DeletePreparer(ctx context.Context, jobScheduleID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (JobScheduleClient) DeleteResponder ¶
func (client JobScheduleClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (JobScheduleClient) DeleteSender ¶
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (JobScheduleClient) Disable ¶
func (client JobScheduleClient) Disable(ctx context.Context, jobScheduleID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
Disable disables a job schedule.
jobScheduleID is the id of the job schedule to disable. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (JobScheduleClient) DisablePreparer ¶
func (client JobScheduleClient) DisablePreparer(ctx context.Context, jobScheduleID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
DisablePreparer prepares the Disable request.
func (JobScheduleClient) DisableResponder ¶
func (client JobScheduleClient) DisableResponder(resp *http.Response) (result autorest.Response, err error)
DisableResponder handles the response to the Disable request. The method always closes the http.Response Body.
func (JobScheduleClient) DisableSender ¶
DisableSender sends the Disable request. The method will close the http.Response Body if it receives an error.
func (JobScheduleClient) Enable ¶
func (client JobScheduleClient) Enable(ctx context.Context, jobScheduleID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
Enable enables a job schedule.
jobScheduleID is the id of the job schedule to enable. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (JobScheduleClient) EnablePreparer ¶
func (client JobScheduleClient) EnablePreparer(ctx context.Context, jobScheduleID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
EnablePreparer prepares the Enable request.
func (JobScheduleClient) EnableResponder ¶
func (client JobScheduleClient) EnableResponder(resp *http.Response) (result autorest.Response, err error)
EnableResponder handles the response to the Enable request. The method always closes the http.Response Body.
func (JobScheduleClient) EnableSender ¶
EnableSender sends the Enable request. The method will close the http.Response Body if it receives an error.
func (JobScheduleClient) Exists ¶
func (client JobScheduleClient) Exists(ctx context.Context, jobScheduleID string, selectParameter string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
Exists checks the specified job schedule exists.
jobScheduleID is the id of the job schedule which you want to check. selectParameter is sets an OData $select clause. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (JobScheduleClient) ExistsPreparer ¶
func (client JobScheduleClient) ExistsPreparer(ctx context.Context, jobScheduleID string, selectParameter string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
ExistsPreparer prepares the Exists request.
func (JobScheduleClient) ExistsResponder ¶
func (client JobScheduleClient) ExistsResponder(resp *http.Response) (result autorest.Response, err error)
ExistsResponder handles the response to the Exists request. The method always closes the http.Response Body.
func (JobScheduleClient) ExistsSender ¶
ExistsSender sends the Exists request. The method will close the http.Response Body if it receives an error.
func (JobScheduleClient) Get ¶
func (client JobScheduleClient) Get(ctx context.Context, jobScheduleID string, selectParameter string, expand string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result CloudJobSchedule, err error)
Get gets information about the specified job schedule.
jobScheduleID is the id of the job schedule to get. selectParameter is sets an OData $select clause. expand is sets an OData $expand clause. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (JobScheduleClient) GetPreparer ¶
func (client JobScheduleClient) GetPreparer(ctx context.Context, jobScheduleID string, selectParameter string, expand string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
GetPreparer prepares the Get request.
func (JobScheduleClient) GetResponder ¶
func (client JobScheduleClient) GetResponder(resp *http.Response) (result CloudJobSchedule, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (JobScheduleClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (JobScheduleClient) List ¶
func (client JobScheduleClient) List(ctx context.Context, filter string, selectParameter string, expand string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result CloudJobScheduleListResultPage, err error)
List lists all of the job schedules in the specified account.
filter is sets an OData $filter clause. selectParameter is sets an OData $select clause. expand is sets an OData $expand clause. maxResults is sets the maximum number of items to return in the response. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (JobScheduleClient) ListComplete ¶
func (client JobScheduleClient) ListComplete(ctx context.Context, filter string, selectParameter string, expand string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result CloudJobScheduleListResultIterator, err error)
ListComplete enumerates all values, automatically crossing page boundaries as required.
func (JobScheduleClient) ListPreparer ¶
func (client JobScheduleClient) ListPreparer(ctx context.Context, filter string, selectParameter string, expand string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
ListPreparer prepares the List request.
func (JobScheduleClient) ListResponder ¶
func (client JobScheduleClient) ListResponder(resp *http.Response) (result CloudJobScheduleListResult, err error)
ListResponder handles the response to the List request. The method always closes the http.Response Body.
func (JobScheduleClient) ListSender ¶
ListSender sends the List request. The method will close the http.Response Body if it receives an error.
func (JobScheduleClient) Patch ¶
func (client JobScheduleClient) Patch(ctx context.Context, jobScheduleID string, jobSchedulePatchParameter JobSchedulePatchParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
Patch updates the properties of the specified job schedule.
jobScheduleID is the id of the job schedule to update. jobSchedulePatchParameter is the parameters for the request. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (JobScheduleClient) PatchPreparer ¶
func (client JobScheduleClient) PatchPreparer(ctx context.Context, jobScheduleID string, jobSchedulePatchParameter JobSchedulePatchParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
PatchPreparer prepares the Patch request.
func (JobScheduleClient) PatchResponder ¶
func (client JobScheduleClient) PatchResponder(resp *http.Response) (result autorest.Response, err error)
PatchResponder handles the response to the Patch request. The method always closes the http.Response Body.
func (JobScheduleClient) PatchSender ¶
PatchSender sends the Patch request. The method will close the http.Response Body if it receives an error.
func (JobScheduleClient) Terminate ¶
func (client JobScheduleClient) Terminate(ctx context.Context, jobScheduleID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
Terminate terminates a job schedule.
jobScheduleID is the id of the job schedule to terminates. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (JobScheduleClient) TerminatePreparer ¶
func (client JobScheduleClient) TerminatePreparer(ctx context.Context, jobScheduleID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
TerminatePreparer prepares the Terminate request.
func (JobScheduleClient) TerminateResponder ¶
func (client JobScheduleClient) TerminateResponder(resp *http.Response) (result autorest.Response, err error)
TerminateResponder handles the response to the Terminate request. The method always closes the http.Response Body.
func (JobScheduleClient) TerminateSender ¶
TerminateSender sends the Terminate request. The method will close the http.Response Body if it receives an error.
func (JobScheduleClient) Update ¶
func (client JobScheduleClient) Update(ctx context.Context, jobScheduleID string, jobScheduleUpdateParameter JobScheduleUpdateParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
Update updates the properties of the specified job schedule.
jobScheduleID is the id of the job schedule to update. jobScheduleUpdateParameter is the parameters for the request. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (JobScheduleClient) UpdatePreparer ¶
func (client JobScheduleClient) UpdatePreparer(ctx context.Context, jobScheduleID string, jobScheduleUpdateParameter JobScheduleUpdateParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
UpdatePreparer prepares the Update request.
func (JobScheduleClient) UpdateResponder ¶
func (client JobScheduleClient) UpdateResponder(resp *http.Response) (result autorest.Response, err error)
UpdateResponder handles the response to the Update request. The method always closes the http.Response Body.
func (JobScheduleClient) UpdateSender ¶
UpdateSender sends the Update request. The method will close the http.Response Body if it receives an error.
type JobScheduleExecutionInformation ¶
type JobScheduleExecutionInformation struct { // NextRunTime - Gets or sets the next time at which a job will be created under this schedule. NextRunTime *date.Time `json:"nextRunTime,omitempty"` // RecentJob - Gets or sets information about the most recent job under the job schedule. RecentJob *RecentJob `json:"recentJob,omitempty"` // EndTime - Gets or sets the time at which the schedule ended. This property is set only if the job schedule is in the completed state. EndTime *date.Time `json:"endTime,omitempty"` }
JobScheduleExecutionInformation specifies how tasks should be run in a job associated with a job schedule.
type JobSchedulePatchParameter ¶
type JobSchedulePatchParameter struct { // Schedule - Sets the schedule according to which jobs will be created. If you do not specify this element, the existing schedule is not modified. Schedule *Schedule `json:"schedule,omitempty"` // JobSpecification - Sets the details of the jobs to be created on this schedule. JobSpecification *JobSpecification `json:"jobSpecification,omitempty"` // Metadata - Sets a list of name-value pairs associated with the job schedule as metadata. Metadata *[]MetadataItem `json:"metadata,omitempty"` }
JobSchedulePatchParameter parameters for a CloudJobScheduleOperations.Patch request.
type JobScheduleState ¶
type JobScheduleState string
JobScheduleState enumerates the values for job schedule state.
const ( // JobScheduleStateActive ... JobScheduleStateActive JobScheduleState = "active" // JobScheduleStateCompleted ... JobScheduleStateCompleted JobScheduleState = "completed" // JobScheduleStateDeleting ... JobScheduleStateDeleting JobScheduleState = "deleting" // JobScheduleStateDisabled ... JobScheduleStateDisabled JobScheduleState = "disabled" // JobScheduleStateTerminating ... JobScheduleStateTerminating JobScheduleState = "terminating" )
type JobScheduleStatistics ¶
type JobScheduleStatistics struct { // URL - Gets or sets the URL for the statistics. URL *string `json:"url,omitempty"` // StartTime - Gets or sets the start time of the time range covered by the statistics. StartTime *date.Time `json:"startTime,omitempty"` // LastUpdateTime - Gets or sets the time at which the statistics were last updated. All statistics are limited to the range between startTime and lastUpdateTime. LastUpdateTime *date.Time `json:"lastUpdateTime,omitempty"` // UserCPUTime - Gets or sets the total user mode CPU time (summed across all cores and all compute nodes) consumed by all the tasks in all the jobs created under the schedule. UserCPUTime *string `json:"userCPUTime,omitempty"` // KernelCPUTime - Gets or sets the total kernel mode CPU time (summed across all cores and all compute nodes) consumed by all the tasks in all the jobs created under the schedule. KernelCPUTime *string `json:"kernelCPUTime,omitempty"` // WallClockTime - Gets or sets the total wall clock time of all the tasks in all the jobs created under the schedule. WallClockTime *string `json:"wallClockTime,omitempty"` // ReadIOps - Gets or sets the total number of I/O read operations performed by all the tasks in all the jobs created under the schedule. ReadIOps *int64 `json:"readIOps,omitempty"` // WriteIOps - Gets or sets the total number of I/O write operations performed by all the tasks in all the jobs created under the schedule. WriteIOps *int64 `json:"writeIOps,omitempty"` // ReadIOGiB - Gets or sets the total amount of data in GiB of I/O read by all the tasks in all the jobs created under the schedule. ReadIOGiB *float64 `json:"readIOGiB,omitempty"` // WriteIOGiB - Gets or sets the total amount of data in GiB of I/O written by all the tasks in all the jobs created under the schedule. WriteIOGiB *float64 `json:"writeIOGiB,omitempty"` // NumSucceededTasks - Gets or sets the total number of tasks successfully completed during the given time range in jobs created under the schedule. A task completes successfully if it returns exit code 0. NumSucceededTasks *int64 `json:"numSucceededTasks,omitempty"` // NumFailedTasks - Gets or sets the total number of tasks that failed during the given time range in jobs created under the schedule. A task fails if it exhausts its maximum retry count without returning exit code 0. NumFailedTasks *int64 `json:"numFailedTasks,omitempty"` // NumTaskRetries - Gets or sets the total number of retries during the given time range on all the tasks in jobs created under the schedule. NumTaskRetries *int64 `json:"numTaskRetries,omitempty"` // WaitTime - Gets or sets the total wait time of all the tasks in jobs created under the schedule. WaitTime *string `json:"waitTime,omitempty"` }
JobScheduleStatistics the lifetime resource usage statistics for a job schedule.
type JobScheduleUpdateParameter ¶
type JobScheduleUpdateParameter struct { // Schedule - Sets the schedule according to which jobs will be created. If you do not specify this element, it is equivalent to passing the default schedule: that is, a single job scheduled to run immediately. Schedule *Schedule `json:"schedule,omitempty"` // JobSpecification - Sets details of the jobs to be created on this schedule. JobSpecification *JobSpecification `json:"jobSpecification,omitempty"` // Metadata - Sets a list of name-value pairs associated with the job schedule as metadata. If you do not specify this element, it takes the default value of an empty list; in effect, any existing metadata is deleted. Metadata *[]MetadataItem `json:"metadata,omitempty"` }
JobScheduleUpdateParameter parameters for a CloudJobScheduleOperations.Update request.
type JobSchedulingError ¶
type JobSchedulingError struct { // Category - Gets or sets the category of the job scheduling error. Possible values include: 'SchedulingErrorCategoryUsererror', 'SchedulingErrorCategoryServererror', 'SchedulingErrorCategoryUnmapped' Category SchedulingErrorCategory `json:"category,omitempty"` // Code - Gets or sets an identifier for the job scheduling error. Codes are invariant and are intended to be consumed programmatically. Code *string `json:"code,omitempty"` // Message - Gets or sets a message describing the job scheduling error, intended to be suitable for display in a user interface. Message *string `json:"message,omitempty"` // Details - Gets or sets a list of additional error details related to the scheduling error. Details *[]NameValuePair `json:"details,omitempty"` }
JobSchedulingError an error encountered by the Batch service when scheduling a job.
type JobSpecification ¶
type JobSpecification struct { // Priority - Gets or sets the priority of jobs created under this schedule. Priority values can range from -1000 to 1000, with -1000 being the lowest priority and 1000 being the highest priority. The default value is 0. Priority *int32 `json:"priority,omitempty"` // DisplayName - Gets or sets the display name for jobs created under this schedule. It need not be unique and can contain any Unicode characters up to a maximum length of 1024. DisplayName *string `json:"displayName,omitempty"` // UsesTaskDependencies - Gets or sets the flag that determines if this job will use tasks with dependencies. UsesTaskDependencies *bool `json:"usesTaskDependencies,omitempty"` // Constraints - Gets or sets the execution constraints for jobs created under this schedule. Constraints *JobConstraints `json:"constraints,omitempty"` // JobManagerTask - Gets or sets the details of a Job Manager task to be launched when a job is started under this schedule. JobManagerTask *JobManagerTask `json:"jobManagerTask,omitempty"` // JobPreparationTask - Gets or sets the Job Preparation task for jobs created under this schedule. JobPreparationTask *JobPreparationTask `json:"jobPreparationTask,omitempty"` // JobReleaseTask - Gets or sets the Job Release task for jobs created under this schedule. JobReleaseTask *JobReleaseTask `json:"jobReleaseTask,omitempty"` // CommonEnvironmentSettings - Gets or sets a list of common environment variable settings. These environment variables are set for all tasks in jobs created under this schedule (including the Job Manager, Job Preparation and Job Release tasks). CommonEnvironmentSettings *[]EnvironmentSetting `json:"commonEnvironmentSettings,omitempty"` // PoolInfo - Gets or sets the pool on which the Batch service runs the tasks of jobs created under this schedule. PoolInfo *PoolInformation `json:"poolInfo,omitempty"` // Metadata - Gets or sets a list of name-value pairs associated with each job created under this schedule as metadata. Metadata *[]MetadataItem `json:"metadata,omitempty"` }
JobSpecification specifies details of the jobs to be created on a schedule.
type JobState ¶
type JobState string
JobState enumerates the values for job state.
const ( // JobStateActive ... JobStateActive JobState = "active" // JobStateCompleted ... JobStateCompleted JobState = "completed" // JobStateDeleting ... JobStateDeleting JobState = "deleting" // JobStateDisabled ... JobStateDisabled JobState = "disabled" // JobStateDisabling ... JobStateDisabling JobState = "disabling" // JobStateEnabling ... JobStateEnabling JobState = "enabling" // JobStateTerminating ... JobStateTerminating JobState = "terminating" )
type JobStatistics ¶
type JobStatistics struct { autorest.Response `json:"-"` // URL - Gets or sets the URL for the statistics. URL *string `json:"url,omitempty"` // StartTime - Gets or sets the start time of the time range covered by the statistics. StartTime *date.Time `json:"startTime,omitempty"` // LastUpdateTime - Gets or sets the time at which the statistics were last updated. All statistics are limited to the range between StartTime and LastUpdateTime. LastUpdateTime *date.Time `json:"lastUpdateTime,omitempty"` // UserCPUTime - Gets or sets the total user mode CPU time (summed across all cores and all compute nodes) consumed by all the tasks in the job. UserCPUTime *string `json:"userCPUTime,omitempty"` // KernelCPUTime - Gets or sets the total kernel mode CPU time (summed across all cores and all compute nodes) consumed by all the tasks in the job. KernelCPUTime *string `json:"kernelCPUTime,omitempty"` // WallClockTime - Gets or sets the total wall clock time of all the tasks in the job. WallClockTime *string `json:"wallClockTime,omitempty"` // ReadIOps - Gets or sets the total number of I/O read operations performed by all the tasks in the job. ReadIOps *int64 `json:"readIOps,omitempty"` // WriteIOps - Gets or sets the total number of I/O write operations performed by all the tasks in the job. WriteIOps *int64 `json:"writeIOps,omitempty"` // ReadIOGiB - Gets or sets the total amount of data in GiB of I/O read by all the tasks in the job. ReadIOGiB *float64 `json:"readIOGiB,omitempty"` // WriteIOGiB - Gets or sets the total amount of data in GiB of I/O written by all the tasks in the job. WriteIOGiB *float64 `json:"writeIOGiB,omitempty"` // NumSucceededTasks - Gets or sets the total number of tasks successfully completed in the job during the given time range. NumSucceededTasks *int64 `json:"numSucceededTasks,omitempty"` // NumFailedTasks - Gets or sets the total number of tasks in the job that failed during the given time range. NumFailedTasks *int64 `json:"numFailedTasks,omitempty"` // NumTaskRetries - Gets or sets the total number of retries on all the tasks in the job during the given time range. NumTaskRetries *int64 `json:"numTaskRetries,omitempty"` // WaitTime - Gets or sets the total wait time of all the tasks in the job. The wait time for a task is defined as the elapsed time between the creation of the task creation and the start of task execution. This value is reported only in the account lifetime statistics; it is not included in individual job statistics. WaitTime *string `json:"waitTime,omitempty"` }
JobStatistics resource usage statistics for a job.
type JobTerminateParameter ¶
type JobTerminateParameter struct { // TerminateReason - Sets the text you want to appear as the job's TerminateReason. The default is 'UserTerminate'. TerminateReason *string `json:"terminateReason,omitempty"` }
JobTerminateParameter parameters for a CloudJobOperations.Terminate request.
type JobUpdateParameter ¶
type JobUpdateParameter struct { // Priority - Sets the priority of the job. Priority values can range from -1000 to 1000, with -1000 being the lowest priority and 1000 being the highest priority. If omitted, the priority of the job is left unchanged. Priority *int32 `json:"priority,omitempty"` // Constraints - Sets the execution constraints for the job. If omitted, the existing execution constraints are left unchanged. Constraints *JobConstraints `json:"constraints,omitempty"` // PoolInfo - Sets the pool on which the Batch service runs the job's tasks. If omitted, the job continues to run on its current pool. PoolInfo *PoolInformation `json:"poolInfo,omitempty"` // Metadata - Sets a list of name-value pairs associated with the job as metadata. If omitted, the existing job metadata is left unchanged. Metadata *[]MetadataItem `json:"metadata,omitempty"` }
JobUpdateParameter parameters for a CloudJobOperations.Update request.
type MetadataItem ¶
type MetadataItem struct { // Name - Gets or sets the name of the metadata item. Name *string `json:"name,omitempty"` // Value - Gets or sets the value of the metadata item. Value *string `json:"value,omitempty"` }
MetadataItem a metadata item associated with an Azure Batch resource. The Batch service does not assign any meaning to metadata; it is solely for the use of user code.
type MultiInstanceSettings ¶
type MultiInstanceSettings struct { // NumberOfInstances - Gets or sets the number of compute node instances used for multi-instance task. NumberOfInstances *int32 `json:"numberOfInstances,omitempty"` // CoordinationCommandLine - Gets or sets the command to be run on the compute node instances to setup coordination among the subtasks. CoordinationCommandLine *string `json:"coordinationCommandLine,omitempty"` // CommonResourceFiles - Gets or sets a list of files that Batch will download on all subtasks. CommonResourceFiles *[]ResourceFile `json:"commonResourceFiles,omitempty"` }
MultiInstanceSettings information about the settings required for multi-instance task.
type NameValuePair ¶
type NameValuePair struct { // Name - Gets or sets the name in the name-value pair. Name *string `json:"name,omitempty"` // Value - Gets or sets the value in the name-value pair. Value *string `json:"value,omitempty"` }
NameValuePair represents a name-value pair.
type NodeDisableSchedulingParameter ¶
type NodeDisableSchedulingParameter struct { // NodeDisableSchedulingOption - Gets or sets what to do with currently running tasks when disable task scheduling on the compute node. The default value is requeue. Possible values include: 'DisableComputeNodeSchedulingOptionRequeue', 'DisableComputeNodeSchedulingOptionTerminate', 'DisableComputeNodeSchedulingOptionTaskcompletion' NodeDisableSchedulingOption DisableComputeNodeSchedulingOption `json:"nodeDisableSchedulingOption,omitempty"` }
NodeDisableSchedulingParameter parameters for a ComputeNodeOperations.DisableScheduling request.
type NodeFile ¶
type NodeFile struct { // Name - Gets or sets the file path. Name *string `json:"name,omitempty"` // URL - Gets or sets the URL of the file. URL *string `json:"url,omitempty"` // IsDirectory - Gets or sets whether the object represents a directory. IsDirectory *bool `json:"isDirectory,omitempty"` // Properties - Gets or sets the file properties. Properties *FileProperties `json:"properties,omitempty"` }
NodeFile information about a file or directory on a compute node.
type NodeFileListResult ¶
type NodeFileListResult struct { autorest.Response `json:"-"` // Value - Gets or sets the list of files. Value *[]NodeFile `json:"value,omitempty"` // OdataNextLink - Gets or sets the URL to get the next set of results. OdataNextLink *string `json:"odata.nextLink,omitempty"` }
NodeFileListResult response to a NodeFileOperations.ListFromComputeNode or NodeFileOperations.ListFromTask request.
func (NodeFileListResult) IsEmpty ¶
func (nflr NodeFileListResult) IsEmpty() bool
IsEmpty returns true if the ListResult contains no values.
type NodeFileListResultIterator ¶
type NodeFileListResultIterator struct {
// contains filtered or unexported fields
}
NodeFileListResultIterator provides access to a complete listing of NodeFile values.
func (*NodeFileListResultIterator) Next ¶
func (iter *NodeFileListResultIterator) Next() error
Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.
func (NodeFileListResultIterator) NotDone ¶
func (iter NodeFileListResultIterator) NotDone() bool
NotDone returns true if the enumeration should be started or is not yet complete.
func (NodeFileListResultIterator) Response ¶
func (iter NodeFileListResultIterator) Response() NodeFileListResult
Response returns the raw server response from the last page request.
func (NodeFileListResultIterator) Value ¶
func (iter NodeFileListResultIterator) Value() NodeFile
Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.
type NodeFileListResultPage ¶
type NodeFileListResultPage struct {
// contains filtered or unexported fields
}
NodeFileListResultPage contains a page of NodeFile values.
func (*NodeFileListResultPage) Next ¶
func (page *NodeFileListResultPage) Next() error
Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.
func (NodeFileListResultPage) NotDone ¶
func (page NodeFileListResultPage) NotDone() bool
NotDone returns true if the page enumeration should be started or is not yet complete.
func (NodeFileListResultPage) Response ¶
func (page NodeFileListResultPage) Response() NodeFileListResult
Response returns the raw server response from the last page request.
func (NodeFileListResultPage) Values ¶
func (page NodeFileListResultPage) Values() []NodeFile
Values returns the slice of values for the current page or nil if there are no values.
type NodeRebootParameter ¶
type NodeRebootParameter struct { // NodeRebootOption - Sets when to reboot the compute node and what to do with currently running tasks. The default value is requeue. Possible values include: 'ComputeNodeRebootOptionRequeue', 'ComputeNodeRebootOptionTerminate', 'ComputeNodeRebootOptionTaskcompletion', 'ComputeNodeRebootOptionRetaineddata' NodeRebootOption ComputeNodeRebootOption `json:"nodeRebootOption,omitempty"` }
NodeRebootParameter parameters for a ComputeNodeOperations.Reboot request.
type NodeReimageParameter ¶
type NodeReimageParameter struct { // NodeReimageOption - Sets when to reimage the compute node and what to do with currently running tasks. The default value is requeue. Possible values include: 'ComputeNodeReimageOptionRequeue', 'ComputeNodeReimageOptionTerminate', 'ComputeNodeReimageOptionTaskcompletion', 'ComputeNodeReimageOptionRetaineddata' NodeReimageOption ComputeNodeReimageOption `json:"nodeReimageOption,omitempty"` }
NodeReimageParameter parameters for a ComputeNodeOperations.Reimage request.
type NodeRemoveParameter ¶
type NodeRemoveParameter struct { // NodeList - Sets a list containing the id of the compute nodes to be removed from the specified pool. NodeList *[]string `json:"nodeList,omitempty"` // ResizeTimeout - Sets the timeout for removal of compute nodes to the pool. The default value is 10 minutes. ResizeTimeout *string `json:"resizeTimeout,omitempty"` // NodeDeallocationOption - Sets when compute nodes may be removed from the pool. Possible values include: 'Requeue', 'Terminate', 'Taskcompletion', 'Retaineddata' NodeDeallocationOption ComputeNodeDeallocationOption `json:"nodeDeallocationOption,omitempty"` }
NodeRemoveParameter parameters for a ComputeNodeOperations.Remove request.
type NodeUpdateUserParameter ¶
type NodeUpdateUserParameter struct { // Password - Sets the password of the account. Password *string `json:"password,omitempty"` // ExpiryTime - Sets the time at which the account should expire. If omitted, the default is 1 day from the current time. ExpiryTime *date.Time `json:"expiryTime,omitempty"` }
NodeUpdateUserParameter parameters for a ComputeNodeOperations.UpdateUser request.
type PoolAddParameter ¶
type PoolAddParameter struct { // ID - Gets or sets a string that uniquely identifies the pool within the account. The id can contain any combination of alphanumeric characters including hyphens and underscores, and cannot contain more than 64 characters. ID *string `json:"id,omitempty"` // DisplayName - Gets or sets the display name for the pool. DisplayName *string `json:"displayName,omitempty"` // VMSize - Gets or sets the size of virtual machines in the pool. All VMs in a pool are the same size. VMSize *string `json:"vmSize,omitempty"` // OsFamily - Gets or sets the Azure Guest OS family to be installed on the virtual machines in the pool. OsFamily *string `json:"osFamily,omitempty"` // TargetOSVersion - Gets or sets the Azure Guest OS version to be installed on the virtual machines in the pool. The default value is * which specifies the latest operating system version for the specified family. TargetOSVersion *string `json:"targetOSVersion,omitempty"` // ResizeTimeout - Gets or sets the timeout for allocation of compute nodes to the pool. In a Get Pool operation, this is the timeout for the most recent resize operation. The default value is 10 minutes. ResizeTimeout *string `json:"resizeTimeout,omitempty"` // TargetDedicated - Gets or sets the desired number of compute nodes in the pool. This property must have the default value if EnableAutoScale is true. It is required if EnableAutoScale is false. TargetDedicated *int32 `json:"targetDedicated,omitempty"` // EnableAutoScale - Gets or sets whether the pool size should automatically adjust over time. If true, the AutoScaleFormula property must be set. If false, the TargetDedicated property must be set. EnableAutoScale *bool `json:"enableAutoScale,omitempty"` // AutoScaleFormula - Gets or sets a formula for the desired number of compute nodes in the pool. AutoScaleFormula *string `json:"autoScaleFormula,omitempty"` // AutoScaleEvaluationInterval - Gets or sets a time interval for the desired autoscale evaluation period in the pool. AutoScaleEvaluationInterval *string `json:"autoScaleEvaluationInterval,omitempty"` // EnableInterNodeCommunication - Gets or sets whether the pool permits direct communication between nodes. EnableInterNodeCommunication *bool `json:"enableInterNodeCommunication,omitempty"` // StartTask - Gets or sets a task specified to run on each compute node as it joins the pool. StartTask *StartTask `json:"startTask,omitempty"` // CertificateReferences - Gets or sets the list of certificates to be installed on each compute node in the pool. CertificateReferences *[]CertificateReference `json:"certificateReferences,omitempty"` // ApplicationPackageReferences - Gets or sets the list of application packages to be installed on each compute node in the pool. ApplicationPackageReferences *[]ApplicationPackageReference `json:"applicationPackageReferences,omitempty"` // MaxTasksPerNode - Gets or sets the maximum number of tasks that can run concurrently on a single compute node in the pool. MaxTasksPerNode *int32 `json:"maxTasksPerNode,omitempty"` // TaskSchedulingPolicy - Gets or sets how the Batch service distributes tasks between compute nodes in the pool. TaskSchedulingPolicy *TaskSchedulingPolicy `json:"taskSchedulingPolicy,omitempty"` // Metadata - Gets or sets a list of name-value pairs associated with the pool as metadata. Metadata *[]MetadataItem `json:"metadata,omitempty"` }
PoolAddParameter a pool in the Azure Batch service to add.
type PoolClient ¶
type PoolClient struct {
BaseClient
}
PoolClient is the a client for issuing REST requests to the Azure Batch service.
func NewPoolClient ¶
func NewPoolClient() PoolClient
NewPoolClient creates an instance of the PoolClient client.
func NewPoolClientWithBaseURI ¶
func NewPoolClientWithBaseURI(baseURI string) PoolClient
NewPoolClientWithBaseURI creates an instance of the PoolClient client.
func (PoolClient) Add ¶
func (client PoolClient) Add(ctx context.Context, pool PoolAddParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result autorest.Response, err error)
Add adds a pool to the specified account.
pool is specifies the pool to be added. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (PoolClient) AddPreparer ¶
func (client PoolClient) AddPreparer(ctx context.Context, pool PoolAddParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
AddPreparer prepares the Add request.
func (PoolClient) AddResponder ¶
AddResponder handles the response to the Add request. The method always closes the http.Response Body.
func (PoolClient) AddSender ¶
AddSender sends the Add request. The method will close the http.Response Body if it receives an error.
func (PoolClient) Delete ¶
func (client PoolClient) Delete(ctx context.Context, poolID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
Delete deletes a pool from the specified account.
poolID is the id of the pool to delete. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (PoolClient) DeletePreparer ¶
func (client PoolClient) DeletePreparer(ctx context.Context, poolID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (PoolClient) DeleteResponder ¶
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (PoolClient) DeleteSender ¶
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (PoolClient) DisableAutoScale ¶
func (client PoolClient) DisableAutoScale(ctx context.Context, poolID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result autorest.Response, err error)
DisableAutoScale disables automatic scaling for a pool.
poolID is the id of the pool on which to disable automatic scaling. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (PoolClient) DisableAutoScalePreparer ¶
func (client PoolClient) DisableAutoScalePreparer(ctx context.Context, poolID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
DisableAutoScalePreparer prepares the DisableAutoScale request.
func (PoolClient) DisableAutoScaleResponder ¶
func (client PoolClient) DisableAutoScaleResponder(resp *http.Response) (result autorest.Response, err error)
DisableAutoScaleResponder handles the response to the DisableAutoScale request. The method always closes the http.Response Body.
func (PoolClient) DisableAutoScaleSender ¶
DisableAutoScaleSender sends the DisableAutoScale request. The method will close the http.Response Body if it receives an error.
func (PoolClient) EnableAutoScale ¶
func (client PoolClient) EnableAutoScale(ctx context.Context, poolID string, poolEnableAutoScaleParameter PoolEnableAutoScaleParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
EnableAutoScale enables automatic scaling for a pool.
poolID is the id of the pool on which to enable automatic scaling. poolEnableAutoScaleParameter is the parameters for the request. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (PoolClient) EnableAutoScalePreparer ¶
func (client PoolClient) EnableAutoScalePreparer(ctx context.Context, poolID string, poolEnableAutoScaleParameter PoolEnableAutoScaleParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
EnableAutoScalePreparer prepares the EnableAutoScale request.
func (PoolClient) EnableAutoScaleResponder ¶
func (client PoolClient) EnableAutoScaleResponder(resp *http.Response) (result autorest.Response, err error)
EnableAutoScaleResponder handles the response to the EnableAutoScale request. The method always closes the http.Response Body.
func (PoolClient) EnableAutoScaleSender ¶
EnableAutoScaleSender sends the EnableAutoScale request. The method will close the http.Response Body if it receives an error.
func (PoolClient) EvaluateAutoScale ¶
func (client PoolClient) EvaluateAutoScale(ctx context.Context, poolID string, poolEvaluateAutoScaleParameter PoolEvaluateAutoScaleParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result AutoScaleRun, err error)
EvaluateAutoScale gets the result of evaluating an automatic scaling formula on the pool.
poolID is the id of the pool on which to evaluate the automatic scaling formula. poolEvaluateAutoScaleParameter is the parameters for the request. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (PoolClient) EvaluateAutoScalePreparer ¶
func (client PoolClient) EvaluateAutoScalePreparer(ctx context.Context, poolID string, poolEvaluateAutoScaleParameter PoolEvaluateAutoScaleParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
EvaluateAutoScalePreparer prepares the EvaluateAutoScale request.
func (PoolClient) EvaluateAutoScaleResponder ¶
func (client PoolClient) EvaluateAutoScaleResponder(resp *http.Response) (result AutoScaleRun, err error)
EvaluateAutoScaleResponder handles the response to the EvaluateAutoScale request. The method always closes the http.Response Body.
func (PoolClient) EvaluateAutoScaleSender ¶
EvaluateAutoScaleSender sends the EvaluateAutoScale request. The method will close the http.Response Body if it receives an error.
func (PoolClient) Exists ¶
func (client PoolClient) Exists(ctx context.Context, poolID string, selectParameter string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
Exists gets basic properties of a pool.
poolID is the id of the pool to get. selectParameter is sets an OData $select clause. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (PoolClient) ExistsPreparer ¶
func (client PoolClient) ExistsPreparer(ctx context.Context, poolID string, selectParameter string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
ExistsPreparer prepares the Exists request.
func (PoolClient) ExistsResponder ¶
ExistsResponder handles the response to the Exists request. The method always closes the http.Response Body.
func (PoolClient) ExistsSender ¶
ExistsSender sends the Exists request. The method will close the http.Response Body if it receives an error.
func (PoolClient) Get ¶
func (client PoolClient) Get(ctx context.Context, poolID string, selectParameter string, expand string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result CloudPool, err error)
Get gets information about the specified pool.
poolID is the id of the pool to get. selectParameter is sets an OData $select clause. expand is sets an OData $expand clause. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (PoolClient) GetAllPoolsLifetimeStatistics ¶
func (client PoolClient) GetAllPoolsLifetimeStatistics(ctx context.Context, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result PoolStatistics, err error)
GetAllPoolsLifetimeStatistics gets lifetime summary statistics for all of the pools in the specified account. Statistics are aggregated across all pools that have ever existed in the account, from account creation to the last update time of the statistics.
timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (PoolClient) GetAllPoolsLifetimeStatisticsPreparer ¶
func (client PoolClient) GetAllPoolsLifetimeStatisticsPreparer(ctx context.Context, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
GetAllPoolsLifetimeStatisticsPreparer prepares the GetAllPoolsLifetimeStatistics request.
func (PoolClient) GetAllPoolsLifetimeStatisticsResponder ¶
func (client PoolClient) GetAllPoolsLifetimeStatisticsResponder(resp *http.Response) (result PoolStatistics, err error)
GetAllPoolsLifetimeStatisticsResponder handles the response to the GetAllPoolsLifetimeStatistics request. The method always closes the http.Response Body.
func (PoolClient) GetAllPoolsLifetimeStatisticsSender ¶
func (client PoolClient) GetAllPoolsLifetimeStatisticsSender(req *http.Request) (*http.Response, error)
GetAllPoolsLifetimeStatisticsSender sends the GetAllPoolsLifetimeStatistics request. The method will close the http.Response Body if it receives an error.
func (PoolClient) GetPreparer ¶
func (client PoolClient) GetPreparer(ctx context.Context, poolID string, selectParameter string, expand string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
GetPreparer prepares the Get request.
func (PoolClient) GetResponder ¶
func (client PoolClient) GetResponder(resp *http.Response) (result CloudPool, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (PoolClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (PoolClient) List ¶
func (client PoolClient) List(ctx context.Context, filter string, selectParameter string, expand string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result CloudPoolListResultPage, err error)
List lists all of the pools in the specified account.
filter is sets an OData $filter clause. selectParameter is sets an OData $select clause. expand is sets an OData $expand clause. maxResults is sets the maximum number of items to return in the response. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (PoolClient) ListComplete ¶
func (client PoolClient) ListComplete(ctx context.Context, filter string, selectParameter string, expand string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result CloudPoolListResultIterator, err error)
ListComplete enumerates all values, automatically crossing page boundaries as required.
func (PoolClient) ListPoolUsageMetrics ¶
func (client PoolClient) ListPoolUsageMetrics(ctx context.Context, startTime *date.Time, endTime *date.Time, filter string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result PoolListPoolUsageMetricsResultPage, err error)
ListPoolUsageMetrics lists the usage metrics, aggregated by pool across individual time intervals, for the specified account.
startTime is the earliest time from which to include metrics. This must be at least two and a half hours before the current time. endTime is the latest time from which to include metrics. This must be at least two hours before the current time. filter is sets an OData $filter clause. maxResults is sets the maximum number of items to return in the response. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (PoolClient) ListPoolUsageMetricsComplete ¶
func (client PoolClient) ListPoolUsageMetricsComplete(ctx context.Context, startTime *date.Time, endTime *date.Time, filter string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result PoolListPoolUsageMetricsResultIterator, err error)
ListPoolUsageMetricsComplete enumerates all values, automatically crossing page boundaries as required.
func (PoolClient) ListPoolUsageMetricsPreparer ¶
func (client PoolClient) ListPoolUsageMetricsPreparer(ctx context.Context, startTime *date.Time, endTime *date.Time, filter string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
ListPoolUsageMetricsPreparer prepares the ListPoolUsageMetrics request.
func (PoolClient) ListPoolUsageMetricsResponder ¶
func (client PoolClient) ListPoolUsageMetricsResponder(resp *http.Response) (result PoolListPoolUsageMetricsResult, err error)
ListPoolUsageMetricsResponder handles the response to the ListPoolUsageMetrics request. The method always closes the http.Response Body.
func (PoolClient) ListPoolUsageMetricsSender ¶
ListPoolUsageMetricsSender sends the ListPoolUsageMetrics request. The method will close the http.Response Body if it receives an error.
func (PoolClient) ListPreparer ¶
func (client PoolClient) ListPreparer(ctx context.Context, filter string, selectParameter string, expand string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
ListPreparer prepares the List request.
func (PoolClient) ListResponder ¶
func (client PoolClient) ListResponder(resp *http.Response) (result CloudPoolListResult, err error)
ListResponder handles the response to the List request. The method always closes the http.Response Body.
func (PoolClient) ListSender ¶
ListSender sends the List request. The method will close the http.Response Body if it receives an error.
func (PoolClient) Patch ¶
func (client PoolClient) Patch(ctx context.Context, poolID string, poolPatchParameter PoolPatchParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
Patch updates the properties of a pool.
poolID is the id of the pool to update. poolPatchParameter is the parameters for the request. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (PoolClient) PatchPreparer ¶
func (client PoolClient) PatchPreparer(ctx context.Context, poolID string, poolPatchParameter PoolPatchParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
PatchPreparer prepares the Patch request.
func (PoolClient) PatchResponder ¶
PatchResponder handles the response to the Patch request. The method always closes the http.Response Body.
func (PoolClient) PatchSender ¶
PatchSender sends the Patch request. The method will close the http.Response Body if it receives an error.
func (PoolClient) RemoveNodes ¶
func (client PoolClient) RemoveNodes(ctx context.Context, poolID string, nodeRemoveParameter NodeRemoveParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
RemoveNodes removes compute nodes from the specified pool.
poolID is the id of the pool from which you want to remove nodes. nodeRemoveParameter is the parameters for the request. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (PoolClient) RemoveNodesPreparer ¶
func (client PoolClient) RemoveNodesPreparer(ctx context.Context, poolID string, nodeRemoveParameter NodeRemoveParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
RemoveNodesPreparer prepares the RemoveNodes request.
func (PoolClient) RemoveNodesResponder ¶
func (client PoolClient) RemoveNodesResponder(resp *http.Response) (result autorest.Response, err error)
RemoveNodesResponder handles the response to the RemoveNodes request. The method always closes the http.Response Body.
func (PoolClient) RemoveNodesSender ¶
RemoveNodesSender sends the RemoveNodes request. The method will close the http.Response Body if it receives an error.
func (PoolClient) Resize ¶
func (client PoolClient) Resize(ctx context.Context, poolID string, poolResizeParameter PoolResizeParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
Resize changes the number of compute nodes that are assigned to a pool.
poolID is the id of the pool to resize. poolResizeParameter is the parameters for the request. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (PoolClient) ResizePreparer ¶
func (client PoolClient) ResizePreparer(ctx context.Context, poolID string, poolResizeParameter PoolResizeParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
ResizePreparer prepares the Resize request.
func (PoolClient) ResizeResponder ¶
ResizeResponder handles the response to the Resize request. The method always closes the http.Response Body.
func (PoolClient) ResizeSender ¶
ResizeSender sends the Resize request. The method will close the http.Response Body if it receives an error.
func (PoolClient) StopResize ¶
func (client PoolClient) StopResize(ctx context.Context, poolID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
StopResize stops an ongoing resize operation on the pool. This does not restore the pool to its previous state before the resize operation: it only stops any further changes being made, and the pool maintains its current state.
poolID is the id of the pool whose resizing you want to stop. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (PoolClient) StopResizePreparer ¶
func (client PoolClient) StopResizePreparer(ctx context.Context, poolID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
StopResizePreparer prepares the StopResize request.
func (PoolClient) StopResizeResponder ¶
func (client PoolClient) StopResizeResponder(resp *http.Response) (result autorest.Response, err error)
StopResizeResponder handles the response to the StopResize request. The method always closes the http.Response Body.
func (PoolClient) StopResizeSender ¶
StopResizeSender sends the StopResize request. The method will close the http.Response Body if it receives an error.
func (PoolClient) UpdateProperties ¶
func (client PoolClient) UpdateProperties(ctx context.Context, poolID string, poolUpdatePropertiesParameter PoolUpdatePropertiesParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result autorest.Response, err error)
UpdateProperties updates the properties of a pool.
poolID is the id of the pool to update. poolUpdatePropertiesParameter is the parameters for the request. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (PoolClient) UpdatePropertiesPreparer ¶
func (client PoolClient) UpdatePropertiesPreparer(ctx context.Context, poolID string, poolUpdatePropertiesParameter PoolUpdatePropertiesParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
UpdatePropertiesPreparer prepares the UpdateProperties request.
func (PoolClient) UpdatePropertiesResponder ¶
func (client PoolClient) UpdatePropertiesResponder(resp *http.Response) (result autorest.Response, err error)
UpdatePropertiesResponder handles the response to the UpdateProperties request. The method always closes the http.Response Body.
func (PoolClient) UpdatePropertiesSender ¶
UpdatePropertiesSender sends the UpdateProperties request. The method will close the http.Response Body if it receives an error.
func (PoolClient) UpgradeOS ¶
func (client PoolClient) UpgradeOS(ctx context.Context, poolID string, poolUpgradeOSParameter PoolUpgradeOSParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
UpgradeOS upgrades the operating system of the specified pool.
poolID is the id of the pool to upgrade. poolUpgradeOSParameter is the parameters for the request. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (PoolClient) UpgradeOSPreparer ¶
func (client PoolClient) UpgradeOSPreparer(ctx context.Context, poolID string, poolUpgradeOSParameter PoolUpgradeOSParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
UpgradeOSPreparer prepares the UpgradeOS request.
func (PoolClient) UpgradeOSResponder ¶
func (client PoolClient) UpgradeOSResponder(resp *http.Response) (result autorest.Response, err error)
UpgradeOSResponder handles the response to the UpgradeOS request. The method always closes the http.Response Body.
func (PoolClient) UpgradeOSSender ¶
UpgradeOSSender sends the UpgradeOS request. The method will close the http.Response Body if it receives an error.
type PoolEnableAutoScaleParameter ¶
type PoolEnableAutoScaleParameter struct { // AutoScaleFormula - Sets the formula for the desired number of compute nodes in the pool. AutoScaleFormula *string `json:"autoScaleFormula,omitempty"` // AutoScaleEvaluationInterval - Gets or sets a time interval for the desired autoscale evaluation period in the pool. AutoScaleEvaluationInterval *string `json:"autoScaleEvaluationInterval,omitempty"` }
PoolEnableAutoScaleParameter parameters for a CloudPoolOperations.EnableAutoScale request.
type PoolEvaluateAutoScaleParameter ¶
type PoolEvaluateAutoScaleParameter struct { // AutoScaleFormula - Sets a formula for the desired number of compute nodes in the pool. AutoScaleFormula *string `json:"autoScaleFormula,omitempty"` }
PoolEvaluateAutoScaleParameter parameters for a CloudJobOperations.EvaluateAutoScale request.
type PoolInformation ¶
type PoolInformation struct { // PoolID - Gets or sets the id of an existing pool. All the tasks of the job will run on the specified pool. You must specify either PoolId or AutoPoolSpecification, but not both. PoolID *string `json:"poolId,omitempty"` // AutoPoolSpecification - Gets or sets characteristics for a temporary 'auto pool.' The Batch service will create this auto pool and run all the tasks of the job on it, and will delete the pool once the job has completed. You must specify either PoolId or AutoPoolSpecification, but not both. AutoPoolSpecification *AutoPoolSpecification `json:"autoPoolSpecification,omitempty"` }
PoolInformation specifies how a job should be assigned to a pool.
type PoolLifetimeOption ¶
type PoolLifetimeOption string
PoolLifetimeOption enumerates the values for pool lifetime option.
const ( // PoolLifetimeOptionJob ... PoolLifetimeOptionJob PoolLifetimeOption = "job" // PoolLifetimeOptionJobschedule ... PoolLifetimeOptionJobschedule PoolLifetimeOption = "jobschedule" // PoolLifetimeOptionUnmapped ... PoolLifetimeOptionUnmapped PoolLifetimeOption = "unmapped" )
type PoolListPoolUsageMetricsResult ¶
type PoolListPoolUsageMetricsResult struct { autorest.Response `json:"-"` // Value - Gets or sets the pool usage metrics data. Value *[]PoolUsageMetrics `json:"value,omitempty"` // OdataNextLink - Gets or sets the URL to get the next set of results. OdataNextLink *string `json:"odata.nextLink,omitempty"` }
PoolListPoolUsageMetricsResult response to an AccountOperations.ListPoolUsageMetrics request.
func (PoolListPoolUsageMetricsResult) IsEmpty ¶
func (plpumr PoolListPoolUsageMetricsResult) IsEmpty() bool
IsEmpty returns true if the ListResult contains no values.
type PoolListPoolUsageMetricsResultIterator ¶
type PoolListPoolUsageMetricsResultIterator struct {
// contains filtered or unexported fields
}
PoolListPoolUsageMetricsResultIterator provides access to a complete listing of PoolUsageMetrics values.
func (*PoolListPoolUsageMetricsResultIterator) Next ¶
func (iter *PoolListPoolUsageMetricsResultIterator) Next() error
Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.
func (PoolListPoolUsageMetricsResultIterator) NotDone ¶
func (iter PoolListPoolUsageMetricsResultIterator) NotDone() bool
NotDone returns true if the enumeration should be started or is not yet complete.
func (PoolListPoolUsageMetricsResultIterator) Response ¶
func (iter PoolListPoolUsageMetricsResultIterator) Response() PoolListPoolUsageMetricsResult
Response returns the raw server response from the last page request.
func (PoolListPoolUsageMetricsResultIterator) Value ¶
func (iter PoolListPoolUsageMetricsResultIterator) Value() PoolUsageMetrics
Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.
type PoolListPoolUsageMetricsResultPage ¶
type PoolListPoolUsageMetricsResultPage struct {
// contains filtered or unexported fields
}
PoolListPoolUsageMetricsResultPage contains a page of PoolUsageMetrics values.
func (*PoolListPoolUsageMetricsResultPage) Next ¶
func (page *PoolListPoolUsageMetricsResultPage) Next() error
Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.
func (PoolListPoolUsageMetricsResultPage) NotDone ¶
func (page PoolListPoolUsageMetricsResultPage) NotDone() bool
NotDone returns true if the page enumeration should be started or is not yet complete.
func (PoolListPoolUsageMetricsResultPage) Response ¶
func (page PoolListPoolUsageMetricsResultPage) Response() PoolListPoolUsageMetricsResult
Response returns the raw server response from the last page request.
func (PoolListPoolUsageMetricsResultPage) Values ¶
func (page PoolListPoolUsageMetricsResultPage) Values() []PoolUsageMetrics
Values returns the slice of values for the current page or nil if there are no values.
type PoolPatchParameter ¶
type PoolPatchParameter struct { // StartTask - Sets a task to run on each compute node as it joins the pool. If omitted, any existing start task is left unchanged. StartTask *StartTask `json:"startTask,omitempty"` // CertificateReferences - Sets a list of certificates to be installed on each compute node in the pool. If omitted, any existing certificate references are left unchanged. CertificateReferences *[]CertificateReference `json:"certificateReferences,omitempty"` // ApplicationPackageReferences - Sets a list of application packages to be installed on each compute node in the pool. If omitted, any existing application package references are left unchanged. ApplicationPackageReferences *[]ApplicationPackageReference `json:"applicationPackageReferences,omitempty"` // Metadata - Sets a list of name-value pairs associated with the pool as metadata. If omitted, any existing metadata is left unchanged. Metadata *[]MetadataItem `json:"metadata,omitempty"` }
PoolPatchParameter parameters for a CloudPoolOperations.Patch request.
type PoolResizeParameter ¶
type PoolResizeParameter struct { // TargetDedicated - Sets the desired number of compute nodes in the pool. TargetDedicated *int32 `json:"targetDedicated,omitempty"` // ResizeTimeout - Sets the timeout for allocation of compute nodes to the pool or removal of compute nodes from the pool. The default value is 10 minutes. ResizeTimeout *string `json:"resizeTimeout,omitempty"` // NodeDeallocationOption - Sets when nodes may be removed from the pool, if the pool size is decreasing. Possible values include: 'Requeue', 'Terminate', 'Taskcompletion', 'Retaineddata' NodeDeallocationOption ComputeNodeDeallocationOption `json:"nodeDeallocationOption,omitempty"` }
PoolResizeParameter parameters for a CloudPoolOperations.Resize request.
type PoolSpecification ¶
type PoolSpecification struct { // DisplayName - Gets or sets the display name for the pool. DisplayName *string `json:"displayName,omitempty"` // VMSize - Gets or sets the size of the virtual machines in the pool. All VMs in a pool are the same size. VMSize *string `json:"vmSize,omitempty"` // OsFamily - Gets or sets the Azure Guest OS family to be installed on the virtual machines in the pool. OsFamily *string `json:"osFamily,omitempty"` // TargetOSVersion - Gets or sets the Azure Guest OS version to be installed on the virtual machines in the pool. TargetOSVersion *string `json:"targetOSVersion,omitempty"` // MaxTasksPerNode - Gets or sets the maximum number of tasks that can run concurrently on a single compute node in the pool. MaxTasksPerNode *int32 `json:"maxTasksPerNode,omitempty"` // TaskSchedulingPolicy - Gets or sets how tasks are distributed among compute nodes in the pool. TaskSchedulingPolicy *TaskSchedulingPolicy `json:"taskSchedulingPolicy,omitempty"` // ResizeTimeout - Gets or sets the timeout for allocation of compute nodes to the pool. ResizeTimeout *string `json:"resizeTimeout,omitempty"` // TargetDedicated - Gets or sets the desired number of compute nodes in the pool. TargetDedicated *int32 `json:"targetDedicated,omitempty"` // EnableAutoScale - Gets or sets whether the pool size should automatically adjust over time. EnableAutoScale *bool `json:"enableAutoScale,omitempty"` // AutoScaleFormula - Gets or sets the formula for the desired number of compute nodes in the pool. AutoScaleFormula *string `json:"autoScaleFormula,omitempty"` // AutoScaleEvaluationInterval - Gets or sets a time interval for the desired AutoScale evaluation period in the pool. AutoScaleEvaluationInterval *string `json:"autoScaleEvaluationInterval,omitempty"` // EnableInterNodeCommunication - Gets or sets whether the pool permits direct communication between nodes. EnableInterNodeCommunication *bool `json:"enableInterNodeCommunication,omitempty"` // StartTask - Gets or sets a task to run on each compute node as it joins the pool. The task runs when the node is added to the pool or when the node is restarted. StartTask *StartTask `json:"startTask,omitempty"` // CertificateReferences - Gets or sets a list of certificates to be installed on each compute node in the pool. CertificateReferences *[]CertificateReference `json:"certificateReferences,omitempty"` // ApplicationPackageReferences - Gets or sets the list of application packages to be installed on each compute node in the pool. ApplicationPackageReferences *[]ApplicationPackageReference `json:"applicationPackageReferences,omitempty"` // Metadata - Gets or sets a list of name-value pairs associated with the pool as metadata. Metadata *[]MetadataItem `json:"metadata,omitempty"` }
PoolSpecification specification for creating a new pool.
type PoolStatistics ¶
type PoolStatistics struct { autorest.Response `json:"-"` // URL - Gets or sets the URL for the statistics. URL *string `json:"url,omitempty"` // StartTime - Gets or sets the start time of the time range covered by the statistics. StartTime *date.Time `json:"startTime,omitempty"` // LastUpdateTime - Gets or sets the time at which the statistics were last updated. All statistics are limited to the range between startTime and lastUpdateTime. LastUpdateTime *date.Time `json:"lastUpdateTime,omitempty"` // UsageStats - Gets or sets statistics related to pool usage information, such as the amount of core-time used. UsageStats *UsageStatistics `json:"usageStats,omitempty"` // ResourceStats - Gets or sets statistics related to resource consumption by compute nodes in the pool. ResourceStats *ResourceStatistics `json:"resourceStats,omitempty"` }
PoolStatistics contains utilization and resource usage statistics for the lifetime of a pool.
type PoolUpdatePropertiesParameter ¶
type PoolUpdatePropertiesParameter struct { // StartTask - Sets a task to run on each compute node as it joins the pool. If omitted, any existing start task is removed from the pool. StartTask *StartTask `json:"startTask,omitempty"` // CertificateReferences - Sets a list of certificates to be installed on each compute node in the pool. If you specify an empty collection, any existing certificate references are removed from the pool. CertificateReferences *[]CertificateReference `json:"certificateReferences,omitempty"` // ApplicationPackageReferences - Sets a list of application packages to be installed on each compute node in the pool. If you specify an empty collection, any existing application packages references are removed from the pool. ApplicationPackageReferences *[]ApplicationPackageReference `json:"applicationPackageReferences,omitempty"` // Metadata - Sets a list of name-value pairs associated with the pool as metadata. If you specify an empty collection, any existing metadata is removed from the pool. Metadata *[]MetadataItem `json:"metadata,omitempty"` }
PoolUpdatePropertiesParameter parameters for a CloudPoolOperations.UpdateProperties request.
type PoolUpgradeOSParameter ¶
type PoolUpgradeOSParameter struct { // TargetOSVersion - Sets the Azure Guest OS version to be installed on the virtual machines in the pool. TargetOSVersion *string `json:"targetOSVersion,omitempty"` }
PoolUpgradeOSParameter parameters for a CloudPoolOperations.UpgradeOS request.
type PoolUsageMetrics ¶
type PoolUsageMetrics struct { // PoolID - Gets or sets the id of the pool whose metrics are being aggregated. PoolID *string `json:"poolId,omitempty"` // StartTime - Gets or sets the start time of the aggregation interval. StartTime *date.Time `json:"startTime,omitempty"` // EndTime - Gets or sets the end time of the aggregation interval. EndTime *date.Time `json:"endTime,omitempty"` // VMSize - Gets or sets the size of virtual machines in the pool. All VMs in a pool are the same size. VMSize *string `json:"vmSize,omitempty"` // TotalCoreHours - Gets or sets the total core hours used in the pool during this aggregation interval. TotalCoreHours *float64 `json:"totalCoreHours,omitempty"` // DataIngressGiB - Gets or sets the cross data center network ingress in GiB to the pool during this interval. DataIngressGiB *float64 `json:"dataIngressGiB,omitempty"` // DataEgressGiB - Gets or sets the cross data center network egress in GiB from the pool during this interval. DataEgressGiB *float64 `json:"dataEgressGiB,omitempty"` }
PoolUsageMetrics usage metrics for a pool across an aggregation interval.
type ReadCloser ¶
type ReadCloser struct { autorest.Response `json:"-"` Value *io.ReadCloser `json:"value,omitempty"` }
ReadCloser ...
type RecentJob ¶
type RecentJob struct { // ID - Gets or sets the id of the job. ID *string `json:"id,omitempty"` // URL - Gets or sets the URL of the job. URL *string `json:"url,omitempty"` }
RecentJob information about the most recent job to run under the job schedule.
type ResizeError ¶
type ResizeError struct { // Code - Gets or sets an identifier for the pool resize error. Codes are invariant and are intended to be consumed programmatically. Code *string `json:"code,omitempty"` // Message - Gets or sets a message describing the pool resize error, intended to be suitable for display in a user interface. Message *string `json:"message,omitempty"` // Values - Gets or sets a list of additional error details related to the pool resize error. Values *[]NameValuePair `json:"values,omitempty"` }
ResizeError an error that occurred when resizing a pool.
type ResourceFile ¶
type ResourceFile struct { // BlobSource - Gets or sets the URL of a blob in Azure storage. The Batch service downloads the blob to the specified file path. The URL must be readable using anonymous access. BlobSource *string `json:"blobSource,omitempty"` // FilePath - Gets or sets the location on the compute node to which the file should be downloaded. FilePath *string `json:"filePath,omitempty"` }
ResourceFile a file to be downloaded from Azure blob storage to a compute node.
type ResourceStatistics ¶
type ResourceStatistics struct { // StartTime - Gets or sets the start time of the time range covered by the statistics. StartTime *date.Time `json:"startTime,omitempty"` // LastUpdateTime - Gets or sets the time at which the statistics were last updated. All statistics are limited to the range between startTime and lastUpdateTime. LastUpdateTime *date.Time `json:"lastUpdateTime,omitempty"` // AvgCPUPercentage - Gets or sets the average CPU usage across all nodes in the pool (percentage per node). AvgCPUPercentage *float64 `json:"avgCPUPercentage,omitempty"` // AvgMemoryGiB - Gets or sets the average memory usage in GiB across all nodes in the pool. AvgMemoryGiB *float64 `json:"avgMemoryGiB,omitempty"` // PeakMemoryGiB - Gets or sets the peak memory usage in GiB across all nodes in the pool. PeakMemoryGiB *float64 `json:"peakMemoryGiB,omitempty"` // AvgDiskGiB - Gets or sets the average used disk space in GiB across all nodes in the pool. AvgDiskGiB *float64 `json:"avgDiskGiB,omitempty"` // PeakDiskGiB - Gets or sets the peak used disk space in GiB across all nodes in the pool. PeakDiskGiB *float64 `json:"peakDiskGiB,omitempty"` // DiskReadIOps - Gets or sets the total number of disk read operations across all nodes in the pool. DiskReadIOps *int64 `json:"diskReadIOps,omitempty"` // DiskWriteIOps - Gets or sets the total number of disk write operations across all nodes in the pool. DiskWriteIOps *int64 `json:"diskWriteIOps,omitempty"` // DiskReadGiB - Gets or sets the total amount of data in GiB of disk reads across all nodes in the pool. DiskReadGiB *float64 `json:"diskReadGiB,omitempty"` // DiskWriteGiB - Gets or sets the total amount of data in GiB of disk writes across all nodes in the pool. DiskWriteGiB *float64 `json:"diskWriteGiB,omitempty"` // NetworkReadGiB - Gets or sets the total amount of data in GiB of network reads across all nodes in the pool. NetworkReadGiB *float64 `json:"networkReadGiB,omitempty"` // NetworkWriteGiB - Gets or sets the total amount of data in GiB of network writes across all nodes in the pool. NetworkWriteGiB *float64 `json:"networkWriteGiB,omitempty"` }
ResourceStatistics statistics related to resource consumption by compute nodes in a pool.
type Schedule ¶
type Schedule struct { // DoNotRunUntil - Gets or sets the earliest time at which any job may be created under this job schedule. If you do not specify a doNotRunUntil time, the schedule becomes ready to create jobs immediately. DoNotRunUntil *date.Time `json:"doNotRunUntil,omitempty"` // DoNotRunAfter - Gets or sets a time after which no job will be created under this job schedule. The schedule will move to the completed state as soon as this deadline is past and there is no active job under this job schedule. DoNotRunAfter *date.Time `json:"doNotRunAfter,omitempty"` // StartWindow - Gets or sets the time interval, starting from the time at which the schedule indicates a job should be created, within which a job must be created. If a job is not created within the startWindow interval, then the 'opportunity' is lost; no job will be created until the next recurrence of the schedule. StartWindow *string `json:"startWindow,omitempty"` // RecurrenceInterval - Gets or sets the time interval between the start times of two successive jobs under the job schedule. A job schedule can have at most one active job under it at any given time. RecurrenceInterval *string `json:"recurrenceInterval,omitempty"` }
Schedule the schedule according to which jobs will be created
type SchedulingErrorCategory ¶
type SchedulingErrorCategory string
SchedulingErrorCategory enumerates the values for scheduling error category.
const ( // SchedulingErrorCategoryServererror ... SchedulingErrorCategoryServererror SchedulingErrorCategory = "servererror" // SchedulingErrorCategoryUnmapped ... SchedulingErrorCategoryUnmapped SchedulingErrorCategory = "unmapped" // SchedulingErrorCategoryUsererror ... SchedulingErrorCategoryUsererror SchedulingErrorCategory = "usererror" )
type SchedulingState ¶
type SchedulingState string
SchedulingState enumerates the values for scheduling state.
const ( // Disabled ... Disabled SchedulingState = "disabled" // Enabled ... Enabled SchedulingState = "enabled" )
type StartTask ¶
type StartTask struct { // CommandLine - Gets or sets the command line of the start task. CommandLine *string `json:"commandLine,omitempty"` // ResourceFiles - Gets or sets a list of files that Batch will download to the compute node before running the command line. ResourceFiles *[]ResourceFile `json:"resourceFiles,omitempty"` // EnvironmentSettings - Gets or sets a list of environment variable settings for the start task. EnvironmentSettings *[]EnvironmentSetting `json:"environmentSettings,omitempty"` // RunElevated - Gets or sets whether to run the start task in elevated mode. The default value is false. RunElevated *bool `json:"runElevated,omitempty"` // MaxTaskRetryCount - Gets or sets the maximum number of times the task may be retried. MaxTaskRetryCount *int32 `json:"maxTaskRetryCount,omitempty"` // WaitForSuccess - Gets or sets whether the Batch Service should wait for the start task to complete successfully (that is, to exit with exit code 0) before scheduling any tasks on the compute node. WaitForSuccess *bool `json:"waitForSuccess,omitempty"` }
StartTask a task defined on a pool and run by compute nodes when they join the pool.
type StartTaskInformation ¶
type StartTaskInformation struct { // State - Gets or sets the state of the start task on the compute node. Possible values include: 'StartTaskStateRunning', 'StartTaskStateCompleted' State StartTaskState `json:"state,omitempty"` // StartTime - Gets or sets the time at which the start task started running. StartTime *date.Time `json:"startTime,omitempty"` // EndTime - Gets or sets the time at which the start task stopped running. EndTime *date.Time `json:"endTime,omitempty"` // ExitCode - Gets or sets the exit code of the start task. ExitCode *int32 `json:"exitCode,omitempty"` // SchedulingError - Gets or sets any error encountered scheduling the start task. SchedulingError *TaskSchedulingError `json:"schedulingError,omitempty"` // RetryCount - Gets or sets the number of times the task has been retried by the Batch service. RetryCount *int32 `json:"retryCount,omitempty"` // LastRetryTime - Gets or sets the most recent time at which a retry of the task started running. LastRetryTime *date.Time `json:"lastRetryTime,omitempty"` }
StartTaskInformation information about a start task running on a compute node.
type StartTaskState ¶
type StartTaskState string
StartTaskState enumerates the values for start task state.
const ( // StartTaskStateCompleted ... StartTaskStateCompleted StartTaskState = "completed" // StartTaskStateRunning ... StartTaskStateRunning StartTaskState = "running" )
type SubtaskInformation ¶
type SubtaskInformation struct { // ID - Gets or sets the id of the subtask. ID *int32 `json:"id,omitempty"` // NodeInfo - Gets or sets information about the compute node on which the subtask ran. NodeInfo *ComputeNodeInformation `json:"nodeInfo,omitempty"` // StartTime - Gets or sets the time at which the subtask started running. If the subtask has been restarted or retried, this is the most recent time at which the subtask started running. StartTime *date.Time `json:"startTime,omitempty"` // EndTime - Gets or sets the time at which the subtask completed. This property is set only if the subtask is in the Completed state. EndTime *date.Time `json:"endTime,omitempty"` // ExitCode - Gets or sets the exit code of the subtask. This property is set only if the subtask is in the Completed state. ExitCode *int32 `json:"exitCode,omitempty"` // SchedulingError - Gets or sets details of any error encountered scheduling the subtask. SchedulingError *TaskSchedulingError `json:"schedulingError,omitempty"` // State - Gets or sets the current state of the subtask. Possible values include: 'TaskStateActive', 'TaskStatePreparing', 'TaskStateRunning', 'TaskStateCompleted' State TaskState `json:"state,omitempty"` // StateTransitionTime - Gets or sets the time at which the subtask entered its current state. StateTransitionTime *date.Time `json:"stateTransitionTime,omitempty"` // PreviousState - Gets or sets the previous state of the subtask. This property is not set if the subtask is in its initial Active state. Possible values include: 'TaskStateActive', 'TaskStatePreparing', 'TaskStateRunning', 'TaskStateCompleted' PreviousState TaskState `json:"previousState,omitempty"` // PreviousStateTransitionTime - Gets or sets the time at which the subtask entered its previous state. This property is not set if the subtask is in its initial Active state. PreviousStateTransitionTime *date.Time `json:"previousStateTransitionTime,omitempty"` }
SubtaskInformation information about an Azure Batch subtask.
type TaskAddParameter ¶
type TaskAddParameter struct { // ID - Gets or sets a string that uniquely identifies the task within the job. The id can contain any combination of alphanumeric characters including hyphens and underscores, and cannot contain more than 64 characters. ID *string `json:"id,omitempty"` // DisplayName - Gets or sets a display name for the task. DisplayName *string `json:"displayName,omitempty"` // CommandLine - Gets or sets the command line of the task. For multi-instance tasks, the command line is executed on the primary subtask after all the subtasks have finished executing the coordianation command line. CommandLine *string `json:"commandLine,omitempty"` // ResourceFiles - Gets or sets a list of files that Batch will download to the compute node before running the command line. For multi-instance tasks, the resource files will only be downloaded to the compute node on which the primary subtask is executed. ResourceFiles *[]ResourceFile `json:"resourceFiles,omitempty"` // EnvironmentSettings - Gets or sets a list of environment variable settings for the task. EnvironmentSettings *[]EnvironmentSetting `json:"environmentSettings,omitempty"` // AffinityInfo - Gets or sets a locality hint that can be used by the Batch service to select a compute node on which to start the new task. AffinityInfo *AffinityInformation `json:"affinityInfo,omitempty"` // Constraints - Gets or sets the execution constraints that apply to this task. Constraints *TaskConstraints `json:"constraints,omitempty"` // RunElevated - Gets or sets whether to run the task in elevated mode. RunElevated *bool `json:"runElevated,omitempty"` // MultiInstanceSettings - Gets or sets information about how to run the multi-instance task. MultiInstanceSettings *MultiInstanceSettings `json:"multiInstanceSettings,omitempty"` // DependsOn - Gets or sets any dependencies this task has. DependsOn *TaskDependencies `json:"dependsOn,omitempty"` }
TaskAddParameter an Azure Batch task to add.
type TaskClient ¶
type TaskClient struct {
BaseClient
}
TaskClient is the a client for issuing REST requests to the Azure Batch service.
func NewTaskClient ¶
func NewTaskClient() TaskClient
NewTaskClient creates an instance of the TaskClient client.
func NewTaskClientWithBaseURI ¶
func NewTaskClientWithBaseURI(baseURI string) TaskClient
NewTaskClientWithBaseURI creates an instance of the TaskClient client.
func (TaskClient) Add ¶
func (client TaskClient) Add(ctx context.Context, jobID string, task TaskAddParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result autorest.Response, err error)
Add adds a task to the specified job.
jobID is the id of the job to which the task is to be added. task is specifies the task to be added. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (TaskClient) AddPreparer ¶
func (client TaskClient) AddPreparer(ctx context.Context, jobID string, task TaskAddParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
AddPreparer prepares the Add request.
func (TaskClient) AddResponder ¶
AddResponder handles the response to the Add request. The method always closes the http.Response Body.
func (TaskClient) AddSender ¶
AddSender sends the Add request. The method will close the http.Response Body if it receives an error.
func (TaskClient) Delete ¶
func (client TaskClient) Delete(ctx context.Context, jobID string, taskID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
Delete deletes a task from the specified job.
jobID is the id of the job from which to delete the task. taskID is the id of the task to delete. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (TaskClient) DeletePreparer ¶
func (client TaskClient) DeletePreparer(ctx context.Context, jobID string, taskID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (TaskClient) DeleteResponder ¶
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (TaskClient) DeleteSender ¶
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (TaskClient) Get ¶
func (client TaskClient) Get(ctx context.Context, jobID string, taskID string, selectParameter string, expand string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result CloudTask, err error)
Get gets information about the specified task.
jobID is the id of the job that contains the task. taskID is the id of the task to get information about. selectParameter is sets an OData $select clause. expand is sets an OData $expand clause. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (TaskClient) GetPreparer ¶
func (client TaskClient) GetPreparer(ctx context.Context, jobID string, taskID string, selectParameter string, expand string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
GetPreparer prepares the Get request.
func (TaskClient) GetResponder ¶
func (client TaskClient) GetResponder(resp *http.Response) (result CloudTask, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (TaskClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (TaskClient) List ¶
func (client TaskClient) List(ctx context.Context, jobID string, filter string, selectParameter string, expand string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result CloudTaskListResultPage, err error)
List lists all of the tasks that are associated with the specified job.
jobID is the id of the job. filter is sets an OData $filter clause. selectParameter is sets an OData $select clause. expand is sets an OData $expand clause. maxResults is sets the maximum number of items to return in the response. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (TaskClient) ListComplete ¶
func (client TaskClient) ListComplete(ctx context.Context, jobID string, filter string, selectParameter string, expand string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result CloudTaskListResultIterator, err error)
ListComplete enumerates all values, automatically crossing page boundaries as required.
func (TaskClient) ListPreparer ¶
func (client TaskClient) ListPreparer(ctx context.Context, jobID string, filter string, selectParameter string, expand string, maxResults *int32, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
ListPreparer prepares the List request.
func (TaskClient) ListResponder ¶
func (client TaskClient) ListResponder(resp *http.Response) (result CloudTaskListResult, err error)
ListResponder handles the response to the List request. The method always closes the http.Response Body.
func (TaskClient) ListSender ¶
ListSender sends the List request. The method will close the http.Response Body if it receives an error.
func (TaskClient) ListSubtasks ¶
func (client TaskClient) ListSubtasks(ctx context.Context, jobID string, taskID string, selectParameter string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (result CloudTaskListSubtasksResult, err error)
ListSubtasks lists all of the subtasks that are associated with the specified multi-instance task.
jobID is the id of the job. taskID is the id of the task. selectParameter is sets an OData $select clause. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time.
func (TaskClient) ListSubtasksPreparer ¶
func (client TaskClient) ListSubtasksPreparer(ctx context.Context, jobID string, taskID string, selectParameter string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123) (*http.Request, error)
ListSubtasksPreparer prepares the ListSubtasks request.
func (TaskClient) ListSubtasksResponder ¶
func (client TaskClient) ListSubtasksResponder(resp *http.Response) (result CloudTaskListSubtasksResult, err error)
ListSubtasksResponder handles the response to the ListSubtasks request. The method always closes the http.Response Body.
func (TaskClient) ListSubtasksSender ¶
ListSubtasksSender sends the ListSubtasks request. The method will close the http.Response Body if it receives an error.
func (TaskClient) Terminate ¶
func (client TaskClient) Terminate(ctx context.Context, jobID string, taskID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
Terminate terminates the specified task.
jobID is the id of the job containing the task. taskID is the id of the task to terminate. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (TaskClient) TerminatePreparer ¶
func (client TaskClient) TerminatePreparer(ctx context.Context, jobID string, taskID string, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
TerminatePreparer prepares the Terminate request.
func (TaskClient) TerminateResponder ¶
func (client TaskClient) TerminateResponder(resp *http.Response) (result autorest.Response, err error)
TerminateResponder handles the response to the Terminate request. The method always closes the http.Response Body.
func (TaskClient) TerminateSender ¶
TerminateSender sends the Terminate request. The method will close the http.Response Body if it receives an error.
func (TaskClient) Update ¶
func (client TaskClient) Update(ctx context.Context, jobID string, taskID string, taskUpdateParameter TaskUpdateParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (result autorest.Response, err error)
Update updates the properties of the specified task.
jobID is the id of the job containing the task. taskID is the id of the task to update. taskUpdateParameter is the parameters for the request. timeout is sets the maximum time that the server can spend processing the request, in seconds. The default is 30 seconds. clientRequestID is caller generated request identity, in the form of a GUID with no decoration such as curly braces e.g. 9C4D50EE-2D56-4CD3-8152-34347DC9F2B0. returnClientRequestID is specifies if the server should return the client-request-id identifier in the response. ocpDate is the time the request was issued. If not specified, this header will be automatically populated with the current system clock time. ifMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag is an exact match as specified. ifNoneMatch is an ETag is specified. Specify this header to perform the operation only if the resource's ETag does not match the specified ETag. ifModifiedSince is specify this header to perform the operation only if the resource has been modified since the specified date/time. ifUnmodifiedSince is specify this header to perform the operation only if the resource has not been modified since the specified date/time.
func (TaskClient) UpdatePreparer ¶
func (client TaskClient) UpdatePreparer(ctx context.Context, jobID string, taskID string, taskUpdateParameter TaskUpdateParameter, timeout *int32, clientRequestID string, returnClientRequestID *bool, ocpDate *date.TimeRFC1123, ifMatch string, ifNoneMatch string, ifModifiedSince *date.TimeRFC1123, ifUnmodifiedSince *date.TimeRFC1123) (*http.Request, error)
UpdatePreparer prepares the Update request.
func (TaskClient) UpdateResponder ¶
UpdateResponder handles the response to the Update request. The method always closes the http.Response Body.
func (TaskClient) UpdateSender ¶
UpdateSender sends the Update request. The method will close the http.Response Body if it receives an error.
type TaskConstraints ¶
type TaskConstraints struct { // MaxWallClockTime - Gets or sets the maximum elapsed time that the task may run, measured from the time the task starts. If the task does not complete within the time limit, the Batch service terminates it. MaxWallClockTime *string `json:"maxWallClockTime,omitempty"` // RetentionTime - Gets or sets the minimum time to retain the working directory for the task on the compute node where it ran. After this time, the Batch service may delete the working directory and all its contents. The default is infinite. RetentionTime *string `json:"retentionTime,omitempty"` // MaxTaskRetryCount - Gets or sets the maximum number of times the task may be retried. The Batch service retries a task if its exit code is nonzero. MaxTaskRetryCount *int32 `json:"maxTaskRetryCount,omitempty"` }
TaskConstraints constraints to apply to the Job Manager task.
type TaskDependencies ¶
type TaskDependencies struct { // TaskIds - Gets or sets the list of task ids that must complete before this task can be scheduled. TaskIds *[]string `json:"taskIds,omitempty"` // TaskIDRanges - Gets or sets the list of task ranges that must complete before this task can be scheduled. TaskIDRanges *[]TaskIDRange `json:"taskIdRanges,omitempty"` }
TaskDependencies specifies any dependencies of a task. Any task that is explicitly specified or within a dependency range must complete before the dependant task will be scheduled.
type TaskExecutionInformation ¶
type TaskExecutionInformation struct { // StartTime - Gets or sets the time at which the task started running. If the task has been restarted or retried, this is the most recent time at which the task started running. StartTime *date.Time `json:"startTime,omitempty"` // EndTime - Gets or sets the time at which the task completed. This property is set only if the task is in the Completed state. EndTime *date.Time `json:"endTime,omitempty"` // ExitCode - Gets or sets the exit code of the task. This property is set only if the task is in completed state. ExitCode *int32 `json:"exitCode,omitempty"` // SchedulingError - Gets or sets details of any error encountered scheduling the task. SchedulingError *TaskSchedulingError `json:"schedulingError,omitempty"` // RetryCount - Gets or sets the number of times the task has been retried by the Batch service. RetryCount *int32 `json:"retryCount,omitempty"` // LastRetryTime - Gets or sets the most recent time at which a retry of the task started running. LastRetryTime *date.Time `json:"lastRetryTime,omitempty"` // RequeueCount - Gets or sets the number of times the task has been requeued by the Batch service as the result of a user request. RequeueCount *int32 `json:"requeueCount,omitempty"` // LastRequeueTime - Gets or sets the most recent time at which the task has been requeued by the Batch service as the result of a user request. LastRequeueTime *date.Time `json:"lastRequeueTime,omitempty"` }
TaskExecutionInformation information about the execution of a task.
type TaskIDRange ¶
type TaskIDRange struct { // Start - Gets or sets the first task id in the range. Start *int32 `json:"start,omitempty"` // End - Gets or sets the last task id in the range. End *int32 `json:"end,omitempty"` }
TaskIDRange ...
type TaskInformation ¶
type TaskInformation struct { // TaskURL - Gets or sets the URL of the task. TaskURL *string `json:"taskUrl,omitempty"` // JobID - Gets or sets the id of the job to which the task belongs. JobID *string `json:"jobId,omitempty"` // TaskID - Gets or sets the id of the task. TaskID *string `json:"taskId,omitempty"` // SubtaskID - Gets or sets the id of the subtask if the task is a multi-instance task. SubtaskID *int32 `json:"subtaskId,omitempty"` // TaskState - Gets or sets the current state of the task. Possible values include: 'TaskStateActive', 'TaskStatePreparing', 'TaskStateRunning', 'TaskStateCompleted' TaskState TaskState `json:"taskState,omitempty"` // ExecutionInfo - Gets or sets information about the execution of the task. ExecutionInfo *TaskExecutionInformation `json:"executionInfo,omitempty"` }
TaskInformation information about a task running on a compute node.
type TaskSchedulingError ¶
type TaskSchedulingError struct { // Category - Gets or sets the category of the task scheduling error. Possible values include: 'SchedulingErrorCategoryUsererror', 'SchedulingErrorCategoryServererror', 'SchedulingErrorCategoryUnmapped' Category SchedulingErrorCategory `json:"category,omitempty"` // Code - Gets or sets an identifier for the task scheduling error. Codes are invariant and are intended to be consumed programmatically. Code *string `json:"code,omitempty"` // Message - Gets or sets a message describing the task scheduling error, intended to be suitable for display in a user interface. Message *string `json:"message,omitempty"` // Details - Gets or sets the list of additional error details related to the scheduling error. Details *[]NameValuePair `json:"details,omitempty"` }
TaskSchedulingError information about an error when scheduling a task.
type TaskSchedulingPolicy ¶
type TaskSchedulingPolicy struct { // NodeFillType - Gets or sets how tasks should be distributed across compute nodes. Possible values include: 'ComputeNodeFillTypeSpread', 'ComputeNodeFillTypePack', 'ComputeNodeFillTypeUnmapped' NodeFillType ComputeNodeFillType `json:"nodeFillType,omitempty"` }
TaskSchedulingPolicy specifies how tasks should be distributed across compute nodes.
type TaskStatistics ¶
type TaskStatistics struct { // URL - Gets or sets the URL for the statistics. URL *string `json:"url,omitempty"` // StartTime - Gets or sets the start time of the time range covered by the statistics. StartTime *date.Time `json:"startTime,omitempty"` // LastUpdateTime - Gets or sets the time at which the statistics were last updated. All statistics are limited to the range between startTime and lastUpdateTime. LastUpdateTime *date.Time `json:"lastUpdateTime,omitempty"` // UserCPUTime - Gets or sets the total user mode CPU time (summed across all cores and all compute nodes) consumed by the task. UserCPUTime *string `json:"userCPUTime,omitempty"` // KernelCPUTime - Gets or sets the total kernel mode CPU time (summed across all cores and all compute nodes) consumed by the task. KernelCPUTime *string `json:"kernelCPUTime,omitempty"` // WallClockTime - Gets or sets the total wall clock time of the task. WallClockTime *string `json:"wallClockTime,omitempty"` // ReadIOps - Gets or sets the total number of I/O read operations performed by the task. ReadIOps *int64 `json:"readIOps,omitempty"` // WriteIOps - Gets or sets the total number of I/O write operations performed by the task. WriteIOps *int64 `json:"writeIOps,omitempty"` // ReadIOGiB - Gets or sets the total amount of data in GiB of I/O read by the task. ReadIOGiB *float64 `json:"readIOGiB,omitempty"` // WriteIOGiB - Gets or sets the total amount of data in GiB of I/O written by the task. WriteIOGiB *float64 `json:"writeIOGiB,omitempty"` // WaitTime - Gets or sets the elapsed time between the creation of the task and the start of task execution. WaitTime *string `json:"waitTime,omitempty"` }
TaskStatistics resource usage statistics for a task.
type TaskUpdateParameter ¶
type TaskUpdateParameter struct { // Constraints - Sets constraints that apply to this task. If omitted, the task is given the default constraints. Constraints *TaskConstraints `json:"constraints,omitempty"` }
TaskUpdateParameter parameters for a CloudTaskOperations.Update request.
type UsageStatistics ¶
type UsageStatistics struct { // StartTime - Gets or sets the start time of the time range covered by the statistics. StartTime *date.Time `json:"startTime,omitempty"` // LastUpdateTime - Gets or sets the time at which the statistics were last updated. All statistics are limited to the range between startTime and lastUpdateTime. LastUpdateTime *date.Time `json:"lastUpdateTime,omitempty"` // DedicatedCoreTime - Gets or sets the aggregated wall-clock time of the dedicated compute node cores being part of the pool. DedicatedCoreTime *string `json:"dedicatedCoreTime,omitempty"` }
UsageStatistics statistics related to pool usage information.