diff options
Diffstat (limited to 'lib/go/thrift/debug_protocol.go')
| -rw-r--r-- | lib/go/thrift/debug_protocol.go | 16 |
1 files changed, 16 insertions, 0 deletions
diff --git a/lib/go/thrift/debug_protocol.go b/lib/go/thrift/debug_protocol.go index c1f4fab4c..83ccad94b 100644 --- a/lib/go/thrift/debug_protocol.go +++ b/lib/go/thrift/debug_protocol.go @@ -258,6 +258,14 @@ func (tdp *TDebugProtocol) WriteBinary(ctx context.Context, value []byte) error } return err } +func (tdp *TDebugProtocol) WriteUUID(ctx context.Context, value Tuuid) error { + err := tdp.Delegate.WriteUUID(ctx, value) + tdp.logf("%sWriteUUID(value=%#v) => %#v", tdp.LogPrefix, value, err) + if tdp.DuplicateTo != nil { + tdp.DuplicateTo.WriteUUID(ctx, value) + } + return err +} func (tdp *TDebugProtocol) ReadMessageBegin(ctx context.Context) (name string, typeId TMessageType, seqid int32, err error) { name, typeId, seqid, err = tdp.Delegate.ReadMessageBegin(ctx) @@ -419,6 +427,14 @@ func (tdp *TDebugProtocol) ReadBinary(ctx context.Context) (value []byte, err er } return } +func (tdp *TDebugProtocol) ReadUUID(ctx context.Context) (value Tuuid, err error) { + value, err = tdp.Delegate.ReadUUID(ctx) + tdp.logf("%sReadUUID() (value=%#v, err=%#v)", tdp.LogPrefix, value, err) + if tdp.DuplicateTo != nil { + tdp.DuplicateTo.WriteUUID(ctx, value) + } + return +} func (tdp *TDebugProtocol) Skip(ctx context.Context, fieldType TType) (err error) { err = tdp.Delegate.Skip(ctx, fieldType) tdp.logf("%sSkip(fieldType=%#v) (err=%#v)", tdp.LogPrefix, fieldType, err) |