- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 134 for downstream (0.32 sec)
-
pkg/bootstrap/instance_test.go
// Upstream metrics record client side measurements. // Downstream metrics record server side measurements. upstreamStatsSuffixes = "upstream_rq_1xx,upstream_rq_2xx,upstream_rq_3xx,upstream_rq_4xx,upstream_rq_5xx," + "upstream_rq_time,upstream_cx_tx_bytes_total,upstream_cx_rx_bytes_total,upstream_cx_total" // example downstream metric: http.10.16.48.230_8080.downstream_rq_2xx
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 17:05:28 UTC 2024 - 19.5K bytes - Viewed (0) -
pkg/hbone/dialer.go
wg := sync.WaitGroup{} wg.Add(1) go func() { // handle upstream (hbone server) --> downstream (app) copyBuffered(conn, resp.Body, log.WithLabels("name", "body to conn")) wg.Done() }() // Copy from conn into the pipe, which will then be sent as part of the request // handle upstream (hbone server) <-- downstream (app) copyBuffered(pw, conn, log.WithLabels("name", "conn to pipe")) wg.Wait()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 15:56:41 UTC 2023 - 5.1K bytes - Viewed (0) -
pkg/istio-agent/metrics/metrics.go
"envoy_connection_terminations", "The total number of connection errors from envoy", ) // TODO: Add type url as type for requeasts and responses if needed. // XdsProxyRequests records total number of downstream requests. XdsProxyRequests = monitoring.NewSum( "xds_proxy_requests", "The total number of Xds Proxy Requests", ) // XdsProxyResponses records total number of upstream responses.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 2.2K bytes - Viewed (0) -
hack/make-rules/test-integration.sh
kube::etcd::start_scraping kube::log::status "Running integration test cases" # shellcheck disable=SC2034 # KUBE_RACE and MAKEFLAGS are used in the downstream make, and we set them to # empty here to ensure that we aren't unintentionally consuming them from the # previous make invocation. KUBE_TEST_ARGS="${SHORT:--short=true} --vmodule=${KUBE_TEST_VMODULE} ${KUBE_TEST_ARGS}" \
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:57 UTC 2024 - 3.6K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/cli/RunBuildAction.java
); if (result.hasFailure()) { // Don't need to unpack the serialized failure. It will already have been reported and is not used by anything downstream of this action. throw new ReportedException(); } } finally { stoppable.stop(); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/quota/v1/install/registry.go
{Group: eventv1.GroupName, Resource: "events"}: {}, } // DefaultIgnoredResources returns the default set of resources that quota system // should ignore. This is exposed so downstream integrators can have access to them. func DefaultIgnoredResources() map[schema.GroupResource]struct{} { return ignoredResources
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 14 16:00:26 UTC 2022 - 2.6K bytes - Viewed (0) -
pilot/pkg/security/authn/utils/utils.go
} authn_model.ApplyToCommonTLSContext(ctx.CommonTlsContext, node, []string{}, /*subjectAltNames*/ "", /*crl*/ trustDomainAliases, ctx.RequireClientCertificate.Value) // Compliance for downstream mesh mTLS. authn_model.EnforceCompliance(ctx.CommonTlsContext) return ctx } // GetMinTLSVersion returns the minimum TLS version for workloads based on the mesh config.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 00:16:21 UTC 2024 - 3.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel.go
// TunnelingHandler is a handler which tunnels SPDY through WebSockets. type TunnelingHandler struct { // Used to communicate between upstream SPDY and downstream tunnel. upgradeHandler http.Handler } // NewTunnelingHandler is used to create the tunnel between an upstream // SPDY connection and a downstream tunneling connection through the stored // UpgradeAwareProxy. func NewTunnelingHandler(upgradeHandler http.Handler) *TunnelingHandler {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.7K bytes - Viewed (0) -
tensorflow/compiler/jit/encapsulate_xla_computations_pass.h
// converter. The single argument overload version calls this function. // // When add_edges_to_output_of_downstream_nodes is true, the output edges of // the xla_launch_node's immediate downstream nodes would be attached to the // generated xla node. For example, if the original graph is // StatefulPartitionedCall{_xla_compile_id=1} -> XlaClusterOutput -> NodeA
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 22 06:59:07 UTC 2024 - 3.6K bytes - Viewed (0) -
ci/official/wheel_test/README.md
## Wheel Test This directory is dedicated to tests that require a built TensorFlow wheel file for testing, such as: * Ensuring the entire API is importable * Testing downstream projects against the wheel Ensure you have Bazel installed and accessible from your command line. These tests use hermetic Python. They also require a built TensorFlow wheel file and a requirements_lock file. The requirements_lock file is generated by the
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Aug 31 18:17:57 UTC 2023 - 3.3K bytes - Viewed (0)