pgxcache

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

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

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

type Querier struct {
	// Options is the cache options.
	Options *QueryOptions
	// Querier is the query executor.
	Querier Queryable
	// Cacher is the cache store.
	Cacher QueryCacher
}

type QuerierTx struct {
	// Querier is the query executor.
	Tx pgx.Tx
	// Options is the cache options.
	Options *QueryOptions
	// Cacher is the cache store.
	Cacher QueryCacher
}

type QueryCacher interface {
	// Get must return a pointer to the item, a boolean representing whether
	// item is present or not, and an error (must be nil when key is not
	// present).
	Get(context.Context, *QueryKey) (*QueryItem, error)
	// Set sets the item into cache with the given TTL.
	Set(context.Context, *QueryKey, *QueryItem, time.Duration) error
	// Reset resets the cache
	Reset(context.Context) error
}

type QueryItem struct {
	// CommandTag is the command tag returned by the query.
	CommandTag string
	// Fields is the field descriptions of the query result.
	Fields []pgconn.FieldDescription
	// Rows is the query result.
	Rows [][][]byte
}

type QueryKey struct {
	// SQL is the SQL query.
	SQL string
	// Args are the arguments to the query.
	Args []any
}

type QueryOptions struct {
	// MinRows is the minimum number of rows that the query should return.
	MinRows int
	// MaxRows is the maximum number of rows that the query should return.
	MaxRows int
	// MaxLifetime is the duration that the query result should be cached.
	MaxLifetime time.Duration
}

type Queryable interface {
	// Begin starts a pseudo nested transaction.
	Begin(ctx context.Context) (pgx.Tx, error)
	// Exec executes a query that doesn't return rows.
	Exec(ctx context.Context, query string, args ...any) (pgconn.CommandTag, error)
	// Query executes a query that returns rows, typically a SELECT.
	Query(ctx context.Context, query string, args ...any) (pgx.Rows, error)
	// QueryRow executes a query that is expected to return at most one row. QueryRow will always return a non-nil value.
	QueryRow(ctx context.Context, query string, args ...any) pgx.Row
	// SendBatch sends a batch of queries to the server. Use Batch.Send to create a batch. The returned Batch
	SendBatch(ctx context.Context, batch *pgx.Batch) pgx.BatchResults
	// CopyFrom copies data from reader to table.
	CopyFrom(ctx context.Context, table pgx.Identifier, columns []string, source pgx.CopyFromSource) (int64, error)
}

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

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

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

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

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

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

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