Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 232 for Ttl (0.09 sec)

  1. pkg/controller/bootstrap/tokencleaner.go

    		if err != nil && !apierrors.IsConflict(err) && !apierrors.IsNotFound(err) {
    			logger.V(3).Info("Error deleting secret", "err", err)
    		}
    	} else if ttl > 0 {
    		key, err := controller.KeyFunc(o)
    		if err != nil {
    			utilruntime.HandleError(err)
    			return
    		}
    		tc.queue.AddAfter(key, ttl)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  2. cluster/addons/dns/nodelocaldns/README.md

      policyTypes:
      - Ingress
      - Egress
    ```
    
    ### Negative caching
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 31 14:16:53 UTC 2022
    - 3K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease.go

    	c.lock.Lock()
    	defer c.lock.Unlock()
    
    	// Refresh the TTL on our key, independently of whether any error or
    	// update conflict happens below. This makes sure that at least some of
    	// the servers will add our endpoint lease.
    	if err := c.reconciler.UpdateLease(c.serverId, host, endpointPorts); err != nil {
    		return err
    	}
    	return nil
    }
    
    // UpdateLease resets the TTL on a server IP in storage
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 12.3K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/dryrun_test.go

    	s, destroy := NewDryRunnableTestStorage(t)
    	defer destroy()
    
    	obj := UnstructuredOrDie(`{"kind": "Pod"}`)
    
    	updateFunc := func(input runtime.Object, res storage.ResponseMeta) (output runtime.Object, ttl *uint64, err error) {
    		return input, nil, errors.New("UpdateFunction shouldn't be called")
    	}
    
    	err := s.GuaranteedUpdate(context.Background(), "key", obj, false, nil, updateFunc, true, nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 9.9K bytes
    - Viewed (0)
  5. pkg/controlplane/apiserver/options/options_test.go

    		"--audit-webhook-version=audit.k8s.io/v1",
    		"--authentication-token-webhook-cache-ttl=3m",
    		"--authentication-token-webhook-config-file=/token-webhook-config",
    		"--authorization-mode=AlwaysDeny,RBAC",
    		"--authorization-policy-file=/policy",
    		"--authorization-webhook-cache-authorized-ttl=3m",
    		"--authorization-webhook-cache-unauthorized-ttl=1m",
    		"--authorization-webhook-config-file=/webhook-config",
    		"--bind-address=192.168.10.20",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:57:37 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/storage/interfaces.go

    // database and to improve testability.
    type ResponseMeta struct {
    	// TTL is the time to live of the node that contained the returned object. It may be
    	// zero or negative in some cases (objects may be expired after the requested
    	// expiration time due to server lag).
    	TTL int64
    	// The resource version of the node that contained the returned object.
    	ResourceVersion uint64
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 07:53:48 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  7. tests/testdata/config/destination-rule-all.yaml

            version: v1
        - name: v2
          labels:
            version: v2
          trafficPolicy:
            loadBalancer:
              consistentHash:
                httpCookie:
                  name: Cookie
                  ttl: 30s
                minimumRingSize: 42
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 26 15:06:45 UTC 2020
    - 1.3K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apimachinery/pkg/util/cache/expiring_test.go

    	}
    
    	c.Set("a", "a", time.Second)
    
    	fc.Step(500 * time.Millisecond)
    	if _, ok := c.Get("a"); !ok {
    		t.Fatalf("we should have found a key")
    	}
    
    	// reset should restart the ttl
    	c.Set("a", "a", time.Second)
    
    	fc.Step(750 * time.Millisecond)
    	if _, ok := c.Get("a"); !ok {
    		t.Fatalf("we should have found a key")
    	}
    
    	// Simulate a race between a reset and cleanup. Assert that del doesn't
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 22 15:51:23 UTC 2023
    - 7.3K bytes
    - Viewed (0)
  9. cmd/kubeadm/app/apis/output/fuzzer/fuzzer.go

    }
    
    func fuzzBootstrapToken(obj *output.BootstrapToken, c fuzz.Continue) {
    	c.FuzzNoCustom(obj)
    
    	obj.Token = &bootstraptokenv1.BootstrapTokenString{ID: "uvxdac", Secret: "fq35fuyue3kd4gda"}
    	obj.Description = ""
    	obj.TTL = &metav1.Duration{Duration: time.Hour * 24}
    	obj.Usages = []string{"authentication", "signing"}
    	obj.Groups = []string{constants.NodeBootstrapTokenAuthGroup}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 07:01:20 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  10. pkg/kubeapiserver/options/authorization_test.go

    		"--authorization-policy-file=policy_file.json",
    		"--authorization-webhook-config-file=webhook_config_file.yaml",
    		"--authorization-webhook-version=v1",
    		"--authorization-webhook-cache-authorized-ttl=60s",
    		"--authorization-webhook-cache-unauthorized-ttl=30s",
    	}
    
    	expected := &BuiltInAuthorizationOptions{
    		Modes:                       []string{modes.ModeAlwaysAllow, modes.ModeAlwaysDeny, modes.ModeABAC, modes.ModeWebhook},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 18 06:28:47 UTC 2023
    - 6.4K bytes
    - Viewed (0)
Back to top