connection

package
v0.14.0 Latest Latest
Warning

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

 Go to latest Published: Sep 10, 2025 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Overview

Package connection implements the reconcilations for pulsar resource

Index

Constants

View Source 
const (
	// PropertyPrefix is the prefix for all properties managed by the operator
	PropertyPrefix = "pulsarpackages.resource.streamnative.io"

	// Property keys
	PropertyFileChecksum = PropertyPrefix + "/file-checksum"
	PropertyFileSize     = PropertyPrefix + "/file-size"
	PropertyManagedBy    = PropertyPrefix + "/managed-by"
	PropertyResourceNS   = PropertyPrefix + "/resource-namespace"
	PropertyResourceName = PropertyPrefix + "/resource-name"
	PropertyResourceUID  = PropertyPrefix + "/resource-uid"
	PropertyCluster      = PropertyPrefix + "/cluster"

	// Property values
	ValueManagedBy = "pulsar-resources-operator"
)
View Source 
const (
	// PulsarPermissionStateAnnotation is the annotation key used to store the previous state
	// of PulsarPermission resources for stateful reconciliation
	PulsarPermissionStateAnnotation = "pulsarpermissions.resource.streamnative.io/managed-state"
)

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 IsManagedByOperator added in v0.9.1 

func IsManagedByOperator(props map[string]string) bool

IsManagedByOperator checks if the package is managed by this operator

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, retryer *utils.ReconcileRetryer) reconciler.Interface

MakeReconciler creates resource reconcilers

func MergeProperties added in v0.9.1 

func MergeProperties(props *PackageProperties, userProps map[string]string) map[string]string

MergeProperties merges package properties with user-defined properties

func NewErrorCondition 

func NewErrorCondition(generation int64, msg string) *metav1.Condition

NewErrorCondition create a condition with error

func NewReadyCondition 

func NewReadyCondition(generation int64) *metav1.Condition

NewReadyCondition make condition with ready info

func NewTopicErrorCondition added in v0.5.3 

func NewTopicErrorCondition(generation int64, conditionType, msg string) metav1.Condition

NewTopicErrorCondition make condition with ready info

func NewTopicReadyCondition added in v0.5.3 

func NewTopicReadyCondition(generation int64, conditionType string) metav1.Condition

NewTopicReadyCondition make condition with ready info

Types

type PackageProperties added in v0.9.1 

type PackageProperties struct {
	FileChecksum string
	FileSize     int64
	Namespace    string
	Name         string
	UID          string
	Cluster      string
}

PackageProperties contains the managed properties for a PulsarPackage

func GeneratePackageProperties added in v0.9.1 

func GeneratePackageProperties(pkg *resourcev1alpha1.PulsarPackage, filePath string, clusterName string) (*PackageProperties, error)

GeneratePackageProperties creates a new PackageProperties from a PulsarPackage and file

func (*PackageProperties) ToMap added in v0.9.1 

func (p *PackageProperties) ToMap() map[string]string

ToMap converts PackageProperties to a map for Pulsar package properties

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

func (*PulsarConnectionReconciler) MakePulsarAdminConfigWithAPIVersion added in v0.5.0 

func (r *PulsarConnectionReconciler) MakePulsarAdminConfigWithAPIVersion(ctx context.Context, ver config.APIVersion) (*admin.PulsarAdminConfig, error)

MakePulsarAdminConfigWithAPIVersion create pulsar admin configuration with api version

func (*PulsarConnectionReconciler) Observe 

func (r *PulsarConnectionReconciler) Observe(ctx context.Context) error

Observe checks the updates of object

func (*PulsarConnectionReconciler) Reconcile 

func (r *PulsarConnectionReconciler) Reconcile(ctx context.Context) error

Reconcile reconciles all resources

type PulsarFunctionReconciler added in v0.5.0 

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

PulsarFunctionReconciler reconciles a PulsarFunction object

func (*PulsarFunctionReconciler) Observe added in v0.5.0 

func (r *PulsarFunctionReconciler) Observe(ctx context.Context) error

Observe checks the updates of object

func (*PulsarFunctionReconciler) Reconcile added in v0.5.0 

func (r *PulsarFunctionReconciler) Reconcile(ctx context.Context) error

Reconcile reconciles all functions

func (*PulsarFunctionReconciler) ReconcileFunction added in v0.5.0 

func (r *PulsarFunctionReconciler) ReconcileFunction(ctx context.Context, pulsarAdmin admin.PulsarAdmin,
	instance *resourcev1alpha1.PulsarFunction) error

ReconcileFunction move the current state of the functions closer to the desired state

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 PulsarNSIsolationPolicyReconciler added in v0.6.3 

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

PulsarNSIsolationPolicyReconciler reconciles a PulsarNSIsolationPolicy object

func (*PulsarNSIsolationPolicyReconciler) Observe added in v0.6.3 

func (r *PulsarNSIsolationPolicyReconciler) Observe(ctx context.Context) error

Observe checks the updates of object

func (*PulsarNSIsolationPolicyReconciler) Reconcile added in v0.6.3 

func (r *PulsarNSIsolationPolicyReconciler) Reconcile(ctx context.Context) error

Reconcile reconciles all ns-isolation-policies

func (*PulsarNSIsolationPolicyReconciler) ReconcilePolicy added in v0.6.3 

func (r *PulsarNSIsolationPolicyReconciler) ReconcilePolicy(ctx context.Context, pulsarAdmin admin.PulsarAdmin,
	policy *resourcev1alpha1.PulsarNSIsolationPolicy) error

ReconcilePolicy move the current state of the ns-isolation-policy closer 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 PulsarPackageReconciler added in v0.5.0 

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

PulsarPackageReconciler reconciles a PulsarPackage object

func (*PulsarPackageReconciler) Observe added in v0.5.0 

func (r *PulsarPackageReconciler) Observe(ctx context.Context) error

Observe checks the updates of object

func (*PulsarPackageReconciler) Reconcile added in v0.5.0 

func (r *PulsarPackageReconciler) Reconcile(ctx context.Context) error

Reconcile reconciles all topics

func (*PulsarPackageReconciler) ReconcilePackage added in v0.5.0 

func (r *PulsarPackageReconciler) ReconcilePackage(ctx context.Context, pulsarAdmin admin.PulsarAdmin,
	pkg *resourcev1alpha1.PulsarPackage) error

ReconcilePackage move the current state of the package 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 PulsarPermissionState added in v0.11.0 

type PulsarPermissionState struct {
	ResourceType string   `json:"resourceType"`
	ResourceName string   `json:"resourceName"`
	Roles        []string `json:"roles"`
	Actions      []string `json:"actions"`
}

PulsarPermissionState represents the state that needs to be tracked for PulsarPermission resources

type PulsarSinkReconciler added in v0.5.0 

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

PulsarSinkReconciler reconciles a PulsarSink object

func (*PulsarSinkReconciler) Observe added in v0.5.0 

func (r *PulsarSinkReconciler) Observe(ctx context.Context) error

Observe checks the updates of object

func (*PulsarSinkReconciler) Reconcile added in v0.5.0 

func (r *PulsarSinkReconciler) Reconcile(ctx context.Context) error

Reconcile reconciles the object

func (*PulsarSinkReconciler) ReconcileSink added in v0.5.0 

func (r *PulsarSinkReconciler) ReconcileSink(ctx context.Context, pulsarAdmin admin.PulsarAdmin, sink *resourcev1alpha1.PulsarSink) error

ReconcileSink reconciles the sink

type PulsarSourceReconciler added in v0.5.0 

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

PulsarSourceReconciler reconciles a PulsarSource object

func (*PulsarSourceReconciler) Observe added in v0.5.0 

func (r *PulsarSourceReconciler) Observe(ctx context.Context) error

Observe checks the updates of object

func (*PulsarSourceReconciler) Reconcile added in v0.5.0 

func (r *PulsarSourceReconciler) Reconcile(ctx context.Context) error

Reconcile reconciles the object

func (*PulsarSourceReconciler) ReconcileSource added in v0.5.0 

func (r *PulsarSourceReconciler) ReconcileSource(ctx context.Context, pulsarAdmin admin.PulsarAdmin, source *resourcev1alpha1.PulsarSource) error

ReconcileSource reconciles the source

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

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.