controllers

package
v0.14.0 Latest Latest
Warning

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

 Go to latest Published: Sep 21, 2023 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateUserConfiguration added in v0.14.0 

func CreateUserConfiguration(userConfig any) (map[string]any, error)

func IsAlreadyRunning added in v0.9.0 

func IsAlreadyRunning(o client.Object) bool

IsAlreadyRunning returns true if object is ready to use

func NewAivenClient added in v0.10.0 

func NewAivenClient(token string) (*aiven.Client, error)

NewAivenClient returns Aiven client

func SetupControllers added in v0.9.0 

func SetupControllers(mgr ctrl.Manager, defaultToken string) error

func UpdateUserConfiguration added in v0.14.0 

func UpdateUserConfiguration(userConfig any) (map[string]any, error)

Types

type CassandraReconciler added in v0.7.0 

type CassandraReconciler struct {
	Controller
}

CassandraReconciler reconciles a Cassandra object

func (*CassandraReconciler) Reconcile added in v0.7.0 

func (r *CassandraReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*CassandraReconciler) SetupWithManager added in v0.7.0 

func (r *CassandraReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type ClickhouseReconciler added in v0.3.0 

type ClickhouseReconciler struct {
	Controller
}

ClickhouseReconciler reconciles a Clickhouse object

func (*ClickhouseReconciler) Reconcile added in v0.3.0 

func (r *ClickhouseReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ClickhouseReconciler) SetupWithManager added in v0.3.0 

func (r *ClickhouseReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type ClickhouseUserReconciler added in v0.3.0 

type ClickhouseUserReconciler struct {
	Controller
}

ClickhouseUserReconciler reconciles a ClickhouseUser object

func (*ClickhouseUserReconciler) Reconcile added in v0.3.0 

func (r *ClickhouseUserReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ClickhouseUserReconciler) SetupWithManager added in v0.3.0 

func (r *ClickhouseUserReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type ConnectionPoolHandler 

type ConnectionPoolHandler struct{}

ConnectionPoolHandler handles an Aiven ConnectionPool

type ConnectionPoolReconciler 

type ConnectionPoolReconciler struct {
	Controller
}

ConnectionPoolReconciler reconciles a ConnectionPool object

func (*ConnectionPoolReconciler) Reconcile 

func (r *ConnectionPoolReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ConnectionPoolReconciler) SetupWithManager 

func (r *ConnectionPoolReconciler) SetupWithManager(mgr ctrl.Manager) error

type Controller 

type Controller struct {
	client.Client

	Log          logr.Logger
	Scheme       *runtime.Scheme
	Recorder     record.EventRecorder
	DefaultToken string
}

Controller reconciles the Aiven objects

type DatabaseHandler 

type DatabaseHandler struct{}

DatabaseHandler handles an Aiven Database

type DatabaseReconciler 

type DatabaseReconciler struct {
	Controller
}

DatabaseReconciler reconciles a Database object

func (*DatabaseReconciler) Reconcile 

func (r *DatabaseReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*DatabaseReconciler) SetupWithManager 

func (r *DatabaseReconciler) SetupWithManager(mgr ctrl.Manager) error

type GrafanaReconciler added in v0.7.0 

type GrafanaReconciler struct {
	Controller
}

GrafanaReconciler reconciles a Grafana object

func (*GrafanaReconciler) Reconcile added in v0.7.0 

func (r *GrafanaReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*GrafanaReconciler) SetupWithManager added in v0.7.0 

func (r *GrafanaReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type Handlers 

type Handlers interface {
	// contains filtered or unexported methods
}

Handlers represents Aiven API handlers It intended to be a layer between Kubernetes and Aiven API that handles all aspects of the Aiven services lifecycle.

type KafkaACLHandler 

type KafkaACLHandler struct{}

type KafkaACLReconciler 

type KafkaACLReconciler struct {
	Controller
}

KafkaACLReconciler reconciles a KafkaACL object

func (*KafkaACLReconciler) Reconcile 

func (r *KafkaACLReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*KafkaACLReconciler) SetupWithManager 

func (r *KafkaACLReconciler) SetupWithManager(mgr ctrl.Manager) error

type KafkaConnectReconciler 

type KafkaConnectReconciler struct {
	Controller
}

KafkaConnectReconciler reconciles a KafkaConnect object

func (*KafkaConnectReconciler) Reconcile 

func (r *KafkaConnectReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*KafkaConnectReconciler) SetupWithManager 

func (r *KafkaConnectReconciler) SetupWithManager(mgr ctrl.Manager) error

type KafkaConnectorHandler 

type KafkaConnectorHandler struct {
	// contains filtered or unexported fields
}

type KafkaConnectorReconciler 

type KafkaConnectorReconciler struct {
	Controller
}

KafkaConnectorReconciler reconciles a KafkaConnector object

func (*KafkaConnectorReconciler) Reconcile 

func (r *KafkaConnectorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*KafkaConnectorReconciler) SetupWithManager 

func (r *KafkaConnectorReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type KafkaReconciler 

type KafkaReconciler struct {
	Controller
}

KafkaReconciler reconciles a Kafka object

func (*KafkaReconciler) Reconcile 

func (r *KafkaReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*KafkaReconciler) SetupWithManager 

func (r *KafkaReconciler) SetupWithManager(mgr ctrl.Manager) error

type KafkaSchemaHandler 

type KafkaSchemaHandler struct{}

type KafkaSchemaReconciler 

type KafkaSchemaReconciler struct {
	Controller
}

KafkaSchemaReconciler reconciles a KafkaSchema object

func (*KafkaSchemaReconciler) Reconcile 

func (r *KafkaSchemaReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*KafkaSchemaReconciler) SetupWithManager 

func (r *KafkaSchemaReconciler) SetupWithManager(mgr ctrl.Manager) error

type KafkaTopicHandler 

type KafkaTopicHandler struct{}

type KafkaTopicReconciler 

type KafkaTopicReconciler struct {
	Controller
}

KafkaTopicReconciler reconciles a KafkaTopic object

func (*KafkaTopicReconciler) Reconcile 

func (r *KafkaTopicReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*KafkaTopicReconciler) SetupWithManager 

func (r *KafkaTopicReconciler) SetupWithManager(mgr ctrl.Manager) error

type MySQLReconciler added in v0.6.0 

type MySQLReconciler struct {
	Controller
}

MySQLReconciler reconciles a MySQL object

func (*MySQLReconciler) Reconcile added in v0.6.0 

func (r *MySQLReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*MySQLReconciler) SetupWithManager added in v0.6.0 

func (r *MySQLReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type OpenSearchHandler added in v0.3.0 

type OpenSearchHandler struct{}

type OpenSearchReconciler added in v0.3.0 

type OpenSearchReconciler struct {
	Controller
}

OpenSearchReconciler reconciles a OpenSearch object

func (*OpenSearchReconciler) Reconcile added in v0.3.0 

func (r *OpenSearchReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*OpenSearchReconciler) SetupWithManager added in v0.3.0 

func (r *OpenSearchReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type PostgreSQLReconciler 

type PostgreSQLReconciler struct {
	Controller
}

PostgreSQLReconciler reconciles a PostgreSQL object

func (*PostgreSQLReconciler) Reconcile 

func (r *PostgreSQLReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*PostgreSQLReconciler) SetupWithManager 

func (r *PostgreSQLReconciler) SetupWithManager(mgr ctrl.Manager) error

type ProjectHandler 

type ProjectHandler struct{}

ProjectHandler handles an Aiven project

type ProjectReconciler 

type ProjectReconciler struct {
	Controller
}

ProjectReconciler reconciles a Project object

func (*ProjectReconciler) Reconcile 

func (r *ProjectReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ProjectReconciler) SetupWithManager 

func (r *ProjectReconciler) SetupWithManager(mgr ctrl.Manager) error

type ProjectVPCHandler 

type ProjectVPCHandler struct{}

type ProjectVPCReconciler 

type ProjectVPCReconciler struct {
	Controller
}

ProjectVPCReconciler reconciles a ProjectVPC object

func (*ProjectVPCReconciler) Reconcile 

func (r *ProjectVPCReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ProjectVPCReconciler) SetupWithManager 

func (r *ProjectVPCReconciler) SetupWithManager(mgr ctrl.Manager) error

type RedisHandler added in v0.2.0 

type RedisHandler struct{}

type RedisReconciler added in v0.2.0 

type RedisReconciler struct {
	Controller
}

RedisReconciler reconciles a Redis object

func (*RedisReconciler) Reconcile added in v0.2.0 

func (r *RedisReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*RedisReconciler) SetupWithManager added in v0.2.0 

func (r *RedisReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type SecretFinalizerGCController 

type SecretFinalizerGCController struct {
	client.Client

	Log logr.Logger
}

SecretFinalizerGCController manages the protection finalizer of the client token secrets, to give the controllers a chance to delete the aiven instances

func (*SecretFinalizerGCController) Reconcile 

func (c *SecretFinalizerGCController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*SecretFinalizerGCController) SetupWithManager 

func (c *SecretFinalizerGCController) SetupWithManager(mgr ctrl.Manager, hasDefaultToken bool) error

type ServiceIntegrationHandler 

type ServiceIntegrationHandler struct{}

type ServiceIntegrationReconciler 

type ServiceIntegrationReconciler struct {
	Controller
}

ServiceIntegrationReconciler reconciles a ServiceIntegration object

func (*ServiceIntegrationReconciler) Reconcile 

func (r *ServiceIntegrationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ServiceIntegrationReconciler) SetupWithManager 

func (r *ServiceIntegrationReconciler) SetupWithManager(mgr ctrl.Manager) error

type ServiceUserHandler 

type ServiceUserHandler struct{}

type ServiceUserReconciler 

type ServiceUserReconciler struct {
	Controller
}

ServiceUserReconciler reconciles a ServiceUser object

func (*ServiceUserReconciler) Reconcile 

func (r *ServiceUserReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ServiceUserReconciler) SetupWithManager 

func (r *ServiceUserReconciler) SetupWithManager(mgr ctrl.Manager) error

Source Files

View all Source files

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.