pub struct UplinkJournal { /* private fields */ }Expand description
Node-side journal bound to a restreamer uplink.
Implementations§
Source§impl UplinkJournal
impl UplinkJournal
pub fn open( node_id: impl Into<String>, path: impl Into<PathBuf>, ) -> Result<Self, String>
pub fn append(&self, channel_id: u32, payload: &[u8]) -> Result<u64, String>
pub fn journal(&self) -> &FileJournal
Sourcepub async fn serve_uplink(
self: Arc<Self>,
restreamer_addr: SocketAddr,
channel_id: u32,
kind: ChannelKind,
) -> Result<(), String>
pub async fn serve_uplink( self: Arc<Self>, restreamer_addr: SocketAddr, channel_id: u32, kind: ChannelKind, ) -> Result<(), String>
Dial the restreamer node listen address, OPEN a channel, and answer JournalReq.
Auto Trait Implementations§
impl Freeze for UplinkJournal
impl RefUnwindSafe for UplinkJournal
impl Send for UplinkJournal
impl Sync for UplinkJournal
impl Unpin for UplinkJournal
impl UnsafeUnpin for UplinkJournal
impl UnwindSafe for UplinkJournal
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<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more