Struct DocsServiceClient

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

Implementations§

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

Compress requests with the given encoding.

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

Enable decompressing responses.

Limits the maximum size of a decoded message.

Default: 4MB

Limits the maximum size of an encoded message.

Default: usize::MAX

Trait Implementations§

Returns a duplicate of the value. Read more

Performs copy-assignment from source. Read more

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

🔬This is a nightly-only experimental API. (clone_to_uninit)

Performs copy-assignment from self to dest. Read more

Returns the argument unchanged.

Converts to this type from a reference to the input type.

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Wrap the input message T in a tonic::Request

Applies the layer to a service and wraps it in Layered.

The resulting type after obtaining ownership.

Creates owned data from borrowed data, usually by cloning. Read more

Uses borrowed data to replace owned data, usually by cloning. Read more

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

Struct DocsServiceClient Copy item path

Implementations§

impl DocsServiceClient<Channel>

pub async fn connect<D>(dst: D) -> Result<Self, Error>where D: TryInto<Endpoint>, D::Error: Into<StdError>,

impl<T> DocsServiceClient<T>where T: GrpcService<Body>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

pub fn new(inner: T) -> Self

pub fn with_origin(inner: T, origin: Uri) -> Self

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

pub fn max_decoding_message_size(self, limit: usize) -> Self

pub fn max_encoding_message_size(self, limit: usize) -> Self

pub async fn health( &mut self, request: impl IntoRequest<HealthRequest>, ) -> Result<Response<HealthResponse>, Status>

pub async fn create_space( &mut self, request: impl IntoRequest<CreateSpaceRequest>, ) -> Result<Response<Space>, Status>

pub async fn list_spaces( &mut self, request: impl IntoRequest<ListSpacesRequest>, ) -> Result<Response<ListSpacesResponse>, Status>

pub async fn upsert_node( &mut self, request: impl IntoRequest<UpsertNodeRequest>, ) -> Result<Response<Node>, Status>

pub async fn get_node( &mut self, request: impl IntoRequest<GetNodeRequest>, ) -> Result<Response<Node>, Status>

pub async fn list_children( &mut self, request: impl IntoRequest<ListChildrenRequest>, ) -> Result<Response<ListChildrenResponse>, Status>

pub async fn delete_node( &mut self, request: impl IntoRequest<DeleteNodeRequest>, ) -> Result<Response<DeleteNodeResponse>, Status>

pub async fn move_node( &mut self, request: impl IntoRequest<MoveNodeRequest>, ) -> Result<Response<Node>, Status>

pub async fn restore_node( &mut self, request: impl IntoRequest<RestoreNodeRequest>, ) -> Result<Response<Node>, Status>

pub async fn save_revision( &mut self, request: impl IntoRequest<SaveRevisionRequest>, ) -> Result<Response<Revision>, Status>

pub async fn list_revisions( &mut self, request: impl IntoRequest<ListRevisionsRequest>, ) -> Result<Response<ListRevisionsResponse>, Status>

pub async fn get_revision_index_status( &mut self, request: impl IntoRequest<GetRevisionIndexStatusRequest>, ) -> Result<Response<RevisionIndexState>, Status>

pub async fn retry_revision_index( &mut self, request: impl IntoRequest<RetryRevisionIndexRequest>, ) -> Result<Response<RevisionIndexState>, Status>

pub async fn set_acl( &mut self, request: impl IntoRequest<SetAclRequest>, ) -> Result<Response<AclEntry>, Status>

pub async fn revoke_acl( &mut self, request: impl IntoRequest<RevokeAclRequest>, ) -> Result<Response<RevokeAclResponse>, Status>

pub async fn list_acl( &mut self, request: impl IntoRequest<ListAclRequest>, ) -> Result<Response<ListAclResponse>, Status>

pub async fn create_invite( &mut self, request: impl IntoRequest<CreateInviteRequest>, ) -> Result<Response<Invite>, Status>

pub async fn list_invites( &mut self, request: impl IntoRequest<ListInvitesRequest>, ) -> Result<Response<ListInvitesResponse>, Status>

pub async fn revoke_invite( &mut self, request: impl IntoRequest<RevokeInviteRequest>, ) -> Result<Response<RevokeInviteResponse>, Status>

pub async fn accept_invite( &mut self, request: impl IntoRequest<AcceptInviteRequest>, ) -> Result<Response<AclEntry>, Status>

pub async fn create_asset( &mut self, request: impl IntoRequest<CreateAssetRequest>, ) -> Result<Response<Asset>, Status>

pub async fn publish_release( &mut self, request: impl IntoRequest<PublishReleaseRequest>, ) -> Result<Response<Release>, Status>

pub async fn get_release( &mut self, request: impl IntoRequest<GetReleaseRequest>, ) -> Result<Response<Release>, Status>

pub async fn search( &mut self, request: impl IntoRequest<SearchRequest>, ) -> Result<Response<SearchResponse>, Status>

Trait Implementations§

impl<T: Clone> Clone for DocsServiceClient<T>

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

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

impl<T: Debug> Debug for DocsServiceClient<T>

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

Auto Trait Implementations§

impl<T> !Freeze for DocsServiceClient<T>

impl<T> RefUnwindSafe for DocsServiceClient<T>where Grpc<T>: RefUnwindSafe,

impl<T> Send for DocsServiceClient<T>where Grpc<T>: Send,

impl<T> Sync for DocsServiceClient<T>where Grpc<T>: Sync,

impl<T> Unpin for DocsServiceClient<T>where Grpc<T>: Unpin,

impl<T> UnsafeUnpin for DocsServiceClient<T>where Grpc<T>: UnsafeUnpin,

impl<T> UnwindSafe for DocsServiceClient<T>where Grpc<T>: UnwindSafe,

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FromRef<T> for Twhere T: Clone,

fn from_ref(input: &T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

fn in_current_span(self) -> Instrumented<Self> ⓘ

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = !

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

Struct DocsServiceClient

pub async fn connect<D>(dst: D) -> Result<Self, Error>
where D: TryInto<Endpoint>, D::Error: Into<StdError>,

impl<T> DocsServiceClient<T>
where T: GrpcService<Body>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

impl<T> RefUnwindSafe for DocsServiceClient<T>
where Grpc<T>: RefUnwindSafe,

impl<T> Send for DocsServiceClient<T>
where Grpc<T>: Send,

impl<T> Sync for DocsServiceClient<T>
where Grpc<T>: Sync,

impl<T> Unpin for DocsServiceClient<T>
where Grpc<T>: Unpin,

impl<T> UnsafeUnpin for DocsServiceClient<T>
where Grpc<T>: UnsafeUnpin,

impl<T> UnwindSafe for DocsServiceClient<T>
where Grpc<T>: UnwindSafe,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T> FromRef<T> for T
where T: Clone,

impl<T, U> Into<U> for T
where U: From<T>,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,