log

type EventStreamer interface {
	// Stream streams events.
	Stream(ready <-chan struct{}) (<-chan event.Event, func())
	// Close closes the streamer. No more events will be generated
	// one the streamer is closed.
	Close()
}

type InitOption func(config zap.Config) zap.Config

type ListenCancelFunc func()

type Message struct {
	// ID is the identifier for this log message.
	ID string
	// Date is the seconds since epoch.
	Date int64 `json:"date"`
	// LogLevel is the log level.
	LogLevel string `json:"logLevel"`
	// Location is the source location.
	Location string `json:"location"`
	// Text is the actual message.
	Text string `json:"text"`
	// JSON is the JSON payload.
	JSON string `json:"json"`
	// StackTrace is an optional stack trace.
	StackTrace string `json:"stackTrace"`
}

type MessageIDGenerator interface {
	Generate() string
}

type MessageListenerFactory interface {
	// Listen creates a listener.
	Listen() (<-chan Message, ListenCancelFunc)
}

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

type OctantSinkOption func(o *OctantSink)

type Option func(o *options)

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

type UUIDMessageIDGenerator struct{}