Versions in this module Expand all Collapse all v2 v2.1.2 Apr 12, 2023 Changes in this version + var DefaultFormat = TextFormat + var DefaultLog = NewLog() + var DefaultSize = 1024 + func JSONFormat(r Record) string + func TextFormat(r Record) string + type FormatFunc func(Record) string + type Log interface + Read func(...ReadOption) ([]Record, error) + Stream func() (Stream, error) + Write func(Record) error + func NewLog(opts ...Option) Log + type Option func(*Options) + func Format(f FormatFunc) Option + func Name(n string) Option + func Size(s int) Option + type Options struct + Format FormatFunc + Name string + Size int + func DefaultOptions() Options + type ReadOption func(*ReadOptions) + func Count(c int) ReadOption + func Since(s time.Time) ReadOption + type ReadOptions struct + Count int + Since time.Time + Stream bool + type Record struct + Message interface{} + Metadata map[string]string + Timestamp time.Time + type Stream interface + Chan func() <-chan Record + Stop func() error
Go to main page