Skip to content

Compose Pool with Workers through vNext contracts #2

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
JairusSW merged 7 commits into from
Aug 12, 2026
Merged

Compose Pool with Workers through vNext contracts #2

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
84fcf51
plugins: compose pool with workers vNext
JairusSW Aug 12, 2026
1557ec4
chore: pin repaired plugin dependencies
JairusSW Aug 12, 2026
8b337a1
chore: pin final plugin dependencies
JairusSW Aug 12, 2026
a2075ed
chore: pin final tested plugin dependencies
JairusSW Aug 12, 2026
f3df635
chore: pin final plugin dependency graph
JairusSW Aug 12, 2026
05c15de
chore: pin final plugin dependency graph
JairusSW Aug 12, 2026
7353ef5
chore: pin verified plugin dependency graph
JairusSW Aug 12, 2026
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
495 changes: 84 additions & 411 deletions README.md
View file
Open in desktop

Large diffs are not rendered by default.

6 changes: 5 additions & 1 deletion behaviors_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -159,11 +159,15 @@ func TestIntegrationOnEvent(t *testing.T) {

var mu sync.Mutex
kinds := map[PoolEventKind]int{}
r.d.pools.OnEvent(func(ev *PoolEvent) {
events, err := r.d.pools.ObserveEvents(func(ev *PoolEvent) {
mu.Lock()
kinds[ev.Kind]++
mu.Unlock()
})
if err != nil {
t.Fatal(err)
}
defer func() { _ = r.d.pools.UnsubscribeEvents(events) }()

r.invoke(t, "start")
id := r.d.pool()
Expand Down
4 changes: 2 additions & 2 deletions go.mod
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,6 @@ module github.com/JairusSW/pool

go 1.24.0

require github.com/wago-org/wago v0.0.0-20260711053856-7d89b98c854d
require github.com/wago-org/wago v0.0.0-20260812144524-1c58c9862d25

require github.com/wago-org/workers v0.0.0-20260712075105-c0bceb592dc0
require github.com/wago-org/workers v0.0.0-20260812144603-4a90ff25d5e4
8 changes: 4 additions & 4 deletions go.sum
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
github.com/wago-org/wago v0.0.0-20260711053856-7d89b98c854d h1:fzJn6UlsGwiqwyTN+Si6oFoETUhUoJ/Rphhx94M5Pqc=
github.com/wago-org/wago v0.0.0-20260711053856-7d89b98c854d/go.mod h1:d44S+59u6VHeqEaIZBKTeB8viyswTP97O9IKA6Gyzc4=
github.com/wago-org/workers v0.0.0-20260712075105-c0bceb592dc0 h1:CRsh9Z+Iilmr6odi9Xlg2asrpffciQrHIARIVlzQ9sg=
github.com/wago-org/workers v0.0.0-20260712075105-c0bceb592dc0/go.mod h1:lRgtcCNsXr30h+ZovoKMGhKMvk6slR1cwFDZ7HoBo2g=
github.com/wago-org/wago v0.0.0-20260812144524-1c58c9862d25 h1:gopNHvaUaDSzmW2Hfd32r8dOwwzYUHH3ph1L/IuhJUA=
github.com/wago-org/wago v0.0.0-20260812144524-1c58c9862d25/go.mod h1:6XmxI3S5qJ+YAzObyXjC6FmxHtbLhBBxrglzix42zl8=
github.com/wago-org/workers v0.0.0-20260812144603-4a90ff25d5e4 h1:Z7S9Hj+JZ8OdNWLgzRjUQOvPIEQpEFNtyRSoHnUYOlI=
github.com/wago-org/workers v0.0.0-20260812144603-4a90ff25d5e4/go.mod h1:FLuFlQ7n+DNP0VNAZuGc702UIxC/JfLuhyuacMQNFp8=
Loading
Loading