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
Reworked SDKs events (introduced sdk-state-change)
[src/xds/xds-server.git]
/
lib
/
xdsserver
/
events.go
diff --git
a/lib/xdsserver/events.go
b/lib/xdsserver/events.go
index
4ae1ff3
..
2528725
100644
(file)
--- a/
lib/xdsserver/events.go
+++ b/
lib/xdsserver/events.go
@@
-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,
}