Skip to content

Commit 4839bef

Browse files
Correct param usage (#133)
1 parent 0bef9c2 commit 4839bef

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

pkg/event/iterator.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -96,8 +96,8 @@ func (i *Iterator) Close() error {
9696
// the error, and then just invalidate the cache the same way you would with ErrOutOfSync.
9797
// As time goes on, we'll know a little bit better how to operate this under real-world
9898
// conditions.
99-
func NewFilteredIterator(ctx context.Context, changelogPath, family, table string, opts IteratorOpt) (*FilteredIterator, error) {
100-
iter, err := NewIterator(ctx, changelogPath, opts)
99+
func NewFilteredIterator(ctx context.Context, changelogPath, family, table string, opts ...IteratorOpt) (*FilteredIterator, error) {
100+
iter, err := NewIterator(ctx, changelogPath, opts...)
101101
if err != nil {
102102
return nil, err
103103
}

0 commit comments

Comments
 (0)