Documentation
¶
Index ¶
- func GetClientSetFromKubeConfig(clusterID, kubeConfig string) (kubernetes.Interface, error)
- func GetClientset(hubServerAddr, clusterID string) (kubernetes.Interface, error)
- func GetDiscoveryClient(hubServerAddr, clusterID string) (*discovery.DiscoveryClient, error)
- func GetDiscoveryClientFromKubeConfig(clusterID, kubeConfig string) (*discovery.DiscoveryClient, error)
- func GetDynamicKubeclient(hubServerAddr, clusterID string) (dynamic.Interface, error)
- func GetDynamicKubeclientFromKubeConfig(clusterID, kubeConfig string) (dynamic.Interface, error)
- func GetIstioV1Alpha3Client(hubServerAddr, clusterID string) (*v1alpha3.NetworkingV1alpha3Client, error)
- func GetIstioV1Alpha3ClientFromKubeConfig(clusterID, kubeConfig string) (*v1alpha3.NetworkingV1alpha3Client, 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 GetKubeMetricsClient(hubServerAddr, clusterID string) (*v1beta1.MetricsV1beta1Client, error)
- func GetKubeMetricsClientFromKubeConfig(clusterID, kubeConfig string) (*v1beta1.MetricsV1beta1Client, error)
- func GetRESTConfig(hubServerAddr, clusterID string) (*rest.Config, error)
- func GetRestConfigFromKubeConfig(clusterID, kubeConfig string) (*rest.Config, error)
- type Agent
- 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) GetDisCoveryClient(clusterID string) (*discovery.DiscoveryClient, error)
- func (s *Agent) GetDynamicKubeClient(clusterID string) (dynamic.Interface, error)
- func (s *Agent) GetIstioV1Alpha3Client(clusterID string) (*v1alpha3.NetworkingV1alpha3Client, error)
- func (s *Agent) GetKubeClient(clusterID string) (client.Client, error)
- func (s *Agent) GetKubeMetricsClient(clusterID string) (*v1beta1.MetricsV1beta1Client, 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 (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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 GetDiscoveryClient ¶
func GetDiscoveryClient(hubServerAddr, clusterID string) (*discovery.DiscoveryClient, error)
func GetDiscoveryClientFromKubeConfig ¶
func GetDiscoveryClientFromKubeConfig(clusterID, kubeConfig string) (*discovery.DiscoveryClient, error)
func GetDynamicKubeclient ¶
func GetIstioV1Alpha3Client ¶
func GetIstioV1Alpha3Client(hubServerAddr, clusterID string) (*v1alpha3.NetworkingV1alpha3Client, error)
func GetIstioV1Alpha3ClientFromKubeConfig ¶
func GetIstioV1Alpha3ClientFromKubeConfig(clusterID, kubeConfig string) (*v1alpha3.NetworkingV1alpha3Client, error)
func GetKubeAPIReader ¶
func GetKubeClientSet ¶
func GetKubeClientSet(hubServerAddr, clusterID string) (*kubernetes.Clientset, error)
func GetKubeClientSetFromKubeConfig ¶
func GetKubeClientSetFromKubeConfig(clusterID, kubeConfig string) (*kubernetes.Clientset, error)
func GetKubeMetricsClient ¶
func GetKubeMetricsClient(hubServerAddr, clusterID string) (*v1beta1.MetricsV1beta1Client, error)
func GetKubeMetricsClientFromKubeConfig ¶
func GetKubeMetricsClientFromKubeConfig(clusterID, kubeConfig string) (*v1beta1.MetricsV1beta1Client, error)
Types ¶
type Agent ¶
type Agent struct {
// contains filtered or unexported fields
}
func (*Agent) ClusterConnected ¶
func (*Agent) DisconnectCluster ¶
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) GetDisCoveryClient ¶
func (s *Agent) GetDisCoveryClient(clusterID string) (*discovery.DiscoveryClient, error)
func (*Agent) GetDynamicKubeClient ¶
func (*Agent) GetIstioV1Alpha3Client ¶
func (s *Agent) GetIstioV1Alpha3Client(clusterID string) (*v1alpha3.NetworkingV1alpha3Client, error)
func (*Agent) GetKubeClient ¶
func (*Agent) GetKubeMetricsClient ¶
func (s *Agent) GetKubeMetricsClient(clusterID string) (*v1beta1.MetricsV1beta1Client, error)
func (*Agent) ProxyAgent ¶
func (s *Agent) ProxyAgent(writer gin.ResponseWriter, request *http.Request)
func (*Agent) ReconnectCluster ¶
type HubClient ¶
type HubClient struct {
// contains filtered or unexported fields
}
func NewHubClient ¶
func (*HubClient) AgentProxy ¶
func (c *HubClient) AgentProxy(w http.ResponseWriter, r *http.Request)
func (*HubClient) Disconnect ¶
func (*HubClient) HasSession ¶
Source Files
Click to show internal directories.
Click to hide internal directories.