ovnstatus

type ClusterServer struct {
	SID        string `json:"sid,omitempty"`
	Address    string `json:"address,omitempty"`
	Role       string `json:"role,omitempty"`
	Self       bool   `json:"self,omitempty"`
	Connected  bool   `json:"connected,omitempty"`
	LastMsgMs  *int64 `json:"lastMsgMs,omitempty"`
	NextIndex  *int64 `json:"nextIndex,omitempty"`  // NEW
	MatchIndex *int64 `json:"matchIndex,omitempty"` // NEW
}

type ClusterStatus struct {
	Name      string          `json:"name,omitempty"`
	Role      string          `json:"role,omitempty"` // leader/follower (local)
	Term      int64           `json:"term,omitempty"`
	Index     int64           `json:"index,omitempty"`
	Connected bool            `json:"connected,omitempty"`
	Servers   []ClusterServer `json:"servers,omitempty"`
}

type ConsensusResult struct {
	AllAgree        bool                // true if all views are identical
	HasMajority     bool                // true if some view is held by >= quorum
	QuorumSize      int                 // floor(n/2)+1
	MajorityKey     string              // canonical key of the majority view (if any)
	MajorityMembers []string            // SIDs of reporters in the majority
	MinorityMembers []string            // SIDs of reporters not in the majority
	TruthView       MemberView          // the majority's canonical view (if HasMajority); empty otherwise
	Diffs           map[string]ViewDiff // per-reporter diffs vs TruthView (only meaningful if HasMajority)
}

type DB string

type ExtendedConsensusResult struct {
	ConsensusResult

	// Union across all views (what anyone reported).
	UnionMembers []string // SIDs (sorted)
	UnionIPs     []string // IPs  (sorted)

	// Reporters (SIDs that produced a HealthSnapshot / self-view).
	Reporters []string // SIDs (sorted)

	// Members that appear in UnionMembers but for which we have no reporter snapshot.
	MissingReporters []string // SIDs (sorted)

	// IPs seen in union but NOT in hints.ExpectedIPs (if provided).
	UnexpectedIPs []string // sorted

	// Expected IPs that did NOT appear anywhere in union.
	MissingExpectedIPs []string // sorted

	// Size checks; MembersCount is distinct SIDs; DistinctIPCount is distinct IPs.
	MembersCount      int
	DistinctIPCount   int
	TooManyMembers    bool // MembersCount > ExpectedReplicas
	TooFewMembers     bool // MembersCount < ExpectedReplicas
	ExpectedShortfall int  // ExpectedReplicas - MembersCount (>=0)
	ExpectedExcess    int  // MembersCount - ExpectedReplicas (>=0)

	// IPConflicts: an IP mapped to multiple SIDs (shouldn’t happen if identity is clean).
	IPConflicts map[string][]string // ip -> []sids

	// SIDAddressDisagreements: number of distinct addresses observed for a SID.
	SIDAddressDisagreements map[string]int // sid -> count(address variants)

	// Suspect stale SIDs: candidates to kick (heuristic, IP-focused).
	// Ranked by: (1) IP not expected, (2) not self-reporting, (3) lowest reference count.
	SuspectStaleSIDs []string // sorted by suspicion
}

type HealthSnapshot struct {
	DB    DB
	Local ServerLocalView
	Full  ClusterStatus
}

type Hints struct {
	// ExpectedReplicas, if >0, is the intended cluster size; if 0 and ExpectedIPs provided,
	// we derive ExpectedReplicas = len(ExpectedIPs).
	ExpectedReplicas int

	// ExpectedIPs is the set of node IPs you expect to participate (unique per member).
	// Optional label can be a pod/node name for reporting (empty string is fine).
	ExpectedIPs map[string]string // ip -> label
}

type MemberView struct {
	FromSID     string            // the reporter's SID (hs.Local.SID)
	FromAddress string            // best-effort: address of self from Servers (if present)
	Members     map[string]string // SID -> Address (as reported by this member)
}

type OVNClient struct {
	// Paths to local control sockets.
	NBCTLPath string // e.g., /var/run/ovn/ovnnb_db.ctl
	SBCTLPath string // e.g., /var/run/ovn/ovnsb_db.ctl
	NBDBSock  string // tcp:127.0.0.1:6641, unix:/var/run/ovn/ovnnb_db.sock, etc
	SBDBSock  string // tcp:127.0.0.1:6642, unix:/var/run/ovn/ovnsb_db.sock, etc

	// TLS for ovsdb-client (used for _Server queries). ovn-appctl uses ctl socket, no TLS needed.
	UseSSL bool
	Key    string
	Cert   string
	CACert string

	FreshLastMsgThreshold time.Duration
	// Optional expected replica count for stale-member checks.
	ExpectedReplicas int

	// Runner is the pluggable command runner. If nil, a default runner is used.
	Runner RunnerFunc
}

type RunnerFunc func(ctx context.Context, bin string, args ...string) (string, error)

type ServerLocalView struct {
	Leader    bool   `json:"leader"`
	Connected bool   `json:"connected"`
	CID       string `json:"cid"` // cluster UUID
	SID       string `json:"sid"` // this server UUID
	Index     int64  `json:"index"`
}

type ViewDiff struct {
	MissingSIDs       []string             // SIDs absent in this view but present in truth
	ExtraSIDs         []string             // SIDs present in this view but absent in truth
	AddressMismatches map[string][2]string // SID -> [truthAddr, thisAddr] when both have SID but addresses differ
}