Skip to content

feat: setup subrouter for pub/sub trigger#704

Open
anFatum wants to merge 1 commit intogoogle:mainfrom
anFatum:pubsub-subrouter
Open

feat: setup subrouter for pub/sub trigger#704
anFatum wants to merge 1 commit intogoogle:mainfrom
anFatum:pubsub-subrouter

Conversation

@anFatum
Copy link
Copy Markdown
Contributor

@anFatum anFatum commented Apr 3, 2026

Create a new subrouter that will handle the pubsub trigger endpoint and add the implementation for this trigger.

This implementation should handle the resource exhausted exceptions with jitter to prevent thundering herd (configured per subrouter).

(see the details in go/orcas-rfc-522)

@anFatum anFatum force-pushed the pubsub-subrouter branch from 20af916 to 8df5c76 Compare April 3, 2026 12:36
@anFatum anFatum requested a review from kdroste-google April 3, 2026 12:40
Copy link
Copy Markdown
Collaborator

@kdroste-google kdroste-google left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Please see my comments

return
}

if _, err := c.runAgent(r.Context(), appName, req.Subscription, messageContent); err != nil {
Copy link
Copy Markdown
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Here messageContent is either req.Message.Data (string with base64 encoded free-format string) or req.Message.Attributes (string with JSON representation of the string-to-string map). Is that correct?

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Yes, see the comment above

@anFatum anFatum force-pushed the pubsub-subrouter branch 5 times, most recently from e4cdcd9 to b8ac13a Compare April 7, 2026 13:34
@anFatum anFatum force-pushed the pubsub-subrouter branch from b8ac13a to bba95b8 Compare April 7, 2026 13:47
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants