badger_store

Documentation

Index

• Variables
• type BadgerStore
  • func New(o *Options) (*BadgerStore, error)
  • func (b *BadgerStore) Close()
  • func (n *BadgerStore) DataKeys(ctx context.Context) (ret []string, err error)
  • func (n *BadgerStore) FindPacketsByAddress(ctx context.Context, ip net.IP) (ret []string, err error)
  • func (n *BadgerStore) GetPackets(ctx context.Context, ids []string, q *store.FindQuery) (pkts []*models.Packet, err error)
  • func (b *BadgerStore) GetStats() (*store.Stats, error)
  • func (n *BadgerStore) IndexKeys(ctx context.Context) (ret []string, err error)
  • func (n *BadgerStore) IndexPackets(ctx context.Context, pkts []*models.Packet) (err error)
  • func (n *BadgerStore) StorePackets(ctx context.Context, pkts []*models.Packet) (err error)
• type Options

Variables

var (
	DefaultOptions = Options{
		CachedIndexKeysInterval: 15 * time.Minute,
	}
)

Types

type BadgerStore

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

func New

func New(o *Options) (*BadgerStore, error)

func (*BadgerStore) Close

func (b *BadgerStore) Close()

func (*BadgerStore) DataKeys

func (n *BadgerStore) DataKeys(ctx context.Context) (ret []string, err error)

func (*BadgerStore) FindPacketsByAddress

func (n *BadgerStore) FindPacketsByAddress(ctx context.Context, ip net.IP) (ret []string, err error)

func (*BadgerStore) GetPackets

func (n *BadgerStore) GetPackets(ctx context.Context, ids []string, q *store.FindQuery) (pkts []*models.Packet, err error)

func (*BadgerStore) GetStats

func (b *BadgerStore) GetStats() (*store.Stats, error)

func (*BadgerStore) IndexKeys

func (n *BadgerStore) IndexKeys(ctx context.Context) (ret []string, err error)

func (*BadgerStore) IndexPackets

func (n *BadgerStore) IndexPackets(ctx context.Context, pkts []*models.Packet) (err error)

func (*BadgerStore) StorePackets

func (n *BadgerStore) StorePackets(ctx context.Context, pkts []*models.Packet) (err error)

TODO: https://dgraph.io/docs/badger/faq/#my-writes-are-really-slow-why

type Options

type Options struct {
	Path                    string
	Encoder                 index_encoder.Interface
	CachedIndexKeysInterval time.Duration
	TTL                     time.Duration
}