Versions in this module Expand all Collapse all v0 v0.5.0 May 24, 2022 Changes in this version + func DefaultMessagesReaderFactory(eventHandler HandlerFunc) options.MessagesReaderFactory + type DefaultMessagesReader struct + EventHandler HandlerFunc + Logger *log.Logger + 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 func(tag string, time *time.Time, record map[string]interface{}) error