server

Documentation

Index

• func AttachClient(server *Server, conn *websocket.Conn)
• type Client
• type Server
  • func New(aggr *feed.Aggregator) *Server
  • func (s *Server) Run()
  • func (s *Server) Serve()
  • func (s *Server) Wait()

Functions

func AttachClient

func AttachClient(server *Server, conn *websocket.Conn)

Types

type Client

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

Client is a middleman between the websocket connection and the server.

type Server

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

Server operates with websocket clients (viewers). Listens for aggregated messages from aggreagtor, calculates values for ticker string an build it. Broadcasts updated ticker string to all clients.

func New

func New(aggr *feed.Aggregator) *Server

Instantiate Server

func (*Server) Run

func (s *Server) Run()

Run registers/deregisters websocket clients. Listens for tick messages from aggregator. Calculates and updates ticker string. Pushes to websocket updated ticker string.

func (*Server) Serve

func (s *Server) Serve()

func (*Server) Wait

func (s *Server) Wait()