aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--axon_test.go2
-rwxr-xr-xclibin0 -> 8000945 bytes
-rw-r--r--cmd/axon/go.mod10
-rw-r--r--cmd/axon/main.go4
-rw-r--r--go.mod2
-rw-r--r--go.sum5
-rw-r--r--relay/go.mod6
-rw-r--r--relay/handler.go8
-rw-r--r--relay/main.go4
-rw-r--r--relay/server.go6
-rw-r--r--relay/storage/events.go2
-rw-r--r--relay/subscription/manager.go2
12 files changed, 28 insertions, 23 deletions
diff --git a/axon_test.go b/axon_test.go
index b7f5bd6..0775c0c 100644
--- a/axon_test.go
+++ b/axon_test.go
@@ -9,7 +9,7 @@ import (
9 "testing" 9 "testing"
10 "time" 10 "time"
11 11
12 "axon" 12 "code.northwest.io/axon"
13) 13)
14 14
15// -------------------------------------------------------------------------- 15// --------------------------------------------------------------------------
diff --git a/cli b/cli
new file mode 100755
index 0000000..c64001f
--- /dev/null
+++ b/cli
Binary files differ
diff --git a/cmd/axon/go.mod b/cmd/axon/go.mod
index 2f26fca..f5438b0 100644
--- a/cmd/axon/go.mod
+++ b/cmd/axon/go.mod
@@ -1,10 +1,10 @@
1module axon/cli 1module code.northwest.io/axon/cli
2 2
3go 1.25.5 3go 1.25.5
4 4
5require ( 5require (
6 axon v0.0.0 6 code.northwest.io/axon v0.0.0
7 axon/relay v0.0.0 7 code.northwest.io/axon/relay v0.0.0
8 github.com/vmihailenco/msgpack/v5 v5.4.1 8 github.com/vmihailenco/msgpack/v5 v5.4.1
9) 9)
10 10
@@ -15,6 +15,6 @@ require (
15) 15)
16 16
17replace ( 17replace (
18 axon => ../../ 18 code.northwest.io/axon => ../../
19 axon/relay => ../../relay 19 code.northwest.io/axon/relay => ../../relay
20) 20)
diff --git a/cmd/axon/main.go b/cmd/axon/main.go
index 9076687..bc7bd88 100644
--- a/cmd/axon/main.go
+++ b/cmd/axon/main.go
@@ -24,8 +24,8 @@ import (
24 "syscall" 24 "syscall"
25 "time" 25 "time"
26 26
27 "axon" 27 "code.northwest.io/axon"
28 ws "axon/relay/websocket" 28 ws "code.northwest.io/axon/relay/websocket"
29 29
30 "github.com/vmihailenco/msgpack/v5" 30 "github.com/vmihailenco/msgpack/v5"
31) 31)
diff --git a/go.mod b/go.mod
index a9bafa6..047a2e6 100644
--- a/go.mod
+++ b/go.mod
@@ -1,4 +1,4 @@
1module axon 1module code.northwest.io/axon
2 2
3go 1.25.5 3go 1.25.5
4 4
diff --git a/go.sum b/go.sum
index 2891988..29b0dda 100644
--- a/go.sum
+++ b/go.sum
@@ -1,6 +1,9 @@
1github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8= 1github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8=
2github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
2github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= 3github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
4github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
3github.com/stretchr/testify v1.6.1 h1:hDPOHmpOpP40lSULcqw7IrRb/u7w6RpDC9399XyoNd0= 5github.com/stretchr/testify v1.6.1 h1:hDPOHmpOpP40lSULcqw7IrRb/u7w6RpDC9399XyoNd0=
6github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
4github.com/vmihailenco/msgpack/v5 v5.4.1 h1:cQriyiUvjTwOHg8QZaPihLWeRAAVoCpE00IUPn0Bjt8= 7github.com/vmihailenco/msgpack/v5 v5.4.1 h1:cQriyiUvjTwOHg8QZaPihLWeRAAVoCpE00IUPn0Bjt8=
5github.com/vmihailenco/msgpack/v5 v5.4.1/go.mod h1:GaZTsDaehaPpQVyxrf5mtQlH+pc21PIudVV/E3rRQok= 8github.com/vmihailenco/msgpack/v5 v5.4.1/go.mod h1:GaZTsDaehaPpQVyxrf5mtQlH+pc21PIudVV/E3rRQok=
6github.com/vmihailenco/tagparser/v2 v2.0.0 h1:y09buUbR+b5aycVFQs/g70pqKVZNBmxwAhO7/IwNM9g= 9github.com/vmihailenco/tagparser/v2 v2.0.0 h1:y09buUbR+b5aycVFQs/g70pqKVZNBmxwAhO7/IwNM9g=
@@ -9,4 +12,6 @@ golang.org/x/crypto v0.48.0 h1:/VRzVqiRSggnhY7gNRxPauEQ5Drw9haKdM0jqfcCFts=
9golang.org/x/crypto v0.48.0/go.mod h1:r0kV5h3qnFPlQnBSrULhlsRfryS2pmewsg+XfMgkVos= 12golang.org/x/crypto v0.48.0/go.mod h1:r0kV5h3qnFPlQnBSrULhlsRfryS2pmewsg+XfMgkVos=
10golang.org/x/sys v0.41.0 h1:Ivj+2Cp/ylzLiEU89QhWblYnOE9zerudt9Ftecq2C6k= 13golang.org/x/sys v0.41.0 h1:Ivj+2Cp/ylzLiEU89QhWblYnOE9zerudt9Ftecq2C6k=
11golang.org/x/sys v0.41.0/go.mod h1:OgkHotnGiDImocRcuBABYBEXf8A9a87e/uXjp9XT3ks= 14golang.org/x/sys v0.41.0/go.mod h1:OgkHotnGiDImocRcuBABYBEXf8A9a87e/uXjp9XT3ks=
15gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
12gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= 16gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
17gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
diff --git a/relay/go.mod b/relay/go.mod
index a3d424a..6f7676f 100644
--- a/relay/go.mod
+++ b/relay/go.mod
@@ -1,9 +1,9 @@
1module axon/relay 1module code.northwest.io/axon/relay
2 2
3go 1.25.5 3go 1.25.5
4 4
5require ( 5require (
6 axon v0.0.0 6 code.northwest.io/axon v0.0.0
7 github.com/vmihailenco/msgpack/v5 v5.4.1 7 github.com/vmihailenco/msgpack/v5 v5.4.1
8 gopkg.in/yaml.v3 v3.0.1 8 gopkg.in/yaml.v3 v3.0.1
9 modernc.org/sqlite v1.33.1 9 modernc.org/sqlite v1.33.1
@@ -27,4 +27,4 @@ require (
27 modernc.org/token v1.1.0 // indirect 27 modernc.org/token v1.1.0 // indirect
28) 28)
29 29
30replace axon => ../ 30replace code.northwest.io/axon => ../
diff --git a/relay/handler.go b/relay/handler.go
index afd9622..c098a66 100644
--- a/relay/handler.go
+++ b/relay/handler.go
@@ -9,10 +9,10 @@ import (
9 9
10 "github.com/vmihailenco/msgpack/v5" 10 "github.com/vmihailenco/msgpack/v5"
11 11
12 "axon" 12 "code.northwest.io/axon"
13 "axon/relay/storage" 13 "code.northwest.io/axon/relay/storage"
14 "axon/relay/subscription" 14 "code.northwest.io/axon/relay/subscription"
15 ws "axon/relay/websocket" 15 ws "code.northwest.io/axon/relay/websocket"
16) 16)
17 17
18// Wire protocol message type constants. 18// Wire protocol message type constants.
diff --git a/relay/main.go b/relay/main.go
index 2cfa034..099b28f 100644
--- a/relay/main.go
+++ b/relay/main.go
@@ -11,8 +11,8 @@ import (
11 "syscall" 11 "syscall"
12 "time" 12 "time"
13 13
14 "axon/relay/storage" 14 "code.northwest.io/axon/relay/storage"
15 "axon/relay/subscription" 15 "code.northwest.io/axon/relay/subscription"
16) 16)
17 17
18func main() { 18func main() {
diff --git a/relay/server.go b/relay/server.go
index d4a1edd..9f716bf 100644
--- a/relay/server.go
+++ b/relay/server.go
@@ -9,9 +9,9 @@ import (
9 "net/http" 9 "net/http"
10 "sync" 10 "sync"
11 11
12 "axon/relay/storage" 12 "code.northwest.io/axon/relay/storage"
13 "axon/relay/subscription" 13 "code.northwest.io/axon/relay/subscription"
14 ws "axon/relay/websocket" 14 ws "code.northwest.io/axon/relay/websocket"
15) 15)
16 16
17// Server is the HTTP + WebSocket server for the Axon relay. 17// Server is the HTTP + WebSocket server for the Axon relay.
diff --git a/relay/storage/events.go b/relay/storage/events.go
index cf10097..0f642bb 100644
--- a/relay/storage/events.go
+++ b/relay/storage/events.go
@@ -7,7 +7,7 @@ import (
7 "fmt" 7 "fmt"
8 "strings" 8 "strings"
9 9
10 "axon" 10 "code.northwest.io/axon"
11) 11)
12 12
13// ErrDuplicate is returned by StoreEvent when the event ID already exists. 13// ErrDuplicate is returned by StoreEvent when the event ID already exists.
diff --git a/relay/subscription/manager.go b/relay/subscription/manager.go
index d8ba653..c9de403 100644
--- a/relay/subscription/manager.go
+++ b/relay/subscription/manager.go
@@ -6,7 +6,7 @@ import (
6 "sync" 6 "sync"
7 "time" 7 "time"
8 8
9 "axon" 9 "code.northwest.io/axon"
10) 10)
11 11
12// Subscription holds a single client subscription: an ID, a set of filters, 12// Subscription holds a single client subscription: an ID, a set of filters,