- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 180 for WORKLOADS (0.21 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/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) -
pkg/scheduler/metrics/resources/resources_test.go
req, err := http.NewRequest("GET", "/metrics/resources", nil) if err != nil { t.Fatal(err) } h.ServeHTTP(r, req) expected := `# HELP kube_pod_resource_limit [STABLE] Resources limit for workloads on the cluster, broken down by pod. This shows the resource usage the scheduler and kubelet expect per pod for resources along with the unit for the resource if any. # TYPE kube_pod_resource_limit gauge
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 13 07:42:19 UTC 2023 - 21.6K bytes - Viewed (0) -
pilot/pkg/xds/mesh_network_test.go
ip: "10.10.10.30", port: 9090, metaNetwork: "vm", } // VM always sees itself directly vm.Expect(vm, "10.10.10.30:9090") workloads := []*workload{pod, vm} var kubeObjects []runtime.Object var configObjects []config.Config for _, w := range workloads { _, objs := w.kubeObjects() kubeObjects = append(kubeObjects, objs...) configObjects = append(configObjects, w.configs()...) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 24.6K bytes - Viewed (0) -
tests/integration/pilot/tunneling_test.go
} func verifyThatRequestWasTunneled(target echo.Instance, expectedSourceIPs []corev1.PodIP, expectedPath string) error { workloads, err := target.Workloads() if err != nil { return fmt.Errorf("failed to get workloads of %s: %s", target.ServiceName(), err) } var logs strings.Builder for _, w := range workloads { workloadLogs, err := w.Logs() if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/test/framework/components/echo/calloptions.go
// Nothing to do. return o.ProxyProtocolVersion } return 0 } func (o *CallOptions) numWorkloads() int { if o.To == nil { return 0 } workloads, err := o.To.Workloads() if err != nil { return 0 } return len(workloads) } func (o *CallOptions) fillConnectionParams() { // Overrides connection parameters for scheme. switch o.Scheme { case scheme.DNS:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Oct 08 09:39:20 UTC 2023 - 13K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_serviceentry_test.go
WorkloadType: workloadapi.WorkloadType_POD, WorkloadName: "name0", ClusterId: testC, }, }, }, }}) // test code path where service entry selects workloads via `ServiceEntry.workloadSelector` s.addPods(t, "140.140.0.10", "pod1", "sa1", map[string]string{"app": "a"}, nil, true, corev1.PodRunning) s.assertEvent(t, s.podXdsName("pod1"))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 03:01:04 UTC 2024 - 12.9K bytes - Viewed (0) -
architecture/ambient/ztunnel.md
Most of the API is fairly straight forward. However, one interesting aspect is how these policies associate with workloads. Istio's AuthorizationPolicy has label selectors. However, we intentionally do not send those as part of the Workload API, in order to keep the size low. The obvious solution to this is to put the list of selected workloads into the policy itself. However, this means anytime a workload changes (often), we need to update the policy.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 22:35:16 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/workloadapi/workload.proto
// This could be a single Pod, a VM instance, etc. Workload workload = 1; // Service represents a service - a group of workloads that can be accessed together. Service service = 2; } } // Service represents a service - a group of workloads that can be accessed together. // The xds primary key is "namespace/hostname".
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:35 UTC 2024 - 12.9K bytes - Viewed (0)