Documentation
¶
Index ¶
- type MysqlFilterService
- func (srv *MysqlFilterService) FilterDelete(cond *condition.MysqlRunTimeFilterCondImpl, deleteFmt *format.DeleteFormat) (serializer.MysqlSeries, bool)
- func (srv *MysqlFilterService) FilterInsert(cond *condition.MysqlRunTimeFilterCondImpl, insertFmt *format.InsertFormat) (serializer.MysqlSeries, bool)
- func (srv *MysqlFilterService) FilterUpdate(cond *condition.MysqlRunTimeFilterCondImpl, updateFmt *format.UpdateFormat) (serializer.MysqlSeries, bool)
- type MysqlFormatService
- func (srv *MysqlFormatService) BuildDirectInsert(database string, table string, tableFmt *dao.TableFormat, ...) (*format.InsertFormat, error)
- func (srv *MysqlFormatService) BuildMaxwellDelete(data map[string]interface{}) *format.DeleteFormat
- func (srv *MysqlFormatService) BuildMaxwellInsert(data map[string]interface{}) *format.InsertFormat
- func (srv *MysqlFormatService) BuildMaxwellUpdate(data map[string]interface{}) *format.UpdateFormat
- type MysqlStreamService
- func (srv *MysqlStreamService) ExecSql(sql []interface{}) stream.HandleWriteFunc
- func (srv *MysqlStreamService) SelectFromPrimaryIdBetween(table string, primaryCol string, begin, end int64) stream.HandleReadFunc
- func (srv *MysqlStreamService) SelectLatestPrimaryId(table string, primaryCol string) stream.HandleReadFunc
- func (srv *MysqlStreamService) ShowTables() stream.HandleReadFunc
- func (srv *MysqlStreamService) TableDesc(table string) stream.HandleReadFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MysqlFilterService ¶
type MysqlFilterService struct {
// contains filtered or unexported fields
}
func NewMysqlFilterService ¶
func NewMysqlFilterService(ctx *context.BizContext) *MysqlFilterService
func (*MysqlFilterService) FilterDelete ¶
func (srv *MysqlFilterService) FilterDelete(cond *condition.MysqlRunTimeFilterCondImpl, deleteFmt *format.DeleteFormat) (serializer.MysqlSeries, bool)
过滤删除数据
func (*MysqlFilterService) FilterInsert ¶
func (srv *MysqlFilterService) FilterInsert(cond *condition.MysqlRunTimeFilterCondImpl, insertFmt *format.InsertFormat) (serializer.MysqlSeries, bool)
过滤插入数据
func (*MysqlFilterService) FilterUpdate ¶
func (srv *MysqlFilterService) FilterUpdate(cond *condition.MysqlRunTimeFilterCondImpl, updateFmt *format.UpdateFormat) (serializer.MysqlSeries, bool)
过滤更新数据
type MysqlFormatService ¶
type MysqlFormatService struct {
// contains filtered or unexported fields
}
func NewMysqlFormatService ¶
func NewMysqlFormatService(ctx *context.BizContext) *MysqlFormatService
func (*MysqlFormatService) BuildDirectInsert ¶
func (srv *MysqlFormatService) BuildDirectInsert(database string, table string, tableFmt *dao.TableFormat, data map[string]interface{}) (*format.InsertFormat, error)
direct sync database insert 构建
func (*MysqlFormatService) BuildMaxwellDelete ¶
func (srv *MysqlFormatService) BuildMaxwellDelete(data map[string]interface{}) *format.DeleteFormat
maxwell delete 格式构建
func (*MysqlFormatService) BuildMaxwellInsert ¶
func (srv *MysqlFormatService) BuildMaxwellInsert(data map[string]interface{}) *format.InsertFormat
maxwell insert 格式构建
func (*MysqlFormatService) BuildMaxwellUpdate ¶
func (srv *MysqlFormatService) BuildMaxwellUpdate(data map[string]interface{}) *format.UpdateFormat
maxwell update 格式构建
type MysqlStreamService ¶
type MysqlStreamService struct {
// contains filtered or unexported fields
}
func NewMysqlStreamService ¶
func NewMysqlStreamService(ctx *context.BizContext) *MysqlStreamService
func (*MysqlStreamService) ExecSql ¶
func (srv *MysqlStreamService) ExecSql(sql []interface{}) stream.HandleWriteFunc
func (*MysqlStreamService) SelectFromPrimaryIdBetween ¶
func (srv *MysqlStreamService) SelectFromPrimaryIdBetween(table string, primaryCol string, begin, end int64) stream.HandleReadFunc
(]
func (*MysqlStreamService) SelectLatestPrimaryId ¶
func (srv *MysqlStreamService) SelectLatestPrimaryId(table string, primaryCol string) stream.HandleReadFunc
func (*MysqlStreamService) ShowTables ¶
func (srv *MysqlStreamService) ShowTables() stream.HandleReadFunc
func (*MysqlStreamService) TableDesc ¶
func (srv *MysqlStreamService) TableDesc(table string) stream.HandleReadFunc
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.