Modifier and Type | Field and Description |
---|---|
protected Context |
AbstractVerticle.context
Reference to the context of the verticle
|
Modifier and Type | Method and Description |
---|---|
static Context |
Vertx.currentContext()
Gets the current context
|
Context |
Context.exceptionHandler(Handler<Throwable> handler)
Set an exception handler called when the context runs an action throwing an uncaught throwable.
When this handler is called,
Vertx.currentContext() will return this context. |
Context |
Vertx.getOrCreateContext()
Gets the current context, or creates one if there isn't one
|
Modifier and Type | Method and Description |
---|---|
static <T> Future<T> |
Future.fromCompletionStage(CompletionStage<T> completionStage,
Context context)
Bridges a
CompletionStage object to a Vert.x future instance. |
void |
Verticle.init(Vertx vertx,
Context context)
Initialise the verticle with the Vert.x instance and the context.
|
void |
AbstractVerticle.init(Vertx vertx,
Context context)
Initialise the verticle.
|
Modifier and Type | Method and Description |
---|---|
default <R> I |
VertxTracer.receiveRequest(Context context,
SpanKind kind,
TracingPolicy policy,
R request,
String operation,
Iterable<Map.Entry<String,String>> headers,
TagExtractor<R> tagExtractor)
Signal a request has been received and will be processed.
|
default <R> void |
VertxTracer.receiveResponse(Context context,
R response,
O payload,
Throwable failure,
TagExtractor<R> tagExtractor)
Signal a response has been received.
|
default <R> O |
VertxTracer.sendRequest(Context context,
SpanKind kind,
TracingPolicy policy,
R request,
String operation,
java.util.function.BiConsumer<String,String> headers,
TagExtractor<R> tagExtractor)
Signal a request is sent.
|
default <R> void |
VertxTracer.sendResponse(Context context,
R response,
I payload,
Throwable failure,
TagExtractor<R> tagExtractor)
Signal the response is sent.
|
Modifier and Type | Method and Description |
---|---|
DB2Pool |
DB2Pool.connectionProvider(java.util.function.Function<Context,Future<SqlConnection>> provider) |
Modifier and Type | Method and Description |
---|---|
static VertxContextPRNG |
VertxContextPRNG.current(Context context)
Get or create a secure non blocking random number generator using the provided vert.x context.
|
Modifier and Type | Method and Description |
---|---|
ReadStream<Buffer> |
EncodedPart.bodyStream(Context context) |
ReadStream<Buffer> |
EncodedPart.dkimBodyStream(Context context) |
Modifier and Type | Method and Description |
---|---|
static <K,V> VertxBatchLoader<K,V> |
VertxBatchLoader.create(java.util.function.BiFunction<List<K>,org.dataloader.BatchLoaderEnvironment,Future<List<V>>> batchLoader,
java.util.function.Function<org.dataloader.BatchLoaderEnvironment,Context> contextProvider)
Like
VertxBatchLoader.create(BiFunction) , except the method uses the provided contextProvider instead of capturing the current one. |
static <K,V> VertxMappedBatchLoader<K,V> |
VertxMappedBatchLoader.create(java.util.function.BiFunction<Set<K>,org.dataloader.BatchLoaderEnvironment,Future<Map<K,V>>> batchLoader,
java.util.function.Function<org.dataloader.BatchLoaderEnvironment,Context> contextProvider)
Like
VertxMappedBatchLoader.create(BiFunction) , except the method uses the provided contextProvider instead of capturing the current one. |
static <K,V> VertxBatchLoader<K,V> |
VertxBatchLoader.create(TriConsumer<List<K>,org.dataloader.BatchLoaderEnvironment,Promise<List<V>>> batchLoader,
java.util.function.Function<org.dataloader.BatchLoaderEnvironment,Context> contextProvider)
Like
VertxBatchLoader.create(TriConsumer) , except the method uses the provided contextProvider instead of capturing the current one. |
static <K,V> VertxMappedBatchLoader<K,V> |
VertxMappedBatchLoader.create(TriConsumer<Set<K>,org.dataloader.BatchLoaderEnvironment,Promise<Map<K,V>>> batchLoader,
java.util.function.Function<org.dataloader.BatchLoaderEnvironment,Context> contextProvider)
Like
VertxMappedBatchLoader.create(TriConsumer) , except the method uses the provided contextProvider instead of capturing the current one. |
Modifier and Type | Method and Description |
---|---|
static <T> VertxDataFetcher<T> |
VertxDataFetcher.create(java.util.function.BiConsumer<graphql.schema.DataFetchingEnvironment,Promise<T>> dataFetcher,
java.util.function.Function<graphql.schema.DataFetchingEnvironment,Context> contextProvider)
Like
VertxDataFetcher.create(BiConsumer) , except the method uses the provided contextProvider instead of capturing the current one. |
static <T> VertxDataFetcher<T> |
VertxDataFetcher.create(java.util.function.Function<graphql.schema.DataFetchingEnvironment,Future<T>> dataFetcher,
java.util.function.Function<graphql.schema.DataFetchingEnvironment,Context> contextProvider)
Like
VertxDataFetcher.create(Function) , except the method uses the provided contextProvider instead of capturing the current one. |
Modifier and Type | Method and Description |
---|---|
void |
ConsumerTracer.StartedSpan.fail(Context context,
Throwable failure) |
void |
ProducerTracer.StartedSpan.fail(Context context,
Throwable failure) |
void |
ConsumerTracer.StartedSpan.finish(Context context) |
void |
ProducerTracer.StartedSpan.finish(Context context) |
ConsumerTracer.StartedSpan |
ConsumerTracer.prepareMessageReceived(Context context,
org.apache.kafka.clients.consumer.ConsumerRecord rec) |
ProducerTracer.StartedSpan |
ProducerTracer.prepareSendMessage(Context context,
org.apache.kafka.clients.producer.ProducerRecord record) |
Modifier and Type | Method and Description |
---|---|
MSSQLPool |
MSSQLPool.connectionProvider(java.util.function.Function<Context,Future<SqlConnection>> provider) |
Modifier and Type | Method and Description |
---|---|
MySQLPool |
MySQLPool.connectionProvider(java.util.function.Function<Context,Future<SqlConnection>> provider) |
Modifier and Type | Method and Description |
---|---|
PgPool |
PgPool.connectionProvider(java.util.function.Function<Context,Future<SqlConnection>> provider) |
Modifier and Type | Method and Description |
---|---|
static Scheduler |
RxHelper.scheduler(Context context)
Create a scheduler for a
Context , actions are executed on the event loop of this context. |
Constructor and Description |
---|
ContextScheduler(Context context,
boolean blocking) |
ContextScheduler(Context context,
boolean blocking,
boolean ordered) |
Modifier and Type | Method and Description |
---|---|
Context |
Context.getDelegate() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractVerticle.init(Vertx vertx,
Context context) |
static Context |
Context.newInstance(Context arg) |
Constructor and Description |
---|
Context(Context delegate) |
Modifier and Type | Method and Description |
---|---|
static Scheduler |
RxHelper.scheduler(Context context)
Create a scheduler for a
Context , actions are executed on the event loop of this context. |
static RxJavaSchedulersHook |
RxHelper.schedulerHook(Context context)
Create a scheduler hook for a
Context object, the RxJavaSchedulersHook.getIOScheduler()
uses a blocking scheduler. |
Constructor and Description |
---|
ContextScheduler(Context context,
boolean blocking) |
ContextScheduler(Context context,
boolean blocking,
boolean ordered) |
Modifier and Type | Method and Description |
---|---|
Context |
Context.getDelegate() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractVerticle.init(Vertx vertx,
Context context) |
static Context |
Context.newInstance(Context arg) |
Constructor and Description |
---|
Context(Context delegate) |
Modifier and Type | Method and Description |
---|---|
static Scheduler |
RxHelper.scheduler(Context context)
Create a scheduler for a
Context , actions are executed on the event loop of this context. |
Constructor and Description |
---|
ContextScheduler(Context context,
boolean blocking) |
ContextScheduler(Context context,
boolean blocking,
boolean ordered) |
Modifier and Type | Method and Description |
---|---|
Context |
Context.getDelegate() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractVerticle.init(Vertx vertx,
Context context) |
static Context |
Context.newInstance(Context arg) |
Constructor and Description |
---|
Context(Context delegate) |
Modifier and Type | Method and Description |
---|---|
Pool |
Pool.connectionProvider(java.util.function.Function<Context,Future<SqlConnection>> provider)
Replace the default pool connection provider, the new
provider returns a future connection for a
given Context . |
Modifier and Type | Method and Description |
---|---|
Future<SqlConnection> |
ConnectionFactory.connect(Context context)
Create a connection using the given
context . |
Modifier and Type | Method and Description |
---|---|
<R> io.opentracing.Span |
OpenTracingTracer.receiveRequest(Context context,
SpanKind kind,
TracingPolicy policy,
R request,
String operation,
Iterable<Map.Entry<String,String>> headers,
TagExtractor<R> tagExtractor) |
<R> void |
OpenTracingTracer.receiveResponse(Context context,
R response,
io.opentracing.Span span,
Throwable failure,
TagExtractor<R> tagExtractor) |
<R> io.opentracing.Span |
OpenTracingTracer.sendRequest(Context context,
SpanKind kind,
TracingPolicy policy,
R request,
String operation,
java.util.function.BiConsumer<String,String> headers,
TagExtractor<R> tagExtractor) |
<R> void |
OpenTracingTracer.sendResponse(Context context,
R response,
io.opentracing.Span span,
Throwable failure,
TagExtractor<R> tagExtractor) |
Modifier and Type | Method and Description |
---|---|
<R> brave.Span |
ZipkinTracer.receiveRequest(Context context,
SpanKind kind,
TracingPolicy policy,
R request,
String operation,
Iterable<Map.Entry<String,String>> headers,
TagExtractor<R> tagExtractor) |
<R> void |
ZipkinTracer.receiveResponse(Context context,
R response,
java.util.function.BiConsumer<Object,Throwable> payload,
Throwable failure,
TagExtractor<R> tagExtractor) |
<R> java.util.function.BiConsumer<Object,Throwable> |
ZipkinTracer.sendRequest(Context context,
SpanKind kind,
TracingPolicy policy,
R request,
String operation,
java.util.function.BiConsumer<String,String> headers,
TagExtractor<R> tagExtractor) |
<R> void |
ZipkinTracer.sendResponse(Context context,
R response,
brave.Span span,
Throwable failure,
TagExtractor<R> tagExtractor) |
Copyright © 2022 Eclipse. All rights reserved.