broker

Documentation

Index

• Constants
• Variables
• func MakeConfigMap(c *pulsarv1alpha1.PulsarCluster) *v1.ConfigMap
• func MakeConfigMapName(c *pulsarv1alpha1.PulsarCluster) string
• func MakeDeployment(c *pulsarv1alpha1.PulsarCluster) *appsv1.Deployment
• func MakeDeploymentName(c *pulsarv1alpha1.PulsarCluster) string
• func MakeService(c *pulsarv1alpha1.PulsarCluster) *v1.Service
• func MakeServiceName(c *pulsarv1alpha1.PulsarCluster) string

Constants

const (
	PulsarMemData = "\" -Xms64m -Xmx128m -XX:MaxDirectMemorySize=128m\""

	ManagedLedgerDefaultEnsembleSize = "1"

	ManagedLedgerDefaultWriteQuorum = "1"

	ManagedLedgerDefaultAckQuorum = "1"

	FunctionsWorkerEnabled = "true"

	AdvertisedAddress = "advertisedAddress"
)

Variables

var DeploymentAnnotations map[string]string

Annotations

Functions

func MakeConfigMap

func MakeConfigMap(c *pulsarv1alpha1.PulsarCluster) *v1.ConfigMap

func MakeConfigMapName

func MakeConfigMapName(c *pulsarv1alpha1.PulsarCluster) string

func MakeDeployment

func MakeDeployment(c *pulsarv1alpha1.PulsarCluster) *appsv1.Deployment

func MakeDeploymentName

func MakeDeploymentName(c *pulsarv1alpha1.PulsarCluster) string

func MakeService

func MakeService(c *pulsarv1alpha1.PulsarCluster) *v1.Service

func MakeServiceName

func MakeServiceName(c *pulsarv1alpha1.PulsarCluster) string