- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 150 for newFunc (0.13 sec)
-
pkg/registry/core/service/allocator/storage/storage.go
// persisting the snapshot state of allocation after each allocation is made. func NewEtcd(alloc allocator.Snapshottable, baseKey string, config *storagebackend.ConfigForResource) (*Etcd, error) { // note that newFunc, newListFunc and resourcePrefix // can be left blank unless the storage.Watch method is used storage, d, err := generic.NewRawStorage(config, nil, nil, "") if err != nil { return nil, err } var once sync.Once
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 6.5K bytes - Viewed (0) -
src/go/types/interface.go
var recvTyp Type = ityp if def != nil { if named := asNamed(def.typ); named != nil { recvTyp = named } } sig.recv = NewVar(name.Pos(), check.pkg, "", recvTyp) m := NewFunc(name.Pos(), check.pkg, name.Name, sig) check.recordDef(name, m) ityp.methods = append(ityp.methods, m) } // All methods and embedded elements for this interface are collected;
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 09 17:24:42 UTC 2023 - 8.1K bytes - Viewed (0) -
pkg/config/schema/kubeclient/common.go
}, ) setupInformer(opts, inf) return inf }) } func setupInformer(opts ktypes.InformerOptions, inf cache.SharedIndexInformer) { // It is important to set this in the newFunc rather than after InformerFor to avoid // https://github.com/kubernetes/kubernetes/issues/117869 if opts.ObjectTransform != nil { _ = inf.SetTransform(opts.ObjectTransform) } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 16:38:40 UTC 2024 - 8.1K bytes - Viewed (0) -
src/cmd/compile/internal/types2/universe.go
// error.Error() string recv := NewVar(nopos, nil, "", typ) res := NewVar(nopos, nil, "", Typ[String]) sig := NewSignatureType(recv, nil, nil, nil, NewTuple(res), false) err := NewFunc(nopos, nil, "Error", sig) // interface{ Error() string } ityp := &Interface{methods: []*Func{err}, complete: true} computeInterfaceTypeSet(nil, nopos, ityp) // prevent races due to lazy computation of tset
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 07 20:08:23 UTC 2024 - 9.1K bytes - Viewed (0) -
src/go/types/universe.go
// error.Error() string recv := NewVar(nopos, nil, "", typ) res := NewVar(nopos, nil, "", Typ[String]) sig := NewSignatureType(recv, nil, nil, nil, NewTuple(res), false) err := NewFunc(nopos, nil, "Error", sig) // interface{ Error() string } ityp := &Interface{methods: []*Func{err}, complete: true} computeInterfaceTypeSet(nil, nopos, ityp) // prevent races due to lazy computation of tset
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 07 20:08:23 UTC 2024 - 9.3K bytes - Viewed (0) -
pkg/registry/core/replicationcontroller/storage/storage.go
} // NewREST returns a RESTStorage object that will work against replication controllers. func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, *StatusREST, error) { store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &api.ReplicationController{} }, NewListFunc: func() runtime.Object { return &api.ReplicationControllerList{} },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 12K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/etcd.go
var storage CustomResourceStorage store := &genericregistry.Store{ NewFunc: func() runtime.Object { // set the expected group/version/kind in the new object as a signal to the versioning decoder ret := &unstructured.Unstructured{} ret.SetGroupVersionKind(kind) return ret },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 12.4K bytes - Viewed (0) -
pkg/registry/apps/replicaset/storage/storage.go
*genericregistry.Store } // NewREST returns a RESTStorage object that will work against ReplicaSet. func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, *StatusREST, error) { store := &genericregistry.Store{ NewFunc: func() runtime.Object { return &apps.ReplicaSet{} }, NewListFunc: func() runtime.Object { return &apps.ReplicaSetList{} }, PredicateFunc: replicaset.MatchReplicaSet,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 12.9K bytes - Viewed (0) -
pkg/registry/core/pod/storage/storage.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 20 14:29:25 UTC 2023 - 13.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease.go
func NewPeerEndpointLeaseReconciler(config *storagebackend.ConfigForResource, baseKey string, leaseTime time.Duration) (PeerEndpointLeaseReconciler, error) { // note that newFunc, newListFunc and resourcePrefix // can be left blank unless the storage.Watch method is used leaseStorage, destroyFn, err := storagefactory.Create(*config, nil, nil, "") if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 12.3K bytes - Viewed (0)