grpc

Documentation

Index

• func ToheaderCarrier(m metadata.MD) headerCarrier
• func UnaryGrpcClientInterceptor(timeout time.Duration, mid []endpoint.Middleware) grpc.UnaryClientInterceptor
• func UnaryGrpcServerInterceptor() grpc.UnaryServerInterceptor
• type Transport
  • func NewTransport(endpoint, operation string, reqHeader, replyHeader headerCarrier) *Transport
  • func (tr *Transport) Endpoint() string
  • func (tr *Transport) Kind() xtransport.Kind
  • func (tr *Transport) Operation() string
  • func (tr *Transport) ReplyHeader() xtransport.Header
  • func (tr *Transport) RequestHeader() xtransport.Header

Functions

func ToheaderCarrier

func ToheaderCarrier(m metadata.MD) headerCarrier

func UnaryGrpcClientInterceptor

func UnaryGrpcClientInterceptor(timeout time.Duration, mid []endpoint.Middleware) grpc.UnaryClientInterceptor

func UnaryGrpcServerInterceptor

func UnaryGrpcServerInterceptor() grpc.UnaryServerInterceptor

Types

type Transport

type Transport struct {
	// contains filtered or unexported fields
}

Transport is a gRPC transport.

func NewTransport

func NewTransport(endpoint, operation string, reqHeader, replyHeader headerCarrier) *Transport

func (*Transport) Endpoint

func (tr *Transport) Endpoint() string

Endpoint returns the transport endpoint.

func (*Transport) Kind

func (tr *Transport) Kind() xtransport.Kind

Kind returns the transport kind.

func (*Transport) Operation

func (tr *Transport) Operation() string

Operation returns the transport operation.

func (*Transport) ReplyHeader

func (tr *Transport) ReplyHeader() xtransport.Header

ReplyHeader returns the reply header.

func (*Transport) RequestHeader

func (tr *Transport) RequestHeader() xtransport.Header

RequestHeader returns the request header.