Home
last modified time | relevance | path

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

/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/vendor/github.com/weaveworks/common/server/
H A Dserver.go156 grpcListener net.Listener member
193grpcListener, err := net.Listen(network, fmt.Sprintf("%s:%d", cfg.GRPCListenAddress, cfg.GRPCListe…
197 grpcListener = middleware.CountingListener(grpcListener, tcpConnections.WithLabelValues("grpc"))
200 grpcListener = netutil.LimitListener(grpcListener, cfg.GRPCConnLimit)
260 …log.WithField("http", httpListener.Addr()).WithField("grpc", grpcListener.Addr()).Infof("server li…
381 grpcListener: grpcListener,
434 err := s.GRPC.Serve(s.grpcListener)
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/weaveworks/common/server/
H A Dserver.go156 grpcListener net.Listener member
193grpcListener, err := net.Listen(network, fmt.Sprintf("%s:%d", cfg.GRPCListenAddress, cfg.GRPCListe…
197 grpcListener = middleware.CountingListener(grpcListener, tcpConnections.WithLabelValues("grpc"))
200 grpcListener = netutil.LimitListener(grpcListener, cfg.GRPCConnLimit)
260 …log.WithField("http", httpListener.Addr()).WithField("grpc", grpcListener.Addr()).Infof("server li…
381 grpcListener: grpcListener,
434 err := s.GRPC.Serve(s.grpcListener)
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/weaveworks/common/server/
H A Dserver.go156 grpcListener net.Listener member
193grpcListener, err := net.Listen(network, fmt.Sprintf("%s:%d", cfg.GRPCListenAddress, cfg.GRPCListe…
197 grpcListener = middleware.CountingListener(grpcListener, tcpConnections.WithLabelValues("grpc"))
200 grpcListener = netutil.LimitListener(grpcListener, cfg.GRPCConnLimit)
260 …log.WithField("http", httpListener.Addr()).WithField("grpc", grpcListener.Addr()).Infof("server li…
381 grpcListener: grpcListener,
434 err := s.GRPC.Serve(s.grpcListener)
H A Dserver_test.go106 require.NoError(t, srv.grpcListener.Close())
477 require.NoError(t, srv.grpcListener.Close())
/dports/net-mgmt/bind_exporter/bind_exporter-0.4.0/vendor/github.com/go-kit/kit/examples/addsvc/cmd/addsvc/
H A Daddsvc.go202 grpcListener, err := net.Listen("tcp", *grpcAddr)
213 return baseServer.Serve(grpcListener)
215 grpcListener.Close()
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/go-kit/kit/examples/addsvc/cmd/addsvc/
H A Daddsvc.go202 grpcListener, err := net.Listen("tcp", *grpcAddr)
213 return baseServer.Serve(grpcListener)
215 grpcListener.Close()
/dports/sysutils/snmp_exporter/snmp_exporter-0.20.0/vendor/github.com/go-kit/kit/examples/addsvc/cmd/addsvc/
H A Daddsvc.go202 grpcListener, err := net.Listen("tcp", *grpcAddr)
213 return baseServer.Serve(grpcListener)
215 grpcListener.Close()
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/go-kit/kit/examples/addsvc/cmd/addsvc/
H A Daddsvc.go202 grpcListener, err := net.Listen("tcp", *grpcAddr)
213 return baseServer.Serve(grpcListener)
215 grpcListener.Close()
/dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/github.com/go-kit/kit/examples/addsvc/cmd/addsvc/
H A Daddsvc.go218 grpcListener, err := net.Listen("tcp", *grpcAddr)
229 return baseServer.Serve(grpcListener)
231 grpcListener.Close()
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/go-kit/kit/examples/addsvc/cmd/addsvc/
H A Daddsvc.go218 grpcListener, err := net.Listen("tcp", *grpcAddr)
229 return baseServer.Serve(grpcListener)
231 grpcListener.Close()
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/go-kit/kit/examples/addsvc/cmd/addsvc/
H A Daddsvc.go218 grpcListener, err := net.Listen("tcp", *grpcAddr)
229 return baseServer.Serve(grpcListener)
231 grpcListener.Close()
/dports/devel/etcd/etcd-2.3.8/integration/
H A Dcluster.go404 grpcListener net.Listener member
485 m.grpcListener = l
586 if m.grpcListener != nil {
588 go m.grpcServer.Serve(m.grpcListener)
660 if m.grpcListener != nil {
/dports/security/certmgr/certmgr-3.0.3/vendor/github.com/google/certificate-transparency-go/certificate-transparency-go-1.0.21/vendor/github.com/coreos/etcd/integration/
H A Dcluster.go493 grpcListener net.Listener member
625 m.grpcListener = l
714 if m.grpcListener != nil {
729 go m.grpcServer.Serve(m.grpcListener)
735 if m.grpcListener != nil {
933 if m.grpcListener != nil {
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/coreos/etcd/integration/
H A Dcluster.go493 grpcListener net.Listener member
625 m.grpcListener = l
715 if m.grpcListener != nil {
730 go m.grpcServer.Serve(m.grpcListener)
736 if m.grpcListener != nil {
934 if m.grpcListener != nil {
/dports/devel/etcd33/etcd-3.3.23/integration/
H A Dcluster.go493 grpcListener net.Listener member
625 m.grpcListener = l
715 if m.grpcListener != nil {
730 go m.grpcServer.Serve(m.grpcListener)
736 if m.grpcListener != nil {
934 if m.grpcListener != nil {
/dports/devel/etcd33/etcd-3.3.23/vendor/github.com/coreos/etcd/integration/
H A Dcluster.go493 grpcListener net.Listener member
625 m.grpcListener = l
715 if m.grpcListener != nil {
730 go m.grpcServer.Serve(m.grpcListener)
736 if m.grpcListener != nil {
934 if m.grpcListener != nil {
/dports/devel/etcd31/etcd-3.1.20/integration/
H A Dcluster.go439 grpcListener net.Listener member
528 m.grpcListener = l
638 if m.grpcListener != nil {
649 go m.grpcServer.Serve(m.grpcListener)
739 if m.grpcListener != nil {
/dports/devel/etcd32/etcd-3.2.32/integration/
H A Dcluster.go485 grpcListener net.Listener member
610 m.grpcListener = l
765 if m.grpcListener != nil {
779 go m.grpcServer.Serve(m.grpcListener)
873 if m.grpcListener != nil {
/dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/integration/
H A Dcluster.go540 grpcListener net.Listener member
715 m.grpcListener = l
814 if m.grpcListener != nil {
829 go m.grpcServer.Serve(m.grpcListener)
835 if m.grpcListener != nil {
1103 if m.grpcListener != nil {
/dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/integration/
H A Dcluster.go540 grpcListener net.Listener member
715 m.grpcListener = l
814 if m.grpcListener != nil {
829 go m.grpcServer.Serve(m.grpcListener)
835 if m.grpcListener != nil {
1089 if m.grpcListener != nil {
/dports/devel/etcd34/etcd-3.4.18/integration/
H A Dcluster.go543 grpcListener net.Listener member
721 m.grpcListener = l
820 if m.grpcListener != nil {
835 go m.grpcServer.Serve(m.grpcListener)
841 if m.grpcListener != nil {
1095 if m.grpcListener != nil {
/dports/sysutils/terraform/terraform-1.0.11/vendor/go.etcd.io/etcd/integration/
H A Dcluster.go543 grpcListener net.Listener member
721 m.grpcListener = l
820 if m.grpcListener != nil {
835 go m.grpcServer.Serve(m.grpcListener)
841 if m.grpcListener != nil {
1095 if m.grpcListener != nil {
/dports/www/gitea/gitea-1.16.5/vendor/go.etcd.io/etcd/tests/v3/integration/
H A Dcluster.go555 grpcListener net.Listener member
733 m.grpcListener = l
832 if m.grpcListener != nil {
847 go m.grpcServer.Serve(m.grpcListener)
853 if m.grpcListener != nil {
1121 if m.grpcListener != nil {
/dports/www/minio-client/etcd-3.5.0/tests/integration/
H A Dcluster.go561 grpcListener net.Listener member
748 m.grpcListener = l
848 if m.grpcListener != nil {
863 go m.grpcServer.Serve(m.grpcListener)
869 if m.grpcListener != nil {
1149 if m.grpcListener != nil {
/dports/sysutils/istio/istio-1.6.7/pilot/pkg/bootstrap/
H A Dserver.go493 grpcListener, err := net.Listen("tcp", args.DiscoveryOptions.GrpcAddr)
497 s.GRPCListener = grpcListener