websocket

Documentation

Index

• Constants
• type IncomingSocket
  • func NewIncomingSocket() IncomingSocket
  • func (i *IncomingSocket) InitiateClose()
  • func (i *IncomingSocket) OnBinMessage(belowNexus nexusHelper.Nexus, msg []byte)
  • func (i *IncomingSocket) OnClose(wasClean bool, code int, reason string)
  • func (i IncomingSocket) OnConnect(r *http.Request)
  • func (i IncomingSocket) OnConnecting(r *http.Request)
  • func (i *IncomingSocket) OnMessage(belowNexus nexusHelper.Nexus, moneysocketMessage base2.MoneysocketMessage)
  • func (i *IncomingSocket) OnOpen()
  • func (i *IncomingSocket) OnWsMessage(payload []byte, isBinary bool)
  • func (i *IncomingSocket) Send(msg base2.MoneysocketMessage) error
  • func (i *IncomingSocket) SendBin(rawMsg []byte) error
  • func (i *IncomingSocket) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (i *IncomingSocket) SharedSeed() *beacon.SharedSeed
• type OutgoingSocket
  • func NewOutgoingSocket() OutgoingSocket
  • func (i *OutgoingSocket) OnBinMessage(belowNexus nexusHelper.Nexus, msg []byte)
  • func (i *OutgoingSocket) OnClose(wasClean bool, code int, reason string)
  • func (i OutgoingSocket) OnConnect(conn *websocket.Conn, r *http.Response)
  • func (i OutgoingSocket) OnConnecting()
  • func (i *OutgoingSocket) OnMessage(belowNexus nexusHelper.Nexus, msg moneysocket_message.MoneysocketMessage)
  • func (i *OutgoingSocket) OnOpen()
  • func (i *OutgoingSocket) OnWsMessage(payload []byte, isBinary bool)
  • func (i *OutgoingSocket) Send(msg moneysocket_message.MoneysocketMessage) error
  • func (i *OutgoingSocket) SendBin(msg []byte) error
  • func (i *OutgoingSocket) SharedSeed() *beacon.SharedSeed
• type WebsocketNexus
  • func NewWebsocketNexus(belowNexus nexus.Nexus) WebsocketNexus
  • func (o *WebsocketNexus) OnBinMessage(belowNexus nexus.Nexus, msgByte []byte)
  • func (o *WebsocketNexus) OnMessage(belowNexus nexus.Nexus, msg base2.MoneysocketMessage)

Constants

const IncomingSocketName = "IncomingSocketName"

const OutgoingSocketName = "OutgoingSocket"

const WebsocketNexusName = "WebsocketNexus"

Types

type IncomingSocket

type IncomingSocket struct {
	ws_server.WebSocketServerProtocol
	nexusHelper.Nexus

	// protocol layer coorespond to the socket interface
	FactoryMsProtocolLayer layer.Layer
	FactoryMsSharedSeed    *beacon.SharedSeed
	// contains filtered or unexported fields
}

func NewIncomingSocket

func NewIncomingSocket() IncomingSocket

create a new incoming websocket nexus (accepts request)

func (*IncomingSocket) InitiateClose

func (i *IncomingSocket) InitiateClose()

func (*IncomingSocket) OnBinMessage

func (i *IncomingSocket) OnBinMessage(belowNexus nexusHelper.Nexus, msg []byte)

cooresponds to the nexus interface, handles a binary message

func (*IncomingSocket) OnClose

func (i *IncomingSocket) OnClose(wasClean bool, code int, reason string)

func (IncomingSocket) OnConnect

func (i IncomingSocket) OnConnect(r *http.Request)

func (IncomingSocket) OnConnecting

func (i IncomingSocket) OnConnecting(r *http.Request)

func (*IncomingSocket) OnMessage

func (i *IncomingSocket) OnMessage(belowNexus nexusHelper.Nexus, moneysocketMessage base2.MoneysocketMessage)

cooresponds to the nexus interface, handles a message

func (*IncomingSocket) OnOpen

func (i *IncomingSocket) OnOpen()

func (*IncomingSocket) OnWsMessage

func (i *IncomingSocket) OnWsMessage(payload []byte, isBinary bool)

func (*IncomingSocket) Send

func (i *IncomingSocket) Send(msg base2.MoneysocketMessage) error

func (*IncomingSocket) SendBin

func (i *IncomingSocket) SendBin(rawMsg []byte) error

func (*IncomingSocket) ServeHTTP

func (i *IncomingSocket) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*IncomingSocket) SharedSeed

func (i *IncomingSocket) SharedSeed() *beacon.SharedSeed

type OutgoingSocket

type OutgoingSocket struct {
	ws_client.WebsocketClientProtocol
	nexusHelper.Nexus

	// protocol layer coorespond to the socket interface
	FactoryMsProtocolLayer layer.Layer
	// add an outgoing shared seed modules
	OutgoingSharedSeed *beacon.SharedSeed
	// contains filtered or unexported fields
}

func NewOutgoingSocket

func NewOutgoingSocket() OutgoingSocket

create a new incoming websocket nexus (accepts request)

func (*OutgoingSocket) OnBinMessage

func (i *OutgoingSocket) OnBinMessage(belowNexus nexusHelper.Nexus, msg []byte)

cooresponds to the nexus interface, handles a binary message

func (*OutgoingSocket) OnClose

func (i *OutgoingSocket) OnClose(wasClean bool, code int, reason string)

func (OutgoingSocket) OnConnect

func (i OutgoingSocket) OnConnect(conn *websocket.Conn, r *http.Response)

func (OutgoingSocket) OnConnecting

func (i OutgoingSocket) OnConnecting()

func (*OutgoingSocket) OnMessage

func (i *OutgoingSocket) OnMessage(belowNexus nexusHelper.Nexus, msg moneysocket_message.MoneysocketMessage)

cooresponds to the nexus interface, handles a message

func (*OutgoingSocket) OnOpen

func (i *OutgoingSocket) OnOpen()

func (*OutgoingSocket) OnWsMessage

func (i *OutgoingSocket) OnWsMessage(payload []byte, isBinary bool)

func (*OutgoingSocket) Send

func (i *OutgoingSocket) Send(msg moneysocket_message.MoneysocketMessage) error

func (*OutgoingSocket) SendBin

func (i *OutgoingSocket) SendBin(msg []byte) error

func (*OutgoingSocket) SharedSeed

func (i *OutgoingSocket) SharedSeed() *beacon.SharedSeed

type WebsocketNexus

type WebsocketNexus struct {
	*base.BaseNexus
}

func NewWebsocketNexus

func NewWebsocketNexus(belowNexus nexus.Nexus) WebsocketNexus

func (*WebsocketNexus) OnBinMessage

func (o *WebsocketNexus) OnBinMessage(belowNexus nexus.Nexus, msgByte []byte)

func (*WebsocketNexus) OnMessage

func (o *WebsocketNexus) OnMessage(belowNexus nexus.Nexus, msg base2.MoneysocketMessage)