Documentation
¶
Index ¶
- type Server
- func (o *Server) CreateReservoir(w http.ResponseWriter, r *http.Request, p httprouter.Params)
- func (o *Server) DisposeReservoir(w http.ResponseWriter, r *http.Request, p httprouter.Params)
- func (o *Server) GetFlow(w http.ResponseWriter, r *http.Request, p httprouter.Params)
- func (o *Server) GetFlows(w http.ResponseWriter, r *http.Request, p httprouter.Params)
- func (o *Server) GetReservoir(w http.ResponseWriter, r *http.Request, p httprouter.Params)
- func (o *Server) GetReservoirs(w http.ResponseWriter, r *http.Request, p httprouter.Params)
- func (o *Server) GetStats(w http.ResponseWriter, r *http.Request, p httprouter.Params)
- func (o *Server) GetVersion(w http.ResponseWriter, r *http.Request, p httprouter.Params)
- func (o *Server) Monitor()
- func (o *Server) RunMonitor()
- func (o *Server) Serve() error
- func (o *Server) StartFlow(w http.ResponseWriter, r *http.Request, p httprouter.Params)
- func (o *Server) StopFlow(w http.ResponseWriter, r *http.Request, p httprouter.Params)
- func (o *Server) StopMonitor()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
Server struct contains what is needed to serve a rest interface
func NewServer ¶
func NewServer(reservoirMap *run.ReservoirMap, address string) (*Server, error)
NewServer creates reservoirs system
func (*Server) CreateReservoir ¶
func (o *Server) CreateReservoir(w http.ResponseWriter, r *http.Request, p httprouter.Params)
CreateReservoir create a reservoir
func (*Server) DisposeReservoir ¶
func (o *Server) DisposeReservoir(w http.ResponseWriter, r *http.Request, p httprouter.Params)
DisposeReservoir disposes a reservoir
func (*Server) GetFlow ¶
func (o *Server) GetFlow(w http.ResponseWriter, r *http.Request, p httprouter.Params)
GetFlow returns a flow
func (*Server) GetFlows ¶
func (o *Server) GetFlows(w http.ResponseWriter, r *http.Request, p httprouter.Params)
GetFlows returns the flows
func (*Server) GetReservoir ¶
func (o *Server) GetReservoir(w http.ResponseWriter, r *http.Request, p httprouter.Params)
GetReservoir get reservoir
func (*Server) GetReservoirs ¶
func (o *Server) GetReservoirs(w http.ResponseWriter, r *http.Request, p httprouter.Params)
GetReservoirs get reservoirs
func (*Server) GetStats ¶
func (o *Server) GetStats(w http.ResponseWriter, r *http.Request, p httprouter.Params)
GetStats returns process statistics
func (*Server) GetVersion ¶
func (o *Server) GetVersion(w http.ResponseWriter, r *http.Request, p httprouter.Params)
func (*Server) StartFlow ¶
func (o *Server) StartFlow(w http.ResponseWriter, r *http.Request, p httprouter.Params)
StartFlow starts a flow
func (*Server) StopFlow ¶
func (o *Server) StopFlow(w http.ResponseWriter, r *http.Request, p httprouter.Params)
StopFlow stops a flow
Source Files
Click to show internal directories.
Click to hide internal directories.