Packages

t

com.google.pubsub.v1

StreamingPullRequestOrBuilder

trait StreamingPullRequestOrBuilder extends MessageOrBuilder

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. StreamingPullRequestOrBuilder
  2. MessageOrBuilder
  3. MessageLiteOrBuilder
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Abstract Value Members

  1. abstract def findInitializationErrors(): List[String]
    Definition Classes
    MessageOrBuilder
  2. abstract def getAckIds(index: Int): String 

    List of acknowledgement IDs for acknowledging previously received messages
(received on this stream or a different stream). If an ack ID has expired,
the corresponding message may be redelivered later. Acknowledging a message
more than once will not result in an error. If the acknowledgement ID is
malformed, the stream will be aborted with status `INVALID_ARGUMENT`.


    List of acknowledgement IDs for acknowledging previously received messages
(received on this stream or a different stream). If an ack ID has expired,
the corresponding message may be redelivered later. Acknowledging a message
more than once will not result in an error. If the acknowledgement ID is
malformed, the stream will be aborted with status `INVALID_ARGUMENT`.

    repeated string ack_ids = 2;

  3. abstract def getAckIdsBytes(index: Int): ByteString 

    List of acknowledgement IDs for acknowledging previously received messages
(received on this stream or a different stream). If an ack ID has expired,
the corresponding message may be redelivered later. Acknowledging a message
more than once will not result in an error. If the acknowledgement ID is
malformed, the stream will be aborted with status `INVALID_ARGUMENT`.


    List of acknowledgement IDs for acknowledging previously received messages
(received on this stream or a different stream). If an ack ID has expired,
the corresponding message may be redelivered later. Acknowledging a message
more than once will not result in an error. If the acknowledgement ID is
malformed, the stream will be aborted with status `INVALID_ARGUMENT`.

    repeated string ack_ids = 2;

  4. abstract def getAckIdsCount(): Int 

    List of acknowledgement IDs for acknowledging previously received messages
(received on this stream or a different stream). If an ack ID has expired,
the corresponding message may be redelivered later. Acknowledging a message
more than once will not result in an error. If the acknowledgement ID is
malformed, the stream will be aborted with status `INVALID_ARGUMENT`.


    List of acknowledgement IDs for acknowledging previously received messages
(received on this stream or a different stream). If an ack ID has expired,
the corresponding message may be redelivered later. Acknowledging a message
more than once will not result in an error. If the acknowledgement ID is
malformed, the stream will be aborted with status `INVALID_ARGUMENT`.

    repeated string ack_ids = 2;

  5. abstract def getAckIdsList(): List[String] 

    List of acknowledgement IDs for acknowledging previously received messages
(received on this stream or a different stream). If an ack ID has expired,
the corresponding message may be redelivered later. Acknowledging a message
more than once will not result in an error. If the acknowledgement ID is
malformed, the stream will be aborted with status `INVALID_ARGUMENT`.


    List of acknowledgement IDs for acknowledging previously received messages
(received on this stream or a different stream). If an ack ID has expired,
the corresponding message may be redelivered later. Acknowledging a message
more than once will not result in an error. If the acknowledgement ID is
malformed, the stream will be aborted with status `INVALID_ARGUMENT`.

    repeated string ack_ids = 2;

  6. abstract def getAllFields(): Map[FieldDescriptor, AnyRef]
    Definition Classes
    MessageOrBuilder
  7. abstract def getDefaultInstanceForType(): Message
    Definition Classes
    MessageOrBuilder → MessageLiteOrBuilder
  8. abstract def getDescriptorForType(): Descriptor
    Definition Classes
    MessageOrBuilder
  9. abstract def getField(arg0: FieldDescriptor): AnyRef
    Definition Classes
    MessageOrBuilder
  10. abstract def getInitializationErrorString(): String
    Definition Classes
    MessageOrBuilder
  11. abstract def getModifyDeadlineAckIds(index: Int): String 

    List of acknowledgement IDs whose deadline will be modified based on the
corresponding element in `modify_deadline_seconds`. This field can be used
to indicate that more time is needed to process a message by the
subscriber, or to make the message available for redelivery if the
processing was interrupted.


    List of acknowledgement IDs whose deadline will be modified based on the
corresponding element in `modify_deadline_seconds`. This field can be used
to indicate that more time is needed to process a message by the
subscriber, or to make the message available for redelivery if the
processing was interrupted.

    repeated string modify_deadline_ack_ids = 4;

  12. abstract def getModifyDeadlineAckIdsBytes(index: Int): ByteString 

    List of acknowledgement IDs whose deadline will be modified based on the
corresponding element in `modify_deadline_seconds`. This field can be used
to indicate that more time is needed to process a message by the
subscriber, or to make the message available for redelivery if the
processing was interrupted.


    List of acknowledgement IDs whose deadline will be modified based on the
corresponding element in `modify_deadline_seconds`. This field can be used
to indicate that more time is needed to process a message by the
subscriber, or to make the message available for redelivery if the
processing was interrupted.

    repeated string modify_deadline_ack_ids = 4;

  13. abstract def getModifyDeadlineAckIdsCount(): Int 

    List of acknowledgement IDs whose deadline will be modified based on the
corresponding element in `modify_deadline_seconds`. This field can be used
to indicate that more time is needed to process a message by the
subscriber, or to make the message available for redelivery if the
processing was interrupted.


    List of acknowledgement IDs whose deadline will be modified based on the
corresponding element in `modify_deadline_seconds`. This field can be used
to indicate that more time is needed to process a message by the
subscriber, or to make the message available for redelivery if the
processing was interrupted.

    repeated string modify_deadline_ack_ids = 4;

  14. abstract def getModifyDeadlineAckIdsList(): List[String] 

    List of acknowledgement IDs whose deadline will be modified based on the
corresponding element in `modify_deadline_seconds`. This field can be used
to indicate that more time is needed to process a message by the
subscriber, or to make the message available for redelivery if the
processing was interrupted.


    List of acknowledgement IDs whose deadline will be modified based on the
corresponding element in `modify_deadline_seconds`. This field can be used
to indicate that more time is needed to process a message by the
subscriber, or to make the message available for redelivery if the
processing was interrupted.

    repeated string modify_deadline_ack_ids = 4;

  15. abstract def getModifyDeadlineSeconds(index: Int): Int 

    The list of new ack deadlines for the IDs listed in
`modify_deadline_ack_ids`. The size of this list must be the same as the
size of `modify_deadline_ack_ids`. If it differs the stream will be aborted
with `INVALID_ARGUMENT`. Each element in this list is applied to the
element in the same position in `modify_deadline_ack_ids`. The new ack
deadline is with respect to the time this request was sent to the Pub/Sub
system. Must be >= 0. For example, if the value is 10, the new ack deadline
will expire 10 seconds after this request is received. If the value is 0,
the message is immediately made available for another streaming or
non-streaming pull request. If the value is < 0 (an error), the stream will
be aborted with status `INVALID_ARGUMENT`.


    The list of new ack deadlines for the IDs listed in
`modify_deadline_ack_ids`. The size of this list must be the same as the
size of `modify_deadline_ack_ids`. If it differs the stream will be aborted
with `INVALID_ARGUMENT`. Each element in this list is applied to the
element in the same position in `modify_deadline_ack_ids`. The new ack
deadline is with respect to the time this request was sent to the Pub/Sub
system. Must be >= 0. For example, if the value is 10, the new ack deadline
will expire 10 seconds after this request is received. If the value is 0,
the message is immediately made available for another streaming or
non-streaming pull request. If the value is < 0 (an error), the stream will
be aborted with status `INVALID_ARGUMENT`.

    repeated int32 modify_deadline_seconds = 3;

  16. abstract def getModifyDeadlineSecondsCount(): Int 

    The list of new ack deadlines for the IDs listed in
`modify_deadline_ack_ids`. The size of this list must be the same as the
size of `modify_deadline_ack_ids`. If it differs the stream will be aborted
with `INVALID_ARGUMENT`. Each element in this list is applied to the
element in the same position in `modify_deadline_ack_ids`. The new ack
deadline is with respect to the time this request was sent to the Pub/Sub
system. Must be >= 0. For example, if the value is 10, the new ack deadline
will expire 10 seconds after this request is received. If the value is 0,
the message is immediately made available for another streaming or
non-streaming pull request. If the value is < 0 (an error), the stream will
be aborted with status `INVALID_ARGUMENT`.


    The list of new ack deadlines for the IDs listed in
`modify_deadline_ack_ids`. The size of this list must be the same as the
size of `modify_deadline_ack_ids`. If it differs the stream will be aborted
with `INVALID_ARGUMENT`. Each element in this list is applied to the
element in the same position in `modify_deadline_ack_ids`. The new ack
deadline is with respect to the time this request was sent to the Pub/Sub
system. Must be >= 0. For example, if the value is 10, the new ack deadline
will expire 10 seconds after this request is received. If the value is 0,
the message is immediately made available for another streaming or
non-streaming pull request. If the value is < 0 (an error), the stream will
be aborted with status `INVALID_ARGUMENT`.

    repeated int32 modify_deadline_seconds = 3;

  17. abstract def getModifyDeadlineSecondsList(): List[Integer] 

    The list of new ack deadlines for the IDs listed in
`modify_deadline_ack_ids`. The size of this list must be the same as the
size of `modify_deadline_ack_ids`. If it differs the stream will be aborted
with `INVALID_ARGUMENT`. Each element in this list is applied to the
element in the same position in `modify_deadline_ack_ids`. The new ack
deadline is with respect to the time this request was sent to the Pub/Sub
system. Must be >= 0. For example, if the value is 10, the new ack deadline
will expire 10 seconds after this request is received. If the value is 0,
the message is immediately made available for another streaming or
non-streaming pull request. If the value is < 0 (an error), the stream will
be aborted with status `INVALID_ARGUMENT`.


    The list of new ack deadlines for the IDs listed in
`modify_deadline_ack_ids`. The size of this list must be the same as the
size of `modify_deadline_ack_ids`. If it differs the stream will be aborted
with `INVALID_ARGUMENT`. Each element in this list is applied to the
element in the same position in `modify_deadline_ack_ids`. The new ack
deadline is with respect to the time this request was sent to the Pub/Sub
system. Must be >= 0. For example, if the value is 10, the new ack deadline
will expire 10 seconds after this request is received. If the value is 0,
the message is immediately made available for another streaming or
non-streaming pull request. If the value is < 0 (an error), the stream will
be aborted with status `INVALID_ARGUMENT`.

    repeated int32 modify_deadline_seconds = 3;

  18. abstract def getOneofFieldDescriptor(arg0: OneofDescriptor): FieldDescriptor
    Definition Classes
    MessageOrBuilder
  19. abstract def getRepeatedField(arg0: FieldDescriptor, arg1: Int): AnyRef
    Definition Classes
    MessageOrBuilder
  20. abstract def getRepeatedFieldCount(arg0: FieldDescriptor): Int
    Definition Classes
    MessageOrBuilder
  21. abstract def getStreamAckDeadlineSeconds(): Int 

    The ack deadline to use for the stream. This must be provided in the
first request on the stream, but it can also be updated on subsequent
requests from client to server. The minimum deadline you can specify is 10
seconds. The maximum deadline you can specify is 600 seconds (10 minutes).


    The ack deadline to use for the stream. This must be provided in the
first request on the stream, but it can also be updated on subsequent
requests from client to server. The minimum deadline you can specify is 10
seconds. The maximum deadline you can specify is 600 seconds (10 minutes).

    int32 stream_ack_deadline_seconds = 5;

  22. abstract def getSubscription(): String 

    The subscription for which to initialize the new stream. This must be
provided in the first request on the stream, and must not be set in
subsequent requests from client to server.
Format is `projects/{project}/subscriptions/{sub}`.


    The subscription for which to initialize the new stream. This must be
provided in the first request on the stream, and must not be set in
subsequent requests from client to server.
Format is `projects/{project}/subscriptions/{sub}`.

    string subscription = 1;

  23. abstract def getSubscriptionBytes(): ByteString 

    The subscription for which to initialize the new stream. This must be
provided in the first request on the stream, and must not be set in
subsequent requests from client to server.
Format is `projects/{project}/subscriptions/{sub}`.


    The subscription for which to initialize the new stream. This must be
provided in the first request on the stream, and must not be set in
subsequent requests from client to server.
Format is `projects/{project}/subscriptions/{sub}`.

    string subscription = 1;

  24. abstract def getUnknownFields(): UnknownFieldSet
    Definition Classes
    MessageOrBuilder
  25. abstract def hasField(arg0: FieldDescriptor): Boolean
    Definition Classes
    MessageOrBuilder
  26. abstract def hasOneof(arg0: OneofDescriptor): Boolean
    Definition Classes
    MessageOrBuilder
  27. abstract def isInitialized(): Boolean
    Definition Classes
    MessageLiteOrBuilder

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  8. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  9. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  12. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  14. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  15. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  16. def toString(): String
    Definition Classes
    AnyRef → Any
  17. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  18. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  19. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )

Inherited from MessageOrBuilder

Inherited from MessageLiteOrBuilder

Inherited from AnyRef

Inherited from Any

Ungrouped