postgres

Jun 2, 2026

Changes in this version

+ type Config struct

+ BatchSize int

+ DSN string

+ FlushInterval time.Duration

+ RetentionDays int

+ Table string

+ type Sink struct

+ func New(ctx context.Context, cfg Config) (*Sink, error)

+ func (s *Sink) Close() error

+ func (s *Sink) Dropped() uint64

+ func (s *Sink) Events(ctx context.Context, q usage.EventQuery) ([]usage.Event, error)

+ func (s *Sink) Summary(ctx context.Context, q usage.SummaryQuery) (usage.SummaryResult, error)

+ func (s *Sink) TimeSeries(ctx context.Context, q usage.TimeSeriesQuery) (usage.TimeSeriesResult, error)

+ func (s *Sink) Write(ev usage.Event) error