Documentation
¶
Index ¶
Constants ¶
View Source
const (
WebSocketPath = "/__shadowfax/events"
)
Variables ¶
This section is empty.
Functions ¶
func BroadcastWhenHealthy ¶
func BroadcastWhenHealthy(ctx context.Context, healthURL string, broadcaster *Broadcaster)
Types ¶
type Broadcaster ¶
type Broadcaster struct {
// contains filtered or unexported fields
}
Broadcaster is a thread-safe pub/sub for reload events. Listeners can subscribe to receive reload signals.
func NewBroadcaster ¶
func NewBroadcaster() *Broadcaster
func (*Broadcaster) Broadcast ¶
func (b *Broadcaster) Broadcast()
func (*Broadcaster) ListenerCount ¶
func (b *Broadcaster) ListenerCount() int
func (*Broadcaster) Subscribe ¶
func (b *Broadcaster) Subscribe() chan struct{}
func (*Broadcaster) Unsubscribe ¶
func (b *Broadcaster) Unsubscribe(ch chan struct{})
type HealthChecker ¶
type HealthChecker struct {
// contains filtered or unexported fields
}
func NewHealthChecker ¶
func NewHealthChecker(url string) *HealthChecker
func (*HealthChecker) WaitForHealthy ¶
func (*HealthChecker) WaitForHealthyWithTimeout ¶
type WebSocketHandler ¶
type WebSocketHandler struct {
// contains filtered or unexported fields
}
func NewWebSocketHandler ¶
func NewWebSocketHandler(broadcaster *Broadcaster) *WebSocketHandler
func (*WebSocketHandler) ServeHTTP ¶
func (h *WebSocketHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
Source Files
Click to show internal directories.
Click to hide internal directories.