Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 15 of 15 for Sanders (0.14 sec)

  1. istioctl/pkg/cli/context.go

    	if err != nil {
    		return "", "", err
    	}
    	return handlers.InferPodInfoFromTypedResource(name, i.NamespaceOrDefault(namespace), MakeKubeFactory(client))
    }
    
    func (i *instance) InferPodsFromTypedResource(name, namespace string) ([]string, string, error) {
    	client, err := i.CLIClient()
    	if err != nil {
    		return nil, "", err
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 02 08:32:06 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/cni-watcher.go

    }
    
    type CniPluginServer struct {
    	cniListenServer       *http.Server
    	cniListenServerCancel context.CancelFunc
    	handlers              K8sHandlers
    	dataplane             MeshDataplane
    
    	sockAddress string
    	ctx         context.Context
    }
    
    func startCniPluginServer(ctx context.Context, pluginSocket string,
    	handlers K8sHandlers,
    	dataplane MeshDataplane,
    ) *CniPluginServer {
    	ctx, cancel := context.WithCancel(ctx)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Feb 08 18:52:24 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/cni-watcher_test.go

    	).Return(nil)
    
    	dpServer := &meshDataplane{
    		kubeClient: client.Kube(),
    		netServer:  fs,
    	}
    
    	handlers := setupHandlers(ctx, client, dpServer, "istio-system")
    
    	// We are not going to start the server, so the sockpath is irrelevant
    	pluginServer := startCniPluginServer(ctx, "/tmp/test.sock", handlers, dpServer)
    
    	// label the namespace
    	labelsPatch := []byte(fmt.Sprintf(`{"metadata":{"labels":{"%s":"%s"}}}`,
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu May 02 21:29:40 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  4. architecture/networking/controllers.md

    Construction should create informers (via `kclient.New`), setup a queue (via `controllers.NewQueue`), and register event handlers on the informers.
    Often, these handlers are adding something to the queue like `client.AddEventHandler(controllers.ObjectHandler(queue.AddObject))`.
    Construction should NOT actually start running all of these things, do I/O, or block in anyway.
    
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Feb 09 17:41:25 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  5. istioctl/pkg/tag/generate.go

    	if err := client.ApplyYAMLContents(ns, manifests); err != nil {
    		return fmt.Errorf("failed to apply tag manifests to cluster: %v", err)
    	}
    	return nil
    }
    
    // generateValidatingWebhook renders a validating webhook configuration from the given tagWebhookConfig.
    func generateValidatingWebhook(config *tagWebhookConfig, opts *GenerateOptions) (string, error) {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Jan 16 17:43:49 GMT 2024
    - 13.2K bytes
    - Viewed (0)
Back to top