httpapi

Documentation

Index

• 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

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