leveldb

Documentation

Index

• type DB
  • func Open(path string, mask ippb.IPMask) (*DB, error)
  • func (db *DB) AddAggregate(aggr *ippb.Aggregate) error
  • func (db *DB) Close()
  • func (db *DB) Compact() error
  • func (db *DB) ScanAll(startTime time.Time, f func(string, map[string]int64) error) error
  • func (db *DB) ScanIP(startTime time.Time, ip string) (map[string]int64, error)
  • func (db *DB) ScanType(startTime time.Time, t string) (map[string]int64, error)
  • func (db *DB) WipeOldData(age time.Duration) (int64, error)

Types

type DB

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

func Open

func Open(path string, mask ippb.IPMask) (*DB, error)

func (*DB) AddAggregate

func (db *DB) AddAggregate(aggr *ippb.Aggregate) error

func (*DB) Close

func (db *DB) Close()

func (*DB) Compact

func (db *DB) Compact() error

func (*DB) ScanAll

func (db *DB) ScanAll(startTime time.Time, f func(string, map[string]int64) error) error

func (*DB) ScanIP

func (db *DB) ScanIP(startTime time.Time, ip string) (map[string]int64, error)

func (*DB) ScanType

func (db *DB) ScanType(startTime time.Time, t string) (map[string]int64, error)

func (*DB) WipeOldData

func (db *DB) WipeOldData(age time.Duration) (int64, error)