Class: Google::Cloud::PubSub::V1::StreamingPullRequest

Inherits:

Object

• Object
• Google::Cloud::PubSub::V1::StreamingPullRequest

Extended by:

Protobuf::MessageExts::ClassMethods

Includes:

Protobuf::MessageExts

Defined in:

proto_docs/google/pubsub/v1/pubsub.rb

Overview

Request for the StreamingPull streaming RPC method. This request is used to establish the initial stream as well as to stream acknowledgements and ack deadline modifications from the client to the server.

Instance Attribute Summary

• #ack_ids ⇒ ::Array<::String>

  List of acknowledgement IDs for acknowledging previously received messages (received on this stream or a different stream).

• #client_id ⇒ ::String

  A unique identifier that is used to distinguish client instances from each other.

• #max_outstanding_bytes ⇒ ::Integer

  Flow control settings for the maximum number of outstanding bytes.

• #max_outstanding_messages ⇒ ::Integer

  Flow control settings for the maximum number of outstanding messages.

• #modify_deadline_ack_ids ⇒ ::Array<::String>

  List of acknowledgement IDs whose deadline will be modified based on the corresponding element in modify_deadline_seconds.

• #modify_deadline_seconds ⇒ ::Array<::Integer>

  The list of new ack deadlines for the IDs listed in modify_deadline_ack_ids.

• #stream_ack_deadline_seconds ⇒ ::Integer

  Required.

• #subscription ⇒ ::String

  Required.

Instance Attribute Details

#ack_ids ⇒ ::Array<::String>

# File 'proto_docs/google/pubsub/v1/pubsub.rb', line 1074

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

#client_id ⇒ ::String

# File 'proto_docs/google/pubsub/v1/pubsub.rb', line 1074

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

#max_outstanding_bytes ⇒ ::Integer

# File 'proto_docs/google/pubsub/v1/pubsub.rb', line 1074

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

#max_outstanding_messages ⇒ ::Integer

# File 'proto_docs/google/pubsub/v1/pubsub.rb', line 1074

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

#modify_deadline_ack_ids ⇒ ::Array<::String>

# File 'proto_docs/google/pubsub/v1/pubsub.rb', line 1074

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

#modify_deadline_seconds ⇒ ::Array<::Integer>

# File 'proto_docs/google/pubsub/v1/pubsub.rb', line 1074

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

#stream_ack_deadline_seconds ⇒ ::Integer

# File 'proto_docs/google/pubsub/v1/pubsub.rb', line 1074

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

#subscription ⇒ ::String

# File 'proto_docs/google/pubsub/v1/pubsub.rb', line 1074

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