Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DisableProcessor ¶
type DisableProcessor struct {
// contains filtered or unexported fields
}
func NewDisableProcessor ¶
func NewDisableProcessor(disableFunc func()) DisableProcessor
func (DisableProcessor) Process ¶
func (p DisableProcessor) Process(_ context.Context) (*pb.ClientMessage, error)
type EnableProcessor ¶
type EnableProcessor struct {
// contains filtered or unexported fields
}
func NewEnableProcessor ¶
func NewEnableProcessor(enableFunc func()) EnableProcessor
func (EnableProcessor) Process ¶
func (p EnableProcessor) Process(_ context.Context) (*pb.ClientMessage, error)
type Processor ¶
type Processor interface {
Process(ctx context.Context) (*pb.ClientMessage, error)
}
type ProcessorFactory ¶
type ProcessorFactory struct {
// contains filtered or unexported fields
}
func NewKubernetesProcessorFactory ¶ added in v0.0.4
func NewKubernetesProcessorFactory(engine engine.ManagerEngine, drainChan chan struct{}) ProcessorFactory
func NewStandaloneProcessorFactory ¶ added in v0.0.4
func NewStandaloneProcessorFactory() ProcessorFactory
func (*ProcessorFactory) CreateProcessor ¶
func (pf *ProcessorFactory) CreateProcessor(op *pb.ServerMessage) (Processor, error)
type RemoteTaskProcessor ¶
type RemoteTaskProcessor struct {
// contains filtered or unexported fields
}
func NewRemoteTaskProcessor ¶
func NewRemoteTaskProcessor(req *pb.ServerMessage_TaskExecutionRequest, isEnabled func() bool) RemoteTaskProcessor
func (RemoteTaskProcessor) Process ¶
func (p RemoteTaskProcessor) Process(_ context.Context) (*pb.ClientMessage, error)
type UpdateWatchConfigurationProcessor ¶
type UpdateWatchConfigurationProcessor struct {
// contains filtered or unexported fields
}
func NewUpdateWatchConfigurationProcessor ¶
func NewUpdateWatchConfigurationProcessor(op *pb.ServerMessage_UpdateConfigRequest, engine engine.ManagerEngine, drainChan chan struct{}, isEnabled func() bool) UpdateWatchConfigurationProcessor
func (UpdateWatchConfigurationProcessor) Process ¶
func (p UpdateWatchConfigurationProcessor) Process(ctx context.Context) (*pb.ClientMessage, error)
Source Files
Click to show internal directories.
Click to hide internal directories.