router

Documentation

Index

• Constants
• Variables
• type CertType
• type HealthListener
  • func (hl *HealthListener) ListenAndServe() error
  • func (hl *HealthListener) Stop()
• type RouteServiceRoundTripper
  • func (rc RouteServiceRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)
• type RouteServicesServer
  • func NewRouteServicesServer(cfg *config.Config) (*RouteServicesServer, error)
  • func (rs *RouteServicesServer) GetRoundTripper() RouteServiceRoundTripper
  • func (rs *RouteServicesServer) Serve(handler http.Handler, errChan chan error) error
  • func (rs *RouteServicesServer) Stop()
• type Router
  • func NewRouter(logger logger.Logger, cfg *config.Config, handler http.Handler, ...) (*Router, error)
  • func (r *Router) Drain(drainWait, drainTimeout time.Duration) error
  • func (r *Router) DrainAndStop()
  • func (r *Router) HandleConnState(conn net.Conn, state http.ConnState)
  • func (r *Router) IsStopping() bool
  • func (r *Router) OnErrOrSignal(signals <-chan os.Signal, errChan chan error)
  • func (r *Router) RegisterComponent()
  • func (r *Router) Run(signals <-chan os.Signal, ready chan<- struct{}) error
  • func (r *Router) ScheduleFlushApps()
  • func (r *Router) Stop()
• type RoutesListener
  • func (rl *RoutesListener) ListenAndServe() error
  • func (rl *RoutesListener) Stop()

Constants

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

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

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()