kiss_gcp_pubsub_queue 0.2.0 copy "kiss_gcp_pubsub_queue: ^0.2.0" to clipboard
kiss_gcp_pubsub_queue: ^0.2.0 copied to clipboard

A Google Cloud Pub/Sub backend for kiss_queue providing SQS-style queue semantics

Changelog #

0.2.0 Breaking Changes #

Fixed #

  • Ack ID extraction: Switched dequeue from gcloud pull to googleapis pull, providing real Pub/Sub ack IDs for modifyAckDeadline and acknowledge operations
  • Message ID preservation: Dequeued messages now retain the original publisher ID (kissId) instead of generating a new local ID
  • reject() return value: Now returns the rejected QueueMessage instead of null, matching the kiss_queue contract

Changed #

  • BREAKING: PubSubQueue no longer accepts a gcloud.Subscription constructor parameter; pull operations now go through PubSubAdmin
  • BREAKING: Removed PubSubAttributes class (was never exported; use AttributeKeys internally)
  • PubSubQueue.configuration field type narrowed from QueueConfiguration to PubSubQueueConfiguration

Added #

  • clearGroupId parameter on PubSubQueueConfiguration.copyWith() to allow resetting groupId to null
  • contentBasedDeduplication test coverage
  • Custom idGenerator test coverage
  • Missing error-rethrow tests for PubSubAdmin subscription operations

0.1.0 Initial Release #

Features #

  • Google Cloud Pub/Sub backend for kiss_queue
  • Standard queue support with at-least-once delivery
  • FIFO queue support with message ordering and client-side deduplication
  • Visibility timeout via Pub/Sub ack deadline management
  • Dead letter queue support with configurable max delivery attempts
  • Pluggable serialization support
  • Comprehensive test suite (102 tests)

Architecture #

  • Dual client design using gcloud for data plane and googleapis for control plane
  • PubSubQueueFactory for queue creation and management
  • PubSubQueue implementing the kiss_queue Queue interface
  • PubSubAdmin for Pub/Sub administrative operations
  • RepositoryDedupeStore using kiss_repository for FIFO deduplication
0
likes
130
points
8
downloads

Documentation

API reference

Publisher

unverified uploader

Weekly Downloads

A Google Cloud Pub/Sub backend for kiss_queue providing SQS-style queue semantics

Repository (GitHub)
View/report issues

License

MIT (license)

Dependencies

crypto, gcloud, googleapis, googleapis_auth, http, kiss_queue, kiss_repository, uuid

More

Packages that depend on kiss_gcp_pubsub_queue