log

Documentation

Index

• Variables
• func JsonFormat(r Record) string
• func TextFormat(r Record) string
• type FormatFunc
• type Log
• type Option
  • func Format(format FormatFunc) Option
  • func Name(name string) Option
  • func Size(size int) Option
• type Options
  • func DefaultOptions() Options
• type ReadOption
  • func Count(count int) ReadOption
  • func Since(since time.Time) ReadOption
  • func Stream(stream bool) ReadOption
• type ReadOptions
• type Record
• type Steam

Variables

var (
	DefaultSize   = 256
	DefaultFormat = TextFormat
)

Functions

func JsonFormat

func JsonFormat(r Record) string

func TextFormat

func TextFormat(r Record) string

Types

type FormatFunc

type FormatFunc func(Record) string

type Log

type Log interface {
	Read(...ReadOption) ([]Record, error)
	Write(Record) error
	Stream() (Steam, error)
}

type Option

type Option func(*Options)

func Format

func Format(format FormatFunc) Option

func Name

func Name(name string) Option

func Size

func Size(size int) Option

type Options

type Options struct {
	Name   string
	Size   int
	Format FormatFunc
}

func DefaultOptions

func DefaultOptions() Options

type ReadOption

type ReadOption func(*ReadOptions)

func Count

func Count(count int) ReadOption

func Since

func Since(since time.Time) ReadOption

func Stream

func Stream(stream bool) ReadOption

type ReadOptions

type ReadOptions struct {
	Since  time.Time
	Count  int
	Stream bool
}

type Record

type Record struct {
	Timestamp time.Time         `json:"timestamp"`
	Metadata  map[string]string `json:"metadata"`
	Message   interface{}       `json:"message"`
}

type Steam

type Steam interface {
	Chan() <-chan Record
	Stop() error
}