Code Review
/
src
/
xds
/
xds-server.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Use go module as dependency tool instead of glide
[src/xds/xds-server.git]
/
lib
/
xdsserver
/
events.go
diff --git
a/lib/xdsserver/events.go
b/lib/xdsserver/events.go
index
4ae1ff3
..
8844c5e
100644
(file)
--- a/
lib/xdsserver/events.go
+++ b/
lib/xdsserver/events.go
@@
-21,7
+21,7
@@
import (
"fmt"
"time"
"fmt"
"time"
- "gerrit.automotivelinux.org/gerrit/src/xds/xds-server/lib/xsapiv1"
+ "gerrit.automotivelinux.org/gerrit/src/xds/xds-server
.git
/lib/xsapiv1"
)
// EventDef Definition on one event
)
// EventDef Definition on one event
@@
-35,8
+35,8
@@
type Events struct {
eventsMap map[string]*EventDef
}
eventsMap map[string]*EventDef
}
-//
NewEvents
creates an instance of Events
-func
NewEvents
(ctx *Context) *Events {
+//
EventsConstructor
creates an instance of Events
+func
EventsConstructor
(ctx *Context) *Events {
evMap := make(map[string]*EventDef)
for _, ev := range xsapiv1.EVTAllList {
evMap[ev] = &EventDef{
evMap := make(map[string]*EventDef)
for _, ev := range xsapiv1.EVTAllList {
evMap[ev] = &EventDef{
@@
-88,7
+88,7
@@
func (e *Events) UnRegister(evName, sessionID string) error {
}
// Emit Used to manually emit an event
}
// Emit Used to manually emit an event
-func (e *Events) Emit(evName string, data interface{}, fromS
id
string) error {
+func (e *Events) Emit(evName string, data interface{}, fromS
essID
string) error {
var firstErr error
if _, ok := e.eventsMap[evName]; !ok {
var firstErr error
if _, ok := e.eventsMap[evName]; !ok {
@@
-108,7
+108,7
@@
func (e *Events) Emit(evName string, data interface{}, fromSid string) error {
}
msg := xsapiv1.EventMsg{
Time: time.Now().String(),
}
msg := xsapiv1.EventMsg{
Time: time.Now().String(),
- FromSessionID: fromS
id
,
+ FromSessionID: fromS
essID
,
Type: evName,
Data: data,
}
Type: evName,
Data: data,
}