agent-plugin-event-emitter / Exports / EventEmitterPlugin
Class: EventEmitterPlugin
Provides pub/sub event coordination during the agent execution lifecycle.
See
- IEventEmitterPluginOptions
- EVENT_EMITTER_EVENTS
Hierarchy
AbstractPlugin<IEventEmitterPluginOptions,IEventEmitterPluginStats>↳
EventEmitterPlugin
Table of contents
Constructors
Properties
Methods
- initialize
- subscribeToModuleEvents
- unsubscribeFromModuleEvents
- dispose
- enable
- disable
- isEnabled
- getConfig
- updateConfig
- getData
- clearData
- getStatus
- beforeRun
- afterRun
- beforeToolCall
- afterToolCall
- beforeProviderCall
- afterProviderCall
- onStreamingChunk
- onMessageAdded
- onModuleEvent
- beforeExecution
- afterExecution
- beforeConversation
- afterConversation
- beforeToolExecution
- afterToolExecution
- onError
- on
- once
- off
- emit
- flushBuffer
- getStats
- clearAllListeners
- destroy
Constructors
constructor
• new EventEmitterPlugin(options?): EventEmitterPlugin
Parameters
| Name | Type |
|---|---|
options | IEventEmitterPluginOptions |
Returns
Overrides
AbstractPlugin< IEventEmitterPluginOptions, IEventEmitterPluginStats >.constructor
Defined in
agent-plugin-event-emitter/src/event-emitter-plugin.ts:64
Properties
enabled
• enabled: boolean
Inherited from
AbstractPlugin.enabled
Defined in
agent-core/dist/node/index.d.ts:1049
category
• category: PluginCategory
Inherited from
AbstractPlugin.category
Defined in
agent-core/dist/node/index.d.ts:1050
priority
• priority: number
Inherited from
AbstractPlugin.priority
Defined in
agent-core/dist/node/index.d.ts:1051
name
• name: string = 'EventEmitterPlugin'
Overrides
AbstractPlugin.name
Defined in
agent-plugin-event-emitter/src/event-emitter-plugin.ts:53
version
• version: string = '1.0.0'
Overrides
AbstractPlugin.version
Defined in
agent-plugin-event-emitter/src/event-emitter-plugin.ts:54
Methods
initialize
▸ initialize(options?): Promise<void>
Parameters
| Name | Type |
|---|---|
options? | IEventEmitterPluginOptions |
Returns
Promise<void>
Inherited from
AbstractPlugin.initialize
Defined in
agent-core/dist/node/index.d.ts:1063
subscribeToModuleEvents
▸ subscribeToModuleEvents(eventEmitter): Promise<void>
Parameters
| Name | Type |
|---|---|
eventEmitter | IEventEmitterPlugin |
Returns
Promise<void>
Inherited from
AbstractPlugin.subscribeToModuleEvents
Defined in
agent-core/dist/node/index.d.ts:1064
unsubscribeFromModuleEvents
▸ unsubscribeFromModuleEvents(eventEmitter): Promise<void>
Parameters
| Name | Type |
|---|---|
eventEmitter | IEventEmitterPlugin |
Returns
Promise<void>
Inherited from
AbstractPlugin.unsubscribeFromModuleEvents
Defined in
agent-core/dist/node/index.d.ts:1065
dispose
▸ dispose(): Promise<void>
Returns
Promise<void>
Inherited from
AbstractPlugin.dispose
Defined in
agent-core/dist/node/index.d.ts:1066
enable
▸ enable(): void
Returns
void
Inherited from
AbstractPlugin.enable
Defined in
agent-core/dist/node/index.d.ts:1067
disable
▸ disable(): void
Returns
void
Inherited from
AbstractPlugin.disable
Defined in
agent-core/dist/node/index.d.ts:1068
isEnabled
▸ isEnabled(): boolean
Returns
boolean
Inherited from
AbstractPlugin.isEnabled
Defined in
agent-core/dist/node/index.d.ts:1069
getConfig
▸ getConfig(): IPluginConfig
Returns
IPluginConfig
Inherited from
AbstractPlugin.getConfig
Defined in
agent-core/dist/node/index.d.ts:1070
updateConfig
▸ updateConfig(_config): void
Parameters
| Name | Type |
|---|---|
_config | IPluginConfig |
Returns
void
Inherited from
AbstractPlugin.updateConfig
Defined in
agent-core/dist/node/index.d.ts:1071
getData
▸ getData(): IPluginData
Returns
IPluginData
Inherited from
AbstractPlugin.getData
Defined in
agent-core/dist/node/index.d.ts:1072
clearData
▸ clearData(): void
Returns
void
Inherited from
AbstractPlugin.clearData
Defined in
agent-core/dist/node/index.d.ts:1073
getStatus
▸ getStatus(): Object
Returns
Object
| Name | Type |
|---|---|
name | string |
version | string |
enabled | boolean |
initialized | boolean |
category | PluginCategory |
priority | number |
subscribedEventsCount | number |
hasEventEmitter | boolean |
Inherited from
AbstractPlugin.getStatus
Defined in
agent-core/dist/node/index.d.ts:1074
beforeRun
▸ beforeRun(input, options?): Promise<void>
Parameters
| Name | Type |
|---|---|
input | string |
options? | IRunOptions |
Returns
Promise<void>
Inherited from
AbstractPlugin.beforeRun
Defined in
agent-core/dist/node/index.d.ts:1087
afterRun
▸ afterRun(input, response, options?): Promise<void>
Parameters
| Name | Type |
|---|---|
input | string |
response | string |
options? | IRunOptions |
Returns
Promise<void>
Inherited from
AbstractPlugin.afterRun
Defined in
agent-core/dist/node/index.d.ts:1088
beforeToolCall
▸ beforeToolCall(toolName, parameters): Promise<void>
Parameters
| Name | Type |
|---|---|
toolName | string |
parameters | TToolParameters |
Returns
Promise<void>
Inherited from
AbstractPlugin.beforeToolCall
Defined in
agent-core/dist/node/index.d.ts:1093
afterToolCall
▸ afterToolCall(toolName, parameters, result): Promise<void>
Parameters
| Name | Type |
|---|---|
toolName | string |
parameters | TToolParameters |
result | IToolExecutionResult |
Returns
Promise<void>
Inherited from
AbstractPlugin.afterToolCall
Defined in
agent-core/dist/node/index.d.ts:1095
beforeProviderCall
▸ beforeProviderCall(messages): Promise<void>
Parameters
| Name | Type |
|---|---|
messages | TUniversalMessage[] |
Returns
Promise<void>
Inherited from
AbstractPlugin.beforeProviderCall
Defined in
agent-core/dist/node/index.d.ts:1097
afterProviderCall
▸ afterProviderCall(messages, response): Promise<void>
Parameters
| Name | Type |
|---|---|
messages | TUniversalMessage[] |
response | TUniversalMessage |
Returns
Promise<void>
Inherited from
AbstractPlugin.afterProviderCall
Defined in
agent-core/dist/node/index.d.ts:1098
onStreamingChunk
▸ onStreamingChunk(chunk): Promise<void>
Parameters
| Name | Type |
|---|---|
chunk | TUniversalMessage |
Returns
Promise<void>
Inherited from
AbstractPlugin.onStreamingChunk
Defined in
agent-core/dist/node/index.d.ts:1099
onMessageAdded
▸ onMessageAdded(message): Promise<void>
Parameters
| Name | Type |
|---|---|
message | TUniversalMessage |
Returns
Promise<void>
Inherited from
AbstractPlugin.onMessageAdded
Defined in
agent-core/dist/node/index.d.ts:1101
onModuleEvent
▸ onModuleEvent(eventName, eventData): Promise<void>
Parameters
| Name | Type |
|---|---|
eventName | TEventName |
eventData | IEventEmitterEventData |
Returns
Promise<void>
Inherited from
AbstractPlugin.onModuleEvent
Defined in
agent-core/dist/node/index.d.ts:1102
beforeExecution
▸ beforeExecution(context): Promise<void>
Parameters
| Name | Type |
|---|---|
context | IPluginExecutionContext |
Returns
Promise<void>
Overrides
AbstractPlugin.beforeExecution
Defined in
agent-plugin-event-emitter/src/event-emitter-plugin.ts:100
afterExecution
▸ afterExecution(context, result): Promise<void>
Parameters
| Name | Type |
|---|---|
context | IPluginExecutionContext |
result | IPluginExecutionResult |
Returns
Promise<void>
Overrides
AbstractPlugin.afterExecution
Defined in
agent-plugin-event-emitter/src/event-emitter-plugin.ts:112
beforeConversation
▸ beforeConversation(context): Promise<void>
Parameters
| Name | Type |
|---|---|
context | IPluginExecutionContext |
Returns
Promise<void>
Overrides
AbstractPlugin.beforeConversation
Defined in
agent-plugin-event-emitter/src/event-emitter-plugin.ts:128
afterConversation
▸ afterConversation(context, result): Promise<void>
Parameters
| Name | Type |
|---|---|
context | IPluginExecutionContext |
result | IPluginExecutionResult |
Returns
Promise<void>
Overrides
AbstractPlugin.afterConversation
Defined in
agent-plugin-event-emitter/src/event-emitter-plugin.ts:156
beforeToolExecution
▸ beforeToolExecution(context, toolData): Promise<void>
Parameters
| Name | Type |
|---|---|
context | IPluginExecutionContext |
toolData | IToolExecutionContext |
Returns
Promise<void>
Overrides
AbstractPlugin.beforeToolExecution
Defined in
agent-plugin-event-emitter/src/event-emitter-plugin.ts:177
afterToolExecution
▸ afterToolExecution(context, toolResults): Promise<void>
Parameters
| Name | Type |
|---|---|
context | IPluginExecutionContext |
toolResults | IPluginExecutionResult |
Returns
Promise<void>
Overrides
AbstractPlugin.afterToolExecution
Defined in
agent-plugin-event-emitter/src/event-emitter-plugin.ts:194
onError
▸ onError(error, context?): Promise<void>
Parameters
| Name | Type |
|---|---|
error | Error |
context? | IPluginErrorContext |
Returns
Promise<void>
Overrides
AbstractPlugin.onError
Defined in
agent-plugin-event-emitter/src/event-emitter-plugin.ts:224
on
▸ on(eventType, listener, options?): string
Parameters
| Name | Type |
|---|---|
eventType | TEventName |
listener | TEventEmitterListener |
options? | Object |
options.once? | boolean |
options.filter? | (event: IEventEmitterEventData) => boolean |
Returns
string
Defined in
agent-plugin-event-emitter/src/event-emitter-plugin.ts:234
once
▸ once(eventType, listener, filter?): string
Parameters
| Name | Type |
|---|---|
eventType | TEventName |
listener | TEventEmitterListener |
filter? | (event: IEventEmitterEventData) => boolean |
Returns
string
Defined in
agent-plugin-event-emitter/src/event-emitter-plugin.ts:261
off
▸ off(eventType, handlerIdOrListener): boolean
Parameters
| Name | Type |
|---|---|
eventType | TEventName |
handlerIdOrListener | string | TEventEmitterListener |
Returns
boolean
Defined in
agent-plugin-event-emitter/src/event-emitter-plugin.ts:269
emit
▸ emit(eventType, eventData?): Promise<void>
Parameters
| Name | Type |
|---|---|
eventType | TEventName |
eventData | Partial<IEventEmitterEventData> |
Returns
Promise<void>
Defined in
agent-plugin-event-emitter/src/event-emitter-plugin.ts:283
flushBuffer
▸ flushBuffer(): Promise<void>
Returns
Promise<void>
Defined in
agent-plugin-event-emitter/src/event-emitter-plugin.ts:332
getStats
▸ getStats(): IEventEmitterPluginStats
Returns
Overrides
AbstractPlugin.getStats
Defined in
agent-plugin-event-emitter/src/event-emitter-plugin.ts:339
clearAllListeners
▸ clearAllListeners(): void
Returns
void
Defined in
agent-plugin-event-emitter/src/event-emitter-plugin.ts:359
destroy
▸ destroy(): Promise<void>
Returns
Promise<void>