message

Mar 15, 2022

Changes in this version

type FluentSession

+ Debug bool

Mar 13, 2022

Changes in this version

type FluentSession

+ Users func(string) []byte

type Ping

+ func (p *Ping) ValidatePassword(hashsalt []byte, user func(string) []byte) error

Mar 13, 2022

Changes in this version

type FluentSession

+ Logger *log.Logger

Mar 12, 2022

Changes in this version

+ type FluentSession struct

+ Hostname string

+ PasswordForKey PasswordForKey

+ Reader *FluentReader

+ SharedKey string

+ func (s *FluentSession) Ack(chunk string) error

+ func (s *FluentSession) Flush() error

+ func (s *FluentSession) HandleEvents(l int, _type string) error

+ func (s *FluentSession) HandleHearthBeat() error

+ func (s *FluentSession) Loop(conn io.ReadWriteCloser) error

+ type Flusher interface

+ Flush func() error

+ type Option struct

+ Chunk string

+ Compressed string

+ Size int

+ Stuff map[string]interface{}

+ type PasswordForKey func(string) string

+ type Ping struct

+ func (p *Ping) ValidateSharedKeyHexdigest(nonce, sharedKey string) error

+ type Step int

+ const WaitingForEvents

+ const WaitingForPing

+ const WaitingForPong

+ const WatingForHelo

Nov 17, 2020

Changes in this version

+ type Event struct

+ type FluentReader struct

+ func New(eventHandler HandlerFunc) *FluentReader

+ func (f *FluentReader) Listen(flux io.ReadWriter) error

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