Struct ContextPipeline 

pub struct ContextPipeline { /* private fields */ }

A dynamic context pipeline that accumulates ContextFrames throughout an AI workflow.

Created when an Intent’s content is first analyzed, seeded with an IntentAnalysis frame. The Plan references this pipeline via pipeline as its context basis. See module documentation for lifecycle position, eviction rules, and purpose.

Implementations

impl ContextPipeline

pub fn new(created_by: ActorRef) -> Result<Self, String>

Create a new empty pipeline.

After creation, seed it with an IntentAnalysis frame, then create a Plan that references this pipeline via pipeline.

pub fn header(&self) -> &Header

pub fn frames(&self) -> &[ContextFrame]

Returns all frames in chronological order.

pub fn max_frames(&self) -> u32

pub fn global_summary(&self) -> Option<&str>

pub fn set_max_frames(&mut self, max_frames: u32)

pub fn set_global_summary(&mut self, summary: Option<String>)

pub fn push_frame(&mut self, kind: FrameKind, summary: impl Into<String>) -> u64

Append a frame, assigning it a stable frame_id.

Returns the assigned frame_id. If max_frames > 0 and the limit is exceeded, the oldest evictable (non-IntentAnalysis, non-Checkpoint) frame is removed to make room. Eviction does not affect the IDs of surviving frames.

pub fn push_frame_raw(&mut self, frame: ContextFrame) -> u64

Append a pre-built frame, overwriting its frame_id with the next monotonic ID. Returns the assigned frame_id.

Use this when you need to set properties (e.g. token_estimate, data) on the frame before pushing.

pub fn frame_by_id(&self, frame_id: u64) -> Option<&ContextFrame>

Look up a frame by its stable frame_id.

Returns None if the frame has been evicted or the ID is invalid.

pub fn active_frames(&self) -> &[ContextFrame]

Returns frames that contribute to the active context window (i.e. all current frames after any eviction has been applied).

pub fn total_token_estimate(&self) -> u64

Total estimated tokens across all frames.

Trait Implementations

impl Clone for ContextPipeline

fn clone(&self) -> ContextPipeline

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ContextPipeline

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ContextPipeline

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for ContextPipeline

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

Formats the value using the given formatter.

impl ObjectTrait for ContextPipeline

fn from_bytes(data: &[u8], _hash: ObjectHash) -> Result<Self, GitError>

where Self: Sized,

Creates a new object from a byte slice.

fn get_type(&self) -> ObjectType

Returns the type of the object.

fn get_size(&self) -> usize

fn to_data(&self) -> Result<Vec<u8>, GitError>

fn from_buf_read<R: BufRead>(read: &mut ReadBoxed<R>, size: usize) -> Self

where Self: Sized,

Generate a new Object from a ReadBoxed<BufRead>. the input size,is only for new a vec with directive space allocation the input data stream and output object should be plain base object .

fn object_hash(&self) -> Result<ObjectHash, GitError>

Computes the object hash from serialized data.

impl Serialize for ContextPipeline

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.