(ctx context.Context, outbox *model.LineageOutbox)
| 646 | } |
| 647 | |
| 648 | func (m *MockDataSource) InsertLineageOutbox(ctx context.Context, outbox *model.LineageOutbox) error { |
| 649 | args := m.Called(ctx, outbox) |
| 650 | return args.Error(0) |
| 651 | } |
| 652 | |
| 653 | func (m *MockDataSource) ClaimPendingOutboxEntries(ctx context.Context, batchSize int, lockDuration time.Duration) ([]model.LineageOutbox, error) { |
| 654 | args := m.Called(ctx, batchSize, lockDuration) |