multicluster

Documentation

Index

• func GetClientSetFromKubeConfig(clusterID, kubeConfig string) (kubernetes.Interface, error)
• func GetClientset(hubServerAddr, clusterID string) (kubernetes.Interface, error)
• func GetDynamicKubeclient(hubServerAddr, clusterID string) (dynamic.Interface, error)
• func GetDynamicKubeclientFromKubeConfig(clusterID, kubeConfig string) (dynamic.Interface, error)
• func GetKubeAPIReader(hubServerAddr, clusterID string) (client.Reader, error)
• func GetKubeClient(hubServerAddr, clusterID string) (client.Client, error)
• func GetKubeClientFromKubeConfig(clusterID, kubeConfig string) (client.Client, error)
• func GetKubeClientSet(hubServerAddr, clusterID string) (*kubernetes.Clientset, error)
• func GetKubeClientSetFromKubeConfig(clusterID, kubeConfig string) (*kubernetes.Clientset, error)
• func GetRESTConfig(hubServerAddr, clusterID string) (*rest.Config, error)
• func GetRestConfigFromKubeConfig(clusterID, kubeConfig string) (*rest.Config, error)
• type Agent
  • func NewAgent(hubServerAddr string) (*Agent, error)
  • func (s *Agent) ClusterConnected(clusterID string) bool
  • func (s *Agent) DisconnectCluster(username string, clusterID string, logger *zap.SugaredLogger) error
  • func (s *Agent) GetClientGoKubeClient(clusterID string) (*kubernetes.Clientset, error)
  • func (s *Agent) GetClientset(clusterID string) (kubernetes.Interface, error)
  • func (s *Agent) GetDynamicKubeClient(clusterID string) (dynamic.Interface, error)
  • func (s *Agent) GetKubeClient(clusterID string) (client.Client, error)
  • func (s *Agent) ProxyAgent(writer gin.ResponseWriter, request *http.Request)
  • func (s *Agent) ReconnectCluster(username string, clusterID string, logger *zap.SugaredLogger) error
• type HubClient
  • func NewHubClient(hubServerAddr string) (*HubClient, error)
  • func (c *HubClient) AgentProxy(w http.ResponseWriter, r *http.Request)
  • func (c *HubClient) CreatePost(uri string) (*http.Request, error)
  • func (c *HubClient) Disconnect(id string) error
  • func (c *HubClient) Do(uri string) error
  • func (c *HubClient) HasSession(id string) error
  • func (c *HubClient) Restore(id string) error

Functions

func GetClientSetFromKubeConfig

func GetClientSetFromKubeConfig(clusterID, kubeConfig string) (kubernetes.Interface, error)

func GetClientset

func GetClientset(hubServerAddr, clusterID string) (kubernetes.Interface, error)

GetClientset returns a client to interact with APIServer which implements kubernetes.Interface

func GetDynamicKubeclient

func GetDynamicKubeclient(hubServerAddr, clusterID string) (dynamic.Interface, error)

func GetDynamicKubeclientFromKubeConfig

func GetDynamicKubeclientFromKubeConfig(clusterID, kubeConfig string) (dynamic.Interface, error)

func GetKubeAPIReader

func GetKubeAPIReader(hubServerAddr, clusterID string) (client.Reader, error)

func GetKubeClient

func GetKubeClient(hubServerAddr, clusterID string) (client.Client, error)

func GetKubeClientFromKubeConfig

func GetKubeClientFromKubeConfig(clusterID, kubeConfig string) (client.Client, error)

func GetKubeClientSet

func GetKubeClientSet(hubServerAddr, clusterID string) (*kubernetes.Clientset, error)

func GetKubeClientSetFromKubeConfig

func GetKubeClientSetFromKubeConfig(clusterID, kubeConfig string) (*kubernetes.Clientset, error)

func GetRESTConfig

func GetRESTConfig(hubServerAddr, clusterID string) (*rest.Config, error)

func GetRestConfigFromKubeConfig

func GetRestConfigFromKubeConfig(clusterID, kubeConfig string) (*rest.Config, error)

Types

type Agent

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

func NewAgent

func NewAgent(hubServerAddr string) (*Agent, error)

func (*Agent) ClusterConnected

func (s *Agent) ClusterConnected(clusterID string) bool

func (*Agent) DisconnectCluster

func (s *Agent) DisconnectCluster(username string, clusterID string, logger *zap.SugaredLogger) error

func (*Agent) GetClientGoKubeClient

func (s *Agent) GetClientGoKubeClient(clusterID string) (*kubernetes.Clientset, error)

func (*Agent) GetClientset

func (s *Agent) GetClientset(clusterID string) (kubernetes.Interface, error)

func (*Agent) GetDynamicKubeClient

func (s *Agent) GetDynamicKubeClient(clusterID string) (dynamic.Interface, error)

func (*Agent) GetKubeClient

func (s *Agent) GetKubeClient(clusterID string) (client.Client, error)

func (*Agent) ProxyAgent

func (s *Agent) ProxyAgent(writer gin.ResponseWriter, request *http.Request)

func (*Agent) ReconnectCluster

func (s *Agent) ReconnectCluster(username string, clusterID string, logger *zap.SugaredLogger) error

type HubClient

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

func NewHubClient

func NewHubClient(hubServerAddr string) (*HubClient, error)

func (*HubClient) AgentProxy

func (c *HubClient) AgentProxy(w http.ResponseWriter, r *http.Request)

func (*HubClient) CreatePost

func (c *HubClient) CreatePost(uri string) (*http.Request, error)

func (*HubClient) Disconnect

func (c *HubClient) Disconnect(id string) error

func (*HubClient) Do

func (c *HubClient) Do(uri string) error

func (*HubClient) HasSession

func (c *HubClient) HasSession(id string) error

func (*HubClient) Restore

func (c *HubClient) Restore(id string) error