Documentation ¶
Index ¶
- type AcknowledgeJobAction
- type JobAction
- type JobActions
- type JobData
- type JobStatus
- type JobUpdatableData
- type JrdsClient
- func (jrds *JrdsClient) AcknowledgeJobAction(sandboxId string, messageMetadata MessageMetadatas) error
- func (jrds *JrdsClient) GetJobActions(sandboxId string, jobActions *JobActions) error
- func (jrds *JrdsClient) GetJobData(jobId string, jobData *JobData) error
- func (jrds *JrdsClient) GetRunbookData(runbookVersionId string, runbookData *RunbookData) error
- func (jrds *JrdsClient) GetSandboxActions(sandboxAction *SandboxActions) error
- func (jrds *JrdsClient) GetUpdatableJobData(jobId string, jobData *JobUpdatableData) error
- func (jrds *JrdsClient) SetJobStatus(sandboxId string, jobId string, status int, isTermial bool, exception *string) error
- func (jrds *JrdsClient) SetJobStream(jobId string, runbookVersionId string, text string, streamType string, ...) error
- func (jrds *JrdsClient) SetLog(eventId int, activityId string, logType int, args ...string) error
- func (jrds *JrdsClient) UnloadJob(subscriptionId string, sandboxId string, jobId string, isTest bool, ...) error
- type Log
- type MessageMetadata
- type MessageMetadatas
- type RequestAuthorizationError
- type RequestError
- type RequestInvalidStatusError
- type RunbookData
- type SandboxAction
- type SandboxActions
- type Stream
- type UnloadJob
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AcknowledgeJobAction ¶
type AcknowledgeJobAction struct {
MessageMetadata MessageMetadata `json:"MessageMetadata"`
}
type JobAction ¶
type JobAction struct { MessageMetadata *MessageMetadata `json:"MessageMetadata"` MessageSource *string `json:"MessageSource"` LockToken *string `json:"LockToken"` JobId *string `json:"JobId"` }
type JobActions ¶
type JobActions struct {
Value []JobAction `json:"value"`
}
type JobUpdatableData ¶
type JobUpdatableData struct { LogActivityTrace *int `json:"logActivityTrace"` TriggerSource *int `json:"triggerSource"` JobId *string `json:"jobId"` LogProgress *bool `json:"logProgress"` JobStatus *int `json:"jobStatus"` AccountName *string `json:"accountName"` PartitionId *int `json:"partitionId"` LogDebug *bool `json:"logDebug"` IsDraft *bool `json:"isDraft"` WorkflowInstanceId *string `json:"workflowInstanceId"` JobKey *int `json:"JobKey"` SubscriptionId *string `json:"subscriptionId"` NoPersistEvictionCount *int `json:"noPersistEvictionsCount"` AccountKey *int `json:"AccountKey"` JobStartedBy *string `json:"jobStartedBy"` JobDestination *string `json:"jobRunDestination"` TierName *string `json:"tierName"` PendingActionData *string `json:"pendingActionData"` JobStatusDetails *int `json:"jobStatusDetails"` ResourceGroupName *string `json:"resourceGroupName"` PendingAction *int `json:"pendingAction"` LogVerbose *bool `json:"logVerbose"` RunbookKey *int `json:"RunbookKey"` }
type JrdsClient ¶
type JrdsClient struct {
// contains filtered or unexported fields
}
func NewJrdsClient ¶
func NewJrdsClient(client httputil.HttpClient, baseUri string, accountId string, workerGroupName string) JrdsClient
func (*JrdsClient) AcknowledgeJobAction ¶
func (jrds *JrdsClient) AcknowledgeJobAction(sandboxId string, messageMetadata MessageMetadatas) error
func (*JrdsClient) GetJobActions ¶
func (jrds *JrdsClient) GetJobActions(sandboxId string, jobActions *JobActions) error
func (*JrdsClient) GetJobData ¶
func (jrds *JrdsClient) GetJobData(jobId string, jobData *JobData) error
func (*JrdsClient) GetRunbookData ¶
func (jrds *JrdsClient) GetRunbookData(runbookVersionId string, runbookData *RunbookData) error
func (*JrdsClient) GetSandboxActions ¶
func (jrds *JrdsClient) GetSandboxActions(sandboxAction *SandboxActions) error
func (*JrdsClient) GetUpdatableJobData ¶
func (jrds *JrdsClient) GetUpdatableJobData(jobId string, jobData *JobUpdatableData) error
func (*JrdsClient) SetJobStatus ¶
func (*JrdsClient) SetJobStream ¶
type MessageMetadata ¶
type MessageMetadatas ¶
type MessageMetadatas struct {
MessageMetadatas []MessageMetadata `json:"MessageMetadatas"`
}
type RequestAuthorizationError ¶
type RequestAuthorizationError struct {
// contains filtered or unexported fields
}
func NewRequestAuthorizationError ¶
func NewRequestAuthorizationError(message string) *RequestAuthorizationError
func (*RequestAuthorizationError) Error ¶
func (e *RequestAuthorizationError) Error() string
type RequestError ¶
type RequestError struct {
// contains filtered or unexported fields
}
func NewRequestError ¶
func NewRequestError(message string) *RequestError
func (*RequestError) Error ¶
func (e *RequestError) Error() string
type RequestInvalidStatusError ¶
type RequestInvalidStatusError struct {
// contains filtered or unexported fields
}
func NewRequestInvalidStatusError ¶
func NewRequestInvalidStatusError(message string) *RequestInvalidStatusError
func (*RequestInvalidStatusError) Error ¶
func (e *RequestInvalidStatusError) Error() string
type RunbookData ¶
type RunbookData struct { Name *string `json:"name"` AccountId *string `json:"accountId"` RunbookId *string `json:"runbookId"` Definition *string `json:"definition"` RunbookDefinitionKind *int `json:"runbookDefinitionKind"` RunbookVersionId *string `json:"runbookVersionId"` Parameters *[]string `json:"parameters"` }
type SandboxAction ¶
type SandboxAction struct {
SandboxId *string `json:"sandboxId"`
}
type SandboxActions ¶
type SandboxActions struct {
Value []SandboxAction `json:"value"`
}
type Stream ¶
type Stream struct { AccountId *string `json:"AccountId"` JobId *string `json:"JobId"` RecordTime *string `json:"RecordTime"` RunbookVersionId *string `json:"RunbookVersionId"` SequenceNumber *int `json:"SequenceNumber"` StreamRecord *string `json:"StreamRecord"` StreamRecordText *string `json:"StreamRecordText"` Type *string `json:"Type"` }
Click to show internal directories.
Click to hide internal directories.