- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 47 for holderIdentity (0.34 sec)
-
pkg/controlplane/controller/apiserverleasegc/gc_controller_test.go
Namespace: metav1.NamespaceSystem, Labels: map[string]string{ "apiserver.kubernetes.io/identity": "kube-apiserver", }, }, Spec: coordinationv1.LeaseSpec{ HolderIdentity: pointer.StringPtr("kube-apiserver-12345"), LeaseDurationSeconds: pointer.Int32Ptr(10), RenewTime: &metav1.MicroTime{Time: fakeClock.Now()}, }, }, expectDeleted: false, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 13 20:37:22 UTC 2023 - 4.7K bytes - Viewed (0) -
staging/src/k8s.io/api/coordination/v1/types.go
} // LeaseSpec is a specification of a Lease. type LeaseSpec struct { // holderIdentity contains the identity of the holder of a current lease. // +optional HolderIdentity *string `json:"holderIdentity,omitempty" protobuf:"bytes,1,opt,name=holderIdentity"` // leaseDurationSeconds is a duration that candidates for a lease need // to wait to force acquire it. This is measure against time of last
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 3K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection_test.go
testTryAcquireOrRenew(t, "leases") } func TestLeaseSpecToLeaderElectionRecordRoundTrip(t *testing.T) { holderIdentity := "foo" leaseDurationSeconds := int32(10) leaseTransitions := int32(1) oldSpec := coordinationv1.LeaseSpec{ HolderIdentity: &holderIdentity, LeaseDurationSeconds: &leaseDurationSeconds, AcquireTime: &metav1.MicroTime{Time: time.Now()},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jan 23 16:39:43 UTC 2023 - 42.5K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/k8sresourcelock/leaselock.go
return ll.LockConfig.Key } func LeaseSpecToLeaderElectionRecord(spec *coordinationv1.LeaseSpec) *LeaderElectionRecord { var r LeaderElectionRecord if spec.HolderIdentity != nil { r.HolderIdentity = *spec.HolderIdentity } if spec.LeaseDurationSeconds != nil { r.LeaseDurationSeconds = int(*spec.LeaseDurationSeconds) } if spec.LeaseTransitions != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Jun 04 16:02:26 UTC 2022 - 4.3K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/healthzadaptor_test.go
config: LeaderElectionConfig{ Lock: &fakeLock{identity: "healthTest"}, LeaseDuration: time.Minute, Name: "foo", }, observedRecord: rl.LeaderElectionRecord{ HolderIdentity: "healthTest", }, observedTime: current, clock: clock.NewFakeClock(current.Add(time.Hour)), }, }, {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Sep 12 18:41:53 UTC 2022 - 5.3K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/k8sresourcelock/multilock.go
if err != nil { // Lock is held by old client if kerrors.IsNotFound(err) && primary.HolderIdentity != ml.Identity() { return primary, primaryRaw, nil } return nil, nil, err } if primary.HolderIdentity != secondary.HolderIdentity { primary.HolderIdentity = UnknownLeader primaryRaw, err = json.Marshal(primary) if err != nil { return nil, nil, err } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 03 08:41:32 UTC 2022 - 2.9K bytes - Viewed (0) -
staging/src/k8s.io/api/coordination/v1beta1/types.go
} // LeaseSpec is a specification of a Lease. type LeaseSpec struct { // holderIdentity contains the identity of the holder of a current lease. // +optional HolderIdentity *string `json:"holderIdentity,omitempty" protobuf:"bytes,1,opt,name=holderIdentity"` // leaseDurationSeconds is a duration that candidates for a lease need // to wait to force acquire it. This is measure against time of last
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 16 16:45:58 UTC 2022 - 3.2K bytes - Viewed (0) -
staging/src/k8s.io/api/coordination/v1/generated.proto
// items is a list of schema objects. repeated Lease items = 2; } // LeaseSpec is a specification of a Lease. message LeaseSpec { // holderIdentity contains the identity of the holder of a current lease. // +optional optional string holderIdentity = 1; // leaseDurationSeconds is a duration that candidates for a lease need // to wait to force acquire it. This is measure against time of last
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 28 15:34:11 UTC 2024 - 2.7K bytes - Viewed (0) -
pkg/apis/coordination/v1/zz_generated.conversion.go
} func autoConvert_v1_LeaseSpec_To_coordination_LeaseSpec(in *v1.LeaseSpec, out *coordination.LeaseSpec, s conversion.Scope) error { out.HolderIdentity = (*string)(unsafe.Pointer(in.HolderIdentity)) out.LeaseDurationSeconds = (*int32)(unsafe.Pointer(in.LeaseDurationSeconds)) out.AcquireTime = (*metav1.MicroTime)(unsafe.Pointer(in.AcquireTime))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 6.5K bytes - Viewed (0) -
pkg/apis/coordination/zz_generated.deepcopy.go
} // DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. func (in *LeaseSpec) DeepCopyInto(out *LeaseSpec) { *out = *in if in.HolderIdentity != nil { in, out := &in.HolderIdentity, &out.HolderIdentity *out = new(string) **out = **in } if in.LeaseDurationSeconds != nil { in, out := &in.LeaseDurationSeconds, &out.LeaseDurationSeconds *out = new(int32) **out = **in
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 3.3K bytes - Viewed (0)