utils

func ExecInPod ¶

func ExecInPod(config *rest.Config, namespace, podName, containerName, command string) (string, string, error)

func GetEnv ¶

func GetEnv(key, fallback string) string

func GetKubeConfig ¶

func GetKubeConfig(kubeConfigPath string) (*rest.Config, error)

GetKubeConfig return the kubeconfig from kubeConfigPath if the path is empty, it will get config from $HOME/.kube/config as default

func MakeNSIsolationPolicy ¶

func MakeNSIsolationPolicy(namespace, name, clusterName, connectionName string, namespaces, primary, secondary []string, params map[string]string) *v1alpha1.PulsarNSIsolationPolicy

MakeNSIsolationPolicy will generate a object of PulsarNSIsolationPolicy

func MakePulsarConnection ¶

func MakePulsarConnection(namespace, name, adminServiceURL string) *v1alpha1.PulsarConnection

MakePulsarConnection will generate a object of PulsarConnection, without authentication

func MakePulsarFunction ¶

func MakePulsarFunction(namespace, name, functionPackageUrl, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarFunction

MakePulsarFunction will generate a object of PulsarFunction

func MakePulsarNamespace ¶

func MakePulsarNamespace(namespace, name, namespaceName, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarNamespace

MakePulsarNamespace will generate a object of PulsarNamespace

func MakePulsarNamespaceWithRateLimiting ¶

func MakePulsarNamespaceWithRateLimiting(namespace, name, namespaceName, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarNamespace

MakePulsarNamespaceWithRateLimiting will generate a PulsarNamespace with rate limiting configurations

func MakePulsarNamespaceWithSecurityConfig ¶

func MakePulsarNamespaceWithSecurityConfig(namespace, name, namespaceName, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarNamespace

MakePulsarNamespaceWithSecurityConfig will generate a PulsarNamespace with security configurations

func MakePulsarNamespaceWithStoragePolicies ¶

func MakePulsarNamespaceWithStoragePolicies(namespace, name, namespaceName, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarNamespace

MakePulsarNamespaceWithStoragePolicies will generate a PulsarNamespace with storage and persistence configurations

func MakePulsarPackage ¶

func MakePulsarPackage(namespace, name, packageURL, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarPackage

MakePulsarPackage will generate a object of PulsarPackage

func MakePulsarPermission ¶

func MakePulsarPermission(namespace, name, resourceName, connectionName string, resourceType v1alpha1.PulsarResourceType,
	roles, actions []string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarPermission

MakePulsarPermission will generate a object of PulsarPermission

func MakePulsarSink ¶

func MakePulsarSink(namespace, name, sinkPackageUrl, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarSink

MakePulsarSink will generate a object of PulsarSink

func MakePulsarSource ¶

func MakePulsarSource(namespace, name, sourcePackageUrl, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarSource

MakePulsarSource will generate a object of PulsarSource

func MakePulsarTenant ¶

func MakePulsarTenant(namespace, name, tenantName, connectionName string, adminRoles, allowedClusters []string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarTenant

MakePulsarTenant will generate a object of PulsarTenant

func MakePulsarTopic ¶

func MakePulsarTopic(namespace, name, topicName, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarTopic

MakePulsarTopic will generate a object of PulsarTopic

func MakePulsarTopicWithAllNewPolicies ¶

func MakePulsarTopicWithAllNewPolicies(namespace, name, topicName, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarTopic

MakePulsarTopicWithAllNewPolicies will generate a PulsarTopic with all new policy configurations

func MakePulsarTopicWithAutoSubscriptionCreation ¶

func MakePulsarTopicWithAutoSubscriptionCreation(namespace, name, topicName, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarTopic

MakePulsarTopicWithAutoSubscriptionCreation will generate a PulsarTopic with auto subscription creation configuration

func MakePulsarTopicWithCompactionThreshold ¶

func MakePulsarTopicWithCompactionThreshold(namespace, name, topicName, connectionName string, compactionThreshold int64, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarTopic

MakePulsarTopicWithCompactionThreshold will generate a object of PulsarTopic with compaction threshold

func MakePulsarTopicWithDelayedDelivery ¶

func MakePulsarTopicWithDelayedDelivery(namespace, name, topicName, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarTopic

MakePulsarTopicWithDelayedDelivery will generate a PulsarTopic with delayed delivery configuration

func MakePulsarTopicWithDispatchRate ¶

func MakePulsarTopicWithDispatchRate(namespace, name, topicName, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarTopic

MakePulsarTopicWithDispatchRate will generate a PulsarTopic with dispatch rate configuration

func MakePulsarTopicWithFiniteRetention ¶

func MakePulsarTopicWithFiniteRetention(namespace, name, topicName, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarTopic

MakePulsarTopicWithFiniteRetention creates a PulsarTopic with finite retention policies for comparison

func MakePulsarTopicWithInactiveTopicPolicies ¶

func MakePulsarTopicWithInactiveTopicPolicies(namespace, name, topicName, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarTopic

MakePulsarTopicWithInactiveTopicPolicies will generate a PulsarTopic with inactive topic policies

func MakePulsarTopicWithInfiniteRetention ¶

func MakePulsarTopicWithInfiniteRetention(namespace, name, topicName, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarTopic

MakePulsarTopicWithInfiniteRetention creates a PulsarTopic with infinite retention policies (both time and size)

func MakePulsarTopicWithInfiniteRetentionSize ¶

func MakePulsarTopicWithInfiniteRetentionSize(namespace, name, topicName, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarTopic

MakePulsarTopicWithInfiniteRetentionSize creates a PulsarTopic with infinite retention size only

func MakePulsarTopicWithInfiniteRetentionTime ¶

func MakePulsarTopicWithInfiniteRetentionTime(namespace, name, topicName, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarTopic

MakePulsarTopicWithInfiniteRetentionTime creates a PulsarTopic with infinite retention time only

func MakePulsarTopicWithOffloadPolicies ¶

func MakePulsarTopicWithOffloadPolicies(namespace, name, topicName, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarTopic

MakePulsarTopicWithOffloadPolicies will generate a PulsarTopic with offload policies configuration

func MakePulsarTopicWithPersistencePolicies ¶

func MakePulsarTopicWithPersistencePolicies(namespace, name, topicName, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarTopic

MakePulsarTopicWithPersistencePolicies will generate a PulsarTopic with persistence configurations

func MakePulsarTopicWithPublishRate ¶

func MakePulsarTopicWithPublishRate(namespace, name, topicName, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarTopic

MakePulsarTopicWithPublishRate will generate a PulsarTopic with publish rate configuration

func MakePulsarTopicWithSchemaCompatibilityStrategy ¶

func MakePulsarTopicWithSchemaCompatibilityStrategy(namespace, name, topicName, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarTopic

MakePulsarTopicWithSchemaCompatibilityStrategy will generate a PulsarTopic with schema compatibility strategy configuration

func MakePulsarTopicWithSubscribeRate ¶

func MakePulsarTopicWithSubscribeRate(namespace, name, topicName, connectionName string, policy v1alpha1.PulsarResourceLifeCyclePolicy) *v1alpha1.PulsarTopic

MakePulsarTopicWithSubscribeRate will generate a PulsarTopic with subscribe rate configuration