pub struct CoreRegistry { /* private fields */ }Implementations§
Source§impl CoreRegistry
impl CoreRegistry
pub fn new() -> Self
pub fn register(&mut self, name: &str, factory: ActorFactory)
pub fn normal_metadata_payload( &self, config: &ServeConfig, ) -> ServerlessMetadataPayload
pub fn serverless_metadata_payload( &self, config: &ServeConfig, ) -> ServerlessMetadataPayload
pub async fn serve(self, shutdown: CancellationToken) -> Result<()>
pub async fn serve_with_config( self, config: ServeConfig, shutdown: CancellationToken, ) -> Result<()>
pub async fn serve_with_config_and_handle_observer( self, config: ServeConfig, shutdown: CancellationToken, on_handle: impl FnOnce(CoreEnvoyHandle) + Send + 'static, ) -> Result<()>
pub async fn into_serverless_runtime( self, config: ServeConfig, ) -> Result<CoreServerlessRuntime>
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for CoreRegistry
impl !UnwindSafe for CoreRegistry
impl Freeze for CoreRegistry
impl Send for CoreRegistry
impl Sync for CoreRegistry
impl Unpin for CoreRegistry
impl UnsafeUnpin for CoreRegistry
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<T> ErasedDestructor for Twhere
T: 'static,
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>
Wrap the input message
T in a tonic::Request