Documentation
¶
Overview ¶
TODO: 存在一个问题，如果修改集群后立即删除，可能会因为控制器处理缓慢而这时又停止了控制器导致资源未被删除
Index ¶
Constants ¶
View Source
const ( // An unknown problem has occurred UnknowReason = "Unknow" // The resource is ready or not ResourceReadyReason = "ResourceReady" // The resource is deleted ResourceDeleteReason = "ResourceDeleted" // The resource is ready ResourceReadyMessage = "Resource is ready" // The resource is deleted ResourceDeleteMessage = "Resource is deleted" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller is the controller implementation for distribution resources
func NewController ¶
func NewController( kubeclientset dynamic.Interface, discoveryClient *discovery.DiscoveryClient, rocketclientset clientset.Interface, rdsinformers informers.DistributionInformer) *Controller
NewController returns a new trait controller
func (*Controller) Run ¶
func (c *Controller) Run(workers int, stopCh <-chan struct{}) error
Run will set up the event handlers for types we are interested in, as well as syncing informer caches and starting workers. It will block until stopCh is closed, at which point it will shutdown the workqueue and wait for workers to finish processing their current work items.
Source Files
Click to show internal directories.
Click to hide internal directories.