From a684fc46288e38a7e1d3555cb9a5a48b8c65b634 Mon Sep 17 00:00:00 2001 From: kim <89579420+NyaaaWhatsUpDoc@users.noreply.github.com> Date: Sat, 18 Feb 2023 16:02:19 +0000 Subject: [chore] transport improvements (#1524) * improve error readability, mark "bad hosts" as fastFail Signed-off-by: kim * pull in latest go-byteutil version with byteutil.Reader{} Signed-off-by: kim * use rewindable body reader for post requests Signed-off-by: kim --------- Signed-off-by: kim --- vendor/codeberg.org/gruf/go-byteutil/reader.go | 36 ++++++++++++++++++++++++++ 1 file changed, 36 insertions(+) create mode 100644 vendor/codeberg.org/gruf/go-byteutil/reader.go (limited to 'vendor/codeberg.org/gruf/go-byteutil/reader.go') diff --git a/vendor/codeberg.org/gruf/go-byteutil/reader.go b/vendor/codeberg.org/gruf/go-byteutil/reader.go new file mode 100644 index 000000000..94c755ff4 --- /dev/null +++ b/vendor/codeberg.org/gruf/go-byteutil/reader.go @@ -0,0 +1,36 @@ +package byteutil + +import "bytes" + +// Reader wraps a bytes.Reader{} to provide Rewind() capabilities. +type Reader struct { + B []byte + bytes.Reader +} + +// NewReader returns a new Reader{} instance reset to b. +func NewReader(b []byte) *Reader { + r := &Reader{} + r.Reset(b) + return r +} + +// Reset resets the Reader{} to be reading from b and sets Reader{}.B. +func (r *Reader) Reset(b []byte) { + r.B = b + r.Rewind() +} + +// Rewind resets the Reader{} to be reading from the start of Reader{}.B. +func (r *Reader) Rewind() { + r.Reader.Reset(r.B) +} + +// ReadNopCloser wraps a Reader{} to provide nop close method. +type ReadNopCloser struct { + Reader +} + +func (*ReadNopCloser) Close() error { + return nil +} -- cgit v1.2.3