(instanceID string)
| 66 | } |
| 67 | |
| 68 | func (r *RingMock) GetInstanceState(instanceID string) (InstanceState, error) { |
| 69 | args := r.Called(instanceID) |
| 70 | return args.Get(0).(InstanceState), args.Error(1) |
| 71 | } |
| 72 | |
| 73 | func (r *RingMock) ShuffleShardWithLookback(identifier string, size int, lookbackPeriod time.Duration, now time.Time) ReadRing { |
| 74 | args := r.Called(identifier, size, lookbackPeriod, now) |