Versions in this module Expand all Collapse all v0 v0.0.0 Dec 20, 2023 Changes in this version + func ProxyHandler(target *url.URL) *httputil.ReverseProxy + type FlowController interface + DeferFlow func() + RestoreFlow func() + type OnInterrupt TaskRunnerFunc + func (t OnInterrupt) Run(proc TaskProcess) + type Scheduler struct + func (s *Scheduler) CancelOnInterruptTasks() + func (s *Scheduler) CancelOnServeTasks() + func (s *Scheduler) CopyTo(to *Scheduler) + func (s *Scheduler) Schedule(runner TaskRunner) TaskCancelFunc + func (s *Scheduler) ScheduleFunc(runner func(TaskProcess)) TaskCancelFunc + type Supervisor struct + func New(srv *http.Server) *Supervisor + func NewProxy(hostAddr string, target *url.URL) *Supervisor + func (su *Supervisor) DeferFlow() + func (su *Supervisor) Done() <-chan struct{} + func (su *Supervisor) Err() <-chan error + func (su *Supervisor) ListenAndServe() error + func (su *Supervisor) ListenAndServeAutoTLS() error + func (su *Supervisor) ListenAndServeTLS(certFile string, keyFile string) error + func (su *Supervisor) RestoreFlow() + func (su *Supervisor) Serve(l net.Listener) error + func (su *Supervisor) Shutdown(ctx context.Context) error + type TaskCancelFunc func() + type TaskHost struct + func (h TaskHost) Done() <-chan struct{} + func (h TaskHost) Err() <-chan error + func (h TaskHost) HostURL() string + func (h TaskHost) Hostname() string + func (h TaskHost) Serve() error + func (h TaskHost) Shutdown(ctx context.Context) error + type TaskProcess struct + func (p TaskProcess) Done() <-chan struct{} + func (p TaskProcess) Host() TaskHost + type TaskRunner interface + Run func(TaskProcess) + func ShutdownOnInterruptTask(shutdownTimeout time.Duration) TaskRunner + type TaskRunnerFunc func(TaskProcess) + func WriteBannerTask(w io.Writer, banner string) TaskRunnerFunc + func (s TaskRunnerFunc) Run(proc TaskProcess)
Go to main page