psrpc

Documentation

Index

• func CheckCompilerVersion(path string) error
• func WithClientLogger(logger logger.Logger) psrpc.ClientOption
• func WithServerLogger(logger logger.Logger) psrpc.ServerOption
• func WithSuppressClientErrors(errs ...error) psrpc.ClientOption
• func WithSuppressServerErrors(errs ...error) psrpc.ServerOption
• type UnimplementedMetricsObserver
  • func (o UnimplementedMetricsObserver) OnMultiRequest(role middleware.MetricRole, rpcInfo psrpc.RPCInfo, duration time.Duration, ...)
  • func (o UnimplementedMetricsObserver) OnStreamClose(role middleware.MetricRole, rpcInfo psrpc.RPCInfo)
  • func (o UnimplementedMetricsObserver) OnStreamOpen(role middleware.MetricRole, rpcInfo psrpc.RPCInfo)
  • func (o UnimplementedMetricsObserver) OnStreamRecv(role middleware.MetricRole, rpcInfo psrpc.RPCInfo, err error)
  • func (o UnimplementedMetricsObserver) OnStreamSend(role middleware.MetricRole, rpcInfo psrpc.RPCInfo, duration time.Duration, ...)
  • func (o UnimplementedMetricsObserver) OnUnaryRequest(role middleware.MetricRole, rpcInfo psrpc.RPCInfo, duration time.Duration, ...)

Functions

func CheckCompilerVersion

func CheckCompilerVersion(path string) error

func WithClientLogger

func WithClientLogger(logger logger.Logger) psrpc.ClientOption

func WithServerLogger

func WithServerLogger(logger logger.Logger) psrpc.ServerOption

func WithSuppressClientErrors

func WithSuppressClientErrors(errs ...error) psrpc.ClientOption

func WithSuppressServerErrors

func WithSuppressServerErrors(errs ...error) psrpc.ServerOption

Types

type UnimplementedMetricsObserver

type UnimplementedMetricsObserver struct{}

func (UnimplementedMetricsObserver) OnMultiRequest

func (o UnimplementedMetricsObserver) OnMultiRequest(role middleware.MetricRole, rpcInfo psrpc.RPCInfo, duration time.Duration, responseCount int, errorCount int)

func (UnimplementedMetricsObserver) OnStreamClose

func (o UnimplementedMetricsObserver) OnStreamClose(role middleware.MetricRole, rpcInfo psrpc.RPCInfo)

func (UnimplementedMetricsObserver) OnStreamOpen

func (o UnimplementedMetricsObserver) OnStreamOpen(role middleware.MetricRole, rpcInfo psrpc.RPCInfo)

func (UnimplementedMetricsObserver) OnStreamRecv

func (o UnimplementedMetricsObserver) OnStreamRecv(role middleware.MetricRole, rpcInfo psrpc.RPCInfo, err error)

func (UnimplementedMetricsObserver) OnStreamSend

func (o UnimplementedMetricsObserver) OnStreamSend(role middleware.MetricRole, rpcInfo psrpc.RPCInfo, duration time.Duration, err error)

func (UnimplementedMetricsObserver) OnUnaryRequest

func (o UnimplementedMetricsObserver) OnUnaryRequest(role middleware.MetricRole, rpcInfo psrpc.RPCInfo, duration time.Duration, err error)