internal

package

v0.1.2 Latest Latest Go to latest Published: Jan 14, 2021 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type EventSink interface {
	FlushEvents(ctx context.Context, cache [][]byte) error
}

EventSink a sink for events

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

LineData caches the unmarshalled json so we only need to unmarshal once

func NewLineData(data []byte) *LineData

NewLineData returns a new LineData

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

LineParseHelper helper for parsing line data

func NewLineParseHelper(optDefs map[string]string) *LineParseHelper

NewLineParseHelper returns a LineParseHelper

func (c *LineParseHelper) GetVal(valName string, data *LineData) (string, error)

GetVal returns a val

type Publisher struct {
	MaxQueueSize  int
	Sink          EventSink
	FlushInterval time.Duration
	// contains filtered or unexported fields
}

Publisher publishes events

func (p *Publisher) Run(ctx context.Context, scanner *bufio.Scanner) error

Run runs Publisher

Path	Synopsis
testutil