@@ -64,7 +64,7 @@ func main() {
6464 logger .Error ("failed to initialize OpenTelemetry" , "error" , err )
6565 os .Exit (1 )
6666 }
67- defer otelProvider .Shutdown (context .Background ())
67+ defer func () { _ = otelProvider .Shutdown (context .Background ()) }( )
6868
6969 // Initialize metrics.
7070 otelMetrics , err := observability .NewMetrics (observability .Meter ("peerclaw-gateway" ))
@@ -79,7 +79,7 @@ func main() {
7979 logger .Error ("failed to open database" , "error" , err , "driver" , cfg .Database .Driver )
8080 os .Exit (1 )
8181 }
82- defer store .Close ()
82+ defer func () { _ = store .Close () } ()
8383
8484 // Extract the underlying *sql.DB for shared use by reputation and verification modules.
8585 sqlDB , _ := store .GetDB ().(* sql.DB )
@@ -116,13 +116,13 @@ func main() {
116116
117117 // Register protocol bridges.
118118 if cfg .Bridge .A2A .Enabled {
119- bridgeManager .RegisterBridge (a2a .New (logger , nil ))
119+ _ = bridgeManager .RegisterBridge (a2a .New (logger , nil ))
120120 }
121121 if cfg .Bridge .ACP .Enabled {
122- bridgeManager .RegisterBridge (acp .New (logger , nil ))
122+ _ = bridgeManager .RegisterBridge (acp .New (logger , nil ))
123123 }
124124 if cfg .Bridge .MCP .Enabled {
125- bridgeManager .RegisterBridge (mcp .New (logger , nil ))
125+ _ = bridgeManager .RegisterBridge (mcp .New (logger , nil ))
126126 }
127127
128128 // Initialize signaling hub.
@@ -228,7 +228,7 @@ func main() {
228228 broker := signaling .NewRedisBroker (redisClient , sigHub , logger )
229229 if _ , err := broker .Subscribe (ctx ); err != nil {
230230 logger .Error ("Redis subscribe failed" , "error" , err )
231- redisClient .Close ()
231+ _ = redisClient .Close ()
232232 sigHub .SetBroker (signaling .NewLocalBroker (sigHub ))
233233 } else {
234234 sigHub .SetBroker (broker )
@@ -263,10 +263,10 @@ func main() {
263263 if err := rows .Scan (& agentID ); err != nil {
264264 continue
265265 }
266- repEngine .RecordEvent (ctx , agentID , "heartbeat_miss" , "" )
266+ _ = repEngine .RecordEvent (ctx , agentID , "heartbeat_miss" , "" )
267267 logger .Debug ("heartbeat miss recorded" , "agent_id" , agentID )
268268 }
269- rows .Close ()
269+ _ = rows .Close ()
270270 }
271271 }
272272 }()
@@ -311,15 +311,15 @@ func main() {
311311 // stop the servers and wait for goroutines to finish.
312312 cancel ()
313313 grpcServer .Stop ()
314- httpServer .Stop ()
314+ _ = httpServer .Stop ()
315315
316316 // Wait for server goroutines to complete before tearing down
317317 // remaining services, ensuring a clean shutdown.
318318 wg .Wait ()
319319
320320 if fedService != nil {
321- fedService .Close ()
321+ _ = fedService .Close ()
322322 }
323- bridgeManager .Close ()
323+ _ = bridgeManager .Close ()
324324 logger .Info ("PeerClaw gateway stopped" )
325325}
0 commit comments