storage

Jan 24, 2025

Changes in this version

+ const DefaultDBPingTimeout

+ const GitProviderBitbucket

+ const GitProviderGitHub

+ const GitProviderGitLab

+ type GitProvider string

+ func (g GitProvider) String() string

+ func (g GitProvider) Valid() bool

+ type MessageStorer interface

+ MessageStore func(ctx context.Context, message *sarama.ConsumerMessage) error

+ type PGPooler interface

+ Close func()

+ Exec func(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error)

+ Ping func(ctx context.Context) error

+ type PingStorer interface

+ type Pinger interface

+ Ping func(ctx context.Context, maxRetries uint8, backoff time.Duration) error

Jan 12, 2025

Changes in this version

+ const DefaultDBPingBackoff

+ const DefaultDBPingMaxRetries

+ type GitHubStorer interface

+ GitHubStore func(payload *GitHubWebhookData) error

+ type GitHubWebhookData struct

+ DeliveryID uuid.UUID

+ Event github.Event

+ HookID uint64

+ Offset int64

+ Partition int32

+ Payload any

+ Target string

+ TargetID uint64

+ UserID int64

+ UserLogin string

+ type Manager struct

+ BackOff time.Duration

+ DSN string

+ Logger *slog.Logger

+ MaxRetries uint8

+ Pool *pgxpool.Pool

+ func New(options ...Option) (*Manager, error)

+ func (m Manager) GitHubStore(data *GitHubWebhookData) error

+ func (m Manager) Ping() error

+ type Option func(*Manager) error

+ func WithBackoff(d time.Duration) Option

+ func WithDSN(s string) Option

+ func WithLogger(l *slog.Logger) Option

+ func WithMaxRetries(i int) Option

+ type Storer interface

+ Ping func() error