- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 126 for Lease (0.14 sec)
-
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) -
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) -
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) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultWorkerLeaseService.java
throw new IllegalStateException("Current thread is already a worker thread"); } DefaultWorkerLease lease = newWorkerLease(); coordinationService.withStateLock(lock(lease)); return lease; } @Override public WorkerLeaseCompletion maybeStartWorker() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 09 04:43:28 UTC 2024 - 20.9K bytes - Viewed (0) -
api/openapi-spec/v3/apis__coordination.k8s.io__v1_openapi.json
{ "components": { "schemas": { "io.k8s.api.coordination.v1.Lease": { "description": "Lease defines a lease concept.", "properties": { "apiVersion": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 136.6K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller_test.go
return &coordv1.Lease{ ObjectMeta: metav1.ObjectMeta{ Name: nodeName, Namespace: v1.NamespaceNodeLease, }, Spec: coordv1.LeaseSpec{ HolderIdentity: pointer.String(nodeName), RenewTime: &renewTime, }, } } func (nc *nodeLifecycleController) syncLeaseStore(lease *coordv1.Lease) error { if lease == nil { return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 03:26:45 UTC 2024 - 119K bytes - Viewed (0) -
plugin/pkg/admission/noderestriction/admission_test.go
}, { name: "allowed create node lease - feature enabled", attributes: admission.NewAttributesRecord(lease, nil, leaseKind, lease.Namespace, lease.Name, leaseResource, "", admission.Create, &metav1.CreateOptions{}, false, mynode), err: "", }, { name: "allowed update node lease - feature enabled",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 73.2K bytes - Viewed (0) -
tests/docker-compose.yml
- MSSQL_DB=gorm - MSSQL_USER=gorm - MSSQL_PASSWORD=LoremIpsum86 tidb: image: 'pingcap/tidb:v6.5.0' ports: - "9940:4000"
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Mon Mar 18 08:28:46 UTC 2024 - 862 bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/operations/MaxWorkersTest.groovy
instant.worker2 > instant.worker1Finished cleanup: workerLeaseService?.stop() } def "BuildOperationWorkerRegistry operations nested in BuildOperationExecutor operations borrow parent lease"() { given: def maxWorkers = 1 def workerLeaseService = this.workerLeaseService(maxWorkers) def processor = createProcessor(workerLeaseService, maxWorkers)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 8.3K bytes - Viewed (0) -
cmd/etcd.go
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)) etcdLogIf(ctx, err) return etcdErrToErr(err, client.Endpoints()) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 2.9K bytes - Viewed (0)