multicluster

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 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) 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 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 GetDiscoveryClient

func GetDiscoveryClient(hubServerAddr, clusterID string) (*discovery.DiscoveryClient, error)

func GetDiscoveryClientFromKubeConfig

func GetDiscoveryClientFromKubeConfig(clusterID, kubeConfig string) (*discovery.DiscoveryClient, error)

func GetDynamicKubeclient

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

func GetDynamicKubeclientFromKubeConfig

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

func GetIstioV1Alpha3Client

func GetIstioV1Alpha3Client(hubServerAddr, clusterID string) (*v1alpha3.NetworkingV1alpha3Client, error)

func GetIstioV1Alpha3ClientFromKubeConfig

func GetIstioV1Alpha3ClientFromKubeConfig(clusterID, kubeConfig string) (*v1alpha3.NetworkingV1alpha3Client, 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 GetKubeMetricsClient

func GetKubeMetricsClient(hubServerAddr, clusterID string) (*v1beta1.MetricsV1beta1Client, error)

func GetKubeMetricsClientFromKubeConfig

func GetKubeMetricsClientFromKubeConfig(clusterID, kubeConfig string) (*v1beta1.MetricsV1beta1Client, 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) GetDisCoveryClient

func (s *Agent) GetDisCoveryClient(clusterID string) (*discovery.DiscoveryClient, error)

func (*Agent) GetDynamicKubeClient

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

func (*Agent) GetIstioV1Alpha3Client

func (s *Agent) GetIstioV1Alpha3Client(clusterID string) (*v1alpha3.NetworkingV1alpha3Client, error)

func (*Agent) GetKubeClient

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

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

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