net

Documentation

Index

• func HandleMonitorRequest(w http.ResponseWriter, r *http.Request)
• func NewSimuHub(ctx context.Context, s *sim.Simulation) *ws.Hub
• type NDJSONScanner
  • func NewNDJSONScanner(sleep time.Duration, repeat int) *NDJSONScanner
  • func (s *NDJSONScanner) Scan(r io.Reader, w io.Writer) error
  • func (s *NDJSONScanner) ScanFile(path string, w io.Writer) error
• type Server
  • func NewHTTPServer() *Server
  • func (s Server) Address() string
  • func (s *Server) Restart(ctx context.Context, addr string) error
  • func (s *Server) Router() chi.Router
  • func (s *Server) Start(addr string) error
  • func (s *Server) Stop()

Functions

func HandleMonitorRequest

func HandleMonitorRequest(w http.ResponseWriter, r *http.Request)

HandleMonitorRequest handles the monitor http request. events are emitted to the monitor event channel.

func NewSimuHub

func NewSimuHub(ctx context.Context, s *sim.Simulation) *ws.Hub

Types

type NDJSONScanner

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

NDJSONScanner scans a reader line by line and writes to the writer.

func NewNDJSONScanner

func NewNDJSONScanner(sleep time.Duration, repeat int) *NDJSONScanner

NewNDJSONScanner creates a new NDJSON scanner.

func (*NDJSONScanner) Scan

func (s *NDJSONScanner) Scan(r io.Reader, w io.Writer) error

Scan scans a reader line by line and writes to the writer.

func (*NDJSONScanner) ScanFile

func (s *NDJSONScanner) ScanFile(path string, w io.Writer) error

ScanFile scans a file line by line and writes to the writer.

type Server

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

func NewHTTPServer

func NewHTTPServer() *Server

func (Server) Address

func (s Server) Address() string

func (*Server) Restart

func (s *Server) Restart(ctx context.Context, addr string) error

func (*Server) Router

func (s *Server) Router() chi.Router

func (*Server) Start

func (s *Server) Start(addr string) error

func (*Server) Stop

func (s *Server) Stop()