Struct decthings_api::rpc::spawned::SpawnedRpc

pub struct SpawnedRpc { /* private fields */ }

Implementations

impl SpawnedRpc

pub async fn spawn_command( &self, params: SpawnCommandParams<'_, impl AsRef<str>> ) -> Result<SpawnCommandResult, DecthingsRpcError<SpawnCommandError>>

pub async fn spawn_command_for_model( &self, params: SpawnCommandForModelParams<'_, impl AsRef<str>> ) -> Result<SpawnCommandForModelResult, DecthingsRpcError<SpawnCommandForModelError>>

pub async fn terminate_spawned_command( &self, params: TerminateSpawnedCommandParams<'_> ) -> Result<TerminateSpawnedCommandResult, DecthingsRpcError<TerminateSpawnedCommandError>>

pub async fn get_spawned_commands( &self, params: GetSpawnedCommandsParams<'_, impl AsRef<str> + Serialize> ) -> Result<GetSpawnedCommandsResult, DecthingsRpcError<GetSpawnedCommandsError>>

pub async fn write_to_spawned_command( &self, params: WriteToSpawnedCommandParams<'_, impl AsRef<[u8]>> ) -> Result<WriteToSpawnedCommandResult, DecthingsRpcError<WriteToSpawnedCommandError>>

pub async fn subscribe_to_events( &self, params: SpawnedSubscribeToEventsParams<'_> ) -> Result<SpawnedSubscribeToEventsResult, DecthingsRpcError<SpawnedSubscribeToEventsError>>

pub async fn unsubscribe_from_events( &self, params: SpawnedUnsubscribeFromEventsParams<'_> ) -> Result<SpawnedUnsubscribeFromEventsResult, DecthingsRpcError<SpawnedUnsubscribeFromEventsError>>