badgerbadger

Documentation

Index

• func GetBackend(c context.T, wg *sync.WaitGroup, L1 *badger.Backend, L2 *badger.Backend) (es eventstore.Store)
• type Backend
  • func (b *Backend) Close()
  • func (b *Backend) CountEvents(c context.T, f *filter.T) (count int, err error)
  • func (b *Backend) DeleteEvent(c context.T, ev *event.T) (err error)
  • func (b *Backend) Init() (err error)
  • func (b *Backend) QueryEvents(c context.T, f *filter.T) (ch event.C, err error)
  • func (b *Backend) SaveEvent(c context.T, ev *event.T) (err error)

Functions

func GetBackend

func GetBackend(
	c context.T,
	wg *sync.WaitGroup,
	L1 *badger.Backend,
	L2 *badger.Backend,
) (es eventstore.Store)

GetBackend returns a l2.Backend that combines two differently configured backends... the settings need to be configured in the badger.Backend data structure before calling this.

Types

type Backend

type Backend struct {
	*l2.Backend
}

Backend is a hybrid badger/badger eventstore where L1 will have GC enabled and L2 will not. This is mainly for testing, as both are local.

func (*Backend) Close

func (b *Backend) Close()

Close the connection to the database. IC is a request/response API authing at each request.

func (*Backend) CountEvents

func (b *Backend) CountEvents(c context.T, f *filter.T) (count int, err error)

CountEvents returns the number of events found matching the filter.

func (*Backend) DeleteEvent

func (b *Backend) DeleteEvent(c context.T, ev *event.T) (err error)

DeleteEvent removes an event from the event store.

func (*Backend) Init

func (b *Backend) Init() (err error)

Init sets up the badger event store and connects to the configured IC canister.

required params are address, canister ID and the badger event store size limit (which can be 0)

func (*Backend) QueryEvents

func (b *Backend) QueryEvents(c context.T, f *filter.T) (ch event.C, err error)

QueryEvents searches for events that match a filter and returns them asynchronously over a provided channel.

func (*Backend) SaveEvent

func (b *Backend) SaveEvent(c context.T, ev *event.T) (err error)

SaveEvent writes an event to the event store.