Search Options

Results per page
Sort
Preferred Languages
Advance

Results 311 - 320 of 453 for ctx_ (0.04 sec)

  1. cni/pkg/nodeagent/server_test.go

    }
    
    func (f *fakeServer) AddPodToMesh(ctx context.Context, pod *corev1.Pod, podIPs []netip.Addr, netNs string) error {
    	if f.testWG != nil {
    		defer f.testWG.Done()
    	}
    	args := f.Called(ctx, pod, podIPs, netNs)
    	return args.Error(0)
    }
    
    func (f *fakeServer) RemovePodFromMesh(ctx context.Context, pod *corev1.Pod, isDelete bool) error {
    	if f.testWG != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/informers.go

    	GetActiveAmbientPodSnapshot() []*corev1.Pod
    	Start()
    }
    
    type InformerHandlers struct {
    	ctx             context.Context
    	dataplane       MeshDataplane
    	systemNamespace string
    
    	queue      controllers.Queue
    	pods       kclient.Client[*corev1.Pod]
    	namespaces kclient.Client[*corev1.Namespace]
    }
    
    func setupHandlers(ctx context.Context, kubeClient kube.Client, dataplane MeshDataplane, systemNamespace string) *InformerHandlers {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  3. tests/test_tutorial/test_query_params_str_validations/test_tutorial010.py

                        "input": "nonregexquery",
                        "ctx": {"pattern": "^fixedquery$"},
                    }
                ]
            }
        ) | IsDict(
            # TODO: remove when deprecating Pydantic v1
            {
                "detail": [
                    {
                        "ctx": {"pattern": "^fixedquery$"},
                        "loc": ["query", "item-query"],
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:40:57 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  4. tests/test_tutorial/test_query_params_str_validations/test_tutorial010_an_py310.py

                        "input": "nonregexquery",
                        "ctx": {"pattern": "^fixedquery$"},
                    }
                ]
            }
        ) | IsDict(
            # TODO: remove when deprecating Pydantic v1
            {
                "detail": [
                    {
                        "ctx": {"pattern": "^fixedquery$"},
                        "loc": ["query", "item-query"],
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:40:57 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  5. cmd/endpoint-ellipses.go

    			return fmt.Errorf("all args must have ellipses for pool expansion (%w) args: %s", errInvalidArgument, args)
    		}
    		setArgs, err = GetAllSets(setDriveCount, arg)
    		if err != nil {
    			return err
    		}
    		ctxt.Layout.pools = append(ctxt.Layout.pools, poolDisksLayout{cmdline: arg, layout: setArgs})
    	}
    	return
    }
    
    // CreateServerEndpoints - validates and creates new endpoints from input args, supports
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  6. cmd/grid.go

    var globalLockGridStart = make(chan struct{})
    
    func initGlobalGrid(ctx context.Context, eps EndpointServerPools) error {
    	hosts, local := eps.GridHosts()
    	lookupHost := globalDNSCache.LookupHost
    	g, err := grid.NewManager(ctx, grid.ManagerOptions{
    		// Pass Dialer for websocket grid, make sure we do not
    		// provide any DriveOPTimeout() function, as that is not
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  7. istioctl/pkg/precheck/precheck.go

    		},
    	}
    }
    
    func checkControlPlane(ctx cli.Context) (diag.Messages, error) {
    	cli, err := ctx.CLIClient()
    	if err != nil {
    		return nil, err
    	}
    	msgs := diag.Messages{}
    
    	m, err := checkServerVersion(cli)
    	if err != nil {
    		return nil, err
    	}
    	msgs = append(msgs, m...)
    
    	msgs = append(msgs, checkInstallPermissions(cli, ctx.IstioNamespace())...)
    	gwMsg, err := checkGatewayAPIs(cli)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 02:31:32 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  8. tests/test_tutorial/test_query_params_str_validations/test_tutorial010_an_py39.py

                        "input": "nonregexquery",
                        "ctx": {"pattern": "^fixedquery$"},
                    }
                ]
            }
        ) | IsDict(
            # TODO: remove when deprecating Pydantic v1
            {
                "detail": [
                    {
                        "ctx": {"pattern": "^fixedquery$"},
                        "loc": ["query", "item-query"],
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:40:57 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  9. istioctl/pkg/tag/generate.go

    	UserManaged bool
    }
    
    // Generate generates the manifests for a revision tag pointed the given revision.
    func Generate(ctx context.Context, client kube.Client, opts *GenerateOptions, istioNS string) (string, error) {
    	// abort if there exists a revision with the target tag name
    	revWebhookCollisions, err := GetWebhooksWithRevision(ctx, client.Kube(), opts.Tag)
    	if err != nil {
    		return "", err
    	}
    	if !opts.Generate && !opts.Overwrite &&
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  10. internal/ioutil/ioutil.go

    // the zero value and the context error is returned.
    func WithDeadline[V any](ctx context.Context, timeout time.Duration, work func(ctx context.Context) (result V, err error)) (result V, err error) {
    	ctx, cancel := context.WithTimeout(ctx, timeout)
    	defer cancel()
    
    	c := make(chan ioret[V], 1)
    	go func() {
    		v, err := work(ctx)
    		c <- ioret[V]{val: v, err: err}
    	}()
    
    	select {
    	case v := <-c:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 10.9K bytes
    - Viewed (0)
Back to top