- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for ApOption (0.12 sec)
-
test/typeparam/issue50485.dir/a.go
type ApplicativeFunctor1[H Header[HT], HT, A, R any] struct { h Option[H] fn Option[Func1[A, R]] } func (r ApplicativeFunctor1[H, HT, A, R]) ApOption(a Option[A]) Option[R] { return Ap(r.fn, a) } func (r ApplicativeFunctor1[H, HT, A, R]) Ap(a A) Option[R] { return r.ApOption(Some(a)) } func Applicative1[A, R any](fn Func1[A, R]) ApplicativeFunctor1[Nil, Nil, A, R] {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Dec 14 17:22:18 UTC 2023 - 4.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/latency_tracker.go
startedAt := time.Now() defer func() { endpointsrequest.TrackStorageLatency(ctx, time.Since(startedAt)) }() return c.KV.Put(ctx, key, val, opts...) } func (c *clientV3KVLatencyTracker) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error) { startedAt := time.Now()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 3.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/factory_test.go
} func (mkv mockKV) Put(ctx context.Context, key, val string, opts ...clientv3.OpOption) (*clientv3.PutResponse, error) { return nil, nil } func (mkv mockKV) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error) { return mkv.get(ctx) } func (mockKV) Delete(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.DeleteResponse, error) { return nil, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 29 15:58:10 UTC 2022 - 12.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
preparedKey += "/" } keyPrefix := preparedKey // set the appropriate clientv3 options to filter the returned data set var limitOption *clientv3.OpOption limit := opts.Predicate.Limit var paging bool options := make([]clientv3.OpOption, 0, 4) if opts.Predicate.Limit > 0 { paging = true options = append(options, clientv3.WithLimit(limit)) limitOption = &options[len(options)-1] }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go
// The revision to watch will be set to the revision in response. // All events sent will have isCreated=true func (wc *watchChan) sync() error { opts := []clientv3.OpOption{} if wc.recursive { opts = append(opts, clientv3.WithLimit(defaultWatcherMaxLimit)) rangeEnd := clientv3.GetPrefixRangeEnd(wc.key) opts = append(opts, clientv3.WithRange(rangeEnd)) } var err error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 18.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go
return &etcdClientKVWrapper{ KV: kv, getCallCounter: 0, } } func (ecw *etcdClientKVWrapper) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error) { resp, err := ecw.KV.Get(ctx, key, opts...) ecw.getCallCounter++ if err != nil { return nil, err } if len(ecw.getReactors) > 0 { reactor := ecw.getReactors[0]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 12.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go
} type clientRecorder struct { reads uint64 clientv3.KV } func (r *clientRecorder) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error) { atomic.AddUint64(&r.reads, 1) return r.KV.Get(ctx, key, opts...) } func (r *clientRecorder) GetReadsAndReset() uint64 { return atomic.SwapUint64(&r.reads, 0) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 26.5K bytes - Viewed (0)