Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 330 for WORKLOADS (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top