v1alpha1

Nov 25, 2024

Changes in this version

+ type AutoFailoverPolicyType string

+ const MinAvailable

+ type BookieAffinityGroupData struct

+ BookkeeperAffinityGroupPrimary string

+ BookkeeperAffinityGroupSecondary string

+ func (in *BookieAffinityGroupData) DeepCopy() *BookieAffinityGroupData

+ func (in *BookieAffinityGroupData) DeepCopyInto(out *BookieAffinityGroupData)

+ type PulsarNSIsolationPolicy struct

+ Spec PulsarNSIsolationPolicySpec

+ Status PulsarNSIsolationPolicyStatus

+ func (in *PulsarNSIsolationPolicy) DeepCopy() *PulsarNSIsolationPolicy

+ func (in *PulsarNSIsolationPolicy) DeepCopyInto(out *PulsarNSIsolationPolicy)

+ func (in *PulsarNSIsolationPolicy) DeepCopyObject() runtime.Object

+ type PulsarNSIsolationPolicyList struct

+ Items []PulsarNSIsolationPolicy

+ func (in *PulsarNSIsolationPolicyList) DeepCopy() *PulsarNSIsolationPolicyList

+ func (in *PulsarNSIsolationPolicyList) DeepCopyInto(out *PulsarNSIsolationPolicyList)

+ func (in *PulsarNSIsolationPolicyList) DeepCopyObject() runtime.Object

+ type PulsarNSIsolationPolicySpec struct

+ AutoFailoverPolicyParams map[string]string

+ AutoFailoverPolicyType AutoFailoverPolicyType

+ Cluster string

+ ConnectionRef corev1.LocalObjectReference

+ Name string

+ Namespaces []string

+ Primary []string

+ Secondary []string

+ func (in *PulsarNSIsolationPolicySpec) DeepCopy() *PulsarNSIsolationPolicySpec

+ func (in *PulsarNSIsolationPolicySpec) DeepCopyInto(out *PulsarNSIsolationPolicySpec)

+ type PulsarNSIsolationPolicyStatus struct

+ Conditions []metav1.Condition

+ ObservedGeneration int64

+ func (in *PulsarNSIsolationPolicyStatus) DeepCopy() *PulsarNSIsolationPolicyStatus

+ func (in *PulsarNSIsolationPolicyStatus) DeepCopyInto(out *PulsarNSIsolationPolicyStatus)

type PulsarNamespaceSpec

+ BookieAffinityGroup *BookieAffinityGroupData

Nov 11, 2024

Changes in this version

type PulsarNamespaceSpec

+ Deduplication *bool

type PulsarTopicSpec

+ Deduplication *bool

Sep 4, 2024

Changes in this version

type PulsarNamespaceSpec

+ OffloadThresholdSize *resource.Quantity

+ OffloadThresholdTime *utils.Duration

type PulsarTopicSpec

+ ReplicationClusters []string

Aug 31, 2024

Changes in this version

type PulsarNamespaceSpec

+ ReplicationClusters []string

Aug 8, 2024

Changes in this version

+ type FunctionSecretKeyRef struct

+ Key string

+ Path string

+ func (in *FunctionSecretKeyRef) DeepCopy() *FunctionSecretKeyRef

+ func (in *FunctionSecretKeyRef) DeepCopyInto(out *FunctionSecretKeyRef)

Aug 2, 2024

Changes in this version

+ const ConditionTopicPolicyReady

Jun 25, 2024

Changes in this version

+ type BatchSourceConfig struct

+ DiscoveryTriggererClassName string

+ DiscoveryTriggererConfig *apiextensionsv1.JSON

+ func (in *BatchSourceConfig) DeepCopy() *BatchSourceConfig

+ func (in *BatchSourceConfig) DeepCopyInto(out *BatchSourceConfig)

+ type ConsumerConfig struct

+ ConsumerProperties map[string]string

+ CryptoConfig *CryptoConfig

+ PoolMessages bool

+ ReceiverQueueSize int

+ RegexPattern bool

+ SchemaProperties map[string]string

+ SchemaType string

+ SerdeClassName string

+ func (in *ConsumerConfig) DeepCopy() *ConsumerConfig

+ func (in *ConsumerConfig) DeepCopyInto(out *ConsumerConfig)

+ type CryptoConfig struct

+ ConsumerCryptoFailureAction string

+ CryptoKeyReaderClassName string

+ CryptoKeyReaderConfig map[string]string

+ EncryptionKeys []string

+ ProducerCryptoFailureAction string

+ func (in *CryptoConfig) DeepCopy() *CryptoConfig

+ func (in *CryptoConfig) DeepCopyInto(out *CryptoConfig)

+ type PackageContentRef struct

+ URL string

+ func (in *PackageContentRef) DeepCopy() *PackageContentRef

+ func (in *PackageContentRef) DeepCopyInto(out *PackageContentRef)

+ type ProducerConfig struct

+ BatchBuilder string

+ CompressionType string

+ CryptoConfig *CryptoConfig

+ MaxPendingMessages int

+ MaxPendingMessagesAcrossPartitions int

+ UseThreadLocalProducers bool

+ func (in *ProducerConfig) DeepCopy() *ProducerConfig

+ func (in *ProducerConfig) DeepCopyInto(out *ProducerConfig)

+ type PulsarFunction struct

+ Spec PulsarFunctionSpec

+ Status PulsarFunctionStatus

+ func (in *PulsarFunction) DeepCopy() *PulsarFunction

+ func (in *PulsarFunction) DeepCopyInto(out *PulsarFunction)

+ func (in *PulsarFunction) DeepCopyObject() runtime.Object

+ type PulsarFunctionList struct

+ Items []PulsarFunction

+ func (in *PulsarFunctionList) DeepCopy() *PulsarFunctionList

+ func (in *PulsarFunctionList) DeepCopyInto(out *PulsarFunctionList)

+ func (in *PulsarFunctionList) DeepCopyObject() runtime.Object

+ type PulsarFunctionSpec struct

+ AutoAck bool

+ BatchBuilder *string

+ ClassName string

+ CleanupSubscription bool

+ ConnectionRef corev1.LocalObjectReference

+ CustomRuntimeOptions *apiextensionsv1.JSON

+ CustomSchemaInputs map[string]string

+ CustomSchemaOutputs map[string]string

+ CustomSerdeInputs map[string]string

+ DeadLetterTopic string

+ ExposePulsarAdminClientEnabled bool

+ ForwardSourceMessageProperty bool

+ Go *PackageContentRef

+ InputSpecs map[string]ConsumerConfig

+ InputTypeClassName string

+ Inputs []string

+ Jar *PackageContentRef

+ LifecyclePolicy PulsarResourceLifeCyclePolicy

+ LogTopic string

+ MaxMessageRetries *int

+ MaxPendingAsyncRequests int

+ Name string

+ Namespace string

+ Output string

+ OutputSchemaType string

+ OutputSerdeClassName string

+ OutputTypeClassName string

+ Parallelism int

+ ProcessingGuarantees string

+ ProducerConfig *ProducerConfig

+ Py *PackageContentRef

+ Resources *Resources

+ RetainKeyOrdering bool

+ RetainOrdering bool

+ RuntimeFlags string

+ Secrets map[string]SecretKeyRef

+ SkipToLatest bool

+ SubName string

+ SubscriptionPosition string

+ Tenant string

+ TimeoutMs *int64

+ TopicsPattern *string

+ UserConfig *apiextensionsv1.JSON

+ WindowConfig *WindowConfig

+ func (in *PulsarFunctionSpec) DeepCopy() *PulsarFunctionSpec

+ func (in *PulsarFunctionSpec) DeepCopyInto(out *PulsarFunctionSpec)

+ type PulsarFunctionStatus struct

+ Conditions []metav1.Condition

+ ObservedGeneration int64

+ func (in *PulsarFunctionStatus) DeepCopy() *PulsarFunctionStatus

+ func (in *PulsarFunctionStatus) DeepCopyInto(out *PulsarFunctionStatus)

+ type PulsarPackage struct

+ Spec PulsarPackageSpec

+ Status PulsarPackageStatus

+ func (in *PulsarPackage) DeepCopy() *PulsarPackage

+ func (in *PulsarPackage) DeepCopyInto(out *PulsarPackage)

+ func (in *PulsarPackage) DeepCopyObject() runtime.Object

+ type PulsarPackageList struct

+ Items []PulsarPackage

+ func (in *PulsarPackageList) DeepCopy() *PulsarPackageList

+ func (in *PulsarPackageList) DeepCopyInto(out *PulsarPackageList)

+ func (in *PulsarPackageList) DeepCopyObject() runtime.Object

+ type PulsarPackageSpec struct

+ ConnectionRef corev1.LocalObjectReference

+ Contact string

+ Description string

+ FileURL string

+ LifecyclePolicy PulsarResourceLifeCyclePolicy

+ PackageURL string

+ Properties map[string]string

+ func (in *PulsarPackageSpec) DeepCopy() *PulsarPackageSpec

+ func (in *PulsarPackageSpec) DeepCopyInto(out *PulsarPackageSpec)

+ type PulsarPackageStatus struct

+ Conditions []metav1.Condition

+ ObservedGeneration int64

+ func (in *PulsarPackageStatus) DeepCopy() *PulsarPackageStatus

+ func (in *PulsarPackageStatus) DeepCopyInto(out *PulsarPackageStatus)

+ type PulsarSink struct

+ Spec PulsarSinkSpec

+ Status PulsarSinkStatus

+ func (in *PulsarSink) DeepCopy() *PulsarSink

+ func (in *PulsarSink) DeepCopyInto(out *PulsarSink)

+ func (in *PulsarSink) DeepCopyObject() runtime.Object

+ type PulsarSinkList struct

+ Items []PulsarSink

+ func (in *PulsarSinkList) DeepCopy() *PulsarSinkList

+ func (in *PulsarSinkList) DeepCopyInto(out *PulsarSinkList)

+ func (in *PulsarSinkList) DeepCopyObject() runtime.Object

+ type PulsarSinkSpec struct

+ Archive *PackageContentRef

+ AutoAck bool

+ ClassName string

+ CleanupSubscription bool

+ Configs *apiextensionsv1.JSON

+ ConnectionRef corev1.LocalObjectReference

+ CustomRuntimeOptions *apiextensionsv1.JSON

+ DeadLetterTopic string

+ InputSpecs map[string]ConsumerConfig

+ Inputs []string

+ LifecyclePolicy PulsarResourceLifeCyclePolicy

+ MaxMessageRetries int

+ Name string

+ Namespace string

+ NegativeAckRedeliveryDelayMs int64

+ Parallelism int

+ ProcessingGuarantees string

+ Resources *Resources

+ RetainKeyOrdering bool

+ RetainOrdering bool

+ RuntimeFlags string

+ Secrets map[string]SecretKeyRef

+ SinkType string

+ SourceSubscriptionName string

+ SourceSubscriptionPosition string

+ Tenant string

+ TimeoutMs *int64

+ TopicToSchemaProperties map[string]string

+ TopicToSchemaType map[string]string

+ TopicToSerdeClassName map[string]string

+ TopicsPattern *string

+ TransformFunction string

+ TransformFunctionClassName string

+ TransformFunctionConfig string

+ func (in *PulsarSinkSpec) DeepCopy() *PulsarSinkSpec

+ func (in *PulsarSinkSpec) DeepCopyInto(out *PulsarSinkSpec)

+ type PulsarSinkStatus struct

+ Conditions []metav1.Condition

+ ObservedGeneration int64

+ func (in *PulsarSinkStatus) DeepCopy() *PulsarSinkStatus

+ func (in *PulsarSinkStatus) DeepCopyInto(out *PulsarSinkStatus)

+ type PulsarSource struct

+ Spec PulsarSourceSpec

+ Status PulsarSourceStatus

+ func (in *PulsarSource) DeepCopy() *PulsarSource

+ func (in *PulsarSource) DeepCopyInto(out *PulsarSource)

+ func (in *PulsarSource) DeepCopyObject() runtime.Object

+ type PulsarSourceList struct

+ Items []PulsarSource

+ func (in *PulsarSourceList) DeepCopy() *PulsarSourceList

+ func (in *PulsarSourceList) DeepCopyInto(out *PulsarSourceList)

+ func (in *PulsarSourceList) DeepCopyObject() runtime.Object

+ type PulsarSourceSpec struct

+ Archive *PackageContentRef

+ BatchBuilder string

+ BatchSourceConfig *BatchSourceConfig

+ ClassName string

+ Configs *apiextensionsv1.JSON

+ ConnectionRef corev1.LocalObjectReference

+ CustomRuntimeOptions *apiextensionsv1.JSON

+ LifecyclePolicy PulsarResourceLifeCyclePolicy

+ Name string

+ Namespace string

+ Parallelism int

+ ProcessingGuarantees string

+ ProducerConfig *ProducerConfig

+ Resources *Resources

+ RuntimeFlags string

+ SchemaType string

+ Secrets map[string]SecretKeyRef

+ SerdeClassName string

+ Tenant string

+ TopicName string

+ func (in *PulsarSourceSpec) DeepCopy() *PulsarSourceSpec

+ func (in *PulsarSourceSpec) DeepCopyInto(out *PulsarSourceSpec)

+ type PulsarSourceStatus struct

+ Conditions []metav1.Condition

+ ObservedGeneration int64

+ func (in *PulsarSourceStatus) DeepCopy() *PulsarSourceStatus

+ func (in *PulsarSourceStatus) DeepCopyInto(out *PulsarSourceStatus)

+ type Resources struct

+ CPU string

+ Disk int64

+ RAM int64

+ func (in *Resources) DeepCopy() *Resources

+ func (in *Resources) DeepCopyInto(out *Resources)

+ type WindowConfig struct

+ ActualWindowFunctionClassName *string

+ LateDataTopic *string

+ MaxLagMs *int64

+ ProcessingGuarantees *string

+ SlidingIntervalCount *int

+ SlidingIntervalDurationMs *int64

+ TimestampExtractorClassName *string

+ WatermarkEmitIntervalMs *int64

+ WindowLengthCount *int

+ WindowLengthDurationMs *int64

+ func (in *WindowConfig) DeepCopy() *WindowConfig

+ func (in *WindowConfig) DeepCopyInto(out *WindowConfig)

Dec 1, 2023

Changes in this version

type PulsarConnectionStatus

+ SecretKeyHash string

Sep 25, 2023

Changes in this version

type PulsarAuthenticationOAuth2

+ Scope string

Apr 28, 2023

Changes in this version

type PulsarConnectionSpec

+ BrokerClientTrustCertsFilePath string

Mar 30, 2023

Changes in this version

+ const AuthPluginOAuth2

+ const AuthPluginToken

+ type ClusterInfo struct

+ ConnectionRef corev1.LocalObjectReference

+ Name string

+ func (in *ClusterInfo) DeepCopy() *ClusterInfo

+ func (in *ClusterInfo) DeepCopyInto(out *ClusterInfo)

type PulsarConnectionSpec

+ AdminServiceSecureURL string

+ BrokerServiceSecureURL string

+ BrokerServiceURL string

+ ClusterName string

+ type PulsarGeoReplication struct

+ Spec PulsarGeoReplicationSpec

+ Status PulsarGeoReplicationStatus

+ func (in *PulsarGeoReplication) DeepCopy() *PulsarGeoReplication

+ func (in *PulsarGeoReplication) DeepCopyInto(out *PulsarGeoReplication)

+ func (in *PulsarGeoReplication) DeepCopyObject() runtime.Object

+ type PulsarGeoReplicationList struct

+ Items []PulsarGeoReplication

+ func (in *PulsarGeoReplicationList) DeepCopy() *PulsarGeoReplicationList

+ func (in *PulsarGeoReplicationList) DeepCopyInto(out *PulsarGeoReplicationList)

+ func (in *PulsarGeoReplicationList) DeepCopyObject() runtime.Object

+ type PulsarGeoReplicationSpec struct

+ ConnectionRef corev1.LocalObjectReference

+ DestinationConnectionRef corev1.LocalObjectReference

+ LifecyclePolicy PulsarResourceLifeCyclePolicy

+ func (in *PulsarGeoReplicationSpec) DeepCopy() *PulsarGeoReplicationSpec

+ func (in *PulsarGeoReplicationSpec) DeepCopyInto(out *PulsarGeoReplicationSpec)

+ type PulsarGeoReplicationStatus struct

+ Conditions []metav1.Condition

+ ObservedGeneration int64

+ func (in *PulsarGeoReplicationStatus) DeepCopy() *PulsarGeoReplicationStatus

+ func (in *PulsarGeoReplicationStatus) DeepCopyInto(out *PulsarGeoReplicationStatus)

type PulsarNamespaceSpec

+ GeoReplicationRefs []*corev1.LocalObjectReference

type PulsarNamespaceStatus

+ GeoReplicationEnabled bool

type PulsarTenantSpec

+ GeoReplicationRefs []*corev1.LocalObjectReference

type PulsarTopicSpec

+ GeoReplicationRefs []*corev1.LocalObjectReference

type PulsarTopicStatus

+ GeoReplicationEnabled bool

Dec 6, 2022

Changes in this version

type PulsarTopicSpec

+ SchemaInfo *SchemaInfo

+ type SchemaInfo struct

+ Properties map[string]string

+ Schema string

+ Type string

+ func (in *SchemaInfo) DeepCopy() *SchemaInfo

+ func (in *SchemaInfo) DeepCopyInto(out *SchemaInfo)

Jul 7, 2022

Changes in this version

+ const ConditionReady

+ const FinalizerName

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ func IsPulsarResourceReady(instance reconciler.Object) bool

+ type PulsarAuthentication struct

+ OAuth2 *PulsarAuthenticationOAuth2

+ Token *ValueOrSecretRef

+ func (in *PulsarAuthentication) DeepCopy() *PulsarAuthentication

+ func (in *PulsarAuthentication) DeepCopyInto(out *PulsarAuthentication)

+ type PulsarAuthenticationOAuth2 struct

+ Audience string

+ ClientID string

+ IssuerEndpoint string

+ Key ValueOrSecretRef

+ func (in *PulsarAuthenticationOAuth2) DeepCopy() *PulsarAuthenticationOAuth2

+ func (in *PulsarAuthenticationOAuth2) DeepCopyInto(out *PulsarAuthenticationOAuth2)

+ type PulsarConnection struct

+ Spec PulsarConnectionSpec

+ Status PulsarConnectionStatus

+ func (in *PulsarConnection) DeepCopy() *PulsarConnection

+ func (in *PulsarConnection) DeepCopyInto(out *PulsarConnection)

+ func (in *PulsarConnection) DeepCopyObject() runtime.Object

+ type PulsarConnectionList struct

+ Items []PulsarConnection

+ func (in *PulsarConnectionList) DeepCopy() *PulsarConnectionList

+ func (in *PulsarConnectionList) DeepCopyInto(out *PulsarConnectionList)

+ func (in *PulsarConnectionList) DeepCopyObject() runtime.Object

+ type PulsarConnectionSpec struct

+ AdminServiceURL string

+ Authentication *PulsarAuthentication

+ func (in *PulsarConnectionSpec) DeepCopy() *PulsarConnectionSpec

+ func (in *PulsarConnectionSpec) DeepCopyInto(out *PulsarConnectionSpec)

+ type PulsarConnectionStatus struct

+ Conditions []metav1.Condition

+ ObservedGeneration int64

+ func (in *PulsarConnectionStatus) DeepCopy() *PulsarConnectionStatus

+ func (in *PulsarConnectionStatus) DeepCopyInto(out *PulsarConnectionStatus)

+ type PulsarNamespace struct

+ Spec PulsarNamespaceSpec

+ Status PulsarNamespaceStatus

+ func (in *PulsarNamespace) DeepCopy() *PulsarNamespace

+ func (in *PulsarNamespace) DeepCopyInto(out *PulsarNamespace)

+ func (in *PulsarNamespace) DeepCopyObject() runtime.Object

+ type PulsarNamespaceList struct

+ Items []PulsarNamespace

+ func (in *PulsarNamespaceList) DeepCopy() *PulsarNamespaceList

+ func (in *PulsarNamespaceList) DeepCopyInto(out *PulsarNamespaceList)

+ func (in *PulsarNamespaceList) DeepCopyObject() runtime.Object

+ type PulsarNamespaceSpec struct

+ BacklogQuotaLimitSize *resource.Quantity

+ BacklogQuotaLimitTime *metav1.Duration

+ BacklogQuotaRetentionPolicy *string

+ BacklogQuotaType *string

+ Bundles *int32

+ ConnectionRef corev1.LocalObjectReference

+ LifecyclePolicy PulsarResourceLifeCyclePolicy

+ MaxConsumersPerSubscription *int32

+ MaxConsumersPerTopic *int32

+ MaxProducersPerTopic *int32

+ MessageTTL *metav1.Duration

+ Name string

+ RetentionSize *resource.Quantity

+ RetentionTime *metav1.Duration

+ func (in *PulsarNamespaceSpec) DeepCopy() *PulsarNamespaceSpec

+ func (in *PulsarNamespaceSpec) DeepCopyInto(out *PulsarNamespaceSpec)

+ type PulsarNamespaceStatus struct

+ Conditions []metav1.Condition

+ ObservedGeneration int64

+ func (in *PulsarNamespaceStatus) DeepCopy() *PulsarNamespaceStatus

+ func (in *PulsarNamespaceStatus) DeepCopyInto(out *PulsarNamespaceStatus)

+ type PulsarPermission struct

+ Spec PulsarPermissionSpec

+ Status PulsarPermissionStatus

+ func (in *PulsarPermission) DeepCopy() *PulsarPermission

+ func (in *PulsarPermission) DeepCopyInto(out *PulsarPermission)

+ func (in *PulsarPermission) DeepCopyObject() runtime.Object

+ type PulsarPermissionList struct

+ Items []PulsarPermission

+ func (in *PulsarPermissionList) DeepCopy() *PulsarPermissionList

+ func (in *PulsarPermissionList) DeepCopyInto(out *PulsarPermissionList)

+ func (in *PulsarPermissionList) DeepCopyObject() runtime.Object

+ type PulsarPermissionSpec struct

+ Actions []string

+ ConnectionRef corev1.LocalObjectReference

+ LifecyclePolicy PulsarResourceLifeCyclePolicy

+ ResourceName string

+ ResoureType PulsarResourceType

+ Roles []string

+ func (in *PulsarPermissionSpec) DeepCopy() *PulsarPermissionSpec

+ func (in *PulsarPermissionSpec) DeepCopyInto(out *PulsarPermissionSpec)

+ type PulsarPermissionStatus struct

+ Conditions []metav1.Condition

+ ObservedGeneration int64

+ func (in *PulsarPermissionStatus) DeepCopy() *PulsarPermissionStatus

+ func (in *PulsarPermissionStatus) DeepCopyInto(out *PulsarPermissionStatus)

+ type PulsarResourceLifeCyclePolicy string

+ const CleanUpAfterDeletion

+ const KeepAfterDeletion

+ type PulsarResourceType string

+ const PulsarResourceTypeNamespace

+ const PulsarResourceTypeTopic

+ type PulsarTenant struct

+ Spec PulsarTenantSpec

+ Status PulsarTenantStatus

+ func (in *PulsarTenant) DeepCopy() *PulsarTenant

+ func (in *PulsarTenant) DeepCopyInto(out *PulsarTenant)

+ func (in *PulsarTenant) DeepCopyObject() runtime.Object

+ type PulsarTenantList struct

+ Items []PulsarTenant

+ func (in *PulsarTenantList) DeepCopy() *PulsarTenantList

+ func (in *PulsarTenantList) DeepCopyInto(out *PulsarTenantList)

+ func (in *PulsarTenantList) DeepCopyObject() runtime.Object

+ type PulsarTenantSpec struct

+ AdminRoles []string

+ AllowedClusters []string

+ ConnectionRef corev1.LocalObjectReference

+ LifecyclePolicy PulsarResourceLifeCyclePolicy

+ Name string

+ func (in *PulsarTenantSpec) DeepCopy() *PulsarTenantSpec

+ func (in *PulsarTenantSpec) DeepCopyInto(out *PulsarTenantSpec)

+ type PulsarTenantStatus struct

+ Conditions []metav1.Condition

+ ObservedGeneration int64

+ func (in *PulsarTenantStatus) DeepCopy() *PulsarTenantStatus

+ func (in *PulsarTenantStatus) DeepCopyInto(out *PulsarTenantStatus)

+ type PulsarTopic struct

+ Spec PulsarTopicSpec

+ Status PulsarTopicStatus

+ func (in *PulsarTopic) DeepCopy() *PulsarTopic

+ func (in *PulsarTopic) DeepCopyInto(out *PulsarTopic)

+ func (in *PulsarTopic) DeepCopyObject() runtime.Object

+ type PulsarTopicList struct

+ Items []PulsarTopic

+ func (in *PulsarTopicList) DeepCopy() *PulsarTopicList

+ func (in *PulsarTopicList) DeepCopyInto(out *PulsarTopicList)

+ func (in *PulsarTopicList) DeepCopyObject() runtime.Object

+ type PulsarTopicSpec struct

+ BacklogQuotaLimitSize *resource.Quantity

+ BacklogQuotaLimitTime *metav1.Duration

+ BacklogQuotaRetentionPolicy *string

+ ConnectionRef corev1.LocalObjectReference

+ LifecyclePolicy PulsarResourceLifeCyclePolicy

+ MaxConsumers *int32

+ MaxProducers *int32

+ MaxUnAckedMessagesPerConsumer *int32

+ MaxUnAckedMessagesPerSubscription *int32

+ MessageTTL *metav1.Duration

+ Name string

+ Partitions *int32

+ Persistent *bool

+ RetentionSize *resource.Quantity

+ RetentionTime *metav1.Duration

+ func (in *PulsarTopicSpec) DeepCopy() *PulsarTopicSpec

+ func (in *PulsarTopicSpec) DeepCopyInto(out *PulsarTopicSpec)

+ type PulsarTopicStatus struct

+ Conditions []metav1.Condition

+ ObservedGeneration int64

+ func (in *PulsarTopicStatus) DeepCopy() *PulsarTopicStatus

+ func (in *PulsarTopicStatus) DeepCopyInto(out *PulsarTopicStatus)

+ type SecretKeyRef struct

+ Key string

+ Name string

+ func (in *SecretKeyRef) DeepCopy() *SecretKeyRef

+ func (in *SecretKeyRef) DeepCopyInto(out *SecretKeyRef)

+ type ValueOrSecretRef struct

+ SecretRef *SecretKeyRef

+ Value *string

+ func (in *ValueOrSecretRef) DeepCopy() *ValueOrSecretRef

+ func (in *ValueOrSecretRef) DeepCopyInto(out *ValueOrSecretRef)