package tapc
import "context"
type SimpleIndexer struct {
EventHandler func(ctx context.Context, evt Event) error
ErrorHandler func(ctx context.Context, err error)
ConnectHandler func(ctx context.Context)
}
var (
_ Handler = (*SimpleIndexer)(nil)
_ ConnectHandler = (*SimpleIndexer)(nil)
)
func (i *SimpleIndexer) OnEvent(ctx context.Context, evt Event) error {
if i.EventHandler == nil {
return nil
}
return i.EventHandler(ctx, evt)
}
func (i *SimpleIndexer) OnError(ctx context.Context, err error) {
if i.ErrorHandler == nil {
return
}
i.ErrorHandler(ctx, err)
}
func (i *SimpleIndexer) OnConnect(ctx context.Context) {
if i.ConnectHandler == nil {
return
}
i.ConnectHandler(ctx)
}