- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 44 for leaseDurationSeconds (0.21 sec)
-
pilot/pkg/leaderelection/k8sleaderelection/k8sresourcelock/leaselock.go
} func LeaderElectionRecordToLeaseSpec(ler *LeaderElectionRecord) coordinationv1.LeaseSpec { leaseDurationSeconds := int32(ler.LeaseDurationSeconds) leaseTransitions := int32(ler.LeaderTransitions) return coordinationv1.LeaseSpec{ HolderIdentity: &ler.HolderIdentity, LeaseDurationSeconds: &leaseDurationSeconds, AcquireTime: &metav1.MicroTime{Time: ler.AcquireTime.Time},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Jun 04 16:02:26 UTC 2022 - 4.3K bytes - Viewed (0) -
pkg/apis/coordination/validation/validation.go
func ValidateLeaseSpec(spec *coordination.LeaseSpec, fldPath *field.Path) field.ErrorList { allErrs := field.ErrorList{} if spec.LeaseDurationSeconds != nil && *spec.LeaseDurationSeconds <= 0 { fld := fldPath.Child("leaseDurationSeconds") allErrs = append(allErrs, field.Invalid(fld, spec.LeaseDurationSeconds, "must be greater than 0")) } if spec.LeaseTransitions != nil && *spec.LeaseTransitions < 0 { fld := fldPath.Child("leaseTransitions")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 03 17:25:43 UTC 2022 - 2K bytes - Viewed (0) -
pkg/controlplane/controller/apiserverleasegc/gc_controller_test.go
"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, }, { name: "expired lease but with a different component label",
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
// leaseDurationSeconds is a duration that candidates for a lease need // to wait to force acquire it. This is measure against time of last // observed renewTime. // +optional LeaseDurationSeconds *int32 `json:"leaseDurationSeconds,omitempty" protobuf:"varint,2,opt,name=leaseDurationSeconds"` // acquireTime is a time when the current lease was acquired. // +optional
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 3K bytes - Viewed (0) -
staging/src/k8s.io/client-go/applyconfigurations/coordination/v1beta1/leasespec.go
// with apply. type LeaseSpecApplyConfiguration struct { HolderIdentity *string `json:"holderIdentity,omitempty"` LeaseDurationSeconds *int32 `json:"leaseDurationSeconds,omitempty"` AcquireTime *v1.MicroTime `json:"acquireTime,omitempty"` RenewTime *v1.MicroTime `json:"renewTime,omitempty"`
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/v1/leasespec.go
// with apply. type LeaseSpecApplyConfiguration struct { HolderIdentity *string `json:"holderIdentity,omitempty"` LeaseDurationSeconds *int32 `json:"leaseDurationSeconds,omitempty"` AcquireTime *v1.MicroTime `json:"acquireTime,omitempty"` RenewTime *v1.MicroTime `json:"renewTime,omitempty"`
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 { t.Errorf("unexpected list of errors: %#v", errs.ToAggregate().Error()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 02 02:22:52 UTC 2018 - 2.9K bytes - Viewed (0) -
staging/src/k8s.io/api/coordination/v1beta1/types.go
// leaseDurationSeconds is a duration that candidates for a lease need // to wait to force acquire it. This is measure against time of last // observed renewTime. // +optional LeaseDurationSeconds *int32 `json:"leaseDurationSeconds,omitempty" protobuf:"varint,2,opt,name=leaseDurationSeconds"` // acquireTime is a time when the current lease was acquired. // +optional
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 16 16:45:58 UTC 2022 - 3.2K 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)) out.RenewTime = (*metav1.MicroTime)(unsafe.Pointer(in.RenewTime))
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
*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 } if in.AcquireTime != nil { in, out := &in.AcquireTime, &out.AcquireTime *out = (*in).DeepCopy() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 3.3K bytes - Viewed (0)