IC

Documentation

Index

• 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, evt *event.T) (err error)
  • func (b *Backend) Init(inf *relayinfo.T, params ...string) (err error)
  • func (b *Backend) QueryEvents(c context.T, C chan *event.T, f *filter.T) (err error)
  • func (b *Backend) SaveEvent(c context.T, ev *event.T) (err error)
  • func (b *Backend) Serial() []byte

Types

type Backend

type Backend struct {
	// Badger backend must be populated
	Badger *badger.Backend
	IC     *agent.Backend
}

func (*Backend) Close

func (b *Backend) Close()

Close the connection to the database.

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, evt *event.T) (err error)

DeleteEvent removes an event from the event store.

func (*Backend) Init

func (b *Backend) Init(inf *relayinfo.T, params ...string) (err error)

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

func (*Backend) QueryEvents

func (b *Backend) QueryEvents(c context.T, C chan *event.T,
	f *filter.T) (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.

func (*Backend) Serial

func (b *Backend) Serial() []byte

Serial returns the serial code for the database.