eventstore

Documentation

Index

• type EventStore
  • func Open(fileName string) (*EventStore, error)
  • func (s *EventStore) All() ([]EventTimes, error)
  • func (s *EventStore) Close()
  • func (s *EventStore) Discard(ev EventTimes) error
  • func (s *EventStore) Queue(details []byte, timestamp time.Time) error
• type EventTimes

Types

type EventStore

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

EventStore perists details for events which are to be sent to the Cacophony Events API.

func Open

func Open(fileName string) (*EventStore, error)

Open opens the event store. It should be closed later with the Close() method.

func (*EventStore) All

func (s *EventStore) All() ([]EventTimes, error)

All returns all the events stored in the event store as EventTimes instances. Events with identical details are grouped together into a single EventTimes instance.

func (*EventStore) Close

func (s *EventStore) Close()

Close releases resources used by the EventStore. It should be called once the EventStore is no longer required.

func (*EventStore) Discard

func (s *EventStore) Discard(ev EventTimes) error

Discard removes an event from from the store.

func (*EventStore) Queue

func (s *EventStore) Queue(details []byte, timestamp time.Time) error

Queue recordings an event in the event store. The details provided uniquely identify the event, but the contents are opaque to the event store.

type EventTimes

type EventTimes struct {
	Details    []byte
	Timestamps []time.Time
}

EventTimes holds