Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for renewTime (0.15 sec)

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

    			postIndex := iNdEx + msglen
    			if postIndex < 0 {
    				return ErrInvalidLengthGenerated
    			}
    			if postIndex > l {
    				return io.ErrUnexpectedEOF
    			}
    			if m.RenewTime == nil {
    				m.RenewTime = &v1.MicroTime{}
    			}
    			if err := m.RenewTime.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
    				return err
    			}
    			iNdEx = postIndex
    		case 5:
    			if wireType != 0 {
    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

    			postIndex := iNdEx + msglen
    			if postIndex < 0 {
    				return ErrInvalidLengthGenerated
    			}
    			if postIndex > l {
    				return io.ErrUnexpectedEOF
    			}
    			if m.RenewTime == nil {
    				m.RenewTime = &v1.MicroTime{}
    			}
    			if err := m.RenewTime.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
    				return err
    			}
    			iNdEx = postIndex
    		case 5:
    			if wireType != 0 {
    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_test.go

    				t.Errorf("unexpected result of tryAcquireOrRenew: [succeeded=%v]", !test.expectSuccess)
    			}
    
    			le.observedRecord.AcquireTime = metav1.Time{}
    			le.observedRecord.RenewTime = metav1.Time{}
    			if le.observedRecord.HolderIdentity != test.outHolder {
    				t.Errorf("expected holder:\n\t%+v\ngot:\n\t%+v", test.outHolder, le.observedRecord.HolderIdentity)
    			}
    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/leaderelection.go

    		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)
    		return false
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jul 24 04:04:42 UTC 2023
    - 16.3K bytes
    - Viewed (0)
Back to top