gsadmin/spinifex
1
0
Fork 0
mirror of https://github.com/mulgadc/spinifex.git synced 2026-10-20 11:21:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: fix viperblock logs to not log the data

Browse Source
This commit is contained in:
Julian Sommer
2026-07-23 12:17:22 +10:00
parent f682d09a72
commit f50f69caff
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
spinifex/services/viperblockd/viperblockd.go
+4 -4
View File
@@ -400,7 +400,7 @@ func launchService(cfg *Config) (err error) {
if _, err := nc.QueueSubscribe("ebs.delete", "spinifex-workers", func(msg *nats.Msg) {
ctx, span := utils.StartConsumerSpan(msg)
defer span.End()
slog.InfoContext(ctx, "Received ebs.delete message", "data", string(msg.Data))
slog.InfoContext(ctx, "Received ebs.delete message")
var ebsRequest types.EBSDeleteRequest
if err := json.Unmarshal(msg.Data, &ebsRequest); err != nil {
@@ -475,7 +475,7 @@ func launchService(cfg *Config) (err error) {
if _, err := unmountSubscribe(unmountTopic, func(msg *nats.Msg) {
ctx, span := utils.StartConsumerSpan(msg)
defer span.End()
slog.InfoContext(ctx, "Received message", "data", string(msg.Data))
slog.InfoContext(ctx, "Received message")
var ebsRequest types.EBSRequest
if err := json.Unmarshal(msg.Data, &ebsRequest); err != nil {
@@ -588,7 +588,7 @@ func launchService(cfg *Config) (err error) {
if _, err := nc.QueueSubscribe("ebs.sync", "spinifex-workers", func(msg *nats.Msg) {
ctx, span := utils.StartConsumerSpan(msg)
defer span.End()
slog.InfoContext(ctx, "Received ebs.sync message", "data", string(msg.Data))
slog.InfoContext(ctx, "Received ebs.sync message")
var syncRequest types.EBSSyncRequest
if err := json.Unmarshal(msg.Data, &syncRequest); err != nil {
@@ -713,7 +713,7 @@ func launchService(cfg *Config) (err error) {
if _, err := mountSubscribe(mountTopic, func(msg *nats.Msg) {
ctx, span := utils.StartConsumerSpan(msg)
defer span.End()
slog.InfoContext(ctx, "Received message:", "data", string(msg.Data))
slog.InfoContext(ctx, "Received message:")
var ebsRequest types.EBSRequest
if err := json.Unmarshal(msg.Data, &ebsRequest); err != nil {