Module publisher.pagers (2.31.0)

API documentation for pubsub_v1.services.publisher.pagers module.

Classes

ListTopicSnapshotsAsyncPager

ListTopicSnapshotsAsyncPager(
 method: typing.Callable[
 [...], typing.Awaitable[google.cloud.pubsub_v1.types.ListTopicSnapshotsResponse]
 ],
 request: google.cloud.pubsub_v1.types.ListTopicSnapshotsRequest,
 response: google.cloud.pubsub_v1.types.ListTopicSnapshotsResponse,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary_async.AsyncRetry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

A pager for iterating through list_topic_snapshots requests.

This class thinly wraps an initial google.pubsub_v1.types.ListTopicSnapshotsResponse object, and provides an __aiter__ method to iterate through its snapshots field.

If there are more pages, the __aiter__ method will make additional ListTopicSnapshots requests and continue to iterate through the snapshots field on the corresponding responses.

All the usual google.pubsub_v1.types.ListTopicSnapshotsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

ListTopicSnapshotsPager

ListTopicSnapshotsPager(
 method: typing.Callable[
 [...], google.cloud.pubsub_v1.types.ListTopicSnapshotsResponse
 ],
 request: google.cloud.pubsub_v1.types.ListTopicSnapshotsRequest,
 response: google.cloud.pubsub_v1.types.ListTopicSnapshotsResponse,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

A pager for iterating through list_topic_snapshots requests.

This class thinly wraps an initial google.pubsub_v1.types.ListTopicSnapshotsResponse object, and provides an __iter__ method to iterate through its snapshots field.

If there are more pages, the __iter__ method will make additional ListTopicSnapshots requests and continue to iterate through the snapshots field on the corresponding responses.

ListTopicSubscriptionsAsyncPager

ListTopicSubscriptionsAsyncPager(
 method: typing.Callable[
 [...],
 typing.Awaitable[google.cloud.pubsub_v1.types.ListTopicSubscriptionsResponse],
 ],
 request: google.cloud.pubsub_v1.types.ListTopicSubscriptionsRequest,
 response: google.cloud.pubsub_v1.types.ListTopicSubscriptionsResponse,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary_async.AsyncRetry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

A pager for iterating through list_topic_subscriptions requests.

This class thinly wraps an initial google.pubsub_v1.types.ListTopicSubscriptionsResponse object, and provides an __aiter__ method to iterate through its subscriptions field.

If there are more pages, the __aiter__ method will make additional ListTopicSubscriptions requests and continue to iterate through the subscriptions field on the corresponding responses.

All the usual google.pubsub_v1.types.ListTopicSubscriptionsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

ListTopicSubscriptionsPager

ListTopicSubscriptionsPager(
 method: typing.Callable[
 [...], google.cloud.pubsub_v1.types.ListTopicSubscriptionsResponse
 ],
 request: google.cloud.pubsub_v1.types.ListTopicSubscriptionsRequest,
 response: google.cloud.pubsub_v1.types.ListTopicSubscriptionsResponse,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

A pager for iterating through list_topic_subscriptions requests.

This class thinly wraps an initial google.pubsub_v1.types.ListTopicSubscriptionsResponse object, and provides an __iter__ method to iterate through its subscriptions field.

If there are more pages, the __iter__ method will make additional ListTopicSubscriptions requests and continue to iterate through the subscriptions field on the corresponding responses.

ListTopicsAsyncPager

ListTopicsAsyncPager(
 method: typing.Callable[
 [...], typing.Awaitable[google.cloud.pubsub_v1.types.ListTopicsResponse]
 ],
 request: google.cloud.pubsub_v1.types.ListTopicsRequest,
 response: google.cloud.pubsub_v1.types.ListTopicsResponse,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary_async.AsyncRetry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

A pager for iterating through list_topics requests.

This class thinly wraps an initial google.pubsub_v1.types.ListTopicsResponse object, and provides an __aiter__ method to iterate through its topics field.

If there are more pages, the __aiter__ method will make additional ListTopics requests and continue to iterate through the topics field on the corresponding responses.

All the usual google.pubsub_v1.types.ListTopicsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

ListTopicsPager

ListTopicsPager(
 method: typing.Callable[[...], google.cloud.pubsub_v1.types.ListTopicsResponse],
 request: google.cloud.pubsub_v1.types.ListTopicsRequest,
 response: google.cloud.pubsub_v1.types.ListTopicsResponse,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)