| 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 | 
|---|---|
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 | 
|---|---|
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 | 
|---|---|
<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 © 2021 Eclipse. All rights reserved.