interfaces.go

package controller

import (
	"context"

	// storage
	"github.com/kubernetes-sigs/container-object-storage-interface-api/apis/objectstorage.k8s.io/v1alpha1"
	bucketclientset "github.com/kubernetes-sigs/container-object-storage-interface-api/clientset"

	// k8s client
	kubeclientset "k8s.io/client-go/kubernetes"
)

// Set the clients for each of the listeners
type GenericListener interface {
	InitializeKubeClient(kubeclientset.Interface)
	InitializeBucketClient(bucketclientset.Interface)
}

type BucketListener interface {
	GenericListener

	Add(ctx context.Context, b *v1alpha1.Bucket) error
	Update(ctx context.Context, old *v1alpha1.Bucket, new *v1alpha1.Bucket) error
	Delete(ctx context.Context, b *v1alpha1.Bucket) error
}

func (c *ObjectStorageController) AddBucketListener(b BucketListener) {
	c.initialized = true
	c.BucketListener = b
}

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
}

func (c *ObjectStorageController) AddBucketRequestListener(b BucketRequestListener) {
	c.initialized = true
	c.BucketRequestListener = b
}

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
}

func (c *ObjectStorageController) AddBucketAccessListener(b BucketAccessListener) {
	c.initialized = true
	c.BucketAccessListener = b
}

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
}

func (c *ObjectStorageController) AddBucketAccessRequestListener(b BucketAccessRequestListener) {
	c.initialized = true
	c.BucketAccessRequestListener = b
}