Documentation
¶
Index ¶
- Variables
- 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 Router ¶
type Router struct {
HeartbeatOK *int32
NatsHost *atomic.Value
// 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.