Struct HTTPClient 

pub struct HTTPClient { /* private fields */ }

Implementations

impl HTTPClient

pub fn new( endpoint: impl Into<String>, builder: ClientBuilder, ) -> Result<Self, ClientError>

pub async fn create_topic( &self, topic_name: String, request: CreateTopicRequest, ) -> Result<HTTPResponse<CreateTopicResponse>, ClientError>

pub async fn publish( &self, topic_name: String, request: PublishMessageRequest, ) -> Result<HTTPResponse<PublishMessageResponse>, ClientError>

pub async fn create_subscription( &self, subscription_name: String, request: CreateSubscriptionRequest, ) -> Result<HTTPResponse<CreateSubscriptionResponse>, ClientError>

pub async fn pull( &self, subscription_name: String, request: PullMessageRequest, ) -> Result<HTTPResponse<PullMessageResponse>, ClientError>

pub async fn acknowledge( &self, subscription_name: String, request: AcknowledgeRequest, ) -> Result<HTTPResponse<AcknowledgeResponse>, ClientError>

Trait Implementations

impl Debug for HTTPClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.