cbdb

Documentation

Index

• type CachableResultModel
• type Cache
  • func (c *Cache) Cache(args CacheArgs) error
  • func (c *Cache) CountWhere(where CachableResultModel, ttl time.Duration) (int64, error)
  • func (c *Cache) DeleteWhereFlush(model CachableResultModel, where CachableResultModel) error
  • func (c *Cache) FindWhere(out interface{}, where CachableResultModel, ttl time.Duration) error
  • func (c *Cache) FirstWhere(out interface{}, where CachableResultModel, ttl time.Duration) error
  • func (c *Cache) Flush(keyGen CacheKeyGenerator) error
  • func (c *Cache) LastWhere(out interface{}, where CachableResultModel, ttl time.Duration) error
  • func (c *Cache) SaveFlush(model CachableResultModel) error
• type CacheArgs
• type CacheKeyGenerator
  • func (k *CacheKeyGenerator) Generate() string
• type CacheProvider
• type Config
• type ErrorHandler
• type GormReadWrite
  • func (g *GormReadWrite) Close() error
  • func (g *GormReadWrite) GetCache() *Cache
  • func (g *GormReadWrite) InitCache(constructor func() CacheProvider)
  • func (g *GormReadWrite) Read() *gorm.DB
  • func (g *GormReadWrite) ReadMock() sqlmock.Sqlmock
  • func (g *GormReadWrite) SetRead(db *gorm.DB)
  • func (g *GormReadWrite) SetReadMock(db sqlmock.Sqlmock)
  • func (g *GormReadWrite) SetWrite(db *gorm.DB)
  • func (g *GormReadWrite) SetWriteMock(db sqlmock.Sqlmock)
  • func (g *GormReadWrite) Write() *gorm.DB
  • func (g *GormReadWrite) WriteMock() sqlmock.Sqlmock
• type Logger
• type PathInterfaceGetter

Types

type CachableResultModel

type CachableResultModel interface {
	GetCacheKey() string
	GetCacheBucket() string
}

type Cache

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

func (*Cache) Cache

func (c *Cache) Cache(args CacheArgs) error

func (*Cache) CountWhere

func (c *Cache) CountWhere(where CachableResultModel, ttl time.Duration) (int64, error)

func (*Cache) DeleteWhereFlush

func (c *Cache) DeleteWhereFlush(model CachableResultModel, where CachableResultModel) error

func (*Cache) FindWhere

func (c *Cache) FindWhere(out interface{}, where CachableResultModel, ttl time.Duration) error

func (*Cache) FirstWhere

func (c *Cache) FirstWhere(out interface{}, where CachableResultModel, ttl time.Duration) error

func (*Cache) Flush

func (c *Cache) Flush(keyGen CacheKeyGenerator) error

func (*Cache) LastWhere

func (c *Cache) LastWhere(out interface{}, where CachableResultModel, ttl time.Duration) error

func (*Cache) SaveFlush

func (c *Cache) SaveFlush(model CachableResultModel) error

type CacheArgs

type CacheArgs struct {
	Miss   func(db *GormReadWrite, out interface{}) error
	Out    interface{}
	Ttl    time.Duration
	KeyGen CacheKeyGenerator
}

type CacheKeyGenerator

type CacheKeyGenerator struct {
	Bucket   string
	Type     interface{}
	Search   CachableResultModel
	Preloads []string
	Wheres   []string
	Order    string
	Limit    int
	Offset   int
	Group    string
	Extra    []string
}

func (*CacheKeyGenerator) Generate

func (k *CacheKeyGenerator) Generate() string

type CacheProvider

type CacheProvider interface {
	Get(key string) (interface{}, bool)
	Delete(key string)
	Set(key string, value interface{}, ttl time.Duration)
}

type Config

type Config interface {
	Get(path string) interface{}
	GetInt(path string) int
	GetString(path string) string
}

type ErrorHandler

type ErrorHandler interface {
	Error(e error)
}

type GormReadWrite

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

func (*GormReadWrite) Close

func (g *GormReadWrite) Close() error

func (*GormReadWrite) GetCache

func (g *GormReadWrite) GetCache() *Cache

func (*GormReadWrite) InitCache

func (g *GormReadWrite) InitCache(constructor func() CacheProvider)

func (*GormReadWrite) Read

func (g *GormReadWrite) Read() *gorm.DB

func (*GormReadWrite) ReadMock

func (g *GormReadWrite) ReadMock() sqlmock.Sqlmock

func (*GormReadWrite) SetRead

func (g *GormReadWrite) SetRead(db *gorm.DB)

func (*GormReadWrite) SetReadMock

func (g *GormReadWrite) SetReadMock(db sqlmock.Sqlmock)

func (*GormReadWrite) SetWrite

func (g *GormReadWrite) SetWrite(db *gorm.DB)

func (*GormReadWrite) SetWriteMock

func (g *GormReadWrite) SetWriteMock(db sqlmock.Sqlmock)

func (*GormReadWrite) Write

func (g *GormReadWrite) Write() *gorm.DB

func (*GormReadWrite) WriteMock

func (g *GormReadWrite) WriteMock() sqlmock.Sqlmock

type Logger

type Logger interface {
	ErrorF(category string, message string, args ...interface{})
	Print(v ...interface{})
}

type PathInterfaceGetter

type PathInterfaceGetter interface {
	Get(path string) interface{}
}