Documentation ¶
Index ¶
Constants ¶
View Source
const ( FLUX_STATE_RECEIVED string = "FLUX_STATE_RECEIVED" FLUX_EVENTS_RECEIVED string = "FLUX_EVENTS_RECEIVED" POD_LOGS_RECEIVED string = "POD_LOGS_RECEIVED" DEPLOYMENT_CREATED string = "DEPLOYMENT_CREATED" DEPLOYMENT_UPDATED string = "DEPLOYMENT_UPDATED" DEPLOYMENT_DELETED string = "DEPLOYMENT_DELETED" POD_CREATED string = "POD_CREATED" POD_UPDATED string = "POD_UPDATED" POD_DELETED string = "POD_DELETED" SERVICE_CREATED string = "SERVICE_CREATED" SERVICE_UPDATED string = "SERVICE_UPDATED" SERVICE_DELETED string = "SERVICE_DELETED" INGRESS_CREATED string = "INGRESS_CREATED" INGRESS_UPDATED string = "INGRESS_UPDATED" INGRESS_DELETED string = "INGRESS_DELETED" )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client is a middleman between the websocket connection and the hub.
type ClientHub ¶
type ClientHub struct { // Registered clients. Clients map[*Client]bool // Updates to be broadcasted to the clients. Broadcast chan []byte // Updates to be sent to a single user. Send chan *ClientMessage // Register requests from the clients. Register chan *Client // Unregister requests from clients. Unregister chan *Client }
ClientHub maintains the set of active clients and broadcasts messages to the clients.
func NewClientHub ¶
func NewClientHub() *ClientHub
type ClientMessage ¶
Click to show internal directories.
Click to hide internal directories.