- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 59 for Initial (0.14 sec)
-
internal/grid/muxclient.go
func (m *muxClient) RequestStateless(h HandlerID, req []byte, out chan<- Response) { if m.init { out <- Response{Err: errors.New("mux client already used")} } m.init = true // Try to grab an initial block. m.singleResp = false msg := message{ Op: OpConnectMux, Handler: h, Flags: FlagEOF, Payload: req, DeadlineMS: uint32(m.deadline.Milliseconds()), }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
// 3. Envoy sends CDS request and we respond with clusters. // 4. Envoy detects a change in cluster state and tries to warm those clusters but never sends // an EDS request for them. // 5. Therefore, any initial CDS request should always trigger an EDS response // to let Envoy finish cluster warming. // Refer to https://github.com/envoyproxy/envoy/issues/13009 for some more details on this type of issues.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
pilot/test/xds/fake.go
cg.ServiceEntryRegistry.ResyncEDS() // Send an update. This ensures that even if there are no configs provided, the push context is // initialized. s.ConfigUpdate(&model.PushRequest{Full: true}) // Wait until initial updates are committed c := s.InboundUpdates.Load() retry.UntilOrFail(t, func() bool { return s.CommittedUpdates.Load() >= c }, retry.Delay(time.Millisecond)) // Mark ourselves ready s.CachesSynced()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
pkg/controlplane/apiserver/options/options_test.go
"--audit-webhook-batch-throttle-burst=44", "--audit-webhook-truncate-enabled=true", "--audit-webhook-truncate-max-batch-size=43", "--audit-webhook-truncate-max-event-size=42", "--audit-webhook-initial-backoff=2s", "--audit-webhook-version=audit.k8s.io/v1", "--authentication-token-webhook-cache-ttl=3m", "--authentication-token-webhook-config-file=/token-webhook-config", "--authorization-mode=AlwaysDeny,RBAC",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 10.7K bytes - Viewed (0) -
analysis/analysis-api/src/org/jetbrains/kotlin/analysis/api/types/KtType.kt
* * Types are always expanded to their final form. That is, if we have a chain of type alias expansions, the [KaType] only represents the * final expanded type, and its [abbreviatedType] the initial type alias application. For example: * * ``` * typealias Inner = String * typealias Outer = Inner * * val outer: Outer = "" * ``` *
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Mon Jun 10 20:18:28 UTC 2024 - 8.5K bytes - Viewed (0) -
cmd/kube-apiserver/app/options/options_test.go
"--audit-webhook-batch-throttle-burst=44", "--audit-webhook-truncate-enabled=true", "--audit-webhook-truncate-max-batch-size=43", "--audit-webhook-truncate-max-event-size=42", "--audit-webhook-initial-backoff=2s", "--audit-webhook-version=audit.k8s.io/v1", "--authentication-token-webhook-cache-ttl=3m", "--authentication-token-webhook-config-file=/token-webhook-config", "--authorization-mode=AlwaysDeny,RBAC",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 12.7K bytes - Viewed (0) -
cluster/gce/windows/k8s-node-setup.psm1
Set_CurrentShellEnvironmentVar "POD_CIDR" ${pod_cidr} } # Adds an initial HNS network on the Windows node which forces the creation of # a virtual switch and the "management" interface that will be used to # communicate with the rest of the Kubernetes cluster without NAT. # # Note that adding the initial HNS network may cause connectivity to the GCE # metadata server to be lost due to a Windows bug.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 21:13:22 UTC 2024 - 88.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go
transformer.prefix = []byte(string(transformer.prefix) + " ") return transformer }) _, initial := testPropagateStore(ctx, t, store, input) revertTransformer() // this update should write the canonical value to etcd because the new serialization differs // from the stored serialization input.ResourceVersion = initial.ResourceVersion out := &example.Pod{} err := store.GuaranteedUpdate(ctx, key, out, true, nil,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 91.4K bytes - Viewed (0) -
internal/grid/handlers.go
Handle StatelessHandlerFn // OutCapacity is the output capacity on the caller. // If <= 0 capacity will be 1. OutCapacity int } // StreamHandlerFn must process a request with an optional initial payload. // It must keep consuming from 'in' until it returns. // 'in' and 'out' are independent. // The handler should never close out. // Buffers received from 'in' can be recycled with PutByteBuffer.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.1K bytes - Viewed (0) -
src/cmd/go/internal/modget/get.go
// packages imported by the main module does not change, and the query // result for the module containing each such package also does not change // (it is always relative to the initial build list, before applying // queries). So the only way that the result of an "all" query can change // is if some matching package moves from one module in the build list
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 18:26:32 UTC 2024 - 66.5K bytes - Viewed (0)