utils

func ExecInPod ¶

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

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 MakePulsarConnection ¶

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

MakePulsarConnection will generate a object of PulsarConnection, without authentication

func MakePulsarNamespace ¶

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

MakePulsarNamespace will generate a object of PulsarNamespace

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