processor

Documentation

Index

• func NewIntentionsMapping() *map[string]func(*config.Configuration, *data.Message)
• type MessageProcessor
  • func NewMessageProcessor(intentions *map[string]func(appConfig *config.Configuration, p *data.Message), ...) *MessageProcessor
  • func (m *MessageProcessor) Drain()
  • func (m *MessageProcessor) Start()

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