jrds

package
v0.0.0-...-12b6483 Latest Latest
Warning

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

Go to latest
Published: Jun 21, 2023 License: MIT Imports: 5 Imported by: 0

Documentation

Index

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 JobData

type JobData struct {
	RunbookVersionId *string `json:"runbookVersionId"`
	JobId            *string `json:"jobId"`
	SubscriptionId   *string `json:"subscriptionId"`
	PendingAction    *int    `json:"pendingAction"`
	JobStatus        *int    `json:"jobStatus"`
}

type JobStatus

type JobStatus struct {
	Exception     *string `json:"exception"`
	IsFinalStatus *bool   `json:"isFinalStatus"`
	JobStatus     *int    `json:"jobStatus"`
}

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 (jrds *JrdsClient) SetJobStatus(sandboxId string, jobId string, status int, isTermial bool, exception *string) error

func (*JrdsClient) SetJobStream

func (jrds *JrdsClient) SetJobStream(jobId string, runbookVersionId string, text string, streamType string, sequence int) error

func (*JrdsClient) SetLog

func (jrds *JrdsClient) SetLog(eventId int, activityId string, logType int, args ...string) error

func (*JrdsClient) UnloadJob

func (jrds *JrdsClient) UnloadJob(subscriptionId string, sandboxId string, jobId string, isTest bool, startTime time.Time, executionTimeInSeconds int) error

type Log

type Log struct {
	ActivityId *string   `json:"activityId"`
	Arguments  *[]string `json:"args"`
	EventId    *int      `json:"eventId"`
	LogType    *int      `json:"logtype"`
}

type MessageMetadata

type MessageMetadata struct {
	PopReceipt *string `json:"PopReceipt"`
	MessageId  *string `json:"MessageId"`
}

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"`
}

type UnloadJob

type UnloadJob struct {
	IsTest                 *bool   `json:"isTest"`
	JobId                  *string `json:"jobId"`
	StartTime              *string `json:"startTime"`
	SubscriptionId         *string `json:"subscriptionId"`
	ExecutionTimeInSeconds *int    `json:"executionTimeInSeconds"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL