tsdb

package
v0.0.0-...-584552c Latest Latest
Warning

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

Go to latest
Published: May 21, 2018 License: Apache-2.0 Imports: 13 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DeleteTableMeta

func DeleteTableMeta(destination string, position *protoc.EntryPosition)

func DeleteTableMetaViaDestination

func DeleteTableMetaViaDestination(destination string)

func InitTableMeta

func InitTableMeta()

func InsertTableMeta

func InsertTableMeta(mh *MetaHistory)

func NewOnceConn

func NewOnceConn(config *MysqlConfig) *sqlx.DB

Types

type DatabaseTableMeta

type DatabaseTableMeta struct {
}

type MetaHistory

type MetaHistory struct {
	Id             int64     `json:"id"`
	GmtCreate      time.Time `json:"gmtCreate"`
	GmtModified    time.Time `json:"gmtModified"`
	Destination    string    `json:"destination"`
	SchemaName     string    `json:"schemaName"`
	TableName      string    `json:"tableName"`
	LogfileName    string    `json:"logfileName"`
	LogPosition    int64     `json:"logPosition"`
	ServerId       string    `json:"serverId"`
	ExecuteTime    int64     `json:"executeTime"`
	TableMetaValue string    `json:"tableMetaValue"`

	SqlText string `json:"sqlText"`
	DdlType string `json:"ddlType"`
}

func SelectLatestTableMeta

func SelectLatestTableMeta(destination, schema, table string, executeTime int64) (*MetaHistory, error)

type MysqlConfig

type MysqlConfig struct {
	Address  string
	Port     string
	Username string
	Password string
	Database string
}

Jump to

Keyboard shortcuts

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