- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 330 for WORKLOADS (0.17 sec)
-
pilot/pkg/serviceregistry/kube/controller/ambient/workloads.go
a.serviceEntryWorkloadBuilder(MeshConfig, AuthorizationPolicies, PeerAuths, Waypoints, Namespaces), krt.WithName("ServiceEntryWorkloads"), ) Workloads := krt.JoinCollection([]krt.Collection[model.WorkloadInfo]{PodWorkloads, WorkloadEntryWorkloads, ServiceEntryWorkloads}, krt.WithName("Workloads")) return Workloads } func (a *index) workloadEntryWorkloadBuilder( MeshConfig krt.Singleton[MeshConfig],
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 20.9K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/testdata/two-workloads-one-nosidecar.yaml
Jonh Wendell <******@****.***> 1700195286 -0500
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Nov 17 04:28:06 UTC 2023 - 3.7K bytes - Viewed (0) -
pkg/test/framework/components/echo/workload.go
type WorkloadContainer interface { // Workloads retrieves the list of all deployed workloads for this Echo service. // Guarantees at least one workload, if error == nil. Workloads() (Workloads, error) WorkloadsOrFail(t test.Failer) Workloads MustWorkloads() Workloads // Clusters where the workloads are deployed. Clusters() cluster.Clusters }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Oct 25 19:46:28 UTC 2023 - 2.7K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/workload_manager.go
// Indicate we're closing. m.closing = true // Stop the controller and queue. close(m.stopCh) // Clear out the workloads array workloads := m.workloads m.workloads = nil m.mutex.Unlock() // Close the workloads. for _, w := range workloads { err = multierror.Append(err, w.Close()).ErrorOrNil() } return
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 02:12:37 UTC 2023 - 6.4K bytes - Viewed (0) -
releasenotes/notes/47574.yaml
releaseNotes: - | **Added** support for automatically set default network to Ambient workloads if they are added to the Ambient before the network topology is set. Before, when you set `topology.istio.io/network` on your Istio root namespace, you need to manually rollout the Ambient workloads to make the network change take effect. Now, the network of Ambient workloads will be automatically updated even if they do not have a network label.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Nov 22 06:59:24 UTC 2023 - 733 bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex.go
// TODO: we should be able to handle multiple IPs or a hostname if len(key.Addresses) == 0 { return nil } workloads := a.workloads.ByOwningWaypoint.Lookup(networkAddress{ network: key.Network, ip: key.Addresses[0], }) workloads = model.SortWorkloadsByCreationTime(workloads) return workloads } func (a *index) AdditionalPodSubscriptions( proxy *model.Proxy, allAddresses sets.String,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 19 17:19:41 UTC 2024 - 15.8K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/connections.go
d := c.ztunnelDump workloads := maps.Values(d.WorkloadState) workloads = slices.SortFunc(workloads, func(a, b WorkloadState) int { if r := cmp.Compare(a.Info.Namespace, b.Info.Namespace); r != 0 { return r } return cmp.Compare(a.Info.Namespace, b.Info.Namespace) }) workloads = slices.FilterInPlace(workloads, func(state WorkloadState) bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:11 UTC 2024 - 3.5K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/instance.go
} } return final, nil } func (c *instance) WorkloadsOrFail(t test.Failer) echo.Workloads { t.Helper() out, err := c.Workloads() if err != nil { t.Fatal(err) } return out } func (c *instance) MustWorkloads() echo.Workloads { out, err := c.Workloads() if err != nil { panic(err) } return out } func (c *instance) Clusters() cluster.Clusters {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 16 18:55:23 UTC 2023 - 9K bytes - Viewed (0) -
pkg/test/framework/components/echo/instances.go
out = append(out, c) } } return out } func (i Instances) Workloads() (Workloads, error) { var out Workloads for _, inst := range i { ws, err := inst.Workloads() if err != nil { return nil, err } out = append(out, ws...) } if len(out) == 0 { return nil, errors.New("got 0 workloads") } return out, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 25 18:26:17 UTC 2024 - 4.7K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
istioctl ztunnel-config workloads --file ztunnel-config.json # Retrieve workload summary for a specific namespace istioctl ztunnel-config workloads <ztunnel-name[.namespace]> --workloads-namespace foo `, Aliases: []string{"w", "workloads"}, Args: common.validateArgs, RunE: runConfigDump(ctx, common, func(cw *ztunnelDump.ConfigWriter) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 20:18:34 UTC 2024 - 22K bytes - Viewed (0)