Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MySQLCoordinator ¶
type MySQLCoordinator struct {
// contains filtered or unexported fields
}
func NewMySQLCoordinator ¶
func NewMySQLCoordinator() (*MySQLCoordinator, error)
func (*MySQLCoordinator) GetAllTimes ¶
func (my *MySQLCoordinator) GetAllTimes() (map[string]int64, error)
func (*MySQLCoordinator) GetLeastTime ¶
func (my *MySQLCoordinator) GetLeastTime() (int64, error)
func (*MySQLCoordinator) GetWorkerId ¶
func (my *MySQLCoordinator) GetWorkerId() (uint64, error)
func (*MySQLCoordinator) ReportTime ¶
func (my *MySQLCoordinator) ReportTime(timestamp int64) error
Source Files
Click to show internal directories.
Click to hide internal directories.