Package | Description |
---|---|
org.axonframework.axonserver.connector.query.subscription | |
org.axonframework.commandhandling |
Classes that implement the concept of command handling using explicit command objects.
|
org.axonframework.deadline | |
org.axonframework.eventhandling |
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus . |
org.axonframework.eventsourcing |
Classes related to event sourcing.
|
org.axonframework.modelling.command | |
org.axonframework.modelling.saga | |
org.axonframework.queryhandling | |
org.axonframework.tracing | |
org.axonframework.tracing.opentelemetry |
Constructor and Description |
---|
AxonServerSubscriptionQueryResult(SubscriptionQueryMessage<?,?,?> queryMessage,
io.axoniq.axonserver.connector.query.SubscriptionQueryResult result,
SubscriptionMessageSerializer subscriptionSerializer,
QueryBusSpanFactory spanFactory,
Span parentSpan)
Instantiate a
AxonServerSubscriptionQueryResult which will emit its initial response and the updates of
the subscription query. |
Modifier and Type | Method and Description |
---|---|
Span |
DefaultCommandBusSpanFactory.createDispatchCommandSpan(CommandMessage<?> commandMessage,
boolean distributed) |
Span |
CommandBusSpanFactory.createDispatchCommandSpan(CommandMessage<?> commandMessage,
boolean distributed)
Creates a span for the dispatching of a command.
|
Span |
DefaultCommandBusSpanFactory.createHandleCommandSpan(CommandMessage<?> commandMessage,
boolean distributed) |
Span |
CommandBusSpanFactory.createHandleCommandSpan(CommandMessage<?> commandMessage,
boolean distributed)
Creates a span for the handling of a command.
|
Modifier and Type | Method and Description |
---|---|
Span |
DefaultDeadlineManagerSpanFactory.createCancelAllSpan(String deadlineName) |
Span |
DeadlineManagerSpanFactory.createCancelAllSpan(String deadlineName)
Creates a span that represents the cancellation of all deadlines with a certain name.
|
Span |
DefaultDeadlineManagerSpanFactory.createCancelAllWithinScopeSpan(String deadlineName,
ScopeDescriptor scopeDescriptor) |
Span |
DeadlineManagerSpanFactory.createCancelAllWithinScopeSpan(String deadlineName,
ScopeDescriptor scopeDescriptor)
Creates a span that represents the cancellation of all deadlines with a certain name within a certain scope.
|
Span |
DefaultDeadlineManagerSpanFactory.createCancelScheduleSpan(String deadlineName,
String deadlineId) |
Span |
DeadlineManagerSpanFactory.createCancelScheduleSpan(String deadlineName,
String deadlineId)
Creates a span that represents the cancellation of a specific deadline.
|
Span |
DefaultDeadlineManagerSpanFactory.createExecuteSpan(String deadlineName,
String deadlineId,
DeadlineMessage<?> deadlineMessage) |
Span |
DeadlineManagerSpanFactory.createExecuteSpan(String deadlineName,
String deadlineId,
DeadlineMessage<?> deadlineMessage)
Creates a span that represents the execution of a deadline.
|
Span |
DefaultDeadlineManagerSpanFactory.createScheduleSpan(String deadlineName,
String deadlineId,
DeadlineMessage<?> deadlineMessage) |
Span |
DeadlineManagerSpanFactory.createScheduleSpan(String deadlineName,
String deadlineId,
DeadlineMessage<?> deadlineMessage)
Creates a span that represents the scheduling of a deadline.
|
Modifier and Type | Method and Description |
---|---|
Span |
EventProcessorSpanFactory.createBatchSpan(boolean streaming,
List<? extends EventMessage<?>> eventMessages)
Creates a span for the batch of events that are handled by the event processor.
|
Span |
DefaultEventProcessorSpanFactory.createBatchSpan(boolean streaming,
List<? extends EventMessage<?>> eventMessages) |
Span |
EventBusSpanFactory.createCommitEventsSpan()
Creates a span for the committing of events.
|
Span |
DefaultEventBusSpanFactory.createCommitEventsSpan() |
Span |
EventProcessorSpanFactory.createProcessEventSpan(boolean streaming,
EventMessage<?> eventMessage)
Creates a span for the handling of an event.
|
Span |
DefaultEventProcessorSpanFactory.createProcessEventSpan(boolean streaming,
EventMessage<?> eventMessage) |
Span |
EventBusSpanFactory.createPublishEventSpan(EventMessage<?> eventMessage)
Creates a span for the publishing of an event.
|
Span |
DefaultEventBusSpanFactory.createPublishEventSpan(EventMessage<?> eventMessage) |
Modifier and Type | Method and Description |
---|---|
Span |
SnapshotterSpanFactory.createCreateSnapshotSpan(String aggregateType,
String aggregateIdentifier)
Creates a new
Span that represents the actual creation of a snapshot. |
Span |
DefaultSnapshotterSpanFactory.createCreateSnapshotSpan(String aggregateType,
String aggregateIdentifier) |
Span |
SnapshotterSpanFactory.createScheduleSnapshotSpan(String aggregateType,
String aggregateIdentifier)
Creates a new
Span that represents the scheduling of snapshot creation to the snapshotter's executor. |
Span |
DefaultSnapshotterSpanFactory.createScheduleSnapshotSpan(String aggregateType,
String aggregateIdentifier) |
Modifier and Type | Method and Description |
---|---|
Span |
RepositorySpanFactory.createInitializeStateSpan(String aggregateType,
String aggregateId)
Creates a span that represents the time it took to hydrate the aggregate with data from, for example, the event
store.
|
Span |
DefaultRepositorySpanFactory.createInitializeStateSpan(String aggregateType,
String aggregateId) |
Span |
RepositorySpanFactory.createLoadSpan(String aggregateId)
Creates a span that represents the loading of an aggregate with the provided identifier.
|
Span |
DefaultRepositorySpanFactory.createLoadSpan(String aggregateId) |
Span |
RepositorySpanFactory.createObtainLockSpan(String aggregateId)
Creates a span that represents the time waiting to acquire a lock on an aggregate with the provided identifier.
|
Span |
DefaultRepositorySpanFactory.createObtainLockSpan(String aggregateId) |
Modifier and Type | Method and Description |
---|---|
Span |
SagaManagerSpanFactory.createCreateSagaInstanceSpan(EventMessage<?> event,
Class<?> sagaType,
String sagaIdentifier)
Creates a span that represents the creation of a new saga instance.
|
Span |
DefaultSagaManagerSpanFactory.createCreateSagaInstanceSpan(EventMessage<?> event,
Class<?> sagaType,
String sagaIdentifier) |
Span |
SagaManagerSpanFactory.createInvokeSagaSpan(EventMessage<?> event,
Class<?> sagaType,
Saga<?> saga)
Creates a span that represents the invocation of a saga.
|
Span |
DefaultSagaManagerSpanFactory.createInvokeSagaSpan(EventMessage<?> event,
Class<?> sagaType,
Saga<?> saga) |
Modifier and Type | Method and Description |
---|---|
Span |
QueryBusSpanFactory.createQueryProcessingSpan(QueryMessage<?,?> queryMessage)
Creates a span for processing a query.
|
Span |
DefaultQueryBusSpanFactory.createQueryProcessingSpan(QueryMessage<?,?> queryMessage) |
Span |
QueryBusSpanFactory.createQuerySpan(QueryMessage<?,?> queryMessage,
boolean distributed)
Creates a span for a query.
|
Span |
DefaultQueryBusSpanFactory.createQuerySpan(QueryMessage<?,?> queryMessage,
boolean distributed) |
Span |
QueryBusSpanFactory.createResponseProcessingSpan(QueryMessage<?,?> queryMessage)
Creates a span for processing a response.
|
Span |
DefaultQueryBusSpanFactory.createResponseProcessingSpan(QueryMessage<?,?> queryMessage) |
Span |
QueryBusSpanFactory.createScatterGatherHandlerSpan(QueryMessage<?,?> queryMessage,
int handlerIndex)
Creates a span for one of the handlers of a scatter-gather query.
|
Span |
DefaultQueryBusSpanFactory.createScatterGatherHandlerSpan(QueryMessage<?,?> queryMessage,
int handlerIndex) |
Span |
QueryBusSpanFactory.createScatterGatherSpan(QueryMessage<?,?> queryMessage,
boolean distributed)
Creates a span for a scatter-gather query.
|
Span |
DefaultQueryBusSpanFactory.createScatterGatherSpan(QueryMessage<?,?> queryMessage,
boolean distributed) |
Span |
QueryBusSpanFactory.createStreamingQuerySpan(QueryMessage<?,?> queryMessage,
boolean distributed)
Creates a span for a streaming query.
|
Span |
DefaultQueryBusSpanFactory.createStreamingQuerySpan(QueryMessage<?,?> queryMessage,
boolean distributed) |
Span |
QueryBusSpanFactory.createSubscriptionQueryProcessUpdateSpan(SubscriptionQueryUpdateMessage<?> updateMessage,
SubscriptionQueryMessage<?,?,?> queryMessage)
Creates a span for processing a subscription query update that has been received from the server.
|
Span |
DefaultQueryBusSpanFactory.createSubscriptionQueryProcessUpdateSpan(SubscriptionQueryUpdateMessage<?> updateMessage,
SubscriptionQueryMessage<?,?,?> queryMessage) |
Span |
QueryBusSpanFactory.createSubscriptionQuerySpan(SubscriptionQueryMessage<?,?,?> queryMessage,
boolean distributed)
Creates a span for a subscription query.
|
Span |
DefaultQueryBusSpanFactory.createSubscriptionQuerySpan(SubscriptionQueryMessage<?,?,?> queryMessage,
boolean distributed) |
Span |
QueryUpdateEmitterSpanFactory.createUpdateEmitSpan(SubscriptionQueryUpdateMessage<?> update)
Creates a span for the actual emit of a query update when the UnitOfWork commits (or immediately if no UnitOfWork
is active).
|
Span |
DefaultQueryUpdateEmitterSpanFactory.createUpdateEmitSpan(SubscriptionQueryUpdateMessage<?> update) |
Span |
QueryUpdateEmitterSpanFactory.createUpdateScheduleEmitSpan(SubscriptionQueryUpdateMessage<?> update)
Creates a span for the scheduling of emitting a query update.
|
Span |
DefaultQueryUpdateEmitterSpanFactory.createUpdateScheduleEmitSpan(SubscriptionQueryUpdateMessage<?> update) |
Modifier and Type | Class and Description |
---|---|
static class |
NoOpSpanFactory.NoOpSpan
The
Span implementation that does nothing. |
Modifier and Type | Method and Description |
---|---|
default Span |
Span.addAttribute(String key,
String value)
Adds an attribute to the span.
|
Span |
NoOpSpanFactory.NoOpSpan.addAttribute(String key,
String value) |
default Span |
SpanFactory.createChildHandlerSpan(Supplier<String> operationNameSupplier,
Message<?> parentMessage,
Message<?>... linkedParents)
Creates a new
Span which is part of the current trace. |
Span |
SpanFactory.createDispatchSpan(Supplier<String> operationNameSupplier,
Message<?> parentMessage,
Message<?>... linkedSiblings)
|
Span |
NoOpSpanFactory.createDispatchSpan(Supplier<String> operationNameSupplier,
Message<?> parentMessage,
Message<?>... linkedSiblings) |
Span |
NestingSpanFactory.createDispatchSpan(Supplier<String> operationNameSupplier,
Message<?> parentMessage,
Message<?>... linkedSiblings)
Deprecated.
|
Span |
MultiSpanFactory.createDispatchSpan(Supplier<String> operationNameSupplier,
Message<?> parentMessage,
Message<?>... linkedSiblings) |
Span |
LoggingSpanFactory.createDispatchSpan(Supplier<String> operationNameSupplier,
Message<?> parentMessage,
Message<?>... linkedSiblings) |
Span |
SpanFactory.createHandlerSpan(Supplier<String> operationNameSupplier,
Message<?> parentMessage,
boolean isChildTrace,
Message<?>... linkedParents)
|
Span |
NoOpSpanFactory.createHandlerSpan(Supplier<String> operationNameSupplier,
Message<?> parentMessage,
boolean isChildTrace,
Message<?>... linkedParents) |
Span |
NestingSpanFactory.createHandlerSpan(Supplier<String> operationNameSupplier,
Message<?> parentMessage,
boolean isChildTrace,
Message<?>... linkedParents)
Deprecated.
|
Span |
MultiSpanFactory.createHandlerSpan(Supplier<String> operationNameSupplier,
Message<?> parentMessage,
boolean isChildTrace,
Message<?>... linkedParents) |
Span |
LoggingSpanFactory.createHandlerSpan(Supplier<String> operationNameSupplier,
Message<?> parentMessage,
boolean isChildTrace,
Message<?>... linkedParents) |
Span |
SpanFactory.createInternalSpan(Supplier<String> operationNameSupplier)
Creates a new
Span linked to the currently active span. |
Span |
NoOpSpanFactory.createInternalSpan(Supplier<String> operationNameSupplier) |
Span |
NestingSpanFactory.createInternalSpan(Supplier<String> operationNameSupplier)
Deprecated.
|
Span |
MultiSpanFactory.createInternalSpan(Supplier<String> operationNameSupplier) |
Span |
LoggingSpanFactory.createInternalSpan(Supplier<String> operationNameSupplier) |
Span |
SpanFactory.createInternalSpan(Supplier<String> operationNameSupplier,
Message<?> message)
Creates a new
Span linked to the currently active span. |
Span |
NoOpSpanFactory.createInternalSpan(Supplier<String> operationNameSupplier,
Message<?> message) |
Span |
NestingSpanFactory.createInternalSpan(Supplier<String> operationNameSupplier,
Message<?> message)
Deprecated.
|
Span |
MultiSpanFactory.createInternalSpan(Supplier<String> operationNameSupplier,
Message<?> message) |
Span |
LoggingSpanFactory.createInternalSpan(Supplier<String> operationNameSupplier,
Message<?> message) |
default Span |
SpanFactory.createLinkedHandlerSpan(Supplier<String> operationNameSupplier,
Message<?> parentMessage,
Message<?>... linkedParents)
Creates a new
Span which becomes its own separate trace, linked to the previous span. |
Span |
SpanFactory.createRootTrace(Supplier<String> operationNameSupplier)
Creates a new
Span without any parent trace. |
Span |
NoOpSpanFactory.createRootTrace(Supplier<String> operationNameSupplier) |
Span |
NestingSpanFactory.createRootTrace(Supplier<String> operationNameSupplier)
Deprecated.
|
Span |
MultiSpanFactory.createRootTrace(Supplier<String> operationNameSupplier) |
Span |
LoggingSpanFactory.createRootTrace(Supplier<String> operationNameSupplier) |
Span |
Span.recordException(Throwable t)
Records an exception to the span.
|
Span |
NoOpSpanFactory.NoOpSpan.recordException(Throwable t) |
Span |
Span.start()
Starts the Span.
|
Span |
NoOpSpanFactory.NoOpSpan.start() |
Modifier and Type | Class and Description |
---|---|
class |
OpenTelemetrySpan
Span implementation that uses OpenTelemetry's Span to provide tracing
capabilities to an application. |
Modifier and Type | Method and Description |
---|---|
Span |
OpenTelemetrySpan.addAttribute(String key,
String value) |
Span |
OpenTelemetrySpanFactory.createDispatchSpan(Supplier<String> operationNameSupplier,
Message<?> parentMessage,
Message<?>... linkedSiblings) |
Span |
OpenTelemetrySpanFactory.createHandlerSpan(Supplier<String> operationNameSupplier,
Message<?> parentMessage,
boolean isChildTrace,
Message<?>... linkedParents) |
Span |
OpenTelemetrySpanFactory.createInternalSpan(Supplier<String> operationNameSupplier) |
Span |
OpenTelemetrySpanFactory.createInternalSpan(Supplier<String> operationNameSupplier,
Message<?> message) |
Span |
OpenTelemetrySpanFactory.createRootTrace(Supplier<String> operationNameSupplier) |
Span |
OpenTelemetrySpan.recordException(Throwable t) |
Span |
OpenTelemetrySpan.start() |
Copyright © 2010–2024. All rights reserved.