server

Documentation

Index

• func Echo(w http.ResponseWriter, r *http.Request)
• func Home(w http.ResponseWriter, r *http.Request)
• type Device
• type DeviceHandler
  • func (h *DeviceHandler) GetDeivce(w http.ResponseWriter, r *http.Request)
  • func (h *DeviceHandler) GetDeviceState(w http.ResponseWriter, r *http.Request)
  • func (h *DeviceHandler) GetDevices(w http.ResponseWriter, r *http.Request)
  • func (h *DeviceHandler) Root(w http.ResponseWriter, r *http.Request)
  • func (h *DeviceHandler) SetDeviceState(w http.ResponseWriter, r *http.Request)
  • func (h *DeviceHandler) SetRoutes(r *mux.Router)
• type DeviceService
  • func NewDeviceService(serviceIp string, servicePort int, websocketPort int, devices *Devices) *DeviceService
  • func (s *DeviceService) ServeHTTPS()
• type Devices
  • func NewDeviceStore() *Devices
  • func (ds *Devices) AddOrUpdateDevice(d *Device)
  • func (ds *Devices) Get(id string) (*Device, bool)
  • func (ds *Devices) ListDevices() []*Device
  • func (ds *Devices) TurnOff(id string) (*types.Device, error)
  • func (ds *Devices) TurnOn(id string) (*types.Device, error)
• type WsServer
  • func NewWsServer(port int, devices *Devices) *WsServer
  • func (ws *WsServer) Ack(msg *types.Message) ([]byte, error)
  • func (ws *WsServer) Date(msg *types.Message) ([]byte, error)
  • func (ws *WsServer) Query(payload []byte) ([]byte, error)
  • func (ws *WsServer) Register(msg *types.Message, conn *websocket.Conn) ([]byte, error)
  • func (ws *WsServer) Serve()
  • func (ws *WsServer) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (ws *WsServer) Update(payload []byte, conn *websocket.Conn) ([]byte, error)

Functions

func Echo

func Echo(w http.ResponseWriter, r *http.Request)

func Home

func Home(w http.ResponseWriter, r *http.Request)

Types

type Device

type Device struct {
	types.Device
	Conn *websocket.Conn `json:"-"`
}

type DeviceHandler

type DeviceHandler struct {
	// contains filtered or unexported fields
}

func (*DeviceHandler) GetDeivce

func (h *DeviceHandler) GetDeivce(w http.ResponseWriter, r *http.Request)

func (*DeviceHandler) GetDeviceState

func (h *DeviceHandler) GetDeviceState(w http.ResponseWriter, r *http.Request)

func (*DeviceHandler) GetDevices

func (h *DeviceHandler) GetDevices(w http.ResponseWriter, r *http.Request)

func (*DeviceHandler) Root

func (h *DeviceHandler) Root(w http.ResponseWriter, r *http.Request)

func (*DeviceHandler) SetDeviceState

func (h *DeviceHandler) SetDeviceState(w http.ResponseWriter, r *http.Request)

func (*DeviceHandler) SetRoutes

func (h *DeviceHandler) SetRoutes(r *mux.Router)

type DeviceService

type DeviceService struct {
	// contains filtered or unexported fields
}

func NewDeviceService

func NewDeviceService(serviceIp string, servicePort int, websocketPort int, devices *Devices) *DeviceService

func (*DeviceService) ServeHTTPS

func (s *DeviceService) ServeHTTPS()

type Devices

type Devices struct {
	// contains filtered or unexported fields
}

func NewDeviceStore

func NewDeviceStore() *Devices

func (*Devices) AddOrUpdateDevice

func (ds *Devices) AddOrUpdateDevice(d *Device)

TODO: improve

func (*Devices) Get

func (ds *Devices) Get(id string) (*Device, bool)

func (*Devices) ListDevices

func (ds *Devices) ListDevices() []*Device

func (*Devices) TurnOff

func (ds *Devices) TurnOff(id string) (*types.Device, error)

func (*Devices) TurnOn

func (ds *Devices) TurnOn(id string) (*types.Device, error)

TODO: move to upper layer

type WsServer

type WsServer struct {
	// contains filtered or unexported fields
}

func NewWsServer

func NewWsServer(port int, devices *Devices) *WsServer

func (*WsServer) Ack

func (ws *WsServer) Ack(msg *types.Message) ([]byte, error)

func (*WsServer) Date

func (ws *WsServer) Date(msg *types.Message) ([]byte, error)

func (*WsServer) Query

func (ws *WsServer) Query(payload []byte) ([]byte, error)

func (*WsServer) Register

func (ws *WsServer) Register(msg *types.Message, conn *websocket.Conn) ([]byte, error)

func (*WsServer) Serve

func (ws *WsServer) Serve()

func (*WsServer) ServeHTTP

func (ws *WsServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*WsServer) Update

func (ws *WsServer) Update(payload []byte, conn *websocket.Conn) ([]byte, error)