Documentation ¶
Index ¶
- type Event
- type 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{})
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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 (*EventStore) Register ¶ added in v0.3.0
func (es *EventStore) Register(event_type string, event interface{})
Click to show internal directories.
Click to hide internal directories.