Skip to content

Data Services Events

DAPs and SM provide event callbacks that can be customized with user code. To use the callbacks, the custom code must be installed via a package.

Packaging and Installation

Refer to the User Defined Analytics (UDAs) documentation.

Process and lifecycle events

Syntax:

.ev.add[eventName;fnName]

The given function is called whenever the event is triggered. The parameters to the function are the event name and payload.

Example:

Code that could be added to sm.q to use the initialization hooks in the SM.

.custom.sm.processInitPreCalled:0b;
.custom.sm.processInitPostCalled:0b;

.custom.sm.processInitPre:{[event;data]
    .custom.sm.processInitPreCalled:1b;
    }

.custom.sm.processInitPost:{[event;data]
    .custom.sm.processInitPostCalled:1b;
    }

.ev.add[`process.init.pre ;`.custom.sm.processInitPre];
.ev.add[`process.init.post;`.custom.sm.processInitPost];

Initialization

Event Component Description Payload
process.init.pre SM,AGG,RC,DAP Before process initialization N/A
process.init.post SM,AGG,RC,DAP After process initialization N/A
process.init.registerAPI DAP Before SG registration so that API's are available via getMeta N/A

Data persistence

Event Component Description Payload
lifecycle.partition.end DAP End of partition (EOI/EOD) received from bus
Deprecates .da.prtnEndCB
(dict) End of partition message details
signal (symbol): either eoi or eod
lifecycle.reload.pre DAP Before reloading the DB (dict) Reload message details
lifecycle.reload.post DAP After reloading the DB
Deprecates .da.reloadCB
(dict) Reload message details
lifecycle.eoi.pre SM (EOI) Before EOI processing (dict) Contains date, isEOD and seqid
lifecycle.eoi.post SM (EOI) After EOI processing (dict) Contains date, isEOD and seqid
lifecycle.eod.pre SM (EOD) Before EOD processing (dict) Contains date, nextDate and seq
lifecycle.eod.post SM (EOD) After EOD processing (dict) Contains date, nextDate and seq
lifecycle.batch.pre SM Before batch processing (dict) Contains batchUpdType and request parameters
lifecycle.batch.post SM After batch processing (dict) Contains batchUpdType, request parameters and result