election

type ElectionConfig struct {
	// Storage is the s3lect-compatible storage for leader election state
	Storage storage.Storage
	// PeerMode enables peer verification of leadership
	PeerMode bool
	// CACert is the CA certificate for peer verification (nil if peer mode disabled)
	CACert []byte
	// FrequentInterval is how often to check leadership when actively participating
	FrequentInterval time.Duration
	// InfrequentInterval is how often to check leadership when idle
	InfrequentInterval time.Duration
	// LeaderTimeout is how long before a leader is considered dead
	LeaderTimeout time.Duration
	// OnAcquire is called after successfully acquiring leadership
	OnAcquire func(ctx context.Context) error
	// OnLose is called after losing leadership
	OnLose func(ctx context.Context) error
}

type ElectorFactory func(opts s3lect.S3ElectorOptions) (s3lect.Elector, error)

type HealthServerConfig struct {
	// BindAddr is the address to listen on (e.g. ":8443")
	BindAddr string
	// TLSCert is the TLS certificate for the HTTPS server
	TLSCert tls.Certificate
}

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

type ManagerConfig struct {
	// ClusterID is the cluster identifier
	ClusterID string
	// ShardID is the shard identifier (e.g. zone shard ID)
	ShardID string
	// ServerID is this server's unique identifier
	ServerID string
	// ServerAddr is the address other servers use for peer verification
	ServerAddr string
	// Logger for election events
	Logger *slog.Logger
}