parse

type AuthenticInfo struct {
	// contains filtered or unexported fields
}

type DdlParserResult struct {
	// contains filtered or unexported fields
}

type DdlSQLParser struct {
	// contains filtered or unexported fields
}

type EventConvert struct {
	FilterQueryDcl bool
	FilterQueryDml bool
	FilterQueryDdl bool
	FilterTableErr bool
	FilterRows     bool
	// contains filtered or unexported fields
}

type Index struct {
	Name     string
	Columns  []string
	IsPK     bool
	IsUnique bool
}

type LogDecoder struct {
	// contains filtered or unexported fields
}

type LogFetcher struct {
	// contains filtered or unexported fields
}

type LogSteamer struct {
	// contains filtered or unexported fields
}

type MemoryTableMeta struct {
	// contains filtered or unexported fields
}

type MySQLConnection struct {
	*MySQLConnector
	// contains filtered or unexported fields
}

type MySQLEventParser struct {
	*MySQLConnection

	MasterAuth     *AuthenticInfo
	SlaveAuth      *AuthenticInfo
	MasterPosition *protoc.EntryPosition
	SlavePosition  *protoc.EntryPosition

	BinLogFormat binlogFormatImage
	BinLogImage  binlogFormatImage
	// contains filtered or unexported fields
}

type RawIndex struct {
	// contains filtered or unexported fields
}

type RawTableColumn struct {
	// contains filtered or unexported fields
}

type SinkFunction func(event *LogEvent) bool

type Streamer struct {
	// contains filtered or unexported fields
}

type TableColumn struct {
	Name       string
	Type       int
	RawType    string
	Collation  string
	Nullable   bool
	IsAuto     bool
	IsUnsigned bool
	EnumValues []string
	SetValues  []string
}

type TableMeta struct {
	Schema string
	Table  string

	Columns []*TableColumn
	Indexes map[string]*Index
}

type TableMetaCache struct {
	// contains filtered or unexported fields
}

type TableMetaTSDB struct {
	// contains filtered or unexported fields
}