Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 44 for leaseDurationSeconds (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top