grpcutil

Documentation

Index

• func StreamServerStatusMetricHandler(statusCodes map[string][]uint64, promRequest func(string, int)) grpc.StreamServerInterceptor
• func StreamServerTimeHandler(cb func(payload, peer string, t time.Duration)) grpc.StreamServerInterceptor
• func UnaryServerStatusMetricHandler(statusCodes map[string][]uint64, promRequest func(string, int)) grpc.UnaryServerInterceptor
• func UnaryServerTimeHandler(cb func(payload, peer string, t time.Duration)) grpc.UnaryServerInterceptor
• type WrappedStream
  • func GetWrappedStream(ss grpc.ServerStream) *WrappedStream
  • func (ws *WrappedStream) Context() context.Context
  • func (ws *WrappedStream) Payload() string
  • func (ws *WrappedStream) RecvMsg(m interface{}) error
  • func (ws *WrappedStream) SetContext(ctx context.Context)

Functions

func StreamServerStatusMetricHandler

func StreamServerStatusMetricHandler(statusCodes map[string][]uint64, promRequest func(string, int)) grpc.StreamServerInterceptor

func StreamServerTimeHandler

func StreamServerTimeHandler(cb func(payload, peer string, t time.Duration)) grpc.StreamServerInterceptor

func UnaryServerStatusMetricHandler

func UnaryServerStatusMetricHandler(statusCodes map[string][]uint64, promRequest func(string, int)) grpc.UnaryServerInterceptor

func UnaryServerTimeHandler

func UnaryServerTimeHandler(cb func(payload, peer string, t time.Duration)) grpc.UnaryServerInterceptor

Types

type WrappedStream

type WrappedStream struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

func GetWrappedStream

func GetWrappedStream(ss grpc.ServerStream) *WrappedStream

func (*WrappedStream) Context

func (ws *WrappedStream) Context() context.Context

func (*WrappedStream) Payload

func (ws *WrappedStream) Payload() string

func (*WrappedStream) RecvMsg

func (ws *WrappedStream) RecvMsg(m interface{}) error

func (*WrappedStream) SetContext

func (ws *WrappedStream) SetContext(ctx context.Context)