eventstore

type Bucket interface {
	Name() string
	Insert(ctx context.Context, ev components.Event) error
	// Find returns nil if the event is not found.
	Find(ctx context.Context, ev components.Event) (*components.Event, error)
	// Get queries the event in the descending order of timestamp (latest event first).
	Get(ctx context.Context, since time.Time) ([]components.Event, error)
	// Latest queries the latest event, returns nil if no event found.
	Latest(ctx context.Context) (*components.Event, error)
	Purge(ctx context.Context, beforeTimestamp int64) (int, error)
	Close()
}

type Store interface {
	Bucket(name string) (Bucket, error)
}