Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FluentReader ¶
type FluentReader struct {
// contains filtered or unexported fields
}
func New ¶
func New(eventHandler HandlerFunc) *FluentReader
type FluentSession ¶
type FluentSession struct { Reader *FluentReader Hostname string PasswordForKey PasswordForKey Logger *log.Logger Users func(string) []byte Debug bool // contains filtered or unexported fields }
func (*FluentSession) Ack ¶
func (s *FluentSession) Ack(chunk string) error
func (*FluentSession) Flush ¶
func (s *FluentSession) Flush() error
func (*FluentSession) HandleEvents ¶
func (s *FluentSession) HandleEvents(l int, _type string) error
func (*FluentSession) HandleHearthBeat ¶
func (s *FluentSession) HandleHearthBeat() error
func (*FluentSession) Loop ¶
func (s *FluentSession) Loop(conn io.ReadWriteCloser) error
type HandlerFunc ¶
type PasswordForKey ¶
type Ping ¶
type Ping struct {
// contains filtered or unexported fields
}
func (*Ping) ValidatePassword ¶
func (*Ping) ValidateSharedKeyHexdigest ¶
Click to show internal directories.
Click to hide internal directories.