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) }