encoding/thrift: Plumb the outbounds calling logic into the generated…

… yarpc client code

@smyth provided the initial logic for making oubounds thrift calls using the
thriftrw 'no-wire' (read: streaming) implementation.  Leverage this logic in
the generated yarpc client code.

This is done through generating a completely independent client and leveraging
that code path iff the new no-wire client was generated and if it was enabled.

encoding/thrift/envelope.go

@@ -25,6 +25,7 @@ import (
 	"io"
 
 	"go.uber.org/thriftrw/protocol"
+	"go.uber.org/thriftrw/protocol/stream"
 	"go.uber.org/thriftrw/wire"
 )
 
@@ -55,3 +56,45 @@ func (ev disableEnvelopingProtocol) DecodeEnveloped(r io.ReaderAt) (wire.Envelop
 		Value: value,
 	}, err
 }
+
+type disableEnvelopingNoWireProtocol struct {
+	stream.Protocol
+
+	Type wire.EnvelopeType
+}
+
+func (evsp disableEnvelopingNoWireProtocol) Reader(r io.Reader) stream.Reader {
+	return disableEnvelopingReader{
+		Reader: evsp.Protocol.Reader(r),
+		Type:   evsp.Type,
+	}
+}
+
+func (evsp disableEnvelopingNoWireProtocol) Writer(w io.Writer) stream.Writer {
+	return disableEnvelopingWriter{
+		Writer: evsp.Protocol.Writer(w),
+	}
+}
+
+type disableEnvelopingReader struct {
+	stream.Reader
+
+	Type wire.EnvelopeType
+}
+
+func (evr disableEnvelopingReader) ReadEnvelopeBegin() (stream.EnvelopeHeader, error) {
+	return stream.EnvelopeHeader{
+		Name:  "",
+		Type:  evr.Type,
+		SeqID: 1,
+	}, nil
+}
+
+func (evr disableEnvelopingReader) ReadEnvelopeEnd() error { return nil }
+
+type disableEnvelopingWriter struct {
+	stream.Writer
+}
+
+func (evw disableEnvelopingWriter) WriteEnvelopeBegin(stream.EnvelopeHeader) error { return nil }
+func (evw disableEnvelopingWriter) WriteEnvelopeEnd() error                        { return nil }

encoding/thrift/inject.go

@@ -45,6 +45,8 @@ func ClientBuilderOptions(_ transport.ClientConfig, f reflect.StructField) []Cli
 			opts = append(opts, Multiplexed)
 		case "enveloped":
 			opts = append(opts, Enveloped)
+		case "nowire":
+			opts = append(opts, NoWire(true))
 		default:
 			// Ignore unknown options
 		}

encoding/thrift/multiplex.go

@@ -25,6 +25,7 @@ import (
 	"strings"
 
 	"go.uber.org/thriftrw/protocol"
+	"go.uber.org/thriftrw/protocol/stream"
 	"go.uber.org/thriftrw/wire"
 )
 
@@ -48,3 +49,46 @@ func (m multiplexedOutboundProtocol) DecodeEnveloped(r io.ReaderAt) (wire.Envelo
 	e.Name = strings.TrimPrefix(e.Name, m.Service+":")
 	return e, err
 }
+
+type multiplexedOutboundNoWireProtocol struct {
+	stream.Protocol
+
+	Service string
+}
+
+func (m multiplexedOutboundNoWireProtocol) Writer(w io.Writer) stream.Writer {
+	return multiplexedWriter{
+		Writer:  m.Protocol.Writer(w),
+		Service: m.Service,
+	}
+}
+
+func (m multiplexedOutboundNoWireProtocol) Reader(r io.Reader) stream.Reader {
+	return multiplexedReader{
+		Reader:  m.Protocol.Reader(r),
+		Service: m.Service,
+	}
+}
+
+type multiplexedWriter struct {
+	stream.Writer
+
+	Service string
+}
+
+func (w multiplexedWriter) WriteEnvelopeBegin(eh stream.EnvelopeHeader) error {
+	eh.Name = w.Service + ":" + eh.Name
+	return w.Writer.WriteEnvelopeBegin(eh)
+}
+
+type multiplexedReader struct {
+	stream.Reader
+
+	Service string
+}
+
+func (r multiplexedReader) ReadEnvelopeBegin() (stream.EnvelopeHeader, error) {
+	eh, err := r.Reader.ReadEnvelopeBegin()
+	eh.Name = strings.TrimPrefix(eh.Name, r.Service+":")
+	return eh, err
+}