queryercache

package

v0.1.0 Latest Latest Go to latest Published: Jun 12, 2025 License: MIT Imports: 6 Imported by: 0

Details

Package queryercache provides cache for paginator Queryer interface.

This section is empty.

This section is empty.

This section is empty.

type CacheMetrics interface {
	CountIncrement(cached bool)
	QueryIncrement(cached bool)
}

CacheMetrics specify interface for metrics methods.

type Option func(opt *options)

Option specify option for QueryerCache.

func WithCountTTL(ttl time.Duration) Option

QueryerCache count cache ttl (default 30 seconds).

func WithMetrics(m CacheMetrics) Option

WithMetrics metrics provider for QueryerCache (default noop impl).

func WithQueryTTL(ttl time.Duration) Option

WithQueryTTL query cache ttl (default 30 seconds).

type QueryerCache[T any] struct {
	// contains filtered or unexported fields
}

QueryerCache implementing cache for paginator.Queryer interface.

func New[T any](queryer paginator.Queryer[T], opts ...Option) *QueryerCache[T]

New conscturcts new QueryerCache.

func (q *QueryerCache[T]) Count(ctx context.Context) (int, error)

Count returns count value from cache if available and not expired. otherwise returns value from queryer.Count and update cache value.

func (q *QueryerCache[T]) Query(ctx context.Context, offset int, limit int) ([]T, error)

Query returns cached data value if available and not expired. otherwise returns value from queryer.Query and update cache value.

Path	Synopsis
metrics Package metrics provides metric support for QueryerCache.	Package metrics provides metric support for QueryerCache.