diff options
author | Jacob Vosmaer <jacob@gitlab.com> | 2018-01-18 18:23:42 +0100 |
---|---|---|
committer | Jacob Vosmaer <jacob@gitlab.com> | 2018-01-18 18:23:42 +0100 |
commit | bcc420c6e28cf74a3ef8c073c3b73f8d25e3fa99 (patch) | |
tree | 0d1dd660cab7bfb97c5d98d0b7f19cf199832ce3 | |
parent | 70d8bcdb9d1b6e578d6bde3adb0b97800adfef86 (diff) | |
download | gitlab-shell-gitaly-dependencies.tar.gz |
Remove unused dependenciesgitaly-dependencies
-rw-r--r-- | go/vendor/gitlab.com/gitlab-org/gitaly-proto/go/helper/inforefs.go | 32 | ||||
-rw-r--r-- | go/vendor/gitlab.com/gitlab-org/gitaly-proto/go/helper/stream.go | 44 |
2 files changed, 0 insertions, 76 deletions
diff --git a/go/vendor/gitlab.com/gitlab-org/gitaly-proto/go/helper/inforefs.go b/go/vendor/gitlab.com/gitlab-org/gitaly-proto/go/helper/inforefs.go deleted file mode 100644 index 5ddfbc2..0000000 --- a/go/vendor/gitlab.com/gitlab-org/gitaly-proto/go/helper/inforefs.go +++ /dev/null @@ -1,32 +0,0 @@ -package helper - -import ( - "io" - - pb "gitlab.com/gitlab-org/gitaly-proto/go" -) - -type InfoRefsClient interface { - Recv() (*pb.InfoRefsResponse, error) -} - -type InfoRefsClientWriterTo struct { - InfoRefsClient -} - -func (clientReader *InfoRefsClientWriterTo) WriteTo(w io.Writer) (total int64, err error) { - for { - response, err := clientReader.Recv() - if err == io.EOF { - return total, nil - } else if err != nil { - return total, err - } - - n, err := w.Write(response.GetData()) - total += int64(n) - if err != nil { - return total, err - } - } -} diff --git a/go/vendor/gitlab.com/gitlab-org/gitaly-proto/go/helper/stream.go b/go/vendor/gitlab.com/gitlab-org/gitaly-proto/go/helper/stream.go deleted file mode 100644 index 77cd157..0000000 --- a/go/vendor/gitlab.com/gitlab-org/gitaly-proto/go/helper/stream.go +++ /dev/null @@ -1,44 +0,0 @@ -package helper - -import ( - "io" -) - -// NewReceiveReader turns receiver into an io.Reader. Errors from the -// receiver function are passed on unmodified. This means receiver should -// emit io.EOF when done. -func NewReceiveReader(receiver func() ([]byte, error)) io.Reader { - return &receiveReader{receiver: receiver} -} - -type receiveReader struct { - receiver func() ([]byte, error) - data []byte - err error -} - -func (rr *receiveReader) Read(p []byte) (int, error) { - if len(rr.data) == 0 { - rr.data, rr.err = rr.receiver() - } - n := copy(p, rr.data) - rr.data = rr.data[n:] - if len(rr.data) == 0 { - return n, rr.err - } - return n, nil -} - -// NewSendWriter turns sender into an io.Writer. The number of 'bytes -// written' reported back is always len(p). -func NewSendWriter(sender func(p []byte) error) io.Writer { - return &sendWriter{sender: sender} -} - -type sendWriter struct { - sender func([]byte) error -} - -func (sw *sendWriter) Write(p []byte) (int, error) { - return len(p), sw.sender(p) -} |