diff --git a/cluster/etcd_service_discovery.go b/cluster/etcd_service_discovery.go index 45cd6061..18139761 100644 --- a/cluster/etcd_service_discovery.go +++ b/cluster/etcd_service_discovery.go @@ -578,7 +578,7 @@ func (sd *etcdServiceDiscovery) SyncServers(firstSync bool) error { servers := parallelGetter.waitAndGetResult() for _, server := range servers { - logger.Log.Debugf("adding server %s", server) + logger.Log.Debugf("adding server %v", server) sd.addServer(server) } diff --git a/cluster/nats_rpc_server.go b/cluster/nats_rpc_server.go index b82999cf..a82f5cfc 100644 --- a/cluster/nats_rpc_server.go +++ b/cluster/nats_rpc_server.go @@ -212,7 +212,7 @@ func (ns *NatsRPCServer) handleMessages() { } subsChanLen := float64(len(ns.subChan)) maxPending = math.Max(float64(maxPending), subsChanLen) - logger.Log.Debugf("subs channel size: %d, max: %d, dropped: %d", subsChanLen, maxPending, dropped) + logger.Log.Debugf("subs channel size: %v, max: %v, dropped: %v", subsChanLen, maxPending, dropped) req := &protos.Request{} // TODO: Add tracing here to report delay to start processing message in spans err = proto.Unmarshal(msg.Data, req) diff --git a/examples/demo/chat/main.go b/examples/demo/chat/main.go index a8b194a1..f6b0ce90 100644 --- a/examples/demo/chat/main.go +++ b/examples/demo/chat/main.go @@ -62,7 +62,7 @@ func NewRoom(app pitaya.Pitaya) *Room { func (r *Room) AfterInit() { r.timer = pitaya.NewTimer(time.Minute, func() { count, err := r.app.GroupCountMembers(context.Background(), "room") - logger.Log.Debugf("UserCount: Time=> %s, Count=> %d, Error=> %q", time.Now().String(), count, err) + logger.Log.Debugf("UserCount: Time=> %s, Count=> %d, Error=> %v", time.Now().String(), count, err) }) }