Struct tinychain::gateway::Gateway [−][src]
Responsible for handling inbound and outbound traffic over the network.
Implementations
impl Gateway
[src]
pub fn time() -> NetworkTime
[src]
Return the current timestamp.
pub fn new(config: Config, kernel: Kernel, txn_server: TxnServer) -> Arc<Self>
[src]
Initialize a new Gateway
pub fn root(&self) -> &LinkHost
[src]
Return the network address of this Gateway
pub fn link(&self, path: TCPathBuf) -> Link
[src]
Return a Link
to the given path at this host.
pub async fn new_txn(
self: &Arc<Self>,
txn_id: TxnId,
token: Option<String>
) -> TCResult<Txn>
[src]
self: &Arc<Self>,
txn_id: TxnId,
token: Option<String>
) -> TCResult<Txn>
Authorize a transaction to execute on this host.
pub async fn fetch<T: DeserializeOwned>(
&self,
txn_id: &TxnId,
link: &Link,
key: &Value
) -> TCResult<T>
[src]
&self,
txn_id: &TxnId,
link: &Link,
key: &Value
) -> TCResult<T>
Read a simple value.
pub async fn get(&self, txn: &Txn, link: Link, key: Value) -> TCResult<State>
[src]
Read the State
key
at link
.
pub fn put<'a>(
&'a self,
txn: &'a Txn,
link: Link,
key: Value,
value: State
) -> Pin<Box<dyn Future<Output = TCResult<()>> + Send + 'a>>
[src]
&'a self,
txn: &'a Txn,
link: Link,
key: Value,
value: State
) -> Pin<Box<dyn Future<Output = TCResult<()>> + Send + 'a>>
Update the State
key
at link
to value
.
pub async fn post(
&self,
txn: &Txn,
link: Link,
params: State
) -> TCResult<State>
[src]
&self,
txn: &Txn,
link: Link,
params: State
) -> TCResult<State>
Execute the POST op at subject
with the params
pub fn listen(
self: Arc<Self>
) -> Pin<Box<impl Future<Output = Result<(), Box<dyn Error>>> + 'static>>
[src]
self: Arc<Self>
) -> Pin<Box<impl Future<Output = Result<(), Box<dyn Error>>> + 'static>>
Start this Gateway
’s server
Auto Trait Implementations
impl !RefUnwindSafe for Gateway
impl Send for Gateway
impl Sync for Gateway
impl Unpin for Gateway
impl !UnwindSafe for Gateway
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<F, T> CastFrom<F> for T where
T: From<F>,
[src]
T: From<F>,
impl<T, F> CastInto<F> for T where
F: CastFrom<T>,
[src]
F: CastFrom<T>,
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<F> Match for F
[src]
pub fn matches<T>(&self) -> bool where
T: TryCastFrom<Self>,
[src]
T: TryCastFrom<Self>,
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<F, T> TryCastFrom<F> for T where
T: CastFrom<F>,
[src]
T: CastFrom<F>,
pub fn can_cast_from(&F) -> bool
[src]
pub fn opt_cast_from(f: F) -> Option<T>
[src]
pub fn try_cast_from<Err, OnErr>(value: T, on_err: OnErr) -> Result<Self, Err> where
OnErr: FnOnce(&T) -> Err,
[src]
OnErr: FnOnce(&T) -> Err,
impl<F, T> TryCastInto<T> for F where
T: TryCastFrom<F>,
[src]
T: TryCastFrom<F>,
pub fn can_cast_into(&self) -> bool
[src]
pub fn opt_cast_into(self) -> Option<T>
[src]
pub fn try_cast_into<Err, OnErr>(self, on_err: OnErr) -> Result<T, Err> where
OnErr: FnOnce(&Self) -> Err,
[src]
OnErr: FnOnce(&Self) -> Err,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,