- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 144 for WORKLOADS (0.24 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) -
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/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) -
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) -
tests/integration/pilot/original_src_addr_test.go
Run(func(t framework.TestContext) { if t.Settings().Skip(echo.TProxy) { t.Skip() } workloads, err := apps.A[0].Workloads() if err != nil { t.Errorf("failed to get Subsets: %v", err) return } // check the server can see the client's original ip var srcIps []string for _, w := range workloads { srcIps = append(srcIps, w.Address()) } checkOriginalSrcIP(t, apps.A[0], apps.Tproxy[0], srcIps)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 1.9K bytes - Viewed (0) -
tests/integration/pilot/multiplecontrolplanes/main_test.go
statusCode int from echo.Instances to echo.Instances }{ { name: "workloads within same usergroup can communicate, same namespace", statusCode: http.StatusOK, from: apps.NS[0].A, to: apps.NS[0].B, }, { name: "workloads within same usergroup can communicate, different namespaces", statusCode: http.StatusOK,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 16:52:52 UTC 2024 - 9.1K bytes - Viewed (0)