Documentation ¶
Index ¶
- type DBTX
- type GetLanguagesRow
- type GetLatestLiveStreamsRow
- type GetLatestStreamsFromStreamerLoginParams
- type GetLatestStreamsFromStreamerLoginRow
- type GetLatestStreamsRow
- type GetMatchingStreamersParams
- type GetMatchingStreamersRow
- type GetPopularCategoriesRow
- type GetPopularLiveStreamsByGameIdParams
- type GetPopularLiveStreamsByGameIdRow
- type GetPopularLiveStreamsByLanguageParams
- type GetPopularLiveStreamsByLanguageRow
- type GetPopularLiveStreamsParams
- type GetPopularLiveStreamsRow
- type GetStreamGzippedBytesParams
- type Queries
- func (q *Queries) DeleteOldStreamers(ctx context.Context, startTime time.Time) error
- func (q *Queries) DeleteOldStreams(ctx context.Context, startTime time.Time) error
- func (q *Queries) DeleteStreams(ctx context.Context) error
- func (q *Queries) GetEverything(ctx context.Context) ([]*Stream, error)
- func (q *Queries) GetLanguages(ctx context.Context) ([]*GetLanguagesRow, error)
- func (q *Queries) GetLatestLiveStreams(ctx context.Context, lastUpdatedAt time.Time) ([]*GetLatestLiveStreamsRow, error)
- func (q *Queries) GetLatestStreams(ctx context.Context, limit int32) ([]*GetLatestStreamsRow, error)
- func (q *Queries) GetLatestStreamsFromStreamerLogin(ctx context.Context, arg GetLatestStreamsFromStreamerLoginParams) ([]*GetLatestStreamsFromStreamerLoginRow, error)
- func (q *Queries) GetMatchingStreamers(ctx context.Context, arg GetMatchingStreamersParams) ([]*GetMatchingStreamersRow, error)
- func (q *Queries) GetPopularCategories(ctx context.Context, limit int32) ([]*GetPopularCategoriesRow, error)
- func (q *Queries) GetPopularLiveStreams(ctx context.Context, arg GetPopularLiveStreamsParams) ([]*GetPopularLiveStreamsRow, error)
- func (q *Queries) GetPopularLiveStreamsByGameId(ctx context.Context, arg GetPopularLiveStreamsByGameIdParams) ([]*GetPopularLiveStreamsByGameIdRow, error)
- func (q *Queries) GetPopularLiveStreamsByLanguage(ctx context.Context, arg GetPopularLiveStreamsByLanguageParams) ([]*GetPopularLiveStreamsByLanguageRow, error)
- func (q *Queries) GetStreamGzippedBytes(ctx context.Context, arg GetStreamGzippedBytesParams) ([][]byte, error)
- func (q *Queries) UpdateRecording(ctx context.Context, arg UpdateRecordingParams) error
- func (q *Queries) UpdateStreamer(ctx context.Context, arg UpdateStreamerParams) error
- func (q *Queries) UpsertManyStreamers(ctx context.Context, arg UpsertManyStreamersParams) error
- func (q *Queries) UpsertManyStreams(ctx context.Context, arg UpsertManyStreamsParams) error
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
- type Stream
- type Streamer
- type UpdateRecordingParams
- type UpdateStreamerParams
- type UpsertManyStreamersParams
- type UpsertManyStreamsParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GetLanguagesRow ¶
type GetLatestLiveStreamsRow ¶
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 GetMatchingStreamersRow ¶
type GetMatchingStreamersRow struct { ProfileImageUrlAtStart sql.NullString StreamerLoginAtStart string }
type GetPopularCategoriesRow ¶
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 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 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 Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) DeleteOldStreamers ¶
func (*Queries) DeleteOldStreams ¶
func (*Queries) GetEverything ¶
func (*Queries) GetLanguages ¶
func (q *Queries) GetLanguages(ctx context.Context) ([]*GetLanguagesRow, error)
func (*Queries) GetLatestLiveStreams ¶
func (*Queries) GetLatestStreams ¶
func (*Queries) GetLatestStreamsFromStreamerLogin ¶
func (q *Queries) GetLatestStreamsFromStreamerLogin(ctx context.Context, arg GetLatestStreamsFromStreamerLoginParams) ([]*GetLatestStreamsFromStreamerLoginRow, error)
func (*Queries) GetMatchingStreamers ¶
func (q *Queries) GetMatchingStreamers(ctx context.Context, arg GetMatchingStreamersParams) ([]*GetMatchingStreamersRow, error)
func (*Queries) GetPopularCategories ¶
func (*Queries) GetPopularLiveStreams ¶
func (q *Queries) GetPopularLiveStreams(ctx context.Context, arg GetPopularLiveStreamsParams) ([]*GetPopularLiveStreamsRow, error)
func (*Queries) GetPopularLiveStreamsByGameId ¶
func (q *Queries) GetPopularLiveStreamsByGameId(ctx context.Context, arg GetPopularLiveStreamsByGameIdParams) ([]*GetPopularLiveStreamsByGameIdRow, error)
func (*Queries) GetPopularLiveStreamsByLanguage ¶
func (q *Queries) GetPopularLiveStreamsByLanguage(ctx context.Context, arg GetPopularLiveStreamsByLanguageParams) ([]*GetPopularLiveStreamsByLanguageRow, error)
func (*Queries) GetStreamGzippedBytes ¶
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
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 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 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 }
Click to show internal directories.
Click to hide internal directories.