- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,573 for lease (0.05 sec)
-
staging/src/k8s.io/client-go/applyconfigurations/coordination/v1beta1/lease.go
} func extractLease(lease *coordinationv1beta1.Lease, fieldManager string, subresource string) (*LeaseApplyConfiguration, error) { b := &LeaseApplyConfiguration{} err := managedfields.ExtractInto(lease, internal.Parser().Type("io.k8s.api.coordination.v1beta1.Lease"), fieldManager, b, subresource) if err != nil { return nil, err } b.WithName(lease.Name) b.WithNamespace(lease.Namespace)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 23 17:59:55 UTC 2022 - 11.4K bytes - Viewed (0) -
staging/src/k8s.io/client-go/applyconfigurations/coordination/v1/lease.go
} func extractLease(lease *apicoordinationv1.Lease, fieldManager string, subresource string) (*LeaseApplyConfiguration, error) { b := &LeaseApplyConfiguration{} err := managedfields.ExtractInto(lease, internal.Parser().Type("io.k8s.api.coordination.v1.Lease"), fieldManager, b, subresource) if err != nil { return nil, err } b.WithName(lease.Name) b.WithNamespace(lease.Namespace)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 23 17:59:55 UTC 2022 - 11.3K bytes - Viewed (0) -
pkg/controlplane/reconcilers/lease.go
endpointsv1 "k8s.io/kubernetes/pkg/api/v1/endpoints" ) // Leases is an interface which assists in managing the set of active masters type Leases interface { // ListLeases retrieves a list of the current master IPs ListLeases() ([]string, error) // UpdateLease adds or refreshes a master's lease UpdateLease(ip string) error // RemoveLease removes a master's lease RemoveLease(ip string) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 11.3K bytes - Viewed (0) -
pkg/controlplane/apiserver/server.go
func labelAPIServerHeartbeatFunc(identity string, peeraddress string) lease.ProcessLeaseFunc { return func(lease *coordinationapiv1.Lease) error { if lease.Labels == nil { lease.Labels = map[string]string{} } if lease.Annotations == nil { lease.Annotations = map[string]string{} } // This label indiciates the identity of the lease object. lease.Labels[IdentityLeaseComponentLabelKey] = identity
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 19:24:41 UTC 2024 - 11K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller.go
for _, v := range sv.Status.StorageVersions { lease, err := c.kubeclientset.CoordinationV1().Leases(metav1.NamespaceSystem).Get(ctx, v.APIServerID, metav1.GetOptions{}) if err != nil || lease == nil || lease.Labels == nil || lease.Labels[controlplane.IdentityLeaseComponentLabelKey] != controlplane.KubeAPIServer { // We cannot find a corresponding identity lease from apiserver as well. // We need to clean up this storage version.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller_test.go
CommonEncodingVersion: utilpointer.String("v1"), }, } clientset := fake.NewSimpleClientset(lease1, lease2, lease3, storageVersion) _, ctx := ktesting.NewTestContext(t) setupController(ctx, clientset) // Delete the lease object and verify that storage version status is updated if err := clientset.CoordinationV1().Leases(metav1.NamespaceSystem).Delete(context.Background(), "kube-apiserver-1", metav1.DeleteOptions{}); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 12:19:43 UTC 2023 - 12.1K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceWorkerLeaseTest.groovy
assert registry.workerThread def lease = registry.currentWorkerLease def nested = registry.runAsWorkerThread({ assert registry.workerThread assert registry.currentWorkerLease == lease "result" } as Factory) assert registry.workerThread assert registry.currentWorkerLease == lease nested } as Factory
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 13.2K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceProjectLockTest.groovy
def lease = workerLeaseService.newWorkerLease() def projectLock = workerLeaseService.getProjectLock(path("root"), path(":project")) expect: workerLeaseService.withLocks([projectLock, lease]) { assert lockIsHeld(lease) assert lockIsHeld(projectLock) workerLeaseService.blocking { assert !lockIsHeld(lease)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 25.6K bytes - Viewed (0) -
cmd/kube-apiserver/app/options/validation_test.go
}, wantErr: true, }, { name: "lease endpoint reconciler - IPv4 families", extra: Extra{ EndpointReconcilerType: "lease", PrimaryServiceClusterIPRange: *ipv4cidr, }, generic: apiserveroptions.ServerRunOptions{ AdvertiseAddress: ipv4address, }, wantErr: false, }, { name: "lease endpoint reconciler - IPv6 families", extra: Extra{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 11.4K bytes - Viewed (0) -
staging/src/k8s.io/api/coordination/v1/generated.pb.go
const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package func (m *Lease) Reset() { *m = Lease{} } func (*Lease) ProtoMessage() {} func (*Lease) Descriptor() ([]byte, []int) { return fileDescriptor_239d5a4df3139dce, []int{0} } func (m *Lease) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *Lease) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:37 UTC 2024 - 24K bytes - Viewed (0)