Package Methods (2.29.1)

Summary of entries of Methods for pubsub.

google.cloud.pubsub_v1.publisher.client.Client

Client(
    batch_settings: typing.Union[
        google.cloud.pubsub_v1.types.BatchSettings, typing.Sequence
    ] = (),
    publisher_options: typing.Union[
        google.cloud.pubsub_v1.types.PublisherOptions, typing.Sequence
    ] = (),
    **kwargs: typing.Any
)

Instantiates the publisher client.

See more: google.cloud.pubsub_v1.publisher.client.Client

google.cloud.pubsub_v1.publisher.client.Client.__exit__

__exit__(type, value, traceback)

Releases underlying transport's resources.

See more: google.cloud.pubsub_v1.publisher.client.Client.exit

google.cloud.pubsub_v1.publisher.client.Client.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.pubsub_v1.publisher.client.Client.common_billing_account_path

google.cloud.pubsub_v1.publisher.client.Client.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.pubsub_v1.publisher.client.Client.common_folder_path

google.cloud.pubsub_v1.publisher.client.Client.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.pubsub_v1.publisher.client.Client.common_location_path

google.cloud.pubsub_v1.publisher.client.Client.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.pubsub_v1.publisher.client.Client.common_organization_path

google.cloud.pubsub_v1.publisher.client.Client.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.pubsub_v1.publisher.client.Client.common_project_path

google.cloud.pubsub_v1.publisher.client.Client.create_topic

create_topic(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.Topic, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    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[
        int,
        float,
        google.api_core.timeout.ConstantTimeout,
        google.api_core.timeout.ExponentialTimeout,
    ] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.pubsub_v1.types.Topic

Creates the given topic with the given name.

See more: google.cloud.pubsub_v1.publisher.client.Client.create_topic

google.cloud.pubsub_v1.publisher.client.Client.delete_topic

delete_topic(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.DeleteTopicRequest, dict]
    ] = None,
    *,
    topic: typing.Optional[str] = None,
    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[
        int,
        float,
        google.api_core.timeout.ConstantTimeout,
        google.api_core.timeout.ExponentialTimeout,
    ] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> None

Deletes the topic with the given name.

See more: google.cloud.pubsub_v1.publisher.client.Client.delete_topic

google.cloud.pubsub_v1.publisher.client.Client.detach_subscription

detach_subscription(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.DetachSubscriptionRequest, dict]
    ] = None,
    *,
    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[
        int,
        float,
        google.api_core.timeout.ConstantTimeout,
        google.api_core.timeout.ExponentialTimeout,
    ] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.pubsub_v1.types.DetachSubscriptionResponse

Detaches a subscription from this topic.

See more: google.cloud.pubsub_v1.publisher.client.Client.detach_subscription

google.cloud.pubsub_v1.publisher.client.Client.ensure_cleanup_and_commit_timer_runs

ensure_cleanup_and_commit_timer_runs() -> None

Ensure a cleanup/commit timer thread is running.

See more: google.cloud.pubsub_v1.publisher.client.Client.ensure_cleanup_and_commit_timer_runs

google.cloud.pubsub_v1.publisher.client.Client.from_service_account_file

from_service_account_file(
    filename: str,
    batch_settings: typing.Union[
        google.cloud.pubsub_v1.types.BatchSettings, typing.Sequence
    ] = (),
    **kwargs: typing.Any
) -> google.cloud.pubsub_v1.publisher.client.Client

Creates an instance of this client using the provided credentials file.

See more: google.cloud.pubsub_v1.publisher.client.Client.from_service_account_file

google.cloud.pubsub_v1.publisher.client.Client.from_service_account_info

from_service_account_info(info: dict, *args, **kwargs)

Creates an instance of this client using the provided credentials info.

See more: google.cloud.pubsub_v1.publisher.client.Client.from_service_account_info

google.cloud.pubsub_v1.publisher.client.Client.from_service_account_json

from_service_account_json(
    filename: str,
    batch_settings: typing.Union[
        google.cloud.pubsub_v1.types.BatchSettings, typing.Sequence
    ] = (),
    **kwargs: typing.Any
) -> google.cloud.pubsub_v1.publisher.client.Client

Creates an instance of this client using the provided credentials file.

See more: google.cloud.pubsub_v1.publisher.client.Client.from_service_account_json

google.cloud.pubsub_v1.publisher.client.Client.get_iam_policy

get_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None,
    *,
    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[
        int,
        float,
        google.api_core.timeout.ConstantTimeout,
        google.api_core.timeout.ExponentialTimeout,
    ] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.Policy

Gets the IAM access control policy for a function.

See more: google.cloud.pubsub_v1.publisher.client.Client.get_iam_policy

google.cloud.pubsub_v1.publisher.client.Client.get_mtls_endpoint_and_cert_source

get_mtls_endpoint_and_cert_source(
    client_options: typing.Optional[
        google.api_core.client_options.ClientOptions
    ] = None,
)

Deprecated.

See more: google.cloud.pubsub_v1.publisher.client.Client.get_mtls_endpoint_and_cert_source

google.cloud.pubsub_v1.publisher.client.Client.get_topic

get_topic(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.GetTopicRequest, dict]
    ] = None,
    *,
    topic: typing.Optional[str] = None,
    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[
        int,
        float,
        google.api_core.timeout.ConstantTimeout,
        google.api_core.timeout.ExponentialTimeout,
    ] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.pubsub_v1.types.Topic

Gets the configuration of a topic.

See more: google.cloud.pubsub_v1.publisher.client.Client.get_topic

google.cloud.pubsub_v1.publisher.client.Client.list_topic_snapshots

list_topic_snapshots(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.ListTopicSnapshotsRequest, dict]
    ] = None,
    *,
    topic: typing.Optional[str] = None,
    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[
        int,
        float,
        google.api_core.timeout.ConstantTimeout,
        google.api_core.timeout.ExponentialTimeout,
    ] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.pubsub_v1.services.publisher.pagers.ListTopicSnapshotsPager

Lists the names of the snapshots on this topic.

See more: google.cloud.pubsub_v1.publisher.client.Client.list_topic_snapshots

google.cloud.pubsub_v1.publisher.client.Client.list_topic_subscriptions

list_topic_subscriptions(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.ListTopicSubscriptionsRequest, dict]
    ] = None,
    *,
    topic: typing.Optional[str] = None,
    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[
        int,
        float,
        google.api_core.timeout.ConstantTimeout,
        google.api_core.timeout.ExponentialTimeout,
    ] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.pubsub_v1.services.publisher.pagers.ListTopicSubscriptionsPager

Lists the names of the attached subscriptions on this topic.

See more: google.cloud.pubsub_v1.publisher.client.Client.list_topic_subscriptions

google.cloud.pubsub_v1.publisher.client.Client.list_topics

list_topics(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.ListTopicsRequest, dict]
    ] = None,
    *,
    project: typing.Optional[str] = None,
    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[
        int,
        float,
        google.api_core.timeout.ConstantTimeout,
        google.api_core.timeout.ExponentialTimeout,
    ] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.pubsub_v1.services.publisher.pagers.ListTopicsPager

Lists matching topics.

See more: google.cloud.pubsub_v1.publisher.client.Client.list_topics

google.cloud.pubsub_v1.publisher.client.Client.parse_common_billing_account_path

parse_common_billing_account_path(path: str) -> typing.Dict[str, str]

Parse a billing_account path into its component segments.

See more: google.cloud.pubsub_v1.publisher.client.Client.parse_common_billing_account_path

google.cloud.pubsub_v1.publisher.client.Client.parse_common_folder_path

parse_common_folder_path(path: str) -> typing.Dict[str, str]

Parse a folder path into its component segments.

See more: google.cloud.pubsub_v1.publisher.client.Client.parse_common_folder_path

google.cloud.pubsub_v1.publisher.client.Client.parse_common_location_path

parse_common_location_path(path: str) -> typing.Dict[str, str]

Parse a location path into its component segments.

See more: google.cloud.pubsub_v1.publisher.client.Client.parse_common_location_path

google.cloud.pubsub_v1.publisher.client.Client.parse_common_organization_path

parse_common_organization_path(path: str) -> typing.Dict[str, str]

Parse a organization path into its component segments.

See more: google.cloud.pubsub_v1.publisher.client.Client.parse_common_organization_path

google.cloud.pubsub_v1.publisher.client.Client.parse_common_project_path

parse_common_project_path(path: str) -> typing.Dict[str, str]

Parse a project path into its component segments.

See more: google.cloud.pubsub_v1.publisher.client.Client.parse_common_project_path

google.cloud.pubsub_v1.publisher.client.Client.parse_schema_path

parse_schema_path(path: str) -> typing.Dict[str, str]

Parses a schema path into its component segments.

See more: google.cloud.pubsub_v1.publisher.client.Client.parse_schema_path

google.cloud.pubsub_v1.publisher.client.Client.parse_subscription_path

parse_subscription_path(path: str) -> typing.Dict[str, str]

Parses a subscription path into its component segments.

See more: google.cloud.pubsub_v1.publisher.client.Client.parse_subscription_path

google.cloud.pubsub_v1.publisher.client.Client.parse_topic_path

parse_topic_path(path: str) -> typing.Dict[str, str]

Parses a topic path into its component segments.

See more: google.cloud.pubsub_v1.publisher.client.Client.parse_topic_path

google.cloud.pubsub_v1.publisher.client.Client.publish

publish(
    topic: str,
    data: bytes,
    ordering_key: str = "",
    retry: OptionalRetry = _MethodDefault._DEFAULT_VALUE,
    timeout: types.OptionalTimeout = _MethodDefault._DEFAULT_VALUE,
    **attrs: typing.Union[bytes, str]
) -> pubsub_v1.publisher.futures.Future

Publish a single message.

See more: google.cloud.pubsub_v1.publisher.client.Client.publish

google.cloud.pubsub_v1.publisher.client.Client.resume_publish

resume_publish(topic: str, ordering_key: str) -> None

Resume publish on an ordering key that has had unrecoverable errors.

See more: google.cloud.pubsub_v1.publisher.client.Client.resume_publish

google.cloud.pubsub_v1.publisher.client.Client.schema_path

schema_path(project: str, schema: str) -> str

Returns a fully-qualified schema string.

See more: google.cloud.pubsub_v1.publisher.client.Client.schema_path

google.cloud.pubsub_v1.publisher.client.Client.set_iam_policy

set_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None,
    *,
    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[
        int,
        float,
        google.api_core.timeout.ConstantTimeout,
        google.api_core.timeout.ExponentialTimeout,
    ] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.Policy

Sets the IAM access control policy on the specified function.

See more: google.cloud.pubsub_v1.publisher.client.Client.set_iam_policy

google.cloud.pubsub_v1.publisher.client.Client.stop

stop() -> None

Immediately publish all outstanding messages.

See more: google.cloud.pubsub_v1.publisher.client.Client.stop

google.cloud.pubsub_v1.publisher.client.Client.subscription_path

subscription_path(project: str, subscription: str) -> str

Returns a fully-qualified subscription string.

See more: google.cloud.pubsub_v1.publisher.client.Client.subscription_path

google.cloud.pubsub_v1.publisher.client.Client.test_iam_permissions

test_iam_permissions(
    request: typing.Optional[
        google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
    ] = None,
    *,
    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[
        int,
        float,
        google.api_core.timeout.ConstantTimeout,
        google.api_core.timeout.ExponentialTimeout,
    ] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponse

Tests the specified IAM permissions against the IAM access control policy for a function.

See more: google.cloud.pubsub_v1.publisher.client.Client.test_iam_permissions

google.cloud.pubsub_v1.publisher.client.Client.topic_path

topic_path(project: str, topic: str) -> str

Returns a fully-qualified topic string.

See more: google.cloud.pubsub_v1.publisher.client.Client.topic_path

google.cloud.pubsub_v1.publisher.client.Client.update_topic

update_topic(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.UpdateTopicRequest, dict]
    ] = None,
    *,
    topic: typing.Optional[google.cloud.pubsub_v1.types.Topic] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    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[
        int,
        float,
        google.api_core.timeout.ConstantTimeout,
        google.api_core.timeout.ExponentialTimeout,
    ] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.pubsub_v1.types.Topic

Updates an existing topic by updating the fields specified in the update mask.

See more: google.cloud.pubsub_v1.publisher.client.Client.update_topic

google.cloud.pubsub_v1.publisher.futures.Future

Future()

Initializes the future.

See more: google.cloud.pubsub_v1.publisher.futures.Future

google.cloud.pubsub_v1.publisher.futures.Future.add_done_callback

add_done_callback(
    callback: typing.Callable[[pubsub_v1.publisher.futures.Future], typing.Any],
) -> None

Attach a callable that will be called when the future finishes.

See more: google.cloud.pubsub_v1.publisher.futures.Future.add_done_callback

google.cloud.pubsub_v1.publisher.futures.Future.cancel

cancel() -> bool

Actions in Pub/Sub generally may not be canceled.

See more: google.cloud.pubsub_v1.publisher.futures.Future.cancel

google.cloud.pubsub_v1.publisher.futures.Future.cancelled

cancelled() -> bool

Actions in Pub/Sub generally may not be canceled.

See more: google.cloud.pubsub_v1.publisher.futures.Future.cancelled

google.cloud.pubsub_v1.publisher.futures.Future.done

done()

Return True if the future was cancelled or finished executing.

See more: google.cloud.pubsub_v1.publisher.futures.Future.done

google.cloud.pubsub_v1.publisher.futures.Future.exception

exception(timeout=None)

Return the exception raised by the call that the future represents.

See more: google.cloud.pubsub_v1.publisher.futures.Future.exception

google.cloud.pubsub_v1.publisher.futures.Future.result

result(timeout: typing.Optional[typing.Union[int, float]] = None) -> str

Return the message ID or raise an exception.

See more: google.cloud.pubsub_v1.publisher.futures.Future.result

google.cloud.pubsub_v1.publisher.futures.Future.running

running() -> bool

Return True if the associated Pub/Sub action has not yet completed.

See more: google.cloud.pubsub_v1.publisher.futures.Future.running

google.cloud.pubsub_v1.publisher.futures.Future.set_exception

set_exception(exception: typing.Optional[BaseException])

Set the result of the future as being the given exception.

See more: google.cloud.pubsub_v1.publisher.futures.Future.set_exception

google.cloud.pubsub_v1.publisher.futures.Future.set_result

set_result(result: typing.Any)

Set the return value of work associated with the future.

See more: google.cloud.pubsub_v1.publisher.futures.Future.set_result

google.cloud.pubsub_v1.publisher.futures.Future.set_running_or_notify_cancel

set_running_or_notify_cancel() -> typing.NoReturn

Mark the future as running or process any cancel notifications.

See more: google.cloud.pubsub_v1.publisher.futures.Future.set_running_or_notify_cancel

google.cloud.pubsub_v1.subscriber.client.Client

Client(
    subscriber_options: typing.Union[
        google.cloud.pubsub_v1.types.SubscriberOptions, typing.Sequence
    ] = (),
    **kwargs: typing.Any
)

Instantiates the subscriber client.

See more: google.cloud.pubsub_v1.subscriber.client.Client

google.cloud.pubsub_v1.subscriber.client.Client.acknowledge

acknowledge(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.AcknowledgeRequest, dict]
    ] = None,
    *,
    subscription: typing.Optional[str] = None,
    ack_ids: typing.Optional[typing.MutableSequence[str]] = None,
    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]]] = ()
) -> None

Acknowledges the messages associated with the ack_ids in the AcknowledgeRequest.

See more: google.cloud.pubsub_v1.subscriber.client.Client.acknowledge

google.cloud.pubsub_v1.subscriber.client.Client.close

close() -> None

Close the underlying channel to release socket resources.

See more: google.cloud.pubsub_v1.subscriber.client.Client.close

google.cloud.pubsub_v1.subscriber.client.Client.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.pubsub_v1.subscriber.client.Client.common_billing_account_path

google.cloud.pubsub_v1.subscriber.client.Client.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.pubsub_v1.subscriber.client.Client.common_folder_path

google.cloud.pubsub_v1.subscriber.client.Client.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.pubsub_v1.subscriber.client.Client.common_location_path

google.cloud.pubsub_v1.subscriber.client.Client.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.pubsub_v1.subscriber.client.Client.common_organization_path

google.cloud.pubsub_v1.subscriber.client.Client.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.pubsub_v1.subscriber.client.Client.common_project_path

google.cloud.pubsub_v1.subscriber.client.Client.create_snapshot

create_snapshot(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.CreateSnapshotRequest, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    subscription: typing.Optional[str] = None,
    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]]] = ()
) -> google.cloud.pubsub_v1.types.Snapshot

Creates a snapshot from the requested subscription.

See more: google.cloud.pubsub_v1.subscriber.client.Client.create_snapshot

google.cloud.pubsub_v1.subscriber.client.Client.create_subscription

create_subscription(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.Subscription, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    topic: typing.Optional[str] = None,
    push_config: typing.Optional[google.cloud.pubsub_v1.types.PushConfig] = None,
    ack_deadline_seconds: typing.Optional[int] = None,
    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]]] = ()
) -> google.cloud.pubsub_v1.types.Subscription

Creates a subscription to a given topic.

See more: google.cloud.pubsub_v1.subscriber.client.Client.create_subscription

google.cloud.pubsub_v1.subscriber.client.Client.delete_snapshot

delete_snapshot(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.DeleteSnapshotRequest, dict]
    ] = None,
    *,
    snapshot: typing.Optional[str] = None,
    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]]] = ()
) -> None

Removes an existing snapshot.

See more: google.cloud.pubsub_v1.subscriber.client.Client.delete_snapshot

google.cloud.pubsub_v1.subscriber.client.Client.delete_subscription

delete_subscription(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.DeleteSubscriptionRequest, dict]
    ] = None,
    *,
    subscription: typing.Optional[str] = None,
    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]]] = ()
) -> None

Deletes an existing subscription.

See more: google.cloud.pubsub_v1.subscriber.client.Client.delete_subscription

google.cloud.pubsub_v1.subscriber.client.Client.from_service_account_file

from_service_account_file(
    filename: str, **kwargs: typing.Any
) -> google.cloud.pubsub_v1.subscriber.client.Client

Creates an instance of this client using the provided credentials file.

See more: google.cloud.pubsub_v1.subscriber.client.Client.from_service_account_file

google.cloud.pubsub_v1.subscriber.client.Client.from_service_account_info

from_service_account_info(info: dict, *args, **kwargs)

Creates an instance of this client using the provided credentials info.

See more: google.cloud.pubsub_v1.subscriber.client.Client.from_service_account_info

google.cloud.pubsub_v1.subscriber.client.Client.from_service_account_json

from_service_account_json(
    filename: str, **kwargs: typing.Any
) -> google.cloud.pubsub_v1.subscriber.client.Client

Creates an instance of this client using the provided credentials file.

See more: google.cloud.pubsub_v1.subscriber.client.Client.from_service_account_json

google.cloud.pubsub_v1.subscriber.client.Client.get_iam_policy

get_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None,
    *,
    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]]] = ()
) -> google.iam.v1.policy_pb2.Policy

Gets the IAM access control policy for a function.

See more: google.cloud.pubsub_v1.subscriber.client.Client.get_iam_policy

google.cloud.pubsub_v1.subscriber.client.Client.get_mtls_endpoint_and_cert_source

get_mtls_endpoint_and_cert_source(
    client_options: typing.Optional[
        google.api_core.client_options.ClientOptions
    ] = None,
)

Deprecated.

See more: google.cloud.pubsub_v1.subscriber.client.Client.get_mtls_endpoint_and_cert_source

google.cloud.pubsub_v1.subscriber.client.Client.get_snapshot

get_snapshot(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.GetSnapshotRequest, dict]
    ] = None,
    *,
    snapshot: typing.Optional[str] = None,
    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]]] = ()
) -> google.cloud.pubsub_v1.types.Snapshot

Gets the configuration details of a snapshot.

See more: google.cloud.pubsub_v1.subscriber.client.Client.get_snapshot

google.cloud.pubsub_v1.subscriber.client.Client.get_subscription

get_subscription(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.GetSubscriptionRequest, dict]
    ] = None,
    *,
    subscription: typing.Optional[str] = None,
    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]]] = ()
) -> google.cloud.pubsub_v1.types.Subscription

Gets the configuration details of a subscription.

See more: google.cloud.pubsub_v1.subscriber.client.Client.get_subscription

google.cloud.pubsub_v1.subscriber.client.Client.list_snapshots

list_snapshots(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.ListSnapshotsRequest, dict]
    ] = None,
    *,
    project: typing.Optional[str] = None,
    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]]] = ()
) -> google.pubsub_v1.services.subscriber.pagers.ListSnapshotsPager

Lists the existing snapshots.

See more: google.cloud.pubsub_v1.subscriber.client.Client.list_snapshots

google.cloud.pubsub_v1.subscriber.client.Client.list_subscriptions

list_subscriptions(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.ListSubscriptionsRequest, dict]
    ] = None,
    *,
    project: typing.Optional[str] = None,
    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]]] = ()
) -> google.pubsub_v1.services.subscriber.pagers.ListSubscriptionsPager

Lists matching subscriptions.

See more: google.cloud.pubsub_v1.subscriber.client.Client.list_subscriptions

google.cloud.pubsub_v1.subscriber.client.Client.modify_ack_deadline

modify_ack_deadline(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.ModifyAckDeadlineRequest, dict]
    ] = None,
    *,
    subscription: typing.Optional[str] = None,
    ack_ids: typing.Optional[typing.MutableSequence[str]] = None,
    ack_deadline_seconds: typing.Optional[int] = None,
    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]]] = ()
) -> None

Modifies the ack deadline for a specific message.

See more: google.cloud.pubsub_v1.subscriber.client.Client.modify_ack_deadline

google.cloud.pubsub_v1.subscriber.client.Client.modify_push_config

modify_push_config(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.ModifyPushConfigRequest, dict]
    ] = None,
    *,
    subscription: typing.Optional[str] = None,
    push_config: typing.Optional[google.cloud.pubsub_v1.types.PushConfig] = None,
    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]]] = ()
) -> None

Modifies the PushConfig for a specified subscription.

See more: google.cloud.pubsub_v1.subscriber.client.Client.modify_push_config

google.cloud.pubsub_v1.subscriber.client.Client.parse_common_billing_account_path

parse_common_billing_account_path(path: str) -> typing.Dict[str, str]

Parse a billing_account path into its component segments.

See more: google.cloud.pubsub_v1.subscriber.client.Client.parse_common_billing_account_path

google.cloud.pubsub_v1.subscriber.client.Client.parse_common_folder_path

parse_common_folder_path(path: str) -> typing.Dict[str, str]

Parse a folder path into its component segments.

See more: google.cloud.pubsub_v1.subscriber.client.Client.parse_common_folder_path

google.cloud.pubsub_v1.subscriber.client.Client.parse_common_location_path

parse_common_location_path(path: str) -> typing.Dict[str, str]

Parse a location path into its component segments.

See more: google.cloud.pubsub_v1.subscriber.client.Client.parse_common_location_path

google.cloud.pubsub_v1.subscriber.client.Client.parse_common_organization_path

parse_common_organization_path(path: str) -> typing.Dict[str, str]

Parse a organization path into its component segments.

See more: google.cloud.pubsub_v1.subscriber.client.Client.parse_common_organization_path

google.cloud.pubsub_v1.subscriber.client.Client.parse_common_project_path

parse_common_project_path(path: str) -> typing.Dict[str, str]

Parse a project path into its component segments.

See more: google.cloud.pubsub_v1.subscriber.client.Client.parse_common_project_path

google.cloud.pubsub_v1.subscriber.client.Client.parse_snapshot_path

parse_snapshot_path(path: str) -> typing.Dict[str, str]

Parses a snapshot path into its component segments.

See more: google.cloud.pubsub_v1.subscriber.client.Client.parse_snapshot_path

google.cloud.pubsub_v1.subscriber.client.Client.parse_subscription_path

parse_subscription_path(path: str) -> typing.Dict[str, str]

Parses a subscription path into its component segments.

See more: google.cloud.pubsub_v1.subscriber.client.Client.parse_subscription_path

google.cloud.pubsub_v1.subscriber.client.Client.parse_topic_path

parse_topic_path(path: str) -> typing.Dict[str, str]

Parses a topic path into its component segments.

See more: google.cloud.pubsub_v1.subscriber.client.Client.parse_topic_path

google.cloud.pubsub_v1.subscriber.client.Client.pull

pull(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.PullRequest, dict]
    ] = None,
    *,
    subscription: typing.Optional[str] = None,
    return_immediately: typing.Optional[bool] = None,
    max_messages: typing.Optional[int] = None,
    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]]] = ()
) -> google.cloud.pubsub_v1.types.PullResponse

Pulls messages from the server.

See more: google.cloud.pubsub_v1.subscriber.client.Client.pull

google.cloud.pubsub_v1.subscriber.client.Client.seek

seek(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.SeekRequest, dict]
    ] = None,
    *,
    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]]] = ()
) -> google.cloud.pubsub_v1.types.SeekResponse

Seeks an existing subscription to a point in time or to a given snapshot, whichever is provided in the request.

See more: google.cloud.pubsub_v1.subscriber.client.Client.seek

google.cloud.pubsub_v1.subscriber.client.Client.set_iam_policy

set_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None,
    *,
    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]]] = ()
) -> google.iam.v1.policy_pb2.Policy

Sets the IAM access control policy on the specified function.

See more: google.cloud.pubsub_v1.subscriber.client.Client.set_iam_policy

google.cloud.pubsub_v1.subscriber.client.Client.snapshot_path

snapshot_path(project: str, snapshot: str) -> str

Returns a fully-qualified snapshot string.

See more: google.cloud.pubsub_v1.subscriber.client.Client.snapshot_path

google.cloud.pubsub_v1.subscriber.client.Client.streaming_pull

streaming_pull(
    requests: typing.Optional[
        typing.Iterator[google.cloud.pubsub_v1.types.StreamingPullRequest]
    ] = None,
    *,
    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]]] = ()
) -> typing.Iterable[google.cloud.pubsub_v1.types.StreamingPullResponse]

Establishes a stream with the server, which sends messages down to the client.

See more: google.cloud.pubsub_v1.subscriber.client.Client.streaming_pull

google.cloud.pubsub_v1.subscriber.client.Client.subscribe

subscribe(
    subscription: str,
    callback: typing.Callable[[subscriber.message.Message], typing.Any],
    flow_control: typing.Union[
        google.cloud.pubsub_v1.types.FlowControl, typing.Sequence
    ] = (),
    scheduler: typing.Optional[subscriber.scheduler.ThreadScheduler] = None,
    use_legacy_flow_control: bool = False,
    await_callbacks_on_shutdown: bool = False,
) -> google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture

Asynchronously start receiving messages on a given subscription.

See more: google.cloud.pubsub_v1.subscriber.client.Client.subscribe

google.cloud.pubsub_v1.subscriber.client.Client.subscription_path

subscription_path(project: str, subscription: str) -> str

Returns a fully-qualified subscription string.

See more: google.cloud.pubsub_v1.subscriber.client.Client.subscription_path

google.cloud.pubsub_v1.subscriber.client.Client.test_iam_permissions

test_iam_permissions(
    request: typing.Optional[
        google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
    ] = None,
    *,
    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]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponse

Tests the specified IAM permissions against the IAM access control policy for a function.

See more: google.cloud.pubsub_v1.subscriber.client.Client.test_iam_permissions

google.cloud.pubsub_v1.subscriber.client.Client.topic_path

topic_path(project: str, topic: str) -> str

Returns a fully-qualified topic string.

See more: google.cloud.pubsub_v1.subscriber.client.Client.topic_path

google.cloud.pubsub_v1.subscriber.client.Client.update_snapshot

update_snapshot(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.UpdateSnapshotRequest, dict]
    ] = None,
    *,
    snapshot: typing.Optional[google.cloud.pubsub_v1.types.Snapshot] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    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]]] = ()
) -> google.cloud.pubsub_v1.types.Snapshot

Updates an existing snapshot by updating the fields specified in the update mask.

See more: google.cloud.pubsub_v1.subscriber.client.Client.update_snapshot

google.cloud.pubsub_v1.subscriber.client.Client.update_subscription

update_subscription(
    request: typing.Optional[
        typing.Union[google.cloud.pubsub_v1.types.UpdateSubscriptionRequest, dict]
    ] = None,
    *,
    subscription: typing.Optional[google.cloud.pubsub_v1.types.Subscription] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    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]]] = ()
) -> google.cloud.pubsub_v1.types.Subscription

Updates an existing subscription by updating the fields specified in the update mask.

See more: google.cloud.pubsub_v1.subscriber.client.Client.update_subscription

google.cloud.pubsub_v1.subscriber.futures.Future

Future()

Initializes the future.

See more: google.cloud.pubsub_v1.subscriber.futures.Future

google.cloud.pubsub_v1.subscriber.futures.Future.add_done_callback

add_done_callback(fn)

Attaches a callable that will be called when the future finishes.

See more: google.cloud.pubsub_v1.subscriber.futures.Future.add_done_callback

google.cloud.pubsub_v1.subscriber.futures.Future.cancel

cancel() -> bool

Actions in Pub/Sub generally may not be canceled.

See more: google.cloud.pubsub_v1.subscriber.futures.Future.cancel

google.cloud.pubsub_v1.subscriber.futures.Future.cancelled

cancelled() -> bool

Actions in Pub/Sub generally may not be canceled.

See more: google.cloud.pubsub_v1.subscriber.futures.Future.cancelled

google.cloud.pubsub_v1.subscriber.futures.Future.done

done()

Return True if the future was cancelled or finished executing.

See more: google.cloud.pubsub_v1.subscriber.futures.Future.done

google.cloud.pubsub_v1.subscriber.futures.Future.exception

exception(timeout=None)

Return the exception raised by the call that the future represents.

See more: google.cloud.pubsub_v1.subscriber.futures.Future.exception

google.cloud.pubsub_v1.subscriber.futures.Future.result

result(
    timeout: typing.Optional[typing.Union[int, float]] = None,
) -> google.cloud.pubsub_v1.subscriber.exceptions.AcknowledgeStatus

Return a success code or raise an exception.

See more: google.cloud.pubsub_v1.subscriber.futures.Future.result

google.cloud.pubsub_v1.subscriber.futures.Future.running

running() -> bool

Return True if the associated Pub/Sub action has not yet completed.

See more: google.cloud.pubsub_v1.subscriber.futures.Future.running

google.cloud.pubsub_v1.subscriber.futures.Future.set_exception

set_exception(exception: typing.Optional[BaseException])

Set the result of the future as being the given exception.

See more: google.cloud.pubsub_v1.subscriber.futures.Future.set_exception

google.cloud.pubsub_v1.subscriber.futures.Future.set_result

set_result(result: typing.Any)

Set the return value of work associated with the future.

See more: google.cloud.pubsub_v1.subscriber.futures.Future.set_result

google.cloud.pubsub_v1.subscriber.futures.Future.set_running_or_notify_cancel

set_running_or_notify_cancel() -> typing.NoReturn

Mark the future as running or process any cancel notifications.

See more: google.cloud.pubsub_v1.subscriber.futures.Future.set_running_or_notify_cancel

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture

StreamingPullFuture(manager: StreamingPullManager)

Initializes the future.

See more: google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.add_done_callback

add_done_callback(fn)

Attaches a callable that will be called when the future finishes.

See more: google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.add_done_callback

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.cancel

cancel() -> bool

Stops pulling messages and shutdowns the background thread consuming messages.

See more: google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.cancel

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.cancelled

cancelled() -> bool

See more: google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.cancelled

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.done

done()

Return True if the future was cancelled or finished executing.

See more: google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.done

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.exception

exception(timeout=None)

Return the exception raised by the call that the future represents.

See more: google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.exception

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.result

result(timeout=None)

Return the result of the call that the future represents.

See more: google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.result

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.running

running() -> bool

Return True if the associated Pub/Sub action has not yet completed.

See more: google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.running

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.set_exception

set_exception(exception: typing.Optional[BaseException])

Set the result of the future as being the given exception.

See more: google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.set_exception

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.set_result

set_result(result: typing.Any)

Set the return value of work associated with the future.

See more: google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.set_result

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.set_running_or_notify_cancel

set_running_or_notify_cancel() -> typing.NoReturn

Mark the future as running or process any cancel notifications.

See more: google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.set_running_or_notify_cancel

google.cloud.pubsub_v1.subscriber.message.Message

Message(message: types.PubsubMessage._meta._pb, ack_id: str, delivery_attempt: int, request_queue: queue.Queue, exactly_once_delivery_enabled_func: typing.Callable[[], bool] =

Construct the Message.

See more: google.cloud.pubsub_v1.subscriber.message.Message

google.cloud.pubsub_v1.subscriber.message.Message.ack

ack() -> None

Acknowledge the given message.

See more: google.cloud.pubsub_v1.subscriber.message.Message.ack

google.cloud.pubsub_v1.subscriber.message.Message.ack_with_response

ack_with_response() -> google.cloud.pubsub_v1.subscriber.futures.Future

Acknowledge the given message.

See more: google.cloud.pubsub_v1.subscriber.message.Message.ack_with_response

google.cloud.pubsub_v1.subscriber.message.Message.drop

drop() -> None

Release the message from lease management.

See more: google.cloud.pubsub_v1.subscriber.message.Message.drop

google.cloud.pubsub_v1.subscriber.message.Message.modify_ack_deadline

modify_ack_deadline(seconds: int) -> None

Resets the deadline for acknowledgement.

See more: google.cloud.pubsub_v1.subscriber.message.Message.modify_ack_deadline

google.cloud.pubsub_v1.subscriber.message.Message.modify_ack_deadline_with_response

modify_ack_deadline_with_response(
    seconds: int,
) -> google.cloud.pubsub_v1.subscriber.futures.Future

Resets the deadline for acknowledgement and returns the response status via a future.

See more: google.cloud.pubsub_v1.subscriber.message.Message.modify_ack_deadline_with_response

google.cloud.pubsub_v1.subscriber.message.Message.nack

nack() -> None

Decline to acknowledge the given message.

See more: google.cloud.pubsub_v1.subscriber.message.Message.nack

google.cloud.pubsub_v1.subscriber.message.Message.nack_with_response

nack_with_response() -> google.cloud.pubsub_v1.subscriber.futures.Future

Decline to acknowledge the given message, returning the response status via a future.

See more: google.cloud.pubsub_v1.subscriber.message.Message.nack_with_response

google.cloud.pubsub_v1.subscriber.scheduler.Scheduler.schedule

schedule(callback: typing.Callable, *args, **kwargs) -> None

Schedule the callback to be called asynchronously.

See more: google.cloud.pubsub_v1.subscriber.scheduler.Scheduler.schedule

google.cloud.pubsub_v1.subscriber.scheduler.Scheduler.shutdown

shutdown(
    await_msg_callbacks: bool = False,
) -> typing.List[pubsub_v1.subscriber.message.Message]

Shuts down the scheduler and immediately end all pending callbacks.

See more: google.cloud.pubsub_v1.subscriber.scheduler.Scheduler.shutdown

google.cloud.pubsub_v1.subscriber.scheduler.ThreadScheduler.schedule

schedule(callback: typing.Callable, *args, **kwargs) -> None

Schedule the callback to be called asynchronously in a thread pool.

See more: google.cloud.pubsub_v1.subscriber.scheduler.ThreadScheduler.schedule

google.cloud.pubsub_v1.subscriber.scheduler.ThreadScheduler.shutdown

shutdown(
    await_msg_callbacks: bool = False,
) -> typing.List[pubsub_v1.subscriber.message.Message]

Shut down the scheduler and immediately end all pending callbacks.

See more: google.cloud.pubsub_v1.subscriber.scheduler.ThreadScheduler.shutdown

google.cloud.pubsub_v1.types.BatchSettings

BatchSettings(
    max_bytes: int = 1000000, max_latency: float = 0.01, max_messages: int = 100
)

Create new instance of BatchSettings(max_bytes, max_latency, max_messages).

See more: google.cloud.pubsub_v1.types.BatchSettings

google.cloud.pubsub_v1.types.FlowControl

FlowControl(
    max_bytes: int = 104857600,
    max_messages: int = 1000,
    max_lease_duration: float = 3600,
    min_duration_per_lease_extension: float = 0,
    max_duration_per_lease_extension: float = 0,
)

Create new instance of FlowControl(max_bytes, max_messages, max_lease_duration, min_duration_per_lease_extension, max_duration_per_lease_extension).

See more: google.cloud.pubsub_v1.types.FlowControl

google.cloud.pubsub_v1.types.PublishFlowControl

PublishFlowControl(
    message_limit: int = 1000,
    byte_limit: int = 10000000,
    limit_exceeded_behavior: google.cloud.pubsub_v1.types.LimitExceededBehavior = LimitExceededBehavior.IGNORE,
)

Create new instance of PublishFlowControl(message_limit, byte_limit, limit_exceeded_behavior).

See more: google.cloud.pubsub_v1.types.PublishFlowControl

google.cloud.pubsub_v1.types.PublisherOptions

PublisherOptions(enable_message_ordering: bool = False, flow_control: google.cloud.pubsub_v1.types.PublishFlowControl = PublishFlowControl(message_limit=1000, byte_limit=10000000, limit_exceeded_behavior=

Create new instance of PublisherOptions(enable_message_ordering, flow_control, retry, timeout, enable_open_telemetry_tracing).

See more: google.cloud.pubsub_v1.types.PublisherOptions

google.pubsub_v1.services.publisher.pagers.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]]] = ()
)

Instantiates the pager.

See more: google.pubsub_v1.services.publisher.pagers.ListTopicSnapshotsAsyncPager

google.pubsub_v1.services.publisher.pagers.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]]] = ()
)

Instantiate the pager.

See more: google.pubsub_v1.services.publisher.pagers.ListTopicSnapshotsPager

google.pubsub_v1.services.publisher.pagers.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]]] = ()
)

Instantiates the pager.

See more: google.pubsub_v1.services.publisher.pagers.ListTopicSubscriptionsAsyncPager

google.pubsub_v1.services.publisher.pagers.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]]] = ()
)

Instantiate the pager.

See more: google.pubsub_v1.services.publisher.pagers.ListTopicSubscriptionsPager

google.pubsub_v1.services.publisher.pagers.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]]] = ()
)

Instantiates the pager.

See more: google.pubsub_v1.services.publisher.pagers.ListTopicsAsyncPager

google.pubsub_v1.services.publisher.pagers.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]]] = ()
)

Instantiate the pager.

See more: google.pubsub_v1.services.publisher.pagers.ListTopicsPager

google.pubsub_v1.services.subscriber.pagers.ListSnapshotsAsyncPager

ListSnapshotsAsyncPager(
    method: typing.Callable[
        [...], typing.Awaitable[google.cloud.pubsub_v1.types.ListSnapshotsResponse]
    ],
    request: google.cloud.pubsub_v1.types.ListSnapshotsRequest,
    response: google.cloud.pubsub_v1.types.ListSnapshotsResponse,
    *,
    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]]] = ()
)

Instantiates the pager.

See more: google.pubsub_v1.services.subscriber.pagers.ListSnapshotsAsyncPager

google.pubsub_v1.services.subscriber.pagers.ListSnapshotsPager

ListSnapshotsPager(
    method: typing.Callable[[...], google.cloud.pubsub_v1.types.ListSnapshotsResponse],
    request: google.cloud.pubsub_v1.types.ListSnapshotsRequest,
    response: google.cloud.pubsub_v1.types.ListSnapshotsResponse,
    *,
    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]]] = ()
)

Instantiate the pager.

See more: google.pubsub_v1.services.subscriber.pagers.ListSnapshotsPager

google.pubsub_v1.services.subscriber.pagers.ListSubscriptionsAsyncPager

ListSubscriptionsAsyncPager(
    method: typing.Callable[
        [...], typing.Awaitable[google.cloud.pubsub_v1.types.ListSubscriptionsResponse]
    ],
    request: google.cloud.pubsub_v1.types.ListSubscriptionsRequest,
    response: google.cloud.pubsub_v1.types.ListSubscriptionsResponse,
    *,
    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]]] = ()
)

Instantiates the pager.

See more: google.pubsub_v1.services.subscriber.pagers.ListSubscriptionsAsyncPager

google.pubsub_v1.services.subscriber.pagers.ListSubscriptionsPager

ListSubscriptionsPager(
    method: typing.Callable[
        [...], google.cloud.pubsub_v1.types.ListSubscriptionsResponse
    ],
    request: google.cloud.pubsub_v1.types.ListSubscriptionsRequest,
    response: google.cloud.pubsub_v1.types.ListSubscriptionsResponse,
    *,
    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]]] = ()
)

Instantiate the pager.

See more: google.pubsub_v1.services.subscriber.pagers.ListSubscriptionsPager