| /dports/net/nsq/nsq-1.2.1/nsqd/ |
| H A D | http.go | 34 type httpServer struct { struct
35 nsqd *NSQD
36 tlsEnabled bool
37 tlsRequired bool
38 router http.Handler
102 func (s *httpServer) ServeHTTP(w http.ResponseWriter, req *http.Request) {
123 …rver) doInfo(w http.ResponseWriter, req *http.Request, ps httprouter.Params) (interface{}, error) {
145 …Server) getExistingTopicFromQuery(req *http.Request) (*http_api.ReqParams, *Topic, string, error) {
165 func (s *httpServer) getTopicFromQuery(req *http.Request) (url.Values, *Topic, error) {
185 …erver) doPUB(w http.ResponseWriter, req *http.Request, ps httprouter.Params) (interface{}, error) {
[all …]
|
| /dports/net/nsq/nsq-1.2.1/nsqadmin/ |
| H A D | http.go | 50 type httpServer struct { struct
51 nsqadmin *NSQAdmin
52 router http.Handler
53 client *http_api.Client
54 ci *clusterinfo.ClusterInfo
55 basePath string
120 func (s *httpServer) ServeHTTP(w http.ResponseWriter, req *http.Request) {
124 … pingHandler(w http.ResponseWriter, req *http.Request, ps httprouter.Params) (interface{}, error) {
128 …indexHandler(w http.ResponseWriter, req *http.Request, ps httprouter.Params) (interface{}, error) {
728 …er) doConfig(w http.ResponseWriter, req *http.Request, ps httprouter.Params) (interface{}, error) {
[all …]
|
| /dports/net/nsq/nsq-1.2.1/nsqlookupd/ |
| H A D | http.go | 15 type httpServer struct { struct
16 nsqlookupd *NSQLookupd
17 router http.Handler
64 func (s *httpServer) ServeHTTP(w http.ResponseWriter, req *http.Request) {
68 … pingHandler(w http.ResponseWriter, req *http.Request, ps httprouter.Params) (interface{}, error) {
72 …rver) doInfo(w http.ResponseWriter, req *http.Request, ps httprouter.Params) (interface{}, error) {
80 …er) doTopics(w http.ResponseWriter, req *http.Request, ps httprouter.Params) (interface{}, error) {
87 …) doChannels(w http.ResponseWriter, req *http.Request, ps httprouter.Params) (interface{}, error) {
104 …er) doLookup(w http.ResponseWriter, req *http.Request, ps httprouter.Params) (interface{}, error) {
263 …ver) doNodes(w http.ResponseWriter, req *http.Request, ps httprouter.Params) (interface{}, error) {
[all …]
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/uber/jaeger-client-go/transport/zipkin/ |
| H A D | http_test.go | 171 type httpServer struct { struct
172 t *testing.T
173 zipkinSpans []*zipkincore.Span
174 authCredentials []*HTTPBasicAuthCredentials
175 mutex sync.RWMutex
176 httpServer *httptest.Server member
179 func (s *httpServer) SpanURL() string {
183 func (s *httpServer) Close() {
187 func (s *httpServer) spans() []*zipkincore.Span {
193 func (s *httpServer) credentials() []*HTTPBasicAuthCredentials {
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/uber/jaeger-client-go/transport/zipkin/ |
| H A D | http_test.go | 172 type httpServer struct { struct
173 t *testing.T
174 zipkinSpans []*zipkincore.Span
175 authCredentials []*HTTPBasicAuthCredentials
176 mutex sync.RWMutex
177 httpServer *httptest.Server member
180 func (s *httpServer) SpanURL() string {
184 func (s *httpServer) Close() {
188 func (s *httpServer) spans() []*zipkincore.Span {
194 func (s *httpServer) credentials() []*HTTPBasicAuthCredentials {
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/uber/jaeger-client-go/transport/zipkin/ |
| H A D | http_test.go | 171 type httpServer struct { struct
172 t *testing.T
173 zipkinSpans []*zipkincore.Span
174 authCredentials []*HTTPBasicAuthCredentials
175 mutex sync.RWMutex
176 httpServer *httptest.Server member
179 func (s *httpServer) SpanURL() string {
183 func (s *httpServer) Close() {
187 func (s *httpServer) spans() []*zipkincore.Span {
193 func (s *httpServer) credentials() []*HTTPBasicAuthCredentials {
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/uber/jaeger-client-go/transport/zipkin/ |
| H A D | http_test.go | 171 type httpServer struct { struct
172 t *testing.T
173 zipkinSpans []*zipkincore.Span
174 authCredentials []*HTTPBasicAuthCredentials
175 mutex sync.RWMutex
176 httpServer *httptest.Server member
179 func (s *httpServer) SpanURL() string {
183 func (s *httpServer) Close() {
187 func (s *httpServer) spans() []*zipkincore.Span {
193 func (s *httpServer) credentials() []*HTTPBasicAuthCredentials {
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/uber/jaeger-client-go/transport/zipkin/ |
| H A D | http_test.go | 172 type httpServer struct { struct
173 t *testing.T
174 zipkinSpans []*zipkincore.Span
175 authCredentials []*HTTPBasicAuthCredentials
176 mutex sync.RWMutex
177 httpServer *httptest.Server argument
180 func (s *httpServer) SpanURL() string {
184 func (s *httpServer) Close() {
188 func (s *httpServer) spans() []*zipkincore.Span {
194 func (s *httpServer) credentials() []*HTTPBasicAuthCredentials {
|
| /dports/www/pomerium/pomerium-0.8.3/vendor/github.com/uber/jaeger-client-go/transport/zipkin/ |
| H A D | http_test.go | 171 type httpServer struct { struct
172 t *testing.T
173 zipkinSpans []*zipkincore.Span
174 authCredentials []*HTTPBasicAuthCredentials
175 mutex sync.RWMutex
176 httpServer *httptest.Server argument
179 func (s *httpServer) SpanURL() string {
183 func (s *httpServer) Close() {
187 func (s *httpServer) spans() []*zipkincore.Span {
193 func (s *httpServer) credentials() []*HTTPBasicAuthCredentials {
|
| /dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/github.com/uber/jaeger-client-go/transport/zipkin/ |
| H A D | http_test.go | 171 type httpServer struct { struct
172 t *testing.T
173 zipkinSpans []*zipkincore.Span
174 authCredentials []*HTTPBasicAuthCredentials
175 mutex sync.RWMutex
176 httpServer *httptest.Server member
179 func (s *httpServer) SpanURL() string {
183 func (s *httpServer) Close() {
187 func (s *httpServer) spans() []*zipkincore.Span {
193 func (s *httpServer) credentials() []*HTTPBasicAuthCredentials {
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/uber/jaeger-client-go/transport/zipkin/ |
| H A D | http_test.go | 172 type httpServer struct { struct
173 t *testing.T
174 zipkinSpans []*zipkincore.Span
175 authCredentials []*HTTPBasicAuthCredentials
176 mutex sync.RWMutex
177 httpServer *httptest.Server member
180 func (s *httpServer) SpanURL() string {
184 func (s *httpServer) Close() {
188 func (s *httpServer) spans() []*zipkincore.Span {
194 func (s *httpServer) credentials() []*HTTPBasicAuthCredentials {
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/uber/jaeger-client-go/transport/zipkin/ |
| H A D | http_test.go | 171 type httpServer struct { struct
172 t *testing.T
173 zipkinSpans []*zipkincore.Span
174 authCredentials []*HTTPBasicAuthCredentials
175 mutex sync.RWMutex
176 httpServer *httptest.Server member
179 func (s *httpServer) SpanURL() string {
183 func (s *httpServer) Close() {
187 func (s *httpServer) spans() []*zipkincore.Span {
193 func (s *httpServer) credentials() []*HTTPBasicAuthCredentials {
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/uber/jaeger-client-go/transport/ |
| H A D | http_test.go | 102 type httpServer struct { struct
103 t *testing.T
104 batches []*j.Batch
105 authCredentials []*HTTPBasicAuthCredentials
106 mutex sync.RWMutex
107 header http.Header
110 func (s *httpServer) getBatches() []*j.Batch {
116 func (s *httpServer) credentials() []*HTTPBasicAuthCredentials {
122 func (s *httpServer) getHeader() http.Header {
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/uber/jaeger-client-go/transport/ |
| H A D | http_test.go | 103 type httpServer struct { struct
104 t *testing.T
105 batches []*j.Batch
106 authCredentials []*HTTPBasicAuthCredentials
107 mutex sync.RWMutex
108 header http.Header
111 func (s *httpServer) getBatches() []*j.Batch {
117 func (s *httpServer) credentials() []*HTTPBasicAuthCredentials {
123 func (s *httpServer) getHeader() http.Header {
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/uber/jaeger-client-go/transport/ |
| H A D | http_test.go | 102 type httpServer struct { struct
103 t *testing.T
104 batches []*j.Batch
105 authCredentials []*HTTPBasicAuthCredentials
106 mutex sync.RWMutex
107 header http.Header
110 func (s *httpServer) getBatches() []*j.Batch {
116 func (s *httpServer) credentials() []*HTTPBasicAuthCredentials {
122 func (s *httpServer) getHeader() http.Header {
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/uber/jaeger-client-go/transport/ |
| H A D | http_test.go | 103 type httpServer struct { struct
104 t *testing.T
105 batches []*j.Batch
106 authCredentials []*HTTPBasicAuthCredentials
107 mutex sync.RWMutex
108 header http.Header
111 func (s *httpServer) getBatches() []*j.Batch {
117 func (s *httpServer) credentials() []*HTTPBasicAuthCredentials {
123 func (s *httpServer) getHeader() http.Header {
|
| /dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/github.com/uber/jaeger-client-go/transport/ |
| H A D | http_test.go | 102 type httpServer struct { struct
103 t *testing.T
104 batches []*j.Batch
105 authCredentials []*HTTPBasicAuthCredentials
106 mutex sync.RWMutex
107 header http.Header
110 func (s *httpServer) getBatches() []*j.Batch {
116 func (s *httpServer) credentials() []*HTTPBasicAuthCredentials {
122 func (s *httpServer) getHeader() http.Header {
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/uber/jaeger-client-go/transport/ |
| H A D | http_test.go | 103 type httpServer struct { struct
104 t *testing.T
105 batches []*j.Batch
106 authCredentials []*HTTPBasicAuthCredentials
107 mutex sync.RWMutex
108 header http.Header
111 func (s *httpServer) getBatches() []*j.Batch {
117 func (s *httpServer) credentials() []*HTTPBasicAuthCredentials {
123 func (s *httpServer) getHeader() http.Header {
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/node/ |
| H A D | rpcstack.go | 57 type httpServer struct { struct
58 log log.Logger
59 timeouts rpc.HTTPTimeouts
62 mu sync.Mutex
63 server *http.Server
68 httpConfig httpConfig
72 wsConfig wsConfig
76 endpoint string
77 host string
78 port int
[all …]
|
| /dports/net/concourse-fly/concourse-6.7.1/vendor/github.com/tedsuo/ifrit/http_server/ |
| H A D | http_server.go | 19 type httpServer struct { struct
20 protocol string
21 address string
22 handler http.Handler
24 connectionWaitGroup *sync.WaitGroup
25 inactiveConnections map[net.Conn]struct{}
26 inactiveConnectionsMu *sync.Mutex
27 stoppingChan chan struct{}
29 tlsConfig *tls.Config
147 func (s *httpServer) addInactiveConnection(conn net.Conn) {
[all …]
|
| /dports/misc/concourse/concourse-6.7.2/vendor/github.com/tedsuo/ifrit/http_server/ |
| H A D | http_server.go | 19 type httpServer struct { struct
20 protocol string
21 address string
22 handler http.Handler
24 connectionWaitGroup *sync.WaitGroup
25 inactiveConnections map[net.Conn]struct{}
26 inactiveConnectionsMu *sync.Mutex
27 stoppingChan chan struct{}
29 tlsConfig *tls.Config
147 func (s *httpServer) addInactiveConnection(conn net.Conn) {
[all …]
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/uber/jaeger-client-go/transport/ |
| H A D | http_test.go | 97 type httpServer struct { struct
98 t *testing.T
99 batches []*j.Batch
100 authCredentials []*HTTPBasicAuthCredentials
101 mutex sync.RWMutex
104 func (s *httpServer) getBatches() []*j.Batch {
110 func (s *httpServer) credentials() []*HTTPBasicAuthCredentials {
|
| /dports/www/pomerium/pomerium-0.8.3/vendor/github.com/uber/jaeger-client-go/transport/ |
| H A D | http_test.go | 97 type httpServer struct { struct
98 t *testing.T
99 batches []*j.Batch
100 authCredentials []*HTTPBasicAuthCredentials
101 mutex sync.RWMutex
104 func (s *httpServer) getBatches() []*j.Batch {
110 func (s *httpServer) credentials() []*HTTPBasicAuthCredentials {
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/uber/jaeger-client-go/transport/ |
| H A D | http_test.go | 97 type httpServer struct { struct
98 t *testing.T
99 batches []*j.Batch
100 authCredentials []*HTTPBasicAuthCredentials
101 mutex sync.RWMutex
104 func (s *httpServer) getBatches() []*j.Batch {
110 func (s *httpServer) credentials() []*HTTPBasicAuthCredentials {
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/openzipkin/zipkin-go-opentracing/zipkin-go-opentracing-0.3.4/ |
| H A D | collector-http_test.go | 260 type httpServer struct { struct
261 t *testing.T
262 zipkinSpans []*zipkincore.Span
263 zipkinHeader http.Header
264 mutex sync.RWMutex
267 func (s *httpServer) spans() []*zipkincore.Span {
273 func (s *httpServer) clearSpans() {
279 func (s *httpServer) headers() http.Header {
285 func (s *httpServer) clearHeaders() {
|