lock

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

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

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

type LeaderGateOptions struct {
	/* RetryInterval is the pause between failed campaigns while another instance leads; defaults to half the ttl, floored at one second. */
	RetryInterval time.Duration

	/* RefreshInterval is the lease-renewal cadence while leading; defaults to half the ttl, or defaultSessionProbeInterval when the ttl is non-positive (session-style locks whose Refresh is a liveness probe). */
	RefreshInterval time.Duration

	/* OnElected runs on the Run goroutine right after the gate becomes leader. */
	OnElected func(runtimeInstance runtimecontract.Runtime)

	/* OnLost runs on the Run goroutine right after leadership is lost to a failed renewal; cause is the renewal error. It does not run on a clean shutdown. */
	OnLost func(runtimeInstance runtimecontract.Runtime, cause error)

	/* OnCampaignError runs on the Run goroutine for every campaign that could not even ask the store who leads — the gate then backs off and campaigns again, so without this hook the error is never seen. A store outage and a permanent misconfiguration (a redis locker built with a non-positive ttl, whose Acquire fails closed on every call) are indistinguishable from the outside: both look exactly like a deployment that quietly elects no leader and does no work. */
	OnCampaignError func(runtimeInstance runtimecontract.Runtime, cause error)
}