pub struct ShredStreamClient { /* private fields */ }Expand description
ShredStream 客户端
Implementations§
Source§impl ShredStreamClient
impl ShredStreamClient
Sourcepub async fn new_with_config(
endpoint: impl Into<String>,
config: ShredStreamConfig,
) -> AnyResult<Self>
pub async fn new_with_config( endpoint: impl Into<String>, config: ShredStreamConfig, ) -> AnyResult<Self>
使用自定义配置创建客户端
Sourcepub async fn subscribe(&self) -> AnyResult<Arc<ArrayQueue<DexEvent>>>
pub async fn subscribe(&self) -> AnyResult<Arc<ArrayQueue<DexEvent>>>
订阅 DEX 事件（自动重连）
返回一个队列，事件会被推送到该队列中
Sourcepub async fn subscribe_with_filter(
&self,
event_type_filter: Option<EventTypeFilter>,
) -> AnyResult<Arc<ArrayQueue<DexEvent>>>
pub async fn subscribe_with_filter( &self, event_type_filter: Option<EventTypeFilter>, ) -> AnyResult<Arc<ArrayQueue<DexEvent>>>
订阅 DEX 事件，并在 ShredStream 热路径中按 SDK 事件类型提前过滤。
过滤发生在解析分发前，用于低延迟场景避免解析不需要的协议/事件。
Trait Implementations§
Source§impl Clone for ShredStreamClient
impl Clone for ShredStreamClient
Source§fn clone(&self) -> ShredStreamClient
fn clone(&self) -> ShredStreamClient
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for ShredStreamClient
impl !RefUnwindSafe for ShredStreamClient
impl Send for ShredStreamClient
impl Sync for ShredStreamClient
impl Unpin for ShredStreamClient
impl UnsafeUnpin for ShredStreamClient
impl !UnwindSafe for ShredStreamClient
Blanket Implementations§
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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<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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§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::RequestSource§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