web

Documentation

Index

• func NewServer(options ServerOptions) *server
• type ServerConfigError
• type ServerOptions
• type WsClient
  • func NewWsClient(hub *WsHub, w http.ResponseWriter, r *http.Request) (*WsClient, error)
  • func (c *WsClient) HandleReads()
  • func (c *WsClient) HandleWrites()
• type WsHub
  • func NewHub() *WsHub
  • func (h *WsHub) Run()

Functions

func NewServer

func NewServer(options ServerOptions) *server

Types

type ServerConfigError

type ServerConfigError interface {
	error
	KubeconfigDefaultLocation() string
	KubeconfigMissing() bool
	BootstrapMissing() bool
}

type ServerOptions

type ServerOptions struct {
	Host       string
	Port       int32
	Kubeconfig string
}

type WsClient

type WsClient struct {
	// contains filtered or unexported fields
}

func NewWsClient

func NewWsClient(hub *WsHub, w http.ResponseWriter, r *http.Request) (*WsClient, error)

func (*WsClient) HandleReads

func (c *WsClient) HandleReads()

func (*WsClient) HandleWrites

func (c *WsClient) HandleWrites()

HandleWrites writes messages from the hub to the websocket connection.

A goroutine running writePump is started for each connection. The application ensures that there is at most one writer to a connection by executing all writes from this goroutine.

type WsHub

type WsHub struct {
	// Inbound messages from the clients.
	Broadcast chan []byte

	// Register requests from the clients.
	Register chan *WsClient

	// Unregister requests from clients.
	Unregister chan *WsClient
	// contains filtered or unexported fields
}

WsHub maintains the set of active clients and broadcasts messages to the clients.

func NewHub

func NewHub() *WsHub

NewHub creates new WsHub

func (*WsHub) Run

func (h *WsHub) Run()

Run handles communication operations with WsHub