Class: Google::Cloud::Bigtable::V2::ReadChangeStreamResponse::Heartbeat

Inherits:

Object

• Object
• Google::Cloud::Bigtable::V2::ReadChangeStreamResponse::Heartbeat

Extended by:

Protobuf::MessageExts::ClassMethods

Includes:

Protobuf::MessageExts

Defined in:

proto_docs/google/bigtable/v2/bigtable.rb

Overview

A periodic message with information that can be used to checkpoint the state of a stream.

Instance Attribute Summary

• #continuation_token ⇒ ::Google::Cloud::Bigtable::V2::StreamContinuationToken

  A token that can be provided to a subsequent ReadChangeStream call to pick up reading at the current stream position.

• #estimated_low_watermark ⇒ ::Google::Protobuf::Timestamp

  An estimate of the commit timestamp that is usually lower than or equal to any timestamp for a record that will be delivered in the future on the stream.

Instance Attribute Details

#continuation_token ⇒ ::Google::Cloud::Bigtable::V2::StreamContinuationToken

Returns A token that can be provided to a subsequent ReadChangeStream call to pick up reading at the current stream position.

Returns:

• (::Google::Cloud::Bigtable::V2::StreamContinuationToken) —

  A token that can be provided to a subsequent ReadChangeStream call to pick up reading at the current stream position.

# File 'proto_docs/google/bigtable/v2/bigtable.rb', line 707

class Heartbeat
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods
end

#estimated_low_watermark ⇒ ::Google::Protobuf::Timestamp

Returns An estimate of the commit timestamp that is usually lower than or equal to any timestamp for a record that will be delivered in the future on the stream. It is possible that, under particular circumstances that a future record has a timestamp is is lower than a previously seen timestamp. For an example usage see https://beam.apache.org/documentation/basics/#watermarks.

Returns:

• (::Google::Protobuf::Timestamp) —

  An estimate of the commit timestamp that is usually lower than or equal to any timestamp for a record that will be delivered in the future on the stream. It is possible that, under particular circumstances that a future record has a timestamp is is lower than a previously seen timestamp. For an example usage see https://beam.apache.org/documentation/basics/#watermarks

# File 'proto_docs/google/bigtable/v2/bigtable.rb', line 707

class Heartbeat
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods
end