The highest tagged major version is v2.

grpcutil

package

v0.2.10-1 Latest Latest Go to latest Published: Sep 19, 2022 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

func ContextWithStats(ctx context.Context, stats *GRPCStats) context.Context

ContextWithStats Returns a new `context.Context` that holds a reference to `GRPCStats`.

func EnableAdmin(s grpc.ServiceRegistrar) (cleanup func(), _ error)

func EnableDebug(s *grpc.Server)

func EnableHealth(srv string, s *grpc.Server)

func EnableReflection(s *grpc.Server)

func HeaderGet(h Header, name string) string

func IsGRPCRequest(r *http.Request) bool

IsGRPCRequest returns true if the message is considered to be a GRPC message

type GRPCStats struct {
	Duration clock.Duration
	Method   string
	Failed   float64
	Success  float64
}

func StatsFromContext(ctx context.Context) *GRPCStats

StatsFromContext Returns the `GRPCStats` previously associated with `ctx`.

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

GRPCStatsHandler Implements the Prometheus collector interface. Such that when the /metrics handler is called this collector pulls all the stats from

func NewGRPCStatsHandler() *GRPCStatsHandler

func (c *GRPCStatsHandler) Close()

func (c *GRPCStatsHandler) Collect(ch chan<- prometheus.Metric)

func (c *GRPCStatsHandler) Describe(ch chan<- *prometheus.Desc)

func (c *GRPCStatsHandler) HandleConn(ctx context.Context, s stats.ConnStats)

func (c *GRPCStatsHandler) HandleRPC(ctx context.Context, s stats.RPCStats)

func (c *GRPCStatsHandler) TagConn(ctx context.Context, _ *stats.ConnTagInfo) context.Context

func (c *GRPCStatsHandler) TagRPC(ctx context.Context, tagInfo *stats.RPCTagInfo) context.Context

type Header = metadata.MD