Documentation
¶
Index ¶
- type AutoscalingGroupSyncController
- func (c *AutoscalingGroupSyncController) Create(ag cerebralv1alpha1.AutoscalingGroup) error
- func (c *AutoscalingGroupSyncController) Delete(name string) error
- func (c *AutoscalingGroupSyncController) SyncWithCloud(stopCh <-chan struct{}) error
- func (c *AutoscalingGroupSyncController) Update(updatedAG cerebralv1alpha1.AutoscalingGroup, obj interface{}) error
- type AutoscalingPolicySyncController
- func (c *AutoscalingPolicySyncController) Create(ag cerebralv1alpha1.AutoscalingPolicy) error
- func (c *AutoscalingPolicySyncController) Delete(name string) error
- func (c *AutoscalingPolicySyncController) SyncWithCloud(stopCh <-chan struct{}) error
- func (c *AutoscalingPolicySyncController) Update(updatedAG cerebralv1alpha1.AutoscalingPolicy, obj interface{}) error
- type PluginSyncController
- type RegistrySyncController
- type UserSyncController
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AutoscalingGroupSyncController ¶
type AutoscalingGroupSyncController struct {
// contains filtered or unexported fields
}
AutoscalingGroupSyncController is the implementation for syncing AutoscalingGroup CRDs
func NewAutoscalingGroupController ¶
func NewAutoscalingGroupController(kubeclientset kubernetes.Interface, clientset cerebral.Interface, cerebralInformerFactory cerebralinformers.SharedInformerFactory, cloud cscloud.Interface) *AutoscalingGroupSyncController
NewAutoscalingGroupController returns a AutoscalingGroupSyncController that will be in control of pulling from cloud comparing to the CR cache and modifying based on those compares
func (*AutoscalingGroupSyncController) Create ¶
func (c *AutoscalingGroupSyncController) Create(ag cerebralv1alpha1.AutoscalingGroup) error
Create takes an AutoscalingGroup in cache and creates the CR
func (*AutoscalingGroupSyncController) Delete ¶
func (c *AutoscalingGroupSyncController) Delete(name string) error
Delete takes the name of the CR and deletes it
func (*AutoscalingGroupSyncController) SyncWithCloud ¶
func (c *AutoscalingGroupSyncController) SyncWithCloud(stopCh <-chan struct{}) error
SyncWithCloud kicks of the Sync() function, should be started only after the informer caches we are about to use are synced
func (*AutoscalingGroupSyncController) Update ¶
func (c *AutoscalingGroupSyncController) Update(updatedAG cerebralv1alpha1.AutoscalingGroup, obj interface{}) error
Update takes an AutoscalingGroup and updates the associated AutoscalingGroup CR spec with the new values
type AutoscalingPolicySyncController ¶
type AutoscalingPolicySyncController struct {
// contains filtered or unexported fields
}
AutoscalingPolicySyncController is the implementation for syncing AutoscalingPolicy CRDs
func NewAutoscalingPolicyController ¶
func NewAutoscalingPolicyController(kubeclientset kubernetes.Interface, clientset cerebral.Interface, cerebralInformerFactory cerebralinformers.SharedInformerFactory, cloud cscloud.Interface) *AutoscalingPolicySyncController
NewAutoscalingPolicyController returns a AutoscalingPolicySyncController that will be in control of pulling from cloud comparing to the CR cache and modifying based on those compares
func (*AutoscalingPolicySyncController) Create ¶
func (c *AutoscalingPolicySyncController) Create(ag cerebralv1alpha1.AutoscalingPolicy) error
Create takes a AutoscalingPolicy in cache and creates the CR
func (*AutoscalingPolicySyncController) Delete ¶
func (c *AutoscalingPolicySyncController) Delete(name string) error
Delete takes a name or the CRD and deletes it
func (*AutoscalingPolicySyncController) SyncWithCloud ¶
func (c *AutoscalingPolicySyncController) SyncWithCloud(stopCh <-chan struct{}) error
SyncWithCloud kicks of the Sync() function, should be started only after Informer caches are synced
func (*AutoscalingPolicySyncController) Update ¶
func (c *AutoscalingPolicySyncController) Update(updatedAG cerebralv1alpha1.AutoscalingPolicy, obj interface{}) error
Update takes an AutoscalingPolicy spec and updates the associated AutoscalingPolicy CR spec with the new values
type PluginSyncController ¶
type PluginSyncController struct {
// contains filtered or unexported fields
}
PluginSyncController is the implementation for syncing Plugin CRDs
func NewPlugin ¶
func NewPlugin(kubeclientset kubernetes.Interface, clientset csclientset.Interface, csInformerFactory csinformers.SharedInformerFactory, cloud cscloud.Interface) *PluginSyncController
NewPlugin returns a PluginSyncController that will be in control of pulling from cloud comparing to the CRD cache and modifying based on those compares
func (*PluginSyncController) Create ¶
func (c *PluginSyncController) Create(p csv3.PluginSpec) error
Create takes a plugin spec in cache and creates the CRD
func (*PluginSyncController) Delete ¶
func (c *PluginSyncController) Delete(namespace, name string) error
Delete takes a name or the CRD and deletes it
func (*PluginSyncController) SyncWithCloud ¶
func (c *PluginSyncController) SyncWithCloud(stopCh <-chan struct{}) error
SyncWithCloud kicks of the Sync() function, should be started only after Informer caches we are about to use are synced
func (*PluginSyncController) Update ¶
func (c *PluginSyncController) Update(p csv3.PluginSpec, obj interface{}) error
Update takes a plugin spec and updates the associated Plugin CR spec with the new values
type RegistrySyncController ¶
type RegistrySyncController struct {
// contains filtered or unexported fields
}
RegistrySyncController is the implementation for syncing Registry CRDs
func NewRegistry ¶
func NewRegistry(kubeclientset kubernetes.Interface, clientset csclientset.Interface, csInformerFactory csinformers.SharedInformerFactory, cloud cscloud.Interface) *RegistrySyncController
NewRegistry returns a RegistrySyncController that will be in control of pulling from cloud comparing to the CRD cache and modifying based on those compares
func (*RegistrySyncController) Create ¶
func (c *RegistrySyncController) Create(u csv3.RegistrySpec) error
Create takes a registry spec in cache and creates the CRD
func (*RegistrySyncController) Delete ¶
func (c *RegistrySyncController) Delete(namespace, name string) error
Delete takes a name or the CRD and deletes it
func (*RegistrySyncController) SyncWithCloud ¶
func (c *RegistrySyncController) SyncWithCloud(stopCh <-chan struct{}) error
SyncWithCloud kicks of the Sync() function, should be started only after Informer caches we are about to use are synced
type UserSyncController ¶
type UserSyncController struct {
// contains filtered or unexported fields
}
UserSyncController is the implementation for syncing User CRDs
func NewUser ¶
func NewUser(kubeclientset kubernetes.Interface, clientset csclientset.Interface, csInformerFactory csinformers.SharedInformerFactory, cloud cscloud.Interface) *UserSyncController
NewUser returns a UserSyncController that will be in control of pulling from cloud comparing to the CRD cache and modifying based on those compares
func (*UserSyncController) Create ¶
func (c *UserSyncController) Create(u csv3.UserSpec) error
Create takes a user spec in cache and creates the CRD
func (*UserSyncController) Delete ¶
func (c *UserSyncController) Delete(namespace, name string) error
Delete takes a name or the CRD and deletes it
func (*UserSyncController) SyncWithCloud ¶
func (c *UserSyncController) SyncWithCloud(stopCh <-chan struct{}) error
SyncWithCloud kicks of the Sync() function, should be started only after Informer caches we are about to use are synced
Source Files