session

Documentation

Index

• type K8sSession
  • func CreateK8sSession() (*K8sSession, error)
  • func (ks *K8sSession) HandleReconnection()
  • func (ks *K8sSession) ServeConnStatus() http.HandlerFunc
  • func (ks *K8sSession) StartClusterMonitoring()
  • func (ks *K8sSession) Switch() http.HandlerFunc

Types

type K8sSession

type K8sSession struct {
	Clients        *client.Clients
	Cache          *resources.Cache
	Cancel         context.CancelFunc
	CurrentCtx     string
	CurrentCluster string
	Status         chan string
	InCluster      bool
	// contains filtered or unexported fields
}

func CreateK8sSession

func CreateK8sSession() (*K8sSession, error)

CreateK8sSession creates a new k8s session

func (*K8sSession) HandleReconnection

func (ks *K8sSession) HandleReconnection()

HandleReconnection infinitely retries to re-create the client and cache of the formerly connected cluster

func (*K8sSession) ServeConnStatus

func (ks *K8sSession) ServeConnStatus() http.HandlerFunc

ServeConnStatus returns a handler function that streams the connection status to the client

func (*K8sSession) StartClusterMonitoring

func (ks *K8sSession) StartClusterMonitoring()

StartClusterMonitoring is a goroutine that checks the connection to the cluster

func (*K8sSession) Switch

func (ks *K8sSession) Switch() http.HandlerFunc

Switch returns a handler function that switches the current cluster and updates the K8sSession