Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SimpleFileFormatter ¶
SimpleFileFormatter outputs tag (or container name in case of Swarm deployment) and log message, separated by TABs.
Types ¶
type Appender ¶
type Appender interface {
Run(ctx context.Context)
Name() string
// FlushedOffset is a position in WAL, data before which is actually *written*
// into appender's target. May fall behind current WAL *read* offset.
FlushedOffset() wal.Offset
Close() error
}
Appender reads log entries from WAL and forwards to a specified destination.
type FileAppender ¶
type FileAppender struct {
// contains filtered or unexported fields
}
func NewFileAppender ¶
func NewFileAppender(reader *wal.Reader, path string) (appender *FileAppender, err error)
func (*FileAppender) Close ¶
func (appender *FileAppender) Close() (err error)
func (FileAppender) FlushedOffset ¶
func (*FileAppender) Run ¶
func (appender *FileAppender) Run(ctx context.Context)
type FileFormatter ¶
FileFormatter appends single message into writable file.
type ForwardAppender ¶
type ForwardAppender struct {
// contains filtered or unexported fields
}
func NewForwardAppender ¶
func NewForwardAppender(reader *wal.Reader, target string) (appender *ForwardAppender, err error)
func (*ForwardAppender) Close ¶
func (appender *ForwardAppender) Close() (err error)
func (ForwardAppender) FlushedOffset ¶
func (*ForwardAppender) Run ¶
func (appender *ForwardAppender) Run(ctx context.Context)
Source Files
Click to show internal directories.
Click to hide internal directories.