Class PublishFlowControl (2.20.3) 

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

The client flow control settings for message publishing.

Attributes

NameDescription
message_limit :noindex: int
The maximum number of messages awaiting to be published. Defaults to 1000.
byte_limit :noindex: int
The maximum total size of messages awaiting to be published. Defaults to 10MB.
limit_exceeded_behavior :noindex: LimitExceededBehavior
The action to take when publish flow control limits are exceeded. Defaults to LimitExceededBehavior.IGNORE.

Methods

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)