pub struct Gateway { /* private fields */ }Expand description
Responsible for handling inbound and outbound traffic over the network.
Implementations
sourceimpl Gateway
impl Gateway
sourcepub fn time() -> NetworkTime
pub fn time() -> NetworkTime
Return the current timestamp.
sourcepub fn new(config: Config, kernel: Kernel, txn_server: TxnServer) -> Arc<Self>
pub fn new(config: Config, kernel: Kernel, txn_server: TxnServer) -> Arc<Self>
Initialize a new Gateway
sourcepub fn request_ttl(&self) -> Duration
pub fn request_ttl(&self) -> Duration
Return the configured maximum request time-to-live (timeout duration).
sourcepub fn new_token(&self, txn_id: &TxnId) -> TCResult<(String, Claims)>
pub fn new_token(&self, txn_id: &TxnId) -> TCResult<(String, Claims)>
Return a new, signed auth token with no claims.
sourcepub async fn new_txn(
self: &Arc<Self>,
txn_id: TxnId,
token: Option<String>
) -> TCResult<Txn>
pub async fn new_txn(
self: &Arc<Self>,
txn_id: TxnId,
token: Option<String>
) -> TCResult<Txn>
Authorize a transaction to execute on this host.
sourcepub async fn fetch<T: FromStream<Context = ()>>(
&self,
txn_id: &TxnId,
link: &Link,
key: &Value
) -> TCResult<T>
pub async fn fetch<T: FromStream<Context = ()>>(
&self,
txn_id: &TxnId,
link: &Link,
key: &Value
) -> TCResult<T>
Read a simple value.
sourcepub async fn get(&self, txn: &Txn, link: Link, key: Value) -> TCResult<State>
pub async fn get(&self, txn: &Txn, link: Link, key: Value) -> TCResult<State>
Read the State with the given key at link.
sourcepub fn put<'a>(
&'a self,
txn: &'a Txn,
link: Link,
key: Value,
value: State
) -> TCBoxTryFuture<'a, ()>
pub fn put<'a>(
&'a self,
txn: &'a Txn,
link: Link,
key: Value,
value: State
) -> TCBoxTryFuture<'a, ()>
Update the State with the given key at link to value.
sourcepub async fn post(
&self,
txn: &Txn,
link: Link,
params: State
) -> TCResult<State>
pub async fn post(
&self,
txn: &Txn,
link: Link,
params: State
) -> TCResult<State>
Execute the POST op at subject with the params
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
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<F> Match for F
impl<F> Match for F
sourcefn matches<T>(&self) -> bool where
T: TryCastFrom<Self>,
fn matches<T>(&self) -> bool where
T: TryCastFrom<Self>,
Returns true if self can be cast into the target type T.
sourceimpl<F, T> TryCastFrom<F> for T where
T: CastFrom<F>,
impl<F, T> TryCastFrom<F> for T where
T: CastFrom<F>,
sourcefn can_cast_from(&F) -> bool
fn can_cast_from(&F) -> bool
Test if value can be cast into Self.
sourcefn opt_cast_from(f: F) -> Option<T>
fn opt_cast_from(f: F) -> Option<T>
Returns Some(Self) if the source value can be cast into Self, otherwise None.
sourcefn try_cast_from<Err, OnErr>(value: T, on_err: OnErr) -> Result<Self, Err> where
OnErr: FnOnce(&T) -> Err,
fn try_cast_from<Err, OnErr>(value: T, on_err: OnErr) -> Result<Self, Err> where
OnErr: FnOnce(&T) -> Err,
Returns Ok(Self) if the source value can be cast into Self, otherwise calls on_err.
sourceimpl<F, T> TryCastInto<T> for F where
T: TryCastFrom<F>,
impl<F, T> TryCastInto<T> for F where
T: TryCastFrom<F>,
sourcefn can_cast_into(&self) -> bool
fn can_cast_into(&self) -> bool
Test if self can be cast into T.
sourcefn opt_cast_into(self) -> Option<T>
fn opt_cast_into(self) -> Option<T>
Returns Some(T) if self can be cast into T, otherwise None.
sourcefn try_cast_into<Err, OnErr>(self, on_err: OnErr) -> Result<T, Err> where
OnErr: FnOnce(&Self) -> Err,
fn try_cast_into<Err, OnErr>(self, on_err: OnErr) -> Result<T, Err> where
OnErr: FnOnce(&Self) -> Err,
Returns Ok(T) if self can be cast into T, otherwise calls on_err.
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber to this type, returning a
WithDispatch wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber to this type, returning a
WithDispatch wrapper. Read more