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
MethodRemoveMaxUnackMessagesPerConsumer
(topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1669
MethodRemoveMaxUnackMessagesPerConsumerWithContext
RemoveMaxUnackMessagesPerConsumerWithContext removes max unacked messages policy on consumer for a topic
pulsaradmin/pkg/admin/topic.go:513
MethodRemoveMaxUnackMessagesPerSubscription
(context.Context, utils.TopicName)
pulsaradmin/pkg/admin/topic_policies.go:50
MethodRemoveMaxUnackMessagesPerSubscription
( ctx context.Context, topic utils.TopicName, )
pulsaradmin/pkg/admin/topic_policies.go:376
MethodRemoveMaxUnackMessagesPerSubscription
(topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1706
MethodRemoveMaxUnackMessagesPerSubscriptionWithContext
RemoveMaxUnackMessagesPerSubscriptionWithContext removes max unacked messages policy on subscription for a topic
pulsaradmin/pkg/admin/topic.go:545
MethodRemoveMessageTTL
(context.Context, utils.TopicName)
pulsaradmin/pkg/admin/topic_policies.go:34
MethodRemoveMessageTTL
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic_policies.go:283
MethodRemoveMessageTTL
(topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1568
MethodRemoveMessageTTLWithContext
RemoveMessageTTLWithContext removes the message TTL for a topic
pulsaradmin/pkg/admin/topic.go:422
MethodRemoveNamespaceMessageTTL
(namespace string)
pulsaradmin/pkg/admin/namespace.go:930
MethodRemoveNamespaceMessageTTLWithContext
RemoveNamespaceMessageTTLWithContext removes the message TTL for a namespace, defaulting to broker settings
pulsaradmin/pkg/admin/namespace.go:101
MethodRemoveOffloadPolicies
(context.Context, utils.TopicName)
pulsaradmin/pkg/admin/topic_policies.go:126
MethodRemoveOffloadPolicies
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic_policies.go:872
MethodRemoveOffloadPolicies
(topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2426
MethodRemoveOffloadPoliciesWithContext
RemoveOffloadPoliciesWithContext removes offload policies for a topic
pulsaradmin/pkg/admin/topic.go:1010
MethodRemovePersistence
(context.Context, utils.TopicName)
pulsaradmin/pkg/admin/topic_policies.go:54
MethodRemovePersistence
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic_policies.go:403
MethodRemovePersistence
(topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1736
MethodRemovePersistence
RemovePersistence removes the persistence configuration for a namespace
pulsaradmin/pkg/admin/namespace.go:436
MethodRemovePersistence
(namespace string)
pulsaradmin/pkg/admin/namespace.go:1540
MethodRemovePersistenceWithContext
RemovePersistenceWithContext removes the persistence policies for a topic
pulsaradmin/pkg/admin/topic.go:565
MethodRemovePersistenceWithContext
RemovePersistenceWithContext removes the persistence configuration for a namespace
pulsaradmin/pkg/admin/namespace.go:439
MethodRemoveProperties
(namespace utils.NameSpaceName)
pulsaradmin/pkg/admin/namespace.go:2124
MethodRemovePropertiesWithContext
RemovePropertiesWithContext clears the properties of a namespace
pulsaradmin/pkg/admin/namespace.go:760
MethodRemoveProperty
(topic utils.TopicName, key string)
pulsaradmin/pkg/admin/topic.go:1195
MethodRemovePropertyWithContext
RemovePropertyWithContext removes a property with the given key of a topic
pulsaradmin/pkg/admin/topic.go:98
MethodRemovePublishRate
(context.Context, utils.TopicName)
pulsaradmin/pkg/admin/topic_policies.go:66
MethodRemovePublishRate
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic_policies.go:475
MethodRemovePublishRate
(topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1832
MethodRemovePublishRateWithContext
RemovePublishRateWithContext removes message publish rate for a topic
pulsaradmin/pkg/admin/topic.go:625
MethodRemoveReplicationClusters
(context.Context, utils.TopicName)
pulsaradmin/pkg/admin/topic_policies.go:90
MethodRemoveReplicationClusters
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic_policies.go:638
MethodRemoveReplicationClusters
(topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2041
MethodRemoveReplicationClustersWithContext
RemoveReplicationClustersWithContext removes the replication clusters override on a topic
pulsaradmin/pkg/admin/topic.go:839
MethodRemoveReplicatorDispatchRate
(context.Context, utils.TopicName)
pulsaradmin/pkg/admin/topic_policies.go:122
MethodRemoveReplicatorDispatchRate
( ctx context.Context, topic utils.TopicName, )
pulsaradmin/pkg/admin/topic_policies.go:845
MethodRemoveReplicatorDispatchRate
(topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2303
MethodRemoveReplicatorDispatchRateWithContext
RemoveReplicatorDispatchRateWithContext removes replicator dispatch rate for a topic
pulsaradmin/pkg/admin/topic.go:990
MethodRemoveRetention
(context.Context, utils.TopicName)
pulsaradmin/pkg/admin/topic_policies.go:74
MethodRemoveRetention
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic_policies.go:523
MethodRemoveRetention
(topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1883
MethodRemoveRetention
RemoveRetention removes the retention configuration for a namespace, defaulting to broker settings
pulsaradmin/pkg/admin/namespace.go:118
MethodRemoveRetention
(namespace string)
pulsaradmin/pkg/admin/namespace.go:978
MethodRemoveRetentionWithContext
RemoveRetentionWithContext removes the retention configuration on a topic
pulsaradmin/pkg/admin/topic.go:683
MethodRemoveRetentionWithContext
RemoveRetentionWithContext removes the retention configuration for a namespace, defaulting to broker settings
pulsaradmin/pkg/admin/namespace.go:121
MethodRemoveSchemaCompatibilityStrategy
(context.Context, utils.TopicName)
pulsaradmin/pkg/admin/topic_policies.go:134
MethodRemoveSchemaCompatibilityStrategy
( ctx context.Context, topic utils.TopicName, )
pulsaradmin/pkg/admin/topic_policies.go:923
MethodRemoveSchemaCompatibilityStrategy
(topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2384
MethodRemoveSchemaCompatibilityStrategyWithContext
RemoveSchemaCompatibilityStrategyWithContext removes schema compatibility strategy for a topic
pulsaradmin/pkg/admin/topic.go:1079
MethodRemoveSchemaValidationEnforced
(context.Context, utils.TopicName)
pulsaradmin/pkg/admin/topic_policies.go:114
MethodRemoveSchemaValidationEnforced
( ctx context.Context, topic utils.TopicName, )
pulsaradmin/pkg/admin/topic_policies.go:791
MethodRemoveSchemaValidationEnforced
(topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2236
MethodRemoveSchemaValidationEnforcedWithContext
RemoveSchemaValidationEnforcedWithContext removes schema validation enforced flag for a topic
pulsaradmin/pkg/admin/topic.go:951
MethodRemoveSubscribeRate
(context.Context, utils.TopicName)
pulsaradmin/pkg/admin/topic_policies.go:94
MethodRemoveSubscribeRate
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic_policies.go:662
MethodRemoveSubscribeRate
(topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2071
MethodRemoveSubscribeRateWithContext
RemoveSubscribeRateWithContext removes subscribe rate configuration for a topic
pulsaradmin/pkg/admin/topic.go:859
MethodRemoveSubscriptionDispatchRate
(context.Context, utils.TopicName)
pulsaradmin/pkg/admin/topic_policies.go:98
MethodRemoveSubscriptionDispatchRate
( ctx context.Context, topic utils.TopicName, )
pulsaradmin/pkg/admin/topic_policies.go:686
MethodRemoveSubscriptionDispatchRate
(topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:2104
MethodRemoveSubscriptionDispatchRateWithContext
RemoveSubscriptionDispatchRateWithContext removes subscription dispatch rate for a topic
pulsaradmin/pkg/admin/topic.go:879
MethodRemoveSubscriptionExpirationTime
(namespace utils.NameSpaceName)
pulsaradmin/pkg/admin/namespace.go:2085
MethodRemoveSubscriptionExpirationTimeWithContext
RemoveSubscriptionExpirationTimeWithContext removes subscription expiration time from a namespace, defaulting to broker settings
pulsaradmin/pkg/admin/namespace.go:742
MethodRemoveTopicAutoCreation
(namespace utils.NameSpaceName)
pulsaradmin/pkg/admin/namespace.go:1072
MethodRemoveTopicAutoCreationWithContext
RemoveTopicAutoCreationWithContext removes topic auto-creation config for a namespace, defaulting to broker settings
pulsaradmin/pkg/admin/namespace.go:174
MethodRequest
(logicalAddr *url.URL, physicalAddr *url.URL, _ uint64, cmdType pb.BaseCommand_Type, message proto.Message)
pulsar/internal/lookup_service_test.go:90
MethodRequest
(_ *url.URL, _ *url.URL, _ uint64, _ pb.BaseCommand_Type, _ proto.Message)
pulsar/internal/lookup_service_test.go:488
MethodRequestOnCnx
( _ internal.Connection, _ uint64, cmdType pb.BaseCommand_Type, msg proto.Message, )
pulsar/consumer_test.go:6221
MethodRequestOnCnx
( _ internal.Connection, _ uint64, cmdType pb.BaseCommand_Type, _ proto.Message, )
pulsar/consumer_test.go:6290
MethodRequestOnCnx
(_ internal.Connection, _ uint64, _ pb.BaseCommand_Type, _ proto.Message)
pulsar/producer_test.go:2910
MethodRequestOnCnx
(_ internal.Connection, _ uint64, cmdType pb.BaseCommand_Type, _ proto.Message)
pulsar/consumer_partition_test.go:688
MethodRequestOnCnx
(_ Connection, _ uint64, _ pb.BaseCommand_Type, _ proto.Message)
pulsar/internal/lookup_service_test.go:118
MethodRequestOnCnx
(_ Connection, _ uint64, _ pb.BaseCommand_Type, _ proto.Message)
pulsar/internal/lookup_service_test.go:506
MethodRequestOnCnxNoWait
( _ internal.Connection, cmdType pb.BaseCommand_Type, msg proto.Message, )
pulsar/consumer_test.go:6209
MethodRequestOnCnxNoWait
( _ internal.Connection, _ pb.BaseCommand_Type, _ proto.Message)
pulsar/consumer_test.go:6285
MethodRequestOnCnxNoWait
(_ internal.Connection, _ pb.BaseCommand_Type, _ proto.Message)
pulsar/consumer_partition_test.go:683
MethodRequestOnCnxNoWait
(_ Connection, _ pb.BaseCommand_Type, _ proto.Message)
pulsar/internal/lookup_service_test.go:124
MethodRequestOnCnxNoWait
(_ Connection, _ pb.BaseCommand_Type, _ proto.Message)
pulsar/internal/lookup_service_test.go:500
MethodRequestOnCnxNoWait
(cnx Connection, cmdType pb.BaseCommand_Type, message proto.Message)
pulsar/internal/rpc_client.go:207
MethodRequestToAnyBroker
(requestID uint64, cmdType pb.BaseCommand_Type, message proto.Message)
pulsar/internal/rpc_client.go:149
MethodRequestToHost
(_ *ServiceNameResolver, requestID uint64, cmdType pb.BaseCommand_Type, message proto.Message)
pulsar/internal/lookup_service_test.go:81
MethodRequestToHost
(_ *ServiceNameResolver, requestID uint64, cmdType pb.BaseCommand_Type, message proto.Message)
pulsar/internal/lookup_service_test.go:512
MethodRequestToHost
(serviceNameResolver *ServiceNameResolver, requestID uint64, cmdType pb.BaseCommand_Type, message proto.Messa
pulsar/internal/rpc_client.go:154
MethodRequestWithCnxKeySuffix
(_ *url.URL, _ *url.URL, _ int32, _ uint64, _ pb.BaseCommand_Type, _ proto.Message)
pulsar/internal/lookup_service_test.go:112
MethodRequestWithCnxKeySuffix
(_ *url.URL, _ *url.URL, _ int32, _ uint64, _ pb.BaseCommand_Type, _ proto.Message)
pulsar/internal/lookup_service_test.go:494
MethodReserveMemory
(ctx context.Context, size int64)
pulsar/internal/memory_limit_controller.go:74
MethodReset
()
integration-tests/pb/hi.pb.go:50
MethodReset
()
integration-tests/pb/hello.pb.go:52
MethodReset
()
integration-tests/pb/hello.pb.go:122
MethodReset
Reset calls Reset() on the underlying timer.
oauth2/clock/clock.go:96
MethodReset
Reset resets the timer to the fake clock's "now" + d. It returns true if the timer has not yet fired, or false otherwise.
oauth2/clock/testing/fake_clock.go:253
MethodReset
()
pulsar/reader_test.go:922
MethodReset
()
pulsar/producer_test.go:2991
MethodReset
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1408
MethodReset
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1489
MethodReset
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1579
MethodReset
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1634
MethodReset
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1689
MethodReset
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1745
← previousnext →3,601–3,700 of 5,094, ranked by callers