Documentation
¶
Index ¶
- Constants
- type ConfigMapControl
- func (rcmc *ConfigMapControl) DeleteConfigMap(ndb *v1alpha1.Ndb) error
- func (rcmc *ConfigMapControl) EnsureConfigMap(ndb *v1alpha1.Ndb) (*corev1.ConfigMap, error)
- func (rcmc *ConfigMapControl) ExtractConfig(cm *corev1.ConfigMap) (string, error)
- func (rcmc *ConfigMapControl) PatchConfigMap(ndb *v1alpha1.Ndb) (*corev1.ConfigMap, error)
- type ConfigMapControlInterface
- type Controller
- type StatefulSetControlInterface
Constants ¶
View Source
const ( // SuccessSynced is used as part of the Event 'reason' when a Foo is synced SuccessSynced = "Synced" // ErrResourceExists is used as part of the Event 'reason' when a Foo fails // to sync due to a Deployment of the same name already existing. ErrResourceExists = "ErrResourceExists" // MessageResourceExists is the message used for Events when a resource // fails to sync due to a Deployment already existing MessageResourceExists = "Resource %q already exists and is not managed by Foo" // MessageResourceSynced is the message used for an Event fired when a Foo // is synced successfully MessageResourceSynced = "Ndb synced successfully" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConfigMapControl ¶
type ConfigMapControl struct {
ConfigMapControlInterface
// contains filtered or unexported fields
}
func (*ConfigMapControl) DeleteConfigMap ¶
func (rcmc *ConfigMapControl) DeleteConfigMap(ndb *v1alpha1.Ndb) error
func (*ConfigMapControl) EnsureConfigMap ¶
func (*ConfigMapControl) ExtractConfig ¶
func (rcmc *ConfigMapControl) ExtractConfig(cm *corev1.ConfigMap) (string, error)
func (*ConfigMapControl) PatchConfigMap ¶
Patch existing config map with new configuration data generated from ndb CRD object
type ConfigMapControlInterface ¶
type ConfigMapControlInterface interface {
EnsureConfigMap(ndb *v1alpha1.Ndb) (*corev1.ConfigMap, error)
PatchConfigMap(ndb *v1alpha1.Ndb) (*corev1.ConfigMap, error)
ExtractConfig(cm *corev1.ConfigMap) (string, error)
DeleteConfigMap(ndb *v1alpha1.Ndb) error
}
func NewConfigMapControl ¶
func NewConfigMapControl(client kubernetes.Interface, configMapInformer coreinformers.ConfigMapInformer) ConfigMapControlInterface
NewConfigMapControl creates a new ConfigMapControl
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller is the main controller implementation for Ndb resources
func NewController ¶
func NewController( kubeclientset kubernetes.Interface, ndbclientset clientset.Interface, statefulSetInformer appsinformers.StatefulSetInformer, serviceInformer coreinformers.ServiceInformer, podInformer coreinformers.PodInformer, configMapInformer coreinformers.ConfigMapInformer, ndbInformer informers.NdbInformer) *Controller
NewController returns a new Ndb controller
func (*Controller) Run ¶
func (c *Controller) Run(threadiness 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.
type StatefulSetControlInterface ¶
type StatefulSetControlInterface interface {
EnsureStatefulSet(ndb *v1alpha1.Ndb) (*apps.StatefulSet, error)
GetStatefulSet(ndb *v1alpha1.Ndb) (*apps.StatefulSet, error)
Patch(ndb *v1alpha1.Ndb, old *apps.StatefulSet) (*apps.StatefulSet, error)
}
func NewRealStatefulSetControl ¶
func NewRealStatefulSetControl(client kubernetes.Interface, statefulSetLister appslisters.StatefulSetLister) StatefulSetControlInterface
NewRealStatefulSetControl creates a concrete implementation of the StatefulSetControlInterface.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.