go-cloud

go-cloud copied to clipboard

pubsub/awssnssqs: aws sqs expose receiver max batch

6

This PR exposes the receiver max batch size as a URL parameter for AWS SQS via `receivermaxbatch`. For example: `awssqs://sqs.us-east-2.amazonaws.com/99999/my-queue?receivermaxbatch=5` Based on the `recvBatcherOpts`: https://github.com/google/go-cloud/blob/be1b4aee38955e1b8cd1c46f8f47fb6f9d820a9b/pubsub/awssnssqs/awssnssqs.go#L118-L123 and the limitations of SQS,...

pxp928

docstore/awsdynamodb panics on iter.Next()

16

### Describe the bug Calling `iter.Next` on a `docstore/awsdynamodb` derived `Query` instance panics with an "index out of range" error along the lines of: ``` panic: runtime error: index out...

thisisaaronland

docstore/all: Fix offset handling and extend test coverage

1

This PR is a continuation of PR #3408 and includes additional changes: - Fixes offset handling for `RunGetQuery` in `docstore/memdocstore`. - Increases test coverage for `documentIterator.Next` in `docstore/awsdynamodb`. I'm not...

bartventer

RabbitPubSub Queue Connection Closes Unexpectedly with FailedPrecondition Error

2

I've encountered an issue with the gocloud.dev/pubsub/rabbitpubsub project where the queue connection closes unexpectedly after a certain period. Despite the establishChannel function's logic to reopen a channel if it exists...

omerfruk

pubsub: Ensure batcher flushes on shutdown, even if min batch size isn't met

3

This PR ensures that the batcher flushes on shutdown, even if the pending length is less than the min batch size specified. Sending events is preferred to dropping, even if...

tonyhb

pubsub: add batch timeouts

6

This PR adds a timeout option to batcher. The timeout specifies how long the batcher waits before sending batched messages, even if the message length is under MinBatchSize. This ensures...

tonyhb

build(deps): bump the go_modules group across 2 directories with 1 update

1

Bumps the go_modules group with 1 update in the /samples directory: [github.com/hashicorp/go-retryablehttp](https://github.com/hashicorp/go-retryablehttp). Bumps the go_modules group with 1 update in the /secrets/hashivault directory: [github.com/hashicorp/go-retryablehttp](https://github.com/hashicorp/go-retryablehttp). Updates `github.com/hashicorp/go-retryablehttp` from 0.7.5 to 0.7.7...

dependabot[bot]

This PR updates Docstore to allow boolean filters in the queries, as it's supported by all the different implementations. This isn't yet merge-able as the replay data needs to be...

ybourgery

aws: lost "forcePathStyle" query parameter in AWS SDK V2

2

### Describe the bug In 0.39.0, S3 URLs now use the V2 of the AWS SDK by default. Therefore, we lost the `s3ForcePathStyle` query parameter. Based on [their documentation](https://aws.github.io/aws-sdk-go-v2/docs/configuring-sdk/endpoints/#immutable-endpoints), we...

SebouChu

docstore/awsdynamodb: Support AWS SDK V2

9

### Is your feature request related to a problem? Please describe. The V1 AWS SDK has officially entered maintenance mode (31st July 2024). In addition, the vendor specific constructors for...

Maldris