Enum ProjectedQueryOutcome 

pub enum ProjectedQueryOutcome {
    Ready {
        fields: Vec<String>,
        primary_key_fields: Vec<String>,
        rows: Vec<ProjectedReadyRow>,
        frontier: ProjectionFrontier,
        head: ProjectionFrontier,
        commit_token: Option<CommitToken>,
    },
    ReadyAggregates {
        group_key_fields: Vec<String>,
        aggregates: Vec<ProjectedAggregate>,
        groups: Vec<ProjectedAggregateGroup>,
        frontier: ProjectionFrontier,
        head: ProjectionFrontier,
        commit_token: Option<CommitToken>,
    },
    Lagging {
        required: ProjectionFrontier,
        current: ProjectionFrontier,
        head: ProjectionFrontier,
        lag_sequences: Option<u64>,
        retry_after: Option<Duration>,
    },
    Building {
        applied_through: ProjectionFrontier,
        head: ProjectionFrontier,
    },
    Rebuilding {
        reason: ProjectedRebuildingReason,
        progress_applied: u64,
        progress_total: u64,
    },
    Degraded {
        reason: ProjectedDegradedReason,
        current: ProjectionFrontier,
    },
    Invalid {
        expected_fingerprint: Vec<u8>,
        found_fingerprint: Vec<u8>,
    },
}

Typed projected-query outcome mirroring the wire oneof arms.

Variants

Ready

Published snapshot under the requested freshness policy.

The select/primary-key split depends on the requested encoding, because the row-oriented wire arm carries no separate primary-key vector:

• ProjectedResponseEncoding::Packed — fields are exactly the selected projected fields, primary_key_fields are the entity primary-key components, and each row’s cells/primary_key align with them respectively.
• ProjectedResponseEncoding::Row — primary_key_fields is always empty and every row’s primary_key is empty. Primary-key names that were not selected are appended by the server to fields, so they arrive as trailing cells. Request Packed when the split matters.

Fields

fields: Vec<String>

Projected field names in wire order for each row’s cells.

Under Row encoding this also carries non-selected primary-key names appended after the selected fields.

primary_key_fields: Vec<String>

Entity primary-key field names aligned with each row’s primary_key.

Always empty under Row encoding (see the variant documentation).

rows: Vec<ProjectedReadyRow>

Matching rows (primary_key empty under Row encoding).

frontier: ProjectionFrontier

Served projection frontier.

head: ProjectionFrontier

Application head known at serve time.

commit_token: Option<CommitToken>

Commit token corresponding to the served frontier when sequenced.

ReadyAggregates

Published snapshot answering an aggregate or grouped request.

Answers every request carrying at least one ProjectedAggregate, grouped or not; a whole-set aggregate arrives as exactly one group with an empty keys list. The requested ProjectedResponseEncoding does not apply to this shape.

groups is in the server’s deterministic canonical value order over the group keys (or the requested group-key order with canonical ascending tie-breaking).

Fields

group_key_fields: Vec<String>

Group key field names; column order for every group’s keys.

aggregates: Vec<ProjectedAggregate>

The request’s aggregate functions echoed back; column order for every group’s values.

groups: Vec<ProjectedAggregateGroup>

Groups in server order.

frontier: ProjectionFrontier

Served projection frontier.

head: ProjectionFrontier

Application head known at serve time.

commit_token: Option<CommitToken>

Commit token corresponding to the served frontier when sequenced.

Lagging

Freshness policy not yet satisfied.

Fields

required: ProjectionFrontier

Required frontier derived from the causal token or bounded policy.

current: ProjectionFrontier

Current projection frontier.

head: ProjectionFrontier

Application head.

lag_sequences: Option<u64>

Sequence distance backlog when both are sequenced.

retry_after: Option<Duration>

Optional retry hint.

Building

Catch-up before first publication.

Fields

applied_through: ProjectionFrontier

Processed position during catch-up.

head: ProjectionFrontier

Known application head.

Rebuilding

Rebuild in progress.

Fields

reason: ProjectedRebuildingReason

Closed reason code.

progress_applied: u64

Progress numerator.

progress_total: u64

Progress denominator (0 = unknown).

Degraded

Degraded health while still identified.

Fields

reason: ProjectedDegradedReason

Closed reason code.

current: ProjectionFrontier

Current frontier while degraded.

Invalid

Durable definition fingerprint mismatch.

Fields

expected_fingerprint: Vec<u8>

Fingerprint expected by the registered definition.

found_fingerprint: Vec<u8>

Fingerprint found in durable state.

Trait Implementations

impl Clone for ProjectedQueryOutcome

fn clone(&self) -> ProjectedQueryOutcome

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ProjectedQueryOutcome

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Eq for ProjectedQueryOutcome

impl PartialEq for ProjectedQueryOutcome

fn eq(&self, other: &ProjectedQueryOutcome) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for ProjectedQueryOutcome