Documentation
¶
Overview ¶
Package messageservice will be responsible for initializing MDS and MGS interactors and then launch message handlers to handle the commands received from interactors. This package is the starting point for the message service module.
Index ¶
- Constants
- func NewService(context context.T) contracts.ICoreModule
- type MessageService
- func (msgSvc *MessageService) GetMessageHandler() messagehandler.IMessageHandler
- func (msgSvc *MessageService) ModuleExecute() (err error)
- func (msgSvc *MessageService) ModuleName() string
- func (msgSvc *MessageService) ModuleStop() error
- func (msgSvc *MessageService) SetInteractor(iInteractor []interactor.IInteractor)
Constants ¶
const (
// ServiceName represents MessageService ICoreModule name
ServiceName = "MessageService"
)
Variables ¶
This section is empty.
Functions ¶
func NewService ¶
func NewService(context context.T) contracts.ICoreModule
NewService instantiates MessageService object and assigns value if needed
Types ¶
type MessageService ¶
type MessageService struct {
// contains filtered or unexported fields
}
MessageService is the core module for initializing MDS and MGS interactors and then launch message handlers which in turn initiates processors to process the commands from interactors
func (*MessageService) GetMessageHandler ¶
func (msgSvc *MessageService) GetMessageHandler() messagehandler.IMessageHandler
GetMessageHandler returns the message handler object reference TODO remove once we start doing stress tests using service mock framework
func (*MessageService) ModuleExecute ¶
func (msgSvc *MessageService) ModuleExecute() (err error)
ModuleExecute starts the MessageService module
func (*MessageService) ModuleName ¶
func (msgSvc *MessageService) ModuleName() string
ModuleName returns the name of module
func (*MessageService) ModuleStop ¶
func (msgSvc *MessageService) ModuleStop() error
ModuleStop stops the MessageService module
func (*MessageService) SetInteractor ¶
func (msgSvc *MessageService) SetInteractor(iInteractor []interactor.IInteractor)
SetInteractor resets the interactor value TODO remove once we start doing stress tests using service mock framework
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package contracts defines the common structs needed for messageservice
|
Package contracts defines the common structs needed for messageservice |
|
Package interactor contains the logic to communicate with upstream core services MGS & MDS
|
Package interactor contains the logic to communicate with upstream core services MGS & MDS |
|
mdsinteractor
Package mdsinteractor will be responsible for communicating with MDS
|
Package mdsinteractor will be responsible for communicating with MDS |
|
mgsinteractor
Package mgsinteractor contains logic to open control channel and communicate with MGS
|
Package mgsinteractor contains logic to open control channel and communicate with MGS |
|
mgsinteractor/replytypes
Package replytypes will be responsible for handling agent run command reply type from the processor
|
Package replytypes will be responsible for handling agent run command reply type from the processor |
|
Package messagehandler defines methods to be used by Interactors for submission of commands to the processors through ProcessorWrappers It also forwards the replies receives from processor wrapper
|
Package messagehandler defines methods to be used by Interactors for submission of commands to the processors through ProcessorWrappers It also forwards the replies receives from processor wrapper |
|
idempotency
Package idempotency implements methods to maintain idempotency with the commands received
|
Package idempotency implements methods to maintain idempotency with the commands received |
|
processorwrappers
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 utils provides utility functions to be used by interactors
|
Package utils provides utility functions to be used by interactors |