Documentation ¶
Index ¶
- Constants
- func ClickhouseRoleExists(ctx context.Context, avn *aiven.Client, r *v1alpha1.ClickhouseRole) error
- func CreateUserConfiguration(userConfig any) (map[string]any, error)
- func IsAlreadyRunning(o client.Object) bool
- func NewAivenClient(token, kubeVersion, operatorVersion string) (*aiven.Client, error)
- func NewAivenGeneratedClient(token, kubeVersion, operatorVersion string) (avngen.Client, error)
- func NewNotFound(msg string) error
- func SetupControllers(mgr ctrl.Manager, defaultToken, kubeVersion, operatorVersion string) error
- func UpdateUserConfiguration(userConfig any) (map[string]any, error)
- type CassandraReconciler
- type ClickhouseDatabaseHandler
- type ClickhouseDatabaseReconciler
- type ClickhouseGrantHandler
- type ClickhouseGrantReconciler
- type ClickhouseReconciler
- type ClickhouseRoleReconciler
- type ClickhouseUserReconciler
- type ConnectionPoolHandler
- type ConnectionPoolReconciler
- type Controller
- type DatabaseHandler
- type DatabaseReconciler
- type GrafanaReconciler
- type Handlers
- type KafkaACLHandler
- type KafkaACLReconciler
- type KafkaConnectReconciler
- type KafkaConnectorHandler
- type KafkaConnectorReconciler
- type KafkaReconciler
- type KafkaSchemaHandler
- type KafkaSchemaReconciler
- type KafkaSchemaRegistryACLHandler
- type KafkaSchemaRegistryACLReconciler
- type KafkaTopicHandler
- type KafkaTopicReconciler
- type MySQLReconciler
- type OpenSearchHandler
- type OpenSearchReconciler
- type PostgreSQLReconciler
- type ProjectHandler
- type ProjectReconciler
- type ProjectVPCHandler
- type ProjectVPCReconciler
- type RedisHandler
- type RedisReconciler
- type SecretFinalizerGCController
- type ServiceIntegrationEndpointHandler
- type ServiceIntegrationEndpointReconciler
- type ServiceIntegrationHandler
- type ServiceIntegrationReconciler
- type ServiceUserHandler
- type ServiceUserReconciler
Constants ¶
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 IsAlreadyRunning ¶ added in v0.9.0
IsAlreadyRunning returns true if object is ready to use
func NewAivenClient ¶ added in v0.10.0
NewAivenClient returns Aiven client (aiven/aiven-go-client/v2)
func NewAivenGeneratedClient ¶ added in v0.18.0
NewAivenGeneratedClient returns Aiven generated client client (aiven/go-client-codegen)
func NewNotFound ¶ added in v0.18.0
func SetupControllers ¶ added in v0.9.0
Types ¶
type CassandraReconciler ¶ added in v0.7.0
type CassandraReconciler struct {
Controller
}
CassandraReconciler reconciles a Cassandra object
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) 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) 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) 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) 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) 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 DatabaseReconciler ¶
type DatabaseReconciler struct {
Controller
}
DatabaseReconciler reconciles a Database object
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) 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) SetupWithManager ¶
func (r *KafkaACLReconciler) SetupWithManager(mgr ctrl.Manager) error
type KafkaConnectReconciler ¶
type KafkaConnectReconciler struct {
Controller
}
KafkaConnectReconciler reconciles a KafkaConnect object
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) 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) 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) 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) 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) 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) 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) 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) SetupWithManager ¶
func (r *PostgreSQLReconciler) SetupWithManager(mgr ctrl.Manager) error
type ProjectReconciler ¶
type ProjectReconciler struct {
Controller
}
ProjectReconciler reconciles a Project object
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) 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) SetupWithManager ¶ added in v0.2.0
func (r *RedisReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type SecretFinalizerGCController ¶
SecretFinalizerGCController manages the protection finalizer of the client token secrets, to give the controllers a chance to delete the aiven instances
func (*SecretFinalizerGCController) SetupWithManager ¶
func (c *SecretFinalizerGCController) SetupWithManager(mgr ctrl.Manager, hasDefaultToken bool) 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) 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) SetupWithManager ¶
func (r *ServiceUserReconciler) SetupWithManager(mgr ctrl.Manager) error
Source Files ¶
- basic_controller.go
- cassandra_controller.go
- clickhouse_controller.go
- clickhousedatabase_controller.go
- clickhousegrant_controller.go
- clickhouserole_controller.go
- clickhouseuser_controller.go
- common.go
- connectionpool_controller.go
- database_controller.go
- generic_service_handler.go
- grafana_controller.go
- kafka_controller.go
- kafkaacl_controller.go
- kafkaconnect_controller.go
- kafkaconnector_controller.go
- kafkaschema_controller.go
- kafkaschemaregistryacl_controller.go
- kafkatopic_controller.go
- mysql_controller.go
- opensearch_controller.go
- postgresql_controller.go
- project_controller.go
- projectvpc_controller.go
- redis_controller.go
- secret_finalizer_gc_controller.go
- serviceintegration_controller.go
- serviceintegrationendpoint_controller.go
- serviceuser_controller.go
- setup.go