- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for pusha (0.06 sec)
-
pilot/pkg/networking/core/cluster_builder_test.go
Services: []*model.Service{service}, Instances: tt.instances, }) cb := NewClusterBuilder(cg.SetupProxy(proxy), &model.PushRequest{Push: cg.PushContext()}, nil) eb := endpoints.NewCDSEndpointBuilder( proxy, cb.req.Push, "outbound|8080|v1|foo.com", model.TrafficDirectionOutbound, "v1", "foo.com", 8080, service, drWithLabels(tt.labels), )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 110.4K bytes - Viewed (0) -
samples/addons/grafana.yaml
{"type":"prometheus","uid":"$datasource"},"expr":"pilot_total_xds_internal_errors{}","legendFormat":"Internal Errors"},{"datasource":{"type":"prometheus","uid":"$datasource"},"expr":"pilot_xds_push_context_errors{}","legendFormat":"Push Context Errors"}],"title":"Push Errors","type":"timeseries"},{"datasource":{"type":"datasource","uid":"-- Mixed --"},"description":"Count of active and pending proxies managed by each instance.\nPending is expected to converge to zero.\n","gridPos":{"h":10,"w":8,...
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 20:46:28 UTC 2024 - 242.3K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/tf_passes.td
maximum size needs to be a constant and 2) a push op can be found with a known shape, and all push ops need to have the same shape. A stack creation op "tf.StackV2" will be turned in to two zero-initialized variables, for the buffer and current size. Each push will be turned into ```mlir %old_val = "tf.ReadVariableOp"(%buffer)
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Jun 12 21:18:05 UTC 2024 - 99.6K bytes - Viewed (0) -
pilot/pkg/networking/core/gateway_test.go
}, }, }, }, } for _, tt := range cases { t.Run(tt.name, func(t *testing.T) { push.Networks = tt.networks httpConnManager := buildGatewayConnectionManager(&meshconfig.ProxyConfig{}, proxy, false, push) if !reflect.DeepEqual(tt.expectedconfig, httpConnManager.InternalAddressConfig) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 144K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/shape_inference.cc
for (auto& use : tensorlist.getUses()) { if (auto push = llvm::dyn_cast<TensorListPushBackOp>(use.getOwner())) { auto element_type = mlir::dyn_cast<RankedTensorType>(push.getTensor().getType()); if (!verify_and_update_potential_element_type(element_type)) return false; add_to_worklist(push.getOutputHandle()); continue; }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Jun 08 07:28:49 UTC 2024 - 134.1K bytes - Viewed (0) -
src/debug/elf/elf.go
R_386_TLS_GD_PUSH R_386 = 25 /* pushl instruction for Sun ABI GD sequence */ R_386_TLS_GD_CALL R_386 = 26 /* call instruction for Sun ABI GD sequence */ R_386_TLS_GD_POP R_386 = 27 /* popl instruction for Sun ABI GD sequence */ R_386_TLS_LDM_32 R_386 = 28 /* 32 bit offset to GOT (index,zero) pair */ R_386_TLS_LDM_PUSH R_386 = 29 /* pushl instruction for Sun ABI LD sequence */
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 16 00:01:16 UTC 2024 - 134.6K bytes - Viewed (0) -
cluster/gce/util.sh
local host=${1} local ca_cert=${2:-} local ca_key=${3:-} GEN_ETCD_CA_CERT="${ca_cert}" GEN_ETCD_CA_KEY="${ca_key}" \ generate-etcd-cert "${KUBE_TEMP}/cfssl" "${host}" "peer" "peer" pushd "${KUBE_TEMP}/cfssl" ETCD_CA_KEY_BASE64=$(base64 "ca-key.pem" | tr -d '\r\n') ETCD_CA_CERT_BASE64=$(gzip -c "ca.pem" | base64 | tr -d '\r\n') ETCD_PEER_KEY_BASE64=$(base64 "peer-key.pem" | tr -d '\r\n')
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 21:47:17 UTC 2024 - 161.6K bytes - Viewed (0) -
cmd/admin-handlers.go
local := globalLocalNodeName if local == "" { local = "127.0.0.1" } failedClients := make(map[int]struct{}) if globalIsDistErasure { // Push binary to other servers for idx, nerr := range globalNotificationSys.VerifyBinary(ctx, u, sha256Sum, releaseInfo, binC) { if nerr.Err != nil { peerResults[nerr.Host.String()] = madmin.ServerPeerUpdateStatus{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
src/net/http/server.go
err error wroteHeader bool code int } var _ Pusher = (*timeoutWriter)(nil) // Push implements the [Pusher] interface. func (tw *timeoutWriter) Push(target string, opts *PushOptions) error { if pusher, ok := tw.w.(Pusher); ok { return pusher.Push(target, opts) } return ErrNotSupported } func (tw *timeoutWriter) Header() Header { return tw.h }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
src/cmd/go/internal/work/exec.go
// Initialize per-action execution state. for _, a := range all { for _, a1 := range a.Deps { a1.triggers = append(a1.triggers, a) } a.pending = len(a.Deps) if a.pending == 0 { b.ready.push(a) b.readySema <- true } } // Handle runs a single action and takes care of triggering // any actions that are runnable as a result. handle := func(ctx context.Context, a *Action) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 14:46:37 UTC 2024 - 105.6K bytes - Viewed (0)