- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 3,918 for lease (0.04 sec)
-
pkg/registry/coordination/lease/doc.go
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 27 11:30:13 UTC 2018 - 585 bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/SharedResourceLeaseRegistry.java
this.coordinationService = coordinationService; } public void registerSharedResource(String name, int leases) { sharedResources.put(name, new LeaseHolder(leases)); } public ResourceLock getResourceLock(final String sharedResource) { String displayName = "lease for " + sharedResource; return new DefaultLease(displayName, coordinationService, this, sharedResources.get(sharedResource)); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 1.5K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/plan/DefaultPlanExecutor.java
stats.startWaitingForNextItem(); // Release worker lease while waiting workerLease.unlock(); return RETRY; } // Have a worker lease and work may be available WorkSource.Selection<WorkItem> workItem; try {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 29.1K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ProjectLeaseRegistry.java
/** * Releases any project state locks or task execution locks currently held by this thread, allowing the current * thread to run as if it were executing an isolated task. * * Does not release worker lease. */ void runAsIsolatedTask(); /** * Returns {@code true} when this registry grants multiple threads access to projects (but no more than one thread per given project)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 5.4K bytes - Viewed (0) -
pkg/controlplane/reconcilers/doc.go
See the License for the specific language governing permissions and limitations under the License. */ // Package reconcilers provides objects for managing the list of active masters. // NOTE: The Lease reconciler is not the intended way for any apiserver other // than kube-apiserver to accomplish the task of Endpoint registration. This is // a special case for the time being.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 02 17:48:26 UTC 2020 - 868 bytes - Viewed (0) -
internal/config/etcd/etcd.go
} cli, err := clientv3.New(cfg.Config) if err != nil { return nil, err } cli.KV = namespace.NewKV(cli.KV, cfg.PathPrefix) cli.Watcher = namespace.NewWatcher(cli.Watcher, cfg.PathPrefix) cli.Lease = namespace.NewLease(cli.Lease, cfg.PathPrefix) return cli, nil } func parseEndpoints(endpoints string) ([]string, bool, error) { etcdEndpoints := strings.Split(endpoints, config.ValueSeparator) var etcdSecure bool
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.8K bytes - Viewed (0) -
staging/src/k8s.io/api/coordination/v1beta1/register.go
AddToScheme = localSchemeBuilder.AddToScheme ) // Adds the list of known types to api.Scheme. func addKnownTypes(scheme *runtime.Scheme) error { scheme.AddKnownTypes(SchemeGroupVersion, &Lease{}, &LeaseList{}, ) metav1.AddToGroupVersion(scheme, SchemeGroupVersion) return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 27 11:30:13 UTC 2018 - 1.7K bytes - Viewed (0) -
pkg/config/schema/kubetypes/resources.gen.go
return gvk.Ingress, true case *k8sioapinetworkingv1.IngressClass: return gvk.IngressClass, true case *sigsk8siogatewayapiapisv1beta1.Gateway: return gvk.KubernetesGateway, true case *k8sioapicoordinationv1.Lease: return gvk.Lease, true case *istioioapimeshv1alpha1.MeshConfig: return gvk.MeshConfig, true case *istioioapimeshv1alpha1.MeshNetworks: return gvk.MeshNetworks, true
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 16:38:40 UTC 2024 - 6.2K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/ConditionalExecutionQueue.java
import org.gradle.internal.concurrent.Stoppable; /** * Represents a queue of executions that can run when a provided resource lock can be acquired. The typical use case would * be that a worker lease must be acquired before execution. */ public interface ConditionalExecutionQueue<T> extends Stoppable { /** * Submit a new conditional execution to the queue. The execution will occur asynchronously when the provided
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 1.5K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/plan/WorkSource.java
formatter.endChildren(); } } /** * Returns the current execution state of this plan. * * <p>Note: the caller does not need to hold a worker lease to call this method.</p> * * <p>The implementation of this method may prefer to return {@link State#MaybeWorkReadyToStart} in certain cases, to limit
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun Nov 13 20:53:27 UTC 2022 - 7.5K bytes - Viewed (0)