Functions — github.com/apache/pulsar-client-go

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

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

⨍ Functions 5,094◇ Types & classes 637

GetRetentionWithContext returns the retention configuration for a topic. Returns nil if the retention policy is not configured at the topic level. @p

pulsaradmin/pkg/admin/topic.go:677

MethodGetRetentionWithContext

GetRetentionWithContext returns the retention configuration for a namespace. Returns nil if the retention policy is not configured at the namespace le

pulsaradmin/pkg/admin/namespace.go:109

MethodGetRuntimeConfigurations

GetRuntimeConfigurations returns values of runtime configuration

pulsaradmin/pkg/admin/brokers.go:76

MethodGetRuntimeConfigurations

()

pulsaradmin/pkg/admin/brokers.go:204

MethodGetRuntimeConfigurationsWithContext

GetRuntimeConfigurationsWithContext returns values of runtime configuration

pulsaradmin/pkg/admin/brokers.go:79

MethodGetSchema

(topic string, schemaVersion []byte)

pulsar/internal/lookup_service.go:109

MethodGetSchema

(topic string, schemaVersion []byte)

pulsar/internal/lookup_service.go:402

MethodGetSchema

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:2995

MethodGetSchema

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:3561

MethodGetSchema

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:4800

MethodGetSchema

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:5982

MethodGetSchema

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:6052

MethodGetSchemaAutoUpdateCompatibilityStrategy

GetSchemaAutoUpdateCompatibilityStrategy returns the strategy used to check the new schema provided by a producer is compatible with the current schem

pulsaradmin/pkg/admin/namespace.go:204

MethodGetSchemaAutoUpdateCompatibilityStrategy

(namespace utils.NameSpaceName)

pulsaradmin/pkg/admin/namespace.go:1122

MethodGetSchemaAutoUpdateCompatibilityStrategyWithContext

GetSchemaAutoUpdateCompatibilityStrategyWithContext returns the strategy used to check the new schema provided by a producer is compatible with the cu

pulsaradmin/pkg/admin/namespace.go:209

MethodGetSchemaCompatibilityStrategy

(context.Context, utils.TopicName, bool)

pulsaradmin/pkg/admin/topic_policies.go:132

MethodGetSchemaCompatibilityStrategy

( ctx context.Context, topic utils.TopicName, applied bool, )

pulsaradmin/pkg/admin/topic_policies.go:903

MethodGetSchemaCompatibilityStrategy

(topic utils.TopicName)

pulsaradmin/pkg/admin/topic.go:2343

MethodGetSchemaCompatibilityStrategy

GetSchemaCompatibilityStrategy returns the strategy used to check the new schema provided by a producer is compatible with the current schema before i

pulsaradmin/pkg/admin/namespace.go:224

MethodGetSchemaCompatibilityStrategy

(namespace utils.NameSpaceName)

pulsaradmin/pkg/admin/namespace.go:1155

MethodGetSchemaCompatibilityStrategyWithContext

GetSchemaCompatibilityStrategyWithContext returns the applied schema compatibility strategy for a topic.

pulsaradmin/pkg/admin/topic.go:1041

MethodGetSchemaCompatibilityStrategyWithContext

( ctx context.Context, topic utils.TopicName, )

pulsaradmin/pkg/admin/topic.go:2347

MethodGetSchemaCompatibilityStrategyWithContext

GetSchemaCompatibilityStrategyWithContext returns the strategy used to check the new schema provided by a producer is compatible with the current sche

pulsaradmin/pkg/admin/namespace.go:228

MethodGetSchemaData

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:1447

pulsaradmin/pkg/admin/schema.go:81

MethodGetSchemaInfoByVersion

GetSchemaInfoByVersion retrieves the schema of a topic at a given <tt>version</tt>

pulsaradmin/pkg/admin/schema.go:37

MethodGetSchemaInfoByVersion

(topic string, version int64)

pulsaradmin/pkg/admin/schema.go:129

MethodGetSchemaInfoWithVersion

GetSchemaInfoWithVersion retrieves the latest schema with version of a topic

pulsaradmin/pkg/admin/schema.go:34

MethodGetSchemaInfoWithVersion

(topic string)

pulsaradmin/pkg/admin/schema.go:103

MethodGetSchemaValidationEnforced

(context.Context, utils.TopicName, bool)

pulsaradmin/pkg/admin/topic_policies.go:112

MethodGetSchemaValidationEnforced

( ctx context.Context, topic utils.TopicName, applied bool, )

pulsaradmin/pkg/admin/topic_policies.go:771

MethodGetSchemaValidationEnforced

(topic utils.TopicName)

pulsaradmin/pkg/admin/topic.go:2211

MethodGetSchemaValidationEnforced

GetSchemaValidationEnforced returns schema validation enforced for namespace

pulsaradmin/pkg/admin/namespace.go:187

MethodGetSchemaValidationEnforced

(namespace utils.NameSpaceName)

pulsaradmin/pkg/admin/namespace.go:1094

MethodGetSchemaValidationEnforcedWithContext

GetSchemaValidationEnforcedWithContext returns schema validation enforced flag for a topic

pulsaradmin/pkg/admin/topic.go:939

MethodGetSchemaValidationEnforcedWithContext

GetSchemaValidationEnforcedWithContext returns schema validation enforced for namespace

pulsaradmin/pkg/admin/namespace.go:190

MethodGetSchemaValue

(v interface{})

pulsar/impl_message.go:373

MethodGetSchemaValue

(_ interface{})

pulsar/negative_acks_tracker_test.go:240

MethodGetSchemaValue

(_ interface{})

pulsar/negative_acks_tracker_test.go:320

MethodGetSchemaValue

(_ interface{})

pulsar/internal/pulsartracing/message_carrier_util_test.go:119

MethodGetSchemaVersion

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:4887

MethodGetSchemaVersion

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:5910

MethodGetSchemaVersion

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:5989

MethodGetSchemaVersion

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:6123

MethodGetSeek

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:7592

MethodGetSend

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:7438

MethodGetSequenceId

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:1906

MethodGetSequenceId

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:2208

MethodGetSequenceId

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:3789

MethodGetSequenceId

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:3860

MethodGetServerVersion

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:2545

MethodGetServerVersion

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:2688

MethodGetServiceURI

()

pulsar/internal/service_name_resolver.go:101

MethodGetSink

GetSink returns the configuration for the specified sink

pulsaradmin/pkg/admin/sinks.go:44

MethodGetSink

(tenant, namespace, sink string)

pulsaradmin/pkg/admin/sinks.go:197

MethodGetSinkStatus

GetSinkStatus returns the current status of a sink.

pulsaradmin/pkg/admin/sinks.go:93

MethodGetSinkStatus

(tenant, namespace, sink string)

pulsaradmin/pkg/admin/sinks.go:485

MethodGetSinkStatusWithContext

GetSinkStatusWithContext returns the current status of a sink.

pulsaradmin/pkg/admin/sinks.go:96

MethodGetSinkStatusWithID

GetSinkStatusWithID returns the current status of a sink instance.

pulsaradmin/pkg/admin/sinks.go:99

MethodGetSinkStatusWithID

(tenant, namespace, sink string, id int)

pulsaradmin/pkg/admin/sinks.go:501

MethodGetSinkStatusWithIDWithContext

GetSinkStatusWithIDWithContext returns the current status of a sink instance.

pulsaradmin/pkg/admin/sinks.go:102

MethodGetSinkWithContext

GetSinkWithContext returns the configuration for the specified sink

pulsaradmin/pkg/admin/sinks.go:47

MethodGetSource

GetSource return the configuration for the specified source

pulsaradmin/pkg/admin/sources.go:44

MethodGetSource

(tenant, namespace, source string)

pulsaradmin/pkg/admin/sources.go:196

MethodGetSourceStatus

GetSourceStatus returns the current status of a source.

pulsaradmin/pkg/admin/sources.go:92

MethodGetSourceStatus

(tenant, namespace, source string)

pulsaradmin/pkg/admin/sources.go:486

MethodGetSourceStatusWithContext

GetSourceStatus returns the current status of a source.

pulsaradmin/pkg/admin/sources.go:95

MethodGetSourceStatusWithID

GetSourceStatusWithID returns the current status of a source instance.

pulsaradmin/pkg/admin/sources.go:98

MethodGetSourceStatusWithID

(tenant, namespace, source string, id int)

pulsaradmin/pkg/admin/sources.go:502

MethodGetSourceStatusWithIDWithContext

GetSourceStatusWithID returns the current status of a source instance.

pulsaradmin/pkg/admin/sources.go:101

MethodGetSourceWithContext

GetSource return the configuration for the specified source

pulsaradmin/pkg/admin/sources.go:47

MethodGetStart

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:1721

MethodGetStartMessageId

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:2974

MethodGetStartMessageRollbackDurationSec

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:3023

MethodGetState

()

pulsar/transaction_impl.go:85

MethodGetStats

(topic utils.TopicName)

pulsaradmin/pkg/admin/topic.go:1392

MethodGetStatsWithContext

GetStatsWithContext returns the stats for the topic. All the rates are computed over a 1-minute window and are relative the last completed 1-minute p

pulsaradmin/pkg/admin/topic.go:262

MethodGetStatsWithOption

(topic utils.TopicName, option utils.GetStatsOptions)

pulsaradmin/pkg/admin/topic.go:1403

MethodGetSubPermissions

(namespace utils.NameSpaceName)

pulsaradmin/pkg/admin/namespace.go:1747

MethodGetSubPermissionsWithContext

GetSubPermissionsWithContext returns subscription permissions on a namespace

pulsaradmin/pkg/admin/namespace.go:535

MethodGetSubType

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:2932

MethodGetSubscribe

()

pulsar/internal/pulsar_proto/PulsarApi.pb.go:7424

MethodGetSubscribeRate

(context.Context, utils.TopicName, bool)

pulsaradmin/pkg/admin/topic_policies.go:92

MethodGetSubscribeRate

( ctx context.Context, topic utils.TopicName, applied bool, )

pulsaradmin/pkg/admin/topic_policies.go:642

MethodGetSubscribeRate

(topic utils.TopicName)

pulsaradmin/pkg/admin/topic.go:2050

MethodGetSubscribeRate

GetSubscribeRate returns namespace-subscribe-rate (topics under this namespace allow subscribe times per consumer in a period)

pulsaradmin/pkg/admin/namespace.go:643

MethodGetSubscribeRate

(namespace utils.NameSpaceName)

pulsaradmin/pkg/admin/namespace.go:1929

MethodGetSubscribeRateWithContext

GetSubscribeRateWithContext returns subscribe rate configuration for a topic. Returns nil if the subscribe rate is not configured at the topic level.

pulsaradmin/pkg/admin/topic.go:847

← previous next →2,801–2,900 of 5,094, ranked by callers