util

type ElectionFactory interface {
	NewElection(ctx context.Context, treeID int64) (MasterElection, error)
}

type FakeTimeSource struct {
	// contains filtered or unexported fields
}

type IncrementingFakeTimeSource struct {
	BaseTime      time.Time
	Increments    []time.Duration
	NextIncrement int
}

type MasterElection interface {
	// Start kicks off the process of mastership election.
	Start(context.Context) error
	// WaitForMastership blocks until the current instance is master for this election.
	WaitForMastership(context.Context) error
	// IsMaster returns whether the current instance is master.
	IsMaster(context.Context) (bool, error)
	// ResignAndRestart releases mastership, and re-joins the election.
	ResignAndRestart(context.Context) error
	// Close permanently stops the mastership election process.
	Close(context.Context) error
}

type MasterTracker struct {
	// contains filtered or unexported fields
}

type NoopElection struct {
	// contains filtered or unexported fields
}

type NoopElectionFactory struct {
	InstanceID string
}

type SystemTimeSource struct{}

type TimeSource interface {
	// Now returns the current time in real implementations or a suitable value in others
	Now() time.Time
}