MCPcopy Create free account

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

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

MethodGetUnsubscribe
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7480
MethodGetUserProvidedProducerName
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:3575
MethodGetValidationError
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:4040
MethodGetValue
()
integration-tests/pb/hello.pb.go:161
MethodGetValue
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1673
MethodGetValue
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:1784
MethodGetVersionByPayload
(topic string, schemaPayload utils.PostSchemaPayload)
pulsaradmin/pkg/admin/schema.go:255
MethodGetVersionBySchemaInfo
(topic string, schemaInfo utils.SchemaInfo)
pulsaradmin/pkg/admin/schema.go:242
MethodGetWatchTopicList
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7781
MethodGetWatchTopicListClose
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7802
MethodGetWatchTopicListSuccess
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7788
MethodGetWatchTopicUpdate
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:7795
MethodGetWatcherId
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5629
MethodGetWatcherId
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5707
MethodGetWatcherId
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5771
MethodGetWatcherId
()
pulsar/internal/pulsar_proto/PulsarApi.pb.go:5847
MethodGetWithOptions
(endpoint string, obj interface{}, params map[string]string, decode bool, file io.Writer)
pulsaradmin/pkg/rest/client.go:163
MethodGetWithQueryParams
(endpoint string, obj interface{}, params map[string]string, decode bool)
pulsaradmin/pkg/rest/client.go:148
MethodGrantNamespacePermission
GrantNamespacePermission grants permission on a namespace.
pulsaradmin/pkg/admin/namespace.go:503
MethodGrantNamespacePermission
(namespace utils.NameSpaceName, role string, action []utils.AuthAction)
pulsaradmin/pkg/admin/namespace.go:1686
MethodGrantNamespacePermissionWithContext
GrantNamespacePermissionWithContext grants permission on a namespace.
pulsaradmin/pkg/admin/namespace.go:506
MethodGrantPermission
GrantPermission grants a new permission to a client role on a single topic @param topic topicName struct @param role client role to which grant permi
pulsaradmin/pkg/admin/topic.go:182
MethodGrantPermission
(topic utils.TopicName, role string, action []utils.AuthAction)
pulsaradmin/pkg/admin/topic.go:1318
MethodGrantPermissionWithContext
GrantPermissionWithContext grants a new permission to a client role on a single topic @param ctx context used for the request @param topic topicName
pulsaradmin/pkg/admin/topic.go:194
MethodGrantSubPermission
(namespace utils.NameSpaceName, sName string, roles []string)
pulsaradmin/pkg/admin/namespace.go:1717
MethodGrantSubPermissionWithContext
GrantSubPermissionWithContext grants permission to role to access subscription's admin-api
pulsaradmin/pkg/admin/namespace.go:523
MethodHasNext
()
pulsar/reader_impl.go:189
MethodHasWaiters
HasWaiters returns true if After has been called on f but not yet satisfied (so you can write race-free tests).
oauth2/clock/testing/fake_clock.go:169
MethodHealthCheck
()
pulsaradmin/pkg/admin/brokers.go:248
MethodHealthCheckWithContext
Deprecated: Use HealthCheckWithTopicVersionWithContext instead
pulsaradmin/pkg/admin/brokers.go:97
MethodHealthCheckWithTopicVersion
(topicVersion utils.TopicVersion)
pulsaradmin/pkg/admin/brokers.go:256
MethodHealthCheckWithTopicVersionWithContext
HealthCheckWithTopicVersionWithContext runs a health check on the broker
pulsaradmin/pkg/admin/brokers.go:103
MethodID
()
pulsar/consumer_multitopic_test.go:352
MethodID
()
pulsar/impl_message.go:341
MethodID
()
pulsar/negative_acks_tracker_test.go:204
MethodID
()
pulsar/negative_acks_tracker_test.go:284
MethodID
()
pulsar/internal/connection.go:1198
MethodID
()
pulsar/internal/pulsartracing/message_carrier_util_test.go:87
MethodIndex
()
pulsar/impl_message.go:396
MethodIndex
()
pulsar/negative_acks_tracker_test.go:256
MethodIndex
()
pulsar/negative_acks_tracker_test.go:336
MethodIndex
()
pulsar/internal/pulsartracing/message_carrier_util_test.go:134
MethodInfo
(args ...interface{})
pulsar/log/wrapper_logrus.go:66
MethodInfo
(args ...interface{})
pulsar/log/wrapper_logrus.go:114
MethodInfo
(args ...interface{})
pulsar/log/logger.go:43
MethodInfo
(args ...any)
pulsar/log/wrapper_slog.go:39
MethodInfo
(_ ...interface{})
pulsar/log/log.go:32
MethodInfo
(_ ...interface{})
pulsar/log/log.go:46
MethodInfof
(format string, args ...interface{})
pulsar/log/wrapper_logrus.go:82
MethodInfof
(format string, args ...interface{})
pulsar/log/wrapper_logrus.go:130
MethodInfof
(format string, args ...interface{})
pulsar/log/logger.go:48
MethodInfof
(format string, args ...any)
pulsar/log/wrapper_slog.go:66
MethodInfof
(_ string, _ ...interface{})
pulsar/log/log.go:36
MethodInfof
(_ string, _ ...interface{})
pulsar/log/log.go:50
MethodInit
()
pulsar/auth/disabled.go:32
MethodInit
()
pulsar/auth/oauth2.go:87
MethodInit
()
pulsar/auth/basic.go:52
MethodInit
()
pulsar/auth/athenz.go:134
MethodInit
()
pulsar/auth/tls.go:54
MethodInit
()
pulsar/auth/token.go:85
MethodInvalidateToken
InvalidateToken clears the cached access token (likely due to a response from the resource server).
oauth2/cache/cache.go:91
FunctionIsAdminError
(err error)
pulsaradmin/pkg/rest/errors.go:32
MethodIsEmpty
IsEmpty returns true if this TableView contains no key-value mappings.
pulsar/table_view.go:54
MethodIsEmpty
()
pulsar/table_view_impl.go:169
MethodIsFull
IsFull check if the size in the current batch exceeds the maximum size allowed by the batch
pulsar/internal/batch_builder.go:42
MethodIsFull
IsFull checks if the size in the current batch meets or exceeds the maximum size allowed by the batch
pulsar/internal/batch_builder.go:165
MethodIsFull
IsFull checks if the size in the current batch meets or exceeds the maximum size allowed by the batch
pulsar/internal/key_based_batch_builder.go:110
MethodIsMaxBackoffReached
()
pulsar/reader_test.go:918
MethodIsMaxBackoffReached
()
pulsar/producer_test.go:2985
MethodIsMemoryLimited
()
pulsar/internal/memory_limit_controller.go:33
MethodIsMultiBatches
batchContainer as a single batch container
pulsar/internal/batch_builder.go:300
MethodIsMultiBatches
()
pulsar/internal/key_based_batch_builder.go:114
MethodIsNullValue
()
pulsar/impl_message.go:337
MethodIsNullValue
()
pulsar/negative_acks_tracker_test.go:200
MethodIsNullValue
()
pulsar/negative_acks_tracker_test.go:280
MethodIsNullValue
()
pulsar/internal/pulsartracing/message_carrier_util_test.go:83
MethodIsPersistent
()
pulsaradmin/pkg/utils/topic_name.go:117
MethodIsProxied
()
pulsar/consumer_multitopic_test.go:367
MethodIsReplicated
IsReplicated determines whether the message is replicated from another cluster.
pulsar/message.go:127
MethodIsReplicated
()
pulsar/impl_message.go:365
MethodIsReplicated
()
pulsar/negative_acks_tracker_test.go:232
MethodIsReplicated
()
pulsar/negative_acks_tracker_test.go:312
MethodIsReplicated
()
pulsar/internal/pulsartracing/message_carrier_util_test.go:111
MethodIsWritable
()
pulsar/internal/buffer.go:44
MethodIsWritable
()
pulsar/internal/buffer.go:175
MethodIterateUnsafe
(f func(item interface{}))
pulsar/producer_test.go:2571
MethodIterateUnsafe
(f func(item interface{}))
pulsar/internal/blocking_queue.go:78
MethodKey
()
pulsar/impl_message.go:353
MethodKey
()
pulsar/negative_acks_tracker_test.go:220
MethodKey
()
pulsar/negative_acks_tracker_test.go:300
MethodKey
Key get the key data
pulsar/crypto/encryption_key_Info.go:42
MethodKey
()
pulsar/internal/pulsartracing/message_carrier_util_test.go:99
MethodKeys
Keys returns a slice of the keys contained in this TableView.
pulsar/table_view.go:66
MethodKeys
()
pulsar/table_view_impl.go:198
MethodLastSequenceID
()
pulsar/producer_impl.go:328
MethodLastSequenceID
()
pulsar/producer_partition.go:1548
MethodLastSequenceID
()
pulsar/internal/pulsartracing/producer_interceptor_test.go:62
MethodLedgerID
()
pulsar/reader_test.go:571
MethodLedgerID
()
pulsar/impl_message.go:176
MethodLedgerID
()
pulsar/impl_message.go:533
← previousnext →3,001–3,100 of 5,094, ranked by callers