Documentation ¶
Index ¶
- Variables
- type AgentService
- type AgentServiceAliveCheckArgs
- type AgentServiceAliveCheckResult
- func (p *AgentServiceAliveCheckResult) GetSuccess() string
- func (p *AgentServiceAliveCheckResult) IsSetSuccess() bool
- func (p *AgentServiceAliveCheckResult) Read(iprot thrift.TProtocol) error
- func (p *AgentServiceAliveCheckResult) String() string
- func (p *AgentServiceAliveCheckResult) Write(oprot thrift.TProtocol) error
- type AgentServiceClient
- type AgentServiceInstructionInvokeAsyncArgs
- func (p *AgentServiceInstructionInvokeAsyncArgs) GetInsList() []*Instruct
- func (p *AgentServiceInstructionInvokeAsyncArgs) Read(iprot thrift.TProtocol) error
- func (p *AgentServiceInstructionInvokeAsyncArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *AgentServiceInstructionInvokeAsyncArgs) String() string
- func (p *AgentServiceInstructionInvokeAsyncArgs) Write(oprot thrift.TProtocol) error
- type AgentServiceInstructionInvokeAsyncResult
- func (p *AgentServiceInstructionInvokeAsyncResult) GetSuccess() []*Reinstruct
- func (p *AgentServiceInstructionInvokeAsyncResult) IsSetSuccess() bool
- func (p *AgentServiceInstructionInvokeAsyncResult) Read(iprot thrift.TProtocol) error
- func (p *AgentServiceInstructionInvokeAsyncResult) String() string
- func (p *AgentServiceInstructionInvokeAsyncResult) Write(oprot thrift.TProtocol) error
- type AgentServiceInstructionInvokeSyncArgs
- func (p *AgentServiceInstructionInvokeSyncArgs) GetIns() *Instruct
- func (p *AgentServiceInstructionInvokeSyncArgs) IsSetIns() bool
- func (p *AgentServiceInstructionInvokeSyncArgs) Read(iprot thrift.TProtocol) error
- func (p *AgentServiceInstructionInvokeSyncArgs) String() string
- func (p *AgentServiceInstructionInvokeSyncArgs) Write(oprot thrift.TProtocol) error
- type AgentServiceInstructionInvokeSyncResult
- func (p *AgentServiceInstructionInvokeSyncResult) GetSuccess() *Reinstruct
- func (p *AgentServiceInstructionInvokeSyncResult) IsSetSuccess() bool
- func (p *AgentServiceInstructionInvokeSyncResult) Read(iprot thrift.TProtocol) error
- func (p *AgentServiceInstructionInvokeSyncResult) String() string
- func (p *AgentServiceInstructionInvokeSyncResult) Write(oprot thrift.TProtocol) error
- type AgentServiceProcessor
- func (p *AgentServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)
- func (p *AgentServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)
- func (p *AgentServiceProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
- func (p *AgentServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction
- type AppService
- type AppServiceClient
- type AppServiceProcessor
- func (p *AppServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)
- func (p *AppServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)
- func (p *AppServiceProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
- func (p *AppServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction
- type AppServiceRunProcessorArgs
- func (p *AppServiceRunProcessorArgs) GetReins() *Reinstruct
- func (p *AppServiceRunProcessorArgs) IsSetReins() bool
- func (p *AppServiceRunProcessorArgs) Read(iprot thrift.TProtocol) error
- func (p *AppServiceRunProcessorArgs) String() string
- func (p *AppServiceRunProcessorArgs) Write(oprot thrift.TProtocol) error
- type AppServiceRunProcessorResult
- func (p *AppServiceRunProcessorResult) GetSuccess() string
- func (p *AppServiceRunProcessorResult) IsSetSuccess() bool
- func (p *AppServiceRunProcessorResult) Read(iprot thrift.TProtocol) error
- func (p *AppServiceRunProcessorResult) String() string
- func (p *AppServiceRunProcessorResult) Write(oprot thrift.TProtocol) error
- type Instruct
- func (p *Instruct) GetApp() string
- func (p *Instruct) GetFunc() string
- func (p *Instruct) GetID() string
- func (p *Instruct) GetIP() string
- func (p *Instruct) GetMode() string
- func (p *Instruct) GetParam() string
- func (p *Instruct) GetProxy() string
- func (p *Instruct) GetTimeout() int32
- func (p *Instruct) GetType() string
- func (p *Instruct) Read(iprot thrift.TProtocol) error
- func (p *Instruct) String() string
- func (p *Instruct) Write(oprot thrift.TProtocol) error
- type Reinstruct
- func (p *Reinstruct) GetCosttime() int32
- func (p *Reinstruct) GetFlag() int32
- func (p *Reinstruct) GetIns() *Instruct
- func (p *Reinstruct) GetResult_() string
- func (p *Reinstruct) IsSetIns() bool
- func (p *Reinstruct) Read(iprot thrift.TProtocol) error
- func (p *Reinstruct) String() string
- func (p *Reinstruct) Write(oprot thrift.TProtocol) error
- type SchedulerService
- type SchedulerServiceAliveCheckArgs
- type SchedulerServiceAliveCheckResult
- func (p *SchedulerServiceAliveCheckResult) GetSuccess() string
- func (p *SchedulerServiceAliveCheckResult) IsSetSuccess() bool
- func (p *SchedulerServiceAliveCheckResult) Read(iprot thrift.TProtocol) error
- func (p *SchedulerServiceAliveCheckResult) String() string
- func (p *SchedulerServiceAliveCheckResult) Write(oprot thrift.TProtocol) error
- type SchedulerServiceClient
- type SchedulerServiceDataTransportArgs
- func (p *SchedulerServiceDataTransportArgs) GetReins() *Reinstruct
- func (p *SchedulerServiceDataTransportArgs) IsSetReins() bool
- func (p *SchedulerServiceDataTransportArgs) Read(iprot thrift.TProtocol) error
- func (p *SchedulerServiceDataTransportArgs) String() string
- func (p *SchedulerServiceDataTransportArgs) Write(oprot thrift.TProtocol) error
- type SchedulerServiceDataTransportResult
- func (p *SchedulerServiceDataTransportResult) GetSuccess() string
- func (p *SchedulerServiceDataTransportResult) IsSetSuccess() bool
- func (p *SchedulerServiceDataTransportResult) Read(iprot thrift.TProtocol) error
- func (p *SchedulerServiceDataTransportResult) String() string
- func (p *SchedulerServiceDataTransportResult) Write(oprot thrift.TProtocol) error
- type SchedulerServiceInstructionTransitArgs
- func (p *SchedulerServiceInstructionTransitArgs) GetIns() *Instruct
- func (p *SchedulerServiceInstructionTransitArgs) IsSetIns() bool
- func (p *SchedulerServiceInstructionTransitArgs) Read(iprot thrift.TProtocol) error
- func (p *SchedulerServiceInstructionTransitArgs) String() string
- func (p *SchedulerServiceInstructionTransitArgs) Write(oprot thrift.TProtocol) error
- type SchedulerServiceInstructionTransitResult
- func (p *SchedulerServiceInstructionTransitResult) GetSuccess() *Reinstruct
- func (p *SchedulerServiceInstructionTransitResult) IsSetSuccess() bool
- func (p *SchedulerServiceInstructionTransitResult) Read(iprot thrift.TProtocol) error
- func (p *SchedulerServiceInstructionTransitResult) String() string
- func (p *SchedulerServiceInstructionTransitResult) Write(oprot thrift.TProtocol) error
- type SchedulerServiceProcessor
- func (p *SchedulerServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)
- func (p *SchedulerServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)
- func (p *SchedulerServiceProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
- func (p *SchedulerServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction
Constants ¶
This section is empty.
Variables ¶
View Source
var AgentServiceAliveCheckResult_Success_DEFAULT string
View Source
var AgentServiceInstructionInvokeAsyncResult_Success_DEFAULT []*Reinstruct
View Source
var AppServiceRunProcessorResult_Success_DEFAULT string
View Source
var GoUnusedProtection__ int
View Source
var SchedulerServiceAliveCheckResult_Success_DEFAULT string
View Source
var SchedulerServiceDataTransportResult_Success_DEFAULT string
Functions ¶
This section is empty.
Types ¶
type AgentService ¶
type AgentService interface { AliveCheck() (r string, err error) // Parameters: // - InsList InstructionInvokeAsync(insList []*Instruct) (r []*Reinstruct, err error) // Parameters: // - Ins InstructionInvokeSync(ins *Instruct) (r *Reinstruct, err error) }
type AgentServiceAliveCheckArgs ¶
type AgentServiceAliveCheckArgs struct { }
func NewAgentServiceAliveCheckArgs ¶
func NewAgentServiceAliveCheckArgs() *AgentServiceAliveCheckArgs
func (*AgentServiceAliveCheckArgs) Read ¶
func (p *AgentServiceAliveCheckArgs) Read(iprot thrift.TProtocol) error
func (*AgentServiceAliveCheckArgs) String ¶
func (p *AgentServiceAliveCheckArgs) String() string
func (*AgentServiceAliveCheckArgs) Write ¶
func (p *AgentServiceAliveCheckArgs) Write(oprot thrift.TProtocol) error
type AgentServiceAliveCheckResult ¶
type AgentServiceAliveCheckResult struct {
Success *string `thrift:"success,0" json:"success,omitempty"`
}
Attributes:
- Success
func NewAgentServiceAliveCheckResult ¶
func NewAgentServiceAliveCheckResult() *AgentServiceAliveCheckResult
func (*AgentServiceAliveCheckResult) GetSuccess ¶
func (p *AgentServiceAliveCheckResult) GetSuccess() string
func (*AgentServiceAliveCheckResult) IsSetSuccess ¶
func (p *AgentServiceAliveCheckResult) IsSetSuccess() bool
func (*AgentServiceAliveCheckResult) Read ¶
func (p *AgentServiceAliveCheckResult) Read(iprot thrift.TProtocol) error
func (*AgentServiceAliveCheckResult) String ¶
func (p *AgentServiceAliveCheckResult) String() string
func (*AgentServiceAliveCheckResult) Write ¶
func (p *AgentServiceAliveCheckResult) Write(oprot thrift.TProtocol) error
type AgentServiceClient ¶
type AgentServiceClient struct { Transport thrift.TTransport ProtocolFactory thrift.TProtocolFactory InputProtocol thrift.TProtocol OutputProtocol thrift.TProtocol SeqId int32 }
func NewAgentServiceClientFactory ¶
func NewAgentServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *AgentServiceClient
func NewAgentServiceClientProtocol ¶
func NewAgentServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *AgentServiceClient
func (*AgentServiceClient) AliveCheck ¶
func (p *AgentServiceClient) AliveCheck() (r string, err error)
func (*AgentServiceClient) InstructionInvokeAsync ¶
func (p *AgentServiceClient) InstructionInvokeAsync(insList []*Instruct) (r []*Reinstruct, err error)
Parameters:
- InsList
func (*AgentServiceClient) InstructionInvokeSync ¶
func (p *AgentServiceClient) InstructionInvokeSync(ins *Instruct) (r *Reinstruct, err error)
Parameters:
- Ins
type AgentServiceInstructionInvokeAsyncArgs ¶
type AgentServiceInstructionInvokeAsyncArgs struct {
InsList []*Instruct `thrift:"insList,1" json:"insList"`
}
Attributes:
- InsList
func NewAgentServiceInstructionInvokeAsyncArgs ¶
func NewAgentServiceInstructionInvokeAsyncArgs() *AgentServiceInstructionInvokeAsyncArgs
func (*AgentServiceInstructionInvokeAsyncArgs) GetInsList ¶
func (p *AgentServiceInstructionInvokeAsyncArgs) GetInsList() []*Instruct
func (*AgentServiceInstructionInvokeAsyncArgs) Read ¶
func (p *AgentServiceInstructionInvokeAsyncArgs) Read(iprot thrift.TProtocol) error
func (*AgentServiceInstructionInvokeAsyncArgs) ReadField1 ¶
func (p *AgentServiceInstructionInvokeAsyncArgs) ReadField1(iprot thrift.TProtocol) error
func (*AgentServiceInstructionInvokeAsyncArgs) String ¶
func (p *AgentServiceInstructionInvokeAsyncArgs) String() string
func (*AgentServiceInstructionInvokeAsyncArgs) Write ¶
func (p *AgentServiceInstructionInvokeAsyncArgs) Write(oprot thrift.TProtocol) error
type AgentServiceInstructionInvokeAsyncResult ¶
type AgentServiceInstructionInvokeAsyncResult struct {
Success []*Reinstruct `thrift:"success,0" json:"success,omitempty"`
}
Attributes:
- Success
func NewAgentServiceInstructionInvokeAsyncResult ¶
func NewAgentServiceInstructionInvokeAsyncResult() *AgentServiceInstructionInvokeAsyncResult
func (*AgentServiceInstructionInvokeAsyncResult) GetSuccess ¶
func (p *AgentServiceInstructionInvokeAsyncResult) GetSuccess() []*Reinstruct
func (*AgentServiceInstructionInvokeAsyncResult) IsSetSuccess ¶
func (p *AgentServiceInstructionInvokeAsyncResult) IsSetSuccess() bool
func (*AgentServiceInstructionInvokeAsyncResult) Read ¶
func (p *AgentServiceInstructionInvokeAsyncResult) Read(iprot thrift.TProtocol) error
func (*AgentServiceInstructionInvokeAsyncResult) String ¶
func (p *AgentServiceInstructionInvokeAsyncResult) String() string
func (*AgentServiceInstructionInvokeAsyncResult) Write ¶
func (p *AgentServiceInstructionInvokeAsyncResult) Write(oprot thrift.TProtocol) error
type AgentServiceInstructionInvokeSyncArgs ¶
type AgentServiceInstructionInvokeSyncArgs struct {
Ins *Instruct `thrift:"ins,1" json:"ins"`
}
Attributes:
- Ins
func NewAgentServiceInstructionInvokeSyncArgs ¶
func NewAgentServiceInstructionInvokeSyncArgs() *AgentServiceInstructionInvokeSyncArgs
func (*AgentServiceInstructionInvokeSyncArgs) GetIns ¶
func (p *AgentServiceInstructionInvokeSyncArgs) GetIns() *Instruct
func (*AgentServiceInstructionInvokeSyncArgs) IsSetIns ¶
func (p *AgentServiceInstructionInvokeSyncArgs) IsSetIns() bool
func (*AgentServiceInstructionInvokeSyncArgs) Read ¶
func (p *AgentServiceInstructionInvokeSyncArgs) Read(iprot thrift.TProtocol) error
func (*AgentServiceInstructionInvokeSyncArgs) String ¶
func (p *AgentServiceInstructionInvokeSyncArgs) String() string
func (*AgentServiceInstructionInvokeSyncArgs) Write ¶
func (p *AgentServiceInstructionInvokeSyncArgs) Write(oprot thrift.TProtocol) error
type AgentServiceInstructionInvokeSyncResult ¶
type AgentServiceInstructionInvokeSyncResult struct {
Success *Reinstruct `thrift:"success,0" json:"success,omitempty"`
}
Attributes:
- Success
func NewAgentServiceInstructionInvokeSyncResult ¶
func NewAgentServiceInstructionInvokeSyncResult() *AgentServiceInstructionInvokeSyncResult
func (*AgentServiceInstructionInvokeSyncResult) GetSuccess ¶
func (p *AgentServiceInstructionInvokeSyncResult) GetSuccess() *Reinstruct
func (*AgentServiceInstructionInvokeSyncResult) IsSetSuccess ¶
func (p *AgentServiceInstructionInvokeSyncResult) IsSetSuccess() bool
func (*AgentServiceInstructionInvokeSyncResult) Read ¶
func (p *AgentServiceInstructionInvokeSyncResult) Read(iprot thrift.TProtocol) error
func (*AgentServiceInstructionInvokeSyncResult) String ¶
func (p *AgentServiceInstructionInvokeSyncResult) String() string
func (*AgentServiceInstructionInvokeSyncResult) Write ¶
func (p *AgentServiceInstructionInvokeSyncResult) Write(oprot thrift.TProtocol) error
type AgentServiceProcessor ¶
type AgentServiceProcessor struct {
// contains filtered or unexported fields
}
func NewAgentServiceProcessor ¶
func NewAgentServiceProcessor(handler AgentService) *AgentServiceProcessor
func (*AgentServiceProcessor) AddToProcessorMap ¶
func (p *AgentServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)
func (*AgentServiceProcessor) GetProcessorFunction ¶
func (p *AgentServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)
func (*AgentServiceProcessor) Process ¶
func (p *AgentServiceProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
func (*AgentServiceProcessor) ProcessorMap ¶
func (p *AgentServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction
type AppService ¶
type AppService interface { // Parameters: // - Reins RunProcessor(reins *Reinstruct) (r string, err error) }
type AppServiceClient ¶
type AppServiceClient struct { Transport thrift.TTransport ProtocolFactory thrift.TProtocolFactory InputProtocol thrift.TProtocol OutputProtocol thrift.TProtocol SeqId int32 }
func NewAppServiceClientFactory ¶
func NewAppServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *AppServiceClient
func NewAppServiceClientProtocol ¶
func NewAppServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *AppServiceClient
func (*AppServiceClient) RunProcessor ¶
func (p *AppServiceClient) RunProcessor(reins *Reinstruct) (r string, err error)
Parameters:
- Reins
type AppServiceProcessor ¶
type AppServiceProcessor struct {
// contains filtered or unexported fields
}
func NewAppServiceProcessor ¶
func NewAppServiceProcessor(handler AppService) *AppServiceProcessor
func (*AppServiceProcessor) AddToProcessorMap ¶
func (p *AppServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)
func (*AppServiceProcessor) GetProcessorFunction ¶
func (p *AppServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)
func (*AppServiceProcessor) Process ¶
func (p *AppServiceProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
func (*AppServiceProcessor) ProcessorMap ¶
func (p *AppServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction
type AppServiceRunProcessorArgs ¶
type AppServiceRunProcessorArgs struct {
Reins *Reinstruct `thrift:"reins,1" json:"reins"`
}
Attributes:
- Reins
func NewAppServiceRunProcessorArgs ¶
func NewAppServiceRunProcessorArgs() *AppServiceRunProcessorArgs
func (*AppServiceRunProcessorArgs) GetReins ¶
func (p *AppServiceRunProcessorArgs) GetReins() *Reinstruct
func (*AppServiceRunProcessorArgs) IsSetReins ¶
func (p *AppServiceRunProcessorArgs) IsSetReins() bool
func (*AppServiceRunProcessorArgs) Read ¶
func (p *AppServiceRunProcessorArgs) Read(iprot thrift.TProtocol) error
func (*AppServiceRunProcessorArgs) String ¶
func (p *AppServiceRunProcessorArgs) String() string
func (*AppServiceRunProcessorArgs) Write ¶
func (p *AppServiceRunProcessorArgs) Write(oprot thrift.TProtocol) error
type AppServiceRunProcessorResult ¶
type AppServiceRunProcessorResult struct {
Success *string `thrift:"success,0" json:"success,omitempty"`
}
Attributes:
- Success
func NewAppServiceRunProcessorResult ¶
func NewAppServiceRunProcessorResult() *AppServiceRunProcessorResult
func (*AppServiceRunProcessorResult) GetSuccess ¶
func (p *AppServiceRunProcessorResult) GetSuccess() string
func (*AppServiceRunProcessorResult) IsSetSuccess ¶
func (p *AppServiceRunProcessorResult) IsSetSuccess() bool
func (*AppServiceRunProcessorResult) Read ¶
func (p *AppServiceRunProcessorResult) Read(iprot thrift.TProtocol) error
func (*AppServiceRunProcessorResult) String ¶
func (p *AppServiceRunProcessorResult) String() string
func (*AppServiceRunProcessorResult) Write ¶
func (p *AppServiceRunProcessorResult) Write(oprot thrift.TProtocol) error
type Instruct ¶
type Instruct struct { ID string `thrift:"id,1" json:"id"` IP string `thrift:"ip,2" json:"ip"` Type string `thrift:"type,3" json:"type"` Mode string `thrift:"mode,4" json:"mode"` App string `thrift:"app,5" json:"app"` Func string `thrift:"func,6" json:"func"` Param string `thrift:"param,7" json:"param"` Timeout int32 `thrift:"timeout,8" json:"timeout"` Proxy string `thrift:"proxy,9" json:"proxy"` }
Attributes:
- ID
- IP
- Type
- Mode
- App
- Func
- Param
- Timeout
- Proxy
var AgentServiceInstructionInvokeSyncArgs_Ins_DEFAULT *Instruct
var Reinstruct_Ins_DEFAULT *Instruct
var SchedulerServiceInstructionTransitArgs_Ins_DEFAULT *Instruct
func NewInstruct ¶
func NewInstruct() *Instruct
func (*Instruct) GetTimeout ¶
type Reinstruct ¶
type Reinstruct struct { Ins *Instruct `thrift:"ins,1" json:"ins"` // unused field # 2 Flag int32 `thrift:"flag,3" json:"flag"` Costtime int32 `thrift:"costtime,4" json:"costtime"` Result_ string `thrift:"result,5" json:"result"` }
Attributes:
- Ins
- Flag
- Costtime
- Result_
var AgentServiceInstructionInvokeSyncResult_Success_DEFAULT *Reinstruct
var AppServiceRunProcessorArgs_Reins_DEFAULT *Reinstruct
var SchedulerServiceDataTransportArgs_Reins_DEFAULT *Reinstruct
var SchedulerServiceInstructionTransitResult_Success_DEFAULT *Reinstruct
func NewReinstruct ¶
func NewReinstruct() *Reinstruct
func (*Reinstruct) GetCosttime ¶
func (p *Reinstruct) GetCosttime() int32
func (*Reinstruct) GetFlag ¶
func (p *Reinstruct) GetFlag() int32
func (*Reinstruct) GetIns ¶
func (p *Reinstruct) GetIns() *Instruct
func (*Reinstruct) GetResult_ ¶
func (p *Reinstruct) GetResult_() string
func (*Reinstruct) IsSetIns ¶
func (p *Reinstruct) IsSetIns() bool
func (*Reinstruct) Read ¶
func (p *Reinstruct) Read(iprot thrift.TProtocol) error
func (*Reinstruct) String ¶
func (p *Reinstruct) String() string
func (*Reinstruct) Write ¶
func (p *Reinstruct) Write(oprot thrift.TProtocol) error
type SchedulerService ¶
type SchedulerService interface { AliveCheck() (r string, err error) // Parameters: // - Reins DataTransport(reins *Reinstruct) (r string, err error) // Parameters: // - Ins InstructionTransit(ins *Instruct) (r *Reinstruct, err error) }
type SchedulerServiceAliveCheckArgs ¶
type SchedulerServiceAliveCheckArgs struct { }
func NewSchedulerServiceAliveCheckArgs ¶
func NewSchedulerServiceAliveCheckArgs() *SchedulerServiceAliveCheckArgs
func (*SchedulerServiceAliveCheckArgs) Read ¶
func (p *SchedulerServiceAliveCheckArgs) Read(iprot thrift.TProtocol) error
func (*SchedulerServiceAliveCheckArgs) String ¶
func (p *SchedulerServiceAliveCheckArgs) String() string
func (*SchedulerServiceAliveCheckArgs) Write ¶
func (p *SchedulerServiceAliveCheckArgs) Write(oprot thrift.TProtocol) error
type SchedulerServiceAliveCheckResult ¶
type SchedulerServiceAliveCheckResult struct {
Success *string `thrift:"success,0" json:"success,omitempty"`
}
Attributes:
- Success
func NewSchedulerServiceAliveCheckResult ¶
func NewSchedulerServiceAliveCheckResult() *SchedulerServiceAliveCheckResult
func (*SchedulerServiceAliveCheckResult) GetSuccess ¶
func (p *SchedulerServiceAliveCheckResult) GetSuccess() string
func (*SchedulerServiceAliveCheckResult) IsSetSuccess ¶
func (p *SchedulerServiceAliveCheckResult) IsSetSuccess() bool
func (*SchedulerServiceAliveCheckResult) Read ¶
func (p *SchedulerServiceAliveCheckResult) Read(iprot thrift.TProtocol) error
func (*SchedulerServiceAliveCheckResult) String ¶
func (p *SchedulerServiceAliveCheckResult) String() string
func (*SchedulerServiceAliveCheckResult) Write ¶
func (p *SchedulerServiceAliveCheckResult) Write(oprot thrift.TProtocol) error
type SchedulerServiceClient ¶
type SchedulerServiceClient struct { Transport thrift.TTransport ProtocolFactory thrift.TProtocolFactory InputProtocol thrift.TProtocol OutputProtocol thrift.TProtocol SeqId int32 }
func NewSchedulerServiceClientFactory ¶
func NewSchedulerServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *SchedulerServiceClient
func NewSchedulerServiceClientProtocol ¶
func NewSchedulerServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *SchedulerServiceClient
func (*SchedulerServiceClient) AliveCheck ¶
func (p *SchedulerServiceClient) AliveCheck() (r string, err error)
func (*SchedulerServiceClient) DataTransport ¶
func (p *SchedulerServiceClient) DataTransport(reins *Reinstruct) (r string, err error)
Parameters:
- Reins
func (*SchedulerServiceClient) InstructionTransit ¶
func (p *SchedulerServiceClient) InstructionTransit(ins *Instruct) (r *Reinstruct, err error)
Parameters:
- Ins
type SchedulerServiceDataTransportArgs ¶
type SchedulerServiceDataTransportArgs struct {
Reins *Reinstruct `thrift:"reins,1" json:"reins"`
}
Attributes:
- Reins
func NewSchedulerServiceDataTransportArgs ¶
func NewSchedulerServiceDataTransportArgs() *SchedulerServiceDataTransportArgs
func (*SchedulerServiceDataTransportArgs) GetReins ¶
func (p *SchedulerServiceDataTransportArgs) GetReins() *Reinstruct
func (*SchedulerServiceDataTransportArgs) IsSetReins ¶
func (p *SchedulerServiceDataTransportArgs) IsSetReins() bool
func (*SchedulerServiceDataTransportArgs) Read ¶
func (p *SchedulerServiceDataTransportArgs) Read(iprot thrift.TProtocol) error
func (*SchedulerServiceDataTransportArgs) String ¶
func (p *SchedulerServiceDataTransportArgs) String() string
func (*SchedulerServiceDataTransportArgs) Write ¶
func (p *SchedulerServiceDataTransportArgs) Write(oprot thrift.TProtocol) error
type SchedulerServiceDataTransportResult ¶
type SchedulerServiceDataTransportResult struct {
Success *string `thrift:"success,0" json:"success,omitempty"`
}
Attributes:
- Success
func NewSchedulerServiceDataTransportResult ¶
func NewSchedulerServiceDataTransportResult() *SchedulerServiceDataTransportResult
func (*SchedulerServiceDataTransportResult) GetSuccess ¶
func (p *SchedulerServiceDataTransportResult) GetSuccess() string
func (*SchedulerServiceDataTransportResult) IsSetSuccess ¶
func (p *SchedulerServiceDataTransportResult) IsSetSuccess() bool
func (*SchedulerServiceDataTransportResult) Read ¶
func (p *SchedulerServiceDataTransportResult) Read(iprot thrift.TProtocol) error
func (*SchedulerServiceDataTransportResult) String ¶
func (p *SchedulerServiceDataTransportResult) String() string
func (*SchedulerServiceDataTransportResult) Write ¶
func (p *SchedulerServiceDataTransportResult) Write(oprot thrift.TProtocol) error
type SchedulerServiceInstructionTransitArgs ¶
type SchedulerServiceInstructionTransitArgs struct {
Ins *Instruct `thrift:"ins,1" json:"ins"`
}
Attributes:
- Ins
func NewSchedulerServiceInstructionTransitArgs ¶
func NewSchedulerServiceInstructionTransitArgs() *SchedulerServiceInstructionTransitArgs
func (*SchedulerServiceInstructionTransitArgs) GetIns ¶
func (p *SchedulerServiceInstructionTransitArgs) GetIns() *Instruct
func (*SchedulerServiceInstructionTransitArgs) IsSetIns ¶
func (p *SchedulerServiceInstructionTransitArgs) IsSetIns() bool
func (*SchedulerServiceInstructionTransitArgs) Read ¶
func (p *SchedulerServiceInstructionTransitArgs) Read(iprot thrift.TProtocol) error
func (*SchedulerServiceInstructionTransitArgs) String ¶
func (p *SchedulerServiceInstructionTransitArgs) String() string
func (*SchedulerServiceInstructionTransitArgs) Write ¶
func (p *SchedulerServiceInstructionTransitArgs) Write(oprot thrift.TProtocol) error
type SchedulerServiceInstructionTransitResult ¶
type SchedulerServiceInstructionTransitResult struct {
Success *Reinstruct `thrift:"success,0" json:"success,omitempty"`
}
Attributes:
- Success
func NewSchedulerServiceInstructionTransitResult ¶
func NewSchedulerServiceInstructionTransitResult() *SchedulerServiceInstructionTransitResult
func (*SchedulerServiceInstructionTransitResult) GetSuccess ¶
func (p *SchedulerServiceInstructionTransitResult) GetSuccess() *Reinstruct
func (*SchedulerServiceInstructionTransitResult) IsSetSuccess ¶
func (p *SchedulerServiceInstructionTransitResult) IsSetSuccess() bool
func (*SchedulerServiceInstructionTransitResult) Read ¶
func (p *SchedulerServiceInstructionTransitResult) Read(iprot thrift.TProtocol) error
func (*SchedulerServiceInstructionTransitResult) String ¶
func (p *SchedulerServiceInstructionTransitResult) String() string
func (*SchedulerServiceInstructionTransitResult) Write ¶
func (p *SchedulerServiceInstructionTransitResult) Write(oprot thrift.TProtocol) error
type SchedulerServiceProcessor ¶
type SchedulerServiceProcessor struct {
// contains filtered or unexported fields
}
func NewSchedulerServiceProcessor ¶
func NewSchedulerServiceProcessor(handler SchedulerService) *SchedulerServiceProcessor
func (*SchedulerServiceProcessor) AddToProcessorMap ¶
func (p *SchedulerServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)
func (*SchedulerServiceProcessor) GetProcessorFunction ¶
func (p *SchedulerServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)
func (*SchedulerServiceProcessor) Process ¶
func (p *SchedulerServiceProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
func (*SchedulerServiceProcessor) ProcessorMap ¶
func (p *SchedulerServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction
Source Files ¶
Click to show internal directories.
Click to hide internal directories.