coordinator

type Config struct {
	Enabled       bool     // Whether the coordinator is enabled
	MyNodeID      string   // The ID of the node
	ClusterAddr   string   // The address for memberlist gossip (host:port format, e.g., "0.0.0.0:7946")
	ListenAddr    string   // The address the node listens on for client requests (Put/Get/Delete and cluster topology)
	AdvertiseAddr string   // The address advertised to other nodes for routing (if different from ListenAddr)
	Seeds         []string // Seed nodes for joining cluster (memberlist addresses of other nodes)
	DiskPath      string   // The path to the disk for persisting ring tokens

	// LifecyclerConfig allows advanced ring configuration (optional).
	// Mainly used for testing.
	LifecyclerConfig ring.LifecyclerConfig

	// Router configuration
	RouterConfig *RouterConfig

	// GRPCDialOptions are additional gRPC dial options for inter-node connections.
	// These are passed through to the Router and appended to outgoing connections.
	GRPCDialOptions []grpc.DialOption

	// Registerer is the prometheus registerer to use. If nil, uses prometheus.DefaultRegisterer.
	// This is useful for tests to avoid duplicate registration panics.
	Registerer prometheus.Registerer
}

type ConnectionStats struct {
	State           string
	FailureCount    int32
	CircuitOpen     bool
	LastFailure     time.Time
	CircuitOpenTime time.Time
}

type Coordinator struct {
	clusterpb.UnimplementedClusterServiceServer
	// contains filtered or unexported fields
}

type EpochGetter func() uint64

type RequestMetadata struct {
	RingEpoch  uint64
	HopCount   int
	Forwarded  bool
	OriginNode string
}

type ResponseMetadata struct {
	RingEpoch   uint64
	OwnerAddr   string
	ForwardedBy string
}

type Ring interface {
	// GetNode returns the node that owns the given key
	GetNode(key string) (*ring.NodeInfo, error)
	// GetAllNodes returns all nodes in the ring
	GetAllNodes() []*ring.NodeInfo
	// GetActiveNodes returns all active nodes in the ring
	GetActiveNodes() []*ring.NodeInfo
	// IsLocal returns true if the local node owns the given key
	IsLocal(key string) bool
}

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

type RouterConfig struct {
	// Connection timeout for establishing new connections
	ConnectionTimeout time.Duration
	// Maximum message size for sending (in bytes)
	MaxSendMsgSize int
	// Maximum message size for receiving (in bytes)
	MaxRecvMsgSize int
	// Number of retry attempts for transient failures
	MaxRetries int
	// Initial retry backoff duration
	InitialRetryBackoff time.Duration
	// Maximum retry backoff duration
	MaxRetryBackoff time.Duration
	// Keepalive parameters
	KeepaliveTime    time.Duration // Send keepalive ping every this duration
	KeepaliveTimeout time.Duration // Wait this long for keepalive response
	// Circuit breaker parameters
	CircuitBreakerThreshold int           // Number of consecutive failures to open circuit
	CircuitBreakerTimeout   time.Duration // How long to wait before attempting to close circuit
	// GRPCDialOptions are additional gRPC dial options applied to all outgoing connections.
	// These are appended after the default options (transport credentials, keepalive, message size).
	GRPCDialOptions []grpc.DialOption
}

type RouterError struct {
	Type    error  // The base error type
	NodeID  string // The node that caused the error
	Key     string // The key being routed (if applicable)
	Message string // Additional context
	Cause   error  // The underlying error (if any)
}