structstream

Documentation

Index

• type Buffer
  • func New(cap int, tr Transformer) (*Buffer, error)
  • func (b *Buffer) Append(meta, line string)
  • func (b *Buffer) Clear()
  • func (b *Buffer) GetAt(loc int) Structline
  • func (b *Buffer) GetRange(st, fi int) []Structline
  • func (b *Buffer) Len() int
• type Structline
  • func GlogTransformer(meta, in string) (Structline, bool)
  • func JSONTransformer(meta, in string) (Structline, bool)
  • func PassthruTransformer(meta, in string) (Structline, bool)
• type Transformer
  • func CombineTransformers(strict bool, ts ...Transformer) Transformer

Types

type Buffer

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

func New

func New(cap int, tr Transformer) (*Buffer, error)

func (*Buffer) Append

func (b *Buffer) Append(meta, line string)

func (*Buffer) Clear

func (b *Buffer) Clear()

func (*Buffer) GetAt

func (b *Buffer) GetAt(loc int) Structline

func (*Buffer) GetRange

func (b *Buffer) GetRange(st, fi int) []Structline

func (*Buffer) Len

func (b *Buffer) Len() int

type Structline

type Structline struct {
	Complete bool
	Type     string

	Message   string
	Meta      string
	Priority  string
	Timestamp time.Time

	KV map[string]interface{}
}

func GlogTransformer

func GlogTransformer(meta, in string) (Structline, bool)

func JSONTransformer

func JSONTransformer(meta, in string) (Structline, bool)

func PassthruTransformer

func PassthruTransformer(meta, in string) (Structline, bool)

type Transformer

type Transformer func(string, string) (Structline, bool)

func CombineTransformers

func CombineTransformers(strict bool, ts ...Transformer) Transformer