router

package
v0.0.0-...-96ff825 Latest Latest
Warning

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

Go to latest
Published: May 16, 2024 License: Apache-2.0, BSD-2-Clause-Views, BSD-3-Clause, + 1 more Imports: 32 Imported by: 0

Documentation

Index

Constants

View Source
const MAX_HEADER_BYTES = 1024 * 1024

golang's default was 1mb. We want to make this explicit, so that we're able to create access logs via our own handler to process MAX_HEADER_BYTES

Variables

View Source
var DrainTimeout = errors.New("router: Drain timeout")

Functions

This section is empty.

Types

type CertType

type CertType int

type HealthListener

type HealthListener struct {
	HealthCheck http.Handler
	TLSConfig   *tls.Config
	Port        uint16
	Router      *Router
	Logger      logger.Logger
	// contains filtered or unexported fields
}

func (*HealthListener) ListenAndServe

func (hl *HealthListener) ListenAndServe() error

func (*HealthListener) Stop

func (hl *HealthListener) Stop()

type RouteServiceRoundTripper

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

func (RouteServiceRoundTripper) RoundTrip

func (rc RouteServiceRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

type RouteServicesServer

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

func NewRouteServicesServer

func NewRouteServicesServer(cfg *config.Config) (*RouteServicesServer, error)

func (*RouteServicesServer) GetRoundTripper

func (rs *RouteServicesServer) GetRoundTripper() RouteServiceRoundTripper

func (*RouteServicesServer) Serve

func (rs *RouteServicesServer) Serve(handler http.Handler, errChan chan error) error

func (*RouteServicesServer) Stop

func (rs *RouteServicesServer) Stop()

type Router

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

func NewRouter

func NewRouter(
	logger logger.Logger,
	cfg *config.Config,
	handler http.Handler,
	mbusClient *nats.Conn,
	r *registry.RouteRegistry,
	v varz.Varz,
	h *health.Health,
	logCounter *schema.LogCounter,
	errChan chan error,
	routeServicesServer rss,
) (*Router, error)

func (*Router) Drain

func (r *Router) Drain(drainWait, drainTimeout time.Duration) error

func (*Router) DrainAndStop

func (r *Router) DrainAndStop()

func (*Router) HandleConnState

func (r *Router) HandleConnState(conn net.Conn, state http.ConnState)

func (*Router) IsStopping

func (r *Router) IsStopping() bool

func (*Router) OnErrOrSignal

func (r *Router) OnErrOrSignal(signals <-chan os.Signal, errChan chan error)

func (*Router) RegisterComponent

func (r *Router) RegisterComponent()

func (*Router) Run

func (r *Router) Run(signals <-chan os.Signal, ready chan<- struct{}) error

func (*Router) ScheduleFlushApps

func (r *Router) ScheduleFlushApps()

func (*Router) Stop

func (r *Router) Stop()

type RoutesListener

type RoutesListener struct {
	Config        *config.Config
	RouteRegistry json.Marshaler
	// contains filtered or unexported fields
}

func (*RoutesListener) ListenAndServe

func (rl *RoutesListener) ListenAndServe() error

func (*RoutesListener) Stop

func (rl *RoutesListener) Stop()

Jump to

Keyboard shortcuts

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