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

Return the API endpoint used by the client instance.

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

Return the target (where the API is).

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

Returns the transport used by the client instance.

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

Return the universe domain used by the client instance.

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

The underlying gapic API client.

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

Return the API endpoint used by the client instance.

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

Return whether the client has been closed and cannot be used anymore.

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

Returns True if Open Telemetry is enabled.

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

Return the target (where the API is).

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

Returns the transport used by the client instance.

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

Return the universe domain used by the client instance.

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

the ID used to ack the message.

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

Return the attributes of the underlying Pub/Sub Message.

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

Return the data for the underlying Pub/Sub Message.

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

The delivery attempt counter is 1 + (the sum of number of NACKsand number of ack_deadline exceeds) for this message.

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

The ordering key used to publish the message.

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

Return the time that the message was originally published.

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

Return the size of the underlying message, in bytes.

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

Queue: A concurrency-safe queue specific to the underlyingconcurrency implementation.

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

Queue: A thread-safe queue used for communication between callbacksand the scheduling thread.

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

The maximum total size of the messages to collect before automatically publishing the batch, including any byte size overhead of the publish request itself.

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

The maximum number of seconds to wait for additional messages before automatically publishing the batch.

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

The maximum number of messages to collect before automatically publishing the batch.

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

The maximum total size of received - but not yet processed - messages before pausing the message stream.

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

The max amount of time in seconds for a single lease extension attempt.

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

The maximum amount of time in seconds to hold a lease on a message before dropping it from the lease management.

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

The maximum number of received - but not yet processed - messages before pausing the message stream.

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

The min amount of time in seconds for a single lease extension attempt.

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

The maximum total size of messages awaiting to be published.

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

The action to take when publish flow control limits are exceeded.

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

The maximum number of messages awaiting to be published.

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

Whether to order messages in a batch by a supplied ordering key.

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

Open Telemetry tracing is enabled if this is set to True.

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

Flow control settings for message publishing by the client.

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

Retry settings for message publishing by the client.

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

Timeout settings for message publishing by the client.

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