controllers

package
v0.34.0 Latest Latest
Warning

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

 Go to latest Published: Oct 21, 2025 License: Apache-2.0 Imports: 54 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ConditionTypeError = "Error"
)

Variables

This section is empty.

Functions

func ClickhouseRoleExists added in v0.19.0 

func ClickhouseRoleExists(ctx context.Context, avnGen avngen.Client, r *v1alpha1.ClickhouseRole) error

func CreateUserConfiguration added in v0.14.0 

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

func GetClickhouseDatabaseByName added in v0.30.0 

func GetClickhouseDatabaseByName(ctx context.Context, avnGen avngen.Client, project, service, name string) (*clickhouse.DatabaseOut, error)

func GetDatabaseByName added in v0.30.0 

func GetDatabaseByName(ctx context.Context, avnGen avngen.Client, projectName, serviceName, dbName string) (*service.DatabaseOut, error)

func GetIsRunningAnnotation added in v0.30.0 

func GetIsRunningAnnotation(o client.Object) string

GetIsRunningAnnotation returns "true" for running/rebalancing resources, and "false" for powered-off resources.

func GetKafkaConnectorByName added in v0.30.0 

func GetKafkaConnectorByName(ctx context.Context, avnGen avngen.Client, projectName, serviceName, name string) (*kafkaconnect.ConnectorOut, error)

func GetPasswordFromSecret added in v0.31.0 

func GetPasswordFromSecret(ctx context.Context, k8sClient client.Client, resource PasswordSource) (string, error)

GetPasswordFromSecret retrieves and validates the password from connInfoSecretSource

func IsReadyToUse added in v0.30.0 

func IsReadyToUse(o client.Object) bool

IsReadyToUse returns true when the client.Object's controller has processed the latest manifest changes and the resource is in a running state in Aiven. For services, this includes both running and powered-off states. This indicates the resource is ready for use and has reached its desired state.

func NewAivenGeneratedClient added in v0.18.0 

func NewAivenGeneratedClient(token, kubeVersion, operatorVersion string) (avngen.Client, error)

NewAivenGeneratedClient returns Aiven generated client client (aiven/go-client-codegen)

func NewNotFound added in v0.18.0 

func NewNotFound(msg string) error

func NilIfZero added in v0.29.0 

func NilIfZero[T comparable](v T) *T

NilIfZero returns a pointer to the value, or nil if the value equals its zero value

func SetupControllers added in v0.9.0 

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

func UpdateUserConfiguration added in v0.14.0 

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

Types

type AlloyDBOmniReconciler added in v0.28.0 

type AlloyDBOmniReconciler struct {
	Controller
}

AlloyDBOmniReconciler reconciles a AlloyDBOmni object

func (*AlloyDBOmniReconciler) Reconcile added in v0.28.0 

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

func (*AlloyDBOmniReconciler) SetupWithManager added in v0.28.0 

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

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 ClickhouseDatabaseHandler added in v0.18.0 

type ClickhouseDatabaseHandler struct{}

ClickhouseDatabaseHandler handles an Aiven ClickhouseDatabase

type ClickhouseDatabaseReconciler added in v0.18.0 

type ClickhouseDatabaseReconciler struct {
	Controller
}

ClickhouseDatabaseReconciler reconciles a ClickhouseDatabase object

func (*ClickhouseDatabaseReconciler) Reconcile added in v0.18.0 

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

func (*ClickhouseDatabaseReconciler) SetupWithManager added in v0.18.0 

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

type ClickhouseGrantHandler added in v0.21.0 

type ClickhouseGrantHandler struct{}

ClickhouseGrantHandler handles an Aiven ClickhouseGrant

type ClickhouseGrantReconciler added in v0.21.0 

type ClickhouseGrantReconciler struct {
	Controller
}

ClickhouseGrantReconciler reconciles a ClickhouseGrant object

func (*ClickhouseGrantReconciler) Reconcile added in v0.21.0 

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

func (*ClickhouseGrantReconciler) SetupWithManager added in v0.21.0 

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

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 ClickhouseRoleReconciler added in v0.19.0 

type ClickhouseRoleReconciler struct {
	Controller
}

ClickhouseRoleReconciler reconciles a ClickhouseRole object

func (*ClickhouseRoleReconciler) Reconcile added in v0.19.0 

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*ClickhouseRoleReconciler) SetupWithManager added in v0.19.0 

func (r *ClickhouseRoleReconciler) 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
	AvGenClient     avngen.Client
	KubeVersion     string
	OperatorVersion 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 FlinkReconciler added in v0.26.0 

type FlinkReconciler struct {
	Controller
}

FlinkReconciler reconciles a Flink object

func (*FlinkReconciler) Reconcile added in v0.26.0 

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

func (*FlinkReconciler) SetupWithManager added in v0.26.0 

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

SetupWithManager sets up the controller with the Manager.

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 KafkaNativeACLHandler added in v0.30.0 

type KafkaNativeACLHandler struct{}

type KafkaNativeACLReconciler added in v0.30.0 

type KafkaNativeACLReconciler struct {
	Controller
}

KafkaNativeACLReconciler reconciles a KafkaNativeACL object

func (*KafkaNativeACLReconciler) Reconcile added in v0.30.0 

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

func (*KafkaNativeACLReconciler) SetupWithManager added in v0.30.0 

func (r *KafkaNativeACLReconciler) 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 KafkaSchemaRegistryACLHandler added in v0.18.0 

type KafkaSchemaRegistryACLHandler struct{}

type KafkaSchemaRegistryACLReconciler added in v0.18.0 

type KafkaSchemaRegistryACLReconciler struct {
	Controller
}

KafkaSchemaRegistryACLReconciler reconciles a KafkaSchemaRegistryACL object

func (*KafkaSchemaRegistryACLReconciler) Reconcile added in v0.18.0 

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

func (*KafkaSchemaRegistryACLReconciler) SetupWithManager added in v0.18.0 

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

SetupWithManager sets up the controller with the Manager.

type KafkaTopicHandler 

type KafkaTopicHandler struct{}

type KafkaTopicReconciler 

type KafkaTopicReconciler struct {
	Controller
	MaxConcurrentReconciles int
}

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 PasswordSource added in v0.31.0 

type PasswordSource interface {
	metav1.Object
	GetConnInfoSecretSource() *v1alpha1.ConnInfoSecretSource
}

PasswordSource defines an interface for resources that can provide password sources

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 {
	// contains filtered or unexported fields
}

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 SecretSourceResource added in v0.32.0 

type SecretSourceResource interface {
	client.Object
	GetConnInfoSecretSource() *v1alpha1.ConnInfoSecretSource
}

SecretSourceResource defines an interface for resources that can have connInfoSecretSource

type SecretWatchController added in v0.32.0 

type SecretWatchController struct {
	client.Client

	Log logr.Logger
}

SecretWatchController watches for changes to secrets referenced by connInfoSecretSource and triggers reconciliation of the dependent resources

func (*SecretWatchController) Reconcile added in v0.32.0 

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

func (*SecretWatchController) SetupWithManager added in v0.32.0 

func (c *SecretWatchController) SetupWithManager(mgr ctrl.Manager) error

type ServiceIntegrationEndpointHandler added in v0.20.0 

type ServiceIntegrationEndpointHandler struct{}

type ServiceIntegrationEndpointReconciler added in v0.20.0 

type ServiceIntegrationEndpointReconciler struct {
	Controller
}

ServiceIntegrationEndpointReconciler reconciles a ServiceIntegrationEndpoint object

func (*ServiceIntegrationEndpointReconciler) Reconcile added in v0.20.0 

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*ServiceIntegrationEndpointReconciler) SetupWithManager added in v0.20.0 

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

SetupWithManager sets up the controller with the Manager.

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 {
	// contains filtered or unexported fields
}

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

type ValkeyHandler added in v0.27.0 

type ValkeyHandler struct{}

type ValkeyReconciler added in v0.27.0 

type ValkeyReconciler struct {
	Controller
}

ValkeyReconciler reconciles a Valkey object

func (*ValkeyReconciler) Reconcile added in v0.27.0 

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

func (*ValkeyReconciler) SetupWithManager added in v0.27.0 

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

SetupWithManager sets up the controller with the Manager.

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.