Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
721 B · 35 lines
Go
123456789101112131415161718192021222324252627282930313233343536package 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)}