Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for lib_func (1.59 sec)

  1. pkg/kubelet/util/manager/watch_based_manager.go

    		options.FieldSelector = fieldSelector
    		return c.watchObject(namespace, options)
    	}
    	store := c.newStore()
    	reflector := cache.NewReflectorWithOptions(
    		&cache.ListWatch{ListFunc: listFunc, WatchFunc: watchFunc},
    		c.newObject(),
    		store,
    		cache.ReflectorOptions{
    			Name: fmt.Sprintf("object-%q/%q", namespace, name),
    			// Bump default 5m MinWatchTimeout to avoid recreating
    			// watches too often.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go

    		serializer.NewCodecFactory(policySourceTestScheme).UniversalDecoder())
    
    	// Make an informer for our policies and bindings
    
    	policyInformer := cache.NewSharedIndexInformer(
    		&cache.ListWatch{
    			ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
    				return policiesAndBindingsTracker.List(fakePolicyGVR, fakePolicyGVK, "")
    			},
    			WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 19K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_test.go

    			}
    		})
    	}
    }
    
    type testLW struct {
    	ListFunc  func(options metav1.ListOptions) (runtime.Object, error)
    	WatchFunc func(options metav1.ListOptions) (watch.Interface, error)
    }
    
    func (t *testLW) List(options metav1.ListOptions) (runtime.Object, error) {
    	return t.ListFunc(options)
    }
    func (t *testLW) Watch(options metav1.ListOptions) (watch.Interface, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 09:20:10 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  4. src/runtime/netpoll_solaris.go

    //go:linkname libc_port_getn libc_port_getn
    //go:linkname libc_port_alert libc_port_alert
    
    var (
    	libc_port_create,
    	libc_port_associate,
    	libc_port_dissociate,
    	libc_port_getn,
    	libc_port_alert libcFunc
    	netpollWakeSig atomic.Uint32 // used to avoid duplicate calls of netpollBreak
    )
    
    func errno() int32 {
    	return *getg().m.perrno
    }
    
    func port_create() int32 {
    	return int32(sysvicall0(&libc_port_create))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  5. src/runtime/os3_solaris.go

    	libc_sem_post,
    	libc_sem_reltimedwait_np,
    	libc_sem_wait,
    	libc_setitimer,
    	libc_sigaction,
    	libc_sigaltstack,
    	libc_sigprocmask,
    	libc_sysconf,
    	libc_usleep,
    	libc_write,
    	libc_pipe2 libcFunc
    )
    
    var sigset_all = sigset{[4]uint32{^uint32(0), ^uint32(0), ^uint32(0), ^uint32(0)}}
    
    func getPageSize() uintptr {
    	n := int32(sysconf(__SC_PAGESIZE))
    	if n <= 0 {
    		return 0
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 17.6K bytes
    - Viewed (0)
  6. cmd/kube-proxy/app/server_linux.go

    	ctx, cancelFunc := context.WithTimeout(ctx, timeoutForNodePodCIDR)
    	defer cancelFunc()
    
    	fieldSelector := fields.OneTermEqualSelector("metadata.name", nodeName).String()
    	lw := &cache.ListWatch{
    		ListFunc: func(options metav1.ListOptions) (object runtime.Object, e error) {
    			options.FieldSelector = fieldSelector
    			return client.CoreV1().Nodes().List(ctx, options)
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 18.1K bytes
    - Viewed (0)
  7. src/syscall/zsyscall_aix_ppc64.go

    //go:linkname libc_write libc_write
    //go:linkname libc_writev libc_writev
    //go:linkname libc_gettimeofday libc_gettimeofday
    //go:linkname libc_mmap libc_mmap
    //go:linkname libc_munmap libc_munmap
    
    type libcFunc uintptr
    
    var (
    	libc_fcntl,
    	libc_Dup2,
    	libc_pipe,
    	libc_readlink,
    	libc_utimes,
    	libc_utimensat,
    	libc_unlinkat,
    	libc_getcwd,
    	libc_getgroups,
    	libc_setgroups,
    	libc_getdirent,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 13:50:55 UTC 2024
    - 41.7K bytes
    - Viewed (0)
  8. pkg/config/schema/kubeclient/resources.gen.go

    		}
    	default:
    		panic(fmt.Sprintf("Unknown type %v", g))
    	}
    	return c.Informers().InformerFor(g, opts, func() cache.SharedIndexInformer {
    		inf := cache.NewSharedIndexInformer(
    			&cache.ListWatch{
    				ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
    					options.FieldSelector = opts.FieldSelector
    					options.LabelSelector = opts.LabelSelector
    					return l(options)
    				},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 13:57:51 UTC 2024
    - 31.1K bytes
    - Viewed (0)
Back to top