src

package
v1.2.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 26, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const BIFROST_VERION = "v1.1.0"
View Source
const VERSION = "v1.1.0"

Variables

This section is empty.

Functions

This section is empty.

Types

type Conn

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

func (*Conn) Close

func (This *Conn) Close() bool

func (*Conn) Commit

func (This *Conn) Commit() (*pluginDriver.PluginBinlog, error)

func (*Conn) Connect

func (This *Conn) Connect() bool

func (*Conn) Del

func (This *Conn) Del(data *pluginDriver.PluginDataType) (postion *pluginDriver.PluginBinlog, e error)

func (*Conn) GetConnStatus

func (This *Conn) GetConnStatus() string

func (*Conn) GetParam

func (This *Conn) GetParam(p interface{}) (*PluginParam, error)

func (*Conn) HeartCheck

func (This *Conn) HeartCheck()

func (*Conn) Insert

func (This *Conn) Insert(data *pluginDriver.PluginDataType) (postion *pluginDriver.PluginBinlog, e error)

func (*Conn) Query

func (*Conn) ReConnect

func (This *Conn) ReConnect() bool

func (*Conn) SetConnStatus

func (This *Conn) SetConnStatus(status string)

func (*Conn) SetParam

func (This *Conn) SetParam(p interface{}) (interface{}, error)

func (*Conn) Update

type MyConn

type MyConn struct{}

func (*MyConn) CheckUri

func (MyConn *MyConn) CheckUri(uri string) error

func (*MyConn) GetUriExample

func (MyConn *MyConn) GetUriExample() string

func (*MyConn) Open

func (MyConn *MyConn) Open(uri string) pluginDriver.ConnFun

type PluginParam

type PluginParam struct {
	SchemaName string
	TableName  string
	PrimaryKey string
	// contains filtered or unexported fields
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL