streamlog

Documentation

Index

• type Event
  • func NewEvent(b []byte) (Event, error)
  • func (event Event) IsZero() bool
  • func (event Event) Map() map[string]any
  • func (event Event) Render(format string)
  • func (event Event) RenderConsole()
  • func (event Event) RenderData()
• type Events
  • func (events Events) MatchString(key, pattern string) bool
  • func (events Events) Render(format string)
  • func (events Events) RenderConsole()
  • func (events Events) RenderData()
  • func (events Events) Sort()
• type Stream
  • func NewStream() *Stream
  • func (stream Stream) Errors() chan error
  • func (stream Stream) Events() chan Event
  • func (stream *Stream) Start(streamConfig StreamConfig) error
  • func (stream *Stream) Stop() error
• type StreamConfig

Types

type Event

type Event struct {
	B []byte
	M map[string]any
}

func NewEvent

func NewEvent(b []byte) (Event, error)

func (Event) IsZero

func (event Event) IsZero() bool

func (Event) Map

func (event Event) Map() map[string]any

func (Event) Render

func (event Event) Render(format string)

func (Event) RenderConsole

func (event Event) RenderConsole()

func (Event) RenderData

func (event Event) RenderData()

type Events

type Events []Event

func (Events) MatchString

func (events Events) MatchString(key, pattern string) bool

func (Events) Render

func (events Events) Render(format string)

func (Events) RenderConsole

func (events Events) RenderConsole()

func (Events) RenderData

func (events Events) RenderData()

func (Events) Sort

func (events Events) Sort()

type Stream

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

func NewStream

func NewStream() *Stream

func (Stream) Errors

func (stream Stream) Errors() chan error

func (Stream) Events

func (stream Stream) Events() chan Event

func (*Stream) Start

func (stream *Stream) Start(streamConfig StreamConfig) error

func (*Stream) Stop

func (stream *Stream) Stop() error

type StreamConfig

type StreamConfig struct {
	Follow  bool
	Lines   int
	Matches []string
}