 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Overview ¶
Proxy is a package responsible for doing common operations on kubernetes resources like UPDATE DELETE CREATE GET deployment and so on.
Index ¶
- Variables
- func BuildApiserverClient()
- func Client(cluster string) (*kubernetes.Clientset, error)
- func Cluster(cluster string) (*models.Cluster, error)
- func Managers() *sync.Map
- type CacheFactory
- func (c *CacheFactory) DeploymentLister() v1beta1.DeploymentLister
- func (c *CacheFactory) EndpointLister() v1.EndpointsLister
- func (c *CacheFactory) EventLister() v1.EventLister
- func (c *CacheFactory) HPALister() autoscalingv1.HorizontalPodAutoscalerLister
- func (c *CacheFactory) NodeLister() v1.NodeLister
- func (c *CacheFactory) PodLister() v1.PodLister
 
- type ClusterManager
- type ResourceHandler
Constants ¶
This section is empty.
Variables ¶
      View Source
      
  
var ( ErrNotExist = errors.New("cluster not exist. ") ErrMaintaining = errors.New("cluster being maintaining .please try again later. ") )
Functions ¶
func BuildApiserverClient ¶
func BuildApiserverClient()
Types ¶
type CacheFactory ¶ added in v1.3.0
type CacheFactory struct {
	// contains filtered or unexported fields
}
    func (*CacheFactory) DeploymentLister ¶ added in v1.3.0
func (c *CacheFactory) DeploymentLister() v1beta1.DeploymentLister
func (*CacheFactory) EndpointLister ¶ added in v1.3.0
func (c *CacheFactory) EndpointLister() v1.EndpointsLister
func (*CacheFactory) EventLister ¶ added in v1.3.0
func (c *CacheFactory) EventLister() v1.EventLister
func (*CacheFactory) HPALister ¶ added in v1.3.0
func (c *CacheFactory) HPALister() autoscalingv1.HorizontalPodAutoscalerLister
func (*CacheFactory) NodeLister ¶ added in v1.3.0
func (c *CacheFactory) NodeLister() v1.NodeLister
func (*CacheFactory) PodLister ¶ added in v1.3.0
func (c *CacheFactory) PodLister() v1.PodLister
type ClusterManager ¶
type ClusterManager struct {
	Cluster *models.Cluster
	// Deprecated: use KubeClient instead
	Client *kubernetes.Clientset
	// Deprecated: use KubeClient instead
	CacheFactory *CacheFactory
	Config       *rest.Config
	KubeClient   ResourceHandler
}
    func Manager ¶
func Manager(cluster string) (*ClusterManager, error)
func (ClusterManager) Close ¶
func (c ClusterManager) Close()
type ResourceHandler ¶ added in v1.3.0
type ResourceHandler interface {
	Create(kind string, namespace string, object *runtime.Unknown) (*runtime.Unknown, error)
	Update(kind string, namespace string, name string, object *runtime.Unknown) (*runtime.Unknown, error)
	Get(kind string, namespace string, name string) (runtime.Object, error)
	List(kind string, namespace string, labelSelector string) ([]runtime.Object, error)
	Delete(kind string, namespace string, name string, options *meta_v1.DeleteOptions) error
}
    func NewResourceHandler ¶ added in v1.3.0
func NewResourceHandler(kubeClient *kubernetes.Clientset, cacheFactory *CacheFactory) ResourceHandler
 Click to show internal directories. 
   Click to hide internal directories.