websocket

package
v0.6.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 7, 2023 License: BlueOak-1.0.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Core 

type Core interface {
	SyncBook(dex string, base, quote uint32) (core.BookFeed, error)
	AckNotes([]dex.Bytes)
}

Core specifies the needed methods for Server to operate. Satisfied by *core.Core.

type Server 

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

Server is a websocket hub that tracks all running websocket clients, allows sending notifications to all of them, and manages per-client order book subscriptions.

func New 

func New(core Core, log dex.Logger) *Server

New returns a new websocket Server.

func (*Server) HandleConnect 

func (s *Server) HandleConnect(ctx context.Context, w http.ResponseWriter, r *http.Request)

HandleConnect handles the websocket connection request, creating a ws.Connection and a connect thread. Since the http.Request's Context is canceled after ServerHTTP returns, a separate context must be provided to be able to cancel the hijacked connection handler at a later time since this function is not blocking.

func (*Server) Notify 

func (s *Server) Notify(route string, payload interface{})

Notify sends a notification to the websocket client.

func (*Server) Shutdown 

func (s *Server) Shutdown()

Shutdown gracefully shuts down all connected clients, waiting for them to disconnect and any running goroutines and message handlers to return.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.