- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 89 for WORKLOADS (5.28 sec)
-
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) -
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/writer/ztunnel/configdump/configdump.go
type ConfigWriter struct { Stdout io.Writer ztunnelDump *ZtunnelDump FullDump []byte } type rawDump struct { Services json.RawMessage `json:"services"` Workloads json.RawMessage `json:"workloads"` Policies json.RawMessage `json:"policies"` Certificates json.RawMessage `json:"certificates"` WorkloadState map[string]WorkloadState `json:"workloadstate"` }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 20:18:34 UTC 2024 - 3.9K bytes - Viewed (0) -
pkg/kube/krt/bench_test.go
ServiceNames: slices.Map(services, func(e *v1.Service) string { return e.Name }), } }) Workloads.Register(func(e krt.Event[Workload]) { events <- fmt.Sprintf(e.Latest().Name, e.Event) }) } type legacy struct { pods kclient.Client[*v1.Pod] services kclient.Client[*v1.Service] queue controllers.Queue workloads map[types.NamespacedName]*Workload handler func(event krt.Event[Workload]) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 7K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/workload.go
func (c *ConfigWriter) PrintWorkloadSummary(filter WorkloadFilter) error { w := c.tabwriter() zDump := c.ztunnelDump verifiedWorkloads := make([]*ZtunnelWorkload, 0, len(zDump.Workloads)) for _, wl := range zDump.Workloads { if filter.Verify(wl) { verifiedWorkloads = append(verifiedWorkloads, wl) } } // Sort by name, node sort.Slice(verifiedWorkloads, func(i, j int) bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 20:18:34 UTC 2024 - 3.9K bytes - Viewed (0)