Class SpanStore
- java.lang.Object
-
- org.apache.synapse.aspects.flow.statistics.tracing.opentelemetry.stores.SpanStore
-
public class SpanStore extends Object
Stores information about the Spans.
-
-
Constructor Summary
Constructors Constructor Description SpanStore()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addContinuationStateSequenceInfo(ContinuationStateSequenceInfo continuationStateSequenceInfo)
SpanWrapper
addSpanWrapper(String spanId, io.opentelemetry.api.trace.Span activeSpan, StatisticDataUnit statisticDataUnit, SpanWrapper parentSpanWrapper, MessageContext synCtx)
Denotes the beginning of a span.void
assignOuterLevelSpan(SpanWrapper spanWrapper)
void
finishSpan(SpanWrapper spanWrapper)
Denotes the end of a span.List<SpanWrapper>
getActiveSpanWrappers()
List<ContinuationStateSequenceInfo>
getContinuationStateSequenceInfos()
SpanWrapper
getOuterLevelSpanWrapper()
SpanWrapper
getSpanWrapper(String spanWrapperId)
SpanWrapper
getSpanWrapperByComponentUniqueId(String componentUniqueId)
Map<String,SpanWrapper>
getSpanWrappers()
boolean
hasContinuationStateSequenceInfoWithId(String id)
-
-
-
Method Detail
-
addSpanWrapper
public SpanWrapper addSpanWrapper(String spanId, io.opentelemetry.api.trace.Span activeSpan, StatisticDataUnit statisticDataUnit, SpanWrapper parentSpanWrapper, MessageContext synCtx)
Denotes the beginning of a span. Adds appropriate elements to necessary data structures.- Parameters:
spanId
- Index of the span wrapperactiveSpan
- Reference to the span object, that have been startedstatisticDataUnit
- The statistic data unit objectparentSpanWrapper
- Parent span wrapper of the created span wrappersynCtx
- Message Context that is reported during the open event- Returns:
- Created span wrapper object
-
finishSpan
public void finishSpan(SpanWrapper spanWrapper)
Denotes the end of a span. Adds tags to the span and removes reference to the appropriate span wrapper in activeSpanWrappers.- Parameters:
spanWrapper
- Span wrapper object, which has been already created
-
assignOuterLevelSpan
public void assignOuterLevelSpan(SpanWrapper spanWrapper)
-
getOuterLevelSpanWrapper
public SpanWrapper getOuterLevelSpanWrapper()
-
getSpanWrappers
public Map<String,SpanWrapper> getSpanWrappers()
-
getSpanWrapper
public SpanWrapper getSpanWrapper(String spanWrapperId)
-
getActiveSpanWrappers
public List<SpanWrapper> getActiveSpanWrappers()
-
getSpanWrapperByComponentUniqueId
public SpanWrapper getSpanWrapperByComponentUniqueId(String componentUniqueId)
-
addContinuationStateSequenceInfo
public void addContinuationStateSequenceInfo(ContinuationStateSequenceInfo continuationStateSequenceInfo)
-
getContinuationStateSequenceInfos
public List<ContinuationStateSequenceInfo> getContinuationStateSequenceInfos()
-
hasContinuationStateSequenceInfoWithId
public boolean hasContinuationStateSequenceInfoWithId(String id)
-
-