Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckGlobalLabelEqual ¶
func CheckGlobalLabelEqual(obj, clone *metav1.ObjectMeta) bool
CheckGlobalLabelEqual checks if two objects both has the global label
func IsObjectGlobal ¶
func IsObjectGlobal(obj *metav1.ObjectMeta) bool
IsObjectGlobal return if an object is global
func SetObjectGlobal ¶
func SetObjectGlobal(obj *metav1.ObjectMeta)
SetObjectGlobal add global annotation to an object
Types ¶
type CommonController ¶
type CommonController struct {
// contains filtered or unexported fields
}
CommonController is a controller sync configMaps and secrets from master cluster to client cluster
func (*CommonController) Run ¶
func (ctrl *CommonController) Run(workers int, stopCh <-chan struct{})
Run starts and listens on channel events
type Controller ¶
type Controller interface {
// Run starts run a controller
Run(int, <-chan struct{})
}
Controller is an interface which should only contains a method Run
func NewCommonController ¶
func NewCommonController(client kubernetes.Interface, masterInformer, clientInformer informers.SharedInformerFactory, configMapRateLimiter, secretRateLimiter workqueue.RateLimiter) Controller
NewCommonController returns a new *CommonController
func NewPVController ¶
func NewPVController(master kubernetes.Interface, client kubernetes.Interface, masterInformer, clientInformer informers.SharedInformerFactory, hostIP string) Controller
NewPVController returns a new *PVController
func NewServiceController ¶
func NewServiceController(master kubernetes.Interface, client kubernetes.Interface, masterInformer, clientInformer informers.SharedInformerFactory, nsLister corelisters.NamespaceLister) Controller
NewServiceController returns a new *ServiceController
type PVController ¶
type PVController struct {
// contains filtered or unexported fields
}
PVController is a controller sync pvc and pv from client cluster to master cluster PV should be created in client, then sync to master cluster. pvc add/delete from master to client pvc/pv update、pv add/delete from client to master, this is currently only for `WaitForFirstConsumer`
func (*PVController) Run ¶
func (ctrl *PVController) Run(workers int, stopCh <-chan struct{})
Run starts and listens on channel events
type ServiceController ¶
type ServiceController struct {
// contains filtered or unexported fields
}
ServiceController is a controller sync service and endpoints from master cluster to client cluster
func (*ServiceController) Run ¶
func (ctrl *ServiceController) Run(workers int, stopCh <-chan struct{})
Run starts and listens on channel events
Source Files