Struct Http 

pub struct Http {
    pub kvs: Arc<Datastore>,
    pub sessions: HashMap<Option<Uuid>, Arc<RwLock<Session>>>,
}

Fields

kvs: Arc<Datastore>

sessions: HashMap<Option<Uuid>, Arc<RwLock<Session>>>

Implementations

impl Http

pub fn new(kvs: Arc<Datastore>, session: Session) -> Self

Trait Implementations

impl RpcProtocol for Http

const LQ_SUPPORT: bool = false

Live queries are disabled on HTTP

fn kvs(&self) -> &Datastore

The datastore for this RPC interface

fn version_data(&self) -> DbResult

The version information for this RPC context

fn session_map(&self) -> &HashMap<Option<Uuid>, Arc<RwLock<Session>>>

A pointer to all active sessions

async fn cleanup_lqs(&self, _session_id: Option<&Uuid>)

Handles the cleanup of live queries

async fn cleanup_all_lqs(&self)

Handles the cleanup of live queries

async fn begin( &self, _txn: Option<Uuid>, _session_id: Option<Uuid>, ) -> Result<DbResult, TypesError>

Transactions are not supported on HTTP RPC context

async fn commit( &self, _txn: Option<Uuid>, _session_id: Option<Uuid>, _params: Array, ) -> Result<DbResult, TypesError>

Transactions are not supported on HTTP RPC context

async fn cancel( &self, _txn: Option<Uuid>, _session_id: Option<Uuid>, _params: Array, ) -> Result<DbResult, TypesError>

Transactions are not supported on HTTP RPC context

async fn attach(&self, session_id: Option<Uuid>) -> Result<DbResult, Error>

Registers a new session with the given ID

async fn detach(&self, session_id: Option<Uuid>) -> Result<DbResult, Error>

Detaches a session from the given ID

fn get_session(&self, id: &Option<Uuid>) -> Result<Arc<RwLock<Session>>, Error>

The current session for this RPC context

fn set_session(&self, id: Option<Uuid>, session: Arc<RwLock<Session>>)

Mutable access to the current session for this RPC context

async fn del_session(&self, id: &Uuid)

Deletes a session

async fn sessions(&self) -> Result<DbResult, Error>

Lists all non-default sessions

async fn get_tx(&self, _id: Uuid) -> Result<Arc<Transaction>, Error>

Retrieves a transaction by ID

async fn set_tx(&self, _id: Uuid, _tx: Arc<Transaction>) -> Result<(), Error>

Stores a transaction

fn handle_live( &self, _lqid: &Uuid, _session_id: Option<Uuid>, ) -> impl Future<Output = ()> + Send

Handles the execution of a LIVE statement

fn handle_kill(&self, _lqid: &Uuid) -> impl Future<Output = ()> + Send

Handles the execution of a KILL statement

async fn execute( &self, txn: Option<Uuid>, session: Option<Uuid>, method: Method, params: Array, ) -> Result<DbResult, Error>

Executes a method on this RPC implementation

async fn yuse( &self, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

Handles the USE RPC method for switching namespace and database context.

async fn signup( &self, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

async fn signin( &self, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

async fn authenticate( &self, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

async fn refresh( &self, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

Refreshes an access token using a refresh token.

async fn invalidate(&self, session_id: Option<Uuid>) -> Result<DbResult, Error>

async fn revoke(&self, params: Array) -> Result<DbResult, Error>

Revokes a refresh token, preventing it from being used to obtain new access tokens.

async fn reset(&self, session_id: Option<Uuid>) -> Result<DbResult, Error>

async fn info( &self, _txn: Option<Uuid>, session_id: Option<Uuid>, ) -> Result<DbResult, Error>

async fn set( &self, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

async fn unset( &self, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

async fn kill( &self, txn: Option<Uuid>, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

async fn live( &self, txn: Option<Uuid>, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

async fn select( &self, txn: Option<Uuid>, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

async fn insert( &self, txn: Option<Uuid>, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

async fn insert_relation( &self, txn: Option<Uuid>, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

async fn create( &self, txn: Option<Uuid>, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

async fn upsert( &self, txn: Option<Uuid>, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

async fn update( &self, _txn: Option<Uuid>, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

async fn merge( &self, txn: Option<Uuid>, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

async fn patch( &self, _txn: Option<Uuid>, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

async fn relate( &self, _txn: Option<Uuid>, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

async fn delete( &self, txn: Option<Uuid>, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

async fn version( &self, _txn: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

async fn query( &self, txn: Option<Uuid>, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>

async fn run( &self, _txn: Option<Uuid>, session_id: Option<Uuid>, params: Array, ) -> Result<DbResult, Error>