options

type FluentOptions struct {
	MessagesReaderConfig  map[string]interface{}
	MessagesReaderFactory MessagesReaderFactory
	SharedKey             string
	Hostname              string
	Logger                *log.Logger
	Users                 func(string) []byte
	Debug                 bool
}

type FluentReader struct {
	MessagesReaderFactory MessagesReaderFactory
}

type MessagesReader interface {
	ForwardMode(wire *wire.Wire, tag string) error
	PackedForwardMode(tag string, blob []byte, opt *msg.Option) error
	MessageMode(wire *wire.Wire, tag string) error
}

type MessagesReaderFactory func(log *log.Logger, cfg map[string]interface{}) MessagesReader

type Session struct {
	Logger *log.Logger
	Reader *FluentReader
}