gitlabstorage

Documentation

Index

• Constants
• type GitLab
• type GitLabStorage
  • func New(ctx context.Context, options ...Option) (*GitLabStorage, error)
  • func (s GitLabStorage) MessageStore(ctx context.Context, message *sarama.ConsumerMessage) error
  • func (s GitLabStorage) Ping(ctx context.Context, maxRetries uint8, backoff time.Duration) error
• type Option
  • func WithDatabaseDSN(dsn string) Option
  • func WithLogger(l *slog.Logger) Option

Constants

const (
	GitLabStoreQuery = `` /* 222-byte string literal not displayed */

)

queries.

Types

type GitLab

type GitLab struct {
	Payload        any
	ObjectKind     string
	ProjectPath    *string
	UserUsername   *string
	EventUUID      uuid.UUID
	WebhookUUID    uuid.UUID
	ProjectID      *int64
	UserID         *int64
	KafkaOffset    int64
	KafkaPartition int32
}

GitLab represents `gitlab` table model fields.

type GitLabStorage

type GitLabStorage struct {
	Logger      *slog.Logger
	Pool        storage.PGPooler
	DatabaseDSN string
}

GitLabStorage implements GitLabPingStorer interface.

func New

func New(ctx context.Context, options ...Option) (*GitLabStorage, error)

New instantiates new gitlab storage.

func (GitLabStorage) MessageStore

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

MessageStore stores received kafka message to database.

func (GitLabStorage) Ping

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

Ping pings database and makes sure db communication is ok.

type Option

type Option func(*GitLabStorage) error

Option represents option function type.

func WithDatabaseDSN

func WithDatabaseDSN(dsn string) Option

WithDatabaseDSN sets database data source.

func WithLogger

func WithLogger(l *slog.Logger) Option

WithLogger sets logger.