mgsinteractor

Documentation

Overview

Package mgsinteractor contains logic to open control channel and communicate with MGS

Package mgsinteractor will be responsible for interacting with MGS

Package mgsinteractor will be responsible for interacting with MGS

Index

• Constants
• func New(context context.T, messageHandler messagehandler.IMessageHandler) (interactor.IInteractor, error)
• type AgentResultLocalStoreData
• type MGSInteractor
  • func (mgs *MGSInteractor) Close() (err error)
  • func (mgs *MGSInteractor) GetName() string
  • func (mgs *MGSInteractor) GetSupportedWorkers() []utils.WorkerName
  • func (mgs *MGSInteractor) Initialize(ableToOpenMGSConnection *uint32) (err error)
  • func (mgs *MGSInteractor) PostProcessorInitialization(worker utils.WorkerName)
  • func (mgs *MGSInteractor) PreProcessorClose()

Constants

const (
	Name          = "MGSInteractor"
	ISO8601Format = "2006-01-02T15:04:05.000Z"
)

Functions

func New

func New(context context.T, messageHandler messagehandler.IMessageHandler) (interactor.IInteractor, error)

New initiates and returns MGS Interactor when needed

Types

type AgentResultLocalStoreData

type AgentResultLocalStoreData struct {
	AgentResult contracts.DocumentResult
	ReplyId     string
	RetryNumber int
}

AgentResultLocalStoreData represents the format of data that we will store it in the local disk for failed replies

type MGSInteractor

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

MGSInteractor defines the properties and methods to communicate with MDS

func (*MGSInteractor) Close

func (mgs *MGSInteractor) Close() (err error)

Close closes the existing MGS connection

func (*MGSInteractor) GetName

func (mgs *MGSInteractor) GetName() string

GetName used to get the name of interactor

func (*MGSInteractor) GetSupportedWorkers

func (mgs *MGSInteractor) GetSupportedWorkers() []utils.WorkerName

GetSupportedWorkers returns the processors needed by the interactors this function can be changed to GetRequiredWorkers in future

func (*MGSInteractor) Initialize

func (mgs *MGSInteractor) Initialize(ableToOpenMGSConnection *uint32) (err error)

Initialize initializes interactor properties and starts failed reply job

func (*MGSInteractor) PostProcessorInitialization

func (mgs *MGSInteractor) PostProcessorInitialization(worker utils.WorkerName)

PostProcessorInitialization registers executes PostProcessorInitialization operations Will be executed after the processor initialization is done in MessageService.

func (*MGSInteractor) PreProcessorClose

func (mgs *MGSInteractor) PreProcessorClose()

PreProcessorClose defines actions to be performed before MGS connection close