Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 36 for CLIClient (0.05 sec)

  1. istioctl/pkg/internaldebug/internal-debug.go

    	"istio.io/istio/istioctl/pkg/multixds"
    	"istio.io/istio/istioctl/pkg/util"
    	v3 "istio.io/istio/pilot/pkg/xds/v3"
    	"istio.io/istio/pkg/kube"
    )
    
    func HandlerForRetrieveDebugList(kubeClient kube.CLIClient,
    	centralOpts clioptions.CentralControlPlaneOptions,
    	writer io.Writer,
    	istioNamespace string,
    ) (map[string]*discovery.DiscoveryResponse, error) {
    	var namespace, serviceAccount string
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jul 12 11:30:24 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  2. istioctl/pkg/util/ambient/util.go

    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    
    	"istio.io/api/annotation"
    	"istio.io/api/label"
    	"istio.io/istio/pkg/config/constants"
    	"istio.io/istio/pkg/kube"
    )
    
    func IsZtunnelPod(client kube.CLIClient, podName, podNamespace string) bool {
    	isZtunnel := strings.HasPrefix(podName, "ztunnel")
    	if client == nil {
    		return isZtunnel
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  3. istioctl/pkg/cli/mock_test.go

    	"k8s.io/client-go/rest/fake"
    	cmdtesting "k8s.io/kubectl/pkg/cmd/testing"
    	"k8s.io/kubectl/pkg/cmd/util"
    
    	"istio.io/istio/pkg/kube"
    )
    
    func init() {
    	MakeKubeFactory = func(k kube.CLIClient) util.Factory {
    		tf := cmdtesting.NewTestFactory()
    		_, _, codec := cmdtesting.NewExternalScheme()
    		tf.UnstructuredClient = &fake.RESTClient{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  4. istioctl/pkg/tag/revision.go

    	EgressGatewayPods  []*PodFilteredInfo           `json:"egress_gateways,omitempty"`
    	NamespaceSummary   map[string]*NsInfo           `json:"namespace_summary,omitempty"`
    }
    
    func ListRevisionDescriptions(client kube.CLIClient) (map[string]*RevisionDescription, error) {
    	revisions := map[string]*RevisionDescription{}
    
    	// Get a list of control planes which are installed in remote clusters
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  5. istioctl/pkg/tag/tag.go

    			}
    			if len(args) > 1 {
    				return fmt.Errorf("must provide a single tag for creation")
    			}
    			return nil
    		},
    		RunE: func(cmd *cobra.Command, args []string) error {
    			kubeClient, err := ctx.CLIClient()
    			if err != nil {
    				return fmt.Errorf("failed to create Kubernetes client: %v", err)
    			}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 22 15:40:30 UTC 2024
    - 16.5K bytes
    - Viewed (0)
  6. istioctl/pkg/ztunnelconfig/ztunnelconfig_test.go

    		}
    	} else {
    		if fErr != nil {
    			t.Fatalf("Unwanted exception for 'istioctl %s': %v", strings.Join(c.args, " "), fErr)
    		}
    	}
    }
    
    func init() {
    	cli.MakeKubeFactory = func(k kube.CLIClient) cmdutil.Factory {
    		tf := cmdtesting.NewTestFactory()
    		_, _, codec := cmdtesting.NewExternalScheme()
    		tf.UnstructuredClient = &fake.RESTClient{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Apr 10 21:51:29 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  7. istioctl/pkg/authz/authz.go

    				cmd.Println(cmd.UsageString())
    				return fmt.Errorf("check requires only <pod-name>[.<pod-namespace>]")
    			}
    			return nil
    		},
    		RunE: func(cmd *cobra.Command, args []string) error {
    			kubeClient, err := ctx.CLIClient()
    			if err != nil {
    				return fmt.Errorf("failed to create k8s client: %w", err)
    			}
    			var configDump *configdump.Wrapper
    			if configDumpFile != "" {
    				configDump, err = getConfigDumpFromFile(configDumpFile)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 5K bytes
    - Viewed (0)
  8. istioctl/pkg/ztunnelconfig/ztunnelconfig.go

    				return fmt.Errorf("--output is not applicable for this command")
    			}
    			return nil
    		},
    		RunE: func(c *cobra.Command, args []string) error {
    			kubeClient, err := ctx.CLIClient()
    			if err != nil {
    				return err
    			}
    			var podNames []string
    			var podNamespace string
    			if len(args) == 1 {
    				podName, ns, err := getComponentPodName(ctx, args[0])
    				if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 19:17:45 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  9. istioctl/pkg/precheck/precheck_test.go

    			"follow https://istio.io/latest/docs/tasks/observability/distributed-tracing/telemetry-api/",
    		"1.21")
    
    	assert.Equal(t, expectedOutput, messages[0])
    }
    
    func init() {
    	cli.MakeKubeFactory = func(k kube.CLIClient) cmdutil.Factory {
    		tf := cmdtesting.NewTestFactory()
    		_, _, codec := cmdtesting.NewExternalScheme()
    		tf.UnstructuredClient = &fake.RESTClient{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 09 12:01:22 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  10. istioctl/pkg/describe/describe.go

    			if len(args) != 1 {
    				return fmt.Errorf("expecting pod name")
    			}
    
    			podName, ns := handlers.InferPodInfo(args[0], ctx.NamespaceOrDefault(""))
    
    			client, err := ctx.CLIClient()
    			if err != nil {
    				return err
    			}
    			pod, err := client.Kube().CoreV1().Pods(ns).Get(context.TODO(), podName, metav1.GetOptions{})
    			if err != nil {
    				return err
    			}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
Back to top