77
78
// DeleteMessagesBefore indicates an expected call of DeleteMessagesBefore.
79
>
func (mr *MockNamespaceReplicationQueueMockRecorder) DeleteMessagesBefore(ctx, exclusiveMessageID any) *gomock.Call {
namespace_replication_queue_mock.go
80
>
mr.mock.ctrl.T.Helper()
81
>
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteMessagesBefore", reflect.TypeOf((*MockNamespaceReplicationQueue)(nil).DeleteMessagesBefore), ctx, exclusiveMessageID)
82
>
}
83
84
// GetAckLevels mocks base method.
85
>
func (m *MockNamespaceReplicationQueue) GetAckLevels(ctx context.Context) (map[string]int64, error) {
namespace_replication_queue_mock.go
86
>
m.ctrl.T.Helper()
87
>
ret := m.ctrl.Call(m, "GetAckLevels", ctx)
88
>
ret0, _ := ret[0].(map[string]int64)
89
>
ret1, _ := ret[1].(error)
90
>
return ret0, ret1
91
>
}
92
93
// GetAckLevels indicates an expected call of GetAckLevels.
94
>
func (mr *MockNamespaceReplicationQueueMockRecorder) GetAckLevels(ctx any) *gomock.Call {
namespace_replication_queue_mock.go
95
>
mr.mock.ctrl.T.Helper()
96
>
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetAckLevels", reflect.TypeOf((*MockNamespaceReplicationQueue)(nil).GetAckLevels), ctx)
97
>
}
98
99
// GetDLQAckLevel mocks base method.