cache

Documentation

Index

• Constants
• func Lookup[T any](ctx context.Context, q *Queries, partition int64, cacheKey string) (*T, error)
• func Migrate(conn *sql.DB) error
• func Write[T any](ctx context.Context, q *Queries, partition int64, cacheKey string, value T, ...) error
• type CacheItem
• type DBTX
• type LookupParams
• type Queries
  • func New(db DBTX) *Queries
  • func (q *Queries) DeleteExpired(ctx context.Context) error
  • func (q *Queries) Lookup(ctx context.Context, arg LookupParams) ([]CacheItem, error)
  • func (q *Queries) WithTx(tx *sql.Tx) *Queries
  • func (q *Queries) Write(ctx context.Context, arg WriteParams) error
• type WriteParams

Constants

const PARTITION_MOVIE_DETAILS = 1

Functions

func Lookup

func Lookup[T any](ctx context.Context, q *Queries, partition int64, cacheKey string) (*T, error)

func Migrate

func Migrate(conn *sql.DB) error

Migrate applies all pending schema migrations to the cache database.

func Write

func Write[T any](ctx context.Context, q *Queries, partition int64, cacheKey string, value T, expires time.Time) error

Types

type CacheItem

type CacheItem struct {
	Partition  int64
	CacheKey   string
	CacheValue []byte
	Expires    int64
}

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 LookupParams

type LookupParams struct {
	Partition int64
	CacheKey  string
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) DeleteExpired

func (q *Queries) DeleteExpired(ctx context.Context) error

func (*Queries) Lookup

func (q *Queries) Lookup(ctx context.Context, arg LookupParams) ([]CacheItem, error)

func (*Queries) WithTx

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

func (*Queries) Write

func (q *Queries) Write(ctx context.Context, arg WriteParams) error

type WriteParams

type WriteParams struct {
	Partition  int64
	CacheKey   string
	CacheValue []byte
	Expires    int64
}