gw

Feb 3, 2023

Changes in this version

+ type CommandHandler interface

+ DownstreamMessage func(localID, localDeviceID, messageID string, payload []byte) error

+ RemoveDevice func(localID string, deviceID string) error

+ Shutdown func()

+ UpdateConfig func(localID string, config map[string]string) (string, error)

+ UpdateDevice func(localID string, localDeviceID string, config map[string]string) (string, map[string]string, error)

+ UpstreamMessage func(upstreamCb UpstreamMessageFunc)

+ type GatewayProcess struct

+ Commands CommandHandler

+ Stream gateway.UserGatewayService_ControlStreamClient

+ func Create(config Parameters, handler CommandHandler) (*GatewayProcess, error)

+ func NewGatewayProcess(stateFile string, stream gateway.UserGatewayService_ControlStreamClient, ...) *GatewayProcess

+ func (sp *GatewayProcess) Run() error

+ func (sp *GatewayProcess) Stop()

+ type GatewayState struct

+ GatewayID string

+ IDMappings map[string]string

+ LocalID string

+ func NewStateFromFile(filename string) (*GatewayState, error)

+ func (g *GatewayState) GetMapping(deviceID string) string

+ func (g *GatewayState) GetReverseMapping(localID string) string

+ func (g *GatewayState) RemoveMapping(id string)

+ func (g *GatewayState) Save(filename string) error

+ func (g *GatewayState) SetMapping(deviceID, otherID string)

+ type Parameters struct

+ CertFile string

+ Chain string

+ KeyFile string

+ SpanEndpoint string

+ StateFile string

+ type UpstreamMessageFunc func(localDeviceID string, payload []byte, metadata map[string]string)