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,