grpcStatsHandler

Documentation

Index

• type ConnCounterHandler
  • func (h *ConnCounterHandler) GetConnCount() int
  • func (h *ConnCounterHandler) GetConnId(ctx context.Context) (int64, bool)
  • func (h *ConnCounterHandler) HandleConn(ctx context.Context, s stats.ConnStats)
  • func (h *ConnCounterHandler) HandleRPC(ctx context.Context, s stats.RPCStats)
  • func (h *ConnCounterHandler) TagConn(ctx context.Context, info *stats.ConnTagInfo) context.Context
  • func (h *ConnCounterHandler) TagRPC(ctx context.Context, info *stats.RPCTagInfo) context.Context

Types

type ConnCounterHandler

type ConnCounterHandler struct {
	sync.Mutex

	//如果非nil，则在连接断开时会以连接id为参数调用此回调
	ConnEndCallBack func(connId int64)
	// contains filtered or unexported fields
}

func (*ConnCounterHandler) GetConnCount

func (h *ConnCounterHandler) GetConnCount() int

func (*ConnCounterHandler) GetConnId

func (h *ConnCounterHandler) GetConnId(ctx context.Context) (int64, bool)

func (*ConnCounterHandler) HandleConn

func (h *ConnCounterHandler) HandleConn(ctx context.Context, s stats.ConnStats)

func (*ConnCounterHandler) HandleRPC

func (h *ConnCounterHandler) HandleRPC(ctx context.Context, s stats.RPCStats)

func (*ConnCounterHandler) TagConn

func (h *ConnCounterHandler) TagConn(ctx context.Context, info *stats.ConnTagInfo) context.Context

func (*ConnCounterHandler) TagRPC

func (h *ConnCounterHandler) TagRPC(ctx context.Context, info *stats.RPCTagInfo) context.Context