aurora

package
v1.21.0 Latest Latest
Warning

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

Go to latest
Published: Mar 15, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source
const AURORA_EXECUTOR_NAME = "AuroraExecutor"
View Source
const BYPASS_LEADER_REDIRECT_HEADER_NAME = "Bypass-Leader-Redirect"
View Source
const GOOD_IDENTIFIER_PATTERN = "^[\\w\\-\\.]+$"
View Source
const GOOD_IDENTIFIER_PATTERN_JVM = "^[\\w\\-\\.]+$"
View Source
const GOOD_IDENTIFIER_PATTERN_PYTHON = "^[\\w\\-\\.]+$"
View Source
const TASK_FILESYSTEM_MOUNT_POINT = "taskfs"

Variables

View Source
var ACTIVE_JOB_UPDATE_STATES []JobUpdateStatus
View Source
var ACTIVE_STATES []ScheduleStatus
View Source
var AWAITNG_PULSE_JOB_UPDATE_STATES []JobUpdateStatus
View Source
var DockerContainer_Parameters_DEFAULT []*DockerParameter
View Source
var ExplicitReconciliationSettings_BatchSize_DEFAULT int32
View Source
var GoUnusedProtection__ int
View Source
var HostAttributes_SlaveId_DEFAULT string
View Source
var JobConfiguration_CronSchedule_DEFAULT string
View Source
var JobInstanceUpdateEvent_Message_DEFAULT string
View Source
var JobSummary_NextCronRunMs_DEFAULT int64
View Source
var JobUpdateEvent_Message_DEFAULT string
View Source
var JobUpdateEvent_User_DEFAULT string
View Source
var JobUpdateQuery_Role_DEFAULT string
View Source
var JobUpdateQuery_UpdateStatuses_DEFAULT []JobUpdateStatus
View Source
var JobUpdateQuery_User_DEFAULT string
View Source
var JobUpdateRequest_Metadata_DEFAULT []*Metadata
View Source
var JobUpdateSettings_BlockIfNoPulsesAfterMs_DEFAULT int32
View Source
var JobUpdateSettings_SlaAware_DEFAULT bool
View Source
var JobUpdateSummary_Metadata_DEFAULT []*Metadata
View Source
var LIVE_STATES []ScheduleStatus
View Source
var Lock_Message_DEFAULT string
View Source
var MesosContainer_Volumes_DEFAULT []*Volume
View Source
var MesosFetcherURI_Cache_DEFAULT bool
View Source
var MesosFetcherURI_Extract_DEFAULT bool
View Source
var PartitionPolicy_DelaySecs_DEFAULT int64
View Source
var Resource_DiskMb_DEFAULT int64
View Source
var Resource_NamedPort_DEFAULT string
View Source
var Resource_NumCpus_DEFAULT float64
View Source
var Resource_NumGpus_DEFAULT int64
View Source
var Resource_RamMb_DEFAULT int64
View Source
var SLAVE_ASSIGNED_STATES []ScheduleStatus
View Source
var TERMINAL_STATES []ScheduleStatus
View Source
var TaskConfig_ContactEmail_DEFAULT string
View Source
var TaskConfig_MesosFetcherUris_DEFAULT []*MesosFetcherURI
View Source
var TaskConfig_Metadata_DEFAULT []*Metadata
View Source
var TaskConfig_Production_DEFAULT bool
View Source
var TaskConfig_TaskLinks_DEFAULT map[string]string
View Source
var TaskConfig_Tier_DEFAULT string
View Source
var TaskEvent_Message_DEFAULT string
View Source
var TaskEvent_Scheduler_DEFAULT string
View Source
var TaskQuery_Environment_DEFAULT string
View Source
var TaskQuery_InstanceIds_DEFAULT []int32
View Source
var TaskQuery_JobKeys_DEFAULT []*JobKey
View Source
var TaskQuery_JobName_DEFAULT string
View Source
var TaskQuery_Limit_DEFAULT int32
View Source
var TaskQuery_Offset_DEFAULT int32
View Source
var TaskQuery_Role_DEFAULT string
View Source
var TaskQuery_SlaveHosts_DEFAULT []string
View Source
var TaskQuery_Statuses_DEFAULT []ScheduleStatus
View Source
var TaskQuery_TaskIds_DEFAULT []string

Functions

This section is empty.

Types

type AppcImage

type AppcImage struct {
	Name    string `thrift:"name,1" db:"name" json:"name"`
	ImageId string `thrift:"imageId,2" db:"imageId" json:"imageId"`
}

Describes an image for use with the Mesos unified containerizer in the AppC format

Attributes:

  • Name: The name of the image to run
  • ImageId: The appc image id identifying the image
var Image_Appc_DEFAULT *AppcImage

func NewAppcImage

func NewAppcImage() *AppcImage

func (*AppcImage) GetImageId

func (p *AppcImage) GetImageId() string

func (*AppcImage) GetName

func (p *AppcImage) GetName() string

func (*AppcImage) Read

func (p *AppcImage) Read(iprot thrift.TProtocol) error

func (*AppcImage) ReadField1 added in v1.21.0

func (p *AppcImage) ReadField1(iprot thrift.TProtocol) error

func (*AppcImage) ReadField2 added in v1.21.0

func (p *AppcImage) ReadField2(iprot thrift.TProtocol) error

func (*AppcImage) String

func (p *AppcImage) String() string

func (*AppcImage) Write

func (p *AppcImage) Write(oprot thrift.TProtocol) error

type AssignedTask

type AssignedTask struct {
	TaskId        string           `thrift:"taskId,1" db:"taskId" json:"taskId"`
	SlaveId       string           `thrift:"slaveId,2" db:"slaveId" json:"slaveId"`
	SlaveHost     string           `thrift:"slaveHost,3" db:"slaveHost" json:"slaveHost"`
	Task          *TaskConfig      `thrift:"task,4" db:"task" json:"task"`
	AssignedPorts map[string]int32 `thrift:"assignedPorts,5" db:"assignedPorts" json:"assignedPorts"`
	InstanceId    int32            `thrift:"instanceId,6" db:"instanceId" json:"instanceId"`
}

A task assignment that is provided to an executor.

Attributes:

  • TaskId: The mesos task ID for this task. Guaranteed to be globally unique
  • SlaveId: The mesos slave ID that this task has been assigned to.

This will not be populated for a PENDING task.

  • SlaveHost: The name of the machine that this task has been assigned to.

This will not be populated for a PENDING task.

  • Task: Information about how to run this task.
  • AssignedPorts: Ports reserved on the machine while this task is running.
  • InstanceId: The instance ID assigned to this task. Instance IDs must be unique and contiguous within a

job, and will be in the range [0, N-1] (inclusive) for a job that has N instances.

var ScheduledTask_AssignedTask_DEFAULT *AssignedTask

func NewAssignedTask

func NewAssignedTask() *AssignedTask

func (*AssignedTask) GetAssignedPorts

func (p *AssignedTask) GetAssignedPorts() map[string]int32

func (*AssignedTask) GetInstanceId

func (p *AssignedTask) GetInstanceId() int32

func (*AssignedTask) GetSlaveHost

func (p *AssignedTask) GetSlaveHost() string

func (*AssignedTask) GetSlaveId

func (p *AssignedTask) GetSlaveId() string

func (*AssignedTask) GetTask

func (p *AssignedTask) GetTask() *TaskConfig

func (*AssignedTask) GetTaskId

func (p *AssignedTask) GetTaskId() string

func (*AssignedTask) IsSetTask

func (p *AssignedTask) IsSetTask() bool

func (*AssignedTask) Read

func (p *AssignedTask) Read(iprot thrift.TProtocol) error

func (*AssignedTask) ReadField1 added in v1.21.0

func (p *AssignedTask) ReadField1(iprot thrift.TProtocol) error

func (*AssignedTask) ReadField2 added in v1.21.0

func (p *AssignedTask) ReadField2(iprot thrift.TProtocol) error

func (*AssignedTask) ReadField3 added in v1.21.0

func (p *AssignedTask) ReadField3(iprot thrift.TProtocol) error

func (*AssignedTask) ReadField4 added in v1.21.0

func (p *AssignedTask) ReadField4(iprot thrift.TProtocol) error

func (*AssignedTask) ReadField5 added in v1.21.0

func (p *AssignedTask) ReadField5(iprot thrift.TProtocol) error

func (*AssignedTask) ReadField6 added in v1.21.0

func (p *AssignedTask) ReadField6(iprot thrift.TProtocol) error

func (*AssignedTask) String

func (p *AssignedTask) String() string

func (*AssignedTask) Write

func (p *AssignedTask) Write(oprot thrift.TProtocol) error

type Attribute

type Attribute struct {
	Name   string   `thrift:"name,1" db:"name" json:"name"`
	Values []string `thrift:"values,2" db:"values" json:"values"`
}

A single host attribute.

Attributes:

  • Name
  • Values

func NewAttribute

func NewAttribute() *Attribute

func (*Attribute) GetName

func (p *Attribute) GetName() string

func (*Attribute) GetValues

func (p *Attribute) GetValues() []string

func (*Attribute) Read

func (p *Attribute) Read(iprot thrift.TProtocol) error

func (*Attribute) ReadField1 added in v1.21.0

func (p *Attribute) ReadField1(iprot thrift.TProtocol) error

func (*Attribute) ReadField2 added in v1.21.0

func (p *Attribute) ReadField2(iprot thrift.TProtocol) error

func (*Attribute) String

func (p *Attribute) String() string

func (*Attribute) Write

func (p *Attribute) Write(oprot thrift.TProtocol) error

type AuroraAdmin

type AuroraAdmin interface {
	AuroraSchedulerManager

	// Assign quota to a user.  This will overwrite any pre-existing quota for the user.
	//
	// Parameters:
	//  - OwnerRole
	//  - Quota
	SetQuota(ctx context.Context, ownerRole string, quota *ResourceAggregate) (r *Response, err error)
	// Forces a task into a specific state.  This does not guarantee the task will enter the given
	// state, as the task must still transition within the bounds of the state machine.  However,
	// it attempts to enter that state via the state machine.
	//
	// Parameters:
	//  - TaskId
	//  - Status
	ForceTaskState(ctx context.Context, taskId string, status ScheduleStatus) (r *Response, err error)
	// Immediately writes a storage snapshot to disk.
	PerformBackup(ctx context.Context) (r *Response, err error)
	// Lists backups that are available for recovery.
	ListBackups(ctx context.Context) (r *Response, err error)
	// Loads a backup to an in-memory storage.  This must precede all other recovery operations.
	//
	// Parameters:
	//  - BackupId
	StageRecovery(ctx context.Context, backupId string) (r *Response, err error)
	// Queries for tasks in a staged recovery.
	//
	// Parameters:
	//  - Query
	QueryRecovery(ctx context.Context, query *TaskQuery) (r *Response, err error)
	// Deletes tasks from a staged recovery.
	//
	// Parameters:
	//  - Query
	DeleteRecoveryTasks(ctx context.Context, query *TaskQuery) (r *Response, err error)
	// Commits a staged recovery, completely replacing the previous storage state.
	CommitRecovery(ctx context.Context) (r *Response, err error)
	// Unloads (aborts) a staged recovery.
	UnloadRecovery(ctx context.Context) (r *Response, err error)
	// Put the given hosts into maintenance mode.
	//
	// Parameters:
	//  - Hosts
	StartMaintenance(ctx context.Context, hosts *Hosts) (r *Response, err error)
	// Ask scheduler to begin moving tasks scheduled on given hosts.
	//
	// Parameters:
	//  - Hosts
	DrainHosts(ctx context.Context, hosts *Hosts) (r *Response, err error)
	// Retrieve the current maintenance states for a group of hosts.
	//
	// Parameters:
	//  - Hosts
	MaintenanceStatus(ctx context.Context, hosts *Hosts) (r *Response, err error)
	// Set the given hosts back into serving mode.
	//
	// Parameters:
	//  - Hosts
	EndMaintenance(ctx context.Context, hosts *Hosts) (r *Response, err error)
	// Ask scheduler to put hosts into DRAINING mode and move scheduled tasks off of the hosts
	// such that its SLA requirements are satisfied. Use defaultSlaPolicy if it is not set for a task.
	//
	//
	// Parameters:
	//  - Hosts
	//  - DefaultSlaPolicy
	//  - TimeoutSecs
	SlaDrainHosts(ctx context.Context, hosts *Hosts, defaultSlaPolicy *SlaPolicy, timeoutSecs int64) (r *Response, err error)
	// Start a storage snapshot and block until it completes.
	Snapshot(ctx context.Context) (r *Response, err error)
	// Tell scheduler to trigger an explicit task reconciliation with the given settings.
	//
	// Parameters:
	//  - Settings
	TriggerExplicitTaskReconciliation(ctx context.Context, settings *ExplicitReconciliationSettings) (r *Response, err error)
	// Tell scheduler to trigger an implicit task reconciliation.
	TriggerImplicitTaskReconciliation(ctx context.Context) (r *Response, err error)
	// Force prune any (terminal) tasks that match the query. If no statuses are supplied with the
	// query, it will default to all terminal task states. If statuses are supplied, they must be
	// terminal states.
	//
	// Parameters:
	//  - Query
	PruneTasks(ctx context.Context, query *TaskQuery) (r *Response, err error)
}

type AuroraAdminClient

type AuroraAdminClient struct {
	*AuroraSchedulerManagerClient
}

func NewAuroraAdminClient added in v1.21.0

func NewAuroraAdminClient(c thrift.TClient) *AuroraAdminClient

func NewAuroraAdminClientProtocol

func NewAuroraAdminClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *AuroraAdminClient

func (*AuroraAdminClient) CommitRecovery

func (p *AuroraAdminClient) CommitRecovery(ctx context.Context) (r *Response, err error)

Commits a staged recovery, completely replacing the previous storage state.

func (*AuroraAdminClient) DeleteRecoveryTasks

func (p *AuroraAdminClient) DeleteRecoveryTasks(ctx context.Context, query *TaskQuery) (r *Response, err error)

Deletes tasks from a staged recovery.

Parameters:

  • Query

func (*AuroraAdminClient) DrainHosts

func (p *AuroraAdminClient) DrainHosts(ctx context.Context, hosts *Hosts) (r *Response, err error)

Ask scheduler to begin moving tasks scheduled on given hosts.

Parameters:

  • Hosts

func (*AuroraAdminClient) EndMaintenance

func (p *AuroraAdminClient) EndMaintenance(ctx context.Context, hosts *Hosts) (r *Response, err error)

Set the given hosts back into serving mode.

Parameters:

  • Hosts

func (*AuroraAdminClient) ForceTaskState

func (p *AuroraAdminClient) ForceTaskState(ctx context.Context, taskId string, status ScheduleStatus) (r *Response, err error)

Forces a task into a specific state. This does not guarantee the task will enter the given state, as the task must still transition within the bounds of the state machine. However, it attempts to enter that state via the state machine.

Parameters:

  • TaskId
  • Status

func (*AuroraAdminClient) ListBackups

func (p *AuroraAdminClient) ListBackups(ctx context.Context) (r *Response, err error)

Lists backups that are available for recovery.

func (*AuroraAdminClient) MaintenanceStatus

func (p *AuroraAdminClient) MaintenanceStatus(ctx context.Context, hosts *Hosts) (r *Response, err error)

Retrieve the current maintenance states for a group of hosts.

Parameters:

  • Hosts

func (*AuroraAdminClient) PerformBackup

func (p *AuroraAdminClient) PerformBackup(ctx context.Context) (r *Response, err error)

Immediately writes a storage snapshot to disk.

func (*AuroraAdminClient) PruneTasks added in v1.1.0

func (p *AuroraAdminClient) PruneTasks(ctx context.Context, query *TaskQuery) (r *Response, err error)

Force prune any (terminal) tasks that match the query. If no statuses are supplied with the query, it will default to all terminal task states. If statuses are supplied, they must be terminal states.

Parameters:

  • Query

func (*AuroraAdminClient) QueryRecovery

func (p *AuroraAdminClient) QueryRecovery(ctx context.Context, query *TaskQuery) (r *Response, err error)

Queries for tasks in a staged recovery.

Parameters:

  • Query

func (*AuroraAdminClient) SetQuota

func (p *AuroraAdminClient) SetQuota(ctx context.Context, ownerRole string, quota *ResourceAggregate) (r *Response, err error)

Assign quota to a user. This will overwrite any pre-existing quota for the user.

Parameters:

  • OwnerRole
  • Quota

func (*AuroraAdminClient) SlaDrainHosts added in v1.3.1

func (p *AuroraAdminClient) SlaDrainHosts(ctx context.Context, hosts *Hosts, defaultSlaPolicy *SlaPolicy, timeoutSecs int64) (r *Response, err error)

Ask scheduler to put hosts into DRAINING mode and move scheduled tasks off of the hosts such that its SLA requirements are satisfied. Use defaultSlaPolicy if it is not set for a task.

Parameters:

  • Hosts
  • DefaultSlaPolicy
  • TimeoutSecs

func (*AuroraAdminClient) Snapshot

func (p *AuroraAdminClient) Snapshot(ctx context.Context) (r *Response, err error)

Start a storage snapshot and block until it completes.

func (*AuroraAdminClient) StageRecovery

func (p *AuroraAdminClient) StageRecovery(ctx context.Context, backupId string) (r *Response, err error)

Loads a backup to an in-memory storage. This must precede all other recovery operations.

Parameters:

  • BackupId

func (*AuroraAdminClient) StartMaintenance

func (p *AuroraAdminClient) StartMaintenance(ctx context.Context, hosts *Hosts) (r *Response, err error)

Put the given hosts into maintenance mode.

Parameters:

  • Hosts

func (*AuroraAdminClient) TriggerExplicitTaskReconciliation

func (p *AuroraAdminClient) TriggerExplicitTaskReconciliation(ctx context.Context, settings *ExplicitReconciliationSettings) (r *Response, err error)

Tell scheduler to trigger an explicit task reconciliation with the given settings.

Parameters:

  • Settings

func (*AuroraAdminClient) TriggerImplicitTaskReconciliation

func (p *AuroraAdminClient) TriggerImplicitTaskReconciliation(ctx context.Context) (r *Response, err error)

Tell scheduler to trigger an implicit task reconciliation.

func (*AuroraAdminClient) UnloadRecovery

func (p *AuroraAdminClient) UnloadRecovery(ctx context.Context) (r *Response, err error)

Unloads (aborts) a staged recovery.

type AuroraAdminCommitRecoveryArgs

type AuroraAdminCommitRecoveryArgs struct {
}

func NewAuroraAdminCommitRecoveryArgs

func NewAuroraAdminCommitRecoveryArgs() *AuroraAdminCommitRecoveryArgs

func (*AuroraAdminCommitRecoveryArgs) Read

func (*AuroraAdminCommitRecoveryArgs) String

func (*AuroraAdminCommitRecoveryArgs) Write

type AuroraAdminCommitRecoveryResult

type AuroraAdminCommitRecoveryResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraAdminCommitRecoveryResult

func NewAuroraAdminCommitRecoveryResult() *AuroraAdminCommitRecoveryResult

func (*AuroraAdminCommitRecoveryResult) GetSuccess

func (p *AuroraAdminCommitRecoveryResult) GetSuccess() *Response

func (*AuroraAdminCommitRecoveryResult) IsSetSuccess

func (p *AuroraAdminCommitRecoveryResult) IsSetSuccess() bool

func (*AuroraAdminCommitRecoveryResult) Read

func (*AuroraAdminCommitRecoveryResult) ReadField0 added in v1.21.0

func (*AuroraAdminCommitRecoveryResult) String

func (*AuroraAdminCommitRecoveryResult) Write

type AuroraAdminDeleteRecoveryTasksArgs

type AuroraAdminDeleteRecoveryTasksArgs struct {
	Query *TaskQuery `thrift:"query,1" db:"query" json:"query"`
}

Attributes:

  • Query

func NewAuroraAdminDeleteRecoveryTasksArgs

func NewAuroraAdminDeleteRecoveryTasksArgs() *AuroraAdminDeleteRecoveryTasksArgs

func (*AuroraAdminDeleteRecoveryTasksArgs) GetQuery

func (*AuroraAdminDeleteRecoveryTasksArgs) IsSetQuery

func (p *AuroraAdminDeleteRecoveryTasksArgs) IsSetQuery() bool

func (*AuroraAdminDeleteRecoveryTasksArgs) Read

func (*AuroraAdminDeleteRecoveryTasksArgs) ReadField1 added in v1.21.0

func (*AuroraAdminDeleteRecoveryTasksArgs) String

func (*AuroraAdminDeleteRecoveryTasksArgs) Write

type AuroraAdminDeleteRecoveryTasksResult

type AuroraAdminDeleteRecoveryTasksResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraAdminDeleteRecoveryTasksResult

func NewAuroraAdminDeleteRecoveryTasksResult() *AuroraAdminDeleteRecoveryTasksResult

func (*AuroraAdminDeleteRecoveryTasksResult) GetSuccess

func (*AuroraAdminDeleteRecoveryTasksResult) IsSetSuccess

func (p *AuroraAdminDeleteRecoveryTasksResult) IsSetSuccess() bool

func (*AuroraAdminDeleteRecoveryTasksResult) Read

func (*AuroraAdminDeleteRecoveryTasksResult) ReadField0 added in v1.21.0

func (*AuroraAdminDeleteRecoveryTasksResult) String

func (*AuroraAdminDeleteRecoveryTasksResult) Write

type AuroraAdminDrainHostsArgs

type AuroraAdminDrainHostsArgs struct {
	Hosts *Hosts `thrift:"hosts,1" db:"hosts" json:"hosts"`
}

Attributes:

  • Hosts

func NewAuroraAdminDrainHostsArgs

func NewAuroraAdminDrainHostsArgs() *AuroraAdminDrainHostsArgs

func (*AuroraAdminDrainHostsArgs) GetHosts

func (p *AuroraAdminDrainHostsArgs) GetHosts() *Hosts

func (*AuroraAdminDrainHostsArgs) IsSetHosts

func (p *AuroraAdminDrainHostsArgs) IsSetHosts() bool

func (*AuroraAdminDrainHostsArgs) Read

func (*AuroraAdminDrainHostsArgs) ReadField1 added in v1.21.0

func (p *AuroraAdminDrainHostsArgs) ReadField1(iprot thrift.TProtocol) error

func (*AuroraAdminDrainHostsArgs) String

func (p *AuroraAdminDrainHostsArgs) String() string

func (*AuroraAdminDrainHostsArgs) Write

type AuroraAdminDrainHostsResult

type AuroraAdminDrainHostsResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraAdminDrainHostsResult

func NewAuroraAdminDrainHostsResult() *AuroraAdminDrainHostsResult

func (*AuroraAdminDrainHostsResult) GetSuccess

func (p *AuroraAdminDrainHostsResult) GetSuccess() *Response

func (*AuroraAdminDrainHostsResult) IsSetSuccess

func (p *AuroraAdminDrainHostsResult) IsSetSuccess() bool

func (*AuroraAdminDrainHostsResult) Read

func (*AuroraAdminDrainHostsResult) ReadField0 added in v1.21.0

func (p *AuroraAdminDrainHostsResult) ReadField0(iprot thrift.TProtocol) error

func (*AuroraAdminDrainHostsResult) String

func (p *AuroraAdminDrainHostsResult) String() string

func (*AuroraAdminDrainHostsResult) Write

type AuroraAdminEndMaintenanceArgs

type AuroraAdminEndMaintenanceArgs struct {
	Hosts *Hosts `thrift:"hosts,1" db:"hosts" json:"hosts"`
}

Attributes:

  • Hosts

func NewAuroraAdminEndMaintenanceArgs

func NewAuroraAdminEndMaintenanceArgs() *AuroraAdminEndMaintenanceArgs

func (*AuroraAdminEndMaintenanceArgs) GetHosts

func (p *AuroraAdminEndMaintenanceArgs) GetHosts() *Hosts

func (*AuroraAdminEndMaintenanceArgs) IsSetHosts

func (p *AuroraAdminEndMaintenanceArgs) IsSetHosts() bool

func (*AuroraAdminEndMaintenanceArgs) Read

func (*AuroraAdminEndMaintenanceArgs) ReadField1 added in v1.21.0

func (p *AuroraAdminEndMaintenanceArgs) ReadField1(iprot thrift.TProtocol) error

func (*AuroraAdminEndMaintenanceArgs) String

func (*AuroraAdminEndMaintenanceArgs) Write

type AuroraAdminEndMaintenanceResult

type AuroraAdminEndMaintenanceResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraAdminEndMaintenanceResult

func NewAuroraAdminEndMaintenanceResult() *AuroraAdminEndMaintenanceResult

func (*AuroraAdminEndMaintenanceResult) GetSuccess

func (p *AuroraAdminEndMaintenanceResult) GetSuccess() *Response

func (*AuroraAdminEndMaintenanceResult) IsSetSuccess

func (p *AuroraAdminEndMaintenanceResult) IsSetSuccess() bool

func (*AuroraAdminEndMaintenanceResult) Read

func (*AuroraAdminEndMaintenanceResult) ReadField0 added in v1.21.0

func (*AuroraAdminEndMaintenanceResult) String

func (*AuroraAdminEndMaintenanceResult) Write

type AuroraAdminForceTaskStateArgs

type AuroraAdminForceTaskStateArgs struct {
	TaskId string         `thrift:"taskId,1" db:"taskId" json:"taskId"`
	Status ScheduleStatus `thrift:"status,2" db:"status" json:"status"`
}

Attributes:

  • TaskId
  • Status

func NewAuroraAdminForceTaskStateArgs

func NewAuroraAdminForceTaskStateArgs() *AuroraAdminForceTaskStateArgs

func (*AuroraAdminForceTaskStateArgs) GetStatus

func (*AuroraAdminForceTaskStateArgs) GetTaskId

func (p *AuroraAdminForceTaskStateArgs) GetTaskId() string

func (*AuroraAdminForceTaskStateArgs) Read

func (*AuroraAdminForceTaskStateArgs) ReadField1 added in v1.21.0

func (p *AuroraAdminForceTaskStateArgs) ReadField1(iprot thrift.TProtocol) error

func (*AuroraAdminForceTaskStateArgs) ReadField2 added in v1.21.0

func (p *AuroraAdminForceTaskStateArgs) ReadField2(iprot thrift.TProtocol) error

func (*AuroraAdminForceTaskStateArgs) String

func (*AuroraAdminForceTaskStateArgs) Write

type AuroraAdminForceTaskStateResult

type AuroraAdminForceTaskStateResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraAdminForceTaskStateResult

func NewAuroraAdminForceTaskStateResult() *AuroraAdminForceTaskStateResult

func (*AuroraAdminForceTaskStateResult) GetSuccess

func (p *AuroraAdminForceTaskStateResult) GetSuccess() *Response

func (*AuroraAdminForceTaskStateResult) IsSetSuccess

func (p *AuroraAdminForceTaskStateResult) IsSetSuccess() bool

func (*AuroraAdminForceTaskStateResult) Read

func (*AuroraAdminForceTaskStateResult) ReadField0 added in v1.21.0

func (*AuroraAdminForceTaskStateResult) String

func (*AuroraAdminForceTaskStateResult) Write

type AuroraAdminListBackupsArgs

type AuroraAdminListBackupsArgs struct {
}

func NewAuroraAdminListBackupsArgs

func NewAuroraAdminListBackupsArgs() *AuroraAdminListBackupsArgs

func (*AuroraAdminListBackupsArgs) Read

func (*AuroraAdminListBackupsArgs) String

func (p *AuroraAdminListBackupsArgs) String() string

func (*AuroraAdminListBackupsArgs) Write

type AuroraAdminListBackupsResult

type AuroraAdminListBackupsResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraAdminListBackupsResult

func NewAuroraAdminListBackupsResult() *AuroraAdminListBackupsResult

func (*AuroraAdminListBackupsResult) GetSuccess

func (p *AuroraAdminListBackupsResult) GetSuccess() *Response

func (*AuroraAdminListBackupsResult) IsSetSuccess

func (p *AuroraAdminListBackupsResult) IsSetSuccess() bool

func (*AuroraAdminListBackupsResult) Read

func (*AuroraAdminListBackupsResult) ReadField0 added in v1.21.0

func (p *AuroraAdminListBackupsResult) ReadField0(iprot thrift.TProtocol) error

func (*AuroraAdminListBackupsResult) String

func (*AuroraAdminListBackupsResult) Write

type AuroraAdminMaintenanceStatusArgs

type AuroraAdminMaintenanceStatusArgs struct {
	Hosts *Hosts `thrift:"hosts,1" db:"hosts" json:"hosts"`
}

Attributes:

  • Hosts

func NewAuroraAdminMaintenanceStatusArgs

func NewAuroraAdminMaintenanceStatusArgs() *AuroraAdminMaintenanceStatusArgs

func (*AuroraAdminMaintenanceStatusArgs) GetHosts

func (p *AuroraAdminMaintenanceStatusArgs) GetHosts() *Hosts

func (*AuroraAdminMaintenanceStatusArgs) IsSetHosts

func (p *AuroraAdminMaintenanceStatusArgs) IsSetHosts() bool

func (*AuroraAdminMaintenanceStatusArgs) Read

func (*AuroraAdminMaintenanceStatusArgs) ReadField1 added in v1.21.0

func (*AuroraAdminMaintenanceStatusArgs) String

func (*AuroraAdminMaintenanceStatusArgs) Write

type AuroraAdminMaintenanceStatusResult

type AuroraAdminMaintenanceStatusResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraAdminMaintenanceStatusResult

func NewAuroraAdminMaintenanceStatusResult() *AuroraAdminMaintenanceStatusResult

func (*AuroraAdminMaintenanceStatusResult) GetSuccess

func (*AuroraAdminMaintenanceStatusResult) IsSetSuccess

func (p *AuroraAdminMaintenanceStatusResult) IsSetSuccess() bool

func (*AuroraAdminMaintenanceStatusResult) Read

func (*AuroraAdminMaintenanceStatusResult) ReadField0 added in v1.21.0

func (*AuroraAdminMaintenanceStatusResult) String

func (*AuroraAdminMaintenanceStatusResult) Write

type AuroraAdminPerformBackupArgs

type AuroraAdminPerformBackupArgs struct {
}

func NewAuroraAdminPerformBackupArgs

func NewAuroraAdminPerformBackupArgs() *AuroraAdminPerformBackupArgs

func (*AuroraAdminPerformBackupArgs) Read

func (*AuroraAdminPerformBackupArgs) String

func (*AuroraAdminPerformBackupArgs) Write

type AuroraAdminPerformBackupResult

type AuroraAdminPerformBackupResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraAdminPerformBackupResult

func NewAuroraAdminPerformBackupResult() *AuroraAdminPerformBackupResult

func (*AuroraAdminPerformBackupResult) GetSuccess

func (p *AuroraAdminPerformBackupResult) GetSuccess() *Response

func (*AuroraAdminPerformBackupResult) IsSetSuccess

func (p *AuroraAdminPerformBackupResult) IsSetSuccess() bool

func (*AuroraAdminPerformBackupResult) Read

func (*AuroraAdminPerformBackupResult) ReadField0 added in v1.21.0

func (*AuroraAdminPerformBackupResult) String

func (*AuroraAdminPerformBackupResult) Write

type AuroraAdminProcessor

type AuroraAdminProcessor struct {
	*AuroraSchedulerManagerProcessor
}

func NewAuroraAdminProcessor

func NewAuroraAdminProcessor(handler AuroraAdmin) *AuroraAdminProcessor

type AuroraAdminPruneTasksArgs added in v1.1.0

type AuroraAdminPruneTasksArgs struct {
	Query *TaskQuery `thrift:"query,1" db:"query" json:"query"`
}

Attributes:

  • Query

func NewAuroraAdminPruneTasksArgs added in v1.1.0

func NewAuroraAdminPruneTasksArgs() *AuroraAdminPruneTasksArgs

func (*AuroraAdminPruneTasksArgs) GetQuery added in v1.1.0

func (p *AuroraAdminPruneTasksArgs) GetQuery() *TaskQuery

func (*AuroraAdminPruneTasksArgs) IsSetQuery added in v1.1.0

func (p *AuroraAdminPruneTasksArgs) IsSetQuery() bool

func (*AuroraAdminPruneTasksArgs) Read added in v1.1.0

func (*AuroraAdminPruneTasksArgs) ReadField1 added in v1.21.0

func (p *AuroraAdminPruneTasksArgs) ReadField1(iprot thrift.TProtocol) error

func (*AuroraAdminPruneTasksArgs) String added in v1.1.0

func (p *AuroraAdminPruneTasksArgs) String() string

func (*AuroraAdminPruneTasksArgs) Write added in v1.1.0

type AuroraAdminPruneTasksResult added in v1.1.0

type AuroraAdminPruneTasksResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraAdminPruneTasksResult added in v1.1.0

func NewAuroraAdminPruneTasksResult() *AuroraAdminPruneTasksResult

func (*AuroraAdminPruneTasksResult) GetSuccess added in v1.1.0

func (p *AuroraAdminPruneTasksResult) GetSuccess() *Response

func (*AuroraAdminPruneTasksResult) IsSetSuccess added in v1.1.0

func (p *AuroraAdminPruneTasksResult) IsSetSuccess() bool

func (*AuroraAdminPruneTasksResult) Read added in v1.1.0

func (*AuroraAdminPruneTasksResult) ReadField0 added in v1.21.0

func (p *AuroraAdminPruneTasksResult) ReadField0(iprot thrift.TProtocol) error

func (*AuroraAdminPruneTasksResult) String added in v1.1.0

func (p *AuroraAdminPruneTasksResult) String() string

func (*AuroraAdminPruneTasksResult) Write added in v1.1.0

type AuroraAdminQueryRecoveryArgs

type AuroraAdminQueryRecoveryArgs struct {
	Query *TaskQuery `thrift:"query,1" db:"query" json:"query"`
}

Attributes:

  • Query

func NewAuroraAdminQueryRecoveryArgs

func NewAuroraAdminQueryRecoveryArgs() *AuroraAdminQueryRecoveryArgs

func (*AuroraAdminQueryRecoveryArgs) GetQuery

func (p *AuroraAdminQueryRecoveryArgs) GetQuery() *TaskQuery

func (*AuroraAdminQueryRecoveryArgs) IsSetQuery

func (p *AuroraAdminQueryRecoveryArgs) IsSetQuery() bool

func (*AuroraAdminQueryRecoveryArgs) Read

func (*AuroraAdminQueryRecoveryArgs) ReadField1 added in v1.21.0

func (p *AuroraAdminQueryRecoveryArgs) ReadField1(iprot thrift.TProtocol) error

func (*AuroraAdminQueryRecoveryArgs) String

func (*AuroraAdminQueryRecoveryArgs) Write

type AuroraAdminQueryRecoveryResult

type AuroraAdminQueryRecoveryResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraAdminQueryRecoveryResult

func NewAuroraAdminQueryRecoveryResult() *AuroraAdminQueryRecoveryResult

func (*AuroraAdminQueryRecoveryResult) GetSuccess

func (p *AuroraAdminQueryRecoveryResult) GetSuccess() *Response

func (*AuroraAdminQueryRecoveryResult) IsSetSuccess

func (p *AuroraAdminQueryRecoveryResult) IsSetSuccess() bool

func (*AuroraAdminQueryRecoveryResult) Read

func (*AuroraAdminQueryRecoveryResult) ReadField0 added in v1.21.0

func (*AuroraAdminQueryRecoveryResult) String

func (*AuroraAdminQueryRecoveryResult) Write

type AuroraAdminSetQuotaArgs

type AuroraAdminSetQuotaArgs struct {
	OwnerRole string             `thrift:"ownerRole,1" db:"ownerRole" json:"ownerRole"`
	Quota     *ResourceAggregate `thrift:"quota,2" db:"quota" json:"quota"`
}

Attributes:

  • OwnerRole
  • Quota

func NewAuroraAdminSetQuotaArgs

func NewAuroraAdminSetQuotaArgs() *AuroraAdminSetQuotaArgs

func (*AuroraAdminSetQuotaArgs) GetOwnerRole

func (p *AuroraAdminSetQuotaArgs) GetOwnerRole() string

func (*AuroraAdminSetQuotaArgs) GetQuota

func (*AuroraAdminSetQuotaArgs) IsSetQuota

func (p *AuroraAdminSetQuotaArgs) IsSetQuota() bool

func (*AuroraAdminSetQuotaArgs) Read

func (*AuroraAdminSetQuotaArgs) ReadField1 added in v1.21.0

func (p *AuroraAdminSetQuotaArgs) ReadField1(iprot thrift.TProtocol) error

func (*AuroraAdminSetQuotaArgs) ReadField2 added in v1.21.0

func (p *AuroraAdminSetQuotaArgs) ReadField2(iprot thrift.TProtocol) error

func (*AuroraAdminSetQuotaArgs) String

func (p *AuroraAdminSetQuotaArgs) String() string

func (*AuroraAdminSetQuotaArgs) Write

type AuroraAdminSetQuotaResult

type AuroraAdminSetQuotaResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraAdminSetQuotaResult

func NewAuroraAdminSetQuotaResult() *AuroraAdminSetQuotaResult

func (*AuroraAdminSetQuotaResult) GetSuccess

func (p *AuroraAdminSetQuotaResult) GetSuccess() *Response

func (*AuroraAdminSetQuotaResult) IsSetSuccess

func (p *AuroraAdminSetQuotaResult) IsSetSuccess() bool

func (*AuroraAdminSetQuotaResult) Read

func (*AuroraAdminSetQuotaResult) ReadField0 added in v1.21.0

func (p *AuroraAdminSetQuotaResult) ReadField0(iprot thrift.TProtocol) error

func (*AuroraAdminSetQuotaResult) String

func (p *AuroraAdminSetQuotaResult) String() string

func (*AuroraAdminSetQuotaResult) Write

type AuroraAdminSlaDrainHostsArgs added in v1.3.1

type AuroraAdminSlaDrainHostsArgs struct {
	Hosts            *Hosts     `thrift:"hosts,1" db:"hosts" json:"hosts"`
	DefaultSlaPolicy *SlaPolicy `thrift:"defaultSlaPolicy,2" db:"defaultSlaPolicy" json:"defaultSlaPolicy"`
	TimeoutSecs      int64      `thrift:"timeoutSecs,3" db:"timeoutSecs" json:"timeoutSecs"`
}

Attributes:

  • Hosts
  • DefaultSlaPolicy
  • TimeoutSecs

func NewAuroraAdminSlaDrainHostsArgs added in v1.3.1

func NewAuroraAdminSlaDrainHostsArgs() *AuroraAdminSlaDrainHostsArgs

func (*AuroraAdminSlaDrainHostsArgs) GetDefaultSlaPolicy added in v1.3.1

func (p *AuroraAdminSlaDrainHostsArgs) GetDefaultSlaPolicy() *SlaPolicy

func (*AuroraAdminSlaDrainHostsArgs) GetHosts added in v1.3.1

func (p *AuroraAdminSlaDrainHostsArgs) GetHosts() *Hosts

func (*AuroraAdminSlaDrainHostsArgs) GetTimeoutSecs added in v1.3.1

func (p *AuroraAdminSlaDrainHostsArgs) GetTimeoutSecs() int64

func (*AuroraAdminSlaDrainHostsArgs) IsSetDefaultSlaPolicy added in v1.3.1

func (p *AuroraAdminSlaDrainHostsArgs) IsSetDefaultSlaPolicy() bool

func (*AuroraAdminSlaDrainHostsArgs) IsSetHosts added in v1.3.1

func (p *AuroraAdminSlaDrainHostsArgs) IsSetHosts() bool

func (*AuroraAdminSlaDrainHostsArgs) Read added in v1.3.1

func (*AuroraAdminSlaDrainHostsArgs) ReadField1 added in v1.21.0

func (p *AuroraAdminSlaDrainHostsArgs) ReadField1(iprot thrift.TProtocol) error

func (*AuroraAdminSlaDrainHostsArgs) ReadField2 added in v1.21.0

func (p *AuroraAdminSlaDrainHostsArgs) ReadField2(iprot thrift.TProtocol) error

func (*AuroraAdminSlaDrainHostsArgs) ReadField3 added in v1.21.0

func (p *AuroraAdminSlaDrainHostsArgs) ReadField3(iprot thrift.TProtocol) error

func (*AuroraAdminSlaDrainHostsArgs) String added in v1.3.1

func (*AuroraAdminSlaDrainHostsArgs) Write added in v1.3.1

type AuroraAdminSlaDrainHostsResult added in v1.3.1

type AuroraAdminSlaDrainHostsResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraAdminSlaDrainHostsResult added in v1.3.1

func NewAuroraAdminSlaDrainHostsResult() *AuroraAdminSlaDrainHostsResult

func (*AuroraAdminSlaDrainHostsResult) GetSuccess added in v1.3.1

func (p *AuroraAdminSlaDrainHostsResult) GetSuccess() *Response

func (*AuroraAdminSlaDrainHostsResult) IsSetSuccess added in v1.3.1

func (p *AuroraAdminSlaDrainHostsResult) IsSetSuccess() bool

func (*AuroraAdminSlaDrainHostsResult) Read added in v1.3.1

func (*AuroraAdminSlaDrainHostsResult) ReadField0 added in v1.21.0

func (*AuroraAdminSlaDrainHostsResult) String added in v1.3.1

func (*AuroraAdminSlaDrainHostsResult) Write added in v1.3.1

type AuroraAdminSnapshotArgs

type AuroraAdminSnapshotArgs struct {
}

func NewAuroraAdminSnapshotArgs

func NewAuroraAdminSnapshotArgs() *AuroraAdminSnapshotArgs

func (*AuroraAdminSnapshotArgs) Read

func (*AuroraAdminSnapshotArgs) String

func (p *AuroraAdminSnapshotArgs) String() string

func (*AuroraAdminSnapshotArgs) Write

type AuroraAdminSnapshotResult

type AuroraAdminSnapshotResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraAdminSnapshotResult

func NewAuroraAdminSnapshotResult() *AuroraAdminSnapshotResult

func (*AuroraAdminSnapshotResult) GetSuccess

func (p *AuroraAdminSnapshotResult) GetSuccess() *Response

func (*AuroraAdminSnapshotResult) IsSetSuccess

func (p *AuroraAdminSnapshotResult) IsSetSuccess() bool

func (*AuroraAdminSnapshotResult) Read

func (*AuroraAdminSnapshotResult) ReadField0 added in v1.21.0

func (p *AuroraAdminSnapshotResult) ReadField0(iprot thrift.TProtocol) error

func (*AuroraAdminSnapshotResult) String

func (p *AuroraAdminSnapshotResult) String() string

func (*AuroraAdminSnapshotResult) Write

type AuroraAdminStageRecoveryArgs

type AuroraAdminStageRecoveryArgs struct {
	BackupId string `thrift:"backupId,1" db:"backupId" json:"backupId"`
}

Attributes:

  • BackupId

func NewAuroraAdminStageRecoveryArgs

func NewAuroraAdminStageRecoveryArgs() *AuroraAdminStageRecoveryArgs

func (*AuroraAdminStageRecoveryArgs) GetBackupId

func (p *AuroraAdminStageRecoveryArgs) GetBackupId() string

func (*AuroraAdminStageRecoveryArgs) Read

func (*AuroraAdminStageRecoveryArgs) ReadField1 added in v1.21.0

func (p *AuroraAdminStageRecoveryArgs) ReadField1(iprot thrift.TProtocol) error

func (*AuroraAdminStageRecoveryArgs) String

func (*AuroraAdminStageRecoveryArgs) Write

type AuroraAdminStageRecoveryResult

type AuroraAdminStageRecoveryResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraAdminStageRecoveryResult

func NewAuroraAdminStageRecoveryResult() *AuroraAdminStageRecoveryResult

func (*AuroraAdminStageRecoveryResult) GetSuccess

func (p *AuroraAdminStageRecoveryResult) GetSuccess() *Response

func (*AuroraAdminStageRecoveryResult) IsSetSuccess

func (p *AuroraAdminStageRecoveryResult) IsSetSuccess() bool

func (*AuroraAdminStageRecoveryResult) Read

func (*AuroraAdminStageRecoveryResult) ReadField0 added in v1.21.0

func (*AuroraAdminStageRecoveryResult) String

func (*AuroraAdminStageRecoveryResult) Write

type AuroraAdminStartMaintenanceArgs

type AuroraAdminStartMaintenanceArgs struct {
	Hosts *Hosts `thrift:"hosts,1" db:"hosts" json:"hosts"`
}

Attributes:

  • Hosts

func NewAuroraAdminStartMaintenanceArgs

func NewAuroraAdminStartMaintenanceArgs() *AuroraAdminStartMaintenanceArgs

func (*AuroraAdminStartMaintenanceArgs) GetHosts

func (p *AuroraAdminStartMaintenanceArgs) GetHosts() *Hosts

func (*AuroraAdminStartMaintenanceArgs) IsSetHosts

func (p *AuroraAdminStartMaintenanceArgs) IsSetHosts() bool

func (*AuroraAdminStartMaintenanceArgs) Read

func (*AuroraAdminStartMaintenanceArgs) ReadField1 added in v1.21.0

func (*AuroraAdminStartMaintenanceArgs) String

func (*AuroraAdminStartMaintenanceArgs) Write

type AuroraAdminStartMaintenanceResult

type AuroraAdminStartMaintenanceResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraAdminStartMaintenanceResult

func NewAuroraAdminStartMaintenanceResult() *AuroraAdminStartMaintenanceResult

func (*AuroraAdminStartMaintenanceResult) GetSuccess

func (*AuroraAdminStartMaintenanceResult) IsSetSuccess

func (p *AuroraAdminStartMaintenanceResult) IsSetSuccess() bool

func (*AuroraAdminStartMaintenanceResult) Read

func (*AuroraAdminStartMaintenanceResult) ReadField0 added in v1.21.0

func (*AuroraAdminStartMaintenanceResult) String

func (*AuroraAdminStartMaintenanceResult) Write

type AuroraAdminTriggerExplicitTaskReconciliationArgs

type AuroraAdminTriggerExplicitTaskReconciliationArgs struct {
	Settings *ExplicitReconciliationSettings `thrift:"settings,1" db:"settings" json:"settings"`
}

Attributes:

  • Settings

func NewAuroraAdminTriggerExplicitTaskReconciliationArgs

func NewAuroraAdminTriggerExplicitTaskReconciliationArgs() *AuroraAdminTriggerExplicitTaskReconciliationArgs

func (*AuroraAdminTriggerExplicitTaskReconciliationArgs) GetSettings

func (*AuroraAdminTriggerExplicitTaskReconciliationArgs) IsSetSettings

func (*AuroraAdminTriggerExplicitTaskReconciliationArgs) Read

func (*AuroraAdminTriggerExplicitTaskReconciliationArgs) ReadField1 added in v1.21.0

func (*AuroraAdminTriggerExplicitTaskReconciliationArgs) String

func (*AuroraAdminTriggerExplicitTaskReconciliationArgs) Write

type AuroraAdminTriggerExplicitTaskReconciliationResult

type AuroraAdminTriggerExplicitTaskReconciliationResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraAdminTriggerExplicitTaskReconciliationResult

func NewAuroraAdminTriggerExplicitTaskReconciliationResult() *AuroraAdminTriggerExplicitTaskReconciliationResult

func (*AuroraAdminTriggerExplicitTaskReconciliationResult) GetSuccess

func (*AuroraAdminTriggerExplicitTaskReconciliationResult) IsSetSuccess

func (*AuroraAdminTriggerExplicitTaskReconciliationResult) Read

func (*AuroraAdminTriggerExplicitTaskReconciliationResult) ReadField0 added in v1.21.0

func (*AuroraAdminTriggerExplicitTaskReconciliationResult) String

func (*AuroraAdminTriggerExplicitTaskReconciliationResult) Write

type AuroraAdminTriggerImplicitTaskReconciliationArgs

type AuroraAdminTriggerImplicitTaskReconciliationArgs struct {
}

func NewAuroraAdminTriggerImplicitTaskReconciliationArgs

func NewAuroraAdminTriggerImplicitTaskReconciliationArgs() *AuroraAdminTriggerImplicitTaskReconciliationArgs

func (*AuroraAdminTriggerImplicitTaskReconciliationArgs) Read

func (*AuroraAdminTriggerImplicitTaskReconciliationArgs) String

func (*AuroraAdminTriggerImplicitTaskReconciliationArgs) Write

type AuroraAdminTriggerImplicitTaskReconciliationResult

type AuroraAdminTriggerImplicitTaskReconciliationResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraAdminTriggerImplicitTaskReconciliationResult

func NewAuroraAdminTriggerImplicitTaskReconciliationResult() *AuroraAdminTriggerImplicitTaskReconciliationResult

func (*AuroraAdminTriggerImplicitTaskReconciliationResult) GetSuccess

func (*AuroraAdminTriggerImplicitTaskReconciliationResult) IsSetSuccess

func (*AuroraAdminTriggerImplicitTaskReconciliationResult) Read

func (*AuroraAdminTriggerImplicitTaskReconciliationResult) ReadField0 added in v1.21.0

func (*AuroraAdminTriggerImplicitTaskReconciliationResult) String

func (*AuroraAdminTriggerImplicitTaskReconciliationResult) Write

type AuroraAdminUnloadRecoveryArgs

type AuroraAdminUnloadRecoveryArgs struct {
}

func NewAuroraAdminUnloadRecoveryArgs

func NewAuroraAdminUnloadRecoveryArgs() *AuroraAdminUnloadRecoveryArgs

func (*AuroraAdminUnloadRecoveryArgs) Read

func (*AuroraAdminUnloadRecoveryArgs) String

func (*AuroraAdminUnloadRecoveryArgs) Write

type AuroraAdminUnloadRecoveryResult

type AuroraAdminUnloadRecoveryResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraAdminUnloadRecoveryResult

func NewAuroraAdminUnloadRecoveryResult() *AuroraAdminUnloadRecoveryResult

func (*AuroraAdminUnloadRecoveryResult) GetSuccess

func (p *AuroraAdminUnloadRecoveryResult) GetSuccess() *Response

func (*AuroraAdminUnloadRecoveryResult) IsSetSuccess

func (p *AuroraAdminUnloadRecoveryResult) IsSetSuccess() bool

func (*AuroraAdminUnloadRecoveryResult) Read

func (*AuroraAdminUnloadRecoveryResult) ReadField0 added in v1.21.0

func (*AuroraAdminUnloadRecoveryResult) String

func (*AuroraAdminUnloadRecoveryResult) Write

type AuroraSchedulerManager

type AuroraSchedulerManager interface {
	ReadOnlyScheduler

	// Creates a new job.  The request will be denied if a job with the provided name already exists
	// in the cluster.
	//
	// Parameters:
	//  - Description
	CreateJob(ctx context.Context, description *JobConfiguration) (r *Response, err error)
	// Enters a job into the cron schedule, without actually starting the job.
	// If the job is already present in the schedule, this will update the schedule entry with the new
	// configuration.
	//
	// Parameters:
	//  - Description
	ScheduleCronJob(ctx context.Context, description *JobConfiguration) (r *Response, err error)
	// Removes a job from the cron schedule. The request will be denied if the job was not previously
	// scheduled with scheduleCronJob.
	//
	// Parameters:
	//  - Job
	DescheduleCronJob(ctx context.Context, job *JobKey) (r *Response, err error)
	// Starts a cron job immediately.  The request will be denied if the specified job does not
	// exist for the role account, or the job is not a cron job.
	//
	// Parameters:
	//  - Job
	StartCronJob(ctx context.Context, job *JobKey) (r *Response, err error)
	// Restarts a batch of shards.
	//
	// Parameters:
	//  - Job
	//  - ShardIds
	RestartShards(ctx context.Context, job *JobKey, shardIds []int32) (r *Response, err error)
	// Initiates a kill on tasks.
	//
	// Parameters:
	//  - Job
	//  - Instances
	//  - Message
	KillTasks(ctx context.Context, job *JobKey, instances []int32, message string) (r *Response, err error)
	// Adds new instances with the TaskConfig of the existing instance pointed by the key.
	//
	// Parameters:
	//  - Key
	//  - Count
	AddInstances(ctx context.Context, key *InstanceKey, count int32) (r *Response, err error)
	// Replaces the template (configuration) for the existing cron job.
	// The cron job template (configuration) must exist for the call to succeed.
	//
	// Parameters:
	//  - Config
	ReplaceCronTemplate(ctx context.Context, config *JobConfiguration) (r *Response, err error)
	// Starts update of the existing service job.
	//
	// Parameters:
	//  - Request: A description of how to change the job.
	//  - Message: A user-specified message to include with the induced job update state change.
	StartJobUpdate(ctx context.Context, request *JobUpdateRequest, message string) (r *Response, err error)
	// Pauses the specified job update. Can be resumed by resumeUpdate call.
	//
	// Parameters:
	//  - Key: The update to pause.
	//  - Message: A user-specified message to include with the induced job update state change.
	PauseJobUpdate(ctx context.Context, key *JobUpdateKey, message string) (r *Response, err error)
	// Resumes progress of a previously paused job update.
	//
	// Parameters:
	//  - Key: The update to resume.
	//  - Message: A user-specified message to include with the induced job update state change.
	ResumeJobUpdate(ctx context.Context, key *JobUpdateKey, message string) (r *Response, err error)
	// Permanently aborts the job update. Does not remove the update history.
	//
	// Parameters:
	//  - Key: The update to abort.
	//  - Message: A user-specified message to include with the induced job update state change.
	AbortJobUpdate(ctx context.Context, key *JobUpdateKey, message string) (r *Response, err error)
	// Rollbacks the specified active job update to the initial state.
	//
	// Parameters:
	//  - Key: The update to rollback.
	//  - Message: A user-specified message to include with the induced job update state change.
	RollbackJobUpdate(ctx context.Context, key *JobUpdateKey, message string) (r *Response, err error)
	// Allows progress of the job update in case blockIfNoPulsesAfterMs is specified in
	// JobUpdateSettings. Unblocks progress if the update was previously blocked.
	// Responds with ResponseCode.INVALID_REQUEST in case an unknown update key is specified.
	//
	// Parameters:
	//  - Key
	PulseJobUpdate(ctx context.Context, key *JobUpdateKey) (r *Response, err error)
}

type AuroraSchedulerManagerAbortJobUpdateArgs

type AuroraSchedulerManagerAbortJobUpdateArgs struct {
	Key *JobUpdateKey `thrift:"key,1" db:"key" json:"key"`
	// unused field # 2
	Message string `thrift:"message,3" db:"message" json:"message"`
}

Attributes:

  • Key: The update to abort.
  • Message: A user-specified message to include with the induced job update state change.

func NewAuroraSchedulerManagerAbortJobUpdateArgs

func NewAuroraSchedulerManagerAbortJobUpdateArgs() *AuroraSchedulerManagerAbortJobUpdateArgs

func (*AuroraSchedulerManagerAbortJobUpdateArgs) GetKey

func (*AuroraSchedulerManagerAbortJobUpdateArgs) GetMessage

func (*AuroraSchedulerManagerAbortJobUpdateArgs) IsSetKey

func (*AuroraSchedulerManagerAbortJobUpdateArgs) Read

func (*AuroraSchedulerManagerAbortJobUpdateArgs) ReadField1 added in v1.21.0

func (*AuroraSchedulerManagerAbortJobUpdateArgs) ReadField3 added in v1.21.0

func (*AuroraSchedulerManagerAbortJobUpdateArgs) String

func (*AuroraSchedulerManagerAbortJobUpdateArgs) Write

type AuroraSchedulerManagerAbortJobUpdateResult

type AuroraSchedulerManagerAbortJobUpdateResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraSchedulerManagerAbortJobUpdateResult

func NewAuroraSchedulerManagerAbortJobUpdateResult() *AuroraSchedulerManagerAbortJobUpdateResult

func (*AuroraSchedulerManagerAbortJobUpdateResult) GetSuccess

func (*AuroraSchedulerManagerAbortJobUpdateResult) IsSetSuccess

func (*AuroraSchedulerManagerAbortJobUpdateResult) Read

func (*AuroraSchedulerManagerAbortJobUpdateResult) ReadField0 added in v1.21.0

func (*AuroraSchedulerManagerAbortJobUpdateResult) String

func (*AuroraSchedulerManagerAbortJobUpdateResult) Write

type AuroraSchedulerManagerAddInstancesArgs

type AuroraSchedulerManagerAddInstancesArgs struct {
	// unused fields # 1 to 2
	Key   *InstanceKey `thrift:"key,3" db:"key" json:"key"`
	Count int32        `thrift:"count,4" db:"count" json:"count"`
}

Attributes:

  • Key
  • Count

func NewAuroraSchedulerManagerAddInstancesArgs

func NewAuroraSchedulerManagerAddInstancesArgs() *AuroraSchedulerManagerAddInstancesArgs

func (*AuroraSchedulerManagerAddInstancesArgs) GetCount

func (*AuroraSchedulerManagerAddInstancesArgs) GetKey

func (*AuroraSchedulerManagerAddInstancesArgs) IsSetKey

func (*AuroraSchedulerManagerAddInstancesArgs) Read

func (*AuroraSchedulerManagerAddInstancesArgs) ReadField3 added in v1.21.0

func (*AuroraSchedulerManagerAddInstancesArgs) ReadField4 added in v1.21.0

func (*AuroraSchedulerManagerAddInstancesArgs) String

func (*AuroraSchedulerManagerAddInstancesArgs) Write

type AuroraSchedulerManagerAddInstancesResult

type AuroraSchedulerManagerAddInstancesResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraSchedulerManagerAddInstancesResult

func NewAuroraSchedulerManagerAddInstancesResult() *AuroraSchedulerManagerAddInstancesResult

func (*AuroraSchedulerManagerAddInstancesResult) GetSuccess

func (*AuroraSchedulerManagerAddInstancesResult) IsSetSuccess

func (*AuroraSchedulerManagerAddInstancesResult) Read

func (*AuroraSchedulerManagerAddInstancesResult) ReadField0 added in v1.21.0

func (*AuroraSchedulerManagerAddInstancesResult) String

func (*AuroraSchedulerManagerAddInstancesResult) Write

type AuroraSchedulerManagerClient

type AuroraSchedulerManagerClient struct {
	*ReadOnlySchedulerClient
}

func NewAuroraSchedulerManagerClient added in v1.21.0

func NewAuroraSchedulerManagerClient(c thrift.TClient) *AuroraSchedulerManagerClient

func NewAuroraSchedulerManagerClientProtocol

func NewAuroraSchedulerManagerClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *AuroraSchedulerManagerClient

func (*AuroraSchedulerManagerClient) AbortJobUpdate

func (p *AuroraSchedulerManagerClient) AbortJobUpdate(ctx context.Context, key *JobUpdateKey, message string) (r *Response, err error)

Permanently aborts the job update. Does not remove the update history.

Parameters:

  • Key: The update to abort.
  • Message: A user-specified message to include with the induced job update state change.

func (*AuroraSchedulerManagerClient) AddInstances

func (p *AuroraSchedulerManagerClient) AddInstances(ctx context.Context, key *InstanceKey, count int32) (r *Response, err error)

Adds new instances with the TaskConfig of the existing instance pointed by the key.

Parameters:

  • Key
  • Count

func (*AuroraSchedulerManagerClient) CreateJob

func (p *AuroraSchedulerManagerClient) CreateJob(ctx context.Context, description *JobConfiguration) (r *Response, err error)

Creates a new job. The request will be denied if a job with the provided name already exists in the cluster.

Parameters:

  • Description

func (*AuroraSchedulerManagerClient) DescheduleCronJob

func (p *AuroraSchedulerManagerClient) DescheduleCronJob(ctx context.Context, job *JobKey) (r *Response, err error)

Removes a job from the cron schedule. The request will be denied if the job was not previously scheduled with scheduleCronJob.

Parameters:

  • Job

func (*AuroraSchedulerManagerClient) KillTasks

func (p *AuroraSchedulerManagerClient) KillTasks(ctx context.Context, job *JobKey, instances []int32, message string) (r *Response, err error)

Initiates a kill on tasks.

Parameters:

  • Job
  • Instances
  • Message

func (*AuroraSchedulerManagerClient) PauseJobUpdate

func (p *AuroraSchedulerManagerClient) PauseJobUpdate(ctx context.Context, key *JobUpdateKey, message string) (r *Response, err error)

Pauses the specified job update. Can be resumed by resumeUpdate call.

Parameters:

  • Key: The update to pause.
  • Message: A user-specified message to include with the induced job update state change.

func (*AuroraSchedulerManagerClient) PulseJobUpdate

func (p *AuroraSchedulerManagerClient) PulseJobUpdate(ctx context.Context, key *JobUpdateKey) (r *Response, err error)

Allows progress of the job update in case blockIfNoPulsesAfterMs is specified in JobUpdateSettings. Unblocks progress if the update was previously blocked. Responds with ResponseCode.INVALID_REQUEST in case an unknown update key is specified.

Parameters:

  • Key

func (*AuroraSchedulerManagerClient) ReplaceCronTemplate

func (p *AuroraSchedulerManagerClient) ReplaceCronTemplate(ctx context.Context, config *JobConfiguration) (r *Response, err error)

Replaces the template (configuration) for the existing cron job. The cron job template (configuration) must exist for the call to succeed.

Parameters:

  • Config

func (*AuroraSchedulerManagerClient) RestartShards

func (p *AuroraSchedulerManagerClient) RestartShards(ctx context.Context, job *JobKey, shardIds []int32) (r *Response, err error)

Restarts a batch of shards.

Parameters:

  • Job
  • ShardIds

func (*AuroraSchedulerManagerClient) ResumeJobUpdate

func (p *AuroraSchedulerManagerClient) ResumeJobUpdate(ctx context.Context, key *JobUpdateKey, message string) (r *Response, err error)

Resumes progress of a previously paused job update.

Parameters:

  • Key: The update to resume.
  • Message: A user-specified message to include with the induced job update state change.

func (*AuroraSchedulerManagerClient) RollbackJobUpdate

func (p *AuroraSchedulerManagerClient) RollbackJobUpdate(ctx context.Context, key *JobUpdateKey, message string) (r *Response, err error)

Rollbacks the specified active job update to the initial state.

Parameters:

  • Key: The update to rollback.
  • Message: A user-specified message to include with the induced job update state change.

func (*AuroraSchedulerManagerClient) ScheduleCronJob

func (p *AuroraSchedulerManagerClient) ScheduleCronJob(ctx context.Context, description *JobConfiguration) (r *Response, err error)

Enters a job into the cron schedule, without actually starting the job. If the job is already present in the schedule, this will update the schedule entry with the new configuration.

Parameters:

  • Description

func (*AuroraSchedulerManagerClient) StartCronJob

func (p *AuroraSchedulerManagerClient) StartCronJob(ctx context.Context, job *JobKey) (r *Response, err error)

Starts a cron job immediately. The request will be denied if the specified job does not exist for the role account, or the job is not a cron job.

Parameters:

  • Job

func (*AuroraSchedulerManagerClient) StartJobUpdate

func (p *AuroraSchedulerManagerClient) StartJobUpdate(ctx context.Context, request *JobUpdateRequest, message string) (r *Response, err error)

Starts update of the existing service job.

Parameters:

  • Request: A description of how to change the job.
  • Message: A user-specified message to include with the induced job update state change.

type AuroraSchedulerManagerCreateJobArgs

type AuroraSchedulerManagerCreateJobArgs struct {
	Description *JobConfiguration `thrift:"description,1" db:"description" json:"description"`
}

Attributes:

  • Description

func NewAuroraSchedulerManagerCreateJobArgs

func NewAuroraSchedulerManagerCreateJobArgs() *AuroraSchedulerManagerCreateJobArgs

func (*AuroraSchedulerManagerCreateJobArgs) GetDescription

func (*AuroraSchedulerManagerCreateJobArgs) IsSetDescription

func (p *AuroraSchedulerManagerCreateJobArgs) IsSetDescription() bool

func (*AuroraSchedulerManagerCreateJobArgs) Read

func (*AuroraSchedulerManagerCreateJobArgs) ReadField1 added in v1.21.0

func (*AuroraSchedulerManagerCreateJobArgs) String

func (*AuroraSchedulerManagerCreateJobArgs) Write

type AuroraSchedulerManagerCreateJobResult

type AuroraSchedulerManagerCreateJobResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraSchedulerManagerCreateJobResult

func NewAuroraSchedulerManagerCreateJobResult() *AuroraSchedulerManagerCreateJobResult

func (*AuroraSchedulerManagerCreateJobResult) GetSuccess

func (*AuroraSchedulerManagerCreateJobResult) IsSetSuccess

func (p *AuroraSchedulerManagerCreateJobResult) IsSetSuccess() bool

func (*AuroraSchedulerManagerCreateJobResult) Read

func (*AuroraSchedulerManagerCreateJobResult) ReadField0 added in v1.21.0

func (*AuroraSchedulerManagerCreateJobResult) String

func (*AuroraSchedulerManagerCreateJobResult) Write

type AuroraSchedulerManagerDescheduleCronJobArgs

type AuroraSchedulerManagerDescheduleCronJobArgs struct {
	// unused fields # 1 to 3
	Job *JobKey `thrift:"job,4" db:"job" json:"job"`
}

Attributes:

  • Job

func NewAuroraSchedulerManagerDescheduleCronJobArgs

func NewAuroraSchedulerManagerDescheduleCronJobArgs() *AuroraSchedulerManagerDescheduleCronJobArgs

func (*AuroraSchedulerManagerDescheduleCronJobArgs) GetJob

func (*AuroraSchedulerManagerDescheduleCronJobArgs) IsSetJob

func (*AuroraSchedulerManagerDescheduleCronJobArgs) Read

func (*AuroraSchedulerManagerDescheduleCronJobArgs) ReadField4 added in v1.21.0

func (*AuroraSchedulerManagerDescheduleCronJobArgs) String

func (*AuroraSchedulerManagerDescheduleCronJobArgs) Write

type AuroraSchedulerManagerDescheduleCronJobResult

type AuroraSchedulerManagerDescheduleCronJobResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraSchedulerManagerDescheduleCronJobResult

func NewAuroraSchedulerManagerDescheduleCronJobResult() *AuroraSchedulerManagerDescheduleCronJobResult

func (*AuroraSchedulerManagerDescheduleCronJobResult) GetSuccess

func (*AuroraSchedulerManagerDescheduleCronJobResult) IsSetSuccess

func (*AuroraSchedulerManagerDescheduleCronJobResult) Read

func (*AuroraSchedulerManagerDescheduleCronJobResult) ReadField0 added in v1.21.0

func (*AuroraSchedulerManagerDescheduleCronJobResult) String

func (*AuroraSchedulerManagerDescheduleCronJobResult) Write

type AuroraSchedulerManagerKillTasksArgs

type AuroraSchedulerManagerKillTasksArgs struct {
	// unused fields # 1 to 3
	Job       *JobKey `thrift:"job,4" db:"job" json:"job"`
	Instances []int32 `thrift:"instances,5" db:"instances" json:"instances"`
	Message   string  `thrift:"message,6" db:"message" json:"message"`
}

Attributes:

  • Job
  • Instances
  • Message

func NewAuroraSchedulerManagerKillTasksArgs

func NewAuroraSchedulerManagerKillTasksArgs() *AuroraSchedulerManagerKillTasksArgs

func (*AuroraSchedulerManagerKillTasksArgs) GetInstances

func (p *AuroraSchedulerManagerKillTasksArgs) GetInstances() []int32

func (*AuroraSchedulerManagerKillTasksArgs) GetJob

func (*AuroraSchedulerManagerKillTasksArgs) GetMessage added in v1.1.0

func (*AuroraSchedulerManagerKillTasksArgs) IsSetJob

func (*AuroraSchedulerManagerKillTasksArgs) Read

func (*AuroraSchedulerManagerKillTasksArgs) ReadField4 added in v1.21.0

func (*AuroraSchedulerManagerKillTasksArgs) ReadField5 added in v1.21.0

func (*AuroraSchedulerManagerKillTasksArgs) ReadField6 added in v1.21.0

func (*AuroraSchedulerManagerKillTasksArgs) String

func (*AuroraSchedulerManagerKillTasksArgs) Write

type AuroraSchedulerManagerKillTasksResult

type AuroraSchedulerManagerKillTasksResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraSchedulerManagerKillTasksResult

func NewAuroraSchedulerManagerKillTasksResult() *AuroraSchedulerManagerKillTasksResult

func (*AuroraSchedulerManagerKillTasksResult) GetSuccess

func (*AuroraSchedulerManagerKillTasksResult) IsSetSuccess

func (p *AuroraSchedulerManagerKillTasksResult) IsSetSuccess() bool

func (*AuroraSchedulerManagerKillTasksResult) Read

func (*AuroraSchedulerManagerKillTasksResult) ReadField0 added in v1.21.0

func (*AuroraSchedulerManagerKillTasksResult) String

func (*AuroraSchedulerManagerKillTasksResult) Write

type AuroraSchedulerManagerPauseJobUpdateArgs

type AuroraSchedulerManagerPauseJobUpdateArgs struct {
	Key *JobUpdateKey `thrift:"key,1" db:"key" json:"key"`
	// unused field # 2
	Message string `thrift:"message,3" db:"message" json:"message"`
}

Attributes:

  • Key: The update to pause.
  • Message: A user-specified message to include with the induced job update state change.

func NewAuroraSchedulerManagerPauseJobUpdateArgs

func NewAuroraSchedulerManagerPauseJobUpdateArgs() *AuroraSchedulerManagerPauseJobUpdateArgs

func (*AuroraSchedulerManagerPauseJobUpdateArgs) GetKey

func (*AuroraSchedulerManagerPauseJobUpdateArgs) GetMessage

func (*AuroraSchedulerManagerPauseJobUpdateArgs) IsSetKey

func (*AuroraSchedulerManagerPauseJobUpdateArgs) Read

func (*AuroraSchedulerManagerPauseJobUpdateArgs) ReadField1 added in v1.21.0

func (*AuroraSchedulerManagerPauseJobUpdateArgs) ReadField3 added in v1.21.0

func (*AuroraSchedulerManagerPauseJobUpdateArgs) String

func (*AuroraSchedulerManagerPauseJobUpdateArgs) Write

type AuroraSchedulerManagerPauseJobUpdateResult

type AuroraSchedulerManagerPauseJobUpdateResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraSchedulerManagerPauseJobUpdateResult

func NewAuroraSchedulerManagerPauseJobUpdateResult() *AuroraSchedulerManagerPauseJobUpdateResult

func (*AuroraSchedulerManagerPauseJobUpdateResult) GetSuccess

func (*AuroraSchedulerManagerPauseJobUpdateResult) IsSetSuccess

func (*AuroraSchedulerManagerPauseJobUpdateResult) Read

func (*AuroraSchedulerManagerPauseJobUpdateResult) ReadField0 added in v1.21.0

func (*AuroraSchedulerManagerPauseJobUpdateResult) String

func (*AuroraSchedulerManagerPauseJobUpdateResult) Write

type AuroraSchedulerManagerProcessor

type AuroraSchedulerManagerProcessor struct {
	*ReadOnlySchedulerProcessor
}

func NewAuroraSchedulerManagerProcessor

func NewAuroraSchedulerManagerProcessor(handler AuroraSchedulerManager) *AuroraSchedulerManagerProcessor

type AuroraSchedulerManagerPulseJobUpdateArgs

type AuroraSchedulerManagerPulseJobUpdateArgs struct {
	Key *JobUpdateKey `thrift:"key,1" db:"key" json:"key"`
}

Attributes:

  • Key

func NewAuroraSchedulerManagerPulseJobUpdateArgs

func NewAuroraSchedulerManagerPulseJobUpdateArgs() *AuroraSchedulerManagerPulseJobUpdateArgs

func (*AuroraSchedulerManagerPulseJobUpdateArgs) GetKey

func (*AuroraSchedulerManagerPulseJobUpdateArgs) IsSetKey

func (*AuroraSchedulerManagerPulseJobUpdateArgs) Read

func (*AuroraSchedulerManagerPulseJobUpdateArgs) ReadField1 added in v1.21.0

func (*AuroraSchedulerManagerPulseJobUpdateArgs) String

func (*AuroraSchedulerManagerPulseJobUpdateArgs) Write

type AuroraSchedulerManagerPulseJobUpdateResult

type AuroraSchedulerManagerPulseJobUpdateResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraSchedulerManagerPulseJobUpdateResult

func NewAuroraSchedulerManagerPulseJobUpdateResult() *AuroraSchedulerManagerPulseJobUpdateResult

func (*AuroraSchedulerManagerPulseJobUpdateResult) GetSuccess

func (*AuroraSchedulerManagerPulseJobUpdateResult) IsSetSuccess

func (*AuroraSchedulerManagerPulseJobUpdateResult) Read

func (*AuroraSchedulerManagerPulseJobUpdateResult) ReadField0 added in v1.21.0

func (*AuroraSchedulerManagerPulseJobUpdateResult) String

func (*AuroraSchedulerManagerPulseJobUpdateResult) Write

type AuroraSchedulerManagerReplaceCronTemplateArgs

type AuroraSchedulerManagerReplaceCronTemplateArgs struct {
	Config *JobConfiguration `thrift:"config,1" db:"config" json:"config"`
}

Attributes:

  • Config

func NewAuroraSchedulerManagerReplaceCronTemplateArgs

func NewAuroraSchedulerManagerReplaceCronTemplateArgs() *AuroraSchedulerManagerReplaceCronTemplateArgs

func (*AuroraSchedulerManagerReplaceCronTemplateArgs) GetConfig

func (*AuroraSchedulerManagerReplaceCronTemplateArgs) IsSetConfig

func (*AuroraSchedulerManagerReplaceCronTemplateArgs) Read

func (*AuroraSchedulerManagerReplaceCronTemplateArgs) ReadField1 added in v1.21.0

func (*AuroraSchedulerManagerReplaceCronTemplateArgs) String

func (*AuroraSchedulerManagerReplaceCronTemplateArgs) Write

type AuroraSchedulerManagerReplaceCronTemplateResult

type AuroraSchedulerManagerReplaceCronTemplateResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraSchedulerManagerReplaceCronTemplateResult

func NewAuroraSchedulerManagerReplaceCronTemplateResult() *AuroraSchedulerManagerReplaceCronTemplateResult

func (*AuroraSchedulerManagerReplaceCronTemplateResult) GetSuccess

func (*AuroraSchedulerManagerReplaceCronTemplateResult) IsSetSuccess

func (*AuroraSchedulerManagerReplaceCronTemplateResult) Read

func (*AuroraSchedulerManagerReplaceCronTemplateResult) ReadField0 added in v1.21.0

func (*AuroraSchedulerManagerReplaceCronTemplateResult) String

func (*AuroraSchedulerManagerReplaceCronTemplateResult) Write

type AuroraSchedulerManagerRestartShardsArgs

type AuroraSchedulerManagerRestartShardsArgs struct {
	// unused fields # 1 to 2
	ShardIds []int32 `thrift:"shardIds,3" db:"shardIds" json:"shardIds"`
	// unused field # 4
	Job *JobKey `thrift:"job,5" db:"job" json:"job"`
}

Attributes:

  • Job
  • ShardIds

func NewAuroraSchedulerManagerRestartShardsArgs

func NewAuroraSchedulerManagerRestartShardsArgs() *AuroraSchedulerManagerRestartShardsArgs

func (*AuroraSchedulerManagerRestartShardsArgs) GetJob

func (*AuroraSchedulerManagerRestartShardsArgs) GetShardIds

func (*AuroraSchedulerManagerRestartShardsArgs) IsSetJob

func (*AuroraSchedulerManagerRestartShardsArgs) Read

func (*AuroraSchedulerManagerRestartShardsArgs) ReadField3 added in v1.21.0

func (*AuroraSchedulerManagerRestartShardsArgs) ReadField5 added in v1.21.0

func (*AuroraSchedulerManagerRestartShardsArgs) String

func (*AuroraSchedulerManagerRestartShardsArgs) Write

type AuroraSchedulerManagerRestartShardsResult

type AuroraSchedulerManagerRestartShardsResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraSchedulerManagerRestartShardsResult

func NewAuroraSchedulerManagerRestartShardsResult() *AuroraSchedulerManagerRestartShardsResult

func (*AuroraSchedulerManagerRestartShardsResult) GetSuccess

func (*AuroraSchedulerManagerRestartShardsResult) IsSetSuccess

func (*AuroraSchedulerManagerRestartShardsResult) Read

func (*AuroraSchedulerManagerRestartShardsResult) ReadField0 added in v1.21.0

func (*AuroraSchedulerManagerRestartShardsResult) String

func (*AuroraSchedulerManagerRestartShardsResult) Write

type AuroraSchedulerManagerResumeJobUpdateArgs

type AuroraSchedulerManagerResumeJobUpdateArgs struct {
	Key *JobUpdateKey `thrift:"key,1" db:"key" json:"key"`
	// unused field # 2
	Message string `thrift:"message,3" db:"message" json:"message"`
}

Attributes:

  • Key: The update to resume.
  • Message: A user-specified message to include with the induced job update state change.

func NewAuroraSchedulerManagerResumeJobUpdateArgs

func NewAuroraSchedulerManagerResumeJobUpdateArgs() *AuroraSchedulerManagerResumeJobUpdateArgs

func (*AuroraSchedulerManagerResumeJobUpdateArgs) GetKey

func (*AuroraSchedulerManagerResumeJobUpdateArgs) GetMessage

func (*AuroraSchedulerManagerResumeJobUpdateArgs) IsSetKey

func (*AuroraSchedulerManagerResumeJobUpdateArgs) Read

func (*AuroraSchedulerManagerResumeJobUpdateArgs) ReadField1 added in v1.21.0

func (*AuroraSchedulerManagerResumeJobUpdateArgs) ReadField3 added in v1.21.0

func (*AuroraSchedulerManagerResumeJobUpdateArgs) String

func (*AuroraSchedulerManagerResumeJobUpdateArgs) Write

type AuroraSchedulerManagerResumeJobUpdateResult

type AuroraSchedulerManagerResumeJobUpdateResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraSchedulerManagerResumeJobUpdateResult

func NewAuroraSchedulerManagerResumeJobUpdateResult() *AuroraSchedulerManagerResumeJobUpdateResult

func (*AuroraSchedulerManagerResumeJobUpdateResult) GetSuccess

func (*AuroraSchedulerManagerResumeJobUpdateResult) IsSetSuccess

func (*AuroraSchedulerManagerResumeJobUpdateResult) Read

func (*AuroraSchedulerManagerResumeJobUpdateResult) ReadField0 added in v1.21.0

func (*AuroraSchedulerManagerResumeJobUpdateResult) String

func (*AuroraSchedulerManagerResumeJobUpdateResult) Write

type AuroraSchedulerManagerRollbackJobUpdateArgs

type AuroraSchedulerManagerRollbackJobUpdateArgs struct {
	Key     *JobUpdateKey `thrift:"key,1" db:"key" json:"key"`
	Message string        `thrift:"message,2" db:"message" json:"message"`
}

Attributes:

  • Key: The update to rollback.
  • Message: A user-specified message to include with the induced job update state change.

func NewAuroraSchedulerManagerRollbackJobUpdateArgs

func NewAuroraSchedulerManagerRollbackJobUpdateArgs() *AuroraSchedulerManagerRollbackJobUpdateArgs

func (*AuroraSchedulerManagerRollbackJobUpdateArgs) GetKey

func (*AuroraSchedulerManagerRollbackJobUpdateArgs) GetMessage

func (*AuroraSchedulerManagerRollbackJobUpdateArgs) IsSetKey

func (*AuroraSchedulerManagerRollbackJobUpdateArgs) Read

func (*AuroraSchedulerManagerRollbackJobUpdateArgs) ReadField1 added in v1.21.0

func (*AuroraSchedulerManagerRollbackJobUpdateArgs) ReadField2 added in v1.21.0

func (*AuroraSchedulerManagerRollbackJobUpdateArgs) String

func (*AuroraSchedulerManagerRollbackJobUpdateArgs) Write

type AuroraSchedulerManagerRollbackJobUpdateResult

type AuroraSchedulerManagerRollbackJobUpdateResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraSchedulerManagerRollbackJobUpdateResult

func NewAuroraSchedulerManagerRollbackJobUpdateResult() *AuroraSchedulerManagerRollbackJobUpdateResult

func (*AuroraSchedulerManagerRollbackJobUpdateResult) GetSuccess

func (*AuroraSchedulerManagerRollbackJobUpdateResult) IsSetSuccess

func (*AuroraSchedulerManagerRollbackJobUpdateResult) Read

func (*AuroraSchedulerManagerRollbackJobUpdateResult) ReadField0 added in v1.21.0

func (*AuroraSchedulerManagerRollbackJobUpdateResult) String

func (*AuroraSchedulerManagerRollbackJobUpdateResult) Write

type AuroraSchedulerManagerScheduleCronJobArgs

type AuroraSchedulerManagerScheduleCronJobArgs struct {
	Description *JobConfiguration `thrift:"description,1" db:"description" json:"description"`
}

Attributes:

  • Description

func NewAuroraSchedulerManagerScheduleCronJobArgs

func NewAuroraSchedulerManagerScheduleCronJobArgs() *AuroraSchedulerManagerScheduleCronJobArgs

func (*AuroraSchedulerManagerScheduleCronJobArgs) GetDescription

func (*AuroraSchedulerManagerScheduleCronJobArgs) IsSetDescription

func (p *AuroraSchedulerManagerScheduleCronJobArgs) IsSetDescription() bool

func (*AuroraSchedulerManagerScheduleCronJobArgs) Read

func (*AuroraSchedulerManagerScheduleCronJobArgs) ReadField1 added in v1.21.0

func (*AuroraSchedulerManagerScheduleCronJobArgs) String

func (*AuroraSchedulerManagerScheduleCronJobArgs) Write

type AuroraSchedulerManagerScheduleCronJobResult

type AuroraSchedulerManagerScheduleCronJobResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraSchedulerManagerScheduleCronJobResult

func NewAuroraSchedulerManagerScheduleCronJobResult() *AuroraSchedulerManagerScheduleCronJobResult

func (*AuroraSchedulerManagerScheduleCronJobResult) GetSuccess

func (*AuroraSchedulerManagerScheduleCronJobResult) IsSetSuccess

func (*AuroraSchedulerManagerScheduleCronJobResult) Read

func (*AuroraSchedulerManagerScheduleCronJobResult) ReadField0 added in v1.21.0

func (*AuroraSchedulerManagerScheduleCronJobResult) String

func (*AuroraSchedulerManagerScheduleCronJobResult) Write

type AuroraSchedulerManagerStartCronJobArgs

type AuroraSchedulerManagerStartCronJobArgs struct {
	// unused fields # 1 to 3
	Job *JobKey `thrift:"job,4" db:"job" json:"job"`
}

Attributes:

  • Job

func NewAuroraSchedulerManagerStartCronJobArgs

func NewAuroraSchedulerManagerStartCronJobArgs() *AuroraSchedulerManagerStartCronJobArgs

func (*AuroraSchedulerManagerStartCronJobArgs) GetJob

func (*AuroraSchedulerManagerStartCronJobArgs) IsSetJob

func (*AuroraSchedulerManagerStartCronJobArgs) Read

func (*AuroraSchedulerManagerStartCronJobArgs) ReadField4 added in v1.21.0

func (*AuroraSchedulerManagerStartCronJobArgs) String

func (*AuroraSchedulerManagerStartCronJobArgs) Write

type AuroraSchedulerManagerStartCronJobResult

type AuroraSchedulerManagerStartCronJobResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraSchedulerManagerStartCronJobResult

func NewAuroraSchedulerManagerStartCronJobResult() *AuroraSchedulerManagerStartCronJobResult

func (*AuroraSchedulerManagerStartCronJobResult) GetSuccess

func (*AuroraSchedulerManagerStartCronJobResult) IsSetSuccess

func (*AuroraSchedulerManagerStartCronJobResult) Read

func (*AuroraSchedulerManagerStartCronJobResult) ReadField0 added in v1.21.0

func (*AuroraSchedulerManagerStartCronJobResult) String

func (*AuroraSchedulerManagerStartCronJobResult) Write

type AuroraSchedulerManagerStartJobUpdateArgs

type AuroraSchedulerManagerStartJobUpdateArgs struct {
	Request *JobUpdateRequest `thrift:"request,1" db:"request" json:"request"`
	// unused field # 2
	Message string `thrift:"message,3" db:"message" json:"message"`
}

Attributes:

  • Request: A description of how to change the job.
  • Message: A user-specified message to include with the induced job update state change.

func NewAuroraSchedulerManagerStartJobUpdateArgs

func NewAuroraSchedulerManagerStartJobUpdateArgs() *AuroraSchedulerManagerStartJobUpdateArgs

func (*AuroraSchedulerManagerStartJobUpdateArgs) GetMessage

func (*AuroraSchedulerManagerStartJobUpdateArgs) GetRequest

func (*AuroraSchedulerManagerStartJobUpdateArgs) IsSetRequest

func (*AuroraSchedulerManagerStartJobUpdateArgs) Read

func (*AuroraSchedulerManagerStartJobUpdateArgs) ReadField1 added in v1.21.0

func (*AuroraSchedulerManagerStartJobUpdateArgs) ReadField3 added in v1.21.0

func (*AuroraSchedulerManagerStartJobUpdateArgs) String

func (*AuroraSchedulerManagerStartJobUpdateArgs) Write

type AuroraSchedulerManagerStartJobUpdateResult

type AuroraSchedulerManagerStartJobUpdateResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAuroraSchedulerManagerStartJobUpdateResult

func NewAuroraSchedulerManagerStartJobUpdateResult() *AuroraSchedulerManagerStartJobUpdateResult

func (*AuroraSchedulerManagerStartJobUpdateResult) GetSuccess

func (*AuroraSchedulerManagerStartJobUpdateResult) IsSetSuccess

func (*AuroraSchedulerManagerStartJobUpdateResult) Read

func (*AuroraSchedulerManagerStartJobUpdateResult) ReadField0 added in v1.21.0

func (*AuroraSchedulerManagerStartJobUpdateResult) String

func (*AuroraSchedulerManagerStartJobUpdateResult) Write

type ConfigGroup

type ConfigGroup struct {
	Config *TaskConfig `thrift:"config,1" db:"config" json:"config"`
	// unused field # 2
	Instances []*Range `thrift:"instances,3" db:"instances" json:"instances"`
}

Attributes:

  • Config
  • Instances

func NewConfigGroup

func NewConfigGroup() *ConfigGroup

func (*ConfigGroup) GetConfig

func (p *ConfigGroup) GetConfig() *TaskConfig

func (*ConfigGroup) GetInstances

func (p *ConfigGroup) GetInstances() []*Range

func (*ConfigGroup) IsSetConfig

func (p *ConfigGroup) IsSetConfig() bool

func (*ConfigGroup) Read

func (p *ConfigGroup) Read(iprot thrift.TProtocol) error

func (*ConfigGroup) ReadField1 added in v1.21.0

func (p *ConfigGroup) ReadField1(iprot thrift.TProtocol) error

func (*ConfigGroup) ReadField3 added in v1.21.0

func (p *ConfigGroup) ReadField3(iprot thrift.TProtocol) error

func (*ConfigGroup) String

func (p *ConfigGroup) String() string

func (*ConfigGroup) Write

func (p *ConfigGroup) Write(oprot thrift.TProtocol) error

type ConfigSummary

type ConfigSummary struct {
	Key    *JobKey        `thrift:"key,1" db:"key" json:"key"`
	Groups []*ConfigGroup `thrift:"groups,2" db:"groups" json:"groups"`
}

Attributes:

  • Key
  • Groups
var ConfigSummaryResult__Summary_DEFAULT *ConfigSummary

func NewConfigSummary

func NewConfigSummary() *ConfigSummary

func (*ConfigSummary) GetGroups

func (p *ConfigSummary) GetGroups() []*ConfigGroup

func (*ConfigSummary) GetKey

func (p *ConfigSummary) GetKey() *JobKey

func (*ConfigSummary) IsSetKey

func (p *ConfigSummary) IsSetKey() bool

func (*ConfigSummary) Read

func (p *ConfigSummary) Read(iprot thrift.TProtocol) error

func (*ConfigSummary) ReadField1 added in v1.21.0

func (p *ConfigSummary) ReadField1(iprot thrift.TProtocol) error

func (*ConfigSummary) ReadField2 added in v1.21.0

func (p *ConfigSummary) ReadField2(iprot thrift.TProtocol) error

func (*ConfigSummary) String

func (p *ConfigSummary) String() string

func (*ConfigSummary) Write

func (p *ConfigSummary) Write(oprot thrift.TProtocol) error

type ConfigSummaryResult_

type ConfigSummaryResult_ struct {
	Summary *ConfigSummary `thrift:"summary,1" db:"summary" json:"summary"`
}

Attributes:

  • Summary
var Result__ConfigSummaryResult__DEFAULT *ConfigSummaryResult_

func NewConfigSummaryResult_

func NewConfigSummaryResult_() *ConfigSummaryResult_

func (*ConfigSummaryResult_) GetSummary

func (p *ConfigSummaryResult_) GetSummary() *ConfigSummary

func (*ConfigSummaryResult_) IsSetSummary

func (p *ConfigSummaryResult_) IsSetSummary() bool

func (*ConfigSummaryResult_) Read

func (p *ConfigSummaryResult_) Read(iprot thrift.TProtocol) error

func (*ConfigSummaryResult_) ReadField1 added in v1.21.0

func (p *ConfigSummaryResult_) ReadField1(iprot thrift.TProtocol) error

func (*ConfigSummaryResult_) String

func (p *ConfigSummaryResult_) String() string

func (*ConfigSummaryResult_) Write

func (p *ConfigSummaryResult_) Write(oprot thrift.TProtocol) error

type Constraint

type Constraint struct {
	Name       string          `thrift:"name,1" db:"name" json:"name"`
	Constraint *TaskConstraint `thrift:"constraint,2" db:"constraint" json:"constraint"`
}

A constraint that defines whether a task may be scheduled on a host.

Attributes:

  • Name: Mesos slave attribute that the constraint is matched against.
  • Constraint

func NewConstraint

func NewConstraint() *Constraint

func (*Constraint) GetConstraint

func (p *Constraint) GetConstraint() *TaskConstraint

func (*Constraint) GetName

func (p *Constraint) GetName() string

func (*Constraint) IsSetConstraint

func (p *Constraint) IsSetConstraint() bool

func (*Constraint) Read

func (p *Constraint) Read(iprot thrift.TProtocol) error

func (*Constraint) ReadField1 added in v1.21.0

func (p *Constraint) ReadField1(iprot thrift.TProtocol) error

func (*Constraint) ReadField2 added in v1.21.0

func (p *Constraint) ReadField2(iprot thrift.TProtocol) error

func (*Constraint) String

func (p *Constraint) String() string

func (*Constraint) Write

func (p *Constraint) Write(oprot thrift.TProtocol) error

type Container

type Container struct {
	Mesos  *MesosContainer  `thrift:"mesos,1" db:"mesos" json:"mesos,omitempty"`
	Docker *DockerContainer `thrift:"docker,2" db:"docker" json:"docker,omitempty"`
}

Describes a container to be used in a task

Attributes:

  • Mesos
  • Docker
var TaskConfig_Container_DEFAULT *Container = &Container{
	Mesos: &MesosContainer{},
}

func NewContainer

func NewContainer() *Container

func (*Container) CountSetFieldsContainer

func (p *Container) CountSetFieldsContainer() int

func (*Container) GetDocker

func (p *Container) GetDocker() *DockerContainer

func (*Container) GetMesos

func (p *Container) GetMesos() *MesosContainer

func (*Container) IsSetDocker

func (p *Container) IsSetDocker() bool

func (*Container) IsSetMesos

func (p *Container) IsSetMesos() bool

func (*Container) Read

func (p *Container) Read(iprot thrift.TProtocol) error

func (*Container) ReadField1 added in v1.21.0

func (p *Container) ReadField1(iprot thrift.TProtocol) error

func (*Container) ReadField2 added in v1.21.0

func (p *Container) ReadField2(iprot thrift.TProtocol) error

func (*Container) String

func (p *Container) String() string

func (*Container) Write

func (p *Container) Write(oprot thrift.TProtocol) error

type CoordinatorSlaPolicy added in v1.3.1

type CoordinatorSlaPolicy struct {
	CoordinatorUrl string `thrift:"coordinatorUrl,1" db:"coordinatorUrl" json:"coordinatorUrl"`
	StatusKey      string `thrift:"statusKey,2" db:"statusKey" json:"statusKey"`
}

SLA requirements to be delegated to an external coordinator

Attributes:

  • CoordinatorUrl: URL for the coordinator service that needs to be contacted for SLA checks
  • StatusKey: Field in the Coordinator response json indicating if the action is allowed or not
var SlaPolicy_CoordinatorSlaPolicy_DEFAULT *CoordinatorSlaPolicy

func NewCoordinatorSlaPolicy added in v1.3.1

func NewCoordinatorSlaPolicy() *CoordinatorSlaPolicy

func (*CoordinatorSlaPolicy) GetCoordinatorUrl added in v1.3.1

func (p *CoordinatorSlaPolicy) GetCoordinatorUrl() string

func (*CoordinatorSlaPolicy) GetStatusKey added in v1.3.1

func (p *CoordinatorSlaPolicy) GetStatusKey() string

func (*CoordinatorSlaPolicy) Read added in v1.3.1

func (p *CoordinatorSlaPolicy) Read(iprot thrift.TProtocol) error

func (*CoordinatorSlaPolicy) ReadField1 added in v1.21.0

func (p *CoordinatorSlaPolicy) ReadField1(iprot thrift.TProtocol) error

func (*CoordinatorSlaPolicy) ReadField2 added in v1.21.0

func (p *CoordinatorSlaPolicy) ReadField2(iprot thrift.TProtocol) error

func (*CoordinatorSlaPolicy) String added in v1.3.1

func (p *CoordinatorSlaPolicy) String() string

func (*CoordinatorSlaPolicy) Write added in v1.3.1

func (p *CoordinatorSlaPolicy) Write(oprot thrift.TProtocol) error

type CountSlaPolicy added in v1.3.1

type CountSlaPolicy struct {
	Count        int64 `thrift:"count,1" db:"count" json:"count"`
	DurationSecs int64 `thrift:"durationSecs,2" db:"durationSecs" json:"durationSecs"`
}

SLA requirements expressed as the number of instances to be RUNNING every durationSecs

Attributes:

  • Count: The number of active instances required every `durationSecs`
  • DurationSecs: Minimum time duration a task needs to be `RUNNING` to be treated as active
var SlaPolicy_CountSlaPolicy_DEFAULT *CountSlaPolicy

func NewCountSlaPolicy added in v1.3.1

func NewCountSlaPolicy() *CountSlaPolicy

func (*CountSlaPolicy) GetCount added in v1.3.1

func (p *CountSlaPolicy) GetCount() int64

func (*CountSlaPolicy) GetDurationSecs added in v1.3.1

func (p *CountSlaPolicy) GetDurationSecs() int64

func (*CountSlaPolicy) Read added in v1.3.1

func (p *CountSlaPolicy) Read(iprot thrift.TProtocol) error

func (*CountSlaPolicy) ReadField1 added in v1.21.0

func (p *CountSlaPolicy) ReadField1(iprot thrift.TProtocol) error

func (*CountSlaPolicy) ReadField2 added in v1.21.0

func (p *CountSlaPolicy) ReadField2(iprot thrift.TProtocol) error

func (*CountSlaPolicy) String added in v1.3.1

func (p *CountSlaPolicy) String() string

func (*CountSlaPolicy) Write added in v1.3.1

func (p *CountSlaPolicy) Write(oprot thrift.TProtocol) error

type CronCollisionPolicy

type CronCollisionPolicy int64

Defines the policy for launching a new cron job when one is already running.

const (
	CronCollisionPolicy_KILL_EXISTING CronCollisionPolicy = 0
	CronCollisionPolicy_CANCEL_NEW    CronCollisionPolicy = 1
	CronCollisionPolicy_RUN_OVERLAP   CronCollisionPolicy = 2
)

func CronCollisionPolicyFromString

func CronCollisionPolicyFromString(s string) (CronCollisionPolicy, error)

func CronCollisionPolicyPtr

func CronCollisionPolicyPtr(v CronCollisionPolicy) *CronCollisionPolicy

func (CronCollisionPolicy) MarshalText

func (p CronCollisionPolicy) MarshalText() ([]byte, error)

func (*CronCollisionPolicy) Scan added in v1.21.0

func (p *CronCollisionPolicy) Scan(value interface{}) error

func (CronCollisionPolicy) String

func (p CronCollisionPolicy) String() string

func (*CronCollisionPolicy) UnmarshalText

func (p *CronCollisionPolicy) UnmarshalText(text []byte) error

func (*CronCollisionPolicy) Value added in v1.21.0

func (p *CronCollisionPolicy) Value() (driver.Value, error)

type DockerContainer

type DockerContainer struct {
	Image      string             `thrift:"image,1" db:"image" json:"image"`
	Parameters []*DockerParameter `thrift:"parameters,2" db:"parameters" json:"parameters,omitempty"`
}

Describes a docker container

Attributes:

  • Image: The container image to be run
  • Parameters: The arbitrary parameters to pass to container
var Container_Docker_DEFAULT *DockerContainer

func NewDockerContainer

func NewDockerContainer() *DockerContainer

func (*DockerContainer) GetImage

func (p *DockerContainer) GetImage() string

func (*DockerContainer) GetParameters

func (p *DockerContainer) GetParameters() []*DockerParameter

func (*DockerContainer) IsSetParameters

func (p *DockerContainer) IsSetParameters() bool

func (*DockerContainer) Read

func (p *DockerContainer) Read(iprot thrift.TProtocol) error

func (*DockerContainer) ReadField1 added in v1.21.0

func (p *DockerContainer) ReadField1(iprot thrift.TProtocol) error

func (*DockerContainer) ReadField2 added in v1.21.0

func (p *DockerContainer) ReadField2(iprot thrift.TProtocol) error

func (*DockerContainer) String

func (p *DockerContainer) String() string

func (*DockerContainer) Write

func (p *DockerContainer) Write(oprot thrift.TProtocol) error

type DockerImage

type DockerImage struct {
	Name string `thrift:"name,1" db:"name" json:"name"`
	Tag  string `thrift:"tag,2" db:"tag" json:"tag"`
}

Describes an image for use with the Mesos unified containerizer in the Docker format

Attributes:

  • Name: The name of the image to run
  • Tag: The Docker tag identifying the image
var Image_Docker_DEFAULT *DockerImage

func NewDockerImage

func NewDockerImage() *DockerImage

func (*DockerImage) GetName

func (p *DockerImage) GetName() string

func (*DockerImage) GetTag

func (p *DockerImage) GetTag() string

func (*DockerImage) Read

func (p *DockerImage) Read(iprot thrift.TProtocol) error

func (*DockerImage) ReadField1 added in v1.21.0

func (p *DockerImage) ReadField1(iprot thrift.TProtocol) error

func (*DockerImage) ReadField2 added in v1.21.0

func (p *DockerImage) ReadField2(iprot thrift.TProtocol) error

func (*DockerImage) String

func (p *DockerImage) String() string

func (*DockerImage) Write

func (p *DockerImage) Write(oprot thrift.TProtocol) error

type DockerParameter

type DockerParameter struct {
	Name  string `thrift:"name,1" db:"name" json:"name"`
	Value string `thrift:"value,2" db:"value" json:"value"`
}

Describes a parameter passed to docker cli

Attributes:

  • Name: a parameter to pass to docker. (e.g. volume)
  • Value: the value to pass to a parameter (e.g. /src/webapp:/opt/webapp)

func NewDockerParameter

func NewDockerParameter() *DockerParameter

func (*DockerParameter) GetName

func (p *DockerParameter) GetName() string

func (*DockerParameter) GetValue

func (p *DockerParameter) GetValue() string

func (*DockerParameter) Read

func (p *DockerParameter) Read(iprot thrift.TProtocol) error

func (*DockerParameter) ReadField1 added in v1.21.0

func (p *DockerParameter) ReadField1(iprot thrift.TProtocol) error

func (*DockerParameter) ReadField2 added in v1.21.0

func (p *DockerParameter) ReadField2(iprot thrift.TProtocol) error

func (*DockerParameter) String

func (p *DockerParameter) String() string

func (*DockerParameter) Write

func (p *DockerParameter) Write(oprot thrift.TProtocol) error

type DrainHostsResult_

type DrainHostsResult_ struct {
	Statuses []*HostStatus `thrift:"statuses,1" db:"statuses" json:"statuses"`
}

Attributes:

  • Statuses
var Result__DrainHostsResult__DEFAULT *DrainHostsResult_

func NewDrainHostsResult_

func NewDrainHostsResult_() *DrainHostsResult_

func (*DrainHostsResult_) GetStatuses

func (p *DrainHostsResult_) GetStatuses() []*HostStatus

func (*DrainHostsResult_) Read

func (p *DrainHostsResult_) Read(iprot thrift.TProtocol) error

func (*DrainHostsResult_) ReadField1 added in v1.21.0

func (p *DrainHostsResult_) ReadField1(iprot thrift.TProtocol) error

func (*DrainHostsResult_) String

func (p *DrainHostsResult_) String() string

func (*DrainHostsResult_) Write

func (p *DrainHostsResult_) Write(oprot thrift.TProtocol) error

type EndMaintenanceResult_

type EndMaintenanceResult_ struct {
	Statuses []*HostStatus `thrift:"statuses,1" db:"statuses" json:"statuses"`
}

Attributes:

  • Statuses
var Result__EndMaintenanceResult__DEFAULT *EndMaintenanceResult_

func NewEndMaintenanceResult_

func NewEndMaintenanceResult_() *EndMaintenanceResult_

func (*EndMaintenanceResult_) GetStatuses

func (p *EndMaintenanceResult_) GetStatuses() []*HostStatus

func (*EndMaintenanceResult_) Read

func (*EndMaintenanceResult_) ReadField1 added in v1.21.0

func (p *EndMaintenanceResult_) ReadField1(iprot thrift.TProtocol) error

func (*EndMaintenanceResult_) String

func (p *EndMaintenanceResult_) String() string

func (*EndMaintenanceResult_) Write

func (p *EndMaintenanceResult_) Write(oprot thrift.TProtocol) error

type ExecutorConfig

type ExecutorConfig struct {
	Name string `thrift:"name,1" db:"name" json:"name"`
	Data string `thrift:"data,2" db:"data" json:"data"`
}

Attributes:

  • Name: Name identifying the Executor.
  • Data: Executor configuration data.
var TaskConfig_ExecutorConfig_DEFAULT *ExecutorConfig

func NewExecutorConfig

func NewExecutorConfig() *ExecutorConfig

func (*ExecutorConfig) GetData

func (p *ExecutorConfig) GetData() string

func (*ExecutorConfig) GetName

func (p *ExecutorConfig) GetName() string

func (*ExecutorConfig) Read

func (p *ExecutorConfig) Read(iprot thrift.TProtocol) error

func (*ExecutorConfig) ReadField1 added in v1.21.0

func (p *ExecutorConfig) ReadField1(iprot thrift.TProtocol) error

func (*ExecutorConfig) ReadField2 added in v1.21.0

func (p *ExecutorConfig) ReadField2(iprot thrift.TProtocol) error

func (*ExecutorConfig) String

func (p *ExecutorConfig) String() string

func (*ExecutorConfig) Write

func (p *ExecutorConfig) Write(oprot thrift.TProtocol) error

type ExplicitReconciliationSettings

type ExplicitReconciliationSettings struct {
	BatchSize *int32 `thrift:"batchSize,1" db:"batchSize" json:"batchSize,omitempty"`
}

Attributes:

  • BatchSize
var AuroraAdminTriggerExplicitTaskReconciliationArgs_Settings_DEFAULT *ExplicitReconciliationSettings

func NewExplicitReconciliationSettings

func NewExplicitReconciliationSettings() *ExplicitReconciliationSettings

func (*ExplicitReconciliationSettings) GetBatchSize

func (p *ExplicitReconciliationSettings) GetBatchSize() int32

func (*ExplicitReconciliationSettings) IsSetBatchSize

func (p *ExplicitReconciliationSettings) IsSetBatchSize() bool

func (*ExplicitReconciliationSettings) Read

func (*ExplicitReconciliationSettings) ReadField1 added in v1.21.0

func (*ExplicitReconciliationSettings) String

func (*ExplicitReconciliationSettings) Write

type GetJobUpdateDetailsResult_

type GetJobUpdateDetailsResult_ struct {
	Details     *JobUpdateDetails   `thrift:"details,1" db:"details" json:"details"`
	DetailsList []*JobUpdateDetails `thrift:"detailsList,2" db:"detailsList" json:"detailsList"`
}

Result of the getJobUpdateDetails call.

Attributes:

  • Details
  • DetailsList
var Result__GetJobUpdateDetailsResult__DEFAULT *GetJobUpdateDetailsResult_

func NewGetJobUpdateDetailsResult_

func NewGetJobUpdateDetailsResult_() *GetJobUpdateDetailsResult_

func (*GetJobUpdateDetailsResult_) GetDetails

func (*GetJobUpdateDetailsResult_) GetDetailsList

func (p *GetJobUpdateDetailsResult_) GetDetailsList() []*JobUpdateDetails

func (*GetJobUpdateDetailsResult_) IsSetDetails

func (p *GetJobUpdateDetailsResult_) IsSetDetails() bool

func (*GetJobUpdateDetailsResult_) Read

func (*GetJobUpdateDetailsResult_) ReadField1 added in v1.21.0

func (p *GetJobUpdateDetailsResult_) ReadField1(iprot thrift.TProtocol) error

func (*GetJobUpdateDetailsResult_) ReadField2 added in v1.21.0

func (p *GetJobUpdateDetailsResult_) ReadField2(iprot thrift.TProtocol) error

func (*GetJobUpdateDetailsResult_) String

func (p *GetJobUpdateDetailsResult_) String() string

func (*GetJobUpdateDetailsResult_) Write

type GetJobUpdateDiffResult_

type GetJobUpdateDiffResult_ struct {
	Add       []*ConfigGroup `thrift:"add,1" db:"add" json:"add"`
	Remove    []*ConfigGroup `thrift:"remove,2" db:"remove" json:"remove"`
	Update    []*ConfigGroup `thrift:"update,3" db:"update" json:"update"`
	Unchanged []*ConfigGroup `thrift:"unchanged,4" db:"unchanged" json:"unchanged"`
}

Attributes:

  • Add: Instance addition diff details.
  • Remove: Instance removal diff details.
  • Update: Instance update diff details.
  • Unchanged: Instances unchanged by the update.
var Result__GetJobUpdateDiffResult__DEFAULT *GetJobUpdateDiffResult_

func NewGetJobUpdateDiffResult_

func NewGetJobUpdateDiffResult_() *GetJobUpdateDiffResult_

func (*GetJobUpdateDiffResult_) GetAdd

func (p *GetJobUpdateDiffResult_) GetAdd() []*ConfigGroup

func (*GetJobUpdateDiffResult_) GetRemove

func (p *GetJobUpdateDiffResult_) GetRemove() []*ConfigGroup

func (*GetJobUpdateDiffResult_) GetUnchanged

func (p *GetJobUpdateDiffResult_) GetUnchanged() []*ConfigGroup

func (*GetJobUpdateDiffResult_) GetUpdate

func (p *GetJobUpdateDiffResult_) GetUpdate() []*ConfigGroup

func (*GetJobUpdateDiffResult_) Read

func (*GetJobUpdateDiffResult_) ReadField1 added in v1.21.0

func (p *GetJobUpdateDiffResult_) ReadField1(iprot thrift.TProtocol) error

func (*GetJobUpdateDiffResult_) ReadField2 added in v1.21.0

func (p *GetJobUpdateDiffResult_) ReadField2(iprot thrift.TProtocol) error

func (*GetJobUpdateDiffResult_) ReadField3 added in v1.21.0

func (p *GetJobUpdateDiffResult_) ReadField3(iprot thrift.TProtocol) error

func (*GetJobUpdateDiffResult_) ReadField4 added in v1.21.0

func (p *GetJobUpdateDiffResult_) ReadField4(iprot thrift.TProtocol) error

func (*GetJobUpdateDiffResult_) String

func (p *GetJobUpdateDiffResult_) String() string

func (*GetJobUpdateDiffResult_) Write

type GetJobUpdateSummariesResult_

type GetJobUpdateSummariesResult_ struct {
	UpdateSummaries []*JobUpdateSummary `thrift:"updateSummaries,1" db:"updateSummaries" json:"updateSummaries"`
}

Result of the getJobUpdateSummaries call.

Attributes:

  • UpdateSummaries
var Result__GetJobUpdateSummariesResult__DEFAULT *GetJobUpdateSummariesResult_

func NewGetJobUpdateSummariesResult_

func NewGetJobUpdateSummariesResult_() *GetJobUpdateSummariesResult_

func (*GetJobUpdateSummariesResult_) GetUpdateSummaries

func (p *GetJobUpdateSummariesResult_) GetUpdateSummaries() []*JobUpdateSummary

func (*GetJobUpdateSummariesResult_) Read

func (*GetJobUpdateSummariesResult_) ReadField1 added in v1.21.0

func (p *GetJobUpdateSummariesResult_) ReadField1(iprot thrift.TProtocol) error

func (*GetJobUpdateSummariesResult_) String

func (*GetJobUpdateSummariesResult_) Write

type GetJobsResult_

type GetJobsResult_ struct {
	Configs []*JobConfiguration `thrift:"configs,1" db:"configs" json:"configs"`
}

Attributes:

  • Configs
var Result__GetJobsResult__DEFAULT *GetJobsResult_

func NewGetJobsResult_

func NewGetJobsResult_() *GetJobsResult_

func (*GetJobsResult_) GetConfigs

func (p *GetJobsResult_) GetConfigs() []*JobConfiguration

func (*GetJobsResult_) Read

func (p *GetJobsResult_) Read(iprot thrift.TProtocol) error

func (*GetJobsResult_) ReadField1 added in v1.21.0

func (p *GetJobsResult_) ReadField1(iprot thrift.TProtocol) error

func (*GetJobsResult_) String

func (p *GetJobsResult_) String() string

func (*GetJobsResult_) Write

func (p *GetJobsResult_) Write(oprot thrift.TProtocol) error

type GetPendingReasonResult_

type GetPendingReasonResult_ struct {
	Reasons []*PendingReason `thrift:"reasons,1" db:"reasons" json:"reasons"`
}

Attributes:

  • Reasons
var Result__GetPendingReasonResult__DEFAULT *GetPendingReasonResult_

func NewGetPendingReasonResult_

func NewGetPendingReasonResult_() *GetPendingReasonResult_

func (*GetPendingReasonResult_) GetReasons

func (p *GetPendingReasonResult_) GetReasons() []*PendingReason

func (*GetPendingReasonResult_) Read

func (*GetPendingReasonResult_) ReadField1 added in v1.21.0

func (p *GetPendingReasonResult_) ReadField1(iprot thrift.TProtocol) error

func (*GetPendingReasonResult_) String

func (p *GetPendingReasonResult_) String() string

func (*GetPendingReasonResult_) Write

type GetQuotaResult_

type GetQuotaResult_ struct {
	Quota                       *ResourceAggregate `thrift:"quota,1" db:"quota" json:"quota"`
	ProdSharedConsumption       *ResourceAggregate `thrift:"prodSharedConsumption,2" db:"prodSharedConsumption" json:"prodSharedConsumption,omitempty"`
	NonProdSharedConsumption    *ResourceAggregate `thrift:"nonProdSharedConsumption,3" db:"nonProdSharedConsumption" json:"nonProdSharedConsumption,omitempty"`
	ProdDedicatedConsumption    *ResourceAggregate `thrift:"prodDedicatedConsumption,4" db:"prodDedicatedConsumption" json:"prodDedicatedConsumption,omitempty"`
	NonProdDedicatedConsumption *ResourceAggregate `thrift:"nonProdDedicatedConsumption,5" db:"nonProdDedicatedConsumption" json:"nonProdDedicatedConsumption,omitempty"`
}

Attributes:

  • Quota: Total allocated resource quota.
  • ProdSharedConsumption: Resources consumed by production jobs from a shared resource pool.
  • NonProdSharedConsumption: Resources consumed by non-production jobs from a shared resource pool.
  • ProdDedicatedConsumption: Resources consumed by production jobs from a dedicated resource pool.
  • NonProdDedicatedConsumption: Resources consumed by non-production jobs from a dedicated resource pool.
var Result__GetQuotaResult__DEFAULT *GetQuotaResult_

func NewGetQuotaResult_

func NewGetQuotaResult_() *GetQuotaResult_

func (*GetQuotaResult_) GetNonProdDedicatedConsumption

func (p *GetQuotaResult_) GetNonProdDedicatedConsumption() *ResourceAggregate

func (*GetQuotaResult_) GetNonProdSharedConsumption

func (p *GetQuotaResult_) GetNonProdSharedConsumption() *ResourceAggregate

func (*GetQuotaResult_) GetProdDedicatedConsumption

func (p *GetQuotaResult_) GetProdDedicatedConsumption() *ResourceAggregate

func (*GetQuotaResult_) GetProdSharedConsumption

func (p *GetQuotaResult_) GetProdSharedConsumption() *ResourceAggregate

func (*GetQuotaResult_) GetQuota

func (p *GetQuotaResult_) GetQuota() *ResourceAggregate

func (*GetQuotaResult_) IsSetNonProdDedicatedConsumption

func (p *GetQuotaResult_) IsSetNonProdDedicatedConsumption() bool

func (*GetQuotaResult_) IsSetNonProdSharedConsumption

func (p *GetQuotaResult_) IsSetNonProdSharedConsumption() bool

func (*GetQuotaResult_) IsSetProdDedicatedConsumption

func (p *GetQuotaResult_) IsSetProdDedicatedConsumption() bool

func (*GetQuotaResult_) IsSetProdSharedConsumption

func (p *GetQuotaResult_) IsSetProdSharedConsumption() bool

func (*GetQuotaResult_) IsSetQuota

func (p *GetQuotaResult_) IsSetQuota() bool

func (*GetQuotaResult_) Read

func (p *GetQuotaResult_) Read(iprot thrift.TProtocol) error

func (*GetQuotaResult_) ReadField1 added in v1.21.0

func (p *GetQuotaResult_) ReadField1(iprot thrift.TProtocol) error

func (*GetQuotaResult_) ReadField2 added in v1.21.0

func (p *GetQuotaResult_) ReadField2(iprot thrift.TProtocol) error

func (*GetQuotaResult_) ReadField3 added in v1.21.0

func (p *GetQuotaResult_) ReadField3(iprot thrift.TProtocol) error

func (*GetQuotaResult_) ReadField4 added in v1.21.0

func (p *GetQuotaResult_) ReadField4(iprot thrift.TProtocol) error

func (*GetQuotaResult_) ReadField5 added in v1.21.0

func (p *GetQuotaResult_) ReadField5(iprot thrift.TProtocol) error

func (*GetQuotaResult_) String

func (p *GetQuotaResult_) String() string

func (*GetQuotaResult_) Write

func (p *GetQuotaResult_) Write(oprot thrift.TProtocol) error

type GetTierConfigResult_

type GetTierConfigResult_ struct {
	DefaultTierName string        `thrift:"defaultTierName,1" db:"defaultTierName" json:"defaultTierName"`
	Tiers           []*TierConfig `thrift:"tiers,2" db:"tiers" json:"tiers"`
}

Result of the getTierConfigResult call.

Attributes:

  • DefaultTierName: Name of the default tier.
  • Tiers: Set of tier configurations.
var Result__GetTierConfigResult__DEFAULT *GetTierConfigResult_

func NewGetTierConfigResult_

func NewGetTierConfigResult_() *GetTierConfigResult_

func (*GetTierConfigResult_) GetDefaultTierName

func (p *GetTierConfigResult_) GetDefaultTierName() string

func (*GetTierConfigResult_) GetTiers

func (p *GetTierConfigResult_) GetTiers() []*TierConfig

func (*GetTierConfigResult_) Read

func (p *GetTierConfigResult_) Read(iprot thrift.TProtocol) error

func (*GetTierConfigResult_) ReadField1 added in v1.21.0

func (p *GetTierConfigResult_) ReadField1(iprot thrift.TProtocol) error

func (*GetTierConfigResult_) ReadField2 added in v1.21.0

func (p *GetTierConfigResult_) ReadField2(iprot thrift.TProtocol) error

func (*GetTierConfigResult_) String

func (p *GetTierConfigResult_) String() string

func (*GetTierConfigResult_) Write

func (p *GetTierConfigResult_) Write(oprot thrift.TProtocol) error

type HostAttributes

type HostAttributes struct {
	Host       string           `thrift:"host,1" db:"host" json:"host"`
	Attributes []*Attribute     `thrift:"attributes,2" db:"attributes" json:"attributes"`
	Mode       *MaintenanceMode `thrift:"mode,3" db:"mode" json:"mode,omitempty"`
	SlaveId    *string          `thrift:"slaveId,4" db:"slaveId" json:"slaveId,omitempty"`
}

The attributes assigned to a host.

Attributes:

  • Host
  • Attributes
  • Mode
  • SlaveId

func NewHostAttributes

func NewHostAttributes() *HostAttributes

func (*HostAttributes) GetAttributes

func (p *HostAttributes) GetAttributes() []*Attribute

func (*HostAttributes) GetHost

func (p *HostAttributes) GetHost() string

func (*HostAttributes) GetMode

func (p *HostAttributes) GetMode() MaintenanceMode

func (*HostAttributes) GetSlaveId

func (p *HostAttributes) GetSlaveId() string

func (*HostAttributes) IsSetMode

func (p *HostAttributes) IsSetMode() bool

func (*HostAttributes) IsSetSlaveId

func (p *HostAttributes) IsSetSlaveId() bool

func (*HostAttributes) Read

func (p *HostAttributes) Read(iprot thrift.TProtocol) error

func (*HostAttributes) ReadField1 added in v1.21.0

func (p *HostAttributes) ReadField1(iprot thrift.TProtocol) error

func (*HostAttributes) ReadField2 added in v1.21.0

func (p *HostAttributes) ReadField2(iprot thrift.TProtocol) error

func (*HostAttributes) ReadField3 added in v1.21.0

func (p *HostAttributes) ReadField3(iprot thrift.TProtocol) error

func (*HostAttributes) ReadField4 added in v1.21.0

func (p *HostAttributes) ReadField4(iprot thrift.TProtocol) error

func (*HostAttributes) String

func (p *HostAttributes) String() string

func (*HostAttributes) Write

func (p *HostAttributes) Write(oprot thrift.TProtocol) error

type HostMaintenanceRequest added in v1.3.1

type HostMaintenanceRequest struct {
	Host               string     `thrift:"host,1" db:"host" json:"host"`
	DefaultSlaPolicy   *SlaPolicy `thrift:"defaultSlaPolicy,2" db:"defaultSlaPolicy" json:"defaultSlaPolicy"`
	TimeoutSecs        int64      `thrift:"timeoutSecs,3" db:"timeoutSecs" json:"timeoutSecs"`
	CreatedTimestampMs int64      `thrift:"createdTimestampMs,4" db:"createdTimestampMs" json:"createdTimestampMs"`
}

Attributes:

  • Host
  • DefaultSlaPolicy
  • TimeoutSecs
  • CreatedTimestampMs

func NewHostMaintenanceRequest added in v1.3.1

func NewHostMaintenanceRequest() *HostMaintenanceRequest

func (*HostMaintenanceRequest) GetCreatedTimestampMs added in v1.3.1

func (p *HostMaintenanceRequest) GetCreatedTimestampMs() int64

func (*HostMaintenanceRequest) GetDefaultSlaPolicy added in v1.3.1

func (p *HostMaintenanceRequest) GetDefaultSlaPolicy() *SlaPolicy

func (*HostMaintenanceRequest) GetHost added in v1.3.1

func (p *HostMaintenanceRequest) GetHost() string

func (*HostMaintenanceRequest) GetTimeoutSecs added in v1.3.1

func (p *HostMaintenanceRequest) GetTimeoutSecs() int64

func (*HostMaintenanceRequest) IsSetDefaultSlaPolicy added in v1.3.1

func (p *HostMaintenanceRequest) IsSetDefaultSlaPolicy() bool

func (*HostMaintenanceRequest) Read added in v1.3.1

func (*HostMaintenanceRequest) ReadField1 added in v1.21.0

func (p *HostMaintenanceRequest) ReadField1(iprot thrift.TProtocol) error

func (*HostMaintenanceRequest) ReadField2 added in v1.21.0

func (p *HostMaintenanceRequest) ReadField2(iprot thrift.TProtocol) error

func (*HostMaintenanceRequest) ReadField3 added in v1.21.0

func (p *HostMaintenanceRequest) ReadField3(iprot thrift.TProtocol) error

func (*HostMaintenanceRequest) ReadField4 added in v1.21.0

func (p *HostMaintenanceRequest) ReadField4(iprot thrift.TProtocol) error

func (*HostMaintenanceRequest) String added in v1.3.1

func (p *HostMaintenanceRequest) String() string

func (*HostMaintenanceRequest) Write added in v1.3.1

func (p *HostMaintenanceRequest) Write(oprot thrift.TProtocol) error

type HostStatus

type HostStatus struct {
	Host string          `thrift:"host,1" db:"host" json:"host"`
	Mode MaintenanceMode `thrift:"mode,2" db:"mode" json:"mode"`
}

Attributes:

  • Host
  • Mode

func NewHostStatus

func NewHostStatus() *HostStatus

func (*HostStatus) GetHost

func (p *HostStatus) GetHost() string

func (*HostStatus) GetMode

func (p *HostStatus) GetMode() MaintenanceMode

func (*HostStatus) Read

func (p *HostStatus) Read(iprot thrift.TProtocol) error

func (*HostStatus) ReadField1 added in v1.21.0

func (p *HostStatus) ReadField1(iprot thrift.TProtocol) error

func (*HostStatus) ReadField2 added in v1.21.0

func (p *HostStatus) ReadField2(iprot thrift.TProtocol) error

func (*HostStatus) String

func (p *HostStatus) String() string

func (*HostStatus) Write

func (p *HostStatus) Write(oprot thrift.TProtocol) error

type Hosts

type Hosts struct {
	HostNames []string `thrift:"hostNames,1" db:"hostNames" json:"hostNames"`
}

Attributes:

  • HostNames
var AuroraAdminDrainHostsArgs_Hosts_DEFAULT *Hosts
var AuroraAdminEndMaintenanceArgs_Hosts_DEFAULT *Hosts
var AuroraAdminMaintenanceStatusArgs_Hosts_DEFAULT *Hosts
var AuroraAdminSlaDrainHostsArgs_Hosts_DEFAULT *Hosts
var AuroraAdminStartMaintenanceArgs_Hosts_DEFAULT *Hosts

func NewHosts

func NewHosts() *Hosts

func (*Hosts) GetHostNames

func (p *Hosts) GetHostNames() []string

func (*Hosts) Read

func (p *Hosts) Read(iprot thrift.TProtocol) error

func (*Hosts) ReadField1 added in v1.21.0

func (p *Hosts) ReadField1(iprot thrift.TProtocol) error

func (*Hosts) String

func (p *Hosts) String() string

func (*Hosts) Write

func (p *Hosts) Write(oprot thrift.TProtocol) error

type Identity

type Identity struct {
	// unused field # 1
	User string `thrift:"user,2" db:"user" json:"user"`
}

Attributes:

  • User
var JobConfiguration_Owner_DEFAULT *Identity
var TaskConfig_Owner_DEFAULT *Identity

func NewIdentity

func NewIdentity() *Identity

func (*Identity) GetUser

func (p *Identity) GetUser() string

func (*Identity) Read

func (p *Identity) Read(iprot thrift.TProtocol) error

func (*Identity) ReadField2 added in v1.21.0

func (p *Identity) ReadField2(iprot thrift.TProtocol) error

func (*Identity) String

func (p *Identity) String() string

func (*Identity) Write

func (p *Identity) Write(oprot thrift.TProtocol) error

type Image

type Image struct {
	Docker *DockerImage `thrift:"docker,1" db:"docker" json:"docker,omitempty"`
	Appc   *AppcImage   `thrift:"appc,2" db:"appc" json:"appc,omitempty"`
}

Describes an image to be used with the Mesos unified containerizer

Attributes:

  • Docker
  • Appc
var MesosContainer_Image_DEFAULT *Image

func NewImage

func NewImage() *Image

func (*Image) CountSetFieldsImage

func (p *Image) CountSetFieldsImage() int

func (*Image) GetAppc

func (p *Image) GetAppc() *AppcImage

func (*Image) GetDocker

func (p *Image) GetDocker() *DockerImage

func (*Image) IsSetAppc

func (p *Image) IsSetAppc() bool

func (*Image) IsSetDocker

func (p *Image) IsSetDocker() bool

func (*Image) Read

func (p *Image) Read(iprot thrift.TProtocol) error

func (*Image) ReadField1 added in v1.21.0

func (p *Image) ReadField1(iprot thrift.TProtocol) error

func (*Image) ReadField2 added in v1.21.0

func (p *Image) ReadField2(iprot thrift.TProtocol) error

func (*Image) String

func (p *Image) String() string

func (*Image) Write

func (p *Image) Write(oprot thrift.TProtocol) error

type InstanceKey

type InstanceKey struct {
	JobKey     *JobKey `thrift:"jobKey,1" db:"jobKey" json:"jobKey"`
	InstanceId int32   `thrift:"instanceId,2" db:"instanceId" json:"instanceId"`
}

A unique identifier for the active task within a job.

Attributes:

  • JobKey: Key identifying the job.
  • InstanceId: Unique instance ID for the active task in a job.
var AuroraSchedulerManagerAddInstancesArgs_Key_DEFAULT *InstanceKey

func NewInstanceKey

func NewInstanceKey() *InstanceKey

func (*InstanceKey) GetInstanceId

func (p *InstanceKey) GetInstanceId() int32

func (*InstanceKey) GetJobKey

func (p *InstanceKey) GetJobKey() *JobKey

func (*InstanceKey) IsSetJobKey

func (p *InstanceKey) IsSetJobKey() bool

func (*InstanceKey) Read

func (p *InstanceKey) Read(iprot thrift.TProtocol) error

func (*InstanceKey) ReadField1 added in v1.21.0

func (p *InstanceKey) ReadField1(iprot thrift.TProtocol) error

func (*InstanceKey) ReadField2 added in v1.21.0

func (p *InstanceKey) ReadField2(iprot thrift.TProtocol) error

func (*InstanceKey) String

func (p *InstanceKey) String() string

func (*InstanceKey) Write

func (p *InstanceKey) Write(oprot thrift.TProtocol) error

type InstanceTaskConfig

type InstanceTaskConfig struct {
	Task      *TaskConfig `thrift:"task,1" db:"task" json:"task"`
	Instances []*Range    `thrift:"instances,2" db:"instances" json:"instances"`
}

Maps instance IDs to TaskConfigs it.

Attributes:

  • Task: A TaskConfig associated with instances.
  • Instances: Instances associated with the TaskConfig.
var JobUpdateInstructions_DesiredState_DEFAULT *InstanceTaskConfig

func NewInstanceTaskConfig

func NewInstanceTaskConfig() *InstanceTaskConfig

func (*InstanceTaskConfig) GetInstances

func (p *InstanceTaskConfig) GetInstances() []*Range

func (*InstanceTaskConfig) GetTask

func (p *InstanceTaskConfig) GetTask() *TaskConfig

func (*InstanceTaskConfig) IsSetTask

func (p *InstanceTaskConfig) IsSetTask() bool

func (*InstanceTaskConfig) Read

func (p *InstanceTaskConfig) Read(iprot thrift.TProtocol) error

func (*InstanceTaskConfig) ReadField1 added in v1.21.0

func (p *InstanceTaskConfig) ReadField1(iprot thrift.TProtocol) error

func (*InstanceTaskConfig) ReadField2 added in v1.21.0

func (p *InstanceTaskConfig) ReadField2(iprot thrift.TProtocol) error

func (*InstanceTaskConfig) String

func (p *InstanceTaskConfig) String() string

func (*InstanceTaskConfig) Write

func (p *InstanceTaskConfig) Write(oprot thrift.TProtocol) error

type JobConfiguration

type JobConfiguration struct {
	// unused fields # 1 to 3
	CronSchedule        *string             `thrift:"cronSchedule,4" db:"cronSchedule" json:"cronSchedule,omitempty"`
	CronCollisionPolicy CronCollisionPolicy `thrift:"cronCollisionPolicy,5" db:"cronCollisionPolicy" json:"cronCollisionPolicy"`
	TaskConfig          *TaskConfig         `thrift:"taskConfig,6" db:"taskConfig" json:"taskConfig"`
	Owner               *Identity           `thrift:"owner,7" db:"owner" json:"owner"`
	InstanceCount       int32               `thrift:"instanceCount,8" db:"instanceCount" json:"instanceCount"`
	Key                 *JobKey             `thrift:"key,9" db:"key" json:"key"`
}

Description of an Aurora job. One task will be scheduled for each instance within the job.

Attributes:

  • Key: Key for this job. If not specified name, owner.role, and a reasonable default environment are

used to construct it server-side.

  • Owner: Owner of this job.
  • CronSchedule: If present, the job will be handled as a cron job with this crontab-syntax schedule.
  • CronCollisionPolicy: Collision policy to use when handling overlapping cron runs. Default is KILL_EXISTING.
  • TaskConfig: Task configuration for this job.
  • InstanceCount: The number of instances in the job. Generated instance IDs for tasks will be in the range

[0, instances).

var AuroraSchedulerManagerCreateJobArgs_Description_DEFAULT *JobConfiguration
var AuroraSchedulerManagerReplaceCronTemplateArgs_Config_DEFAULT *JobConfiguration
var AuroraSchedulerManagerScheduleCronJobArgs_Description_DEFAULT *JobConfiguration
var JobSummary_Job_DEFAULT *JobConfiguration
var ReadOnlySchedulerPopulateJobConfigArgs_Description_DEFAULT *JobConfiguration

func NewJobConfiguration

func NewJobConfiguration() *JobConfiguration

func (*JobConfiguration) GetCronCollisionPolicy

func (p *JobConfiguration) GetCronCollisionPolicy() CronCollisionPolicy

func (*JobConfiguration) GetCronSchedule

func (p *JobConfiguration) GetCronSchedule() string

func (*JobConfiguration) GetInstanceCount

func (p *JobConfiguration) GetInstanceCount() int32

func (*JobConfiguration) GetKey

func (p *JobConfiguration) GetKey() *JobKey

func (*JobConfiguration) GetOwner

func (p *JobConfiguration) GetOwner() *Identity

func (*JobConfiguration) GetTaskConfig

func (p *JobConfiguration) GetTaskConfig() *TaskConfig

func (*JobConfiguration) IsSetCronSchedule

func (p *JobConfiguration) IsSetCronSchedule() bool

func (*JobConfiguration) IsSetKey

func (p *JobConfiguration) IsSetKey() bool

func (*JobConfiguration) IsSetOwner

func (p *JobConfiguration) IsSetOwner() bool

func (*JobConfiguration) IsSetTaskConfig

func (p *JobConfiguration) IsSetTaskConfig() bool

func (*JobConfiguration) Read

func (p *JobConfiguration) Read(iprot thrift.TProtocol) error

func (*JobConfiguration) ReadField4 added in v1.21.0

func (p *JobConfiguration) ReadField4(iprot thrift.TProtocol) error

func (*JobConfiguration) ReadField5 added in v1.21.0

func (p *JobConfiguration) ReadField5(iprot thrift.TProtocol) error

func (*JobConfiguration) ReadField6 added in v1.21.0

func (p *JobConfiguration) ReadField6(iprot thrift.TProtocol) error

func (*JobConfiguration) ReadField7 added in v1.21.0

func (p *JobConfiguration) ReadField7(iprot thrift.TProtocol) error

func (*JobConfiguration) ReadField8 added in v1.21.0

func (p *JobConfiguration) ReadField8(iprot thrift.TProtocol) error

func (*JobConfiguration) ReadField9 added in v1.21.0

func (p *JobConfiguration) ReadField9(iprot thrift.TProtocol) error

func (*JobConfiguration) String

func (p *JobConfiguration) String() string

func (*JobConfiguration) Write

func (p *JobConfiguration) Write(oprot thrift.TProtocol) error

type JobInstanceUpdateEvent

type JobInstanceUpdateEvent struct {
	InstanceId  int32           `thrift:"instanceId,1" db:"instanceId" json:"instanceId"`
	TimestampMs int64           `thrift:"timestampMs,2" db:"timestampMs" json:"timestampMs"`
	Action      JobUpdateAction `thrift:"action,3" db:"action" json:"action"`
	Message     *string         `thrift:"message,4" db:"message" json:"message,omitempty"`
}

Event marking a state transition in job instance update lifecycle.

Attributes:

  • InstanceId: Job instance ID.
  • TimestampMs: Epoch timestamp in milliseconds.
  • Action: Job update action taken on the instance.
  • Message: Optional message explaining the instance update event.

func NewJobInstanceUpdateEvent

func NewJobInstanceUpdateEvent() *JobInstanceUpdateEvent

func (*JobInstanceUpdateEvent) GetAction

func (p *JobInstanceUpdateEvent) GetAction() JobUpdateAction

func (*JobInstanceUpdateEvent) GetInstanceId

func (p *JobInstanceUpdateEvent) GetInstanceId() int32

func (*JobInstanceUpdateEvent) GetMessage added in v1.3.1

func (p *JobInstanceUpdateEvent) GetMessage() string

func (*JobInstanceUpdateEvent) GetTimestampMs

func (p *JobInstanceUpdateEvent) GetTimestampMs() int64

func (*JobInstanceUpdateEvent) IsSetMessage added in v1.3.1

func (p *JobInstanceUpdateEvent) IsSetMessage() bool

func (*JobInstanceUpdateEvent) Read

func (*JobInstanceUpdateEvent) ReadField1 added in v1.21.0

func (p *JobInstanceUpdateEvent) ReadField1(iprot thrift.TProtocol) error

func (*JobInstanceUpdateEvent) ReadField2 added in v1.21.0

func (p *JobInstanceUpdateEvent) ReadField2(iprot thrift.TProtocol) error

func (*JobInstanceUpdateEvent) ReadField3 added in v1.21.0

func (p *JobInstanceUpdateEvent) ReadField3(iprot thrift.TProtocol) error

func (*JobInstanceUpdateEvent) ReadField4 added in v1.21.0

func (p *JobInstanceUpdateEvent) ReadField4(iprot thrift.TProtocol) error

func (*JobInstanceUpdateEvent) String

func (p *JobInstanceUpdateEvent) String() string

func (*JobInstanceUpdateEvent) Write

func (p *JobInstanceUpdateEvent) Write(oprot thrift.TProtocol) error

type JobKey

type JobKey struct {
	Role        string `thrift:"role,1" db:"role" json:"role"`
	Environment string `thrift:"environment,2" db:"environment" json:"environment"`
	Name        string `thrift:"name,3" db:"name" json:"name"`
}

A unique identifier for a Job.

Attributes:

  • Role: User role (Unix service account), for example "mesos"
  • Environment: Environment, for example "devel"
  • Name: Name, for example "labrat"
var AuroraSchedulerManagerDescheduleCronJobArgs_Job_DEFAULT *JobKey
var AuroraSchedulerManagerKillTasksArgs_Job_DEFAULT *JobKey
var AuroraSchedulerManagerRestartShardsArgs_Job_DEFAULT *JobKey
var AuroraSchedulerManagerStartCronJobArgs_Job_DEFAULT *JobKey
var ConfigSummary_Key_DEFAULT *JobKey
var InstanceKey_JobKey_DEFAULT *JobKey
var JobConfiguration_Key_DEFAULT *JobKey
var JobUpdateKey_Job_DEFAULT *JobKey
var JobUpdateQuery_JobKey_DEFAULT *JobKey
var LockKey_Job_DEFAULT *JobKey
var ReadOnlySchedulerGetConfigSummaryArgs_Job_DEFAULT *JobKey
var TaskConfig_Job_DEFAULT *JobKey

func NewJobKey

func NewJobKey() *JobKey

func (*JobKey) GetEnvironment

func (p *JobKey) GetEnvironment() string

func (*JobKey) GetName

func (p *JobKey) GetName() string

func (*JobKey) GetRole

func (p *JobKey) GetRole() string

func (*JobKey) Read

func (p *JobKey) Read(iprot thrift.TProtocol) error

func (*JobKey) ReadField1 added in v1.21.0

func (p *JobKey) ReadField1(iprot thrift.TProtocol) error

func (*JobKey) ReadField2 added in v1.21.0

func (p *JobKey) ReadField2(iprot thrift.TProtocol) error

func (*JobKey) ReadField3 added in v1.21.0

func (p *JobKey) ReadField3(iprot thrift.TProtocol) error

func (*JobKey) String

func (p *JobKey) String() string

func (*JobKey) Write

func (p *JobKey) Write(oprot thrift.TProtocol) error

type JobStats

type JobStats struct {
	ActiveTaskCount   int32 `thrift:"activeTaskCount,1" db:"activeTaskCount" json:"activeTaskCount"`
	FinishedTaskCount int32 `thrift:"finishedTaskCount,2" db:"finishedTaskCount" json:"finishedTaskCount"`
	FailedTaskCount   int32 `thrift:"failedTaskCount,3" db:"failedTaskCount" json:"failedTaskCount"`
	PendingTaskCount  int32 `thrift:"pendingTaskCount,4" db:"pendingTaskCount" json:"pendingTaskCount"`
}

Attributes:

  • ActiveTaskCount: Number of tasks in active state for this job.
  • FinishedTaskCount: Number of tasks in finished state for this job.
  • FailedTaskCount: Number of failed tasks for this job.
  • PendingTaskCount: Number of tasks in pending state for this job.
var JobSummary_Stats_DEFAULT *JobStats

func NewJobStats

func NewJobStats() *JobStats

func (*JobStats) GetActiveTaskCount

func (p *JobStats) GetActiveTaskCount() int32

func (*JobStats) GetFailedTaskCount

func (p *JobStats) GetFailedTaskCount() int32

func (*JobStats) GetFinishedTaskCount

func (p *JobStats) GetFinishedTaskCount() int32

func (*JobStats) GetPendingTaskCount

func (p *JobStats) GetPendingTaskCount() int32

func (*JobStats) Read

func (p *JobStats) Read(iprot thrift.TProtocol) error

func (*JobStats) ReadField1 added in v1.21.0

func (p *JobStats) ReadField1(iprot thrift.TProtocol) error

func (*JobStats) ReadField2 added in v1.21.0

func (p *JobStats) ReadField2(iprot thrift.TProtocol) error

func (*JobStats) ReadField3 added in v1.21.0

func (p *JobStats) ReadField3(iprot thrift.TProtocol) error

func (*JobStats) ReadField4 added in v1.21.0

func (p *JobStats) ReadField4(iprot thrift.TProtocol) error

func (*JobStats) String

func (p *JobStats) String() string

func (*JobStats) Write

func (p *JobStats) Write(oprot thrift.TProtocol) error

type JobSummary

type JobSummary struct {
	Job           *JobConfiguration `thrift:"job,1" db:"job" json:"job"`
	Stats         *JobStats         `thrift:"stats,2" db:"stats" json:"stats"`
	NextCronRunMs *int64            `thrift:"nextCronRunMs,3" db:"nextCronRunMs" json:"nextCronRunMs,omitempty"`
}

Attributes:

  • Job
  • Stats
  • NextCronRunMs: Timestamp of next cron run in ms since epoch, for a cron job

func NewJobSummary

func NewJobSummary() *JobSummary

func (*JobSummary) GetJob

func (p *JobSummary) GetJob() *JobConfiguration

func (*JobSummary) GetNextCronRunMs

func (p *JobSummary) GetNextCronRunMs() int64

func (*JobSummary) GetStats

func (p *JobSummary) GetStats() *JobStats

func (*JobSummary) IsSetJob

func (p *JobSummary) IsSetJob() bool

func (*JobSummary) IsSetNextCronRunMs

func (p *JobSummary) IsSetNextCronRunMs() bool

func (*JobSummary) IsSetStats

func (p *JobSummary) IsSetStats() bool

func (*JobSummary) Read

func (p *JobSummary) Read(iprot thrift.TProtocol) error

func (*JobSummary) ReadField1 added in v1.21.0

func (p *JobSummary) ReadField1(iprot thrift.TProtocol) error

func (*JobSummary) ReadField2 added in v1.21.0

func (p *JobSummary) ReadField2(iprot thrift.TProtocol) error

func (*JobSummary) ReadField3 added in v1.21.0

func (p *JobSummary) ReadField3(iprot thrift.TProtocol) error

func (*JobSummary) String

func (p *JobSummary) String() string

func (*JobSummary) Write

func (p *JobSummary) Write(oprot thrift.TProtocol) error

type JobSummaryResult_

type JobSummaryResult_ struct {
	Summaries []*JobSummary `thrift:"summaries,1" db:"summaries" json:"summaries"`
}

Attributes:

  • Summaries
var Result__JobSummaryResult__DEFAULT *JobSummaryResult_

func NewJobSummaryResult_

func NewJobSummaryResult_() *JobSummaryResult_

func (*JobSummaryResult_) GetSummaries

func (p *JobSummaryResult_) GetSummaries() []*JobSummary

func (*JobSummaryResult_) Read

func (p *JobSummaryResult_) Read(iprot thrift.TProtocol) error

func (*JobSummaryResult_) ReadField1 added in v1.21.0

func (p *JobSummaryResult_) ReadField1(iprot thrift.TProtocol) error

func (*JobSummaryResult_) String

func (p *JobSummaryResult_) String() string

func (*JobSummaryResult_) Write

func (p *JobSummaryResult_) Write(oprot thrift.TProtocol) error

type JobUpdate

type JobUpdate struct {
	Summary      *JobUpdateSummary      `thrift:"summary,1" db:"summary" json:"summary"`
	Instructions *JobUpdateInstructions `thrift:"instructions,2" db:"instructions" json:"instructions"`
}

Full definition of the job update.

Attributes:

  • Summary: Update summary.
  • Instructions: Update configuration.
var JobUpdateDetails_Update_DEFAULT *JobUpdate

func NewJobUpdate

func NewJobUpdate() *JobUpdate

func (*JobUpdate) GetInstructions

func (p *JobUpdate) GetInstructions() *JobUpdateInstructions

func (*JobUpdate) GetSummary

func (p *JobUpdate) GetSummary() *JobUpdateSummary

func (*JobUpdate) IsSetInstructions

func (p *JobUpdate) IsSetInstructions() bool

func (*JobUpdate) IsSetSummary

func (p *JobUpdate) IsSetSummary() bool

func (*JobUpdate) Read

func (p *JobUpdate) Read(iprot thrift.TProtocol) error

func (*JobUpdate) ReadField1 added in v1.21.0

func (p *JobUpdate) ReadField1(iprot thrift.TProtocol) error

func (*JobUpdate) ReadField2 added in v1.21.0

func (p *JobUpdate) ReadField2(iprot thrift.TProtocol) error

func (*JobUpdate) String

func (p *JobUpdate) String() string

func (*JobUpdate) Write

func (p *JobUpdate) Write(oprot thrift.TProtocol) error

type JobUpdateAction

type JobUpdateAction int64

Job update actions that can be applied to job instances.

const (
	JobUpdateAction_INSTANCE_UPDATED         JobUpdateAction = 1
	JobUpdateAction_INSTANCE_ROLLED_BACK     JobUpdateAction = 2
	JobUpdateAction_INSTANCE_UPDATING        JobUpdateAction = 3
	JobUpdateAction_INSTANCE_ROLLING_BACK    JobUpdateAction = 4
	JobUpdateAction_INSTANCE_UPDATE_FAILED   JobUpdateAction = 5
	JobUpdateAction_INSTANCE_ROLLBACK_FAILED JobUpdateAction = 6
)

func JobUpdateActionFromString

func JobUpdateActionFromString(s string) (JobUpdateAction, error)

func JobUpdateActionPtr

func JobUpdateActionPtr(v JobUpdateAction) *JobUpdateAction

func (JobUpdateAction) MarshalText

func (p JobUpdateAction) MarshalText() ([]byte, error)

func (*JobUpdateAction) Scan added in v1.21.0

func (p *JobUpdateAction) Scan(value interface{}) error

func (JobUpdateAction) String

func (p JobUpdateAction) String() string

func (*JobUpdateAction) UnmarshalText

func (p *JobUpdateAction) UnmarshalText(text []byte) error

func (*JobUpdateAction) Value added in v1.21.0

func (p *JobUpdateAction) Value() (driver.Value, error)

type JobUpdateDetails

type JobUpdateDetails struct {
	Update         *JobUpdate                `thrift:"update,1" db:"update" json:"update"`
	UpdateEvents   []*JobUpdateEvent         `thrift:"updateEvents,2" db:"updateEvents" json:"updateEvents"`
	InstanceEvents []*JobInstanceUpdateEvent `thrift:"instanceEvents,3" db:"instanceEvents" json:"instanceEvents"`
}

Attributes:

  • Update: Update definition.
  • UpdateEvents: History for this update.
  • InstanceEvents: History for the individual instances updated.
var GetJobUpdateDetailsResult__Details_DEFAULT *JobUpdateDetails

func NewJobUpdateDetails

func NewJobUpdateDetails() *JobUpdateDetails

func (*JobUpdateDetails) GetInstanceEvents

func (p *JobUpdateDetails) GetInstanceEvents() []*JobInstanceUpdateEvent

func (*JobUpdateDetails) GetUpdate

func (p *JobUpdateDetails) GetUpdate() *JobUpdate

func (*JobUpdateDetails) GetUpdateEvents

func (p *JobUpdateDetails) GetUpdateEvents() []*JobUpdateEvent

func (*JobUpdateDetails) IsSetUpdate

func (p *JobUpdateDetails) IsSetUpdate() bool

func (*JobUpdateDetails) Read

func (p *JobUpdateDetails) Read(iprot thrift.TProtocol) error

func (*JobUpdateDetails) ReadField1 added in v1.21.0

func (p *JobUpdateDetails) ReadField1(iprot thrift.TProtocol) error

func (*JobUpdateDetails) ReadField2 added in v1.21.0

func (p *JobUpdateDetails) ReadField2(iprot thrift.TProtocol) error

func (*JobUpdateDetails) ReadField3 added in v1.21.0

func (p *JobUpdateDetails) ReadField3(iprot thrift.TProtocol) error

func (*JobUpdateDetails) String

func (p *JobUpdateDetails) String() string

func (*JobUpdateDetails) Write

func (p *JobUpdateDetails) Write(oprot thrift.TProtocol) error

type JobUpdateEvent

type JobUpdateEvent struct {
	Status      JobUpdateStatus `thrift:"status,1" db:"status" json:"status"`
	TimestampMs int64           `thrift:"timestampMs,2" db:"timestampMs" json:"timestampMs"`
	User        *string         `thrift:"user,3" db:"user" json:"user,omitempty"`
	Message     *string         `thrift:"message,4" db:"message" json:"message,omitempty"`
}

Event marking a state transition in job update lifecycle.

Attributes:

  • Status: Update status.
  • TimestampMs: Epoch timestamp in milliseconds.
  • User: User who performed this event (if user-initiated).
  • Message: Message from the user (for user-initiated transitions) or the scheduler about why the state was

changed.

func NewJobUpdateEvent

func NewJobUpdateEvent() *JobUpdateEvent

func (*JobUpdateEvent) GetMessage

func (p *JobUpdateEvent) GetMessage() string

func (*JobUpdateEvent) GetStatus

func (p *JobUpdateEvent) GetStatus() JobUpdateStatus

func (*JobUpdateEvent) GetTimestampMs

func (p *JobUpdateEvent) GetTimestampMs() int64

func (*JobUpdateEvent) GetUser

func (p *JobUpdateEvent) GetUser() string

func (*JobUpdateEvent) IsSetMessage

func (p *JobUpdateEvent) IsSetMessage() bool

func (*JobUpdateEvent) IsSetUser

func (p *JobUpdateEvent) IsSetUser() bool

func (*JobUpdateEvent) Read

func (p *JobUpdateEvent) Read(iprot thrift.TProtocol) error

func (*JobUpdateEvent) ReadField1 added in v1.21.0

func (p *JobUpdateEvent) ReadField1(iprot thrift.TProtocol) error

func (*JobUpdateEvent) ReadField2 added in v1.21.0

func (p *JobUpdateEvent) ReadField2(iprot thrift.TProtocol) error

func (*JobUpdateEvent) ReadField3 added in v1.21.0

func (p *JobUpdateEvent) ReadField3(iprot thrift.TProtocol) error

func (*JobUpdateEvent) ReadField4 added in v1.21.0

func (p *JobUpdateEvent) ReadField4(iprot thrift.TProtocol) error

func (*JobUpdateEvent) String

func (p *JobUpdateEvent) String() string

func (*JobUpdateEvent) Write

func (p *JobUpdateEvent) Write(oprot thrift.TProtocol) error

type JobUpdateInstructions

type JobUpdateInstructions struct {
	InitialState []*InstanceTaskConfig `thrift:"initialState,1" db:"initialState" json:"initialState"`
	DesiredState *InstanceTaskConfig   `thrift:"desiredState,2" db:"desiredState" json:"desiredState"`
	Settings     *JobUpdateSettings    `thrift:"settings,3" db:"settings" json:"settings"`
}

Update configuration and setting details.

Attributes:

  • InitialState: Actual InstanceId -> TaskConfig mapping when the update was requested.
  • DesiredState: Desired configuration when the update completes.
  • Settings: Update specific settings.
var JobUpdate_Instructions_DEFAULT *JobUpdateInstructions

func NewJobUpdateInstructions

func NewJobUpdateInstructions() *JobUpdateInstructions

func (*JobUpdateInstructions) GetDesiredState

func (p *JobUpdateInstructions) GetDesiredState() *InstanceTaskConfig

func (*JobUpdateInstructions) GetInitialState

func (p *JobUpdateInstructions) GetInitialState() []*InstanceTaskConfig

func (*JobUpdateInstructions) GetSettings

func (p *JobUpdateInstructions) GetSettings() *JobUpdateSettings

func (*JobUpdateInstructions) IsSetDesiredState

func (p *JobUpdateInstructions) IsSetDesiredState() bool

func (*JobUpdateInstructions) IsSetSettings

func (p *JobUpdateInstructions) IsSetSettings() bool

func (*JobUpdateInstructions) Read

func (*JobUpdateInstructions) ReadField1 added in v1.21.0

func (p *JobUpdateInstructions) ReadField1(iprot thrift.TProtocol) error

func (*JobUpdateInstructions) ReadField2 added in v1.21.0

func (p *JobUpdateInstructions) ReadField2(iprot thrift.TProtocol) error

func (*JobUpdateInstructions) ReadField3 added in v1.21.0

func (p *JobUpdateInstructions) ReadField3(iprot thrift.TProtocol) error

func (*JobUpdateInstructions) String

func (p *JobUpdateInstructions) String() string

func (*JobUpdateInstructions) Write

func (p *JobUpdateInstructions) Write(oprot thrift.TProtocol) error

type JobUpdateKey

type JobUpdateKey struct {
	Job *JobKey `thrift:"job,1" db:"job" json:"job"`
	ID  string  `thrift:"id,2" db:"id" json:"id"`
}

Job update key.

Attributes:

  • Job: Job being updated
  • ID: Update ID.
var AuroraSchedulerManagerAbortJobUpdateArgs_Key_DEFAULT *JobUpdateKey
var AuroraSchedulerManagerPauseJobUpdateArgs_Key_DEFAULT *JobUpdateKey
var AuroraSchedulerManagerPulseJobUpdateArgs_Key_DEFAULT *JobUpdateKey
var AuroraSchedulerManagerResumeJobUpdateArgs_Key_DEFAULT *JobUpdateKey
var AuroraSchedulerManagerRollbackJobUpdateArgs_Key_DEFAULT *JobUpdateKey
var JobUpdateQuery_Key_DEFAULT *JobUpdateKey
var JobUpdateSummary_Key_DEFAULT *JobUpdateKey
var StartJobUpdateResult__Key_DEFAULT *JobUpdateKey

func NewJobUpdateKey

func NewJobUpdateKey() *JobUpdateKey

func (*JobUpdateKey) GetID

func (p *JobUpdateKey) GetID() string

func (*JobUpdateKey) GetJob

func (p *JobUpdateKey) GetJob() *JobKey

func (*JobUpdateKey) IsSetJob

func (p *JobUpdateKey) IsSetJob() bool

func (*JobUpdateKey) Read

func (p *JobUpdateKey) Read(iprot thrift.TProtocol) error

func (*JobUpdateKey) ReadField1 added in v1.21.0

func (p *JobUpdateKey) ReadField1(iprot thrift.TProtocol) error

func (*JobUpdateKey) ReadField2 added in v1.21.0

func (p *JobUpdateKey) ReadField2(iprot thrift.TProtocol) error

func (*JobUpdateKey) String

func (p *JobUpdateKey) String() string

func (*JobUpdateKey) Write

func (p *JobUpdateKey) Write(oprot thrift.TProtocol) error

type JobUpdatePulseStatus

type JobUpdatePulseStatus int64

Status of the coordinated update. Intended as a response to pulseJobUpdate RPC.

const (
	JobUpdatePulseStatus_OK       JobUpdatePulseStatus = 1
	JobUpdatePulseStatus_FINISHED JobUpdatePulseStatus = 2
)

func JobUpdatePulseStatusFromString

func JobUpdatePulseStatusFromString(s string) (JobUpdatePulseStatus, error)

func (JobUpdatePulseStatus) MarshalText

func (p JobUpdatePulseStatus) MarshalText() ([]byte, error)

func (*JobUpdatePulseStatus) Scan added in v1.21.0

func (p *JobUpdatePulseStatus) Scan(value interface{}) error

func (JobUpdatePulseStatus) String

func (p JobUpdatePulseStatus) String() string

func (*JobUpdatePulseStatus) UnmarshalText

func (p *JobUpdatePulseStatus) UnmarshalText(text []byte) error

func (*JobUpdatePulseStatus) Value added in v1.21.0

func (p *JobUpdatePulseStatus) Value() (driver.Value, error)

type JobUpdateQuery

type JobUpdateQuery struct {
	// unused field # 1
	Role           *string           `thrift:"role,2" db:"role" json:"role,omitempty"`
	JobKey         *JobKey           `thrift:"jobKey,3" db:"jobKey" json:"jobKey,omitempty"`
	User           *string           `thrift:"user,4" db:"user" json:"user,omitempty"`
	UpdateStatuses []JobUpdateStatus `thrift:"updateStatuses,5" db:"updateStatuses" json:"updateStatuses,omitempty"`
	Offset         int32             `thrift:"offset,6" db:"offset" json:"offset"`
	Limit          int32             `thrift:"limit,7" db:"limit" json:"limit"`
	Key            *JobUpdateKey     `thrift:"key,8" db:"key" json:"key,omitempty"`
}

Contains a set of restrictions on matching job updates where all restrictions must be met (terms are AND'ed together).

Attributes:

  • Role: Job role.
  • Key: Unique identifier for a job update.
  • JobKey: Job key.
  • User: User who created the update.
  • UpdateStatuses: Set of update statuses.
  • Offset: Offset to serve data from. Used by pagination.
  • Limit: Number or records to serve. Used by pagination.
var ReadOnlySchedulerGetJobUpdateDetailsArgs_Query_DEFAULT *JobUpdateQuery
var ReadOnlySchedulerGetJobUpdateSummariesArgs_JobUpdateQuery_DEFAULT *JobUpdateQuery

func NewJobUpdateQuery

func NewJobUpdateQuery() *JobUpdateQuery

func (*JobUpdateQuery) GetJobKey

func (p *JobUpdateQuery) GetJobKey() *JobKey

func (*JobUpdateQuery) GetKey

func (p *JobUpdateQuery) GetKey() *JobUpdateKey

func (*JobUpdateQuery) GetLimit

func (p *JobUpdateQuery) GetLimit() int32

func (*JobUpdateQuery) GetOffset

func (p *JobUpdateQuery) GetOffset() int32

func (*JobUpdateQuery) GetRole

func (p *JobUpdateQuery) GetRole() string

func (*JobUpdateQuery) GetUpdateStatuses

func (p *JobUpdateQuery) GetUpdateStatuses() []JobUpdateStatus

func (*JobUpdateQuery) GetUser

func (p *JobUpdateQuery) GetUser() string

func (*JobUpdateQuery) IsSetJobKey

func (p *JobUpdateQuery) IsSetJobKey() bool

func (*JobUpdateQuery) IsSetKey

func (p *JobUpdateQuery) IsSetKey() bool

func (*JobUpdateQuery) IsSetRole

func (p *JobUpdateQuery) IsSetRole() bool

func (*JobUpdateQuery) IsSetUpdateStatuses

func (p *JobUpdateQuery) IsSetUpdateStatuses() bool

func (*JobUpdateQuery) IsSetUser

func (p *JobUpdateQuery) IsSetUser() bool

func (*JobUpdateQuery) Read

func (p *JobUpdateQuery) Read(iprot thrift.TProtocol) error

func (*JobUpdateQuery) ReadField2 added in v1.21.0

func (p *JobUpdateQuery) ReadField2(iprot thrift.TProtocol) error

func (*JobUpdateQuery) ReadField3 added in v1.21.0

func (p *JobUpdateQuery) ReadField3(iprot thrift.TProtocol) error

func (*JobUpdateQuery) ReadField4 added in v1.21.0

func (p *JobUpdateQuery) ReadField4(iprot thrift.TProtocol) error

func (*JobUpdateQuery) ReadField5 added in v1.21.0

func (p *JobUpdateQuery) ReadField5(iprot thrift.TProtocol) error

func (*JobUpdateQuery) ReadField6 added in v1.21.0

func (p *JobUpdateQuery) ReadField6(iprot thrift.TProtocol) error

func (*JobUpdateQuery) ReadField7 added in v1.21.0

func (p *JobUpdateQuery) ReadField7(iprot thrift.TProtocol) error

func (*JobUpdateQuery) ReadField8 added in v1.21.0

func (p *JobUpdateQuery) ReadField8(iprot thrift.TProtocol) error

func (*JobUpdateQuery) String

func (p *JobUpdateQuery) String() string

func (*JobUpdateQuery) Write

func (p *JobUpdateQuery) Write(oprot thrift.TProtocol) error

type JobUpdateRequest

type JobUpdateRequest struct {
	TaskConfig    *TaskConfig        `thrift:"taskConfig,1" db:"taskConfig" json:"taskConfig"`
	InstanceCount int32              `thrift:"instanceCount,2" db:"instanceCount" json:"instanceCount"`
	Settings      *JobUpdateSettings `thrift:"settings,3" db:"settings" json:"settings"`
	Metadata      []*Metadata        `thrift:"metadata,4" db:"metadata" json:"metadata,omitempty"`
}

A request to update the following instances of an existing job. Used by startUpdate.

Attributes:

  • TaskConfig: Desired TaskConfig to apply.
  • InstanceCount: Desired number of instances of the task config.
  • Settings: Update settings and limits.
  • Metadata: Update metadata supplied by the client issuing the JobUpdateRequest.
var AuroraSchedulerManagerStartJobUpdateArgs_Request_DEFAULT *JobUpdateRequest
var ReadOnlySchedulerGetJobUpdateDiffArgs_Request_DEFAULT *JobUpdateRequest

func NewJobUpdateRequest

func NewJobUpdateRequest() *JobUpdateRequest

func (*JobUpdateRequest) GetInstanceCount

func (p *JobUpdateRequest) GetInstanceCount() int32

func (*JobUpdateRequest) GetMetadata

func (p *JobUpdateRequest) GetMetadata() []*Metadata

func (*JobUpdateRequest) GetSettings

func (p *JobUpdateRequest) GetSettings() *JobUpdateSettings

func (*JobUpdateRequest) GetTaskConfig

func (p *JobUpdateRequest) GetTaskConfig() *TaskConfig

func (*JobUpdateRequest) IsSetMetadata

func (p *JobUpdateRequest) IsSetMetadata() bool

func (*JobUpdateRequest) IsSetSettings

func (p *JobUpdateRequest) IsSetSettings() bool

func (*JobUpdateRequest) IsSetTaskConfig

func (p *JobUpdateRequest) IsSetTaskConfig() bool

func (*JobUpdateRequest) Read

func (p *JobUpdateRequest) Read(iprot thrift.TProtocol) error

func (*JobUpdateRequest) ReadField1 added in v1.21.0

func (p *JobUpdateRequest) ReadField1(iprot thrift.TProtocol) error

func (*JobUpdateRequest) ReadField2 added in v1.21.0

func (p *JobUpdateRequest) ReadField2(iprot thrift.TProtocol) error

func (*JobUpdateRequest) ReadField3 added in v1.21.0

func (p *JobUpdateRequest) ReadField3(iprot thrift.TProtocol) error

func (*JobUpdateRequest) ReadField4 added in v1.21.0

func (p *JobUpdateRequest) ReadField4(iprot thrift.TProtocol) error

func (*JobUpdateRequest) String

func (p *JobUpdateRequest) String() string

func (*JobUpdateRequest) Write

func (p *JobUpdateRequest) Write(oprot thrift.TProtocol) error

type JobUpdateSettings

type JobUpdateSettings struct {
	UpdateGroupSize        int32 `thrift:"updateGroupSize,1" db:"updateGroupSize" json:"updateGroupSize"`
	MaxPerInstanceFailures int32 `thrift:"maxPerInstanceFailures,2" db:"maxPerInstanceFailures" json:"maxPerInstanceFailures"`
	MaxFailedInstances     int32 `thrift:"maxFailedInstances,3" db:"maxFailedInstances" json:"maxFailedInstances"`
	// unused field # 4
	MinWaitInInstanceRunningMs int32    `thrift:"minWaitInInstanceRunningMs,5" db:"minWaitInInstanceRunningMs" json:"minWaitInInstanceRunningMs"`
	RollbackOnFailure          bool     `thrift:"rollbackOnFailure,6" db:"rollbackOnFailure" json:"rollbackOnFailure"`
	UpdateOnlyTheseInstances   []*Range `thrift:"updateOnlyTheseInstances,7" db:"updateOnlyTheseInstances" json:"updateOnlyTheseInstances"`
	WaitForBatchCompletion     bool     `thrift:"waitForBatchCompletion,8" db:"waitForBatchCompletion" json:"waitForBatchCompletion"`
	BlockIfNoPulsesAfterMs     *int32   `thrift:"blockIfNoPulsesAfterMs,9" db:"blockIfNoPulsesAfterMs" json:"blockIfNoPulsesAfterMs,omitempty"`
	SlaAware                   *bool    `thrift:"slaAware,10" db:"slaAware" json:"slaAware,omitempty"`
}

Job update thresholds and limits.

Attributes:

  • UpdateGroupSize: Max number of instances being updated at any given moment.
  • MaxPerInstanceFailures: Max number of instance failures to tolerate before marking instance as FAILED.
  • MaxFailedInstances: Max number of FAILED instances to tolerate before terminating the update.
  • MinWaitInInstanceRunningMs: Min time to watch a RUNNING instance.
  • RollbackOnFailure: If true, enables failed update rollback.
  • UpdateOnlyTheseInstances: Instance IDs to act on. All instances will be affected if this is not set.
  • WaitForBatchCompletion: If true, use updateGroupSize as strict batching boundaries, and avoid proceeding to another

batch until the preceding batch finishes updating.

  • BlockIfNoPulsesAfterMs: If set, requires external calls to pulseJobUpdate RPC within the specified rate for the

update to make progress. If no pulses received within specified interval the update will block. A blocked update is unable to continue but retains its current status. It may only get unblocked by a fresh pulseJobUpdate call.

  • SlaAware: If true, updates will obey the SLA requirements of the tasks being updated. If the SLA policy

differs between the old and new task configurations, updates will use the newest configuration.

var JobUpdateInstructions_Settings_DEFAULT *JobUpdateSettings
var JobUpdateRequest_Settings_DEFAULT *JobUpdateSettings

func NewJobUpdateSettings

func NewJobUpdateSettings() *JobUpdateSettings

func (*JobUpdateSettings) GetBlockIfNoPulsesAfterMs

func (p *JobUpdateSettings) GetBlockIfNoPulsesAfterMs() int32

func (*JobUpdateSettings) GetMaxFailedInstances

func (p *JobUpdateSettings) GetMaxFailedInstances() int32

func (*JobUpdateSettings) GetMaxPerInstanceFailures

func (p *JobUpdateSettings) GetMaxPerInstanceFailures() int32

func (*JobUpdateSettings) GetMinWaitInInstanceRunningMs

func (p *JobUpdateSettings) GetMinWaitInInstanceRunningMs() int32

func (*JobUpdateSettings) GetRollbackOnFailure

func (p *JobUpdateSettings) GetRollbackOnFailure() bool

func (*JobUpdateSettings) GetSlaAware added in v1.3.1

func (p *JobUpdateSettings) GetSlaAware() bool

func (*JobUpdateSettings) GetUpdateGroupSize

func (p *JobUpdateSettings) GetUpdateGroupSize() int32

func (*JobUpdateSettings) GetUpdateOnlyTheseInstances

func (p *JobUpdateSettings) GetUpdateOnlyTheseInstances() []*Range

func (*JobUpdateSettings) GetWaitForBatchCompletion

func (p *JobUpdateSettings) GetWaitForBatchCompletion() bool

func (*JobUpdateSettings) IsSetBlockIfNoPulsesAfterMs

func (p *JobUpdateSettings) IsSetBlockIfNoPulsesAfterMs() bool

func (*JobUpdateSettings) IsSetSlaAware added in v1.3.1

func (p *JobUpdateSettings) IsSetSlaAware() bool

func (*JobUpdateSettings) Read

func (p *JobUpdateSettings) Read(iprot thrift.TProtocol) error

func (*JobUpdateSettings) ReadField1 added in v1.21.0

func (p *JobUpdateSettings) ReadField1(iprot thrift.TProtocol) error

func (*JobUpdateSettings) ReadField10 added in v1.21.0

func (p *JobUpdateSettings) ReadField10(iprot thrift.TProtocol) error

func (*JobUpdateSettings) ReadField2 added in v1.21.0

func (p *JobUpdateSettings) ReadField2(iprot thrift.TProtocol) error

func (*JobUpdateSettings) ReadField3 added in v1.21.0

func (p *JobUpdateSettings) ReadField3(iprot thrift.TProtocol) error

func (*JobUpdateSettings) ReadField5 added in v1.21.0

func (p *JobUpdateSettings) ReadField5(iprot thrift.TProtocol) error

func (*JobUpdateSettings) ReadField6 added in v1.21.0

func (p *JobUpdateSettings) ReadField6(iprot thrift.TProtocol) error

func (*JobUpdateSettings) ReadField7 added in v1.21.0

func (p *JobUpdateSettings) ReadField7(iprot thrift.TProtocol) error

func (*JobUpdateSettings) ReadField8 added in v1.21.0

func (p *JobUpdateSettings) ReadField8(iprot thrift.TProtocol) error

func (*JobUpdateSettings) ReadField9 added in v1.21.0

func (p *JobUpdateSettings) ReadField9(iprot thrift.TProtocol) error

func (*JobUpdateSettings) String

func (p *JobUpdateSettings) String() string

func (*JobUpdateSettings) Write

func (p *JobUpdateSettings) Write(oprot thrift.TProtocol) error

type JobUpdateState

type JobUpdateState struct {
	Status                  JobUpdateStatus `thrift:"status,1" db:"status" json:"status"`
	CreatedTimestampMs      int64           `thrift:"createdTimestampMs,2" db:"createdTimestampMs" json:"createdTimestampMs"`
	LastModifiedTimestampMs int64           `thrift:"lastModifiedTimestampMs,3" db:"lastModifiedTimestampMs" json:"lastModifiedTimestampMs"`
}

Current job update state including status and created/modified timestamps.

Attributes:

  • Status: Current status of the update.
  • CreatedTimestampMs: Created timestamp in milliseconds.
  • LastModifiedTimestampMs: Last modified timestamp in milliseconds.
var JobUpdateSummary_State_DEFAULT *JobUpdateState

func NewJobUpdateState

func NewJobUpdateState() *JobUpdateState

func (*JobUpdateState) GetCreatedTimestampMs

func (p *JobUpdateState) GetCreatedTimestampMs() int64

func (*JobUpdateState) GetLastModifiedTimestampMs

func (p *JobUpdateState) GetLastModifiedTimestampMs() int64

func (*JobUpdateState) GetStatus

func (p *JobUpdateState) GetStatus() JobUpdateStatus

func (*JobUpdateState) Read

func (p *JobUpdateState) Read(iprot thrift.TProtocol) error

func (*JobUpdateState) ReadField1 added in v1.21.0

func (p *JobUpdateState) ReadField1(iprot thrift.TProtocol) error

func (*JobUpdateState) ReadField2 added in v1.21.0

func (p *JobUpdateState) ReadField2(iprot thrift.TProtocol) error

func (*JobUpdateState) ReadField3 added in v1.21.0

func (p *JobUpdateState) ReadField3(iprot thrift.TProtocol) error

func (*JobUpdateState) String

func (p *JobUpdateState) String() string

func (*JobUpdateState) Write

func (p *JobUpdateState) Write(oprot thrift.TProtocol) error

type JobUpdateStatus

type JobUpdateStatus int64

States that a job update may be in.

const (
	JobUpdateStatus_ROLLING_FORWARD             JobUpdateStatus = 0
	JobUpdateStatus_ROLLING_BACK                JobUpdateStatus = 1
	JobUpdateStatus_ROLL_FORWARD_PAUSED         JobUpdateStatus = 2
	JobUpdateStatus_ROLL_BACK_PAUSED            JobUpdateStatus = 3
	JobUpdateStatus_ROLLED_FORWARD              JobUpdateStatus = 4
	JobUpdateStatus_ROLLED_BACK                 JobUpdateStatus = 5
	JobUpdateStatus_ABORTED                     JobUpdateStatus = 6
	JobUpdateStatus_ERROR                       JobUpdateStatus = 7
	JobUpdateStatus_FAILED                      JobUpdateStatus = 8
	JobUpdateStatus_ROLL_FORWARD_AWAITING_PULSE JobUpdateStatus = 9
	JobUpdateStatus_ROLL_BACK_AWAITING_PULSE    JobUpdateStatus = 10
)

func JobUpdateStatusFromString

func JobUpdateStatusFromString(s string) (JobUpdateStatus, error)

func JobUpdateStatusPtr

func JobUpdateStatusPtr(v JobUpdateStatus) *JobUpdateStatus

func (JobUpdateStatus) MarshalText

func (p JobUpdateStatus) MarshalText() ([]byte, error)

func (*JobUpdateStatus) Scan added in v1.21.0

func (p *JobUpdateStatus) Scan(value interface{}) error

func (JobUpdateStatus) String

func (p JobUpdateStatus) String() string

func (*JobUpdateStatus) UnmarshalText

func (p *JobUpdateStatus) UnmarshalText(text []byte) error

func (*JobUpdateStatus) Value added in v1.21.0

func (p *JobUpdateStatus) Value() (driver.Value, error)

type JobUpdateSummary

type JobUpdateSummary struct {
	// unused fields # 1 to 2
	User     string          `thrift:"user,3" db:"user" json:"user"`
	State    *JobUpdateState `thrift:"state,4" db:"state" json:"state"`
	Key      *JobUpdateKey   `thrift:"key,5" db:"key" json:"key"`
	Metadata []*Metadata     `thrift:"metadata,6" db:"metadata" json:"metadata,omitempty"`
}

Summary of the job update including job key, user and current state.

Attributes:

  • Key: Unique identifier for the update.
  • User: User initiated an update.
  • State: Current job update state.
  • Metadata: Update metadata supplied by the client.
var JobUpdate_Summary_DEFAULT *JobUpdateSummary
var StartJobUpdateResult__UpdateSummary_DEFAULT *JobUpdateSummary

func NewJobUpdateSummary

func NewJobUpdateSummary() *JobUpdateSummary

func (*JobUpdateSummary) GetKey

func (p *JobUpdateSummary) GetKey() *JobUpdateKey

func (*JobUpdateSummary) GetMetadata

func (p *JobUpdateSummary) GetMetadata() []*Metadata

func (*JobUpdateSummary) GetState

func (p *JobUpdateSummary) GetState() *JobUpdateState

func (*JobUpdateSummary) GetUser

func (p *JobUpdateSummary) GetUser() string

func (*JobUpdateSummary) IsSetKey

func (p *JobUpdateSummary) IsSetKey() bool

func (*JobUpdateSummary) IsSetMetadata

func (p *JobUpdateSummary) IsSetMetadata() bool

func (*JobUpdateSummary) IsSetState

func (p *JobUpdateSummary) IsSetState() bool

func (*JobUpdateSummary) Read

func (p *JobUpdateSummary) Read(iprot thrift.TProtocol) error

func (*JobUpdateSummary) ReadField3 added in v1.21.0

func (p *JobUpdateSummary) ReadField3(iprot thrift.TProtocol) error

func (*JobUpdateSummary) ReadField4 added in v1.21.0

func (p *JobUpdateSummary) ReadField4(iprot thrift.TProtocol) error

func (*JobUpdateSummary) ReadField5 added in v1.21.0

func (p *JobUpdateSummary) ReadField5(iprot thrift.TProtocol) error

func (*JobUpdateSummary) ReadField6 added in v1.21.0

func (p *JobUpdateSummary) ReadField6(iprot thrift.TProtocol) error

func (*JobUpdateSummary) String

func (p *JobUpdateSummary) String() string

func (*JobUpdateSummary) Write

func (p *JobUpdateSummary) Write(oprot thrift.TProtocol) error

type LimitConstraint

type LimitConstraint struct {
	Limit int32 `thrift:"limit,1" db:"limit" json:"limit"`
}

A constraint the specifies the maximum number of active tasks on a host with a matching attribute that may be scheduled simultaneously.

Attributes:

  • Limit
var TaskConstraint_Limit_DEFAULT *LimitConstraint

func NewLimitConstraint

func NewLimitConstraint() *LimitConstraint

func (*LimitConstraint) GetLimit

func (p *LimitConstraint) GetLimit() int32

func (*LimitConstraint) Read

func (p *LimitConstraint) Read(iprot thrift.TProtocol) error

func (*LimitConstraint) ReadField1 added in v1.21.0

func (p *LimitConstraint) ReadField1(iprot thrift.TProtocol) error

func (*LimitConstraint) String

func (p *LimitConstraint) String() string

func (*LimitConstraint) Write

func (p *LimitConstraint) Write(oprot thrift.TProtocol) error

type ListBackupsResult_

type ListBackupsResult_ struct {
	Backups []string `thrift:"backups,1" db:"backups" json:"backups"`
}

Attributes:

  • Backups
var Result__ListBackupsResult__DEFAULT *ListBackupsResult_

func NewListBackupsResult_

func NewListBackupsResult_() *ListBackupsResult_

func (*ListBackupsResult_) GetBackups

func (p *ListBackupsResult_) GetBackups() []string

func (*ListBackupsResult_) Read

func (p *ListBackupsResult_) Read(iprot thrift.TProtocol) error

func (*ListBackupsResult_) ReadField1 added in v1.21.0

func (p *ListBackupsResult_) ReadField1(iprot thrift.TProtocol) error

func (*ListBackupsResult_) String

func (p *ListBackupsResult_) String() string

func (*ListBackupsResult_) Write

func (p *ListBackupsResult_) Write(oprot thrift.TProtocol) error

type Lock

type Lock struct {
	Key         *LockKey `thrift:"key,1" db:"key" json:"key"`
	Token       string   `thrift:"token,2" db:"token" json:"token"`
	User        string   `thrift:"user,3" db:"user" json:"user"`
	TimestampMs int64    `thrift:"timestampMs,4" db:"timestampMs" json:"timestampMs"`
	Message     *string  `thrift:"message,5" db:"message" json:"message,omitempty"`
}

A generic lock struct to facilitate context specific resource/operation serialization.

Attributes:

  • Key: ID of the lock - unique per storage
  • Token: UUID - facilitating soft lock authorization
  • User: Lock creator
  • TimestampMs: Lock creation timestamp in milliseconds
  • Message: Optional message to record with the lock

func NewLock

func NewLock() *Lock

func (*Lock) GetKey

func (p *Lock) GetKey() *LockKey

func (*Lock) GetMessage

func (p *Lock) GetMessage() string

func (*Lock) GetTimestampMs

func (p *Lock) GetTimestampMs() int64

func (*Lock) GetToken

func (p *Lock) GetToken() string

func (*Lock) GetUser

func (p *Lock) GetUser() string

func (*Lock) IsSetKey

func (p *Lock) IsSetKey() bool

func (*Lock) IsSetMessage

func (p *Lock) IsSetMessage() bool

func (*Lock) Read

func (p *Lock) Read(iprot thrift.TProtocol) error

func (*Lock) ReadField1 added in v1.21.0

func (p *Lock) ReadField1(iprot thrift.TProtocol) error

func (*Lock) ReadField2 added in v1.21.0

func (p *Lock) ReadField2(iprot thrift.TProtocol) error

func (*Lock) ReadField3 added in v1.21.0

func (p *Lock) ReadField3(iprot thrift.TProtocol) error

func (*Lock) ReadField4 added in v1.21.0

func (p *Lock) ReadField4(iprot thrift.TProtocol) error

func (*Lock) ReadField5 added in v1.21.0

func (p *Lock) ReadField5(iprot thrift.TProtocol) error

func (*Lock) String

func (p *Lock) String() string

func (*Lock) Write

func (p *Lock) Write(oprot thrift.TProtocol) error

type LockKey

type LockKey struct {
	Job *JobKey `thrift:"job,1" db:"job" json:"job,omitempty"`
}

A unique lock key.

Attributes:

  • Job
var Lock_Key_DEFAULT *LockKey

func NewLockKey

func NewLockKey() *LockKey

func (*LockKey) CountSetFieldsLockKey

func (p *LockKey) CountSetFieldsLockKey() int

func (*LockKey) GetJob

func (p *LockKey) GetJob() *JobKey

func (*LockKey) IsSetJob

func (p *LockKey) IsSetJob() bool

func (*LockKey) Read

func (p *LockKey) Read(iprot thrift.TProtocol) error

func (*LockKey) ReadField1 added in v1.21.0

func (p *LockKey) ReadField1(iprot thrift.TProtocol) error

func (*LockKey) String

func (p *LockKey) String() string

func (*LockKey) Write

func (p *LockKey) Write(oprot thrift.TProtocol) error

type MaintenanceMode

type MaintenanceMode int64
const (
	MaintenanceMode_NONE      MaintenanceMode = 1
	MaintenanceMode_SCHEDULED MaintenanceMode = 2
	MaintenanceMode_DRAINING  MaintenanceMode = 3
	MaintenanceMode_DRAINED   MaintenanceMode = 4
)
var HostAttributes_Mode_DEFAULT MaintenanceMode

func MaintenanceModeFromString

func MaintenanceModeFromString(s string) (MaintenanceMode, error)

func MaintenanceModePtr

func MaintenanceModePtr(v MaintenanceMode) *MaintenanceMode

func (MaintenanceMode) MarshalText

func (p MaintenanceMode) MarshalText() ([]byte, error)

func (*MaintenanceMode) Scan added in v1.21.0

func (p *MaintenanceMode) Scan(value interface{}) error

func (MaintenanceMode) String

func (p MaintenanceMode) String() string

func (*MaintenanceMode) UnmarshalText

func (p *MaintenanceMode) UnmarshalText(text []byte) error

func (*MaintenanceMode) Value added in v1.21.0

func (p *MaintenanceMode) Value() (driver.Value, error)

type MaintenanceStatusResult_

type MaintenanceStatusResult_ struct {
	Statuses []*HostStatus `thrift:"statuses,1" db:"statuses" json:"statuses"`
}

Attributes:

  • Statuses
var Result__MaintenanceStatusResult__DEFAULT *MaintenanceStatusResult_

func NewMaintenanceStatusResult_

func NewMaintenanceStatusResult_() *MaintenanceStatusResult_

func (*MaintenanceStatusResult_) GetStatuses

func (p *MaintenanceStatusResult_) GetStatuses() []*HostStatus

func (*MaintenanceStatusResult_) Read

func (*MaintenanceStatusResult_) ReadField1 added in v1.21.0

func (p *MaintenanceStatusResult_) ReadField1(iprot thrift.TProtocol) error

func (*MaintenanceStatusResult_) String

func (p *MaintenanceStatusResult_) String() string

func (*MaintenanceStatusResult_) Write

type MesosContainer

type MesosContainer struct {
	Image   *Image    `thrift:"image,1" db:"image" json:"image,omitempty"`
	Volumes []*Volume `thrift:"volumes,2" db:"volumes" json:"volumes,omitempty"`
}

Describes a mesos container, this is the default

Attributes:

  • Image: the optional filesystem image to use when launching this task.
  • Volumes: the optional list of volumes to mount into the task.
var Container_Mesos_DEFAULT *MesosContainer

func NewMesosContainer

func NewMesosContainer() *MesosContainer

func (*MesosContainer) GetImage

func (p *MesosContainer) GetImage() *Image

func (*MesosContainer) GetVolumes added in v1.1.0

func (p *MesosContainer) GetVolumes() []*Volume

func (*MesosContainer) IsSetImage

func (p *MesosContainer) IsSetImage() bool

func (*MesosContainer) IsSetVolumes added in v1.1.0

func (p *MesosContainer) IsSetVolumes() bool

func (*MesosContainer) Read

func (p *MesosContainer) Read(iprot thrift.TProtocol) error

func (*MesosContainer) ReadField1 added in v1.21.0

func (p *MesosContainer) ReadField1(iprot thrift.TProtocol) error

func (*MesosContainer) ReadField2 added in v1.21.0

func (p *MesosContainer) ReadField2(iprot thrift.TProtocol) error

func (*MesosContainer) String

func (p *MesosContainer) String() string

func (*MesosContainer) Write

func (p *MesosContainer) Write(oprot thrift.TProtocol) error

type MesosFetcherURI

type MesosFetcherURI struct {
	Value   string `thrift:"value,1" db:"value" json:"value"`
	Extract *bool  `thrift:"extract,2" db:"extract" json:"extract,omitempty"`
	Cache   *bool  `thrift:"cache,3" db:"cache" json:"cache,omitempty"`
}

URI which mirrors CommandInfo.URI in the Mesos Protobuf

Attributes:

  • Value: Where to get the resource from
  • Extract: Extract compressed archive after downloading
  • Cache: Cache value using Mesos Fetcher caching mechanism *

func NewMesosFetcherURI

func NewMesosFetcherURI() *MesosFetcherURI

func (*MesosFetcherURI) GetCache

func (p *MesosFetcherURI) GetCache() bool

func (*MesosFetcherURI) GetExtract

func (p *MesosFetcherURI) GetExtract() bool

func (*MesosFetcherURI) GetValue

func (p *MesosFetcherURI) GetValue() string

func (*MesosFetcherURI) IsSetCache

func (p *MesosFetcherURI) IsSetCache() bool

func (*MesosFetcherURI) IsSetExtract

func (p *MesosFetcherURI) IsSetExtract() bool

func (*MesosFetcherURI) Read

func (p *MesosFetcherURI) Read(iprot thrift.TProtocol) error

func (*MesosFetcherURI) ReadField1 added in v1.21.0

func (p *MesosFetcherURI) ReadField1(iprot thrift.TProtocol) error

func (*MesosFetcherURI) ReadField2 added in v1.21.0

func (p *MesosFetcherURI) ReadField2(iprot thrift.TProtocol) error

func (*MesosFetcherURI) ReadField3 added in v1.21.0

func (p *MesosFetcherURI) ReadField3(iprot thrift.TProtocol) error

func (*MesosFetcherURI) String

func (p *MesosFetcherURI) String() string

func (*MesosFetcherURI) Write

func (p *MesosFetcherURI) Write(oprot thrift.TProtocol) error

type Metadata

type Metadata struct {
	Key   string `thrift:"key,1" db:"key" json:"key"`
	Value string `thrift:"value,2" db:"value" json:"value"`
}

Arbitrary key-value metadata to be included into TaskConfig.

Attributes:

  • Key
  • Value

func NewMetadata

func NewMetadata() *Metadata

func (*Metadata) GetKey

func (p *Metadata) GetKey() string

func (*Metadata) GetValue

func (p *Metadata) GetValue() string

func (*Metadata) Read

func (p *Metadata) Read(iprot thrift.TProtocol) error

func (*Metadata) ReadField1 added in v1.21.0

func (p *Metadata) ReadField1(iprot thrift.TProtocol) error

func (*Metadata) ReadField2 added in v1.21.0

func (p *Metadata) ReadField2(iprot thrift.TProtocol) error

func (*Metadata) String

func (p *Metadata) String() string

func (*Metadata) Write

func (p *Metadata) Write(oprot thrift.TProtocol) error

type Mode

type Mode int64

The mode for a volume mount

const (
	Mode_RW Mode = 1
	Mode_RO Mode = 2
)

func ModeFromString

func ModeFromString(s string) (Mode, error)

func ModePtr

func ModePtr(v Mode) *Mode

func (Mode) MarshalText

func (p Mode) MarshalText() ([]byte, error)

func (*Mode) Scan added in v1.21.0

func (p *Mode) Scan(value interface{}) error

func (Mode) String

func (p Mode) String() string

func (*Mode) UnmarshalText

func (p *Mode) UnmarshalText(text []byte) error

func (*Mode) Value added in v1.21.0

func (p *Mode) Value() (driver.Value, error)

type Package

type Package struct {
	Role    string `thrift:"role,1" db:"role" json:"role"`
	Name    string `thrift:"name,2" db:"name" json:"name"`
	Version int32  `thrift:"version,3" db:"version" json:"version"`
}

Attributes:

  • Role
  • Name
  • Version

func NewPackage

func NewPackage() *Package

func (*Package) GetName

func (p *Package) GetName() string

func (*Package) GetRole

func (p *Package) GetRole() string

func (*Package) GetVersion

func (p *Package) GetVersion() int32

func (*Package) Read

func (p *Package) Read(iprot thrift.TProtocol) error

func (*Package) ReadField1 added in v1.21.0

func (p *Package) ReadField1(iprot thrift.TProtocol) error

func (*Package) ReadField2 added in v1.21.0

func (p *Package) ReadField2(iprot thrift.TProtocol) error

func (*Package) ReadField3 added in v1.21.0

func (p *Package) ReadField3(iprot thrift.TProtocol) error

func (*Package) String

func (p *Package) String() string

func (*Package) Write

func (p *Package) Write(oprot thrift.TProtocol) error

type PartitionPolicy added in v1.3.1

type PartitionPolicy struct {
	Reschedule bool   `thrift:"reschedule,1" db:"reschedule" json:"reschedule"`
	DelaySecs  *int64 `thrift:"delaySecs,2" db:"delaySecs" json:"delaySecs,omitempty"`
}

Attributes:

  • Reschedule
  • DelaySecs
var TaskConfig_PartitionPolicy_DEFAULT *PartitionPolicy

func NewPartitionPolicy added in v1.3.1

func NewPartitionPolicy() *PartitionPolicy

func (*PartitionPolicy) GetDelaySecs added in v1.3.1

func (p *PartitionPolicy) GetDelaySecs() int64

func (*PartitionPolicy) GetReschedule added in v1.3.1

func (p *PartitionPolicy) GetReschedule() bool

func (*PartitionPolicy) IsSetDelaySecs added in v1.3.1

func (p *PartitionPolicy) IsSetDelaySecs() bool

func (*PartitionPolicy) Read added in v1.3.1

func (p *PartitionPolicy) Read(iprot thrift.TProtocol) error

func (*PartitionPolicy) ReadField1 added in v1.21.0

func (p *PartitionPolicy) ReadField1(iprot thrift.TProtocol) error

func (*PartitionPolicy) ReadField2 added in v1.21.0

func (p *PartitionPolicy) ReadField2(iprot thrift.TProtocol) error

func (*PartitionPolicy) String added in v1.3.1

func (p *PartitionPolicy) String() string

func (*PartitionPolicy) Write added in v1.3.1

func (p *PartitionPolicy) Write(oprot thrift.TProtocol) error

type PendingReason

type PendingReason struct {
	TaskId string `thrift:"taskId,1" db:"taskId" json:"taskId"`
	Reason string `thrift:"reason,2" db:"reason" json:"reason"`
}

Attributes:

  • TaskId
  • Reason

func NewPendingReason

func NewPendingReason() *PendingReason

func (*PendingReason) GetReason

func (p *PendingReason) GetReason() string

func (*PendingReason) GetTaskId

func (p *PendingReason) GetTaskId() string

func (*PendingReason) Read

func (p *PendingReason) Read(iprot thrift.TProtocol) error

func (*PendingReason) ReadField1 added in v1.21.0

func (p *PendingReason) ReadField1(iprot thrift.TProtocol) error

func (*PendingReason) ReadField2 added in v1.21.0

func (p *PendingReason) ReadField2(iprot thrift.TProtocol) error

func (*PendingReason) String

func (p *PendingReason) String() string

func (*PendingReason) Write

func (p *PendingReason) Write(oprot thrift.TProtocol) error

type PercentageSlaPolicy added in v1.3.1

type PercentageSlaPolicy struct {
	Percentage   float64 `thrift:"percentage,1" db:"percentage" json:"percentage"`
	DurationSecs int64   `thrift:"durationSecs,2" db:"durationSecs" json:"durationSecs"`
}

SLA requirements expressed as the percentage of instances to be RUNNING every durationSecs

Attributes:

  • Percentage
  • DurationSecs: Minimum time duration a task needs to be `RUNNING` to be treated as active
var SlaPolicy_PercentageSlaPolicy_DEFAULT *PercentageSlaPolicy

func NewPercentageSlaPolicy added in v1.3.1

func NewPercentageSlaPolicy() *PercentageSlaPolicy

func (*PercentageSlaPolicy) GetDurationSecs added in v1.3.1

func (p *PercentageSlaPolicy) GetDurationSecs() int64

func (*PercentageSlaPolicy) GetPercentage added in v1.3.1

func (p *PercentageSlaPolicy) GetPercentage() float64

func (*PercentageSlaPolicy) Read added in v1.3.1

func (p *PercentageSlaPolicy) Read(iprot thrift.TProtocol) error

func (*PercentageSlaPolicy) ReadField1 added in v1.21.0

func (p *PercentageSlaPolicy) ReadField1(iprot thrift.TProtocol) error

func (*PercentageSlaPolicy) ReadField2 added in v1.21.0

func (p *PercentageSlaPolicy) ReadField2(iprot thrift.TProtocol) error

func (*PercentageSlaPolicy) String added in v1.3.1

func (p *PercentageSlaPolicy) String() string

func (*PercentageSlaPolicy) Write added in v1.3.1

func (p *PercentageSlaPolicy) Write(oprot thrift.TProtocol) error

type PopulateJobResult_

type PopulateJobResult_ struct {
	// unused field # 1
	TaskConfig *TaskConfig `thrift:"taskConfig,2" db:"taskConfig" json:"taskConfig"`
}

Attributes:

  • TaskConfig
var Result__PopulateJobResult__DEFAULT *PopulateJobResult_

func NewPopulateJobResult_

func NewPopulateJobResult_() *PopulateJobResult_

func (*PopulateJobResult_) GetTaskConfig

func (p *PopulateJobResult_) GetTaskConfig() *TaskConfig

func (*PopulateJobResult_) IsSetTaskConfig

func (p *PopulateJobResult_) IsSetTaskConfig() bool

func (*PopulateJobResult_) Read

func (p *PopulateJobResult_) Read(iprot thrift.TProtocol) error

func (*PopulateJobResult_) ReadField2 added in v1.21.0

func (p *PopulateJobResult_) ReadField2(iprot thrift.TProtocol) error

func (*PopulateJobResult_) String

func (p *PopulateJobResult_) String() string

func (*PopulateJobResult_) Write

func (p *PopulateJobResult_) Write(oprot thrift.TProtocol) error

type PulseJobUpdateResult_

type PulseJobUpdateResult_ struct {
	Status JobUpdatePulseStatus `thrift:"status,1" db:"status" json:"status"`
}

Result of the pulseJobUpdate call.

Attributes:

  • Status
var Result__PulseJobUpdateResult__DEFAULT *PulseJobUpdateResult_

func NewPulseJobUpdateResult_

func NewPulseJobUpdateResult_() *PulseJobUpdateResult_

func (*PulseJobUpdateResult_) GetStatus

func (*PulseJobUpdateResult_) Read

func (*PulseJobUpdateResult_) ReadField1 added in v1.21.0

func (p *PulseJobUpdateResult_) ReadField1(iprot thrift.TProtocol) error

func (*PulseJobUpdateResult_) String

func (p *PulseJobUpdateResult_) String() string

func (*PulseJobUpdateResult_) Write

func (p *PulseJobUpdateResult_) Write(oprot thrift.TProtocol) error

type QueryRecoveryResult_

type QueryRecoveryResult_ struct {
	Tasks []*ScheduledTask `thrift:"tasks,1" db:"tasks" json:"tasks"`
}

Attributes:

  • Tasks
var Result__QueryRecoveryResult__DEFAULT *QueryRecoveryResult_

func NewQueryRecoveryResult_

func NewQueryRecoveryResult_() *QueryRecoveryResult_

func (*QueryRecoveryResult_) GetTasks

func (p *QueryRecoveryResult_) GetTasks() []*ScheduledTask

func (*QueryRecoveryResult_) Read

func (p *QueryRecoveryResult_) Read(iprot thrift.TProtocol) error

func (*QueryRecoveryResult_) ReadField1 added in v1.21.0

func (p *QueryRecoveryResult_) ReadField1(iprot thrift.TProtocol) error

func (*QueryRecoveryResult_) String

func (p *QueryRecoveryResult_) String() string

func (*QueryRecoveryResult_) Write

func (p *QueryRecoveryResult_) Write(oprot thrift.TProtocol) error

type Range

type Range struct {
	First int32 `thrift:"first,1" db:"first" json:"first"`
	Last  int32 `thrift:"last,2" db:"last" json:"last"`
}

Closed range of integers.

Attributes:

  • First
  • Last

func NewRange

func NewRange() *Range

func (*Range) GetFirst

func (p *Range) GetFirst() int32

func (*Range) GetLast

func (p *Range) GetLast() int32

func (*Range) Read

func (p *Range) Read(iprot thrift.TProtocol) error

func (*Range) ReadField1 added in v1.21.0

func (p *Range) ReadField1(iprot thrift.TProtocol) error

func (*Range) ReadField2 added in v1.21.0

func (p *Range) ReadField2(iprot thrift.TProtocol) error

func (*Range) String

func (p *Range) String() string

func (*Range) Write

func (p *Range) Write(oprot thrift.TProtocol) error

type ReadOnlyScheduler

type ReadOnlyScheduler interface {
	// Returns a summary of the jobs grouped by role.
	GetRoleSummary(ctx context.Context) (r *Response, err error)
	// Returns a summary of jobs, optionally only those owned by a specific role.
	//
	// Parameters:
	//  - Role
	GetJobSummary(ctx context.Context, role string) (r *Response, err error)
	// Fetches the status of tasks.
	//
	// Parameters:
	//  - Query
	GetTasksStatus(ctx context.Context, query *TaskQuery) (r *Response, err error)
	// Same as getTaskStatus but without the TaskConfig.ExecutorConfig data set.
	// This is an interim solution until we have a better way to query TaskConfigs (AURORA-541).
	//
	// Parameters:
	//  - Query
	GetTasksWithoutConfigs(ctx context.Context, query *TaskQuery) (r *Response, err error)
	// Returns user-friendly reasons (if available) for tasks retained in PENDING state.
	//
	// Parameters:
	//  - Query
	GetPendingReason(ctx context.Context, query *TaskQuery) (r *Response, err error)
	// Fetches the configuration summary of active tasks for the specified job.
	//
	// Parameters:
	//  - Job
	GetConfigSummary(ctx context.Context, job *JobKey) (r *Response, err error)
	// Fetches the status of jobs.
	// ownerRole is optional, in which case all jobs are returned.
	//
	// Parameters:
	//  - OwnerRole
	GetJobs(ctx context.Context, ownerRole string) (r *Response, err error)
	// Fetches the quota allocated for a user.
	//
	// Parameters:
	//  - OwnerRole
	GetQuota(ctx context.Context, ownerRole string) (r *Response, err error)
	// Populates fields in a job configuration as though it were about to be run.
	// This can be used to diff a configuration running tasks.
	//
	// Parameters:
	//  - Description
	PopulateJobConfig(ctx context.Context, description *JobConfiguration) (r *Response, err error)
	// Gets job update summaries.
	//
	// Parameters:
	//  - JobUpdateQuery
	GetJobUpdateSummaries(ctx context.Context, jobUpdateQuery *JobUpdateQuery) (r *Response, err error)
	// Gets job update details.
	//
	// Parameters:
	//  - Query
	GetJobUpdateDetails(ctx context.Context, query *JobUpdateQuery) (r *Response, err error)
	// Gets the diff between client (desired) and server (current) job states.
	//
	// Parameters:
	//  - Request
	GetJobUpdateDiff(ctx context.Context, request *JobUpdateRequest) (r *Response, err error)
	// Gets tier configurations.
	GetTierConfigs(ctx context.Context) (r *Response, err error)
}

type ReadOnlySchedulerClient

type ReadOnlySchedulerClient struct {
	// contains filtered or unexported fields
}

func NewReadOnlySchedulerClient added in v1.21.0

func NewReadOnlySchedulerClient(c thrift.TClient) *ReadOnlySchedulerClient

func NewReadOnlySchedulerClientProtocol

func NewReadOnlySchedulerClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *ReadOnlySchedulerClient

func (*ReadOnlySchedulerClient) Client_ added in v1.21.0

func (p *ReadOnlySchedulerClient) Client_() thrift.TClient

func (*ReadOnlySchedulerClient) GetConfigSummary

func (p *ReadOnlySchedulerClient) GetConfigSummary(ctx context.Context, job *JobKey) (r *Response, err error)

Fetches the configuration summary of active tasks for the specified job.

Parameters:

  • Job

func (*ReadOnlySchedulerClient) GetJobSummary

func (p *ReadOnlySchedulerClient) GetJobSummary(ctx context.Context, role string) (r *Response, err error)

Returns a summary of jobs, optionally only those owned by a specific role.

Parameters:

  • Role

func (*ReadOnlySchedulerClient) GetJobUpdateDetails

func (p *ReadOnlySchedulerClient) GetJobUpdateDetails(ctx context.Context, query *JobUpdateQuery) (r *Response, err error)

Gets job update details.

Parameters:

  • Query

func (*ReadOnlySchedulerClient) GetJobUpdateDiff

func (p *ReadOnlySchedulerClient) GetJobUpdateDiff(ctx context.Context, request *JobUpdateRequest) (r *Response, err error)

Gets the diff between client (desired) and server (current) job states.

Parameters:

  • Request

func (*ReadOnlySchedulerClient) GetJobUpdateSummaries

func (p *ReadOnlySchedulerClient) GetJobUpdateSummaries(ctx context.Context, jobUpdateQuery *JobUpdateQuery) (r *Response, err error)

Gets job update summaries.

Parameters:

  • JobUpdateQuery

func (*ReadOnlySchedulerClient) GetJobs

func (p *ReadOnlySchedulerClient) GetJobs(ctx context.Context, ownerRole string) (r *Response, err error)

Fetches the status of jobs. ownerRole is optional, in which case all jobs are returned.

Parameters:

  • OwnerRole

func (*ReadOnlySchedulerClient) GetPendingReason

func (p *ReadOnlySchedulerClient) GetPendingReason(ctx context.Context, query *TaskQuery) (r *Response, err error)

Returns user-friendly reasons (if available) for tasks retained in PENDING state.

Parameters:

  • Query

func (*ReadOnlySchedulerClient) GetQuota

func (p *ReadOnlySchedulerClient) GetQuota(ctx context.Context, ownerRole string) (r *Response, err error)

Fetches the quota allocated for a user.

Parameters:

  • OwnerRole

func (*ReadOnlySchedulerClient) GetRoleSummary

func (p *ReadOnlySchedulerClient) GetRoleSummary(ctx context.Context) (r *Response, err error)

Returns a summary of the jobs grouped by role.

func (*ReadOnlySchedulerClient) GetTasksStatus

func (p *ReadOnlySchedulerClient) GetTasksStatus(ctx context.Context, query *TaskQuery) (r *Response, err error)

Fetches the status of tasks.

Parameters:

  • Query

func (*ReadOnlySchedulerClient) GetTasksWithoutConfigs

func (p *ReadOnlySchedulerClient) GetTasksWithoutConfigs(ctx context.Context, query *TaskQuery) (r *Response, err error)

Same as getTaskStatus but without the TaskConfig.ExecutorConfig data set. This is an interim solution until we have a better way to query TaskConfigs (AURORA-541).

Parameters:

  • Query

func (*ReadOnlySchedulerClient) GetTierConfigs

func (p *ReadOnlySchedulerClient) GetTierConfigs(ctx context.Context) (r *Response, err error)

Gets tier configurations.

func (*ReadOnlySchedulerClient) PopulateJobConfig

func (p *ReadOnlySchedulerClient) PopulateJobConfig(ctx context.Context, description *JobConfiguration) (r *Response, err error)

Populates fields in a job configuration as though it were about to be run. This can be used to diff a configuration running tasks.

Parameters:

  • Description

type ReadOnlySchedulerGetConfigSummaryArgs

type ReadOnlySchedulerGetConfigSummaryArgs struct {
	Job *JobKey `thrift:"job,1" db:"job" json:"job"`
}

Attributes:

  • Job

func NewReadOnlySchedulerGetConfigSummaryArgs

func NewReadOnlySchedulerGetConfigSummaryArgs() *ReadOnlySchedulerGetConfigSummaryArgs

func (*ReadOnlySchedulerGetConfigSummaryArgs) GetJob

func (*ReadOnlySchedulerGetConfigSummaryArgs) IsSetJob

func (*ReadOnlySchedulerGetConfigSummaryArgs) Read

func (*ReadOnlySchedulerGetConfigSummaryArgs) ReadField1 added in v1.21.0

func (*ReadOnlySchedulerGetConfigSummaryArgs) String

func (*ReadOnlySchedulerGetConfigSummaryArgs) Write

type ReadOnlySchedulerGetConfigSummaryResult

type ReadOnlySchedulerGetConfigSummaryResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewReadOnlySchedulerGetConfigSummaryResult

func NewReadOnlySchedulerGetConfigSummaryResult() *ReadOnlySchedulerGetConfigSummaryResult

func (*ReadOnlySchedulerGetConfigSummaryResult) GetSuccess

func (*ReadOnlySchedulerGetConfigSummaryResult) IsSetSuccess

func (*ReadOnlySchedulerGetConfigSummaryResult) Read

func (*ReadOnlySchedulerGetConfigSummaryResult) ReadField0 added in v1.21.0

func (*ReadOnlySchedulerGetConfigSummaryResult) String

func (*ReadOnlySchedulerGetConfigSummaryResult) Write

type ReadOnlySchedulerGetJobSummaryArgs

type ReadOnlySchedulerGetJobSummaryArgs struct {
	Role string `thrift:"role,1" db:"role" json:"role"`
}

Attributes:

  • Role

func NewReadOnlySchedulerGetJobSummaryArgs

func NewReadOnlySchedulerGetJobSummaryArgs() *ReadOnlySchedulerGetJobSummaryArgs

func (*ReadOnlySchedulerGetJobSummaryArgs) GetRole

func (*ReadOnlySchedulerGetJobSummaryArgs) Read

func (*ReadOnlySchedulerGetJobSummaryArgs) ReadField1 added in v1.21.0

func (*ReadOnlySchedulerGetJobSummaryArgs) String

func (*ReadOnlySchedulerGetJobSummaryArgs) Write

type ReadOnlySchedulerGetJobSummaryResult

type ReadOnlySchedulerGetJobSummaryResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewReadOnlySchedulerGetJobSummaryResult

func NewReadOnlySchedulerGetJobSummaryResult() *ReadOnlySchedulerGetJobSummaryResult

func (*ReadOnlySchedulerGetJobSummaryResult) GetSuccess

func (*ReadOnlySchedulerGetJobSummaryResult) IsSetSuccess

func (p *ReadOnlySchedulerGetJobSummaryResult) IsSetSuccess() bool

func (*ReadOnlySchedulerGetJobSummaryResult) Read

func (*ReadOnlySchedulerGetJobSummaryResult) ReadField0 added in v1.21.0

func (*ReadOnlySchedulerGetJobSummaryResult) String

func (*ReadOnlySchedulerGetJobSummaryResult) Write

type ReadOnlySchedulerGetJobUpdateDetailsArgs

type ReadOnlySchedulerGetJobUpdateDetailsArgs struct {
	// unused field # 1
	Query *JobUpdateQuery `thrift:"query,2" db:"query" json:"query"`
}

Attributes:

  • Query

func NewReadOnlySchedulerGetJobUpdateDetailsArgs

func NewReadOnlySchedulerGetJobUpdateDetailsArgs() *ReadOnlySchedulerGetJobUpdateDetailsArgs

func (*ReadOnlySchedulerGetJobUpdateDetailsArgs) GetQuery

func (*ReadOnlySchedulerGetJobUpdateDetailsArgs) IsSetQuery

func (*ReadOnlySchedulerGetJobUpdateDetailsArgs) Read

func (*ReadOnlySchedulerGetJobUpdateDetailsArgs) ReadField2 added in v1.21.0

func (*ReadOnlySchedulerGetJobUpdateDetailsArgs) String

func (*ReadOnlySchedulerGetJobUpdateDetailsArgs) Write

type ReadOnlySchedulerGetJobUpdateDetailsResult

type ReadOnlySchedulerGetJobUpdateDetailsResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewReadOnlySchedulerGetJobUpdateDetailsResult

func NewReadOnlySchedulerGetJobUpdateDetailsResult() *ReadOnlySchedulerGetJobUpdateDetailsResult

func (*ReadOnlySchedulerGetJobUpdateDetailsResult) GetSuccess

func (*ReadOnlySchedulerGetJobUpdateDetailsResult) IsSetSuccess

func (*ReadOnlySchedulerGetJobUpdateDetailsResult) Read

func (*ReadOnlySchedulerGetJobUpdateDetailsResult) ReadField0 added in v1.21.0

func (*ReadOnlySchedulerGetJobUpdateDetailsResult) String

func (*ReadOnlySchedulerGetJobUpdateDetailsResult) Write

type ReadOnlySchedulerGetJobUpdateDiffArgs

type ReadOnlySchedulerGetJobUpdateDiffArgs struct {
	Request *JobUpdateRequest `thrift:"request,1" db:"request" json:"request"`
}

Attributes:

  • Request

func NewReadOnlySchedulerGetJobUpdateDiffArgs

func NewReadOnlySchedulerGetJobUpdateDiffArgs() *ReadOnlySchedulerGetJobUpdateDiffArgs

func (*ReadOnlySchedulerGetJobUpdateDiffArgs) GetRequest

func (*ReadOnlySchedulerGetJobUpdateDiffArgs) IsSetRequest

func (p *ReadOnlySchedulerGetJobUpdateDiffArgs) IsSetRequest() bool

func (*ReadOnlySchedulerGetJobUpdateDiffArgs) Read

func (*ReadOnlySchedulerGetJobUpdateDiffArgs) ReadField1 added in v1.21.0

func (*ReadOnlySchedulerGetJobUpdateDiffArgs) String

func (*ReadOnlySchedulerGetJobUpdateDiffArgs) Write

type ReadOnlySchedulerGetJobUpdateDiffResult

type ReadOnlySchedulerGetJobUpdateDiffResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewReadOnlySchedulerGetJobUpdateDiffResult

func NewReadOnlySchedulerGetJobUpdateDiffResult() *ReadOnlySchedulerGetJobUpdateDiffResult

func (*ReadOnlySchedulerGetJobUpdateDiffResult) GetSuccess

func (*ReadOnlySchedulerGetJobUpdateDiffResult) IsSetSuccess

func (*ReadOnlySchedulerGetJobUpdateDiffResult) Read

func (*ReadOnlySchedulerGetJobUpdateDiffResult) ReadField0 added in v1.21.0

func (*ReadOnlySchedulerGetJobUpdateDiffResult) String

func (*ReadOnlySchedulerGetJobUpdateDiffResult) Write

type ReadOnlySchedulerGetJobUpdateSummariesArgs

type ReadOnlySchedulerGetJobUpdateSummariesArgs struct {
	JobUpdateQuery *JobUpdateQuery `thrift:"jobUpdateQuery,1" db:"jobUpdateQuery" json:"jobUpdateQuery"`
}

Attributes:

  • JobUpdateQuery

func NewReadOnlySchedulerGetJobUpdateSummariesArgs

func NewReadOnlySchedulerGetJobUpdateSummariesArgs() *ReadOnlySchedulerGetJobUpdateSummariesArgs

func (*ReadOnlySchedulerGetJobUpdateSummariesArgs) GetJobUpdateQuery

func (*ReadOnlySchedulerGetJobUpdateSummariesArgs) IsSetJobUpdateQuery

func (p *ReadOnlySchedulerGetJobUpdateSummariesArgs) IsSetJobUpdateQuery() bool

func (*ReadOnlySchedulerGetJobUpdateSummariesArgs) Read

func (*ReadOnlySchedulerGetJobUpdateSummariesArgs) ReadField1 added in v1.21.0

func (*ReadOnlySchedulerGetJobUpdateSummariesArgs) String

func (*ReadOnlySchedulerGetJobUpdateSummariesArgs) Write

type ReadOnlySchedulerGetJobUpdateSummariesResult

type ReadOnlySchedulerGetJobUpdateSummariesResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewReadOnlySchedulerGetJobUpdateSummariesResult

func NewReadOnlySchedulerGetJobUpdateSummariesResult() *ReadOnlySchedulerGetJobUpdateSummariesResult

func (*ReadOnlySchedulerGetJobUpdateSummariesResult) GetSuccess

func (*ReadOnlySchedulerGetJobUpdateSummariesResult) IsSetSuccess

func (*ReadOnlySchedulerGetJobUpdateSummariesResult) Read

func (*ReadOnlySchedulerGetJobUpdateSummariesResult) ReadField0 added in v1.21.0

func (*ReadOnlySchedulerGetJobUpdateSummariesResult) String

func (*ReadOnlySchedulerGetJobUpdateSummariesResult) Write

type ReadOnlySchedulerGetJobsArgs

type ReadOnlySchedulerGetJobsArgs struct {
	OwnerRole string `thrift:"ownerRole,1" db:"ownerRole" json:"ownerRole"`
}

Attributes:

  • OwnerRole

func NewReadOnlySchedulerGetJobsArgs

func NewReadOnlySchedulerGetJobsArgs() *ReadOnlySchedulerGetJobsArgs

func (*ReadOnlySchedulerGetJobsArgs) GetOwnerRole

func (p *ReadOnlySchedulerGetJobsArgs) GetOwnerRole() string

func (*ReadOnlySchedulerGetJobsArgs) Read

func (*ReadOnlySchedulerGetJobsArgs) ReadField1 added in v1.21.0

func (p *ReadOnlySchedulerGetJobsArgs) ReadField1(iprot thrift.TProtocol) error

func (*ReadOnlySchedulerGetJobsArgs) String

func (*ReadOnlySchedulerGetJobsArgs) Write

type ReadOnlySchedulerGetJobsResult

type ReadOnlySchedulerGetJobsResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewReadOnlySchedulerGetJobsResult

func NewReadOnlySchedulerGetJobsResult() *ReadOnlySchedulerGetJobsResult

func (*ReadOnlySchedulerGetJobsResult) GetSuccess

func (p *ReadOnlySchedulerGetJobsResult) GetSuccess() *Response

func (*ReadOnlySchedulerGetJobsResult) IsSetSuccess

func (p *ReadOnlySchedulerGetJobsResult) IsSetSuccess() bool

func (*ReadOnlySchedulerGetJobsResult) Read

func (*ReadOnlySchedulerGetJobsResult) ReadField0 added in v1.21.0

func (*ReadOnlySchedulerGetJobsResult) String

func (*ReadOnlySchedulerGetJobsResult) Write

type ReadOnlySchedulerGetPendingReasonArgs

type ReadOnlySchedulerGetPendingReasonArgs struct {
	Query *TaskQuery `thrift:"query,1" db:"query" json:"query"`
}

Attributes:

  • Query

func NewReadOnlySchedulerGetPendingReasonArgs

func NewReadOnlySchedulerGetPendingReasonArgs() *ReadOnlySchedulerGetPendingReasonArgs

func (*ReadOnlySchedulerGetPendingReasonArgs) GetQuery

func (*ReadOnlySchedulerGetPendingReasonArgs) IsSetQuery

func (*ReadOnlySchedulerGetPendingReasonArgs) Read

func (*ReadOnlySchedulerGetPendingReasonArgs) ReadField1 added in v1.21.0

func (*ReadOnlySchedulerGetPendingReasonArgs) String

func (*ReadOnlySchedulerGetPendingReasonArgs) Write

type ReadOnlySchedulerGetPendingReasonResult

type ReadOnlySchedulerGetPendingReasonResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewReadOnlySchedulerGetPendingReasonResult

func NewReadOnlySchedulerGetPendingReasonResult() *ReadOnlySchedulerGetPendingReasonResult

func (*ReadOnlySchedulerGetPendingReasonResult) GetSuccess

func (*ReadOnlySchedulerGetPendingReasonResult) IsSetSuccess

func (*ReadOnlySchedulerGetPendingReasonResult) Read

func (*ReadOnlySchedulerGetPendingReasonResult) ReadField0 added in v1.21.0

func (*ReadOnlySchedulerGetPendingReasonResult) String

func (*ReadOnlySchedulerGetPendingReasonResult) Write

type ReadOnlySchedulerGetQuotaArgs

type ReadOnlySchedulerGetQuotaArgs struct {
	OwnerRole string `thrift:"ownerRole,1" db:"ownerRole" json:"ownerRole"`
}

Attributes:

  • OwnerRole

func NewReadOnlySchedulerGetQuotaArgs

func NewReadOnlySchedulerGetQuotaArgs() *ReadOnlySchedulerGetQuotaArgs

func (*ReadOnlySchedulerGetQuotaArgs) GetOwnerRole

func (p *ReadOnlySchedulerGetQuotaArgs) GetOwnerRole() string

func (*ReadOnlySchedulerGetQuotaArgs) Read

func (*ReadOnlySchedulerGetQuotaArgs) ReadField1 added in v1.21.0

func (p *ReadOnlySchedulerGetQuotaArgs) ReadField1(iprot thrift.TProtocol) error

func (*ReadOnlySchedulerGetQuotaArgs) String

func (*ReadOnlySchedulerGetQuotaArgs) Write

type ReadOnlySchedulerGetQuotaResult

type ReadOnlySchedulerGetQuotaResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewReadOnlySchedulerGetQuotaResult

func NewReadOnlySchedulerGetQuotaResult() *ReadOnlySchedulerGetQuotaResult

func (*ReadOnlySchedulerGetQuotaResult) GetSuccess

func (p *ReadOnlySchedulerGetQuotaResult) GetSuccess() *Response

func (*ReadOnlySchedulerGetQuotaResult) IsSetSuccess

func (p *ReadOnlySchedulerGetQuotaResult) IsSetSuccess() bool

func (*ReadOnlySchedulerGetQuotaResult) Read

func (*ReadOnlySchedulerGetQuotaResult) ReadField0 added in v1.21.0

func (*ReadOnlySchedulerGetQuotaResult) String

func (*ReadOnlySchedulerGetQuotaResult) Write

type ReadOnlySchedulerGetRoleSummaryArgs

type ReadOnlySchedulerGetRoleSummaryArgs struct {
}

func NewReadOnlySchedulerGetRoleSummaryArgs

func NewReadOnlySchedulerGetRoleSummaryArgs() *ReadOnlySchedulerGetRoleSummaryArgs

func (*ReadOnlySchedulerGetRoleSummaryArgs) Read

func (*ReadOnlySchedulerGetRoleSummaryArgs) String

func (*ReadOnlySchedulerGetRoleSummaryArgs) Write

type ReadOnlySchedulerGetRoleSummaryResult

type ReadOnlySchedulerGetRoleSummaryResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewReadOnlySchedulerGetRoleSummaryResult

func NewReadOnlySchedulerGetRoleSummaryResult() *ReadOnlySchedulerGetRoleSummaryResult

func (*ReadOnlySchedulerGetRoleSummaryResult) GetSuccess

func (*ReadOnlySchedulerGetRoleSummaryResult) IsSetSuccess

func (p *ReadOnlySchedulerGetRoleSummaryResult) IsSetSuccess() bool

func (*ReadOnlySchedulerGetRoleSummaryResult) Read

func (*ReadOnlySchedulerGetRoleSummaryResult) ReadField0 added in v1.21.0

func (*ReadOnlySchedulerGetRoleSummaryResult) String

func (*ReadOnlySchedulerGetRoleSummaryResult) Write

type ReadOnlySchedulerGetTasksStatusArgs

type ReadOnlySchedulerGetTasksStatusArgs struct {
	Query *TaskQuery `thrift:"query,1" db:"query" json:"query"`
}

Attributes:

  • Query

func NewReadOnlySchedulerGetTasksStatusArgs

func NewReadOnlySchedulerGetTasksStatusArgs() *ReadOnlySchedulerGetTasksStatusArgs

func (*ReadOnlySchedulerGetTasksStatusArgs) GetQuery

func (*ReadOnlySchedulerGetTasksStatusArgs) IsSetQuery

func (p *ReadOnlySchedulerGetTasksStatusArgs) IsSetQuery() bool

func (*ReadOnlySchedulerGetTasksStatusArgs) Read

func (*ReadOnlySchedulerGetTasksStatusArgs) ReadField1 added in v1.21.0

func (*ReadOnlySchedulerGetTasksStatusArgs) String

func (*ReadOnlySchedulerGetTasksStatusArgs) Write

type ReadOnlySchedulerGetTasksStatusResult

type ReadOnlySchedulerGetTasksStatusResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewReadOnlySchedulerGetTasksStatusResult

func NewReadOnlySchedulerGetTasksStatusResult() *ReadOnlySchedulerGetTasksStatusResult

func (*ReadOnlySchedulerGetTasksStatusResult) GetSuccess

func (*ReadOnlySchedulerGetTasksStatusResult) IsSetSuccess

func (p *ReadOnlySchedulerGetTasksStatusResult) IsSetSuccess() bool

func (*ReadOnlySchedulerGetTasksStatusResult) Read

func (*ReadOnlySchedulerGetTasksStatusResult) ReadField0 added in v1.21.0

func (*ReadOnlySchedulerGetTasksStatusResult) String

func (*ReadOnlySchedulerGetTasksStatusResult) Write

type ReadOnlySchedulerGetTasksWithoutConfigsArgs

type ReadOnlySchedulerGetTasksWithoutConfigsArgs struct {
	Query *TaskQuery `thrift:"query,1" db:"query" json:"query"`
}

Attributes:

  • Query

func NewReadOnlySchedulerGetTasksWithoutConfigsArgs

func NewReadOnlySchedulerGetTasksWithoutConfigsArgs() *ReadOnlySchedulerGetTasksWithoutConfigsArgs

func (*ReadOnlySchedulerGetTasksWithoutConfigsArgs) GetQuery

func (*ReadOnlySchedulerGetTasksWithoutConfigsArgs) IsSetQuery

func (*ReadOnlySchedulerGetTasksWithoutConfigsArgs) Read

func (*ReadOnlySchedulerGetTasksWithoutConfigsArgs) ReadField1 added in v1.21.0

func (*ReadOnlySchedulerGetTasksWithoutConfigsArgs) String

func (*ReadOnlySchedulerGetTasksWithoutConfigsArgs) Write

type ReadOnlySchedulerGetTasksWithoutConfigsResult

type ReadOnlySchedulerGetTasksWithoutConfigsResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewReadOnlySchedulerGetTasksWithoutConfigsResult

func NewReadOnlySchedulerGetTasksWithoutConfigsResult() *ReadOnlySchedulerGetTasksWithoutConfigsResult

func (*ReadOnlySchedulerGetTasksWithoutConfigsResult) GetSuccess

func (*ReadOnlySchedulerGetTasksWithoutConfigsResult) IsSetSuccess

func (*ReadOnlySchedulerGetTasksWithoutConfigsResult) Read

func (*ReadOnlySchedulerGetTasksWithoutConfigsResult) ReadField0 added in v1.21.0

func (*ReadOnlySchedulerGetTasksWithoutConfigsResult) String

func (*ReadOnlySchedulerGetTasksWithoutConfigsResult) Write

type ReadOnlySchedulerGetTierConfigsArgs

type ReadOnlySchedulerGetTierConfigsArgs struct {
}

func NewReadOnlySchedulerGetTierConfigsArgs

func NewReadOnlySchedulerGetTierConfigsArgs() *ReadOnlySchedulerGetTierConfigsArgs

func (*ReadOnlySchedulerGetTierConfigsArgs) Read

func (*ReadOnlySchedulerGetTierConfigsArgs) String

func (*ReadOnlySchedulerGetTierConfigsArgs) Write

type ReadOnlySchedulerGetTierConfigsResult

type ReadOnlySchedulerGetTierConfigsResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewReadOnlySchedulerGetTierConfigsResult

func NewReadOnlySchedulerGetTierConfigsResult() *ReadOnlySchedulerGetTierConfigsResult

func (*ReadOnlySchedulerGetTierConfigsResult) GetSuccess

func (*ReadOnlySchedulerGetTierConfigsResult) IsSetSuccess

func (p *ReadOnlySchedulerGetTierConfigsResult) IsSetSuccess() bool

func (*ReadOnlySchedulerGetTierConfigsResult) Read

func (*ReadOnlySchedulerGetTierConfigsResult) ReadField0 added in v1.21.0

func (*ReadOnlySchedulerGetTierConfigsResult) String

func (*ReadOnlySchedulerGetTierConfigsResult) Write

type ReadOnlySchedulerPopulateJobConfigArgs

type ReadOnlySchedulerPopulateJobConfigArgs struct {
	Description *JobConfiguration `thrift:"description,1" db:"description" json:"description"`
}

Attributes:

  • Description

func NewReadOnlySchedulerPopulateJobConfigArgs

func NewReadOnlySchedulerPopulateJobConfigArgs() *ReadOnlySchedulerPopulateJobConfigArgs

func (*ReadOnlySchedulerPopulateJobConfigArgs) GetDescription

func (*ReadOnlySchedulerPopulateJobConfigArgs) IsSetDescription

func (p *ReadOnlySchedulerPopulateJobConfigArgs) IsSetDescription() bool

func (*ReadOnlySchedulerPopulateJobConfigArgs) Read

func (*ReadOnlySchedulerPopulateJobConfigArgs) ReadField1 added in v1.21.0

func (*ReadOnlySchedulerPopulateJobConfigArgs) String

func (*ReadOnlySchedulerPopulateJobConfigArgs) Write

type ReadOnlySchedulerPopulateJobConfigResult

type ReadOnlySchedulerPopulateJobConfigResult struct {
	Success *Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewReadOnlySchedulerPopulateJobConfigResult

func NewReadOnlySchedulerPopulateJobConfigResult() *ReadOnlySchedulerPopulateJobConfigResult

func (*ReadOnlySchedulerPopulateJobConfigResult) GetSuccess

func (*ReadOnlySchedulerPopulateJobConfigResult) IsSetSuccess

func (*ReadOnlySchedulerPopulateJobConfigResult) Read

func (*ReadOnlySchedulerPopulateJobConfigResult) ReadField0 added in v1.21.0

func (*ReadOnlySchedulerPopulateJobConfigResult) String

func (*ReadOnlySchedulerPopulateJobConfigResult) Write

type ReadOnlySchedulerProcessor

type ReadOnlySchedulerProcessor struct {
	// contains filtered or unexported fields
}

func NewReadOnlySchedulerProcessor

func NewReadOnlySchedulerProcessor(handler ReadOnlyScheduler) *ReadOnlySchedulerProcessor

func (*ReadOnlySchedulerProcessor) AddToProcessorMap

func (p *ReadOnlySchedulerProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*ReadOnlySchedulerProcessor) GetProcessorFunction

func (p *ReadOnlySchedulerProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*ReadOnlySchedulerProcessor) Process

func (p *ReadOnlySchedulerProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*ReadOnlySchedulerProcessor) ProcessorMap

type Resource

type Resource struct {
	NumCpus   *float64 `thrift:"numCpus,1" db:"numCpus" json:"numCpus,omitempty"`
	RamMb     *int64   `thrift:"ramMb,2" db:"ramMb" json:"ramMb,omitempty"`
	DiskMb    *int64   `thrift:"diskMb,3" db:"diskMb" json:"diskMb,omitempty"`
	NamedPort *string  `thrift:"namedPort,4" db:"namedPort" json:"namedPort,omitempty"`
	NumGpus   *int64   `thrift:"numGpus,5" db:"numGpus" json:"numGpus,omitempty"`
}

Describes resource value required to run a task.

Attributes:

  • NumCpus
  • RamMb
  • DiskMb
  • NamedPort
  • NumGpus

func NewResource

func NewResource() *Resource

func (*Resource) CountSetFieldsResource

func (p *Resource) CountSetFieldsResource() int

func (*Resource) GetDiskMb

func (p *Resource) GetDiskMb() int64

func (*Resource) GetNamedPort

func (p *Resource) GetNamedPort() string

func (*Resource) GetNumCpus

func (p *Resource) GetNumCpus() float64

func (*Resource) GetNumGpus

func (p *Resource) GetNumGpus() int64

func (*Resource) GetRamMb

func (p *Resource) GetRamMb() int64

func (*Resource) IsSetDiskMb

func (p *Resource) IsSetDiskMb() bool

func (*Resource) IsSetNamedPort

func (p *Resource) IsSetNamedPort() bool

func (*Resource) IsSetNumCpus

func (p *Resource) IsSetNumCpus() bool

func (*Resource) IsSetNumGpus

func (p *Resource) IsSetNumGpus() bool

func (*Resource) IsSetRamMb

func (p *Resource) IsSetRamMb() bool

func (*Resource) Read

func (p *Resource) Read(iprot thrift.TProtocol) error

func (*Resource) ReadField1 added in v1.21.0

func (p *Resource) ReadField1(iprot thrift.TProtocol) error

func (*Resource) ReadField2 added in v1.21.0

func (p *Resource) ReadField2(iprot thrift.TProtocol) error

func (*Resource) ReadField3 added in v1.21.0

func (p *Resource) ReadField3(iprot thrift.TProtocol) error

func (*Resource) ReadField4 added in v1.21.0

func (p *Resource) ReadField4(iprot thrift.TProtocol) error

func (*Resource) ReadField5 added in v1.21.0

func (p *Resource) ReadField5(iprot thrift.TProtocol) error

func (*Resource) String

func (p *Resource) String() string

func (*Resource) Write

func (p *Resource) Write(oprot thrift.TProtocol) error

type ResourceAggregate

type ResourceAggregate struct {
	// unused fields # 1 to 3
	Resources []*Resource `thrift:"resources,4" db:"resources" json:"resources"`
}

Attributes:

  • Resources: Aggregated resource values.
var AuroraAdminSetQuotaArgs_Quota_DEFAULT *ResourceAggregate
var GetQuotaResult__NonProdDedicatedConsumption_DEFAULT *ResourceAggregate
var GetQuotaResult__NonProdSharedConsumption_DEFAULT *ResourceAggregate
var GetQuotaResult__ProdDedicatedConsumption_DEFAULT *ResourceAggregate
var GetQuotaResult__ProdSharedConsumption_DEFAULT *ResourceAggregate
var GetQuotaResult__Quota_DEFAULT *ResourceAggregate

func NewResourceAggregate

func NewResourceAggregate() *ResourceAggregate

func (*ResourceAggregate) GetResources

func (p *ResourceAggregate) GetResources() []*Resource

func (*ResourceAggregate) Read

func (p *ResourceAggregate) Read(iprot thrift.TProtocol) error

func (*ResourceAggregate) ReadField4 added in v1.21.0

func (p *ResourceAggregate) ReadField4(iprot thrift.TProtocol) error

func (*ResourceAggregate) String

func (p *ResourceAggregate) String() string

func (*ResourceAggregate) Write

func (p *ResourceAggregate) Write(oprot thrift.TProtocol) error

type Response

type Response struct {
	ResponseCode ResponseCode `thrift:"responseCode,1" db:"responseCode" json:"responseCode"`
	// unused field # 2
	Result_ *Result_ `thrift:"result,3" db:"result" json:"result,omitempty"`
	// unused field # 4
	ServerInfo *ServerInfo       `thrift:"serverInfo,5" db:"serverInfo" json:"serverInfo"`
	Details    []*ResponseDetail `thrift:"details,6" db:"details" json:"details"`
}

Attributes:

  • ResponseCode
  • ServerInfo
  • Result_: Payload from the invoked RPC.
  • Details: Messages from the server relevant to the request, such as warnings or use of deprecated

features.

var AuroraAdminCommitRecoveryResult_Success_DEFAULT *Response
var AuroraAdminDeleteRecoveryTasksResult_Success_DEFAULT *Response
var AuroraAdminDrainHostsResult_Success_DEFAULT *Response
var AuroraAdminEndMaintenanceResult_Success_DEFAULT *Response
var AuroraAdminForceTaskStateResult_Success_DEFAULT *Response
var AuroraAdminListBackupsResult_Success_DEFAULT *Response
var AuroraAdminMaintenanceStatusResult_Success_DEFAULT *Response
var AuroraAdminPerformBackupResult_Success_DEFAULT *Response
var AuroraAdminPruneTasksResult_Success_DEFAULT *Response
var AuroraAdminQueryRecoveryResult_Success_DEFAULT *Response
var AuroraAdminSetQuotaResult_Success_DEFAULT *Response
var AuroraAdminSlaDrainHostsResult_Success_DEFAULT *Response
var AuroraAdminSnapshotResult_Success_DEFAULT *Response
var AuroraAdminStageRecoveryResult_Success_DEFAULT *Response
var AuroraAdminStartMaintenanceResult_Success_DEFAULT *Response
var AuroraAdminTriggerExplicitTaskReconciliationResult_Success_DEFAULT *Response
var AuroraAdminTriggerImplicitTaskReconciliationResult_Success_DEFAULT *Response
var AuroraAdminUnloadRecoveryResult_Success_DEFAULT *Response
var AuroraSchedulerManagerAbortJobUpdateResult_Success_DEFAULT *Response
var AuroraSchedulerManagerAddInstancesResult_Success_DEFAULT *Response
var AuroraSchedulerManagerCreateJobResult_Success_DEFAULT *Response
var AuroraSchedulerManagerDescheduleCronJobResult_Success_DEFAULT *Response
var AuroraSchedulerManagerKillTasksResult_Success_DEFAULT *Response
var AuroraSchedulerManagerPauseJobUpdateResult_Success_DEFAULT *Response
var AuroraSchedulerManagerPulseJobUpdateResult_Success_DEFAULT *Response
var AuroraSchedulerManagerReplaceCronTemplateResult_Success_DEFAULT *Response
var AuroraSchedulerManagerRestartShardsResult_Success_DEFAULT *Response
var AuroraSchedulerManagerResumeJobUpdateResult_Success_DEFAULT *Response
var AuroraSchedulerManagerRollbackJobUpdateResult_Success_DEFAULT *Response
var AuroraSchedulerManagerScheduleCronJobResult_Success_DEFAULT *Response
var AuroraSchedulerManagerStartCronJobResult_Success_DEFAULT *Response
var AuroraSchedulerManagerStartJobUpdateResult_Success_DEFAULT *Response
var ReadOnlySchedulerGetConfigSummaryResult_Success_DEFAULT *Response
var ReadOnlySchedulerGetJobSummaryResult_Success_DEFAULT *Response
var ReadOnlySchedulerGetJobUpdateDetailsResult_Success_DEFAULT *Response
var ReadOnlySchedulerGetJobUpdateDiffResult_Success_DEFAULT *Response
var ReadOnlySchedulerGetJobUpdateSummariesResult_Success_DEFAULT *Response
var ReadOnlySchedulerGetJobsResult_Success_DEFAULT *Response
var ReadOnlySchedulerGetPendingReasonResult_Success_DEFAULT *Response
var ReadOnlySchedulerGetQuotaResult_Success_DEFAULT *Response
var ReadOnlySchedulerGetRoleSummaryResult_Success_DEFAULT *Response
var ReadOnlySchedulerGetTasksStatusResult_Success_DEFAULT *Response
var ReadOnlySchedulerGetTasksWithoutConfigsResult_Success_DEFAULT *Response
var ReadOnlySchedulerGetTierConfigsResult_Success_DEFAULT *Response
var ReadOnlySchedulerPopulateJobConfigResult_Success_DEFAULT *Response

func NewResponse

func NewResponse() *Response

func (*Response) GetDetails

func (p *Response) GetDetails() []*ResponseDetail

func (*Response) GetResponseCode

func (p *Response) GetResponseCode() ResponseCode

func (*Response) GetResult_

func (p *Response) GetResult_() *Result_

func (*Response) GetServerInfo

func (p *Response) GetServerInfo() *ServerInfo

func (*Response) IsSetResult_

func (p *Response) IsSetResult_() bool

func (*Response) IsSetServerInfo

func (p *Response) IsSetServerInfo() bool

func (*Response) Read

func (p *Response) Read(iprot thrift.TProtocol) error

func (*Response) ReadField1 added in v1.21.0

func (p *Response) ReadField1(iprot thrift.TProtocol) error

func (*Response) ReadField3 added in v1.21.0

func (p *Response) ReadField3(iprot thrift.TProtocol) error

func (*Response) ReadField5 added in v1.21.0

func (p *Response) ReadField5(iprot thrift.TProtocol) error

func (*Response) ReadField6 added in v1.21.0

func (p *Response) ReadField6(iprot thrift.TProtocol) error

func (*Response) String

func (p *Response) String() string

func (*Response) Write

func (p *Response) Write(oprot thrift.TProtocol) error

type ResponseCode

type ResponseCode int64
const (
	ResponseCode_INVALID_REQUEST    ResponseCode = 0
	ResponseCode_OK                 ResponseCode = 1
	ResponseCode_ERROR              ResponseCode = 2
	ResponseCode_WARNING            ResponseCode = 3
	ResponseCode_AUTH_FAILED        ResponseCode = 4
	ResponseCode_JOB_UPDATING_ERROR ResponseCode = 5
	ResponseCode_ERROR_TRANSIENT    ResponseCode = 6
)

func ResponseCodeFromString

func ResponseCodeFromString(s string) (ResponseCode, error)

func ResponseCodePtr

func ResponseCodePtr(v ResponseCode) *ResponseCode

func (ResponseCode) MarshalText

func (p ResponseCode) MarshalText() ([]byte, error)

func (*ResponseCode) Scan added in v1.21.0

func (p *ResponseCode) Scan(value interface{}) error

func (ResponseCode) String

func (p ResponseCode) String() string

func (*ResponseCode) UnmarshalText

func (p *ResponseCode) UnmarshalText(text []byte) error

func (*ResponseCode) Value added in v1.21.0

func (p *ResponseCode) Value() (driver.Value, error)

type ResponseDetail

type ResponseDetail struct {
	Message string `thrift:"message,1" db:"message" json:"message"`
}

Attributes:

  • Message

func NewResponseDetail

func NewResponseDetail() *ResponseDetail

func (*ResponseDetail) GetMessage

func (p *ResponseDetail) GetMessage() string

func (*ResponseDetail) Read

func (p *ResponseDetail) Read(iprot thrift.TProtocol) error

func (*ResponseDetail) ReadField1 added in v1.21.0

func (p *ResponseDetail) ReadField1(iprot thrift.TProtocol) error

func (*ResponseDetail) String

func (p *ResponseDetail) String() string

func (*ResponseDetail) Write

func (p *ResponseDetail) Write(oprot thrift.TProtocol) error

type Result_

type Result_ struct {
	PopulateJobResult_ *PopulateJobResult_ `thrift:"populateJobResult,1" db:"populateJobResult" json:"populateJobResult,omitempty"`
	// unused field # 2
	ScheduleStatusResult_    *ScheduleStatusResult_    `thrift:"scheduleStatusResult,3" db:"scheduleStatusResult" json:"scheduleStatusResult,omitempty"`
	GetJobsResult_           *GetJobsResult_           `thrift:"getJobsResult,4" db:"getJobsResult" json:"getJobsResult,omitempty"`
	GetQuotaResult_          *GetQuotaResult_          `thrift:"getQuotaResult,5" db:"getQuotaResult" json:"getQuotaResult,omitempty"`
	ListBackupsResult_       *ListBackupsResult_       `thrift:"listBackupsResult,6" db:"listBackupsResult" json:"listBackupsResult,omitempty"`
	StartMaintenanceResult_  *StartMaintenanceResult_  `thrift:"startMaintenanceResult,7" db:"startMaintenanceResult" json:"startMaintenanceResult,omitempty"`
	DrainHostsResult_        *DrainHostsResult_        `thrift:"drainHostsResult,8" db:"drainHostsResult" json:"drainHostsResult,omitempty"`
	QueryRecoveryResult_     *QueryRecoveryResult_     `thrift:"queryRecoveryResult,9" db:"queryRecoveryResult" json:"queryRecoveryResult,omitempty"`
	MaintenanceStatusResult_ *MaintenanceStatusResult_ `thrift:"maintenanceStatusResult,10" db:"maintenanceStatusResult" json:"maintenanceStatusResult,omitempty"`
	EndMaintenanceResult_    *EndMaintenanceResult_    `thrift:"endMaintenanceResult,11" db:"endMaintenanceResult" json:"endMaintenanceResult,omitempty"`
	// unused fields # 12 to 16
	RoleSummaryResult_ *RoleSummaryResult_ `thrift:"roleSummaryResult,17" db:"roleSummaryResult" json:"roleSummaryResult,omitempty"`
	JobSummaryResult_  *JobSummaryResult_  `thrift:"jobSummaryResult,18" db:"jobSummaryResult" json:"jobSummaryResult,omitempty"`
	// unused field # 19
	ConfigSummaryResult_         *ConfigSummaryResult_         `thrift:"configSummaryResult,20" db:"configSummaryResult" json:"configSummaryResult,omitempty"`
	GetPendingReasonResult_      *GetPendingReasonResult_      `thrift:"getPendingReasonResult,21" db:"getPendingReasonResult" json:"getPendingReasonResult,omitempty"`
	StartJobUpdateResult_        *StartJobUpdateResult_        `thrift:"startJobUpdateResult,22" db:"startJobUpdateResult" json:"startJobUpdateResult,omitempty"`
	GetJobUpdateSummariesResult_ *GetJobUpdateSummariesResult_ `thrift:"getJobUpdateSummariesResult,23" db:"getJobUpdateSummariesResult" json:"getJobUpdateSummariesResult,omitempty"`
	GetJobUpdateDetailsResult_   *GetJobUpdateDetailsResult_   `thrift:"getJobUpdateDetailsResult,24" db:"getJobUpdateDetailsResult" json:"getJobUpdateDetailsResult,omitempty"`
	PulseJobUpdateResult_        *PulseJobUpdateResult_        `thrift:"pulseJobUpdateResult,25" db:"pulseJobUpdateResult" json:"pulseJobUpdateResult,omitempty"`
	GetJobUpdateDiffResult_      *GetJobUpdateDiffResult_      `thrift:"getJobUpdateDiffResult,26" db:"getJobUpdateDiffResult" json:"getJobUpdateDiffResult,omitempty"`
	GetTierConfigResult_         *GetTierConfigResult_         `thrift:"getTierConfigResult,27" db:"getTierConfigResult" json:"getTierConfigResult,omitempty"`
}

Attributes:

  • PopulateJobResult_
  • ScheduleStatusResult_
  • GetJobsResult_
  • GetQuotaResult_
  • ListBackupsResult_
  • StartMaintenanceResult_
  • DrainHostsResult_
  • QueryRecoveryResult_
  • MaintenanceStatusResult_
  • EndMaintenanceResult_
  • RoleSummaryResult_
  • JobSummaryResult_
  • ConfigSummaryResult_
  • GetPendingReasonResult_
  • StartJobUpdateResult_
  • GetJobUpdateSummariesResult_
  • GetJobUpdateDetailsResult_
  • PulseJobUpdateResult_
  • GetJobUpdateDiffResult_
  • GetTierConfigResult_
var Response_Result__DEFAULT *Result_

func NewResult_

func NewResult_() *Result_

func (*Result_) CountSetFieldsResult_

func (p *Result_) CountSetFieldsResult_() int

func (*Result_) GetConfigSummaryResult_

func (p *Result_) GetConfigSummaryResult_() *ConfigSummaryResult_

func (*Result_) GetDrainHostsResult_

func (p *Result_) GetDrainHostsResult_() *DrainHostsResult_

func (*Result_) GetEndMaintenanceResult_

func (p *Result_) GetEndMaintenanceResult_() *EndMaintenanceResult_

func (*Result_) GetGetJobUpdateDetailsResult_

func (p *Result_) GetGetJobUpdateDetailsResult_() *GetJobUpdateDetailsResult_

func (*Result_) GetGetJobUpdateDiffResult_

func (p *Result_) GetGetJobUpdateDiffResult_() *GetJobUpdateDiffResult_

func (*Result_) GetGetJobUpdateSummariesResult_

func (p *Result_) GetGetJobUpdateSummariesResult_() *GetJobUpdateSummariesResult_

func (*Result_) GetGetJobsResult_

func (p *Result_) GetGetJobsResult_() *GetJobsResult_

func (*Result_) GetGetPendingReasonResult_

func (p *Result_) GetGetPendingReasonResult_() *GetPendingReasonResult_

func (*Result_) GetGetQuotaResult_

func (p *Result_) GetGetQuotaResult_() *GetQuotaResult_

func (*Result_) GetGetTierConfigResult_

func (p *Result_) GetGetTierConfigResult_() *GetTierConfigResult_

func (*Result_) GetJobSummaryResult_

func (p *Result_) GetJobSummaryResult_() *JobSummaryResult_

func (*Result_) GetListBackupsResult_

func (p *Result_) GetListBackupsResult_() *ListBackupsResult_

func (*Result_) GetMaintenanceStatusResult_

func (p *Result_) GetMaintenanceStatusResult_() *MaintenanceStatusResult_

func (*Result_) GetPopulateJobResult_

func (p *Result_) GetPopulateJobResult_() *PopulateJobResult_

func (*Result_) GetPulseJobUpdateResult_

func (p *Result_) GetPulseJobUpdateResult_() *PulseJobUpdateResult_

func (*Result_) GetQueryRecoveryResult_

func (p *Result_) GetQueryRecoveryResult_() *QueryRecoveryResult_

func (*Result_) GetRoleSummaryResult_

func (p *Result_) GetRoleSummaryResult_() *RoleSummaryResult_

func (*Result_) GetScheduleStatusResult_

func (p *Result_) GetScheduleStatusResult_() *ScheduleStatusResult_

func (*Result_) GetStartJobUpdateResult_

func (p *Result_) GetStartJobUpdateResult_() *StartJobUpdateResult_

func (*Result_) GetStartMaintenanceResult_

func (p *Result_) GetStartMaintenanceResult_() *StartMaintenanceResult_

func (*Result_) IsSetConfigSummaryResult_

func (p *Result_) IsSetConfigSummaryResult_() bool

func (*Result_) IsSetDrainHostsResult_

func (p *Result_) IsSetDrainHostsResult_() bool

func (*Result_) IsSetEndMaintenanceResult_

func (p *Result_) IsSetEndMaintenanceResult_() bool

func (*Result_) IsSetGetJobUpdateDetailsResult_

func (p *Result_) IsSetGetJobUpdateDetailsResult_() bool

func (*Result_) IsSetGetJobUpdateDiffResult_

func (p *Result_) IsSetGetJobUpdateDiffResult_() bool

func (*Result_) IsSetGetJobUpdateSummariesResult_

func (p *Result_) IsSetGetJobUpdateSummariesResult_() bool

func (*Result_) IsSetGetJobsResult_

func (p *Result_) IsSetGetJobsResult_() bool

func (*Result_) IsSetGetPendingReasonResult_

func (p *Result_) IsSetGetPendingReasonResult_() bool

func (*Result_) IsSetGetQuotaResult_

func (p *Result_) IsSetGetQuotaResult_() bool

func (*Result_) IsSetGetTierConfigResult_

func (p *Result_) IsSetGetTierConfigResult_() bool

func (*Result_) IsSetJobSummaryResult_

func (p *Result_) IsSetJobSummaryResult_() bool

func (*Result_) IsSetListBackupsResult_

func (p *Result_) IsSetListBackupsResult_() bool

func (*Result_) IsSetMaintenanceStatusResult_

func (p *Result_) IsSetMaintenanceStatusResult_() bool

func (*Result_) IsSetPopulateJobResult_

func (p *Result_) IsSetPopulateJobResult_() bool

func (*Result_) IsSetPulseJobUpdateResult_

func (p *Result_) IsSetPulseJobUpdateResult_() bool

func (*Result_) IsSetQueryRecoveryResult_

func (p *Result_) IsSetQueryRecoveryResult_() bool

func (*Result_) IsSetRoleSummaryResult_

func (p *Result_) IsSetRoleSummaryResult_() bool

func (*Result_) IsSetScheduleStatusResult_

func (p *Result_) IsSetScheduleStatusResult_() bool

func (*Result_) IsSetStartJobUpdateResult_

func (p *Result_) IsSetStartJobUpdateResult_() bool

func (*Result_) IsSetStartMaintenanceResult_

func (p *Result_) IsSetStartMaintenanceResult_() bool

func (*Result_) Read

func (p *Result_) Read(iprot thrift.TProtocol) error

func (*Result_) ReadField1 added in v1.21.0

func (p *Result_) ReadField1(iprot thrift.TProtocol) error

func (*Result_) ReadField10 added in v1.21.0

func (p *Result_) ReadField10(iprot thrift.TProtocol) error

func (*Result_) ReadField11 added in v1.21.0

func (p *Result_) ReadField11(iprot thrift.TProtocol) error

func (*Result_) ReadField17 added in v1.21.0

func (p *Result_) ReadField17(iprot thrift.TProtocol) error

func (*Result_) ReadField18 added in v1.21.0

func (p *Result_) ReadField18(iprot thrift.TProtocol) error

func (*Result_) ReadField20 added in v1.21.0

func (p *Result_) ReadField20(iprot thrift.TProtocol) error

func (*Result_) ReadField21 added in v1.21.0

func (p *Result_) ReadField21(iprot thrift.TProtocol) error

func (*Result_) ReadField22 added in v1.21.0

func (p *Result_) ReadField22(iprot thrift.TProtocol) error

func (*Result_) ReadField23 added in v1.21.0

func (p *Result_) ReadField23(iprot thrift.TProtocol) error

func (*Result_) ReadField24 added in v1.21.0

func (p *Result_) ReadField24(iprot thrift.TProtocol) error

func (*Result_) ReadField25 added in v1.21.0

func (p *Result_) ReadField25(iprot thrift.TProtocol) error

func (*Result_) ReadField26 added in v1.21.0

func (p *Result_) ReadField26(iprot thrift.TProtocol) error

func (*Result_) ReadField27 added in v1.21.0

func (p *Result_) ReadField27(iprot thrift.TProtocol) error

func (*Result_) ReadField3 added in v1.21.0

func (p *Result_) ReadField3(iprot thrift.TProtocol) error

func (*Result_) ReadField4 added in v1.21.0

func (p *Result_) ReadField4(iprot thrift.TProtocol) error

func (*Result_) ReadField5 added in v1.21.0

func (p *Result_) ReadField5(iprot thrift.TProtocol) error

func (*Result_) ReadField6 added in v1.21.0

func (p *Result_) ReadField6(iprot thrift.TProtocol) error

func (*Result_) ReadField7 added in v1.21.0

func (p *Result_) ReadField7(iprot thrift.TProtocol) error

func (*Result_) ReadField8 added in v1.21.0

func (p *Result_) ReadField8(iprot thrift.TProtocol) error

func (*Result_) ReadField9 added in v1.21.0

func (p *Result_) ReadField9(iprot thrift.TProtocol) error

func (*Result_) String

func (p *Result_) String() string

func (*Result_) Write

func (p *Result_) Write(oprot thrift.TProtocol) error

type RoleSummary

type RoleSummary struct {
	Role         string `thrift:"role,1" db:"role" json:"role"`
	JobCount     int32  `thrift:"jobCount,2" db:"jobCount" json:"jobCount"`
	CronJobCount int32  `thrift:"cronJobCount,3" db:"cronJobCount" json:"cronJobCount"`
}

Attributes:

  • Role
  • JobCount
  • CronJobCount

func NewRoleSummary

func NewRoleSummary() *RoleSummary

func (*RoleSummary) GetCronJobCount

func (p *RoleSummary) GetCronJobCount() int32

func (*RoleSummary) GetJobCount

func (p *RoleSummary) GetJobCount() int32

func (*RoleSummary) GetRole

func (p *RoleSummary) GetRole() string

func (*RoleSummary) Read

func (p *RoleSummary) Read(iprot thrift.TProtocol) error

func (*RoleSummary) ReadField1 added in v1.21.0

func (p *RoleSummary) ReadField1(iprot thrift.TProtocol) error

func (*RoleSummary) ReadField2 added in v1.21.0

func (p *RoleSummary) ReadField2(iprot thrift.TProtocol) error

func (*RoleSummary) ReadField3 added in v1.21.0

func (p *RoleSummary) ReadField3(iprot thrift.TProtocol) error

func (*RoleSummary) String

func (p *RoleSummary) String() string

func (*RoleSummary) Write

func (p *RoleSummary) Write(oprot thrift.TProtocol) error

type RoleSummaryResult_

type RoleSummaryResult_ struct {
	Summaries []*RoleSummary `thrift:"summaries,1" db:"summaries" json:"summaries"`
}

Attributes:

  • Summaries
var Result__RoleSummaryResult__DEFAULT *RoleSummaryResult_

func NewRoleSummaryResult_

func NewRoleSummaryResult_() *RoleSummaryResult_

func (*RoleSummaryResult_) GetSummaries

func (p *RoleSummaryResult_) GetSummaries() []*RoleSummary

func (*RoleSummaryResult_) Read

func (p *RoleSummaryResult_) Read(iprot thrift.TProtocol) error

func (*RoleSummaryResult_) ReadField1 added in v1.21.0

func (p *RoleSummaryResult_) ReadField1(iprot thrift.TProtocol) error

func (*RoleSummaryResult_) String

func (p *RoleSummaryResult_) String() string

func (*RoleSummaryResult_) Write

func (p *RoleSummaryResult_) Write(oprot thrift.TProtocol) error

type ScheduleStatus

type ScheduleStatus int64

States that a task may be in.

const (
	ScheduleStatus_INIT        ScheduleStatus = 11
	ScheduleStatus_THROTTLED   ScheduleStatus = 16
	ScheduleStatus_PENDING     ScheduleStatus = 0
	ScheduleStatus_ASSIGNED    ScheduleStatus = 9
	ScheduleStatus_STARTING    ScheduleStatus = 1
	ScheduleStatus_RUNNING     ScheduleStatus = 2
	ScheduleStatus_FINISHED    ScheduleStatus = 3
	ScheduleStatus_PREEMPTING  ScheduleStatus = 13
	ScheduleStatus_RESTARTING  ScheduleStatus = 12
	ScheduleStatus_DRAINING    ScheduleStatus = 17
	ScheduleStatus_FAILED      ScheduleStatus = 4
	ScheduleStatus_KILLED      ScheduleStatus = 5
	ScheduleStatus_KILLING     ScheduleStatus = 6
	ScheduleStatus_LOST        ScheduleStatus = 7
	ScheduleStatus_PARTITIONED ScheduleStatus = 18
)

func ScheduleStatusFromString

func ScheduleStatusFromString(s string) (ScheduleStatus, error)

func ScheduleStatusPtr

func ScheduleStatusPtr(v ScheduleStatus) *ScheduleStatus

func (ScheduleStatus) MarshalText

func (p ScheduleStatus) MarshalText() ([]byte, error)

func (*ScheduleStatus) Scan added in v1.21.0

func (p *ScheduleStatus) Scan(value interface{}) error

func (ScheduleStatus) String

func (p ScheduleStatus) String() string

func (*ScheduleStatus) UnmarshalText

func (p *ScheduleStatus) UnmarshalText(text []byte) error

func (*ScheduleStatus) Value added in v1.21.0

func (p *ScheduleStatus) Value() (driver.Value, error)

type ScheduleStatusResult_

type ScheduleStatusResult_ struct {
	Tasks []*ScheduledTask `thrift:"tasks,1" db:"tasks" json:"tasks"`
}

Attributes:

  • Tasks
var Result__ScheduleStatusResult__DEFAULT *ScheduleStatusResult_

func NewScheduleStatusResult_

func NewScheduleStatusResult_() *ScheduleStatusResult_

func (*ScheduleStatusResult_) GetTasks

func (p *ScheduleStatusResult_) GetTasks() []*ScheduledTask

func (*ScheduleStatusResult_) Read

func (*ScheduleStatusResult_) ReadField1 added in v1.21.0

func (p *ScheduleStatusResult_) ReadField1(iprot thrift.TProtocol) error

func (*ScheduleStatusResult_) String

func (p *ScheduleStatusResult_) String() string

func (*ScheduleStatusResult_) Write

func (p *ScheduleStatusResult_) Write(oprot thrift.TProtocol) error

type ScheduledTask

type ScheduledTask struct {
	AssignedTask     *AssignedTask  `thrift:"assignedTask,1" db:"assignedTask" json:"assignedTask"`
	Status           ScheduleStatus `thrift:"status,2" db:"status" json:"status"`
	FailureCount     int32          `thrift:"failureCount,3" db:"failureCount" json:"failureCount"`
	TaskEvents       []*TaskEvent   `thrift:"taskEvents,4" db:"taskEvents" json:"taskEvents"`
	AncestorId       string         `thrift:"ancestorId,5" db:"ancestorId" json:"ancestorId"`
	TimesPartitioned int32          `thrift:"timesPartitioned,6" db:"timesPartitioned" json:"timesPartitioned"`
}

A task that has been scheduled.

Attributes:

  • AssignedTask: The task that was scheduled.
  • Status: The current status of this task.
  • FailureCount: The number of failures that this task has accumulated over the multi-generational history of

this task.

  • TimesPartitioned: The number of partitions this task has accumulated over its lifetime.
  • TaskEvents: State change history for this task.
  • AncestorId: The task ID of the previous generation of this task. When a task is automatically rescheduled,

a copy of the task is created and ancestor ID of the previous task's task ID.

func NewScheduledTask

func NewScheduledTask() *ScheduledTask

func (*ScheduledTask) GetAncestorId

func (p *ScheduledTask) GetAncestorId() string

func (*ScheduledTask) GetAssignedTask

func (p *ScheduledTask) GetAssignedTask() *AssignedTask

func (*ScheduledTask) GetFailureCount

func (p *ScheduledTask) GetFailureCount() int32

func (*ScheduledTask) GetStatus

func (p *ScheduledTask) GetStatus() ScheduleStatus

func (*ScheduledTask) GetTaskEvents

func (p *ScheduledTask) GetTaskEvents() []*TaskEvent

func (*ScheduledTask) GetTimesPartitioned added in v1.3.1

func (p *ScheduledTask) GetTimesPartitioned() int32

func (*ScheduledTask) IsSetAssignedTask

func (p *ScheduledTask) IsSetAssignedTask() bool

func (*ScheduledTask) Read

func (p *ScheduledTask) Read(iprot thrift.TProtocol) error

func (*ScheduledTask) ReadField1 added in v1.21.0

func (p *ScheduledTask) ReadField1(iprot thrift.TProtocol) error

func (*ScheduledTask) ReadField2 added in v1.21.0

func (p *ScheduledTask) ReadField2(iprot thrift.TProtocol) error

func (*ScheduledTask) ReadField3 added in v1.21.0

func (p *ScheduledTask) ReadField3(iprot thrift.TProtocol) error

func (*ScheduledTask) ReadField4 added in v1.21.0

func (p *ScheduledTask) ReadField4(iprot thrift.TProtocol) error

func (*ScheduledTask) ReadField5 added in v1.21.0

func (p *ScheduledTask) ReadField5(iprot thrift.TProtocol) error

func (*ScheduledTask) ReadField6 added in v1.21.0

func (p *ScheduledTask) ReadField6(iprot thrift.TProtocol) error

func (*ScheduledTask) String

func (p *ScheduledTask) String() string

func (*ScheduledTask) Write

func (p *ScheduledTask) Write(oprot thrift.TProtocol) error

type ServerInfo

type ServerInfo struct {
	ClusterName string `thrift:"clusterName,1" db:"clusterName" json:"clusterName"`
	// unused field # 2
	StatsUrlPrefix string `thrift:"statsUrlPrefix,3" db:"statsUrlPrefix" json:"statsUrlPrefix"`
}

Information about the scheduler.

Attributes:

  • ClusterName
  • StatsUrlPrefix: A url prefix for job container stats.
var Response_ServerInfo_DEFAULT *ServerInfo

func NewServerInfo

func NewServerInfo() *ServerInfo

func (*ServerInfo) GetClusterName

func (p *ServerInfo) GetClusterName() string

func (*ServerInfo) GetStatsUrlPrefix

func (p *ServerInfo) GetStatsUrlPrefix() string

func (*ServerInfo) Read

func (p *ServerInfo) Read(iprot thrift.TProtocol) error

func (*ServerInfo) ReadField1 added in v1.21.0

func (p *ServerInfo) ReadField1(iprot thrift.TProtocol) error

func (*ServerInfo) ReadField3 added in v1.21.0

func (p *ServerInfo) ReadField3(iprot thrift.TProtocol) error

func (*ServerInfo) String

func (p *ServerInfo) String() string

func (*ServerInfo) Write

func (p *ServerInfo) Write(oprot thrift.TProtocol) error

type SlaPolicy added in v1.3.1

type SlaPolicy struct {
	PercentageSlaPolicy  *PercentageSlaPolicy  `thrift:"percentageSlaPolicy,1" db:"percentageSlaPolicy" json:"percentageSlaPolicy,omitempty"`
	CountSlaPolicy       *CountSlaPolicy       `thrift:"countSlaPolicy,2" db:"countSlaPolicy" json:"countSlaPolicy,omitempty"`
	CoordinatorSlaPolicy *CoordinatorSlaPolicy `thrift:"coordinatorSlaPolicy,3" db:"coordinatorSlaPolicy" json:"coordinatorSlaPolicy,omitempty"`
}

SLA requirements expressed in one of the many types

Attributes:

  • PercentageSlaPolicy
  • CountSlaPolicy
  • CoordinatorSlaPolicy
var AuroraAdminSlaDrainHostsArgs_DefaultSlaPolicy_DEFAULT *SlaPolicy
var HostMaintenanceRequest_DefaultSlaPolicy_DEFAULT *SlaPolicy
var TaskConfig_SlaPolicy_DEFAULT *SlaPolicy

func NewSlaPolicy added in v1.3.1

func NewSlaPolicy() *SlaPolicy

func (*SlaPolicy) CountSetFieldsSlaPolicy added in v1.3.1

func (p *SlaPolicy) CountSetFieldsSlaPolicy() int

func (*SlaPolicy) GetCoordinatorSlaPolicy added in v1.3.1

func (p *SlaPolicy) GetCoordinatorSlaPolicy() *CoordinatorSlaPolicy

func (*SlaPolicy) GetCountSlaPolicy added in v1.3.1

func (p *SlaPolicy) GetCountSlaPolicy() *CountSlaPolicy

func (*SlaPolicy) GetPercentageSlaPolicy added in v1.3.1

func (p *SlaPolicy) GetPercentageSlaPolicy() *PercentageSlaPolicy

func (*SlaPolicy) IsSetCoordinatorSlaPolicy added in v1.3.1

func (p *SlaPolicy) IsSetCoordinatorSlaPolicy() bool

func (*SlaPolicy) IsSetCountSlaPolicy added in v1.3.1

func (p *SlaPolicy) IsSetCountSlaPolicy() bool

func (*SlaPolicy) IsSetPercentageSlaPolicy added in v1.3.1

func (p *SlaPolicy) IsSetPercentageSlaPolicy() bool

func (*SlaPolicy) Read added in v1.3.1

func (p *SlaPolicy) Read(iprot thrift.TProtocol) error

func (*SlaPolicy) ReadField1 added in v1.21.0

func (p *SlaPolicy) ReadField1(iprot thrift.TProtocol) error

func (*SlaPolicy) ReadField2 added in v1.21.0

func (p *SlaPolicy) ReadField2(iprot thrift.TProtocol) error

func (*SlaPolicy) ReadField3 added in v1.21.0

func (p *SlaPolicy) ReadField3(iprot thrift.TProtocol) error

func (*SlaPolicy) String added in v1.3.1

func (p *SlaPolicy) String() string

func (*SlaPolicy) Write added in v1.3.1

func (p *SlaPolicy) Write(oprot thrift.TProtocol) error

type StartJobUpdateResult_

type StartJobUpdateResult_ struct {
	Key           *JobUpdateKey     `thrift:"key,1" db:"key" json:"key"`
	UpdateSummary *JobUpdateSummary `thrift:"updateSummary,2" db:"updateSummary" json:"updateSummary,omitempty"`
}

Result of the startUpdate call.

Attributes:

  • Key: Unique identifier for the job update.
  • UpdateSummary: Summary of the update that is in progress for the given JobKey.
var Result__StartJobUpdateResult__DEFAULT *StartJobUpdateResult_

func NewStartJobUpdateResult_

func NewStartJobUpdateResult_() *StartJobUpdateResult_

func (*StartJobUpdateResult_) GetKey

func (p *StartJobUpdateResult_) GetKey() *JobUpdateKey

func (*StartJobUpdateResult_) GetUpdateSummary

func (p *StartJobUpdateResult_) GetUpdateSummary() *JobUpdateSummary

func (*StartJobUpdateResult_) IsSetKey

func (p *StartJobUpdateResult_) IsSetKey() bool

func (*StartJobUpdateResult_) IsSetUpdateSummary

func (p *StartJobUpdateResult_) IsSetUpdateSummary() bool

func (*StartJobUpdateResult_) Read

func (*StartJobUpdateResult_) ReadField1 added in v1.21.0

func (p *StartJobUpdateResult_) ReadField1(iprot thrift.TProtocol) error

func (*StartJobUpdateResult_) ReadField2 added in v1.21.0

func (p *StartJobUpdateResult_) ReadField2(iprot thrift.TProtocol) error

func (*StartJobUpdateResult_) String

func (p *StartJobUpdateResult_) String() string

func (*StartJobUpdateResult_) Write

func (p *StartJobUpdateResult_) Write(oprot thrift.TProtocol) error

type StartMaintenanceResult_

type StartMaintenanceResult_ struct {
	Statuses []*HostStatus `thrift:"statuses,1" db:"statuses" json:"statuses"`
}

Attributes:

  • Statuses
var Result__StartMaintenanceResult__DEFAULT *StartMaintenanceResult_

func NewStartMaintenanceResult_

func NewStartMaintenanceResult_() *StartMaintenanceResult_

func (*StartMaintenanceResult_) GetStatuses

func (p *StartMaintenanceResult_) GetStatuses() []*HostStatus

func (*StartMaintenanceResult_) Read

func (*StartMaintenanceResult_) ReadField1 added in v1.21.0

func (p *StartMaintenanceResult_) ReadField1(iprot thrift.TProtocol) error

func (*StartMaintenanceResult_) String

func (p *StartMaintenanceResult_) String() string

func (*StartMaintenanceResult_) Write

type TaskConfig

type TaskConfig struct {
	// unused fields # 1 to 6
	IsService bool `thrift:"isService,7" db:"isService" json:"isService"`
	// unused fields # 8 to 10
	Priority int32 `thrift:"priority,11" db:"priority" json:"priority"`
	// unused field # 12
	MaxTaskFailures int32 `thrift:"maxTaskFailures,13" db:"maxTaskFailures" json:"maxTaskFailures"`
	// unused fields # 14 to 16
	Owner      *Identity `thrift:"owner,17" db:"owner" json:"owner"`
	Production *bool     `thrift:"production,18" db:"production" json:"production,omitempty"`
	// unused field # 19
	Constraints []*Constraint `thrift:"constraints,20" db:"constraints" json:"constraints"`
	// unused field # 21
	TaskLinks    map[string]string `thrift:"taskLinks,22" db:"taskLinks" json:"taskLinks,omitempty"`
	ContactEmail *string           `thrift:"contactEmail,23" db:"contactEmail" json:"contactEmail,omitempty"`
	// unused field # 24
	ExecutorConfig *ExecutorConfig `thrift:"executorConfig,25" db:"executorConfig" json:"executorConfig,omitempty"`
	// unused field # 26
	Metadata  []*Metadata `thrift:"metadata,27" db:"metadata" json:"metadata,omitempty"`
	Job       *JobKey     `thrift:"job,28" db:"job" json:"job"`
	Container *Container  `thrift:"container,29" db:"container" json:"container"`
	Tier      *string     `thrift:"tier,30" db:"tier" json:"tier,omitempty"`
	// unused field # 31
	Resources        []*Resource        `thrift:"resources,32" db:"resources" json:"resources"`
	MesosFetcherUris []*MesosFetcherURI `thrift:"mesosFetcherUris,33" db:"mesosFetcherUris" json:"mesosFetcherUris,omitempty"`
	PartitionPolicy  *PartitionPolicy   `thrift:"partitionPolicy,34" db:"partitionPolicy" json:"partitionPolicy,omitempty"`
	SlaPolicy        *SlaPolicy         `thrift:"slaPolicy,35" db:"slaPolicy" json:"slaPolicy,omitempty"`
}

Description of the tasks contained within a job.

Attributes:

  • Job: Job task belongs to.
  • Owner: contains the role component of JobKey
  • IsService
  • Priority
  • MaxTaskFailures
  • Production: Whether this is a production task, which can preempt.
  • Tier: Task tier type.
  • Resources: All resources required to run a task.
  • Constraints
  • MesosFetcherUris: Resources to retrieve with Mesos Fetcher
  • TaskLinks: Custom links to include when displaying this task on the scheduler dashboard. Keys are anchor

text, values are URLs. Wildcards are supported for dynamic link crafting based on host, ports, instance, etc.

  • ContactEmail
  • ExecutorConfig: Executor configuration
  • Metadata: Used to display additional details in the UI.
  • PartitionPolicy: Policy for how to deal with task partitions
  • SlaPolicy: SLA requirements to be met during maintenance
  • Container: the container the task should use to execute
var AssignedTask_Task_DEFAULT *TaskConfig
var ConfigGroup_Config_DEFAULT *TaskConfig
var InstanceTaskConfig_Task_DEFAULT *TaskConfig
var JobConfiguration_TaskConfig_DEFAULT *TaskConfig
var JobUpdateRequest_TaskConfig_DEFAULT *TaskConfig
var PopulateJobResult__TaskConfig_DEFAULT *TaskConfig

func NewTaskConfig

func NewTaskConfig() *TaskConfig

func (*TaskConfig) GetConstraints

func (p *TaskConfig) GetConstraints() []*Constraint

func (*TaskConfig) GetContactEmail

func (p *TaskConfig) GetContactEmail() string

func (*TaskConfig) GetContainer

func (p *TaskConfig) GetContainer() *Container

func (*TaskConfig) GetExecutorConfig

func (p *TaskConfig) GetExecutorConfig() *ExecutorConfig

func (*TaskConfig) GetIsService

func (p *TaskConfig) GetIsService() bool

func (*TaskConfig) GetJob

func (p *TaskConfig) GetJob() *JobKey

func (*TaskConfig) GetMaxTaskFailures

func (p *TaskConfig) GetMaxTaskFailures() int32

func (*TaskConfig) GetMesosFetcherUris

func (p *TaskConfig) GetMesosFetcherUris() []*MesosFetcherURI

func (*TaskConfig) GetMetadata

func (p *TaskConfig) GetMetadata() []*Metadata

func (*TaskConfig) GetOwner

func (p *TaskConfig) GetOwner() *Identity

func (*TaskConfig) GetPartitionPolicy added in v1.3.1

func (p *TaskConfig) GetPartitionPolicy() *PartitionPolicy

func (*TaskConfig) GetPriority

func (p *TaskConfig) GetPriority() int32

func (*TaskConfig) GetProduction

func (p *TaskConfig) GetProduction() bool

func (*TaskConfig) GetResources

func (p *TaskConfig) GetResources() []*Resource

func (*TaskConfig) GetSlaPolicy added in v1.3.1

func (p *TaskConfig) GetSlaPolicy() *SlaPolicy
func (p *TaskConfig) GetTaskLinks() map[string]string

func (*TaskConfig) GetTier

func (p *TaskConfig) GetTier() string

func (*TaskConfig) IsSetContactEmail

func (p *TaskConfig) IsSetContactEmail() bool

func (*TaskConfig) IsSetContainer

func (p *TaskConfig) IsSetContainer() bool

func (*TaskConfig) IsSetExecutorConfig

func (p *TaskConfig) IsSetExecutorConfig() bool

func (*TaskConfig) IsSetJob

func (p *TaskConfig) IsSetJob() bool

func (*TaskConfig) IsSetMesosFetcherUris

func (p *TaskConfig) IsSetMesosFetcherUris() bool

func (*TaskConfig) IsSetMetadata

func (p *TaskConfig) IsSetMetadata() bool

func (*TaskConfig) IsSetOwner

func (p *TaskConfig) IsSetOwner() bool

func (*TaskConfig) IsSetPartitionPolicy added in v1.3.1

func (p *TaskConfig) IsSetPartitionPolicy() bool

func (*TaskConfig) IsSetProduction

func (p *TaskConfig) IsSetProduction() bool

func (*TaskConfig) IsSetSlaPolicy added in v1.3.1

func (p *TaskConfig) IsSetSlaPolicy() bool
func (p *TaskConfig) IsSetTaskLinks() bool

func (*TaskConfig) IsSetTier

func (p *TaskConfig) IsSetTier() bool

func (*TaskConfig) Read

func (p *TaskConfig) Read(iprot thrift.TProtocol) error

func (*TaskConfig) ReadField11 added in v1.21.0

func (p *TaskConfig) ReadField11(iprot thrift.TProtocol) error

func (*TaskConfig) ReadField13 added in v1.21.0

func (p *TaskConfig) ReadField13(iprot thrift.TProtocol) error

func (*TaskConfig) ReadField17 added in v1.21.0

func (p *TaskConfig) ReadField17(iprot thrift.TProtocol) error

func (*TaskConfig) ReadField18 added in v1.21.0

func (p *TaskConfig) ReadField18(iprot thrift.TProtocol) error

func (*TaskConfig) ReadField20 added in v1.21.0

func (p *TaskConfig) ReadField20(iprot thrift.TProtocol) error

func (*TaskConfig) ReadField22 added in v1.21.0

func (p *TaskConfig) ReadField22(iprot thrift.TProtocol) error

func (*TaskConfig) ReadField23 added in v1.21.0

func (p *TaskConfig) ReadField23(iprot thrift.TProtocol) error

func (*TaskConfig) ReadField25 added in v1.21.0

func (p *TaskConfig) ReadField25(iprot thrift.TProtocol) error

func (*TaskConfig) ReadField27 added in v1.21.0

func (p *TaskConfig) ReadField27(iprot thrift.TProtocol) error

func (*TaskConfig) ReadField28 added in v1.21.0

func (p *TaskConfig) ReadField28(iprot thrift.TProtocol) error

func (*TaskConfig) ReadField29 added in v1.21.0

func (p *TaskConfig) ReadField29(iprot thrift.TProtocol) error

func (*TaskConfig) ReadField30 added in v1.21.0

func (p *TaskConfig) ReadField30(iprot thrift.TProtocol) error

func (*TaskConfig) ReadField32 added in v1.21.0

func (p *TaskConfig) ReadField32(iprot thrift.TProtocol) error

func (*TaskConfig) ReadField33 added in v1.21.0

func (p *TaskConfig) ReadField33(iprot thrift.TProtocol) error

func (*TaskConfig) ReadField34 added in v1.21.0

func (p *TaskConfig) ReadField34(iprot thrift.TProtocol) error

func (*TaskConfig) ReadField35 added in v1.21.0

func (p *TaskConfig) ReadField35(iprot thrift.TProtocol) error

func (*TaskConfig) ReadField7 added in v1.21.0

func (p *TaskConfig) ReadField7(iprot thrift.TProtocol) error

func (*TaskConfig) String

func (p *TaskConfig) String() string

func (*TaskConfig) Write

func (p *TaskConfig) Write(oprot thrift.TProtocol) error

type TaskConstraint

type TaskConstraint struct {
	Value *ValueConstraint `thrift:"value,1" db:"value" json:"value,omitempty"`
	Limit *LimitConstraint `thrift:"limit,2" db:"limit" json:"limit,omitempty"`
}

Types of constraints that may be applied to a task.

Attributes:

  • Value
  • Limit
var Constraint_Constraint_DEFAULT *TaskConstraint

func NewTaskConstraint

func NewTaskConstraint() *TaskConstraint

func (*TaskConstraint) CountSetFieldsTaskConstraint

func (p *TaskConstraint) CountSetFieldsTaskConstraint() int

func (*TaskConstraint) GetLimit

func (p *TaskConstraint) GetLimit() *LimitConstraint

func (*TaskConstraint) GetValue

func (p *TaskConstraint) GetValue() *ValueConstraint

func (*TaskConstraint) IsSetLimit

func (p *TaskConstraint) IsSetLimit() bool

func (*TaskConstraint) IsSetValue

func (p *TaskConstraint) IsSetValue() bool

func (*TaskConstraint) Read

func (p *TaskConstraint) Read(iprot thrift.TProtocol) error

func (*TaskConstraint) ReadField1 added in v1.21.0

func (p *TaskConstraint) ReadField1(iprot thrift.TProtocol) error

func (*TaskConstraint) ReadField2 added in v1.21.0

func (p *TaskConstraint) ReadField2(iprot thrift.TProtocol) error

func (*TaskConstraint) String

func (p *TaskConstraint) String() string

func (*TaskConstraint) Write

func (p *TaskConstraint) Write(oprot thrift.TProtocol) error

type TaskEvent

type TaskEvent struct {
	Timestamp int64          `thrift:"timestamp,1" db:"timestamp" json:"timestamp"`
	Status    ScheduleStatus `thrift:"status,2" db:"status" json:"status"`
	Message   *string        `thrift:"message,3" db:"message" json:"message,omitempty"`
	Scheduler *string        `thrift:"scheduler,4" db:"scheduler" json:"scheduler,omitempty"`
}

Event marking a state transition within a task's lifecycle.

Attributes:

  • Timestamp: Epoch timestamp in milliseconds.
  • Status: New status of the task.
  • Message: Audit message that explains why a transition occurred.
  • Scheduler: Hostname of the scheduler machine that performed the event.

func NewTaskEvent

func NewTaskEvent() *TaskEvent

func (*TaskEvent) GetMessage

func (p *TaskEvent) GetMessage() string

func (*TaskEvent) GetScheduler

func (p *TaskEvent) GetScheduler() string

func (*TaskEvent) GetStatus

func (p *TaskEvent) GetStatus() ScheduleStatus

func (*TaskEvent) GetTimestamp

func (p *TaskEvent) GetTimestamp() int64

func (*TaskEvent) IsSetMessage

func (p *TaskEvent) IsSetMessage() bool

func (*TaskEvent) IsSetScheduler

func (p *TaskEvent) IsSetScheduler() bool

func (*TaskEvent) Read

func (p *TaskEvent) Read(iprot thrift.TProtocol) error

func (*TaskEvent) ReadField1 added in v1.21.0

func (p *TaskEvent) ReadField1(iprot thrift.TProtocol) error

func (*TaskEvent) ReadField2 added in v1.21.0

func (p *TaskEvent) ReadField2(iprot thrift.TProtocol) error

func (*TaskEvent) ReadField3 added in v1.21.0

func (p *TaskEvent) ReadField3(iprot thrift.TProtocol) error

func (*TaskEvent) ReadField4 added in v1.21.0

func (p *TaskEvent) ReadField4(iprot thrift.TProtocol) error

func (*TaskEvent) String

func (p *TaskEvent) String() string

func (*TaskEvent) Write

func (p *TaskEvent) Write(oprot thrift.TProtocol) error

type TaskQuery

type TaskQuery struct {
	// unused field # 1
	JobName *string `thrift:"jobName,2" db:"jobName" json:"jobName,omitempty"`
	// unused field # 3
	TaskIds  []string         `thrift:"taskIds,4" db:"taskIds" json:"taskIds,omitempty"`
	Statuses []ScheduleStatus `thrift:"statuses,5" db:"statuses" json:"statuses,omitempty"`
	// unused field # 6
	InstanceIds []int32 `thrift:"instanceIds,7" db:"instanceIds" json:"instanceIds,omitempty"`
	// unused field # 8
	Environment *string   `thrift:"environment,9" db:"environment" json:"environment,omitempty"`
	SlaveHosts  []string  `thrift:"slaveHosts,10" db:"slaveHosts" json:"slaveHosts,omitempty"`
	JobKeys     []*JobKey `thrift:"jobKeys,11" db:"jobKeys" json:"jobKeys,omitempty"`
	Offset      *int32    `thrift:"offset,12" db:"offset" json:"offset,omitempty"`
	Limit       *int32    `thrift:"limit,13" db:"limit" json:"limit,omitempty"`
	Role        *string   `thrift:"role,14" db:"role" json:"role,omitempty"`
}

Contains a set of restrictions on matching tasks where all restrictions must be met (terms are AND'ed together).

Attributes:

  • Role
  • Environment
  • JobName
  • TaskIds
  • Statuses
  • InstanceIds
  • SlaveHosts
  • JobKeys
  • Offset
  • Limit
var AuroraAdminDeleteRecoveryTasksArgs_Query_DEFAULT *TaskQuery
var AuroraAdminPruneTasksArgs_Query_DEFAULT *TaskQuery
var AuroraAdminQueryRecoveryArgs_Query_DEFAULT *TaskQuery
var ReadOnlySchedulerGetPendingReasonArgs_Query_DEFAULT *TaskQuery
var ReadOnlySchedulerGetTasksStatusArgs_Query_DEFAULT *TaskQuery
var ReadOnlySchedulerGetTasksWithoutConfigsArgs_Query_DEFAULT *TaskQuery

func NewTaskQuery

func NewTaskQuery() *TaskQuery

func (*TaskQuery) GetEnvironment

func (p *TaskQuery) GetEnvironment() string

func (*TaskQuery) GetInstanceIds

func (p *TaskQuery) GetInstanceIds() []int32

func (*TaskQuery) GetJobKeys

func (p *TaskQuery) GetJobKeys() []*JobKey

func (*TaskQuery) GetJobName

func (p *TaskQuery) GetJobName() string

func (*TaskQuery) GetLimit

func (p *TaskQuery) GetLimit() int32

func (*TaskQuery) GetOffset

func (p *TaskQuery) GetOffset() int32

func (*TaskQuery) GetRole

func (p *TaskQuery) GetRole() string

func (*TaskQuery) GetSlaveHosts

func (p *TaskQuery) GetSlaveHosts() []string

func (*TaskQuery) GetStatuses

func (p *TaskQuery) GetStatuses() []ScheduleStatus

func (*TaskQuery) GetTaskIds

func (p *TaskQuery) GetTaskIds() []string

func (*TaskQuery) IsSetEnvironment added in v1.3.0

func (p *TaskQuery) IsSetEnvironment() bool

func (*TaskQuery) IsSetInstanceIds added in v1.3.0

func (p *TaskQuery) IsSetInstanceIds() bool

func (*TaskQuery) IsSetJobKeys added in v1.3.0

func (p *TaskQuery) IsSetJobKeys() bool

func (*TaskQuery) IsSetJobName added in v1.3.0

func (p *TaskQuery) IsSetJobName() bool

func (*TaskQuery) IsSetLimit added in v1.3.0

func (p *TaskQuery) IsSetLimit() bool

func (*TaskQuery) IsSetOffset added in v1.3.0

func (p *TaskQuery) IsSetOffset() bool

func (*TaskQuery) IsSetRole added in v1.3.0

func (p *TaskQuery) IsSetRole() bool

func (*TaskQuery) IsSetSlaveHosts added in v1.3.0

func (p *TaskQuery) IsSetSlaveHosts() bool

func (*TaskQuery) IsSetStatuses added in v1.3.0

func (p *TaskQuery) IsSetStatuses() bool

func (*TaskQuery) IsSetTaskIds added in v1.3.0

func (p *TaskQuery) IsSetTaskIds() bool

func (*TaskQuery) Read

func (p *TaskQuery) Read(iprot thrift.TProtocol) error

func (*TaskQuery) ReadField10 added in v1.21.0

func (p *TaskQuery) ReadField10(iprot thrift.TProtocol) error

func (*TaskQuery) ReadField11 added in v1.21.0

func (p *TaskQuery) ReadField11(iprot thrift.TProtocol) error

func (*TaskQuery) ReadField12 added in v1.21.0

func (p *TaskQuery) ReadField12(iprot thrift.TProtocol) error

func (*TaskQuery) ReadField13 added in v1.21.0

func (p *TaskQuery) ReadField13(iprot thrift.TProtocol) error

func (*TaskQuery) ReadField14 added in v1.21.0

func (p *TaskQuery) ReadField14(iprot thrift.TProtocol) error

func (*TaskQuery) ReadField2 added in v1.21.0

func (p *TaskQuery) ReadField2(iprot thrift.TProtocol) error

func (*TaskQuery) ReadField4 added in v1.21.0

func (p *TaskQuery) ReadField4(iprot thrift.TProtocol) error

func (*TaskQuery) ReadField5 added in v1.21.0

func (p *TaskQuery) ReadField5(iprot thrift.TProtocol) error

func (*TaskQuery) ReadField7 added in v1.21.0

func (p *TaskQuery) ReadField7(iprot thrift.TProtocol) error

func (*TaskQuery) ReadField9 added in v1.21.0

func (p *TaskQuery) ReadField9(iprot thrift.TProtocol) error

func (*TaskQuery) String

func (p *TaskQuery) String() string

func (*TaskQuery) Write

func (p *TaskQuery) Write(oprot thrift.TProtocol) error

type TierConfig

type TierConfig struct {
	Name     string            `thrift:"name,1" db:"name" json:"name"`
	Settings map[string]string `thrift:"settings,2" db:"settings" json:"settings"`
}

Tier information.

Attributes:

  • Name: Name of tier.
  • Settings: Tier attributes.

func NewTierConfig

func NewTierConfig() *TierConfig

func (*TierConfig) GetName

func (p *TierConfig) GetName() string

func (*TierConfig) GetSettings

func (p *TierConfig) GetSettings() map[string]string

func (*TierConfig) Read

func (p *TierConfig) Read(iprot thrift.TProtocol) error

func (*TierConfig) ReadField1 added in v1.21.0

func (p *TierConfig) ReadField1(iprot thrift.TProtocol) error

func (*TierConfig) ReadField2 added in v1.21.0

func (p *TierConfig) ReadField2(iprot thrift.TProtocol) error

func (*TierConfig) String

func (p *TierConfig) String() string

func (*TierConfig) Write

func (p *TierConfig) Write(oprot thrift.TProtocol) error

type ValueConstraint

type ValueConstraint struct {
	Negated bool     `thrift:"negated,1" db:"negated" json:"negated"`
	Values  []string `thrift:"values,2" db:"values" json:"values"`
}

A constraint that specifies an explicit set of values, at least one of which must be present on a host for a task to be scheduled there.

Attributes:

  • Negated: If true, treat this as a 'not' - to avoid specific values.
  • Values
var TaskConstraint_Value_DEFAULT *ValueConstraint

func NewValueConstraint

func NewValueConstraint() *ValueConstraint

func (*ValueConstraint) GetNegated

func (p *ValueConstraint) GetNegated() bool

func (*ValueConstraint) GetValues

func (p *ValueConstraint) GetValues() []string

func (*ValueConstraint) Read

func (p *ValueConstraint) Read(iprot thrift.TProtocol) error

func (*ValueConstraint) ReadField1 added in v1.21.0

func (p *ValueConstraint) ReadField1(iprot thrift.TProtocol) error

func (*ValueConstraint) ReadField2 added in v1.21.0

func (p *ValueConstraint) ReadField2(iprot thrift.TProtocol) error

func (*ValueConstraint) String

func (p *ValueConstraint) String() string

func (*ValueConstraint) Write

func (p *ValueConstraint) Write(oprot thrift.TProtocol) error

type Volume

type Volume struct {
	ContainerPath string `thrift:"containerPath,1" db:"containerPath" json:"containerPath"`
	HostPath      string `thrift:"hostPath,2" db:"hostPath" json:"hostPath"`
	Mode          Mode   `thrift:"mode,3" db:"mode" json:"mode"`
}

A volume mount point within a container

Attributes:

  • ContainerPath: The path inside the container where the mount will be created.
  • HostPath: The path on the host that will serve as the source for the mount.
  • Mode: The access mode

func NewVolume

func NewVolume() *Volume

func (*Volume) GetContainerPath

func (p *Volume) GetContainerPath() string

func (*Volume) GetHostPath

func (p *Volume) GetHostPath() string

func (*Volume) GetMode

func (p *Volume) GetMode() Mode

func (*Volume) Read

func (p *Volume) Read(iprot thrift.TProtocol) error

func (*Volume) ReadField1 added in v1.21.0

func (p *Volume) ReadField1(iprot thrift.TProtocol) error

func (*Volume) ReadField2 added in v1.21.0

func (p *Volume) ReadField2(iprot thrift.TProtocol) error

func (*Volume) ReadField3 added in v1.21.0

func (p *Volume) ReadField3(iprot thrift.TProtocol) error

func (*Volume) String

func (p *Volume) String() string

func (*Volume) Write

func (p *Volume) Write(oprot thrift.TProtocol) error

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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