Documentation
¶
Index ¶
- type IncomingWebsocketLayer
- type 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.Base)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IncomingWebsocketLayer ¶
type IncomingWebsocketLayer struct {
layer.BaseLayer
Config *config.Config
// IncomingSocket is a simulated socket
IncomingSocket *websocket.IncomingSocket
// WebsocketNexus handles the socket
WebsocketNexus *websocket.Nexus
}
IncomingWebsocketLayer is handles websockets
func NewIncomingWebsocketLayer ¶
func NewIncomingWebsocketLayer(config *config.Config) *IncomingWebsocketLayer
NewIncomingWebsocketLayer creates a new incoming websocket layer
func (*IncomingWebsocketLayer) AnnounceNexus ¶
func (i *IncomingWebsocketLayer) AnnounceNexus(belowNexus nexusHelper.Nexus)
AnnounceNexus creates a new websocket.WebsocketNexus and registers it
func (*IncomingWebsocketLayer) Listen ¶
func (i *IncomingWebsocketLayer) Listen(wsURL string, tlsInfo *server.TLSInfo) (err error)
Listen listens at a given wsUrl
func (*IncomingWebsocketLayer) RegisterAboveLayer ¶
func (i *IncomingWebsocketLayer) RegisterAboveLayer(belowLayer layer.Base)
RegisterAboveLayer registers the current nexuses announce/revoke nexuses to the below layer
func (*IncomingWebsocketLayer) StopListening ¶
func (i *IncomingWebsocketLayer) StopListening()
StopListening stops listening on the incoming websocket layer
type OutgoingWebsocketLayer ¶
type OutgoingWebsocketLayer struct {
layer.BaseLayer
NexusBySharedSeed layer.NexusStringMap
// OutgoingSocketProtocol
OutgoingSocketProtocol *nws.OutgoingSocket
}
OutgoingWebsocketLayer processes outgoing websocket connections
func NewOutgoingWebsocketLayer ¶
func NewOutgoingWebsocketLayer() *OutgoingWebsocketLayer
NewOutgoingWebsocketLayer creates a OutgoingWebsocketLayer
func (*OutgoingWebsocketLayer) AnnounceNexus ¶
func (o *OutgoingWebsocketLayer) AnnounceNexus(belowNexus nexus.Nexus)
AnnounceNexus creates a new nws.WebsocketNexus and registers it
func (*OutgoingWebsocketLayer) Connect ¶
func (o *OutgoingWebsocketLayer) Connect(location location.WebsocketLocation, seed *beacon.SharedSeed) (*nws.OutgoingSocket, error)
Connect connects to the outgoing layer
func (*OutgoingWebsocketLayer) InitiateCloseAll ¶
func (o *OutgoingWebsocketLayer) InitiateCloseAll()
InitiateCloseAll closes all nexuses associated with the layer
func (*OutgoingWebsocketLayer) RegisterAboveLayer ¶
func (o *OutgoingWebsocketLayer) RegisterAboveLayer(belowLayer layer.Base)
RegisterAboveLayer registers the current nexuses announce/revoke nexuses to the below layer
Source Files