aurora

package

Go to main page

Versions in this module

v1

v1.25.0

Oct 13, 2022

v1.24.0

Nov 9, 2021

v1.23.0

Feb 26, 2021

Changes in this version

type AppcImage

+ func (p *AppcImage) Equals(other *AppcImage) bool

type AssignedTask

+ func (p *AssignedTask) Equals(other *AssignedTask) bool

type Attribute

+ func (p *Attribute) Equals(other *Attribute) bool

type BatchJobUpdateStrategy

+ func (p *BatchJobUpdateStrategy) Equals(other *BatchJobUpdateStrategy) bool

type ConfigGroup

+ func (p *ConfigGroup) Equals(other *ConfigGroup) bool

type ConfigSummary

+ func (p *ConfigSummary) Equals(other *ConfigSummary) bool

type ConfigSummaryResult_

+ func (p *ConfigSummaryResult_) Equals(other *ConfigSummaryResult_) bool

type Constraint

+ func (p *Constraint) Equals(other *Constraint) bool

type Container

+ func (p *Container) Equals(other *Container) bool

type CoordinatorSlaPolicy

+ func (p *CoordinatorSlaPolicy) Equals(other *CoordinatorSlaPolicy) bool

type CountSlaPolicy

+ func (p *CountSlaPolicy) Equals(other *CountSlaPolicy) bool

type DockerContainer

+ func (p *DockerContainer) Equals(other *DockerContainer) bool

type DockerImage

+ func (p *DockerImage) Equals(other *DockerImage) bool

type DockerParameter

+ func (p *DockerParameter) Equals(other *DockerParameter) bool

type DrainHostsResult_

+ func (p *DrainHostsResult_) Equals(other *DrainHostsResult_) bool

type EndMaintenanceResult_

+ func (p *EndMaintenanceResult_) Equals(other *EndMaintenanceResult_) bool

type ExecutorConfig

+ func (p *ExecutorConfig) Equals(other *ExecutorConfig) bool

type ExplicitReconciliationSettings

+ func (p *ExplicitReconciliationSettings) Equals(other *ExplicitReconciliationSettings) bool

type GetJobUpdateDetailsResult_

+ func (p *GetJobUpdateDetailsResult_) Equals(other *GetJobUpdateDetailsResult_) bool

type GetJobUpdateDiffResult_

+ func (p *GetJobUpdateDiffResult_) Equals(other *GetJobUpdateDiffResult_) bool

type GetJobUpdateSummariesResult_

+ func (p *GetJobUpdateSummariesResult_) Equals(other *GetJobUpdateSummariesResult_) bool

type GetJobsResult_

+ func (p *GetJobsResult_) Equals(other *GetJobsResult_) bool

type GetPendingReasonResult_

+ func (p *GetPendingReasonResult_) Equals(other *GetPendingReasonResult_) bool

type GetQuotaResult_

+ func (p *GetQuotaResult_) Equals(other *GetQuotaResult_) bool

type GetTierConfigResult_

+ func (p *GetTierConfigResult_) Equals(other *GetTierConfigResult_) bool

type HostAttributes

+ func (p *HostAttributes) Equals(other *HostAttributes) bool

type HostMaintenanceRequest

+ func (p *HostMaintenanceRequest) Equals(other *HostMaintenanceRequest) bool

type HostStatus

+ func (p *HostStatus) Equals(other *HostStatus) bool

type Hosts

+ func (p *Hosts) Equals(other *Hosts) bool

type Identity

+ func (p *Identity) Equals(other *Identity) bool

type Image

+ func (p *Image) Equals(other *Image) bool

type InstanceKey

+ func (p *InstanceKey) Equals(other *InstanceKey) bool

type InstanceTaskConfig

+ func (p *InstanceTaskConfig) Equals(other *InstanceTaskConfig) bool

type JobConfiguration

+ func (p *JobConfiguration) Equals(other *JobConfiguration) bool

type JobInstanceUpdateEvent

+ func (p *JobInstanceUpdateEvent) Equals(other *JobInstanceUpdateEvent) bool

type JobKey

+ func (p *JobKey) Equals(other *JobKey) bool

type JobStats

+ func (p *JobStats) Equals(other *JobStats) bool

type JobSummary

+ func (p *JobSummary) Equals(other *JobSummary) bool

type JobSummaryResult_

+ func (p *JobSummaryResult_) Equals(other *JobSummaryResult_) bool

type JobUpdate

+ func (p *JobUpdate) Equals(other *JobUpdate) bool

type JobUpdateDetails

+ func (p *JobUpdateDetails) Equals(other *JobUpdateDetails) bool

type JobUpdateEvent

+ func (p *JobUpdateEvent) Equals(other *JobUpdateEvent) bool

type JobUpdateInstructions

+ func (p *JobUpdateInstructions) Equals(other *JobUpdateInstructions) bool

type JobUpdateKey

+ func (p *JobUpdateKey) Equals(other *JobUpdateKey) bool

type JobUpdateQuery

+ func (p *JobUpdateQuery) Equals(other *JobUpdateQuery) bool

type JobUpdateRequest

+ func (p *JobUpdateRequest) Equals(other *JobUpdateRequest) bool

type JobUpdateSettings

+ func (p *JobUpdateSettings) Equals(other *JobUpdateSettings) bool

type JobUpdateState

+ func (p *JobUpdateState) Equals(other *JobUpdateState) bool

type JobUpdateStrategy

+ func (p *JobUpdateStrategy) Equals(other *JobUpdateStrategy) bool

type JobUpdateSummary

+ func (p *JobUpdateSummary) Equals(other *JobUpdateSummary) bool

type LimitConstraint

+ func (p *LimitConstraint) Equals(other *LimitConstraint) bool

type ListBackupsResult_

+ func (p *ListBackupsResult_) Equals(other *ListBackupsResult_) bool

type Lock

+ func (p *Lock) Equals(other *Lock) bool

type LockKey

+ func (p *LockKey) Equals(other *LockKey) bool

type MaintenanceStatusResult_

+ func (p *MaintenanceStatusResult_) Equals(other *MaintenanceStatusResult_) bool

type MesosContainer

+ func (p *MesosContainer) Equals(other *MesosContainer) bool

type MesosFetcherURI

+ func (p *MesosFetcherURI) Equals(other *MesosFetcherURI) bool

type Metadata

+ func (p *Metadata) Equals(other *Metadata) bool

type Package

+ func (p *Package) Equals(other *Package) bool

type PartitionPolicy

+ func (p *PartitionPolicy) Equals(other *PartitionPolicy) bool

type PendingReason

+ func (p *PendingReason) Equals(other *PendingReason) bool

type PercentageSlaPolicy

+ func (p *PercentageSlaPolicy) Equals(other *PercentageSlaPolicy) bool

type PopulateJobResult_

+ func (p *PopulateJobResult_) Equals(other *PopulateJobResult_) bool

type PulseJobUpdateResult_

+ func (p *PulseJobUpdateResult_) Equals(other *PulseJobUpdateResult_) bool

type QueryRecoveryResult_

+ func (p *QueryRecoveryResult_) Equals(other *QueryRecoveryResult_) bool

type QueueJobUpdateStrategy

+ func (p *QueueJobUpdateStrategy) Equals(other *QueueJobUpdateStrategy) bool

type Range

+ func (p *Range) Equals(other *Range) bool

type ReadOnlySchedulerClient

+ func (p *ReadOnlySchedulerClient) LastResponseMeta_() thrift.ResponseMeta

+ func (p *ReadOnlySchedulerClient) SetLastResponseMeta_(meta thrift.ResponseMeta)

type Resource

+ func (p *Resource) Equals(other *Resource) bool

type ResourceAggregate

+ func (p *ResourceAggregate) Equals(other *ResourceAggregate) bool

type Response

+ func (p *Response) Equals(other *Response) bool

type ResponseDetail

+ func (p *ResponseDetail) Equals(other *ResponseDetail) bool

type Result_

+ func (p *Result_) Equals(other *Result_) bool

type RoleSummary

+ func (p *RoleSummary) Equals(other *RoleSummary) bool

type RoleSummaryResult_

+ func (p *RoleSummaryResult_) Equals(other *RoleSummaryResult_) bool

type ScheduleStatusResult_

+ func (p *ScheduleStatusResult_) Equals(other *ScheduleStatusResult_) bool

type ScheduledTask

+ func (p *ScheduledTask) Equals(other *ScheduledTask) bool

type ServerInfo

+ func (p *ServerInfo) Equals(other *ServerInfo) bool

type SlaPolicy

+ func (p *SlaPolicy) Equals(other *SlaPolicy) bool

type StartJobUpdateResult_

+ func (p *StartJobUpdateResult_) Equals(other *StartJobUpdateResult_) bool

type StartMaintenanceResult_

+ func (p *StartMaintenanceResult_) Equals(other *StartMaintenanceResult_) bool

type TaskConfig

+ func (p *TaskConfig) Equals(other *TaskConfig) bool

type TaskConstraint

+ func (p *TaskConstraint) Equals(other *TaskConstraint) bool

type TaskEvent

+ func (p *TaskEvent) Equals(other *TaskEvent) bool

type TaskQuery

+ func (p *TaskQuery) Equals(other *TaskQuery) bool

type TierConfig

+ func (p *TierConfig) Equals(other *TierConfig) bool

type ValueConstraint

+ func (p *ValueConstraint) Equals(other *ValueConstraint) bool

type VariableBatchJobUpdateStrategy

+ func (p *VariableBatchJobUpdateStrategy) Equals(other *VariableBatchJobUpdateStrategy) bool

type Volume

+ func (p *Volume) Equals(other *Volume) bool

v1.22.5

Sep 28, 2020

v1.22.4

Jul 29, 2020

v1.22.3

May 27, 2020

v1.22.2

May 27, 2020

v1.22.1

May 27, 2020

v1.22.0

Jan 14, 2020

Changes in this version

+ type BatchJobUpdateStrategy struct

+ AutopauseAfterBatch bool

+ GroupSize int32

+ var JobUpdateStrategy_BatchStrategy_DEFAULT *BatchJobUpdateStrategy

+ func NewBatchJobUpdateStrategy() *BatchJobUpdateStrategy

+ func (p *BatchJobUpdateStrategy) GetAutopauseAfterBatch() bool

+ func (p *BatchJobUpdateStrategy) GetGroupSize() int32

+ func (p *BatchJobUpdateStrategy) Read(iprot thrift.TProtocol) error

+ func (p *BatchJobUpdateStrategy) ReadField1(iprot thrift.TProtocol) error

+ func (p *BatchJobUpdateStrategy) ReadField2(iprot thrift.TProtocol) error

+ func (p *BatchJobUpdateStrategy) String() string

+ func (p *BatchJobUpdateStrategy) Write(oprot thrift.TProtocol) error

type JobUpdateSettings

+ UpdateStrategy *JobUpdateStrategy

+ func (p *JobUpdateSettings) GetUpdateStrategy() *JobUpdateStrategy

+ func (p *JobUpdateSettings) IsSetUpdateStrategy() bool

+ func (p *JobUpdateSettings) ReadField11(iprot thrift.TProtocol) error

+ type JobUpdateStrategy struct

+ BatchStrategy *BatchJobUpdateStrategy

+ QueueStrategy *QueueJobUpdateStrategy

+ VarBatchStrategy *VariableBatchJobUpdateStrategy

+ var JobUpdateSettings_UpdateStrategy_DEFAULT *JobUpdateStrategy

+ func NewJobUpdateStrategy() *JobUpdateStrategy

+ func (p *JobUpdateStrategy) CountSetFieldsJobUpdateStrategy() int

+ func (p *JobUpdateStrategy) GetBatchStrategy() *BatchJobUpdateStrategy

+ func (p *JobUpdateStrategy) GetQueueStrategy() *QueueJobUpdateStrategy

+ func (p *JobUpdateStrategy) GetVarBatchStrategy() *VariableBatchJobUpdateStrategy

+ func (p *JobUpdateStrategy) IsSetBatchStrategy() bool

+ func (p *JobUpdateStrategy) IsSetQueueStrategy() bool

+ func (p *JobUpdateStrategy) IsSetVarBatchStrategy() bool

+ func (p *JobUpdateStrategy) Read(iprot thrift.TProtocol) error

+ func (p *JobUpdateStrategy) ReadField1(iprot thrift.TProtocol) error

+ func (p *JobUpdateStrategy) ReadField2(iprot thrift.TProtocol) error

+ func (p *JobUpdateStrategy) ReadField3(iprot thrift.TProtocol) error

+ func (p *JobUpdateStrategy) String() string

+ func (p *JobUpdateStrategy) Write(oprot thrift.TProtocol) error

+ type QueueJobUpdateStrategy struct

+ GroupSize int32

+ var JobUpdateStrategy_QueueStrategy_DEFAULT *QueueJobUpdateStrategy

+ func NewQueueJobUpdateStrategy() *QueueJobUpdateStrategy

+ func (p *QueueJobUpdateStrategy) GetGroupSize() int32

+ func (p *QueueJobUpdateStrategy) Read(iprot thrift.TProtocol) error

+ func (p *QueueJobUpdateStrategy) ReadField1(iprot thrift.TProtocol) error

+ func (p *QueueJobUpdateStrategy) String() string

+ func (p *QueueJobUpdateStrategy) Write(oprot thrift.TProtocol) error

+ type VariableBatchJobUpdateStrategy struct

+ AutopauseAfterBatch bool

+ GroupSizes []int32

+ var JobUpdateStrategy_VarBatchStrategy_DEFAULT *VariableBatchJobUpdateStrategy

+ func NewVariableBatchJobUpdateStrategy() *VariableBatchJobUpdateStrategy

+ func (p *VariableBatchJobUpdateStrategy) GetAutopauseAfterBatch() bool

+ func (p *VariableBatchJobUpdateStrategy) GetGroupSizes() []int32

+ func (p *VariableBatchJobUpdateStrategy) Read(iprot thrift.TProtocol) error

+ func (p *VariableBatchJobUpdateStrategy) ReadField1(iprot thrift.TProtocol) error

+ func (p *VariableBatchJobUpdateStrategy) ReadField2(iprot thrift.TProtocol) error

+ func (p *VariableBatchJobUpdateStrategy) String() string

+ func (p *VariableBatchJobUpdateStrategy) Write(oprot thrift.TProtocol) error

v1.21.1

Jun 12, 2019

v1.21.0

Mar 15, 2019

Changes in this version

type AppcImage

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

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

type AssignedTask

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

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

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

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

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

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

type Attribute

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

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

type AuroraAdminClient

+ func NewAuroraAdminClient(c thrift.TClient) *AuroraAdminClient

type AuroraAdminCommitRecoveryResult

+ func (p *AuroraAdminCommitRecoveryResult) ReadField0(iprot thrift.TProtocol) error

type AuroraAdminDeleteRecoveryTasksArgs

+ func (p *AuroraAdminDeleteRecoveryTasksArgs) ReadField1(iprot thrift.TProtocol) error

type AuroraAdminDeleteRecoveryTasksResult

+ func (p *AuroraAdminDeleteRecoveryTasksResult) ReadField0(iprot thrift.TProtocol) error

type AuroraAdminDrainHostsArgs

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

type AuroraAdminDrainHostsResult

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

type AuroraAdminEndMaintenanceArgs

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

type AuroraAdminEndMaintenanceResult

+ func (p *AuroraAdminEndMaintenanceResult) ReadField0(iprot thrift.TProtocol) error

type AuroraAdminForceTaskStateArgs

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

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

type AuroraAdminForceTaskStateResult

+ func (p *AuroraAdminForceTaskStateResult) ReadField0(iprot thrift.TProtocol) error

type AuroraAdminListBackupsResult

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

type AuroraAdminMaintenanceStatusArgs

+ func (p *AuroraAdminMaintenanceStatusArgs) ReadField1(iprot thrift.TProtocol) error

type AuroraAdminMaintenanceStatusResult

+ func (p *AuroraAdminMaintenanceStatusResult) ReadField0(iprot thrift.TProtocol) error

type AuroraAdminPerformBackupResult

+ func (p *AuroraAdminPerformBackupResult) ReadField0(iprot thrift.TProtocol) error

type AuroraAdminPruneTasksArgs

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

type AuroraAdminPruneTasksResult

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

type AuroraAdminQueryRecoveryArgs

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

type AuroraAdminQueryRecoveryResult

+ func (p *AuroraAdminQueryRecoveryResult) ReadField0(iprot thrift.TProtocol) error

type AuroraAdminSetQuotaArgs

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

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

type AuroraAdminSetQuotaResult

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

type AuroraAdminSlaDrainHostsArgs

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

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

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

type AuroraAdminSlaDrainHostsResult

+ func (p *AuroraAdminSlaDrainHostsResult) ReadField0(iprot thrift.TProtocol) error

type AuroraAdminSnapshotResult

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

type AuroraAdminStageRecoveryArgs

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

type AuroraAdminStageRecoveryResult

+ func (p *AuroraAdminStageRecoveryResult) ReadField0(iprot thrift.TProtocol) error

type AuroraAdminStartMaintenanceArgs

+ func (p *AuroraAdminStartMaintenanceArgs) ReadField1(iprot thrift.TProtocol) error

type AuroraAdminStartMaintenanceResult

+ func (p *AuroraAdminStartMaintenanceResult) ReadField0(iprot thrift.TProtocol) error

type AuroraAdminTriggerExplicitTaskReconciliationArgs

+ func (p *AuroraAdminTriggerExplicitTaskReconciliationArgs) ReadField1(iprot thrift.TProtocol) error

type AuroraAdminTriggerExplicitTaskReconciliationResult

+ func (p *AuroraAdminTriggerExplicitTaskReconciliationResult) ReadField0(iprot thrift.TProtocol) error

type AuroraAdminTriggerImplicitTaskReconciliationResult

+ func (p *AuroraAdminTriggerImplicitTaskReconciliationResult) ReadField0(iprot thrift.TProtocol) error

type AuroraAdminUnloadRecoveryResult

+ func (p *AuroraAdminUnloadRecoveryResult) ReadField0(iprot thrift.TProtocol) error

type AuroraSchedulerManagerAbortJobUpdateArgs

+ func (p *AuroraSchedulerManagerAbortJobUpdateArgs) ReadField1(iprot thrift.TProtocol) error

+ func (p *AuroraSchedulerManagerAbortJobUpdateArgs) ReadField3(iprot thrift.TProtocol) error

type AuroraSchedulerManagerAbortJobUpdateResult

+ func (p *AuroraSchedulerManagerAbortJobUpdateResult) ReadField0(iprot thrift.TProtocol) error

type AuroraSchedulerManagerAddInstancesArgs

+ func (p *AuroraSchedulerManagerAddInstancesArgs) ReadField3(iprot thrift.TProtocol) error

+ func (p *AuroraSchedulerManagerAddInstancesArgs) ReadField4(iprot thrift.TProtocol) error

type AuroraSchedulerManagerAddInstancesResult

+ func (p *AuroraSchedulerManagerAddInstancesResult) ReadField0(iprot thrift.TProtocol) error

type AuroraSchedulerManagerClient

+ func NewAuroraSchedulerManagerClient(c thrift.TClient) *AuroraSchedulerManagerClient

type AuroraSchedulerManagerCreateJobArgs

+ func (p *AuroraSchedulerManagerCreateJobArgs) ReadField1(iprot thrift.TProtocol) error

type AuroraSchedulerManagerCreateJobResult

+ func (p *AuroraSchedulerManagerCreateJobResult) ReadField0(iprot thrift.TProtocol) error

type AuroraSchedulerManagerDescheduleCronJobArgs

+ func (p *AuroraSchedulerManagerDescheduleCronJobArgs) ReadField4(iprot thrift.TProtocol) error

type AuroraSchedulerManagerDescheduleCronJobResult

+ func (p *AuroraSchedulerManagerDescheduleCronJobResult) ReadField0(iprot thrift.TProtocol) error

type AuroraSchedulerManagerKillTasksArgs

+ func (p *AuroraSchedulerManagerKillTasksArgs) ReadField4(iprot thrift.TProtocol) error

+ func (p *AuroraSchedulerManagerKillTasksArgs) ReadField5(iprot thrift.TProtocol) error

+ func (p *AuroraSchedulerManagerKillTasksArgs) ReadField6(iprot thrift.TProtocol) error

type AuroraSchedulerManagerKillTasksResult

+ func (p *AuroraSchedulerManagerKillTasksResult) ReadField0(iprot thrift.TProtocol) error

type AuroraSchedulerManagerPauseJobUpdateArgs

+ func (p *AuroraSchedulerManagerPauseJobUpdateArgs) ReadField1(iprot thrift.TProtocol) error

+ func (p *AuroraSchedulerManagerPauseJobUpdateArgs) ReadField3(iprot thrift.TProtocol) error

type AuroraSchedulerManagerPauseJobUpdateResult

+ func (p *AuroraSchedulerManagerPauseJobUpdateResult) ReadField0(iprot thrift.TProtocol) error

type AuroraSchedulerManagerPulseJobUpdateArgs

+ func (p *AuroraSchedulerManagerPulseJobUpdateArgs) ReadField1(iprot thrift.TProtocol) error

type AuroraSchedulerManagerPulseJobUpdateResult

+ func (p *AuroraSchedulerManagerPulseJobUpdateResult) ReadField0(iprot thrift.TProtocol) error

type AuroraSchedulerManagerReplaceCronTemplateArgs

+ func (p *AuroraSchedulerManagerReplaceCronTemplateArgs) ReadField1(iprot thrift.TProtocol) error

type AuroraSchedulerManagerReplaceCronTemplateResult

+ func (p *AuroraSchedulerManagerReplaceCronTemplateResult) ReadField0(iprot thrift.TProtocol) error

type AuroraSchedulerManagerRestartShardsArgs

+ func (p *AuroraSchedulerManagerRestartShardsArgs) ReadField3(iprot thrift.TProtocol) error

+ func (p *AuroraSchedulerManagerRestartShardsArgs) ReadField5(iprot thrift.TProtocol) error

type AuroraSchedulerManagerRestartShardsResult

+ func (p *AuroraSchedulerManagerRestartShardsResult) ReadField0(iprot thrift.TProtocol) error

type AuroraSchedulerManagerResumeJobUpdateArgs

+ func (p *AuroraSchedulerManagerResumeJobUpdateArgs) ReadField1(iprot thrift.TProtocol) error

+ func (p *AuroraSchedulerManagerResumeJobUpdateArgs) ReadField3(iprot thrift.TProtocol) error

type AuroraSchedulerManagerResumeJobUpdateResult

+ func (p *AuroraSchedulerManagerResumeJobUpdateResult) ReadField0(iprot thrift.TProtocol) error

type AuroraSchedulerManagerRollbackJobUpdateArgs

+ func (p *AuroraSchedulerManagerRollbackJobUpdateArgs) ReadField1(iprot thrift.TProtocol) error

+ func (p *AuroraSchedulerManagerRollbackJobUpdateArgs) ReadField2(iprot thrift.TProtocol) error

type AuroraSchedulerManagerRollbackJobUpdateResult

+ func (p *AuroraSchedulerManagerRollbackJobUpdateResult) ReadField0(iprot thrift.TProtocol) error

type AuroraSchedulerManagerScheduleCronJobArgs

+ func (p *AuroraSchedulerManagerScheduleCronJobArgs) ReadField1(iprot thrift.TProtocol) error

type AuroraSchedulerManagerScheduleCronJobResult

+ func (p *AuroraSchedulerManagerScheduleCronJobResult) ReadField0(iprot thrift.TProtocol) error

type AuroraSchedulerManagerStartCronJobArgs

+ func (p *AuroraSchedulerManagerStartCronJobArgs) ReadField4(iprot thrift.TProtocol) error

type AuroraSchedulerManagerStartCronJobResult

+ func (p *AuroraSchedulerManagerStartCronJobResult) ReadField0(iprot thrift.TProtocol) error

type AuroraSchedulerManagerStartJobUpdateArgs

+ func (p *AuroraSchedulerManagerStartJobUpdateArgs) ReadField1(iprot thrift.TProtocol) error

+ func (p *AuroraSchedulerManagerStartJobUpdateArgs) ReadField3(iprot thrift.TProtocol) error

type AuroraSchedulerManagerStartJobUpdateResult

+ func (p *AuroraSchedulerManagerStartJobUpdateResult) ReadField0(iprot thrift.TProtocol) error

type ConfigGroup

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

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

type ConfigSummary

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

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

type ConfigSummaryResult_

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

type Constraint

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

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

type Container

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

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

type CoordinatorSlaPolicy

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

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

type CountSlaPolicy

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

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

type CronCollisionPolicy

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

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

type DockerContainer

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

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

type DockerImage

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

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

type DockerParameter

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

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

type DrainHostsResult_

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

type EndMaintenanceResult_

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

type ExecutorConfig

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

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

type ExplicitReconciliationSettings

+ func (p *ExplicitReconciliationSettings) ReadField1(iprot thrift.TProtocol) error

type GetJobUpdateDetailsResult_

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

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

type GetJobUpdateDiffResult_

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

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

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

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

type GetJobUpdateSummariesResult_

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

type GetJobsResult_

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

type GetPendingReasonResult_

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

type GetQuotaResult_

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

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

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

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

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

type GetTierConfigResult_

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

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

type HostAttributes

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

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

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

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

type HostMaintenanceRequest

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

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

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

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

type HostStatus

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

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

type Hosts

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

type Identity

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

type Image

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

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

type InstanceKey

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

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

type InstanceTaskConfig

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

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

type JobConfiguration

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

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

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

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

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

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

type JobInstanceUpdateEvent

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

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

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

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

type JobKey

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

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

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

type JobStats

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

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

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

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

type JobSummary

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

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

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

type JobSummaryResult_

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

type JobUpdate

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

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

type JobUpdateAction

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

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

type JobUpdateDetails

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

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

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

type JobUpdateEvent

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

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

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

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

type JobUpdateInstructions

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

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

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

type JobUpdateKey

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

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

type JobUpdatePulseStatus

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

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

type JobUpdateQuery

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

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

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

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

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

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

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

type JobUpdateRequest

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

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

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

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

type JobUpdateSettings

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

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

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

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

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

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

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

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

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

type JobUpdateState

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

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

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

type JobUpdateStatus

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

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

type JobUpdateSummary

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

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

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

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

type LimitConstraint

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

type ListBackupsResult_

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

type Lock

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

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

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

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

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

type LockKey

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

type MaintenanceMode

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

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

type MaintenanceStatusResult_

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

type MesosContainer

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

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

type MesosFetcherURI

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

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

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

type Metadata

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

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

type Mode

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

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

type Package

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

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

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

type PartitionPolicy

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

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

type PendingReason

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

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

type PercentageSlaPolicy

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

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

type PopulateJobResult_

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

type PulseJobUpdateResult_

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

type QueryRecoveryResult_

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

type Range

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

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

type ReadOnlySchedulerClient

+ func NewReadOnlySchedulerClient(c thrift.TClient) *ReadOnlySchedulerClient

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

type ReadOnlySchedulerGetConfigSummaryArgs

+ func (p *ReadOnlySchedulerGetConfigSummaryArgs) ReadField1(iprot thrift.TProtocol) error

type ReadOnlySchedulerGetConfigSummaryResult

+ func (p *ReadOnlySchedulerGetConfigSummaryResult) ReadField0(iprot thrift.TProtocol) error

type ReadOnlySchedulerGetJobSummaryArgs

+ func (p *ReadOnlySchedulerGetJobSummaryArgs) ReadField1(iprot thrift.TProtocol) error

type ReadOnlySchedulerGetJobSummaryResult

+ func (p *ReadOnlySchedulerGetJobSummaryResult) ReadField0(iprot thrift.TProtocol) error

type ReadOnlySchedulerGetJobUpdateDetailsArgs

+ func (p *ReadOnlySchedulerGetJobUpdateDetailsArgs) ReadField2(iprot thrift.TProtocol) error

type ReadOnlySchedulerGetJobUpdateDetailsResult

+ func (p *ReadOnlySchedulerGetJobUpdateDetailsResult) ReadField0(iprot thrift.TProtocol) error

type ReadOnlySchedulerGetJobUpdateDiffArgs

+ func (p *ReadOnlySchedulerGetJobUpdateDiffArgs) ReadField1(iprot thrift.TProtocol) error

type ReadOnlySchedulerGetJobUpdateDiffResult

+ func (p *ReadOnlySchedulerGetJobUpdateDiffResult) ReadField0(iprot thrift.TProtocol) error

type ReadOnlySchedulerGetJobUpdateSummariesArgs

+ func (p *ReadOnlySchedulerGetJobUpdateSummariesArgs) ReadField1(iprot thrift.TProtocol) error

type ReadOnlySchedulerGetJobUpdateSummariesResult

+ func (p *ReadOnlySchedulerGetJobUpdateSummariesResult) ReadField0(iprot thrift.TProtocol) error

type ReadOnlySchedulerGetJobsArgs

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

type ReadOnlySchedulerGetJobsResult

+ func (p *ReadOnlySchedulerGetJobsResult) ReadField0(iprot thrift.TProtocol) error

type ReadOnlySchedulerGetPendingReasonArgs

+ func (p *ReadOnlySchedulerGetPendingReasonArgs) ReadField1(iprot thrift.TProtocol) error

type ReadOnlySchedulerGetPendingReasonResult

+ func (p *ReadOnlySchedulerGetPendingReasonResult) ReadField0(iprot thrift.TProtocol) error

type ReadOnlySchedulerGetQuotaArgs

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

type ReadOnlySchedulerGetQuotaResult

+ func (p *ReadOnlySchedulerGetQuotaResult) ReadField0(iprot thrift.TProtocol) error

type ReadOnlySchedulerGetRoleSummaryResult

+ func (p *ReadOnlySchedulerGetRoleSummaryResult) ReadField0(iprot thrift.TProtocol) error

type ReadOnlySchedulerGetTasksStatusArgs

+ func (p *ReadOnlySchedulerGetTasksStatusArgs) ReadField1(iprot thrift.TProtocol) error

type ReadOnlySchedulerGetTasksStatusResult

+ func (p *ReadOnlySchedulerGetTasksStatusResult) ReadField0(iprot thrift.TProtocol) error

type ReadOnlySchedulerGetTasksWithoutConfigsArgs

+ func (p *ReadOnlySchedulerGetTasksWithoutConfigsArgs) ReadField1(iprot thrift.TProtocol) error

type ReadOnlySchedulerGetTasksWithoutConfigsResult

+ func (p *ReadOnlySchedulerGetTasksWithoutConfigsResult) ReadField0(iprot thrift.TProtocol) error

type ReadOnlySchedulerGetTierConfigsResult

+ func (p *ReadOnlySchedulerGetTierConfigsResult) ReadField0(iprot thrift.TProtocol) error

type ReadOnlySchedulerPopulateJobConfigArgs

+ func (p *ReadOnlySchedulerPopulateJobConfigArgs) ReadField1(iprot thrift.TProtocol) error

type ReadOnlySchedulerPopulateJobConfigResult

+ func (p *ReadOnlySchedulerPopulateJobConfigResult) ReadField0(iprot thrift.TProtocol) error

type Resource

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

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

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

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

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

type ResourceAggregate

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

type Response

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

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

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

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

type ResponseCode

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

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

type ResponseDetail

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

type Result_

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

type RoleSummary

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

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

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

type RoleSummaryResult_

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

type ScheduleStatus

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

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

type ScheduleStatusResult_

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

type ScheduledTask

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

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

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

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

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

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

type ServerInfo

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

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

type SlaPolicy

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

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

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

type StartJobUpdateResult_

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

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

type StartMaintenanceResult_

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

type TaskConfig

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

type TaskConstraint

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

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

type TaskEvent

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

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

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

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

type TaskQuery

+ func (p *TaskQuery) ReadField10(iprot thrift.TProtocol) error

+ func (p *TaskQuery) ReadField11(iprot thrift.TProtocol) error

+ func (p *TaskQuery) ReadField12(iprot thrift.TProtocol) error

+ func (p *TaskQuery) ReadField13(iprot thrift.TProtocol) error

+ func (p *TaskQuery) ReadField14(iprot thrift.TProtocol) error

+ func (p *TaskQuery) ReadField2(iprot thrift.TProtocol) error

+ func (p *TaskQuery) ReadField4(iprot thrift.TProtocol) error

+ func (p *TaskQuery) ReadField5(iprot thrift.TProtocol) error

+ func (p *TaskQuery) ReadField7(iprot thrift.TProtocol) error

+ func (p *TaskQuery) ReadField9(iprot thrift.TProtocol) error

type TierConfig

+ func (p *TierConfig) ReadField1(iprot thrift.TProtocol) error

+ func (p *TierConfig) ReadField2(iprot thrift.TProtocol) error

type ValueConstraint

+ func (p *ValueConstraint) ReadField1(iprot thrift.TProtocol) error

+ func (p *ValueConstraint) ReadField2(iprot thrift.TProtocol) error

type Volume

+ func (p *Volume) ReadField1(iprot thrift.TProtocol) error

+ func (p *Volume) ReadField2(iprot thrift.TProtocol) error

+ func (p *Volume) ReadField3(iprot thrift.TProtocol) error

v1.3.1

Jan 8, 2019

Changes in this version

+ var JobInstanceUpdateEvent_Message_DEFAULT string

+ var JobUpdateSettings_SlaAware_DEFAULT bool

+ var PartitionPolicy_DelaySecs_DEFAULT int64

type AuroraAdmin

+ SlaDrainHosts func(hosts *Hosts, defaultSlaPolicy *SlaPolicy, timeoutSecs int64) (r *Response, err error)

type AuroraAdminClient

+ func (p *AuroraAdminClient) SlaDrainHosts(hosts *Hosts, defaultSlaPolicy *SlaPolicy, timeoutSecs int64) (r *Response, err error)

+ type AuroraAdminSlaDrainHostsArgs struct

+ DefaultSlaPolicy *SlaPolicy

+ Hosts *Hosts

+ TimeoutSecs int64

+ func NewAuroraAdminSlaDrainHostsArgs() *AuroraAdminSlaDrainHostsArgs

+ func (p *AuroraAdminSlaDrainHostsArgs) GetDefaultSlaPolicy() *SlaPolicy

+ func (p *AuroraAdminSlaDrainHostsArgs) GetHosts() *Hosts

+ func (p *AuroraAdminSlaDrainHostsArgs) GetTimeoutSecs() int64

+ func (p *AuroraAdminSlaDrainHostsArgs) IsSetDefaultSlaPolicy() bool

+ func (p *AuroraAdminSlaDrainHostsArgs) IsSetHosts() bool

+ func (p *AuroraAdminSlaDrainHostsArgs) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminSlaDrainHostsArgs) String() string

+ func (p *AuroraAdminSlaDrainHostsArgs) Write(oprot thrift.TProtocol) error

+ type AuroraAdminSlaDrainHostsResult struct

+ Success *Response

+ func NewAuroraAdminSlaDrainHostsResult() *AuroraAdminSlaDrainHostsResult

+ func (p *AuroraAdminSlaDrainHostsResult) GetSuccess() *Response

+ func (p *AuroraAdminSlaDrainHostsResult) IsSetSuccess() bool

+ func (p *AuroraAdminSlaDrainHostsResult) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminSlaDrainHostsResult) String() string

+ func (p *AuroraAdminSlaDrainHostsResult) Write(oprot thrift.TProtocol) error

+ type CoordinatorSlaPolicy struct

+ CoordinatorUrl string

+ StatusKey string

+ var SlaPolicy_CoordinatorSlaPolicy_DEFAULT *CoordinatorSlaPolicy

+ func NewCoordinatorSlaPolicy() *CoordinatorSlaPolicy

+ func (p *CoordinatorSlaPolicy) GetCoordinatorUrl() string

+ func (p *CoordinatorSlaPolicy) GetStatusKey() string

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

+ func (p *CoordinatorSlaPolicy) String() string

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

+ type CountSlaPolicy struct

+ Count int64

+ DurationSecs int64

+ var SlaPolicy_CountSlaPolicy_DEFAULT *CountSlaPolicy

+ func NewCountSlaPolicy() *CountSlaPolicy

+ func (p *CountSlaPolicy) GetCount() int64

+ func (p *CountSlaPolicy) GetDurationSecs() int64

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

+ func (p *CountSlaPolicy) String() string

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

+ type HostMaintenanceRequest struct

+ CreatedTimestampMs int64

+ DefaultSlaPolicy *SlaPolicy

+ Host string

+ TimeoutSecs int64

+ func NewHostMaintenanceRequest() *HostMaintenanceRequest

+ func (p *HostMaintenanceRequest) GetCreatedTimestampMs() int64

+ func (p *HostMaintenanceRequest) GetDefaultSlaPolicy() *SlaPolicy

+ func (p *HostMaintenanceRequest) GetHost() string

+ func (p *HostMaintenanceRequest) GetTimeoutSecs() int64

+ func (p *HostMaintenanceRequest) IsSetDefaultSlaPolicy() bool

+ func (p *HostMaintenanceRequest) Read(iprot thrift.TProtocol) error

+ func (p *HostMaintenanceRequest) String() string

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

type Hosts

+ var AuroraAdminSlaDrainHostsArgs_Hosts_DEFAULT *Hosts

type JobInstanceUpdateEvent

+ Message *string

+ func (p *JobInstanceUpdateEvent) GetMessage() string

+ func (p *JobInstanceUpdateEvent) IsSetMessage() bool

type JobUpdateSettings

+ SlaAware *bool

+ func (p *JobUpdateSettings) GetSlaAware() bool

+ func (p *JobUpdateSettings) IsSetSlaAware() bool

+ type PartitionPolicy struct

+ DelaySecs *int64

+ Reschedule bool

+ var TaskConfig_PartitionPolicy_DEFAULT *PartitionPolicy

+ func NewPartitionPolicy() *PartitionPolicy

+ func (p *PartitionPolicy) GetDelaySecs() int64

+ func (p *PartitionPolicy) GetReschedule() bool

+ func (p *PartitionPolicy) IsSetDelaySecs() bool

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

+ func (p *PartitionPolicy) String() string

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

+ type PercentageSlaPolicy struct

+ DurationSecs int64

+ Percentage float64

+ var SlaPolicy_PercentageSlaPolicy_DEFAULT *PercentageSlaPolicy

+ func NewPercentageSlaPolicy() *PercentageSlaPolicy

+ func (p *PercentageSlaPolicy) GetDurationSecs() int64

+ func (p *PercentageSlaPolicy) GetPercentage() float64

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

+ func (p *PercentageSlaPolicy) String() string

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

type Response

+ var AuroraAdminSlaDrainHostsResult_Success_DEFAULT *Response

type ScheduleStatus

+ const ScheduleStatus_PARTITIONED

type ScheduledTask

+ TimesPartitioned int32

+ func (p *ScheduledTask) GetTimesPartitioned() int32

+ type SlaPolicy struct

+ CoordinatorSlaPolicy *CoordinatorSlaPolicy

+ CountSlaPolicy *CountSlaPolicy

+ PercentageSlaPolicy *PercentageSlaPolicy

+ var AuroraAdminSlaDrainHostsArgs_DefaultSlaPolicy_DEFAULT *SlaPolicy

+ var HostMaintenanceRequest_DefaultSlaPolicy_DEFAULT *SlaPolicy

+ var TaskConfig_SlaPolicy_DEFAULT *SlaPolicy

+ func NewSlaPolicy() *SlaPolicy

+ func (p *SlaPolicy) CountSetFieldsSlaPolicy() int

+ func (p *SlaPolicy) GetCoordinatorSlaPolicy() *CoordinatorSlaPolicy

+ func (p *SlaPolicy) GetCountSlaPolicy() *CountSlaPolicy

+ func (p *SlaPolicy) GetPercentageSlaPolicy() *PercentageSlaPolicy

+ func (p *SlaPolicy) IsSetCoordinatorSlaPolicy() bool

+ func (p *SlaPolicy) IsSetCountSlaPolicy() bool

+ func (p *SlaPolicy) IsSetPercentageSlaPolicy() bool

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

+ func (p *SlaPolicy) String() string

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

type TaskConfig

+ PartitionPolicy *PartitionPolicy

+ SlaPolicy *SlaPolicy

+ func (p *TaskConfig) GetPartitionPolicy() *PartitionPolicy

+ func (p *TaskConfig) GetSlaPolicy() *SlaPolicy

+ func (p *TaskConfig) IsSetPartitionPolicy() bool

+ func (p *TaskConfig) IsSetSlaPolicy() bool

v1.3.0

Oct 5, 2018

Changes in this version

+ var TaskQuery_Environment_DEFAULT string

+ var TaskQuery_InstanceIds_DEFAULT map[int32]bool

+ var TaskQuery_JobKeys_DEFAULT map[*JobKey]bool

+ var TaskQuery_JobName_DEFAULT string

+ var TaskQuery_Limit_DEFAULT int32

+ var TaskQuery_Offset_DEFAULT int32

+ var TaskQuery_Role_DEFAULT string

+ var TaskQuery_SlaveHosts_DEFAULT map[string]bool

+ var TaskQuery_Statuses_DEFAULT map[ScheduleStatus]bool

+ var TaskQuery_TaskIds_DEFAULT map[string]bool

type TaskQuery

+ func (p *TaskQuery) IsSetEnvironment() bool

+ func (p *TaskQuery) IsSetInstanceIds() bool

+ func (p *TaskQuery) IsSetJobKeys() bool

+ func (p *TaskQuery) IsSetJobName() bool

+ func (p *TaskQuery) IsSetLimit() bool

+ func (p *TaskQuery) IsSetOffset() bool

+ func (p *TaskQuery) IsSetRole() bool

+ func (p *TaskQuery) IsSetSlaveHosts() bool

+ func (p *TaskQuery) IsSetStatuses() bool

+ func (p *TaskQuery) IsSetTaskIds() bool

v1.2.0

Jan 24, 2018

v1.1.0

Dec 23, 2017

Changes in this version

+ var AWAITNG_PULSE_JOB_UPDATE_STATES map[JobUpdateStatus]bool

+ var MesosContainer_Volumes_DEFAULT []*Volume

type AuroraAdmin

+ PruneTasks func(query *TaskQuery) (r *Response, err error)

type AuroraAdminClient

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

+ type AuroraAdminPruneTasksArgs struct

+ Query *TaskQuery

+ func NewAuroraAdminPruneTasksArgs() *AuroraAdminPruneTasksArgs

+ func (p *AuroraAdminPruneTasksArgs) GetQuery() *TaskQuery

+ func (p *AuroraAdminPruneTasksArgs) IsSetQuery() bool

+ func (p *AuroraAdminPruneTasksArgs) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminPruneTasksArgs) String() string

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

+ type AuroraAdminPruneTasksResult struct

+ Success *Response

+ func NewAuroraAdminPruneTasksResult() *AuroraAdminPruneTasksResult

+ func (p *AuroraAdminPruneTasksResult) GetSuccess() *Response

+ func (p *AuroraAdminPruneTasksResult) IsSetSuccess() bool

+ func (p *AuroraAdminPruneTasksResult) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminPruneTasksResult) String() string

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

type AuroraSchedulerManagerKillTasksArgs

+ Message string

+ func (p *AuroraSchedulerManagerKillTasksArgs) GetMessage() string

type MesosContainer

+ Volumes []*Volume

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

+ func (p *MesosContainer) IsSetVolumes() bool

type Response

+ var AuroraAdminPruneTasksResult_Success_DEFAULT *Response

type ResponseCode

+ const ResponseCode_JOB_UPDATING_ERROR

type TaskQuery

+ var AuroraAdminPruneTasksArgs_Query_DEFAULT *TaskQuery

v1.0.5

Nov 11, 2016

v1.0.4

Nov 3, 2016

v1.0.3

Nov 2, 2016

v1.0.2

Nov 2, 2016

v1.0.1

Oct 1, 2016

Changes in this version

+ const AURORA_EXECUTOR_NAME

+ const BYPASS_LEADER_REDIRECT_HEADER_NAME

+ const GOOD_IDENTIFIER_PATTERN

+ const GOOD_IDENTIFIER_PATTERN_JVM

+ const GOOD_IDENTIFIER_PATTERN_PYTHON

+ const TASK_FILESYSTEM_MOUNT_POINT

+ var ACTIVE_JOB_UPDATE_STATES map[JobUpdateStatus]bool

+ var ACTIVE_STATES map[ScheduleStatus]bool

+ var DockerContainer_Parameters_DEFAULT []*DockerParameter

+ var ExplicitReconciliationSettings_BatchSize_DEFAULT int32

+ var GoUnusedProtection__ int

+ var HostAttributes_SlaveId_DEFAULT string

+ var JobConfiguration_CronSchedule_DEFAULT string

+ var JobSummary_NextCronRunMs_DEFAULT int64

+ var JobUpdateEvent_Message_DEFAULT string

+ var JobUpdateEvent_User_DEFAULT string

+ var JobUpdateQuery_Role_DEFAULT string

+ var JobUpdateQuery_UpdateStatuses_DEFAULT map[JobUpdateStatus]bool

+ var JobUpdateQuery_User_DEFAULT string

+ var JobUpdateRequest_Metadata_DEFAULT map[*Metadata]bool

+ var JobUpdateSettings_BlockIfNoPulsesAfterMs_DEFAULT int32

+ var JobUpdateSummary_Metadata_DEFAULT map[*Metadata]bool

+ var LIVE_STATES map[ScheduleStatus]bool

+ var Lock_Message_DEFAULT string

+ var MesosFetcherURI_Cache_DEFAULT bool

+ var MesosFetcherURI_Extract_DEFAULT bool

+ var Resource_DiskMb_DEFAULT int64

+ var Resource_NamedPort_DEFAULT string

+ var Resource_NumCpus_DEFAULT float64

+ var Resource_NumGpus_DEFAULT int64

+ var Resource_RamMb_DEFAULT int64

+ var SLAVE_ASSIGNED_STATES map[ScheduleStatus]bool

+ var TERMINAL_STATES map[ScheduleStatus]bool

+ var TaskConfig_ContactEmail_DEFAULT string

+ var TaskConfig_MesosFetcherUris_DEFAULT map[*MesosFetcherURI]bool

+ var TaskConfig_Metadata_DEFAULT map[*Metadata]bool

+ var TaskConfig_Production_DEFAULT bool

+ var TaskConfig_TaskLinks_DEFAULT map[string]string

+ var TaskConfig_Tier_DEFAULT string

+ var TaskEvent_Message_DEFAULT string

+ var TaskEvent_Scheduler_DEFAULT string

+ type AppcImage struct

+ ImageId string

+ Name string

+ var Image_Appc_DEFAULT *AppcImage

+ func NewAppcImage() *AppcImage

+ func (p *AppcImage) GetImageId() string

+ func (p *AppcImage) GetName() string

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

+ func (p *AppcImage) String() string

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

+ type AssignedTask struct

+ AssignedPorts map[string]int32

+ InstanceId int32

+ SlaveHost string

+ SlaveId string

+ Task *TaskConfig

+ TaskId string

+ var ScheduledTask_AssignedTask_DEFAULT *AssignedTask

+ func NewAssignedTask() *AssignedTask

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

+ func (p *AssignedTask) GetInstanceId() int32

+ func (p *AssignedTask) GetSlaveHost() string

+ func (p *AssignedTask) GetSlaveId() string

+ func (p *AssignedTask) GetTask() *TaskConfig

+ func (p *AssignedTask) GetTaskId() string

+ func (p *AssignedTask) IsSetTask() bool

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

+ func (p *AssignedTask) String() string

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

+ type Attribute struct

+ Name string

+ Values map[string]bool

+ func NewAttribute() *Attribute

+ func (p *Attribute) GetName() string

+ func (p *Attribute) GetValues() map[string]bool

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

+ func (p *Attribute) String() string

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

+ type AuroraAdmin interface

+ CommitRecovery func() (r *Response, err error)

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

+ DrainHosts func(hosts *Hosts) (r *Response, err error)

+ EndMaintenance func(hosts *Hosts) (r *Response, err error)

+ ForceTaskState func(taskId string, status ScheduleStatus) (r *Response, err error)

+ ListBackups func() (r *Response, err error)

+ MaintenanceStatus func(hosts *Hosts) (r *Response, err error)

+ PerformBackup func() (r *Response, err error)

+ QueryRecovery func(query *TaskQuery) (r *Response, err error)

+ RewriteConfigs func(request *RewriteConfigsRequest) (r *Response, err error)

+ SetQuota func(ownerRole string, quota *ResourceAggregate) (r *Response, err error)

+ Snapshot func() (r *Response, err error)

+ StageRecovery func(backupId string) (r *Response, err error)

+ StartMaintenance func(hosts *Hosts) (r *Response, err error)

+ TriggerExplicitTaskReconciliation func(settings *ExplicitReconciliationSettings) (r *Response, err error)

+ TriggerImplicitTaskReconciliation func() (r *Response, err error)

+ UnloadRecovery func() (r *Response, err error)

+ type AuroraAdminClient struct

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

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

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

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

+ func (p *AuroraAdminClient) DrainHosts(hosts *Hosts) (r *Response, err error)

+ func (p *AuroraAdminClient) EndMaintenance(hosts *Hosts) (r *Response, err error)

+ func (p *AuroraAdminClient) ForceTaskState(taskId string, status ScheduleStatus) (r *Response, err error)

+ func (p *AuroraAdminClient) ListBackups() (r *Response, err error)

+ func (p *AuroraAdminClient) MaintenanceStatus(hosts *Hosts) (r *Response, err error)

+ func (p *AuroraAdminClient) PerformBackup() (r *Response, err error)

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

+ func (p *AuroraAdminClient) RewriteConfigs(request *RewriteConfigsRequest) (r *Response, err error)

+ func (p *AuroraAdminClient) SetQuota(ownerRole string, quota *ResourceAggregate) (r *Response, err error)

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

+ func (p *AuroraAdminClient) StageRecovery(backupId string) (r *Response, err error)

+ func (p *AuroraAdminClient) StartMaintenance(hosts *Hosts) (r *Response, err error)

+ func (p *AuroraAdminClient) TriggerExplicitTaskReconciliation(settings *ExplicitReconciliationSettings) (r *Response, err error)

+ func (p *AuroraAdminClient) TriggerImplicitTaskReconciliation() (r *Response, err error)

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

+ type AuroraAdminCommitRecoveryArgs struct

+ func NewAuroraAdminCommitRecoveryArgs() *AuroraAdminCommitRecoveryArgs

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

+ func (p *AuroraAdminCommitRecoveryArgs) String() string

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

+ type AuroraAdminCommitRecoveryResult struct

+ Success *Response

+ func NewAuroraAdminCommitRecoveryResult() *AuroraAdminCommitRecoveryResult

+ func (p *AuroraAdminCommitRecoveryResult) GetSuccess() *Response

+ func (p *AuroraAdminCommitRecoveryResult) IsSetSuccess() bool

+ func (p *AuroraAdminCommitRecoveryResult) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminCommitRecoveryResult) String() string

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

+ type AuroraAdminDeleteRecoveryTasksArgs struct

+ Query *TaskQuery

+ func NewAuroraAdminDeleteRecoveryTasksArgs() *AuroraAdminDeleteRecoveryTasksArgs

+ func (p *AuroraAdminDeleteRecoveryTasksArgs) GetQuery() *TaskQuery

+ func (p *AuroraAdminDeleteRecoveryTasksArgs) IsSetQuery() bool

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

+ func (p *AuroraAdminDeleteRecoveryTasksArgs) String() string

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

+ type AuroraAdminDeleteRecoveryTasksResult struct

+ Success *Response

+ func NewAuroraAdminDeleteRecoveryTasksResult() *AuroraAdminDeleteRecoveryTasksResult

+ func (p *AuroraAdminDeleteRecoveryTasksResult) GetSuccess() *Response

+ func (p *AuroraAdminDeleteRecoveryTasksResult) IsSetSuccess() bool

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

+ func (p *AuroraAdminDeleteRecoveryTasksResult) String() string

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

+ type AuroraAdminDrainHostsArgs struct

+ Hosts *Hosts

+ func NewAuroraAdminDrainHostsArgs() *AuroraAdminDrainHostsArgs

+ func (p *AuroraAdminDrainHostsArgs) GetHosts() *Hosts

+ func (p *AuroraAdminDrainHostsArgs) IsSetHosts() bool

+ func (p *AuroraAdminDrainHostsArgs) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminDrainHostsArgs) String() string

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

+ type AuroraAdminDrainHostsResult struct

+ Success *Response

+ func NewAuroraAdminDrainHostsResult() *AuroraAdminDrainHostsResult

+ func (p *AuroraAdminDrainHostsResult) GetSuccess() *Response

+ func (p *AuroraAdminDrainHostsResult) IsSetSuccess() bool

+ func (p *AuroraAdminDrainHostsResult) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminDrainHostsResult) String() string

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

+ type AuroraAdminEndMaintenanceArgs struct

+ Hosts *Hosts

+ func NewAuroraAdminEndMaintenanceArgs() *AuroraAdminEndMaintenanceArgs

+ func (p *AuroraAdminEndMaintenanceArgs) GetHosts() *Hosts

+ func (p *AuroraAdminEndMaintenanceArgs) IsSetHosts() bool

+ func (p *AuroraAdminEndMaintenanceArgs) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminEndMaintenanceArgs) String() string

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

+ type AuroraAdminEndMaintenanceResult struct

+ Success *Response

+ func NewAuroraAdminEndMaintenanceResult() *AuroraAdminEndMaintenanceResult

+ func (p *AuroraAdminEndMaintenanceResult) GetSuccess() *Response

+ func (p *AuroraAdminEndMaintenanceResult) IsSetSuccess() bool

+ func (p *AuroraAdminEndMaintenanceResult) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminEndMaintenanceResult) String() string

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

+ type AuroraAdminForceTaskStateArgs struct

+ Status ScheduleStatus

+ TaskId string

+ func NewAuroraAdminForceTaskStateArgs() *AuroraAdminForceTaskStateArgs

+ func (p *AuroraAdminForceTaskStateArgs) GetStatus() ScheduleStatus

+ func (p *AuroraAdminForceTaskStateArgs) GetTaskId() string

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

+ func (p *AuroraAdminForceTaskStateArgs) String() string

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

+ type AuroraAdminForceTaskStateResult struct

+ Success *Response

+ func NewAuroraAdminForceTaskStateResult() *AuroraAdminForceTaskStateResult

+ func (p *AuroraAdminForceTaskStateResult) GetSuccess() *Response

+ func (p *AuroraAdminForceTaskStateResult) IsSetSuccess() bool

+ func (p *AuroraAdminForceTaskStateResult) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminForceTaskStateResult) String() string

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

+ type AuroraAdminListBackupsArgs struct

+ func NewAuroraAdminListBackupsArgs() *AuroraAdminListBackupsArgs

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

+ func (p *AuroraAdminListBackupsArgs) String() string

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

+ type AuroraAdminListBackupsResult struct

+ Success *Response

+ func NewAuroraAdminListBackupsResult() *AuroraAdminListBackupsResult

+ func (p *AuroraAdminListBackupsResult) GetSuccess() *Response

+ func (p *AuroraAdminListBackupsResult) IsSetSuccess() bool

+ func (p *AuroraAdminListBackupsResult) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminListBackupsResult) String() string

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

+ type AuroraAdminMaintenanceStatusArgs struct

+ Hosts *Hosts

+ func NewAuroraAdminMaintenanceStatusArgs() *AuroraAdminMaintenanceStatusArgs

+ func (p *AuroraAdminMaintenanceStatusArgs) GetHosts() *Hosts

+ func (p *AuroraAdminMaintenanceStatusArgs) IsSetHosts() bool

+ func (p *AuroraAdminMaintenanceStatusArgs) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminMaintenanceStatusArgs) String() string

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

+ type AuroraAdminMaintenanceStatusResult struct

+ Success *Response

+ func NewAuroraAdminMaintenanceStatusResult() *AuroraAdminMaintenanceStatusResult

+ func (p *AuroraAdminMaintenanceStatusResult) GetSuccess() *Response

+ func (p *AuroraAdminMaintenanceStatusResult) IsSetSuccess() bool

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

+ func (p *AuroraAdminMaintenanceStatusResult) String() string

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

+ type AuroraAdminPerformBackupArgs struct

+ func NewAuroraAdminPerformBackupArgs() *AuroraAdminPerformBackupArgs

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

+ func (p *AuroraAdminPerformBackupArgs) String() string

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

+ type AuroraAdminPerformBackupResult struct

+ Success *Response

+ func NewAuroraAdminPerformBackupResult() *AuroraAdminPerformBackupResult

+ func (p *AuroraAdminPerformBackupResult) GetSuccess() *Response

+ func (p *AuroraAdminPerformBackupResult) IsSetSuccess() bool

+ func (p *AuroraAdminPerformBackupResult) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminPerformBackupResult) String() string

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

+ type AuroraAdminProcessor struct

+ func NewAuroraAdminProcessor(handler AuroraAdmin) *AuroraAdminProcessor

+ type AuroraAdminQueryRecoveryArgs struct

+ Query *TaskQuery

+ func NewAuroraAdminQueryRecoveryArgs() *AuroraAdminQueryRecoveryArgs

+ func (p *AuroraAdminQueryRecoveryArgs) GetQuery() *TaskQuery

+ func (p *AuroraAdminQueryRecoveryArgs) IsSetQuery() bool

+ func (p *AuroraAdminQueryRecoveryArgs) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminQueryRecoveryArgs) String() string

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

+ type AuroraAdminQueryRecoveryResult struct

+ Success *Response

+ func NewAuroraAdminQueryRecoveryResult() *AuroraAdminQueryRecoveryResult

+ func (p *AuroraAdminQueryRecoveryResult) GetSuccess() *Response

+ func (p *AuroraAdminQueryRecoveryResult) IsSetSuccess() bool

+ func (p *AuroraAdminQueryRecoveryResult) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminQueryRecoveryResult) String() string

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

+ type AuroraAdminRewriteConfigsArgs struct

+ Request *RewriteConfigsRequest

+ func NewAuroraAdminRewriteConfigsArgs() *AuroraAdminRewriteConfigsArgs

+ func (p *AuroraAdminRewriteConfigsArgs) GetRequest() *RewriteConfigsRequest

+ func (p *AuroraAdminRewriteConfigsArgs) IsSetRequest() bool

+ func (p *AuroraAdminRewriteConfigsArgs) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminRewriteConfigsArgs) String() string

+ func (p *AuroraAdminRewriteConfigsArgs) Write(oprot thrift.TProtocol) error

+ type AuroraAdminRewriteConfigsResult struct

+ Success *Response

+ func NewAuroraAdminRewriteConfigsResult() *AuroraAdminRewriteConfigsResult

+ func (p *AuroraAdminRewriteConfigsResult) GetSuccess() *Response

+ func (p *AuroraAdminRewriteConfigsResult) IsSetSuccess() bool

+ func (p *AuroraAdminRewriteConfigsResult) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminRewriteConfigsResult) String() string

+ func (p *AuroraAdminRewriteConfigsResult) Write(oprot thrift.TProtocol) error

+ type AuroraAdminSetQuotaArgs struct

+ OwnerRole string

+ Quota *ResourceAggregate

+ func NewAuroraAdminSetQuotaArgs() *AuroraAdminSetQuotaArgs

+ func (p *AuroraAdminSetQuotaArgs) GetOwnerRole() string

+ func (p *AuroraAdminSetQuotaArgs) GetQuota() *ResourceAggregate

+ func (p *AuroraAdminSetQuotaArgs) IsSetQuota() bool

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

+ func (p *AuroraAdminSetQuotaArgs) String() string

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

+ type AuroraAdminSetQuotaResult struct

+ Success *Response

+ func NewAuroraAdminSetQuotaResult() *AuroraAdminSetQuotaResult

+ func (p *AuroraAdminSetQuotaResult) GetSuccess() *Response

+ func (p *AuroraAdminSetQuotaResult) IsSetSuccess() bool

+ func (p *AuroraAdminSetQuotaResult) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminSetQuotaResult) String() string

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

+ type AuroraAdminSnapshotArgs struct

+ func NewAuroraAdminSnapshotArgs() *AuroraAdminSnapshotArgs

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

+ func (p *AuroraAdminSnapshotArgs) String() string

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

+ type AuroraAdminSnapshotResult struct

+ Success *Response

+ func NewAuroraAdminSnapshotResult() *AuroraAdminSnapshotResult

+ func (p *AuroraAdminSnapshotResult) GetSuccess() *Response

+ func (p *AuroraAdminSnapshotResult) IsSetSuccess() bool

+ func (p *AuroraAdminSnapshotResult) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminSnapshotResult) String() string

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

+ type AuroraAdminStageRecoveryArgs struct

+ BackupId string

+ func NewAuroraAdminStageRecoveryArgs() *AuroraAdminStageRecoveryArgs

+ func (p *AuroraAdminStageRecoveryArgs) GetBackupId() string

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

+ func (p *AuroraAdminStageRecoveryArgs) String() string

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

+ type AuroraAdminStageRecoveryResult struct

+ Success *Response

+ func NewAuroraAdminStageRecoveryResult() *AuroraAdminStageRecoveryResult

+ func (p *AuroraAdminStageRecoveryResult) GetSuccess() *Response

+ func (p *AuroraAdminStageRecoveryResult) IsSetSuccess() bool

+ func (p *AuroraAdminStageRecoveryResult) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminStageRecoveryResult) String() string

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

+ type AuroraAdminStartMaintenanceArgs struct

+ Hosts *Hosts

+ func NewAuroraAdminStartMaintenanceArgs() *AuroraAdminStartMaintenanceArgs

+ func (p *AuroraAdminStartMaintenanceArgs) GetHosts() *Hosts

+ func (p *AuroraAdminStartMaintenanceArgs) IsSetHosts() bool

+ func (p *AuroraAdminStartMaintenanceArgs) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminStartMaintenanceArgs) String() string

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

+ type AuroraAdminStartMaintenanceResult struct

+ Success *Response

+ func NewAuroraAdminStartMaintenanceResult() *AuroraAdminStartMaintenanceResult

+ func (p *AuroraAdminStartMaintenanceResult) GetSuccess() *Response

+ func (p *AuroraAdminStartMaintenanceResult) IsSetSuccess() bool

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

+ func (p *AuroraAdminStartMaintenanceResult) String() string

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

+ type AuroraAdminTriggerExplicitTaskReconciliationArgs struct

+ Settings *ExplicitReconciliationSettings

+ func NewAuroraAdminTriggerExplicitTaskReconciliationArgs() *AuroraAdminTriggerExplicitTaskReconciliationArgs

+ func (p *AuroraAdminTriggerExplicitTaskReconciliationArgs) GetSettings() *ExplicitReconciliationSettings

+ func (p *AuroraAdminTriggerExplicitTaskReconciliationArgs) IsSetSettings() bool

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

+ func (p *AuroraAdminTriggerExplicitTaskReconciliationArgs) String() string

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

+ type AuroraAdminTriggerExplicitTaskReconciliationResult struct

+ Success *Response

+ func NewAuroraAdminTriggerExplicitTaskReconciliationResult() *AuroraAdminTriggerExplicitTaskReconciliationResult

+ func (p *AuroraAdminTriggerExplicitTaskReconciliationResult) GetSuccess() *Response

+ func (p *AuroraAdminTriggerExplicitTaskReconciliationResult) IsSetSuccess() bool

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

+ func (p *AuroraAdminTriggerExplicitTaskReconciliationResult) String() string

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

+ type AuroraAdminTriggerImplicitTaskReconciliationArgs struct

+ func NewAuroraAdminTriggerImplicitTaskReconciliationArgs() *AuroraAdminTriggerImplicitTaskReconciliationArgs

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

+ func (p *AuroraAdminTriggerImplicitTaskReconciliationArgs) String() string

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

+ type AuroraAdminTriggerImplicitTaskReconciliationResult struct

+ Success *Response

+ func NewAuroraAdminTriggerImplicitTaskReconciliationResult() *AuroraAdminTriggerImplicitTaskReconciliationResult

+ func (p *AuroraAdminTriggerImplicitTaskReconciliationResult) GetSuccess() *Response

+ func (p *AuroraAdminTriggerImplicitTaskReconciliationResult) IsSetSuccess() bool

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

+ func (p *AuroraAdminTriggerImplicitTaskReconciliationResult) String() string

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

+ type AuroraAdminUnloadRecoveryArgs struct

+ func NewAuroraAdminUnloadRecoveryArgs() *AuroraAdminUnloadRecoveryArgs

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

+ func (p *AuroraAdminUnloadRecoveryArgs) String() string

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

+ type AuroraAdminUnloadRecoveryResult struct

+ Success *Response

+ func NewAuroraAdminUnloadRecoveryResult() *AuroraAdminUnloadRecoveryResult

+ func (p *AuroraAdminUnloadRecoveryResult) GetSuccess() *Response

+ func (p *AuroraAdminUnloadRecoveryResult) IsSetSuccess() bool

+ func (p *AuroraAdminUnloadRecoveryResult) Read(iprot thrift.TProtocol) error

+ func (p *AuroraAdminUnloadRecoveryResult) String() string

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

+ type AuroraSchedulerManager interface

+ AbortJobUpdate func(key *JobUpdateKey, message string) (r *Response, err error)

+ AddInstances func(key *InstanceKey, count int32) (r *Response, err error)

+ CreateJob func(description *JobConfiguration) (r *Response, err error)

+ DescheduleCronJob func(job *JobKey) (r *Response, err error)

+ KillTasks func(job *JobKey, instances map[int32]bool) (r *Response, err error)

+ PauseJobUpdate func(key *JobUpdateKey, message string) (r *Response, err error)

+ PulseJobUpdate func(key *JobUpdateKey) (r *Response, err error)

+ ReplaceCronTemplate func(config *JobConfiguration) (r *Response, err error)

+ RestartShards func(job *JobKey, shardIds map[int32]bool) (r *Response, err error)

+ ResumeJobUpdate func(key *JobUpdateKey, message string) (r *Response, err error)

+ RollbackJobUpdate func(key *JobUpdateKey, message string) (r *Response, err error)

+ ScheduleCronJob func(description *JobConfiguration) (r *Response, err error)

+ StartCronJob func(job *JobKey) (r *Response, err error)

+ StartJobUpdate func(request *JobUpdateRequest, message string) (r *Response, err error)

+ type AuroraSchedulerManagerAbortJobUpdateArgs struct

+ Key *JobUpdateKey

+ Message string

+ func NewAuroraSchedulerManagerAbortJobUpdateArgs() *AuroraSchedulerManagerAbortJobUpdateArgs

+ func (p *AuroraSchedulerManagerAbortJobUpdateArgs) GetKey() *JobUpdateKey

+ func (p *AuroraSchedulerManagerAbortJobUpdateArgs) GetMessage() string

+ func (p *AuroraSchedulerManagerAbortJobUpdateArgs) IsSetKey() bool

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

+ func (p *AuroraSchedulerManagerAbortJobUpdateArgs) String() string

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

+ type AuroraSchedulerManagerAbortJobUpdateResult struct

+ Success *Response

+ func NewAuroraSchedulerManagerAbortJobUpdateResult() *AuroraSchedulerManagerAbortJobUpdateResult

+ func (p *AuroraSchedulerManagerAbortJobUpdateResult) GetSuccess() *Response

+ func (p *AuroraSchedulerManagerAbortJobUpdateResult) IsSetSuccess() bool

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

+ func (p *AuroraSchedulerManagerAbortJobUpdateResult) String() string

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

+ type AuroraSchedulerManagerAddInstancesArgs struct

+ Count int32

+ Key *InstanceKey

+ func NewAuroraSchedulerManagerAddInstancesArgs() *AuroraSchedulerManagerAddInstancesArgs

+ func (p *AuroraSchedulerManagerAddInstancesArgs) GetCount() int32

+ func (p *AuroraSchedulerManagerAddInstancesArgs) GetKey() *InstanceKey

+ func (p *AuroraSchedulerManagerAddInstancesArgs) IsSetKey() bool

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

+ func (p *AuroraSchedulerManagerAddInstancesArgs) String() string

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

+ type AuroraSchedulerManagerAddInstancesResult struct

+ Success *Response

+ func NewAuroraSchedulerManagerAddInstancesResult() *AuroraSchedulerManagerAddInstancesResult

+ func (p *AuroraSchedulerManagerAddInstancesResult) GetSuccess() *Response

+ func (p *AuroraSchedulerManagerAddInstancesResult) IsSetSuccess() bool

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

+ func (p *AuroraSchedulerManagerAddInstancesResult) String() string

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

+ type AuroraSchedulerManagerClient struct

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

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

+ func (p *AuroraSchedulerManagerClient) AbortJobUpdate(key *JobUpdateKey, message string) (r *Response, err error)

+ func (p *AuroraSchedulerManagerClient) AddInstances(key *InstanceKey, count int32) (r *Response, err error)

+ func (p *AuroraSchedulerManagerClient) CreateJob(description *JobConfiguration) (r *Response, err error)

+ func (p *AuroraSchedulerManagerClient) DescheduleCronJob(job *JobKey) (r *Response, err error)

+ func (p *AuroraSchedulerManagerClient) KillTasks(job *JobKey, instances map[int32]bool) (r *Response, err error)

+ func (p *AuroraSchedulerManagerClient) PauseJobUpdate(key *JobUpdateKey, message string) (r *Response, err error)

+ func (p *AuroraSchedulerManagerClient) PulseJobUpdate(key *JobUpdateKey) (r *Response, err error)

+ func (p *AuroraSchedulerManagerClient) ReplaceCronTemplate(config *JobConfiguration) (r *Response, err error)

+ func (p *AuroraSchedulerManagerClient) RestartShards(job *JobKey, shardIds map[int32]bool) (r *Response, err error)

+ func (p *AuroraSchedulerManagerClient) ResumeJobUpdate(key *JobUpdateKey, message string) (r *Response, err error)

+ func (p *AuroraSchedulerManagerClient) RollbackJobUpdate(key *JobUpdateKey, message string) (r *Response, err error)

+ func (p *AuroraSchedulerManagerClient) ScheduleCronJob(description *JobConfiguration) (r *Response, err error)

+ func (p *AuroraSchedulerManagerClient) StartCronJob(job *JobKey) (r *Response, err error)

+ func (p *AuroraSchedulerManagerClient) StartJobUpdate(request *JobUpdateRequest, message string) (r *Response, err error)

+ type AuroraSchedulerManagerCreateJobArgs struct

+ Description *JobConfiguration

+ func NewAuroraSchedulerManagerCreateJobArgs() *AuroraSchedulerManagerCreateJobArgs

+ func (p *AuroraSchedulerManagerCreateJobArgs) GetDescription() *JobConfiguration

+ func (p *AuroraSchedulerManagerCreateJobArgs) IsSetDescription() bool

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

+ func (p *AuroraSchedulerManagerCreateJobArgs) String() string

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

+ type AuroraSchedulerManagerCreateJobResult struct

+ Success *Response

+ func NewAuroraSchedulerManagerCreateJobResult() *AuroraSchedulerManagerCreateJobResult

+ func (p *AuroraSchedulerManagerCreateJobResult) GetSuccess() *Response

+ func (p *AuroraSchedulerManagerCreateJobResult) IsSetSuccess() bool

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

+ func (p *AuroraSchedulerManagerCreateJobResult) String() string

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

+ type AuroraSchedulerManagerDescheduleCronJobArgs struct

+ Job *JobKey

+ func NewAuroraSchedulerManagerDescheduleCronJobArgs() *AuroraSchedulerManagerDescheduleCronJobArgs

+ func (p *AuroraSchedulerManagerDescheduleCronJobArgs) GetJob() *JobKey

+ func (p *AuroraSchedulerManagerDescheduleCronJobArgs) IsSetJob() bool

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

+ func (p *AuroraSchedulerManagerDescheduleCronJobArgs) String() string

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

+ type AuroraSchedulerManagerDescheduleCronJobResult struct

+ Success *Response

+ func NewAuroraSchedulerManagerDescheduleCronJobResult() *AuroraSchedulerManagerDescheduleCronJobResult

+ func (p *AuroraSchedulerManagerDescheduleCronJobResult) GetSuccess() *Response

+ func (p *AuroraSchedulerManagerDescheduleCronJobResult) IsSetSuccess() bool

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

+ func (p *AuroraSchedulerManagerDescheduleCronJobResult) String() string

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

+ type AuroraSchedulerManagerKillTasksArgs struct

+ Instances map[int32]bool

+ Job *JobKey

+ func NewAuroraSchedulerManagerKillTasksArgs() *AuroraSchedulerManagerKillTasksArgs

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

+ func (p *AuroraSchedulerManagerKillTasksArgs) GetJob() *JobKey

+ func (p *AuroraSchedulerManagerKillTasksArgs) IsSetJob() bool

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

+ func (p *AuroraSchedulerManagerKillTasksArgs) String() string

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

+ type AuroraSchedulerManagerKillTasksResult struct

+ Success *Response

+ func NewAuroraSchedulerManagerKillTasksResult() *AuroraSchedulerManagerKillTasksResult

+ func (p *AuroraSchedulerManagerKillTasksResult) GetSuccess() *Response

+ func (p *AuroraSchedulerManagerKillTasksResult) IsSetSuccess() bool

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

+ func (p *AuroraSchedulerManagerKillTasksResult) String() string

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

+ type AuroraSchedulerManagerPauseJobUpdateArgs struct

+ Key *JobUpdateKey

+ Message string

+ func NewAuroraSchedulerManagerPauseJobUpdateArgs() *AuroraSchedulerManagerPauseJobUpdateArgs

+ func (p *AuroraSchedulerManagerPauseJobUpdateArgs) GetKey() *JobUpdateKey

+ func (p *AuroraSchedulerManagerPauseJobUpdateArgs) GetMessage() string

+ func (p *AuroraSchedulerManagerPauseJobUpdateArgs) IsSetKey() bool

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

+ func (p *AuroraSchedulerManagerPauseJobUpdateArgs) String() string

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

+ type AuroraSchedulerManagerPauseJobUpdateResult struct

+ Success *Response

+ func NewAuroraSchedulerManagerPauseJobUpdateResult() *AuroraSchedulerManagerPauseJobUpdateResult

+ func (p *AuroraSchedulerManagerPauseJobUpdateResult) GetSuccess() *Response

+ func (p *AuroraSchedulerManagerPauseJobUpdateResult) IsSetSuccess() bool

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

+ func (p *AuroraSchedulerManagerPauseJobUpdateResult) String() string

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

+ type AuroraSchedulerManagerProcessor struct

+ func NewAuroraSchedulerManagerProcessor(handler AuroraSchedulerManager) *AuroraSchedulerManagerProcessor

+ type AuroraSchedulerManagerPulseJobUpdateArgs struct

+ Key *JobUpdateKey

+ func NewAuroraSchedulerManagerPulseJobUpdateArgs() *AuroraSchedulerManagerPulseJobUpdateArgs

+ func (p *AuroraSchedulerManagerPulseJobUpdateArgs) GetKey() *JobUpdateKey

+ func (p *AuroraSchedulerManagerPulseJobUpdateArgs) IsSetKey() bool

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

+ func (p *AuroraSchedulerManagerPulseJobUpdateArgs) String() string

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

+ type AuroraSchedulerManagerPulseJobUpdateResult struct

+ Success *Response

+ func NewAuroraSchedulerManagerPulseJobUpdateResult() *AuroraSchedulerManagerPulseJobUpdateResult

+ func (p *AuroraSchedulerManagerPulseJobUpdateResult) GetSuccess() *Response

+ func (p *AuroraSchedulerManagerPulseJobUpdateResult) IsSetSuccess() bool

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

+ func (p *AuroraSchedulerManagerPulseJobUpdateResult) String() string

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

+ type AuroraSchedulerManagerReplaceCronTemplateArgs struct

+ Config *JobConfiguration

+ func NewAuroraSchedulerManagerReplaceCronTemplateArgs() *AuroraSchedulerManagerReplaceCronTemplateArgs

+ func (p *AuroraSchedulerManagerReplaceCronTemplateArgs) GetConfig() *JobConfiguration

+ func (p *AuroraSchedulerManagerReplaceCronTemplateArgs) IsSetConfig() bool

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

+ func (p *AuroraSchedulerManagerReplaceCronTemplateArgs) String() string

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

+ type AuroraSchedulerManagerReplaceCronTemplateResult struct

+ Success *Response

+ func NewAuroraSchedulerManagerReplaceCronTemplateResult() *AuroraSchedulerManagerReplaceCronTemplateResult

+ func (p *AuroraSchedulerManagerReplaceCronTemplateResult) GetSuccess() *Response

+ func (p *AuroraSchedulerManagerReplaceCronTemplateResult) IsSetSuccess() bool

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

+ func (p *AuroraSchedulerManagerReplaceCronTemplateResult) String() string

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

+ type AuroraSchedulerManagerRestartShardsArgs struct

+ Job *JobKey

+ ShardIds map[int32]bool

+ func NewAuroraSchedulerManagerRestartShardsArgs() *AuroraSchedulerManagerRestartShardsArgs

+ func (p *AuroraSchedulerManagerRestartShardsArgs) GetJob() *JobKey

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

+ func (p *AuroraSchedulerManagerRestartShardsArgs) IsSetJob() bool

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

+ func (p *AuroraSchedulerManagerRestartShardsArgs) String() string

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

+ type AuroraSchedulerManagerRestartShardsResult struct

+ Success *Response

+ func NewAuroraSchedulerManagerRestartShardsResult() *AuroraSchedulerManagerRestartShardsResult

+ func (p *AuroraSchedulerManagerRestartShardsResult) GetSuccess() *Response

+ func (p *AuroraSchedulerManagerRestartShardsResult) IsSetSuccess() bool

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

+ func (p *AuroraSchedulerManagerRestartShardsResult) String() string

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

+ type AuroraSchedulerManagerResumeJobUpdateArgs struct

+ Key *JobUpdateKey

+ Message string

+ func NewAuroraSchedulerManagerResumeJobUpdateArgs() *AuroraSchedulerManagerResumeJobUpdateArgs

+ func (p *AuroraSchedulerManagerResumeJobUpdateArgs) GetKey() *JobUpdateKey

+ func (p *AuroraSchedulerManagerResumeJobUpdateArgs) GetMessage() string

+ func (p *AuroraSchedulerManagerResumeJobUpdateArgs) IsSetKey() bool

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

+ func (p *AuroraSchedulerManagerResumeJobUpdateArgs) String() string

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

+ type AuroraSchedulerManagerResumeJobUpdateResult struct

+ Success *Response

+ func NewAuroraSchedulerManagerResumeJobUpdateResult() *AuroraSchedulerManagerResumeJobUpdateResult

+ func (p *AuroraSchedulerManagerResumeJobUpdateResult) GetSuccess() *Response

+ func (p *AuroraSchedulerManagerResumeJobUpdateResult) IsSetSuccess() bool

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

+ func (p *AuroraSchedulerManagerResumeJobUpdateResult) String() string

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

+ type AuroraSchedulerManagerRollbackJobUpdateArgs struct

+ Key *JobUpdateKey

+ Message string

+ func NewAuroraSchedulerManagerRollbackJobUpdateArgs() *AuroraSchedulerManagerRollbackJobUpdateArgs

+ func (p *AuroraSchedulerManagerRollbackJobUpdateArgs) GetKey() *JobUpdateKey

+ func (p *AuroraSchedulerManagerRollbackJobUpdateArgs) GetMessage() string

+ func (p *AuroraSchedulerManagerRollbackJobUpdateArgs) IsSetKey() bool

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

+ func (p *AuroraSchedulerManagerRollbackJobUpdateArgs) String() string

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

+ type AuroraSchedulerManagerRollbackJobUpdateResult struct

+ Success *Response

+ func NewAuroraSchedulerManagerRollbackJobUpdateResult() *AuroraSchedulerManagerRollbackJobUpdateResult

+ func (p *AuroraSchedulerManagerRollbackJobUpdateResult) GetSuccess() *Response

+ func (p *AuroraSchedulerManagerRollbackJobUpdateResult) IsSetSuccess() bool

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

+ func (p *AuroraSchedulerManagerRollbackJobUpdateResult) String() string

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

+ type AuroraSchedulerManagerScheduleCronJobArgs struct

+ Description *JobConfiguration

+ func NewAuroraSchedulerManagerScheduleCronJobArgs() *AuroraSchedulerManagerScheduleCronJobArgs

+ func (p *AuroraSchedulerManagerScheduleCronJobArgs) GetDescription() *JobConfiguration

+ func (p *AuroraSchedulerManagerScheduleCronJobArgs) IsSetDescription() bool

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

+ func (p *AuroraSchedulerManagerScheduleCronJobArgs) String() string

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

+ type AuroraSchedulerManagerScheduleCronJobResult struct

+ Success *Response

+ func NewAuroraSchedulerManagerScheduleCronJobResult() *AuroraSchedulerManagerScheduleCronJobResult

+ func (p *AuroraSchedulerManagerScheduleCronJobResult) GetSuccess() *Response

+ func (p *AuroraSchedulerManagerScheduleCronJobResult) IsSetSuccess() bool

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

+ func (p *AuroraSchedulerManagerScheduleCronJobResult) String() string

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

+ type AuroraSchedulerManagerStartCronJobArgs struct

+ Job *JobKey

+ func NewAuroraSchedulerManagerStartCronJobArgs() *AuroraSchedulerManagerStartCronJobArgs

+ func (p *AuroraSchedulerManagerStartCronJobArgs) GetJob() *JobKey

+ func (p *AuroraSchedulerManagerStartCronJobArgs) IsSetJob() bool

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

+ func (p *AuroraSchedulerManagerStartCronJobArgs) String() string

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

+ type AuroraSchedulerManagerStartCronJobResult struct

+ Success *Response

+ func NewAuroraSchedulerManagerStartCronJobResult() *AuroraSchedulerManagerStartCronJobResult

+ func (p *AuroraSchedulerManagerStartCronJobResult) GetSuccess() *Response

+ func (p *AuroraSchedulerManagerStartCronJobResult) IsSetSuccess() bool

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

+ func (p *AuroraSchedulerManagerStartCronJobResult) String() string

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

+ type AuroraSchedulerManagerStartJobUpdateArgs struct

+ Message string

+ Request *JobUpdateRequest

+ func NewAuroraSchedulerManagerStartJobUpdateArgs() *AuroraSchedulerManagerStartJobUpdateArgs

+ func (p *AuroraSchedulerManagerStartJobUpdateArgs) GetMessage() string

+ func (p *AuroraSchedulerManagerStartJobUpdateArgs) GetRequest() *JobUpdateRequest

+ func (p *AuroraSchedulerManagerStartJobUpdateArgs) IsSetRequest() bool

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

+ func (p *AuroraSchedulerManagerStartJobUpdateArgs) String() string

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

+ type AuroraSchedulerManagerStartJobUpdateResult struct

+ Success *Response

+ func NewAuroraSchedulerManagerStartJobUpdateResult() *AuroraSchedulerManagerStartJobUpdateResult

+ func (p *AuroraSchedulerManagerStartJobUpdateResult) GetSuccess() *Response

+ func (p *AuroraSchedulerManagerStartJobUpdateResult) IsSetSuccess() bool

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

+ func (p *AuroraSchedulerManagerStartJobUpdateResult) String() string

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

+ type ConfigGroup struct

+ Config *TaskConfig

+ Instances map[*Range]bool

+ func NewConfigGroup() *ConfigGroup

+ func (p *ConfigGroup) GetConfig() *TaskConfig

+ func (p *ConfigGroup) GetInstances() map[*Range]bool

+ func (p *ConfigGroup) IsSetConfig() bool

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

+ func (p *ConfigGroup) String() string

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

+ type ConfigRewrite struct

+ InstanceRewrite *InstanceConfigRewrite

+ JobRewrite *JobConfigRewrite

+ func NewConfigRewrite() *ConfigRewrite

+ func (p *ConfigRewrite) CountSetFieldsConfigRewrite() int

+ func (p *ConfigRewrite) GetInstanceRewrite() *InstanceConfigRewrite

+ func (p *ConfigRewrite) GetJobRewrite() *JobConfigRewrite

+ func (p *ConfigRewrite) IsSetInstanceRewrite() bool

+ func (p *ConfigRewrite) IsSetJobRewrite() bool

+ func (p *ConfigRewrite) Read(iprot thrift.TProtocol) error

+ func (p *ConfigRewrite) String() string

+ func (p *ConfigRewrite) Write(oprot thrift.TProtocol) error

+ type ConfigSummary struct

+ Groups map[*ConfigGroup]bool

+ Key *JobKey

+ var ConfigSummaryResult__Summary_DEFAULT *ConfigSummary

+ func NewConfigSummary() *ConfigSummary

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

+ func (p *ConfigSummary) GetKey() *JobKey

+ func (p *ConfigSummary) IsSetKey() bool

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

+ func (p *ConfigSummary) String() string

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

+ type ConfigSummaryResult_ struct

+ Summary *ConfigSummary

+ var Result__ConfigSummaryResult__DEFAULT *ConfigSummaryResult_

+ func NewConfigSummaryResult_() *ConfigSummaryResult_

+ func (p *ConfigSummaryResult_) GetSummary() *ConfigSummary

+ func (p *ConfigSummaryResult_) IsSetSummary() bool

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

+ func (p *ConfigSummaryResult_) String() string

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

+ type Constraint struct

+ Constraint *TaskConstraint

+ Name string

+ func NewConstraint() *Constraint

+ func (p *Constraint) GetConstraint() *TaskConstraint

+ func (p *Constraint) GetName() string

+ func (p *Constraint) IsSetConstraint() bool

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

+ func (p *Constraint) String() string

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

+ type Container struct

+ Docker *DockerContainer

+ Mesos *MesosContainer

+ var TaskConfig_Container_DEFAULT *Container = &Container{ ... }

+ func NewContainer() *Container

+ func (p *Container) CountSetFieldsContainer() int

+ func (p *Container) GetDocker() *DockerContainer

+ func (p *Container) GetMesos() *MesosContainer

+ func (p *Container) IsSetDocker() bool

+ func (p *Container) IsSetMesos() bool

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

+ func (p *Container) String() string

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

+ type CronCollisionPolicy int64

+ const CronCollisionPolicy_CANCEL_NEW

+ const CronCollisionPolicy_KILL_EXISTING

+ const CronCollisionPolicy_RUN_OVERLAP

+ func CronCollisionPolicyFromString(s string) (CronCollisionPolicy, error)

+ func CronCollisionPolicyPtr(v CronCollisionPolicy) *CronCollisionPolicy

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

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

+ func (p CronCollisionPolicy) String() string

+ type DockerContainer struct

+ Image string

+ Parameters []*DockerParameter

+ var Container_Docker_DEFAULT *DockerContainer

+ func NewDockerContainer() *DockerContainer

+ func (p *DockerContainer) GetImage() string

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

+ func (p *DockerContainer) IsSetParameters() bool

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

+ func (p *DockerContainer) String() string

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

+ type DockerImage struct

+ Name string

+ Tag string

+ var Image_Docker_DEFAULT *DockerImage

+ func NewDockerImage() *DockerImage

+ func (p *DockerImage) GetName() string

+ func (p *DockerImage) GetTag() string

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

+ func (p *DockerImage) String() string

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

+ type DockerParameter struct

+ Name string

+ Value string

+ func NewDockerParameter() *DockerParameter

+ func (p *DockerParameter) GetName() string

+ func (p *DockerParameter) GetValue() string

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

+ func (p *DockerParameter) String() string

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

+ type DrainHostsResult_ struct

+ Statuses map[*HostStatus]bool

+ var Result__DrainHostsResult__DEFAULT *DrainHostsResult_

+ func NewDrainHostsResult_() *DrainHostsResult_

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

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

+ func (p *DrainHostsResult_) String() string

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

+ type EndMaintenanceResult_ struct

+ Statuses map[*HostStatus]bool

+ var Result__EndMaintenanceResult__DEFAULT *EndMaintenanceResult_

+ func NewEndMaintenanceResult_() *EndMaintenanceResult_

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

+ func (p *EndMaintenanceResult_) Read(iprot thrift.TProtocol) error

+ func (p *EndMaintenanceResult_) String() string

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

+ type ExecutorConfig struct

+ Data string

+ Name string

+ var TaskConfig_ExecutorConfig_DEFAULT *ExecutorConfig

+ func NewExecutorConfig() *ExecutorConfig

+ func (p *ExecutorConfig) GetData() string

+ func (p *ExecutorConfig) GetName() string

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

+ func (p *ExecutorConfig) String() string

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

+ type ExplicitReconciliationSettings struct

+ BatchSize *int32

+ var AuroraAdminTriggerExplicitTaskReconciliationArgs_Settings_DEFAULT *ExplicitReconciliationSettings

+ func NewExplicitReconciliationSettings() *ExplicitReconciliationSettings

+ func (p *ExplicitReconciliationSettings) GetBatchSize() int32

+ func (p *ExplicitReconciliationSettings) IsSetBatchSize() bool

+ func (p *ExplicitReconciliationSettings) Read(iprot thrift.TProtocol) error

+ func (p *ExplicitReconciliationSettings) String() string

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

+ type GetJobUpdateDetailsResult_ struct

+ Details *JobUpdateDetails

+ DetailsList []*JobUpdateDetails

+ var Result__GetJobUpdateDetailsResult__DEFAULT *GetJobUpdateDetailsResult_

+ func NewGetJobUpdateDetailsResult_() *GetJobUpdateDetailsResult_

+ func (p *GetJobUpdateDetailsResult_) GetDetails() *JobUpdateDetails

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

+ func (p *GetJobUpdateDetailsResult_) IsSetDetails() bool

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

+ func (p *GetJobUpdateDetailsResult_) String() string

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

+ type GetJobUpdateDiffResult_ struct

+ Add map[*ConfigGroup]bool

+ Remove map[*ConfigGroup]bool

+ Unchanged map[*ConfigGroup]bool

+ Update map[*ConfigGroup]bool

+ var Result__GetJobUpdateDiffResult__DEFAULT *GetJobUpdateDiffResult_

+ func NewGetJobUpdateDiffResult_() *GetJobUpdateDiffResult_

+ func (p *GetJobUpdateDiffResult_) GetAdd() map[*ConfigGroup]bool

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

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

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

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

+ func (p *GetJobUpdateDiffResult_) String() string

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

+ type GetJobUpdateSummariesResult_ struct

+ UpdateSummaries []*JobUpdateSummary

+ var Result__GetJobUpdateSummariesResult__DEFAULT *GetJobUpdateSummariesResult_

+ func NewGetJobUpdateSummariesResult_() *GetJobUpdateSummariesResult_

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

+ func (p *GetJobUpdateSummariesResult_) Read(iprot thrift.TProtocol) error

+ func (p *GetJobUpdateSummariesResult_) String() string

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

+ type GetJobsResult_ struct

+ Configs map[*JobConfiguration]bool

+ var Result__GetJobsResult__DEFAULT *GetJobsResult_

+ func NewGetJobsResult_() *GetJobsResult_

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

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

+ func (p *GetJobsResult_) String() string

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

+ type GetPendingReasonResult_ struct

+ Reasons map[*PendingReason]bool

+ var Result__GetPendingReasonResult__DEFAULT *GetPendingReasonResult_

+ func NewGetPendingReasonResult_() *GetPendingReasonResult_

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

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

+ func (p *GetPendingReasonResult_) String() string

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

+ type GetQuotaResult_ struct

+ NonProdDedicatedConsumption *ResourceAggregate

+ NonProdSharedConsumption *ResourceAggregate

+ ProdDedicatedConsumption *ResourceAggregate

+ ProdSharedConsumption *ResourceAggregate

+ Quota *ResourceAggregate

+ var Result__GetQuotaResult__DEFAULT *GetQuotaResult_

+ func NewGetQuotaResult_() *GetQuotaResult_

+ func (p *GetQuotaResult_) GetNonProdDedicatedConsumption() *ResourceAggregate

+ func (p *GetQuotaResult_) GetNonProdSharedConsumption() *ResourceAggregate

+ func (p *GetQuotaResult_) GetProdDedicatedConsumption() *ResourceAggregate

+ func (p *GetQuotaResult_) GetProdSharedConsumption() *ResourceAggregate

+ func (p *GetQuotaResult_) GetQuota() *ResourceAggregate

+ func (p *GetQuotaResult_) IsSetNonProdDedicatedConsumption() bool

+ func (p *GetQuotaResult_) IsSetNonProdSharedConsumption() bool

+ func (p *GetQuotaResult_) IsSetProdDedicatedConsumption() bool

+ func (p *GetQuotaResult_) IsSetProdSharedConsumption() bool

+ func (p *GetQuotaResult_) IsSetQuota() bool

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

+ func (p *GetQuotaResult_) String() string

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

+ type GetTierConfigResult_ struct

+ DefaultTierName string

+ Tiers map[*TierConfig]bool

+ var Result__GetTierConfigResult__DEFAULT *GetTierConfigResult_

+ func NewGetTierConfigResult_() *GetTierConfigResult_

+ func (p *GetTierConfigResult_) GetDefaultTierName() string

+ func (p *GetTierConfigResult_) GetTiers() map[*TierConfig]bool

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

+ func (p *GetTierConfigResult_) String() string

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

+ type HostAttributes struct

+ Attributes map[*Attribute]bool

+ Host string

+ Mode *MaintenanceMode

+ SlaveId *string

+ func NewHostAttributes() *HostAttributes

+ func (p *HostAttributes) GetAttributes() map[*Attribute]bool

+ func (p *HostAttributes) GetHost() string

+ func (p *HostAttributes) GetMode() MaintenanceMode

+ func (p *HostAttributes) GetSlaveId() string

+ func (p *HostAttributes) IsSetMode() bool

+ func (p *HostAttributes) IsSetSlaveId() bool

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

+ func (p *HostAttributes) String() string

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

+ type HostStatus struct

+ Host string

+ Mode MaintenanceMode

+ func NewHostStatus() *HostStatus

+ func (p *HostStatus) GetHost() string

+ func (p *HostStatus) GetMode() MaintenanceMode

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

+ func (p *HostStatus) String() string

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

+ type Hosts struct

+ HostNames map[string]bool

+ var AuroraAdminDrainHostsArgs_Hosts_DEFAULT *Hosts

+ var AuroraAdminEndMaintenanceArgs_Hosts_DEFAULT *Hosts

+ var AuroraAdminMaintenanceStatusArgs_Hosts_DEFAULT *Hosts

+ var AuroraAdminStartMaintenanceArgs_Hosts_DEFAULT *Hosts

+ func NewHosts() *Hosts

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

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

+ func (p *Hosts) String() string

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

+ type Identity struct

+ User string

+ var JobConfiguration_Owner_DEFAULT *Identity

+ var TaskConfig_Owner_DEFAULT *Identity

+ func NewIdentity() *Identity

+ func (p *Identity) GetUser() string

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

+ func (p *Identity) String() string

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

+ type Image struct

+ Appc *AppcImage

+ Docker *DockerImage

+ var MesosContainer_Image_DEFAULT *Image

+ func NewImage() *Image

+ func (p *Image) CountSetFieldsImage() int

+ func (p *Image) GetAppc() *AppcImage

+ func (p *Image) GetDocker() *DockerImage

+ func (p *Image) IsSetAppc() bool

+ func (p *Image) IsSetDocker() bool

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

+ func (p *Image) String() string

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

+ type InstanceConfigRewrite struct

+ InstanceKey *InstanceKey

+ OldTask *TaskConfig

+ RewrittenTask *TaskConfig

+ var ConfigRewrite_InstanceRewrite_DEFAULT *InstanceConfigRewrite

+ func NewInstanceConfigRewrite() *InstanceConfigRewrite

+ func (p *InstanceConfigRewrite) GetInstanceKey() *InstanceKey

+ func (p *InstanceConfigRewrite) GetOldTask() *TaskConfig

+ func (p *InstanceConfigRewrite) GetRewrittenTask() *TaskConfig

+ func (p *InstanceConfigRewrite) IsSetInstanceKey() bool

+ func (p *InstanceConfigRewrite) IsSetOldTask() bool

+ func (p *InstanceConfigRewrite) IsSetRewrittenTask() bool

+ func (p *InstanceConfigRewrite) Read(iprot thrift.TProtocol) error

+ func (p *InstanceConfigRewrite) String() string

+ func (p *InstanceConfigRewrite) Write(oprot thrift.TProtocol) error

+ type InstanceKey struct

+ InstanceId int32

+ JobKey *JobKey

+ var AuroraSchedulerManagerAddInstancesArgs_Key_DEFAULT *InstanceKey

+ var InstanceConfigRewrite_InstanceKey_DEFAULT *InstanceKey

+ func NewInstanceKey() *InstanceKey

+ func (p *InstanceKey) GetInstanceId() int32

+ func (p *InstanceKey) GetJobKey() *JobKey

+ func (p *InstanceKey) IsSetJobKey() bool

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

+ func (p *InstanceKey) String() string

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

+ type InstanceTaskConfig struct

+ Instances map[*Range]bool

+ Task *TaskConfig

+ var JobUpdateInstructions_DesiredState_DEFAULT *InstanceTaskConfig

+ func NewInstanceTaskConfig() *InstanceTaskConfig

+ func (p *InstanceTaskConfig) GetInstances() map[*Range]bool

+ func (p *InstanceTaskConfig) GetTask() *TaskConfig

+ func (p *InstanceTaskConfig) IsSetTask() bool

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

+ func (p *InstanceTaskConfig) String() string

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

+ type JobConfigRewrite struct

+ OldJob *JobConfiguration

+ RewrittenJob *JobConfiguration

+ var ConfigRewrite_JobRewrite_DEFAULT *JobConfigRewrite

+ func NewJobConfigRewrite() *JobConfigRewrite

+ func (p *JobConfigRewrite) GetOldJob() *JobConfiguration

+ func (p *JobConfigRewrite) GetRewrittenJob() *JobConfiguration

+ func (p *JobConfigRewrite) IsSetOldJob() bool

+ func (p *JobConfigRewrite) IsSetRewrittenJob() bool

+ func (p *JobConfigRewrite) Read(iprot thrift.TProtocol) error

+ func (p *JobConfigRewrite) String() string

+ func (p *JobConfigRewrite) Write(oprot thrift.TProtocol) error

+ type JobConfiguration struct

+ CronCollisionPolicy CronCollisionPolicy

+ CronSchedule *string

+ InstanceCount int32

+ Key *JobKey

+ Owner *Identity

+ TaskConfig *TaskConfig

+ var AuroraSchedulerManagerCreateJobArgs_Description_DEFAULT *JobConfiguration

+ var AuroraSchedulerManagerReplaceCronTemplateArgs_Config_DEFAULT *JobConfiguration

+ var AuroraSchedulerManagerScheduleCronJobArgs_Description_DEFAULT *JobConfiguration

+ var JobConfigRewrite_OldJob_DEFAULT *JobConfiguration

+ var JobConfigRewrite_RewrittenJob_DEFAULT *JobConfiguration

+ var JobSummary_Job_DEFAULT *JobConfiguration

+ var ReadOnlySchedulerPopulateJobConfigArgs_Description_DEFAULT *JobConfiguration

+ func NewJobConfiguration() *JobConfiguration

+ func (p *JobConfiguration) GetCronCollisionPolicy() CronCollisionPolicy

+ func (p *JobConfiguration) GetCronSchedule() string

+ func (p *JobConfiguration) GetInstanceCount() int32

+ func (p *JobConfiguration) GetKey() *JobKey

+ func (p *JobConfiguration) GetOwner() *Identity

+ func (p *JobConfiguration) GetTaskConfig() *TaskConfig

+ func (p *JobConfiguration) IsSetCronSchedule() bool

+ func (p *JobConfiguration) IsSetKey() bool

+ func (p *JobConfiguration) IsSetOwner() bool

+ func (p *JobConfiguration) IsSetTaskConfig() bool

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

+ func (p *JobConfiguration) String() string

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

+ type JobInstanceUpdateEvent struct

+ Action JobUpdateAction

+ InstanceId int32

+ TimestampMs int64

+ func NewJobInstanceUpdateEvent() *JobInstanceUpdateEvent

+ func (p *JobInstanceUpdateEvent) GetAction() JobUpdateAction

+ func (p *JobInstanceUpdateEvent) GetInstanceId() int32

+ func (p *JobInstanceUpdateEvent) GetTimestampMs() int64

+ func (p *JobInstanceUpdateEvent) Read(iprot thrift.TProtocol) error

+ func (p *JobInstanceUpdateEvent) String() string

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

+ type JobKey struct

+ Environment string

+ Name string

+ Role string

+ 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() *JobKey

+ func (p *JobKey) GetEnvironment() string

+ func (p *JobKey) GetName() string

+ func (p *JobKey) GetRole() string

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

+ func (p *JobKey) String() string

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

+ type JobStats struct

+ ActiveTaskCount int32

+ FailedTaskCount int32

+ FinishedTaskCount int32

+ PendingTaskCount int32

+ var JobSummary_Stats_DEFAULT *JobStats

+ func NewJobStats() *JobStats

+ func (p *JobStats) GetActiveTaskCount() int32

+ func (p *JobStats) GetFailedTaskCount() int32

+ func (p *JobStats) GetFinishedTaskCount() int32

+ func (p *JobStats) GetPendingTaskCount() int32

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

+ func (p *JobStats) String() string

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

+ type JobSummary struct

+ Job *JobConfiguration

+ NextCronRunMs *int64

+ Stats *JobStats

+ func NewJobSummary() *JobSummary

+ func (p *JobSummary) GetJob() *JobConfiguration

+ func (p *JobSummary) GetNextCronRunMs() int64

+ func (p *JobSummary) GetStats() *JobStats

+ func (p *JobSummary) IsSetJob() bool

+ func (p *JobSummary) IsSetNextCronRunMs() bool

+ func (p *JobSummary) IsSetStats() bool

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

+ func (p *JobSummary) String() string

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

+ type JobSummaryResult_ struct

+ Summaries map[*JobSummary]bool

+ var Result__JobSummaryResult__DEFAULT *JobSummaryResult_

+ func NewJobSummaryResult_() *JobSummaryResult_

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

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

+ func (p *JobSummaryResult_) String() string

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

+ type JobUpdate struct

+ Instructions *JobUpdateInstructions

+ Summary *JobUpdateSummary

+ var JobUpdateDetails_Update_DEFAULT *JobUpdate

+ func NewJobUpdate() *JobUpdate

+ func (p *JobUpdate) GetInstructions() *JobUpdateInstructions

+ func (p *JobUpdate) GetSummary() *JobUpdateSummary

+ func (p *JobUpdate) IsSetInstructions() bool

+ func (p *JobUpdate) IsSetSummary() bool

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

+ func (p *JobUpdate) String() string

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

+ type JobUpdateAction int64

+ const JobUpdateAction_INSTANCE_ROLLBACK_FAILED

+ const JobUpdateAction_INSTANCE_ROLLED_BACK

+ const JobUpdateAction_INSTANCE_ROLLING_BACK

+ const JobUpdateAction_INSTANCE_UPDATED

+ const JobUpdateAction_INSTANCE_UPDATE_FAILED

+ const JobUpdateAction_INSTANCE_UPDATING

+ func JobUpdateActionFromString(s string) (JobUpdateAction, error)

+ func JobUpdateActionPtr(v JobUpdateAction) *JobUpdateAction

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

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

+ func (p JobUpdateAction) String() string

+ type JobUpdateDetails struct

+ InstanceEvents []*JobInstanceUpdateEvent

+ Update *JobUpdate

+ UpdateEvents []*JobUpdateEvent

+ var GetJobUpdateDetailsResult__Details_DEFAULT *JobUpdateDetails

+ func NewJobUpdateDetails() *JobUpdateDetails

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

+ func (p *JobUpdateDetails) GetUpdate() *JobUpdate

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

+ func (p *JobUpdateDetails) IsSetUpdate() bool

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

+ func (p *JobUpdateDetails) String() string

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

+ type JobUpdateEvent struct

+ Message *string

+ Status JobUpdateStatus

+ TimestampMs int64

+ User *string

+ func NewJobUpdateEvent() *JobUpdateEvent

+ func (p *JobUpdateEvent) GetMessage() string

+ func (p *JobUpdateEvent) GetStatus() JobUpdateStatus

+ func (p *JobUpdateEvent) GetTimestampMs() int64

+ func (p *JobUpdateEvent) GetUser() string

+ func (p *JobUpdateEvent) IsSetMessage() bool

+ func (p *JobUpdateEvent) IsSetUser() bool

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

+ func (p *JobUpdateEvent) String() string

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

+ type JobUpdateInstructions struct

+ DesiredState *InstanceTaskConfig

+ InitialState map[*InstanceTaskConfig]bool

+ Settings *JobUpdateSettings

+ var JobUpdate_Instructions_DEFAULT *JobUpdateInstructions

+ func NewJobUpdateInstructions() *JobUpdateInstructions

+ func (p *JobUpdateInstructions) GetDesiredState() *InstanceTaskConfig

+ func (p *JobUpdateInstructions) GetInitialState() map[*InstanceTaskConfig]bool

+ func (p *JobUpdateInstructions) GetSettings() *JobUpdateSettings

+ func (p *JobUpdateInstructions) IsSetDesiredState() bool

+ func (p *JobUpdateInstructions) IsSetSettings() bool

+ func (p *JobUpdateInstructions) Read(iprot thrift.TProtocol) error

+ func (p *JobUpdateInstructions) String() string

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

+ type JobUpdateKey struct

+ ID string

+ Job *JobKey

+ 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() *JobUpdateKey

+ func (p *JobUpdateKey) GetID() string

+ func (p *JobUpdateKey) GetJob() *JobKey

+ func (p *JobUpdateKey) IsSetJob() bool

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

+ func (p *JobUpdateKey) String() string

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

+ type JobUpdatePulseStatus int64

+ const JobUpdatePulseStatus_FINISHED

+ const JobUpdatePulseStatus_OK

+ func JobUpdatePulseStatusFromString(s string) (JobUpdatePulseStatus, error)

+ func JobUpdatePulseStatusPtr(v JobUpdatePulseStatus) *JobUpdatePulseStatus

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

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

+ func (p JobUpdatePulseStatus) String() string

+ type JobUpdateQuery struct

+ JobKey *JobKey

+ Key *JobUpdateKey

+ Limit int32

+ Offset int32

+ Role *string

+ UpdateStatuses map[JobUpdateStatus]bool

+ User *string

+ var ReadOnlySchedulerGetJobUpdateDetailsArgs_Query_DEFAULT *JobUpdateQuery

+ var ReadOnlySchedulerGetJobUpdateSummariesArgs_JobUpdateQuery_DEFAULT *JobUpdateQuery

+ func NewJobUpdateQuery() *JobUpdateQuery

+ func (p *JobUpdateQuery) GetJobKey() *JobKey

+ func (p *JobUpdateQuery) GetKey() *JobUpdateKey

+ func (p *JobUpdateQuery) GetLimit() int32

+ func (p *JobUpdateQuery) GetOffset() int32

+ func (p *JobUpdateQuery) GetRole() string

+ func (p *JobUpdateQuery) GetUpdateStatuses() map[JobUpdateStatus]bool

+ func (p *JobUpdateQuery) GetUser() string

+ func (p *JobUpdateQuery) IsSetJobKey() bool

+ func (p *JobUpdateQuery) IsSetKey() bool

+ func (p *JobUpdateQuery) IsSetRole() bool

+ func (p *JobUpdateQuery) IsSetUpdateStatuses() bool

+ func (p *JobUpdateQuery) IsSetUser() bool

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

+ func (p *JobUpdateQuery) String() string

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

+ type JobUpdateRequest struct

+ InstanceCount int32

+ Metadata map[*Metadata]bool

+ Settings *JobUpdateSettings

+ TaskConfig *TaskConfig

+ var AuroraSchedulerManagerStartJobUpdateArgs_Request_DEFAULT *JobUpdateRequest

+ var ReadOnlySchedulerGetJobUpdateDiffArgs_Request_DEFAULT *JobUpdateRequest

+ func NewJobUpdateRequest() *JobUpdateRequest

+ func (p *JobUpdateRequest) GetInstanceCount() int32

+ func (p *JobUpdateRequest) GetMetadata() map[*Metadata]bool

+ func (p *JobUpdateRequest) GetSettings() *JobUpdateSettings

+ func (p *JobUpdateRequest) GetTaskConfig() *TaskConfig

+ func (p *JobUpdateRequest) IsSetMetadata() bool

+ func (p *JobUpdateRequest) IsSetSettings() bool

+ func (p *JobUpdateRequest) IsSetTaskConfig() bool

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

+ func (p *JobUpdateRequest) String() string

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

+ type JobUpdateSettings struct

+ BlockIfNoPulsesAfterMs *int32

+ MaxFailedInstances int32

+ MaxPerInstanceFailures int32

+ MinWaitInInstanceRunningMs int32

+ RollbackOnFailure bool

+ UpdateGroupSize int32

+ UpdateOnlyTheseInstances map[*Range]bool

+ WaitForBatchCompletion bool

+ var JobUpdateInstructions_Settings_DEFAULT *JobUpdateSettings

+ var JobUpdateRequest_Settings_DEFAULT *JobUpdateSettings

+ func NewJobUpdateSettings() *JobUpdateSettings

+ func (p *JobUpdateSettings) GetBlockIfNoPulsesAfterMs() int32

+ func (p *JobUpdateSettings) GetMaxFailedInstances() int32

+ func (p *JobUpdateSettings) GetMaxPerInstanceFailures() int32

+ func (p *JobUpdateSettings) GetMinWaitInInstanceRunningMs() int32

+ func (p *JobUpdateSettings) GetRollbackOnFailure() bool

+ func (p *JobUpdateSettings) GetUpdateGroupSize() int32

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

+ func (p *JobUpdateSettings) GetWaitForBatchCompletion() bool

+ func (p *JobUpdateSettings) IsSetBlockIfNoPulsesAfterMs() bool

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

+ func (p *JobUpdateSettings) String() string

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

+ type JobUpdateState struct

+ CreatedTimestampMs int64

+ LastModifiedTimestampMs int64

+ Status JobUpdateStatus

+ var JobUpdateSummary_State_DEFAULT *JobUpdateState

+ func NewJobUpdateState() *JobUpdateState

+ func (p *JobUpdateState) GetCreatedTimestampMs() int64

+ func (p *JobUpdateState) GetLastModifiedTimestampMs() int64

+ func (p *JobUpdateState) GetStatus() JobUpdateStatus

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

+ func (p *JobUpdateState) String() string

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

+ type JobUpdateStatus int64

+ const JobUpdateStatus_ABORTED

+ const JobUpdateStatus_ERROR

+ const JobUpdateStatus_FAILED

+ const JobUpdateStatus_ROLLED_BACK

+ const JobUpdateStatus_ROLLED_FORWARD

+ const JobUpdateStatus_ROLLING_BACK

+ const JobUpdateStatus_ROLLING_FORWARD

+ const JobUpdateStatus_ROLL_BACK_AWAITING_PULSE

+ const JobUpdateStatus_ROLL_BACK_PAUSED

+ const JobUpdateStatus_ROLL_FORWARD_AWAITING_PULSE

+ const JobUpdateStatus_ROLL_FORWARD_PAUSED

+ func JobUpdateStatusFromString(s string) (JobUpdateStatus, error)

+ func JobUpdateStatusPtr(v JobUpdateStatus) *JobUpdateStatus

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

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

+ func (p JobUpdateStatus) String() string

+ type JobUpdateSummary struct

+ Key *JobUpdateKey

+ Metadata map[*Metadata]bool

+ State *JobUpdateState

+ User string

+ var JobUpdate_Summary_DEFAULT *JobUpdateSummary

+ var StartJobUpdateResult__UpdateSummary_DEFAULT *JobUpdateSummary

+ func NewJobUpdateSummary() *JobUpdateSummary

+ func (p *JobUpdateSummary) GetKey() *JobUpdateKey

+ func (p *JobUpdateSummary) GetMetadata() map[*Metadata]bool

+ func (p *JobUpdateSummary) GetState() *JobUpdateState

+ func (p *JobUpdateSummary) GetUser() string

+ func (p *JobUpdateSummary) IsSetKey() bool

+ func (p *JobUpdateSummary) IsSetMetadata() bool

+ func (p *JobUpdateSummary) IsSetState() bool

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

+ func (p *JobUpdateSummary) String() string

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

+ type LimitConstraint struct

+ Limit int32

+ var TaskConstraint_Limit_DEFAULT *LimitConstraint

+ func NewLimitConstraint() *LimitConstraint

+ func (p *LimitConstraint) GetLimit() int32

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

+ func (p *LimitConstraint) String() string

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

+ type ListBackupsResult_ struct

+ Backups map[string]bool

+ var Result__ListBackupsResult__DEFAULT *ListBackupsResult_

+ func NewListBackupsResult_() *ListBackupsResult_

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

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

+ func (p *ListBackupsResult_) String() string

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

+ type Lock struct

+ Key *LockKey

+ Message *string

+ TimestampMs int64

+ Token string

+ User string

+ func NewLock() *Lock

+ func (p *Lock) GetKey() *LockKey

+ func (p *Lock) GetMessage() string

+ func (p *Lock) GetTimestampMs() int64

+ func (p *Lock) GetToken() string

+ func (p *Lock) GetUser() string

+ func (p *Lock) IsSetKey() bool

+ func (p *Lock) IsSetMessage() bool

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

+ func (p *Lock) String() string

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

+ type LockKey struct

+ Job *JobKey

+ var Lock_Key_DEFAULT *LockKey

+ func NewLockKey() *LockKey

+ func (p *LockKey) CountSetFieldsLockKey() int

+ func (p *LockKey) GetJob() *JobKey

+ func (p *LockKey) IsSetJob() bool

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

+ func (p *LockKey) String() string

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

+ type MaintenanceMode int64

+ const MaintenanceMode_DRAINED

+ const MaintenanceMode_DRAINING

+ const MaintenanceMode_NONE

+ const MaintenanceMode_SCHEDULED

+ var HostAttributes_Mode_DEFAULT MaintenanceMode

+ func MaintenanceModeFromString(s string) (MaintenanceMode, error)

+ func MaintenanceModePtr(v MaintenanceMode) *MaintenanceMode

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

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

+ func (p MaintenanceMode) String() string

+ type MaintenanceStatusResult_ struct

+ Statuses map[*HostStatus]bool

+ var Result__MaintenanceStatusResult__DEFAULT *MaintenanceStatusResult_

+ func NewMaintenanceStatusResult_() *MaintenanceStatusResult_

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

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

+ func (p *MaintenanceStatusResult_) String() string

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

+ type MesosContainer struct

+ Image *Image

+ var Container_Mesos_DEFAULT *MesosContainer

+ func NewMesosContainer() *MesosContainer

+ func (p *MesosContainer) GetImage() *Image

+ func (p *MesosContainer) IsSetImage() bool

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

+ func (p *MesosContainer) String() string

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

+ type MesosFetcherURI struct

+ Cache *bool

+ Extract *bool

+ Value string

+ func NewMesosFetcherURI() *MesosFetcherURI

+ func (p *MesosFetcherURI) GetCache() bool

+ func (p *MesosFetcherURI) GetExtract() bool

+ func (p *MesosFetcherURI) GetValue() string

+ func (p *MesosFetcherURI) IsSetCache() bool

+ func (p *MesosFetcherURI) IsSetExtract() bool

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

+ func (p *MesosFetcherURI) String() string

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

+ type Metadata struct

+ Key string

+ Value string

+ func NewMetadata() *Metadata

+ func (p *Metadata) GetKey() string

+ func (p *Metadata) GetValue() string

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

+ func (p *Metadata) String() string

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

+ type Mode int64

+ const Mode_RO

+ const Mode_RW

+ func ModeFromString(s string) (Mode, error)

+ func ModePtr(v Mode) *Mode

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

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

+ func (p Mode) String() string

+ type Package struct

+ Name string

+ Role string

+ Version int32

+ func NewPackage() *Package

+ func (p *Package) GetName() string

+ func (p *Package) GetRole() string

+ func (p *Package) GetVersion() int32

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

+ func (p *Package) String() string

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

+ type PendingReason struct

+ Reason string

+ TaskId string

+ func NewPendingReason() *PendingReason

+ func (p *PendingReason) GetReason() string

+ func (p *PendingReason) GetTaskId() string

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

+ func (p *PendingReason) String() string

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

+ type PopulateJobResult_ struct

+ TaskConfig *TaskConfig

+ var Result__PopulateJobResult__DEFAULT *PopulateJobResult_

+ func NewPopulateJobResult_() *PopulateJobResult_

+ func (p *PopulateJobResult_) GetTaskConfig() *TaskConfig

+ func (p *PopulateJobResult_) IsSetTaskConfig() bool

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

+ func (p *PopulateJobResult_) String() string

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

+ type PulseJobUpdateResult_ struct

+ Status JobUpdatePulseStatus

+ var Result__PulseJobUpdateResult__DEFAULT *PulseJobUpdateResult_

+ func NewPulseJobUpdateResult_() *PulseJobUpdateResult_

+ func (p *PulseJobUpdateResult_) GetStatus() JobUpdatePulseStatus

+ func (p *PulseJobUpdateResult_) Read(iprot thrift.TProtocol) error

+ func (p *PulseJobUpdateResult_) String() string

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

+ type QueryRecoveryResult_ struct

+ Tasks map[*ScheduledTask]bool

+ var Result__QueryRecoveryResult__DEFAULT *QueryRecoveryResult_

+ func NewQueryRecoveryResult_() *QueryRecoveryResult_

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

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

+ func (p *QueryRecoveryResult_) String() string

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

+ type Range struct

+ First int32

+ Last int32

+ func NewRange() *Range

+ func (p *Range) GetFirst() int32

+ func (p *Range) GetLast() int32

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

+ func (p *Range) String() string

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

+ type ReadOnlyScheduler interface

+ GetConfigSummary func(job *JobKey) (r *Response, err error)

+ GetJobSummary func(role string) (r *Response, err error)

+ GetJobUpdateDetails func(query *JobUpdateQuery) (r *Response, err error)

+ GetJobUpdateDiff func(request *JobUpdateRequest) (r *Response, err error)

+ GetJobUpdateSummaries func(jobUpdateQuery *JobUpdateQuery) (r *Response, err error)

+ GetJobs func(ownerRole string) (r *Response, err error)

+ GetPendingReason func(query *TaskQuery) (r *Response, err error)

+ GetQuota func(ownerRole string) (r *Response, err error)

+ GetRoleSummary func() (r *Response, err error)

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

+ GetTasksWithoutConfigs func(query *TaskQuery) (r *Response, err error)

+ GetTierConfigs func() (r *Response, err error)

+ PopulateJobConfig func(description *JobConfiguration) (r *Response, err error)

+ type ReadOnlySchedulerClient struct

+ InputProtocol thrift.TProtocol

+ OutputProtocol thrift.TProtocol

+ ProtocolFactory thrift.TProtocolFactory

+ SeqId int32

+ Transport thrift.TTransport

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

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

+ func (p *ReadOnlySchedulerClient) GetConfigSummary(job *JobKey) (r *Response, err error)

+ func (p *ReadOnlySchedulerClient) GetJobSummary(role string) (r *Response, err error)

+ func (p *ReadOnlySchedulerClient) GetJobUpdateDetails(query *JobUpdateQuery) (r *Response, err error)

+ func (p *ReadOnlySchedulerClient) GetJobUpdateDiff(request *JobUpdateRequest) (r *Response, err error)

+ func (p *ReadOnlySchedulerClient) GetJobUpdateSummaries(jobUpdateQuery *JobUpdateQuery) (r *Response, err error)

+ func (p *ReadOnlySchedulerClient) GetJobs(ownerRole string) (r *Response, err error)

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

+ func (p *ReadOnlySchedulerClient) GetQuota(ownerRole string) (r *Response, err error)

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

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

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

+ func (p *ReadOnlySchedulerClient) GetTierConfigs() (r *Response, err error)

+ func (p *ReadOnlySchedulerClient) PopulateJobConfig(description *JobConfiguration) (r *Response, err error)

+ type ReadOnlySchedulerGetConfigSummaryArgs struct

+ Job *JobKey

+ func NewReadOnlySchedulerGetConfigSummaryArgs() *ReadOnlySchedulerGetConfigSummaryArgs

+ func (p *ReadOnlySchedulerGetConfigSummaryArgs) GetJob() *JobKey

+ func (p *ReadOnlySchedulerGetConfigSummaryArgs) IsSetJob() bool

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

+ func (p *ReadOnlySchedulerGetConfigSummaryArgs) String() string

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

+ type ReadOnlySchedulerGetConfigSummaryResult struct

+ Success *Response

+ func NewReadOnlySchedulerGetConfigSummaryResult() *ReadOnlySchedulerGetConfigSummaryResult

+ func (p *ReadOnlySchedulerGetConfigSummaryResult) GetSuccess() *Response

+ func (p *ReadOnlySchedulerGetConfigSummaryResult) IsSetSuccess() bool

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

+ func (p *ReadOnlySchedulerGetConfigSummaryResult) String() string

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

+ type ReadOnlySchedulerGetJobSummaryArgs struct

+ Role string

+ func NewReadOnlySchedulerGetJobSummaryArgs() *ReadOnlySchedulerGetJobSummaryArgs

+ func (p *ReadOnlySchedulerGetJobSummaryArgs) GetRole() string

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

+ func (p *ReadOnlySchedulerGetJobSummaryArgs) String() string

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

+ type ReadOnlySchedulerGetJobSummaryResult struct

+ Success *Response

+ func NewReadOnlySchedulerGetJobSummaryResult() *ReadOnlySchedulerGetJobSummaryResult

+ func (p *ReadOnlySchedulerGetJobSummaryResult) GetSuccess() *Response

+ func (p *ReadOnlySchedulerGetJobSummaryResult) IsSetSuccess() bool

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

+ func (p *ReadOnlySchedulerGetJobSummaryResult) String() string

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

+ type ReadOnlySchedulerGetJobUpdateDetailsArgs struct

+ Query *JobUpdateQuery

+ func NewReadOnlySchedulerGetJobUpdateDetailsArgs() *ReadOnlySchedulerGetJobUpdateDetailsArgs

+ func (p *ReadOnlySchedulerGetJobUpdateDetailsArgs) GetQuery() *JobUpdateQuery

+ func (p *ReadOnlySchedulerGetJobUpdateDetailsArgs) IsSetQuery() bool

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

+ func (p *ReadOnlySchedulerGetJobUpdateDetailsArgs) String() string

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

+ type ReadOnlySchedulerGetJobUpdateDetailsResult struct

+ Success *Response

+ func NewReadOnlySchedulerGetJobUpdateDetailsResult() *ReadOnlySchedulerGetJobUpdateDetailsResult

+ func (p *ReadOnlySchedulerGetJobUpdateDetailsResult) GetSuccess() *Response

+ func (p *ReadOnlySchedulerGetJobUpdateDetailsResult) IsSetSuccess() bool

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

+ func (p *ReadOnlySchedulerGetJobUpdateDetailsResult) String() string

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

+ type ReadOnlySchedulerGetJobUpdateDiffArgs struct

+ Request *JobUpdateRequest

+ func NewReadOnlySchedulerGetJobUpdateDiffArgs() *ReadOnlySchedulerGetJobUpdateDiffArgs

+ func (p *ReadOnlySchedulerGetJobUpdateDiffArgs) GetRequest() *JobUpdateRequest

+ func (p *ReadOnlySchedulerGetJobUpdateDiffArgs) IsSetRequest() bool

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

+ func (p *ReadOnlySchedulerGetJobUpdateDiffArgs) String() string

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

+ type ReadOnlySchedulerGetJobUpdateDiffResult struct

+ Success *Response

+ func NewReadOnlySchedulerGetJobUpdateDiffResult() *ReadOnlySchedulerGetJobUpdateDiffResult

+ func (p *ReadOnlySchedulerGetJobUpdateDiffResult) GetSuccess() *Response

+ func (p *ReadOnlySchedulerGetJobUpdateDiffResult) IsSetSuccess() bool

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

+ func (p *ReadOnlySchedulerGetJobUpdateDiffResult) String() string

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

+ type ReadOnlySchedulerGetJobUpdateSummariesArgs struct

+ JobUpdateQuery *JobUpdateQuery

+ func NewReadOnlySchedulerGetJobUpdateSummariesArgs() *ReadOnlySchedulerGetJobUpdateSummariesArgs

+ func (p *ReadOnlySchedulerGetJobUpdateSummariesArgs) GetJobUpdateQuery() *JobUpdateQuery

+ func (p *ReadOnlySchedulerGetJobUpdateSummariesArgs) IsSetJobUpdateQuery() bool

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

+ func (p *ReadOnlySchedulerGetJobUpdateSummariesArgs) String() string

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

+ type ReadOnlySchedulerGetJobUpdateSummariesResult struct

+ Success *Response

+ func NewReadOnlySchedulerGetJobUpdateSummariesResult() *ReadOnlySchedulerGetJobUpdateSummariesResult

+ func (p *ReadOnlySchedulerGetJobUpdateSummariesResult) GetSuccess() *Response

+ func (p *ReadOnlySchedulerGetJobUpdateSummariesResult) IsSetSuccess() bool

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

+ func (p *ReadOnlySchedulerGetJobUpdateSummariesResult) String() string

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

+ type ReadOnlySchedulerGetJobsArgs struct

+ OwnerRole string

+ func NewReadOnlySchedulerGetJobsArgs() *ReadOnlySchedulerGetJobsArgs

+ func (p *ReadOnlySchedulerGetJobsArgs) GetOwnerRole() string

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

+ func (p *ReadOnlySchedulerGetJobsArgs) String() string

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

+ type ReadOnlySchedulerGetJobsResult struct

+ Success *Response

+ func NewReadOnlySchedulerGetJobsResult() *ReadOnlySchedulerGetJobsResult

+ func (p *ReadOnlySchedulerGetJobsResult) GetSuccess() *Response

+ func (p *ReadOnlySchedulerGetJobsResult) IsSetSuccess() bool

+ func (p *ReadOnlySchedulerGetJobsResult) Read(iprot thrift.TProtocol) error

+ func (p *ReadOnlySchedulerGetJobsResult) String() string

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

+ type ReadOnlySchedulerGetPendingReasonArgs struct

+ Query *TaskQuery

+ func NewReadOnlySchedulerGetPendingReasonArgs() *ReadOnlySchedulerGetPendingReasonArgs

+ func (p *ReadOnlySchedulerGetPendingReasonArgs) GetQuery() *TaskQuery

+ func (p *ReadOnlySchedulerGetPendingReasonArgs) IsSetQuery() bool

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

+ func (p *ReadOnlySchedulerGetPendingReasonArgs) String() string

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

+ type ReadOnlySchedulerGetPendingReasonResult struct

+ Success *Response

+ func NewReadOnlySchedulerGetPendingReasonResult() *ReadOnlySchedulerGetPendingReasonResult

+ func (p *ReadOnlySchedulerGetPendingReasonResult) GetSuccess() *Response

+ func (p *ReadOnlySchedulerGetPendingReasonResult) IsSetSuccess() bool

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

+ func (p *ReadOnlySchedulerGetPendingReasonResult) String() string

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

+ type ReadOnlySchedulerGetQuotaArgs struct

+ OwnerRole string

+ func NewReadOnlySchedulerGetQuotaArgs() *ReadOnlySchedulerGetQuotaArgs

+ func (p *ReadOnlySchedulerGetQuotaArgs) GetOwnerRole() string

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

+ func (p *ReadOnlySchedulerGetQuotaArgs) String() string

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

+ type ReadOnlySchedulerGetQuotaResult struct

+ Success *Response

+ func NewReadOnlySchedulerGetQuotaResult() *ReadOnlySchedulerGetQuotaResult

+ func (p *ReadOnlySchedulerGetQuotaResult) GetSuccess() *Response

+ func (p *ReadOnlySchedulerGetQuotaResult) IsSetSuccess() bool

+ func (p *ReadOnlySchedulerGetQuotaResult) Read(iprot thrift.TProtocol) error

+ func (p *ReadOnlySchedulerGetQuotaResult) String() string

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

+ type ReadOnlySchedulerGetRoleSummaryArgs struct

+ func NewReadOnlySchedulerGetRoleSummaryArgs() *ReadOnlySchedulerGetRoleSummaryArgs

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

+ func (p *ReadOnlySchedulerGetRoleSummaryArgs) String() string

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

+ type ReadOnlySchedulerGetRoleSummaryResult struct

+ Success *Response

+ func NewReadOnlySchedulerGetRoleSummaryResult() *ReadOnlySchedulerGetRoleSummaryResult

+ func (p *ReadOnlySchedulerGetRoleSummaryResult) GetSuccess() *Response

+ func (p *ReadOnlySchedulerGetRoleSummaryResult) IsSetSuccess() bool

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

+ func (p *ReadOnlySchedulerGetRoleSummaryResult) String() string

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

+ type ReadOnlySchedulerGetTasksStatusArgs struct

+ Query *TaskQuery

+ func NewReadOnlySchedulerGetTasksStatusArgs() *ReadOnlySchedulerGetTasksStatusArgs

+ func (p *ReadOnlySchedulerGetTasksStatusArgs) GetQuery() *TaskQuery

+ func (p *ReadOnlySchedulerGetTasksStatusArgs) IsSetQuery() bool

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

+ func (p *ReadOnlySchedulerGetTasksStatusArgs) String() string

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

+ type ReadOnlySchedulerGetTasksStatusResult struct

+ Success *Response

+ func NewReadOnlySchedulerGetTasksStatusResult() *ReadOnlySchedulerGetTasksStatusResult

+ func (p *ReadOnlySchedulerGetTasksStatusResult) GetSuccess() *Response

+ func (p *ReadOnlySchedulerGetTasksStatusResult) IsSetSuccess() bool

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

+ func (p *ReadOnlySchedulerGetTasksStatusResult) String() string

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

+ type ReadOnlySchedulerGetTasksWithoutConfigsArgs struct

+ Query *TaskQuery

+ func NewReadOnlySchedulerGetTasksWithoutConfigsArgs() *ReadOnlySchedulerGetTasksWithoutConfigsArgs

+ func (p *ReadOnlySchedulerGetTasksWithoutConfigsArgs) GetQuery() *TaskQuery

+ func (p *ReadOnlySchedulerGetTasksWithoutConfigsArgs) IsSetQuery() bool

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

+ func (p *ReadOnlySchedulerGetTasksWithoutConfigsArgs) String() string

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

+ type ReadOnlySchedulerGetTasksWithoutConfigsResult struct

+ Success *Response

+ func NewReadOnlySchedulerGetTasksWithoutConfigsResult() *ReadOnlySchedulerGetTasksWithoutConfigsResult

+ func (p *ReadOnlySchedulerGetTasksWithoutConfigsResult) GetSuccess() *Response

+ func (p *ReadOnlySchedulerGetTasksWithoutConfigsResult) IsSetSuccess() bool

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

+ func (p *ReadOnlySchedulerGetTasksWithoutConfigsResult) String() string

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

+ type ReadOnlySchedulerGetTierConfigsArgs struct

+ func NewReadOnlySchedulerGetTierConfigsArgs() *ReadOnlySchedulerGetTierConfigsArgs

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

+ func (p *ReadOnlySchedulerGetTierConfigsArgs) String() string

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

+ type ReadOnlySchedulerGetTierConfigsResult struct

+ Success *Response

+ func NewReadOnlySchedulerGetTierConfigsResult() *ReadOnlySchedulerGetTierConfigsResult

+ func (p *ReadOnlySchedulerGetTierConfigsResult) GetSuccess() *Response

+ func (p *ReadOnlySchedulerGetTierConfigsResult) IsSetSuccess() bool

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

+ func (p *ReadOnlySchedulerGetTierConfigsResult) String() string

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

+ type ReadOnlySchedulerPopulateJobConfigArgs struct

+ Description *JobConfiguration

+ func NewReadOnlySchedulerPopulateJobConfigArgs() *ReadOnlySchedulerPopulateJobConfigArgs

+ func (p *ReadOnlySchedulerPopulateJobConfigArgs) GetDescription() *JobConfiguration

+ func (p *ReadOnlySchedulerPopulateJobConfigArgs) IsSetDescription() bool

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

+ func (p *ReadOnlySchedulerPopulateJobConfigArgs) String() string

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

+ type ReadOnlySchedulerPopulateJobConfigResult struct

+ Success *Response

+ func NewReadOnlySchedulerPopulateJobConfigResult() *ReadOnlySchedulerPopulateJobConfigResult

+ func (p *ReadOnlySchedulerPopulateJobConfigResult) GetSuccess() *Response

+ func (p *ReadOnlySchedulerPopulateJobConfigResult) IsSetSuccess() bool

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

+ func (p *ReadOnlySchedulerPopulateJobConfigResult) String() string

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

+ type ReadOnlySchedulerProcessor struct

+ func NewReadOnlySchedulerProcessor(handler ReadOnlyScheduler) *ReadOnlySchedulerProcessor

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

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

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

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

+ type Resource struct

+ DiskMb *int64

+ NamedPort *string

+ NumCpus *float64

+ NumGpus *int64

+ RamMb *int64

+ func NewResource() *Resource

+ func (p *Resource) CountSetFieldsResource() int

+ func (p *Resource) GetDiskMb() int64

+ func (p *Resource) GetNamedPort() string

+ func (p *Resource) GetNumCpus() float64

+ func (p *Resource) GetNumGpus() int64

+ func (p *Resource) GetRamMb() int64

+ func (p *Resource) IsSetDiskMb() bool

+ func (p *Resource) IsSetNamedPort() bool

+ func (p *Resource) IsSetNumCpus() bool

+ func (p *Resource) IsSetNumGpus() bool

+ func (p *Resource) IsSetRamMb() bool

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

+ func (p *Resource) String() string

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

+ type ResourceAggregate struct

+ DiskMb int64

+ NumCpus float64

+ RamMb int64

+ Resources map[*Resource]bool

+ 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() *ResourceAggregate

+ func (p *ResourceAggregate) GetDiskMb() int64

+ func (p *ResourceAggregate) GetNumCpus() float64

+ func (p *ResourceAggregate) GetRamMb() int64

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

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

+ func (p *ResourceAggregate) String() string

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

+ type Response struct

+ Details []*ResponseDetail

+ ResponseCode ResponseCode

+ Result_ *Result_

+ ServerInfo *ServerInfo

+ 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 AuroraAdminQueryRecoveryResult_Success_DEFAULT *Response

+ var AuroraAdminRewriteConfigsResult_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() *Response

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

+ func (p *Response) GetResponseCode() ResponseCode

+ func (p *Response) GetResult_() *Result_

+ func (p *Response) GetServerInfo() *ServerInfo

+ func (p *Response) IsSetResult_() bool

+ func (p *Response) IsSetServerInfo() bool

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

+ func (p *Response) String() string

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

+ type ResponseCode int64

+ const ResponseCode_AUTH_FAILED

+ const ResponseCode_ERROR

+ const ResponseCode_ERROR_TRANSIENT

+ const ResponseCode_INVALID_REQUEST

+ const ResponseCode_LOCK_ERROR

+ const ResponseCode_OK

+ const ResponseCode_WARNING

+ func ResponseCodeFromString(s string) (ResponseCode, error)

+ func ResponseCodePtr(v ResponseCode) *ResponseCode

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

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

+ func (p ResponseCode) String() string

+ type ResponseDetail struct

+ Message string

+ func NewResponseDetail() *ResponseDetail

+ func (p *ResponseDetail) GetMessage() string

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

+ func (p *ResponseDetail) String() string

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

+ type Result_ struct

+ ConfigSummaryResult_ *ConfigSummaryResult_

+ DrainHostsResult_ *DrainHostsResult_

+ EndMaintenanceResult_ *EndMaintenanceResult_

+ GetJobUpdateDetailsResult_ *GetJobUpdateDetailsResult_

+ GetJobUpdateDiffResult_ *GetJobUpdateDiffResult_

+ GetJobUpdateSummariesResult_ *GetJobUpdateSummariesResult_

+ GetJobsResult_ *GetJobsResult_

+ GetPendingReasonResult_ *GetPendingReasonResult_

+ GetQuotaResult_ *GetQuotaResult_

+ GetTierConfigResult_ *GetTierConfigResult_

+ JobSummaryResult_ *JobSummaryResult_

+ ListBackupsResult_ *ListBackupsResult_

+ MaintenanceStatusResult_ *MaintenanceStatusResult_

+ PopulateJobResult_ *PopulateJobResult_

+ PulseJobUpdateResult_ *PulseJobUpdateResult_

+ QueryRecoveryResult_ *QueryRecoveryResult_

+ RoleSummaryResult_ *RoleSummaryResult_

+ ScheduleStatusResult_ *ScheduleStatusResult_

+ StartJobUpdateResult_ *StartJobUpdateResult_

+ StartMaintenanceResult_ *StartMaintenanceResult_

+ var Response_Result__DEFAULT *Result_

+ func NewResult_() *Result_

+ func (p *Result_) CountSetFieldsResult_() int

+ func (p *Result_) GetConfigSummaryResult_() *ConfigSummaryResult_

+ func (p *Result_) GetDrainHostsResult_() *DrainHostsResult_

+ func (p *Result_) GetEndMaintenanceResult_() *EndMaintenanceResult_

+ func (p *Result_) GetGetJobUpdateDetailsResult_() *GetJobUpdateDetailsResult_

+ func (p *Result_) GetGetJobUpdateDiffResult_() *GetJobUpdateDiffResult_

+ func (p *Result_) GetGetJobUpdateSummariesResult_() *GetJobUpdateSummariesResult_

+ func (p *Result_) GetGetJobsResult_() *GetJobsResult_

+ func (p *Result_) GetGetPendingReasonResult_() *GetPendingReasonResult_

+ func (p *Result_) GetGetQuotaResult_() *GetQuotaResult_

+ func (p *Result_) GetGetTierConfigResult_() *GetTierConfigResult_

+ func (p *Result_) GetJobSummaryResult_() *JobSummaryResult_

+ func (p *Result_) GetListBackupsResult_() *ListBackupsResult_

+ func (p *Result_) GetMaintenanceStatusResult_() *MaintenanceStatusResult_

+ func (p *Result_) GetPopulateJobResult_() *PopulateJobResult_

+ func (p *Result_) GetPulseJobUpdateResult_() *PulseJobUpdateResult_

+ func (p *Result_) GetQueryRecoveryResult_() *QueryRecoveryResult_

+ func (p *Result_) GetRoleSummaryResult_() *RoleSummaryResult_

+ func (p *Result_) GetScheduleStatusResult_() *ScheduleStatusResult_

+ func (p *Result_) GetStartJobUpdateResult_() *StartJobUpdateResult_

+ func (p *Result_) GetStartMaintenanceResult_() *StartMaintenanceResult_

+ func (p *Result_) IsSetConfigSummaryResult_() bool

+ func (p *Result_) IsSetDrainHostsResult_() bool

+ func (p *Result_) IsSetEndMaintenanceResult_() bool

+ func (p *Result_) IsSetGetJobUpdateDetailsResult_() bool

+ func (p *Result_) IsSetGetJobUpdateDiffResult_() bool

+ func (p *Result_) IsSetGetJobUpdateSummariesResult_() bool

+ func (p *Result_) IsSetGetJobsResult_() bool

+ func (p *Result_) IsSetGetPendingReasonResult_() bool

+ func (p *Result_) IsSetGetQuotaResult_() bool

+ func (p *Result_) IsSetGetTierConfigResult_() bool

+ func (p *Result_) IsSetJobSummaryResult_() bool

+ func (p *Result_) IsSetListBackupsResult_() bool

+ func (p *Result_) IsSetMaintenanceStatusResult_() bool

+ func (p *Result_) IsSetPopulateJobResult_() bool

+ func (p *Result_) IsSetPulseJobUpdateResult_() bool

+ func (p *Result_) IsSetQueryRecoveryResult_() bool

+ func (p *Result_) IsSetRoleSummaryResult_() bool

+ func (p *Result_) IsSetScheduleStatusResult_() bool

+ func (p *Result_) IsSetStartJobUpdateResult_() bool

+ func (p *Result_) IsSetStartMaintenanceResult_() bool

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

+ func (p *Result_) String() string

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

+ type RewriteConfigsRequest struct

+ RewriteCommands []*ConfigRewrite

+ var AuroraAdminRewriteConfigsArgs_Request_DEFAULT *RewriteConfigsRequest

+ func NewRewriteConfigsRequest() *RewriteConfigsRequest

+ func (p *RewriteConfigsRequest) GetRewriteCommands() []*ConfigRewrite

+ func (p *RewriteConfigsRequest) Read(iprot thrift.TProtocol) error

+ func (p *RewriteConfigsRequest) String() string

+ func (p *RewriteConfigsRequest) Write(oprot thrift.TProtocol) error

+ type RoleSummary struct

+ CronJobCount int32

+ JobCount int32

+ Role string

+ func NewRoleSummary() *RoleSummary

+ func (p *RoleSummary) GetCronJobCount() int32

+ func (p *RoleSummary) GetJobCount() int32

+ func (p *RoleSummary) GetRole() string

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

+ func (p *RoleSummary) String() string

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

+ type RoleSummaryResult_ struct

+ Summaries map[*RoleSummary]bool

+ var Result__RoleSummaryResult__DEFAULT *RoleSummaryResult_

+ func NewRoleSummaryResult_() *RoleSummaryResult_

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

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

+ func (p *RoleSummaryResult_) String() string

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

+ type ScheduleStatus int64

+ const ScheduleStatus_ASSIGNED

+ const ScheduleStatus_DRAINING

+ const ScheduleStatus_FAILED

+ const ScheduleStatus_FINISHED

+ const ScheduleStatus_INIT

+ const ScheduleStatus_KILLED

+ const ScheduleStatus_KILLING

+ const ScheduleStatus_LOST

+ const ScheduleStatus_PENDING

+ const ScheduleStatus_PREEMPTING

+ const ScheduleStatus_RESTARTING

+ const ScheduleStatus_RUNNING

+ const ScheduleStatus_STARTING

+ const ScheduleStatus_THROTTLED

+ func ScheduleStatusFromString(s string) (ScheduleStatus, error)

+ func ScheduleStatusPtr(v ScheduleStatus) *ScheduleStatus

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

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

+ func (p ScheduleStatus) String() string

+ type ScheduleStatusResult_ struct

+ Tasks []*ScheduledTask

+ var Result__ScheduleStatusResult__DEFAULT *ScheduleStatusResult_

+ func NewScheduleStatusResult_() *ScheduleStatusResult_

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

+ func (p *ScheduleStatusResult_) Read(iprot thrift.TProtocol) error

+ func (p *ScheduleStatusResult_) String() string

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

+ type ScheduledTask struct

+ AncestorId string

+ AssignedTask *AssignedTask

+ FailureCount int32

+ Status ScheduleStatus

+ TaskEvents []*TaskEvent

+ func NewScheduledTask() *ScheduledTask

+ func (p *ScheduledTask) GetAncestorId() string

+ func (p *ScheduledTask) GetAssignedTask() *AssignedTask

+ func (p *ScheduledTask) GetFailureCount() int32

+ func (p *ScheduledTask) GetStatus() ScheduleStatus

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

+ func (p *ScheduledTask) IsSetAssignedTask() bool

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

+ func (p *ScheduledTask) String() string

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

+ type ServerInfo struct

+ ClusterName string

+ StatsUrlPrefix string

+ var Response_ServerInfo_DEFAULT *ServerInfo

+ func NewServerInfo() *ServerInfo

+ func (p *ServerInfo) GetClusterName() string

+ func (p *ServerInfo) GetStatsUrlPrefix() string

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

+ func (p *ServerInfo) String() string

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

+ type StartJobUpdateResult_ struct

+ Key *JobUpdateKey

+ UpdateSummary *JobUpdateSummary

+ var Result__StartJobUpdateResult__DEFAULT *StartJobUpdateResult_

+ func NewStartJobUpdateResult_() *StartJobUpdateResult_

+ func (p *StartJobUpdateResult_) GetKey() *JobUpdateKey

+ func (p *StartJobUpdateResult_) GetUpdateSummary() *JobUpdateSummary

+ func (p *StartJobUpdateResult_) IsSetKey() bool

+ func (p *StartJobUpdateResult_) IsSetUpdateSummary() bool

+ func (p *StartJobUpdateResult_) Read(iprot thrift.TProtocol) error

+ func (p *StartJobUpdateResult_) String() string

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

+ type StartMaintenanceResult_ struct

+ Statuses map[*HostStatus]bool

+ var Result__StartMaintenanceResult__DEFAULT *StartMaintenanceResult_

+ func NewStartMaintenanceResult_() *StartMaintenanceResult_

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

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

+ func (p *StartMaintenanceResult_) String() string

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

+ type TaskConfig struct

+ Constraints map[*Constraint]bool

+ ContactEmail *string

+ Container *Container

+ DiskMb int64

+ ExecutorConfig *ExecutorConfig

+ IsService bool

+ Job *JobKey

+ MaxTaskFailures int32

+ MesosFetcherUris map[*MesosFetcherURI]bool

+ Metadata map[*Metadata]bool

+ NumCpus float64

+ Owner *Identity

+ Priority int32

+ Production *bool

+ RamMb int64

+ RequestedPorts map[string]bool

+ Resources map[*Resource]bool

+ TaskLinks map[string]string

+ Tier *string

+ var AssignedTask_Task_DEFAULT *TaskConfig

+ var ConfigGroup_Config_DEFAULT *TaskConfig

+ var InstanceConfigRewrite_OldTask_DEFAULT *TaskConfig

+ var InstanceConfigRewrite_RewrittenTask_DEFAULT *TaskConfig

+ var InstanceTaskConfig_Task_DEFAULT *TaskConfig

+ var JobConfiguration_TaskConfig_DEFAULT *TaskConfig

+ var JobUpdateRequest_TaskConfig_DEFAULT *TaskConfig

+ var PopulateJobResult__TaskConfig_DEFAULT *TaskConfig

+ func NewTaskConfig() *TaskConfig

+ func (p *TaskConfig) GetConstraints() map[*Constraint]bool

+ func (p *TaskConfig) GetContactEmail() string

+ func (p *TaskConfig) GetContainer() *Container

+ func (p *TaskConfig) GetDiskMb() int64

+ func (p *TaskConfig) GetExecutorConfig() *ExecutorConfig

+ func (p *TaskConfig) GetIsService() bool

+ func (p *TaskConfig) GetJob() *JobKey

+ func (p *TaskConfig) GetMaxTaskFailures() int32

+ func (p *TaskConfig) GetMesosFetcherUris() map[*MesosFetcherURI]bool

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

+ func (p *TaskConfig) GetNumCpus() float64

+ func (p *TaskConfig) GetOwner() *Identity

+ func (p *TaskConfig) GetPriority() int32

+ func (p *TaskConfig) GetProduction() bool

+ func (p *TaskConfig) GetRamMb() int64

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

+ func (p *TaskConfig) GetResources() map[*Resource]bool

+ func (p *TaskConfig) GetTaskLinks() map[string]string

+ func (p *TaskConfig) GetTier() string

+ func (p *TaskConfig) IsSetContactEmail() bool

+ func (p *TaskConfig) IsSetContainer() bool

+ func (p *TaskConfig) IsSetExecutorConfig() bool

+ func (p *TaskConfig) IsSetJob() bool

+ func (p *TaskConfig) IsSetMesosFetcherUris() bool

+ func (p *TaskConfig) IsSetMetadata() bool

+ func (p *TaskConfig) IsSetOwner() bool

+ func (p *TaskConfig) IsSetProduction() bool

+ func (p *TaskConfig) IsSetTaskLinks() bool

+ func (p *TaskConfig) IsSetTier() bool

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

+ func (p *TaskConfig) String() string

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

+ type TaskConstraint struct

+ Limit *LimitConstraint

+ Value *ValueConstraint

+ var Constraint_Constraint_DEFAULT *TaskConstraint

+ func NewTaskConstraint() *TaskConstraint

+ func (p *TaskConstraint) CountSetFieldsTaskConstraint() int

+ func (p *TaskConstraint) GetLimit() *LimitConstraint

+ func (p *TaskConstraint) GetValue() *ValueConstraint

+ func (p *TaskConstraint) IsSetLimit() bool

+ func (p *TaskConstraint) IsSetValue() bool

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

+ func (p *TaskConstraint) String() string

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

+ type TaskEvent struct

+ Message *string

+ Scheduler *string

+ Status ScheduleStatus

+ Timestamp int64

+ func NewTaskEvent() *TaskEvent

+ func (p *TaskEvent) GetMessage() string

+ func (p *TaskEvent) GetScheduler() string

+ func (p *TaskEvent) GetStatus() ScheduleStatus

+ func (p *TaskEvent) GetTimestamp() int64

+ func (p *TaskEvent) IsSetMessage() bool

+ func (p *TaskEvent) IsSetScheduler() bool

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

+ func (p *TaskEvent) String() string

+ func (p *TaskEvent) Write(oprot thrift.TProtocol) error

+ type TaskQuery struct

+ Environment string

+ InstanceIds map[int32]bool

+ JobKeys map[*JobKey]bool

+ JobName string

+ Limit int32

+ Offset int32

+ Role string

+ SlaveHosts map[string]bool

+ Statuses map[ScheduleStatus]bool

+ TaskIds map[string]bool

+ var AuroraAdminDeleteRecoveryTasksArgs_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() *TaskQuery

+ func (p *TaskQuery) GetEnvironment() string

+ func (p *TaskQuery) GetInstanceIds() map[int32]bool

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

+ func (p *TaskQuery) GetJobName() string

+ func (p *TaskQuery) GetLimit() int32

+ func (p *TaskQuery) GetOffset() int32

+ func (p *TaskQuery) GetRole() string

+ func (p *TaskQuery) GetSlaveHosts() map[string]bool

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

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

+ func (p *TaskQuery) Read(iprot thrift.TProtocol) error

+ func (p *TaskQuery) String() string

+ func (p *TaskQuery) Write(oprot thrift.TProtocol) error

+ type TierConfig struct

+ Name string

+ Settings map[string]string

+ func NewTierConfig() *TierConfig

+ func (p *TierConfig) GetName() string

+ func (p *TierConfig) GetSettings() map[string]string

+ func (p *TierConfig) Read(iprot thrift.TProtocol) error

+ func (p *TierConfig) String() string

+ func (p *TierConfig) Write(oprot thrift.TProtocol) error

+ type ValueConstraint struct

+ Negated bool

+ Values map[string]bool

+ var TaskConstraint_Value_DEFAULT *ValueConstraint

+ func NewValueConstraint() *ValueConstraint

+ func (p *ValueConstraint) GetNegated() bool

+ func (p *ValueConstraint) GetValues() map[string]bool

+ func (p *ValueConstraint) Read(iprot thrift.TProtocol) error

+ func (p *ValueConstraint) String() string

+ func (p *ValueConstraint) Write(oprot thrift.TProtocol) error

+ type Volume struct

+ ContainerPath string

+ HostPath string

+ Mode Mode

+ func NewVolume() *Volume

+ func (p *Volume) GetContainerPath() string

+ func (p *Volume) GetHostPath() string

+ func (p *Volume) GetMode() Mode

+ func (p *Volume) Read(iprot thrift.TProtocol) error

+ func (p *Volume) String() string

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

Other modules containing this package

github.com/paypal/gorealis/v2

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