core / tap / simpleIndexer.go

package tap

import "context"

type SimpleIndexer struct {
	EventHandler func(ctx context.Context, evt Event) error
	ErrorHandler func(ctx context.Context, err error)
}

var _ Handler = (*SimpleIndexer)(nil)

func (i *SimpleIndexer) OnEvent(ctx context.Context, evt Event) error {
	return i.EventHandler(ctx, evt)
}

func (i *SimpleIndexer) OnError(ctx context.Context, err error) {
	i.ErrorHandler(ctx, err)
}