Documentation
¶
Index ¶
- Variables
- type RegistryMessage
- 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) HandleGreetings()
- 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) SendStartMessage()
- func (r *Router) Stop()
- func (r *Router) SubscribeRegister()
- func (r *Router) SubscribeUnregister()
Constants ¶
This section is empty.
Variables ¶
View Source
var DrainTimeout = errors.New("router: Drain timeout")
Functions ¶
This section is empty.
Types ¶
type RegistryMessage ¶
type RegistryMessage struct {
Host string `json:"host"`
Port uint16 `json:"port"`
Uris []route.Uri `json:"uris"`
Tags map[string]string `json:"tags"`
App string `json:"app"`
StaleThresholdInSeconds int `json:"stale_threshold_in_seconds"`
RouteServiceUrl string `json:"route_service_url"`
PrivateInstanceId string `json:"private_instance_id"`
}
func (*RegistryMessage) ValidateMessage ¶
func (rm *RegistryMessage) ValidateMessage() bool
type Router ¶
type Router struct {
// contains filtered or unexported fields
}
func (*Router) DrainAndStop ¶
func (r *Router) DrainAndStop()
func (*Router) HandleConnState ¶
func (*Router) HandleGreetings ¶
func (r *Router) HandleGreetings()
func (*Router) OnErrOrSignal ¶
func (*Router) RegisterComponent ¶
func (r *Router) RegisterComponent()
func (*Router) ScheduleFlushApps ¶
func (r *Router) ScheduleFlushApps()
func (*Router) SendStartMessage ¶
func (r *Router) SendStartMessage()
func (*Router) SubscribeRegister ¶
func (r *Router) SubscribeRegister()
func (*Router) SubscribeUnregister ¶
func (r *Router) SubscribeUnregister()
Source Files
Click to show internal directories.
Click to hide internal directories.