From 9cdf035d05bf573b3f321e8d7c7647d0b075dc65 Mon Sep 17 00:00:00 2001 From: reshke kirill Date: Mon, 26 Aug 2024 09:01:57 +0000 Subject: [PATCH] Fixes --- pkg/message/message.go | 2 ++ pkg/proc/interaction.go | 4 ++++ 2 files changed, 6 insertions(+) diff --git a/pkg/message/message.go b/pkg/message/message.go index ba80836..9fd8a65 100644 --- a/pkg/message/message.go +++ b/pkg/message/message.go @@ -38,6 +38,8 @@ func (m MessageType) String() string { return "CAT" case MessageTypePut: return "PUT" + case MessageTypePutV2: + return "PUTV2" case MessageTypeCommandComplete: return "COMMAND COMPLETE" case MessageTypeReadyForQuery: diff --git a/pkg/proc/interaction.go b/pkg/proc/interaction.go index 252070e..c821730 100644 --- a/pkg/proc/interaction.go +++ b/pkg/proc/interaction.go @@ -95,6 +95,10 @@ func ProcessPutExtended( } }() + for _, s := range settings { + ylogger.Zero.Debug().Str("name", s.Name).Str("value", s.Value).Msg("offloadng setting") + } + /* Should go after reader dispatch! */ err := s.PutFileToDest(name, r, settings)