pub enum RpcKind {
Unary,
ServerStreaming,
}Expand description
Kind of gRPC RPC to invoke.
Selected via the rpc_kind config field; defaults to RpcKind::Unary
so existing configs are backward-compatible.
Variants§
Unary
One request, one response (default).
ServerStreaming
One request, a server-driven stream of responses. The source consumes each streamed message and emits records as they arrive. Useful for event feeds, change feeds, log tails, and any long-lived gRPC stream.
Trait Implementations§
Source§impl<'de> Deserialize<'de> for RpcKind
impl<'de> Deserialize<'de> for RpcKind
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl JsonSchema for RpcKind
impl JsonSchema for RpcKind
Source§fn schema_id() -> Cow<'static, str>
fn schema_id() -> Cow<'static, str>
Returns a string that uniquely identifies the schema produced by this type. Read more
Source§fn json_schema(generator: &mut SchemaGenerator) -> Schema
fn json_schema(generator: &mut SchemaGenerator) -> Schema
Generates a JSON Schema for this type. Read more
Source§fn inline_schema() -> bool
fn inline_schema() -> bool
Whether JSON Schemas generated for this type should be included directly in parent schemas,
rather than being re-used where possible using the
$ref keyword. Read moreimpl Copy for RpcKind
impl Eq for RpcKind
impl StructuralPartialEq for RpcKind
Auto Trait Implementations§
impl Freeze for RpcKind
impl RefUnwindSafe for RpcKind
impl Send for RpcKind
impl Sync for RpcKind
impl Unpin for RpcKind
impl UnsafeUnpin for RpcKind
impl UnwindSafe for RpcKind
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request