aurora

package
v1.3.0 Latest Latest
Warning

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

 Go to latest Published: Oct 5, 2018 License: Apache-2.0 Imports: 3 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 map[JobUpdateStatus]bool
View Source 
var ACTIVE_STATES map[ScheduleStatus]bool
View Source 
var AWAITNG_PULSE_JOB_UPDATE_STATES map[JobUpdateStatus]bool
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 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 map[JobUpdateStatus]bool
View Source 
var JobUpdateQuery_User_DEFAULT string
View Source 
var JobUpdateRequest_Metadata_DEFAULT map[*Metadata]bool
View Source 
var JobUpdateSettings_BlockIfNoPulsesAfterMs_DEFAULT int32
View Source 
var JobUpdateSummary_Metadata_DEFAULT map[*Metadata]bool
View Source 
var LIVE_STATES map[ScheduleStatus]bool
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 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 map[ScheduleStatus]bool
View Source 
var TERMINAL_STATES map[ScheduleStatus]bool
View Source 
var TaskConfig_ContactEmail_DEFAULT string
View Source 
var TaskConfig_MesosFetcherUris_DEFAULT map[*MesosFetcherURI]bool
View Source 
var TaskConfig_Metadata_DEFAULT map[*Metadata]bool
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 map[int32]bool
View Source 
var TaskQuery_JobKeys_DEFAULT map[*JobKey]bool
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 map[string]bool
View Source 
var TaskQuery_Statuses_DEFAULT map[ScheduleStatus]bool
View Source 
var TaskQuery_TaskIds_DEFAULT map[string]bool

Functions

This section is empty.

Types

type AppcImage 

type AppcImage struct {
	Name    string `thrift:"name,1" json:"name"`
	ImageId string `thrift:"imageId,2" 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) 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" json:"taskId"`
	SlaveId       string           `thrift:"slaveId,2" json:"slaveId"`
	SlaveHost     string           `thrift:"slaveHost,3" json:"slaveHost"`
	Task          *TaskConfig      `thrift:"task,4" json:"task"`
	AssignedPorts map[string]int32 `thrift:"assignedPorts,5" json:"assignedPorts"`
	InstanceId    int32            `thrift:"instanceId,6" 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) 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" json:"name"`
	Values map[string]bool `thrift:"values,2" 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() map[string]bool

func (*Attribute) Read 

func (p *Attribute) Read(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(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(taskId string, status ScheduleStatus) (r *Response, err error)
	// Immediately writes a storage snapshot to disk.
	PerformBackup() (r *Response, err error)
	// Lists backups that are available for recovery.
	ListBackups() (r *Response, err error)
	// Loads a backup to an in-memory storage.  This must precede all other recovery operations.
	//
	// Parameters:
	//  - BackupId
	StageRecovery(backupId string) (r *Response, err error)
	// Queries for tasks in a staged recovery.
	//
	// Parameters:
	//  - Query
	QueryRecovery(query *TaskQuery) (r *Response, err error)
	// Deletes tasks from a staged recovery.
	//
	// Parameters:
	//  - Query
	DeleteRecoveryTasks(query *TaskQuery) (r *Response, err error)
	// Commits a staged recovery, completely replacing the previous storage state.
	CommitRecovery() (r *Response, err error)
	// Unloads (aborts) a staged recovery.
	UnloadRecovery() (r *Response, err error)
	// Put the given hosts into maintenance mode.
	//
	// Parameters:
	//  - Hosts
	StartMaintenance(hosts *Hosts) (r *Response, err error)
	// Ask scheduler to begin moving tasks scheduled on given hosts.
	//
	// Parameters:
	//  - Hosts
	DrainHosts(hosts *Hosts) (r *Response, err error)
	// Retrieve the current maintenance states for a group of hosts.
	//
	// Parameters:
	//  - Hosts
	MaintenanceStatus(hosts *Hosts) (r *Response, err error)
	// Set the given hosts back into serving mode.
	//
	// Parameters:
	//  - Hosts
	EndMaintenance(hosts *Hosts) (r *Response, err error)
	// Start a storage snapshot and block until it completes.
	Snapshot() (r *Response, err error)
	// Tell scheduler to trigger an explicit task reconciliation with the given settings.
	//
	// Parameters:
	//  - Settings
	TriggerExplicitTaskReconciliation(settings *ExplicitReconciliationSettings) (r *Response, err error)
	// Tell scheduler to trigger an implicit task reconciliation.
	TriggerImplicitTaskReconciliation() (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(query *TaskQuery) (r *Response, err error)
}

type AuroraAdminClient 

type AuroraAdminClient struct {
	*AuroraSchedulerManagerClient
}

func NewAuroraAdminClientFactory 

func NewAuroraAdminClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *AuroraAdminClient

func NewAuroraAdminClientProtocol 

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

func (*AuroraAdminClient) CommitRecovery 

func (p *AuroraAdminClient) CommitRecovery() (r *Response, err error)

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

func (*AuroraAdminClient) DeleteRecoveryTasks 

func (p *AuroraAdminClient) DeleteRecoveryTasks(query *TaskQuery) (r *Response, err error)

Deletes tasks from a staged recovery.

Parameters:

  • Query

func (*AuroraAdminClient) DrainHosts 

func (p *AuroraAdminClient) DrainHosts(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(hosts *Hosts) (r *Response, err error)

Set the given hosts back into serving mode.

Parameters:

  • Hosts

func (*AuroraAdminClient) ForceTaskState 

func (p *AuroraAdminClient) ForceTaskState(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() (r *Response, err error)

Lists backups that are available for recovery.

func (*AuroraAdminClient) MaintenanceStatus 

func (p *AuroraAdminClient) MaintenanceStatus(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() (r *Response, err error)

Immediately writes a storage snapshot to disk.

func (*AuroraAdminClient) PruneTasks added in v1.1.0 

func (p *AuroraAdminClient) PruneTasks(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(query *TaskQuery) (r *Response, err error)

Queries for tasks in a staged recovery.

Parameters:

  • Query

func (*AuroraAdminClient) SetQuota 

func (p *AuroraAdminClient) SetQuota(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) Snapshot 

func (p *AuroraAdminClient) Snapshot() (r *Response, err error)

Start a storage snapshot and block until it completes.

func (*AuroraAdminClient) StageRecovery 

func (p *AuroraAdminClient) StageRecovery(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(hosts *Hosts) (r *Response, err error)

Put the given hosts into maintenance mode.

Parameters:

  • Hosts

func (*AuroraAdminClient) TriggerExplicitTaskReconciliation 

func (p *AuroraAdminClient) TriggerExplicitTaskReconciliation(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() (r *Response, err error)

Tell scheduler to trigger an implicit task reconciliation.

func (*AuroraAdminClient) UnloadRecovery 

func (p *AuroraAdminClient) UnloadRecovery() (r *Response, err error)

Unloads (aborts) a staged recovery.

type AuroraAdminCommitRecoveryArgs 

type AuroraAdminCommitRecoveryArgs struct {
}

func NewAuroraAdminCommitRecoveryArgs 

func NewAuroraAdminCommitRecoveryArgs() *AuroraAdminCommitRecoveryArgs

func (*AuroraAdminCommitRecoveryArgs) Read 

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

func (*AuroraAdminCommitRecoveryArgs) String 

func (p *AuroraAdminCommitRecoveryArgs) String() string

func (*AuroraAdminCommitRecoveryArgs) Write 

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

type AuroraAdminCommitRecoveryResult 

type AuroraAdminCommitRecoveryResult struct {
	Success *Response `thrift:"success,0" 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 (p *AuroraAdminCommitRecoveryResult) Read(iprot thrift.TProtocol) error

func (*AuroraAdminCommitRecoveryResult) String 

func (p *AuroraAdminCommitRecoveryResult) String() string

func (*AuroraAdminCommitRecoveryResult) Write 

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

type AuroraAdminDeleteRecoveryTasksArgs 

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

Attributes:

  • Query

func NewAuroraAdminDeleteRecoveryTasksArgs 

func NewAuroraAdminDeleteRecoveryTasksArgs() *AuroraAdminDeleteRecoveryTasksArgs

func (*AuroraAdminDeleteRecoveryTasksArgs) GetQuery 

func (p *AuroraAdminDeleteRecoveryTasksArgs) GetQuery() *TaskQuery

func (*AuroraAdminDeleteRecoveryTasksArgs) IsSetQuery 

func (p *AuroraAdminDeleteRecoveryTasksArgs) IsSetQuery() bool

func (*AuroraAdminDeleteRecoveryTasksArgs) Read 

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

func (*AuroraAdminDeleteRecoveryTasksArgs) String 

func (p *AuroraAdminDeleteRecoveryTasksArgs) String() string

func (*AuroraAdminDeleteRecoveryTasksArgs) Write 

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

type AuroraAdminDeleteRecoveryTasksResult 

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

Attributes:

  • Success

func NewAuroraAdminDeleteRecoveryTasksResult 

func NewAuroraAdminDeleteRecoveryTasksResult() *AuroraAdminDeleteRecoveryTasksResult

func (*AuroraAdminDeleteRecoveryTasksResult) GetSuccess 

func (p *AuroraAdminDeleteRecoveryTasksResult) GetSuccess() *Response

func (*AuroraAdminDeleteRecoveryTasksResult) IsSetSuccess 

func (p *AuroraAdminDeleteRecoveryTasksResult) IsSetSuccess() bool

func (*AuroraAdminDeleteRecoveryTasksResult) Read 

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

func (*AuroraAdminDeleteRecoveryTasksResult) String 

func (p *AuroraAdminDeleteRecoveryTasksResult) String() string

func (*AuroraAdminDeleteRecoveryTasksResult) Write 

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

type AuroraAdminDrainHostsArgs 

type AuroraAdminDrainHostsArgs struct {
	Hosts *Hosts `thrift:"hosts,1" 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 (p *AuroraAdminDrainHostsArgs) Read(iprot thrift.TProtocol) error

func (*AuroraAdminDrainHostsArgs) String 

func (p *AuroraAdminDrainHostsArgs) String() string

func (*AuroraAdminDrainHostsArgs) Write 

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

type AuroraAdminDrainHostsResult 

type AuroraAdminDrainHostsResult struct {
	Success *Response `thrift:"success,0" 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 (p *AuroraAdminDrainHostsResult) Read(iprot thrift.TProtocol) error

func (*AuroraAdminDrainHostsResult) String 

func (p *AuroraAdminDrainHostsResult) String() string

func (*AuroraAdminDrainHostsResult) Write 

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

type AuroraAdminEndMaintenanceArgs 

type AuroraAdminEndMaintenanceArgs struct {
	Hosts *Hosts `thrift:"hosts,1" 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 (p *AuroraAdminEndMaintenanceArgs) Read(iprot thrift.TProtocol) error

func (*AuroraAdminEndMaintenanceArgs) String 

func (p *AuroraAdminEndMaintenanceArgs) String() string

func (*AuroraAdminEndMaintenanceArgs) Write 

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

type AuroraAdminEndMaintenanceResult 

type AuroraAdminEndMaintenanceResult struct {
	Success *Response `thrift:"success,0" 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 (p *AuroraAdminEndMaintenanceResult) Read(iprot thrift.TProtocol) error

func (*AuroraAdminEndMaintenanceResult) String 

func (p *AuroraAdminEndMaintenanceResult) String() string

func (*AuroraAdminEndMaintenanceResult) Write 

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

type AuroraAdminForceTaskStateArgs 

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

Attributes:

  • TaskId
  • Status

func NewAuroraAdminForceTaskStateArgs 

func NewAuroraAdminForceTaskStateArgs() *AuroraAdminForceTaskStateArgs

func (*AuroraAdminForceTaskStateArgs) GetStatus 

func (p *AuroraAdminForceTaskStateArgs) GetStatus() ScheduleStatus

func (*AuroraAdminForceTaskStateArgs) GetTaskId 

func (p *AuroraAdminForceTaskStateArgs) GetTaskId() string

func (*AuroraAdminForceTaskStateArgs) Read 

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

func (*AuroraAdminForceTaskStateArgs) String 

func (p *AuroraAdminForceTaskStateArgs) String() string

func (*AuroraAdminForceTaskStateArgs) Write 

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

type AuroraAdminForceTaskStateResult 

type AuroraAdminForceTaskStateResult struct {
	Success *Response `thrift:"success,0" 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 (p *AuroraAdminForceTaskStateResult) Read(iprot thrift.TProtocol) error

func (*AuroraAdminForceTaskStateResult) String 

func (p *AuroraAdminForceTaskStateResult) String() string

func (*AuroraAdminForceTaskStateResult) Write 

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

type AuroraAdminListBackupsArgs 

type AuroraAdminListBackupsArgs struct {
}

func NewAuroraAdminListBackupsArgs 

func NewAuroraAdminListBackupsArgs() *AuroraAdminListBackupsArgs

func (*AuroraAdminListBackupsArgs) Read 

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

func (*AuroraAdminListBackupsArgs) String 

func (p *AuroraAdminListBackupsArgs) String() string

func (*AuroraAdminListBackupsArgs) Write 

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

type AuroraAdminListBackupsResult 

type AuroraAdminListBackupsResult struct {
	Success *Response `thrift:"success,0" 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 (p *AuroraAdminListBackupsResult) Read(iprot thrift.TProtocol) error

func (*AuroraAdminListBackupsResult) String 

func (p *AuroraAdminListBackupsResult) String() string

func (*AuroraAdminListBackupsResult) Write 

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

type AuroraAdminMaintenanceStatusArgs 

type AuroraAdminMaintenanceStatusArgs struct {
	Hosts *Hosts `thrift:"hosts,1" 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 (p *AuroraAdminMaintenanceStatusArgs) Read(iprot thrift.TProtocol) error

func (*AuroraAdminMaintenanceStatusArgs) String 

func (p *AuroraAdminMaintenanceStatusArgs) String() string

func (*AuroraAdminMaintenanceStatusArgs) Write 

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

type AuroraAdminMaintenanceStatusResult 

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

Attributes:

  • Success

func NewAuroraAdminMaintenanceStatusResult 

func NewAuroraAdminMaintenanceStatusResult() *AuroraAdminMaintenanceStatusResult

func (*AuroraAdminMaintenanceStatusResult) GetSuccess 

func (p *AuroraAdminMaintenanceStatusResult) GetSuccess() *Response

func (*AuroraAdminMaintenanceStatusResult) IsSetSuccess 

func (p *AuroraAdminMaintenanceStatusResult) IsSetSuccess() bool

func (*AuroraAdminMaintenanceStatusResult) Read 

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

func (*AuroraAdminMaintenanceStatusResult) String 

func (p *AuroraAdminMaintenanceStatusResult) String() string

func (*AuroraAdminMaintenanceStatusResult) Write 

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

type AuroraAdminPerformBackupArgs 

type AuroraAdminPerformBackupArgs struct {
}

func NewAuroraAdminPerformBackupArgs 

func NewAuroraAdminPerformBackupArgs() *AuroraAdminPerformBackupArgs

func (*AuroraAdminPerformBackupArgs) Read 

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

func (*AuroraAdminPerformBackupArgs) String 

func (p *AuroraAdminPerformBackupArgs) String() string

func (*AuroraAdminPerformBackupArgs) Write 

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

type AuroraAdminPerformBackupResult 

type AuroraAdminPerformBackupResult struct {
	Success *Response `thrift:"success,0" 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 (p *AuroraAdminPerformBackupResult) Read(iprot thrift.TProtocol) error

func (*AuroraAdminPerformBackupResult) String 

func (p *AuroraAdminPerformBackupResult) String() string

func (*AuroraAdminPerformBackupResult) Write 

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

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" 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 (p *AuroraAdminPruneTasksArgs) Read(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 

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

type AuroraAdminPruneTasksResult added in v1.1.0 

type AuroraAdminPruneTasksResult struct {
	Success *Response `thrift:"success,0" 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 (p *AuroraAdminPruneTasksResult) Read(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 

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

type AuroraAdminQueryRecoveryArgs 

type AuroraAdminQueryRecoveryArgs struct {
	Query *TaskQuery `thrift:"query,1" 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 (p *AuroraAdminQueryRecoveryArgs) Read(iprot thrift.TProtocol) error

func (*AuroraAdminQueryRecoveryArgs) String 

func (p *AuroraAdminQueryRecoveryArgs) String() string

func (*AuroraAdminQueryRecoveryArgs) Write 

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

type AuroraAdminQueryRecoveryResult 

type AuroraAdminQueryRecoveryResult struct {
	Success *Response `thrift:"success,0" 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 (p *AuroraAdminQueryRecoveryResult) Read(iprot thrift.TProtocol) error

func (*AuroraAdminQueryRecoveryResult) String 

func (p *AuroraAdminQueryRecoveryResult) String() string

func (*AuroraAdminQueryRecoveryResult) Write 

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

type AuroraAdminSetQuotaArgs 

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

Attributes:

  • OwnerRole
  • Quota

func NewAuroraAdminSetQuotaArgs 

func NewAuroraAdminSetQuotaArgs() *AuroraAdminSetQuotaArgs

func (*AuroraAdminSetQuotaArgs) GetOwnerRole 

func (p *AuroraAdminSetQuotaArgs) GetOwnerRole() string

func (*AuroraAdminSetQuotaArgs) GetQuota 

func (p *AuroraAdminSetQuotaArgs) GetQuota() *ResourceAggregate

func (*AuroraAdminSetQuotaArgs) IsSetQuota 

func (p *AuroraAdminSetQuotaArgs) IsSetQuota() bool

func (*AuroraAdminSetQuotaArgs) Read 

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

func (*AuroraAdminSetQuotaArgs) String 

func (p *AuroraAdminSetQuotaArgs) String() string

func (*AuroraAdminSetQuotaArgs) Write 

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

type AuroraAdminSetQuotaResult 

type AuroraAdminSetQuotaResult struct {
	Success *Response `thrift:"success,0" 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 (p *AuroraAdminSetQuotaResult) Read(iprot thrift.TProtocol) error

func (*AuroraAdminSetQuotaResult) String 

func (p *AuroraAdminSetQuotaResult) String() string

func (*AuroraAdminSetQuotaResult) Write 

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

type AuroraAdminSnapshotArgs 

type AuroraAdminSnapshotArgs struct {
}

func NewAuroraAdminSnapshotArgs 

func NewAuroraAdminSnapshotArgs() *AuroraAdminSnapshotArgs

func (*AuroraAdminSnapshotArgs) Read 

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

func (*AuroraAdminSnapshotArgs) String 

func (p *AuroraAdminSnapshotArgs) String() string

func (*AuroraAdminSnapshotArgs) Write 

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

type AuroraAdminSnapshotResult 

type AuroraAdminSnapshotResult struct {
	Success *Response `thrift:"success,0" 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 (p *AuroraAdminSnapshotResult) Read(iprot thrift.TProtocol) error

func (*AuroraAdminSnapshotResult) String 

func (p *AuroraAdminSnapshotResult) String() string

func (*AuroraAdminSnapshotResult) Write 

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

type AuroraAdminStageRecoveryArgs 

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

Attributes:

  • BackupId

func NewAuroraAdminStageRecoveryArgs 

func NewAuroraAdminStageRecoveryArgs() *AuroraAdminStageRecoveryArgs

func (*AuroraAdminStageRecoveryArgs) GetBackupId 

func (p *AuroraAdminStageRecoveryArgs) GetBackupId() string

func (*AuroraAdminStageRecoveryArgs) Read 

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

func (*AuroraAdminStageRecoveryArgs) String 

func (p *AuroraAdminStageRecoveryArgs) String() string

func (*AuroraAdminStageRecoveryArgs) Write 

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

type AuroraAdminStageRecoveryResult 

type AuroraAdminStageRecoveryResult struct {
	Success *Response `thrift:"success,0" 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 (p *AuroraAdminStageRecoveryResult) Read(iprot thrift.TProtocol) error

func (*AuroraAdminStageRecoveryResult) String 

func (p *AuroraAdminStageRecoveryResult) String() string

func (*AuroraAdminStageRecoveryResult) Write 

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

type AuroraAdminStartMaintenanceArgs 

type AuroraAdminStartMaintenanceArgs struct {
	Hosts *Hosts `thrift:"hosts,1" 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 (p *AuroraAdminStartMaintenanceArgs) Read(iprot thrift.TProtocol) error

func (*AuroraAdminStartMaintenanceArgs) String 

func (p *AuroraAdminStartMaintenanceArgs) String() string

func (*AuroraAdminStartMaintenanceArgs) Write 

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

type AuroraAdminStartMaintenanceResult 

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

Attributes:

  • Success

func NewAuroraAdminStartMaintenanceResult 

func NewAuroraAdminStartMaintenanceResult() *AuroraAdminStartMaintenanceResult

func (*AuroraAdminStartMaintenanceResult) GetSuccess 

func (p *AuroraAdminStartMaintenanceResult) GetSuccess() *Response

func (*AuroraAdminStartMaintenanceResult) IsSetSuccess 

func (p *AuroraAdminStartMaintenanceResult) IsSetSuccess() bool

func (*AuroraAdminStartMaintenanceResult) Read 

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

func (*AuroraAdminStartMaintenanceResult) String 

func (p *AuroraAdminStartMaintenanceResult) String() string

func (*AuroraAdminStartMaintenanceResult) Write 

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

type AuroraAdminTriggerExplicitTaskReconciliationArgs 

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

Attributes:

  • Settings

func NewAuroraAdminTriggerExplicitTaskReconciliationArgs 

func NewAuroraAdminTriggerExplicitTaskReconciliationArgs() *AuroraAdminTriggerExplicitTaskReconciliationArgs

func (*AuroraAdminTriggerExplicitTaskReconciliationArgs) GetSettings 

func (p *AuroraAdminTriggerExplicitTaskReconciliationArgs) GetSettings() *ExplicitReconciliationSettings

func (*AuroraAdminTriggerExplicitTaskReconciliationArgs) IsSetSettings 

func (p *AuroraAdminTriggerExplicitTaskReconciliationArgs) IsSetSettings() bool

func (*AuroraAdminTriggerExplicitTaskReconciliationArgs) Read 

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

func (*AuroraAdminTriggerExplicitTaskReconciliationArgs) String 

func (p *AuroraAdminTriggerExplicitTaskReconciliationArgs) String() string

func (*AuroraAdminTriggerExplicitTaskReconciliationArgs) Write 

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

type AuroraAdminTriggerExplicitTaskReconciliationResult 

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

Attributes:

  • Success

func NewAuroraAdminTriggerExplicitTaskReconciliationResult 

func NewAuroraAdminTriggerExplicitTaskReconciliationResult() *AuroraAdminTriggerExplicitTaskReconciliationResult

func (*AuroraAdminTriggerExplicitTaskReconciliationResult) GetSuccess 

func (p *AuroraAdminTriggerExplicitTaskReconciliationResult) GetSuccess() *Response

func (*AuroraAdminTriggerExplicitTaskReconciliationResult) IsSetSuccess 

func (p *AuroraAdminTriggerExplicitTaskReconciliationResult) IsSetSuccess() bool

func (*AuroraAdminTriggerExplicitTaskReconciliationResult) Read 

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

func (*AuroraAdminTriggerExplicitTaskReconciliationResult) String 

func (p *AuroraAdminTriggerExplicitTaskReconciliationResult) String() string

func (*AuroraAdminTriggerExplicitTaskReconciliationResult) Write 

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

type AuroraAdminTriggerImplicitTaskReconciliationArgs 

type AuroraAdminTriggerImplicitTaskReconciliationArgs struct {
}

func NewAuroraAdminTriggerImplicitTaskReconciliationArgs 

func NewAuroraAdminTriggerImplicitTaskReconciliationArgs() *AuroraAdminTriggerImplicitTaskReconciliationArgs

func (*AuroraAdminTriggerImplicitTaskReconciliationArgs) Read 

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

func (*AuroraAdminTriggerImplicitTaskReconciliationArgs) String 

func (p *AuroraAdminTriggerImplicitTaskReconciliationArgs) String() string

func (*AuroraAdminTriggerImplicitTaskReconciliationArgs) Write 

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

type AuroraAdminTriggerImplicitTaskReconciliationResult 

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

Attributes:

  • Success

func NewAuroraAdminTriggerImplicitTaskReconciliationResult 

func NewAuroraAdminTriggerImplicitTaskReconciliationResult() *AuroraAdminTriggerImplicitTaskReconciliationResult

func (*AuroraAdminTriggerImplicitTaskReconciliationResult) GetSuccess 

func (p *AuroraAdminTriggerImplicitTaskReconciliationResult) GetSuccess() *Response

func (*AuroraAdminTriggerImplicitTaskReconciliationResult) IsSetSuccess 

func (p *AuroraAdminTriggerImplicitTaskReconciliationResult) IsSetSuccess() bool

func (*AuroraAdminTriggerImplicitTaskReconciliationResult) Read 

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

func (*AuroraAdminTriggerImplicitTaskReconciliationResult) String 

func (p *AuroraAdminTriggerImplicitTaskReconciliationResult) String() string

func (*AuroraAdminTriggerImplicitTaskReconciliationResult) Write 

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

type AuroraAdminUnloadRecoveryArgs 

type AuroraAdminUnloadRecoveryArgs struct {
}

func NewAuroraAdminUnloadRecoveryArgs 

func NewAuroraAdminUnloadRecoveryArgs() *AuroraAdminUnloadRecoveryArgs

func (*AuroraAdminUnloadRecoveryArgs) Read 

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

func (*AuroraAdminUnloadRecoveryArgs) String 

func (p *AuroraAdminUnloadRecoveryArgs) String() string

func (*AuroraAdminUnloadRecoveryArgs) Write 

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

type AuroraAdminUnloadRecoveryResult 

type AuroraAdminUnloadRecoveryResult struct {
	Success *Response `thrift:"success,0" 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 (p *AuroraAdminUnloadRecoveryResult) Read(iprot thrift.TProtocol) error

func (*AuroraAdminUnloadRecoveryResult) String 

func (p *AuroraAdminUnloadRecoveryResult) String() string

func (*AuroraAdminUnloadRecoveryResult) Write 

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

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(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(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(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(job *JobKey) (r *Response, err error)
	// Restarts a batch of shards.
	//
	// Parameters:
	//  - Job
	//  - ShardIds
	RestartShards(job *JobKey, shardIds map[int32]bool) (r *Response, err error)
	// Initiates a kill on tasks.
	//
	// Parameters:
	//  - Job
	//  - Instances
	//  - Message
	KillTasks(job *JobKey, instances map[int32]bool, message string) (r *Response, err error)
	// Adds new instances with the TaskConfig of the existing instance pointed by the key.
	//
	// Parameters:
	//  - Key
	//  - Count
	AddInstances(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(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(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(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(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(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(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(key *JobUpdateKey) (r *Response, err error)
}

type AuroraSchedulerManagerAbortJobUpdateArgs 

type AuroraSchedulerManagerAbortJobUpdateArgs struct {
	Key *JobUpdateKey `thrift:"key,1" json:"key"`
	// unused field # 2
	Message string `thrift:"message,3" 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 (p *AuroraSchedulerManagerAbortJobUpdateArgs) GetKey() *JobUpdateKey

func (*AuroraSchedulerManagerAbortJobUpdateArgs) GetMessage 

func (p *AuroraSchedulerManagerAbortJobUpdateArgs) GetMessage() string

func (*AuroraSchedulerManagerAbortJobUpdateArgs) IsSetKey 

func (p *AuroraSchedulerManagerAbortJobUpdateArgs) IsSetKey() bool

func (*AuroraSchedulerManagerAbortJobUpdateArgs) Read 

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

func (*AuroraSchedulerManagerAbortJobUpdateArgs) String 

func (p *AuroraSchedulerManagerAbortJobUpdateArgs) String() string

func (*AuroraSchedulerManagerAbortJobUpdateArgs) Write 

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

type AuroraSchedulerManagerAbortJobUpdateResult 

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

Attributes:

  • Success

func NewAuroraSchedulerManagerAbortJobUpdateResult 

func NewAuroraSchedulerManagerAbortJobUpdateResult() *AuroraSchedulerManagerAbortJobUpdateResult

func (*AuroraSchedulerManagerAbortJobUpdateResult) GetSuccess 

func (p *AuroraSchedulerManagerAbortJobUpdateResult) GetSuccess() *Response

func (*AuroraSchedulerManagerAbortJobUpdateResult) IsSetSuccess 

func (p *AuroraSchedulerManagerAbortJobUpdateResult) IsSetSuccess() bool

func (*AuroraSchedulerManagerAbortJobUpdateResult) Read 

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

func (*AuroraSchedulerManagerAbortJobUpdateResult) String 

func (p *AuroraSchedulerManagerAbortJobUpdateResult) String() string

func (*AuroraSchedulerManagerAbortJobUpdateResult) Write 

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

type AuroraSchedulerManagerAddInstancesArgs 

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

Attributes:

  • Key
  • Count

func NewAuroraSchedulerManagerAddInstancesArgs 

func NewAuroraSchedulerManagerAddInstancesArgs() *AuroraSchedulerManagerAddInstancesArgs

func (*AuroraSchedulerManagerAddInstancesArgs) GetCount 

func (p *AuroraSchedulerManagerAddInstancesArgs) GetCount() int32

func (*AuroraSchedulerManagerAddInstancesArgs) GetKey 

func (p *AuroraSchedulerManagerAddInstancesArgs) GetKey() *InstanceKey

func (*AuroraSchedulerManagerAddInstancesArgs) IsSetKey 

func (p *AuroraSchedulerManagerAddInstancesArgs) IsSetKey() bool

func (*AuroraSchedulerManagerAddInstancesArgs) Read 

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

func (*AuroraSchedulerManagerAddInstancesArgs) String 

func (p *AuroraSchedulerManagerAddInstancesArgs) String() string

func (*AuroraSchedulerManagerAddInstancesArgs) Write 

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

type AuroraSchedulerManagerAddInstancesResult 

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

Attributes:

  • Success

func NewAuroraSchedulerManagerAddInstancesResult 

func NewAuroraSchedulerManagerAddInstancesResult() *AuroraSchedulerManagerAddInstancesResult

func (*AuroraSchedulerManagerAddInstancesResult) GetSuccess 

func (p *AuroraSchedulerManagerAddInstancesResult) GetSuccess() *Response

func (*AuroraSchedulerManagerAddInstancesResult) IsSetSuccess 

func (p *AuroraSchedulerManagerAddInstancesResult) IsSetSuccess() bool

func (*AuroraSchedulerManagerAddInstancesResult) Read 

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

func (*AuroraSchedulerManagerAddInstancesResult) String 

func (p *AuroraSchedulerManagerAddInstancesResult) String() string

func (*AuroraSchedulerManagerAddInstancesResult) Write 

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

type AuroraSchedulerManagerClient 

type AuroraSchedulerManagerClient struct {
	*ReadOnlySchedulerClient
}

func NewAuroraSchedulerManagerClientFactory 

func NewAuroraSchedulerManagerClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *AuroraSchedulerManagerClient

func NewAuroraSchedulerManagerClientProtocol 

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

func (*AuroraSchedulerManagerClient) AbortJobUpdate 

func (p *AuroraSchedulerManagerClient) AbortJobUpdate(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(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(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(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(job *JobKey, instances map[int32]bool, message string) (r *Response, err error)

Initiates a kill on tasks.

Parameters:

  • Job
  • Instances
  • Message

func (*AuroraSchedulerManagerClient) PauseJobUpdate 

func (p *AuroraSchedulerManagerClient) PauseJobUpdate(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(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(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(job *JobKey, shardIds map[int32]bool) (r *Response, err error)

Restarts a batch of shards.

Parameters:

  • Job
  • ShardIds

func (*AuroraSchedulerManagerClient) ResumeJobUpdate 

func (p *AuroraSchedulerManagerClient) ResumeJobUpdate(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(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(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(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(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" json:"description"`
}

Attributes:

  • Description

func NewAuroraSchedulerManagerCreateJobArgs 

func NewAuroraSchedulerManagerCreateJobArgs() *AuroraSchedulerManagerCreateJobArgs

func (*AuroraSchedulerManagerCreateJobArgs) GetDescription 

func (p *AuroraSchedulerManagerCreateJobArgs) GetDescription() *JobConfiguration

func (*AuroraSchedulerManagerCreateJobArgs) IsSetDescription 

func (p *AuroraSchedulerManagerCreateJobArgs) IsSetDescription() bool

func (*AuroraSchedulerManagerCreateJobArgs) Read 

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

func (*AuroraSchedulerManagerCreateJobArgs) String 

func (p *AuroraSchedulerManagerCreateJobArgs) String() string

func (*AuroraSchedulerManagerCreateJobArgs) Write 

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

type AuroraSchedulerManagerCreateJobResult 

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

Attributes:

  • Success

func NewAuroraSchedulerManagerCreateJobResult 

func NewAuroraSchedulerManagerCreateJobResult() *AuroraSchedulerManagerCreateJobResult

func (*AuroraSchedulerManagerCreateJobResult) GetSuccess 

func (p *AuroraSchedulerManagerCreateJobResult) GetSuccess() *Response

func (*AuroraSchedulerManagerCreateJobResult) IsSetSuccess 

func (p *AuroraSchedulerManagerCreateJobResult) IsSetSuccess() bool

func (*AuroraSchedulerManagerCreateJobResult) Read 

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

func (*AuroraSchedulerManagerCreateJobResult) String 

func (p *AuroraSchedulerManagerCreateJobResult) String() string

func (*AuroraSchedulerManagerCreateJobResult) Write 

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

type AuroraSchedulerManagerDescheduleCronJobArgs 

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

Attributes:

  • Job

func NewAuroraSchedulerManagerDescheduleCronJobArgs 

func NewAuroraSchedulerManagerDescheduleCronJobArgs() *AuroraSchedulerManagerDescheduleCronJobArgs

func (*AuroraSchedulerManagerDescheduleCronJobArgs) GetJob 

func (p *AuroraSchedulerManagerDescheduleCronJobArgs) GetJob() *JobKey

func (*AuroraSchedulerManagerDescheduleCronJobArgs) IsSetJob 

func (p *AuroraSchedulerManagerDescheduleCronJobArgs) IsSetJob() bool

func (*AuroraSchedulerManagerDescheduleCronJobArgs) Read 

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

func (*AuroraSchedulerManagerDescheduleCronJobArgs) String 

func (p *AuroraSchedulerManagerDescheduleCronJobArgs) String() string

func (*AuroraSchedulerManagerDescheduleCronJobArgs) Write 

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

type AuroraSchedulerManagerDescheduleCronJobResult 

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

Attributes:

  • Success

func NewAuroraSchedulerManagerDescheduleCronJobResult 

func NewAuroraSchedulerManagerDescheduleCronJobResult() *AuroraSchedulerManagerDescheduleCronJobResult

func (*AuroraSchedulerManagerDescheduleCronJobResult) GetSuccess 

func (p *AuroraSchedulerManagerDescheduleCronJobResult) GetSuccess() *Response

func (*AuroraSchedulerManagerDescheduleCronJobResult) IsSetSuccess 

func (p *AuroraSchedulerManagerDescheduleCronJobResult) IsSetSuccess() bool

func (*AuroraSchedulerManagerDescheduleCronJobResult) Read 

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

func (*AuroraSchedulerManagerDescheduleCronJobResult) String 

func (p *AuroraSchedulerManagerDescheduleCronJobResult) String() string

func (*AuroraSchedulerManagerDescheduleCronJobResult) Write 

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

type AuroraSchedulerManagerKillTasksArgs 

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

Attributes:

  • Job
  • Instances
  • Message

func NewAuroraSchedulerManagerKillTasksArgs 

func NewAuroraSchedulerManagerKillTasksArgs() *AuroraSchedulerManagerKillTasksArgs

func (*AuroraSchedulerManagerKillTasksArgs) GetInstances 

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

func (*AuroraSchedulerManagerKillTasksArgs) GetJob 

func (p *AuroraSchedulerManagerKillTasksArgs) GetJob() *JobKey

func (*AuroraSchedulerManagerKillTasksArgs) GetMessage added in v1.1.0 

func (p *AuroraSchedulerManagerKillTasksArgs) GetMessage() string

func (*AuroraSchedulerManagerKillTasksArgs) IsSetJob 

func (p *AuroraSchedulerManagerKillTasksArgs) IsSetJob() bool

func (*AuroraSchedulerManagerKillTasksArgs) Read 

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

func (*AuroraSchedulerManagerKillTasksArgs) String 

func (p *AuroraSchedulerManagerKillTasksArgs) String() string

func (*AuroraSchedulerManagerKillTasksArgs) Write 

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

type AuroraSchedulerManagerKillTasksResult 

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

Attributes:

  • Success

func NewAuroraSchedulerManagerKillTasksResult 

func NewAuroraSchedulerManagerKillTasksResult() *AuroraSchedulerManagerKillTasksResult

func (*AuroraSchedulerManagerKillTasksResult) GetSuccess 

func (p *AuroraSchedulerManagerKillTasksResult) GetSuccess() *Response

func (*AuroraSchedulerManagerKillTasksResult) IsSetSuccess 

func (p *AuroraSchedulerManagerKillTasksResult) IsSetSuccess() bool

func (*AuroraSchedulerManagerKillTasksResult) Read 

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

func (*AuroraSchedulerManagerKillTasksResult) String 

func (p *AuroraSchedulerManagerKillTasksResult) String() string

func (*AuroraSchedulerManagerKillTasksResult) Write 

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

type AuroraSchedulerManagerPauseJobUpdateArgs 

type AuroraSchedulerManagerPauseJobUpdateArgs struct {
	Key *JobUpdateKey `thrift:"key,1" json:"key"`
	// unused field # 2
	Message string `thrift:"message,3" 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 (p *AuroraSchedulerManagerPauseJobUpdateArgs) GetKey() *JobUpdateKey

func (*AuroraSchedulerManagerPauseJobUpdateArgs) GetMessage 

func (p *AuroraSchedulerManagerPauseJobUpdateArgs) GetMessage() string

func (*AuroraSchedulerManagerPauseJobUpdateArgs) IsSetKey 

func (p *AuroraSchedulerManagerPauseJobUpdateArgs) IsSetKey() bool

func (*AuroraSchedulerManagerPauseJobUpdateArgs) Read 

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

func (*AuroraSchedulerManagerPauseJobUpdateArgs) String 

func (p *AuroraSchedulerManagerPauseJobUpdateArgs) String() string

func (*AuroraSchedulerManagerPauseJobUpdateArgs) Write 

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

type AuroraSchedulerManagerPauseJobUpdateResult 

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

Attributes:

  • Success

func NewAuroraSchedulerManagerPauseJobUpdateResult 

func NewAuroraSchedulerManagerPauseJobUpdateResult() *AuroraSchedulerManagerPauseJobUpdateResult

func (*AuroraSchedulerManagerPauseJobUpdateResult) GetSuccess 

func (p *AuroraSchedulerManagerPauseJobUpdateResult) GetSuccess() *Response

func (*AuroraSchedulerManagerPauseJobUpdateResult) IsSetSuccess 

func (p *AuroraSchedulerManagerPauseJobUpdateResult) IsSetSuccess() bool

func (*AuroraSchedulerManagerPauseJobUpdateResult) Read 

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

func (*AuroraSchedulerManagerPauseJobUpdateResult) String 

func (p *AuroraSchedulerManagerPauseJobUpdateResult) String() string

func (*AuroraSchedulerManagerPauseJobUpdateResult) Write 

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

type AuroraSchedulerManagerProcessor 

type AuroraSchedulerManagerProcessor struct {
	*ReadOnlySchedulerProcessor
}

func NewAuroraSchedulerManagerProcessor 

func NewAuroraSchedulerManagerProcessor(handler AuroraSchedulerManager) *AuroraSchedulerManagerProcessor

type AuroraSchedulerManagerPulseJobUpdateArgs 

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

Attributes:

  • Key

func NewAuroraSchedulerManagerPulseJobUpdateArgs 

func NewAuroraSchedulerManagerPulseJobUpdateArgs() *AuroraSchedulerManagerPulseJobUpdateArgs

func (*AuroraSchedulerManagerPulseJobUpdateArgs) GetKey 

func (p *AuroraSchedulerManagerPulseJobUpdateArgs) GetKey() *JobUpdateKey

func (*AuroraSchedulerManagerPulseJobUpdateArgs) IsSetKey 

func (p *AuroraSchedulerManagerPulseJobUpdateArgs) IsSetKey() bool

func (*AuroraSchedulerManagerPulseJobUpdateArgs) Read 

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

func (*AuroraSchedulerManagerPulseJobUpdateArgs) String 

func (p *AuroraSchedulerManagerPulseJobUpdateArgs) String() string

func (*AuroraSchedulerManagerPulseJobUpdateArgs) Write 

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

type AuroraSchedulerManagerPulseJobUpdateResult 

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

Attributes:

  • Success

func NewAuroraSchedulerManagerPulseJobUpdateResult 

func NewAuroraSchedulerManagerPulseJobUpdateResult() *AuroraSchedulerManagerPulseJobUpdateResult

func (*AuroraSchedulerManagerPulseJobUpdateResult) GetSuccess 

func (p *AuroraSchedulerManagerPulseJobUpdateResult) GetSuccess() *Response

func (*AuroraSchedulerManagerPulseJobUpdateResult) IsSetSuccess 

func (p *AuroraSchedulerManagerPulseJobUpdateResult) IsSetSuccess() bool

func (*AuroraSchedulerManagerPulseJobUpdateResult) Read 

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

func (*AuroraSchedulerManagerPulseJobUpdateResult) String 

func (p *AuroraSchedulerManagerPulseJobUpdateResult) String() string

func (*AuroraSchedulerManagerPulseJobUpdateResult) Write 

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

type AuroraSchedulerManagerReplaceCronTemplateArgs 

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

Attributes:

  • Config

func NewAuroraSchedulerManagerReplaceCronTemplateArgs 

func NewAuroraSchedulerManagerReplaceCronTemplateArgs() *AuroraSchedulerManagerReplaceCronTemplateArgs

func (*AuroraSchedulerManagerReplaceCronTemplateArgs) GetConfig 

func (p *AuroraSchedulerManagerReplaceCronTemplateArgs) GetConfig() *JobConfiguration

func (*AuroraSchedulerManagerReplaceCronTemplateArgs) IsSetConfig 

func (p *AuroraSchedulerManagerReplaceCronTemplateArgs) IsSetConfig() bool

func (*AuroraSchedulerManagerReplaceCronTemplateArgs) Read 

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

func (*AuroraSchedulerManagerReplaceCronTemplateArgs) String 

func (p *AuroraSchedulerManagerReplaceCronTemplateArgs) String() string

func (*AuroraSchedulerManagerReplaceCronTemplateArgs) Write 

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

type AuroraSchedulerManagerReplaceCronTemplateResult 

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

Attributes:

  • Success

func NewAuroraSchedulerManagerReplaceCronTemplateResult 

func NewAuroraSchedulerManagerReplaceCronTemplateResult() *AuroraSchedulerManagerReplaceCronTemplateResult

func (*AuroraSchedulerManagerReplaceCronTemplateResult) GetSuccess 

func (p *AuroraSchedulerManagerReplaceCronTemplateResult) GetSuccess() *Response

func (*AuroraSchedulerManagerReplaceCronTemplateResult) IsSetSuccess 

func (p *AuroraSchedulerManagerReplaceCronTemplateResult) IsSetSuccess() bool

func (*AuroraSchedulerManagerReplaceCronTemplateResult) Read 

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

func (*AuroraSchedulerManagerReplaceCronTemplateResult) String 

func (p *AuroraSchedulerManagerReplaceCronTemplateResult) String() string

func (*AuroraSchedulerManagerReplaceCronTemplateResult) Write 

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

type AuroraSchedulerManagerRestartShardsArgs 

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

Attributes:

  • Job
  • ShardIds

func NewAuroraSchedulerManagerRestartShardsArgs 

func NewAuroraSchedulerManagerRestartShardsArgs() *AuroraSchedulerManagerRestartShardsArgs

func (*AuroraSchedulerManagerRestartShardsArgs) GetJob 

func (p *AuroraSchedulerManagerRestartShardsArgs) GetJob() *JobKey

func (*AuroraSchedulerManagerRestartShardsArgs) GetShardIds 

func (p *AuroraSchedulerManagerRestartShardsArgs) GetShardIds() map[int32]bool

func (*AuroraSchedulerManagerRestartShardsArgs) IsSetJob 

func (p *AuroraSchedulerManagerRestartShardsArgs) IsSetJob() bool

func (*AuroraSchedulerManagerRestartShardsArgs) Read 

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

func (*AuroraSchedulerManagerRestartShardsArgs) String 

func (p *AuroraSchedulerManagerRestartShardsArgs) String() string

func (*AuroraSchedulerManagerRestartShardsArgs) Write 

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

type AuroraSchedulerManagerRestartShardsResult 

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

Attributes:

  • Success

func NewAuroraSchedulerManagerRestartShardsResult 

func NewAuroraSchedulerManagerRestartShardsResult() *AuroraSchedulerManagerRestartShardsResult

func (*AuroraSchedulerManagerRestartShardsResult) GetSuccess 

func (p *AuroraSchedulerManagerRestartShardsResult) GetSuccess() *Response

func (*AuroraSchedulerManagerRestartShardsResult) IsSetSuccess 

func (p *AuroraSchedulerManagerRestartShardsResult) IsSetSuccess() bool

func (*AuroraSchedulerManagerRestartShardsResult) Read 

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

func (*AuroraSchedulerManagerRestartShardsResult) String 

func (p *AuroraSchedulerManagerRestartShardsResult) String() string

func (*AuroraSchedulerManagerRestartShardsResult) Write 

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

type AuroraSchedulerManagerResumeJobUpdateArgs 

type AuroraSchedulerManagerResumeJobUpdateArgs struct {
	Key *JobUpdateKey `thrift:"key,1" json:"key"`
	// unused field # 2
	Message string `thrift:"message,3" 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 (p *AuroraSchedulerManagerResumeJobUpdateArgs) GetKey() *JobUpdateKey

func (*AuroraSchedulerManagerResumeJobUpdateArgs) GetMessage 

func (p *AuroraSchedulerManagerResumeJobUpdateArgs) GetMessage() string

func (*AuroraSchedulerManagerResumeJobUpdateArgs) IsSetKey 

func (p *AuroraSchedulerManagerResumeJobUpdateArgs) IsSetKey() bool

func (*AuroraSchedulerManagerResumeJobUpdateArgs) Read 

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

func (*AuroraSchedulerManagerResumeJobUpdateArgs) String 

func (p *AuroraSchedulerManagerResumeJobUpdateArgs) String() string

func (*AuroraSchedulerManagerResumeJobUpdateArgs) Write 

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

type AuroraSchedulerManagerResumeJobUpdateResult 

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

Attributes:

  • Success

func NewAuroraSchedulerManagerResumeJobUpdateResult 

func NewAuroraSchedulerManagerResumeJobUpdateResult() *AuroraSchedulerManagerResumeJobUpdateResult

func (*AuroraSchedulerManagerResumeJobUpdateResult) GetSuccess 

func (p *AuroraSchedulerManagerResumeJobUpdateResult) GetSuccess() *Response

func (*AuroraSchedulerManagerResumeJobUpdateResult) IsSetSuccess 

func (p *AuroraSchedulerManagerResumeJobUpdateResult) IsSetSuccess() bool

func (*AuroraSchedulerManagerResumeJobUpdateResult) Read 

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

func (*AuroraSchedulerManagerResumeJobUpdateResult) String 

func (p *AuroraSchedulerManagerResumeJobUpdateResult) String() string

func (*AuroraSchedulerManagerResumeJobUpdateResult) Write 

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

type AuroraSchedulerManagerRollbackJobUpdateArgs 

type AuroraSchedulerManagerRollbackJobUpdateArgs struct {
	Key     *JobUpdateKey `thrift:"key,1" json:"key"`
	Message string        `thrift:"message,2" 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 (p *AuroraSchedulerManagerRollbackJobUpdateArgs) GetKey() *JobUpdateKey

func (*AuroraSchedulerManagerRollbackJobUpdateArgs) GetMessage 

func (p *AuroraSchedulerManagerRollbackJobUpdateArgs) GetMessage() string

func (*AuroraSchedulerManagerRollbackJobUpdateArgs) IsSetKey 

func (p *AuroraSchedulerManagerRollbackJobUpdateArgs) IsSetKey() bool

func (*AuroraSchedulerManagerRollbackJobUpdateArgs) Read 

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

func (*AuroraSchedulerManagerRollbackJobUpdateArgs) String 

func (p *AuroraSchedulerManagerRollbackJobUpdateArgs) String() string

func (*AuroraSchedulerManagerRollbackJobUpdateArgs) Write 

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

type AuroraSchedulerManagerRollbackJobUpdateResult 

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

Attributes:

  • Success

func NewAuroraSchedulerManagerRollbackJobUpdateResult 

func NewAuroraSchedulerManagerRollbackJobUpdateResult() *AuroraSchedulerManagerRollbackJobUpdateResult

func (*AuroraSchedulerManagerRollbackJobUpdateResult) GetSuccess 

func (p *AuroraSchedulerManagerRollbackJobUpdateResult) GetSuccess() *Response

func (*AuroraSchedulerManagerRollbackJobUpdateResult) IsSetSuccess 

func (p *AuroraSchedulerManagerRollbackJobUpdateResult) IsSetSuccess() bool

func (*AuroraSchedulerManagerRollbackJobUpdateResult) Read 

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

func (*AuroraSchedulerManagerRollbackJobUpdateResult) String 

func (p *AuroraSchedulerManagerRollbackJobUpdateResult) String() string

func (*AuroraSchedulerManagerRollbackJobUpdateResult) Write 

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

type AuroraSchedulerManagerScheduleCronJobArgs 

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

Attributes:

  • Description

func NewAuroraSchedulerManagerScheduleCronJobArgs 

func NewAuroraSchedulerManagerScheduleCronJobArgs() *AuroraSchedulerManagerScheduleCronJobArgs

func (*AuroraSchedulerManagerScheduleCronJobArgs) GetDescription 

func (p *AuroraSchedulerManagerScheduleCronJobArgs) GetDescription() *JobConfiguration

func (*AuroraSchedulerManagerScheduleCronJobArgs) IsSetDescription 

func (p *AuroraSchedulerManagerScheduleCronJobArgs) IsSetDescription() bool

func (*AuroraSchedulerManagerScheduleCronJobArgs) Read 

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

func (*AuroraSchedulerManagerScheduleCronJobArgs) String 

func (p *AuroraSchedulerManagerScheduleCronJobArgs) String() string

func (*AuroraSchedulerManagerScheduleCronJobArgs) Write 

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

type AuroraSchedulerManagerScheduleCronJobResult 

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

Attributes:

  • Success

func NewAuroraSchedulerManagerScheduleCronJobResult 

func NewAuroraSchedulerManagerScheduleCronJobResult() *AuroraSchedulerManagerScheduleCronJobResult

func (*AuroraSchedulerManagerScheduleCronJobResult) GetSuccess 

func (p *AuroraSchedulerManagerScheduleCronJobResult) GetSuccess() *Response

func (*AuroraSchedulerManagerScheduleCronJobResult) IsSetSuccess 

func (p *AuroraSchedulerManagerScheduleCronJobResult) IsSetSuccess() bool

func (*AuroraSchedulerManagerScheduleCronJobResult) Read 

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

func (*AuroraSchedulerManagerScheduleCronJobResult) String 

func (p *AuroraSchedulerManagerScheduleCronJobResult) String() string

func (*AuroraSchedulerManagerScheduleCronJobResult) Write 

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

type AuroraSchedulerManagerStartCronJobArgs 

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

Attributes:

  • Job

func NewAuroraSchedulerManagerStartCronJobArgs 

func NewAuroraSchedulerManagerStartCronJobArgs() *AuroraSchedulerManagerStartCronJobArgs

func (*AuroraSchedulerManagerStartCronJobArgs) GetJob 

func (p *AuroraSchedulerManagerStartCronJobArgs) GetJob() *JobKey

func (*AuroraSchedulerManagerStartCronJobArgs) IsSetJob 

func (p *AuroraSchedulerManagerStartCronJobArgs) IsSetJob() bool

func (*AuroraSchedulerManagerStartCronJobArgs) Read 

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

func (*AuroraSchedulerManagerStartCronJobArgs) String 

func (p *AuroraSchedulerManagerStartCronJobArgs) String() string

func (*AuroraSchedulerManagerStartCronJobArgs) Write 

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

type AuroraSchedulerManagerStartCronJobResult 

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

Attributes:

  • Success

func NewAuroraSchedulerManagerStartCronJobResult 

func NewAuroraSchedulerManagerStartCronJobResult() *AuroraSchedulerManagerStartCronJobResult

func (*AuroraSchedulerManagerStartCronJobResult) GetSuccess 

func (p *AuroraSchedulerManagerStartCronJobResult) GetSuccess() *Response

func (*AuroraSchedulerManagerStartCronJobResult) IsSetSuccess 

func (p *AuroraSchedulerManagerStartCronJobResult) IsSetSuccess() bool

func (*AuroraSchedulerManagerStartCronJobResult) Read 

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

func (*AuroraSchedulerManagerStartCronJobResult) String 

func (p *AuroraSchedulerManagerStartCronJobResult) String() string

func (*AuroraSchedulerManagerStartCronJobResult) Write 

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

type AuroraSchedulerManagerStartJobUpdateArgs 

type AuroraSchedulerManagerStartJobUpdateArgs struct {
	Request *JobUpdateRequest `thrift:"request,1" json:"request"`
	// unused field # 2
	Message string `thrift:"message,3" 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 (p *AuroraSchedulerManagerStartJobUpdateArgs) GetMessage() string

func (*AuroraSchedulerManagerStartJobUpdateArgs) GetRequest 

func (p *AuroraSchedulerManagerStartJobUpdateArgs) GetRequest() *JobUpdateRequest

func (*AuroraSchedulerManagerStartJobUpdateArgs) IsSetRequest 

func (p *AuroraSchedulerManagerStartJobUpdateArgs) IsSetRequest() bool

func (*AuroraSchedulerManagerStartJobUpdateArgs) Read 

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

func (*AuroraSchedulerManagerStartJobUpdateArgs) String 

func (p *AuroraSchedulerManagerStartJobUpdateArgs) String() string

func (*AuroraSchedulerManagerStartJobUpdateArgs) Write 

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

type AuroraSchedulerManagerStartJobUpdateResult 

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

Attributes:

  • Success

func NewAuroraSchedulerManagerStartJobUpdateResult 

func NewAuroraSchedulerManagerStartJobUpdateResult() *AuroraSchedulerManagerStartJobUpdateResult

func (*AuroraSchedulerManagerStartJobUpdateResult) GetSuccess 

func (p *AuroraSchedulerManagerStartJobUpdateResult) GetSuccess() *Response

func (*AuroraSchedulerManagerStartJobUpdateResult) IsSetSuccess 

func (p *AuroraSchedulerManagerStartJobUpdateResult) IsSetSuccess() bool

func (*AuroraSchedulerManagerStartJobUpdateResult) Read 

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

func (*AuroraSchedulerManagerStartJobUpdateResult) String 

func (p *AuroraSchedulerManagerStartJobUpdateResult) String() string

func (*AuroraSchedulerManagerStartJobUpdateResult) Write 

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

type ConfigGroup 

type ConfigGroup struct {
	Config *TaskConfig `thrift:"config,1" json:"config"`
	// unused field # 2
	Instances map[*Range]bool `thrift:"instances,3" 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() map[*Range]bool

func (*ConfigGroup) IsSetConfig 

func (p *ConfigGroup) IsSetConfig() bool

func (*ConfigGroup) Read 

func (p *ConfigGroup) Read(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" json:"key"`
	Groups map[*ConfigGroup]bool `thrift:"groups,2" json:"groups"`
}

Attributes:

  • Key
  • Groups
var ConfigSummaryResult__Summary_DEFAULT *ConfigSummary

func NewConfigSummary 

func NewConfigSummary() *ConfigSummary

func (*ConfigSummary) GetGroups 

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

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) 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" 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_) 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" json:"name"`
	Constraint *TaskConstraint `thrift:"constraint,2" 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) 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" json:"mesos,omitempty"`
	Docker *DockerContainer `thrift:"docker,2" 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) String 

func (p *Container) String() string

func (*Container) Write 

func (p *Container) 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) String 

func (p CronCollisionPolicy) String() string

func (*CronCollisionPolicy) UnmarshalText 

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

type DockerContainer 

type DockerContainer struct {
	Image      string             `thrift:"image,1" json:"image"`
	Parameters []*DockerParameter `thrift:"parameters,2" 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) 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" json:"name"`
	Tag  string `thrift:"tag,2" 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) 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" json:"name"`
	Value string `thrift:"value,2" 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) String 

func (p *DockerParameter) String() string

func (*DockerParameter) Write 

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

type DrainHostsResult_ 

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

Attributes:

  • Statuses
var Result__DrainHostsResult__DEFAULT *DrainHostsResult_

func NewDrainHostsResult_ 

func NewDrainHostsResult_() *DrainHostsResult_

func (*DrainHostsResult_) GetStatuses 

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

func (*DrainHostsResult_) Read 

func (p *DrainHostsResult_) Read(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 map[*HostStatus]bool `thrift:"statuses,1" json:"statuses"`
}

Attributes:

  • Statuses
var Result__EndMaintenanceResult__DEFAULT *EndMaintenanceResult_

func NewEndMaintenanceResult_ 

func NewEndMaintenanceResult_() *EndMaintenanceResult_

func (*EndMaintenanceResult_) GetStatuses 

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

func (*EndMaintenanceResult_) Read 

func (p *EndMaintenanceResult_) Read(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" json:"name"`
	Data string `thrift:"data,2" 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) 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" 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 (p *ExplicitReconciliationSettings) Read(iprot thrift.TProtocol) error

func (*ExplicitReconciliationSettings) String 

func (p *ExplicitReconciliationSettings) String() string

func (*ExplicitReconciliationSettings) Write 

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

type GetJobUpdateDetailsResult_ 

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

Result of the getJobUpdateDetails call.

Attributes:

  • Details
  • DetailsList
var Result__GetJobUpdateDetailsResult__DEFAULT *GetJobUpdateDetailsResult_

func NewGetJobUpdateDetailsResult_ 

func NewGetJobUpdateDetailsResult_() *GetJobUpdateDetailsResult_

func (*GetJobUpdateDetailsResult_) GetDetails 

func (p *GetJobUpdateDetailsResult_) GetDetails() *JobUpdateDetails

func (*GetJobUpdateDetailsResult_) GetDetailsList 

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

func (*GetJobUpdateDetailsResult_) IsSetDetails 

func (p *GetJobUpdateDetailsResult_) IsSetDetails() bool

func (*GetJobUpdateDetailsResult_) Read 

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

func (*GetJobUpdateDetailsResult_) String 

func (p *GetJobUpdateDetailsResult_) String() string

func (*GetJobUpdateDetailsResult_) Write 

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

type GetJobUpdateDiffResult_ 

type GetJobUpdateDiffResult_ struct {
	Add       map[*ConfigGroup]bool `thrift:"add,1" json:"add"`
	Remove    map[*ConfigGroup]bool `thrift:"remove,2" json:"remove"`
	Update    map[*ConfigGroup]bool `thrift:"update,3" json:"update"`
	Unchanged map[*ConfigGroup]bool `thrift:"unchanged,4" 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() map[*ConfigGroup]bool

func (*GetJobUpdateDiffResult_) GetRemove 

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

func (*GetJobUpdateDiffResult_) GetUnchanged 

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

func (*GetJobUpdateDiffResult_) GetUpdate 

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

func (*GetJobUpdateDiffResult_) Read 

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

func (*GetJobUpdateDiffResult_) String 

func (p *GetJobUpdateDiffResult_) String() string

func (*GetJobUpdateDiffResult_) Write 

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

type GetJobUpdateSummariesResult_ 

type GetJobUpdateSummariesResult_ struct {
	UpdateSummaries []*JobUpdateSummary `thrift:"updateSummaries,1" 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 (p *GetJobUpdateSummariesResult_) Read(iprot thrift.TProtocol) error

func (*GetJobUpdateSummariesResult_) String 

func (p *GetJobUpdateSummariesResult_) String() string

func (*GetJobUpdateSummariesResult_) Write 

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

type GetJobsResult_ 

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

Attributes:

  • Configs
var Result__GetJobsResult__DEFAULT *GetJobsResult_

func NewGetJobsResult_ 

func NewGetJobsResult_() *GetJobsResult_

func (*GetJobsResult_) GetConfigs 

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

func (*GetJobsResult_) Read 

func (p *GetJobsResult_) Read(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 map[*PendingReason]bool `thrift:"reasons,1" json:"reasons"`
}

Attributes:

  • Reasons
var Result__GetPendingReasonResult__DEFAULT *GetPendingReasonResult_

func NewGetPendingReasonResult_ 

func NewGetPendingReasonResult_() *GetPendingReasonResult_

func (*GetPendingReasonResult_) GetReasons 

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

func (*GetPendingReasonResult_) Read 

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

func (*GetPendingReasonResult_) String 

func (p *GetPendingReasonResult_) String() string

func (*GetPendingReasonResult_) Write 

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

type GetQuotaResult_ 

type GetQuotaResult_ struct {
	Quota                       *ResourceAggregate `thrift:"quota,1" json:"quota"`
	ProdSharedConsumption       *ResourceAggregate `thrift:"prodSharedConsumption,2" json:"prodSharedConsumption,omitempty"`
	NonProdSharedConsumption    *ResourceAggregate `thrift:"nonProdSharedConsumption,3" json:"nonProdSharedConsumption,omitempty"`
	ProdDedicatedConsumption    *ResourceAggregate `thrift:"prodDedicatedConsumption,4" json:"prodDedicatedConsumption,omitempty"`
	NonProdDedicatedConsumption *ResourceAggregate `thrift:"nonProdDedicatedConsumption,5" 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_) 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" json:"defaultTierName"`
	Tiers           map[*TierConfig]bool `thrift:"tiers,2" 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() map[*TierConfig]bool

func (*GetTierConfigResult_) Read 

func (p *GetTierConfigResult_) Read(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" json:"host"`
	Attributes map[*Attribute]bool `thrift:"attributes,2" json:"attributes"`
	Mode       *MaintenanceMode    `thrift:"mode,3" json:"mode,omitempty"`
	SlaveId    *string             `thrift:"slaveId,4" 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() map[*Attribute]bool

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) String 

func (p *HostAttributes) String() string

func (*HostAttributes) Write 

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

type HostStatus 

type HostStatus struct {
	Host string          `thrift:"host,1" json:"host"`
	Mode MaintenanceMode `thrift:"mode,2" 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) String 

func (p *HostStatus) String() string

func (*HostStatus) Write 

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

type Hosts 

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

Attributes:

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

func NewHosts 

func NewHosts() *Hosts

func (*Hosts) GetHostNames 

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

func (*Hosts) Read 

func (p *Hosts) Read(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" 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) 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" json:"docker,omitempty"`
	Appc   *AppcImage   `thrift:"appc,2" 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) 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" json:"jobKey"`
	InstanceId int32   `thrift:"instanceId,2" 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) 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" json:"task"`
	Instances map[*Range]bool `thrift:"instances,2" 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() map[*Range]bool

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) 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" json:"cronSchedule,omitempty"`
	CronCollisionPolicy CronCollisionPolicy `thrift:"cronCollisionPolicy,5" json:"cronCollisionPolicy"`
	TaskConfig          *TaskConfig         `thrift:"taskConfig,6" json:"taskConfig"`
	Owner               *Identity           `thrift:"owner,7" json:"owner"`
	InstanceCount       int32               `thrift:"instanceCount,8" json:"instanceCount"`
	Key                 *JobKey             `thrift:"key,9" 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) 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" json:"instanceId"`
	TimestampMs int64           `thrift:"timestampMs,2" json:"timestampMs"`
	Action      JobUpdateAction `thrift:"action,3" json:"action"`
}

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.

func NewJobInstanceUpdateEvent 

func NewJobInstanceUpdateEvent() *JobInstanceUpdateEvent

func (*JobInstanceUpdateEvent) GetAction 

func (p *JobInstanceUpdateEvent) GetAction() JobUpdateAction

func (*JobInstanceUpdateEvent) GetInstanceId 

func (p *JobInstanceUpdateEvent) GetInstanceId() int32

func (*JobInstanceUpdateEvent) GetTimestampMs 

func (p *JobInstanceUpdateEvent) GetTimestampMs() int64

func (*JobInstanceUpdateEvent) Read 

func (p *JobInstanceUpdateEvent) Read(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" json:"role"`
	Environment string `thrift:"environment,2" json:"environment"`
	Name        string `thrift:"name,3" 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) 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" json:"activeTaskCount"`
	FinishedTaskCount int32 `thrift:"finishedTaskCount,2" json:"finishedTaskCount"`
	FailedTaskCount   int32 `thrift:"failedTaskCount,3" json:"failedTaskCount"`
	PendingTaskCount  int32 `thrift:"pendingTaskCount,4" 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) 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" json:"job"`
	Stats         *JobStats         `thrift:"stats,2" json:"stats"`
	NextCronRunMs *int64            `thrift:"nextCronRunMs,3" 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) String 

func (p *JobSummary) String() string

func (*JobSummary) Write 

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

type JobSummaryResult_ 

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

Attributes:

  • Summaries
var Result__JobSummaryResult__DEFAULT *JobSummaryResult_

func NewJobSummaryResult_ 

func NewJobSummaryResult_() *JobSummaryResult_

func (*JobSummaryResult_) GetSummaries 

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

func (*JobSummaryResult_) Read 

func (p *JobSummaryResult_) Read(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" json:"summary"`
	Instructions *JobUpdateInstructions `thrift:"instructions,2" 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) 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) String 

func (p JobUpdateAction) String() string

func (*JobUpdateAction) UnmarshalText 

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

type JobUpdateDetails 

type JobUpdateDetails struct {
	Update         *JobUpdate                `thrift:"update,1" json:"update"`
	UpdateEvents   []*JobUpdateEvent         `thrift:"updateEvents,2" json:"updateEvents"`
	InstanceEvents []*JobInstanceUpdateEvent `thrift:"instanceEvents,3" 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) 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" json:"status"`
	TimestampMs int64           `thrift:"timestampMs,2" json:"timestampMs"`
	User        *string         `thrift:"user,3" json:"user,omitempty"`
	Message     *string         `thrift:"message,4" 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) String 

func (p *JobUpdateEvent) String() string

func (*JobUpdateEvent) Write 

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

type JobUpdateInstructions 

type JobUpdateInstructions struct {
	InitialState map[*InstanceTaskConfig]bool `thrift:"initialState,1" json:"initialState"`
	DesiredState *InstanceTaskConfig          `thrift:"desiredState,2" json:"desiredState"`
	Settings     *JobUpdateSettings           `thrift:"settings,3" 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() map[*InstanceTaskConfig]bool

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 (p *JobUpdateInstructions) Read(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" json:"job"`
	ID  string  `thrift:"id,2" 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) 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 JobUpdatePulseStatusPtr 

func JobUpdatePulseStatusPtr(v JobUpdatePulseStatus) *JobUpdatePulseStatus

func (JobUpdatePulseStatus) MarshalText 

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

func (JobUpdatePulseStatus) String 

func (p JobUpdatePulseStatus) String() string

func (*JobUpdatePulseStatus) UnmarshalText 

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

type JobUpdateQuery 

type JobUpdateQuery struct {
	// unused field # 1
	Role           *string                  `thrift:"role,2" json:"role,omitempty"`
	JobKey         *JobKey                  `thrift:"jobKey,3" json:"jobKey,omitempty"`
	User           *string                  `thrift:"user,4" json:"user,omitempty"`
	UpdateStatuses map[JobUpdateStatus]bool `thrift:"updateStatuses,5" json:"updateStatuses,omitempty"`
	Offset         int32                    `thrift:"offset,6" json:"offset"`
	Limit          int32                    `thrift:"limit,7" json:"limit"`
	Key            *JobUpdateKey            `thrift:"key,8" 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() map[JobUpdateStatus]bool

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) 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" json:"taskConfig"`
	InstanceCount int32              `thrift:"instanceCount,2" json:"instanceCount"`
	Settings      *JobUpdateSettings `thrift:"settings,3" json:"settings"`
	Metadata      map[*Metadata]bool `thrift:"metadata,4" 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() map[*Metadata]bool

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) 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" json:"updateGroupSize"`
	MaxPerInstanceFailures int32 `thrift:"maxPerInstanceFailures,2" json:"maxPerInstanceFailures"`
	MaxFailedInstances     int32 `thrift:"maxFailedInstances,3" json:"maxFailedInstances"`
	// unused field # 4
	MinWaitInInstanceRunningMs int32           `thrift:"minWaitInInstanceRunningMs,5" json:"minWaitInInstanceRunningMs"`
	RollbackOnFailure          bool            `thrift:"rollbackOnFailure,6" json:"rollbackOnFailure"`
	UpdateOnlyTheseInstances   map[*Range]bool `thrift:"updateOnlyTheseInstances,7" json:"updateOnlyTheseInstances"`
	WaitForBatchCompletion     bool            `thrift:"waitForBatchCompletion,8" json:"waitForBatchCompletion"`
	BlockIfNoPulsesAfterMs     *int32          `thrift:"blockIfNoPulsesAfterMs,9" json:"blockIfNoPulsesAfterMs,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. 

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) GetUpdateGroupSize 

func (p *JobUpdateSettings) GetUpdateGroupSize() int32

func (*JobUpdateSettings) GetUpdateOnlyTheseInstances 

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

func (*JobUpdateSettings) GetWaitForBatchCompletion 

func (p *JobUpdateSettings) GetWaitForBatchCompletion() bool

func (*JobUpdateSettings) IsSetBlockIfNoPulsesAfterMs 

func (p *JobUpdateSettings) IsSetBlockIfNoPulsesAfterMs() bool

func (*JobUpdateSettings) Read 

func (p *JobUpdateSettings) Read(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" json:"status"`
	CreatedTimestampMs      int64           `thrift:"createdTimestampMs,2" json:"createdTimestampMs"`
	LastModifiedTimestampMs int64           `thrift:"lastModifiedTimestampMs,3" 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) 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) String 

func (p JobUpdateStatus) String() string

func (*JobUpdateStatus) UnmarshalText 

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

type JobUpdateSummary 

type JobUpdateSummary struct {
	// unused fields # 1 to 2
	User     string             `thrift:"user,3" json:"user"`
	State    *JobUpdateState    `thrift:"state,4" json:"state"`
	Key      *JobUpdateKey      `thrift:"key,5" json:"key"`
	Metadata map[*Metadata]bool `thrift:"metadata,6" 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() map[*Metadata]bool

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) 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" 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) String 

func (p *LimitConstraint) String() string

func (*LimitConstraint) Write 

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

type ListBackupsResult_ 

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

Attributes:

  • Backups
var Result__ListBackupsResult__DEFAULT *ListBackupsResult_

func NewListBackupsResult_ 

func NewListBackupsResult_() *ListBackupsResult_

func (*ListBackupsResult_) GetBackups 

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

func (*ListBackupsResult_) Read 

func (p *ListBackupsResult_) Read(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" json:"key"`
	Token       string   `thrift:"token,2" json:"token"`
	User        string   `thrift:"user,3" json:"user"`
	TimestampMs int64    `thrift:"timestampMs,4" json:"timestampMs"`
	Message     *string  `thrift:"message,5" 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) 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" 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) 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) String 

func (p MaintenanceMode) String() string

func (*MaintenanceMode) UnmarshalText 

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

type MaintenanceStatusResult_ 

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

Attributes:

  • Statuses
var Result__MaintenanceStatusResult__DEFAULT *MaintenanceStatusResult_

func NewMaintenanceStatusResult_ 

func NewMaintenanceStatusResult_() *MaintenanceStatusResult_

func (*MaintenanceStatusResult_) GetStatuses 

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

func (*MaintenanceStatusResult_) Read 

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

func (*MaintenanceStatusResult_) String 

func (p *MaintenanceStatusResult_) String() string

func (*MaintenanceStatusResult_) Write 

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

type MesosContainer 

type MesosContainer struct {
	Image   *Image    `thrift:"image,1" json:"image,omitempty"`
	Volumes []*Volume `thrift:"volumes,2" 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) 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" json:"value"`
	Extract *bool  `thrift:"extract,2" json:"extract,omitempty"`
	Cache   *bool  `thrift:"cache,3" 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) 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" json:"key"`
	Value string `thrift:"value,2" 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) 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) String 

func (p Mode) String() string

func (*Mode) UnmarshalText 

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

type Package 

type Package struct {
	Role    string `thrift:"role,1" json:"role"`
	Name    string `thrift:"name,2" json:"name"`
	Version int32  `thrift:"version,3" 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) String 

func (p *Package) String() string

func (*Package) Write 

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

type PendingReason 

type PendingReason struct {
	TaskId string `thrift:"taskId,1" json:"taskId"`
	Reason string `thrift:"reason,2" 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) String 

func (p *PendingReason) String() string

func (*PendingReason) Write 

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

type PopulateJobResult_ 

type PopulateJobResult_ struct {
	// unused field # 1
	TaskConfig *TaskConfig `thrift:"taskConfig,2" 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_) 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" json:"status"`
}

Result of the pulseJobUpdate call.

Attributes:

  • Status
var Result__PulseJobUpdateResult__DEFAULT *PulseJobUpdateResult_

func NewPulseJobUpdateResult_ 

func NewPulseJobUpdateResult_() *PulseJobUpdateResult_

func (*PulseJobUpdateResult_) GetStatus 

func (p *PulseJobUpdateResult_) GetStatus() JobUpdatePulseStatus

func (*PulseJobUpdateResult_) Read 

func (p *PulseJobUpdateResult_) Read(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 map[*ScheduledTask]bool `thrift:"tasks,1" json:"tasks"`
}

Attributes:

  • Tasks
var Result__QueryRecoveryResult__DEFAULT *QueryRecoveryResult_

func NewQueryRecoveryResult_ 

func NewQueryRecoveryResult_() *QueryRecoveryResult_

func (*QueryRecoveryResult_) GetTasks 

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

func (*QueryRecoveryResult_) Read 

func (p *QueryRecoveryResult_) Read(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" json:"first"`
	Last  int32 `thrift:"last,2" 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) 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() (r *Response, err error)
	// Returns a summary of jobs, optionally only those owned by a specific role.
	//
	// Parameters:
	//  - Role
	GetJobSummary(role string) (r *Response, err error)
	// Fetches the status of tasks.
	//
	// Parameters:
	//  - Query
	GetTasksStatus(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(query *TaskQuery) (r *Response, err error)
	// Returns user-friendly reasons (if available) for tasks retained in PENDING state.
	//
	// Parameters:
	//  - Query
	GetPendingReason(query *TaskQuery) (r *Response, err error)
	// Fetches the configuration summary of active tasks for the specified job.
	//
	// Parameters:
	//  - Job
	GetConfigSummary(job *JobKey) (r *Response, err error)
	// Fetches the status of jobs.
	// ownerRole is optional, in which case all jobs are returned.
	//
	// Parameters:
	//  - OwnerRole
	GetJobs(ownerRole string) (r *Response, err error)
	// Fetches the quota allocated for a user.
	//
	// Parameters:
	//  - OwnerRole
	GetQuota(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(description *JobConfiguration) (r *Response, err error)
	// Gets job update summaries.
	//
	// Parameters:
	//  - JobUpdateQuery
	GetJobUpdateSummaries(jobUpdateQuery *JobUpdateQuery) (r *Response, err error)
	// Gets job update details.
	//
	// Parameters:
	//  - Query
	GetJobUpdateDetails(query *JobUpdateQuery) (r *Response, err error)
	// Gets the diff between client (desired) and server (current) job states.
	//
	// Parameters:
	//  - Request
	GetJobUpdateDiff(request *JobUpdateRequest) (r *Response, err error)
	// Gets tier configurations.
	GetTierConfigs() (r *Response, err error)
}

type ReadOnlySchedulerClient 

type ReadOnlySchedulerClient struct {
	Transport       thrift.TTransport
	ProtocolFactory thrift.TProtocolFactory
	InputProtocol   thrift.TProtocol
	OutputProtocol  thrift.TProtocol
	SeqId           int32
}

func NewReadOnlySchedulerClientFactory 

func NewReadOnlySchedulerClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *ReadOnlySchedulerClient

func NewReadOnlySchedulerClientProtocol 

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

func (*ReadOnlySchedulerClient) GetConfigSummary 

func (p *ReadOnlySchedulerClient) GetConfigSummary(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(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(query *JobUpdateQuery) (r *Response, err error)

Gets job update details.

Parameters:

  • Query

func (*ReadOnlySchedulerClient) GetJobUpdateDiff 

func (p *ReadOnlySchedulerClient) GetJobUpdateDiff(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(jobUpdateQuery *JobUpdateQuery) (r *Response, err error)

Gets job update summaries.

Parameters:

  • JobUpdateQuery

func (*ReadOnlySchedulerClient) GetJobs 

func (p *ReadOnlySchedulerClient) GetJobs(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(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(ownerRole string) (r *Response, err error)

Fetches the quota allocated for a user.

Parameters:

  • OwnerRole

func (*ReadOnlySchedulerClient) GetRoleSummary 

func (p *ReadOnlySchedulerClient) GetRoleSummary() (r *Response, err error)

Returns a summary of the jobs grouped by role.

func (*ReadOnlySchedulerClient) GetTasksStatus 

func (p *ReadOnlySchedulerClient) GetTasksStatus(query *TaskQuery) (r *Response, err error)

Fetches the status of tasks.

Parameters:

  • Query

func (*ReadOnlySchedulerClient) GetTasksWithoutConfigs 

func (p *ReadOnlySchedulerClient) GetTasksWithoutConfigs(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() (r *Response, err error)

Gets tier configurations.

func (*ReadOnlySchedulerClient) PopulateJobConfig 

func (p *ReadOnlySchedulerClient) PopulateJobConfig(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" json:"job"`
}

Attributes:

  • Job

func NewReadOnlySchedulerGetConfigSummaryArgs 

func NewReadOnlySchedulerGetConfigSummaryArgs() *ReadOnlySchedulerGetConfigSummaryArgs

func (*ReadOnlySchedulerGetConfigSummaryArgs) GetJob 

func (p *ReadOnlySchedulerGetConfigSummaryArgs) GetJob() *JobKey

func (*ReadOnlySchedulerGetConfigSummaryArgs) IsSetJob 

func (p *ReadOnlySchedulerGetConfigSummaryArgs) IsSetJob() bool

func (*ReadOnlySchedulerGetConfigSummaryArgs) Read 

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

func (*ReadOnlySchedulerGetConfigSummaryArgs) String 

func (p *ReadOnlySchedulerGetConfigSummaryArgs) String() string

func (*ReadOnlySchedulerGetConfigSummaryArgs) Write 

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

type ReadOnlySchedulerGetConfigSummaryResult 

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

Attributes:

  • Success

func NewReadOnlySchedulerGetConfigSummaryResult 

func NewReadOnlySchedulerGetConfigSummaryResult() *ReadOnlySchedulerGetConfigSummaryResult

func (*ReadOnlySchedulerGetConfigSummaryResult) GetSuccess 

func (p *ReadOnlySchedulerGetConfigSummaryResult) GetSuccess() *Response

func (*ReadOnlySchedulerGetConfigSummaryResult) IsSetSuccess 

func (p *ReadOnlySchedulerGetConfigSummaryResult) IsSetSuccess() bool

func (*ReadOnlySchedulerGetConfigSummaryResult) Read 

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

func (*ReadOnlySchedulerGetConfigSummaryResult) String 

func (p *ReadOnlySchedulerGetConfigSummaryResult) String() string

func (*ReadOnlySchedulerGetConfigSummaryResult) Write 

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

type ReadOnlySchedulerGetJobSummaryArgs 

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

Attributes:

  • Role

func NewReadOnlySchedulerGetJobSummaryArgs 

func NewReadOnlySchedulerGetJobSummaryArgs() *ReadOnlySchedulerGetJobSummaryArgs

func (*ReadOnlySchedulerGetJobSummaryArgs) GetRole 

func (p *ReadOnlySchedulerGetJobSummaryArgs) GetRole() string

func (*ReadOnlySchedulerGetJobSummaryArgs) Read 

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

func (*ReadOnlySchedulerGetJobSummaryArgs) String 

func (p *ReadOnlySchedulerGetJobSummaryArgs) String() string

func (*ReadOnlySchedulerGetJobSummaryArgs) Write 

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

type ReadOnlySchedulerGetJobSummaryResult 

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

Attributes:

  • Success

func NewReadOnlySchedulerGetJobSummaryResult 

func NewReadOnlySchedulerGetJobSummaryResult() *ReadOnlySchedulerGetJobSummaryResult

func (*ReadOnlySchedulerGetJobSummaryResult) GetSuccess 

func (p *ReadOnlySchedulerGetJobSummaryResult) GetSuccess() *Response

func (*ReadOnlySchedulerGetJobSummaryResult) IsSetSuccess 

func (p *ReadOnlySchedulerGetJobSummaryResult) IsSetSuccess() bool

func (*ReadOnlySchedulerGetJobSummaryResult) Read 

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

func (*ReadOnlySchedulerGetJobSummaryResult) String 

func (p *ReadOnlySchedulerGetJobSummaryResult) String() string

func (*ReadOnlySchedulerGetJobSummaryResult) Write 

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

type ReadOnlySchedulerGetJobUpdateDetailsArgs 

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

Attributes:

  • Query

func NewReadOnlySchedulerGetJobUpdateDetailsArgs 

func NewReadOnlySchedulerGetJobUpdateDetailsArgs() *ReadOnlySchedulerGetJobUpdateDetailsArgs

func (*ReadOnlySchedulerGetJobUpdateDetailsArgs) GetQuery 

func (p *ReadOnlySchedulerGetJobUpdateDetailsArgs) GetQuery() *JobUpdateQuery

func (*ReadOnlySchedulerGetJobUpdateDetailsArgs) IsSetQuery 

func (p *ReadOnlySchedulerGetJobUpdateDetailsArgs) IsSetQuery() bool

func (*ReadOnlySchedulerGetJobUpdateDetailsArgs) Read 

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

func (*ReadOnlySchedulerGetJobUpdateDetailsArgs) String 

func (p *ReadOnlySchedulerGetJobUpdateDetailsArgs) String() string

func (*ReadOnlySchedulerGetJobUpdateDetailsArgs) Write 

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

type ReadOnlySchedulerGetJobUpdateDetailsResult 

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

Attributes:

  • Success

func NewReadOnlySchedulerGetJobUpdateDetailsResult 

func NewReadOnlySchedulerGetJobUpdateDetailsResult() *ReadOnlySchedulerGetJobUpdateDetailsResult

func (*ReadOnlySchedulerGetJobUpdateDetailsResult) GetSuccess 

func (p *ReadOnlySchedulerGetJobUpdateDetailsResult) GetSuccess() *Response

func (*ReadOnlySchedulerGetJobUpdateDetailsResult) IsSetSuccess 

func (p *ReadOnlySchedulerGetJobUpdateDetailsResult) IsSetSuccess() bool

func (*ReadOnlySchedulerGetJobUpdateDetailsResult) Read 

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

func (*ReadOnlySchedulerGetJobUpdateDetailsResult) String 

func (p *ReadOnlySchedulerGetJobUpdateDetailsResult) String() string

func (*ReadOnlySchedulerGetJobUpdateDetailsResult) Write 

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

type ReadOnlySchedulerGetJobUpdateDiffArgs 

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

Attributes:

  • Request

func NewReadOnlySchedulerGetJobUpdateDiffArgs 

func NewReadOnlySchedulerGetJobUpdateDiffArgs() *ReadOnlySchedulerGetJobUpdateDiffArgs

func (*ReadOnlySchedulerGetJobUpdateDiffArgs) GetRequest 

func (p *ReadOnlySchedulerGetJobUpdateDiffArgs) GetRequest() *JobUpdateRequest

func (*ReadOnlySchedulerGetJobUpdateDiffArgs) IsSetRequest 

func (p *ReadOnlySchedulerGetJobUpdateDiffArgs) IsSetRequest() bool

func (*ReadOnlySchedulerGetJobUpdateDiffArgs) Read 

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

func (*ReadOnlySchedulerGetJobUpdateDiffArgs) String 

func (p *ReadOnlySchedulerGetJobUpdateDiffArgs) String() string

func (*ReadOnlySchedulerGetJobUpdateDiffArgs) Write 

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

type ReadOnlySchedulerGetJobUpdateDiffResult 

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

Attributes:

  • Success

func NewReadOnlySchedulerGetJobUpdateDiffResult 

func NewReadOnlySchedulerGetJobUpdateDiffResult() *ReadOnlySchedulerGetJobUpdateDiffResult

func (*ReadOnlySchedulerGetJobUpdateDiffResult) GetSuccess 

func (p *ReadOnlySchedulerGetJobUpdateDiffResult) GetSuccess() *Response

func (*ReadOnlySchedulerGetJobUpdateDiffResult) IsSetSuccess 

func (p *ReadOnlySchedulerGetJobUpdateDiffResult) IsSetSuccess() bool

func (*ReadOnlySchedulerGetJobUpdateDiffResult) Read 

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

func (*ReadOnlySchedulerGetJobUpdateDiffResult) String 

func (p *ReadOnlySchedulerGetJobUpdateDiffResult) String() string

func (*ReadOnlySchedulerGetJobUpdateDiffResult) Write 

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

type ReadOnlySchedulerGetJobUpdateSummariesArgs 

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

Attributes:

  • JobUpdateQuery

func NewReadOnlySchedulerGetJobUpdateSummariesArgs 

func NewReadOnlySchedulerGetJobUpdateSummariesArgs() *ReadOnlySchedulerGetJobUpdateSummariesArgs

func (*ReadOnlySchedulerGetJobUpdateSummariesArgs) GetJobUpdateQuery 

func (p *ReadOnlySchedulerGetJobUpdateSummariesArgs) GetJobUpdateQuery() *JobUpdateQuery

func (*ReadOnlySchedulerGetJobUpdateSummariesArgs) IsSetJobUpdateQuery 

func (p *ReadOnlySchedulerGetJobUpdateSummariesArgs) IsSetJobUpdateQuery() bool

func (*ReadOnlySchedulerGetJobUpdateSummariesArgs) Read 

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

func (*ReadOnlySchedulerGetJobUpdateSummariesArgs) String 

func (p *ReadOnlySchedulerGetJobUpdateSummariesArgs) String() string

func (*ReadOnlySchedulerGetJobUpdateSummariesArgs) Write 

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

type ReadOnlySchedulerGetJobUpdateSummariesResult 

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

Attributes:

  • Success

func NewReadOnlySchedulerGetJobUpdateSummariesResult 

func NewReadOnlySchedulerGetJobUpdateSummariesResult() *ReadOnlySchedulerGetJobUpdateSummariesResult

func (*ReadOnlySchedulerGetJobUpdateSummariesResult) GetSuccess 

func (p *ReadOnlySchedulerGetJobUpdateSummariesResult) GetSuccess() *Response

func (*ReadOnlySchedulerGetJobUpdateSummariesResult) IsSetSuccess 

func (p *ReadOnlySchedulerGetJobUpdateSummariesResult) IsSetSuccess() bool

func (*ReadOnlySchedulerGetJobUpdateSummariesResult) Read 

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

func (*ReadOnlySchedulerGetJobUpdateSummariesResult) String 

func (p *ReadOnlySchedulerGetJobUpdateSummariesResult) String() string

func (*ReadOnlySchedulerGetJobUpdateSummariesResult) Write 

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

type ReadOnlySchedulerGetJobsArgs 

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

Attributes:

  • OwnerRole

func NewReadOnlySchedulerGetJobsArgs 

func NewReadOnlySchedulerGetJobsArgs() *ReadOnlySchedulerGetJobsArgs

func (*ReadOnlySchedulerGetJobsArgs) GetOwnerRole 

func (p *ReadOnlySchedulerGetJobsArgs) GetOwnerRole() string

func (*ReadOnlySchedulerGetJobsArgs) Read 

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

func (*ReadOnlySchedulerGetJobsArgs) String 

func (p *ReadOnlySchedulerGetJobsArgs) String() string

func (*ReadOnlySchedulerGetJobsArgs) Write 

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

type ReadOnlySchedulerGetJobsResult 

type ReadOnlySchedulerGetJobsResult struct {
	Success *Response `thrift:"success,0" 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 (p *ReadOnlySchedulerGetJobsResult) Read(iprot thrift.TProtocol) error

func (*ReadOnlySchedulerGetJobsResult) String 

func (p *ReadOnlySchedulerGetJobsResult) String() string

func (*ReadOnlySchedulerGetJobsResult) Write 

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

type ReadOnlySchedulerGetPendingReasonArgs 

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

Attributes:

  • Query

func NewReadOnlySchedulerGetPendingReasonArgs 

func NewReadOnlySchedulerGetPendingReasonArgs() *ReadOnlySchedulerGetPendingReasonArgs

func (*ReadOnlySchedulerGetPendingReasonArgs) GetQuery 

func (p *ReadOnlySchedulerGetPendingReasonArgs) GetQuery() *TaskQuery

func (*ReadOnlySchedulerGetPendingReasonArgs) IsSetQuery 

func (p *ReadOnlySchedulerGetPendingReasonArgs) IsSetQuery() bool

func (*ReadOnlySchedulerGetPendingReasonArgs) Read 

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

func (*ReadOnlySchedulerGetPendingReasonArgs) String 

func (p *ReadOnlySchedulerGetPendingReasonArgs) String() string

func (*ReadOnlySchedulerGetPendingReasonArgs) Write 

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

type ReadOnlySchedulerGetPendingReasonResult 

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

Attributes:

  • Success

func NewReadOnlySchedulerGetPendingReasonResult 

func NewReadOnlySchedulerGetPendingReasonResult() *ReadOnlySchedulerGetPendingReasonResult

func (*ReadOnlySchedulerGetPendingReasonResult) GetSuccess 

func (p *ReadOnlySchedulerGetPendingReasonResult) GetSuccess() *Response

func (*ReadOnlySchedulerGetPendingReasonResult) IsSetSuccess 

func (p *ReadOnlySchedulerGetPendingReasonResult) IsSetSuccess() bool

func (*ReadOnlySchedulerGetPendingReasonResult) Read 

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

func (*ReadOnlySchedulerGetPendingReasonResult) String 

func (p *ReadOnlySchedulerGetPendingReasonResult) String() string

func (*ReadOnlySchedulerGetPendingReasonResult) Write 

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

type ReadOnlySchedulerGetQuotaArgs 

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

Attributes:

  • OwnerRole

func NewReadOnlySchedulerGetQuotaArgs 

func NewReadOnlySchedulerGetQuotaArgs() *ReadOnlySchedulerGetQuotaArgs

func (*ReadOnlySchedulerGetQuotaArgs) GetOwnerRole 

func (p *ReadOnlySchedulerGetQuotaArgs) GetOwnerRole() string

func (*ReadOnlySchedulerGetQuotaArgs) Read 

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

func (*ReadOnlySchedulerGetQuotaArgs) String 

func (p *ReadOnlySchedulerGetQuotaArgs) String() string

func (*ReadOnlySchedulerGetQuotaArgs) Write 

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

type ReadOnlySchedulerGetQuotaResult 

type ReadOnlySchedulerGetQuotaResult struct {
	Success *Response `thrift:"success,0" 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 (p *ReadOnlySchedulerGetQuotaResult) Read(iprot thrift.TProtocol) error

func (*ReadOnlySchedulerGetQuotaResult) String 

func (p *ReadOnlySchedulerGetQuotaResult) String() string

func (*ReadOnlySchedulerGetQuotaResult) Write 

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

type ReadOnlySchedulerGetRoleSummaryArgs 

type ReadOnlySchedulerGetRoleSummaryArgs struct {
}

func NewReadOnlySchedulerGetRoleSummaryArgs 

func NewReadOnlySchedulerGetRoleSummaryArgs() *ReadOnlySchedulerGetRoleSummaryArgs

func (*ReadOnlySchedulerGetRoleSummaryArgs) Read 

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

func (*ReadOnlySchedulerGetRoleSummaryArgs) String 

func (p *ReadOnlySchedulerGetRoleSummaryArgs) String() string

func (*ReadOnlySchedulerGetRoleSummaryArgs) Write 

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

type ReadOnlySchedulerGetRoleSummaryResult 

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

Attributes:

  • Success

func NewReadOnlySchedulerGetRoleSummaryResult 

func NewReadOnlySchedulerGetRoleSummaryResult() *ReadOnlySchedulerGetRoleSummaryResult

func (*ReadOnlySchedulerGetRoleSummaryResult) GetSuccess 

func (p *ReadOnlySchedulerGetRoleSummaryResult) GetSuccess() *Response

func (*ReadOnlySchedulerGetRoleSummaryResult) IsSetSuccess 

func (p *ReadOnlySchedulerGetRoleSummaryResult) IsSetSuccess() bool

func (*ReadOnlySchedulerGetRoleSummaryResult) Read 

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

func (*ReadOnlySchedulerGetRoleSummaryResult) String 

func (p *ReadOnlySchedulerGetRoleSummaryResult) String() string

func (*ReadOnlySchedulerGetRoleSummaryResult) Write 

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

type ReadOnlySchedulerGetTasksStatusArgs 

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

Attributes:

  • Query

func NewReadOnlySchedulerGetTasksStatusArgs 

func NewReadOnlySchedulerGetTasksStatusArgs() *ReadOnlySchedulerGetTasksStatusArgs

func (*ReadOnlySchedulerGetTasksStatusArgs) GetQuery 

func (p *ReadOnlySchedulerGetTasksStatusArgs) GetQuery() *TaskQuery

func (*ReadOnlySchedulerGetTasksStatusArgs) IsSetQuery 

func (p *ReadOnlySchedulerGetTasksStatusArgs) IsSetQuery() bool

func (*ReadOnlySchedulerGetTasksStatusArgs) Read 

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

func (*ReadOnlySchedulerGetTasksStatusArgs) String 

func (p *ReadOnlySchedulerGetTasksStatusArgs) String() string

func (*ReadOnlySchedulerGetTasksStatusArgs) Write 

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

type ReadOnlySchedulerGetTasksStatusResult 

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

Attributes:

  • Success

func NewReadOnlySchedulerGetTasksStatusResult 

func NewReadOnlySchedulerGetTasksStatusResult() *ReadOnlySchedulerGetTasksStatusResult

func (*ReadOnlySchedulerGetTasksStatusResult) GetSuccess 

func (p *ReadOnlySchedulerGetTasksStatusResult) GetSuccess() *Response

func (*ReadOnlySchedulerGetTasksStatusResult) IsSetSuccess 

func (p *ReadOnlySchedulerGetTasksStatusResult) IsSetSuccess() bool

func (*ReadOnlySchedulerGetTasksStatusResult) Read 

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

func (*ReadOnlySchedulerGetTasksStatusResult) String 

func (p *ReadOnlySchedulerGetTasksStatusResult) String() string

func (*ReadOnlySchedulerGetTasksStatusResult) Write 

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

type ReadOnlySchedulerGetTasksWithoutConfigsArgs 

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

Attributes:

  • Query

func NewReadOnlySchedulerGetTasksWithoutConfigsArgs 

func NewReadOnlySchedulerGetTasksWithoutConfigsArgs() *ReadOnlySchedulerGetTasksWithoutConfigsArgs

func (*ReadOnlySchedulerGetTasksWithoutConfigsArgs) GetQuery 

func (p *ReadOnlySchedulerGetTasksWithoutConfigsArgs) GetQuery() *TaskQuery

func (*ReadOnlySchedulerGetTasksWithoutConfigsArgs) IsSetQuery 

func (p *ReadOnlySchedulerGetTasksWithoutConfigsArgs) IsSetQuery() bool

func (*ReadOnlySchedulerGetTasksWithoutConfigsArgs) Read 

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

func (*ReadOnlySchedulerGetTasksWithoutConfigsArgs) String 

func (p *ReadOnlySchedulerGetTasksWithoutConfigsArgs) String() string

func (*ReadOnlySchedulerGetTasksWithoutConfigsArgs) Write 

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

type ReadOnlySchedulerGetTasksWithoutConfigsResult 

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

Attributes:

  • Success

func NewReadOnlySchedulerGetTasksWithoutConfigsResult 

func NewReadOnlySchedulerGetTasksWithoutConfigsResult() *ReadOnlySchedulerGetTasksWithoutConfigsResult

func (*ReadOnlySchedulerGetTasksWithoutConfigsResult) GetSuccess 

func (p *ReadOnlySchedulerGetTasksWithoutConfigsResult) GetSuccess() *Response

func (*ReadOnlySchedulerGetTasksWithoutConfigsResult) IsSetSuccess 

func (p *ReadOnlySchedulerGetTasksWithoutConfigsResult) IsSetSuccess() bool

func (*ReadOnlySchedulerGetTasksWithoutConfigsResult) Read 

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

func (*ReadOnlySchedulerGetTasksWithoutConfigsResult) String 

func (p *ReadOnlySchedulerGetTasksWithoutConfigsResult) String() string

func (*ReadOnlySchedulerGetTasksWithoutConfigsResult) Write 

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

type ReadOnlySchedulerGetTierConfigsArgs 

type ReadOnlySchedulerGetTierConfigsArgs struct {
}

func NewReadOnlySchedulerGetTierConfigsArgs 

func NewReadOnlySchedulerGetTierConfigsArgs() *ReadOnlySchedulerGetTierConfigsArgs

func (*ReadOnlySchedulerGetTierConfigsArgs) Read 

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

func (*ReadOnlySchedulerGetTierConfigsArgs) String 

func (p *ReadOnlySchedulerGetTierConfigsArgs) String() string

func (*ReadOnlySchedulerGetTierConfigsArgs) Write 

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

type ReadOnlySchedulerGetTierConfigsResult 

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

Attributes:

  • Success

func NewReadOnlySchedulerGetTierConfigsResult 

func NewReadOnlySchedulerGetTierConfigsResult() *ReadOnlySchedulerGetTierConfigsResult

func (*ReadOnlySchedulerGetTierConfigsResult) GetSuccess 

func (p *ReadOnlySchedulerGetTierConfigsResult) GetSuccess() *Response

func (*ReadOnlySchedulerGetTierConfigsResult) IsSetSuccess 

func (p *ReadOnlySchedulerGetTierConfigsResult) IsSetSuccess() bool

func (*ReadOnlySchedulerGetTierConfigsResult) Read 

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

func (*ReadOnlySchedulerGetTierConfigsResult) String 

func (p *ReadOnlySchedulerGetTierConfigsResult) String() string

func (*ReadOnlySchedulerGetTierConfigsResult) Write 

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

type ReadOnlySchedulerPopulateJobConfigArgs 

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

Attributes:

  • Description

func NewReadOnlySchedulerPopulateJobConfigArgs 

func NewReadOnlySchedulerPopulateJobConfigArgs() *ReadOnlySchedulerPopulateJobConfigArgs

func (*ReadOnlySchedulerPopulateJobConfigArgs) GetDescription 

func (p *ReadOnlySchedulerPopulateJobConfigArgs) GetDescription() *JobConfiguration

func (*ReadOnlySchedulerPopulateJobConfigArgs) IsSetDescription 

func (p *ReadOnlySchedulerPopulateJobConfigArgs) IsSetDescription() bool

func (*ReadOnlySchedulerPopulateJobConfigArgs) Read 

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

func (*ReadOnlySchedulerPopulateJobConfigArgs) String 

func (p *ReadOnlySchedulerPopulateJobConfigArgs) String() string

func (*ReadOnlySchedulerPopulateJobConfigArgs) Write 

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

type ReadOnlySchedulerPopulateJobConfigResult 

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

Attributes:

  • Success

func NewReadOnlySchedulerPopulateJobConfigResult 

func NewReadOnlySchedulerPopulateJobConfigResult() *ReadOnlySchedulerPopulateJobConfigResult

func (*ReadOnlySchedulerPopulateJobConfigResult) GetSuccess 

func (p *ReadOnlySchedulerPopulateJobConfigResult) GetSuccess() *Response

func (*ReadOnlySchedulerPopulateJobConfigResult) IsSetSuccess 

func (p *ReadOnlySchedulerPopulateJobConfigResult) IsSetSuccess() bool

func (*ReadOnlySchedulerPopulateJobConfigResult) Read 

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

func (*ReadOnlySchedulerPopulateJobConfigResult) String 

func (p *ReadOnlySchedulerPopulateJobConfigResult) String() string

func (*ReadOnlySchedulerPopulateJobConfigResult) Write 

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

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(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*ReadOnlySchedulerProcessor) ProcessorMap 

func (p *ReadOnlySchedulerProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type Resource 

type Resource struct {
	NumCpus   *float64 `thrift:"numCpus,1" json:"numCpus,omitempty"`
	RamMb     *int64   `thrift:"ramMb,2" json:"ramMb,omitempty"`
	DiskMb    *int64   `thrift:"diskMb,3" json:"diskMb,omitempty"`
	NamedPort *string  `thrift:"namedPort,4" json:"namedPort,omitempty"`
	NumGpus   *int64   `thrift:"numGpus,5" 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) String 

func (p *Resource) String() string

func (*Resource) Write 

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

type ResourceAggregate 

type ResourceAggregate struct {
	NumCpus   float64            `thrift:"numCpus,1" json:"numCpus"`
	RamMb     int64              `thrift:"ramMb,2" json:"ramMb"`
	DiskMb    int64              `thrift:"diskMb,3" json:"diskMb"`
	Resources map[*Resource]bool `thrift:"resources,4" json:"resources"`
}

Attributes:

  • NumCpus: Number of CPU cores allotted.
  • RamMb: Megabytes of RAM allotted.
  • DiskMb: Megabytes of disk space allotted.
  • 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) GetDiskMb 

func (p *ResourceAggregate) GetDiskMb() int64

func (*ResourceAggregate) GetNumCpus 

func (p *ResourceAggregate) GetNumCpus() float64

func (*ResourceAggregate) GetRamMb 

func (p *ResourceAggregate) GetRamMb() int64

func (*ResourceAggregate) GetResources 

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

func (*ResourceAggregate) Read 

func (p *ResourceAggregate) Read(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" json:"responseCode"`
	// unused field # 2
	Result_ *Result_ `thrift:"result,3" json:"result,omitempty"`
	// unused field # 4
	ServerInfo *ServerInfo       `thrift:"serverInfo,5" json:"serverInfo"`
	Details    []*ResponseDetail `thrift:"details,6" 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 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) 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) String 

func (p ResponseCode) String() string

func (*ResponseCode) UnmarshalText 

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

type ResponseDetail 

type ResponseDetail struct {
	Message string `thrift:"message,1" 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) 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" json:"populateJobResult,omitempty"`
	// unused field # 2
	ScheduleStatusResult_    *ScheduleStatusResult_    `thrift:"scheduleStatusResult,3" json:"scheduleStatusResult,omitempty"`
	GetJobsResult_           *GetJobsResult_           `thrift:"getJobsResult,4" json:"getJobsResult,omitempty"`
	GetQuotaResult_          *GetQuotaResult_          `thrift:"getQuotaResult,5" json:"getQuotaResult,omitempty"`
	ListBackupsResult_       *ListBackupsResult_       `thrift:"listBackupsResult,6" json:"listBackupsResult,omitempty"`
	StartMaintenanceResult_  *StartMaintenanceResult_  `thrift:"startMaintenanceResult,7" json:"startMaintenanceResult,omitempty"`
	DrainHostsResult_        *DrainHostsResult_        `thrift:"drainHostsResult,8" json:"drainHostsResult,omitempty"`
	QueryRecoveryResult_     *QueryRecoveryResult_     `thrift:"queryRecoveryResult,9" json:"queryRecoveryResult,omitempty"`
	MaintenanceStatusResult_ *MaintenanceStatusResult_ `thrift:"maintenanceStatusResult,10" json:"maintenanceStatusResult,omitempty"`
	EndMaintenanceResult_    *EndMaintenanceResult_    `thrift:"endMaintenanceResult,11" json:"endMaintenanceResult,omitempty"`
	// unused fields # 12 to 16
	RoleSummaryResult_ *RoleSummaryResult_ `thrift:"roleSummaryResult,17" json:"roleSummaryResult,omitempty"`
	JobSummaryResult_  *JobSummaryResult_  `thrift:"jobSummaryResult,18" json:"jobSummaryResult,omitempty"`
	// unused field # 19
	ConfigSummaryResult_         *ConfigSummaryResult_         `thrift:"configSummaryResult,20" json:"configSummaryResult,omitempty"`
	GetPendingReasonResult_      *GetPendingReasonResult_      `thrift:"getPendingReasonResult,21" json:"getPendingReasonResult,omitempty"`
	StartJobUpdateResult_        *StartJobUpdateResult_        `thrift:"startJobUpdateResult,22" json:"startJobUpdateResult,omitempty"`
	GetJobUpdateSummariesResult_ *GetJobUpdateSummariesResult_ `thrift:"getJobUpdateSummariesResult,23" json:"getJobUpdateSummariesResult,omitempty"`
	GetJobUpdateDetailsResult_   *GetJobUpdateDetailsResult_   `thrift:"getJobUpdateDetailsResult,24" json:"getJobUpdateDetailsResult,omitempty"`
	PulseJobUpdateResult_        *PulseJobUpdateResult_        `thrift:"pulseJobUpdateResult,25" json:"pulseJobUpdateResult,omitempty"`
	GetJobUpdateDiffResult_      *GetJobUpdateDiffResult_      `thrift:"getJobUpdateDiffResult,26" json:"getJobUpdateDiffResult,omitempty"`
	GetTierConfigResult_         *GetTierConfigResult_         `thrift:"getTierConfigResult,27" 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_) 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" json:"role"`
	JobCount     int32  `thrift:"jobCount,2" json:"jobCount"`
	CronJobCount int32  `thrift:"cronJobCount,3" 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) String 

func (p *RoleSummary) String() string

func (*RoleSummary) Write 

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

type RoleSummaryResult_ 

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

Attributes:

  • Summaries
var Result__RoleSummaryResult__DEFAULT *RoleSummaryResult_

func NewRoleSummaryResult_ 

func NewRoleSummaryResult_() *RoleSummaryResult_

func (*RoleSummaryResult_) GetSummaries 

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

func (*RoleSummaryResult_) Read 

func (p *RoleSummaryResult_) Read(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
)

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) String 

func (p ScheduleStatus) String() string

func (*ScheduleStatus) UnmarshalText 

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

type ScheduleStatusResult_ 

type ScheduleStatusResult_ struct {
	Tasks []*ScheduledTask `thrift:"tasks,1" 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 (p *ScheduleStatusResult_) Read(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" json:"assignedTask"`
	Status       ScheduleStatus `thrift:"status,2" json:"status"`
	FailureCount int32          `thrift:"failureCount,3" json:"failureCount"`
	TaskEvents   []*TaskEvent   `thrift:"taskEvents,4" json:"taskEvents"`
	AncestorId   string         `thrift:"ancestorId,5" json:"ancestorId"`
}

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.

  • 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) IsSetAssignedTask 

func (p *ScheduledTask) IsSetAssignedTask() bool

func (*ScheduledTask) Read 

func (p *ScheduledTask) Read(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" json:"clusterName"`
	// unused field # 2
	StatsUrlPrefix string `thrift:"statsUrlPrefix,3" 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) String 

func (p *ServerInfo) String() string

func (*ServerInfo) Write 

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

type StartJobUpdateResult_ 

type StartJobUpdateResult_ struct {
	Key           *JobUpdateKey     `thrift:"key,1" json:"key"`
	UpdateSummary *JobUpdateSummary `thrift:"updateSummary,2" 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 (p *StartJobUpdateResult_) Read(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 map[*HostStatus]bool `thrift:"statuses,1" json:"statuses"`
}

Attributes:

  • Statuses
var Result__StartMaintenanceResult__DEFAULT *StartMaintenanceResult_

func NewStartMaintenanceResult_ 

func NewStartMaintenanceResult_() *StartMaintenanceResult_

func (*StartMaintenanceResult_) GetStatuses 

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

func (*StartMaintenanceResult_) Read 

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

func (*StartMaintenanceResult_) String 

func (p *StartMaintenanceResult_) String() string

func (*StartMaintenanceResult_) Write 

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

type TaskConfig 

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

Description of the tasks contained within a job.

Attributes:

  • Job: Job task belongs to.
  • Owner: contains the role component of JobKey
  • IsService
  • NumCpus
  • RamMb
  • DiskMb
  • 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
  • RequestedPorts: a list of named ports this task requests
  • 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.
  • 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() map[*Constraint]bool

func (*TaskConfig) GetContactEmail 

func (p *TaskConfig) GetContactEmail() string

func (*TaskConfig) GetContainer 

func (p *TaskConfig) GetContainer() *Container

func (*TaskConfig) GetDiskMb 

func (p *TaskConfig) GetDiskMb() int64

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() map[*MesosFetcherURI]bool

func (*TaskConfig) GetMetadata 

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

func (*TaskConfig) GetNumCpus 

func (p *TaskConfig) GetNumCpus() float64

func (*TaskConfig) GetOwner 

func (p *TaskConfig) GetOwner() *Identity

func (*TaskConfig) GetPriority 

func (p *TaskConfig) GetPriority() int32

func (*TaskConfig) GetProduction 

func (p *TaskConfig) GetProduction() bool

func (*TaskConfig) GetRamMb 

func (p *TaskConfig) GetRamMb() int64

func (*TaskConfig) GetRequestedPorts 

func (p *TaskConfig) GetRequestedPorts() map[string]bool

func (*TaskConfig) GetResources 

func (p *TaskConfig) GetResources() map[*Resource]bool
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) IsSetProduction 

func (p *TaskConfig) IsSetProduction() 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) 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" json:"value,omitempty"`
	Limit *LimitConstraint `thrift:"limit,2" 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) 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" json:"timestamp"`
	Status    ScheduleStatus `thrift:"status,2" json:"status"`
	Message   *string        `thrift:"message,3" json:"message,omitempty"`
	Scheduler *string        `thrift:"scheduler,4" 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) 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" json:"jobName,omitempty"`
	// unused field # 3
	TaskIds  map[string]bool         `thrift:"taskIds,4" json:"taskIds,omitempty"`
	Statuses map[ScheduleStatus]bool `thrift:"statuses,5" json:"statuses,omitempty"`
	// unused field # 6
	InstanceIds map[int32]bool `thrift:"instanceIds,7" json:"instanceIds,omitempty"`
	// unused field # 8
	Environment *string          `thrift:"environment,9" json:"environment,omitempty"`
	SlaveHosts  map[string]bool  `thrift:"slaveHosts,10" json:"slaveHosts,omitempty"`
	JobKeys     map[*JobKey]bool `thrift:"jobKeys,11" json:"jobKeys,omitempty"`
	Offset      *int32           `thrift:"offset,12" json:"offset,omitempty"`
	Limit       *int32           `thrift:"limit,13" json:"limit,omitempty"`
	Role        *string          `thrift:"role,14" 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() map[int32]bool

func (*TaskQuery) GetJobKeys 

func (p *TaskQuery) GetJobKeys() map[*JobKey]bool

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() map[string]bool

func (*TaskQuery) GetStatuses 

func (p *TaskQuery) GetStatuses() map[ScheduleStatus]bool

func (*TaskQuery) GetTaskIds 

func (p *TaskQuery) GetTaskIds() map[string]bool

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) 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" json:"name"`
	Settings map[string]string `thrift:"settings,2" 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) 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" json:"negated"`
	Values  map[string]bool `thrift:"values,2" 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() map[string]bool

func (*ValueConstraint) Read 

func (p *ValueConstraint) Read(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" json:"containerPath"`
	HostPath      string `thrift:"hostPath,2" json:"hostPath"`
	Mode          Mode   `thrift:"mode,3" 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) String 

func (p *Volume) String() string

func (*Volume) Write 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.