Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 263 for Lease (0.1 sec)

  1. staging/src/k8s.io/api/coordination/v1beta1/zz_generated.prerelease-lifecycle.go

    func (in *Lease) APILifecycleDeprecated() (major, minor int) {
    	return 1, 19
    }
    
    // APILifecycleReplacement is an autogenerated function, returning the group, version, and kind that should be used instead of this deprecated type.
    // It is controlled by "k8s:prerelease-lifecycle-gen:replacement=<group>,<version>,<kind>" tags in types.go.
    func (in *Lease) APILifecycleReplacement() schema.GroupVersionKind {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 3.8K bytes
    - Viewed (0)
  2. pkg/controller/storageversiongc/gc_controller_test.go

    	go controller.Run(context.Background())
    	informerFactory.Start(nil)
    }
    
    func newKubeApiserverLease(name, holderIdentity string) *coordinationv1.Lease {
    	return &coordinationv1.Lease{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      name,
    			Namespace: metav1.NamespaceSystem,
    			Labels: map[string]string{
    				"apiserver.kubernetes.io/identity": "kube-apiserver",
    			},
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 07 12:19:43 UTC 2023
    - 12.1K bytes
    - Viewed (0)
  3. api/discovery/apis__coordination.k8s.io__v1.json

    {
      "apiVersion": "v1",
      "groupVersion": "coordination.k8s.io/v1",
      "kind": "APIResourceList",
      "resources": [
        {
          "kind": "Lease",
          "name": "leases",
          "namespaced": true,
          "singularName": "lease",
          "storageVersionHash": "gqkMMb/YqFM=",
          "verbs": [
            "create",
            "delete",
            "deletecollection",
            "get",
            "list",
            "patch",
            "update",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 15 18:18:19 UTC 2023
    - 451 bytes
    - Viewed (0)
  4. subprojects/core/src/test/groovy/org/gradle/internal/operations/DefaultBuildOperationQueueTest.groovy

        WorkerLeaseService workerRegistry
        WorkerLeaseRegistry.WorkerLeaseCompletion lease
    
        void setupQueue(int threads) {
            coordinationService = new DefaultResourceLockCoordinationService()
            workerRegistry = new DefaultWorkerLeaseService(coordinationService, new DefaultWorkerLimits(threads)) {}
            workerRegistry.startProjectExecution(true)
            lease = workerRegistry.startWorker()
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 05 16:29:26 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  5. pilot/pkg/leaderelection/leaderelection.go

    		// Function to use to decide whether this leader should steal the existing lock.
    		// This is disable when perRevision is used, as this enables the Lease. Lease doesn't have a holderKey field to place our key
    		// as holderKey is an Istio specific fork.
    		// While its possible to make it work with Lease as well (via an annotation to store it), we don't ever need prioritized
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 12 16:44:32 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  6. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/WorkerLeaseService.java

         * the new lock is released and the old locks reacquired.
         * If a lock cannot be immediately (re)acquired, the current worker lease will be released and the method will block until the locks are (re)acquired.
         */
        <T> T withReplacedLocks(Collection<? extends ResourceLock> currentLocks, ResourceLock newLock, Factory<T> factory);
    
        /**
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 06:02:18 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  7. subprojects/core/src/main/java/org/gradle/internal/operations/DefaultBuildOperationQueue.java

                // condition where the pending count is 0, but a child worker lease is still held when
                // the parent lease is released.
                completeOperations(
                    // Run while holding worker lease.
                    workerLeases.runAsWorkerThread(() -> {
                        if (allowAccessToProjectState) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jan 31 15:18:20 UTC 2023
    - 10.4K bytes
    - Viewed (0)
  8. plugin/pkg/auth/authorizer/node/node_authorizer_test.go

    		},
    		{
    			name:   "disallowed get lease in namespace other than kube-node-lease - feature enabled",
    			attrs:  authorizer.AttributesRecord{User: node0, ResourceRequest: true, Verb: "get", Resource: "leases", APIGroup: "coordination.k8s.io", Name: "node0", Namespace: "foo"},
    			expect: authorizer.DecisionNoOpinion,
    		},
    		{
    			name:   "disallowed create lease in namespace other than kube-node-lease - feature enabled",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 40.5K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease.go

    	// UpdateLease updates the ip and port of peer servers
    	UpdateLease(serverId string, ip string, endpointPorts []corev1.EndpointPort) error
    	// RemoveEndpoints removes this apiserver's peer endpoint lease.
    	RemoveLease(serverId string) error
    	// Destroy cleans up everything on shutdown.
    	Destroy()
    	// StopReconciling turns any later ReconcileEndpoints call into a noop.
    	StopReconciling()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 12.3K bytes
    - Viewed (0)
  10. pilot/pkg/leaderelection/k8sleaderelection/healthzadaptor.go

    	defer l.pointerLock.Unlock()
    	l.le = le
    }
    
    // NewLeaderHealthzAdaptor creates a basic healthz adaptor to monitor a leader election.
    // timeout determines the time beyond the lease expiry to be allowed for timeout.
    // checks within the timeout period after the lease expires will still return healthy.
    func NewLeaderHealthzAdaptor(timeout time.Duration) *HealthzAdaptor {
    	result := &HealthzAdaptor{
    		timeout: timeout,
    	}
    	return result
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Oct 11 16:58:48 UTC 2021
    - 2.3K bytes
    - Viewed (0)
Back to top