ddsmetadata

package module
v0.0.0-...-9b26c28 Latest Latest
Warning

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

 Go to latest Published: Oct 10, 2023 License: MIT Imports: 11 Imported by: 5

Documentation

Index

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
}

func (*MdHandle) CreateMetaDataFile 

func (m *MdHandle) CreateMetaDataFile(processName string, dataBaseType string, processType string, log *logrus.Logger) error

初始化元数据句柄

func (*MdHandle) LoadMetaDataFile 

func (m *MdHandle) LoadMetaDataFile(processName string, dataBaseType string, processType string, log *logrus.Logger) error

初始化元数据句柄

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)
}

func InitMetaData 

func InitMetaData(processName string, dataBaseType string, processType string, log *logrus.Logger, opsType int) (MetaData, error)

创建加载元数据文件

type MetaDatas 

type MetaDatas interface {
	Registry(*MdHandle, *logrus.Logger) (MetaData, 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
}

func (*MySQLMetaDataBus) Registry 

func (m *MySQLMetaDataBus) Registry(md *MdHandle, log *logrus.Logger) (MetaData, error)

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
}

func (*OracleMetaDataBus) Registry 

func (m *OracleMetaDataBus) Registry(md *MdHandle, log *logrus.Logger) (MetaData, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.