grpc

Documentation

Index

• Variables
• func AddMetaToOutgoingStreamInterceptor(kv ...string) grpc.StreamClientInterceptor
• func AddMetaToOutgoingUnaryInterceptor(kv ...string) grpc.UnaryClientInterceptor
• func WithErrorWrapper(c grpc.ClientConnInterface, serviceNamePrefix string) grpc.ClientConnInterface
• type Closable
• type ClosableClientConnInterface
  • func MakeCloseable(c grpc.ClientConnInterface) ClosableClientConnInterface
• type HostNamePropagator
  • func (h HostNamePropagator) ClientStream() grpc.StreamClientInterceptor
  • func (h HostNamePropagator) ClientUnary() grpc.UnaryClientInterceptor

Variables

var ErrConnClosed = internal.ErrConnClosed

ErrConnClosed send when grpc is closed

Functions

func AddMetaToOutgoingStreamInterceptor

func AddMetaToOutgoingStreamInterceptor(kv ...string) grpc.StreamClientInterceptor

AddMetaToOutgoingStreamInterceptor - specifies fixed headers for every rpc as kv array

func AddMetaToOutgoingUnaryInterceptor

func AddMetaToOutgoingUnaryInterceptor(kv ...string) grpc.UnaryClientInterceptor

AddMetaToOutgoingUnaryInterceptor - specifies fixed headers for every rpc as kv array

func WithErrorWrapper

func WithErrorWrapper(c grpc.ClientConnInterface, serviceNamePrefix string) grpc.ClientConnInterface

WithErrorWrapper ...

Types

type Closable

type Closable interface {
	CloseConn() error
}

Closable is closable connect

type ClosableClientConnInterface

type ClosableClientConnInterface interface {
	grpc.ClientConnInterface
	Closable
}

ClosableClientConnInterface grpc client conn interface with close ability

func MakeCloseable

func MakeCloseable(c grpc.ClientConnInterface) ClosableClientConnInterface

MakeCloseable ...

type HostNamePropagator

type HostNamePropagator string

HostNamePropagator add host name into outgoing metadata

func (HostNamePropagator) ClientStream

func (h HostNamePropagator) ClientStream() grpc.StreamClientInterceptor

ClientStream stream client interceptor

func (HostNamePropagator) ClientUnary

func (h HostNamePropagator) ClientUnary() grpc.UnaryClientInterceptor

ClientUnary unary client interceptor