98
99
// GetDLQAckLevel mocks base method.
100
>
func (m *MockNamespaceReplicationQueue) GetDLQAckLevel(ctx context.Context) (int64, error) {
namespace_replication_queue_mock.go
101
>
m.ctrl.T.Helper()
102
>
ret := m.ctrl.Call(m, "GetDLQAckLevel", ctx)
103
>
ret0, _ := ret[0].(int64)
104
>
ret1, _ := ret[1].(error)
105
>
return ret0, ret1
106
>
}
107
108
// GetDLQAckLevel indicates an expected call of GetDLQAckLevel.
109
>
func (mr *MockNamespaceReplicationQueueMockRecorder) GetDLQAckLevel(ctx any) *gomock.Call {
namespace_replication_queue_mock.go
110
>
mr.mock.ctrl.T.Helper()
111
>
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetDLQAckLevel", reflect.TypeOf((*MockNamespaceReplicationQueue)(nil).GetDLQAckLevel), ctx)
112
>
}
113
114
// GetMessagesFromDLQ mocks base method.