Documentation
¶
Index ¶
- Constants
- type MetaPlugin
- func (m *MetaPlugin) Add(newTable *metas.Table) error
- func (m *MetaPlugin) Close()
- func (m *MetaPlugin) Configure(conf map[string]interface{}) error
- func (m *MetaPlugin) Delete(schema string, name string) error
- func (m *MetaPlugin) Get(schema string, tableName string) (table *metas.Table, err error)
- func (m *MetaPlugin) GetAll() map[string]*metas.Table
- func (m *MetaPlugin) GetMeta(router *metas.Router) (table interface{}, err error)
- func (m *MetaPlugin) GetVersion(schema string, tableName string, version uint) (table *metas.Table, err error)
- func (m *MetaPlugin) GetVersions(schema string, tableName string) []*metas.Table
- func (m *MetaPlugin) LoadMeta(routers []*metas.Router) (err error)
- func (m *MetaPlugin) Save() error
- func (m *MetaPlugin) Update(newTable *metas.Table) error
- type OutputPlugin
Constants ¶
View Source
const ( PluginName = "mysql" DefaultBatchSize int = 10240 DefaultBatchIntervalMs int = 100 RetryCount int = 3 RetryInterval int = 5 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MetaPlugin ¶
type MetaPlugin struct {
*config.MysqlConfig
// contains filtered or unexported fields
}
func (*MetaPlugin) Close ¶
func (m *MetaPlugin) Close()
func (*MetaPlugin) Configure ¶
func (m *MetaPlugin) Configure(conf map[string]interface{}) error
func (*MetaPlugin) GetMeta ¶ added in v0.3.0
func (m *MetaPlugin) GetMeta(router *metas.Router) (table interface{}, err error)
func (*MetaPlugin) GetVersion ¶
func (*MetaPlugin) GetVersions ¶
func (m *MetaPlugin) GetVersions(schema string, tableName string) []*metas.Table
func (*MetaPlugin) Save ¶
func (m *MetaPlugin) Save() error
type OutputPlugin ¶
type OutputPlugin struct {
*config.MysqlConfig
Done chan bool
// contains filtered or unexported fields
}
func (*OutputPlugin) Close ¶
func (o *OutputPlugin) Close()
func (*OutputPlugin) Configure ¶
func (o *OutputPlugin) Configure(conf map[string]interface{}) error
func (*OutputPlugin) NewOutput ¶
func (o *OutputPlugin) NewOutput(metas *core.Metas)
Source Files
Click to show internal directories.
Click to hide internal directories.