Trait ftl_protocol::server::IngestServer

pub trait IngestServer {
    fn get_stream_key<'life0, 'life1, 'async_trait>(
        &'life0 self, 
        channel_id: &'life1 str
    ) -> Pin<Box<dyn Future<Output = Result<String, ()>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;
    fn allocate_ingest<'life0, 'life1, 'async_trait>(
        &'life0 self, 
        channel_id: &'life1 str, 
        handshake: FtlHandshakeFinalised, 
        should_stop: Arc<AtomicBool>
    ) -> Pin<Box<dyn Future<Output = Result<u16, ()>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;

    fn launch<'async_trait>(
        &'static self, 
        addr: String
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
    where
        Self: Sync + 'async_trait,
    { ... }
    fn handler<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self, 
        client: &'life1 mut IngestClient, 
        writer: &'life2 TcpStream, 
        command: FtlCommand
    ) -> Pin<Box<dyn Future<Output = Result<(), FtlError>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        'life2: 'async_trait,
        Self: Sync + 'async_trait,
    { ... }
}

This is supported on crate feature server only.

Required methods

fn get_stream_key<'life0, 'life1, 'async_trait>(
    &'life0 self,
    channel_id: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<String, ()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

fn allocate_ingest<'life0, 'life1, 'async_trait>(
    &'life0 self,
    channel_id: &'life1 str,
    handshake: FtlHandshakeFinalised,
    should_stop: Arc<AtomicBool>
) -> Pin<Box<dyn Future<Output = Result<u16, ()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Provided methods

fn launch<'async_trait>(
    &'static self,
    addr: String
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
    Self: Sync + 'async_trait, 

fn handler<'life0, 'life1, 'life2, 'async_trait>(
    &'life0 self,
    client: &'life1 mut IngestClient,
    writer: &'life2 TcpStream,
    command: FtlCommand
) -> Pin<Box<dyn Future<Output = Result<(), FtlError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,
    Self: Sync + 'async_trait, 

Implementors