meta

Documentation

Index

• Variables
• func GetColumns(ctx context.Context, db proto.DB, tableName string) ([]schema.ColumnMeta, error)
• func GetIndexes(ctx context.Context, db proto.DB, tableName string) ([]schema.IndexMeta, error)
• type MysqlTableMetaCache
  • func GetTableMetaCache() *MysqlTableMetaCache
  • func (cache *MysqlTableMetaCache) FetchSchema(ctx context.Context, db proto.DB, tableName string) (schema.TableMeta, error)
  • func (cache *MysqlTableMetaCache) GetCacheKey(dbName, tableName string) string
  • func (cache *MysqlTableMetaCache) GetTableMeta(ctx context.Context, db proto.DB, tableName string) (schema.TableMeta, error)
  • func (cache *MysqlTableMetaCache) Refresh(db proto.DB) error

Variables

var ExpireTime = 15 * time.Minute

Functions

func GetColumns

func GetColumns(ctx context.Context, db proto.DB, tableName string) ([]schema.ColumnMeta, error)

func GetIndexes

func GetIndexes(ctx context.Context, db proto.DB, tableName string) ([]schema.IndexMeta, error)

Types

type MysqlTableMetaCache

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

func GetTableMetaCache

func GetTableMetaCache() *MysqlTableMetaCache

func (*MysqlTableMetaCache) FetchSchema

func (cache *MysqlTableMetaCache) FetchSchema(ctx context.Context, db proto.DB, tableName string) (schema.TableMeta, error)

func (*MysqlTableMetaCache) GetCacheKey

func (cache *MysqlTableMetaCache) GetCacheKey(dbName, tableName string) string

func (*MysqlTableMetaCache) GetTableMeta

func (cache *MysqlTableMetaCache) GetTableMeta(ctx context.Context, db proto.DB, tableName string) (schema.TableMeta, error)

func (*MysqlTableMetaCache) Refresh

func (cache *MysqlTableMetaCache) Refresh(db proto.DB) error