From ddade2ab3f30c0ede8129a4b0ad1062e5d0ac5f0 Mon Sep 17 00:00:00 2001 From: Rui Fu Date: Mon, 9 Feb 2026 16:09:39 +0800 Subject: [PATCH] refactor(logging): replace fmt.Printf with log.Printf for error logging --- pkg/mcp/pulsar_admin_functions_worker_tools.go | 4 ++-- pkg/mcp/pulsar_admin_namespace_tools.go | 4 ++-- pkg/mcp/pulsar_admin_schemas_tools.go | 4 ++-- pkg/mcp/pulsar_admin_subscription_tools.go | 4 ++-- pkg/mcp/pulsar_admin_topic_tools.go | 4 ++-- pkg/mcp/pulsar_client_consume_tools.go | 4 ++-- pkg/mcp/pulsar_client_produce_tools.go | 4 ++-- 7 files changed, 14 insertions(+), 14 deletions(-) diff --git a/pkg/mcp/pulsar_admin_functions_worker_tools.go b/pkg/mcp/pulsar_admin_functions_worker_tools.go index 1a4a428..b4480c1 100644 --- a/pkg/mcp/pulsar_admin_functions_worker_tools.go +++ b/pkg/mcp/pulsar_admin_functions_worker_tools.go @@ -16,7 +16,7 @@ package mcp import ( "context" - "fmt" + "log" "github.com/mark3labs/mcp-go/server" "github.com/streamnative/streamnative-mcp-server/pkg/mcp/builders" @@ -34,7 +34,7 @@ func PulsarAdminFunctionsWorkerTools(readOnly bool, features []string) []server. tools, err := builder.BuildTools(context.Background(), config) if err != nil { // In production environment, this should use proper logging - fmt.Printf("Failed to build Pulsar Admin Functions Worker tools: %v\n", err) + log.Printf("Failed to build Pulsar Admin Functions Worker tools: %v", err) return nil } diff --git a/pkg/mcp/pulsar_admin_namespace_tools.go b/pkg/mcp/pulsar_admin_namespace_tools.go index a31b0e3..3d5f532 100644 --- a/pkg/mcp/pulsar_admin_namespace_tools.go +++ b/pkg/mcp/pulsar_admin_namespace_tools.go @@ -16,7 +16,7 @@ package mcp import ( "context" - "fmt" + "log" "github.com/mark3labs/mcp-go/server" "github.com/streamnative/streamnative-mcp-server/pkg/mcp/builders" @@ -34,7 +34,7 @@ func PulsarAdminNamespaceTools(readOnly bool, features []string) []server.Server tools, err := builder.BuildTools(context.Background(), config) if err != nil { // In production environment, this should use proper logging - fmt.Printf("Failed to build Pulsar Admin Namespace tools: %v\n", err) + log.Printf("Failed to build Pulsar Admin Namespace tools: %v", err) return nil } diff --git a/pkg/mcp/pulsar_admin_schemas_tools.go b/pkg/mcp/pulsar_admin_schemas_tools.go index fd8ea01..9e79444 100644 --- a/pkg/mcp/pulsar_admin_schemas_tools.go +++ b/pkg/mcp/pulsar_admin_schemas_tools.go @@ -16,7 +16,7 @@ package mcp import ( "context" - "fmt" + "log" "github.com/mark3labs/mcp-go/server" "github.com/streamnative/streamnative-mcp-server/pkg/mcp/builders" @@ -34,7 +34,7 @@ func PulsarAdminSchemaTools(readOnly bool, features []string) []server.ServerToo tools, err := builder.BuildTools(context.Background(), config) if err != nil { // In production environment, this should use proper logging - fmt.Printf("Failed to build Pulsar Admin Schema tools: %v\n", err) + log.Printf("Failed to build Pulsar Admin Schema tools: %v", err) return nil } diff --git a/pkg/mcp/pulsar_admin_subscription_tools.go b/pkg/mcp/pulsar_admin_subscription_tools.go index 2a7d03e..925a414 100644 --- a/pkg/mcp/pulsar_admin_subscription_tools.go +++ b/pkg/mcp/pulsar_admin_subscription_tools.go @@ -16,7 +16,7 @@ package mcp import ( "context" - "fmt" + "log" "github.com/mark3labs/mcp-go/server" "github.com/streamnative/streamnative-mcp-server/pkg/mcp/builders" @@ -34,7 +34,7 @@ func PulsarAdminSubscriptionTools(readOnly bool, features []string) []server.Ser tools, err := builder.BuildTools(context.Background(), config) if err != nil { // In production environment, this should use proper logging - fmt.Printf("Failed to build Pulsar Admin Subscription tools: %v\n", err) + log.Printf("Failed to build Pulsar Admin Subscription tools: %v", err) return nil } diff --git a/pkg/mcp/pulsar_admin_topic_tools.go b/pkg/mcp/pulsar_admin_topic_tools.go index c02fc64..d2309f5 100644 --- a/pkg/mcp/pulsar_admin_topic_tools.go +++ b/pkg/mcp/pulsar_admin_topic_tools.go @@ -16,7 +16,7 @@ package mcp import ( "context" - "fmt" + "log" "github.com/mark3labs/mcp-go/server" "github.com/streamnative/streamnative-mcp-server/pkg/mcp/builders" @@ -34,7 +34,7 @@ func PulsarAdminTopicTools(readOnly bool, features []string) []server.ServerTool tools, err := builder.BuildTools(context.Background(), config) if err != nil { // In production environment, this should use proper logging - fmt.Printf("Failed to build Pulsar Admin Topic tools: %v\n", err) + log.Printf("Failed to build Pulsar Admin Topic tools: %v", err) return nil } diff --git a/pkg/mcp/pulsar_client_consume_tools.go b/pkg/mcp/pulsar_client_consume_tools.go index 7e68f33..3cb73ea 100644 --- a/pkg/mcp/pulsar_client_consume_tools.go +++ b/pkg/mcp/pulsar_client_consume_tools.go @@ -16,7 +16,7 @@ package mcp import ( "context" - "fmt" + "log" "github.com/mark3labs/mcp-go/server" "github.com/streamnative/streamnative-mcp-server/pkg/mcp/builders" @@ -34,7 +34,7 @@ func PulsarClientConsumeTools(readOnly bool, features []string) []server.ServerT tools, err := builder.BuildTools(context.Background(), config) if err != nil { // In production environment, this should use proper logging - fmt.Printf("Failed to build Pulsar Client Consumer tools: %v\n", err) + log.Printf("Failed to build Pulsar Client Consumer tools: %v", err) return nil } diff --git a/pkg/mcp/pulsar_client_produce_tools.go b/pkg/mcp/pulsar_client_produce_tools.go index 15a5a84..1ae9d20 100644 --- a/pkg/mcp/pulsar_client_produce_tools.go +++ b/pkg/mcp/pulsar_client_produce_tools.go @@ -16,7 +16,7 @@ package mcp import ( "context" - "fmt" + "log" "github.com/mark3labs/mcp-go/server" "github.com/streamnative/streamnative-mcp-server/pkg/mcp/builders" @@ -34,7 +34,7 @@ func PulsarClientProduceTools(readOnly bool, features []string) []server.ServerT tools, err := builder.BuildTools(context.Background(), config) if err != nil { // In production environment, this should use proper logging - fmt.Printf("Failed to build Pulsar Client Producer tools: %v\n", err) + log.Printf("Failed to build Pulsar Client Producer tools: %v", err) return nil }