Pub/Sub Lite Client Types
class google.cloud.pubsublite.types.CloudRegion(name)
Create new instance of CloudRegion(name,)
name(: [str](https://python.readthedocs.io/en/latest/library/stdtypes.html#str )
Alias for field number 0
class google.cloud.pubsublite.types.CloudZone(region, zone_id)
Create new instance of CloudZone(region, zone_id)
region(: google.cloud.pubsublite.types.location.CloudRegio )
Alias for field number 0
zone_id(: [str](https://python.readthedocs.io/en/latest/library/stdtypes.html#str )
Alias for field number 1
class google.cloud.pubsublite.types.FlowControlSettings(messages_outstanding, bytes_outstanding)
Create new instance of FlowControlSettings(messages_outstanding, bytes_outstanding)
bytes_outstanding(: [int](https://python.readthedocs.io/en/latest/library/functions.html#int )
Alias for field number 1
messages_outstanding(: [int](https://python.readthedocs.io/en/latest/library/functions.html#int )
Alias for field number 0
class google.cloud.pubsublite.types.LocationPath(project_number, location)
Create new instance of LocationPath(project_number, location)
location(: google.cloud.pubsublite.types.location.CloudZon )
Alias for field number 1
project_number(: [int](https://python.readthedocs.io/en/latest/library/functions.html#int )
Alias for field number 0
class google.cloud.pubsublite.types.Partition(value)
Create new instance of Partition(value,)
value(: [int](https://python.readthedocs.io/en/latest/library/functions.html#int )
Alias for field number 0
class google.cloud.pubsublite.types.PublishMetadata(partition, cursor)
Create new instance of PublishMetadata(partition, cursor)
cursor(: google.cloud.pubsublite_v1.types.common.Curso )
Alias for field number 1
partition(: google.cloud.pubsublite.types.partition.Partitio )
Alias for field number 0
class google.cloud.pubsublite.types.SubscriptionPath(project_number, location, name)
Create new instance of SubscriptionPath(project_number, location, name)
location(: google.cloud.pubsublite.types.location.CloudZon )
Alias for field number 1
name(: [str](https://python.readthedocs.io/en/latest/library/stdtypes.html#str )
Alias for field number 2
project_number(: [int](https://python.readthedocs.io/en/latest/library/functions.html#int )
Alias for field number 0
class google.cloud.pubsublite.types.TopicPath(project_number, location, name)
Create new instance of TopicPath(project_number, location, name)
location(: google.cloud.pubsublite.types.location.CloudZon )
Alias for field number 1
name(: [str](https://python.readthedocs.io/en/latest/library/stdtypes.html#str )
Alias for field number 2
project_number(: [int](https://python.readthedocs.io/en/latest/library/functions.html#int )
Alias for field number 0
class google.cloud.pubsublite_v1.Cursor(mapping=None, *, ignore_unknown_fields=False, **kwargs)
A cursor that describes the position of a message within a topic partition.
offset()
The offset of a message within a topic partition. Must be greater than or equal 0.
Type
class google.cloud.pubsublite_v1.Subscription(mapping=None, *, ignore_unknown_fields=False, **kwargs)
Metadata about a subscription resource.
name()
The name of the subscription. Structured like: projects/{project_number}/locations/{location}/subscriptions/{subscription_id}
Type
topic()
The name of the topic this subscription is attached to. Structured like: projects/{project_number}/locations/{location}/topics/{topic_id}
Type
delivery_config()
The settings for this subscription’s message delivery.
Type
DeliveryConfig
class DeliveryConfig(mapping=None, *, ignore_unknown_fields=False, **kwargs)
The settings for a subscription’s message delivery.
delivery_requirement()
The DeliveryRequirement for this subscription.
Type
DeliveryRequirement
class DeliveryRequirement(value)
When this subscription should send messages to subscribers relative to messages persistence in storage. For details, see Creating Lite subscriptions.
class google.cloud.pubsublite_v1.Topic(mapping=None, *, ignore_unknown_fields=False, **kwargs)
Metadata about a topic resource.
name()
The name of the topic. Structured like: projects/{project_number}/locations/{location}/topics/{topic_id}
Type
partition_config()
The settings for this topic’s partitions.
Type
PartitionConfig
retention_config()
The settings for this topic’s message retention.
Type
RetentionConfig
class PartitionConfig(mapping=None, *, ignore_unknown_fields=False, **kwargs)
The settings for a topic’s partitions.
count()
The number of partitions in the topic. Must be at least 1.
Type
scale()
DEPRECATED: Use capacity instead which can express a superset of configurations.
Every partition in the topic is allocated throughput
equivalent to scale times the standard partition
throughput (4 MiB/s). This is also reflected in the cost of
this topic; a topic with scale of 2 and count of 10 is
charged for 20 partitions. This value must be in the range
[1,4].
Type
capacity()
The capacity configuration.
Type
Capacity
class Capacity(mapping=None, *, ignore_unknown_fields=False, **kwargs)
The throughput capacity configuration for each partition.
publish_mib_per_sec()
Publish throughput capacity per partition in MiB/s. Must be >= 4 and <= 16.
Type
subscribe_mib_per_sec()
Subscribe throughput capacity per partition in MiB/s. Must be >= 4 and <= 32.
Type
class RetentionConfig(mapping=None, *, ignore_unknown_fields=False, **kwargs)
The settings for a topic’s message retention.
per_partition_bytes()
The provisioned storage, in bytes, per partition. If the
number of bytes stored in any of the topic’s partitions
grows beyond this value, older messages will be dropped to
make room for newer ones, regardless of the value of
period.
Type
period()
How long a published message is retained. If unset, messages
will be retained as long as the bytes retained for each
partition is below per_partition_bytes.
Type
Duration