Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for leaseDurationSeconds (0.29 sec)

  1. staging/src/k8s.io/api/coordination/v1/generated.pb.go

    			if err != nil {
    				return 0, err
    			}
    			i -= size
    			i = encodeVarintGenerated(dAtA, i, uint64(size))
    		}
    		i--
    		dAtA[i] = 0x1a
    	}
    	if m.LeaseDurationSeconds != nil {
    		i = encodeVarintGenerated(dAtA, i, uint64(*m.LeaseDurationSeconds))
    		i--
    		dAtA[i] = 0x10
    	}
    	if m.HolderIdentity != nil {
    		i -= len(*m.HolderIdentity)
    		copy(dAtA[i:], *m.HolderIdentity)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 24K bytes
    - Viewed (0)
  2. staging/src/k8s.io/api/coordination/v1beta1/generated.pb.go

    			if err != nil {
    				return 0, err
    			}
    			i -= size
    			i = encodeVarintGenerated(dAtA, i, uint64(size))
    		}
    		i--
    		dAtA[i] = 0x1a
    	}
    	if m.LeaseDurationSeconds != nil {
    		i = encodeVarintGenerated(dAtA, i, uint64(*m.LeaseDurationSeconds))
    		i--
    		dAtA[i] = 0x10
    	}
    	if m.HolderIdentity != nil {
    		i -= len(*m.HolderIdentity)
    		copy(dAtA[i:], *m.HolderIdentity)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  3. pilot/pkg/leaderelection/k8sleaderelection/leaderelection.go

    	if !le.IsLeader() {
    		return true
    	}
    	now := metav1.Now()
    	leaderElectionRecord := k8sresourcelock.LeaderElectionRecord{
    		LeaderTransitions:    le.observedRecord.LeaderTransitions,
    		LeaseDurationSeconds: 1,
    		RenewTime:            now,
    		AcquireTime:          now,
    	}
    	if err := le.config.Lock.Update(context.TODO(), leaderElectionRecord); err != nil {
    		klog.Errorf("Failed to release lock: %v", err)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jul 24 04:04:42 UTC 2023
    - 16.3K bytes
    - Viewed (0)
  4. pilot/pkg/leaderelection/k8sleaderelection/leaderelection_test.go

    }
    
    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()},
    		RenewTime:            &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)
Back to top