postgres

Documentation

Overview

package postgres implements the session storage driver for PostgreSQL

Index

• type Queryer
• type SessionStorageDriver
  • func NewSessionStorageDriver(conn Queryer) *SessionStorageDriver
  • func (d *SessionStorageDriver) DestroySession(ctx context.Context, sessionID ccc.UUID) error
  • func (d *SessionStorageDriver) DestroySessionOIDC(ctx context.Context, oidcSID string) error
  • func (d *SessionStorageDriver) InsertSession(ctx context.Context, session *dbtype.InsertSession) (ccc.UUID, error)
  • func (d *SessionStorageDriver) InsertSessionOIDC(ctx context.Context, session *dbtype.InsertSessionOIDC) (ccc.UUID, error)
  • func (d *SessionStorageDriver) Session(ctx context.Context, sessionID ccc.UUID) (*dbtype.Session, error)
  • func (d *SessionStorageDriver) SessionOIDC(ctx context.Context, sessionID ccc.UUID) (*dbtype.SessionOIDC, error)
  • func (d *SessionStorageDriver) UpdateSessionActivity(ctx context.Context, sessionID ccc.UUID) error

Types

type Queryer

type Queryer interface {
	Begin(ctx context.Context) (pgx.Tx, error)
	Query(ctx context.Context, query string, args ...interface{}) (pgx.Rows, error)
	QueryRow(ctx context.Context, query string, args ...interface{}) pgx.Row
	Exec(ctx context.Context, query string, args ...interface{}) (pgconn.CommandTag, error)
}

type SessionStorageDriver

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

func NewSessionStorageDriver

func NewSessionStorageDriver(conn Queryer) *SessionStorageDriver

NewSessionStorageDriver creates a new SessionStorageDriver

func (*SessionStorageDriver) DestroySession

func (d *SessionStorageDriver) DestroySession(ctx context.Context, sessionID ccc.UUID) error

DestroySession marks the session as expired

func (*SessionStorageDriver) DestroySessionOIDC

func (d *SessionStorageDriver) DestroySessionOIDC(ctx context.Context, oidcSID string) error

DestroySessionOIDC marks the session as expired

func (*SessionStorageDriver) InsertSession

func (d *SessionStorageDriver) InsertSession(ctx context.Context, session *dbtype.InsertSession) (ccc.UUID, error)

InsertSession inserts Session into database

func (*SessionStorageDriver) InsertSessionOIDC

func (d *SessionStorageDriver) InsertSessionOIDC(ctx context.Context, session *dbtype.InsertSessionOIDC) (ccc.UUID, error)

InsertSessionOIDC inserts Session into database

func (*SessionStorageDriver) Session

func (d *SessionStorageDriver) Session(ctx context.Context, sessionID ccc.UUID) (*dbtype.Session, error)

Session returns the session information from the database for given sessionID

func (*SessionStorageDriver) SessionOIDC

func (d *SessionStorageDriver) SessionOIDC(ctx context.Context, sessionID ccc.UUID) (*dbtype.SessionOIDC, error)

SessionOIDC returns the session information from the database for given sessionID

func (*SessionStorageDriver) UpdateSessionActivity

func (d *SessionStorageDriver) UpdateSessionActivity(ctx context.Context, sessionID ccc.UUID) error

UpdateSessionActivity updates the session activity column with the current time