pub struct LlmStreamCallExecuteParams {
pub name: String,
pub request: LlmRequest,
pub func: LlmStreamExecutionNextFn,
pub collector: LlmCollectorFn,
pub finalizer: LlmFinalizerFn,
pub parent: Option<ScopeHandle>,
pub attributes: LlmAttributes,
pub data: Option<Json>,
pub metadata: Option<Json>,
pub model_name: Option<String>,
pub codec: Option<Arc<dyn LlmCodec>>,
pub response_codec: Option<Arc<dyn LlmResponseCodec>>,
}Expand description
Builder parameters for llm_stream_call_execute.
Fields§
§name: StringLogical provider or model family name recorded on emitted events.
request: LlmRequestRaw request passed into the managed pipeline.
func: LlmStreamExecutionNextFnStreaming provider callback or execution continuation.
collector: LlmCollectorFnPer-chunk collector callback used to accumulate stream state.
finalizer: LlmFinalizerFnFinalizer callback used to construct the completed response.
parent: Option<ScopeHandle>Optional explicit parent scope for the emitted LLM span.
attributes: LlmAttributesLLM attribute bitflags applied to the managed span.
data: Option<Json>Optional application payload stored on the handle but not emitted as Agent Trajectory Observability Format (ATOF) data.
metadata: Option<Json>Optional JSON metadata recorded on emitted events.
model_name: Option<String>Optional normalized model name for observability output.
codec: Option<Arc<dyn LlmCodec>>Optional request codec used to produce annotated request data.
response_codec: Option<Arc<dyn LlmResponseCodec>>Optional response codec used to attach annotated response data.
Implementations§
Source§impl LlmStreamCallExecuteParams
impl LlmStreamCallExecuteParams
Sourcepub fn builder() -> LlmStreamCallExecuteParamsBuilder<((), (), (), (), (), (), (), (), (), (), (), ())>
pub fn builder() -> LlmStreamCallExecuteParamsBuilder<((), (), (), (), (), (), (), (), (), (), (), ())>
Create a builder for building LlmStreamCallExecuteParams.
On the builder, call .name(...), .request(...), .func(...), .collector(...), .finalizer(...), .parent(...)(optional), .attributes(...)(optional), .data(...)(optional), .metadata(...)(optional), .model_name(...)(optional), .codec(...)(optional), .response_codec(...)(optional) to set the values of the fields.
Finally, call .build() to create the instance of LlmStreamCallExecuteParams.
Auto Trait Implementations§
impl Freeze for LlmStreamCallExecuteParams
impl !RefUnwindSafe for LlmStreamCallExecuteParams
impl Send for LlmStreamCallExecuteParams
impl !Sync for LlmStreamCallExecuteParams
impl Unpin for LlmStreamCallExecuteParams
impl UnsafeUnpin for LlmStreamCallExecuteParams
impl !UnwindSafe for LlmStreamCallExecuteParams
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
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§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>
T in a tonic::Request