Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PluginSyncController ¶
type PluginSyncController struct {
// contains filtered or unexported fields
}
PluginSyncController is the implementation for syncing Plugin CRDs
func NewPlugin ¶
func NewPlugin(csInformerFactory csinformers.SharedInformerFactory, clientset csclientset.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(u containershipv3.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
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, csInformerFactory csinformers.SharedInformerFactory, clientset csclientset.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 containershipv3.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, csInformerFactory csinformers.SharedInformerFactory, clientset csclientset.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 containershipv3.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
func (*UserSyncController) Update ¶
func (c *UserSyncController) Update(u containershipv3.UserSpec, obj interface{}) error
Update takes a user spec in cache and updates a User CRD spec with the same ID with that value
Source Files