ebl

type Direction ¶

type Direction uint8

const (
	DirectionUnknown Direction = iota
	DirectionReceived
	DirectionTransmitted
)

type Event ¶

type Event struct {
	Timestamp    time.Time
	HasTimestamp bool
	Direction    Direction
	RawBST       bool
	Payload      []byte
}

Event is an owned raw-stream chunk or one unframed BST record.

type Reader ¶

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

Reader incrementally parses one EBL file. Retained tag and raw-stream state is bounded by MaxTagPayload and maxRawChunk.

func NewReader() *Reader

func (r *Reader) Read(input io.Reader, emit func(Event), report func(Warning)) error

type Warning ¶

type Warning struct {
	Offset int64
	Err    error
}

func (w Warning) Error() string

func (w Warning) Unwrap() error

type Writer ¶ added in v1.2.0

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

Writer serializes Enhanced Binary Log records. Each public write is one atomic event group so timestamps and direction markers cannot interleave.

func NewWriter(output io.Writer, config WriterConfig) (*Writer, error)

func (w *Writer) Err() error

func (w *Writer) Metrics() WriterMetrics

func (w *Writer) WriteDescription(description string) error

func (w *Writer) WriteRawBST(timestamp time.Time, direction Direction, raw []byte) error

func (w *Writer) WriteRawBytes(timestamp time.Time, direction Direction, data []byte) error

type WriterConfig ¶ added in v1.2.0

type WriterConfig struct {
	StartTime   time.Time
	Description string
}

type WriterMetrics ¶ added in v1.2.0

type WriterMetrics struct {
	Records uint64
	Bytes   uint64
	Errors  uint64
}