v1alpha1

package

Go to main page

Versions in this module

v0

v0.4.0

Jan 13, 2025

v0.3.9

Jan 13, 2025

Changes in this version

type PulsarClusterSpec

+ InitJobResources v1.ResourceRequirements

v0.3.8

Jan 13, 2025

v0.3.7

Jan 13, 2025

v0.3.6

Jan 13, 2025

v0.3.5

Jan 13, 2025

Changes in this version

type Metadata

+ BrokerConfig map[string]string

+ PulsarVersion string

+ Size int32

v0.2.1

Jan 2, 2025

v0.2.0

Nov 14, 2023

v0.1.2

Nov 24, 2022

Changes in this version

type PulsarClusterSpec

+ Persistence *v1.PersistentVolumeClaimSpec

v0.1.1

Sep 16, 2022

v0.1.0

May 9, 2022

Changes in this version

+ const BrokerSetupImageRepository

+ const ClientPortName

+ const ClientTLSPortName

+ const ClusterStageInitialized

+ const ClusterStageLaunched

+ const ClusterStageRunning

+ const DefaultBrokerSetupImagePullPolicy

+ const DefaultBrokerSetupImageVersion

+ const KopPlainTextPortName

+ const KopSecuredPortName

+ const WebPortName

+ const WebTLSPortName

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ type ClusterStage string

+ type Connector struct

+ Builtin []string

+ Custom []CustomConnectorSource

+ type CustomConnectorSource struct

+ Headers map[string]string

+ URL string

+ type JVMOptions struct

+ Extra []string

+ Gc []string

+ GcLogging []string

+ Memory []string

+ type KOP struct

+ Enabled bool

+ PlainTextPort int32

+ SecuredPort int32

+ type Metadata struct

+ Stage ClusterStage

+ type MonitoringConfig struct

+ Enabled bool

+ type Ports struct

+ Client int32

+ ClientTLS int32

+ Web int32

+ WebTLS int32

+ type PulsarCluster struct

+ Spec PulsarClusterSpec

+ Status PulsarClusterStatus

+ func (in *PulsarCluster) BrokersDataPvcName() string

+ func (in *PulsarCluster) ClientHeadlessServiceFQDN() string

+ func (in *PulsarCluster) ClientServiceFQDN() string

+ func (in *PulsarCluster) ClientServiceName() string

+ func (in *PulsarCluster) ConfigMapName() string

+ func (in *PulsarCluster) Default()

+ func (in *PulsarCluster) GenerateAnnotations() map[string]string

+ func (in *PulsarCluster) GenerateLabels(broker bool) map[string]string

+ func (in *PulsarCluster) HeadlessServiceName() string

+ func (in *PulsarCluster) Image() basetype.Image

+ func (in *PulsarCluster) SetSpecDefaults() bool

+ func (in *PulsarCluster) SetStatusDefaults() bool

+ func (in *PulsarCluster) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (in *PulsarCluster) StatefulSetName() string

+ func (in *PulsarCluster) ValidateCreate() error

+ func (in *PulsarCluster) ValidateDelete() error

+ func (in *PulsarCluster) ValidateUpdate(_ runtime.Object) error

+ type PulsarClusterList struct

+ Items []PulsarCluster

+ type PulsarClusterSpec struct

+ Annotations map[string]string

+ BookkeeperClusterUri string

+ BrokerConfig map[string]string

+ ClusterDomain string

+ ConfigurationStoreServers string

+ Connectors Connector

+ ImagePullPolicy v1.PullPolicy

+ JVMOptions JVMOptions

+ KOP KOP

+ Labels map[string]string

+ MaxUnavailableNodes int32

+ PodConfig basetype.PodConfig

+ Ports *Ports

+ ProbeConfig *pod.Probes

+ PulsarVersion string

+ Size *int32

+ ZookeeperServers string

+ func (in *PulsarClusterSpec) VersionInt() int

+ type PulsarClusterStatus struct

+ Metadata Metadata

+ type PulsarManager struct

+ Spec PulsarManagerSpec

+ Status PulsarManagerStatus

+ func (in *PulsarManager) Default()

+ func (in *PulsarManager) SetSpecDefaults() bool

+ func (in *PulsarManager) SetStatusDefaults() bool

+ func (in *PulsarManager) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (in *PulsarManager) ValidateCreate() error

+ func (in *PulsarManager) ValidateDelete() error

+ func (in *PulsarManager) ValidateUpdate(old runtime.Object) error

+ type PulsarManagerList struct

+ Items []PulsarManager

+ type PulsarManagerSpec struct

+ type PulsarManagerStatus struct

+ type PulsarProxy struct

+ Spec PulsarProxySpec

+ Status PulsarProxyStatus

+ func (in *PulsarProxy) Default()

+ func (in *PulsarProxy) SetSpecDefaults() bool

+ func (in *PulsarProxy) SetStatusDefaults() bool

+ func (in *PulsarProxy) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (in *PulsarProxy) ValidateCreate() error

+ func (in *PulsarProxy) ValidateDelete() error

+ func (in *PulsarProxy) ValidateUpdate(old runtime.Object) error

+ type PulsarProxyList struct

+ Items []PulsarProxy

+ type PulsarProxySpec struct

+ type PulsarProxyStatus struct

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL