discovery

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

type AWSOption func(*AWSDiscovery)

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

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

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

type Discovery interface {
	// DiscoverPeers returns list of discovered peers with reachability status.
	// For static discovery: validates configured peer list
	// For cloud discovery (future): queries metadata service
	DiscoverPeers(ctx context.Context) (*DiscoveryResult, error)
}

type DiscoveryResult struct {
	// Peers is the list of discovered peers with reachability status
	Peers []PeerInfo

	// SingleNode is true when no peers are configured (single-node deployment)
	SingleNode bool

	// ReachableCount is the number of reachable peers
	ReachableCount int

	// TotalCount is the total number of peers discovered
	TotalCount int
}

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

type Option func(*StaticDiscovery)

type PeerInfo struct {
	// Address is the peer address in "host:port" format
	Address string

	// Reachable indicates if TCP dial succeeded
	Reachable bool

	// Latency is the RTT for successful dial
	Latency time.Duration

	// Error contains the error if unreachable
	Error error
}

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