Crate force_pubsub 

Salesforce Pub/Sub API client for Rust.

This crate provides a gRPC client for the Salesforce Pub/Sub API, supporting subscribe, publish, and schema operations.

Re-exports

pub use config::BackoffConfig;

pub use config::PubSubConfig;

pub use config::ReconnectPolicy;

pub use config::ReplayPreset;

pub use error::PubSubError;

pub use error::Result;

pub use handler::PubSubHandler;

pub use handler::SchemaInfo;

pub use handler::TopicInfo;

pub use schema_cache::SchemaCache;

pub use types::EventMessage;

pub use types::PubSubEvent;

pub use types::PublishResponse;

pub use types::PublishResult;

pub use types::ReplayId;

Modules

codec

Avro codec utilities for encoding and decoding Salesforce Pub/Sub events.

config

Configuration types for the Salesforce Pub/Sub API client.

error

Error types for the force-pubsub crate.

handler

Pub/Sub API handler.

proto

Generated protobuf types from the Salesforce Pub/Sub API proto.

schema_cache

DashMap-backed schema cache for Avro schemas fetched from the Pub/Sub API.

types

Domain types for Salesforce Pub/Sub API events and responses.

Structs

PublishSink

A bidirectional streaming publish sink for the Salesforce Pub/Sub API.