Struct PuppetClient 

pub struct PuppetClient<T> { /* private fields */ }

Implementations

impl PuppetClient<Channel>

pub async fn connect<D>(dst: D) -> Result<Self, Error>

where D: TryInto<Endpoint>, D::Error: Into<StdError>,

Attempt to create a new client by connecting to a given endpoint.

impl<T> PuppetClient<T>

where T: GrpcService<BoxBody>, T::ResponseBody: Body + Send + Sync + 'static, T::Error: Into<StdError>, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

pub fn new(inner: T) -> Self

pub fn with_interceptor<F>( inner: T, interceptor: F, ) -> PuppetClient<InterceptedService<T, F>>

where F: Interceptor, T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>, <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,

pub fn send_gzip(self) -> Self

Compress requests with gzip.

This requires the server to support it otherwise it might respond with an error.

pub fn accept_gzip(self) -> Self

Enable decompressing responses with gzip.

pub async fn start( &mut self, request: impl IntoRequest<StartRequest>, ) -> Result<Response<StartResponse>, Status>

Base

pub async fn stop( &mut self, request: impl IntoRequest<StopRequest>, ) -> Result<Response<StopResponse>, Status>

pub async fn logout( &mut self, request: impl IntoRequest<LogoutRequest>, ) -> Result<Response<LogoutResponse>, Status>

pub async fn ding( &mut self, request: impl IntoRequest<DingRequest>, ) -> Result<Response<DingResponse>, Status>

pub async fn version( &mut self, request: impl IntoRequest<VersionRequest>, ) -> Result<Response<VersionResponse>, Status>

pub async fn event( &mut self, request: impl IntoRequest<EventRequest>, ) -> Result<Response<Streaming<EventResponse>>, Status>

Event - Server Stream

pub async fn dirty_payload( &mut self, request: impl IntoRequest<DirtyPayloadRequest>, ) -> Result<Response<DirtyPayloadResponse>, Status>

pub async fn contact_self_qr_code( &mut self, request: impl IntoRequest<ContactSelfQrCodeRequest>, ) -> Result<Response<ContactSelfQrCodeResponse>, Status>

Contact Self

pub async fn contact_self_name( &mut self, request: impl IntoRequest<ContactSelfNameRequest>, ) -> Result<Response<ContactSelfNameResponse>, Status>

pub async fn contact_self_signature( &mut self, request: impl IntoRequest<ContactSelfSignatureRequest>, ) -> Result<Response<ContactSelfSignatureResponse>, Status>

pub async fn contact_payload( &mut self, request: impl IntoRequest<ContactPayloadRequest>, ) -> Result<Response<ContactPayloadResponse>, Status>

Contact

pub async fn contact_alias( &mut self, request: impl IntoRequest<ContactAliasRequest>, ) -> Result<Response<ContactAliasResponse>, Status>

pub async fn contact_avatar( &mut self, request: impl IntoRequest<ContactAvatarRequest>, ) -> Result<Response<ContactAvatarResponse>, Status>

pub async fn contact_phone( &mut self, request: impl IntoRequest<ContactPhoneRequest>, ) -> Result<Response<ContactPhoneResponse>, Status>

pub async fn contact_corporation_remark( &mut self, request: impl IntoRequest<ContactCorporationRemarkRequest>, ) -> Result<Response<ContactCorporationRemarkResponse>, Status>

pub async fn contact_description( &mut self, request: impl IntoRequest<ContactDescriptionRequest>, ) -> Result<Response<ContactDescriptionResponse>, Status>

pub async fn contact_list( &mut self, request: impl IntoRequest<ContactListRequest>, ) -> Result<Response<ContactListResponse>, Status>

Huan(202002): consider changing response to a stream in the future for better performance

pub async fn friendship_payload( &mut self, request: impl IntoRequest<FriendshipPayloadRequest>, ) -> Result<Response<FriendshipPayloadResponse>, Status>

Friendship

pub async fn friendship_search_phone( &mut self, request: impl IntoRequest<FriendshipSearchPhoneRequest>, ) -> Result<Response<FriendshipSearchPhoneResponse>, Status>

pub async fn friendship_search_weixin( &mut self, request: impl IntoRequest<FriendshipSearchWeixinRequest>, ) -> Result<Response<FriendshipSearchWeixinResponse>, Status>

pub async fn friendship_add( &mut self, request: impl IntoRequest<FriendshipAddRequest>, ) -> Result<Response<FriendshipAddResponse>, Status>

pub async fn friendship_accept( &mut self, request: impl IntoRequest<FriendshipAcceptRequest>, ) -> Result<Response<FriendshipAcceptResponse>, Status>

pub async fn message_file( &mut self, request: impl IntoRequest<MessageFileRequest>, ) -> Result<Response<MessageFileResponse>, Status>

@deprecated: using MessageFileStream to transfer files Huan(202010): will be removed (replaced by MessageFileStream) after Dec 31, 2021

pub async fn message_image( &mut self, request: impl IntoRequest<MessageImageRequest>, ) -> Result<Response<MessageImageResponse>, Status>

@deprecated: using MessageImageStream to transfer images Huan(202010): will be removed (replaced by MessageImageStream) after Dec 31, 2021

pub async fn message_send_file( &mut self, request: impl IntoRequest<MessageSendFileRequest>, ) -> Result<Response<MessageSendFileResponse>, Status>

@deprecated: using MesageSendFileStream to transfer file message to server Huan(202010): will be removed (replaced by MessageSendFileStream) after Dec 31, 2021

pub async fn message_payload( &mut self, request: impl IntoRequest<MessagePayloadRequest>, ) -> Result<Response<MessagePayloadResponse>, Status>

pub async fn message_contact( &mut self, request: impl IntoRequest<MessageContactRequest>, ) -> Result<Response<MessageContactResponse>, Status>

pub async fn message_file_stream( &mut self, request: impl IntoRequest<MessageFileStreamRequest>, ) -> Result<Response<Streaming<MessageFileStreamResponse>>, Status>

pub async fn message_image_stream( &mut self, request: impl IntoRequest<MessageImageStreamRequest>, ) -> Result<Response<Streaming<MessageImageStreamResponse>>, Status>

pub async fn message_mini_program( &mut self, request: impl IntoRequest<MessageMiniProgramRequest>, ) -> Result<Response<MessageMiniProgramResponse>, Status>

pub async fn message_url( &mut self, request: impl IntoRequest<MessageUrlRequest>, ) -> Result<Response<MessageUrlResponse>, Status>

pub async fn message_recall( &mut self, request: impl IntoRequest<MessageRecallRequest>, ) -> Result<Response<MessageRecallResponse>, Status>

pub async fn message_forward( &mut self, request: impl IntoRequest<MessageForwardRequest>, ) -> Result<Response<MessageForwardResponse>, Status>

pub async fn message_send_contact( &mut self, request: impl IntoRequest<MessageSendContactRequest>, ) -> Result<Response<MessageSendContactResponse>, Status>

pub async fn message_send_file_stream( &mut self, request: impl IntoStreamingRequest<Message = MessageSendFileStreamRequest>, ) -> Result<Response<MessageSendFileStreamResponse>, Status>

pub async fn message_send_text( &mut self, request: impl IntoRequest<MessageSendTextRequest>, ) -> Result<Response<MessageSendTextResponse>, Status>

pub async fn message_send_mini_program( &mut self, request: impl IntoRequest<MessageSendMiniProgramRequest>, ) -> Result<Response<MessageSendMiniProgramResponse>, Status>

pub async fn message_send_url( &mut self, request: impl IntoRequest<MessageSendUrlRequest>, ) -> Result<Response<MessageSendUrlResponse>, Status>

pub async fn room_payload( &mut self, request: impl IntoRequest<RoomPayloadRequest>, ) -> Result<Response<RoomPayloadResponse>, Status>

Room

pub async fn room_list( &mut self, request: impl IntoRequest<RoomListRequest>, ) -> Result<Response<RoomListResponse>, Status>

pub async fn room_add( &mut self, request: impl IntoRequest<RoomAddRequest>, ) -> Result<Response<RoomAddResponse>, Status>

pub async fn room_avatar( &mut self, request: impl IntoRequest<RoomAvatarRequest>, ) -> Result<Response<RoomAvatarResponse>, Status>

pub async fn room_create( &mut self, request: impl IntoRequest<RoomCreateRequest>, ) -> Result<Response<RoomCreateResponse>, Status>

pub async fn room_del( &mut self, request: impl IntoRequest<RoomDelRequest>, ) -> Result<Response<RoomDelResponse>, Status>

pub async fn room_quit( &mut self, request: impl IntoRequest<RoomQuitRequest>, ) -> Result<Response<RoomQuitResponse>, Status>

pub async fn room_topic( &mut self, request: impl IntoRequest<RoomTopicRequest>, ) -> Result<Response<RoomTopicResponse>, Status>

pub async fn room_qr_code( &mut self, request: impl IntoRequest<RoomQrCodeRequest>, ) -> Result<Response<RoomQrCodeResponse>, Status>

pub async fn room_announce( &mut self, request: impl IntoRequest<RoomAnnounceRequest>, ) -> Result<Response<RoomAnnounceResponse>, Status>

pub async fn room_member_payload( &mut self, request: impl IntoRequest<RoomMemberPayloadRequest>, ) -> Result<Response<RoomMemberPayloadResponse>, Status>

Room Member

pub async fn room_member_list( &mut self, request: impl IntoRequest<RoomMemberListRequest>, ) -> Result<Response<RoomMemberListResponse>, Status>

pub async fn room_invitation_payload( &mut self, request: impl IntoRequest<RoomInvitationPayloadRequest>, ) -> Result<Response<RoomInvitationPayloadResponse>, Status>

Room Invitation

pub async fn room_invitation_accept( &mut self, request: impl IntoRequest<RoomInvitationAcceptRequest>, ) -> Result<Response<RoomInvitationAcceptResponse>, Status>

pub async fn tag_contact_add( &mut self, request: impl IntoRequest<TagContactAddRequest>, ) -> Result<Response<TagContactAddResponse>, Status>

Tag

pub async fn tag_contact_remove( &mut self, request: impl IntoRequest<TagContactRemoveRequest>, ) -> Result<Response<TagContactRemoveResponse>, Status>

pub async fn tag_contact_delete( &mut self, request: impl IntoRequest<TagContactDeleteRequest>, ) -> Result<Response<TagContactDeleteResponse>, Status>

Operate Sub-Collections https://cloud.google.com/apis/design/design_patterns#list_sub-collections

pub async fn tag_contact_list( &mut self, request: impl IntoRequest<TagContactListRequest>, ) -> Result<Response<TagContactListResponse>, Status>

Trait Implementations

impl<T: Clone> Clone for PuppetClient<T>

fn clone(&self) -> PuppetClient<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for PuppetClient<T>

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

Formats the value using the given formatter.