client

Documentation

Index

• Variables
• func BuildApiserverClient()
• func Client(cluster string) (*kubernetes.Clientset, error)
• func Clients() map[string]*kubernetes.Clientset
• func Cluster(cluster string) (*models.Cluster, error)
• func Managers() map[string]*ClusterManager
• type CacheIndexer
• type ClusterManager
  • func Manager(cluster string) (*ClusterManager, error)
  • func (c ClusterManager) Close()

Variables

var (
	ErrNotExist    = errors.New("cluster not exist. ")
	ErrMaintaining = errors.New("cluster being maintaining .please try again later. ")
)

Functions

func BuildApiserverClient

func BuildApiserverClient()

func Client

func Client(cluster string) (*kubernetes.Clientset, error)

func Clients

func Clients() map[string]*kubernetes.Clientset

func Cluster

func Cluster(cluster string) (*models.Cluster, error)

func Managers

func Managers() map[string]*ClusterManager

Types

type CacheIndexer

type CacheIndexer struct {
	Pod   kcache.Indexer
	Event kcache.Indexer
	// contains filtered or unexported fields
}

type ClusterManager

type ClusterManager struct {
	Cluster *models.Cluster
	Client  *kubernetes.Clientset
	Config  *rest.Config
	Indexer *CacheIndexer
}

func Manager

func Manager(cluster string) (*ClusterManager, error)

func (ClusterManager) Close

func (c ClusterManager) Close()