ws

Documentation

Index

• func AddNode(nodeName string, read ReadMsgFunc, write WriteMsgFunc, closeCh chan struct{})
• func Done() <-chan struct{}
• func ReceiveFromEdge() (nodeName string, msg model.Message, err error)
• func SendToCloud(nodeName string, msg model.Message) error
• func SendToEdge(nodeName string, msg *model.Message) error
• type ChannelContext
  • func NewChannelContext() *ChannelContext
• type ReadMsgFunc
• type Server
  • func NewServer(address string) *Server
  • func (srv *Server) Close() error
  • func (srv *Server) ListenAndServe() error
  • func (srv *Server) ServeHTTP(w http.ResponseWriter, req *http.Request)
• type WriteMsgFunc

Functions

func AddNode

func AddNode(nodeName string, read ReadMsgFunc, write WriteMsgFunc, closeCh chan struct{})

AddNode registers a node

func Done

func Done() <-chan struct{}

Done returns a channel that's closed when done

func ReceiveFromEdge

func ReceiveFromEdge() (nodeName string, msg model.Message, err error)

ReceiveFromEdge receives a message from edge

func SendToCloud

func SendToCloud(nodeName string, msg model.Message) error

SendToCloud sends the message to cloud from specified node name

func SendToEdge

func SendToEdge(nodeName string, msg *model.Message) error

SendToEdge sends the msg to nodeName

Types

type ChannelContext

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

ChannelContext is object for Context channel

func NewChannelContext

func NewChannelContext() *ChannelContext

NewChannelContext creates a ChannelContext

type ReadMsgFunc

type ReadMsgFunc func() (model.Message, error)

ReadMsgFunc defines read msg callback

type Server

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

Server defines websocket protocol server

func NewServer

func NewServer(address string) *Server

NewServer creates a websocket server

func (*Server) Close

func (srv *Server) Close() error

Close closes the server

func (*Server) ListenAndServe

func (srv *Server) ListenAndServe() error

ListenAndServe listens and serves the server

func (*Server) ServeHTTP

func (srv *Server) ServeHTTP(w http.ResponseWriter, req *http.Request)

type WriteMsgFunc

type WriteMsgFunc func(model.Message) error

WriteMsgFunc defines write msg callback