badgerbadger

Documentation

Index

• func GetBackend(c cx, wg *sync.WaitGroup, L1, L2 *ratel.T) (es store.I)
• type Backend
  • func (b *Backend) Close() (err er)
  • func (b *Backend) CountEvents(c cx, f *filter.T) (count no, approx bo, err er)
  • func (b *Backend) DeleteEvent(c cx, eid *eventid.T) (err er)
  • func (b *Backend) Init(path st) (err er)
  • func (b *Backend) QueryEvents(c cx, f *filter.T) (ch event.Ts, err er)
  • func (b *Backend) SaveEvent(c cx, ev *event.T) (err er)

Functions

func GetBackend

func GetBackend(c cx, wg *sync.WaitGroup, L1, L2 *ratel.T) (es store.I)

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

Types

type Backend

type Backend struct {
	*layer2.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() (err er)

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

func (*Backend) CountEvents

func (b *Backend) CountEvents(c cx, f *filter.T) (count no, approx bo, err er)

CountEvents returns the number of events found matching the filter.

func (*Backend) DeleteEvent

func (b *Backend) DeleteEvent(c cx, eid *eventid.T) (err er)

DeleteEvent removes an event from the event store.

func (*Backend) Init

func (b *Backend) Init(path st) (err er)

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 cx, f *filter.T) (ch event.Ts, err er)

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

func (*Backend) SaveEvent

func (b *Backend) SaveEvent(c cx, ev *event.T) (err er)

SaveEvent writes an event to the event store.