synccontroller

package
v2.1.1+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 12, 2018 License: GPL-3.0 Imports: 18 Imported by: 0

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(kubeclientset kubernetes.Interface, clientset csclientset.Interface, csInformerFactory csinformers.SharedInformerFactory) *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

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, clientset csclientset.Interface, csInformerFactory csinformers.SharedInformerFactory) *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

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) *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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL