Versions in this module Expand all Collapse all v0 v0.0.1 Aug 6, 2019 Changes in this version + const Version + func MarshallTracing(carrier map[string]string) (b []byte, err error) + func NewRequestPayload(srv string, method string, d []byte, tracing []byte, metadata []byte) (req payload.Payload, err error) + func UnmarshallTracingCarrier(tracing []byte) (map[string]string, error) + type CallOption func(*callOption) + func WithMetadata(metadata []byte) CallOption + func WithTracing(tracing []byte) CallOption + type ClientConn struct + func NewClientConn(c rsocket.RSocket, m MeterRegistry, t Tracer) *ClientConn + func (p *ClientConn) InvokeChannel(ctx context.Context, srv string, method string, datachan chan *[]byte, ...) (<-chan payload.Payload, <-chan error) + func (p *ClientConn) InvokeRequestResponse(ctx context.Context, srv string, method string, data *[]byte, ...) (<-chan payload.Payload, <-chan error) + func (p *ClientConn) InvokeRequestStream(ctx context.Context, srv string, method string, data *[]byte, ...) (<-chan payload.Payload, <-chan error) + type Metadata []byte + func EncodeMetadata(service string, method string, tracing []byte, metadata []byte) (m Metadata, err error) + func (p Metadata) Metadata() []byte + func (p Metadata) Method() string + func (p Metadata) Service() string + func (p Metadata) String() string + func (p Metadata) Tracing() []byte + func (p Metadata) Version() uint16 + type MeterRegistry interface + type MethodDesc struct + Handler methodHandler + Name string + type RequestHandler struct + func NewRequestHandler() *RequestHandler + func (r *RequestHandler) FireAndForget(msg payload.Payload) + func (r *RequestHandler) MetadataPush(msg payload.Payload) + func (r *RequestHandler) Register(rsocket RrpcRSocket) error + func (r *RequestHandler) RequestChannel(msgs rx.Publisher) flux.Flux + func (r *RequestHandler) RequestResponse(msg payload.Payload) mono.Mono + func (r *RequestHandler) RequestStream(msg payload.Payload) flux.Flux + type RequestHandlingRSocket interface + Register func(rsocket RrpcRSocket) error + type RrpcRSocket interface + Name func() string + type ServiceDesc struct + HandlerType interface{} + Metadata interface{} + Methods []MethodDesc + Name string + type SpanContext opentracing.SpanContext + func UnmarshallTracing(tracer Tracer, tracing []byte) (SpanContext, error) + type Tracer opentracing.Tracer