controllers

package
v0.19.0 Latest Latest
Warning

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

 Go to latest Published: Apr 18, 2024 License: Apache-2.0 Imports: 42 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, avn *aiven.Client, r *v1alpha1.ClickhouseRole) error

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, kubeVersion, operatorVersion string) (*aiven.Client, error)

NewAivenClient returns Aiven client (aiven/aiven-go-client/v2)

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 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 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 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 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 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
}

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 {
	// 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 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.