- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for doForward (0.28 sec)
-
pkg/test/echo/server/forwarder/util.go
if nt == "" { nt = network } addr := dnsServer if addr == "" { addr = address } return d.DialContext(ctx, nt, addr) }, } } // doForward sends the requests and collect the responses. func doForward(ctx context.Context, cfg *Config, e *executor, doReq func(context.Context, *Config, int) (string, error)) (*proto.ForwardEchoResponse, error) { // make the timeout apply to the entire set of requests
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Oct 08 09:39:20 UTC 2023 - 4.4K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/xds.go
defer func() { _ = conn.Close() }() getConn = func() (*grpc.ClientConn, func(), error) { return conn, func() {}, nil } } call := grpcCall{ e: c.e, getConn: getConn, } return doForward(ctx, cfg, c.e, call.makeRequest) } func (c *xdsProtocol) Close() error { return nil } func newXDSConnection(cfg *Config) (*grpc.ClientConn, error) { var opts []grpc.DialOption // transport security
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 10 18:09:08 UTC 2022 - 2.7K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Enums.java
implements Serializable { private final Class<T> enumClass; StringConverter(Class<T> enumClass) { this.enumClass = checkNotNull(enumClass); } @Override protected T doForward(String value) { return Enum.valueOf(enumClass, value); } @Override protected String doBackward(T enumValue) { return enumValue.name(); } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 26 11:56:44 UTC 2023 - 5K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/udp.go
e *executor } func newUDPProtocol(e *executor) protocol { return &udpProtocol{e: e} } func (c *udpProtocol) ForwardEcho(ctx context.Context, cfg *Config) (*proto.ForwardEchoResponse, error) { return doForward(ctx, cfg, c.e, c.makeRequest) } func (c *udpProtocol) makeRequest(ctx context.Context, cfg *Config, requestID int) (string, error) { conn, err := newUDPConnection(cfg) if err != nil { return "", err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 13 17:19:22 UTC 2022 - 3.4K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/websocket.go
} func newWebsocketProtocol(e *executor) protocol { return &websocketProtocol{e: e} } func (c *websocketProtocol) ForwardEcho(ctx context.Context, cfg *Config) (*proto.ForwardEchoResponse, error) { return doForward(ctx, cfg, c.e, c.makeRequest) } func (c *websocketProtocol) Close() error { return nil } func (c *websocketProtocol) makeRequest(ctx context.Context, cfg *Config, requestID int) (string, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 11 16:27:16 UTC 2022 - 3.3K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/tls.go
e *executor } func newTLSProtocol(e *executor) protocol { return &tlsProtocol{e: e} } func (c *tlsProtocol) ForwardEcho(ctx context.Context, cfg *Config) (*proto.ForwardEchoResponse, error) { return doForward(ctx, cfg, c.e, c.makeRequest) } func (c *tlsProtocol) makeRequest(ctx context.Context, cfg *Config, requestID int) (string, error) { conn, err := newTLSConnection(cfg) if err != nil { return "", err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 11 16:27:16 UTC 2022 - 3.4K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/dns.go
e *executor } func newDNSProtocol(e *executor) protocol { return &dnsProtocol{e: e} } func (c *dnsProtocol) ForwardEcho(ctx context.Context, cfg *Config) (*proto.ForwardEchoResponse, error) { return doForward(ctx, cfg, c.e, c.makeRequest) } type dnsRequest struct { hostname string dnsServer string query string protocol string } func checkIn(got string, want ...string) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 10 18:09:08 UTC 2022 - 3.3K bytes - Viewed (0) -
guava/src/com/google/common/base/Enums.java
implements Serializable { private final Class<T> enumClass; StringConverter(Class<T> enumClass) { this.enumClass = checkNotNull(enumClass); } @Override protected T doForward(String value) { return Enum.valueOf(enumClass, value); } @Override protected String doBackward(T enumValue) { return enumValue.name(); } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 26 11:56:44 UTC 2023 - 5K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/grpc.go
defer func() { _ = conn.Close() }() getConn = func() (*grpc.ClientConn, func(), error) { return conn, func() {}, nil } } call := &grpcCall{ e: c.e, getConn: getConn, } return doForward(ctx, cfg, c.e, call.makeRequest) } func (c *grpcProtocol) Close() error { return nil } type grpcCall struct { e *executor getConn grpcConnectionGetter }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 14 19:45:43 UTC 2023 - 4.5K bytes - Viewed (0) -
android/guava/src/com/google/common/base/CaseFormat.java
this.sourceFormat = checkNotNull(sourceFormat); this.targetFormat = checkNotNull(targetFormat); } @Override protected String doForward(String s) { return sourceFormat.to(targetFormat, s); } @Override protected String doBackward(String s) { return targetFormat.to(sourceFormat, s); } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 19 20:20:14 UTC 2022 - 6.3K bytes - Viewed (0)