centrifuge v0.34.0 changes (#441)

This branch collects Centrifuge v0.34.0 related works. v0.34.0 is aimed to become the base for Centrifugo v6. So it contains notable improvements, new features and some breaking changes.
centrifugal · Jan 12, 2025 · 81f7854 · 81f7854
1 parent 38ab1ae
commit 81f7854
Show file tree

Hide file tree

Showing 49 changed files with 2,318 additions and 3,831 deletions.
diff --git a/_examples/chat_json/main.go b/_examples/chat_json/main.go
@@ -68,11 +68,14 @@ func channelSubscribeAllowed(channel string) bool {
 }
 
 func main() {
-	node, _ := centrifuge.New(centrifuge.Config{
+	node, err := centrifuge.New(centrifuge.Config{
 		LogLevel:       centrifuge.LogLevelInfo,
 		LogHandler:     handleLog,
 		HistoryMetaTTL: 24 * time.Hour,
 	})
+	if err != nil {
+		log.Fatal(err)
+	}
 
 	node.OnConnecting(func(ctx context.Context, e centrifuge.ConnectEvent) (centrifuge.ConnectReply, error) {
 		cred, _ := centrifuge.GetCredentials(ctx)

diff --git a/_examples/custom_broker_nats/natsbroker/broker.go b/_examples/custom_broker_nats/natsbroker/broker.go
@@ -93,7 +93,6 @@ func (b *NatsBroker) Run(h centrifuge.BrokerEventHandler) error {
 		return err
 	}
 	b.nc = nc
-	b.node.Log(centrifuge.NewLogEntry(centrifuge.LogLevelInfo, fmt.Sprintf("Nats Broker connected to: %s", servers)))
 	return nil
 }
 

diff --git a/_examples/custom_engine_tarantool/index.html b/_examples/custom_engine_tarantool/index.html
diff --git a/_examples/custom_engine_tarantool/main.go b/_examples/custom_engine_tarantool/main.go