processors

package
v0.0.3 Latest Latest
Warning

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

Go to latest
Published: Oct 20, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Error

func Error(err error) processorResultOption

func InitProcessorFactory

func InitProcessorFactory(engine engine.ManagerEngine)

func OnChannel

func OnChannel(done chan struct{}) processorResultOption

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 (RemoteTaskProcessor) Process

func (p RemoteTaskProcessor) Process() <-chan *ProcessorResult

type UpdateWatchConfigurationProcessor

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

func (UpdateWatchConfigurationProcessor) Process

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL