Documentation ¶
Index ¶
- type BucketAccessClassListener
- type BucketAccessListener
- type BucketAccessRequestListener
- type BucketClassListener
- type BucketListener
- type BucketRequestListener
- type GenericListener
- type ObjectStorageController
- func (c *ObjectStorageController) AddBucketAccessClassListener(b BucketAccessClassListener)
- func (c *ObjectStorageController) AddBucketAccessListener(b BucketAccessListener)
- func (c *ObjectStorageController) AddBucketAccessRequestListener(b BucketAccessRequestListener)
- func (c *ObjectStorageController) AddBucketClassListener(b BucketClassListener)
- func (c *ObjectStorageController) AddBucketListener(b BucketListener)
- func (c *ObjectStorageController) AddBucketRequestListener(b BucketRequestListener)
- func (c *ObjectStorageController) GetOpLock(op interface{}) *sync.Mutex
- func (c *ObjectStorageController) OpLock(op interface{})
- func (c *ObjectStorageController) OpUnlock(op interface{})
- func (c *ObjectStorageController) Run(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BucketAccessClassListener ¶
type BucketAccessClassListener interface { GenericListener Add(ctx context.Context, b *v1alpha1.BucketAccessClass) error Update(ctx context.Context, old *v1alpha1.BucketAccessClass, new *v1alpha1.BucketAccessClass) error Delete(ctx context.Context, b *v1alpha1.BucketAccessClass) error }
type BucketAccessListener ¶
type BucketAccessListener interface { GenericListener Add(ctx context.Context, b *v1alpha1.BucketAccess) error Update(ctx context.Context, old *v1alpha1.BucketAccess, new *v1alpha1.BucketAccess) error Delete(ctx context.Context, b *v1alpha1.BucketAccess) error }
type BucketAccessRequestListener ¶
type BucketAccessRequestListener interface { GenericListener Add(ctx context.Context, b *v1alpha1.BucketAccessRequest) error Update(ctx context.Context, old *v1alpha1.BucketAccessRequest, new *v1alpha1.BucketAccessRequest) error Delete(ctx context.Context, b *v1alpha1.BucketAccessRequest) error }
type BucketClassListener ¶
type BucketClassListener interface { GenericListener Add(ctx context.Context, b *v1alpha1.BucketClass) error Update(ctx context.Context, old *v1alpha1.BucketClass, new *v1alpha1.BucketClass) error Delete(ctx context.Context, b *v1alpha1.BucketClass) error }
type BucketListener ¶
type BucketRequestListener ¶
type BucketRequestListener interface { GenericListener Add(ctx context.Context, b *v1alpha1.BucketRequest) error Update(ctx context.Context, old *v1alpha1.BucketRequest, new *v1alpha1.BucketRequest) error Delete(ctx context.Context, b *v1alpha1.BucketRequest) error }
type GenericListener ¶
type GenericListener interface { InitializeKubeClient(kubeclientset.Interface) InitializeBucketClient(bucketclientset.Interface) }
Set the clients for each of the listeners
type ObjectStorageController ¶
type ObjectStorageController struct { LeaseDuration time.Duration RenewDeadline time.Duration RetryPeriod time.Duration // Controller ResyncPeriod time.Duration // Listeners BucketListener BucketListener BucketClassListener BucketClassListener BucketRequestListener BucketRequestListener BucketAccessListener BucketAccessListener BucketAccessClassListener BucketAccessClassListener BucketAccessRequestListener BucketAccessRequestListener // contains filtered or unexported fields }
func NewDefaultObjectStorageController ¶
func NewDefaultObjectStorageController(identity string, leaderLockName string, threads int) (*ObjectStorageController, error)
func NewObjectStorageController ¶
func NewObjectStorageController(identity string, leaderLockName string, threads int, limiter workqueue.RateLimiter) (*ObjectStorageController, error)
func (*ObjectStorageController) AddBucketAccessClassListener ¶
func (c *ObjectStorageController) AddBucketAccessClassListener(b BucketAccessClassListener)
func (*ObjectStorageController) AddBucketAccessListener ¶
func (c *ObjectStorageController) AddBucketAccessListener(b BucketAccessListener)
func (*ObjectStorageController) AddBucketAccessRequestListener ¶
func (c *ObjectStorageController) AddBucketAccessRequestListener(b BucketAccessRequestListener)
func (*ObjectStorageController) AddBucketClassListener ¶
func (c *ObjectStorageController) AddBucketClassListener(b BucketClassListener)
func (*ObjectStorageController) AddBucketListener ¶
func (c *ObjectStorageController) AddBucketListener(b BucketListener)
func (*ObjectStorageController) AddBucketRequestListener ¶
func (c *ObjectStorageController) AddBucketRequestListener(b BucketRequestListener)
func (*ObjectStorageController) GetOpLock ¶
func (c *ObjectStorageController) GetOpLock(op interface{}) *sync.Mutex
func (*ObjectStorageController) OpLock ¶
func (c *ObjectStorageController) OpLock(op interface{})
func (*ObjectStorageController) OpUnlock ¶
func (c *ObjectStorageController) OpUnlock(op interface{})
Click to show internal directories.
Click to hide internal directories.