netflowdb

Documentation

Index

• Variables
• type Interface
  • func Open(db *badger.DB) Interface

Variables

var InputQueue = make(chan []*netdb.NetFlowEntry, 128)

var RequestQueue = make(chan *netdb.TrafficMetricsRequest, 128)

Types

type Interface

type Interface interface {
	Query(r *netdb.TrafficMetricsRequest) (*netdb.TrafficMetricsResponse, error)
	WriteBatch(nfel []*netdb.NetFlowEntry) error
	Scan() ([]*netdb.NetFlowEntry, error)
	Close()
}

func Open

func Open(db *badger.DB) Interface