Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 57 for lib_func (0.21 sec)

  1. staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/cr/v1/example.go

    	return cache.NewSharedIndexInformer(
    		&cache.ListWatch{
    			ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
    				if tweakListOptions != nil {
    					tweakListOptions(&options)
    				}
    				return client.CrV1().Examples(namespace).List(context.TODO(), options)
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 08 02:16:47 UTC 2020
    - 3.5K bytes
    - Viewed (0)
  2. src/runtime/netpoll_aix.go

    // It's also based on Solaris implementation for the arming mechanisms
    
    //go:cgo_import_dynamic libc_poll poll "libc.a/shr_64.o"
    //go:linkname libc_poll libc_poll
    
    var libc_poll libFunc
    
    //go:nosplit
    func poll(pfds *pollfd, npfds uintptr, timeout uintptr) (int32, int32) {
    	r, err := syscall3(&libc_poll, uintptr(unsafe.Pointer(pfds)), npfds, timeout)
    	return int32(r), int32(err)
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  3. pkg/config/schema/codegen/templates/clients.go.tmpl

    {{- end }}
      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
    - 3.8K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/quota/v1/generic/evaluator.go

    	listFunc ListFuncByNamespace,
    	scopeFunc MatchesScopeFunc,
    	usageFunc UsageFunc) (quota.UsageStats, error) {
    	// default each tracked resource to zero
    	result := quota.UsageStats{Used: corev1.ResourceList{}}
    	for _, resourceName := range options.Resources {
    		result.Used[resourceName] = resource.Quantity{Format: resource.DecimalSI}
    	}
    	items, err := listFunc(options.Namespace)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 05 00:02:47 UTC 2023
    - 11.7K bytes
    - Viewed (0)
  5. src/runtime/syscall_aix.go

    var (
    	libc_chdir,
    	libc_chroot,
    	libc_dup2,
    	libc_execve,
    	libc_fcntl,
    	libc_fork,
    	libc_ioctl,
    	libc_setgid,
    	libc_setgroups,
    	libc_setrlimit,
    	libc_setsid,
    	libc_setuid,
    	libc_setpgid libFunc
    )
    
    // In syscall_syscall6 and syscall_rawsyscall6, r2 is always 0
    // as it's never used on AIX
    // TODO: remove r2 from zsyscall_aix_$GOARCH.go
    
    // Syscall is needed because some packages (like net) need it too.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Dec 14 17:22:18 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  6. staging/src/k8s.io/cli-runtime/pkg/resource/helper.go

    // should include a non-zero Limit parameter.
    func FollowContinue(initialOpts *metav1.ListOptions,
    	listFunc func(metav1.ListOptions) (runtime.Object, error)) error {
    	opts := initialOpts
    	for {
    		list, err := listFunc(*opts)
    		if err != nil {
    			return err
    		}
    		nextContinueToken, _ := metadataAccessor.Continue(list)
    		if len(nextContinueToken) == 0 {
    			return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 26 03:45:13 UTC 2022
    - 10.5K bytes
    - Viewed (0)
  7. src/runtime/syscall_solaris.go

    	libc_forkx,
    	libc_gethostname,
    	libc_getpid,
    	libc_ioctl,
    	libc_setgid,
    	libc_setgroups,
    	libc_setrlimit,
    	libc_setsid,
    	libc_setuid,
    	libc_setpgid,
    	libc_syscall,
    	libc_issetugid,
    	libc_wait4 libcFunc
    )
    
    // Many of these are exported via linkname to assembly in the syscall
    // package.
    
    //go:nosplit
    //go:linkname syscall_sysvicall6
    //go:cgo_unsafe_args
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 06 18:49:01 UTC 2023
    - 8.4K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top