utils

Documentation

Index

• Constants
• func Alarm(msg string)
• func CheckTableExist(mysqlHost string, mysqlPort int, mysqlUser string, mysqlPasswd string, ...) (bool, error)
• func CreateEphemeralSequential(zkConn *zk.Conn, nodesPath string) (string, error)
• func EnsurePath(zkConn *zk.Conn, path string, value []byte) error
• func GetConsumeOffset(mysqlHost string, mysqlPort int, mysqlUser string, mysqlPasswd string, ...) (int64, error)
• func GetMysqlVar(mysqlHost string, mysqlPort int, mysqlUser string, mysqlPasswd string, ...) (string, error)

Constants

const (
	OffsetNewest     int64 = -1
	OffsetOldest     int64 = -2
	OffsetCheckpoint int64 = -3
)

Functions

func Alarm

func Alarm(msg string)

func CheckTableExist

func CheckTableExist(mysqlHost string, mysqlPort int, mysqlUser string,
	mysqlPasswd string, tableSchema string, tableName string) (bool, error)

func CreateEphemeralSequential

func CreateEphemeralSequential(zkConn *zk.Conn, nodesPath string) (string, error)

func EnsurePath

func EnsurePath(zkConn *zk.Conn, path string, value []byte) error

func GetConsumeOffset

func GetConsumeOffset(mysqlHost string, mysqlPort int, mysqlUser string,
	mysqlPasswd string, tableSchema string, tableName string, kafkaTopic string) (int64, error)

func GetMysqlVar

func GetMysqlVar(mysqlHost string, mysqlPort int, mysqlUser string, mysqlPasswd string, varName string) (string, error)