leaderelection

type Config struct {
	// TTL is the time-to-live for the leader lock
	TTL time.Duration

	// RenewalInterval is how often to renew the leader lock
	RenewalInterval time.Duration

	// NodeID is the unique identifier for this node (for logging/metrics only)
	// If empty, a random ID will be generated
	NodeID string
}

type Elector interface {
	// Start begins the leader election process
	Start(ctx context.Context) error

	// Stop gracefully stops the leader election
	Stop(ctx context.Context) error

	// IsLeader returns true if this node is currently the leader
	IsLeader() bool

	// OnLeadershipChange registers a callback for guaranteed leadership notification.
	// The callback is invoked synchronously when leadership status changes.
	// Multiple callbacks can be registered and will be invoked in registration order.
	//
	// Important: Keep callbacks fast (< 100ms) to avoid delaying leadership renewal.
	// For long-running operations, spawn a goroutine within the callback.
	OnLeadershipChange(callback LeadershipCallback)
}

type LeadershipCallback func(ctx context.Context, isLeader bool)

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