Documentation ¶
Index ¶
- Constants
- Variables
- type MdHandle
- type MetaData
- type MetaDatas
- type MySQLMdExtConsole
- func (m *MySQLMdExtConsole) Close() error
- func (m *MySQLMdExtConsole) GetCreateTime() (*uint64, error)
- func (m *MySQLMdExtConsole) GetDataBaseType() (*string, error)
- func (m *MySQLMdExtConsole) GetFilePosition() (*uint64, *uint64, error)
- func (m *MySQLMdExtConsole) GetLastTransactionTime() (uint64, error)
- func (m *MySQLMdExtConsole) GetLastUpdateTime() (*uint64, error)
- func (m *MySQLMdExtConsole) GetPosition() (*uint64, *uint64, error)
- func (m *MySQLMdExtConsole) GetProcessType() (*string, error)
- func (m *MySQLMdExtConsole) GetStartTime() (uint64, error)
- func (m *MySQLMdExtConsole) GetTransactionBeginTime() (uint64, error)
- func (m *MySQLMdExtConsole) GetXid() ([]byte, error)
- func (m *MySQLMdExtConsole) Init() error
- func (m *MySQLMdExtConsole) SetCreateTime(c uint64) error
- func (m *MySQLMdExtConsole) SetDataBaseType(r string) error
- func (m *MySQLMdExtConsole) SetFilePosition(seq uint64, rba uint64) error
- func (m *MySQLMdExtConsole) SetLastTransactionTime(t uint64) error
- func (m *MySQLMdExtConsole) SetLastUpdateTime(ltime uint64) error
- func (m *MySQLMdExtConsole) SetPosition(seq uint64, csn uint64) error
- func (m *MySQLMdExtConsole) SetProcessType(r string) error
- func (m *MySQLMdExtConsole) SetStartTime() error
- func (m *MySQLMdExtConsole) SetTransactionBeginTime(t uint64) error
- func (m *MySQLMdExtConsole) SetXid(xid []byte) error
- func (m *MySQLMdExtConsole) Sync() error
- type MySQLMetaDataBus
- type OracleMdExtConsole
- func (m *OracleMdExtConsole) Close() error
- func (m *OracleMdExtConsole) GetCreateTime() (*uint64, error)
- func (m *OracleMdExtConsole) GetDataBaseType() (*string, error)
- func (m *OracleMdExtConsole) GetFilePosition() (*uint64, *uint64, error)
- func (m *OracleMdExtConsole) GetLastTransactionTime() (uint64, error)
- func (m *OracleMdExtConsole) GetLastUpdateTime() (*uint64, error)
- func (m *OracleMdExtConsole) GetPosition() (*uint64, *uint64, error)
- func (m *OracleMdExtConsole) GetProcessType() (*string, error)
- func (m *OracleMdExtConsole) GetStartTime() (uint64, error)
- func (m *OracleMdExtConsole) GetTransactionBeginTime() (uint64, error)
- func (m *OracleMdExtConsole) GetXid() ([]byte, error)
- func (m *OracleMdExtConsole) Init() error
- func (m *OracleMdExtConsole) SetCreateTime(c uint64) error
- func (m *OracleMdExtConsole) SetDataBaseType(r string) error
- func (m *OracleMdExtConsole) SetFilePosition(seq uint64, rba uint64) error
- func (m *OracleMdExtConsole) SetLastTransactionTime(t uint64) error
- func (m *OracleMdExtConsole) SetLastUpdateTime(ltime uint64) error
- func (m *OracleMdExtConsole) SetPosition(seq uint64, csn uint64) error
- func (m *OracleMdExtConsole) SetProcessType(r string) error
- func (m *OracleMdExtConsole) SetStartTime() error
- func (m *OracleMdExtConsole) SetTransactionBeginTime(t uint64) error
- func (m *OracleMdExtConsole) SetXid(xid []byte) error
- func (m *OracleMdExtConsole) Sync() error
- type OracleMetaDataBus
Constants ¶
View Source
const ( ORACLE = iota MYSQL )
View Source
const ( CAPTURE = iota REPLICATION )
View Source
const ( NOW = iota + 1 SPECIFY )
View Source
const ( SequenceInitialPlace = 0 SequencePlace = 8 CommitScnInitialPlace = SequenceInitialPlace + SequencePlace CommitScnPlace = 8 XidInitialPlace = CommitScnInitialPlace + CommitScnPlace XidPlace = 16 LastTimeInitialPlace = XidInitialPlace + XidPlace LastTimePlace = 8 CreateTimeInitialPlace = LastTimeInitialPlace + LastTimePlace CreateTimePlace = 8 DataBaseTypeInitialPlace = CreateTimeInitialPlace + CreateTimePlace DataBaseTypePlace = 8 ProcessTypeInitialPlace = DataBaseTypeInitialPlace + DataBaseTypePlace ProcessTypePlace = 8 FileSequenceInitialPlace = ProcessTypeInitialPlace + ProcessTypePlace FileSequencePlace = 8 FileRbaInitialPlace = FileSequenceInitialPlace + FileSequencePlace FileRbaPlace = 8 StartTimeInitialPlace = FileRbaInitialPlace + FileRbaPlace StartTimePlace = 8 TransactionBeginInitialPlace = StartTimeInitialPlace + StartTimePlace TransactionBeginPlace = 8 LastTransactionInitialPlace = TransactionBeginInitialPlace + TransactionBeginPlace LastTransactionPlace = 8 )
View Source
const ( CREATE = iota // 创建元数据 LOAD // 加载元数据 )
Variables ¶
View Source
var CallFunctionErrorMySQL = errors.Errorf("MySQL does not support this function")
View Source
var CallFunctionErrorOracle = errors.Errorf("Oracle does not support this function")
View Source
var UnknownDT = errors.Errorf("Unknown database type")
View Source
var UnknownPT = errors.Errorf("Unknown process type")
Functions ¶
This section is empty.
Types ¶
type MdHandle ¶
type MdHandle struct {
// contains filtered or unexported fields
}
type MetaData ¶
type MetaData interface { Init() error SetPosition(seq uint64, csn uint64) error GetPosition() (*uint64, *uint64, error) SetXid(xid []byte) error GetXid() ([]byte, error) SetLastUpdateTime(ltime uint64) error GetLastUpdateTime() (*uint64, error) SetCreateTime(c uint64) error GetCreateTime() (*uint64, error) SetDataBaseType(r string) error GetDataBaseType() (*string, error) SetProcessType(r string) error GetProcessType() (*string, error) SetFilePosition(seq uint64, rba uint64) error GetFilePosition() (*uint64, *uint64, error) Sync() error Close() error SetStartTime() error GetStartTime() (uint64, error) SetTransactionBeginTime(t uint64) error GetTransactionBeginTime() (uint64, error) }
type MySQLMdExtConsole ¶
type MySQLMdExtConsole struct {
// contains filtered or unexported fields
}
========================================================= MySQL的抓取进程元数据信息结构
func (*MySQLMdExtConsole) Close ¶
func (m *MySQLMdExtConsole) Close() error
func (*MySQLMdExtConsole) GetCreateTime ¶
func (m *MySQLMdExtConsole) GetCreateTime() (*uint64, error)
创建进程时间(单位秒)
func (*MySQLMdExtConsole) GetDataBaseType ¶
func (m *MySQLMdExtConsole) GetDataBaseType() (*string, error)
func (*MySQLMdExtConsole) GetFilePosition ¶
func (m *MySQLMdExtConsole) GetFilePosition() (*uint64, *uint64, error)
func (*MySQLMdExtConsole) GetLastTransactionTime ¶
func (m *MySQLMdExtConsole) GetLastTransactionTime() (uint64, error)
秒,获取事务开始时间
func (*MySQLMdExtConsole) GetLastUpdateTime ¶
func (m *MySQLMdExtConsole) GetLastUpdateTime() (*uint64, error)
最后事务的更新时间(单位秒)
func (*MySQLMdExtConsole) GetPosition ¶
func (m *MySQLMdExtConsole) GetPosition() (*uint64, *uint64, error)
func (*MySQLMdExtConsole) GetProcessType ¶
func (m *MySQLMdExtConsole) GetProcessType() (*string, error)
func (*MySQLMdExtConsole) GetStartTime ¶
func (m *MySQLMdExtConsole) GetStartTime() (uint64, error)
纳秒,获取进程启动时间
func (*MySQLMdExtConsole) GetTransactionBeginTime ¶
func (m *MySQLMdExtConsole) GetTransactionBeginTime() (uint64, error)
纳秒,获取事务开始时间
func (*MySQLMdExtConsole) GetXid ¶
func (m *MySQLMdExtConsole) GetXid() ([]byte, error)
func (*MySQLMdExtConsole) Init ¶
func (m *MySQLMdExtConsole) Init() error
func (*MySQLMdExtConsole) SetCreateTime ¶
func (m *MySQLMdExtConsole) SetCreateTime(c uint64) error
创建进程时间(单位秒)
func (*MySQLMdExtConsole) SetDataBaseType ¶
func (m *MySQLMdExtConsole) SetDataBaseType(r string) error
func (*MySQLMdExtConsole) SetFilePosition ¶
func (m *MySQLMdExtConsole) SetFilePosition(seq uint64, rba uint64) error
func (*MySQLMdExtConsole) SetLastTransactionTime ¶
func (m *MySQLMdExtConsole) SetLastTransactionTime(t uint64) error
纳秒,设置事务开始时间
func (*MySQLMdExtConsole) SetLastUpdateTime ¶
func (m *MySQLMdExtConsole) SetLastUpdateTime(ltime uint64) error
最后事务的更新时间(单位秒)
func (*MySQLMdExtConsole) SetPosition ¶
func (m *MySQLMdExtConsole) SetPosition(seq uint64, csn uint64) error
func (*MySQLMdExtConsole) SetProcessType ¶
func (m *MySQLMdExtConsole) SetProcessType(r string) error
func (*MySQLMdExtConsole) SetStartTime ¶
func (m *MySQLMdExtConsole) SetStartTime() error
纳秒,设置进程启动时间
func (*MySQLMdExtConsole) SetTransactionBeginTime ¶
func (m *MySQLMdExtConsole) SetTransactionBeginTime(t uint64) error
纳秒,设置事务开始时间
func (*MySQLMdExtConsole) SetXid ¶
func (m *MySQLMdExtConsole) SetXid(xid []byte) error
func (*MySQLMdExtConsole) Sync ¶
func (m *MySQLMdExtConsole) Sync() error
type MySQLMetaDataBus ¶
type MySQLMetaDataBus struct {
// contains filtered or unexported fields
}
type OracleMdExtConsole ¶
type OracleMdExtConsole struct {
// contains filtered or unexported fields
}
func (*OracleMdExtConsole) Close ¶
func (m *OracleMdExtConsole) Close() error
func (*OracleMdExtConsole) GetCreateTime ¶
func (m *OracleMdExtConsole) GetCreateTime() (*uint64, error)
创建进程时间(单位秒)
func (*OracleMdExtConsole) GetDataBaseType ¶
func (m *OracleMdExtConsole) GetDataBaseType() (*string, error)
func (*OracleMdExtConsole) GetFilePosition ¶
func (m *OracleMdExtConsole) GetFilePosition() (*uint64, *uint64, error)
func (*OracleMdExtConsole) GetLastTransactionTime ¶
func (m *OracleMdExtConsole) GetLastTransactionTime() (uint64, error)
秒,获取事务开始时间
func (*OracleMdExtConsole) GetLastUpdateTime ¶
func (m *OracleMdExtConsole) GetLastUpdateTime() (*uint64, error)
最后事务的更新时间(单位秒)
func (*OracleMdExtConsole) GetPosition ¶
func (m *OracleMdExtConsole) GetPosition() (*uint64, *uint64, error)
func (*OracleMdExtConsole) GetProcessType ¶
func (m *OracleMdExtConsole) GetProcessType() (*string, error)
func (*OracleMdExtConsole) GetStartTime ¶
func (m *OracleMdExtConsole) GetStartTime() (uint64, error)
纳秒,获取进程启动时间
func (*OracleMdExtConsole) GetTransactionBeginTime ¶
func (m *OracleMdExtConsole) GetTransactionBeginTime() (uint64, error)
纳秒,获取事务开始时间
func (*OracleMdExtConsole) GetXid ¶
func (m *OracleMdExtConsole) GetXid() ([]byte, error)
func (*OracleMdExtConsole) Init ¶
func (m *OracleMdExtConsole) Init() error
func (*OracleMdExtConsole) SetCreateTime ¶
func (m *OracleMdExtConsole) SetCreateTime(c uint64) error
创建进程时间(单位秒)
func (*OracleMdExtConsole) SetDataBaseType ¶
func (m *OracleMdExtConsole) SetDataBaseType(r string) error
func (*OracleMdExtConsole) SetFilePosition ¶
func (m *OracleMdExtConsole) SetFilePosition(seq uint64, rba uint64) error
func (*OracleMdExtConsole) SetLastTransactionTime ¶
func (m *OracleMdExtConsole) SetLastTransactionTime(t uint64) error
纳秒,设置事务开始时间
func (*OracleMdExtConsole) SetLastUpdateTime ¶
func (m *OracleMdExtConsole) SetLastUpdateTime(ltime uint64) error
最后事务的更新时间(单位秒)
func (*OracleMdExtConsole) SetPosition ¶
func (m *OracleMdExtConsole) SetPosition(seq uint64, csn uint64) error
func (*OracleMdExtConsole) SetProcessType ¶
func (m *OracleMdExtConsole) SetProcessType(r string) error
func (*OracleMdExtConsole) SetStartTime ¶
func (m *OracleMdExtConsole) SetStartTime() error
纳秒,设置进程启动时间
func (*OracleMdExtConsole) SetTransactionBeginTime ¶
func (m *OracleMdExtConsole) SetTransactionBeginTime(t uint64) error
纳秒,设置事务开始时间
func (*OracleMdExtConsole) SetXid ¶
func (m *OracleMdExtConsole) SetXid(xid []byte) error
func (*OracleMdExtConsole) Sync ¶
func (m *OracleMdExtConsole) Sync() error
type OracleMetaDataBus ¶
type OracleMetaDataBus struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.