pub struct SubscribePushRequest {
pub notify_subscribe: bool,
}Expand description
订阅推送请求
Fields§
§notify_subscribe: boolv1.4.106 codex 1125 F6 [P2]: 显式 notify subscription opt-in.
对齐 C++ raw TCP IsConnSubRecvNotify(nConnID) 语义
(APIServer_Qot_PriceReminder.cpp:730-735): broadcast push (e.g.
QOT_UPDATE_PRICE_REMINDER) 必须连接显式 sub 才下发, 不再无条件推送给
所有 SubscribePush stream.
- false (proto3 默认): 客户端只收 quote/trade 类 push, 不收 broadcast notify 类 push (e.g. price reminder). 对齐 C++ raw conn 默认状态.
- true: 客户端额外收 broadcast notify push.
Breaking change vs v1.4.105: v1.4.105 之前 gRPC SubscribePush 默认 收所有 broadcast (含 price reminder), v1.4.106 起需 notify_subscribe=true 才能继续收. 老客户端如果依赖 price reminder push 必须传 true.
Trait Implementations§
Source§impl Clone for SubscribePushRequest
impl Clone for SubscribePushRequest
Source§fn clone(&self) -> SubscribePushRequest
fn clone(&self) -> SubscribePushRequest
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for SubscribePushRequest
impl Debug for SubscribePushRequest
Source§impl Default for SubscribePushRequest
impl Default for SubscribePushRequest
Source§impl Hash for SubscribePushRequest
impl Hash for SubscribePushRequest
Source§impl Message for SubscribePushRequest
impl Message for SubscribePushRequest
Source§fn encoded_len(&self) -> usize
fn encoded_len(&self) -> usize
Returns the encoded length of the message without a length delimiter.
Source§fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
Encodes the message to a buffer. Read more
Source§fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Encodes the message to a newly allocated buffer.
Source§fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
Encodes the message with a length-delimiter to a buffer. Read more
Source§fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Encodes the message with a length-delimiter to a newly allocated buffer.
Source§fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
Decodes an instance of the message from a buffer. Read more
Source§fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
Decodes a length-delimited instance of the message from the buffer.
Source§fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
Decodes an instance of the message from a buffer, and merges it into
self. Read moreSource§fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
Decodes a length-delimited instance of the message from buffer, and
merges it into
self.Source§impl PartialEq for SubscribePushRequest
impl PartialEq for SubscribePushRequest
impl Copy for SubscribePushRequest
impl Eq for SubscribePushRequest
impl StructuralPartialEq for SubscribePushRequest
Auto Trait Implementations§
impl Freeze for SubscribePushRequest
impl RefUnwindSafe for SubscribePushRequest
impl Send for SubscribePushRequest
impl Sync for SubscribePushRequest
impl Unpin for SubscribePushRequest
impl UnsafeUnpin for SubscribePushRequest
impl UnwindSafe for SubscribePushRequest
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,
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Checks if this value is equivalent to the given key. Read more
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Checks if this value is equivalent to the given key. Read more
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].