Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 47 for holderIdentity (0.34 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  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))
    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

    }
    
    // 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)
Back to top