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)