mysql

Documentation

Index

• Variables
• func NewMysqlTrigger() *mysqlTrigger
• type TableMetaCache
  • func NewTableMetaInstance(db *sql.DB) *TableMetaCache
  • func (c *TableMetaCache) Destroy() error
  • func (c *TableMetaCache) GetTableMeta(ctx context.Context, dbName, tableName string) (*types.TableMeta, error)
  • func (c *TableMetaCache) Init(ctx context.Context, conn *sql.DB) error

Variables

var (
	EexpireTime = 15 * time.Minute
)

Functions

func NewMysqlTrigger

func NewMysqlTrigger() *mysqlTrigger

Types

type TableMetaCache

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

func NewTableMetaInstance

func NewTableMetaInstance(db *sql.DB) *TableMetaCache

func (*TableMetaCache) Destroy

func (c *TableMetaCache) Destroy() error

Destroy

func (*TableMetaCache) GetTableMeta

func (c *TableMetaCache) GetTableMeta(ctx context.Context, dbName, tableName string) (*types.TableMeta, error)

GetTableMeta get table info from cache or information schema

func (*TableMetaCache) Init

func (c *TableMetaCache) Init(ctx context.Context, conn *sql.DB) error

Init