556
557
// GetQueueExclusiveHighReadWatermark mocks base method.
558
>
func (m *MockShardContext) GetQueueExclusiveHighReadWatermark(category tasks.Category) tasks.Key {
shard_context_mock.go
559
>
m.ctrl.T.Helper()
560
>
ret := m.ctrl.Call(m, "GetQueueExclusiveHighReadWatermark", category)
561
>
ret0, _ := ret[0].(tasks.Key)
562
>
return ret0
563
>
}
564
565
// GetQueueExclusiveHighReadWatermark indicates an expected call of GetQueueExclusiveHighReadWatermark.
566
>
func (mr *MockShardContextMockRecorder) GetQueueExclusiveHighReadWatermark(category any) *gomock.Call {
shard_context_mock.go
567
>
mr.mock.ctrl.T.Helper()
568
>
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetQueueExclusiveHighReadWatermark", reflect.TypeOf((*MockShardContext)(nil).GetQueueExclusiveHighReadWatermark), category)
569
>
}
570
571
// GetQueueState mocks base method.