discovery

type Config struct {
	DiscoveryInterval time.Duration
	MaxConnections    int
}

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

type MetadataProvider interface {
	ProvideMetadata() *RQLiteNodeMetadata
}

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

type NamespaceStatus struct {
	Name   string `json:"name"`
	Status string `json:"status"` // "healthy", "degraded", "recovering"
}

type PeerExchangeRequest struct {
	Limit int `json:"limit"`
}

type PeerExchangeResponse struct {
	Peers          []PeerInfo          `json:"peers"`
	RQLiteMetadata *RQLiteNodeMetadata `json:"rqlite_metadata,omitempty"`
}

type PeerExchangeResponseV2 struct {
	Peers          []PeerInfo          `json:"peers"`
	RQLiteMetadata *RQLiteNodeMetadata `json:"rqlite_metadata,omitempty"`
}

type PeerInfo struct {
	ID    string   `json:"id"`
	Addrs []string `json:"addrs"`
}

type RQLiteNodeMetadata struct {
	NodeID         string    `json:"node_id"`         // RQLite node ID (raft address)
	RaftAddress    string    `json:"raft_address"`    // Raft port address (e.g., "10.0.0.1:7001")
	HTTPAddress    string    `json:"http_address"`    // HTTP API address (e.g., "10.0.0.1:5001")
	NodeType       string    `json:"node_type"`       // Node type identifier
	RaftLogIndex   uint64    `json:"raft_log_index"`  // Current Raft log index (for data comparison)
	LastSeen       time.Time `json:"last_seen"`       // Updated on every announcement
	ClusterVersion string    `json:"cluster_version"` // For compatibility checking

	// PeerID is the LibP2P peer ID of the node. Used for metadata authentication:
	// on receipt, the receiver verifies PeerID == stream sender to prevent spoofing.
	PeerID string `json:"peer_id,omitempty"`

	// WireGuardIP is the node's WireGuard VPN address (e.g., "10.0.0.1").
	WireGuardIP string `json:"wireguard_ip,omitempty"`

	// LifecycleState is the node's current lifecycle state:
	// "joining", "active", "draining", or "maintenance".
	// Zero value (empty string) from old nodes is treated as "active".
	LifecycleState string `json:"lifecycle_state,omitempty"`

	// MaintenanceTTL is the time at which maintenance mode expires.
	// Only meaningful when LifecycleState == "maintenance".
	MaintenanceTTL time.Time `json:"maintenance_ttl,omitempty"`

	// Services reports the status of each service running on the node.
	Services map[string]*ServiceStatus `json:"services,omitempty"`

	// Namespaces reports the status of each namespace on the node.
	Namespaces map[string]*NamespaceStatus `json:"namespaces,omitempty"`

	// BinaryVersion is the node's binary version string (e.g., "1.2.3").
	BinaryVersion string `json:"binary_version,omitempty"`
}

type ServiceStatus struct {
	Name    string `json:"name"`              // e.g. "rqlite", "gateway", "olric"
	Running bool   `json:"running"`           // whether the process is up
	Healthy bool   `json:"healthy"`           // whether it passed its health check
	Message string `json:"message,omitempty"` // optional detail ("leader", "follower", etc.)
}