Versions in this module Expand all Collapse all v1 v1.0.1 May 12, 2021 v1.0.0 May 11, 2021 Changes in this version + var DefaultFormat = TextFormat + var DefaultSize = 256 + 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() (Steam, error) + Write func(Record) error + type Option func(*Options) + func Format(format FormatFunc) Option + func Name(name string) Option + func Size(size int) Option + type Options struct + Format FormatFunc + Name string + Size int + func DefaultOptions() Options + type ReadOption func(*ReadOptions) + func Count(count int) ReadOption + func Since(since time.Time) ReadOption + func Stream(stream bool) ReadOption + type ReadOptions struct + Count int + Since time.Time + Stream bool + type Record struct + Message interface{} + Metadata map[string]string + Timestamp time.Time + type Steam interface + Chan func() <-chan Record + Stop func() error
Go to main page