defaultreader

Documentation

Index

• func DefaultMessagesReaderFactory(eventHandler HandlerFunc) options.MessagesReaderFactory
• type DefaultMessagesReader
  • func (r *DefaultMessagesReader) ForwardMode(wire *wire.Wire, tag string) error
  • func (r *DefaultMessagesReader) MessageMode(wire *wire.Wire, tag string) error
  • func (r *DefaultMessagesReader) PackedForwardMode(tag string, entries []byte, opt *msg.Option) error
• type HandlerFunc

Functions

func DefaultMessagesReaderFactory

func DefaultMessagesReaderFactory(eventHandler HandlerFunc) options.MessagesReaderFactory

Types

type DefaultMessagesReader

type DefaultMessagesReader struct {
	Logger       *log.Logger
	EventHandler HandlerFunc
}

func (*DefaultMessagesReader) ForwardMode

func (r *DefaultMessagesReader) ForwardMode(wire *wire.Wire, tag string) error

func (*DefaultMessagesReader) MessageMode

func (r *DefaultMessagesReader) MessageMode(wire *wire.Wire, tag string) error

func (*DefaultMessagesReader) PackedForwardMode

func (r *DefaultMessagesReader) PackedForwardMode(tag string, entries []byte, opt *msg.Option) error

type HandlerFunc

type HandlerFunc func(tag string, time *time.Time, record map[string]interface{}) error

HandlerFunc handles an event