api

Documentation

Index

• type Filter
• type Input
• type JsonEngine
  • func NewJsonEngine(output Output, filters ...Filter) *JsonEngine
  • func (j *JsonEngine) Write(ctx context.Context, ts time.Time, line string) error
• type Output
• type Writer

Types

type Filter

type Filter interface {
	Filter(ctx context.Context, ts time.Time, data *fastjson.Value, meta map[string]interface{}) error
	Start(context.Context) error
}

type Input

type Input interface {
	To(Writer)
	Start(context.Context) error
}

type JsonEngine

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

func NewJsonEngine

func NewJsonEngine(output Output, filters ...Filter) *JsonEngine

func (*JsonEngine) Write

func (j *JsonEngine) Write(ctx context.Context, ts time.Time, line string) error

type Output

type Output interface {
	Write(ctx context.Context, ts time.Time, line string, meta map[string]interface{}) error
	Close() error
}

type Writer

type Writer interface {
	Write(ctx context.Context, ts time.Time, line string) error
}