Struct tinychain::gateway::Gateway

pub struct Gateway { /* private fields */ }

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) -> Self

Initialize a new Gateway

pub fn request_ttl(&self) -> Duration

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

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

Return a new, signed auth token with no claims.

pub fn new_txn(self, txn_id: TxnId, token: Option<SignedToken>) -> TCResult<Txn>

Authorize a transaction to execute on this host.

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

Start this Gateway’s server

Trait Implementations

impl Clone for Gateway

fn clone(&self) -> Gateway

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Gateway for Gateway

type State = State

fn host(&self) -> &Host

Return this [Host]

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

Return a link to the given path on this host.

fn fetch<'a>( &'a self, txn_id: &'a TxnId, link: ToUrl<'a>, key: &'a Value ) -> TCBoxTryFuture<'_, Value>

Read a simple value.

fn get<'a>( &'a self, txn: &'a Txn, link: ToUrl<'a>, key: Value ) -> TCBoxTryFuture<'a, State>

Read the [State] at link with the given key.

fn put<'a>( &'a self, txn: &'a Txn, link: ToUrl<'a>, key: Value, value: State ) -> TCBoxTryFuture<'a, ()>

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

fn post<'a>( &'a self, txn: &'a Txn, link: ToUrl<'a>, params: State ) -> TCBoxTryFuture<'a, State>

Execute the POST op at link with the params

fn delete<'a>( &'a self, txn: &'a Txn, link: ToUrl<'a>, key: Value ) -> TCBoxTryFuture<'a, ()>

Delete the [State] at link with the given key.

fn finalize(&self, txn_id: TxnId) -> TCBoxFuture<'_, ()>