cleanups

centrifugal · May 26, 2024 · fb3d1cd · fb3d1cd
1 parent 08f7f32
commit fb3d1cd
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 24 deletions.
diff --git a/_examples/document_sync/main.go b/_examples/document_sync/main.go
@@ -80,27 +80,6 @@ func main() {
 		LogHandler: handleLog,
 	})
 
-	redisShardConfigs := []centrifuge.RedisShardConfig{
-		{Address: "localhost:6379"},
-	}
-	var redisShards []*centrifuge.RedisShard
-	for _, redisConf := range redisShardConfigs {
-		redisShard, err := centrifuge.NewRedisShard(node, redisConf)
-		if err != nil {
-			log.Fatal(err)
-		}
-		redisShards = append(redisShards, redisShard)
-	}
-
-	broker, err := centrifuge.NewRedisBroker(node, centrifuge.RedisBrokerConfig{
-		// And configure a couple of shards to use.
-		Shards: redisShards,
-	})
-	if err != nil {
-		log.Fatal(err)
-	}
-	node.SetBroker(broker)
-
 	node.OnConnect(func(client *centrifuge.Client) {
 		transport := client.Transport()
 		log.Printf("user %s connected via %s with protocol: %s", client.UserID(), transport.Name(), transport.Protocol())

diff --git a/broker_redis_test.go b/broker_redis_test.go
@@ -1965,13 +1965,13 @@ func TestParseDeltaPush(t *testing.T) {
 		name           string
 		input          string
 		expectError    bool
-		expectedResult *deltaPublicationPush
+		expectedResult deltaPublicationPush
 	}{
 		{
 			name:        "valid data with colon in payload",
 			input:       "d1:1234567890:epoch1:4:test:18:payload:with:colon",
 			expectError: false,
-			expectedResult: &deltaPublicationPush{
+			expectedResult: deltaPublicationPush{
 				Offset:            1234567890,
 				Epoch:             "epoch1",
 				PrevPayloadLength: 4,
@@ -1984,7 +1984,7 @@ func TestParseDeltaPush(t *testing.T) {
 			name:        "valid data with empty payload",
 			input:       "d1:1234567890:epoch2:0::0:",
 			expectError: false,
-			expectedResult: &deltaPublicationPush{
+			expectedResult: deltaPublicationPush{
 				Offset:            1234567890,
 				Epoch:             "epoch2",
 				PrevPayloadLength: 0,