message

Documentation

Index

• func Ack(wire *wire.Wire, chunk string) error
• func DecodeEntry(decoder *msgpack.Decoder) (*time.Time, map[string]interface{}, error)
• func DecodeOption(decoder *msgpack.Decoder) (*msg.Option, error)
• func DecodeTime(decoder *msgpack.Decoder) (*time.Time, error)
• type Event
• type FluentSession
  • func NewSession(opts *options.FluentOptions, conn io.ReadWriteCloser) *FluentSession
  • func (s *FluentSession) DoHelo() error
  • func (s *FluentSession) HandleEvents(l int, _type string) error
  • func (s *FluentSession) HandleHearthBeat() error
  • func (s *FluentSession) HandlePing(wire *wire.Wire, l int, _type string) error
  • func (s *FluentSession) Loop() error
• 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

Functions

func Ack

func Ack(wire *wire.Wire, chunk string) error

func DecodeEntry

func DecodeEntry(decoder *msgpack.Decoder) (*time.Time, map[string]interface{}, error)

func DecodeOption

func DecodeOption(decoder *msgpack.Decoder) (*msg.Option, error)

func DecodeTime

func DecodeTime(decoder *msgpack.Decoder) (*time.Time, error)

Types

type Event

type Event struct {
	Tag    string
	Ts     *time.Time
	Record map[string]interface{}
}

type FluentSession

type FluentSession struct {
	Wire *wire.Wire

	PasswordForKey PasswordForKey
	// contains filtered or unexported fields
}

func NewSession

func NewSession(opts *options.FluentOptions, conn io.ReadWriteCloser) *FluentSession

func (*FluentSession) DoHelo

func (s *FluentSession) DoHelo() error

func (*FluentSession) HandleEvents

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

func (*FluentSession) HandleHearthBeat

func (s *FluentSession) HandleHearthBeat() error

func (*FluentSession) HandlePing

func (s *FluentSession) HandlePing(wire *wire.Wire, l int, _type string) error

func (*FluentSession) Loop

func (s *FluentSession) Loop() error

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
)