-
Notifications
You must be signed in to change notification settings - Fork 0
/
event.go
55 lines (42 loc) · 1.01 KB
/
event.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
package ankadb
import (
"context"
)
var (
// EventOnStarted - onStarted
EventOnStarted = "onstarted"
)
// FuncAnkaDBEvent - func event
type FuncAnkaDBEvent func(ctx context.Context, anka AnkaDB) error
// eventMgr event manager
type eventMgr struct {
mapAnkaDBEvent map[string]([]FuncAnkaDBEvent)
anka AnkaDB
}
func newEventMgr(anka AnkaDB) *eventMgr {
mgr := &eventMgr{
mapAnkaDBEvent: make(map[string]([]FuncAnkaDBEvent)),
anka: anka,
}
return mgr
}
func (mgr *eventMgr) checkAnkaDBEvent(event string) bool {
return event == EventOnStarted
}
func (mgr *eventMgr) regAnkaDBEventFunc(event string, eventfunc FuncAnkaDBEvent) error {
if !mgr.checkAnkaDBEvent(event) {
return ErrInvalidEvent
}
mgr.mapAnkaDBEvent[event] = append(mgr.mapAnkaDBEvent[event], eventfunc)
return nil
}
func (mgr *eventMgr) onAnkaDBEvent(ctx context.Context, event string) error {
lst, ok := mgr.mapAnkaDBEvent[event]
if !ok {
return nil
}
for i := range lst {
lst[i](ctx, mgr.anka)
}
return nil
}