- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for WARMING (0.12 sec)
-
istioctl/pkg/writer/compare/sds/util.go
} proxySecretItems := make([]SecretItem, 0) for _, warmingSecret := range secretConfigDump.DynamicWarmingSecrets { secret, err := parseDynamicSecret(warmingSecret, "WARMING") if err != nil { return nil, fmt.Errorf("failed building warming secret %s: %v", warmingSecret.Name, err) } proxySecretItems = append(proxySecretItems, secret) } for _, activeSecret := range secretConfigDump.DynamicActiveSecrets {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 06 15:14:48 UTC 2023 - 6.6K bytes - Viewed (0) -
pkg/test/kube/dump.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 22.2K bytes - Viewed (0) -
pkg/xds/server.go
removed := prev.Difference(cur) added := cur.Difference(prev) // We should always respond "alwaysRespond" marked requests to let Envoy finish warming // even though Nonce match and it looks like an ACK. if alwaysRespond { log.Infof("ADS:%s: FORCE RESPONSE %s for warming.", stype, id) return true, emptyResourceDelta } if len(removed) == 0 && len(added) == 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
if !subChanged { // We should always respond "alwaysRespond" marked requests to let Envoy finish warming // even though Nonce match and it looks like an ACK. if alwaysRespond { deltaLog.Infof("ADS:%s: FORCE RESPONSE %s for warming.", stype, con.ID()) return true } deltaLog.Debugf("ADS:%s: ACK %s %s", stype, con.ID(), request.ResponseNonce) return false }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
tests/integration/security/egress_sidecar_tls_origination_test.go
StatusCode: http.StatusOK, }, }, // Mutual TLS origination from an unauthorized sidecar to https endpoint // This will result in a 503 with the UH flag because the cluster will // stay warming until a valid secret is sent. { name: "unauthorized sidecar", credentialToUse: credNameGeneric, from: apps.Ns1.B, drSelector: "b",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 10.4K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/configdump.go
if err != nil { return err } if len(secretDump.DynamicActiveSecrets) == 0 && len(secretDump.DynamicWarmingSecrets) == 0 { fmt.Fprintln(c.Stdout, "No active or warming secrets found.") return nil } secretItems, err := sdscompare.GetEnvoySecrets(c.configDump) if err != nil { return err } secretWriter := sdscompare.NewSDSWriter(c.Stdout, sdscompare.TABULAR)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 20:46:41 UTC 2024 - 7.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/RateLimiter.java
* if the {@code RateLimiter} is left <i>unused</i> for a duration of {@code warmupPeriod}, it * will gradually return to its "cold" state, i.e. it will go through the same warming up process * as when it was first created. * * <p>The returned {@code RateLimiter} is intended for cases where the resource that actually
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 21.5K bytes - Viewed (0) -
pilot/pkg/model/context.go
// Refer to https://github.com/envoyproxy/envoy/issues/13009 for more details. for _, dependent := range WarmingDependencies(typeURL) { if dwr, exists := node.WatchedResources[dependent]; exists { dwr.AlwaysRespond = true } } } // WarmingDependencies returns the dependent typeURLs that need to be responded with // for warming of this typeURL.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (1) -
tests/integration/pilot/istioctl_test.go
dump := &admin.SecretsConfigDump{} if err := protomarshal.Unmarshal([]byte(output), dump); err != nil { t.Fatal(err) } if len(dump.DynamicWarmingSecrets) > 0 { t.Fatalf("found warming secrets: %v", output) } if len(dump.DynamicActiveSecrets) != 2 { // If the config for the SDS does not align in all locations, we may get duplicates.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 15K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/RateLimiter.java
* if the {@code RateLimiter} is left <i>unused</i> for a duration of {@code warmupPeriod}, it * will gradually return to its "cold" state, i.e. it will go through the same warming up process * as when it was first created. * * <p>The returned {@code RateLimiter} is intended for cases where the resource that actually
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 18.2K bytes - Viewed (0)