2a81659f49
Rather than employ the typeurl package, we now generate code to correctly allocate the incoming types from the caller. As a side-effect of this activity, the services definitions have been split out into a separate type that handles the full resolution and dispatch of the method, incuding correctly mapping the RPC status. This work is a pre-cursor to larger protocol change that will allow us to handle multiple, concurrent requests. Signed-off-by: Stephen J Day <stephen.day@docker.com>
27 lines
776 B
Go
27 lines
776 B
Go
package ttrpc
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
spb "google.golang.org/genproto/googleapis/rpc/status"
|
|
)
|
|
|
|
type Request struct {
|
|
Service string `protobuf:"bytes,1,opt,name=service,proto3"`
|
|
Method string `protobuf:"bytes,2,opt,name=method,proto3"`
|
|
Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3"`
|
|
}
|
|
|
|
func (r *Request) Reset() { *r = Request{} }
|
|
func (r *Request) String() string { return fmt.Sprintf("%+#v", r) }
|
|
func (r *Request) ProtoMessage() {}
|
|
|
|
type Response struct {
|
|
Status *spb.Status `protobuf:"bytes,1,opt,name=status,proto3"`
|
|
Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3"`
|
|
}
|
|
|
|
func (r *Response) Reset() { *r = Response{} }
|
|
func (r *Response) String() string { return fmt.Sprintf("%+#v", r) }
|
|
func (r *Response) ProtoMessage() {}
|