Versions in this module Expand all Collapse all v0 v0.2.2 Oct 31, 2018 Changes in this version + var DefaultStreamTransportBuilder StreamTransportBuilder = WebSocketTransportBuilder + var DefaultTransportBuilder TransportBuilder = HTTPTransportBuilder + var ErrConnectionClosed = errors.New("connection closed") + func ToEndpoint(pkg string, s *descriptor.ServiceDescriptorProto, ...) string + type BidiStreamClient interface + Close func() error + Receive func() (*Response, error) + Send func(*Request) error + type Client struct + func NewClient(host string, opts ...ClientOption) *Client + func (c *Client) BidiStreaming(ctx context.Context, req *Request) (BidiStreamClient, error) + func (c *Client) ClientStreaming(ctx context.Context) (ClientStreamClient, error) + func (c *Client) ServerStreaming(ctx context.Context, req *Request) (ServerStreamClient, error) + func (c *Client) Unary(ctx context.Context, req *Request) (*Response, error) + type ClientOption func(*Client) + func WithCodec(codec encoding.Codec) ClientOption + func WithStreamTransportBuilder(b StreamTransportBuilder) ClientOption + func WithTransportBuilder(b TransportBuilder) ClientOption + type ClientStreamClient interface + CloseAndReceive func() (*Response, error) + Send func(*Request) error + type HTTPTransport struct + func (t *HTTPTransport) Send(ctx context.Context, body io.Reader) (io.ReadCloser, error) + type Request struct + func NewRequest(endpoint string, in proto.Message, out proto.Message) *Request + type Response struct + Content interface{} + ContentType string + type ServerStreamClient interface + Receive func() (*Response, error) + type StreamTransport interface + Close func() error + Finish func() (io.ReadCloser, error) + Receive func() (io.ReadCloser, error) + Send func(body io.Reader) error + func WebSocketTransportBuilder(host string, endpoint string) (StreamTransport, error) + type StreamTransportBuilder func(host string, endpoint string) (StreamTransport, error) + type Transport interface + Send func(ctx context.Context, body io.Reader) (io.ReadCloser, error) + func HTTPTransportBuilder(host string, req *Request) Transport + type TransportBuilder func(host string, req *Request) Transport + type WebSocketTransport struct + func (t *WebSocketTransport) Close() error + func (t *WebSocketTransport) Finish() (io.ReadCloser, error) + func (t *WebSocketTransport) Receive() (res io.ReadCloser, err error) + func (t *WebSocketTransport) Send(body io.Reader) error