multicluster

Documentation

Index

• func GetClientset(hubServerAddr, clusterID string) (kubernetes.Interface, error)
• func GetDynamicKubeclient(hubServerAddr, clusterID string) (dynamic.Interface, error)
• func GetKubeAPIReader(hubServerAddr, clusterID string) (client.Reader, error)
• func GetKubeClient(hubServerAddr, clusterID string) (client.Client, error)
• func GetKubeClientSet(hubServerAddr, clusterID string) (*kubernetes.Clientset, error)
• func GetRESTConfig(hubServerAddr, clusterID 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 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 GetKubeAPIReader

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

func GetKubeClient

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

func GetKubeClientSet

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

func GetRESTConfig

func GetRESTConfig(hubServerAddr, clusterID 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