Search
Preparing search index...
The search index is not available
ddes
Options
All
Public
Public/Protected
All
Inherited
Externals
Only exported
Menu
Packages
@ddes/event-streaming
EventStreamer
Class EventStreamer
Hierarchy
EventStreamer
Index
Constructors
constructor
Properties
chronological
Groups
debug
store
Pollers
wss
Methods
close
on
Client
Connected
on
Client
Disconnected
process
Commit
publish
Event
ToSubscribers
Constructors
constructor
new
Event
Streamer
(
params
:
StorePollerParams
&
object
)
:
EventStreamer
Parameters
params:
StorePollerParams
&
object
Optional
authenticate
Client
?:
undefined
|
function
Optional
chronological
Groups
?:
string
[]
port
:
number
Returns
EventStreamer
Properties
Protected
chronological
Groups
chronological
Groups
:
string
[]
Protected
debug
debug
:
IDebugger
Protected
store
Pollers
store
Pollers
:
StorePoller
[]
= []
wss
wss
:
WebSocketServer
Methods
close
close
(
)
:
void
Returns
void
Protected
on
Client
Connected
on
Client
Connected
(
client
:
any
)
:
void
Parameters
client:
any
Returns
void
Protected
on
Client
Disconnected
on
Client
Disconnected
(
)
:
void
Returns
void
process
Commit
process
Commit
(
commit
:
Commit
)
:
Promise
<
void
>
Parameters
commit:
Commit
Returns
Promise
<
void
>
publish
Event
ToSubscribers
publish
Event
ToSubscribers
(
eventWithMetadata
:
EventWithMetadata
)
:
void
Parameters
eventWithMetadata:
EventWithMetadata
Returns
void
Packages
@ddes/aws-
lambda-
transformer
@ddes/aws-
store
@ddes/cli
@ddes/core
@ddes/event-
streaming
@ddes/store-
transformations
Event
Streamer
constructor
chronological
Groups
debug
store
Pollers
wss
close
on
Client
Connected
on
Client
Disconnected
process
Commit
publish
Event
ToSubscribers
Event
Subscriber
Filter
Set
Generated using
TypeDoc