Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 453 for ctx_ (0.02 sec)

  1. cni/pkg/repair/repair.go

    	}
    
    	rc, err := NewRepairController(client, cfg)
    	if err != nil {
    		repairLog.Fatalf("Fatal error constructing repair controller: %+v", err)
    	}
    	go rc.Run(ctx.Done())
    	client.RunAndWait(ctx.Done())
    }
    
    // Set up Kubernetes client using kubeconfig (or in-cluster config if no file provided)
    func clientSetup() (kube.Client, error) {
    	config, err := kube.DefaultRestConfig("", "")
    	if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 19:12:54 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  2. istioctl/pkg/analyze/analyze.go

    			// for file resources that don't have one specified.
    			selectedNamespace = ctx.Namespace()
    			if useKube {
    				// apply default namespace if not specified and useKube is true
    				selectedNamespace = ctx.NamespaceOrDefault(selectedNamespace)
    				if selectedNamespace != "" {
    					client, err := ctx.CLIClient()
    					if err != nil {
    						return err
    					}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 31 06:53:50 UTC 2024
    - 17.6K bytes
    - Viewed (0)
  3. internal/logger/config.go

    }
    
    // LookupConfigForSubSys - lookup logger config, override with ENVs if set, for the given sub-system
    func LookupConfigForSubSys(ctx context.Context, scfg config.Config, subSys string) (cfg Config, err error) {
    	switch subSys {
    	case config.LoggerWebhookSubSys:
    		cfg = lookupLegacyConfigForSubSys(ctx, config.LoggerWebhookSubSys)
    		if cfg, err = lookupLoggerWebhookConfig(scfg, cfg); err != nil {
    			return cfg, err
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 20 16:02:50 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  4. prepare_stmt.go

    		if errors.Is(err, driver.ErrBadConn) {
    			db.Mux.Lock()
    			defer db.Mux.Unlock()
    
    			go stmt.Close()
    			delete(db.Stmts, query)
    		}
    	}
    	return rows, err
    }
    
    func (db *PreparedStmtDB) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row {
    	stmt, err := db.prepare(ctx, db.ConnPool, false, query)
    	if err == nil {
    		return stmt.QueryRowContext(ctx, args...)
    	}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  5. istioctl/pkg/multicluster/options.go

    // but it allows us to directly get the final values for each of these flags without needing
    // to pass pointers-to-flags through all of the (sub)commands.
    func (o *KubeOptions) prepare(ctx cli.Context) {
    	o.Namespace = ctx.Namespace()
    	if o.Namespace == "" {
    		o.Namespace = ctx.IstioNamespace()
    
    		configAccess := clientcmd.NewDefaultPathOptions()
    		configAccess.GlobalFile = o.Kubeconfig
    		if config, err := configAccess.GetStartingConfig(); err == nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Aug 01 23:59:49 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/net.go

    	log.Debug("notifying subscribed node proxies")
    	if err := s.sendPodToZtunnelAndWaitForAck(ctx, pod, openNetns); err != nil {
    		return NewErrPartialAdd(err)
    	}
    	return nil
    }
    
    func (s *NetServer) sendPodToZtunnelAndWaitForAck(ctx context.Context, pod *corev1.Pod, netns Netns) error {
    	return s.ztunnelServer.PodAdded(ctx, pod, netns)
    }
    
    // ConstructInitialSnapshot takes a "snapshot" of current ambient pods and
    //
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 21 16:48:55 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/informers_test.go

    	fs := &fakeServer{testWG: wg}
    
    	fs.On("AddPodToMesh",
    		ctx,
    		mock.IsType(pod),
    		util.GetPodIPsIfPresent(pod),
    		"",
    	).Return(nil)
    
    	server := getFakeDP(fs, client.Kube())
    
    	fs.Start(ctx)
    	handlers := setupHandlers(ctx, client, server, "istio-system")
    	client.RunAndWait(ctx.Done())
    	go handlers.Start()
    
    	// label the namespace
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  8. cmd/tier-sweeper.go

    }
    
    type jentry struct {
    	ObjName   string
    	VersionID string
    	TierName  string
    }
    
    func deleteObjectFromRemoteTier(ctx context.Context, objName, rvID, tierName string) error {
    	w, err := globalTierConfigMgr.getDriver(ctx, tierName)
    	if err != nil {
    		return err
    	}
    	return w.Remove(ctx, objName, remoteVersionID(rvID))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 17 05:09:58 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  9. internal/config/lambda/target/webhook.go

    		return errNotConnected
    	}
    
    	return nil
    }
    
    // NewWebhookTarget - creates new Webhook target.
    func NewWebhookTarget(ctx context.Context, id string, args WebhookArgs, loggerOnce logger.LogOnce, transport *http.Transport) (*WebhookTarget, error) {
    	ctx, cancel := context.WithCancel(ctx)
    
    	target := &WebhookTarget{
    		id:         event.TargetID{ID: id, Name: "webhook"},
    		args:       args,
    		loggerOnce: loggerOnce,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 08 21:39:49 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  10. istioctl/pkg/describe/describe.go

    			}
    			return nil
    		},
    		RunE: func(cmd *cobra.Command, args []string) error {
    			describeNamespace = ctx.NamespaceOrDefault(ctx.Namespace())
    			svcName, ns := handlers.InferPodInfo(args[0], ctx.NamespaceOrDefault(ctx.Namespace()))
    
    			client, err := ctx.CLIClient()
    			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