Atlas › Test
Test_OK_CancelAt
Exact test identity: go.temporal.io/server/common/quotas/TestMultiReservationSuite/Test_OK_CancelAt
- Package
go.temporal.io/server/common/quotas- Suite / test hierarchy
TestMultiReservationSuite/Test_OK_CancelAt- Test
Test_OK_CancelAt- Introduced at
- multi_reservation_impl.go ×1 Frontier kind: Joint frontier
- Covered ranges
- 8
- Covered lines
- 27
- Covered files
- 2
Covered source
Expand a file to inspect source; the > gutter marks covered lines.
go.temporal.io/server/common/quotas/reservation_mock.go 16 covered LOC · 4 ranges
Open complete file
30
31
// NewMockReservation creates a new mock instance.
33
>
mock := &MockReservation{ctrl: ctrl}
34
>
mock.recorder = &MockReservationMockRecorder{mock}
35
>
return mock
36
>
}
37
38
// EXPECT returns an object that allows the caller to indicate expected use.
40
>
return m.recorder
41
>
}
42
43
// Cancel mocks base method.
54
55
// CancelAt mocks base method.
57
>
m.ctrl.T.Helper()
58
>
m.ctrl.Call(m, "CancelAt", now)
59
>
}
60
61
// CancelAt indicates an expected call of CancelAt.
62
>
func (mr *MockReservationMockRecorder) CancelAt(now any) *gomock.Call {
reservation_mock.go
63
>
mr.mock.ctrl.T.Helper()
64
>
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CancelAt", reflect.TypeOf((*MockReservation)(nil).CancelAt), now)
65
>
}
66
67
// Delay mocks base method.
go.temporal.io/server/common/quotas/multi_reservation_impl.go 11 covered LOC · 4 ranges
Open complete file
17
ok bool,
18
reservations []Reservation,
20
>
if ok && len(reservations) == 0 {
21
panic("expect at least one reservation")
22
}
24
>
ok: ok,
25
>
reservations: reservations,
26
>
}
27
}
28
40
// CancelAt indicates that the reservation holder will not perform the reserved action
41
// and reverses the effects of this Reservation on the rate limit as much as possible
43
>
if !r.ok {
44
return
45
}
46
48
>
reservation.CancelAt(now)
49
>
}
50
}
51