sqlcgen

Documentation

Index

• type Config
• type CreateEventSubSubscriptionParams
• type DBTX
• type EventsubSubscription
• type GetEventSubByStreamerIDRow
• type ListEventSubSubscriptionsRow
• type Queries
  • func New(db DBTX) *Queries
  • func (q *Queries) CreateEventSubSubscription(ctx context.Context, arg CreateEventSubSubscriptionParams) error
  • func (q *Queries) DeleteEventSubByConduitID(ctx context.Context, conduitID string) error
  • func (q *Queries) DeleteEventSubByStreamerID(ctx context.Context, streamerID uuid.UUID) error
  • func (q *Queries) GetConfigByBroadcasterID(ctx context.Context, twitchUserID string) (Config, error)
  • func (q *Queries) GetConfigByStreamerID(ctx context.Context, streamerID uuid.UUID) (Config, error)
  • func (q *Queries) GetEventSubByStreamerID(ctx context.Context, streamerID uuid.UUID) (GetEventSubByStreamerIDRow, error)
  • func (q *Queries) GetStreamerByID(ctx context.Context, id uuid.UUID) (Streamer, error)
  • func (q *Queries) GetStreamerByOverlayUUID(ctx context.Context, overlayUuid uuid.UUID) (Streamer, error)
  • func (q *Queries) InsertDefaultConfig(ctx context.Context, streamerID uuid.UUID) error
  • func (q *Queries) ListEventSubSubscriptions(ctx context.Context) ([]ListEventSubSubscriptionsRow, error)
  • func (q *Queries) RotateOverlayUUID(ctx context.Context, id uuid.UUID) (uuid.UUID, error)
  • func (q *Queries) UpdateConfig(ctx context.Context, arg UpdateConfigParams) (pgconn.CommandTag, error)
  • func (q *Queries) UpsertStreamer(ctx context.Context, arg UpsertStreamerParams) (Streamer, error)
  • func (q *Queries) WithTx(tx pgx.Tx) *Queries
• type Streamer
• type UpdateConfigParams
• type UpsertStreamerParams

Types

type Config

type Config struct {
	StreamerID     uuid.UUID
	Version        int32
	CreatedAt      time.Time
	UpdatedAt      time.Time
	ForTrigger     string
	ForLabel       string
	AgainstTrigger string
	AgainstLabel   string
	MemorySeconds  int32
	DisplayMode    string
	Theme          string
}

type CreateEventSubSubscriptionParams

type CreateEventSubSubscriptionParams struct {
	StreamerID     uuid.UUID
	SubscriptionID string
	ConduitID      string
}

type DBTX

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type EventsubSubscription

type EventsubSubscription struct {
	StreamerID     uuid.UUID
	SubscriptionID string
	ConduitID      string
	CreatedAt      time.Time
}

type GetEventSubByStreamerIDRow

type GetEventSubByStreamerIDRow struct {
	StreamerID        uuid.UUID
	BroadcasterUserID string
	SubscriptionID    string
	ConduitID         string
	CreatedAt         time.Time
}

type ListEventSubSubscriptionsRow

type ListEventSubSubscriptionsRow struct {
	StreamerID        uuid.UUID
	BroadcasterUserID string
	SubscriptionID    string
	ConduitID         string
	CreatedAt         time.Time
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) CreateEventSubSubscription

func (q *Queries) CreateEventSubSubscription(ctx context.Context, arg CreateEventSubSubscriptionParams) error

func (*Queries) DeleteEventSubByConduitID

func (q *Queries) DeleteEventSubByConduitID(ctx context.Context, conduitID string) error

func (*Queries) DeleteEventSubByStreamerID

func (q *Queries) DeleteEventSubByStreamerID(ctx context.Context, streamerID uuid.UUID) error

func (*Queries) GetConfigByBroadcasterID

func (q *Queries) GetConfigByBroadcasterID(ctx context.Context, twitchUserID string) (Config, error)

func (*Queries) GetConfigByStreamerID

func (q *Queries) GetConfigByStreamerID(ctx context.Context, streamerID uuid.UUID) (Config, error)

func (*Queries) GetEventSubByStreamerID

func (q *Queries) GetEventSubByStreamerID(ctx context.Context, streamerID uuid.UUID) (GetEventSubByStreamerIDRow, error)

func (*Queries) GetStreamerByID

func (q *Queries) GetStreamerByID(ctx context.Context, id uuid.UUID) (Streamer, error)

func (*Queries) GetStreamerByOverlayUUID

func (q *Queries) GetStreamerByOverlayUUID(ctx context.Context, overlayUuid uuid.UUID) (Streamer, error)

func (*Queries) InsertDefaultConfig

func (q *Queries) InsertDefaultConfig(ctx context.Context, streamerID uuid.UUID) error

func (*Queries) ListEventSubSubscriptions

func (q *Queries) ListEventSubSubscriptions(ctx context.Context) ([]ListEventSubSubscriptionsRow, error)

func (*Queries) RotateOverlayUUID

func (q *Queries) RotateOverlayUUID(ctx context.Context, id uuid.UUID) (uuid.UUID, error)

func (*Queries) UpdateConfig

func (q *Queries) UpdateConfig(ctx context.Context, arg UpdateConfigParams) (pgconn.CommandTag, error)

func (*Queries) UpsertStreamer

func (q *Queries) UpsertStreamer(ctx context.Context, arg UpsertStreamerParams) (Streamer, error)

func (*Queries) WithTx

func (q *Queries) WithTx(tx pgx.Tx) *Queries

type Streamer

type Streamer struct {
	ID             uuid.UUID
	CreatedAt      time.Time
	UpdatedAt      time.Time
	OverlayUUID    uuid.UUID
	TwitchUserID   string
	TwitchUsername string
}

type UpdateConfigParams

type UpdateConfigParams struct {
	ForTrigger     string
	ForLabel       string
	AgainstTrigger string
	AgainstLabel   string
	MemorySeconds  int32
	DisplayMode    string
	Theme          string
	Version        int32
	StreamerID     uuid.UUID
}

type UpsertStreamerParams

type UpsertStreamerParams struct {
	TwitchUserID   string
	TwitchUsername string
}