Versions in this module Expand all Collapse all v0 v0.1.0 Jun 28, 2026 Changes in this version + type Store struct + func Open(ctx context.Context, dsn string) (*Store, error) + func (s *Store) ClaimDue(ctx context.Context, now time.Time, lease time.Duration, limit int) ([]core.PendingDelivery, error) + func (s *Store) Close() error + func (s *Store) CreateDestination(ctx context.Context, d core.Destination) error + func (s *Store) CreateSource(ctx context.Context, src core.Source, secret []byte) error + func (s *Store) DeliveriesForEvent(ctx context.Context, eventID string) ([]core.PendingDelivery, error) + func (s *Store) Enqueue(ctx context.Context, p core.PendingDelivery) error + func (s *Store) GetDestination(ctx context.Context, id string) (core.Destination, error) + func (s *Store) GetEvent(ctx context.Context, id string) (core.Event, error) + func (s *Store) GetSource(ctx context.Context, name string) (core.Source, error) + func (s *Store) ListAttempts(ctx context.Context, eventID string) ([]core.DeliveryAttempt, error) + func (s *Store) ListDeadLetters(ctx context.Context, limit, offset int) ([]core.PendingDelivery, error) + func (s *Store) ListDestinations(ctx context.Context, source string) ([]core.Destination, error) + func (s *Store) ListEvents(ctx context.Context, f storage.EventFilter) ([]core.Event, error) + func (s *Store) ListSources(ctx context.Context) ([]core.Source, error) + func (s *Store) MarkDeadLetter(ctx context.Context, id string) error + func (s *Store) MarkDelivered(ctx context.Context, id string) error + func (s *Store) Prune(ctx context.Context, normalCutoff, failedCutoff time.Time) (int, error) + func (s *Store) RecordAttempt(ctx context.Context, a core.DeliveryAttempt) error + func (s *Store) Reschedule(ctx context.Context, id string, attempt int, next time.Time) error + func (s *Store) SaveEvent(ctx context.Context, e core.Event) (string, bool, error) + func (s *Store) SourceSecret(ctx context.Context, name string) ([]byte, error) + func (s *Store) UpdateDestination(ctx context.Context, d core.Destination) error + func (s *Store) UpdateSource(ctx context.Context, src core.Source, secret []byte) error
Go to main page