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