Qorus Integration Engine®  4.0.3.p2_git
QorusSystemArchService Class Reference

the main arch service class More...

Inheritance diagram for QorusSystemArchService:
QorusSystemService

Static Private:Internal Member Methods

static hash< auto > estimated_counts (*hash filter)
 returns the approximate number of workflow order data instances and job result instances that would be purged (optional param: boolean More...
 
static hash< auto > info ()
 show service parameters More...
 
static *hash< auto > archive (*int loops, *hash filter)
 Run the archive/purge/space management. More...
 
static *hash< auto > purge (*int loops, *hash filter)
 Run purge/space management only. More...
 
static space_management ()
 Run the space management in standalone process. More...
 
static statistics (*hash customOptions)
 Run the statistics computing in standalone process. More...
 
static interrupt ()
 Interrupt currently running processes in the first possible moment.
 
static *hash< auto > filter ()
 Return current archiving filter if there is any.
 
static auto set_filter (*hash< auto > filter)
 Set new archiving filter. Hash or NOTHING. More...
 

Additional Inherited Members

- Public Member Methods inherited from QorusSystemService
 constructor ()
 initializes the info service
 
softlist getOrderInfoFromKey (string name, string version, softstring key, softstring value)
 returns order instance info from user order key (params: workflowname, workflowversion, keyname, value)
 
*list getWorkflowListFromWorkflowKey (string workflow, softstring key, softstring value)
 returns order instance info from the workflow name, key, and value More...
 
hash getAllInfoFromOrderKey (string name, string version, softstring key, softstring value)
 returns all information about a workflow from a user order key (params: workflowname, workflowversion, keyname, value)
 
deprecated *hash getWorkflowMetadata ()
 gets workflow metadata (optional params: list of IDs), returns: hash of workflow metadata keyed by name and then version: COMPAT VERSION with fake flow information (removed in Qorus v2); use getWorkflowMetadata2() instead More...
 
*hash getWorkflowMetadata2 ()
 gets workflow metadata (optional params: list of IDs), returns: hash of workflow metadata keyed by name and then version More...
 
*hash getWorkflowMetadataFromName (string name, *string ver)
 gets workflow metadata from name and version (params: name, optional: version), returns: hash of workflow metadata keyed by name and then version: COMPAT VERSION with fake flow information; use getWorkflowMetadataFromName2() instead More...
 
*hash getWorkflowMetadataFromName2 (string name, *string ver)
 gets workflow metadata from name and version (params: name, optional: version), returns: hash of workflow metadata keyed by name and then version, new version without flows (removed in Qorus v2) More...
 
*hash getFunctionInstance (softint fiid, *softdate date)
 retrieves function data from the function_instanceid (params: function_instanceid), returns: hash of function data keyed by name and then version
 
*hash getFunctionInstanceFromName (string name, *string ver)
 retrieves function data from the name and optionally the version (params: name, [version]), returns: hash of function data keyed by name and then version
 
*hash getServiceMethod2 (softint mid, *softdate date)
 retrieves method data from the service_methodid (params: service_methodid), returns: hash of method data More...
 
*hash getServiceMethod (softint mid, *softdate date)
 retrieves method data from the service_methodid (params: service_methodid), returns: hash of method data More...
 
*list getWorkflowInstanceList (*softlist workflowid, *softdate date=now() - 1D, any stati, softint rownum=OptionHelper::getOption("row-limit"))
 gets a list of workflow instance ids (not more than 100 by default, can be overridden with the 4th argument), params: workflowid (single value, list, or NOTHING), date, [statuses, num rows]
 
list getWorkflowInstances (*softlist wfids, *list statuses, *softdate modified, softint rownum=OptionHelper::getOption("row-limit"), *int offset, *softlist sort, *softlist wfiids, *softbool desc, *date minstarted, *date maxstarted)
 gets a list of workflow instance ids; this is the safe and preferred variant of this method More...
 
deprecated list getWorkflowInstances (softint workflowid, *string condition, int rownum=OptionHelper::getOption("row-limit"))
 gets a list of workflow instance ids, params: workflowid, condition, number of rows (100 default) More...
 
*list getWorkflowInstancesByKeyValue (softlist val, *softstring key, *softlist wfids, *softlist statuses, *date modified, softint rownum=OptionHelper::getOption("row-limit"), *int offset, *softlist sort, *softlist wfiids, *softbool desc, *date minstarted, *date maxstarted)
 retrieves workflow instances from a key value and optional key name
 
*list searchWorkflowInstances (*hash h)
 searches for workflow order instances according to a hash More...
 
list getWorkflowInstanceOverview (list wfilist)
 return the Workflow Instance Overview info, PARAMS: list(hash("ID",[optional: "date"])), RETURN: list(hash(info))
 
list getStepInstanceList (softint wfiId)
 gets a list of step instances, params: workflowinstanceid
 
list getErrorInstanceList (softint workflowInstanceId, *softint stepId, *softint ind)
 gets a list of error instances, params: workflowInstanceId, [stepId, ind]
 
list getErrorInstanceListByWFIID (softint workflowInstanceId, *softint stepId)
 gets a list of error instances, params: workflowInstanceId, [stepId]
 
*hash< auto > getClass (softint classid, *softdate date)
 retrieves class data from a classid; returns: hash of class data keyed by name and then version
 
*hash getStepMetadata ()
 gets step metadata (optional params: list of IDs), returns: hash of step metadata information keyed by name and then version
 
*hash getTreeWithWorkflowInstance (softint workflowinstanceid, softbool full=False, softbool compat=True)
 retrieves tree view like structure that contains specific instanceid (params: workflowinstanceid)
 
*hash getWFIAllInfo (softint workflowInstanceID, *softdate lastModifiedDate, softbool compat=True, softbool with_sensitive_data=False)
 Retrieves all workflow instance info (params: workflowInstanceID, [lastModifiedDate]; output hash keys: InstanceInfo, OrderInfo, StepInstances, ErrorInstances, LastModified. More...
 
*hash getWFIInstanceInfo (softint workflowInstanceID, *softdate lastModifiedDate, softbool compat=True)
 Retrieves only workflow instance info (params: workflowInstanceID, [lastModifiedDate]; output hash keys: InstanceInfo, LastModified. More...
 
*hash getWFIOrderInfo (softint workflowInstanceID, *softdate lastModifiedDate, softbool compat=True, softbool with_sensitive_data=False)
 Retrieves workflow instances order info (params: workflowInstanceID, [lastModifiedDate]; output hash keys: OrderInfo, LastModified. More...
 
*hash getWFIStepInstances (softint workflowInstanceID, *softdate lastModifiedDate, softbool compat=False)
 Retrieves all step info for workflow instance (params: workflowInstanceID, [lastModifiedDate]; output hash keys: StepInstances, LastModified.
 
*hash getWFIErrorInstances (softint workflowInstanceID, *softdate lastModifiedDate, softbool compat=True)
 gets workflow instance error info (params: workflowInstanceID, [lastModifiedDate]; output hash keys: ErrorInstances, LastModified
 
*list getWorkflowInstanceListFromWorkflowNameAndKeyValue (string name, softstring val)
 retrieves workflow instances from a workflow name and a key value, returns a list of workflow instance IDs
 
*list getWorkflowInstanceListFromWorkflowNameVersionAndKeyValue (string name, string version, softstring val)
 retrieves workflow instances from a workflow name, version, and key value, returns a list of workflow instance IDs
 
*list getWorkflowInstanceListFromKeyValue (softstring val)
 retrieves workflow instances from a key value only, returns a list of workflow instance IDs
 
list getOrderInfoList (string name, softstring key, softstring value)
 returns order info from a workflow name and an order key and value (params: workflowname, keyname, value)
 
*list< auto > searchOrderKeys (hash params)
 returns a list of workflow instance info matching the input criteria More...
 
softlist searchWorkflowErrors (hash h)
 returns a list of matching errors for the input criteria More...
 
*list searchReleases (*hash params)
 returns release info More...
 
*list searchSessions (*hash params)
 returns information about application sessions More...
 
*hash getUnpostedEvents (*softlist ids, *softdate lastmod=now() - 6M, softint rownum=OptionHelper::getOption("row-limit"), *int offset)
 returns a hash of event type names with lists of unposted events for each, params: event ID(s), [last modified date] More...
 
*hash getUnpostedEventsFromName (string eventname, *softdate lastmod)
 returns a hash of event type names with lists of unposted events for each, params: event type name, [last modified date] More...
 
list searchEvents (*hash h)
 returns workflow synchronization event information More...
 
*hash getJobMetadata ()
 retrieves job metadata (optional params: list of job ids), returns: job info keyed by name More...
 
*hash getJobMetadataFromName (string name)
 retrieves job metadata from the name, returns: job info keyed by name More...
 
list getJobList ()
 retrieves a list of all jobs without the code field More...
 
*hash getJobStatus (softint jiid)
 returns NOTHING if the job instance ID is not valid or a hash giving job instance status corresponding to the job instance ID passed as an argument More...
 
*list getJobInstanceList (any jobid, *softdate date=now() - 1D, any stati, softint rownum=OptionHelper::getOption("row-limit"))
 gets a list of job instance ids (not more than 100 by default, can be overridden with the 4th argument), params: jobid (single value or list), date, [statuses, num rows] More...
 
*list getJobInstances (*softlist jobids, *softlist statuses, *softdate modified, softint rownum=OptionHelper::getOption("row-limit"), *softint offset, *softlist sort, *softlist jiids, *softbool desc, *softbool full)
 gets a list of job instance ids, params: jobid, condition, number of rows (100 default) More...
 
softlist getOrderInstanceNotes (softint wfiid, *int count)
 gets a list of order instance notes More...
 
list< hash< SlaEventInfo > > searchSlaEvents (*hash h)
 searches for SLA events according to the given criteria and returns a list of results More...
 
softlist< hash< SlaPerformanceInfo > > getSlaPerformance (*hash h)
 searches for SLA events according to the given criteria and returns a list of results More...
 
- Static Public Member Methods inherited from QorusSystemService
static deprecated *hash getWorkflowStatus (softint id)
 returns workflow instance status from workflow_instanceid: COMPAT VERSION with fake flow and flow_instance information (removed in Qorus v2); use getWorkflowStatus2() instead More...
 
static *hash getWorkflowStatus2 (softstring wfiid)
 returns workflow order data instance status from the workflow_instanceid More...
 
static *hash getOrderInfo (softstring wfiid)
 returns order instance info from workflow_instanceid
 
static *list getOrderInfoFromExternalID (softstring id)
 returns order instance info from external_order_instanceid
 
static softlist getOrdersFromKey (softstring key, softstring value)
 returns order instance info from the key and value
 
static *hash< auto > getWorkflowOverview (softdate date=now() - 1D, *softlist wfids, softbool useSqlCache=True, softbool with_deprecated=True)
 gets workflow overview, params: [date, [workflowids]]: If no date is given, default = last 24 hours More...
 
static *hash getWorkflowOverviewFromName (softdate date=now() - 1D, *string name, *string version, softbool useSqlCache=True, softbool with_deprecated=True)
 gets workflow overview, params: [date, [name, [version]]]: If no date is given, default = last 24 hours More...
 
static *list getWorkflowSummaryOverview (softdate date=now() - 1D, softbool useSqlCache=True, softbool with_deprecated=True)
 gets system overview, params: [date]: If no date is given, default = last 24 hours More...
 
static *hash getServiceMetadata ()
 retrieves service metadata (optional params: list of service ids), returns: service info keyed by name. NOTE: if no list is given, only the latest version of each service will be returned
 
static *hash getServiceMetadataFromName (string type, string name, *string ver)
 retrieves service metadata from the type, name and optional version (params: type, name, [version]), returns: service info keyed by name. NOTE: if no version is given, only the latest version will be returned
 
static list getLibraryMetadata ()
 retrieves function library information as a list of hashes with the keys name, function_instanceid
 
static *hash getClassFromName (string name, *string ver)
 retrieves class data from the class name and optional version (params: name, [version]), returns: hash of class data keyed by name and then version
 
static *hash getConstant (softint constantid, *softdate date)
 retrieves constant data from the constantid (params: constantid), returns: hash of constant data keyed by name and then version
 
static *hash getConstantFromName (string name, *string ver)
 retrieves constant data from the constant name and optional version (params: name, [version]), returns: hash of constant data keyed by name and then version
 
static *hash getWFIOrderKeysOnly (softint workflowInstanceID)
 Retrieves only order keys for workflow instance params: workflowInstanceID; output: hash.
 
static *list getWorkflowProcessingSummary (hash h)
 returns a summary of workflow processing for the given time period and optional workflow ID(s) More...
 
static *list getStepProcessingSummary (hash h)
 returns a summary of step processing for the given time period and optional step ID(s) More...
 
static *hash getJobOverview (softdate date=now() - 1D, any jobids, bool useSqlCache=True)
 gets job overview, params: [date, [jobids]]: If no date is given, default = last 24 hours More...
 
static *hash getJobOverviewFromName (softdate date=now() - 1D, *string name, bool useSqlCache=True)
 gets job overview, params: [date, [name]]: If no date is given, default = last 24 hours More...
 

Detailed Description

the main arch service class

Member Function Documentation

◆ archive()

static *hash<auto> QorusSystemArchService::archive ( *int  loops,
*hash  filter 
)
inlinestaticprivate:internal

Run the archive/purge/space management.

Parameters
loopsoptional integer value which will stop puring after loops of batch-size. 0 = do not stop.
filteroptional hash. See Archiving Filters for more info.
Returns
a hash with merged result of all sub-actions. Structure:
  • metadata: Qorus "static" meta-data
    • table name
      • full_insert: count of lines for tables where is required toperform FULL delete/insert
      • insert: count of lines directly inserted to the archive schema
      • update: count of lines updated in the archive schema
      • noop: count of lines where there is no operation required
      • src_deleted: count of lines which are found in the archive schema but not in source (probably deleted from source, but they cannot be delete from archive to keep referential integrity).
  • orders: Qorus live orders/workflow instances etc.
    • table name
      • arch: count of archived lines (archive schema)
      • purge: count of purged lines (source schema)
  • space: Space management result
    • table_name: result for given table
  • indexes: a list with result from space_management.
Note
- lock: OMQ::SLWrite

◆ estimated_counts()

static hash<auto> QorusSystemArchService::estimated_counts ( *hash  filter)
inlinestaticprivate:internal

returns the approximate number of workflow order data instances and job result instances that would be purged (optional param: boolean

Parameters
filteroptional hash. See Archiving Filters for more info.
Returns
the approximate number of workflow order data instances that would be purged. Hash keys are:
  • workflow-live: order count in COMPLETE or CANCELED status older than "day-interval"
  • workflow-prepared: count if rows in the internal helper table ARCH_WF_INSTANCES
  • job-live: order count older than "day-interval"
  • job-prepared: count if rows in the internal helper table ARCH_JOB_INSTANCES

◆ info()

static hash<auto> QorusSystemArchService::info ( )
inlinestaticprivate:internal

show service parameters

Returns
a hash of current service parameters

◆ purge()

static *hash<auto> QorusSystemArchService::purge ( *int  loops,
*hash  filter 
)
inlinestaticprivate:internal

Run purge/space management only.

Parameters
loopsoptional integer value which will stop puring after loops of batch-size. 0 = do not stop.
filteroptional hash. See Archiving Filters for more info.
Note
- lock: OMQ::SLWrite

◆ set_filter()

static auto QorusSystemArchService::set_filter ( *hash< auto >  filter)
inlinestaticprivate:internal

Set new archiving filter. Hash or NOTHING.

Parameters
filteroptional hash. See Archiving Filters for more info.
Note
- lock: OMQ::SLWrite

◆ space_management()

static QorusSystemArchService::space_management ( )
inlinestaticprivate:internal

Run the space management in standalone process.

Returns
a hash with database table names as keys and values with appropriate space management result. Or single key/value result for Postgresql.
Note
- lock: OMQ::SLWrite

◆ statistics()

static QorusSystemArchService::statistics ( *hash  customOptions)
inlinestaticprivate:internal

Run the statistics computing in standalone process.

Parameters
customOptionsa hash or nothing with custom statistics-options. System statistics-options are overriden by custom ones. See Database Statistics
Note
- lock: OMQ::SLWrite

The documentation for this class was generated from the following file: