chainstats

README

ChainStats

ChainStats is a simple Go library that allows you to chain multiple grpc.StatsHandler instances.

Installation

go get github.com/inigohu/chainstats

Usage

package main

import (
 "context"
 "google.golang.org/grpc"
 "google.golang.org/grpc/stats"
 "github.com/inigohu/chainstats"
)

// Example custom stats handler
type customStatsHandler struct{}

func (h *customStatsHandler) TagRPC(ctx context.Context, info *stats.RPCTagInfo) context.Context {
 // Add custom logic here
 return ctx
}

func (h *customStatsHandler) HandleRPC(ctx context.Context, stat stats.RPCStats) {
 // Add custom logic here
}

func (h *customStatsHandler) TagConn(ctx context.Context, info *stats.ConnTagInfo) context.Context {
 // Add custom logic here
 return ctx
}

func (h *customStatsHandler) HandleConn(ctx context.Context, stat stats.ConnStats) {
 // Add custom logic here
}

func main() {
 customHandler1 := &customStatsHandler{}
 customHandler2 := &customStatsHandler{}

 statsHandler := chainstats.NewChainStatsHandler(customHandler1, customHandler2)

 server := grpc.NewServer(grpc.StatsHandler(statsHandler))

 // Register your gRPC services and start the server
}

Documentation

Index

• type ChainStatsHandler
  • func NewChainStatsHandler(handlers ...stats.Handler) *ChainStatsHandler
  • func (c *ChainStatsHandler) HandleConn(ctx context.Context, stat stats.ConnStats)
  • func (c *ChainStatsHandler) HandleRPC(ctx context.Context, stat stats.RPCStats)
  • func (c *ChainStatsHandler) TagConn(ctx context.Context, info *stats.ConnTagInfo) context.Context
  • func (c *ChainStatsHandler) TagRPC(ctx context.Context, info *stats.RPCTagInfo) context.Context

Types

type ChainStatsHandler

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

ChainStatsHandler is a composite stats.Handler that chains multiple stats.Handler instances.

func NewChainStatsHandler

func NewChainStatsHandler(handlers ...stats.Handler) *ChainStatsHandler

NewChainStatsHandler creates a new ChainStatsHandler.

func (*ChainStatsHandler) HandleConn

func (c *ChainStatsHandler) HandleConn(ctx context.Context, stat stats.ConnStats)

HandleConn calls HandleConn on all the chained stats.Handler instances.

func (*ChainStatsHandler) HandleRPC

func (c *ChainStatsHandler) HandleRPC(ctx context.Context, stat stats.RPCStats)

HandleRPC calls HandleRPC on all the chained stats.Handler instances.

func (*ChainStatsHandler) TagConn

func (c *ChainStatsHandler) TagConn(ctx context.Context, info *stats.ConnTagInfo) context.Context

TagConn calls TagConn on all the chained stats.Handler instances.

func (*ChainStatsHandler) TagRPC

func (c *ChainStatsHandler) TagRPC(ctx context.Context, info *stats.RPCTagInfo) context.Context

TagRPC calls TagRPC on all the chained stats.Handler instances.