coordinator

Documentation

Index

• func CheckClockDrift(coordinator Coordinator) error
• func Reporter(coordinator Coordinator)
• type ClockDriftChecker
• type Coordinator
  • func NewCoordinator() (Coordinator, error)
• type ETCDClockDriftChecker
  • func (ETCDClockDriftChecker) CheckOtherNodes(coordinator Coordinator) error
• type NoClockDriftChecker
  • func (NoClockDriftChecker) CheckOtherNodes(coordinator Coordinator) error
• type StoreClockDriftChecker
  • func (StoreClockDriftChecker) CheckOtherNodes(coordinator Coordinator) error

Functions

func CheckClockDrift

func CheckClockDrift(coordinator Coordinator) error

check time

func Reporter

func Reporter(coordinator Coordinator)

reporter

Types

type ClockDriftChecker

type ClockDriftChecker interface {
	CheckOtherNodes(Coordinator) error
}

type Coordinator

type Coordinator interface {
	GetWorkerId() (uint64, error)
	GetLeastTime() (int64, error)
	ReportTime(int64) error
	GetAllTimes() (map[string]int64, error)
}

func NewCoordinator

func NewCoordinator() (Coordinator, error)

type ETCDClockDriftChecker

type ETCDClockDriftChecker struct {
}

func (ETCDClockDriftChecker) CheckOtherNodes

func (ETCDClockDriftChecker) CheckOtherNodes(coordinator Coordinator) error

type NoClockDriftChecker

type NoClockDriftChecker struct {
}

func (NoClockDriftChecker) CheckOtherNodes

func (NoClockDriftChecker) CheckOtherNodes(coordinator Coordinator) error

type StoreClockDriftChecker

type StoreClockDriftChecker struct {
}

func (StoreClockDriftChecker) CheckOtherNodes

func (StoreClockDriftChecker) CheckOtherNodes(coordinator Coordinator) error