Documentation
¶
Index ¶
- Variables
- type CertType
- 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()
Constants ¶
This section is empty.
Variables ¶
View Source
var DrainTimeout = errors.New("router: Drain timeout")
Functions ¶
This section is empty.
Types ¶
type RouteServiceRoundTripper ¶
type RouteServiceRoundTripper struct {
// contains filtered or unexported fields
}
type RouteServicesServer ¶
type RouteServicesServer struct {
// contains filtered or unexported fields
}
func NewRouteServicesServer ¶
func NewRouteServicesServer() (*RouteServicesServer, error)
func (*RouteServicesServer) ArrivedViaARouteServicesServer ¶
func (rs *RouteServicesServer) ArrivedViaARouteServicesServer(req *http.Request) bool
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 {
HeartbeatOK *int32
// 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()
Source Files
Click to show internal directories.
Click to hide internal directories.