federation

type Config struct {
	Mode     string        // federation-level mode: sync | publish | subscribe
	Peers    []PeerConfig  `yaml:"peers,omitempty"`
	Interval time.Duration // parsed from string

	// SharedKey is the MCP bearer token this syncer attaches to every
	// outbound request as "Authorization: Bearer <SharedKey>". Empty
	// means open mode (no header sent). Populated at startup from
	// cortex.LoadAccessKey; never surfaced in YAML, logs, or events.
	SharedKey string `yaml:"-"`
}

type EventReplayer interface {
	ReplayEvent(event.Event) error
	MergeClock(VClock) error
}

type PeerConfig struct {
	Name     string `yaml:"name"`
	Endpoint string `yaml:"endpoint"`
	CA       string `yaml:"ca,omitempty"`   // path to CA certificate for TLS verification
	Mode     string `yaml:"mode,omitempty"` // sync | paused
}

type PeerError struct {
	// Reason is one of the Reason* constants below.
	Reason string `json:"reason"`
	// EventID is the ULID of the event that failed to replay, if
	// applicable. Empty for failures that occurred before any event
	// was fetched.
	EventID string `json:"event_id,omitempty"`
	// TraceID is the trace ID carried by the failing event, if any.
	// Derived from titles via slugification but already exposed
	// elsewhere in federation_state (peer cursors index the event
	// log), so storing it here adds no new attack surface.
	TraceID string `json:"trace_id,omitempty"`
	// ObservedAt is the RFC3339 timestamp when the failure happened.
	ObservedAt string `json:"observed_at"`
}

type PeerHealth struct {
	// Version is the peer's binary version advertised via MCP
	// initialize (serverInfo.Version). Updated on every successful
	// connection, left blank until first contact.
	Version string `json:"version,omitempty"`

	// VersionObservedAt is the RFC3339 timestamp of the most recent
	// successful MCP initialize where the peer reported Version.
	VersionObservedAt string `json:"version_observed_at,omitempty"`

	// LastSuccess is the RFC3339 timestamp of the most recent poll
	// iteration that completed without any error (connect, identity
	// check, fetch, and replay all succeeded).
	LastSuccess string `json:"last_success,omitempty"`

	// ConsecutiveFailures counts poll iterations since the last
	// success that produced any error. Zero when the last poll
	// succeeded.
	ConsecutiveFailures int `json:"consecutive_failures,omitempty"`

	// LastError is present when the most recent poll failed. Absent
	// when LastSuccess is newer than the last failure.
	LastError *PeerError `json:"last_error,omitempty"`
}

type PeerState struct {
	Name      string
	Endpoint  string
	LastSeen  string // RFC3339, "" if never reached
	LastEvent string // ULID of last synced event, "" if never synced
	CortexID  string // pinned ULID after first successful identity handshake
	Health    PeerHealth
}

type PollError struct {
	Reason  string
	EventID string
	TraceID string
	Err     error
}

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

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

type VClock map[string]uint64