pluginTest

Documentation

Index

• Variables
• func GetTestDeleteData() *pluginDriver.PluginDataType
• func GetTestInsertData() *pluginDriver.PluginDataType
• func GetTestQueryData() *pluginDriver.PluginDataType
• func GetTestUpdateData() *pluginDriver.PluginDataType
• type BifrostManager
  • func (This *BifrostManager) AddChannel(dbname string, channel_name string, cosumercount int) (bool, int)
  • func (This *BifrostManager) AddDB(dbname string, uri string) bool
  • func (This *BifrostManager) AddTable(dbname string, schema string, table string, channelid int) bool
  • func (This *BifrostManager) AddTableToServer(dbname string, schema string, table string, toserver_key string, ...) (bool, int)
  • func (This *BifrostManager) AddToServer(toServerKeyName string, pluginName string, uri string, notes string) bool
  • func (This *BifrostManager) ChannelClose(dbname string, channelid int) bool
  • func (This *BifrostManager) ChannelDel(dbname string, channelid int) bool
  • func (This *BifrostManager) ChannelStart(dbname string, channelid int) bool
  • func (This *BifrostManager) ChannelStop(dbname string, channelid int) bool
  • func (This *BifrostManager) DBClose(dbname string) bool
  • func (This *BifrostManager) DBDel(dbname string) bool
  • func (This *BifrostManager) DBStart(dbname string) bool
  • func (This *BifrostManager) DBStop(dbname string) bool
  • func (This *BifrostManager) DelChannel(dbname string, channelid int) bool
  • func (This *BifrostManager) DelTable(dbname string, schema string, table string) bool
  • func (This *BifrostManager) DelTableToServer(dbname string, schema string, table string, toserver_key string, ...) bool
  • func (This *BifrostManager) DelToServer(toServerKeyName string) bool
  • func (This *BifrostManager) DoLogin() bool
  • func (This *BifrostManager) Init()
  • func (This *BifrostManager) JsonDecodeResult(body []byte) *resultStruct
• type MasterBinlogInfoStruct
• type MySQLConn
  • func (This *MySQLConn) DBConnect()
  • func (This *MySQLConn) ExecSQL(sql string)
  • func (This *MySQLConn) GetBinLogInfo() MasterBinlogInfoStruct
  • func (This *MySQLConn) GetServerId() int

Variables

var TestDeleteDataJson = `` /* 665-byte string literal not displayed */

var TestInsertDataJson = `` /* 668-byte string literal not displayed */

var TestQueryData = "ALTER TABLE `bifrost_test`.`binlog_field_http_plugin_test` CHANGE COLUMN `testvarchar` `testvarchar` varchar(20) NOT NULL"

var TestUpdateDataJson = `` /* 1332-byte string literal not displayed */

Functions

func GetTestDeleteData

func GetTestDeleteData() *pluginDriver.PluginDataType

func GetTestInsertData

func GetTestInsertData() *pluginDriver.PluginDataType

func GetTestQueryData

func GetTestQueryData() *pluginDriver.PluginDataType

func GetTestUpdateData

func GetTestUpdateData() *pluginDriver.PluginDataType

Types

type BifrostManager

type BifrostManager struct {
	Host         string
	User         string
	Pwd          string
	CurCookies   []*http.Cookie
	CurCookieJar *cookiejar.Jar //管理cookie
	MysqlConn    *MySQLConn
}

func (*BifrostManager) AddChannel

func (This *BifrostManager) AddChannel(dbname string, channel_name string, cosumercount int) (bool, int)

func (*BifrostManager) AddDB

func (This *BifrostManager) AddDB(dbname string, uri string) bool

func (*BifrostManager) AddTable

func (This *BifrostManager) AddTable(dbname string, schema string, table string, channelid int) bool

func (*BifrostManager) AddTableToServer

func (This *BifrostManager) AddTableToServer(dbname string, schema string, table string, toserver_key string, plugin_name string, fieldlist []string, mustbe int, param map[string]interface{}) (bool, int)

func (*BifrostManager) AddToServer

func (This *BifrostManager) AddToServer(toServerKeyName string, pluginName string, uri string, notes string) bool

func (*BifrostManager) ChannelClose

func (This *BifrostManager) ChannelClose(dbname string, channelid int) bool

func (*BifrostManager) ChannelDel

func (This *BifrostManager) ChannelDel(dbname string, channelid int) bool

func (*BifrostManager) ChannelStart

func (This *BifrostManager) ChannelStart(dbname string, channelid int) bool

func (*BifrostManager) ChannelStop

func (This *BifrostManager) ChannelStop(dbname string, channelid int) bool

func (*BifrostManager) DBClose

func (This *BifrostManager) DBClose(dbname string) bool

func (*BifrostManager) DBDel

func (This *BifrostManager) DBDel(dbname string) bool

func (*BifrostManager) DBStart

func (This *BifrostManager) DBStart(dbname string) bool

func (*BifrostManager) DBStop

func (This *BifrostManager) DBStop(dbname string) bool

func (*BifrostManager) DelChannel

func (This *BifrostManager) DelChannel(dbname string, channelid int) bool

func (*BifrostManager) DelTable

func (This *BifrostManager) DelTable(dbname string, schema string, table string) bool

func (*BifrostManager) DelTableToServer

func (This *BifrostManager) DelTableToServer(dbname string, schema string, table string, toserver_key string, to_server_id int) bool

func (*BifrostManager) DelToServer

func (This *BifrostManager) DelToServer(toServerKeyName string) bool

func (*BifrostManager) DoLogin

func (This *BifrostManager) DoLogin() bool

func (*BifrostManager) Init

func (This *BifrostManager) Init()

func (*BifrostManager) JsonDecodeResult

func (This *BifrostManager) JsonDecodeResult(body []byte) *resultStruct

type MasterBinlogInfoStruct

type MasterBinlogInfoStruct struct {
	File              string
	Position          int
	Binlog_Do_DB      string
	Binlog_Ignore_DB  string
	Executed_Gtid_Set string
}

type MySQLConn

type MySQLConn struct {
	Uri string
	// contains filtered or unexported fields
}

func (*MySQLConn) DBConnect

func (This *MySQLConn) DBConnect()

func (*MySQLConn) ExecSQL

func (This *MySQLConn) ExecSQL(sql string)

func (*MySQLConn) GetBinLogInfo

func (This *MySQLConn) GetBinLogInfo() MasterBinlogInfoStruct

func (*MySQLConn) GetServerId

func (This *MySQLConn) GetServerId() int