Documentation
¶
Overview ¶
Package processorwrappers implements different processor wrappers to handle the processors which launches document worker and session worker for now
Package processorwrappers implements different processor wrappers to handle the processors which launches document worker and session worker for now
Package processorwrappers implements different processor wrappers to handle the processors which launches document worker and session worker for now
Package processorwrappers implements different processor wrappers to handle the processors which launches document worker and session worker for now
Index ¶
- func GetProcessorWrapperDelegateMap() ...
- type CommandWorkerProcessorWrapper
- func (cpw *CommandWorkerProcessorWrapper) GetName() utils.ProcessorName
- func (cpw *CommandWorkerProcessorWrapper) GetStartWorker() contracts.DocumentType
- func (cpw *CommandWorkerProcessorWrapper) GetTerminateWorker() contracts.DocumentType
- func (cpw *CommandWorkerProcessorWrapper) Initialize(outputChan map[contracts.UpstreamServiceName]chan contracts.DocumentResult) error
- func (cpw *CommandWorkerProcessorWrapper) PushToProcessor(message contracts.DocumentState) processor.ErrorCode
- func (cpw *CommandWorkerProcessorWrapper) Stop()
- type IProcessorWrapper
- type SessionWorkerProcessorWrapper
- func (spw *SessionWorkerProcessorWrapper) GetName() utils.ProcessorName
- func (spw *SessionWorkerProcessorWrapper) GetStartWorker() contracts.DocumentType
- func (spw *SessionWorkerProcessorWrapper) GetTerminateWorker() contracts.DocumentType
- func (spw *SessionWorkerProcessorWrapper) Initialize(outputChan map[contracts.UpstreamServiceName]chan contracts.DocumentResult) error
- func (spw *SessionWorkerProcessorWrapper) PushToProcessor(message contracts.DocumentState) processor.ErrorCode
- func (spw *SessionWorkerProcessorWrapper) Stop()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetProcessorWrapperDelegateMap ¶
func GetProcessorWrapperDelegateMap() map[utils.WorkerName]func(context.T, *utils.ProcessorWorkerConfig) IProcessorWrapper
GetProcessorWrapperDelegateMap returns preloaded map with worker name and processor wrapper creation function pointer as its key and value
Types ¶
type CommandWorkerProcessorWrapper ¶
type CommandWorkerProcessorWrapper struct {
// contains filtered or unexported fields
}
CommandWorkerProcessorWrapper defines properties and methods to interact with the processor launched for the document worker
func (*CommandWorkerProcessorWrapper) GetName ¶
func (cpw *CommandWorkerProcessorWrapper) GetName() utils.ProcessorName
GetName returns the name of the processor
func (*CommandWorkerProcessorWrapper) GetStartWorker ¶
func (cpw *CommandWorkerProcessorWrapper) GetStartWorker() contracts.DocumentType
GetStartWorker gets the command which launches the command worker in processor
func (*CommandWorkerProcessorWrapper) GetTerminateWorker ¶
func (cpw *CommandWorkerProcessorWrapper) GetTerminateWorker() contracts.DocumentType
GetTerminateWorker gets the command which cancels the command worker in processor
func (*CommandWorkerProcessorWrapper) Initialize ¶
func (cpw *CommandWorkerProcessorWrapper) Initialize(outputChan map[contracts.UpstreamServiceName]chan contracts.DocumentResult) error
Initialize initializes command processor and launches the reply thread
func (*CommandWorkerProcessorWrapper) PushToProcessor ¶
func (cpw *CommandWorkerProcessorWrapper) PushToProcessor(message contracts.DocumentState) processor.ErrorCode
PushToProcessor submits the command to the processor
func (*CommandWorkerProcessorWrapper) Stop ¶
func (cpw *CommandWorkerProcessorWrapper) Stop()
Stop stops the processor
type IProcessorWrapper ¶
type IProcessorWrapper interface {
Initialize(outputChan map[contracts.UpstreamServiceName]chan contracts.DocumentResult) error
GetName() utils.ProcessorName
GetStartWorker() contracts.DocumentType
GetTerminateWorker() contracts.DocumentType
PushToProcessor(contracts.DocumentState) processor.ErrorCode
Stop()
}
IProcessorWrapper provides basic methods for processor wrapper
func NewCommandWorkerProcessorWrapper ¶
func NewCommandWorkerProcessorWrapper(context context.T, worker *utils.ProcessorWorkerConfig) IProcessorWrapper
NewCommandWorkerProcessorWrapper initiates new processor wrapper which supports document workers
func NewSessionWorkerProcessorWrapper ¶
func NewSessionWorkerProcessorWrapper(context context.T, worker *utils.ProcessorWorkerConfig) IProcessorWrapper
NewSessionWorkerProcessorWrapper initiates new processor wrapper which supports session workers
type SessionWorkerProcessorWrapper ¶
type SessionWorkerProcessorWrapper struct {
// contains filtered or unexported fields
}
SessionWorkerProcessorWrapper defines properties and methods to interact with the processor launched for the session worker
func (*SessionWorkerProcessorWrapper) GetName ¶
func (spw *SessionWorkerProcessorWrapper) GetName() utils.ProcessorName
GetName gets the name of the processor wrapper
func (*SessionWorkerProcessorWrapper) GetStartWorker ¶
func (spw *SessionWorkerProcessorWrapper) GetStartWorker() contracts.DocumentType
GetStartWorker gets the command which launches the session worker in processor
func (*SessionWorkerProcessorWrapper) GetTerminateWorker ¶
func (spw *SessionWorkerProcessorWrapper) GetTerminateWorker() contracts.DocumentType
GetTerminateWorker gets the command which cancels the session worker in processor
func (*SessionWorkerProcessorWrapper) Initialize ¶
func (spw *SessionWorkerProcessorWrapper) Initialize(outputChan map[contracts.UpstreamServiceName]chan contracts.DocumentResult) error
Initialize initializes session processor and launches the reply thread
func (*SessionWorkerProcessorWrapper) PushToProcessor ¶
func (spw *SessionWorkerProcessorWrapper) PushToProcessor(message contracts.DocumentState) processor.ErrorCode
PushToProcessor submits the command to the processor
func (*SessionWorkerProcessorWrapper) Stop ¶
func (spw *SessionWorkerProcessorWrapper) Stop()
Stop stops the processor
Source Files
Directories