- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 161 for It (0.04 sec)
-
pilot/pkg/serviceregistry/serviceentry/controller.go
cs := convertServices(curr) configsUpdated := sets.New[model.ConfigKey]() key := curr.NamespacedName() s.mutex.Lock() // If it is add/delete event we should always do a full push. If it is update event, we should do full push, // only when services have changed - otherwise, just push endpoint updates. var addedSvcs, deletedSvcs, updatedSvcs, unchangedSvcs []*model.Service
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod_test.go
} } // This pod exists, but should not be in the cache because it is in a // namespace not watched by the controller. assert.Equal(t, c.pods.getPodsByIP("128.0.0.4"), nil) // This pod should not be in the cache because it never existed. assert.Equal(t, c.pods.getPodsByIP("128.0.0.128"), nil)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 18:27:40 UTC 2024 - 12.3K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/deploymentcontroller_test.go
gws.Update(defaultGateway) expectReconciled() // We should not be updating the version, its already set. Setting it introduces a possible race condition // since we use SSA so there is no conflict checks. assert.ChannelIsEmpty(t, writes) // Somehow the annotation is removed - it should be added back defaultGateway.Annotations = map[string]string{} gws.Update(defaultGateway) expectReconciled()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 21:43:20 UTC 2024 - 16.5K bytes - Viewed (0) -
pkg/test/framework/components/echo/config.go
TLSSettings *common.TLSSettings // If enabled, echo will be deployed as a "VM". This means it will run Envoy in the same pod as echo, // disable sidecar injection, etc. // This aims to simulate a VM, but instead of managing the complex test setup of spinning up a VM, // connecting, etc we run it inside a pod. The pod has pretty much all Kubernetes features disabled (DNS and SA token mount)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 12:26:52 UTC 2024 - 18.2K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
func portForward(podName, namespace, flavor, urlFormat, localAddress string, remotePort int, client kube.CLIClient, writer io.Writer, browser bool, ) error { // port preference: // - If --listenPort is specified, use it // - without --listenPort, prefer the remotePort but fall back to a random port var portPrefs []int if listenPort != 0 { portPrefs = []int{listenPort} } else { portPrefs = []int{remotePort, 0} }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 15 01:29:35 UTC 2024 - 20.5K bytes - Viewed (0) -
pkg/test/framework/components/echo/common/deployment/echos.go
// locally with the application container in the same pod. IncludeExtAuthz bool // Custom allows for configuring custom echo deployments. If a deployment's namespace // is nil, it will be created in all namespaces. Otherwise, it must match one of the // namespaces configured above. // // Custom echo instances will be accessible from the `All` field in the namespace(s) under which they // were created.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 20 16:01:31 UTC 2024 - 16K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
if err != nil { return err } // Anytime we get a CDS request on reconnect, we should always push EDS as well. // It is always the server's responsibility to send EDS after CDS, regardless if // Envoy asks for it or not (See https://github.com/envoyproxy/envoy/issues/33607 for more details). // Without this logic, there are cases where the clusters we send could stay warming forever,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
operator/cmd/mesh/manifest-generate_test.go
) type testGroup []struct { desc string // Small changes to the input profile produce large changes to the golden output // files. This makes it difficult to spot meaningful changes in pull requests. // By default we hide these changes to make developers life's a bit easier. However, // it is still useful to sometimes override this behavior and show the full diff. // When this flag is true, use an alternative file suffix that is not hidden by
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 04 18:05:06 UTC 2024 - 43.5K bytes - Viewed (0) -
pkg/wasm/cache.go
) // Cache models a Wasm module cache. type Cache interface { Get(url string, opts GetOptions) (string, error) Cleanup() } // LocalFileCache for downloaded Wasm modules. Currently it stores the Wasm module as local file. type LocalFileCache struct { // Map from Wasm module checksum to cache entry. modules map[moduleKey]*cacheEntry // Map from tagged URL to checksum checksums map[string]*checksumEntry
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/istio-agent/agent.go
return true } return false } // Checks whether the socket exists and is responsive. // If it doesn't exist, returns (false, nil) // If it exists and is NOT responsive, tries to delete the socket file. // If it can be deleted, returns (false, nil). // If it cannot be deleted, returns (false, error). // Otherwise, returns (true, nil)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 10:02:56 UTC 2024 - 26.7K bytes - Viewed (0)