dbs

Documentation

Index

• Variables
• type DBTX
• type Queries
  • func New(db DBTX) *Queries
  • func (q *Queries) UserOnlineAll(ctx context.Context) ([]UserOnline, error)
  • func (q *Queries) UserOnlineBatchExecUpdate(ctx context.Context, arg []UserOnlineBatchExecUpdateParams) *UserOnlineBatchExecUpdateBatchResults
  • func (q *Queries) UserOnlineBatchExecUpsert(ctx context.Context, arg []UserOnlineBatchExecUpsertParams) *UserOnlineBatchExecUpsertBatchResults
  • func (q *Queries) UserOnlineFixtureCount(ctx context.Context, online int64) (UserOnlineFixtureCountRow, error)
  • func (q *Queries) UserOnlineFixtureUpsert(ctx context.Context, arg UserOnlineFixtureUpsertParams) error
  • func (q *Queries) UserOnlineUnnestUpdate(ctx context.Context, arg UserOnlineUnnestUpdateParams) error
  • func (q *Queries) UserOnlineUnnestUpsert(ctx context.Context, arg UserOnlineUnnestUpsertParams) error
  • func (q *Queries) UserOnlineUpdate(ctx context.Context, arg UserOnlineUpdateParams) error
  • func (q *Queries) UserOnlineUpsert(ctx context.Context, arg UserOnlineUpsertParams) error
  • func (q *Queries) WithTx(tx pgx.Tx) *Queries
• type UserOnline
• type UserOnlineBatchExecUpdateBatchResults
  • func (b *UserOnlineBatchExecUpdateBatchResults) Close() error
  • func (b *UserOnlineBatchExecUpdateBatchResults) Exec(f func(int, error))
• type UserOnlineBatchExecUpdateParams
• type UserOnlineBatchExecUpsertBatchResults
  • func (b *UserOnlineBatchExecUpsertBatchResults) Close() error
  • func (b *UserOnlineBatchExecUpsertBatchResults) Exec(f func(int, error))
• type UserOnlineBatchExecUpsertParams
• type UserOnlineFixtureCountRow
• type UserOnlineFixtureUpsertParams
• type UserOnlineUnnestUpdateParams
• type UserOnlineUnnestUpsertParams
• type UserOnlineUpdateParams
• type UserOnlineUpsertParams

Variables

var (
	ErrBatchAlreadyClosed = errors.New("batch already closed")
)

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
	SendBatch(context.Context, *pgx.Batch) pgx.BatchResults
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) UserOnlineAll

func (q *Queries) UserOnlineAll(ctx context.Context) ([]UserOnline, error)

func (*Queries) UserOnlineBatchExecUpdate

func (q *Queries) UserOnlineBatchExecUpdate(ctx context.Context, arg []UserOnlineBatchExecUpdateParams) *UserOnlineBatchExecUpdateBatchResults

func (*Queries) UserOnlineBatchExecUpsert

func (q *Queries) UserOnlineBatchExecUpsert(ctx context.Context, arg []UserOnlineBatchExecUpsertParams) *UserOnlineBatchExecUpsertBatchResults

func (*Queries) UserOnlineFixtureCount

func (q *Queries) UserOnlineFixtureCount(ctx context.Context, online int64) (UserOnlineFixtureCountRow, error)

func (*Queries) UserOnlineFixtureUpsert

func (q *Queries) UserOnlineFixtureUpsert(ctx context.Context, arg UserOnlineFixtureUpsertParams) error

func (*Queries) UserOnlineUnnestUpdate

func (q *Queries) UserOnlineUnnestUpdate(ctx context.Context, arg UserOnlineUnnestUpdateParams) error

func (*Queries) UserOnlineUnnestUpsert

func (q *Queries) UserOnlineUnnestUpsert(ctx context.Context, arg UserOnlineUnnestUpsertParams) error

func (*Queries) UserOnlineUpdate

func (q *Queries) UserOnlineUpdate(ctx context.Context, arg UserOnlineUpdateParams) error

func (*Queries) UserOnlineUpsert

func (q *Queries) UserOnlineUpsert(ctx context.Context, arg UserOnlineUpsertParams) error

func (*Queries) WithTx

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

type UserOnline

type UserOnline struct {
	UserID int64
	Online pgtype.Timestamp
}

type UserOnlineBatchExecUpdateBatchResults

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

func (*UserOnlineBatchExecUpdateBatchResults) Close

func (b *UserOnlineBatchExecUpdateBatchResults) Close() error

func (*UserOnlineBatchExecUpdateBatchResults) Exec

func (b *UserOnlineBatchExecUpdateBatchResults) Exec(f func(int, error))

type UserOnlineBatchExecUpdateParams

type UserOnlineBatchExecUpdateParams struct {
	Online pgtype.Timestamp
	UserID int64
}

type UserOnlineBatchExecUpsertBatchResults

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

func (*UserOnlineBatchExecUpsertBatchResults) Close

func (b *UserOnlineBatchExecUpsertBatchResults) Close() error

func (*UserOnlineBatchExecUpsertBatchResults) Exec

func (b *UserOnlineBatchExecUpsertBatchResults) Exec(f func(int, error))

type UserOnlineBatchExecUpsertParams

type UserOnlineBatchExecUpsertParams struct {
	UserID int64
	Online pgtype.Timestamp
}

type UserOnlineFixtureCountRow

type UserOnlineFixtureCountRow struct {
	Total   int64
	Changed int64
}

type UserOnlineFixtureUpsertParams

type UserOnlineFixtureUpsertParams struct {
	Online int64
	Count  int64
}

type UserOnlineUnnestUpdateParams

type UserOnlineUnnestUpdateParams struct {
	UserIds []int64
	Onlines []pgtype.Timestamp
}

type UserOnlineUnnestUpsertParams

type UserOnlineUnnestUpsertParams struct {
	UserIds []int64
	Onlines []pgtype.Timestamp
}

type UserOnlineUpdateParams

type UserOnlineUpdateParams struct {
	Online pgtype.Timestamp
	UserID int64
}

type UserOnlineUpsertParams

type UserOnlineUpsertParams struct {
	UserID int64
	Online pgtype.Timestamp
}