message

Documentation

Index

• type Event
• type FluentReader
  • func New(eventHandler HandlerFunc) *FluentReader
• type FluentSession
  • 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
• type HandlerFunc
• type Option
• type PasswordForKey
• type Ping
  • func (p *Ping) ValidatePassword(hashsalt []byte, user func(string) []byte) error
  • func (p *Ping) ValidateSharedKeyHexdigest(nonce, sharedKey string) error
• type Step

Types

type Event

type Event struct {
	// contains filtered or unexported fields
}

type FluentReader

type FluentReader struct {
	// contains filtered or unexported fields
}

func New

func New(eventHandler HandlerFunc) *FluentReader

type FluentSession

type FluentSession struct {
	Reader    *FluentReader
	SharedKey string

	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 Flusher

type Flusher interface {
	Flush() error
}

type HandlerFunc

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

type Option

type Option struct {
	Size       int
	Chunk      string
	Compressed string
	Stuff      map[string]interface{}
}

type PasswordForKey

type PasswordForKey func(string) string

type Ping

type Ping struct {
	// contains filtered or unexported fields
}

func (*Ping) ValidatePassword

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

func (*Ping) ValidateSharedKeyHexdigest

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

type Step

type Step int

const (
	WatingForHelo Step = iota
	WaitingForPing
	WaitingForPong
	WaitingForEvents
)