- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 263 for Lease (0.1 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)