Struct ObserveRunsRequest 

pub struct ObserveRunsRequest {
    pub spool: Option<SpoolRef>,
    pub threads: Vec<ThreadRef>,
    pub runs: Vec<RecordRef>,
    pub include_timeline: bool,
    pub page: Option<PageRequest>,
    pub observe: Option<ObserveOptions>,
    pub timeline_start: i32,
    pub timeline_limit: u32,
}

Fields

spool: Option<SpoolRef>

threads: Vec<ThreadRef>

runs: Vec<RecordRef>

include_timeline: bool

page: Option<PageRequest>

observe: Option<ObserveOptions>

timeline_start: i32

LATEST requires include_timeline, exactly one run in runs, FOLLOW (or the default mode), a positive timeline_limit, and no page request. The initial snapshot includes the selected RunRecord and policy, when present, plus at most timeline_limit records, ordered by position from oldest to newest. Its PageInfo is exhausted with an empty next_page when the selection fits. When mandatory run/policy and each whole timeline record fit, budget-limited snapshots return timeline PARTIAL with an empty next_page and page.exhausted=false. The checkpoint cursor retains the fixed initial latest-N lower/upper boundary and last delivered position. The first snapshot_complete=true commits staging, not completeness of coverage. Deliver the fixed remainder in bounded UPSERT batches on this stream or after resume, before following newer positions. The last remainder batch has timeline COMPLETE, page.exhausted=true and empty next_page, then a checkpoint. Charge all remainder payloads/statuses/checkpoints to budget. Impossible fixed request/control overhead (including the terminal-failure reserve in ReadBudget) is INVALID_ARGUMENT before matching. ObserveRuns has no guaranteed whole-record bound: after authorization/projection, a RunRecord, RunPolicy or TimelineRecord that cannot fit an empty legal batch with controls, or a mandatory initial run/policy set that cannot fit the initial snapshot, ends with CallFailure RESOURCE_EXHAUSTED, message exactly “indivisible result exceeds read budget”, no ErrorDetail or retry hint. Apply this in default/LATEST mode, initial/resumed/live batches; charge the reserved failure item/bytes. Discard uncommitted staging and keep only the last committed cursor. Never omit pending permissions/policy, truncate exact intent bytes or loop PARTIAL/Reset. Same-budget automatic retries are forbidden. Default UNSPECIFIED retains oldest-first paging and WindowChanged resets when a non-exhausted page changes. In LATEST, new positions append after the fixed initial selection; they MUST NOT trigger WindowChanged merely because more than timeline_limit records now exist. A genuine loss of continuity or removal may still reset the stream.

timeline_limit: u32

Number of latest timeline records to include in the initial snapshot. Valid only with timeline_start = TIMELINE_START_LATEST; otherwise zero.

ObserveOptions.after_cursor is a stream resume cursor, never a page token. It is bound to timeline_start, timeline_limit and the run filter. Successful after_cursor resume delivers the retained initial remainder before following later positions, without selecting a new latest N; if replay or the fixed boundary/remainder is unavailable, or a genuine removal loses continuity, the server sends a terminal reset. Recheck live authorization at each handoff. The client reconnects without after_cursor to start a replacement latest snapshot. PageRequest.after_page is invalid in LATEST mode.

Implementations

impl ObserveRunsRequest

pub fn timeline_start(&self) -> TimelineStart

Returns the enum value of timeline_start, or the default if the field is set to an invalid enum value.

pub fn set_timeline_start(&mut self, value: TimelineStart)

Sets timeline_start to the provided enum value.

Trait Implementations

impl Clone for ObserveRunsRequest

fn clone(&self) -> ObserveRunsRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ObserveRunsRequest

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

Formats the value using the given formatter.

impl Default for ObserveRunsRequest

fn default() -> ObserveRunsRequest

Returns the “default value” for a type.

impl Message for ObserveRunsRequest

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message to a buffer.

fn encode_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message to a newly allocated buffer.

fn encode_length_delimited( &self, buf: &mut impl BufMut, ) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message with a length-delimiter to a buffer.

fn encode_length_delimited_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message with a length-delimiter to a newly allocated buffer.

fn decode(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes an instance of the message from a buffer.

fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes a length-delimited instance of the message from the buffer.

fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl ObservationRequest for ObserveRunsRequest

fn options_mut(&mut self) -> &mut ObserveOptions

impl PartialEq for ObserveRunsRequest

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ObserveRunsRequest