Struct backend::pool::PulsarMq

pub struct PulsarMq(_);

Pulsar Connection Pool

Trait Implementations

impl Database for PulsarMq

type Pool = PulsarProducerPool

The Pool type of connections to this database.

const NAME: &'static str

The configuration name for this database.

fn init() -> Initializer<Self>

Returns a fairing that initializes the database and its connection pool.

fn fetch<P>(rocket: &Rocket<P>) -> Option<&Self> where
    P: Phase, 

Returns a reference to the initialized database in rocket. The initializer fairing returned by init() must have already executed for Option to be Some. This is guaranteed to be the case if the fairing is attached and either:

impl Deref for PulsarMq

type Target = PulsarProducerPool

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for PulsarMq

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl From<PulsarProducerPool> for PulsarMq

fn from(pool: PulsarProducerPool) -> Self

Performs the conversion.

impl<'r> FromRequest<'r> for &'r PulsarMq

type Error = ()

The associated error to be returned if derivation fails.

fn from_request<'life0, 'async_trait>(
    req: &'r Request<'life0>
) -> Pin<Box<dyn Future<Output = Outcome<Self, Self::Error>> + Send + 'async_trait>> where
    'r: 'async_trait,
    'life0: 'async_trait,
    Self: 'async_trait, 

Derives an instance of Self from the incoming request metadata.

impl Sentinel for &PulsarMq

fn abort(rocket: &Rocket<Ignite>) -> bool

Returns true if launch should be aborted and false otherwise.