processor

package
v0.0.0-...-bbbf429 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 4, 2017 License: GPL-3.0 Imports: 10 Imported by: 1

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL