boltdb

Oct 7, 2024

Changes in this version

+ type EventStore struct

+ func NewEventStore(db *bbolt.DB, opts ...EventStoreOption) (*EventStore, error)

+ func (s *EventStore) Close(ctx context.Context) error

+ func (s *EventStore) GetCheckpoint(ctx context.Context, watcherID string) (uint64, error)

+ func (s *EventStore) GetEvents(ctx context.Context, params watcher.GetEventsRequest) (*watcher.GetEventsResponse, error)

+ func (s *EventStore) GetLatestEventNum(ctx context.Context) (uint64, error)

+ func (s *EventStore) StoreCheckpoint(ctx context.Context, watcherID string, eventSeqNum uint64) error

+ func (s *EventStore) StoreEvent(ctx context.Context, operation watcher.Operation, objectType string, ...) error

+ func (s *EventStore) StoreEventTx(tx *bbolt.Tx, operation watcher.Operation, objectType string, ...) error

+ type EventStoreOption func(*eventStoreOptions)

+ func WithCacheSize(size int) EventStoreOption

+ func WithCheckpointBucket(name string) EventStoreOption

+ func WithClock(clock clock.Clock) EventStoreOption

+ func WithEventSerializer(serializer watcher.Serializer) EventStoreOption

+ func WithEventsBucket(name string) EventStoreOption

+ func WithGCAgeThreshold(threshold time.Duration) EventStoreOption

+ func WithGCCadence(cadence time.Duration) EventStoreOption

+ func WithGCMaxDuration(duration time.Duration) EventStoreOption

+ func WithGCMaxRecordsPerRun(max int) EventStoreOption

+ func WithLongPollingTimeout(timeout time.Duration) EventStoreOption