本文整理了Java中zipkin.internal.Util.checkNotNull()
方法的一些代码示例,展示了Util.checkNotNull()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Util.checkNotNull()
方法的具体详情如下:
包路径:zipkin.internal.Util
类名称:Util
方法名:checkNotNull
暂无
代码示例来源:origin: io.zipkin.java/zipkin-transport-scribe
/**
* {@link CollectorSampler#isSampled(Span) samples spans} to reduce load on the storage system.
* Defaults to always sample.
*/
public Builder sampler(CollectorSampler sampler) {
this.sampler = checkNotNull(sampler, "sampler");
return this;
}
代码示例来源:origin: io.zipkin.java/transport-kafka
/** The zookeeper connect string, ex. 127.0.0.1:2181. No default */
public Builder zookeeper(String zookeeper) {
this.zookeeper = checkNotNull(zookeeper, "zookeeper");
return this;
}
代码示例来源:origin: io.zipkin.java/zipkin-storage-elasticsearch
/**
* The index prefix to use when generating daily index names. Defaults to zipkin.
*/
public Builder index(String index) {
this.index = checkNotNull(index, "index");
return this;
}
代码示例来源:origin: io.zipkin.java/zipkin-storage-cassandra
/** Keyspace to store span and index data. Defaults to "zipkin" */
public Builder keyspace(String keyspace) {
this.keyspace = checkNotNull(keyspace, "keyspace");
return this;
}
代码示例来源:origin: io.zipkin.java/zipkin-storage-cassandra
/** Comma separated list of host addresses part of Cassandra cluster. You can also specify a custom port with 'host:port'. Defaults to localhost on port 9042 **/
public Builder contactPoints(String contactPoints) {
this.contactPoints = checkNotNull(contactPoints, "contactPoints");
return this;
}
代码示例来源:origin: io.zipkin.java/zipkin-transport-scribe
/** Category zipkin spans will be consumed from. Defaults to "zipkin" */
public Builder category(String category) {
this.category = checkNotNull(category, "category");
return this;
}
代码示例来源:origin: io.zipkin.java/zipkin-transport-kafka
/**
* {@link CollectorSampler#isSampled(Span) samples spans} to reduce load on the storage system.
* Defaults to always sample.
*/
public Builder sampler(CollectorSampler sampler) {
this.sampler = checkNotNull(sampler, "sampler");
return this;
}
代码示例来源:origin: io.zipkin.java/transport-kafka
/** The consumer group this process is consuming on behalf of. Defaults to "zipkin" */
public Builder groupId(String groupId) {
this.groupId = checkNotNull(groupId, "groupId");
return this;
}
代码示例来源:origin: io.zipkin.java/storage-jdbc
public Builder settings(Settings settings) {
this.settings = checkNotNull(settings, "settings");
return this;
}
代码示例来源:origin: io.zipkin.java/zipkin-transport-kafka
/** Topic zipkin spans will be consumed from. Defaults to "zipkin" */
public Builder topic(String topic) {
this.topic = checkNotNull(topic, "topic");
return this;
}
代码示例来源:origin: io.zipkin.java/zipkin-collector-kafka10
/** The bootstrapServers connect string, ex. 127.0.0.1:9092. No default. */
public Builder bootstrapServers(String bootstrapServers) {
properties.put(BOOTSTRAP_SERVERS_CONFIG, checkNotNull(bootstrapServers, "bootstrapServers"));
return this;
}
代码示例来源:origin: io.zipkin.java/zipkin-storage-mysql
MySQLStorage(MySQLStorage.Builder builder) {
this.datasource = checkNotNull(builder.datasource, "datasource");
this.executor = checkNotNull(builder.executor, "executor");
this.context = new DSLContexts(builder.settings, builder.listenerProvider);
this.strictTraceId = builder.strictTraceId;
this.schema = new Lazy<Schema>() {
@Override protected Schema compute() {
return new Schema(datasource, context, strictTraceId);
}
};
}
代码示例来源:origin: io.zipkin.java/spanstore-jdbc
public JDBCSpanStore(DataSource datasource, Settings settings, @Nullable ExecuteListenerProvider listenerProvider) {
this.datasource = checkNotNull(datasource, "datasource");
this.settings = checkNotNull(settings, "settings");
this.listenerProvider = listenerProvider;
}
代码示例来源:origin: io.zipkin.java/zipkin-transport-kafka
@Override protected AsyncSpanConsumer compute() {
AsyncSpanConsumer result = storage.asyncSpanConsumer(sampler, metrics);
return checkNotNull(result, storage + ".asyncSpanConsumer()");
}
});
代码示例来源:origin: io.zipkin.java/zipkin-transport-kafka
/** Aggregates and reports collection metrics to a monitoring system. Defaults to no-op. */
public Builder metrics(CollectorMetrics metrics) {
this.metrics = checkNotNull(metrics, "metrics").forTransport("kafka");
return this;
}
代码示例来源:origin: io.zipkin.java/transport-kafka
/** Aggregates and reports collection metrics to a monitoring system. Defaults to no-op. */
public Builder metrics(CollectorMetrics metrics) {
this.metrics = checkNotNull(metrics, "metrics").forTransport("kafka");
return this;
}
代码示例来源:origin: io.zipkin.java/zipkin-transport-scribe
/** Aggregates and reports collection metrics to a monitoring system. Defaults to no-op. */
public Builder metrics(CollectorMetrics metrics) {
this.metrics = checkNotNull(metrics, "metrics").forTransport("scribe");
return this;
}
代码示例来源:origin: io.zipkin.java/transport-kafka
@Override protected AsyncSpanConsumer compute() {
AsyncSpanConsumer result = storage.asyncSpanConsumer(sampler, metrics);
return checkNotNull(result, storage + ".asyncSpanConsumer()");
}
});
代码示例来源:origin: io.zipkin.java/zipkin-storage-elasticsearch
/**
* The client supplier to consume for connectivity to elasticsearch. Defaults to using the
* transport-client based {@link NativeClient}, but can be overriden with a HTTP-speaking client
* (e.g. for use in cloud environments where the transport protocol is not exposed).
*/
public static Builder builder(InternalElasticsearchClient.Builder clientBuilder) {
return new Builder(checkNotNull(clientBuilder, "clientBuilder"));
}
代码示例来源:origin: io.zipkin.java/zipkin-collector-kafka10
@Override public Builder metrics(CollectorMetrics metrics) {
this.metrics = checkNotNull(metrics, "metrics").forTransport("kafka");
delegate.metrics(this.metrics);
return this;
}
内容来源于网络,如有侵权,请联系作者删除!