| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/go-kit/kit/transport/amqp/ |
| H A D | request_response_func.go | 13 type RequestFunc func(context.Context, *amqp.Publishing) context.Context type
31 func SetPublishExchange(publishExchange string) RequestFunc {
39 func SetPublishKey(publishKey string) RequestFunc {
47 func SetPublishDeliveryMode(dmode uint8) RequestFunc {
59 func SetNackSleepDuration(duration time.Duration) RequestFunc {
70 func SetConsumeAutoAck(autoAck bool) RequestFunc {
79 func SetConsumeArgs(args amqp.Table) RequestFunc {
87 func SetContentType(contentType string) RequestFunc {
96 func SetContentEncoding(contentEncoding string) RequestFunc {
105 func SetCorrelationID(cid string) RequestFunc {
|
| /dports/net-mgmt/bind_exporter/bind_exporter-0.4.0/vendor/github.com/go-kit/kit/transport/amqp/ |
| H A D | request_response_func.go | 13 type RequestFunc func(context.Context, *amqp.Publishing, *amqp.Delivery) context.Context type
31 func SetPublishExchange(publishExchange string) RequestFunc {
39 func SetPublishKey(publishKey string) RequestFunc {
47 func SetPublishDeliveryMode(dmode uint8) RequestFunc {
59 func SetNackSleepDuration(duration time.Duration) RequestFunc {
70 func SetConsumeAutoAck(autoAck bool) RequestFunc {
79 func SetConsumeArgs(args amqp.Table) RequestFunc {
87 func SetContentType(contentType string) RequestFunc {
96 func SetContentEncoding(contentEncoding string) RequestFunc {
105 func SetCorrelationID(cid string) RequestFunc {
|
| /dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/github.com/go-kit/kit/transport/amqp/ |
| H A D | request_response_func.go | 13 type RequestFunc func(context.Context, *amqp.Publishing, *amqp.Delivery) context.Context type
31 func SetPublishExchange(publishExchange string) RequestFunc {
39 func SetPublishKey(publishKey string) RequestFunc {
47 func SetPublishDeliveryMode(dmode uint8) RequestFunc {
59 func SetNackSleepDuration(duration time.Duration) RequestFunc {
70 func SetConsumeAutoAck(autoAck bool) RequestFunc {
79 func SetConsumeArgs(args amqp.Table) RequestFunc {
87 func SetContentType(contentType string) RequestFunc {
96 func SetContentEncoding(contentEncoding string) RequestFunc {
105 func SetCorrelationID(cid string) RequestFunc {
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/go-kit/kit/transport/amqp/ |
| H A D | request_response_func.go | 13 type RequestFunc func(context.Context, *amqp.Publishing, *amqp.Delivery) context.Context type
31 func SetPublishExchange(publishExchange string) RequestFunc {
39 func SetPublishKey(publishKey string) RequestFunc {
47 func SetPublishDeliveryMode(dmode uint8) RequestFunc {
59 func SetNackSleepDuration(duration time.Duration) RequestFunc {
70 func SetConsumeAutoAck(autoAck bool) RequestFunc {
79 func SetConsumeArgs(args amqp.Table) RequestFunc {
87 func SetContentType(contentType string) RequestFunc {
96 func SetContentEncoding(contentEncoding string) RequestFunc {
105 func SetCorrelationID(cid string) RequestFunc {
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/go-kit/kit/transport/amqp/ |
| H A D | request_response_func.go | 13 type RequestFunc func(context.Context, *amqp.Publishing, *amqp.Delivery) context.Context type
31 func SetPublishExchange(publishExchange string) RequestFunc {
39 func SetPublishKey(publishKey string) RequestFunc {
47 func SetPublishDeliveryMode(dmode uint8) RequestFunc {
59 func SetNackSleepDuration(duration time.Duration) RequestFunc {
70 func SetConsumeAutoAck(autoAck bool) RequestFunc {
79 func SetConsumeArgs(args amqp.Table) RequestFunc {
87 func SetContentType(contentType string) RequestFunc {
96 func SetContentEncoding(contentEncoding string) RequestFunc {
105 func SetCorrelationID(cid string) RequestFunc {
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/go-kit/kit/transport/amqp/ |
| H A D | request_response_func.go | 13 type RequestFunc func(context.Context, *amqp.Publishing, *amqp.Delivery) context.Context type
31 func SetPublishExchange(publishExchange string) RequestFunc {
39 func SetPublishKey(publishKey string) RequestFunc {
47 func SetPublishDeliveryMode(dmode uint8) RequestFunc {
59 func SetNackSleepDuration(duration time.Duration) RequestFunc {
70 func SetConsumeAutoAck(autoAck bool) RequestFunc {
79 func SetConsumeArgs(args amqp.Table) RequestFunc {
87 func SetContentType(contentType string) RequestFunc {
96 func SetContentEncoding(contentEncoding string) RequestFunc {
105 func SetCorrelationID(cid string) RequestFunc {
|
| /dports/sysutils/snmp_exporter/snmp_exporter-0.20.0/vendor/github.com/go-kit/kit/transport/amqp/ |
| H A D | request_response_func.go | 13 type RequestFunc func(context.Context, *amqp.Publishing, *amqp.Delivery) context.Context type
31 func SetPublishExchange(publishExchange string) RequestFunc {
39 func SetPublishKey(publishKey string) RequestFunc {
47 func SetPublishDeliveryMode(dmode uint8) RequestFunc {
59 func SetNackSleepDuration(duration time.Duration) RequestFunc {
70 func SetConsumeAutoAck(autoAck bool) RequestFunc {
79 func SetConsumeArgs(args amqp.Table) RequestFunc {
87 func SetContentType(contentType string) RequestFunc {
96 func SetContentEncoding(contentEncoding string) RequestFunc {
105 func SetCorrelationID(cid string) RequestFunc {
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/go-kit/kit/transport/amqp/ |
| H A D | request_response_func.go | 13 type RequestFunc func(context.Context, *amqp.Publishing, *amqp.Delivery) context.Context type
31 func SetPublishExchange(publishExchange string) RequestFunc {
39 func SetPublishKey(publishKey string) RequestFunc {
47 func SetPublishDeliveryMode(dmode uint8) RequestFunc {
59 func SetNackSleepDuration(duration time.Duration) RequestFunc {
70 func SetConsumeAutoAck(autoAck bool) RequestFunc {
79 func SetConsumeArgs(args amqp.Table) RequestFunc {
87 func SetContentType(contentType string) RequestFunc {
96 func SetContentEncoding(contentEncoding string) RequestFunc {
105 func SetCorrelationID(cid string) RequestFunc {
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/executor/ |
| H A D | test_network_connection_hook.h | 46 template <typename ValidateFunc, typename RequestFunc, typename ReplyFunc>
50 RequestFunc&& requestFunc, in TestConnectionHook()
53 _requestFunc(std::forward<RequestFunc>(requestFunc)), in TestConnectionHook()
71 RequestFunc _requestFunc;
|
| /dports/www/grafana8/grafana-8.3.6/vendor/go.opentelemetry.io/otel/exporters/otlp/otlptrace/internal/retry/ |
| H A D | retry_test.go | 73 }.RequestFunc(ev)
98 }.RequestFunc(ev)
129 }.RequestFunc(ev)
159 }.RequestFunc(ev)
175 }.RequestFunc(ev)
189 reqFunc := Config{}.RequestFunc(ev)
|
| H A D | retry.go | 53 type RequestFunc func(context.Context, func(context.Context) error) error type
59 func (c Config) RequestFunc(evaluate EvaluateFunc) RequestFunc { func
|
| /dports/net-mgmt/bind_exporter/bind_exporter-0.4.0/vendor/github.com/go-kit/kit/transport/httprp/ |
| H A D | server.go | 13 type RequestFunc func(context.Context, *http.Request) context.Context type
18 before []RequestFunc
44 func ServerBefore(before ...RequestFunc) ServerOption { argument
|
| /dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/github.com/go-kit/kit/transport/httprp/ |
| H A D | server.go | 13 type RequestFunc func(context.Context, *http.Request) context.Context type
18 before []RequestFunc
44 func ServerBefore(before ...RequestFunc) ServerOption { argument
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/go-kit/kit/transport/httprp/ |
| H A D | server.go | 13 type RequestFunc func(context.Context, *http.Request) context.Context type
18 before []RequestFunc
44 func ServerBefore(before ...RequestFunc) ServerOption { argument
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/go-kit/kit/transport/httprp/ |
| H A D | server.go | 13 type RequestFunc func(context.Context, *http.Request) context.Context type
18 before []RequestFunc
44 func ServerBefore(before ...RequestFunc) ServerOption { argument
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/go-kit/kit/transport/httprp/ |
| H A D | server.go | 13 type RequestFunc func(context.Context, *http.Request) context.Context type
18 before []RequestFunc
44 func ServerBefore(before ...RequestFunc) ServerOption { argument
|
| /dports/sysutils/snmp_exporter/snmp_exporter-0.20.0/vendor/github.com/go-kit/kit/transport/httprp/ |
| H A D | server.go | 13 type RequestFunc func(context.Context, *http.Request) context.Context type
18 before []RequestFunc
44 func ServerBefore(before ...RequestFunc) ServerOption { argument
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/go-kit/kit/transport/httprp/ |
| H A D | server.go | 13 type RequestFunc func(context.Context, *http.Request) context.Context type
18 before []RequestFunc
44 func ServerBefore(before ...RequestFunc) ServerOption { argument
|
| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/go-kit/kit/transport/httprp/ |
| H A D | server.go | 13 type RequestFunc func(context.Context, *http.Request) context.Context type
18 before []RequestFunc
44 func ServerBefore(before ...RequestFunc) ServerOption { argument
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/status-im/keycard-go/vendor/github.com/ethereum/go-ethereum/swarm/network/ |
| H A D | fetcher.go | 35 type RequestFunc func(context.Context, *Request) (*discover.NodeID, chan struct{}, error) type
44 …protoRequestFunc RequestFunc // request function fetcher calls to issue retrieve request…
88 request RequestFunc
93 func NewFetcherFactory(request RequestFunc, skipCheck bool) *FetcherFactory { argument
111 func NewFetcher(addr storage.Address, rf RequestFunc, skipCheck bool) *Fetcher { argument
|
| /dports/sysutils/helm/helm-3.5.2/vendor/k8s.io/apiserver/pkg/endpoints/filters/ |
| H A D | authentication_test.go | 80 authenticator.RequestFunc(func(req *http.Request) (*authenticator.Response, bool, error) {
121 authenticator.RequestFunc(func(req *http.Request) (*authenticator.Response, bool, error) {
144 authenticator.RequestFunc(func(req *http.Request) (*authenticator.Response, bool, error) {
164 authenticator.RequestFunc(func(req *http.Request) (*authenticator.Response, bool, error) {
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/apiserver/pkg/endpoints/filters/ |
| H A D | authentication_test.go | 82 authenticator.RequestFunc(func(req *http.Request) (*authenticator.Response, bool, error) {
158 authenticator.RequestFunc(func(req *http.Request) (*authenticator.Response, bool, error) {
207 authenticator.RequestFunc(func(req *http.Request) (*authenticator.Response, bool, error) {
230 authenticator.RequestFunc(func(req *http.Request) (*authenticator.Response, bool, error) {
250 authenticator.RequestFunc(func(req *http.Request) (*authenticator.Response, bool, error) {
|
| /dports/sysutils/helm/helm-3.5.2/vendor/k8s.io/apiserver/pkg/authentication/authenticator/ |
| H A D | interfaces.go | 47 type RequestFunc func(req *http.Request) (*Response, bool, error) type
50 func (f RequestFunc) AuthenticateRequest(req *http.Request) (*Response, bool, error) {
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/apiserver/pkg/authentication/authenticator/ |
| H A D | interfaces.go | 47 type RequestFunc func(req *http.Request) (*Response, bool, error) type
50 func (f RequestFunc) AuthenticateRequest(req *http.Request) (*Response, bool, error) {
|
| /dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/google/martian/v3/priority/ |
| H A D | priority_group_test.go | 37 tm50.RequestFunc(func(*http.Request) {
43 tm100a.RequestFunc(func(*http.Request) {
49 tm100b.RequestFunc(func(*http.Request) {
55 tm75.RequestFunc(func(*http.Request) {
|