sqlvods

package
v0.0.0-...-54a1e58 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 24, 2023 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

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 GetLanguagesRow

type GetLanguagesRow struct {
	Count           int64
	LanguageAtStart string
}

type GetLatestLiveStreamsRow

type GetLatestLiveStreamsRow struct {
	ID                   uuid.UUID
	StreamID             string
	StreamerID           string
	StreamerLoginAtStart string
	GameIDAtStart        string
	StartTime            time.Time
	MaxViews             int64
	LastUpdatedAt        time.Time
}

type GetLatestStreamsFromStreamerLoginParams

type GetLatestStreamsFromStreamerLoginParams struct {
	StreamerLoginAtStart string
	Limit                int32
}

type GetLatestStreamsFromStreamerLoginRow

type GetLatestStreamsFromStreamerLoginRow struct {
	ID                     uuid.UUID
	MaxViews               int64
	StartTime              time.Time
	StreamerID             string
	StreamID               string
	StreamerLoginAtStart   string
	GameNameAtStart        string
	LanguageAtStart        string
	TitleAtStart           string
	IsMatureAtStart        bool
	GameIDAtStart          string
	BytesFound             sql.NullBool
	Public                 sql.NullBool
	HlsDurationSeconds     sql.NullFloat64
	BoxArtUrlAtStart       sql.NullString
	ProfileImageUrlAtStart sql.NullString
}

type GetLatestStreamsRow

type GetLatestStreamsRow struct {
	ID            uuid.UUID
	StreamID      string
	StreamerID    string
	StartTime     time.Time
	MaxViews      int64
	LastUpdatedAt time.Time
}

type GetMatchingStreamersParams

type GetMatchingStreamersParams struct {
	StreamerLoginAtStart   string
	StreamerLoginAtStart_2 string
	Limit                  int32
}

type GetMatchingStreamersRow

type GetMatchingStreamersRow struct {
	ProfileImageUrlAtStart sql.NullString
	StreamerLoginAtStart   string
}

type GetPopularCategoriesRow

type GetPopularCategoriesRow struct {
	Count           int64
	GameNameAtStart string
	GameIDAtStart   string
}

type GetPopularLiveStreamsByGameIdParams

type GetPopularLiveStreamsByGameIdParams struct {
	GameIDAtStart string
	Public        sql.NullBool
	Limit         int32
}

type GetPopularLiveStreamsByGameIdRow

type GetPopularLiveStreamsByGameIdRow struct {
	ID                     uuid.UUID
	MaxViews               int64
	StartTime              time.Time
	StreamerID             string
	StreamID               string
	StreamerLoginAtStart   string
	GameNameAtStart        string
	LanguageAtStart        string
	TitleAtStart           string
	IsMatureAtStart        bool
	GameIDAtStart          string
	BytesFound             sql.NullBool
	Public                 sql.NullBool
	HlsDurationSeconds     sql.NullFloat64
	BoxArtUrlAtStart       sql.NullString
	ProfileImageUrlAtStart sql.NullString
}

type GetPopularLiveStreamsByLanguageParams

type GetPopularLiveStreamsByLanguageParams struct {
	LanguageAtStart string
	Public          sql.NullBool
	Limit           int32
}

type GetPopularLiveStreamsByLanguageRow

type GetPopularLiveStreamsByLanguageRow struct {
	ID                     uuid.UUID
	MaxViews               int64
	StartTime              time.Time
	StreamerID             string
	StreamID               string
	StreamerLoginAtStart   string
	GameNameAtStart        string
	LanguageAtStart        string
	TitleAtStart           string
	IsMatureAtStart        bool
	GameIDAtStart          string
	BytesFound             sql.NullBool
	Public                 sql.NullBool
	HlsDurationSeconds     sql.NullFloat64
	BoxArtUrlAtStart       sql.NullString
	ProfileImageUrlAtStart sql.NullString
}

type GetPopularLiveStreamsParams

type GetPopularLiveStreamsParams struct {
	Public sql.NullBool
	Limit  int32
}

type GetPopularLiveStreamsRow

type GetPopularLiveStreamsRow struct {
	ID                     uuid.UUID
	MaxViews               int64
	StartTime              time.Time
	StreamerID             string
	StreamID               string
	StreamerLoginAtStart   string
	GameNameAtStart        string
	LanguageAtStart        string
	TitleAtStart           string
	IsMatureAtStart        bool
	GameIDAtStart          string
	BytesFound             sql.NullBool
	Public                 sql.NullBool
	HlsDurationSeconds     sql.NullFloat64
	BoxArtUrlAtStart       sql.NullString
	ProfileImageUrlAtStart sql.NullString
}

type GetStreamGzippedBytesParams

type GetStreamGzippedBytesParams struct {
	StreamID  string
	StartTime time.Time
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) DeleteOldStreamers

func (q *Queries) DeleteOldStreamers(ctx context.Context, startTime time.Time) error

func (*Queries) DeleteOldStreams

func (q *Queries) DeleteOldStreams(ctx context.Context, startTime time.Time) error

func (*Queries) DeleteStreams

func (q *Queries) DeleteStreams(ctx context.Context) error

func (*Queries) GetEverything

func (q *Queries) GetEverything(ctx context.Context) ([]*Stream, error)

func (*Queries) GetLanguages

func (q *Queries) GetLanguages(ctx context.Context) ([]*GetLanguagesRow, error)

func (*Queries) GetLatestLiveStreams

func (q *Queries) GetLatestLiveStreams(ctx context.Context, lastUpdatedAt time.Time) ([]*GetLatestLiveStreamsRow, error)

func (*Queries) GetLatestStreams

func (q *Queries) GetLatestStreams(ctx context.Context, limit int32) ([]*GetLatestStreamsRow, error)

func (*Queries) GetMatchingStreamers

func (q *Queries) GetMatchingStreamers(ctx context.Context, arg GetMatchingStreamersParams) ([]*GetMatchingStreamersRow, error)

func (*Queries) GetPopularCategories

func (q *Queries) GetPopularCategories(ctx context.Context, limit int32) ([]*GetPopularCategoriesRow, error)

func (*Queries) GetPopularLiveStreams

func (q *Queries) GetPopularLiveStreams(ctx context.Context, arg GetPopularLiveStreamsParams) ([]*GetPopularLiveStreamsRow, error)

func (*Queries) GetStreamGzippedBytes

func (q *Queries) GetStreamGzippedBytes(ctx context.Context, arg GetStreamGzippedBytesParams) ([][]byte, error)

func (*Queries) UpdateRecording

func (q *Queries) UpdateRecording(ctx context.Context, arg UpdateRecordingParams) error

func (*Queries) UpdateStreamer

func (q *Queries) UpdateStreamer(ctx context.Context, arg UpdateStreamerParams) error

func (*Queries) UpsertManyStreamers

func (q *Queries) UpsertManyStreamers(ctx context.Context, arg UpsertManyStreamersParams) error

func (*Queries) UpsertManyStreams

func (q *Queries) UpsertManyStreams(ctx context.Context, arg UpsertManyStreamsParams) error

func (*Queries) WithTx

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

type Stream

type Stream struct {
	ID                               uuid.UUID
	StreamerID                       string
	StreamID                         string
	StartTime                        time.Time
	MaxViews                         int64
	LastUpdatedAt                    time.Time
	StreamerLoginAtStart             string
	LanguageAtStart                  string
	TitleAtStart                     string
	GameNameAtStart                  string
	GameIDAtStart                    string
	IsMatureAtStart                  bool
	LastUpdatedMinusStartTimeSeconds float64
	RecordingFetchedAt               sql.NullTime
	GzippedBytes                     []byte
	HlsDomain                        sql.NullString
	HlsDurationSeconds               sql.NullFloat64
	BytesFound                       sql.NullBool
	Public                           sql.NullBool
	BoxArtUrlAtStart                 sql.NullString
	ProfileImageUrlAtStart           sql.NullString
}

type Streamer

type Streamer struct {
	ID                     uuid.UUID
	StartTime              time.Time
	StreamerLoginAtStart   string
	StreamerID             string
	ProfileImageUrlAtStart sql.NullString
}

type UpdateRecordingParams

type UpdateRecordingParams struct {
	StreamID               string
	StartTime              time.Time
	RecordingFetchedAt     sql.NullTime
	HlsDomain              sql.NullString
	GzippedBytes           []byte
	BytesFound             sql.NullBool
	Public                 sql.NullBool
	HlsDurationSeconds     sql.NullFloat64
	ProfileImageUrlAtStart sql.NullString
	BoxArtUrlAtStart       sql.NullString
}

type UpdateStreamerParams

type UpdateStreamerParams struct {
	StreamerLoginAtStart   string
	ProfileImageUrlAtStart sql.NullString
}

type UpsertManyStreamersParams

type UpsertManyStreamersParams struct {
	StreamerIDArr           []string
	StartTimeArr            []time.Time
	StreamerLoginAtStartArr []string
}

type UpsertManyStreamsParams

type UpsertManyStreamsParams struct {
	LastUpdatedAtArr                    []time.Time
	MaxViewsArr                         []int64
	StartTimeArr                        []time.Time
	StreamerIDArr                       []string
	StreamIDArr                         []string
	StreamerLoginAtStartArr             []string
	GameNameAtStartArr                  []string
	LanguageAtStartArr                  []string
	TitleAtStartArr                     []string
	IsMatureAtStartArr                  []bool
	GameIDAtStartArr                    []string
	LastUpdatedMinusStartTimeSecondsArr []float64
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL