| /dports/security/xray-core/Xray-core-1.5.0/transport/internet/udp/ |
| H A D | dispatcher.go | 36 func NewDispatcher(dispatcher routing.Dispatcher, callback ResponseCallback) *Dispatcher { func
136 d := NewDispatcher(dispatcher, c.callback)
|
| H A D | dispatcher_test.go | 68 dispatcher := NewDispatcher(td, func(ctx context.Context, packet *udp.Packet) {
|
| /dports/net/v2ray/v2ray-core-4.36.2/transport/internet/udp/ |
| H A D | dispatcher.go | 35 func NewDispatcher(dispatcher routing.Dispatcher, callback ResponseCallback) *Dispatcher { func
135 d := NewDispatcher(dispatcher, c.callback)
|
| H A D | dispatcher_test.go | 68 dispatcher := NewDispatcher(td, func(ctx context.Context, packet *udp.Packet) {
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/prometheus/alertmanager/dispatch/ |
| H A D | dispatch_test.go | 377 …dispatcher := NewDispatcher(alerts, route, recorder, marker, timeout, nil, logger, NewDispatcherMe…
517 dispatcher := NewDispatcher(alerts, route, recorder, marker, timeout, lim, logger, m)
635 …dispatcher := NewDispatcher(alerts, nil, nil, marker, timeout, nil, logger, NewDispatcherMetrics(f…
663 …dispatcher := NewDispatcher(alerts, route, recorder, marker, timeout, nil, logger, NewDispatcherMe…
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/prometheus/alertmanager/dispatch/ |
| H A D | dispatch_test.go | 377 …dispatcher := NewDispatcher(alerts, route, recorder, marker, timeout, nil, logger, NewDispatcherMe…
517 dispatcher := NewDispatcher(alerts, route, recorder, marker, timeout, lim, logger, m)
635 …dispatcher := NewDispatcher(alerts, nil, nil, marker, timeout, nil, logger, NewDispatcherMetrics(f…
663 …dispatcher := NewDispatcher(alerts, route, recorder, marker, timeout, nil, logger, NewDispatcherMe…
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/google/cel-go/interpreter/ |
| H A D | dispatcher.go | 36 func NewDispatcher() Dispatcher { func
|
| H A D | interpreter.go | 104 dispatcher := NewDispatcher()
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/cmd/vic-machine/update/ |
| H A D | firewall.go | 145 executor := management.NewDispatcher(op, validator.Session(), management.ActionUpdate, false)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/cmd/vic-machine/delete/ |
| H A D | delete.go | 125 executor := management.NewDispatcher(op, validator.Session(), management.ActionDelete, d.Force)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/cmd/vic-machine/debug/ |
| H A D | debug.go | 150 executor := management.NewDispatcher(op, validator.Session(), management.ActionDebug, d.Force)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/cmd/vic-machine/list/ |
| H A D | list.go | 178 executor := management.NewDispatcher(op, validator.Session(), management.ActionList, false)
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/google/cel-go/cel/ |
| H A D | program.go | 117 disp := interpreter.NewDispatcher()
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/cmd/vic-machine/upgrade/ |
| H A D | upgrade.go | 147 executor := management.NewDispatcher(op, validator.Session(), action, u.Force)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/lib/apiservers/service/restapi/handlers/client/ |
| H A D | client.go | 93 executor := management.NewDispatcher(op, session, action, false)
|
| /dports/net/v2ray/v2ray-core-4.36.2/proxy/shadowsocks/ |
| H A D | server.go | 75 udpServer := udp.NewDispatcher(dispatcher, func(ctx context.Context, packet *udp_proto.Packet) {
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/cmd/vic-machine/inspect/ |
| H A D | inspect.go | 163 executor := management.NewDispatcher(op, validator.Session(), management.ActionInspect, i.Force)
|
| /dports/security/xray-core/Xray-core-1.5.0/proxy/shadowsocks/ |
| H A D | server.go | 86 udpServer := udp.NewDispatcher(dispatcher, func(ctx context.Context, packet *udp_proto.Packet) {
|
| /dports/net/v2ray/v2ray-core-4.36.2/app/dns/ |
| H A D | nameserver_udp.go | 57 s.udpServer = udp.NewDispatcher(dispatcher, s.HandleResponse)
|
| /dports/net/v2ray/v2ray-core-4.36.2/proxy/socks/ |
| H A D | server.go | 191 udpServer := udp.NewDispatcher(dispatcher, func(ctx context.Context, packet *udp_proto.Packet) {
|
| /dports/security/xray-core/Xray-core-1.5.0/app/dns/ |
| H A D | nameserver_udp.go | 56 s.udpServer = udp.NewDispatcher(dispatcher, s.HandleResponse)
|
| /dports/security/xray-core/Xray-core-1.5.0/proxy/socks/ |
| H A D | server.go | 196 udpServer := udp.NewDispatcher(dispatcher, func(ctx context.Context, packet *udp_proto.Packet) {
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/lib/install/management/ |
| H A D | dispatcher.go | 124 func NewDispatcher(ctx context.Context, s *session.Session, action Action, force bool) *Dispatcher { func
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/prometheus/alertmanager/dispatch/ |
| H A D | dispatch.go | 82 func NewDispatcher( func
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/prometheus/alertmanager/dispatch/ |
| H A D | dispatch.go | 106 func NewDispatcher( func
|