Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
49 commits
Select commit Hold shift + click to select a range
d0079ae
feat: add SubscriptionOnStartHandler (#2059)
alepane21 Oct 10, 2025
b594b1c
feat: batch and stream hooks (#2087)
alepane21 Oct 10, 2025
167e28f
Merge branch 'main' into dominik/update-cosmo-streams-topic-branch
dkorittki Oct 16, 2025
c498de7
fix: async handler execution (#2288)
dkorittki Oct 23, 2025
4c7687d
feat: distinguish between read / write events (#2304)
dkorittki Oct 30, 2025
d61e56b
feat(router): provide an agnostic way of creating events in hooks (#2…
dkorittki Oct 30, 2025
7020faf
fix(router): recover from panics in hooks (#2311)
dkorittki Oct 30, 2025
e6169f3
fix(router): ignore nil events (#2315)
dkorittki Oct 31, 2025
a4df549
chore: update Cosmo Streams ADR (#2314)
dkorittki Oct 31, 2025
6aeea7d
Merge branch 'main' into dominik/update-cosmo-streams-topic-branch
dkorittki Nov 11, 2025
405f64c
chore: go mod tidy
dkorittki Nov 11, 2025
b3bc7af
feat(router): add a timeout for on_receive_event hooks (#2329)
dkorittki Nov 13, 2025
2955b62
fix(router): return correct error when creating event config fails (C…
dkorittki Nov 14, 2025
149a0e1
Merge branch 'main' into topic/streams-v1
dkorittki Nov 14, 2025
34f020b
chore: ensure nop logger is set when no logger is passed
dkorittki Nov 16, 2025
b1b9df3
fix: prevent potential race condition
dkorittki Nov 16, 2025
c3d33da
fix: remove unnecessary semaphore channel close
dkorittki Nov 16, 2025
b311cef
fix: escape input when marshalling json template
dkorittki Nov 16, 2025
538c0ae
fix: stop processing hooks on error
dkorittki Nov 16, 2025
81b7eae
chore: fix test name + add nil logger checks
dkorittki Nov 17, 2025
a0ed7e5
fix: wrong mock in tests
dkorittki Nov 17, 2025
ef85d0a
chore: remove obsolete return from mock + rename test package
dkorittki Nov 17, 2025
736ef09
chore: add description to router-tests + delete obsolete test
dkorittki Nov 18, 2025
ef0b638
chore: Use builtin error instead of inappropriate graphql-error
dkorittki Nov 18, 2025
8dcd1f4
fix: remove unwanted logging of errors from OnPublishEvent hook
dkorittki Nov 18, 2025
f07f077
fix: filter nil events at end of hook processing
dkorittki Nov 18, 2025
f93145f
chore: reintroduce StreamHandlerError
dkorittki Nov 18, 2025
65d5d55
chore: rename WriteEvent to EmitLocalEvent
dkorittki Nov 19, 2025
f1442f1
chore: rename config events.subscription_hooks to events.handlers
dkorittki Nov 19, 2025
e1bf8cd
chore: use counter to count hook calls
dkorittki Nov 19, 2025
544bf72
chore: removed unused case of switch + remove early return
dkorittki Nov 19, 2025
1cabe5d
fix: add timeout waiting for channel in test
dkorittki Nov 19, 2025
d2946a1
fix: avoid using Len on channel in test
dkorittki Nov 19, 2025
5d0c630
chore: remove unused channel from test
dkorittki Nov 19, 2025
cdcbf93
chore: remove unused constant and a corresponding check
dkorittki Nov 19, 2025
288bf52
chore: update Cosmo Streams ADR
dkorittki Nov 20, 2025
551ef84
fix: do not close updater when poller closes
dkorittki Nov 20, 2025
bffad18
Merge branch 'main' into topic/streams-v1
dkorittki Nov 20, 2025
cd086fc
chore: go mod tidy
dkorittki Nov 21, 2025
20770e1
chore: rename EmitLocalEvent to EmitEvent
dkorittki Nov 21, 2025
435c0f2
chore: use type assert instead of copy
dkorittki Nov 21, 2025
0f131a0
fix: handle partial errors when publishing events
dkorittki Nov 21, 2025
5c3e834
chore: rename edfs to streams error
dkorittki Nov 21, 2025
7f91fb3
chore: use context instead of seperate timer
dkorittki Nov 21, 2025
bb03b5f
chore: use semaphore package instead of channel
dkorittki Nov 21, 2025
ef45209
fix: get rid of cloning events while publishing for redis+nats as well
dkorittki Nov 21, 2025
8e79ea0
chore: fix typo in error message
dkorittki Nov 21, 2025
fd676e2
Merge branch 'main' into topic/streams-v1
dkorittki Nov 21, 2025
da8f4a6
chore: update graphql-go-tools in router + router-tests
dkorittki Nov 21, 2025
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
492 changes: 492 additions & 0 deletions adr/cosmo-streams-v1.md

Large diffs are not rendered by default.

16 changes: 10 additions & 6 deletions demo/pkg/subgraphs/availability/subgraph/schema.resolvers.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

11 changes: 5 additions & 6 deletions demo/pkg/subgraphs/mood/subgraph/schema.resolvers.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading
Loading