Monorepo for Tangled
tangled.org
1package tapc
2
3import "context"
4
5type SimpleIndexer struct {
6 EventHandler func(ctx context.Context, evt Event) error
7 ErrorHandler func(ctx context.Context, err error)
8 ConnectHandler func(ctx context.Context)
9}
10
11var (
12 _ Handler = (*SimpleIndexer)(nil)
13 _ ConnectHandler = (*SimpleIndexer)(nil)
14)
15
16func (i *SimpleIndexer) OnEvent(ctx context.Context, evt Event) error {
17 if i.EventHandler == nil {
18 return nil
19 }
20 return i.EventHandler(ctx, evt)
21}
22
23func (i *SimpleIndexer) OnError(ctx context.Context, err error) {
24 if i.ErrorHandler == nil {
25 return
26 }
27 i.ErrorHandler(ctx, err)
28}
29
30func (i *SimpleIndexer) OnConnect(ctx context.Context) {
31 if i.ConnectHandler == nil {
32 return
33 }
34 i.ConnectHandler(ctx)
35}