http

package
v2.4.0-alpha.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 12, 2021 License: MIT Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// PluginName declares plugin name.
	PluginName = "http"

	// RrMode RR_HTTP env variable key (internal) if the HTTP presents
	RrMode = "RR_MODE"

	HTTPSScheme = "https"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Middleware

type Middleware interface {
	Middleware(f http.Handler) http.Handler
}

Middleware interface

type Plugin

type Plugin struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Plugin manages pool, http servers. The main http plugin structure

func (*Plugin) AddMiddleware

func (p *Plugin) AddMiddleware(name endure.Named, m Middleware)

AddMiddleware is base requirement for the middleware (name and Middleware)

func (*Plugin) Available added in v2.2.0

func (p *Plugin) Available()

Available interface implementation

func (*Plugin) Collect added in v2.3.0

func (p *Plugin) Collect(ch chan<- prometheus.Metric)

func (*Plugin) Collects

func (p *Plugin) Collects() []interface{}

Collects collecting http middlewares

func (*Plugin) Describe added in v2.3.0

func (p *Plugin) Describe(d chan<- *prometheus.Desc)

func (*Plugin) Init

func (p *Plugin) Init(cfg config.Configurer, rrLogger logger.Logger, server server.Server) error

Init must return configure svc and return true if svc hasStatus enabled. Must return error in case of misconfiguration. Services must not be used without proper configuration pushed first.

func (*Plugin) MetricsCollector added in v2.3.0

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

func (*Plugin) Name

func (p *Plugin) Name() string

Name returns endure.Named interface implementation

func (*Plugin) Ready added in v2.0.4

func (p *Plugin) Ready() status.Status

Ready return readiness status of the particular plugin

func (*Plugin) Reset

func (p *Plugin) Reset() error

Reset destroys the old pool and replaces it with new one, waiting for old pool to die

func (*Plugin) Serve

func (p *Plugin) Serve() chan error

Serve serves the svc.

func (*Plugin) ServeHTTP

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

ServeHTTP handles connection using set of middleware and pool PSR-7 server.

func (*Plugin) Status

func (p *Plugin) Status() status.Status

Status return status of the particular plugin

func (*Plugin) Stop

func (p *Plugin) Stop() error

Stop stops the http.

func (*Plugin) Workers

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

Workers returns slice with the process states for the workers

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL