/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) {
|