panopticon

README

panopticon

WIP

A data store and filter engine using badger and voyeur

Documentation

Index

• func BuildFilter(s *Store, f func(context.Context, *Store, voyeur.Emitter, voyeur.Event)) voyeur.Filter
• func Fwd(ctx context.Context, s *Store, em voyeur.Emitter, e voyeur.Event)
• type DB
  • func NewDB(bdg *badger.DB, spec FilterSpec) (*DB, error)
  • func (db *DB) Put(ctx context.Context, key, value []byte) error
• type FilterSpec
  • func (s FilterSpec) Sorted() []string
• type NewMessageEvent
  • func (e NewMessageEvent) EventType() string
• type PutEvent
  • func (e PutEvent) EventType() string
• type Store
  • func NewStore(db *badger.DB, f voyeur.Filter) *Store
  • func (s *Store) Get(path binpath.Path) (data []byte, err error)
  • func (s *Store) GetStore(path binpath.Path) *Store
  • func (s *Store) MkSubStore(rel string, ...) (*Store, error)
  • func (s *Store) Put(path binpath.Path, data []byte) error

Functions

func BuildFilter

func BuildFilter(s *Store, f func(context.Context, *Store, voyeur.Emitter, voyeur.Event)) voyeur.Filter

func Fwd

func Fwd(ctx context.Context, s *Store, em voyeur.Emitter, e voyeur.Event)

Types

type DB

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

func NewDB

func NewDB(bdg *badger.DB, spec FilterSpec) (*DB, error)

func (*DB) Put

func (db *DB) Put(ctx context.Context, key, value []byte) error

type FilterSpec

type FilterSpec map[string]func(context.Context, *Store, voyeur.Emitter, voyeur.Event)

func (FilterSpec) Sorted

func (s FilterSpec) Sorted() []string

type NewMessageEvent

type NewMessageEvent struct {
	Key   []byte
	Path  binpath.Path
	Seq   uint64
	Value []byte
}

func (NewMessageEvent) EventType

func (e NewMessageEvent) EventType() string

type PutEvent

type PutEvent struct {
	Path  binpath.Path
	Value []byte
}

func (PutEvent) EventType

func (e PutEvent) EventType() string

type Store

type Store struct {
	voyeur.Filter
	// contains filtered or unexported fields
}

func NewStore

func NewStore(db *badger.DB, f voyeur.Filter) *Store

func (*Store) Get

func (s *Store) Get(path binpath.Path) (data []byte, err error)

func (*Store) GetStore

func (s *Store) GetStore(path binpath.Path) *Store

func (*Store) MkSubStore

func (s *Store) MkSubStore(rel string, filterFunc func(context.Context, *Store, voyeur.Emitter, voyeur.Event)) (*Store, error)

func (*Store) Put

func (s *Store) Put(path binpath.Path, data []byte) error