Struct CallbackRuntime 

pub struct CallbackRuntime { /* private fields */ }

Owns the callback queue worker and its graceful-shutdown signal.

Implementations

impl CallbackRuntime

pub fn new( manager: Arc<IntegrationManager>, queue_capacity: usize, ) -> IntegrationResult<Self>

Start a callback worker around an existing integration manager.

pub fn disabled() -> Self

Construct a disabled runtime.

pub fn dispatcher(&self) -> CallbackDispatcher

Obtain the request-path dispatcher.

pub async fn shutdown(self) -> IntegrationResult<()>

Drain pending events, flush integrations, and stop the worker.

Trait Implementations

impl Drop for CallbackRuntime

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.