- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 50 for holderIdentity (0.25 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) -
staging/src/k8s.io/client-go/applyconfigurations/coordination/v1/leasespec.go
} // WithHolderIdentity sets the HolderIdentity field in the declarative configuration to the given value // and returns the receiver, so that objects can be built by chaining "With" function invocations. // If called multiple times, the HolderIdentity field is set to the value of the last call. func (b *LeaseSpecApplyConfiguration) WithHolderIdentity(value string) *LeaseSpecApplyConfiguration { b.HolderIdentity = &value return b }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 04 18:31:34 UTC 2021 - 3.5K bytes - Viewed (0) -
staging/src/k8s.io/client-go/applyconfigurations/coordination/v1beta1/leasespec.go
} // WithHolderIdentity sets the HolderIdentity field in the declarative configuration to the given value // and returns the receiver, so that objects can be built by chaining "With" function invocations. // If called multiple times, the HolderIdentity field is set to the value of the last call. func (b *LeaseSpecApplyConfiguration) WithHolderIdentity(value string) *LeaseSpecApplyConfiguration { b.HolderIdentity = &value return b }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 04 18:31:34 UTC 2021 - 3.5K bytes - Viewed (0) -
pkg/apis/coordination/validation/validation_test.go
} } func TestValidateLeaseSpec(t *testing.T) { holder := "holder" leaseDuration := int32(0) leaseTransitions := int32(-1) spec := &coordination.LeaseSpec{ HolderIdentity: &holder, LeaseDurationSeconds: &leaseDuration, LeaseTransitions: &leaseTransitions, } errs := ValidateLeaseSpec(spec, field.NewPath("foo")) if len(errs) != 2 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 02 02:22:52 UTC 2018 - 2.9K 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)