Interface ICorrelationTracker

Interface for correlation tracking between agents.

interface ICorrelationTracker {
    recordVote(
        agentId: string,
        vote: {
            decision: "approve" | "reject" | "abstain";
            reasoning: string;
            confidence: number;
            conditions?: string[];
            rejectionCategories?: (
                | "YAGNI"
                | "DRY_VIOLATION"
                | "OVER_ENGINEERING"
                | "SCOPE_CREEP"
                | "SECURITY_RISK"
                | "MISALIGNED"
                | "INSUFFICIENT_EVIDENCE"
            )[];
            findings?: {
                summary: string;
                location: string;
                severity: "low"
                | "medium"
                | "high"
                | "critical";
                gate: {
                    reread_cited_line: "failed" | "skipped" | "passed";
                    traced_call_path: "failed" | "skipped" | "passed";
                    named_assertion: string;
                    ruled_out_language_non_issue: "failed" | "skipped" | "passed";
                };
                claim: string;
            }[];
            timestamp?: string;
        },
        outcome: "rejected" | "approved",
    ): void;
    recordProposalVotes(
        proposalId: string,
        votes: ReadonlyMap<
            string,
            {
                decision: "approve"
                | "reject"
                | "abstain";
                reasoning: string;
                confidence: number;
                conditions?: string[];
                rejectionCategories?: (
                    | "YAGNI"
                    | "DRY_VIOLATION"
                    | "OVER_ENGINEERING"
                    | "SCOPE_CREEP"
                    | "SECURITY_RISK"
                    | "MISALIGNED"
                    | "INSUFFICIENT_EVIDENCE"
                )[];
                findings?: {
                    summary: string;
                    location: string;
                    severity: "low"
                    | "medium"
                    | "high"
                    | "critical";
                    gate: {
                        reread_cited_line: "failed" | "skipped" | "passed";
                        traced_call_path: "failed" | "skipped" | "passed";
                        named_assertion: string;
                        ruled_out_language_non_issue: "failed" | "skipped" | "passed";
                    };
                    claim: string;
                }[];
                timestamp?: string;
            },
        >,
        outcome: "rejected" | "approved",
    ): void;
    computeCorrelationMatrix(): CorrelationMatrix;
    getCorrelation(agentA: string, agentB: string): number | undefined;
    identifyIndependentSubsets(): readonly IndependentSubset[];
    hasSufficientData(agentIds: readonly string[]): boolean;
    getStats(): CorrelationTrackerStats;
    clear(): void;
}

Implemented by

CorrelationTracker

Index

Methods

recordVote recordProposalVotes computeCorrelationMatrix getCorrelation identifyIndependentSubsets hasSufficientData getStats clear

Methods

recordVote

recordVote(
    agentId: string,
    vote: {
        decision: "approve" | "reject" | "abstain";
        reasoning: string;
        confidence: number;
        conditions?: string[];
        rejectionCategories?: (
            | "YAGNI"
            | "DRY_VIOLATION"
            | "OVER_ENGINEERING"
            | "SCOPE_CREEP"
            | "SECURITY_RISK"
            | "MISALIGNED"
            | "INSUFFICIENT_EVIDENCE"
        )[];
        findings?: {
            summary: string;
            location: string;
            severity: "low"
            | "medium"
            | "high"
            | "critical";
            gate: {
                reread_cited_line: "failed" | "skipped" | "passed";
                traced_call_path: "failed" | "skipped" | "passed";
                named_assertion: string;
                ruled_out_language_non_issue: "failed" | "skipped" | "passed";
            };
            claim: string;
        }[];
        timestamp?: string;
    },
    outcome: "rejected" | "approved",
): void
Record a vote and its outcome for correlation tracking.
Parameters
- agentId: string
- vote: {
      decision: "approve" | "reject" | "abstain";
      reasoning: string;
      confidence: number;
      conditions?: string[];
      rejectionCategories?: (
          | "YAGNI"
          | "DRY_VIOLATION"
          | "OVER_ENGINEERING"
          | "SCOPE_CREEP"
          | "SECURITY_RISK"
          | "MISALIGNED"
          | "INSUFFICIENT_EVIDENCE"
      )[];
      findings?: {
          summary: string;
          location: string;
          severity: "low"
          | "medium"
          | "high"
          | "critical";
          gate: {
              reread_cited_line: "failed" | "skipped" | "passed";
              traced_call_path: "failed" | "skipped" | "passed";
              named_assertion: string;
              ruled_out_language_non_issue: "failed" | "skipped" | "passed";
          };
          claim: string;
      }[];
      timestamp?: string;
  }
  - decision: "approve" | "reject" | "abstain"
  - reasoning: string
  - confidence: number
  - Optionalconditions?: string[]
  - OptionalrejectionCategories?: (
        | "YAGNI"
        | "DRY_VIOLATION"
        | "OVER_ENGINEERING"
        | "SCOPE_CREEP"
        | "SECURITY_RISK"
        | "MISALIGNED"
        | "INSUFFICIENT_EVIDENCE"
    )[]
    Structured rejection categories for reject→refine→re-vote loops (Issue #1213).
  - Optionalfindings?: {
        summary: string;
        location: string;
        severity: "low" | "medium" | "high" | "critical";
        gate: {
            reread_cited_line: "failed" | "skipped" | "passed";
            traced_call_path: "failed" | "skipped" | "passed";
            named_assertion: string;
            ruled_out_language_non_issue: "failed" | "skipped" | "passed";
        };
        claim: string;
    }[]
    Pre-verified PR-review findings (#2245 v4 follow-up). Optional; populated only when the voter emits the structured top-level array.
  - Optionaltimestamp?: string
- outcome: "rejected" | "approved"
Returns void
- Defined in packages/nexus-agents/src/consensus/higher-order-types.ts:272

recordProposalVotes

recordProposalVotes(
    proposalId: string,
    votes: ReadonlyMap<
        string,
        {
            decision: "approve"
            | "reject"
            | "abstain";
            reasoning: string;
            confidence: number;
            conditions?: string[];
            rejectionCategories?: (
                | "YAGNI"
                | "DRY_VIOLATION"
                | "OVER_ENGINEERING"
                | "SCOPE_CREEP"
                | "SECURITY_RISK"
                | "MISALIGNED"
                | "INSUFFICIENT_EVIDENCE"
            )[];
            findings?: {
                summary: string;
                location: string;
                severity: "low"
                | "medium"
                | "high"
                | "critical";
                gate: {
                    reread_cited_line: "failed" | "skipped" | "passed";
                    traced_call_path: "failed" | "skipped" | "passed";
                    named_assertion: string;
                    ruled_out_language_non_issue: "failed" | "skipped" | "passed";
                };
                claim: string;
            }[];
            timestamp?: string;
        },
    >,
    outcome: "rejected" | "approved",
): void
Record votes from multiple agents for the same proposal.
Parameters
- proposalId: string
- votes: ReadonlyMap<
      string,
      {
          decision: "approve"
          | "reject"
          | "abstain";
          reasoning: string;
          confidence: number;
          conditions?: string[];
          rejectionCategories?: (
              | "YAGNI"
              | "DRY_VIOLATION"
              | "OVER_ENGINEERING"
              | "SCOPE_CREEP"
              | "SECURITY_RISK"
              | "MISALIGNED"
              | "INSUFFICIENT_EVIDENCE"
          )[];
          findings?: {
              summary: string;
              location: string;
              severity: "low"
              | "medium"
              | "high"
              | "critical";
              gate: {
                  reread_cited_line: "failed" | "skipped" | "passed";
                  traced_call_path: "failed" | "skipped" | "passed";
                  named_assertion: string;
                  ruled_out_language_non_issue: "failed" | "skipped" | "passed";
              };
              claim: string;
          }[];
          timestamp?: string;
      },
  >
- outcome: "rejected" | "approved"
Returns void
- Defined in packages/nexus-agents/src/consensus/higher-order-types.ts:277

computeCorrelationMatrix

computeCorrelationMatrix(): CorrelationMatrix
Compute the full correlation matrix for all tracked agents.

Returns CorrelationMatrix
- Defined in packages/nexus-agents/src/consensus/higher-order-types.ts:286

getCorrelation

getCorrelation(agentA: string, agentB: string): number | undefined
Get correlation between two specific agents. Returns undefined if insufficient data.
Parameters
- agentA: string
- agentB: string
Returns number | undefined
- Defined in packages/nexus-agents/src/consensus/higher-order-types.ts:292

identifyIndependentSubsets

identifyIndependentSubsets(): readonly IndependentSubset[]
Identify groups of agents that vote independently.

Returns readonly IndependentSubset[]
- Defined in packages/nexus-agents/src/consensus/higher-order-types.ts:297

hasSufficientData

hasSufficientData(agentIds: readonly string[]): boolean
Check if there is sufficient correlation data for a set of agents.
Parameters
- agentIds: readonly string[]
Returns boolean
- Defined in packages/nexus-agents/src/consensus/higher-order-types.ts:302

getStats

getStats(): CorrelationTrackerStats
Get statistics about the correlation tracker.

Returns CorrelationTrackerStats
- Defined in packages/nexus-agents/src/consensus/higher-order-types.ts:307

clear

clear(): void
Clear all recorded data.

Returns void
- Defined in packages/nexus-agents/src/consensus/higher-order-types.ts:312

Interface ICorrelationTracker

Implemented by

Index

Methods

Methods

recordVote

Parameters

decision: "approve" | "reject" | "abstain"

reasoning: string

confidence: number

`Optional`conditions?: string[]

`Optional`rejectionCategories?: (
    | "YAGNI"
    | "DRY_VIOLATION"
    | "OVER_ENGINEERING"
    | "SCOPE_CREEP"
    | "SECURITY_RISK"
    | "MISALIGNED"
    | "INSUFFICIENT_EVIDENCE"
)[]

`Optional`timestamp?: string

Returns void

recordProposalVotes

Parameters

Returns void

computeCorrelationMatrix

Returns CorrelationMatrix

getCorrelation

Parameters

Returns number | undefined

identifyIndependentSubsets

Returns readonly IndependentSubset[]

hasSufficientData

Parameters

Returns boolean

getStats

Returns CorrelationTrackerStats

clear

Returns void

Settings

On This Page

Interface ICorrelationTracker

Implemented by

Index

Methods

Methods

recordVote

Parameters

decision: "approve" | "reject" | "abstain"

reasoning: string

confidence: number

Optionalconditions?: string[]

OptionalrejectionCategories?: ( | "YAGNI" | "DRY_VIOLATION" | "OVER_ENGINEERING" | "SCOPE_CREEP" | "SECURITY_RISK" | "MISALIGNED" | "INSUFFICIENT_EVIDENCE")[]

Optionaltimestamp?: string

Returns void

recordProposalVotes

Parameters

Returns void

computeCorrelationMatrix

Returns CorrelationMatrix

getCorrelation

Parameters

Returns number | undefined

identifyIndependentSubsets

Returns readonly IndependentSubset[]

hasSufficientData

Parameters

Returns boolean

getStats

Returns CorrelationTrackerStats

clear

Returns void

Settings

On This Page

`Optional`conditions?: string[]

`Optional`rejectionCategories?: (
| "YAGNI"
| "DRY_VIOLATION"
| "OVER_ENGINEERING"
| "SCOPE_CREEP"
| "SECURITY_RISK"
| "MISALIGNED"
| "INSUFFICIENT_EVIDENCE"
)[]

`Optional`timestamp?: string