Skip to content

Commit 82640fe

Browse files
committed
Report availableIn as seconds in stagger plugin
1 parent d7f4964 commit 82640fe

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

plugin/impl/stagger.go

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ func (s *Stagger) ID() string {
7272
// Check asserts that since the last successful check is a certain time has passed.
7373
func (s *Stagger) Check(params plugin.Parameters) (plugin.CheckResult, error) {
7474
s.grabIndex = noGrab
75-
availableIn := make([]time.Duration, 0)
75+
availableIn := make([]float64, 0)
7676
for i := range s.Parallel {
7777
lease, err := s.getOrCreateLease(i, &params)
7878
if err != nil {
@@ -83,9 +83,10 @@ func (s *Stagger) Check(params plugin.Parameters) (plugin.CheckResult, error) {
8383
s.grabIndex = i
8484
return plugin.Passed(nil), nil
8585
}
86-
availableIn = append(availableIn, leaseDuration-time.Since(lease.Spec.RenewTime.Time))
86+
remaining := leaseDuration - time.Since(lease.Spec.RenewTime.Time)
87+
availableIn = append(availableIn, remaining.Seconds())
8788
}
88-
return plugin.Failed(map[string]any{"availableIn": availableIn}), nil
89+
return plugin.Failed(map[string]any{"availableInSec": availableIn}), nil
8990
}
9091

9192
func (s *Stagger) getOrCreateLease(idx int, params *plugin.Parameters) (coordinationv1.Lease, error) {

0 commit comments

Comments
 (0)