Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewIntentionsMapping ¶
func NewIntentionsMapping() *map[string]func(*config.Configuration, *data.Message)
NewIntentionsMapping Creates the intentions mappings...
Types ¶
type MessageProcessor ¶
type MessageProcessor struct {
PubSubRef event.IEvent
PubSubConfigurationRef event.IEventConfiguration
ApplicationConfiguration *config.Configuration
// contains filtered or unexported fields
}
MessageProcessor object definition
func NewMessageProcessor ¶
func NewMessageProcessor(intentions *map[string]func(appConfig *config.Configuration, p *data.Message), pubsub event.IEvent, pubsubconf event.IEventConfiguration, appConfig *config.Configuration) *MessageProcessor
NewMessageProcessor creates a new MessageProcessor object
func (*MessageProcessor) Drain ¶
func (m *MessageProcessor) Drain()
func (*MessageProcessor) Start ¶
func (m *MessageProcessor) Start()
Start the blocking process to ingest and egest traffic
Source Files
Click to show internal directories.
Click to hide internal directories.