Versions in this module Expand all Collapse all v0 v0.5.0 May 24, 2022 Changes in this version + type FluentOptions struct + Debug bool + Hostname string + Logger *log.Logger + MessagesReaderConfig map[string]interface{} + MessagesReaderFactory MessagesReaderFactory + SharedKey string + Users func(string) []byte + type FluentReader struct + MessagesReaderFactory MessagesReaderFactory + type MessagesReader interface + ForwardMode func(wire *wire.Wire, tag string) error + MessageMode func(wire *wire.Wire, tag string) error + PackedForwardMode func(tag string, blob []byte, opt *msg.Option) error + type MessagesReaderFactory func(log *log.Logger, cfg map[string]interface{}) MessagesReader + type Session struct + Logger *log.Logger + Reader *FluentReader
Go to main page