Stay organized with collections
Save and categorize content based on your preferences.
Changelog
0.6.1 (2021-07-16)
Bug Fixes
- Add ClientCache which forces new client creation after 75 uses (#188) (089789c)
0.6.0 (2021-07-13)
Features
Bug Fixes
Documentation
0.5.0 (2021-06-11)
Features
Bug Fixes
Add admin interfaces for reservations (#159) (ad0f3d2)
Replace unreleased InitialSubscribeRequest initial_cursor field with initial_location (#150) (30fcd3f)
shutdown event loop if publisher fails to start and set exception on result future (#124) (c2c2b00)
Version bump overrides library past fix and undo workarounds (#137) (94ae2f0)
0.4.1 (2021-05-05)
Bug Fixes
Change type hint on callback to be Callback. (#135) (cbf16f8)
deps: remove duplicate dependencies and add version ranges (#105) (d7ee309)
do not crash if pubsublite distribution can not be found when extracting semver (#120) (811434e)
Remove Future type hint from return type which fails to type check when overridden (#133) (abe9b14)
0.4.0 (2021-03-22)
Features
- adding ability to create subscriptions at HEAD (#106) (4d03d3a)
0.3.0 (2021-03-09)
Features
- Make message_id encode a PublishMetadata which includes the partition (#90) (85944e7)
Bug Fixes
Documentation
0.2.0 (2020-12-14)
Features
- Add support for increasing partitions in python (#74) (e117a1a)
Bug Fixes
- Fix type hints in paths now that string projects are allowed. (#75) (b5ffc42)
0.1.0 (2020-11-19)
Features
generate v1 (4624ac7)
Implement a single partition publisher (#8) (fd1d76f)
Implement AckSetTracker which tracks message acknowledgements. (#19) (7f88458)
Implement admin client. (#17) (3068da5)
Implement assigner, which handles partition-subscriber assignment. (#14) (b2d0d36)
implement assigning subscriber (#23) (6afd477)
Implement committer (#13) (aa9aca8)
Implement CPS non-asyncio subscriber (#25) (a9293c1)
implement Flow control batcher (#15) (0a09bb3)
Implement make_publisher which creates a routing publisher. (#11) (baeb0f6)
Implement Publisher and subscriber factories (#24) (4890cae)
Implement Publisher API (#21) (58fda6f)
Implement python retrying connection, which generically retries stream errors (#4) (11c9a69)
Implement RoutingPolicy (#5) (f72a2f0), closes #4
Implement RoutingPublisher which routes between publishers. (#10) (7aa39a1)
Implement SerialBatcher which helps with transforming single writes into batch writes. (#7) (a6dc15f)
Implement SinglePartitionSubscriber. (#22) (bb76d90)
Implement Subscriber, which handles flow control and batch message processing. (#16) (697df4a)
Implement transforms to/from Cloud Pub/Sub Messages (#20) (903070d)
Wire batching settings through publisher client factories (#42) (a037d0b)
Bug Fixes
Assorted fixes to the publish layer and internals. (#39) (4276882)
Enforce that enter is called on all user interfaces before use (#70) (eb8d63a)
Ensure tasks are always awaited to remove shutdown errors (#57) (7735d2f)
fix circular import due to make_admin_client and AdminClient being in the same file (#34) (d631626)
import from types (#52) (e4199ff)
Make public API more similar to generated clients (#56) (7cf02ae)
Move FlowControlSettings to types (#53) (457a74d)
Move types to common directory (#51) (45a8a71)
remaining issues with subscriber client (#43) (ec19dfc)
update cps async clients (#41) (f41c228)
update pubsub_context to correctly modify proto map fields (#38) (860c443)
Documentation
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2024-10-01 UTC.
[{
"type": "thumb-down",
"id": "hardToUnderstand",
"label":"Hard to understand"
},{
"type": "thumb-down",
"id": "incorrectInformationOrSampleCode",
"label":"Incorrect information or sample code"
},{
"type": "thumb-down",
"id": "missingTheInformationSamplesINeed",
"label":"Missing the information/samples I need"
},{
"type": "thumb-down",
"id": "otherDown",
"label":"Other"
}]
[{
"type": "thumb-up",
"id": "easyToUnderstand",
"label":"Easy to understand"
},{
"type": "thumb-up",
"id": "solvedMyProblem",
"label":"Solved my problem"
},{
"type": "thumb-up",
"id": "otherUp",
"label":"Other"
}]
{"lastModified": "Last updated 2024-10-01 UTC."}
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2024-10-01 UTC."]]