Documentation
¶
Index ¶
- Constants
- Variables
- type CertType
- type HealthListener
- type RouteServiceRoundTripper
- type RouteServicesServer
- type Router
- 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) 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
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 HealthListener ¶
type HealthListener struct {
HealthCheck http.Handler
TLSConfig *tls.Config
Port uint16
// 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
}
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 (*Router) DrainAndStop ¶
func (r *Router) DrainAndStop()
func (*Router) HandleConnState ¶
func (*Router) OnErrOrSignal ¶
func (*Router) RegisterComponent ¶
func (r *Router) RegisterComponent()
func (*Router) ScheduleFlushApps ¶
func (r *Router) ScheduleFlushApps()
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()
Source Files
Click to show internal directories.
Click to hide internal directories.