net

Documentation

Index

• func HandleMonitorRequest(w http.ResponseWriter, r *http.Request)
• func ScanJsonDelimitedFile(fn string, sleep time.Duration, repeat int, emitter chan []byte)
• 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()
• type SimuRpcHandler
  • func NewSimuRpcHandler(simu *sim.Simulation) *SimuRpcHandler
  • func (s SimuRpcHandler) HandleMessage(r *rpc.Request) error

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 ScanJsonDelimitedFile

func ScanJsonDelimitedFile(fn string, sleep time.Duration, repeat int, emitter chan []byte)

Types

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()

type SimuRpcHandler

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

func NewSimuRpcHandler

func NewSimuRpcHandler(simu *sim.Simulation) *SimuRpcHandler

func (SimuRpcHandler) HandleMessage

func (s SimuRpcHandler) HandleMessage(r *rpc.Request) error