eventsdb

Documentation

Index

• Variables
• type Event
• type EventsDB
  • func New(path string) (*EventsDB, error)
  • func (db *EventsDB) Add(event *Event) error
  • func (db *EventsDB) AddAt(event *Event, t time.Time) error
  • func (db *EventsDB) Close() error
  • func (db *EventsDB) List(cursor string, limit int) ([]*Event, string, error)

Variables

var (
	EventAppStart    = "app_start"
	EventAppShutdown = "app_shutdown"
)

Types

type Event

type Event struct {
	Type    string `msgpack:"t"`
	Message string `msgpack:"m"`
	ID      *id.ID `msgpack:"-"`
}

type EventsDB

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

func New

func New(path string) (*EventsDB, error)

func (*EventsDB) Add

func (db *EventsDB) Add(event *Event) error

func (*EventsDB) AddAt

func (db *EventsDB) AddAt(event *Event, t time.Time) error

func (*EventsDB) Close

func (db *EventsDB) Close() error

func (*EventsDB) List

func (db *EventsDB) List(cursor string, limit int) ([]*Event, string, error)