Struct InProcessBackend 

pub struct InProcessBackend { /* private fields */ }

Implementations

impl InProcessBackend

pub fn new(config: InProcessBackendConfig) -> Self

pub fn send_report( &self, message_id: &MessageId, ) -> Result<Option<InProcessSendReport>, SdkError>

pub fn set_propagation_relay( &self, relay: Option<AddressHash>, ) -> Result<(), SdkError>

pub fn record_delivery( &self, message_id: &MessageId, state: DeliveryState, reason: Option<String>, ) -> Result<(), SdkError>

pub fn record_event( &self, event_type: &str, severity: Severity, payload: JsonValue, ) -> Result<(), SdkError>

Trait Implementations

impl Clone for InProcessBackend

fn clone(&self) -> InProcessBackend

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl SdkBackend for InProcessBackend

fn negotiate( &self, _req: NegotiationRequest, ) -> Result<NegotiationResponse, SdkError>

fn send(&self, request: SendRequest) -> Result<MessageId, SdkError>

fn cancel(&self, _id: MessageId) -> Result<CancelResult, SdkError>

fn status(&self, id: MessageId) -> Result<Option<DeliverySnapshot>, SdkError>

fn configure( &self, _expected_revision: u64, _patch: ConfigPatch, ) -> Result<Ack, SdkError>

fn poll_events( &self, cursor: Option<EventCursor>, max: usize, ) -> Result<EventBatch, SdkError>

fn snapshot(&self) -> Result<RuntimeSnapshot, SdkError>

fn shutdown(&self, _mode: ShutdownMode) -> Result<Ack, SdkError>

fn router_stats(&self) -> Result<RouterStats, SdkError>

fn router_storage_policy(&self) -> Result<RouterStoragePolicy, SdkError>

fn set_router_storage_policy( &self, patch: RouterStoragePolicyPatch, ) -> Result<RouterStoragePolicy, SdkError>

fn tick(&self, _budget: TickBudget) -> Result<TickResult, SdkError>

fn topic_create( &self, _req: TopicCreateRequest, ) -> Result<TopicRecord, SdkError>

fn topic_get(&self, _topic_id: TopicId) -> Result<Option<TopicRecord>, SdkError>

fn topic_list( &self, _req: TopicListRequest, ) -> Result<TopicListResult, SdkError>

fn topic_subscribe( &self, _req: TopicSubscriptionRequest, ) -> Result<Ack, SdkError>

fn topic_unsubscribe(&self, _topic_id: TopicId) -> Result<Ack, SdkError>

fn topic_publish(&self, _req: TopicPublishRequest) -> Result<Ack, SdkError>

fn telemetry_query( &self, _query: TelemetryQuery, ) -> Result<Vec<TelemetryPoint>, SdkError>

fn telemetry_subscribe(&self, _query: TelemetryQuery) -> Result<Ack, SdkError>

fn attachment_store( &self, _req: AttachmentStoreRequest, ) -> Result<AttachmentMeta, SdkError>

fn attachment_get( &self, _attachment_id: AttachmentId, ) -> Result<Option<AttachmentMeta>, SdkError>

fn attachment_list( &self, _req: AttachmentListRequest, ) -> Result<AttachmentListResult, SdkError>

fn attachment_delete( &self, _attachment_id: AttachmentId, ) -> Result<Ack, SdkError>

fn attachment_download( &self, _attachment_id: AttachmentId, ) -> Result<Ack, SdkError>

fn attachment_upload_start( &self, _req: AttachmentUploadStartRequest, ) -> Result<AttachmentUploadSession, SdkError>

fn attachment_upload_chunk( &self, _req: AttachmentUploadChunkRequest, ) -> Result<AttachmentUploadChunkAck, SdkError>

fn attachment_upload_commit( &self, _req: AttachmentUploadCommitRequest, ) -> Result<AttachmentMeta, SdkError>

fn attachment_download_chunk( &self, _req: AttachmentDownloadChunkRequest, ) -> Result<AttachmentDownloadChunk, SdkError>

fn attachment_associate_topic( &self, _attachment_id: AttachmentId, _topic_id: TopicId, ) -> Result<Ack, SdkError>

fn marker_create( &self, _req: MarkerCreateRequest, ) -> Result<MarkerRecord, SdkError>

fn marker_list( &self, _req: MarkerListRequest, ) -> Result<MarkerListResult, SdkError>

fn marker_update_position( &self, _req: MarkerUpdatePositionRequest, ) -> Result<MarkerRecord, SdkError>

fn marker_delete(&self, _req: MarkerDeleteRequest) -> Result<Ack, SdkError>

fn identity_list(&self) -> Result<Vec<IdentityBundle>, SdkError>

fn identity_announce_now(&self) -> Result<Ack, SdkError>

fn identity_announce( &self, _req: IdentityAnnounceRequest, ) -> Result<IdentityAnnounceResult, SdkError>

fn identity_presence_list( &self, _req: PresenceListRequest, ) -> Result<PresenceListResult, SdkError>

fn identity_activate(&self, _identity: IdentityRef) -> Result<Ack, SdkError>

fn identity_import( &self, _req: IdentityImportRequest, ) -> Result<IdentityBundle, SdkError>

fn identity_export( &self, _identity: IdentityRef, ) -> Result<IdentityImportRequest, SdkError>

fn identity_resolve( &self, _req: IdentityResolveRequest, ) -> Result<Option<IdentityRef>, SdkError>

fn identity_contact_update( &self, _req: ContactUpdateRequest, ) -> Result<ContactRecord, SdkError>

fn identity_contact_list( &self, _req: ContactListRequest, ) -> Result<ContactListResult, SdkError>

fn identity_bootstrap( &self, _req: IdentityBootstrapRequest, ) -> Result<ContactRecord, SdkError>

fn peer_connect( &self, _req: PeerConnectionRequest, ) -> Result<PeerConnectionResult, SdkError>

fn peer_disconnect( &self, _req: PeerConnectionRequest, ) -> Result<PeerConnectionResult, SdkError>

fn peer_reconnect( &self, _req: PeerConnectionRequest, ) -> Result<PeerConnectionResult, SdkError>

fn paper_encode( &self, _message_id: MessageId, ) -> Result<PaperMessageEnvelope, SdkError>

fn paper_decode(&self, _envelope: PaperMessageEnvelope) -> Result<Ack, SdkError>

fn paper_decode_with_metadata( &self, _envelope: PaperMessageEnvelope, ) -> Result<PaperDecodeResult, SdkError>

fn command_invoke( &self, _req: RemoteCommandRequest, ) -> Result<RemoteCommandResponse, SdkError>

fn command_reply( &self, _correlation_id: String, _reply: RemoteCommandResponse, ) -> Result<Ack, SdkError>

fn command_session_get( &self, _correlation_id: String, ) -> Result<Option<RemoteCommandSession>, SdkError>

fn command_session_list( &self, _req: RemoteCommandSessionListRequest, ) -> Result<RemoteCommandSessionListResult, SdkError>

fn voice_session_open( &self, _req: VoiceSessionOpenRequest, ) -> Result<VoiceSessionId, SdkError>

fn voice_session_update( &self, _req: VoiceSessionUpdateRequest, ) -> Result<VoiceSessionState, SdkError>

fn voice_session_close( &self, _session_id: VoiceSessionId, ) -> Result<Ack, SdkError>

fn operation_registry(&self) -> Result<OperationRegistry, SdkError>

fn envelope_execute( &self, _envelope: Envelope, ) -> Result<EnvelopeResponse, SdkError>