websocket

Documentation

Index

• type IncomingWebsocketLayer
  • func NewIncomingWebsocketLayer(config *config.Config) *IncomingWebsocketLayer
  • func (i *IncomingWebsocketLayer) AnnounceNexus(belowNexus nexusHelper.Nexus)
  • func (i *IncomingWebsocketLayer) Listen(wsUrl string, tlsInfo *ws_server.TlsInfo) (err error)
  • func (i *IncomingWebsocketLayer) RegisterAboveLayer(belowLayer layer.Layer)
  • func (i *IncomingWebsocketLayer) StopListening()
• type OutgoingWebsocketLayer
  • func NewOutgoingWebsocketLayer() *OutgoingWebsocketLayer
  • func (o *OutgoingWebsocketLayer) AnnounceNexus(belowNexus nexus.Nexus)
  • func (o *OutgoingWebsocketLayer) Connect(location location.WebsocketLocation, seed *beacon.SharedSeed) (nws.OutgoingSocket, error)
  • func (o *OutgoingWebsocketLayer) InitiateCloseAll()
  • func (o *OutgoingWebsocketLayer) RegisterAboveLayer(belowLayer layer.Layer)

Types

type IncomingWebsocketLayer

type IncomingWebsocketLayer struct {
	layer.BaseLayer
	Config         *config.Config
	IncomingSocket *websocket.IncomingSocket
	WebsocketNexus *websocket.WebsocketNexus
}

func NewIncomingWebsocketLayer

func NewIncomingWebsocketLayer(config *config.Config) *IncomingWebsocketLayer

func (*IncomingWebsocketLayer) AnnounceNexus

func (i *IncomingWebsocketLayer) AnnounceNexus(belowNexus nexusHelper.Nexus)

func (*IncomingWebsocketLayer) Listen

func (i *IncomingWebsocketLayer) Listen(wsUrl string, tlsInfo *ws_server.TlsInfo) (err error)

func (*IncomingWebsocketLayer) RegisterAboveLayer

func (i *IncomingWebsocketLayer) RegisterAboveLayer(belowLayer layer.Layer)

func (*IncomingWebsocketLayer) StopListening

func (i *IncomingWebsocketLayer) StopListening()

type OutgoingWebsocketLayer

type OutgoingWebsocketLayer struct {
	layer.BaseLayer
	NexusBySharedSeed      layer.NexusStringMap
	OutgoingSocketProtocol nws.OutgoingSocket
}

TODO this needs to be fully implemented

func NewOutgoingWebsocketLayer

func NewOutgoingWebsocketLayer() *OutgoingWebsocketLayer

func (*OutgoingWebsocketLayer) AnnounceNexus

func (o *OutgoingWebsocketLayer) AnnounceNexus(belowNexus nexus.Nexus)

func (*OutgoingWebsocketLayer) Connect

func (o *OutgoingWebsocketLayer) Connect(location location.WebsocketLocation, seed *beacon.SharedSeed) (nws.OutgoingSocket, error)

func (*OutgoingWebsocketLayer) InitiateCloseAll

func (o *OutgoingWebsocketLayer) InitiateCloseAll()

func (*OutgoingWebsocketLayer) RegisterAboveLayer

func (o *OutgoingWebsocketLayer) RegisterAboveLayer(belowLayer layer.Layer)