nettraceStorage

Documentation

Index

• type BoltBatchSink
  • func NewBoltBatchSink(dbPath string) (*BoltBatchSink, error)
  • func (s *BoltBatchSink) Close() error
  • func (s *BoltBatchSink) DeleteDBFile() error
  • func (s *BoltBatchSink) ExportToJSON(filePath string, meta nt.NetTrace) error
  • func (s *BoltBatchSink) HandleBatch(b nt.BatchSnapshot)
  • func (s *BoltBatchSink) Handler() nt.BatchCallback

Types

type BoltBatchSink

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

BoltBatchSink offloads batches of netTrace data into BoltDB and supports exporting them into a single JSON file.

func NewBoltBatchSink

func NewBoltBatchSink(dbPath string) (*BoltBatchSink, error)

NewBoltBatchSink opens/creates the BoltDB file and initializes buckets.

func (*BoltBatchSink) Close

func (s *BoltBatchSink) Close() error

Close closes the BoltDB.

func (*BoltBatchSink) DeleteDBFile

func (s *BoltBatchSink) DeleteDBFile() error

DeleteDBFile deletes the BoltDB file, based on session UUID

func (*BoltBatchSink) ExportToJSON

func (s *BoltBatchSink) ExportToJSON(filePath string, meta nt.NetTrace) error

ExportToJSON writes one JSON file with everything persisted in Bbolt. Pass the meta you receive from server.GetTrace (which now returns only NetTraceMeta + pcaps).

func (*BoltBatchSink) HandleBatch

func (s *BoltBatchSink) HandleBatch(b nt.BatchSnapshot)

HandleBatch persists a batch (upsert by TraceID). Safe to call concurrently.

func (*BoltBatchSink) Handler

func (s *BoltBatchSink) Handler() nt.BatchCallback

Handler returns a nettrace.BatchCallback to pass into WithBatchOffload.