Index
All Classes and Interfaces|All Packages
B
- build() - Method in class zipkin2.collector.pulsar.PulsarCollector.Builder
- builder() - Static method in class zipkin2.collector.pulsar.PulsarCollector
- Builder() - Constructor for class zipkin2.collector.pulsar.PulsarCollector.Builder
C
- check() - Method in class zipkin2.collector.pulsar.PulsarCollector
- clientProps(Map<String, Object>) - Method in class zipkin2.collector.pulsar.PulsarCollector.Builder
-
Any properties set here will override the previous Pulsar client configuration.
- close() - Method in class zipkin2.collector.pulsar.PulsarCollector
- close() - Method in class zipkin2.collector.pulsar.PulsarSpanConsumer
- concurrency(Integer) - Method in class zipkin2.collector.pulsar.PulsarCollector.Builder
-
Count of concurrent message consumers on the topic.
- consumerProps(Map<String, Object>) - Method in class zipkin2.collector.pulsar.PulsarCollector.Builder
-
Any properties set here will override the previous Pulsar consumer configuration.
M
- metrics(CollectorMetrics) - Method in class zipkin2.collector.pulsar.PulsarCollector.Builder
P
- PulsarCollector - Class in zipkin2.collector.pulsar
-
This collector consumes encoded binary messages from a Pulsar topic.
- PulsarCollector.Builder - Class in zipkin2.collector.pulsar
-
Configuration including defaults needed to consume spans from a Pulsar topic.
- PulsarSpanConsumer - Class in zipkin2.collector.pulsar
- PulsarSpanConsumer(String, Map<String, Object>, PulsarClient, Collector, CollectorMetrics) - Constructor for class zipkin2.collector.pulsar.PulsarSpanConsumer
S
- sampler(CollectorSampler) - Method in class zipkin2.collector.pulsar.PulsarCollector.Builder
- serviceUrl(String) - Method in class zipkin2.collector.pulsar.PulsarCollector.Builder
-
The service URL for the Pulsar client ex. pulsar://my-broker:6650.
- start() - Method in class zipkin2.collector.pulsar.PulsarCollector
- startConsumer() - Method in class zipkin2.collector.pulsar.PulsarSpanConsumer
- storage(StorageComponent) - Method in class zipkin2.collector.pulsar.PulsarCollector.Builder
- subscriptionName(String) - Method in class zipkin2.collector.pulsar.PulsarCollector.Builder
-
Specify the subscription name for this consumer.
T
- topic(String) - Method in class zipkin2.collector.pulsar.PulsarCollector.Builder
-
Queue zipkin spans will be consumed from.
- toString() - Method in class zipkin2.collector.pulsar.PulsarCollector
Z
- zipkin2.collector.pulsar - package zipkin2.collector.pulsar
All Classes and Interfaces|All Packages