Documentation
¶
Index ¶
- func Error(err error) processorResultOption
- func InitProcessorFactory(engine engine.ManagerEngine)
- func OnChannel(done chan struct{}) processorResultOption
- func Result(r *pb.ClientMessage) processorResultOption
- type DisableProcessor
- type EnableProcessor
- type ProbeSessionProcessor
- type Processor
- type ProcessorError
- type ProcessorFactory
- type ProcessorResult
- type RemoteTaskProcessor
- type UpdateWatchConfigurationProcessor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitProcessorFactory ¶
func InitProcessorFactory(engine engine.ManagerEngine)
func Result ¶
func Result(r *pb.ClientMessage) processorResultOption
Types ¶
type DisableProcessor ¶
type DisableProcessor struct { }
Currently remote work processor ID should be in the following format - <cluster>:<app>:<instance>
func NewDisableProcessor ¶
func NewDisableProcessor() DisableProcessor
func (DisableProcessor) Process ¶
func (p DisableProcessor) Process() <-chan *ProcessorResult
type EnableProcessor ¶
type EnableProcessor struct { }
Currently remote work processor ID should be in the following format - <cluster>:<app>:<instance>
func NewEnableProcessor ¶
func NewEnableProcessor() EnableProcessor
func (EnableProcessor) Process ¶
func (p EnableProcessor) Process() <-chan *ProcessorResult
type ProbeSessionProcessor ¶
type ProbeSessionProcessor struct { }
func NewProbeSessionProcessor ¶
func NewProbeSessionProcessor() ProbeSessionProcessor
func (ProbeSessionProcessor) Process ¶
func (p ProbeSessionProcessor) Process() <-chan *ProcessorResult
type Processor ¶
type Processor interface {
Process() <-chan *ProcessorResult
}
type ProcessorError ¶
type ProcessorError struct {
// contains filtered or unexported fields
}
func NewProcessorError ¶
func NewProcessorError(message string) *ProcessorError
func (ProcessorError) Error ¶
func (e ProcessorError) Error() string
type ProcessorFactory ¶
type ProcessorFactory struct {
// contains filtered or unexported fields
}
var (
Factory ProcessorFactory
)
func (*ProcessorFactory) CreateProbeSessionProcessor ¶
func (pf *ProcessorFactory) CreateProbeSessionProcessor() Processor
func (*ProcessorFactory) CreateProcessor ¶
func (pf *ProcessorFactory) CreateProcessor(op *pb.ServerMessage) (Processor, error)
type ProcessorResult ¶
type ProcessorResult struct { Result *pb.ClientMessage Err error Done chan struct{} }
func NewProcessorResult ¶
func NewProcessorResult(opts ...processorResultOption) *ProcessorResult
type RemoteTaskProcessor ¶
type RemoteTaskProcessor struct {
// contains filtered or unexported fields
}
func NewRemoteTaskProcessor ¶
func NewRemoteTaskProcessor(req *pb.ServerMessage_TaskExecutionRequest) RemoteTaskProcessor
func (RemoteTaskProcessor) Process ¶
func (p RemoteTaskProcessor) Process() <-chan *ProcessorResult
type UpdateWatchConfigurationProcessor ¶
type UpdateWatchConfigurationProcessor struct {
// contains filtered or unexported fields
}
func NewUpdateWatchConfigurationProcessor ¶
func NewUpdateWatchConfigurationProcessor(op *pb.ServerMessage, engine engine.ManagerEngine) UpdateWatchConfigurationProcessor
func (UpdateWatchConfigurationProcessor) Process ¶
func (p UpdateWatchConfigurationProcessor) Process() <-chan *ProcessorResult
Click to show internal directories.
Click to hide internal directories.