http

Jul 4, 2024

Changes in this version

+ const MB

+ const PluginName

+ const RrMode

+ const RrModeHTTP

+ type Informer interface

+ Workers func() []*process.State

+ type Plugin struct

+ func (p *Plugin) AddWorker() error

+ func (p *Plugin) Collects() []*dep.In

+ func (p *Plugin) Init(cfg common.Configurer, log common.Logger, srv common.Server) error

+ func (p *Plugin) MetricsCollector() []prometheus.Collector

+ func (p *Plugin) Name() string

+ func (p *Plugin) Ready() (*status.Status, error)

+ func (p *Plugin) RemoveWorker(ctx context.Context) error

+ func (p *Plugin) Reset() error

+ func (p *Plugin) Serve() chan error

+ func (p *Plugin) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (p *Plugin) Status() (*status.Status, error)

+ func (p *Plugin) Stop(ctx context.Context) error

+ func (p *Plugin) Workers() []*process.State

+ type StatsExporter struct

+ StateDesc *prometheus.Desc

+ TotalMemoryDesc *prometheus.Desc

+ TotalWorkersDesc *prometheus.Desc

+ WorkerMemoryDesc *prometheus.Desc

+ Workers Informer

+ WorkersInvalid *prometheus.Desc

+ WorkersReady *prometheus.Desc

+ WorkersWorking *prometheus.Desc

+ func (s *StatsExporter) Collect(ch chan<- prometheus.Metric)

+ func (s *StatsExporter) Describe(d chan<- *prometheus.Desc)

+ type StdLogAdapter struct

+ func NewStdAdapter(log *zap.Logger) *StdLogAdapter

+ func (s *StdLogAdapter) Write(p []byte) (n int, err error)