Bifrost Document

Version 1.6.x

Bifrost ---- A heterogeneous middleware which can synchronize MySQL binlog data To Redis,MongoDB,ClickHouse...

hprose

Implementing an interface

Checks if you can connect to the current service

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

Insert data

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

Upate data


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

Delete data

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
}

example

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

Last updated on 29 Jan 2021
Edit on GitHub