Documentation ¶
Index ¶
- Constants
- 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
- type 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
- type MeterRegistry
- type MethodDesc
- type 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
- type RrpcRSocket
- type ServiceDesc
- type SpanContext
- type Tracer
Constants ¶
View Source
const Version = uint16(1)
Variables ¶
This section is empty.
Functions ¶
func NewRequestPayload ¶
Types ¶
type CallOption ¶
type CallOption func(*callOption)
func WithMetadata ¶
func WithMetadata(metadata []byte) CallOption
func WithTracing ¶
func WithTracing(tracing []byte) CallOption
type ClientConn ¶
type ClientConn struct {
// contains filtered or unexported fields
}
ClientConn struct
func NewClientConn ¶
func NewClientConn(c rsocket.RSocket, m MeterRegistry, t Tracer) *ClientConn
NewClientConn creates new client
func (*ClientConn) InvokeChannel ¶
func (*ClientConn) InvokeRequestResponse ¶
func (p *ClientConn) InvokeRequestResponse( ctx context.Context, srv string, method string, data *[]byte, opts ...CallOption, ) (<-chan payload.Payload, <-chan error)
InvokeRequestResponse invoke request response
func (*ClientConn) InvokeRequestStream ¶
func (p *ClientConn) InvokeRequestStream( ctx context.Context, srv string, method string, data *[]byte, opts ...CallOption, ) (<-chan payload.Payload, <-chan error)
InvokeRequestStream invoke request stream
type MeterRegistry ¶
type MeterRegistry interface { }
type MethodDesc ¶
type MethodDesc struct { Name string Handler methodHandler }
type RequestHandler ¶
type RequestHandler struct { rsocket.RSocket // contains filtered or unexported fields }
func NewRequestHandler ¶
func NewRequestHandler() *RequestHandler
func (*RequestHandler) FireAndForget ¶
func (r *RequestHandler) FireAndForget(msg payload.Payload)
FireAndForget is a single one-way message.
func (*RequestHandler) MetadataPush ¶
func (r *RequestHandler) MetadataPush(msg payload.Payload)
MetadataPush sends asynchronous Metadata frame.
func (*RequestHandler) Register ¶
func (r *RequestHandler) Register(rsocket RrpcRSocket) error
func (*RequestHandler) RequestChannel ¶
func (r *RequestHandler) RequestChannel(msgs rx.Publisher) flux.Flux
func (*RequestHandler) RequestResponse ¶
func (r *RequestHandler) RequestResponse(msg payload.Payload) mono.Mono
RequestResponse request single response.
func (*RequestHandler) RequestStream ¶
func (r *RequestHandler) RequestStream(msg payload.Payload) flux.Flux
RequestStream request a completable stream.
type RequestHandlingRSocket ¶
type RequestHandlingRSocket interface {
rsocket.RSocket
Register(rsocket RrpcRSocket) error
}
type RrpcRSocket ¶
type RrpcRSocket interface {
rsocket.RSocket
Name() string
}
type ServiceDesc ¶
type ServiceDesc struct { Name string HandlerType interface{} Methods []MethodDesc Metadata interface{} }
type SpanContext ¶
type SpanContext opentracing.SpanContext
func UnmarshallTracing ¶
func UnmarshallTracing(tracer Tracer, tracing []byte) (SpanContext, error)
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
protoc-gen-go is a plugin for the Google protocol buffer compiler to generate Go code.
|
protoc-gen-go is a plugin for the Google protocol buffer compiler to generate Go code. |
Click to show internal directories.
Click to hide internal directories.