scoot

package
v0.0.1-alpha Latest Latest
Warning

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

 Go to latest Published: Feb 28, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CanNotScheduleNow_RetryAfterMs_DEFAULT int64
View Source 
var CloudScootGetClassLoadPercentsResult_Success_DEFAULT map[string]int32
View Source 
var CloudScootGetRebalanceMinimumDurationResult_Success_DEFAULT int32
View Source 
var CloudScootGetRebalanceThresholdResult_Success_DEFAULT int32
View Source 
var CloudScootGetRequestorToClassMapResult_Success_DEFAULT map[string]string
View Source 
var Command_EnvVars_DEFAULT map[string]string
View Source 
var GoUnusedProtection__ int
View Source 
var InvalidRequest_Message_DEFAULT string
View Source 
var JobDefinition_Basis_DEFAULT string
View Source 
var JobDefinition_DefaultTaskTimeoutMs_DEFAULT int32
View Source 
var JobDefinition_JobType_DEFAULT string
View Source 
var JobDefinition_Priority_DEFAULT int32
View Source 
var JobDefinition_Requestor_DEFAULT string
View Source 
var JobDefinition_Tag_DEFAULT string
View Source 
var JobStatus_TaskData_DEFAULT map[string]*RunStatus
View Source 
var JobStatus_TaskStatus_DEFAULT map[string]Status
View Source 
var RunStatus_BazelResult__DEFAULT *bazel.ActionResult_
View Source 
var RunStatus_ErrUri_DEFAULT string
View Source 
var RunStatus_Error_DEFAULT string
View Source 
var RunStatus_ExitCode_DEFAULT int32
View Source 
var RunStatus_JobId_DEFAULT string
View Source 
var RunStatus_OutUri_DEFAULT string
View Source 
var RunStatus_SnapshotId_DEFAULT string
View Source 
var RunStatus_Tag_DEFAULT string
View Source 
var RunStatus_TaskId_DEFAULT string
View Source 
var ScootServerError_RetryAfterMs_DEFAULT int64
View Source 
var TaskDefinition_SnapshotId_DEFAULT string
View Source 
var TaskDefinition_TaskId_DEFAULT string
View Source 
var TaskDefinition_TimeoutMs_DEFAULT int32

Functions

This section is empty.

Types

type CanNotScheduleNow 

type CanNotScheduleNow struct {
	RetryAfterMs *int64 `thrift:"retryAfterMs,1" json:"retryAfterMs,omitempty"`
}

Attributes:

  • RetryAfterMs
var CloudScootRunJobResult_Cnsn_DEFAULT *CanNotScheduleNow

func NewCanNotScheduleNow 

func NewCanNotScheduleNow() *CanNotScheduleNow

func (*CanNotScheduleNow) Error 

func (p *CanNotScheduleNow) Error() string

func (*CanNotScheduleNow) GetRetryAfterMs 

func (p *CanNotScheduleNow) GetRetryAfterMs() int64

func (*CanNotScheduleNow) IsSetRetryAfterMs 

func (p *CanNotScheduleNow) IsSetRetryAfterMs() bool

func (*CanNotScheduleNow) Read 

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

func (*CanNotScheduleNow) String 

func (p *CanNotScheduleNow) String() string

func (*CanNotScheduleNow) Write 

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

type CloudScoot 

type CloudScoot interface {
	// Parameters:
	//  - Job
	RunJob(job *JobDefinition) (r *JobId, err error)
	// Parameters:
	//  - JobId
	GetStatus(jobId string) (r *JobStatus, err error)
	// Parameters:
	//  - JobId
	KillJob(jobId string) (r *JobStatus, err error)
	// Parameters:
	//  - Req
	OfflineWorker(req *OfflineWorkerReq) (err error)
	// Parameters:
	//  - Req
	ReinstateWorker(req *ReinstateWorkerReq) (err error)
	GetSchedulerStatus() (r *SchedulerStatus, err error)
	// Parameters:
	//  - MaxTasks
	SetSchedulerStatus(maxTasks int32) (err error)
	GetClassLoadPercents() (r map[string]int32, err error)
	// Parameters:
	//  - LoadPercents
	SetClassLoadPercents(loadPercents map[string]int32) (err error)
	GetRequestorToClassMap() (r map[string]string, err error)
	// Parameters:
	//  - RequestorToClassMap
	SetRequestorToClassMap(requestorToClassMap map[string]string) (err error)
	GetRebalanceMinimumDuration() (r int32, err error)
	// Parameters:
	//  - DurationMin
	SetRebalanceMinimumDuration(durationMin int32) (err error)
	GetRebalanceThreshold() (r int32, err error)
	// Parameters:
	//  - Threshold
	SetRebalanceThreshold(threshold int32) (err error)
}

type CloudScootClient 

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

func NewCloudScootClientFactory 

func NewCloudScootClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *CloudScootClient

func NewCloudScootClientProtocol 

func NewCloudScootClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *CloudScootClient

func (*CloudScootClient) GetClassLoadPercents 

func (p *CloudScootClient) GetClassLoadPercents() (r map[string]int32, err error)

func (*CloudScootClient) GetRebalanceMinimumDuration 

func (p *CloudScootClient) GetRebalanceMinimumDuration() (r int32, err error)

func (*CloudScootClient) GetRebalanceThreshold 

func (p *CloudScootClient) GetRebalanceThreshold() (r int32, err error)

func (*CloudScootClient) GetRequestorToClassMap 

func (p *CloudScootClient) GetRequestorToClassMap() (r map[string]string, err error)

func (*CloudScootClient) GetSchedulerStatus 

func (p *CloudScootClient) GetSchedulerStatus() (r *SchedulerStatus, err error)

func (*CloudScootClient) GetStatus 

func (p *CloudScootClient) GetStatus(jobId string) (r *JobStatus, err error)

Parameters:

  • JobId

func (*CloudScootClient) KillJob 

func (p *CloudScootClient) KillJob(jobId string) (r *JobStatus, err error)

Parameters:

  • JobId

func (*CloudScootClient) OfflineWorker 

func (p *CloudScootClient) OfflineWorker(req *OfflineWorkerReq) (err error)

Parameters:

  • Req

func (*CloudScootClient) ReinstateWorker 

func (p *CloudScootClient) ReinstateWorker(req *ReinstateWorkerReq) (err error)

Parameters:

  • Req

func (*CloudScootClient) RunJob 

func (p *CloudScootClient) RunJob(job *JobDefinition) (r *JobId, err error)

Parameters:

  • Job

func (*CloudScootClient) SetClassLoadPercents 

func (p *CloudScootClient) SetClassLoadPercents(loadPercents map[string]int32) (err error)

Parameters:

  • LoadPercents

func (*CloudScootClient) SetRebalanceMinimumDuration 

func (p *CloudScootClient) SetRebalanceMinimumDuration(durationMin int32) (err error)

Parameters:

  • DurationMin

func (*CloudScootClient) SetRebalanceThreshold 

func (p *CloudScootClient) SetRebalanceThreshold(threshold int32) (err error)

Parameters:

  • Threshold

func (*CloudScootClient) SetRequestorToClassMap 

func (p *CloudScootClient) SetRequestorToClassMap(requestorToClassMap map[string]string) (err error)

Parameters:

  • RequestorToClassMap

func (*CloudScootClient) SetSchedulerStatus 

func (p *CloudScootClient) SetSchedulerStatus(maxTasks int32) (err error)

Parameters:

  • MaxTasks

type CloudScootGetClassLoadPercentsArgs 

type CloudScootGetClassLoadPercentsArgs struct {
}

func NewCloudScootGetClassLoadPercentsArgs 

func NewCloudScootGetClassLoadPercentsArgs() *CloudScootGetClassLoadPercentsArgs

func (*CloudScootGetClassLoadPercentsArgs) Read 

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

func (*CloudScootGetClassLoadPercentsArgs) String 

func (p *CloudScootGetClassLoadPercentsArgs) String() string

func (*CloudScootGetClassLoadPercentsArgs) Write 

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

type CloudScootGetClassLoadPercentsResult 

type CloudScootGetClassLoadPercentsResult struct {
	Success map[string]int32 `thrift:"success,0" json:"success,omitempty"`
	Ir      *InvalidRequest  `thrift:"ir,1" json:"ir,omitempty"`
}

Attributes:

  • Success
  • Ir

func NewCloudScootGetClassLoadPercentsResult 

func NewCloudScootGetClassLoadPercentsResult() *CloudScootGetClassLoadPercentsResult

func (*CloudScootGetClassLoadPercentsResult) GetIr 

func (p *CloudScootGetClassLoadPercentsResult) GetIr() *InvalidRequest

func (*CloudScootGetClassLoadPercentsResult) GetSuccess 

func (p *CloudScootGetClassLoadPercentsResult) GetSuccess() map[string]int32

func (*CloudScootGetClassLoadPercentsResult) IsSetIr 

func (p *CloudScootGetClassLoadPercentsResult) IsSetIr() bool

func (*CloudScootGetClassLoadPercentsResult) IsSetSuccess 

func (p *CloudScootGetClassLoadPercentsResult) IsSetSuccess() bool

func (*CloudScootGetClassLoadPercentsResult) Read 

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

func (*CloudScootGetClassLoadPercentsResult) String 

func (p *CloudScootGetClassLoadPercentsResult) String() string

func (*CloudScootGetClassLoadPercentsResult) Write 

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

type CloudScootGetRebalanceMinimumDurationArgs 

type CloudScootGetRebalanceMinimumDurationArgs struct {
}

func NewCloudScootGetRebalanceMinimumDurationArgs 

func NewCloudScootGetRebalanceMinimumDurationArgs() *CloudScootGetRebalanceMinimumDurationArgs

func (*CloudScootGetRebalanceMinimumDurationArgs) Read 

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

func (*CloudScootGetRebalanceMinimumDurationArgs) String 

func (p *CloudScootGetRebalanceMinimumDurationArgs) String() string

func (*CloudScootGetRebalanceMinimumDurationArgs) Write 

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

type CloudScootGetRebalanceMinimumDurationResult 

type CloudScootGetRebalanceMinimumDurationResult struct {
	Success *int32          `thrift:"success,0" json:"success,omitempty"`
	Ir      *InvalidRequest `thrift:"ir,1" json:"ir,omitempty"`
}

Attributes:

  • Success
  • Ir

func NewCloudScootGetRebalanceMinimumDurationResult 

func NewCloudScootGetRebalanceMinimumDurationResult() *CloudScootGetRebalanceMinimumDurationResult

func (*CloudScootGetRebalanceMinimumDurationResult) GetIr 

func (p *CloudScootGetRebalanceMinimumDurationResult) GetIr() *InvalidRequest

func (*CloudScootGetRebalanceMinimumDurationResult) GetSuccess 

func (p *CloudScootGetRebalanceMinimumDurationResult) GetSuccess() int32

func (*CloudScootGetRebalanceMinimumDurationResult) IsSetIr 

func (p *CloudScootGetRebalanceMinimumDurationResult) IsSetIr() bool

func (*CloudScootGetRebalanceMinimumDurationResult) IsSetSuccess 

func (p *CloudScootGetRebalanceMinimumDurationResult) IsSetSuccess() bool

func (*CloudScootGetRebalanceMinimumDurationResult) Read 

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

func (*CloudScootGetRebalanceMinimumDurationResult) String 

func (p *CloudScootGetRebalanceMinimumDurationResult) String() string

func (*CloudScootGetRebalanceMinimumDurationResult) Write 

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

type CloudScootGetRebalanceThresholdArgs 

type CloudScootGetRebalanceThresholdArgs struct {
}

func NewCloudScootGetRebalanceThresholdArgs 

func NewCloudScootGetRebalanceThresholdArgs() *CloudScootGetRebalanceThresholdArgs

func (*CloudScootGetRebalanceThresholdArgs) Read 

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

func (*CloudScootGetRebalanceThresholdArgs) String 

func (p *CloudScootGetRebalanceThresholdArgs) String() string

func (*CloudScootGetRebalanceThresholdArgs) Write 

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

type CloudScootGetRebalanceThresholdResult 

type CloudScootGetRebalanceThresholdResult struct {
	Success *int32          `thrift:"success,0" json:"success,omitempty"`
	Ir      *InvalidRequest `thrift:"ir,1" json:"ir,omitempty"`
}

Attributes:

  • Success
  • Ir

func NewCloudScootGetRebalanceThresholdResult 

func NewCloudScootGetRebalanceThresholdResult() *CloudScootGetRebalanceThresholdResult

func (*CloudScootGetRebalanceThresholdResult) GetIr 

func (p *CloudScootGetRebalanceThresholdResult) GetIr() *InvalidRequest

func (*CloudScootGetRebalanceThresholdResult) GetSuccess 

func (p *CloudScootGetRebalanceThresholdResult) GetSuccess() int32

func (*CloudScootGetRebalanceThresholdResult) IsSetIr 

func (p *CloudScootGetRebalanceThresholdResult) IsSetIr() bool

func (*CloudScootGetRebalanceThresholdResult) IsSetSuccess 

func (p *CloudScootGetRebalanceThresholdResult) IsSetSuccess() bool

func (*CloudScootGetRebalanceThresholdResult) Read 

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

func (*CloudScootGetRebalanceThresholdResult) String 

func (p *CloudScootGetRebalanceThresholdResult) String() string

func (*CloudScootGetRebalanceThresholdResult) Write 

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

type CloudScootGetRequestorToClassMapArgs 

type CloudScootGetRequestorToClassMapArgs struct {
}

func NewCloudScootGetRequestorToClassMapArgs 

func NewCloudScootGetRequestorToClassMapArgs() *CloudScootGetRequestorToClassMapArgs

func (*CloudScootGetRequestorToClassMapArgs) Read 

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

func (*CloudScootGetRequestorToClassMapArgs) String 

func (p *CloudScootGetRequestorToClassMapArgs) String() string

func (*CloudScootGetRequestorToClassMapArgs) Write 

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

type CloudScootGetRequestorToClassMapResult 

type CloudScootGetRequestorToClassMapResult struct {
	Success map[string]string `thrift:"success,0" json:"success,omitempty"`
	Ir      *InvalidRequest   `thrift:"ir,1" json:"ir,omitempty"`
}

Attributes:

  • Success
  • Ir

func NewCloudScootGetRequestorToClassMapResult 

func NewCloudScootGetRequestorToClassMapResult() *CloudScootGetRequestorToClassMapResult

func (*CloudScootGetRequestorToClassMapResult) GetIr 

func (p *CloudScootGetRequestorToClassMapResult) GetIr() *InvalidRequest

func (*CloudScootGetRequestorToClassMapResult) GetSuccess 

func (p *CloudScootGetRequestorToClassMapResult) GetSuccess() map[string]string

func (*CloudScootGetRequestorToClassMapResult) IsSetIr 

func (p *CloudScootGetRequestorToClassMapResult) IsSetIr() bool

func (*CloudScootGetRequestorToClassMapResult) IsSetSuccess 

func (p *CloudScootGetRequestorToClassMapResult) IsSetSuccess() bool

func (*CloudScootGetRequestorToClassMapResult) Read 

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

func (*CloudScootGetRequestorToClassMapResult) String 

func (p *CloudScootGetRequestorToClassMapResult) String() string

func (*CloudScootGetRequestorToClassMapResult) Write 

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

type CloudScootGetSchedulerStatusArgs 

type CloudScootGetSchedulerStatusArgs struct {
}

func NewCloudScootGetSchedulerStatusArgs 

func NewCloudScootGetSchedulerStatusArgs() *CloudScootGetSchedulerStatusArgs

func (*CloudScootGetSchedulerStatusArgs) Read 

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

func (*CloudScootGetSchedulerStatusArgs) String 

func (p *CloudScootGetSchedulerStatusArgs) String() string

func (*CloudScootGetSchedulerStatusArgs) Write 

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

type CloudScootGetSchedulerStatusResult 

type CloudScootGetSchedulerStatusResult struct {
	Success *SchedulerStatus  `thrift:"success,0" json:"success,omitempty"`
	Err     *ScootServerError `thrift:"err,1" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewCloudScootGetSchedulerStatusResult 

func NewCloudScootGetSchedulerStatusResult() *CloudScootGetSchedulerStatusResult

func (*CloudScootGetSchedulerStatusResult) GetErr 

func (p *CloudScootGetSchedulerStatusResult) GetErr() *ScootServerError

func (*CloudScootGetSchedulerStatusResult) GetSuccess 

func (p *CloudScootGetSchedulerStatusResult) GetSuccess() *SchedulerStatus

func (*CloudScootGetSchedulerStatusResult) IsSetErr 

func (p *CloudScootGetSchedulerStatusResult) IsSetErr() bool

func (*CloudScootGetSchedulerStatusResult) IsSetSuccess 

func (p *CloudScootGetSchedulerStatusResult) IsSetSuccess() bool

func (*CloudScootGetSchedulerStatusResult) Read 

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

func (*CloudScootGetSchedulerStatusResult) String 

func (p *CloudScootGetSchedulerStatusResult) String() string

func (*CloudScootGetSchedulerStatusResult) Write 

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

type CloudScootGetStatusArgs 

type CloudScootGetStatusArgs struct {
	JobId string `thrift:"jobId,1" json:"jobId"`
}

Attributes:

  • JobId

func NewCloudScootGetStatusArgs 

func NewCloudScootGetStatusArgs() *CloudScootGetStatusArgs

func (*CloudScootGetStatusArgs) GetJobId 

func (p *CloudScootGetStatusArgs) GetJobId() string

func (*CloudScootGetStatusArgs) Read 

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

func (*CloudScootGetStatusArgs) String 

func (p *CloudScootGetStatusArgs) String() string

func (*CloudScootGetStatusArgs) Write 

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

type CloudScootGetStatusResult 

type CloudScootGetStatusResult struct {
	Success *JobStatus        `thrift:"success,0" json:"success,omitempty"`
	Ir      *InvalidRequest   `thrift:"ir,1" json:"ir,omitempty"`
	Err     *ScootServerError `thrift:"err,2" json:"err,omitempty"`
}

Attributes:

  • Success
  • Ir
  • Err

func NewCloudScootGetStatusResult 

func NewCloudScootGetStatusResult() *CloudScootGetStatusResult

func (*CloudScootGetStatusResult) GetErr 

func (p *CloudScootGetStatusResult) GetErr() *ScootServerError

func (*CloudScootGetStatusResult) GetIr 

func (p *CloudScootGetStatusResult) GetIr() *InvalidRequest

func (*CloudScootGetStatusResult) GetSuccess 

func (p *CloudScootGetStatusResult) GetSuccess() *JobStatus

func (*CloudScootGetStatusResult) IsSetErr 

func (p *CloudScootGetStatusResult) IsSetErr() bool

func (*CloudScootGetStatusResult) IsSetIr 

func (p *CloudScootGetStatusResult) IsSetIr() bool

func (*CloudScootGetStatusResult) IsSetSuccess 

func (p *CloudScootGetStatusResult) IsSetSuccess() bool

func (*CloudScootGetStatusResult) Read 

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

func (*CloudScootGetStatusResult) String 

func (p *CloudScootGetStatusResult) String() string

func (*CloudScootGetStatusResult) Write 

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

type CloudScootKillJobArgs 

type CloudScootKillJobArgs struct {
	JobId string `thrift:"jobId,1" json:"jobId"`
}

Attributes:

  • JobId

func NewCloudScootKillJobArgs 

func NewCloudScootKillJobArgs() *CloudScootKillJobArgs

func (*CloudScootKillJobArgs) GetJobId 

func (p *CloudScootKillJobArgs) GetJobId() string

func (*CloudScootKillJobArgs) Read 

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

func (*CloudScootKillJobArgs) String 

func (p *CloudScootKillJobArgs) String() string

func (*CloudScootKillJobArgs) Write 

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

type CloudScootKillJobResult 

type CloudScootKillJobResult struct {
	Success *JobStatus        `thrift:"success,0" json:"success,omitempty"`
	Ir      *InvalidRequest   `thrift:"ir,1" json:"ir,omitempty"`
	Err     *ScootServerError `thrift:"err,2" json:"err,omitempty"`
}

Attributes:

  • Success
  • Ir
  • Err

func NewCloudScootKillJobResult 

func NewCloudScootKillJobResult() *CloudScootKillJobResult

func (*CloudScootKillJobResult) GetErr 

func (p *CloudScootKillJobResult) GetErr() *ScootServerError

func (*CloudScootKillJobResult) GetIr 

func (p *CloudScootKillJobResult) GetIr() *InvalidRequest

func (*CloudScootKillJobResult) GetSuccess 

func (p *CloudScootKillJobResult) GetSuccess() *JobStatus

func (*CloudScootKillJobResult) IsSetErr 

func (p *CloudScootKillJobResult) IsSetErr() bool

func (*CloudScootKillJobResult) IsSetIr 

func (p *CloudScootKillJobResult) IsSetIr() bool

func (*CloudScootKillJobResult) IsSetSuccess 

func (p *CloudScootKillJobResult) IsSetSuccess() bool

func (*CloudScootKillJobResult) Read 

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

func (*CloudScootKillJobResult) String 

func (p *CloudScootKillJobResult) String() string

func (*CloudScootKillJobResult) Write 

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

type CloudScootOfflineWorkerArgs 

type CloudScootOfflineWorkerArgs struct {
	Req *OfflineWorkerReq `thrift:"req,1" json:"req"`
}

Attributes:

  • Req

func NewCloudScootOfflineWorkerArgs 

func NewCloudScootOfflineWorkerArgs() *CloudScootOfflineWorkerArgs

func (*CloudScootOfflineWorkerArgs) GetReq 

func (p *CloudScootOfflineWorkerArgs) GetReq() *OfflineWorkerReq

func (*CloudScootOfflineWorkerArgs) IsSetReq 

func (p *CloudScootOfflineWorkerArgs) IsSetReq() bool

func (*CloudScootOfflineWorkerArgs) Read 

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

func (*CloudScootOfflineWorkerArgs) String 

func (p *CloudScootOfflineWorkerArgs) String() string

func (*CloudScootOfflineWorkerArgs) Write 

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

type CloudScootOfflineWorkerResult 

type CloudScootOfflineWorkerResult struct {
	Ir  *InvalidRequest   `thrift:"ir,1" json:"ir,omitempty"`
	Err *ScootServerError `thrift:"err,2" json:"err,omitempty"`
}

Attributes:

  • Ir
  • Err

func NewCloudScootOfflineWorkerResult 

func NewCloudScootOfflineWorkerResult() *CloudScootOfflineWorkerResult

func (*CloudScootOfflineWorkerResult) GetErr 

func (p *CloudScootOfflineWorkerResult) GetErr() *ScootServerError

func (*CloudScootOfflineWorkerResult) GetIr 

func (p *CloudScootOfflineWorkerResult) GetIr() *InvalidRequest

func (*CloudScootOfflineWorkerResult) IsSetErr 

func (p *CloudScootOfflineWorkerResult) IsSetErr() bool

func (*CloudScootOfflineWorkerResult) IsSetIr 

func (p *CloudScootOfflineWorkerResult) IsSetIr() bool

func (*CloudScootOfflineWorkerResult) Read 

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

func (*CloudScootOfflineWorkerResult) String 

func (p *CloudScootOfflineWorkerResult) String() string

func (*CloudScootOfflineWorkerResult) Write 

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

type CloudScootProcessor 

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

func NewCloudScootProcessor 

func NewCloudScootProcessor(handler CloudScoot) *CloudScootProcessor

func (*CloudScootProcessor) AddToProcessorMap 

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

func (*CloudScootProcessor) GetProcessorFunction 

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

func (*CloudScootProcessor) Process 

func (p *CloudScootProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*CloudScootProcessor) ProcessorMap 

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

type CloudScootReinstateWorkerArgs 

type CloudScootReinstateWorkerArgs struct {
	Req *ReinstateWorkerReq `thrift:"req,1" json:"req"`
}

Attributes:

  • Req

func NewCloudScootReinstateWorkerArgs 

func NewCloudScootReinstateWorkerArgs() *CloudScootReinstateWorkerArgs

func (*CloudScootReinstateWorkerArgs) GetReq 

func (p *CloudScootReinstateWorkerArgs) GetReq() *ReinstateWorkerReq

func (*CloudScootReinstateWorkerArgs) IsSetReq 

func (p *CloudScootReinstateWorkerArgs) IsSetReq() bool

func (*CloudScootReinstateWorkerArgs) Read 

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

func (*CloudScootReinstateWorkerArgs) String 

func (p *CloudScootReinstateWorkerArgs) String() string

func (*CloudScootReinstateWorkerArgs) Write 

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

type CloudScootReinstateWorkerResult 

type CloudScootReinstateWorkerResult struct {
	Ir  *InvalidRequest   `thrift:"ir,1" json:"ir,omitempty"`
	Err *ScootServerError `thrift:"err,2" json:"err,omitempty"`
}

Attributes:

  • Ir
  • Err

func NewCloudScootReinstateWorkerResult 

func NewCloudScootReinstateWorkerResult() *CloudScootReinstateWorkerResult

func (*CloudScootReinstateWorkerResult) GetErr 

func (p *CloudScootReinstateWorkerResult) GetErr() *ScootServerError

func (*CloudScootReinstateWorkerResult) GetIr 

func (p *CloudScootReinstateWorkerResult) GetIr() *InvalidRequest

func (*CloudScootReinstateWorkerResult) IsSetErr 

func (p *CloudScootReinstateWorkerResult) IsSetErr() bool

func (*CloudScootReinstateWorkerResult) IsSetIr 

func (p *CloudScootReinstateWorkerResult) IsSetIr() bool

func (*CloudScootReinstateWorkerResult) Read 

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

func (*CloudScootReinstateWorkerResult) String 

func (p *CloudScootReinstateWorkerResult) String() string

func (*CloudScootReinstateWorkerResult) Write 

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

type CloudScootRunJobArgs 

type CloudScootRunJobArgs struct {
	Job *JobDefinition `thrift:"job,1" json:"job"`
}

Attributes:

  • Job

func NewCloudScootRunJobArgs 

func NewCloudScootRunJobArgs() *CloudScootRunJobArgs

func (*CloudScootRunJobArgs) GetJob 

func (p *CloudScootRunJobArgs) GetJob() *JobDefinition

func (*CloudScootRunJobArgs) IsSetJob 

func (p *CloudScootRunJobArgs) IsSetJob() bool

func (*CloudScootRunJobArgs) Read 

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

func (*CloudScootRunJobArgs) String 

func (p *CloudScootRunJobArgs) String() string

func (*CloudScootRunJobArgs) Write 

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

type CloudScootRunJobResult 

type CloudScootRunJobResult struct {
	Success *JobId             `thrift:"success,0" json:"success,omitempty"`
	Ir      *InvalidRequest    `thrift:"ir,1" json:"ir,omitempty"`
	Cnsn    *CanNotScheduleNow `thrift:"cnsn,2" json:"cnsn,omitempty"`
}

Attributes:

  • Success
  • Ir
  • Cnsn

func NewCloudScootRunJobResult 

func NewCloudScootRunJobResult() *CloudScootRunJobResult

func (*CloudScootRunJobResult) GetCnsn 

func (p *CloudScootRunJobResult) GetCnsn() *CanNotScheduleNow

func (*CloudScootRunJobResult) GetIr 

func (p *CloudScootRunJobResult) GetIr() *InvalidRequest

func (*CloudScootRunJobResult) GetSuccess 

func (p *CloudScootRunJobResult) GetSuccess() *JobId

func (*CloudScootRunJobResult) IsSetCnsn 

func (p *CloudScootRunJobResult) IsSetCnsn() bool

func (*CloudScootRunJobResult) IsSetIr 

func (p *CloudScootRunJobResult) IsSetIr() bool

func (*CloudScootRunJobResult) IsSetSuccess 

func (p *CloudScootRunJobResult) IsSetSuccess() bool

func (*CloudScootRunJobResult) Read 

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

func (*CloudScootRunJobResult) String 

func (p *CloudScootRunJobResult) String() string

func (*CloudScootRunJobResult) Write 

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

type CloudScootSetClassLoadPercentsArgs 

type CloudScootSetClassLoadPercentsArgs struct {
	LoadPercents map[string]int32 `thrift:"loadPercents,1" json:"loadPercents"`
}

Attributes:

  • LoadPercents

func NewCloudScootSetClassLoadPercentsArgs 

func NewCloudScootSetClassLoadPercentsArgs() *CloudScootSetClassLoadPercentsArgs

func (*CloudScootSetClassLoadPercentsArgs) GetLoadPercents 

func (p *CloudScootSetClassLoadPercentsArgs) GetLoadPercents() map[string]int32

func (*CloudScootSetClassLoadPercentsArgs) Read 

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

func (*CloudScootSetClassLoadPercentsArgs) String 

func (p *CloudScootSetClassLoadPercentsArgs) String() string

func (*CloudScootSetClassLoadPercentsArgs) Write 

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

type CloudScootSetClassLoadPercentsResult 

type CloudScootSetClassLoadPercentsResult struct {
	Ir  *InvalidRequest   `thrift:"ir,1" json:"ir,omitempty"`
	Err *ScootServerError `thrift:"err,2" json:"err,omitempty"`
}

Attributes:

  • Ir
  • Err

func NewCloudScootSetClassLoadPercentsResult 

func NewCloudScootSetClassLoadPercentsResult() *CloudScootSetClassLoadPercentsResult

func (*CloudScootSetClassLoadPercentsResult) GetErr 

func (p *CloudScootSetClassLoadPercentsResult) GetErr() *ScootServerError

func (*CloudScootSetClassLoadPercentsResult) GetIr 

func (p *CloudScootSetClassLoadPercentsResult) GetIr() *InvalidRequest

func (*CloudScootSetClassLoadPercentsResult) IsSetErr 

func (p *CloudScootSetClassLoadPercentsResult) IsSetErr() bool

func (*CloudScootSetClassLoadPercentsResult) IsSetIr 

func (p *CloudScootSetClassLoadPercentsResult) IsSetIr() bool

func (*CloudScootSetClassLoadPercentsResult) Read 

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

func (*CloudScootSetClassLoadPercentsResult) String 

func (p *CloudScootSetClassLoadPercentsResult) String() string

func (*CloudScootSetClassLoadPercentsResult) Write 

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

type CloudScootSetRebalanceMinimumDurationArgs 

type CloudScootSetRebalanceMinimumDurationArgs struct {
	DurationMin int32 `thrift:"durationMin,1" json:"durationMin"`
}

Attributes:

  • DurationMin

func NewCloudScootSetRebalanceMinimumDurationArgs 

func NewCloudScootSetRebalanceMinimumDurationArgs() *CloudScootSetRebalanceMinimumDurationArgs

func (*CloudScootSetRebalanceMinimumDurationArgs) GetDurationMin 

func (p *CloudScootSetRebalanceMinimumDurationArgs) GetDurationMin() int32

func (*CloudScootSetRebalanceMinimumDurationArgs) Read 

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

func (*CloudScootSetRebalanceMinimumDurationArgs) String 

func (p *CloudScootSetRebalanceMinimumDurationArgs) String() string

func (*CloudScootSetRebalanceMinimumDurationArgs) Write 

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

type CloudScootSetRebalanceMinimumDurationResult 

type CloudScootSetRebalanceMinimumDurationResult struct {
	Ir  *InvalidRequest   `thrift:"ir,1" json:"ir,omitempty"`
	Err *ScootServerError `thrift:"err,2" json:"err,omitempty"`
}

Attributes:

  • Ir
  • Err

func NewCloudScootSetRebalanceMinimumDurationResult 

func NewCloudScootSetRebalanceMinimumDurationResult() *CloudScootSetRebalanceMinimumDurationResult

func (*CloudScootSetRebalanceMinimumDurationResult) GetErr 

func (p *CloudScootSetRebalanceMinimumDurationResult) GetErr() *ScootServerError

func (*CloudScootSetRebalanceMinimumDurationResult) GetIr 

func (p *CloudScootSetRebalanceMinimumDurationResult) GetIr() *InvalidRequest

func (*CloudScootSetRebalanceMinimumDurationResult) IsSetErr 

func (p *CloudScootSetRebalanceMinimumDurationResult) IsSetErr() bool

func (*CloudScootSetRebalanceMinimumDurationResult) IsSetIr 

func (p *CloudScootSetRebalanceMinimumDurationResult) IsSetIr() bool

func (*CloudScootSetRebalanceMinimumDurationResult) Read 

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

func (*CloudScootSetRebalanceMinimumDurationResult) String 

func (p *CloudScootSetRebalanceMinimumDurationResult) String() string

func (*CloudScootSetRebalanceMinimumDurationResult) Write 

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

type CloudScootSetRebalanceThresholdArgs 

type CloudScootSetRebalanceThresholdArgs struct {
	Threshold int32 `thrift:"threshold,1" json:"threshold"`
}

Attributes:

  • Threshold

func NewCloudScootSetRebalanceThresholdArgs 

func NewCloudScootSetRebalanceThresholdArgs() *CloudScootSetRebalanceThresholdArgs

func (*CloudScootSetRebalanceThresholdArgs) GetThreshold 

func (p *CloudScootSetRebalanceThresholdArgs) GetThreshold() int32

func (*CloudScootSetRebalanceThresholdArgs) Read 

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

func (*CloudScootSetRebalanceThresholdArgs) String 

func (p *CloudScootSetRebalanceThresholdArgs) String() string

func (*CloudScootSetRebalanceThresholdArgs) Write 

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

type CloudScootSetRebalanceThresholdResult 

type CloudScootSetRebalanceThresholdResult struct {
	Ir  *InvalidRequest   `thrift:"ir,1" json:"ir,omitempty"`
	Err *ScootServerError `thrift:"err,2" json:"err,omitempty"`
}

Attributes:

  • Ir
  • Err

func NewCloudScootSetRebalanceThresholdResult 

func NewCloudScootSetRebalanceThresholdResult() *CloudScootSetRebalanceThresholdResult

func (*CloudScootSetRebalanceThresholdResult) GetErr 

func (p *CloudScootSetRebalanceThresholdResult) GetErr() *ScootServerError

func (*CloudScootSetRebalanceThresholdResult) GetIr 

func (p *CloudScootSetRebalanceThresholdResult) GetIr() *InvalidRequest

func (*CloudScootSetRebalanceThresholdResult) IsSetErr 

func (p *CloudScootSetRebalanceThresholdResult) IsSetErr() bool

func (*CloudScootSetRebalanceThresholdResult) IsSetIr 

func (p *CloudScootSetRebalanceThresholdResult) IsSetIr() bool

func (*CloudScootSetRebalanceThresholdResult) Read 

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

func (*CloudScootSetRebalanceThresholdResult) String 

func (p *CloudScootSetRebalanceThresholdResult) String() string

func (*CloudScootSetRebalanceThresholdResult) Write 

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

type CloudScootSetRequestorToClassMapArgs 

type CloudScootSetRequestorToClassMapArgs struct {
	RequestorToClassMap map[string]string `thrift:"requestorToClassMap,1" json:"requestorToClassMap"`
}

Attributes:

  • RequestorToClassMap

func NewCloudScootSetRequestorToClassMapArgs 

func NewCloudScootSetRequestorToClassMapArgs() *CloudScootSetRequestorToClassMapArgs

func (*CloudScootSetRequestorToClassMapArgs) GetRequestorToClassMap 

func (p *CloudScootSetRequestorToClassMapArgs) GetRequestorToClassMap() map[string]string

func (*CloudScootSetRequestorToClassMapArgs) Read 

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

func (*CloudScootSetRequestorToClassMapArgs) String 

func (p *CloudScootSetRequestorToClassMapArgs) String() string

func (*CloudScootSetRequestorToClassMapArgs) Write 

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

type CloudScootSetRequestorToClassMapResult 

type CloudScootSetRequestorToClassMapResult struct {
	Ir  *InvalidRequest   `thrift:"ir,1" json:"ir,omitempty"`
	Err *ScootServerError `thrift:"err,2" json:"err,omitempty"`
}

Attributes:

  • Ir
  • Err

func NewCloudScootSetRequestorToClassMapResult 

func NewCloudScootSetRequestorToClassMapResult() *CloudScootSetRequestorToClassMapResult

func (*CloudScootSetRequestorToClassMapResult) GetErr 

func (p *CloudScootSetRequestorToClassMapResult) GetErr() *ScootServerError

func (*CloudScootSetRequestorToClassMapResult) GetIr 

func (p *CloudScootSetRequestorToClassMapResult) GetIr() *InvalidRequest

func (*CloudScootSetRequestorToClassMapResult) IsSetErr 

func (p *CloudScootSetRequestorToClassMapResult) IsSetErr() bool

func (*CloudScootSetRequestorToClassMapResult) IsSetIr 

func (p *CloudScootSetRequestorToClassMapResult) IsSetIr() bool

func (*CloudScootSetRequestorToClassMapResult) Read 

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

func (*CloudScootSetRequestorToClassMapResult) String 

func (p *CloudScootSetRequestorToClassMapResult) String() string

func (*CloudScootSetRequestorToClassMapResult) Write 

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

type CloudScootSetSchedulerStatusArgs 

type CloudScootSetSchedulerStatusArgs struct {
	MaxTasks int32 `thrift:"maxTasks,1" json:"maxTasks"`
}

Attributes:

  • MaxTasks

func NewCloudScootSetSchedulerStatusArgs 

func NewCloudScootSetSchedulerStatusArgs() *CloudScootSetSchedulerStatusArgs

func (*CloudScootSetSchedulerStatusArgs) GetMaxTasks 

func (p *CloudScootSetSchedulerStatusArgs) GetMaxTasks() int32

func (*CloudScootSetSchedulerStatusArgs) Read 

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

func (*CloudScootSetSchedulerStatusArgs) String 

func (p *CloudScootSetSchedulerStatusArgs) String() string

func (*CloudScootSetSchedulerStatusArgs) Write 

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

type CloudScootSetSchedulerStatusResult 

type CloudScootSetSchedulerStatusResult struct {
	Ir  *InvalidRequest   `thrift:"ir,1" json:"ir,omitempty"`
	Err *ScootServerError `thrift:"err,2" json:"err,omitempty"`
}

Attributes:

  • Ir
  • Err

func NewCloudScootSetSchedulerStatusResult 

func NewCloudScootSetSchedulerStatusResult() *CloudScootSetSchedulerStatusResult

func (*CloudScootSetSchedulerStatusResult) GetErr 

func (p *CloudScootSetSchedulerStatusResult) GetErr() *ScootServerError

func (*CloudScootSetSchedulerStatusResult) GetIr 

func (p *CloudScootSetSchedulerStatusResult) GetIr() *InvalidRequest

func (*CloudScootSetSchedulerStatusResult) IsSetErr 

func (p *CloudScootSetSchedulerStatusResult) IsSetErr() bool

func (*CloudScootSetSchedulerStatusResult) IsSetIr 

func (p *CloudScootSetSchedulerStatusResult) IsSetIr() bool

func (*CloudScootSetSchedulerStatusResult) Read 

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

func (*CloudScootSetSchedulerStatusResult) String 

func (p *CloudScootSetSchedulerStatusResult) String() string

func (*CloudScootSetSchedulerStatusResult) Write 

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

type Command 

type Command struct {
	Argv    []string          `thrift:"argv,1" json:"argv"`
	EnvVars map[string]string `thrift:"envVars,2" json:"envVars,omitempty"`
}

Attributes:

  • Argv
  • EnvVars
var TaskDefinition_Command_DEFAULT *Command

func NewCommand 

func NewCommand() *Command

func (*Command) GetArgv 

func (p *Command) GetArgv() []string

func (*Command) GetEnvVars 

func (p *Command) GetEnvVars() map[string]string

func (*Command) IsSetEnvVars 

func (p *Command) IsSetEnvVars() bool

func (*Command) Read 

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

func (*Command) String 

func (p *Command) String() string

func (*Command) Write 

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

type InvalidRequest 

type InvalidRequest struct {
	Message *string `thrift:"message,1" json:"message,omitempty"`
}

Attributes:

  • Message
var CloudScootGetClassLoadPercentsResult_Ir_DEFAULT *InvalidRequest
var CloudScootGetRebalanceMinimumDurationResult_Ir_DEFAULT *InvalidRequest
var CloudScootGetRebalanceThresholdResult_Ir_DEFAULT *InvalidRequest
var CloudScootGetRequestorToClassMapResult_Ir_DEFAULT *InvalidRequest
var CloudScootGetStatusResult_Ir_DEFAULT *InvalidRequest
var CloudScootKillJobResult_Ir_DEFAULT *InvalidRequest
var CloudScootOfflineWorkerResult_Ir_DEFAULT *InvalidRequest
var CloudScootReinstateWorkerResult_Ir_DEFAULT *InvalidRequest
var CloudScootRunJobResult_Ir_DEFAULT *InvalidRequest
var CloudScootSetClassLoadPercentsResult_Ir_DEFAULT *InvalidRequest
var CloudScootSetRebalanceMinimumDurationResult_Ir_DEFAULT *InvalidRequest
var CloudScootSetRebalanceThresholdResult_Ir_DEFAULT *InvalidRequest
var CloudScootSetRequestorToClassMapResult_Ir_DEFAULT *InvalidRequest
var CloudScootSetSchedulerStatusResult_Ir_DEFAULT *InvalidRequest

func NewInvalidRequest 

func NewInvalidRequest() *InvalidRequest

func (*InvalidRequest) Error 

func (p *InvalidRequest) Error() string

func (*InvalidRequest) GetMessage 

func (p *InvalidRequest) GetMessage() string

func (*InvalidRequest) IsSetMessage 

func (p *InvalidRequest) IsSetMessage() bool

func (*InvalidRequest) Read 

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

func (*InvalidRequest) String 

func (p *InvalidRequest) String() string

func (*InvalidRequest) Write 

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

type JobDefinition 

type JobDefinition struct {
	Tasks                []*TaskDefinition `thrift:"tasks,1,required" json:"tasks"`
	DEPRECATEDJobType    *JobType          `thrift:"DEPRECATED_jobType,2" json:"DEPRECATED_jobType,omitempty"`
	DefaultTaskTimeoutMs *int32            `thrift:"defaultTaskTimeoutMs,3" json:"defaultTaskTimeoutMs,omitempty"`
	Priority             *int32            `thrift:"priority,4" json:"priority,omitempty"`
	Tag                  *string           `thrift:"tag,5" json:"tag,omitempty"`
	Basis                *string           `thrift:"basis,6" json:"basis,omitempty"`
	Requestor            *string           `thrift:"requestor,7" json:"requestor,omitempty"`
	JobType              *string           `thrift:"jobType,8" json:"jobType,omitempty"`
}

Attributes:

  • Tasks
  • DEPRECATEDJobType
  • DefaultTaskTimeoutMs
  • Priority
  • Tag
  • Basis
  • Requestor
  • JobType
var CloudScootRunJobArgs_Job_DEFAULT *JobDefinition

func NewJobDefinition 

func NewJobDefinition() *JobDefinition

func (*JobDefinition) GetBasis 

func (p *JobDefinition) GetBasis() string

func (*JobDefinition) GetDEPRECATEDJobType 

func (p *JobDefinition) GetDEPRECATEDJobType() JobType

func (*JobDefinition) GetDefaultTaskTimeoutMs 

func (p *JobDefinition) GetDefaultTaskTimeoutMs() int32

func (*JobDefinition) GetJobType 

func (p *JobDefinition) GetJobType() string

func (*JobDefinition) GetPriority 

func (p *JobDefinition) GetPriority() int32

func (*JobDefinition) GetRequestor 

func (p *JobDefinition) GetRequestor() string

func (*JobDefinition) GetTag 

func (p *JobDefinition) GetTag() string

func (*JobDefinition) GetTasks 

func (p *JobDefinition) GetTasks() []*TaskDefinition

func (*JobDefinition) IsSetBasis 

func (p *JobDefinition) IsSetBasis() bool

func (*JobDefinition) IsSetDEPRECATEDJobType 

func (p *JobDefinition) IsSetDEPRECATEDJobType() bool

func (*JobDefinition) IsSetDefaultTaskTimeoutMs 

func (p *JobDefinition) IsSetDefaultTaskTimeoutMs() bool

func (*JobDefinition) IsSetJobType 

func (p *JobDefinition) IsSetJobType() bool

func (*JobDefinition) IsSetPriority 

func (p *JobDefinition) IsSetPriority() bool

func (*JobDefinition) IsSetRequestor 

func (p *JobDefinition) IsSetRequestor() bool

func (*JobDefinition) IsSetTag 

func (p *JobDefinition) IsSetTag() bool

func (*JobDefinition) Read 

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

func (*JobDefinition) String 

func (p *JobDefinition) String() string

func (*JobDefinition) Write 

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

type JobId 

type JobId struct {
	ID string `thrift:"id,1,required" json:"id"`
}

Attributes:

  • ID
var CloudScootRunJobResult_Success_DEFAULT *JobId

func NewJobId 

func NewJobId() *JobId

func (*JobId) GetID 

func (p *JobId) GetID() string

func (*JobId) Read 

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

func (*JobId) String 

func (p *JobId) String() string

func (*JobId) Write 

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

type JobStatus 

type JobStatus struct {
	ID         string                `thrift:"id,1,required" json:"id"`
	Status     Status                `thrift:"status,2,required" json:"status"`
	TaskStatus map[string]Status     `thrift:"taskStatus,3" json:"taskStatus,omitempty"`
	TaskData   map[string]*RunStatus `thrift:"taskData,4" json:"taskData,omitempty"`
}

Attributes:

  • ID
  • Status
  • TaskStatus
  • TaskData
var CloudScootGetStatusResult_Success_DEFAULT *JobStatus
var CloudScootKillJobResult_Success_DEFAULT *JobStatus

func NewJobStatus 

func NewJobStatus() *JobStatus

func (*JobStatus) GetID 

func (p *JobStatus) GetID() string

func (*JobStatus) GetStatus 

func (p *JobStatus) GetStatus() Status

func (*JobStatus) GetTaskData 

func (p *JobStatus) GetTaskData() map[string]*RunStatus

func (*JobStatus) GetTaskStatus 

func (p *JobStatus) GetTaskStatus() map[string]Status

func (*JobStatus) IsSetTaskData 

func (p *JobStatus) IsSetTaskData() bool

func (*JobStatus) IsSetTaskStatus 

func (p *JobStatus) IsSetTaskStatus() bool

func (*JobStatus) Read 

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

func (*JobStatus) String 

func (p *JobStatus) String() string

func (*JobStatus) Write 

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

type JobType 

type JobType int64
const (
	JobType_UNKNOWN    JobType = 1
	JobType_IRON_TESTS JobType = 2
)
var JobDefinition_DEPRECATEDJobType_DEFAULT JobType

func JobTypeFromString 

func JobTypeFromString(s string) (JobType, error)

func JobTypePtr 

func JobTypePtr(v JobType) *JobType

func (JobType) MarshalText 

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

func (JobType) String 

func (p JobType) String() string

func (*JobType) UnmarshalText 

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

type OfflineWorkerReq 

type OfflineWorkerReq struct {
	ID        string `thrift:"id,1,required" json:"id"`
	Requestor string `thrift:"requestor,2,required" json:"requestor"`
}

Attributes:

  • ID
  • Requestor
var CloudScootOfflineWorkerArgs_Req_DEFAULT *OfflineWorkerReq

func NewOfflineWorkerReq 

func NewOfflineWorkerReq() *OfflineWorkerReq

func (*OfflineWorkerReq) GetID 

func (p *OfflineWorkerReq) GetID() string

func (*OfflineWorkerReq) GetRequestor 

func (p *OfflineWorkerReq) GetRequestor() string

func (*OfflineWorkerReq) Read 

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

func (*OfflineWorkerReq) String 

func (p *OfflineWorkerReq) String() string

func (*OfflineWorkerReq) Write 

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

type ReinstateWorkerReq 

type ReinstateWorkerReq struct {
	ID        string `thrift:"id,1,required" json:"id"`
	Requestor string `thrift:"requestor,2,required" json:"requestor"`
}

Attributes:

  • ID
  • Requestor
var CloudScootReinstateWorkerArgs_Req_DEFAULT *ReinstateWorkerReq

func NewReinstateWorkerReq 

func NewReinstateWorkerReq() *ReinstateWorkerReq

func (*ReinstateWorkerReq) GetID 

func (p *ReinstateWorkerReq) GetID() string

func (*ReinstateWorkerReq) GetRequestor 

func (p *ReinstateWorkerReq) GetRequestor() string

func (*ReinstateWorkerReq) Read 

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

func (*ReinstateWorkerReq) String 

func (p *ReinstateWorkerReq) String() string

func (*ReinstateWorkerReq) Write 

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

type RunStatus 

type RunStatus struct {
	Status       RunStatusState       `thrift:"status,1,required" json:"status"`
	RunId        string               `thrift:"runId,2,required" json:"runId"`
	OutUri       *string              `thrift:"outUri,3" json:"outUri,omitempty"`
	ErrUri       *string              `thrift:"errUri,4" json:"errUri,omitempty"`
	Error        *string              `thrift:"error,5" json:"error,omitempty"`
	ExitCode     *int32               `thrift:"exitCode,6" json:"exitCode,omitempty"`
	SnapshotId   *string              `thrift:"snapshotId,7" json:"snapshotId,omitempty"`
	JobId        *string              `thrift:"jobId,8" json:"jobId,omitempty"`
	TaskId       *string              `thrift:"taskId,9" json:"taskId,omitempty"`
	Tag          *string              `thrift:"tag,10" json:"tag,omitempty"`
	BazelResult_ *bazel.ActionResult_ `thrift:"bazelResult,11" json:"bazelResult,omitempty"`
}

Attributes:

  • Status
  • RunId
  • OutUri
  • ErrUri
  • Error
  • ExitCode
  • SnapshotId
  • JobId
  • TaskId
  • Tag
  • BazelResult_

func NewRunStatus 

func NewRunStatus() *RunStatus

func (*RunStatus) GetBazelResult_ 

func (p *RunStatus) GetBazelResult_() *bazel.ActionResult_

func (*RunStatus) GetErrUri 

func (p *RunStatus) GetErrUri() string

func (*RunStatus) GetError 

func (p *RunStatus) GetError() string

func (*RunStatus) GetExitCode 

func (p *RunStatus) GetExitCode() int32

func (*RunStatus) GetJobId 

func (p *RunStatus) GetJobId() string

func (*RunStatus) GetOutUri 

func (p *RunStatus) GetOutUri() string

func (*RunStatus) GetRunId 

func (p *RunStatus) GetRunId() string

func (*RunStatus) GetSnapshotId 

func (p *RunStatus) GetSnapshotId() string

func (*RunStatus) GetStatus 

func (p *RunStatus) GetStatus() RunStatusState

func (*RunStatus) GetTag 

func (p *RunStatus) GetTag() string

func (*RunStatus) GetTaskId 

func (p *RunStatus) GetTaskId() string

func (*RunStatus) IsSetBazelResult_ 

func (p *RunStatus) IsSetBazelResult_() bool

func (*RunStatus) IsSetErrUri 

func (p *RunStatus) IsSetErrUri() bool

func (*RunStatus) IsSetError 

func (p *RunStatus) IsSetError() bool

func (*RunStatus) IsSetExitCode 

func (p *RunStatus) IsSetExitCode() bool

func (*RunStatus) IsSetJobId 

func (p *RunStatus) IsSetJobId() bool

func (*RunStatus) IsSetOutUri 

func (p *RunStatus) IsSetOutUri() bool

func (*RunStatus) IsSetSnapshotId 

func (p *RunStatus) IsSetSnapshotId() bool

func (*RunStatus) IsSetTag 

func (p *RunStatus) IsSetTag() bool

func (*RunStatus) IsSetTaskId 

func (p *RunStatus) IsSetTaskId() bool

func (*RunStatus) Read 

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

func (*RunStatus) String 

func (p *RunStatus) String() string

func (*RunStatus) Write 

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

type RunStatusState 

type RunStatusState int64
const (
	RunStatusState_UNKNOWN  RunStatusState = 0
	RunStatusState_PENDING  RunStatusState = 1
	RunStatusState_RUNNING  RunStatusState = 2
	RunStatusState_COMPLETE RunStatusState = 3
	RunStatusState_FAILED   RunStatusState = 4
	RunStatusState_ABORTED  RunStatusState = 5
	RunStatusState_TIMEDOUT RunStatusState = 6
)

func RunStatusStateFromString 

func RunStatusStateFromString(s string) (RunStatusState, error)

func RunStatusStatePtr 

func RunStatusStatePtr(v RunStatusState) *RunStatusState

func (RunStatusState) MarshalText 

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

func (RunStatusState) String 

func (p RunStatusState) String() string

func (*RunStatusState) UnmarshalText 

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

type SchedulerStatus 

type SchedulerStatus struct {
	CurrentTasks int32 `thrift:"currentTasks,1,required" json:"currentTasks"`
	MaxTasks     int32 `thrift:"maxTasks,2,required" json:"maxTasks"`
}

Attributes:

  • CurrentTasks
  • MaxTasks
var CloudScootGetSchedulerStatusResult_Success_DEFAULT *SchedulerStatus

func NewSchedulerStatus 

func NewSchedulerStatus() *SchedulerStatus

func (*SchedulerStatus) GetCurrentTasks 

func (p *SchedulerStatus) GetCurrentTasks() int32

func (*SchedulerStatus) GetMaxTasks 

func (p *SchedulerStatus) GetMaxTasks() int32

func (*SchedulerStatus) Read 

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

func (*SchedulerStatus) String 

func (p *SchedulerStatus) String() string

func (*SchedulerStatus) Write 

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

type ScootServerError 

type ScootServerError struct {
	RetryAfterMs *int64 `thrift:"retryAfterMs,1" json:"retryAfterMs,omitempty"`
}

Attributes:

  • RetryAfterMs
var CloudScootGetSchedulerStatusResult_Err_DEFAULT *ScootServerError
var CloudScootGetStatusResult_Err_DEFAULT *ScootServerError
var CloudScootKillJobResult_Err_DEFAULT *ScootServerError
var CloudScootOfflineWorkerResult_Err_DEFAULT *ScootServerError
var CloudScootReinstateWorkerResult_Err_DEFAULT *ScootServerError
var CloudScootSetClassLoadPercentsResult_Err_DEFAULT *ScootServerError
var CloudScootSetRebalanceMinimumDurationResult_Err_DEFAULT *ScootServerError
var CloudScootSetRebalanceThresholdResult_Err_DEFAULT *ScootServerError
var CloudScootSetRequestorToClassMapResult_Err_DEFAULT *ScootServerError
var CloudScootSetSchedulerStatusResult_Err_DEFAULT *ScootServerError

func NewScootServerError 

func NewScootServerError() *ScootServerError

func (*ScootServerError) Error 

func (p *ScootServerError) Error() string

func (*ScootServerError) GetRetryAfterMs 

func (p *ScootServerError) GetRetryAfterMs() int64

func (*ScootServerError) IsSetRetryAfterMs 

func (p *ScootServerError) IsSetRetryAfterMs() bool

func (*ScootServerError) Read 

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

func (*ScootServerError) String 

func (p *ScootServerError) String() string

func (*ScootServerError) Write 

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

type Status 

type Status int64
const (
	Status_NOT_STARTED  Status = 1
	Status_IN_PROGRESS  Status = 2
	Status_COMPLETED    Status = 3
	Status_ROLLING_BACK Status = 4
	Status_ROLLED_BACK  Status = 5
)

func StatusFromString 

func StatusFromString(s string) (Status, error)

func StatusPtr 

func StatusPtr(v Status) *Status

func (Status) MarshalText 

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

func (Status) String 

func (p Status) String() string

func (*Status) UnmarshalText 

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

type TaskDefinition 

type TaskDefinition struct {
	Command    *Command `thrift:"command,1,required" json:"command"`
	SnapshotId *string  `thrift:"snapshotId,2" json:"snapshotId,omitempty"`
	TaskId     *string  `thrift:"taskId,3" json:"taskId,omitempty"`
	TimeoutMs  *int32   `thrift:"timeoutMs,4" json:"timeoutMs,omitempty"`
}

Attributes:

  • Command
  • SnapshotId
  • TaskId
  • TimeoutMs

func NewTaskDefinition 

func NewTaskDefinition() *TaskDefinition

func (*TaskDefinition) GetCommand 

func (p *TaskDefinition) GetCommand() *Command

func (*TaskDefinition) GetSnapshotId 

func (p *TaskDefinition) GetSnapshotId() string

func (*TaskDefinition) GetTaskId 

func (p *TaskDefinition) GetTaskId() string

func (*TaskDefinition) GetTimeoutMs 

func (p *TaskDefinition) GetTimeoutMs() int32

func (*TaskDefinition) IsSetCommand 

func (p *TaskDefinition) IsSetCommand() bool

func (*TaskDefinition) IsSetSnapshotId 

func (p *TaskDefinition) IsSetSnapshotId() bool

func (*TaskDefinition) IsSetTaskId 

func (p *TaskDefinition) IsSetTaskId() bool

func (*TaskDefinition) IsSetTimeoutMs 

func (p *TaskDefinition) IsSetTimeoutMs() bool

func (*TaskDefinition) Read 

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

func (*TaskDefinition) String 

func (p *TaskDefinition) String() string

func (*TaskDefinition) Write 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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