cache

Sep 1, 2020

Changes in this version

+ var EXPIRE_TIME = 15 * time.Minute

+ func GetColumns(tx *Tx, tableName string) ([]schema.ColumnMeta, error)

+ func GetIndexes(tx *Tx, tableName string) ([]schema.IndexMeta, error)

+ func SetTableMetaCache(tbMetaCache ITableMetaCache)

+ type ITableMetaCache interface

+ GetTableMeta func(tx *sql.Tx, tableName, resourceId string) (schema.TableMeta, error)

+ Refresh func(tx *sql.Tx, resourceId string)

+ func GetTableMetaCache() ITableMetaCache

+ func NewMysqlTableMetaCache(dsn string) ITableMetaCache

+ type MysqlTableMetaCache struct

+ func (cache *MysqlTableMetaCache) FetchSchema(tx *Tx, tableName string) (schema.TableMeta, error)

+ func (cache *MysqlTableMetaCache) GetCacheKey(tableName string, resourceId string) string

+ func (cache *MysqlTableMetaCache) GetTableMeta(tx *sql.Tx, tableName, resourceId string) (schema.TableMeta, error)

+ func (cache *MysqlTableMetaCache) Refresh(tx *sql.Tx, resourceId string)

+ type Tx struct