database

package
v0.0.0-...-8a38cc6 Latest Latest
Warning

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

 Go to latest Published: Oct 6, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Account 

type Account struct {
	ID                int32
	UserID            uuid.UUID
	Provider          string
	ProviderAccountID string
	RefreshToken      sql.NullString
	AccessToken       sql.NullString
	ValidUntil        time.Time
	Scope             sql.NullString
	TokenType         sql.NullString
}

type CreateAccountParams 

type CreateAccountParams struct {
	UserID            uuid.UUID
	Provider          string
	ProviderAccountID string
	RefreshToken      sql.NullString
	AccessToken       sql.NullString
	ValidUntil        time.Time
	Scope             sql.NullString
	TokenType         sql.NullString
}

type CreatePushTokenParams 

type CreatePushTokenParams struct {
	Token    string
	Provider ProviderType
	UserID   uuid.UUID
}

type CreateResetPasswordTokenParams 

type CreateResetPasswordTokenParams struct {
	UserID     uuid.UUID
	ValidUntil time.Time
}

type CreateStreamDetailsParams 

type CreateStreamDetailsParams struct {
	StreamID    uuid.UUID
	Title       string
	Description string
}

type CreateStreamParams 

type CreateStreamParams struct {
	UserID     uuid.UUID
	App        string
	StreamName string
	Url        string
}

type CreateStreamStatusParams 

type CreateStreamStatusParams struct {
	StreamID        uuid.UUID
	Status          StreamStatusEnum
	EstStartTime    sql.NullTime
	LastPublishedAt sql.NullTime
	ViewersCount    sql.NullInt32
}

type CreateUserParams 

type CreateUserParams struct {
	Name     string
	Email    string
	Password string
}

type DBTX 

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type DeleteAccountParams 

type DeleteAccountParams struct {
	UserID            uuid.UUID
	ProviderAccountID string
}

type DeleteAccountsByUserIDAndProviderParams 

type DeleteAccountsByUserIDAndProviderParams struct {
	UserID   uuid.UUID
	Provider string
}

type DeletePushTokensByUserIDAndProviderParams 

type DeletePushTokensByUserIDAndProviderParams struct {
	UserID   uuid.UUID
	Provider ProviderType
}

type GetAccountByUserIDAndProviderAccountIDParams 

type GetAccountByUserIDAndProviderAccountIDParams struct {
	UserID            uuid.UUID
	ProviderAccountID string
}

type GetAccountByUserIDAndProviderAndProviderAccountIDParams 

type GetAccountByUserIDAndProviderAndProviderAccountIDParams struct {
	UserID            uuid.UUID
	ProviderAccountID string
	Provider          string
}

type GetPushTokensByUserIDAndProviderParams 

type GetPushTokensByUserIDAndProviderParams struct {
	UserID   uuid.UUID
	Provider ProviderType
}

type NullProviderType 

type NullProviderType struct {
	ProviderType ProviderType
	Valid        bool // Valid is true if ProviderType is not NULL
}

func (*NullProviderType) Scan 

func (ns *NullProviderType) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullProviderType) Value 

func (ns NullProviderType) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullStreamStatusEnum 

type NullStreamStatusEnum struct {
	StreamStatusEnum StreamStatusEnum
	Valid            bool // Valid is true if StreamStatusEnum is not NULL
}

func (*NullStreamStatusEnum) Scan 

func (ns *NullStreamStatusEnum) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullStreamStatusEnum) Value 

func (ns NullStreamStatusEnum) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type PasswordResetToken 

type PasswordResetToken struct {
	Token      uuid.UUID
	ValidUntil time.Time
	UserID     uuid.UUID
	CreatedAt  time.Time
	UpdatedAt  time.Time
}

type ProviderType 

type ProviderType string
const (
	ProviderTypeFcm ProviderType = "fcm"
	ProviderTypeApn ProviderType = "apn"
)

func (*ProviderType) Scan 

func (e *ProviderType) Scan(src interface{}) error

type PushToken 

type PushToken struct {
	ID        uuid.UUID
	Token     string
	Provider  ProviderType
	UserID    uuid.UUID
	CreatedAt time.Time
	UpdatedAt time.Time
}

type Queries 

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

func New 

func New(db DBTX) *Queries

func (*Queries) CheckUserExists 

func (q *Queries) CheckUserExists(ctx context.Context, email string) (bool, error)

func (*Queries) CreateAccount 

func (q *Queries) CreateAccount(ctx context.Context, arg CreateAccountParams) (Account, error)

func (*Queries) CreatePushToken 

func (q *Queries) CreatePushToken(ctx context.Context, arg CreatePushTokenParams) (PushToken, error)

func (*Queries) CreateResetPasswordToken 

func (q *Queries) CreateResetPasswordToken(ctx context.Context, arg CreateResetPasswordTokenParams) (PasswordResetToken, error)

func (*Queries) CreateStream 

func (q *Queries) CreateStream(ctx context.Context, arg CreateStreamParams) (Stream, error)

func (*Queries) CreateStreamDetails 

func (q *Queries) CreateStreamDetails(ctx context.Context, arg CreateStreamDetailsParams) (StreamDetail, error)

func (*Queries) CreateStreamStatus 

func (q *Queries) CreateStreamStatus(ctx context.Context, arg CreateStreamStatusParams) (StreamStatus, error)

func (*Queries) CreateUser 

func (q *Queries) CreateUser(ctx context.Context, arg CreateUserParams) (User, error)

func (*Queries) DecrementStreamStatusViewersCount 

func (q *Queries) DecrementStreamStatusViewersCount(ctx context.Context, streamID uuid.UUID) error

func (*Queries) DeleteAccount 

func (q *Queries) DeleteAccount(ctx context.Context, arg DeleteAccountParams) error

func (*Queries) DeleteAccountsByUserID 

func (q *Queries) DeleteAccountsByUserID(ctx context.Context, userID uuid.UUID) error

func (*Queries) DeleteAccountsByUserIDAndProvider 

func (q *Queries) DeleteAccountsByUserIDAndProvider(ctx context.Context, arg DeleteAccountsByUserIDAndProviderParams) error

func (*Queries) DeletePushToken 

func (q *Queries) DeletePushToken(ctx context.Context, token string) error

func (*Queries) DeletePushTokensByUserID 

func (q *Queries) DeletePushTokensByUserID(ctx context.Context, userID uuid.UUID) error

func (*Queries) DeletePushTokensByUserIDAndProvider 

func (q *Queries) DeletePushTokensByUserIDAndProvider(ctx context.Context, arg DeletePushTokensByUserIDAndProviderParams) error

func (*Queries) DeleteResetPasswordToken 

func (q *Queries) DeleteResetPasswordToken(ctx context.Context, token uuid.UUID) error

func (*Queries) DeleteStream 

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

func (*Queries) DeleteStreamDetails 

func (q *Queries) DeleteStreamDetails(ctx context.Context, streamID uuid.UUID) error

func (*Queries) DeleteStreamStatus 

func (q *Queries) DeleteStreamStatus(ctx context.Context, streamID uuid.UUID) error

func (*Queries) DeleteUser 

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

func (*Queries) GetAccountByID 

func (q *Queries) GetAccountByID(ctx context.Context, id int32) (Account, error)

func (*Queries) GetAccountByUserID 

func (q *Queries) GetAccountByUserID(ctx context.Context, userID uuid.UUID) (Account, error)

func (*Queries) GetAccountByUserIDAndProviderAccountID 

func (q *Queries) GetAccountByUserIDAndProviderAccountID(ctx context.Context, arg GetAccountByUserIDAndProviderAccountIDParams) (Account, error)

func (*Queries) GetAccountByUserIDAndProviderAndProviderAccountID 

func (q *Queries) GetAccountByUserIDAndProviderAndProviderAccountID(ctx context.Context, arg GetAccountByUserIDAndProviderAndProviderAccountIDParams) (Account, error)

func (*Queries) GetAccountsByUserID 

func (q *Queries) GetAccountsByUserID(ctx context.Context, userID uuid.UUID) ([]Account, error)

func (*Queries) GetPushToken 

func (q *Queries) GetPushToken(ctx context.Context, token string) (PushToken, error)

func (*Queries) GetPushTokensByUserID 

func (q *Queries) GetPushTokensByUserID(ctx context.Context, userID uuid.UUID) ([]PushToken, error)

func (*Queries) GetPushTokensByUserIDAndProvider 

func (q *Queries) GetPushTokensByUserIDAndProvider(ctx context.Context, arg GetPushTokensByUserIDAndProviderParams) ([]PushToken, error)

func (*Queries) GetResetPasswordToken 

func (q *Queries) GetResetPasswordToken(ctx context.Context, token uuid.UUID) (PasswordResetToken, error)

func (*Queries) GetStream 

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

func (*Queries) GetStreamDetails 

func (q *Queries) GetStreamDetails(ctx context.Context, streamID uuid.UUID) (StreamDetail, error)

func (*Queries) GetStreamStatus 

func (q *Queries) GetStreamStatus(ctx context.Context, streamID uuid.UUID) (StreamStatus, error)

func (*Queries) GetStreamsByApp 

func (q *Queries) GetStreamsByApp(ctx context.Context, app string) ([]Stream, error)

func (*Queries) GetStreamsByStreamName 

func (q *Queries) GetStreamsByStreamName(ctx context.Context, streamName string) ([]Stream, error)

func (*Queries) GetStreamsByUserId 

func (q *Queries) GetStreamsByUserId(ctx context.Context, userID uuid.UUID) ([]Stream, error)

func (*Queries) GetUserByEmail 

func (q *Queries) GetUserByEmail(ctx context.Context, email string) (User, error)

func (*Queries) GetUserByID 

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

func (*Queries) IncrementStreamStatusViewersCount 

func (q *Queries) IncrementStreamStatusViewersCount(ctx context.Context, streamID uuid.UUID) error

func (*Queries) PublishStream 

func (q *Queries) PublishStream(ctx context.Context, streamID uuid.UUID) error

func (*Queries) ScheduleStream 

func (q *Queries) ScheduleStream(ctx context.Context, arg ScheduleStreamParams) error

func (*Queries) StopStream 

func (q *Queries) StopStream(ctx context.Context, streamID uuid.UUID) error

func (*Queries) UpdateAccount 

func (q *Queries) UpdateAccount(ctx context.Context, arg UpdateAccountParams) (Account, error)

func (*Queries) UpdateAccountTokens 

func (q *Queries) UpdateAccountTokens(ctx context.Context, arg UpdateAccountTokensParams) (Account, error)

func (*Queries) UpdateStream 

func (q *Queries) UpdateStream(ctx context.Context, arg UpdateStreamParams) (Stream, error)

func (*Queries) UpdateStreamDetails 

func (q *Queries) UpdateStreamDetails(ctx context.Context, arg UpdateStreamDetailsParams) (StreamDetail, error)

func (*Queries) UpdateStreamStatus 

func (q *Queries) UpdateStreamStatus(ctx context.Context, arg UpdateStreamStatusParams) (StreamStatus, error)

func (*Queries) UpdateStreamStatusViewersCount 

func (q *Queries) UpdateStreamStatusViewersCount(ctx context.Context, arg UpdateStreamStatusViewersCountParams) error

func (*Queries) UpdateUser 

func (q *Queries) UpdateUser(ctx context.Context, arg UpdateUserParams) (User, error)

func (*Queries) UpdateUserPassword 

func (q *Queries) UpdateUserPassword(ctx context.Context, arg UpdateUserPasswordParams) (User, error)

func (*Queries) WithTx 

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

type ScheduleStreamParams 

type ScheduleStreamParams struct {
	StreamID     uuid.UUID
	EstStartTime sql.NullTime
}

type Stream 

type Stream struct {
	ID         uuid.UUID
	App        string
	StreamName string
	Url        string
	UserID     uuid.UUID
	CreatedAt  sql.NullTime
	UpdatedAt  sql.NullTime
}

type StreamDetail 

type StreamDetail struct {
	ID          uuid.UUID
	StreamID    uuid.UUID
	Title       string
	Description string
	CreatedAt   sql.NullTime
	UpdatedAt   sql.NullTime
}

type StreamStatus 

type StreamStatus struct {
	ID              uuid.UUID
	StreamID        uuid.UUID
	Status          StreamStatusEnum
	EstStartTime    sql.NullTime
	LastPublishedAt sql.NullTime
	ViewersCount    sql.NullInt32
	CreatedAt       sql.NullTime
	UpdatedAt       sql.NullTime
}

type StreamStatusEnum 

type StreamStatusEnum string
const (
	StreamStatusEnumOnline    StreamStatusEnum = "online"
	StreamStatusEnumOffline   StreamStatusEnum = "offline"
	StreamStatusEnumScheduled StreamStatusEnum = "scheduled"
)

func (*StreamStatusEnum) Scan 

func (e *StreamStatusEnum) Scan(src interface{}) error

type UpdateAccountParams 

type UpdateAccountParams struct {
	UserID            uuid.UUID
	ProviderAccountID string
	RefreshToken      sql.NullString
	AccessToken       sql.NullString
	ValidUntil        time.Time
	Scope             sql.NullString
	TokenType         sql.NullString
}

type UpdateAccountTokensParams 

type UpdateAccountTokensParams struct {
	UserID            uuid.UUID
	ProviderAccountID string
	RefreshToken      sql.NullString
	AccessToken       sql.NullString
	ValidUntil        time.Time
}

type UpdateStreamDetailsParams 

type UpdateStreamDetailsParams struct {
	StreamID    uuid.UUID
	Title       string
	Description string
}

type UpdateStreamParams 

type UpdateStreamParams struct {
	ID         uuid.UUID
	App        string
	StreamName string
	Url        string
}

type UpdateStreamStatusParams 

type UpdateStreamStatusParams struct {
	StreamID        uuid.UUID
	Status          StreamStatusEnum
	EstStartTime    sql.NullTime
	LastPublishedAt sql.NullTime
	ViewersCount    sql.NullInt32
}

type UpdateStreamStatusViewersCountParams 

type UpdateStreamStatusViewersCountParams struct {
	StreamID     uuid.UUID
	ViewersCount sql.NullInt32
}

type UpdateUserParams 

type UpdateUserParams struct {
	ID       uuid.UUID
	Name     string
	Email    string
	Password string
}

type UpdateUserPasswordParams 

type UpdateUserPasswordParams struct {
	ID       uuid.UUID
	Password string
}

type User 

type User struct {
	ID          uuid.UUID
	Name        string
	Email       string
	Password    string
	IsVerified  bool
	IsActive    bool
	LastLoginAt sql.NullTime
	CreatedAt   sql.NullTime
	UpdatedAt   sql.NullTime
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.