- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 232 for Ttl (0.03 sec)
-
staging/src/k8s.io/apiserver/pkg/apis/example/fuzzer/fuzzer.go
return []interface{}{ func(s *example.PodSpec, c fuzz.Continue) { c.FuzzNoCustom(s) // has a default value ttl := int64(30) if c.RandBool() { ttl = int64(c.Uint32()) } s.TerminationGracePeriodSeconds = &ttl if s.SchedulerName == "" { s.SchedulerName = "default-scheduler" } }, func(j *example.PodPhase, c fuzz.Continue) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 01 19:31:12 UTC 2018 - 3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/testapigroup/fuzzer/fuzzer.go
return []interface{}{ func(s *testapigroup.CarpSpec, c fuzz.Continue) { c.FuzzNoCustom(s) // has a default value ttl := int64(30) if c.RandBool() { ttl = int64(c.Uint32()) } s.TerminationGracePeriodSeconds = &ttl if s.SchedulerName == "" { s.SchedulerName = "default-scheduler" } }, func(j *testapigroup.CarpPhase, c fuzz.Continue) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 01 19:31:12 UTC 2018 - 3.1K bytes - Viewed (0) -
pkg/kubelet/util/cache/object_cache_test.go
) type testObject struct { key string val string } // A fake objectCache for unit test. func NewFakeObjectCache(f func() (interface{}, error), ttl time.Duration, clock clock.Clock) *ObjectCache { ttlPolicy := &expirationcache.TTLPolicy{TTL: ttl, Clock: clock} deleteChan := make(chan string, 1) return &ObjectCache{ updater: f,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 17 13:19:08 UTC 2021 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/token/cache/cache_striped.go
} func (c *stripedCache) get(key string) (*cacheRecord, bool) { return c.caches[c.hashFunc(key)%c.stripeCount].get(key) } func (c *stripedCache) set(key string, value *cacheRecord, ttl time.Duration) { c.caches[c.hashFunc(key)%c.stripeCount].set(key, value, ttl) } func (c *stripedCache) remove(key string) { c.caches[c.hashFunc(key)%c.stripeCount].remove(key) } func fnvHashFunc(key string) uint32 { f := fnv.New32()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 22 17:16:59 UTC 2018 - 1.6K bytes - Viewed (0) -
pkg/controlplane/apiserver/peer.go
ttl := DefaultPeerEndpointReconcilerTTL config, err := storageFactory.NewConfig(api.Resource("apiServerPeerIPInfo")) if err != nil { return nil, fmt.Errorf("error creating storage factory config: %w", err) } reconciler, err := reconcilers.NewPeerEndpointLeaseReconciler(config, "/peerserverleases/", ttl) return reconciler, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 08:15:02 UTC 2024 - 3.9K bytes - Viewed (0) -
cmd/etcd.go
} } func saveKeyEtcdWithTTL(ctx context.Context, client *etcd.Client, key string, data []byte, ttl int64) error { timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout) defer cancel() lease, err := client.Grant(timeoutCtx, ttl) if err != nil { return etcdErrToErr(err, client.Endpoints()) } _, err = client.Put(timeoutCtx, key, string(data), etcd.WithLease(lease.ID))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 2.9K bytes - Viewed (0) -
security/pkg/server/ca/server.go
} serverCaLog.Debugf("generating a certificate, sans: %v, requested ttl: %s", sans, time.Duration(request.ValidityDuration*int64(time.Second))) certSigner := crMetadata[security.CertSigner].GetStringValue() _, _, certChainBytes, rootCertBytes := s.ca.GetCAKeyCertBundle().GetAll() certOpts := ca.CertOpts{ SubjectIDs: sans, TTL: time.Duration(request.ValidityDuration) * time.Second, ForCA: false,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 17:35:26 UTC 2024 - 8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/cache/lruexpirecache.go
func (c *LRUExpireCache) Add(key interface{}, value interface{}, ttl time.Duration) { c.lock.Lock() defer c.lock.Unlock() // Key already exists oldElement, ok := c.entries[key] if ok { c.evictionList.MoveToFront(oldElement) oldElement.Value.(*cacheEntry).value = value oldElement.Value.(*cacheEntry).expireTime = c.clock.Now().Add(ttl) return } // Make space if necessary
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 4.3K bytes - Viewed (0) -
src/main/java/jcifs/internal/dfs/DfsReferralDataImpl.java
+ ",path=" + this.path + ",ttl=" + this.ttl + ",expiration=" + this.expiration + ",remain=" + ( this.expiration - System.currentTimeMillis() ) + "]"; } /** * @return the ttl */ public long getTtl () { return this.ttl; } /** * {@inheritDoc} *
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sat Nov 13 15:13:49 UTC 2021 - 11K bytes - Viewed (0) -
cmd/kubeadm/app/apis/bootstraptoken/v1/defaults.go
) // SetDefaults_BootstrapToken sets the defaults for an individual Bootstrap Token func SetDefaults_BootstrapToken(bt *BootstrapToken) { if bt.TTL == nil { bt.TTL = &metav1.Duration{ Duration: DefaultTokenDuration, } } if len(bt.Usages) == 0 { bt.Usages = DefaultTokenUsages } if len(bt.Groups) == 0 { bt.Groups = DefaultTokenGroups }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 21 10:34:21 UTC 2023 - 1.5K bytes - Viewed (0)