apps/mochi-mqtt
1
0
Fork 0
mirror of https://github.com/mochi-mqtt/server.git synced 2025-10-31 19:42:38 +08:00
Code Issues Packages Projects Releases Wiki Activity

Return packets to internal

Browse Source 
Now that we can alias types, there's no compelling reason to expose the packets library
This commit is contained in:
mochi
2022-01-05 18:10:24 +00:00
parent ce773b3978
commit 7c7b8d58fe
12 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server/internal/clients/clients.go
View File

@@ -13,9 +13,9 @@ import (
"github.com/rs/xid" "github.com/rs/xid"
"github.com/mochi-co/mqtt/server/internal/circ" "github.com/mochi-co/mqtt/server/internal/circ"
"github.com/mochi-co/mqtt/server/internal/packets"
"github.com/mochi-co/mqtt/server/internal/topics" "github.com/mochi-co/mqtt/server/internal/topics"
"github.com/mochi-co/mqtt/server/listeners/auth" "github.com/mochi-co/mqtt/server/listeners/auth"
"github.com/mochi-co/mqtt/server/packets"
"github.com/mochi-co/mqtt/server/system" "github.com/mochi-co/mqtt/server/system"
) )

2
server/internal/clients/clients_test.go
View File

@@ -10,8 +10,8 @@ import (
"time" "time"
"github.com/mochi-co/mqtt/server/internal/circ" "github.com/mochi-co/mqtt/server/internal/circ"
"github.com/mochi-co/mqtt/server/internal/packets"
"github.com/mochi-co/mqtt/server/listeners/auth" "github.com/mochi-co/mqtt/server/listeners/auth"
"github.com/mochi-co/mqtt/server/packets"
"github.com/mochi-co/mqtt/server/system" "github.com/mochi-co/mqtt/server/system"
"github.com/stretchr/testify/require" "github.com/stretchr/testify/require"
) )

0
server/packets/codec.go → server/internal/packets/codec.go
View File

0
server/packets/codec_test.go → server/internal/packets/codec_test.go
View File

0
server/packets/fixedheader.go → server/internal/packets/fixedheader.go
View File

0
server/packets/fixedheader_test.go → server/internal/packets/fixedheader_test.go
View File

0
server/packets/packets.go → server/internal/packets/packets.go
View File

0
server/packets/packets_tables_test.go → server/internal/packets/packets_tables_test.go
View File

0
server/packets/packets_test.go → server/internal/packets/packets_test.go
View File

2
server/internal/topics/trie.go
View File

@@ -4,7 +4,7 @@ import (
"strings" "strings"
"sync" "sync"
"github.com/mochi-co/mqtt/server/packets" "github.com/mochi-co/mqtt/server/internal/packets"
) )
// Subscriptions is a map of subscriptions keyed on client. // Subscriptions is a map of subscriptions keyed on client.

2
server/internal/topics/trie_test.go
View File

@@ -5,7 +5,7 @@ import (
"github.com/stretchr/testify/require" "github.com/stretchr/testify/require"
"github.com/mochi-co/mqtt/server/packets" "github.com/mochi-co/mqtt/server/internal/packets"
) )
func TestNew(t *testing.T) { func TestNew(t *testing.T) {

2
server/server_test.go
View File

@@ -13,10 +13,10 @@ import (
"github.com/mochi-co/mqtt/server/internal/circ" "github.com/mochi-co/mqtt/server/internal/circ"
"github.com/mochi-co/mqtt/server/internal/clients" "github.com/mochi-co/mqtt/server/internal/clients"
"github.com/mochi-co/mqtt/server/internal/packets"
"github.com/mochi-co/mqtt/server/internal/topics" "github.com/mochi-co/mqtt/server/internal/topics"
"github.com/mochi-co/mqtt/server/listeners" "github.com/mochi-co/mqtt/server/listeners"
"github.com/mochi-co/mqtt/server/listeners/auth" "github.com/mochi-co/mqtt/server/listeners/auth"
"github.com/mochi-co/mqtt/server/packets"
"github.com/mochi-co/mqtt/server/persistence" "github.com/mochi-co/mqtt/server/persistence"
"github.com/mochi-co/mqtt/server/system" "github.com/mochi-co/mqtt/server/system"
) )