Trait StreamingSessionService 

pub trait StreamingSessionService {
    // Required methods
    fn resolve(
        &self,
        auth_: BearerToken,
        dataset_rid: DatasetRid,
        request: ResolveStreamingSessionRequest,
    ) -> Result<ResolveStreamingSessionResponse, Error>;
    fn heartbeat(
        &self,
        auth_: BearerToken,
        session_rid: StreamingSessionRid,
    ) -> Result<(), Error>;
}

Required Methods

fn resolve( &self, auth_: BearerToken, dataset_rid: DatasetRid, request: ResolveStreamingSessionRequest, ) -> Result<ResolveStreamingSessionResponse, Error>

fn heartbeat( &self, auth_: BearerToken, session_rid: StreamingSessionRid, ) -> Result<(), Error>

Implementors