controllers

package
v0.0.0-...-53bcd79 Latest Latest
Warning

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

 Go to latest Published: Jan 2, 2025 License: MIT Imports: 55 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Auth 

type Auth struct {
	Username string `json:"username"`
	Password string `json:"password"`
	Auth     string `json:"auth"`
}

type BucketReconciler 

type BucketReconciler struct {
	CoreClient kubernetes.Interface
	Client     *client.MinioV1alpha1

	Original *miniov1alpha1.MinIOBucket
	Obj      *miniov1alpha1.MinIOBucket

	MinIOInstances []*miniocontrollerv1beta1.MinIOInstance
	Secret         *corev1.Secret
	MinIOClient    *minio.Client
	PortForwarder  *portforward.PortForwarder
	// contains filtered or unexported fields
}

func NewBucketReconciler 

func NewBucketReconciler(
	coreClient kubernetes.Interface,
	client *client.MinioV1alpha1,
	config *rest.Config,
	serviceLister corev1listers.ServiceLister,
	podLister corev1listers.PodLister,
	secretLister corev1listers.SecretLister,
	instanceLister *client.MiniocontrollerV1beta1MinIOInstanceLister,
	runOutsideCluster bool,
	transport http.RoundTripper,
	log *zap.Logger,
) *BucketReconciler

func (*BucketReconciler) Finalize 

func (r *BucketReconciler) Finalize(ctx context.Context, obj runtime.Object) error

func (*BucketReconciler) Reconcile 

func (r *BucketReconciler) Reconcile(ctx context.Context, obj runtime.Object) error

type ConsulBackupController 

type ConsulBackupController struct {
	*controllerutil.ControllerBase
	// contains filtered or unexported fields
}

func NewConsulBackupController 

func NewConsulBackupController(
	coreSharedInformerFactory kubeinformers.SharedInformerFactory,
	factory *client.InformerFactory,
	coreClient kubernetes.Interface,
	apiClient *client.Set,
	config *rest.Config,
	runOutsideCluster bool,
) (*ConsulBackupController, error)

func (*ConsulBackupController) Finalize 

func (b *ConsulBackupController) Finalize(ctx context.Context, obj runtime.Object) error

func (*ConsulBackupController) GetObject 

func (b *ConsulBackupController) GetObject(key string) (runtime.Object, error)

func (*ConsulBackupController) ObjectToKeys 

func (b *ConsulBackupController) ObjectToKeys(obj interface{}) []string

func (*ConsulBackupController) Reconcile 

func (b *ConsulBackupController) Reconcile(ctx context.Context, obj runtime.Object) error

func (*ConsulBackupController) UpdateObject 

func (b *ConsulBackupController) UpdateObject(ctx context.Context, obj runtime.Object) (runtime.Object, error)

type DockerConfig 

type DockerConfig struct {
	Auths map[string]Auth `json:"auths"`
}

func NewDockerConfig 

func NewDockerConfig(registry, username, password string) *DockerConfig

type GrafanaController 

type GrafanaController struct {
	*controllerutil.GenericControllerBase[*grafanav1alpha1.Grafana]
	// contains filtered or unexported fields
}

func NewGrafanaController 

func NewGrafanaController(
	coreSharedInformerFactory kubeinformers.SharedInformerFactory,
	factory *client.InformerFactory,
	coreClient kubernetes.Interface,
	apiClient *client.Set,
) (*GrafanaController, error)

type HarborProjectController 

type HarborProjectController struct {
	*controllerutil.ControllerBase
	// contains filtered or unexported fields
}

func NewHarborProjectController 

func NewHarborProjectController(
	ctx context.Context,
	coreClient kubernetes.Interface,
	apiClient *client.Set,
	cfg *rest.Config,
	factory *client.InformerFactory,
	harborNamespace,
	harborName,
	adminSecretName,
	coreConfigMapName string,
	runOutsideCluster bool,
) (*HarborProjectController, error)

func (*HarborProjectController) Finalize 

func (c *HarborProjectController) Finalize(ctx context.Context, obj runtime.Object) error

func (*HarborProjectController) GetObject 

func (c *HarborProjectController) GetObject(key string) (runtime.Object, error)

func (*HarborProjectController) ObjectToKeys 

func (c *HarborProjectController) ObjectToKeys(obj interface{}) []string

func (*HarborProjectController) Reconcile 

func (c *HarborProjectController) Reconcile(ctx context.Context, obj runtime.Object) error

func (*HarborProjectController) UpdateObject 

func (c *HarborProjectController) UpdateObject(ctx context.Context, obj runtime.Object) (runtime.Object, error)

type HarborRobotAccountController 

type HarborRobotAccountController struct {
	*controllerutil.ControllerBase
	// contains filtered or unexported fields
}

func NewHarborRobotAccountController 

func NewHarborRobotAccountController(
	ctx context.Context,
	coreClient kubernetes.Interface,
	apiClient *client.Set,
	cfg *rest.Config,
	factory *client.InformerFactory,
	harborNamespace,
	harborName,
	adminSecretName string,
	runOutsideCluster bool,
) (*HarborRobotAccountController, error)

func (*HarborRobotAccountController) Finalize 

func (c *HarborRobotAccountController) Finalize(ctx context.Context, obj runtime.Object) error

func (*HarborRobotAccountController) GetObject 

func (c *HarborRobotAccountController) GetObject(key string) (runtime.Object, error)

func (*HarborRobotAccountController) ObjectToKeys 

func (c *HarborRobotAccountController) ObjectToKeys(obj interface{}) []string

func (*HarborRobotAccountController) Reconcile 

func (c *HarborRobotAccountController) Reconcile(ctx context.Context, obj runtime.Object) error

func (*HarborRobotAccountController) UpdateObject 

func (c *HarborRobotAccountController) UpdateObject(ctx context.Context, obj runtime.Object) (runtime.Object, error)

type MinIOBucketController 

type MinIOBucketController struct {
	*controllerutil.ControllerBase
	// contains filtered or unexported fields
}

func NewMinIOBucketController 

func NewMinIOBucketController(
	coreClient kubernetes.Interface,
	apiClient *client.Set,
	cfg *rest.Config,
	coreSharedInformerFactory kubeinformers.SharedInformerFactory,
	factory *client.InformerFactory,
	runOutsideCluster bool,
) (*MinIOBucketController, error)

func (*MinIOBucketController) Finalize 

func (c *MinIOBucketController) Finalize(ctx context.Context, obj runtime.Object) error

func (*MinIOBucketController) GetObject 

func (c *MinIOBucketController) GetObject(key string) (runtime.Object, error)

func (*MinIOBucketController) NewReconciler 

func (c *MinIOBucketController) NewReconciler(log *zap.Logger) controllerutil.Reconciler

func (*MinIOBucketController) ObjectToKeys 

func (c *MinIOBucketController) ObjectToKeys(obj interface{}) []string

func (*MinIOBucketController) Reconcile 

func (c *MinIOBucketController) Reconcile(ctx context.Context, obj runtime.Object) error

func (*MinIOBucketController) UpdateObject 

func (c *MinIOBucketController) UpdateObject(ctx context.Context, obj runtime.Object) (runtime.Object, error)

type MinIOClusterController 

type MinIOClusterController struct {
	*controllerutil.GenericControllerBase[*miniov1alpha1.MinIOCluster]
	// contains filtered or unexported fields
}

func NewMinIOClusterController 

func NewMinIOClusterController(
	coreClient kubernetes.Interface,
	apiClient *client.Set,
	cfg *rest.Config,
	coreSharedInformerFactory kubeinformers.SharedInformerFactory,
	factory *client.InformerFactory,
	runOutsideCluster bool,
) *MinIOClusterController

type MinIOUserController 

type MinIOUserController struct {
	*controllerutil.GenericControllerBase[*miniov1alpha1.MinIOUser]
	// contains filtered or unexported fields
}

func NewMinIOUserController 

func NewMinIOUserController(
	coreClient kubernetes.Interface,
	apiClient *client.Set,
	cfg *rest.Config,
	coreSharedInformerFactory kubeinformers.SharedInformerFactory,
	factory *client.InformerFactory,
	vaultClient *vault.Client,
	runOutsideCluster bool,
) (*MinIOUserController, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.