store

Documentation

Index

• type Event
• type EventStore
• type PendingEvent

Types

type Event

type Event struct {
	SessionID string
	Seq       int64
	Type      string
	Time      time.Time
	Payload   json.RawMessage
}

type EventStore

type EventStore interface {
	Append(ctx context.Context, sessionID string, evs []PendingEvent) (firstSeq int64, err error)
	Replay(ctx context.Context, sessionID string, afterSeq int64, fn func(Event) error) error
	LatestSeq(ctx context.Context, sessionID string) (int64, error)
}

type PendingEvent

type PendingEvent struct {
	Type    string
	Time    time.Time
	Payload json.RawMessage
}