pub struct ChannelSizes {
pub rag_to_assemble: Option<usize>,
pub assemble_to_inference: Option<usize>,
pub inference_to_post: Option<usize>,
pub post_to_stream: Option<usize>,
pub stream_output: Option<usize>,
}Expand description
Per-channel capacity overrides for the five inter-stage pipeline channels.
All fields are optional; when absent the stage default is used (512, 512, 1024, 512, 256 respectively).
§Panics
This type never panics.
Fields§
§rag_to_assemble: Option<usize>Capacity of the RAG → Assemble channel (default: 512).
assemble_to_inference: Option<usize>Capacity of the Assemble → Inference channel (default: 512).
inference_to_post: Option<usize>Capacity of the Inference → Post channel (default: 1024).
post_to_stream: Option<usize>Capacity of the Post → Stream channel (default: 512).
stream_output: Option<usize>Capacity of the Stream output channel (default: 256).
Trait Implementations§
Source§impl Clone for ChannelSizes
impl Clone for ChannelSizes
Source§fn clone(&self) -> ChannelSizes
fn clone(&self) -> ChannelSizes
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for ChannelSizes
impl Debug for ChannelSizes
Source§impl<'de> Deserialize<'de> for ChannelSizes
impl<'de> Deserialize<'de> for ChannelSizes
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl PartialEq for ChannelSizes
impl PartialEq for ChannelSizes
Source§fn eq(&self, other: &ChannelSizes) -> bool
fn eq(&self, other: &ChannelSizes) -> bool
Tests for
self and other values to be equal, and is used by ==.Source§impl Serialize for ChannelSizes
impl Serialize for ChannelSizes
impl StructuralPartialEq for ChannelSizes
Auto Trait Implementations§
impl Freeze for ChannelSizes
impl RefUnwindSafe for ChannelSizes
impl Send for ChannelSizes
impl Sync for ChannelSizes
impl Unpin for ChannelSizes
impl UnsafeUnpin for ChannelSizes
impl UnwindSafe for ChannelSizes
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request