pgdb

Documentation

Index

• type DBTX
• type ExtendSessionParams
• type GasAuthSession
• type InsertSessionParams
• type Queries
  • func New(db DBTX) *Queries
  • func (q *Queries) DeleteExpiredSessions(ctx context.Context, expiresAt time.Time) (int64, error)
  • func (q *Queries) DeleteSession(ctx context.Context, id string) error
  • func (q *Queries) DeleteSessionsBySubject(ctx context.Context, subject string) error
  • func (q *Queries) ExtendSession(ctx context.Context, arg *ExtendSessionParams) error
  • func (q *Queries) GetSession(ctx context.Context, id string) (*GasAuthSession, error)
  • func (q *Queries) InsertSession(ctx context.Context, arg *InsertSessionParams) error
  • func (q *Queries) WithTx(tx *sql.Tx) *Queries

Types

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 ExtendSessionParams

type ExtendSessionParams struct {
	ID         string
	ExpiresAt  time.Time
	LastActive time.Time
}

type GasAuthSession

type GasAuthSession struct {
	ID         string
	Subject    string
	Metadata   json.RawMessage
	IpAddress  string
	UserAgent  string
	CreatedAt  time.Time
	ExpiresAt  time.Time
	LastActive time.Time
}

type InsertSessionParams

type InsertSessionParams struct {
	ID         string
	Subject    string
	Metadata   json.RawMessage
	IpAddress  string
	UserAgent  string
	CreatedAt  time.Time
	ExpiresAt  time.Time
	LastActive time.Time
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) DeleteExpiredSessions

func (q *Queries) DeleteExpiredSessions(ctx context.Context, expiresAt time.Time) (int64, error)

func (*Queries) DeleteSession

func (q *Queries) DeleteSession(ctx context.Context, id string) error

func (*Queries) DeleteSessionsBySubject

func (q *Queries) DeleteSessionsBySubject(ctx context.Context, subject string) error

func (*Queries) ExtendSession

func (q *Queries) ExtendSession(ctx context.Context, arg *ExtendSessionParams) error

func (*Queries) GetSession

func (q *Queries) GetSession(ctx context.Context, id string) (*GasAuthSession, error)

func (*Queries) InsertSession

func (q *Queries) InsertSession(ctx context.Context, arg *InsertSessionParams) error

func (*Queries) WithTx

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