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
- type PasswordForKey
- type Ping
- type Step
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DecodeEntry ¶ added in v0.5.0
func DecodeOption ¶ added in v0.5.0
func DecodeTime ¶ added in v0.5.0
Types ¶
type FluentSession ¶
type FluentSession struct { Wire *wire.Wire PasswordForKey PasswordForKey // contains filtered or unexported fields }
func NewSession ¶ added in v0.5.0
func NewSession(opts *options.FluentOptions, conn io.ReadWriteCloser) *FluentSession
func (*FluentSession) DoHelo ¶ added in v0.5.0
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 ¶ added in v0.5.0
func (*FluentSession) Loop ¶
func (s *FluentSession) Loop() error
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.