Documentation
¶
Overview ¶
Package connection implements the reconcilations for pulsar resource
Index ¶
- func GetPermissioner(p *resourcev1alpha1.PulsarPermission) admin.Permissioner
- func GetValue(ctx context.Context, k8sClient client.Client, namespace string, ...) (*string, error)
- func MakePulsarAdminConfig(ctx context.Context, connection *resourcev1alpha1.PulsarConnection, ...) (*admin.PulsarAdminConfig, error)
- func MakeReconciler(log logr.Logger, k8sClient client.Client, creator admin.PulsarAdminCreator, ...) reconciler.Interface
- func NewErrorCondition(generation int64, msg string) *metav1.Condition
- func NewReadyCondition(generation int64) *metav1.Condition
- type PulsarConnectionReconciler
- type PulsarGeoReplicationReconciler
- type PulsarNamespaceReconciler
- type PulsarPermissionReconciler
- type PulsarTenantReconciler
- type PulsarTopicReconciler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetPermissioner ¶
func GetPermissioner(p *resourcev1alpha1.PulsarPermission) admin.Permissioner
GetPermissioner will return Permissioner according resource type
func GetValue ¶
func GetValue(ctx context.Context, k8sClient client.Client, namespace string, vRef *resourcev1alpha1.ValueOrSecretRef) (*string, error)
GetValue get the authentication token value or secret
func MakePulsarAdminConfig ¶ added in v0.4.4
func MakePulsarAdminConfig(ctx context.Context, connection *resourcev1alpha1.PulsarConnection, k8sClient client.Client) (*admin.PulsarAdminConfig, error)
MakePulsarAdminConfig create pulsar admin configuration
func MakeReconciler ¶
func MakeReconciler(log logr.Logger, k8sClient client.Client, creator admin.PulsarAdminCreator, connection *resourcev1alpha1.PulsarConnection) reconciler.Interface
MakeReconciler creates resource reconcilers
func NewErrorCondition ¶
NewErrorCondition create a condition with error
func NewReadyCondition ¶
NewReadyCondition make condition with ready info
Types ¶
type PulsarConnectionReconciler ¶
type PulsarConnectionReconciler struct {
// contains filtered or unexported fields
}
PulsarConnectionReconciler reconciles a PulsarConnection object
func (*PulsarConnectionReconciler) MakePulsarAdminConfig ¶
func (r *PulsarConnectionReconciler) MakePulsarAdminConfig(ctx context.Context) (*admin.PulsarAdminConfig, error)
MakePulsarAdminConfig create pulsar admin configuration
type PulsarGeoReplicationReconciler ¶ added in v0.3.0
type PulsarGeoReplicationReconciler struct {
// contains filtered or unexported fields
}
PulsarGeoReplicationReconciler reconciles a PulsarGeoReplication object
func (*PulsarGeoReplicationReconciler) Observe ¶ added in v0.3.0
func (r *PulsarGeoReplicationReconciler) Observe(ctx context.Context) error
Observe checks the updates of object
func (*PulsarGeoReplicationReconciler) Reconcile ¶ added in v0.3.0
func (r *PulsarGeoReplicationReconciler) Reconcile(ctx context.Context) error
Reconcile reconciles all the geo replication objects
func (*PulsarGeoReplicationReconciler) ReconcileGeoReplication ¶ added in v0.3.0
func (r *PulsarGeoReplicationReconciler) ReconcileGeoReplication(ctx context.Context, pulsarAdmin admin.PulsarAdmin, geoReplication *resourcev1alpha1.PulsarGeoReplication) error
ReconcileGeoReplication handle the current state of the geo replication to the desired state
type PulsarNamespaceReconciler ¶
type PulsarNamespaceReconciler struct {
// contains filtered or unexported fields
}
PulsarNamespaceReconciler reconciles a PulsarNamespace object
func (*PulsarNamespaceReconciler) Observe ¶
func (r *PulsarNamespaceReconciler) Observe(ctx context.Context) error
Observe checks the updates of object
func (*PulsarNamespaceReconciler) Reconcile ¶
func (r *PulsarNamespaceReconciler) Reconcile(ctx context.Context) error
Reconcile reconciles all namespaces
func (*PulsarNamespaceReconciler) ReconcileNamespace ¶
func (r *PulsarNamespaceReconciler) ReconcileNamespace(ctx context.Context, pulsarAdmin admin.PulsarAdmin, namespace *resourcev1alpha1.PulsarNamespace) error
ReconcileNamespace move the current state of the toic closer to the desired state
type PulsarPermissionReconciler ¶
type PulsarPermissionReconciler struct {
// contains filtered or unexported fields
}
PulsarPermissionReconciler reconciles a PulsarPermission object
func (*PulsarPermissionReconciler) Observe ¶
func (r *PulsarPermissionReconciler) Observe(ctx context.Context) error
Observe checks the updates of object
func (*PulsarPermissionReconciler) Reconcile ¶
func (r *PulsarPermissionReconciler) Reconcile(ctx context.Context) error
Reconcile reconciles all permissions
func (*PulsarPermissionReconciler) ReconcilePermission ¶
func (r *PulsarPermissionReconciler) ReconcilePermission(ctx context.Context, pulsarAdmin admin.PulsarAdmin, permission *resourcev1alpha1.PulsarPermission) error
ReconcilePermission move the current state of the toic closer to the desired state
type PulsarTenantReconciler ¶
type PulsarTenantReconciler struct {
// contains filtered or unexported fields
}
PulsarTenantReconciler reconciles a PulsarTenant object
func (*PulsarTenantReconciler) Observe ¶
func (r *PulsarTenantReconciler) Observe(ctx context.Context) error
Observe checks the updates of object
func (*PulsarTenantReconciler) Reconcile ¶
func (r *PulsarTenantReconciler) Reconcile(ctx context.Context) error
Reconcile reconciles all tenants
func (*PulsarTenantReconciler) ReconcileTenant ¶
func (r *PulsarTenantReconciler) ReconcileTenant(ctx context.Context, pulsarAdmin admin.PulsarAdmin, tenant *resourcev1alpha1.PulsarTenant) error
ReconcileTenant move the current state of the toic closer to the desired state
type PulsarTopicReconciler ¶
type PulsarTopicReconciler struct {
// contains filtered or unexported fields
}
PulsarTopicReconciler reconciles a PulsarTopic object
func (*PulsarTopicReconciler) Observe ¶
func (r *PulsarTopicReconciler) Observe(ctx context.Context) error
Observe checks the updates of object
func (*PulsarTopicReconciler) Reconcile ¶
func (r *PulsarTopicReconciler) Reconcile(ctx context.Context) error
Reconcile reconciles all topics
func (*PulsarTopicReconciler) ReconcileTopic ¶
func (r *PulsarTopicReconciler) ReconcileTopic(ctx context.Context, pulsarAdmin admin.PulsarAdmin, topic *resourcev1alpha1.PulsarTopic) error
ReconcileTopic move the current state of the toic closer to the desired state
Source Files