X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=lib%2Fxdsserver%2Fevents.go;h=8844c5e62a0e2b38604c55a46cf83196946137b0;hb=5dc2ff003106f0ced38caadb06033f24c792f9b9;hp=007b89ab782bae9246d9ce1d78c95091b971df1c;hpb=285332c351777b74abca638b8b2a2cde3c68edc6;p=src%2Fxds%2Fxds-server.git diff --git a/lib/xdsserver/events.go b/lib/xdsserver/events.go index 007b89a..8844c5e 100644 --- a/lib/xdsserver/events.go +++ b/lib/xdsserver/events.go @@ -1,5 +1,5 @@ /* - * Copyright (C) 2017 "IoT.bzh" + * Copyright (C) 2017-2018 "IoT.bzh" * Author Sebastien Douheret * * Licensed under the Apache License, Version 2.0 (the "License"); @@ -21,7 +21,7 @@ import ( "fmt" "time" - "github.com/iotbzh/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, }