capture

Documentation

Index

• func Run(ctx context.Context, cfg Config, w io.Writer) error
• type Config
  • func DefaultConfig() Config
• type Emitter
  • func NewEmitter(w io.Writer) *Emitter
  • func (e *Emitter) Emit(r model.Record) error

Functions

func Run

func Run(ctx context.Context, cfg Config, w io.Writer) error

Run opens a live packet capture on the configured interface and emits parsed HTTP/gRPC records as NDJSON to w. It blocks until ctx is cancelled.

Types

type Config

type Config struct {
	Interface string
	BPFFilter string
	SnapLen   int32
}

Config holds the settings for a capture session.

func DefaultConfig

func DefaultConfig() Config

DefaultConfig returns a Config with sensible defaults.

type Emitter

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

Emitter writes Records as NDJSON to an io.Writer. It is safe for concurrent use.

func NewEmitter

func NewEmitter(w io.Writer) *Emitter

NewEmitter creates an Emitter that writes to w.

func (*Emitter) Emit

func (e *Emitter) Emit(r model.Record) error

Emit serializes r as a single JSON line.