postgres

package

v0.0.0-...-8ed5974 Latest Latest Go to latest Published: Feb 23, 2026 License: MIT Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

func Connect(ctx context.Context, databaseURL string) (*pgxpool.Pool, error)

func RunMigrationsWithLock(ctx context.Context, pool *pgxpool.Pool) error

type ConfigRepo struct {
	// contains filtered or unexported fields
}

func NewConfigRepo(pool *pgxpool.Pool) *ConfigRepo

func (r *ConfigRepo) GetByBroadcasterID(ctx context.Context, broadcasterID string) (*domain.OverlayConfigWithVersion, error)

func (r *ConfigRepo) GetByStreamerID(ctx context.Context, streamerID uuid.UUID) (*domain.OverlayConfigWithVersion, error)

func (r *ConfigRepo) Update(ctx context.Context, streamerID uuid.UUID, config domain.OverlayConfig, version int) error

type EventSubRepo struct {
	// contains filtered or unexported fields
}

func NewEventSubRepo(pool *pgxpool.Pool) *EventSubRepo

func (r *EventSubRepo) Create(ctx context.Context, streamerID uuid.UUID, subscriptionID, conduitID string) error

func (r *EventSubRepo) Delete(ctx context.Context, streamerID uuid.UUID) error

func (r *EventSubRepo) DeleteByConduitID(ctx context.Context, conduitID string) error

func (r *EventSubRepo) GetByStreamerID(ctx context.Context, streamerID uuid.UUID) (*domain.EventSubSubscription, error)

func (r *EventSubRepo) List(ctx context.Context) ([]domain.EventSubSubscription, error)

type StreamerRepo struct {
	// contains filtered or unexported fields
}

func NewStreamerRepo(pool *pgxpool.Pool) *StreamerRepo

func (r *StreamerRepo) GetByID(ctx context.Context, streamerID uuid.UUID) (*domain.Streamer, error)

func (r *StreamerRepo) GetByOverlayUUID(ctx context.Context, overlayUUID uuid.UUID) (*domain.Streamer, error)

func (r *StreamerRepo) RotateOverlayUUID(ctx context.Context, streamerID uuid.UUID) (uuid.UUID, error)

func (r *StreamerRepo) Upsert(ctx context.Context, twitchUserID, twitchUsername string) (*domain.Streamer, error)

Path	Synopsis
sqlcgen