Enum google_api_proto::google::cloud::pubsublite::v1::time_target::Time
source · pub enum Time {
PublishTime(Timestamp),
EventTime(Timestamp),
}
Expand description
The type of message time to query.
Variants§
PublishTime(Timestamp)
Request the cursor of the first message with publish time greater than or
equal to publish_time
. All messages thereafter are guaranteed to have
publish times >= publish_time
.
EventTime(Timestamp)
Request the cursor of the first message with event time greater than or
equal to event_time
. If messages are missing an event time, the publish
time is used as a fallback. As event times are user supplied, subsequent
messages may have event times less than event_time
and should be
filtered by the client, if necessary.
Implementations§
source§impl Time
impl Time
sourcepub fn merge(
field: &mut Option<Time>,
tag: u32,
wire_type: WireType,
buf: &mut impl Buf,
ctx: DecodeContext,
) -> Result<(), DecodeError>
pub fn merge( field: &mut Option<Time>, tag: u32, wire_type: WireType, buf: &mut impl Buf, ctx: DecodeContext, ) -> Result<(), DecodeError>
Decodes an instance of the message from a buffer, and merges it into self.
sourcepub fn encoded_len(&self) -> usize
pub fn encoded_len(&self) -> usize
Returns the encoded length of the message without a length delimiter.
Trait Implementations§
source§impl PartialEq for Time
impl PartialEq for Time
impl Copy for Time
impl StructuralPartialEq for Time
Auto Trait Implementations§
impl Freeze for Time
impl RefUnwindSafe for Time
impl Send for Time
impl Sync for Time
impl Unpin for Time
impl UnwindSafe for Time
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<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>
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