Class EventProcessor

Hierarchy

EventProcessor

Implements

LDEventProcessor

Constructors

constructor

new EventProcessor(config, clientContext, baseHeaders, contextDeduplicator?, diagnosticsManager?, start?): EventProcessor
Parameters
- config: EventProcessorOptions
- clientContext: ClientContext
- baseHeaders: LDHeaders
- Optional contextDeduplicator: LDContextDeduplicator
  Optional
- Optional diagnosticsManager: DiagnosticsManager
  Optional
- Optional start: boolean
  Optional
Returns EventProcessor
- Defined in packages/shared/common/dist/internal/events/EventProcessor.d.ts:33

Properties

`Private` capacity

capacity: any

`Private` `Readonly` config

config: any

`Private` `Optional` `Readonly` contextDeduplicator

contextDeduplicator?: any

`Private` contextFilter

contextFilter: any

`Private` deduplicatedUsers

deduplicatedUsers: any

`Private` `Optional` `Readonly` diagnosticsManager

diagnosticsManager?: any

`Private` diagnosticsTimer

diagnosticsTimer: any

`Private` droppedEvents

droppedEvents: any

`Private` enqueue

enqueue: any

`Private` eventSender

eventSender: any

`Private` eventsInLastBatch

eventsInLastBatch: any

`Private` exceededCapacity

exceededCapacity: any

`Private` flushTimer

flushTimer: any

`Private` flushUsersTimer

flushUsersTimer: any

`Private` lastKnownPastTime

lastKnownPastTime: any

`Private` `Optional` logger

logger?: any

`Private` makeOutputEvent

makeOutputEvent: any

`Private` postDiagnosticEvent

postDiagnosticEvent: any

`Private` queue

queue: any

`Private` shouldDebugEvent

shouldDebugEvent: any

`Private` shutdown

shutdown: any

`Private` summarizer

summarizer: any

`Private` tryPostingEvents

tryPostingEvents: any

Methods

close

close(): void
Returns void
Implementation of LDEventProcessor.close
- Defined in packages/shared/common/dist/internal/events/EventProcessor.d.ts:36

flush

flush(): Promise<void>
Returns Promise<void>
Implementation of LDEventProcessor.flush
- Defined in packages/shared/common/dist/internal/events/EventProcessor.d.ts:37

sendEvent

sendEvent(inputEvent): void
Parameters
- inputEvent: InputEvent
Returns void
Implementation of LDEventProcessor.sendEvent
- Defined in packages/shared/common/dist/internal/events/EventProcessor.d.ts:38

start

start(): void
Returns void
- Defined in packages/shared/common/dist/internal/events/EventProcessor.d.ts:34

Class EventProcessor

Hierarchy

Implements

Index

Constructors

Properties

Methods

Constructors

constructor

Parameters

config: EventProcessorOptions

clientContext: ClientContext

baseHeaders: LDHeaders

Optional contextDeduplicator: LDContextDeduplicator

Optional diagnosticsManager: DiagnosticsManager

Optional start: boolean

Returns EventProcessor

Properties

Private capacity

Private Readonly config

Private Optional Readonly contextDeduplicator

Private contextFilter

Private deduplicatedUsers

Private Optional Readonly diagnosticsManager

Private diagnosticsTimer

Private droppedEvents

Private enqueue

Private eventSender

Private eventsInLastBatch

Private exceededCapacity

Private flushTimer

Private flushUsersTimer

Private lastKnownPastTime

Private Optional logger

Private makeOutputEvent

Private postDiagnosticEvent

Private queue

Private shouldDebugEvent

Private shutdown

Private summarizer

Private tryPostingEvents

Methods

close

Returns void

flush

Returns Promise<void>

sendEvent

Parameters

inputEvent: InputEvent

Returns void

start

Returns void

Settings

Member Visibility

Theme

On This Page

`Optional` contextDeduplicator: LDContextDeduplicator

`Optional` diagnosticsManager: DiagnosticsManager

`Optional` start: boolean

`Private` capacity

`Private` `Readonly` config

`Private` `Optional` `Readonly` contextDeduplicator

`Private` contextFilter

`Private` deduplicatedUsers

`Private` `Optional` `Readonly` diagnosticsManager

`Private` diagnosticsTimer

`Private` droppedEvents

`Private` enqueue

`Private` eventSender

`Private` eventsInLastBatch

`Private` exceededCapacity

`Private` flushTimer

`Private` flushUsersTimer

`Private` lastKnownPastTime

`Private` `Optional` logger

`Private` makeOutputEvent

`Private` postDiagnosticEvent

`Private` queue

`Private` shouldDebugEvent

`Private` shutdown

`Private` summarizer

`Private` tryPostingEvents