eventstore

README

A simple helper module for retrieving and storing events from postgres

Documentation

Index

• type Event
• type EventStore
  • func NewEventStore(conn *pgx.Conn) *EventStore
  • func (es *EventStore) AppendToStream(stream string, version int, events []Event) error
  • func (es *EventStore) LoadFromAll(since int, limit int) ([]Event, error)
  • func (es *EventStore) LoadFromStream(stream string, since int, limit int) ([]Event, error)
  • func (es *EventStore) Register(event_type string, event interface{})

Types

type Event

type Event struct {
	Stream    string      `json:"stream"`
	Version   int         `json:"version"`
	EventType string      `json:"event_type"`
	Data      interface{} `json:"data"`
	Metadata  interface{} `json:"metadata"`
	Timestamp time.Time   `json:"timestamp"`
}

type EventStore

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

func NewEventStore

func NewEventStore(conn *pgx.Conn) *EventStore

func (*EventStore) AppendToStream

func (es *EventStore) AppendToStream(stream string, version int, events []Event) error

func (*EventStore) LoadFromAll

func (es *EventStore) LoadFromAll(since int, limit int) ([]Event, error)

func (*EventStore) LoadFromStream

func (es *EventStore) LoadFromStream(stream string, since int, limit int) ([]Event, error)

func (*EventStore) Register

func (es *EventStore) Register(event_type string, event interface{})