Bifrost Document

Version 1.6.x

Bifrost ---- 面向生产环境的 MySQL 同步到 Redis,MongoDB,ClickHouse 等服务的异构中间件

hprose

实现以下几个方法

检测是否可以连接到当前服务

func Check(context *rpc.HTTPContext) (e error) {
log.Println("Check success")
return nil
}

新增数据

func Insert(SchemaName string,TableName string, data map[string]interface{}) (e error) {
return nil
}

更新数据


func Update(SchemaName string,TableName string, data []map[string]interface{}) (e error){
log.Println("data:",data)
return nil
}

删除数据

func Delete(SchemaName string,TableName string,data map[string]map[string]interface{}) (e error) {
log.Println("Delete")
log.Println("SchemaName:",SchemaName)
log.Println("TableName:",TableName)
log.Println("data:",data)
return nil
}

sql

func Query(SchemaName string,TableName string,sql string) (e error) {
log.Println("sql")
log.Println("SchemaName:",SchemaName)
log.Println("TableName:",TableName)
log.Println("sql:",sql)
return nil
}

map[string]interface{} 格式

map[字段名][字段的值]

example

https://github.com/brokercap/Bifrost/tree/master/plugin/hprose/hprose_server

Last updated on 29 Jan 2021
Edit on GitHub