MCPcopy Create free account

hub / github.com/apache/pulsar-client-go / functions

Functions5,094 in github.com/apache/pulsar-client-go

⨍ Functions 5,094◇ Types & classes 637
↓ 1 callersFunctionNewMessageID
NewMessageID Custom Create MessageID
pulsar/message.go:187
↓ 1 callersFunctionNewNamespaceBundleStats
()
pulsaradmin/pkg/utils/load_manage_report.go:103
↓ 1 callersMethodNewProducerID
()
pulsar/internal/rpc_client.go:57
↓ 1 callersFunctionNewProvider
NewProvider get/create an authentication data provider which provides the data that this client will be sent to the broker. Some authentication method
pulsar/auth/provider.go:61
↓ 1 callersFunctionNewSchema
(schemaType SchemaType, schemaData []byte, properties map[string]string)
pulsar/schema.go:90
↓ 1 callersMethodOffloadStatusWithContext
( ctx context.Context, topic utils.TopicName, )
pulsaradmin/pkg/admin/topic.go:1502
↓ 1 callersMethodOffloadWithContext
(ctx context.Context, topic utils.TopicName, messageID utils.MessageID)
pulsaradmin/pkg/admin/topic.go:1493
↓ 1 callersFunctionParseMessageIDWithPartitionIndex
(str string, index int)
pulsaradmin/pkg/utils/message_id.go:37
↓ 1 callersFunctionParseTopicDomain
(domain string)
pulsaradmin/pkg/utils/topic_domain.go:29
↓ 1 callersMethodPeekMessagesWithContext
( ctx context.Context, topic utils.TopicName, sName string, n int, )
pulsaradmin/pkg/admin/subscription.go:282
↓ 1 callersMethodPrimaryHostName
()
pulsar/internal/service_uri.go:73
↓ 1 callersMethodPrivateKey
PrivateKey get private key that is used by the consumer to decrypt data key
pulsar/crypto/crypto_key_reader.go:27
↓ 1 callersMethodPublicKey
PublicKey get public key that is be used by the producer to encrypt data key
pulsar/crypto/crypto_key_reader.go:24
↓ 1 callersMethodPutDouble
(datum interface{})
pulsar/primitiveSerDe.go:148
↓ 1 callersMethodPutFloat
(datum interface{})
pulsar/primitiveSerDe.go:176
↓ 1 callersMethodPutFunctionStateWithContext
( ctx context.Context, tenant, namespace, name string, state utils.FunctionState, )
pulsaradmin/pkg/admin/functions.go:823
↓ 1 callersMethodPutUnsafe
(item interface{})
pulsar/internal/blocking_queue.go:110
↓ 1 callersMethodReadUint16
()
pulsar/internal/buffer.go:62
↓ 1 callersMethodReaderIndex
()
pulsar/internal/buffer.go:69
↓ 1 callersMethodReceivedSendReceipt
ReceivedSendReceipt receive and process the return value of the send command.
pulsar/internal/connection.go:69
↓ 1 callersMethodReconsumeLaterWithCustomProperties
(msg Message, customProperties map[string]string, delay time.Duration)
pulsar/consumer_regex.go:194
↓ 1 callersMethodReconsumeLaterWithCustomProperties
(msg Message, customProperties map[string]string, delay time.Duration)
pulsar/consumer_multitopic.go:293
↓ 1 callersMethodReconsumeLaterWithCustomProperties
ReconsumeLaterWithCustomProperties mark a message for redelivery after custom delay with custom properties
pulsar/consumer_impl.go:612
↓ 1 callersMethodRedeliver
(msgIDs []messageID)
pulsar/negative_acks_tracker.go:30
↓ 1 callersMethodRefCnt
RefCnt returns the current reference count of the buffer.
pulsar/internal/buffer.go:85
↓ 1 callersMethodRefresh
(grant *AuthorizationGrant)
oauth2/client_credentials_flow.go:170
↓ 1 callersMethodRegisterListener
(id uint64, listener ConnectionListener)
pulsar/internal/connection.go:83
↓ 1 callersMethodReloadBuiltInSinksWithContext
(ctx context.Context)
pulsaradmin/pkg/admin/sinks.go:600
↓ 1 callersMethodReloadBuiltInSourcesWithContext
(ctx context.Context)
pulsaradmin/pkg/admin/sources.go:609
↓ 1 callersMethodRemoveAutoSubscriptionCreation
RemoveAutoSubscriptionCreation Remove auto subscription creation override for a topic
pulsaradmin/pkg/admin/topic.go:1032
↓ 1 callersMethodRemoveAutoSubscriptionCreationWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2338
↓ 1 callersMethodRemoveBacklogQuotaWithContext
( ctx context.Context, topic utils.TopicName, backlogQuotaType utils.BacklogQuotaType, )
pulsaradmin/pkg/admin/topic.go:1972
↓ 1 callersMethodRemoveBacklogQuotaWithContext
(ctx context.Context, namespace string)
pulsaradmin/pkg/admin/namespace.go:1030
↓ 1 callersMethodRemoveCompactionThresholdWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1935
↓ 1 callersMethodRemoveDeduplicationSnapshotInterval
RemoveDeduplicationSnapshotInterval removes deduplication snapshot interval for a topic
pulsaradmin/pkg/admin/topic.go:967
↓ 1 callersMethodRemoveDeduplicationSnapshotIntervalWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2274
↓ 1 callersMethodRemoveDeduplicationStatusWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1866
↓ 1 callersMethodRemoveDelayedDelivery
RemoveDelayedDelivery removes the delayed delivery policy on a topic
pulsaradmin/pkg/admin/topic.go:582
↓ 1 callersMethodRemoveDelayedDeliveryWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1773
↓ 1 callersMethodRemoveDispatchRate
RemoveDispatchRate removes message dispatch rate for a topic
pulsaradmin/pkg/admin/topic.go:602
↓ 1 callersMethodRemoveDispatchRateWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1806
↓ 1 callersMethodRemoveInactiveTopicPoliciesWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2006
↓ 1 callersMethodRemoveInactiveTopicPoliciesWithContext
(ctx context.Context, namespace utils.NameSpaceName)
pulsaradmin/pkg/admin/namespace.go:2041
↓ 1 callersMethodRemoveMaxConsumers
RemoveMaxConsumers removes max number of consumers for a topic
pulsaradmin/pkg/admin/topic.go:479
↓ 1 callersMethodRemoveMaxConsumersPerSubscriptionWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2142
↓ 1 callersMethodRemoveMaxConsumersPerSubscriptionWithContext
( ctx context.Context, namespace utils.NameSpaceName, )
pulsaradmin/pkg/admin/namespace.go:1240
↓ 1 callersMethodRemoveMaxConsumersPerTopic
RemoveMaxConsumersPerTopic removes maxConsumersPerTopic configuration for a namespace, defaulting to broker settings
pulsaradmin/pkg/admin/namespace.go:327
↓ 1 callersMethodRemoveMaxConsumersPerTopicWithContext
( ctx context.Context, namespace utils.NameSpaceName, )
pulsaradmin/pkg/admin/namespace.go:1332
↓ 1 callersMethodRemoveMaxConsumersWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1638
↓ 1 callersMethodRemoveMaxMessageSize
RemoveMaxMessageSize removes max message size for a topic
pulsaradmin/pkg/admin/topic.go:912
↓ 1 callersMethodRemoveMaxMessageSizeWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2172
↓ 1 callersMethodRemoveMaxProducers
RemoveMaxProducers removes max number of producers for a topic
pulsaradmin/pkg/admin/topic.go:449
↓ 1 callersMethodRemoveMaxProducersPerTopic
RemoveMaxProducersPerTopic removes maxProducersPerTopic configuration for a namespace, defaulting to broker settings
pulsaradmin/pkg/admin/namespace.go:349
↓ 1 callersMethodRemoveMaxProducersPerTopicWithContext
( ctx context.Context, namespace utils.NameSpaceName, )
pulsaradmin/pkg/admin/namespace.go:1400
↓ 1 callersMethodRemoveMaxProducersWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1606
↓ 1 callersMethodRemoveMaxSubscriptionsPerTopic
RemoveMaxSubscriptionsPerTopic removes max subscriptions per topic
pulsaradmin/pkg/admin/topic.go:930
↓ 1 callersMethodRemoveMaxSubscriptionsPerTopicWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2206
↓ 1 callersMethodRemoveMaxTopicsPerNamespaceWithContext
(ctx context.Context, namespace utils.NameSpaceName)
pulsaradmin/pkg/admin/namespace.go:2166
↓ 1 callersMethodRemoveMaxUnackMessagesPerConsumer
RemoveMaxUnackMessagesPerConsumer removes max unacked messages policy on consumer for a topic
pulsaradmin/pkg/admin/topic.go:510
↓ 1 callersMethodRemoveMaxUnackMessagesPerConsumerWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1673
↓ 1 callersMethodRemoveMaxUnackMessagesPerSubscription
RemoveMaxUnackMessagesPerSubscription removes max unacked messages policy on subscription for a topic
pulsaradmin/pkg/admin/topic.go:542
↓ 1 callersMethodRemoveMaxUnackMessagesPerSubscriptionWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1710
↓ 1 callersMethodRemoveMessageTTL
RemoveMessageTTL removes the message TTL for a topic
pulsaradmin/pkg/admin/topic.go:419
↓ 1 callersMethodRemoveMessageTTLWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1572
↓ 1 callersMethodRemoveNamespaceMessageTTL
RemoveNamespaceMessageTTL removes the message TTL configuration for a namespace, defaulting to broker settings
pulsaradmin/pkg/admin/namespace.go:98
↓ 1 callersMethodRemoveNamespaceMessageTTLWithContext
(ctx context.Context, namespace string)
pulsaradmin/pkg/admin/namespace.go:934
↓ 1 callersMethodRemoveOffloadPolicies
RemoveOffloadPolicies removes offload policies for a topic
pulsaradmin/pkg/admin/topic.go:1007
↓ 1 callersMethodRemoveOffloadPoliciesWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2430
↓ 1 callersMethodRemovePersistenceWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1740
↓ 1 callersMethodRemovePersistenceWithContext
(ctx context.Context, namespace string)
pulsaradmin/pkg/admin/namespace.go:1544
↓ 1 callersMethodRemoveProperties
RemoveProperties clears the properties of a namespace
pulsaradmin/pkg/admin/namespace.go:757
↓ 1 callersMethodRemovePropertiesWithContext
(ctx context.Context, namespace utils.NameSpaceName)
pulsaradmin/pkg/admin/namespace.go:2128
↓ 1 callersMethodRemoveProperty
RemoveProperty removes a property with the given key of a topic
pulsaradmin/pkg/admin/topic.go:95
↓ 1 callersMethodRemovePropertyWithContext
(ctx context.Context, topic utils.TopicName, key string)
pulsaradmin/pkg/admin/topic.go:1199
↓ 1 callersMethodRemovePublishRate
RemovePublishRate removes message publish rate for a topic
pulsaradmin/pkg/admin/topic.go:622
↓ 1 callersMethodRemovePublishRateWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1836
↓ 1 callersMethodRemoveReplicationClusters
RemoveReplicationClusters removes the replication clusters override on a topic
pulsaradmin/pkg/admin/topic.go:836
↓ 1 callersMethodRemoveReplicationClustersWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2045
↓ 1 callersMethodRemoveReplicatorDispatchRate
RemoveReplicatorDispatchRate removes replicator dispatch rate for a topic
pulsaradmin/pkg/admin/topic.go:987
↓ 1 callersMethodRemoveReplicatorDispatchRateWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2307
↓ 1 callersMethodRemoveRetentionWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1887
↓ 1 callersMethodRemoveRetentionWithContext
(ctx context.Context, namespace string)
pulsaradmin/pkg/admin/namespace.go:982
↓ 1 callersMethodRemoveSchemaCompatibilityStrategy
RemoveSchemaCompatibilityStrategy removes schema compatibility strategy for a topic
pulsaradmin/pkg/admin/topic.go:1076
↓ 1 callersMethodRemoveSchemaCompatibilityStrategyWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2388
↓ 1 callersMethodRemoveSchemaValidationEnforced
RemoveSchemaValidationEnforced removes schema validation enforced flag for a topic
pulsaradmin/pkg/admin/topic.go:948
↓ 1 callersMethodRemoveSchemaValidationEnforcedWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2240
↓ 1 callersMethodRemoveSubscribeRate
RemoveSubscribeRate removes subscribe rate configuration for a topic
pulsaradmin/pkg/admin/topic.go:856
↓ 1 callersMethodRemoveSubscribeRateWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2075
↓ 1 callersMethodRemoveSubscriptionDispatchRate
RemoveSubscriptionDispatchRate removes subscription dispatch rate for a topic
pulsaradmin/pkg/admin/topic.go:876
↓ 1 callersMethodRemoveSubscriptionDispatchRateWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2108
↓ 1 callersMethodRemoveSubscriptionExpirationTimeWithContext
( ctx context.Context, namespace utils.NameSpaceName, )
pulsaradmin/pkg/admin/namespace.go:2089
↓ 1 callersMethodRemoveTopicAutoCreationWithContext
(ctx context.Context, namespace utils.NameSpaceName)
pulsaradmin/pkg/admin/namespace.go:1076
↓ 1 callersMethodRequest
(logicalAddr *url.URL, physicalAddr *url.URL, requestID uint64, cmdType pb.BaseCommand_Type, message proto.M
pulsar/internal/rpc_client.go:70
↓ 1 callersMethodRequest
(logicalAddr *url.URL, physicalAddr *url.URL, requestID uint64, cmdType pb.BaseCommand_Type, message proto.Me
pulsar/internal/rpc_client.go:159
↓ 1 callersMethodRequestOnCnx
(cnx Connection, requestID uint64, cmdType pb.BaseCommand_Type, message proto.Message)
pulsar/internal/rpc_client.go:175
↓ 1 callersMethodRequestToAnyBroker
(_ uint64, cmdType pb.BaseCommand_Type, message proto.Message)
pulsar/internal/lookup_service_test.go:61
↓ 1 callersMethodRequestToAnyBroker
(requestID uint64, cmdType pb.BaseCommand_Type, _ proto.Message)
pulsar/internal/lookup_service_test.go:468
↓ 1 callersMethodRequestToHost
(serviceNameResolver *ServiceNameResolver, requestID uint64, cmdType pb.BaseCommand_Type, message proto.Mess
pulsar/internal/rpc_client.go:64
↓ 1 callersMethodRequestWithCnxKeySuffix
(logicalAddr *url.URL, physicalAddr *url.URL, cnxKeySuffix int32, requestID uint64, cmdType pb.BaseCommand_T
pulsar/internal/rpc_client.go:67
↓ 1 callersMethodRequestWithCnxKeySuffix
(logicalAddr *url.URL, physicalAddr *url.URL, cnxKeySuffix int32, requestID uint64, cmdType pb.BaseCommand_Ty
pulsar/internal/rpc_client.go:165
← previousnext →1,201–1,300 of 5,094, ranked by callers