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 callersMethodSplitNamespaceBundleWithContext
( ctx context.Context, namespace, bundle string, unloadSplitBundles bool, )
pulsaradmin/pkg/admin/namespace.go:1655
↓ 1 callersFunctionStartCleanConnectionsTask
These method should only be used by tests
pulsar/internal/helper.go:24
↓ 1 callersMethodStartFunctionWithContext
(ctx context.Context, tenant, namespace, name string)
pulsaradmin/pkg/admin/functions.go:508
↓ 1 callersMethodStartFunctionWithIDWithContext
( ctx context.Context, tenant, namespace, name string, instanceID int, )
pulsaradmin/pkg/admin/functions.go:517
↓ 1 callersMethodStartPrefetcher
()
pulsar/auth/athenz_test.go:75
↓ 1 callersMethodStartSinkWithContext
(ctx context.Context, tenant, namespace, sink string)
pulsaradmin/pkg/admin/sinks.go:569
↓ 1 callersMethodStartSinkWithIDWithContext
(ctx context.Context, tenant, namespace, sink string, instanceID int)
pulsaradmin/pkg/admin/sinks.go:578
↓ 1 callersMethodStartSourceWithContext
(ctx context.Context, tenant, namespace, source string)
pulsaradmin/pkg/admin/sources.go:572
↓ 1 callersMethodStartSourceWithIDWithContext
( ctx context.Context, tenant, namespace, source string, instanceID int, )
pulsaradmin/pkg/admin/sources.go:581
↓ 1 callersMethodStep
Step moves the clock by Duration and notifies anyone that's called After, Tick, or NewTimer.
oauth2/clock/testing/fake_clock.go:121
↓ 1 callersMethodStopFunctionWithContext
(ctx context.Context, tenant, namespace, name string)
pulsaradmin/pkg/admin/functions.go:413
↓ 1 callersMethodStopFunctionWithIDWithContext
( ctx context.Context, tenant, namespace, name string, instanceID int, )
pulsaradmin/pkg/admin/functions.go:422
↓ 1 callersMethodStopPrefetcher
()
pulsar/auth/athenz_test.go:81
↓ 1 callersMethodStopSinkWithContext
(ctx context.Context, tenant, namespace, sink string)
pulsaradmin/pkg/admin/sinks.go:549
↓ 1 callersMethodStopSinkWithIDWithContext
(ctx context.Context, tenant, namespace, sink string, instanceID int)
pulsaradmin/pkg/admin/sinks.go:558
↓ 1 callersMethodStopSourceWithContext
(ctx context.Context, tenant, namespace, source string)
pulsaradmin/pkg/admin/sources.go:546
↓ 1 callersMethodStopSourceWithIDWithContext
( ctx context.Context, tenant, namespace, source string, instanceID int, )
pulsaradmin/pkg/admin/sources.go:555
↓ 1 callersMethodString
()
pulsaradmin/pkg/admin/config/api_version.go:31
↓ 1 callersMethodTerminateWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1482
↓ 1 callersMethodTestCompatibilityWithPostSchemaPayload
TestCompatibilityWithPostSchemaPayload tests compatibility with a schema
pulsaradmin/pkg/admin/schema.go:64
↓ 1 callersMethodTestCompatibilityWithSchemaInfo
TestCompatibilityWithSchemaInfo tests compatibility with a schema
pulsaradmin/pkg/admin/schema.go:61
↓ 1 callersMethodTestCompatibilityWithSchemaInfoWithContext
(ctx context.Context, topic string, schemaInfo utils.SchemaInfo)
pulsaradmin/pkg/admin/schema.go:282
↓ 1 callersMethodTick
(d time.Duration)
oauth2/clock/clock.go:30
↓ 1 callersMethodTopic
()
pulsar/consumer_partition.go:268
↓ 1 callersMethodTransport
()
pulsaradmin/pkg/admin/auth/provider.go:31
↓ 1 callersMethodTriggerFunctionWithContext
( ctx context.Context, tenant, namespace, name, topic, triggerValue, triggerFile string, )
pulsaradmin/pkg/admin/functions.go:875
↓ 1 callersMethodUnloadNamespaceBundleWithContext
(ctx context.Context, namespace, bundle string)
pulsaradmin/pkg/admin/namespace.go:1642
↓ 1 callersMethodUnloadWithContext
(ctx context.Context, topic utils.TopicName)
pulsaradmin/pkg/admin/topic.go:1516
↓ 1 callersMethodUnloadWithContext
(ctx context.Context, namespace string)
pulsaradmin/pkg/admin/namespace.go:1629
↓ 1 callersMethodUnlock
()
pulsar/internal/blocking_queue.go:229
↓ 1 callersMethodUnsubscribeNamespaceBundleWithContext
( ctx context.Context, namespace utils.NameSpaceName, bundle, sName string, )
pulsaradmin/pkg/admin/namespace.go:1804
↓ 1 callersMethodUnsubscribeNamespaceWithContext
( ctx context.Context, namespace utils.NameSpaceName, sName string, )
pulsaradmin/pkg/admin/namespace.go:1791
↓ 1 callersMethodUpdateDynamicConfigurationWithContext
(ctx context.Context, configName, configValue string)
pulsaradmin/pkg/admin/brokers.go:189
↓ 1 callersMethodUpdateFailureDomainWithContext
(ctx context.Context, data utils.FailureDomainData)
pulsaradmin/pkg/admin/cluster.go:235
↓ 1 callersMethodUpdateFunctionWithContext
( ctx context.Context, functionConfig *utils.FunctionConfig, fileName string, updateOptions *utils.UpdateO
pulsaradmin/pkg/admin/functions.go:588
↓ 1 callersMethodUpdateFunctionWithURLWithContext
( ctx context.Context, functionConfig *utils.FunctionConfig, pkgURL string, updateOptions *utils.UpdateOpt
pulsaradmin/pkg/admin/functions.go:673
↓ 1 callersMethodUpdateMetadataWithContext
( ctx context.Context, packageURL, description, contact string, properties map[string]string, )
pulsaradmin/pkg/admin/packages.go:329
↓ 1 callersMethodUpdatePeerClustersWithContext
(ctx context.Context, cluster string, peerClusters []string)
pulsaradmin/pkg/admin/cluster.go:177
↓ 1 callersMethodUpdatePropertiesWithContext
( ctx context.Context, topic utils.TopicName, properties map[string]string, )
pulsaradmin/pkg/admin/topic.go:1186
↓ 1 callersMethodUpdatePropertiesWithContext
( ctx context.Context, namespace utils.NameSpaceName, properties map[string]string, )
pulsaradmin/pkg/admin/namespace.go:2101
↓ 1 callersMethodUpdateServiceURL
(serviceURL string)
pulsar/internal/service_name_resolver.go:73
↓ 1 callersMethodUpdateSinkWithContext
( ctx context.Context, config *utils.SinkConfig, fileName string, updateOptions *utils.UpdateOptions, )
pulsaradmin/pkg/admin/sinks.go:323
↓ 1 callersMethodUpdateSinkWithURLWithContext
( ctx context.Context, config *utils.SinkConfig, pkgURL string, updateOptions *utils.UpdateOptions, )
pulsaradmin/pkg/admin/sinks.go:407
↓ 1 callersMethodUpdateSourceWithContext
( ctx context.Context, config *utils.SourceConfig, fileName string, updateOptions *utils.UpdateOptions, )
pulsaradmin/pkg/admin/sources.go:327
↓ 1 callersMethodUpdateSourceWithURLWithContext
(ctx context.Context, config *utils.SourceConfig, pkgURL string, updateOptions *utils.UpdateOptions)
pulsaradmin/pkg/admin/sources.go:412
↓ 1 callersMethodUpdateWithContext
(ctx context.Context, data utils.TenantData)
pulsaradmin/pkg/admin/tenant.go:94
↓ 1 callersMethodUpdateWithContext
(ctx context.Context, topic utils.TopicName, partitions int)
pulsaradmin/pkg/admin/topic.go:1223
↓ 1 callersMethodUpdateWithContext
(ctx context.Context, cdata utils.ClusterData)
pulsaradmin/pkg/admin/cluster.go:157
↓ 1 callersMethodUploadWithContext
( ctx context.Context, packageURL, filePath, description, contact string, properties map[string]string,
pulsaradmin/pkg/admin/packages.go:191
↓ 1 callersMethodUploadWithContext
(ctx context.Context, sourceFile, path string)
pulsaradmin/pkg/admin/functions.go:955
↓ 1 callersMethodUseTLS
()
pulsar/internal/service_uri.go:69
↓ 1 callersMethodVal
(key string)
pulsar/internal/key_based_batch_builder.go:78
↓ 1 callersMethodWaitForClose
()
pulsar/internal/connection.go:90
↓ 1 callersMethodWithField
(name string, value any)
pulsar/log/wrapper_slog.go:94
↓ 1 callersMethodWrite
(p []byte)
pulsar/internal/checksum.go:38
↓ 1 callersMethodWriteUint16
(n uint16)
pulsar/internal/buffer.go:65
↓ 1 callersMethodadd
(delta int32)
pulsar/consumer_partition.go:295
↓ 1 callersMethodadd
(schemaVersionHash string, schema Schema)
pulsar/consumer_partition.go:396
↓ 1 callersFunctionaddMsgIDToPendingAcks
(pendingAcks map[position]*bitset.BitSet, id MessageID)
pulsar/ack_grouping_tracker.go:150
↓ 1 callersMethodappend
(chunkID int32, msgID *messageID, partPayload internal.Buffer)
pulsar/consumer_partition.go:2658
↓ 1 callersMethodappliedQueryParams
(applied bool)
pulsaradmin/pkg/admin/topic_policies.go:190
↓ 1 callersFunctionassertConnectionClosed
(t *testing.T, c *connection)
pulsar/internal/connection_test.go:158
↓ 1 callersFunctionassertPanic
(t *testing.T, panicValue interface{}, f func())
pulsar/consumer_zero_queue_test.go:749
↓ 1 callersMethodcanTryRunning
()
pulsar/internal/memory_limit_controller.go:52
↓ 1 callersMethodclearPendingSendRequests
clearPendingSendRequests makes sure to push forward previous sending requests by emptying the data channel.
pulsar/producer_partition.go:1096
↓ 1 callersMethodclearReceiverQueue
** * Clear the internal receiver queue and returns the message id of what was the 1st message in the queue that was * not seen by the application *
pulsar/consumer_partition.go:2374
↓ 1 callersMethodcloseAndEmptyObservers
()
pulsar/internal/connection.go:1081
↓ 1 callersMethodcloseWithCause
(err error)
pulsar/consumer_partition.go:143
↓ 1 callersMethodcloseWithCause
closeWithCause closes the consumer and notifies any ConsumerCloseInterceptor with the supplied cause. The hook fires exactly once per consumer; the ca
pulsar/consumer_impl.go:716
↓ 1 callersMethodcloseWithCause
closeWithCause closes the consumer and notifies any ConsumerCloseInterceptor with the supplied cause. The hook fires exactly once per consumer.
pulsar/consumer_zero_queue.go:269
↓ 1 callersMethodclosed
()
pulsar/consumer_regex.go:351
↓ 1 callersMethodcompareLedgerAndEntryID
(other *messageID)
pulsar/impl_message.go:153
↓ 1 callersMethodconfigTLS
()
pulsar/auth/tls.go:93
↓ 1 callersMethodconfigTLS
()
pulsaradmin/pkg/admin/auth/tls.go:96
↓ 1 callersMethodconnect
()
pulsar/internal/connection.go:252
↓ 1 callersFunctionconsume
(consumeArgs *ConsumeArgs, stop <-chan struct{})
perf/perf-consumer.go:73
↓ 1 callersFunctionconvertToMessageIDData
(msgID *trackingMessageID)
pulsar/consumer_partition.go:2607
↓ 1 callersFunctioncreateEncryptionContext
create EncryptionContext from message metadata this will be used to decrypt the message payload outside of this client it is the responsibility of end
pulsar/consumer_partition.go:1723
↓ 1 callersFunctioncreateNamespace
(namespace string, policy map[string]interface{})
pulsar/helper_for_test.go:142
↓ 1 callersMethodcreateStringFromField
(w *multipart.Writer, value string)
pulsaradmin/pkg/admin/packages.go:133
↓ 1 callersFunctiondecodeJSONBody
decodeJSONBody is used to JSON decode a body
pulsar/internal/http_client.go:301
↓ 1 callersFunctiondecodeJSONWithBody
decodeJSONWithBody is used to JSON decode a body AND ALSO return the raw body bytes
pulsaradmin/pkg/rest/client.go:543
↓ 1 callersFunctiondecodeOptionalSchemaCompatibilityStrategy
(body []byte)
pulsaradmin/pkg/admin/topic_policies.go:242
↓ 1 callersMethoddecryptData
(dataKeySecret []byte, msgMetadata MessageMetadataSupplier, payload []byte)
pulsar/crypto/default_message_crypto.go:245
↓ 1 callersMethoddecryptDataKey
(keyName string, encDatakey []byte, keyMeta map[string]string, keyReader KeyReader)
pulsar/crypto/default_message_crypto.go:295
↓ 1 callersFunctiondeleteTopic
(topic string)
pulsar/helper_for_test.go:150
↓ 1 callersMethoddeserializeCmd
(data []byte)
pulsar/internal/connection_reader.go:136
↓ 1 callersMethoddiscardChunkIfExpire
(uuid string, autoAck bool, expire time.Duration)
pulsar/consumer_partition.go:2802
↓ 1 callersMethoddiscardChunkMessage
(uuid string, autoAck bool)
pulsar/consumer_partition.go:2777
↓ 1 callersMethoddiscardOldestChunkMessage
(autoAck bool)
pulsar/consumer_partition.go:2758
↓ 1 callersMethoddispatcher
dispatcher manages the internal message queue channel and manages the flow control
pulsar/consumer_partition.go:1802
↓ 1 callersFunctiondistinct
(fqdnTopics []string)
pulsar/consumer_impl.go:868
↓ 1 callersMethoddoHandshake
()
pulsar/internal/connection.go:297
↓ 1 callersFunctionencodeJSONBody
encodeJSONBody is used to JSON encode a body
pulsar/internal/http_client.go:291
↓ 1 callersMethodencryptionKeyPresent
(keyInfo EncryptionKeyInfo)
pulsar/crypto/message_metadata.go:91
↓ 1 callersFunctionendpoint
(parts ...string)
pulsar/internal/http_client.go:286
↓ 1 callersFunctionendpoint
(parts ...string)
pulsaradmin/pkg/rest/client.go:520
↓ 1 callersMethodendpointWithFullPath
this function won't do any escaping
pulsaradmin/pkg/admin/admin.go:117
↓ 1 callersFunctionenrichConsumerSpan
(message *pulsar.ConsumerMessage, span opentracing.Span)
pulsar/internal/pulsartracing/span-enrichment.go:25
↓ 1 callersFunctionenrichProducerSpan
(message *pulsar.ProducerMessage, producer pulsar.Producer, span opentracing.Span)
pulsar/internal/pulsartracing/span-enrichment.go:36
← previousnext →1,401–1,500 of 5,094, ranked by callers