OpenTelemetry.EventlogStreaming_Internal

Documentation

data WatDoOnEOF

Constructors

StopOnEOF

SleepAndRetryOnEOF

data State

Constructors

S

Fields

• originTimestamp :: !Timestamp
• threadMap :: IntMap ThreadId
• spans :: HashMap SpanId Span
• instrumentMap :: HashMap InstrumentId CaptureInstrument
• traceMap :: HashMap ThreadId TraceId
• serial2sid :: HashMap Word64 SpanId
• thread2sid :: HashMap ThreadId SpanId
• gcStartedAt :: !Timestamp
• gcGeneration :: !Int
• counterEventsProcessed :: !Int
• counterOpenTelemetryEventsProcessed :: !Int
• counterSpansEmitted :: !Int
• randomGen :: SMGen

Instances

Show State

Defined in OpenTelemetry.EventlogStreaming_Internal

Methods

showsPrec :: Int -> State -> ShowS

show :: State -> String

showList :: [State] -> ShowS

initialState :: Word64 -> SMGen -> State

data EventSource

Constructors

EventLogHandle Handle WatDoOnEOF

EventLogFilename FilePath

work :: Timestamp -> Exporter Span -> Exporter Metric -> EventSource -> IO ()

parseOpenTelemetry :: EventInfo -> Maybe OpenTelemetryEventlogEvent

processEvent :: Event -> State -> (State, [Span], [Metric])

isTerminalThreadStatus :: ThreadStopStatus -> Bool

data OpenTelemetryEventlogEvent

Constructors

BeginSpanEv SpanInFlight SpanName

EndSpanEv SpanInFlight

TagEv SpanInFlight TagName TagVal

EventEv SpanInFlight EventName EventVal

SetParentEv SpanInFlight SpanContext

SetTraceEv SpanInFlight TraceId

SetSpanEv SpanInFlight SpanId

DeclareInstrumentEv InstrumentType InstrumentId InstrumentName

MetricCaptureEv InstrumentId Int

Instances

Eq OpenTelemetryEventlogEvent

Defined in OpenTelemetry.EventlogStreaming_Internal

Methods

(==) :: OpenTelemetryEventlogEvent -> OpenTelemetryEventlogEvent -> Bool

(/=) :: OpenTelemetryEventlogEvent -> OpenTelemetryEventlogEvent -> Bool

Show OpenTelemetryEventlogEvent

Defined in OpenTelemetry.EventlogStreaming_Internal

Methods

showsPrec :: Int -> OpenTelemetryEventlogEvent -> ShowS

show :: OpenTelemetryEventlogEvent -> String

showList :: [OpenTelemetryEventlogEvent] -> ShowS

Generic OpenTelemetryEventlogEvent

Defined in OpenTelemetry.EventlogStreaming_Internal

Associated Types

type Rep OpenTelemetryEventlogEvent :: Type -> Type

Methods

from :: OpenTelemetryEventlogEvent -> Rep OpenTelemetryEventlogEvent x

to :: Rep OpenTelemetryEventlogEvent x -> OpenTelemetryEventlogEvent

type Rep OpenTelemetryEventlogEvent

Defined in OpenTelemetry.EventlogStreaming_Internal

type Rep OpenTelemetryEventlogEvent = D1 (MetaData "OpenTelemetryEventlogEvent" "OpenTelemetry.EventlogStreaming_Internal" "opentelemetry-extra-0.6.1-FScfpIqnq1Q3XlqEbIlE01" False) (((C1 (MetaCons "BeginSpanEv" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 SpanInFlight) :*: S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 SpanName)) :+: C1 (MetaCons "EndSpanEv" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 SpanInFlight))) :+: (C1 (MetaCons "TagEv" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 SpanInFlight) :*: (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 TagName) :*: S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 TagVal))) :+: C1 (MetaCons "EventEv" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 SpanInFlight) :*: (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 EventName) :*: S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 EventVal))))) :+: ((C1 (MetaCons "SetParentEv" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 SpanInFlight) :*: S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 SpanContext)) :+: C1 (MetaCons "SetTraceEv" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 SpanInFlight) :*: S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 TraceId))) :+: (C1 (MetaCons "SetSpanEv" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 SpanInFlight) :*: S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 SpanId)) :+: (C1 (MetaCons "DeclareInstrumentEv" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 InstrumentType) :*: (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 InstrumentId) :*: S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 InstrumentName))) :+: C1 (MetaCons "MetricCaptureEv" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 InstrumentId) :*: S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int))))))

handleOpenTelemetryEventlogEvent :: OpenTelemetryEventlogEvent -> State -> (Word32, Timestamp, Maybe TraceId) -> (State, [Span], [Metric])

createSpan :: SpanId -> Span -> State -> State

emitSpan :: Word64 -> SpanId -> State -> (State, Span)

modifySpan :: HasCallStack => SpanId -> (Span -> Span) -> State -> State

setParent :: TraceId -> SpanId -> Span -> Span

addEvent :: Timestamp -> EventName -> EventVal -> Span -> Span

setTraceId :: TraceId -> Span -> Span

setTag :: ToTagValue v => TagName -> v -> Span -> Span

setSpanId :: SpanId -> Span -> Span

inventSpanId :: Word64 -> State -> (State, SpanId)

parseText :: [Text] -> Maybe OpenTelemetryEventlogEvent

instrumentStringTagP :: Text -> Maybe InstrumentType

headerP :: Get (Maybe MsgType)

lastStringP :: Get Text

stringP :: Word32 -> Get Text

logEventBodyP :: MsgType -> Get OpenTelemetryEventlogEvent

logEventP :: Get (Maybe OpenTelemetryEventlogEvent)

instrumentTagP :: Int8 -> Get InstrumentType

parseByteString :: ByteString -> Maybe OpenTelemetryEventlogEvent

exportEventlog :: Exporter Span -> Exporter Metric -> FilePath -> IO ()