websocket

package

v0.61.0 Latest Latest Go to latest Published: Mar 27, 2021 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/xplorfin/moneysocket-go

Links

Open Source Insights

Documentation ¶

Index ¶

type IncomingWebsocketLayer
- func NewIncomingWebsocketLayer(config *config.Config) *IncomingWebsocketLayer
type OutgoingWebsocketLayer
- func NewOutgoingWebsocketLayer() *OutgoingWebsocketLayer

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 *websocket.IncomingSocket
	WebsocketNexus *websocket.Nexus
}

func NewIncomingWebsocketLayer ¶

func NewIncomingWebsocketLayer(config *config.Config) *IncomingWebsocketLayer

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)

func (*IncomingWebsocketLayer) RegisterAboveLayer ¶

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

RegisterAboveLayer registers the current nexuses announce/revoke nexuses to the below 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)

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)

func (*OutgoingWebsocketLayer) InitiateCloseAll ¶

func (o *OutgoingWebsocketLayer) InitiateCloseAll()

func (*OutgoingWebsocketLayer) RegisterAboveLayer ¶

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

RegisterAboveLayer registers the current nexuses announce/revoke nexuses to the below layer

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL