pub struct StreamAutoClaimReply {
pub next_stream_id: String,
pub claimed: Vec<StreamId>,
pub deleted_ids: Vec<String>,
pub invalid_entries: bool,
}Expand description
The XAUTOCLAIM reply.
Mirrors redis-rs’s streams::StreamAutoClaimReply type.
Fields§
§next_stream_id: StringThe ID to pass as start to the next XAUTOCLAIM call (0-0 when done).
claimed: Vec<StreamId>The claimed entries. With JUSTID, each entry’s map is empty.
deleted_ids: Vec<String>The pending IDs that were deleted from the stream (empty before Valkey 7.0).
invalid_entries: boolWhether nil entries (deleted from the stream; Redis 6 only) were skipped.
Only detected with JUSTID, since glide-core drops nil full entries.
Trait Implementations§
Source§impl Clone for StreamAutoClaimReply
impl Clone for StreamAutoClaimReply
Source§impl Debug for StreamAutoClaimReply
impl Debug for StreamAutoClaimReply
Source§impl Default for StreamAutoClaimReply
impl Default for StreamAutoClaimReply
Source§impl FromValkeyValue for StreamAutoClaimReply
impl FromValkeyValue for StreamAutoClaimReply
Source§fn from_owned_valkey_value(value: ValkeyValue) -> ValkeyResult<Self>
fn from_owned_valkey_value(value: ValkeyValue) -> ValkeyResult<Self>
Decodes [next_stream_id, claimed, deleted_ids], where deleted_ids is absent
before Valkey 7.0.
Source§fn from_valkey_value(value: &ValkeyValue) -> ValkeyResult<Self>
fn from_valkey_value(value: &ValkeyValue) -> ValkeyResult<Self>
Converts a borrowed
ValkeyValue into Self.Auto Trait Implementations§
impl Freeze for StreamAutoClaimReply
impl RefUnwindSafe for StreamAutoClaimReply
impl Send for StreamAutoClaimReply
impl Sync for StreamAutoClaimReply
impl Unpin for StreamAutoClaimReply
impl UnsafeUnpin for StreamAutoClaimReply
impl UnwindSafe for StreamAutoClaimReply
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
Source§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
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::RequestCreates a shared type from an unshared type.