Struct tinychain::gateway::Gateway

pub struct Gateway { /* fields omitted */ }

Responsible for handling inbound and outbound traffic over the network.

Implementations

impl Gateway

pub fn time() -> NetworkTime

Return the current timestamp.

pub fn new(config: Config, kernel: Kernel, txn_server: TxnServer) -> Arc<Self>

Initialize a new Gateway

pub fn request_ttl(&self) -> Duration

Return the configured maximum request time-to-live (timeout duration).

pub fn root(&self) -> &LinkHost

Return the network address of this Gateway

pub fn link(&self, path: TCPathBuf) -> Link

Return a Link to the given path at this host.

pub fn new_token(&self, txn_id: &TxnId) -> TCResult<(String, Claims)>

Return a new, signed auth token with no claims.

pub async fn new_txn(
    self: &Arc<Self>,
    txn_id: TxnId,
    token: Option<String>
) -> TCResult<Txn>

Authorize a transaction to execute on this host.

pub async fn fetch<T: FromStream<Context = ()>>(
    &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>

Read the State with the given 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>>

Update the State with the given key at link to value.

pub async fn post(
    &self,
    txn: &Txn,
    link: Link,
    params: State
) -> TCResult<State>

Execute the POST op at subject with the params

pub async fn delete(&self, txn: &Txn, link: Link, key: Value) -> TCResult<()>

Delete the State with the given key at link.

pub fn listen(
    self: Arc<Self>
) -> Pin<Box<impl Future<Output = Result<(), Box<dyn Error>>> + 'static>>

Start this Gateway’s server