Struct AgentServer

Source

pub struct AgentServer<H, S> { /* private fields */ }

Expand description

Per-agent server that manages one agent’s serving lifecycle.

Implementations§

Source §

impl<H, S> AgentServer<H, S>
where H: AsyncMessageHandler + Clone + Send + Sync + 'static, S: AsyncTaskLifecycle + AsyncTaskQuery + AsyncNotificationManager + Clone + Send + Sync + 'static,

Source

pub fn new(config: AgentConfig, handler: Arc<H>, storage: Arc<S>) -> Self

Create a new agent server.

Source

pub fn with_streaming(self, streaming: Arc<dyn AsyncStreamingHandler>) -> Self

Attach a shared streaming backend.

Pass the same AsyncStreamingHandler instance the message handler broadcasts to (clones of an InMemoryStreamingHandler share their subscriber registry). The runtime injects it into the transport adapter so tasks/subscribe SSE streams observe those broadcasts.

Source

pub async fn start_http(&self) -> Result<(), ServerError>

Start HTTP server

Source

pub async fn run(self) -> Result<(), ServerError>

Start the appropriate server(s) based on configuration

Auto Trait Implementations§

§

impl<H, S> UnsafeUnpin for AgentServer<H, S>
where Arc<H>: UnsafeUnpin, Arc<S>: UnsafeUnpin,

Blanket Implementations§

Source §

impl<T> Any for T
where T: 'static + ?Sized,

Source §

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

Source §

impl<T> Borrow<T> for T
where T: ?Sized,

Source §

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

Source §

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source §

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

Source §

impl<T> From<T> for T

Source §

fn from(t: T) -> T

Returns the argument unchanged.

Source §

impl<T> Instrument for T

Source §

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

Source §

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

Source §

impl<T, U> Into for T
where U: From<T>,

Source §

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source §

impl<T> IntoEither for T

Source §

fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more

Source §

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more

Source §

impl<T> PolicyExt for T
where T: ?Sized,

Source §

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more

Source §

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more

Source §

impl<T> Same for T

Source §

type Output = T

Should always be Self

Source §

impl<T, U> TryFrom for T
where U: Into<T>,

Source §

type Error = !

The type returned in the event of a conversion error.

Source §

fn try_from(value: U) -> Result<T, !>

Performs the conversion.

Source §

impl<T, U> TryInto for T
where U: TryFrom<T>,

Source §

type Error = >::Error

The type returned in the event of a conversion error.

Source §

fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

Source §

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source §

fn vzip(self) -> V

Source §

impl<T> WithSubscriber for T

Source §

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

Source §

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

AgentServer

Struct AgentServer Copy item path

Implementations§

impl<H, S> AgentServer<H, S>where H: AsyncMessageHandler + Clone + Send + Sync + 'static, S: AsyncTaskLifecycle + AsyncTaskQuery + AsyncNotificationManager + Clone + Send + Sync + 'static,

pub fn new(config: AgentConfig, handler: Arc<H>, storage: Arc<S>) -> Self

pub fn with_streaming(self, streaming: Arc<dyn AsyncStreamingHandler>) -> Self

pub async fn start_http(&self) -> Result<(), ServerError>

pub async fn run(self) -> Result<(), ServerError>

Auto Trait Implementations§

impl<H, S> !RefUnwindSafe for AgentServer<H, S>

impl<H, S> !UnwindSafe for AgentServer<H, S>

impl<H, S> Freeze for AgentServer<H, S>where Arc<H>: Freeze, Arc<S>: Freeze,

impl<H, S> Send for AgentServer<H, S>where Arc<H>: Send, Arc<S>: Send,

impl<H, S> Sync for AgentServer<H, S>where Arc<H>: Sync, Arc<S>: Sync,

impl<H, S> Unpin for AgentServer<H, S>where Arc<H>: Unpin, Arc<S>: Unpin,

impl<H, S> UnsafeUnpin for AgentServer<H, S>where Arc<H>: UnsafeUnpin, Arc<S>: UnsafeUnpin,

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

fn in_current_span(self) -> Instrumented<Self> ⓘ

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘwhere F: FnOnce(&Self) -> bool,

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = !

fn try_from(value: U) -> Result<T, !>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘwhere S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Struct AgentServer

impl<H, S> AgentServer<H, S>
where H: AsyncMessageHandler + Clone + Send + Sync + 'static, S: AsyncTaskLifecycle + AsyncTaskQuery + AsyncNotificationManager + Clone + Send + Sync + 'static,

impl<H, S> Freeze for AgentServer<H, S>
where Arc<H>: Freeze, Arc<S>: Freeze,

impl<H, S> Send for AgentServer<H, S>
where Arc<H>: Send, Arc<S>: Send,

impl<H, S> Sync for AgentServer<H, S>
where Arc<H>: Sync, Arc<S>: Sync,

impl<H, S> Unpin for AgentServer<H, S>
where Arc<H>: Unpin, Arc<S>: Unpin,

impl<H, S> UnsafeUnpin for AgentServer<H, S>
where Arc<H>: UnsafeUnpin, Arc<S>: UnsafeUnpin,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
where F: FnOnce(&Self) -> bool,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,