X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=lib%2Fxdsserver%2Fevents.go;h=8844c5e62a0e2b38604c55a46cf83196946137b0;hb=HEAD;hp=4ae1ff352e0aea02d9edf19dea47440f358ee801;hpb=2a7a112bbffcd41a3436c086f1910ea7a9c94744;p=src%2Fxds%2Fxds-server.git diff --git a/lib/xdsserver/events.go b/lib/xdsserver/events.go index 4ae1ff3..8844c5e 100644 --- a/lib/xdsserver/events.go +++ b/lib/xdsserver/events.go @@ -21,7 +21,7 @@ import ( "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 @@ -35,8 +35,8 @@ type Events struct { 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{ @@ -88,7 +88,7 @@ func (e *Events) UnRegister(evName, sessionID string) error { } // Emit Used to manually emit an event -func (e *Events) Emit(evName string, data interface{}, fromSid string) error { +func (e *Events) Emit(evName string, data interface{}, fromSessID string) error { 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(), - FromSessionID: fromSid, + FromSessionID: fromSessID, Type: evName, Data: data, }