Documentation
¶
Index ¶
Constants ¶
View Source
const (
ErrorCodeServerUnvailable = 503
)
error code
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Controller ¶
type Controller struct {
// GroupVersionKind indicates the controller type.
// Different instances of this struct may handle different GVKs.
// For example, this struct can be used (with adapters) to handle ReplicationController.
schema.GroupVersionKind
controller.DefaultController
// contains filtered or unexported fields
}
Controller is the controller implementation for ServicePublisher resources
func NewController ¶
func NewController( kubeclientset kubernetes.Interface, carbonclientset clientset.Interface, workerInformer carboninformers.WorkerNodeInformer, publisherInformer carboninformers.ServicePublisherInformer, serviceInformer coreinformers.ServiceInformer) *Controller
NewController returns a new rollingset controller
func (*Controller) GetObj ¶
func (c *Controller) GetObj(namespace, key string) (interface{}, error)
GetObj grep replica
func (*Controller) Sync ¶
func (c *Controller) Sync(key string) error
Sync compares the actual state with the desired, and attempts to converge the two.
func (*Controller) WaitForCacheSync ¶
func (c *Controller) WaitForCacheSync(stopCh <-chan struct{}) bool
WaitForCacheSync wait for informers synced
Source Files
Click to show internal directories.
Click to hide internal directories.