database

Documentation

Index

• Constants
• Variables
• func ConfigureDBCache(db *gorm.DB, cacheManager gocache.CacheInterface[any])
• func ConfigureMetrics(db *gorm.DB, dbName string, refreshInterval uint32, labels map[string]string, ...)
• func NewDb(conf config.Config) (db *gorm.DB)
• type CacherAdapter
  • func NewCacherAdapter(cacheManager cache.CacheInterface[any]) *CacherAdapter
  • func (c *CacherAdapter) Delete(tag string, tags ...string) error
  • func (c *CacherAdapter) Get(key string) *caches.Query
  • func (c *CacherAdapter) Store(key string, val *caches.Query) error
• type Marshaler
  • func NewMarshaler(cache cache.CacheInterface[any]) *Marshaler
  • func (c *Marshaler) Clear(ctx context.Context) error
  • func (c *Marshaler) Delete(ctx context.Context, key any) error
  • func (c *Marshaler) Get(ctx context.Context, key any, returnObj any) (any, error)
  • func (c *Marshaler) Invalidate(ctx context.Context, options ...store.InvalidateOption) error
  • func (c *Marshaler) Set(ctx context.Context, key, object any, options ...store.Option) error

Constants

const (
	DriverMysql      = "mysql"
	DriverPostgres   = "postgres"
	DriverSqlite     = "sqlite"
	DriverSqlserver  = "sqlserver"
	DriverTidb       = "tidb"
	DriverClickhouse = "clickhouse"
)

Variables

var Db *gorm.DB

Functions

func ConfigureDBCache

func ConfigureDBCache(db *gorm.DB, cacheManager gocache.CacheInterface[any])

func ConfigureMetrics

func ConfigureMetrics(db *gorm.DB, dbName string, refreshInterval uint32, labels map[string]string, collectors ...prometheus.MetricsCollector)

func NewDb

func NewDb(conf config.Config) (db *gorm.DB)

Types

type CacherAdapter

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

func NewCacherAdapter

func NewCacherAdapter(cacheManager cache.CacheInterface[any]) *CacherAdapter

func (*CacherAdapter) Delete

func (c *CacherAdapter) Delete(tag string, tags ...string) error

func (*CacherAdapter) Get

func (c *CacherAdapter) Get(key string) *caches.Query

func (*CacherAdapter) Store

func (c *CacherAdapter) Store(key string, val *caches.Query) error

type Marshaler

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

Marshaler is the struct that marshal and unmarshal cache values

func NewMarshaler

func NewMarshaler(cache cache.CacheInterface[any]) *Marshaler

NewMarshaler creates a new marshaler that marshals/unmarshals cache values

func (*Marshaler) Clear

func (c *Marshaler) Clear(ctx context.Context) error

Clear reset all cache data

func (*Marshaler) Delete

func (c *Marshaler) Delete(ctx context.Context, key any) error

Delete removes a value from the cache

func (*Marshaler) Get

func (c *Marshaler) Get(ctx context.Context, key any, returnObj any) (any, error)

Get obtains a value from cache and unmarshal value with given object

func (*Marshaler) Invalidate

func (c *Marshaler) Invalidate(ctx context.Context, options ...store.InvalidateOption) error

Invalidate invalidate cache values using given options

func (*Marshaler) Set

func (c *Marshaler) Set(ctx context.Context, key, object any, options ...store.Option) error

Set sets a value in cache by marshaling value