message

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

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

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
}

type Flusher interface {
	Flush() error
}

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

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

type PasswordForKey func(string) string

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

type Step int