Home
last modified time | relevance | path

Searched refs:statsHandler (Results 1 – 25 of 540) sorted by relevance

12345678910>>...22

/dports/www/pomerium/pomerium-0.8.3/internal/telemetry/metrics/
H A Dgrpc_test.go34 statsHandler stats.Handler member
41 ctx = t.statsHandler.TagRPC(ctx, &stats.RPCTagInfo{FullMethodName: method})
42 t.statsHandler.HandleRPC(ctx, &stats.InPayload{Client: true, Length: len(r.message)})
43 t.statsHandler.HandleRPC(ctx, &stats.OutPayload{Client: true, Length: len(r.message)})
44 t.statsHandler.HandleRPC(ctx, &stats.End{Client: true, Error: t.invokeResult})
106 statsHandler: &ocgrpc.ClientHandler{},
124 statsHandler.HandleRPC(ctx, &stats.InPayload{Client: false, Length: len(message)})
125 statsHandler.HandleRPC(ctx, &stats.OutPayload{Client: false, Length: len(message)})
126 statsHandler.HandleRPC(ctx, &stats.End{Client: false, Error: errorCode})
174 statsHandler := NewGRPCServerStatsHandler("test_service")
[all …]
/dports/sysutils/consul/consul-1.10.3/agent/grpc/
H A Dstats.go54 type statsHandler struct { struct
62 func newStatsHandler(m *metrics.Metrics) *statsHandler {
63 return &statsHandler{metrics: m}
67 func (c *statsHandler) TagRPC(ctx context.Context, _ *stats.RPCTagInfo) context.Context { argument
73 func (c *statsHandler) HandleRPC(_ context.Context, s stats.RPCStats) { argument
85 func (c *statsHandler) TagConn(ctx context.Context, _ *stats.ConnTagInfo) context.Context { argument
91 func (c *statsHandler) HandleConn(_ context.Context, s stats.ConnStats) { argument
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/hashicorp/consul/agent/grpc/
H A Dstats.go54 type statsHandler struct { struct
62 func newStatsHandler(m *metrics.Metrics) *statsHandler {
63 return &statsHandler{metrics: m}
67 func (c *statsHandler) TagRPC(ctx context.Context, _ *stats.RPCTagInfo) context.Context { argument
73 func (c *statsHandler) HandleRPC(_ context.Context, s stats.RPCStats) { argument
85 func (c *statsHandler) TagConn(ctx context.Context, _ *stats.ConnTagInfo) context.Context { argument
91 func (c *statsHandler) HandleConn(_ context.Context, s stats.ConnStats) { argument
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/hashicorp/consul/agent/grpc/
H A Dstats.go54 type statsHandler struct { struct
62 func newStatsHandler(m *metrics.Metrics) *statsHandler {
63 return &statsHandler{metrics: m}
67 func (c *statsHandler) TagRPC(ctx context.Context, _ *stats.RPCTagInfo) context.Context { argument
73 func (c *statsHandler) HandleRPC(_ context.Context, s stats.RPCStats) { argument
85 func (c *statsHandler) TagConn(ctx context.Context, _ *stats.ConnTagInfo) context.Context { argument
91 func (c *statsHandler) HandleConn(_ context.Context, s stats.ConnStats) { argument
/dports/graphics/osg34/OpenSceneGraph-OpenSceneGraph-3.4.1/examples/osguserstats/
H A Dosguserstats.cpp49 void initUserStats(osgViewer::StatsHandler* statsHandler) in initUserStats() argument
52 statsHandler->addUserStatsLine("Frame", osg::Vec4(0.7,0.7,0.7,1), osg::Vec4(0.7,0.7,0.7,0.5), in initUserStats()
56 statsHandler->addUserStatsLine("MS/frame", osg::Vec4(1,0,1,1), osg::Vec4(1,0,1,0.5), in initUserStats()
60 statsHandler->addUserStatsLine("Custom", osg::Vec4(1,1,1,1), osg::Vec4(1,1,1,0.5), in initUserStats()
64 statsHandler->addUserStatsLine("Sleep1", osg::Vec4(1,0,0,1), osg::Vec4(1,0,0,0.5), in initUserStats()
68 statsHandler->addUserStatsLine("Sleep2", osg::Vec4(1,0.5,0.5,1), osg::Vec4(1,0.5,0.5,0.5), in initUserStats()
72 statsHandler->addUserStatsLine("Thread", osg::Vec4(0,0.5,0,1), osg::Vec4(0,0.5,0,0.5), in initUserStats()
305 osgViewer::StatsHandler* statsHandler = new osgViewer::StatsHandler; in main() local
306 viewer.addEventHandler(statsHandler); in main()
308 initUserStats(statsHandler); in main()
/dports/graphics/osg/OpenSceneGraph-OpenSceneGraph-3.6.5/examples/osguserstats/
H A Dosguserstats.cpp49 void initUserStats(osgViewer::StatsHandler* statsHandler) in initUserStats() argument
52 statsHandler->addUserStatsLine("Frame", osg::Vec4(0.7,0.7,0.7,1), osg::Vec4(0.7,0.7,0.7,0.5), in initUserStats()
56 statsHandler->addUserStatsLine("MS/frame", osg::Vec4(1,0,1,1), osg::Vec4(1,0,1,0.5), in initUserStats()
60 statsHandler->addUserStatsLine("Custom", osg::Vec4(1,1,1,1), osg::Vec4(1,1,1,0.5), in initUserStats()
64 statsHandler->addUserStatsLine("Sleep1", osg::Vec4(1,0,0,1), osg::Vec4(1,0,0,0.5), in initUserStats()
68 statsHandler->addUserStatsLine("Sleep2", osg::Vec4(1,0.5,0.5,1), osg::Vec4(1,0.5,0.5,0.5), in initUserStats()
72 statsHandler->addUserStatsLine("Thread", osg::Vec4(0,0.5,0,1), osg::Vec4(0,0.5,0,0.5), in initUserStats()
305 osgViewer::StatsHandler* statsHandler = new osgViewer::StatsHandler; in main() local
306 viewer.addEventHandler(statsHandler); in main()
308 initUserStats(statsHandler); in main()
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gopkg.in/DataDog/dd-trace-go.v1/contrib/google.golang.org/grpc/
H A Dstats_server_test.go27 statsHandler := NewServerStatsHandler(WithServiceName(serviceName))
28 server, err := newServerStatsHandlerTestServer(statsHandler)
56 func newServerStatsHandlerTestServer(statsHandler stats.Handler) (*rig, error) {
57 server := grpc.NewServer(grpc.StatsHandler(statsHandler))
H A Dstats_client_test.go28 statsHandler := NewClientStatsHandler(WithServiceName(serviceName))
29 server, err := newClientStatsHandlerTestServer(statsHandler)
61 func newClientStatsHandlerTestServer(statsHandler stats.Handler) (*rig, error) {
73 …conn, err := grpc.Dial(li.Addr().String(), grpc.WithInsecure(), grpc.WithStatsHandler(statsHandler…
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/gopkg.in/DataDog/dd-trace-go.v1/contrib/google.golang.org/grpc/
H A Dstats_server_test.go27 statsHandler := NewServerStatsHandler(WithServiceName(serviceName))
28 server, err := newServerStatsHandlerTestServer(statsHandler)
56 func newServerStatsHandlerTestServer(statsHandler stats.Handler) (*rig, error) {
57 server := grpc.NewServer(grpc.StatsHandler(statsHandler))
H A Dstats_client_test.go28 statsHandler := NewClientStatsHandler(WithServiceName(serviceName))
29 server, err := newClientStatsHandlerTestServer(statsHandler)
61 func newClientStatsHandlerTestServer(statsHandler stats.Handler) (*rig, error) {
73 …conn, err := grpc.Dial(li.Addr().String(), grpc.WithInsecure(), grpc.WithStatsHandler(statsHandler…
/dports/www/fabio/fabio-1.5.14/vendor/github.com/hashicorp/consul/consul-1.4.2/vendor/github.com/hashicorp/go-discover/provider/gce/vendor/google.golang.org/grpc/
H A Dstream.go228 statsHandler: cc.dopts.copts.StatsHandler,
287 statsHandler stats.Handler member
341 if cs.statsHandler != nil {
358 cs.statsHandler.HandleRPC(cs.statsCtx, outPayload)
365 if err != nil && cs.statsHandler != nil {
376 cs.statsHandler.HandleRPC(cs.statsCtx, end)
380 if cs.statsHandler != nil {
401 cs.statsHandler.HandleRPC(cs.statsCtx, inPayload)
526 statsHandler stats.Handler member
570 if ss.statsHandler != nil {
[all …]
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/hashicorp/consul/vendor/github.com/hashicorp/go-discover/provider/gce/vendor/google.golang.org/grpc/
H A Dstream.go228 statsHandler: cc.dopts.copts.StatsHandler,
287 statsHandler stats.Handler member
341 if cs.statsHandler != nil {
358 cs.statsHandler.HandleRPC(cs.statsCtx, outPayload)
365 if err != nil && cs.statsHandler != nil {
376 cs.statsHandler.HandleRPC(cs.statsCtx, end)
380 if cs.statsHandler != nil {
401 cs.statsHandler.HandleRPC(cs.statsCtx, inPayload)
526 statsHandler stats.Handler member
570 if ss.statsHandler != nil {
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/vendor/github.com/hashicorp/go-discover/provider/gce/vendor/google.golang.org/grpc/
H A Dstream.go228 statsHandler: cc.dopts.copts.StatsHandler,
287 statsHandler stats.Handler member
341 if cs.statsHandler != nil {
358 cs.statsHandler.HandleRPC(cs.statsCtx, outPayload)
365 if err != nil && cs.statsHandler != nil {
376 cs.statsHandler.HandleRPC(cs.statsCtx, end)
380 if cs.statsHandler != nil {
401 cs.statsHandler.HandleRPC(cs.statsCtx, inPayload)
526 statsHandler stats.Handler member
570 if ss.statsHandler != nil {
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/go-discover/provider/gce/vendor/google.golang.org/grpc/
H A Dstream.go228 statsHandler: cc.dopts.copts.StatsHandler,
287 statsHandler stats.Handler member
341 if cs.statsHandler != nil {
358 cs.statsHandler.HandleRPC(cs.statsCtx, outPayload)
365 if err != nil && cs.statsHandler != nil {
376 cs.statsHandler.HandleRPC(cs.statsCtx, end)
380 if cs.statsHandler != nil {
401 cs.statsHandler.HandleRPC(cs.statsCtx, inPayload)
526 statsHandler stats.Handler member
570 if ss.statsHandler != nil {
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/docker/docker/vendor/google.golang.org/grpc/
H A Dstream.go233 statsHandler: cc.dopts.copts.StatsHandler,
293 statsHandler stats.Handler member
347 if cs.statsHandler != nil {
364 cs.statsHandler.HandleRPC(cs.statsCtx, outPayload)
371 if cs.statsHandler != nil {
392 cs.statsHandler.HandleRPC(cs.statsCtx, inPayload)
477 if cs.statsHandler != nil {
486 cs.statsHandler.HandleRPC(cs.statsCtx, end)
534 statsHandler stats.Handler member
578 if ss.statsHandler != nil {
[all …]
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/concourse/dex/vendor/google.golang.org/grpc/
H A Dstream.go229 statsHandler: cc.dopts.copts.StatsHandler,
286 statsHandler stats.Handler member
340 if cs.statsHandler != nil {
357 cs.statsHandler.HandleRPC(cs.statsCtx, outPayload)
364 if cs.statsHandler != nil {
385 cs.statsHandler.HandleRPC(cs.statsCtx, inPayload)
466 if cs.statsHandler != nil {
475 cs.statsHandler.HandleRPC(cs.statsCtx, end)
523 statsHandler stats.Handler member
567 if ss.statsHandler != nil {
[all …]
/dports/sysutils/helm/helm-3.5.2/vendor/github.com/docker/docker/vendor/google.golang.org/grpc/
H A Dstream.go233 statsHandler: cc.dopts.copts.StatsHandler,
293 statsHandler stats.Handler member
347 if cs.statsHandler != nil {
364 cs.statsHandler.HandleRPC(cs.statsCtx, outPayload)
371 if cs.statsHandler != nil {
392 cs.statsHandler.HandleRPC(cs.statsCtx, inPayload)
477 if cs.statsHandler != nil {
486 cs.statsHandler.HandleRPC(cs.statsCtx, end)
534 statsHandler stats.Handler member
578 if ss.statsHandler != nil {
[all …]
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/hashicorp/consul/vendor/github.com/hashicorp/go-discover/provider/gce/vendor/google.golang.org/grpc/
H A Dstream.go228 statsHandler: cc.dopts.copts.StatsHandler,
287 statsHandler stats.Handler member
341 if cs.statsHandler != nil {
358 cs.statsHandler.HandleRPC(cs.statsCtx, outPayload)
365 if err != nil && cs.statsHandler != nil {
376 cs.statsHandler.HandleRPC(cs.statsCtx, end)
380 if cs.statsHandler != nil {
401 cs.statsHandler.HandleRPC(cs.statsCtx, inPayload)
526 statsHandler stats.Handler member
570 if ss.statsHandler != nil {
[all …]
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/prometheus/prometheus/vendor/google.golang.org/grpc/
H A Dstream.go236 statsHandler: cc.dopts.copts.StatsHandler,
296 statsHandler stats.Handler member
350 if cs.statsHandler != nil {
367 cs.statsHandler.HandleRPC(cs.statsCtx, outPayload)
374 if cs.statsHandler != nil {
395 cs.statsHandler.HandleRPC(cs.statsCtx, inPayload)
480 if cs.statsHandler != nil {
489 cs.statsHandler.HandleRPC(cs.statsCtx, end)
537 statsHandler stats.Handler member
581 if ss.statsHandler != nil {
[all …]
/dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/hashicorp/consul/vendor/github.com/hashicorp/go-discover/provider/gce/vendor/google.golang.org/grpc/
H A Dstream.go228 statsHandler: cc.dopts.copts.StatsHandler,
287 statsHandler stats.Handler member
341 if cs.statsHandler != nil {
358 cs.statsHandler.HandleRPC(cs.statsCtx, outPayload)
365 if err != nil && cs.statsHandler != nil {
376 cs.statsHandler.HandleRPC(cs.statsCtx, end)
380 if cs.statsHandler != nil {
401 cs.statsHandler.HandleRPC(cs.statsCtx, inPayload)
526 statsHandler stats.Handler member
570 if ss.statsHandler != nil {
[all …]
/dports/databases/tile38/tile38-1.12.0/vendor/google.golang.org/grpc/
H A Dstream.go252 statsHandler: cc.dopts.copts.StatsHandler,
311 statsHandler stats.Handler member
365 if cs.statsHandler != nil {
388 cs.statsHandler.HandleRPC(cs.statsCtx, outPayload)
395 if cs.statsHandler != nil {
419 cs.statsHandler.HandleRPC(cs.statsCtx, inPayload)
507 if cs.statsHandler != nil {
516 cs.statsHandler.HandleRPC(cs.statsCtx, end)
565 statsHandler stats.Handler member
613 if ss.statsHandler != nil {
[all …]
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/golang/gddo/vendor/google.golang.org/grpc/
H A Dstream.go253 statsHandler: cc.dopts.copts.StatsHandler,
308 statsHandler stats.Handler member
362 if cs.statsHandler != nil {
380 cs.statsHandler.HandleRPC(cs.statsCtx, outPayload)
387 if cs.statsHandler != nil {
411 cs.statsHandler.HandleRPC(cs.statsCtx, inPayload)
499 if cs.statsHandler != nil {
508 cs.statsHandler.HandleRPC(cs.statsCtx, end)
556 statsHandler stats.Handler member
604 if ss.statsHandler != nil {
[all …]
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/docker/docker/vendor/google.golang.org/grpc/
H A Dstream.go298 statsHandler: sh,
364 statsHandler stats.Handler member
470 if a.statsHandler != nil {
489 a.statsHandler.HandleRPC(a.ctx, outPayload)
508 if a.statsHandler != nil {
547 a.statsHandler.HandleRPC(a.ctx, inPayload)
592 if a.statsHandler != nil {
599 a.statsHandler.HandleRPC(a.ctx, end)
650 statsHandler stats.Handler member
700 if ss.statsHandler != nil {
[all …]
/dports/sysutils/docker/docker-ce-18.09.5/components/cli/vendor/google.golang.org/grpc/
H A Dstream.go298 statsHandler: sh,
364 statsHandler stats.Handler member
470 if a.statsHandler != nil {
489 a.statsHandler.HandleRPC(a.ctx, outPayload)
508 if a.statsHandler != nil {
547 a.statsHandler.HandleRPC(a.ctx, inPayload)
592 if a.statsHandler != nil {
599 a.statsHandler.HandleRPC(a.ctx, end)
650 statsHandler stats.Handler member
700 if ss.statsHandler != nil {
[all …]
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/docker/vendor/google.golang.org/grpc/
H A Dstream.go298 statsHandler: sh,
364 statsHandler stats.Handler member
470 if a.statsHandler != nil {
489 a.statsHandler.HandleRPC(a.ctx, outPayload)
508 if a.statsHandler != nil {
547 a.statsHandler.HandleRPC(a.ctx, inPayload)
592 if a.statsHandler != nil {
599 a.statsHandler.HandleRPC(a.ctx, end)
650 statsHandler stats.Handler member
700 if ss.statsHandler != nil {
[all …]

12345678910>>...22