rpc

package

v1.20.2 Latest Latest Go to latest Published: Apr 18, 2024 License: MIT Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func MetadataStreamInterceptor(md map[string][]string) grpc.StreamClientInterceptor

func MetadataUnaryInterceptor(md map[string][]string) grpc.UnaryClientInterceptor

func WithStatsCtx(parentCtx context.Context) context.Context

type ConnFactoryOption func(*GrpcConnFactorySettings)

func WithAuthority(authority string) ConnFactoryOption

func WithConnCred(insecure bool, caCert string, cert string, certKey string) ConnFactoryOption

func WithHeaders(h map[string][]string) ConnFactoryOption

func WithKeepalive(keepalive bool, keepaliveTime time.Duration) ConnFactoryOption

func WithMaxRecvMsgSize(messageSize int) ConnFactoryOption

type ConnectionOptions struct {
	Host      string
	Authority string
	Metadata  map[string][]string
}

func NewConnectionOpts(target string) (*ConnectionOptions, error)

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

func NewGrpcConnFactory(opts ...ConnFactoryOption) *GrpcConnFactory

func (f *GrpcConnFactory) Close() error

func (f *GrpcConnFactory) CloseConn(target string) error

func (f *GrpcConnFactory) GetConn(target string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

func (f *GrpcConnFactory) GetConnContext(ctx context.Context, target string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

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

type Stats struct {
	Duration time.Duration

	sync.RWMutex
	// contains filtered or unexported fields
}

func ExtractRpcStats(ctx context.Context) *Stats

func (s *Stats) FullMethod() string

func (s *Stats) ReqHeaders() metadata.MD

func (s *Stats) ReqSize() int64

func (s *Stats) RespHeaders() metadata.MD

func (s *Stats) RespSize() int64

func (s *Stats) RespTrailers() metadata.MD