Welcome to Minerva Schema’s documentation!¶

Contents:

Introduction¶

Minerva

User Guide¶

How To¶

Examples are executed on a psql prompt.

Create Entities¶

Before any data is stored, entities have to be created to which the data belongs. Basic information about entities is stored in the tables entitytype and entity. These tables are automatically populated when the appropriate functions are used to create the entities.

Create an entity using create_entity:

minerva=# select directory.create_entity('Node=root');
                     create_entity
-------------------------------------------------------
 (1,"2015-09-07 12:21:01.594337+00",root,2,Node=root,)

The directory.create_entity function returns a value of type entity and this is exactly the record you will find in the table entity:

minerva=# select * from directory.entity where id = 1;
 id |       first_appearance        | name | entitytype_id |    dn     | parent_id
----+-------------------------------+------+---------------+-----------+-----------
  1 | 2015-09-07 12:21:01.594337+00 | root |             2 | Node=root |

The function create_entity will also define new entitytypes if required. So the previous example will have resulted in a new record in the entitytype table:

minerva=# select * from directory.entitytype where id = 2;
 id |       name       | description
----+------------------+-------------
  2 | Node             |

Any required intermediate entities are also automatically created:

minerva=# select directory.create_entity('Node=root,Slot=c1,Port=12');
                             create_entity
------------------------------------------------------------------------
 (2,"2015-09-07 13:10:11.809796+00",12,3,"Node=root,Slot=c1,Port=12",3)

minerva=# select * from directory.entity;
 id |       first_appearance        | name | entitytype_id |            dn             | parent_id
----+-------------------------------+------+---------------+---------------------------+-----------
  1 | 2015-09-07 12:21:01.594337+00 | root |             2 | Node=root                 |
  3 | 2015-09-07 13:10:11.809796+00 | c1   |             4 | Node=root,Slot=c1         |         1
  2 | 2015-09-07 13:10:11.809796+00 | 12   |             3 | Node=root,Slot=c1,Port=12 |         3

The intermediate ‘Node=root,Slot=c1’ entity and its type are automatically created.

Define Data Sources¶

All data about entities is linked to a data source. Data sources are used to organize different sets of data for potentially overlapping sets of entities. This solves the problem of having conflicting facts about entities when they have the same name, but come from different sources and have different values and meanings.

To create a data source, use the function create_datasource:

minerva=# select directory.create_datasource('network-conf');
      create_datasource
------------------------------
 (2,network-conf,default,UTC)

The function returns a value of type datasource, and is the record inserted into the datasource table:

minerva=# select * from directory.datasource where id = 2;
 id |     name     | description | timezone
----+--------------+-------------+----------
  2 | network-conf | default     | UTC

Store Attributes¶

To store attributes of entities, you have to create one or more attribute stores. One attribute store can hold data for exactly one entity type of one data source. What data an attribute store can hold is reflected in the name: <data source name>_<entity type name>

Create the attribute store¶

Create an attribute store to hold data for the entity type ‘Port’ of data source ‘network-conf’:

minerva=# select attribute_directory.create_attributestore('network-conf', 'Port', ARRAY[('speed','integer', '')]::attribute_directory.attribute_descr[]);
 create_attributestore
-----------------------
 (1,1,1)

Like the functions mentioned in the previous sections, this function also returns a value of its corresponding type attributestore, which is the record inserted into the table attributestore:

minerva=# select * from attribute_directory.attributestore where id = 2;
 id | datasource_id | entitytype_id
----+---------------+---------------
  1 |             1 |             1

Now this record doesn’t read as easily as the records seen in the previous sections about entities and data sources because there is no textual component in the attributestore record. An easy way to make this more readable is by using the to-text-cast to obtain the ‘name’ of the attribute store:

minerva=# select attributestore::text, * from attribute_directory.attributestore where id = 1;
  attributestore   | id | datasource_id | entitytype_id
-------------------+----+---------------+---------------
 network-conf_Port |  1 |             1 |             1

Here you can see the textual representation of the attribute store that is used for naming the corresponding tables, functions and views of the attribute store.

Store attribute data¶

Now the attribute store is ready to hold data, add an initial value. First insert the data into the staging table:

minerva=# insert into attribute_staging."network-conf_Port"(entity_id, timestamp, speed) values (2, now(), 1000);
INSERT 0 1

And then transfer the staged data to the history table:

minerva=# select attribute_directory.transfer_staged(attributestore) from attribute_directory.attributestore where attributestore::text = 'network-conf_Port';
 transfer_staged
-----------------
 (1,1,1)

minerva=# select * from attribute_history."network-conf_Port";
 entity_id |           timestamp           | speed |       first_appearance        |           modified            |               hash
 -----------+-------------------------------+-------+-------------------------------+-------------------------------+----------------------------------
          2 | 2015-09-07 14:11:47.768745+00 |  1000 | 2015-09-07 14:14:51.160655+00 | 2015-09-07 14:14:51.160655+00 | a9b7ba70783b617e9998dc4dd82eb3c5

It can be difficult to script the insertion of attribute data when the entity Id is not yet known. For this reason, there is a convenience function to lookup the entity by its Distinguished Name, named dn_to_entity(character varying) -> directory.entity. This function returns an existing entity or creates a new one and returns that. Now to combine that with adding a new attribute record that updates the ‘current’ state:

minerva=# insert into attribute_staging."network-conf_Port"(entity_id, timestamp, speed) values ((directory.dn_to_entity('Node=root,Slot=c1,Port=12')).id, now(), 5000);
INSERT 0 1

minerva=# select attribute_directory.transfer_staged(attributestore) from attribute_directory.attributestore where attributestore::text = 'network-conf_Port';
 transfer_staged
-----------------
 (2,2,3)

minerva=# select * from attribute_history."network-conf_Port";
 entity_id |           timestamp           | speed |       first_appearance        |           modified            |               hash
-----------+-------------------------------+-------+-------------------------------+-------------------------------+----------------------------------
         2 | 2015-09-07 14:11:47.768745+00 |  1000 | 2015-09-07 14:14:51.160655+00 | 2015-09-07 14:14:51.160655+00 | a9b7ba70783b617e9998dc4dd82eb3c5
         2 | 2015-09-07 14:27:13.738692+00 |  5000 | 2015-09-07 14:27:18.066607+00 | 2015-09-07 14:27:18.066607+00 | a35fe7f7fe8217b4369a0af4244d1fca

Store Trends¶

Create the trend store¶

Create a trend store to hold data for the entity type ‘Port’ of data source ‘network-measurements’ with a granularity of 15 minutes:

minerva=# select trend.create_trendstore('network-measurements', 'Port', '900', ARRAY[('bytes_transferred', 'bigint', '')]::trend.trend_descr[]);
         create_trendstore
-----------------------------------
 (1,3,3,900,21600,table,4,"1 mon")

The return value is of type trend.trendstore and holds the record inserted into the trend.trendstore table:

minerva=# select * from trend.trendstore where id = 1;
 id | entitytype_id | datasource_id | granularity | partition_size | type  | version | retention_period
----+---------------+---------------+-------------+----------------+-------+---------+------------------
  1 |             3 |             3 | 900         |          21600 | table |       4 | 1 mon

By default, a trend store with a granularity of 900 seconds is partitioned into tables with a partition size of 6 hours (21600 seconds) and has a data retention period of 1 month.

Materialize Trend Data¶

To be documented

Define Triggers¶

Triggers are defined in a number of steps:

Create a function that returns records with all KPI’s, measurement values, etc that are needed to calculate the notifications for a specific timestamp.
Create the new rule with it’s name and thresholds.
Define the actual rule in the form of a where-clause.
Set the threshold values for the defined thresholds in step 1.
Define the weighing function.
Define the notification details text.

Here, we will work out an example trigger named ‘high_traffic’.

Create KPI function¶

This function should return all data that is required for the actual rule and weight calculation. Before we can create this function, we need to define a return record type:

CREATE TYPE trigger_rule.high_traffic_kpi (
    entity_id integer,
    timestamp timestamp with time zone,
    traffic bigint
);

Now we can create the actual function:

CREATE FUNCTION trigger_rule.high_traffic_kpi(timestamp with time zone)
    RETURNS SETOF trigger_rule.high_traffic_kpi
AS $$
BEGIN
    RETURNS QUERY EXECUTE $query$
    SELECT entity_id, timestamp, traffic
    FROM trend."network-measurements_Port_qtr"
    WHERE timestamp = $1
    $query$ USING $1;
END;
$$ LANGUAGE plpgsql STABLE;

Create New Rule¶

The following statement defines the rule in the system.

SELECT trigger.create_rule(
    'high_traffic',
    ARRAY[
        ('max_traffic', 'bigint')
    ]::trigger.threshold_def[]
);

Define Rule Condition¶

Now set the actual condition of the rule that defines when a record results in a notification:

SELECT trigger.set_condition(
    'high_traffic',
    $predicate$
    traffic > max_traffic
    $predicate$
);

Set Threshold Values¶

Set the threshold values for the condition. The arguments are in the same order as defined in the create_rule statement:

SELECT trigger_rule."high_traffic_set_thresholds"(50000);

Define Weighing Function¶

The logic for determining the weight of a notification can be as complex as you want, or as simple as a constant value. Here we choose a simple case selection:

SELECT trigger.set_weight(
    'high_traffic',
    $query$
    SELECT CASE
    WHEN $1.traffic > 1000000 THEN
        100
    WHEN $1.traffic > 500000 THEN
        50
    ELSE
        10
    END
    $query$
);

Define Notification Details¶

SELECT trigger.define_notification(
    'high_traffic',
    $details$
    SELECT format('traffic(%s) > max_traffic(%s)', $1.traffic, $1.max_traffic);
    $details$
);

Schema Reference¶

attribute¶

Contains views pointing to current attribute records

Types¶

Tables¶

Views¶

Functions¶

Name	Return Type	Description

attribute_base¶

Contains the parent/base tables for attribute store data tables

Types¶

Tables¶

Views¶

Functions¶

Name	Return Type	Description

attribute_directory¶

Contains a directory with attribute store meta data

Types¶

attribute_descr¶

Name	Type	Description
name	char[]
datatype	character varying
description	text

attribute_info¶

Name	Type	Description
name	char[]
data_type	character varying

source_modified¶

Name	Type	Description
source_name	text
modified	timestamp with time zone

Tables¶

attribute¶

Name	Type	Description
attributestore_id	integer
description	text
name	char[]
datatype	character varying
id	integer

attribute_tag_link¶

Name	Type	Description
attribute_id	integer
tag_id	integer

attributestore¶

Name	Type	Description
datasource_id	integer
entitytype_id	integer
id	integer

attributestore_compacted¶

Name	Type	Description
attributestore_id	integer
compacted	timestamp with time zone

attributestore_curr_materialized¶

Name	Type	Description
attributestore_id	integer
materialized	timestamp with time zone

attributestore_materialization¶

Name	Type	Description
attributestore_id	integer
last_modified	timestamp with time zone

attributestore_modified¶

Name	Type	Description
attributestore_id	integer
modified	timestamp with time zone

sampled_view_materialization¶

Name	Type	Description
attributestore_id	integer
view_class	oid
source_modified_proc	oid
id	integer
stability_delay	interval

sampled_view_materialization_state¶

Name	Type	Description
materialization_id	integer
fingerprint	text

Views¶

dependencies¶

Name	Type	Description
src	char[]
column_name	char[]
dst	char[]

sampled_view_materialization_runnable¶

Name	Type	Description
id	integer
attributestore_id	integer
view_class	oid
source_modified_proc	oid
stability_delay	interval

Functions¶

Name	Return Type	Description
add_attribute(attribute_directory.attributestore, name char[], datatype character varying, description text)	attribute_directory.attribute
add_attribute_column(attribute_directory.attributestore, char[], text)	attribute_directory.attributestore
add_attributes(attribute_directory.attributestore, attributes attribute_descr[])	attribute_directory.attributestore
add_first_appearance_to_attribute_table(attribute_directory.attributestore)	attribute_directory.attributestore
at_function_name(attribute_directory.attributestore)	char[]
at_ptr_function_name(attribute_directory.attributestore)	char[]
attributestore_fingerprint(attributestore_name text)	text	Return easily readable fingerprint text containing the name of the
attributestore_modified(attributestore_name text)	timestamp with time zone	Return modified timestamp of attributestore as recorded in
changes_view_name(attribute_directory.attributestore)	char[]
changes_view_query(attribute_directory.attributestore)	text
check_attribute_types(attribute[])	attribute_directory.attribute
check_attributes_exist(attribute[])	attribute_directory.attribute
clean(store attribute_directory.attributestore, ts timestamp with time zone)	bigint
cleanup_attribute_after_delete()	trigger
cleanup_attributestore_on_delete()	trigger
cleanup_on_datasource_delete()	trigger
compact(attribute_directory.attributestore)	attribute_directory.attributestore	Remove all subsequent records with duplicate attribute values and update the modified of the first
compacted_tmp_table_name(attribute_directory.attributestore)	char[]
compacted_view_name(attribute_directory.attributestore)	char[]
compacted_view_query(attribute_directory.attributestore)	text
create_at_func(attribute_directory.attributestore)	attribute_directory.attributestore
create_at_func_ptr(attribute_directory.attributestore)	attribute_directory.attributestore
create_at_func_ptr_sql(attribute_directory.attributestore)	text[]
create_attributestore(datasource_name text, entitytype_name text)	attribute_directory.attributestore
create_attributestore(datasource_name text, entitytype_name text, attributes attribute_descr[])	attribute_directory.attributestore
create_attributestore_from_view(oid, datasource_name text, entitytype_name text)	attribute_directory.attributestore
create_base_table(attribute_directory.attributestore)	attribute_directory.attributestore
create_changes_view(attribute_directory.attributestore)	attribute_directory.attributestore
create_changes_view_sql(attribute_directory.attributestore)	text[]
create_compacted_tmp_table(attribute_directory.attributestore)	attribute_directory.attributestore
create_compacted_tmp_table_sql(attribute_directory.attributestore)	text[]
create_compacted_view(attribute_directory.attributestore)	attribute_directory.attributestore
create_compacted_view_sql(attribute_directory.attributestore)	text[]
create_curr_ptr_table(attribute_directory.attributestore)	attribute_directory.attributestore
create_curr_ptr_table_sql(attribute_directory.attributestore)	text[]
create_curr_ptr_view(attribute_directory.attributestore)	attribute_directory.attributestore
create_curr_ptr_view_sql(attribute_directory.attributestore)	text[]
create_curr_view(attribute_directory.attributestore)	attribute_directory.attributestore
create_curr_view_sql(attribute_directory.attributestore)	text[]
create_dependees(attribute_directory.attributestore)	attribute_directory.attributestore
create_entity_at_func(attribute_directory.attributestore)	attribute_directory.attributestore
create_entity_at_func_ptr(attribute_directory.attributestore)	attribute_directory.attributestore
create_entity_at_func_ptr_sql(attribute_directory.attributestore)	text[]
create_entity_at_func_sql(attribute_directory.attributestore)	text[]
create_hash_function(attribute_directory.attributestore)	attribute_directory.attributestore
create_hash_function_sql(attribute_directory.attributestore)	text[]
create_hash_triggers(attribute_directory.attributestore)	attribute_directory.attributestore
create_hash_triggers_sql(attribute_directory.attributestore)	text[]
create_history_table(attribute_directory.attributestore)	attribute_directory.attributestore
create_modified_trigger_function(attribute_directory.attributestore)	attribute_directory.attributestore
create_modified_trigger_function_sql(attribute_directory.attributestore)	text[]
create_modified_triggers(attribute_directory.attributestore)	attribute_directory.attributestore
create_modified_triggers_sql(attribute_directory.attributestore)	text[]
create_run_length_view(attribute_directory.attributestore)	attribute_directory.attributestore	Create a view on an attributestore’s history table that lists the runs of
create_run_length_view_sql(attribute_directory.attributestore)	text[]
create_sampled_view_materialization(view_class oid, source_modified_proc oid, datasource_name text, entitytype_name text)	attribute_directory.sampled_view_materialization
create_staging_modified_view(attribute_directory.attributestore)	attribute_directory.attributestore
create_staging_modified_view_sql(attribute_directory.attributestore)	text[]
create_staging_new_view(attribute_directory.attributestore)	attribute_directory.attributestore
create_staging_new_view_sql(attribute_directory.attributestore)	text[]
create_staging_table(attribute_directory.attributestore)	attribute_directory.attributestore
create_staging_table_sql(attribute_directory.attributestore)	text[]
curr_ptr_table_name(attribute_directory.attributestore)	char[]
curr_ptr_view_name(attribute_directory.attributestore)	char[]
curr_view_name(attribute_directory.attributestore)	char[]
curr_view_query(attribute_directory.attributestore)	text
datatype_order(datatype character varying)	integer
define(attribute_directory.attribute)	attribute_directory.attribute
define_attributestore(datasource_id integer, entitytype_id integer)	attribute_directory.attributestore
define_attributestore(datasource_name text, entitytype_name text)	attribute_directory.attributestore
define_sampled_view_materialization(attributestore_id integer, view_class oid, source_modified_proc oid)	attribute_directory.sampled_view_materialization
dependees(attribute_directory.attributestore)	obj_ref[]	Return array with all managed dependees of attributestore base table
dependers(name char[], level integer)	TABLE(char[], integer)
dependers(name char[])	TABLE(char[], integer)
direct_dependers(name text)	char[]
drop_compacted_view(attribute_directory.attributestore)	attribute_directory.attributestore
drop_compacted_view_sql(attribute_directory.attributestore)	text
drop_curr_ptr_view(attribute_directory.attributestore)	attribute_directory.attributestore
drop_curr_ptr_view_sql(attribute_directory.attributestore)	character varying
drop_curr_view(attribute_directory.attributestore)	attribute_directory.attributestore
drop_curr_view_sql(attribute_directory.attributestore)	character varying
drop_dependees(attribute_directory.attributestore)	attribute_directory.attributestore
drop_entity_at_func(attribute_directory.attributestore)	attribute_directory.attributestore
drop_entity_at_func_sql(attribute_directory.attributestore)	text
drop_hash_function(attribute_directory.attributestore)	attribute_directory.attributestore
drop_staging_modified_view(attribute_directory.attributestore)	attribute_directory.attributestore
drop_staging_modified_view_sql(attribute_directory.attributestore)	character varying
drop_staging_new_view(attribute_directory.attributestore)	attribute_directory.attributestore
fingerprint(attribute_directory.sampled_view_materialization)	text
get_attribute(attribute_directory.attributestore, char[])	attribute_directory.attribute
get_attributes(oid)	attribute_directory.attribute_descr
get_attributes(attribute_directory.attributestore)	attribute_directory.attribute
get_attributestore(datasource_id integer, entitytype_id integer)	attribute_directory.attributestore
get_attributestore(attribute_directory.sampled_view_materialization)	attribute_directory.attributestore
greatest_datatype(datatype_a character varying, datatype_b character varying)	character varying
init(attribute_directory.attributestore)	attribute_directory.attributestore
init(attribute_directory.attribute)	attribute_directory.attribute
insert_state(attribute_directory.sampled_view_materialization, text)	text
mark_compacted(attributestore_id integer, compacted timestamp with time zone)	attribute_directory.attributestore_compacted
mark_compacted(attributestore_id integer)	attribute_directory.attributestore_compacted
mark_curr_materialized(attributestore_id integer, materialized timestamp with time zone)	attribute_directory.attributestore_curr_materialized
mark_curr_materialized(attributestore_id integer)	attribute_directory.attributestore_curr_materialized
mark_modified(attributestore_id integer, modified timestamp with time zone)	attribute_directory.attributestore_modified
mark_modified(attributestore_id integer)	attribute_directory.attributestore_modified
materialize(store attribute_directory.attributestore)	attribute_directory.attributestore
materialize(attribute_directory.sampled_view_materialization)	attribute_directory.sampled_view_materialization
materialize_curr_ptr(attribute_directory.attributestore)	integer
max_modified(attribute_directory.sampled_view_materialization)	timestamp with time zone
modify_column_type(attribute_directory.attributestore, column_name char[], datatype character varying)	attribute_directory.attributestore
modify_column_type_sql(attribute_directory.attributestore, column_name char[], datatype character varying)	text[]
modify_datatype(attribute_directory.attribute)	attribute_directory.attribute
remove_attribute(attribute_directory.attribute)	dep_recurse.obj_ref
remove_attribute(attribute_directory.attributestore, char[])	dep_recurse.obj_ref
remove_attribute_column(attribute_directory.attributestore, char[])	attribute_directory.attributestore	Remove named column from the attributestore and update all attributestore system functions dependent on the columns (e.g.: hash function). Possible other/user defined functions dependent on the columns in the attributestore are outside of the scope of this function.
render_hash_query(attribute_directory.attributestore)	text
requires_compacting(attributestore_id integer)	boolean
requires_compacting(attribute_directory.attributestore)	boolean
run_length_view_name(attribute_directory.attributestore)	char[]
run_length_view_query(attribute_directory.attributestore)	text
sampled_view_materialization_runnable(timestamp with time zone)	attribute_directory.sampled_view_materialization
set_hash()	trigger
stage_sample(attribute_directory.sampled_view_materialization)	attribute_directory.sampled_view_materialization
staging_modified_view_name(attribute_directory.attributestore)	char[]
staging_new_view_name(attribute_directory.attributestore)	char[]
store_compacted(attributestore_id integer, compacted timestamp with time zone)	attribute_directory.attributestore_compacted
store_curr_materialized(attributestore_id integer, materialized timestamp with time zone)	attribute_directory.attributestore_curr_materialized
store_modified(attributestore_id integer, modified timestamp with time zone)	attribute_directory.attributestore_modified
store_state(attribute_directory.sampled_view_materialization, text)	text
store_state(attribute_directory.sampled_view_materialization)	attribute_directory.sampled_view_materialization
to_attribute(attribute_directory.attribute)	attribute_directory.attribute
to_attributestore(datasource_id integer, entitytype_id integer)	attribute_directory.attributestore
to_char(attribute_directory.attributestore)	text
to_char(attribute_directory.sampled_view_materialization)	text
to_table_name(attribute_directory.attributestore)	char[]
transfer_staged(attribute_directory.attributestore)	attribute_directory.attributestore
update_compacted(attributestore_id integer, compacted timestamp with time zone)	attribute_directory.attributestore_compacted
update_curr_materialized(attributestore_id integer, materialized timestamp with time zone)	attribute_directory.attributestore_curr_materialized
update_datatype_on_change()	trigger
update_modified(attributestore_id integer, modified timestamp with time zone)	attribute_directory.attributestore_modified
update_state(attribute_directory.sampled_view_materialization, text)	text
upgrade_attribute_table(attribute_directory.attributestore)	attribute_directory.attributestore
view_to_attribute_staging_sql(oid, attribute_directory.attributestore)	text

add_attribute(attribute_directory.attributestore, name char[], datatype character varying, description text) -> attribute_directory.attribute¶

returns: attribute_directory.attribute

add_attribute_column(attribute_directory.attributestore, char[], text) -> attribute_directory.attributestore¶

returns: attribute_directory.attributestore

add_attributes(attribute_directory.attributestore, attributes attribute_descr[]) -> attribute_directory.attributestore¶

returns: attribute_directory.attributestore

add_first_appearance_to_attribute_table(attribute_directory.attributestore) -> attribute_directory.attributestore¶

returns: attribute_directory.attributestore

at_function_name(attribute_directory.attributestore) -> char[]¶

returns: char[]

at_ptr_function_name(attribute_directory.attributestore) -> char[]¶

returns: char[]

attributestore_fingerprint(attributestore_name text) -> text¶

returns: text

Return easily readable fingerprint text containing the name of the attributestore and the modified timestamp

attributestore_modified(attributestore_name text) -> timestamp with time zone¶

compact(attribute_directory.attributestore) -> attribute_directory.attributestore¶

create_modified_triggers_sql(attribute_directory.attributestore) -> text[]¶

returns: text[]

create_run_length_view(attribute_directory.attributestore) -> attribute_directory.attributestore¶

define_attributestore(datasource_name text, entitytype_name text) -> attribute_directory.attributestore¶

returns: attribute_directory.attributestore

define_sampled_view_materialization(attributestore_id integer, view_class oid, source_modified_proc oid) -> attribute_directory.sampled_view_materialization¶

returns: attribute_directory.sampled_view_materialization

dependees(attribute_directory.attributestore) -> obj_ref[]¶

returns: obj_ref[]

Return array with all managed dependees of attributestore base table

This array is primarily used to alter the base table using dep_recurse.alter so that the alter function can skip the database objects that are already dynamically created and recreated

dependers(name char[], level integer) -> TABLE(char[], integer)¶

returns: TABLE(char[], integer)

dependers(name char[]) -> TABLE(char[], integer)¶

returns: TABLE(char[], integer)

direct_dependers(name text) -> SETOF char[]¶

returns: char[]

drop_compacted_view(attribute_directory.attributestore) -> attribute_directory.attributestore¶

returns: attribute_directory.attributestore

drop_compacted_view_sql(attribute_directory.attributestore) -> text¶

returns: text

drop_curr_ptr_view(attribute_directory.attributestore) -> attribute_directory.attributestore¶

returns: attribute_directory.attributestore

drop_curr_ptr_view_sql(attribute_directory.attributestore) -> character varying¶

returns: character varying

drop_curr_view(attribute_directory.attributestore) -> attribute_directory.attributestore¶

returns: attribute_directory.attributestore

drop_curr_view_sql(attribute_directory.attributestore) -> character varying¶

returns: character varying

drop_dependees(attribute_directory.attributestore) -> attribute_directory.attributestore¶

returns: attribute_directory.attributestore

drop_entity_at_func(attribute_directory.attributestore) -> attribute_directory.attributestore¶

returns: attribute_directory.attributestore

drop_entity_at_func_sql(attribute_directory.attributestore) -> text¶

returns: text

drop_hash_function(attribute_directory.attributestore) -> attribute_directory.attributestore¶

returns: attribute_directory.attributestore

drop_staging_modified_view(attribute_directory.attributestore) -> attribute_directory.attributestore¶

returns: attribute_directory.attributestore

drop_staging_modified_view_sql(attribute_directory.attributestore) -> character varying¶

returns: character varying

drop_staging_new_view(attribute_directory.attributestore) -> attribute_directory.attributestore¶

returns: attribute_directory.attributestore

fingerprint(attribute_directory.sampled_view_materialization) -> text¶

returns: text

get_attribute(attribute_directory.attributestore, char[]) -> attribute_directory.attribute¶

returns: attribute_directory.attribute

get_attributes(oid) -> SETOF attribute_directory.attribute_descr¶

returns: attribute_directory.attribute_descr

get_attributes(attribute_directory.attributestore) -> SETOF attribute_directory.attribute¶

returns: attribute_directory.attribute

get_attributestore(datasource_id integer, entitytype_id integer) -> attribute_directory.attributestore¶

returns: attribute_directory.attributestore

get_attributestore(attribute_directory.sampled_view_materialization) -> attribute_directory.attributestore¶

returns: attribute_directory.attributestore

greatest_datatype(datatype_a character varying, datatype_b character varying) -> character varying¶

returns: character varying

init(attribute_directory.attributestore) -> attribute_directory.attributestore¶

returns: attribute_directory.attributestore

init(attribute_directory.attribute) -> attribute_directory.attribute¶

returns: attribute_directory.attribute

insert_state(attribute_directory.sampled_view_materialization, text) -> text¶

returns: text

mark_compacted(attributestore_id integer, compacted timestamp with time zone) -> attribute_directory.attributestore_compacted¶

returns: attribute_directory.attributestore_compacted

mark_compacted(attributestore_id integer) -> attribute_directory.attributestore_compacted¶

returns: attribute_directory.attributestore_compacted

mark_curr_materialized(attributestore_id integer, materialized timestamp with time zone) -> attribute_directory.attributestore_curr_materialized¶

returns: attribute_directory.attributestore_curr_materialized

mark_curr_materialized(attributestore_id integer) -> attribute_directory.attributestore_curr_materialized¶

returns: attribute_directory.attributestore_curr_materialized

mark_modified(attributestore_id integer, modified timestamp with time zone) -> attribute_directory.attributestore_modified¶

returns: attribute_directory.attributestore_modified

mark_modified(attributestore_id integer) -> attribute_directory.attributestore_modified¶

returns: attribute_directory.attributestore_modified

materialize(store attribute_directory.attributestore) -> attribute_directory.attributestore¶

returns: attribute_directory.attributestore

materialize(attribute_directory.sampled_view_materialization) -> attribute_directory.sampled_view_materialization¶

returns: attribute_directory.sampled_view_materialization

materialize_curr_ptr(attribute_directory.attributestore) -> integer¶

returns: integer

max_modified(attribute_directory.sampled_view_materialization) -> timestamp with time zone¶

returns: timestamp with time zone

modify_column_type(attribute_directory.attributestore, column_name char[], datatype character varying) -> attribute_directory.attributestore¶

returns: attribute_directory.attributestore

modify_column_type_sql(attribute_directory.attributestore, column_name char[], datatype character varying) -> text[]¶

returns: text[]

modify_datatype(attribute_directory.attribute) -> attribute_directory.attribute¶

returns: attribute_directory.attribute

remove_attribute(attribute_directory.attribute) -> dep_recurse.obj_ref¶

returns: dep_recurse.obj_ref

remove_attribute(attribute_directory.attributestore, char[]) -> dep_recurse.obj_ref¶

returns: dep_recurse.obj_ref

remove_attribute_column(attribute_directory.attributestore, char[]) -> attribute_directory.attributestore¶

Types¶

Tables¶

Views¶

Functions¶

Name	Return Type	Description

attribute_staging¶

Contains tables for staging new data to be added to attribute stores

Types¶

Tables¶

Views¶

Functions¶

Name	Return Type	Description

dimension¶

Types¶

Tables¶

5m¶

Name	Type	Description
timestamp	timestamp with time zone
start	timestamp with time zone
end	timestamp with time zone

day¶

Name	Type	Description
timestamp	timestamp with time zone
start	timestamp with time zone
end	timestamp with time zone

day_15m¶

Name	Type	Description
timestamp	timestamp with time zone
timestamp_15m	timestamp with time zone

four_consec_qtr¶

Name	Type	Description
timestamp	timestamp with time zone
start	timestamp with time zone
end	timestamp with time zone

hour¶

Name	Type	Description
timestamp	timestamp with time zone
start	timestamp with time zone
end	timestamp with time zone

month¶

Name	Type	Description
timestamp	timestamp with time zone
start	timestamp with time zone
end	timestamp with time zone

month_15m¶

Name	Type	Description
timestamp	timestamp with time zone
timestamp_15m	timestamp with time zone

quarter¶

Name	Type	Description
timestamp	timestamp with time zone
start	timestamp with time zone
end	timestamp with time zone

week¶

Name	Type	Description
timestamp	timestamp with time zone
start	timestamp with time zone
end	timestamp with time zone
year	smallint
week_iso_8601	smallint

week_15m¶

Name	Type	Description
timestamp	timestamp with time zone
timestamp_15m	timestamp with time zone

Views¶

Functions¶

Name	Return Type	Description
update_5m()	void
update_day()	void
update_day_15m()	void
update_four_consec_qtr()	void
update_hour()	void
update_month()	void
update_month_15m()	void
update_quarter()	void
update_week()	void
update_week_15m()	void

Name	Type	Description
type_name	character varying
name	character varying

existence¶

Name	Type	Description
timestamp	timestamp with time zone
exists	boolean
entity_id	integer

query_part¶

Name	Type	Description
c	text[]
s	text

query_row¶

Name	Type	Description
id	integer
dn	text
entitytype_id	integer

Tables¶

alias¶

Name	Type	Description
entity_id	integer
name	character varying
type_id	integer

aliastype¶

Name	Type	Description
name	character varying
id	integer

datasource¶

Describes datasources. A datasource is used to indicate where data came from. Datasources are also used to prevent collisions between sets of data from different sources, where names can be the same, but the meaning of the data differs.

Name	Type	Description
name	character varying
description	character varying
timezone	character varying
id	integer

entity¶

Describes entities. An entity is the base object for which the database can hold further information such as attributes, trends and notifications. All data must have a reference to an entity.

Name	Type	Description
first_appearance	timestamp with time zone
name	character varying
entitytype_id	integer
dn	character varying
parent_id	integer
id	integer

entity_link_denorm¶

The denormalized relation between entity and tag.

Stores one record for each entity, with all tag names in lower case in the tags column. A gin index on tags makes it ideal to lookup entities that have certain tags.

Name	Type	Description
entity_id	integer
tags	text[]
name	text

entitytaglink¶

The n:n relation between entity and tag

Name	Type	Description
tag_id	integer
entity_id	integer

entitytype¶

Stores the entity types that exist in the entity table. Entity types are also used to give context to data that is stored for entities.

Name	Type	Description
name	character varying
description	character varying
id	integer

existence_staging¶

Name	Type	Description
dn	character varying

tag¶

Stores all tags. A tag is a simple label that can be attached to a number of object types in the database, such as entities and trends.

Name	Type	Description
name	character varying
taggroup_id	integer
description	character varying
id	integer

Views¶

existence_staging_entitytype_ids¶

Name	Type	Description
entitytype_id	integer

Functions¶

Name	Return Type	Description
addentity(timestamp with time zone, character varying, integer, character varying, integer)	integer
array_to_dn_part(varchar[])	directory.dn_part
cluster_entity_tag_denorm(char[])	char[]
compile_minerva_query(query text)	text
compile_minerva_query(query query_part[])	text
create alias for new entity (func)()	trigger
create entitytaglink for new entity (func)()	trigger
create tag for new entitytypes (func)()	trigger
create_datasource(character varying)	directory.datasource	Create a new datasource with specified name and return the new record
create_entity(character varying)	directory.entity
create_entity_tag_denorm(char[])	char[]
create_entity_tag_denorm_indexes(char[])	char[]
create_entity_tag_denorm_sql(char[])	text[]
create_entitytype(character varying)	directory.entitytype	Create new entitytype with specified name and return it.
dn_part_to_string(directory.dn_part)	character varying
dn_to_entity(character varying)	directory.entity	Return existing or new entity with specified DN.
dns_to_entity_ids(varchar[])	integer
entities_by_type(character varying)	directory.entity
entities_by_type(integer)	directory.entity
entity_id(directory.entity)	integer
entitytype_id(directory.entitytype)	integer
existence_staging_state(timestamp with time zone, entitytype_id integer)	directory.existence
existing_staging(timestamp with time zone, entitytype_id integer)	directory.existence
explode_dn(character varying)	dn_part[]
get_alias(entity_id integer, aliastype_name character varying)	character varying
get_datasource(character varying)	directory.datasource
get_entity(character varying)	directory.entity
get_entitytype(character varying)	directory.entitytype
get_entitytype_id(character varying)	integer
getentitybydn(character varying)	TABLE(integer, integer, character varying, integer)
getentitybyid(integer)	TABLE(character varying, integer, character varying, integer)
glue_dn(dn_part[])	character varying
last_dn_part(dn_part[])	directory.dn_part
make_c_join(index integer, entity_id_table text, entity_id_column text, tag_index integer, tag text)	text
make_s_join(index integer, entity_id_table text, entity_id_column text, alias text)	text
name_to_datasource(character varying)	directory.datasource
name_to_entitytype(character varying)	directory.entitytype	Return new or existing entitytype with specified name.
new_existence_state(timestamp with time zone, entitytype_id integer)	directory.existence
non_existing_staging(timestamp with time zone, entitytype_id integer)	directory.existence
parent_dn(character varying)	character varying	Return DN string of the parent.
parent_dn_parts(dn_part[])	dn_part[]	Return all but the last DN part or NULL if the array is empty.
populate_entity_tag_denorm(char[])	char[]
rebuild_entity_tag_denorm(char[])	char[]	Build a new denormalized entity tags table, populate it and replace the old
replace_entity_tag_denorm(char[])	char[]
run_minerva_query(query query_part[])	TABLE(integer, character varying, integer)
split_raw_part(character varying)	directory.dn_part
sumproduct(query query_part[], value_trend text, weight_trend text)	TABLE(timestamp with time zone, double precision)
tag_entity(entity_id integer, tag character varying)	integer
tag_entity(dn character varying, tag character varying)	character varying
transfer_existence(timestamp with time zone)	timestamp with time zone
update_denormalized_entity_tags(entity_id integer)	text[]
update_entity_link_denorm_for_delete()	trigger
update_entity_link_denorm_for_insert()	trigger
wavg(query query_part[], value_trend_id integer, weight_trend_id integer)	TABLE(timestamp with time zone, double precision)

Create a new datasource with specified name and return the new record

create_entity(character varying) -> directory.entity¶

returns: directory.entity

create_entity_tag_denorm(char[]) -> char[]¶

returns: char[]

create_entity_tag_denorm_indexes(char[]) -> char[]¶

returns: char[]

create_entity_tag_denorm_sql(char[]) -> text[]¶

returns: text[]

create_entitytype(character varying) -> directory.entitytype¶

returns: directory.entitytype

returns: directory.datasource

name_to_entitytype(character varying) -> directory.entitytype¶

returns: directory.entitytype

Return new or existing entitytype with specified name.

new_existence_state(timestamp with time zone, entitytype_id integer) -> SETOF directory.existence¶

returns: directory.existence

non_existing_staging(timestamp with time zone, entitytype_id integer) -> SETOF directory.existence¶

returns: directory.existence

parent_dn(character varying) -> character varying¶

returns: character varying

Return DN string of the parent.

parent_dn_parts(dn_part[]) -> dn_part[]¶

returns: dn_part[]

Return all but the last DN part or NULL if the array is empty.

populate_entity_tag_denorm(char[]) -> char[]¶

returns: char[]

rebuild_entity_tag_denorm(char[]) -> char[]¶

returns: char[]

Build a new denormalized entity tags table, populate it and replace the old one by using drop/rename to avoid blocking other users

replace_entity_tag_denorm(char[]) -> char[]¶

returns: char[]

run_minerva_query(query query_part[]) -> TABLE(integer, character varying, integer)¶

returns: TABLE(integer, character varying, integer)

split_raw_part(character varying) -> directory.dn_part¶

returns: directory.dn_part

sumproduct(query query_part[], value_trend text, weight_trend text) -> TABLE(timestamp with time zone, double precision)¶

returns: TABLE(timestamp with time zone, double precision)

tag_entity(entity_id integer, tag character varying) -> integer¶

returns: integer

tag_entity(dn character varying, tag character varying) -> character varying¶

returns: character varying

transfer_existence(timestamp with time zone) -> timestamp with time zone¶

returns: timestamp with time zone

update_denormalized_entity_tags(entity_id integer) -> text[]¶

returns: text[]

update_entity_link_denorm_for_delete() -> trigger¶

returns: trigger

update_entity_link_denorm_for_insert() -> trigger¶

returns: trigger

wavg(query query_part[], value_trend_id integer, weight_trend_id integer) -> TABLE(timestamp with time zone, double precision)¶

returns: TABLE(timestamp with time zone, double precision)

entity_tag¶

Types¶

process_staged_links_result¶

Name	Type	Description
tags_added	bigint
links_added	bigint
links_removed	bigint

update_result¶

Name	Type	Description
staged	bigint
tags_added	bigint
links_added	bigint
links_removed	bigint

Tables¶

entitytaglink_staging¶

Name	Type	Description
entity_id	integer
tag_name	text
taggroup_id	integer

type¶

Name	Type	Description
name	char[]
taggroup_id	integer
id	integer

Views¶

_new_links_in_staging¶

Name	Type	Description
entity_id	integer
tag_id	integer

_new_tags_in_staging¶

Name	Type	Description
name	text
taggroup_id	integer

_obsolete_links¶

Name	Type	Description
entity_id	integer
tag_id	integer

Functions¶

Name	Return Type	Description
add_new_links(add_limit integer)	bigint
add_new_tags()	bigint
define(type_name char[], tag_group text, sql text)	entity_tag.type
process_staged_links(process_limit integer)	entity_tag.process_staged_links_result
remove_obsolete_links()	bigint
transfer_to_staging(name char[])	bigint
update(type_name char[], update_limit integer)	entity_tag.update_result

materialization¶

Types¶

materialization_result¶

Name	Type	Description
processed_max_modified	timestamp with time zone
row_count	integer

source_fragment¶

Name	Type	Description
trendstore_id	integer
timestamp	timestamp with time zone

source_fragment_state¶

Name	Type	Description
fragment	materialization.source_fragment
modified	timestamp with time zone

Tables¶

group_priority¶

Name	Type	Description
tag_id	integer
resources	integer

state¶

The Id of the materialization type

Name	Type	Description
type_id	integer	The Id of the materialization type
timestamp	timestamp with time zone	The timestamp of the materialized (materialization result) data
max_modified	timestamp with time zone	The greatest modified timestamp of all materialization sources
source_states	source_fragment_state[]	Array of trendstore_id/timestamp/modified combinations for all source data fragments
processed_states	source_fragment_state[]	Array containing a snapshot of the source_states at the time of the most recent materialization
job_id	integer	Id of the most recent job for this materialization

state¶

The timestamp of the materialized (materialization result) data

Name	Type	Description
type_id	integer	The Id of the materialization type
timestamp	timestamp with time zone	The timestamp of the materialized (materialization result) data
max_modified	timestamp with time zone	The greatest modified timestamp of all materialization sources
source_states	source_fragment_state[]	Array of trendstore_id/timestamp/modified combinations for all source data fragments
processed_states	source_fragment_state[]	Array containing a snapshot of the source_states at the time of the most recent materialization
job_id	integer	Id of the most recent job for this materialization

state¶

The greatest modified timestamp of all materialization sources

Name	Type	Description
type_id	integer	The Id of the materialization type
timestamp	timestamp with time zone	The timestamp of the materialized (materialization result) data
max_modified	timestamp with time zone	The greatest modified timestamp of all materialization sources
source_states	source_fragment_state[]	Array of trendstore_id/timestamp/modified combinations for all source data fragments
processed_states	source_fragment_state[]	Array containing a snapshot of the source_states at the time of the most recent materialization
job_id	integer	Id of the most recent job for this materialization

state¶

Array of trendstore_id/timestamp/modified combinations for all source data fragments

Name	Type	Description
type_id	integer	The Id of the materialization type
timestamp	timestamp with time zone	The timestamp of the materialized (materialization result) data
max_modified	timestamp with time zone	The greatest modified timestamp of all materialization sources
source_states	source_fragment_state[]	Array of trendstore_id/timestamp/modified combinations for all source data fragments
processed_states	source_fragment_state[]	Array containing a snapshot of the source_states at the time of the most recent materialization
job_id	integer	Id of the most recent job for this materialization

state¶

Array containing a snapshot of the source_states at the time of the most recent materialization

Name	Type	Description
type_id	integer	The Id of the materialization type
timestamp	timestamp with time zone	The timestamp of the materialized (materialization result) data
max_modified	timestamp with time zone	The greatest modified timestamp of all materialization sources
source_states	source_fragment_state[]	Array of trendstore_id/timestamp/modified combinations for all source data fragments
processed_states	source_fragment_state[]	Array containing a snapshot of the source_states at the time of the most recent materialization
job_id	integer	Id of the most recent job for this materialization

state¶

Id of the most recent job for this materialization

Name	Type	Description
type_id	integer	The Id of the materialization type
timestamp	timestamp with time zone	The timestamp of the materialized (materialization result) data
max_modified	timestamp with time zone	The greatest modified timestamp of all materialization sources
source_states	source_fragment_state[]	Array of trendstore_id/timestamp/modified combinations for all source data fragments
processed_states	source_fragment_state[]	Array containing a snapshot of the source_states at the time of the most recent materialization
job_id	integer	Id of the most recent job for this materialization

type¶

The Id of the source trendstore, which should be the Id of a view based trendstore

Name	Type	Description
src_trendstore_id	integer	The Id of the source trendstore, which should be the Id of a view based trendstore
dst_trendstore_id	integer	The Id of the destination trendstore, which should be the Id of a table based trendstore
processing_delay	interval	The time after the destination timestamp before this materialization can be executed
stability_delay	interval	The time to wait after the most recent modified timestamp before the source data is considered ‘stable’
reprocessing_period	interval	The maximum time after the destination timestamp that the materialization is allowed to be executed
id	integer
enabled	boolean	Indicates if jobs should be created for this materialization (manual execution is always possible)
cost	integer

type¶

The Id of the destination trendstore, which should be the Id of a table based trendstore

Name	Type	Description
src_trendstore_id	integer	The Id of the source trendstore, which should be the Id of a view based trendstore
dst_trendstore_id	integer	The Id of the destination trendstore, which should be the Id of a table based trendstore
processing_delay	interval	The time after the destination timestamp before this materialization can be executed
stability_delay	interval	The time to wait after the most recent modified timestamp before the source data is considered ‘stable’
reprocessing_period	interval	The maximum time after the destination timestamp that the materialization is allowed to be executed
id	integer
enabled	boolean	Indicates if jobs should be created for this materialization (manual execution is always possible)
cost	integer

type¶

The time after the destination timestamp before this materialization can be executed

Name	Type	Description
src_trendstore_id	integer	The Id of the source trendstore, which should be the Id of a view based trendstore
dst_trendstore_id	integer	The Id of the destination trendstore, which should be the Id of a table based trendstore
processing_delay	interval	The time after the destination timestamp before this materialization can be executed
stability_delay	interval	The time to wait after the most recent modified timestamp before the source data is considered ‘stable’
reprocessing_period	interval	The maximum time after the destination timestamp that the materialization is allowed to be executed
id	integer
enabled	boolean	Indicates if jobs should be created for this materialization (manual execution is always possible)
cost	integer

type¶

The time to wait after the most recent modified timestamp before the source data is considered ‘stable’

Name	Type	Description
src_trendstore_id	integer	The Id of the source trendstore, which should be the Id of a view based trendstore
dst_trendstore_id	integer	The Id of the destination trendstore, which should be the Id of a table based trendstore
processing_delay	interval	The time after the destination timestamp before this materialization can be executed
stability_delay	interval	The time to wait after the most recent modified timestamp before the source data is considered ‘stable’
reprocessing_period	interval	The maximum time after the destination timestamp that the materialization is allowed to be executed
id	integer
enabled	boolean	Indicates if jobs should be created for this materialization (manual execution is always possible)
cost	integer

type¶

The maximum time after the destination timestamp that the materialization is allowed to be executed

Name	Type	Description
src_trendstore_id	integer	The Id of the source trendstore, which should be the Id of a view based trendstore
dst_trendstore_id	integer	The Id of the destination trendstore, which should be the Id of a table based trendstore
processing_delay	interval	The time after the destination timestamp before this materialization can be executed
stability_delay	interval	The time to wait after the most recent modified timestamp before the source data is considered ‘stable’
reprocessing_period	interval	The maximum time after the destination timestamp that the materialization is allowed to be executed
id	integer
enabled	boolean	Indicates if jobs should be created for this materialization (manual execution is always possible)
cost	integer

type¶

Indicates if jobs should be created for this materialization (manual execution is always possible)

Name	Type	Description
src_trendstore_id	integer	The Id of the source trendstore, which should be the Id of a view based trendstore
dst_trendstore_id	integer	The Id of the destination trendstore, which should be the Id of a table based trendstore
processing_delay	interval	The time after the destination timestamp before this materialization can be executed
stability_delay	interval	The time to wait after the most recent modified timestamp before the source data is considered ‘stable’
reprocessing_period	interval	The maximum time after the destination timestamp that the materialization is allowed to be executed
id	integer
enabled	boolean	Indicates if jobs should be created for this materialization (manual execution is always possible)
cost	integer

type_tag_link¶

Name	Type	Description
type_id	integer
tag_id	integer

Views¶

materializable_source_state¶

Name	Type	Description
type_id	integer
timestamp	timestamp with time zone
trendstore_id	integer
src_timestamp	timestamp with time zone
modified	timestamp with time zone

materializables¶

Name	Type	Description
type_id	integer
timestamp	timestamp with time zone
max_modified	timestamp with time zone
source_states	source_fragment_state[]

modified_materializables¶

Name	Type	Description
type_id	integer
timestamp	timestamp with time zone
max_modified	timestamp with time zone
source_states	source_fragment_state[]

new_materializables¶

Name	Type	Description
type_id	integer
timestamp	timestamp with time zone
max_modified	timestamp with time zone
source_states	source_fragment_state[]

next_up_materializations¶

Name	Type	Description
type_id	integer
timestamp	timestamp with time zone
name	character varying
cost	integer
cumsum	bigint
group_resources	integer
job_active	boolean

obsolete_state¶

Name	Type	Description
type_id	integer
timestamp	timestamp with time zone

required_resources_by_group¶

Name	Type	Description
tag_id	integer
required	bigint

runnable_materializations¶

Name	Type	Description
type	materialization.type
state	materialization.state

tagged_runnable_materializations¶

Name	Type	Description
type_id	integer
timestamp	timestamp with time zone
tag	character varying

trend_ext¶

Convenience view for easy lookup of trends

Name	Type	Description
id	integer
name	character varying
datasource_name	character varying
entitytype_name	character varying
granularity	character varying
materialized	boolean

Functions¶

Name	Return Type	Description
add_missing_trends(src trend.trendstore, dst trend.trendstore)	bigint	Add trends and actual table columns to destination that exist in the source
add_missing_trends(materialization.type)	materialization.type
add_new_state()	integer
create_job(type_id integer, timestamp timestamp with time zone)	integer
create_jobs(tag character varying, job_limit integer)	integer
create_jobs(tag character varying)	integer
create_jobs()	integer
create_jobs_limited(tag character varying, job_limit integer)	integer	Deprecated function that just calls the overloaded create_jobs function.
default_processing_delay(granularity character varying)	interval
default_stability_delay(granularity character varying)	interval
define(src_trendstore_id integer, dst_trendstore_id integer)	materialization.type
define(src trend.trendstore, dst trend.trendstore)	materialization.type
define(text, text)	materialization.type
define(trend.trendstore)	materialization.type	Defines a new materialization with the convention that the datasource of
define(trend.view)	materialization.type	Defines a new materialization with the convention that the datasource of
delete_obsolete_state()	integer
dependencies(trend.trendstore, level integer)	TABLE(trend.trendstore, integer)
dependencies(trend.trendstore)	TABLE(trend.trendstore, integer)
dependencies(name text)	TABLE(trend.trendstore, integer)
direct_dependencies(trend.trendstore)	trend.trendstore
direct_table_dependencies(trend.trendstore)	trend.trendstore
direct_view_dependencies(trend.trendstore)	trend.trendstore
disable(materialization.type)	materialization.type
enable(materialization.type)	materialization.type
fragments(source_fragment_state[])	source_fragment[]
materialization(src text, dst text, timestamp timestamp with time zone)	materialization.materialization_result
materialize(src trend.trendstore, dst trend.trendstore, timestamp timestamp with time zone)	materialization.materialization_result
materialize(src_trendstore_id integer, dst_trendstore_id integer, timestamp timestamp with time zone)	materialization.materialization_result
materialize(materialization text, timestamp timestamp with time zone)	materialization.materialization_result
materialize(materialization.type, timestamp timestamp with time zone)	materialization.materialization_result
materialize(id integer, timestamp timestamp with time zone)	materialization.materialization_result
missing_columns(src trend.trendstore, dst trend.trendstore)	TABLE(character varying, character varying)	The set of table columns (name, datatype) that exist in the source trendstore but not yet in the destination.
missing_columns(materialization.type)	TABLE(character varying, character varying)
modify_mismatching_trends(src trend.trendstore, dst trend.trendstore)	void
modify_mismatching_trends(materialization.type)	void
no_slave_lag()	boolean
open_job_slots(slot_count integer)	integer
render_job_json(type_id integer, timestamp with time zone)	character varying
requires_update(materialization.state)	boolean
reset(type_id integer)	materialization.state
reset(type_id integer, timestamp with time zone)	materialization.state
reset(materialization.type, timestamp with time zone)	materialization.state
reset_hard(materialization.type)	void	Remove data (partitions) resulting from this materialization and the
runnable(materialization.type, materialization.state)	boolean
runnable(type materialization.type, timestamp timestamp with time zone, max_modified timestamp with time zone)	boolean
runnable_materializations(tag character varying)	TABLE(integer, timestamp with time zone)	Return table with all combinations (type_id, timestamp) that are ready to
source_data_ready(type materialization.type, timestamp timestamp with time zone, max_modified timestamp with time zone)	boolean
tag(tag_name character varying, type_id integer)	materialization.type_tag_link	Add tag with name tag_name to materialization type with id type_id.
tag(tag_name character varying, materialization.type)	materialization.type	Add tag with name tag_name to materialization type. The tag must already exist.
to_char(materialization.type)	text
untag(materialization.type)	materialization.type	Remove all tags from the materialization
update_modified_state()	integer
update_state()	text

add_missing_trends(src trend.trendstore, dst trend.trendstore) -> bigint¶

returns: bigint

Defines a new materialization with the convention that the datasource of the source trendstore should start with a ‘v’ for views and that the destination trendstore has the same properties except for a datasource with a name without the leading ‘v’. A new trendstore and datasource are created if they do not exist.

define(trend.view) -> materialization.type¶

materialize(materialization.type, timestamp timestamp with time zone) -> materialization.materialization_result¶

returns: materialization.materialization_result

materialize(id integer, timestamp timestamp with time zone) -> materialization.materialization_result¶

returns: materialization.materialization_result

missing_columns(src trend.trendstore, dst trend.trendstore) -> TABLE(character varying, character varying)¶

Remove data (partitions) resulting from this materialization and the corresponding state records, so materialization for all timestamps can be done again

runnable(materialization.type, materialization.state) -> boolean¶

returns: boolean

runnable(type materialization.type, timestamp timestamp with time zone, max_modified timestamp with time zone) -> boolean¶

returns: boolean

runnable_materializations(tag character varying) -> TABLE(integer, timestamp with time zone)¶

returns: TABLE(integer, timestamp with time zone)

Return table with all combinations (type_id, timestamp) that are ready to run. This includes the check between the master and slave states.

source_data_ready(type materialization.type, timestamp timestamp with time zone, max_modified timestamp with time zone) -> boolean¶

returns: boolean

tag(tag_name character varying, type_id integer) -> materialization.type_tag_link¶

returns: materialization.type_tag_link

Add tag with name tag_name to materialization type with id type_id. The tag must already exist.

tag(tag_name character varying, materialization.type) -> materialization.type¶

returns: materialization.type

Add tag with name tag_name to materialization type. The tag must already exist.

to_char(materialization.type) -> text¶

returns: text

untag(materialization.type) -> materialization.type¶

returns: materialization.type

Remove all tags from the materialization

update_modified_state() -> integer¶

returns: integer

update_state() -> text¶

returns: text

notification¶

Stores information of events that can occur at irregular intervals, but still have a fixed, known format.

Types¶

attr_def¶

Name	Type	Description
name	char[]
data_type	char[]

Tables¶

attribute¶

Describes attributes of notificationstores. An attribute of a notificationstore is an attribute that each notification stored in that notificationstore has. An attribute corresponds directly to a column in the main notificationstore table

Name	Type	Description
notificationstore_id	integer
name	char[]
data_type	char[]
description	character varying
id	integer

notificationsetstore¶

Describes notificationsetstores. A notificationsetstore can hold information over sets of notifications that are related to each other.

Name	Type	Description
name	char[]
notificationstore_id	integer
id	integer

notificationstore¶

Describes notificationstores. Each notificationstore maps to a set of tables and functions that can store and manage notifications of a certain type. These corresponding tables and functions are created automatically for each notificationstore. Because each notificationstore maps one-on-one to a datasource, the name of the notificationstore is the same as that of the datasource. Use the create_notificationstore function to create new notificationstores.

Name	Type	Description
datasource_id	integer
version	integer
id	integer

setattribute¶

Describes attributes of notificationsetstores. A setattribute of a notificationsetstore is an attribute that each notification set has. A setattribute corresponds directly to a column in the main notificationsetstore table.

Name	Type	Description
notificationsetstore_id	integer
name	char[]
data_type	char[]
description	character varying
id	integer

Views¶

Functions¶

Name	Return Type	Description
action(anyelement, text)	anyelement
add_attribute_column_sql(char[], notification.attribute)	text
add_staging_attribute_column_sql(notification.attribute)	text
cleanup_on_datasource_delete()	trigger
column_exists(schema_name char[], table_name char[], column_name char[])	boolean
column_exists(table_name char[], column_name char[])	boolean
create_attribute(notification.notificationstore, char[], char[])	notification.attribute
create_attribute_column(notification.attribute)	notification.attribute
create_attribute_column_on_insert()	trigger
create_notificationsetstore(name char[], notificationstore_id integer)	notification.notificationsetstore
create_notificationsetstore(name char[], notification.notificationstore)	notification.notificationsetstore
create_notificationstore(datasource_id integer)	notification.notificationstore
create_notificationstore(datasource_name text)	notification.notificationstore
create_notificationstore(datasource_id integer, attr_def[])	notification.notificationstore
create_notificationstore(datasource_name text, attr_def[])	notification.notificationstore
create_staging_table(notification.notificationstore)	notification.notificationstore
create_table(notification.notificationstore)	notification.notificationstore
create_table_on_insert()	trigger
define_notificationsetstore(name char[], notificationstore_id integer)	notification.notificationsetstore
drop_notificationsetstore_table_on_delete()	trigger
drop_table_on_delete()	trigger
get_attr_defs(notification.notificationstore)	notification.attr_def
get_column_type_name(namespace_name char[], table_name char[], column_name char[])	char[]
get_column_type_name(notification.notificationstore, char[])	char[]
get_notificationstore(datasource_name char[])	notification.notificationstore
init_notificationsetstore(notification.notificationsetstore)	notification.notificationsetstore
notificationstore(notification.notificationsetstore)	notification.notificationstore
staging_table_name(notification.notificationstore)	char[]
table_exists(schema_name char[], table_name char[])	boolean
table_exists(char[])	boolean
table_name(notification.notificationstore)	char[]
to_char(notification.notificationstore)	text

table_name(notification.notificationstore) -> char[]¶

returns: char[]

to_char(notification.notificationstore) -> text¶

returns: text

olap¶

Types¶

Tables¶

Views¶

Functions¶

Name	Return Type	Description

public¶

standard public schema

Types¶

_time_trial_type¶

Name	Type	Description
a_time	numeric

column_info¶

Name	Type	Description
name	char[]
data_type	text

Tables¶

Views¶

pg_all_foreign_keys¶

Name	Type	Description
fk_schema_name	char[]
fk_table_name	char[]
fk_constraint_name	char[]
fk_table_oid	oid
fk_columns	name[]
pk_schema_name	char[]
pk_table_name	char[]
pk_constraint_name	char[]
pk_table_oid	oid
pk_index_name	char[]
pk_columns	name[]
match_type	text
on_delete	text
on_update	text
is_deferrable	boolean
is_deferred	boolean

tap_funky¶

Name	Type	Description
oid	oid
schema	char[]
name	char[]
owner	char[]
args	text
returns	text
langoid	oid
is_strict	boolean
is_agg	boolean
is_definer	boolean
returns_set	boolean
volatility	character
is_visible	boolean

Functions¶

Name	Return Type	Description
_add(text, integer, text)	integer
_add(text, integer)	integer
_agg(char[], char[], name[])	boolean
_agg(char[], char[])	boolean
_agg(char[], name[])	boolean
_agg(char[])	boolean
_alike(boolean, anyelement, text, text)	text
_are(text, name[], name[], text)	text
_areni(text, text[], text[], text)	text
_assets_are(text, text[], text[], text)	text
_cast_exists(char[], char[], char[], char[])	boolean
_cast_exists(char[], char[], char[])	boolean
_cast_exists(char[], char[])	boolean
_cdi(char[], char[], char[], anyelement, text)	text
_cdi(char[], char[], anyelement, text)	text
_cdi(char[], char[], anyelement)	text
_cexists(char[], char[], char[])	boolean
_cexists(char[], char[])	boolean
_ckeys(char[], char[], character)	name[]
_ckeys(char[], character)	name[]
_cleanup()	boolean
_cmp_types(oid, char[])	boolean
_col_is_null(char[], char[], char[], text, boolean)	text
_col_is_null(char[], char[], text, boolean)	text
_constraint(char[], char[], character, name[], text, text)	text
_constraint(char[], character, name[], text, text)	text
_contract_on(text)	“char”
_currtest()	integer
_db_privs()	name[]
_def_is(text, text, anyelement, text)	text
_definer(char[], char[], name[])	boolean
_definer(char[], char[])	boolean
_definer(char[], name[])	boolean
_definer(char[])	boolean
_dexists(char[], char[])	boolean
_dexists(char[])	boolean
_do_ne(text, text, text, text)	text
_docomp(text, text, text, text)	text
_expand_context(character)	text
_expand_on(character)	text
_expand_vol(character)	text
_extras(character, char[], name[])	name[]
_extras(character, name[])	name[]
_finish(integer, integer, integer)	text
_fkexists(char[], char[], name[])	boolean
_fkexists(char[], name[])	boolean
_fprivs_are(text, char[], name[], text)	text
_func_compare(char[], char[], name[], anyelement, anyelement, text)	text
_func_compare(char[], char[], name[], boolean, text)	text
_func_compare(char[], char[], anyelement, anyelement, text)	text
_func_compare(char[], char[], boolean, text)	text
_get(text)	integer
_get_ac_privs(char[], text)	text[]
_get_col_ns_type(char[], char[], char[])	text
_get_col_privs(char[], text, char[])	text[]
_get_col_type(char[], char[], char[])	text
_get_col_type(char[], char[])	text
_get_context(char[], char[])	“char”
_get_db_owner(char[])	char[]
_get_db_privs(char[], text)	text[]
_get_dtype(char[], text, boolean)	text
_get_dtype(char[])	text
_get_fdw_privs(char[], text)	text[]
_get_func_owner(char[], char[], name[])	char[]
_get_func_owner(char[], name[])	char[]
_get_func_privs(text, text)	text[]
_get_index_owner(char[], char[], char[])	char[]
_get_index_owner(char[], char[])	char[]
_get_lang_privs(char[], text)	text[]
_get_language_owner(char[])	char[]
_get_latest(text)	int4[]
_get_latest(text, integer)	integer
_get_note(text)	text
_get_note(integer)	text
_get_opclass_owner(char[], char[])	char[]
_get_opclass_owner(char[])	char[]
_get_rel_owner(character, char[])	char[]
_get_rel_owner(char[], char[])	char[]
_get_rel_owner(char[])	char[]
_get_rel_owner(character, char[], char[])	char[]
_get_schema_owner(char[])	char[]
_get_schema_privs(char[], text)	text[]
_get_sequence_privs(char[], text)	text[]
_get_server_privs(char[], text)	text[]
_get_table_privs(char[], text)	text[]
_get_tablespace_owner(char[])	char[]
_get_tablespaceprivs(char[], text)	text[]
_get_type_owner(char[], char[])	char[]
_get_type_owner(char[])	char[]
_got_func(char[], char[], name[])	boolean
_got_func(char[], char[])	boolean
_got_func(char[], name[])	boolean
_got_func(char[])	boolean
_grolist(char[])	oid[]
_has_def(char[], char[], char[])	boolean
_has_def(char[], char[])	boolean
_has_group(char[])	boolean
_has_role(char[])	boolean
_has_type(char[], char[], bpchar[])	boolean
_has_type(char[], bpchar[])	boolean
_has_user(char[])	boolean
_hasc(char[], char[], character)	boolean
_hasc(char[], character)	boolean
_have_index(char[], char[], char[])	boolean
_have_index(char[], char[])	boolean
_ident_array_to_string(name[], text)	text
_ikeys(char[], char[], char[])	text[]
_ikeys(char[], char[])	text[]
_is_instead(char[], char[], char[])	boolean
_is_instead(char[], char[])	boolean
_is_schema(char[])	boolean
_is_super(char[])	boolean
_is_trusted(char[])	boolean
_is_verbose()	boolean
_keys(char[], char[], character)	name[]
_keys(char[], character)	name[]
_lang(char[], char[], name[])	char[]
_lang(char[], char[])	char[]
_lang(char[], name[])	char[]
_lang(char[])	char[]
_missing(character, char[], name[])	name[]
_missing(character, name[])	name[]
_nosuch(char[], char[], name[])	text
_op_exists(char[], char[], char[], char[], char[])	boolean
_op_exists(char[], char[], char[], char[])	boolean
_op_exists(char[], char[], char[])	boolean
_opc_exists(char[], char[])	boolean
_opc_exists(char[])	boolean
_pg_sv_column_array(oid, int2[])	name[]
_pg_sv_table_accessible(oid, oid)	boolean
_pg_sv_type_array(oid[])	name[]
_query(text)	text
_quote_ident_like(text, text)	text
_refine_vol(text)	text
_relcomp(text, text, text, text)	text
_relcomp(text, anyarray, text, text)	text
_relcomp(text, text, text, text, text)	text
_relexists(char[], char[])	boolean
_relexists(char[])	boolean
_relne(text, text, text, text)	text
_relne(text, anyarray, text, text)	text
_returns(char[], char[], name[])	text
_returns(char[], char[])	text
_returns(char[], name[])	text
_returns(char[])	text
_rexists(character, char[], char[])	boolean
_rexists(character, char[])	boolean
_rule_on(char[], char[], char[])	“char”
_rule_on(char[], char[])	“char”
_runem(text[], boolean)	text
_runner(text[], text[], text[], text[], text[])	text
_set(text, integer, text)	integer
_set(text, integer)	integer
_set(integer, integer)	integer
_strict(char[], char[], name[])	boolean
_strict(char[], char[])	boolean
_strict(char[], name[])	boolean
_strict(char[])	boolean
_table_privs()	name[]
_temptable(text, text)	text
_temptable(anyarray, text)	text
_temptypes(text)	text
_time_trials(text, integer, numeric)	_time_trial_type
_tlike(boolean, text, text, text)	text
_todo()	text
_trig(char[], char[], char[])	boolean
_trig(char[], char[])	boolean
_types_are(char[], name[], text, bpchar[])	text
_types_are(name[], text, bpchar[])	text
_unalike(boolean, anyelement, text, text)	text
_vol(char[], char[], name[])	text
_vol(char[], char[])	text
_vol(char[], name[])	text
_vol(char[])	text
action(anyelement, sql text)	anyelement
action(anyelement, sql text[])	anyelement
add_array(anyarray, anyarray)	anyarray
add_result(boolean, boolean, text, text, text)	integer
alike(anyelement, text, text)	text
alike(anyelement, text)	text
any_column_privs_are(char[], char[], char[], name[], text)	text
any_column_privs_are(char[], char[], char[], name[])	text
any_column_privs_are(char[], char[], name[], text)	text
any_column_privs_are(char[], char[], name[])	text
array_sum(int4[])	bigint
array_sum(int8[])	numeric
array_sum(numeric[])	numeric
array_sum(float8[])	double precision
array_to_char(anyarray, format text)	text[]
bag_eq(text, text, text)	text
bag_eq(text, text)	text
bag_eq(text, anyarray, text)	text
bag_eq(text, anyarray)	text
bag_has(text, text, text)	text
bag_has(text, text)	text
bag_hasnt(text, text, text)	text
bag_hasnt(text, text)	text
bag_ne(text, text, text)	text
bag_ne(text, text)	text
bag_ne(text, anyarray, text)	text
bag_ne(text, anyarray)	text
can(char[], name[], text)	text
can(char[], name[])	text
can(name[], text)	text
can(name[])	text
cast_context_is(char[], char[], text, text)	text
cast_context_is(char[], char[], text)	text
casts_are(text[], text)	text
casts_are(text[])	text
check_test(text, boolean, text, text, text, boolean)	text
check_test(text, boolean, text, text, text)	text
check_test(text, boolean, text, text)	text
check_test(text, boolean, text)	text
check_test(text, boolean)	text
cmp_ok(anyelement, text, anyelement, text)	text
cmp_ok(anyelement, text, anyelement)	text
col_default_is(char[], char[], char[], anyelement, text)	text
col_default_is(char[], char[], char[], text, text)	text
col_default_is(char[], char[], anyelement, text)	text
col_default_is(char[], char[], text, text)	text
col_default_is(char[], char[], anyelement)	text
col_default_is(char[], char[], text)	text
col_has_check(char[], char[], name[], text)	text
col_has_check(char[], name[], text)	text
col_has_check(char[], name[])	text
col_has_check(char[], char[], char[], text)	text
col_has_check(char[], char[], text)	text
col_has_check(char[], char[])	text
col_has_default(char[], char[], char[], text)	text
col_has_default(char[], char[], text)	text
col_has_default(char[], char[])	text
col_hasnt_default(char[], char[], char[], text)	text
col_hasnt_default(char[], char[], text)	text
col_hasnt_default(char[], char[])	text
col_is_fk(char[], char[], name[], text)	text
col_is_fk(char[], name[], text)	text
col_is_fk(char[], name[])	text
col_is_fk(char[], char[], char[], text)	text
col_is_fk(char[], char[], text)	text
col_is_fk(char[], char[])	text
col_is_null(char[], char[], char[], text)	text
col_is_null(char[], char[], char[])	text
col_is_null(char[], char[])	text
col_is_pk(char[], char[], name[], text)	text
col_is_pk(char[], name[], text)	text
col_is_pk(char[], name[])	text
col_is_pk(char[], char[], char[], text)	text
col_is_pk(char[], char[], text)	text
col_is_pk(char[], char[])	text
col_is_unique(char[], char[], name[], text)	text
col_is_unique(char[], char[], name[])	text
col_is_unique(char[], char[], char[])	text
col_is_unique(char[], name[], text)	text
col_is_unique(char[], name[])	text
col_is_unique(char[], char[], char[], text)	text
col_is_unique(char[], char[], text)	text
col_is_unique(char[], char[])	text
col_isnt_fk(char[], char[], name[], text)	text
col_isnt_fk(char[], name[], text)	text
col_isnt_fk(char[], name[])	text
col_isnt_fk(char[], char[], char[], text)	text
col_isnt_fk(char[], char[], text)	text
col_isnt_fk(char[], char[])	text
col_isnt_pk(char[], char[], name[], text)	text
col_isnt_pk(char[], name[], text)	text
col_isnt_pk(char[], name[])	text
col_isnt_pk(char[], char[], char[], text)	text
col_isnt_pk(char[], char[], text)	text
col_isnt_pk(char[], char[])	text
col_not_null(char[], char[], char[], text)	text
col_not_null(char[], char[], text)	text
col_not_null(char[], char[])	text
col_type_is(char[], char[], char[], char[], text, text)	text
col_type_is(char[], char[], char[], char[], text)	text
col_type_is(char[], char[], char[], text, text)	text
col_type_is(char[], char[], char[], text)	text
col_type_is(char[], char[], text, text)	text
col_type_is(char[], char[], text)	text
collect_tap(text[])	RECORD()
collect_tap(varchar[])	text
column_names(namespace char[], table char[])	char[]
column_privs_are(char[], char[], char[], char[], name[], text)	text
column_privs_are(char[], char[], char[], char[], name[])	text
column_privs_are(char[], char[], char[], name[], text)	text
column_privs_are(char[], char[], char[], name[])	text
columns_are(char[], char[], name[], text)	text
columns_are(char[], char[], name[])	text
columns_are(char[], name[], text)	text
columns_are(char[], name[])	text
composite_owner_is(char[], char[], char[], text)	text
composite_owner_is(char[], char[], char[])	text
composite_owner_is(char[], char[], text)	text
composite_owner_is(char[], char[])	text
database_privs_are(char[], char[], name[], text)	text
database_privs_are(char[], char[], name[])	text
db_owner_is(char[], char[], text)	text
db_owner_is(char[], char[])	text
diag(msg text)	text
diag(msg anyelement)	text
diag(text[])	RECORD()
diag(anyarray)	RECORD()
diag_test_name(text)	text
display_oper(char[], oid)	text
divide_array(anyarray, anyelement)	anyarray
divide_array(anyarray, anyarray)	anyarray
do_tap(char[], text)	text
do_tap(char[])	text
do_tap(text)	text
do_tap()	text
doesnt_imatch(anyelement, text, text)	text
doesnt_imatch(anyelement, text)	text
doesnt_match(anyelement, text, text)	text
doesnt_match(anyelement, text)	text
domain_type_is(char[], text, char[], text, text)	text
domain_type_is(char[], text, char[], text)	text
domain_type_is(char[], text, text, text)	text
domain_type_is(char[], text, text)	text
domain_type_is(text, text, text)	text
domain_type_is(text, text)	text
domain_type_isnt(char[], text, char[], text, text)	text
domain_type_isnt(char[], text, char[], text)	text
domain_type_isnt(char[], text, text, text)	text
domain_type_isnt(char[], text, text)	text
domain_type_isnt(text, text, text)	text
domain_type_isnt(text, text)	text
domains_are(char[], name[], text)	text
domains_are(char[], name[])	text
domains_are(name[], text)	text
domains_are(name[])	text
drop_changes_view(attribute_directory.attributestore)	attribute_directory.attributestore
enum_has_labels(char[], char[], name[])	text
enum_has_labels(char[], char[], name[], text)	text
enum_has_labels(char[], name[], text)	text
enum_has_labels(char[], name[])	text
enums_are(char[], name[], text)	text
enums_are(char[], name[])	text
enums_are(name[], text)	text
enums_are(name[])	text
fail(text)	text
fail()	text
fdw_privs_are(char[], char[], name[], text)	text
fdw_privs_are(char[], char[], name[])	text
findfuncs(char[], text, text)	text[]
findfuncs(char[], text)	text[]
findfuncs(text, text)	text[]
findfuncs(text)	text[]
finish()	text
first(anyelement)	anyelement
fk_ok(char[], char[], name[], char[], char[], name[], text)	text
fk_ok(char[], name[], char[], name[], text)	text
fk_ok(char[], char[], name[], char[], char[], name[])	text
fk_ok(char[], name[], char[], name[])	text
fk_ok(char[], char[], char[], char[], char[], char[], text)	text
fk_ok(char[], char[], char[], char[], char[], text)	text
fk_ok(char[], char[], char[], char[], text)	text
fk_ok(char[], char[], char[], char[])	text
foreign_table_owner_is(char[], char[])	text
foreign_table_owner_is(char[], char[], char[], text)	text
foreign_table_owner_is(char[], char[], char[])	text
foreign_table_owner_is(char[], char[], text)	text
foreign_tables_are(char[], name[], text)	text
foreign_tables_are(name[], text)	text
foreign_tables_are(char[], name[])	text
foreign_tables_are(name[])	text
fst(anyelement, anyelement)	anyelement
function_lang_is(char[], char[], name[], char[], text)	text
function_lang_is(char[], char[], name[], char[])	text
function_lang_is(char[], char[], char[], text)	text
function_lang_is(char[], char[], char[])	text
function_lang_is(char[], name[], char[], text)	text
function_lang_is(char[], name[], char[])	text
function_lang_is(char[], char[], text)	text
function_lang_is(char[], char[])	text
function_owner_is(char[], char[], name[], char[], text)	text
function_owner_is(char[], char[], name[], char[])	text
function_owner_is(char[], name[], char[], text)	text
function_owner_is(char[], name[], char[])	text
function_privs_are(char[], char[], name[], char[], name[], text)	text
function_privs_are(char[], char[], name[], char[], name[])	text
function_privs_are(char[], name[], char[], name[], text)	text
function_privs_are(char[], name[], char[], name[])	text
function_returns(char[], char[], name[], text, text)	text
function_returns(char[], char[], name[], text)	text
function_returns(char[], char[], text, text)	text
function_returns(char[], char[], text)	text
function_returns(char[], name[], text, text)	text
function_returns(char[], name[], text)	text
function_returns(char[], text, text)	text
function_returns(char[], text)	text
functions_are(char[], name[], text)	text
functions_are(char[], name[])	text
functions_are(name[], text)	text
functions_are(name[])	text
groups_are(name[], text)	text
groups_are(name[])	text
has_cast(char[], char[], char[], char[], text)	text
has_cast(char[], char[], char[], char[])	text
has_cast(char[], char[], char[], text)	text
has_cast(char[], char[], char[])	text
has_cast(char[], char[], text)	text
has_cast(char[], char[])	text
has_check(char[], char[], text)	text
has_check(char[], text)	text
has_check(char[])	text
has_column(char[], char[], char[], text)	text
has_column(char[], char[], text)	text
has_column(char[], char[])	text
has_composite(char[], char[], text)	text
has_composite(char[], text)	text
has_composite(char[])	text
has_domain(char[], char[], text)	text
has_domain(char[], char[])	text
has_domain(char[], text)	text
has_domain(char[])	text
has_enum(char[], char[], text)	text
has_enum(char[], char[])	text
has_enum(char[], text)	text
has_enum(char[])	text
has_fk(char[], char[], text)	text
has_fk(char[], text)	text
has_fk(char[])	text
has_foreign_table(char[], char[], text)	text
has_foreign_table(char[], char[])	text
has_foreign_table(char[], text)	text
has_foreign_table(char[])	text
has_function(char[], char[], name[], text)	text
has_function(char[], char[], name[])	text
has_function(char[], char[], text)	text
has_function(char[], char[])	text
has_function(char[], name[], text)	text
has_function(char[], name[])	text
has_function(char[], text)	text
has_function(char[])	text
has_group(char[], text)	text
has_group(char[])	text
has_index(char[], char[], char[], name[], text)	text
has_index(char[], char[], char[], name[])	text
has_index(char[], char[], char[], char[], text)	text
has_index(char[], char[], char[], char[])	text
has_index(char[], char[], name[], text)	text
has_index(char[], char[], name[])	text
has_index(char[], char[], char[], text)	text
has_index(char[], char[], char[])	text
has_index(char[], char[], text)	text
has_index(char[], char[])	text
has_language(char[], text)	text
has_language(char[])	text
has_leftop(char[], char[], char[], char[], text)	text
has_leftop(char[], char[], char[], char[])	text
has_leftop(char[], char[], char[], text)	text
has_leftop(char[], char[], char[])	text
has_leftop(char[], char[], text)	text
has_leftop(char[], char[])	text
has_materialized_view(char[], char[], text)	text
has_materialized_view(char[], text)	text
has_materialized_view(char[])	text
has_opclass(char[], char[], text)	text
has_opclass(char[], char[])	text
has_opclass(char[], text)	text
has_opclass(char[])	text
has_operator(char[], char[], char[], char[], char[], text)	text
has_operator(char[], char[], char[], char[], char[])	text
has_operator(char[], char[], char[], char[], text)	text
has_operator(char[], char[], char[], char[])	text
has_operator(char[], char[], char[], text)	text
has_operator(char[], char[], char[])	text
has_pk(char[], char[], text)	text
has_pk(char[], text)	text
has_pk(char[])	text
has_relation(char[], char[], text)	text
has_relation(char[], text)	text
has_relation(char[])	text
has_rightop(char[], char[], char[], char[], text)	text
has_rightop(char[], char[], char[], char[])	text
has_rightop(char[], char[], char[], text)	text
has_rightop(char[], char[], char[])	text
has_rightop(char[], char[], text)	text
has_rightop(char[], char[])	text
has_role(char[], text)	text
has_role(char[])	text
has_rule(char[], char[], char[], text)	text
has_rule(char[], char[], char[])	text
has_rule(char[], char[], text)	text
has_rule(char[], char[])	text
has_schema(char[], text)	text
has_schema(char[])	text
has_sequence(char[], char[], text)	text
has_sequence(char[], char[])	text
has_sequence(char[], text)	text
has_sequence(char[])	text
has_table(char[], char[], text)	text
has_table(char[], char[])	text
has_table(char[], text)	text
has_table(char[])	text
has_tablespace(char[], text, text)	text
has_tablespace(char[], text)	text
has_tablespace(char[])	text
has_trigger(char[], char[], char[], text)	text
has_trigger(char[], char[], char[])	text
has_trigger(char[], char[], text)	text
has_trigger(char[], char[])	text
has_type(char[], char[], text)	text
has_type(char[], char[])	text
has_type(char[], text)	text
has_type(char[])	text
has_unique(text, text, text)	text
has_unique(text, text)	text
has_unique(text)	text
has_user(char[], text)	text
has_user(char[])	text
has_view(char[], char[], text)	text
has_view(char[], text)	text
has_view(char[])	text
hasnt_cast(char[], char[], char[], char[], text)	text
hasnt_cast(char[], char[], char[], char[])	text
hasnt_cast(char[], char[], char[], text)	text
hasnt_cast(char[], char[], char[])	text
hasnt_cast(char[], char[], text)	text
hasnt_cast(char[], char[])	text
hasnt_column(char[], char[], char[], text)	text
hasnt_column(char[], char[], text)	text
hasnt_column(char[], char[])	text
hasnt_composite(char[], char[], text)	text
hasnt_composite(char[], text)	text
hasnt_composite(char[])	text
hasnt_domain(char[], char[], text)	text
hasnt_domain(char[], char[])	text
hasnt_domain(char[], text)	text
hasnt_domain(char[])	text
hasnt_enum(char[], char[], text)	text
hasnt_enum(char[], char[])	text
hasnt_enum(char[], text)	text
hasnt_enum(char[])	text
hasnt_fk(char[], char[], text)	text
hasnt_fk(char[], text)	text
hasnt_fk(char[])	text
hasnt_foreign_table(char[], char[], text)	text
hasnt_foreign_table(char[], char[])	text
hasnt_foreign_table(char[], text)	text
hasnt_foreign_table(char[])	text
hasnt_function(char[], char[], name[], text)	text
hasnt_function(char[], char[], name[])	text
hasnt_function(char[], char[], text)	text
hasnt_function(char[], char[])	text
hasnt_function(char[], name[], text)	text
hasnt_function(char[], name[])	text
hasnt_function(char[], text)	text
hasnt_function(char[])	text
hasnt_group(char[], text)	text
hasnt_group(char[])	text
hasnt_index(char[], char[], char[], text)	text
hasnt_index(char[], char[], char[])	text
hasnt_index(char[], char[], text)	text
hasnt_index(char[], char[])	text
hasnt_language(char[])	text
hasnt_language(char[], text)	text
hasnt_materialized_view(char[], char[], text)	text
hasnt_materialized_view(char[], text)	text
hasnt_materialized_view(char[])	text
hasnt_opclass(char[], char[], text)	text
hasnt_opclass(char[], char[])	text
hasnt_opclass(char[], text)	text
hasnt_opclass(char[])	text
hasnt_pk(char[])	text
hasnt_pk(char[], char[], text)	text
hasnt_pk(char[], text)	text
hasnt_relation(char[], char[], text)	text
hasnt_relation(char[], text)	text
hasnt_relation(char[])	text
hasnt_role(char[], text)	text
hasnt_role(char[])	text
hasnt_rule(char[], char[], char[], text)	text
hasnt_rule(char[], char[], char[])	text
hasnt_rule(char[], char[], text)	text
hasnt_rule(char[], char[])	text
hasnt_schema(char[], text)	text
hasnt_schema(char[])	text
hasnt_sequence(char[], char[], text)	text
hasnt_sequence(char[], text)	text
hasnt_sequence(char[])	text
hasnt_table(char[], char[], text)	text
hasnt_table(char[], char[])	text
hasnt_table(char[], text)	text
hasnt_table(char[])	text
hasnt_tablespace(char[])	text
hasnt_tablespace(char[], text)	text
hasnt_trigger(char[], char[], char[], text)	text
hasnt_trigger(char[], char[], char[])	text
hasnt_trigger(char[], char[], text)	text
hasnt_trigger(char[], char[])	text
hasnt_type(char[], char[], text)	text
hasnt_type(char[], char[])	text
hasnt_type(char[], text)	text
hasnt_type(char[])	text
hasnt_user(char[], text)	text
hasnt_user(char[])	text
hasnt_view(char[], char[], text)	text
hasnt_view(char[], text)	text
hasnt_view(char[])	text
ialike(anyelement, text, text)	text
ialike(anyelement, text)	text
imatches(anyelement, text, text)	text
imatches(anyelement, text)	text
in_todo()	boolean
index_is_primary(char[], char[], char[], text)	text
index_is_primary(char[], char[], char[])	text
index_is_primary(char[], char[])	text
index_is_primary(char[])	text
index_is_type(char[], char[], char[], char[], text)	text
index_is_type(char[], char[], char[], char[])	text
index_is_type(char[], char[], char[])	text
index_is_type(char[], char[])	text
index_is_unique(char[], char[], char[], text)	text
index_is_unique(char[], char[], char[])	text
index_is_unique(char[], char[])	text
index_is_unique(char[])	text
index_owner_is(char[], char[], char[], char[], text)	text
index_owner_is(char[], char[], char[], char[])	text
index_owner_is(char[], char[], char[], text)	text
index_owner_is(char[], char[], char[])	text
indexes_are(char[], char[], name[], text)	text
indexes_are(char[], char[], name[])	text
indexes_are(char[], name[], text)	text
indexes_are(char[], name[])	text
integer_to_array(value integer)	int4[]
is(anyelement, anyelement, text)	text
is(anyelement, anyelement)	text
is_aggregate(char[], char[], name[], text)	text
is_aggregate(char[], char[], name[])	text
is_aggregate(char[], char[], text)	text
is_aggregate(char[], char[])	text
is_aggregate(char[], name[], text)	text
is_aggregate(char[], name[])	text
is_aggregate(char[], text)	text
is_aggregate(char[])	text
is_clustered(char[], char[], char[], text)	text
is_clustered(char[], char[], char[])	text
is_clustered(char[], char[])	text
is_clustered(char[])	text
is_definer(char[], char[], name[], text)	text
is_definer(char[], char[], name[])	text
is_definer(char[], char[], text)	text
is_definer(char[], char[])	text
is_definer(char[], name[], text)	text
is_definer(char[], name[])	text
is_definer(char[], text)	text
is_definer(char[])	text
is_empty(text, text)	text
is_empty(text)	text
is_member_of(char[], char[])	text
is_member_of(char[], name[], text)	text
is_member_of(char[], char[], text)	text
is_member_of(char[], name[])	text
is_strict(char[], char[], name[], text)	text
is_strict(char[], char[], name[])	text
is_strict(char[], char[], text)	text
is_strict(char[], char[])	text
is_strict(char[], name[], text)	text
is_strict(char[], name[])	text
is_strict(char[], text)	text
is_strict(char[])	text
is_superuser(char[], text)	text
is_superuser(char[])	text
isa_ok(anyelement, regtype, text)	text
isa_ok(anyelement, regtype)	text
isnt(anyelement, anyelement, text)	text
isnt(anyelement, anyelement)	text
isnt_empty(text, text)	text
isnt_empty(text)	text
isnt_strict(char[], char[], name[], text)	text
isnt_strict(char[], char[], name[])	text
isnt_strict(char[], char[], text)	text
isnt_strict(char[], char[])	text
isnt_strict(char[], name[], text)	text
isnt_strict(char[], name[])	text
isnt_strict(char[], text)	text
isnt_strict(char[])	text
isnt_superuser(char[], text)	text
isnt_superuser(char[])	text
language_is_trusted(char[], text)	text
language_is_trusted(char[])	text
language_owner_is(char[], char[], text)	text
language_owner_is(char[], char[])	text
language_privs_are(char[], char[], name[], text)	text
language_privs_are(char[], char[], name[])	text
languages_are(name[], text)	text
languages_are(name[])	text
last(anyelement)	anyelement
lives_ok(text, text)	text
lives_ok(text)	text
matches(anyelement, text, text)	text
matches(anyelement, text)	text
materialized_view_owner_is(char[], char[], char[], text)	text
materialized_view_owner_is(char[], char[], char[])	text
materialized_view_owner_is(char[], char[], text)	text
materialized_view_owner_is(char[], char[])	text
materialized_views_are(char[], name[], text)	text
materialized_views_are(name[], text)	text
materialized_views_are(char[], name[])	text
materialized_views_are(name[])	text
multiply_array(anyarray, anyelement)	anyarray
multiply_array(anyarray, anyarray)	anyarray
no_plan()	boolean
num_failed()	integer
ok(boolean, text)	text
ok(boolean)	text
opclass_owner_is(char[], char[], char[], text)	text
opclass_owner_is(char[], char[], char[])	text
opclass_owner_is(char[], char[], text)	text
opclass_owner_is(char[], char[])	text
opclasses_are(char[], name[], text)	text
opclasses_are(char[], name[])	text
opclasses_are(name[], text)	text
opclasses_are(name[])	text
operators_are(char[], text[], text)	text
operators_are(char[], text[])	text
operators_are(text[], text)	text
operators_are(text[])	text
os_name()	text
pass(text)	text
pass()	text
performs_ok(text, numeric, text)	text
performs_ok(text, numeric)	text
performs_within(text, numeric, numeric, integer, text)	text
performs_within(text, numeric, numeric, integer)	text
performs_within(text, numeric, numeric, text)	text
performs_within(text, numeric, numeric)	text
pg_version()	text
pg_version_num()	integer
pgtap_version()	numeric
plan(integer)	text
prorettype(oid)	oid
relation_owner_is(char[], char[], char[], text)	text
relation_owner_is(char[], char[], char[])	text
relation_owner_is(char[], char[], text)	text
relation_owner_is(char[], char[])	text
results_eq(refcursor, refcursor, text)	text
results_eq(refcursor, refcursor)	text
results_eq(text, text, text)	text
results_eq(text, text)	text
results_eq(text, anyarray, text)	text
results_eq(text, anyarray)	text
results_eq(text, refcursor, text)	text
results_eq(text, refcursor)	text
results_eq(refcursor, text, text)	text
results_eq(refcursor, text)	text
results_eq(refcursor, anyarray, text)	text
results_eq(refcursor, anyarray)	text
results_ne(refcursor, refcursor, text)	text
results_ne(refcursor, refcursor)	text
results_ne(text, text, text)	text
results_ne(text, text)	text
results_ne(text, anyarray, text)	text
results_ne(text, anyarray)	text
results_ne(text, refcursor, text)	text
results_ne(text, refcursor)	text
results_ne(refcursor, text, text)	text
results_ne(refcursor, text)	text
results_ne(refcursor, anyarray, text)	text
results_ne(refcursor, anyarray)	text
roles_are(name[], text)	text
roles_are(name[])	text
row_eq(text, anyelement, text)	text
row_eq(text, anyelement)	text
rule_is_instead(char[], char[], char[], text)	text
rule_is_instead(char[], char[], char[])	text
rule_is_instead(char[], char[], text)	text
rule_is_instead(char[], char[])	text
rule_is_on(char[], char[], char[], text, text)	text
rule_is_on(char[], char[], char[], text)	text
rule_is_on(char[], char[], text, text)	text
rule_is_on(char[], char[], text)	text
rules_are(char[], char[], name[], text)	text
rules_are(char[], char[], name[])	text
rules_are(char[], name[], text)	text
rules_are(char[], name[])	text
runtests(char[], text)	text
runtests(char[])	text
runtests(text)	text
runtests()	text
safe_division(numerator anyelement, denominator anyelement)	anyelement
schema_owner_is(char[], char[], text)	text
schema_owner_is(char[], char[])	text
schema_privs_are(char[], char[], name[], text)	text
schema_privs_are(char[], char[], name[])	text
schemas_are(name[], text)	text
schemas_are(name[])	text
sequence_owner_is(char[], char[], char[], text)	text
sequence_owner_is(char[], char[], char[])	text
sequence_owner_is(char[], char[], text)	text
sequence_owner_is(char[], char[])	text
sequence_privs_are(char[], char[], char[], name[], text)	text
sequence_privs_are(char[], char[], char[], name[])	text
sequence_privs_are(char[], char[], name[], text)	text
sequence_privs_are(char[], char[], name[])	text
sequences_are(char[], name[], text)	text
sequences_are(name[], text)	text
sequences_are(char[], name[])	text
sequences_are(name[])	text
server_privs_are(char[], char[], name[], text)	text
server_privs_are(char[], char[], name[])	text
set_eq(text, text, text)	text
set_eq(text, text)	text
set_eq(text, anyarray, text)	text
set_eq(text, anyarray)	text
set_has(text, text, text)	text
set_has(text, text)	text
set_hasnt(text, text, text)	text
set_hasnt(text, text)	text
set_ne(text, text, text)	text
set_ne(text, text)	text
set_ne(text, anyarray, text)	text
set_ne(text, anyarray)	text
skip(why text, how_many integer)	text
skip(text)	text
skip(integer, text)	text
skip(integer)	text
smallint_to_array(value smallint)	int2[]
smallint_to_timestamp_with_time_zone(smallint)	timestamp with time zone
smallint_to_timestamp_without_time_zone(smallint)	timestamp without time zone
snd(anyelement, anyelement)	anyelement
sum_array(anyarray)	anyarray
table_owner_is(char[], char[], char[], text)	text
table_owner_is(char[], char[], char[])	text
table_owner_is(char[], char[], text)	text
table_owner_is(char[], char[])	text
table_privs_are(char[], char[], char[], name[], text)	text
table_privs_are(char[], char[], char[], name[])	text
table_privs_are(char[], char[], name[], text)	text
table_privs_are(char[], char[], name[])	text
tables_are(char[], name[], text)	text
tables_are(name[], text)	text
tables_are(char[], name[])	text
tables_are(name[])	text
tablespace_owner_is(char[], char[], text)	text
tablespace_owner_is(char[], char[])	text
tablespace_privs_are(char[], char[], name[], text)	text
tablespace_privs_are(char[], char[], name[])	text
tablespaces_are(name[])	text
tablespaces_are(name[], text)	text
throws_ilike(text, text, text)	text
throws_ilike(text, text)	text
throws_imatching(text, text, text)	text
throws_imatching(text, text)	text
throws_like(text, text, text)	text
throws_like(text, text)	text
throws_matching(text, text, text)	text
throws_matching(text, text)	text
throws_ok(text, character, text, text)	text
throws_ok(text, text, text)	text
throws_ok(text, text)	text
throws_ok(text)	text
throws_ok(text, integer, text, text)	text
throws_ok(text, integer, text)	text
throws_ok(text, integer)	text
to_pdf(text)	int4[]
todo(why text, how_many integer)	boolean
todo(how_many integer, why text)	boolean
todo(why text)	boolean
todo(how_many integer)	boolean
todo_end()	boolean
todo_start(text)	boolean
todo_start()	boolean
trigger_is(char[], char[], char[], char[], char[], text)	text
trigger_is(char[], char[], char[], char[], char[])	text
trigger_is(char[], char[], char[], text)	text
trigger_is(char[], char[], char[])	text
triggers_are(char[], char[], name[], text)	text
triggers_are(char[], char[], name[])	text
triggers_are(char[], name[], text)	text
triggers_are(char[], name[])	text
type_columns(oid)	column_info
type_columns(namespace char[], type char[])	column_info
type_owner_is(char[], char[], char[], text)	text
type_owner_is(char[], char[], char[])	text
type_owner_is(char[], char[], text)	text
type_owner_is(char[], char[])	text
types_are(char[], name[], text)	text
types_are(char[], name[])	text
types_are(name[], text)	text
types_are(name[])	text
unalike(anyelement, text, text)	text
unalike(anyelement, text)	text
unialike(anyelement, text, text)	text
unialike(anyelement, text)	text
users_are(name[], text)	text
users_are(name[])	text
view_exists(char[], char[])	boolean
view_owner_is(char[], char[], char[], text)	text
view_owner_is(char[], char[], char[])	text
view_owner_is(char[], char[], text)	text
view_owner_is(char[], char[])	text
views_are(char[], name[], text)	text
views_are(name[], text)	text
views_are(char[], name[])	text
views_are(name[])	text
volatility_is(char[], char[], name[], text, text)	text
volatility_is(char[], char[], name[], text)	text
volatility_is(char[], char[], text, text)	text
volatility_is(char[], char[], text)	text
volatility_is(char[], name[], text, text)	text
volatility_is(char[], name[], text)	text
volatility_is(char[], text, text)	text
volatility_is(char[], text)	text
wal_location_to_int(text)	bigint	Convert a textual WAL location in the form of ‘1752F/CDC6E050’ into a bigint.

wal_location_to_int(text) -> bigint¶

returns: bigint

Convert a textual WAL location in the form of ‘1752F/CDC6E050’ into a bigint. Use this function to monitor slave delay on the master:

SELECT: client_addr, (public.wal_location_to_int(pg_current_xlog_location()) - public.wal_location_to_int(replay_location)) / 2^20 AS distance_mb

FROM pg_stat_replication;

relation¶

Stores directional relations between entities.

Types¶

Tables¶

all¶

Name	Type	Description
source_id	integer
target_id	integer
type_id	integer

all_materialized¶

Name	Type	Description
source_id	integer
target_id	integer
type_id	integer

group¶

Name	Type	Description
name	character varying
id	integer

self¶

Name	Type	Description
source_id	integer
target_id	integer
type_id	integer

type¶

Name	Type	Description
name	character varying
cardinality	relation.type_cardinality_enum
group_id	integer
id	integer

Views¶

dependencies¶

Name	Type	Description
type	relation.type
depth	integer

materialization_order¶

Name	Type	Description
id	integer
name	character varying
cardinality	relation.type_cardinality_enum
group_id	integer
depth	integer

Functions¶

Name	Return Type	Description
create_all_materialized(char[])	char[]
create_all_materialized_indexes(char[])	char[]
create_relation_table(name text, type_id integer)	void
create_relation_table_on_insert()	trigger
create_self_relation()	trigger
create_type(character varying)	relation.type
define(char[], text)	relation.type
define_reverse(reverse char[], original char[])	relation.type
define_reverse(reverse char[], original relation.type)	relation.type
drop_table_on_type_delete()	trigger
get_type(character varying)	relation.type
materialize_relation(type relation.type)	integer
name_to_type(character varying)	relation.type
populate_all_materialized(char[])	char[]
replace_all_materialized(char[])	char[]
set_view_permissions(relation.type)	relation.type
update(relation.type, text)	relation.type
update_all_materialized(intermediate_name char[])	char[]

relation_def¶

Types¶

Tables¶

Views¶

self¶

Name	Type	Description
source_id	integer
target_id	integer

Functions¶

Name	Return Type	Description

system¶

Types¶

job_type¶

Name	Type	Description
id	integer
type	character varying
description	character varying
size	bigint
config	text

version_tuple¶

Name	Type	Description
major	smallint
minor	smallint
patch	smallint

Tables¶

job¶

Name	Type	Description
type	character varying
description	character varying
size	bigint
started	timestamp with time zone
finished	timestamp with time zone
job_source_id	integer
created	timestamp with time zone
state	system.job_state_enum
id	integer

job_error_log¶

Name	Type	Description
job_id	integer
message	character varying

job_queue¶

Name	Type	Description
job_id	integer

job_source¶

Name	Type	Description
name	character varying
job_type	character varying
config	character varying
id	integer

setting¶

Name	Type	Description
name	text
value	text
id	integer

Views¶

Functions¶

Name	Return Type	Description
add_job_source(character varying, character varying, character varying)	integer
add_setting(name text, value text)	system.setting
create_job(type character varying, description character varying, size bigint, job_source_id integer)	integer
fail_job(job_id integer)	void
fail_job(job_id integer, message character varying)	void
finish_job(job_id integer)	void
get_job()	system.job_type
get_job_source(integer)	TABLE(character varying, character varying, character varying)
get_setting(name text)	system.setting
get_setting_value(name text)	text
get_setting_value(name text, default text)	text
remove_jobs(before timestamp with time zone)	integer
set_setting(name text, value text)	system.setting
set_version(system.version_tuple)	system.version_tuple
set_version(integer, integer, integer)	system.version_tuple
update_setting(name text, value text)	system.setting
version()	system.version_tuple
version_gtlt_version(system.version_tuple, system.version_tuple)	boolean

Name	Type	Description
name	character varying
datatype	character varying

transfer_result¶

Name	Type	Description
row_count	integer
max_modified	timestamp with time zone

trend_descr¶

Name	Type	Description
name	char[]
datatype	character varying
description	text

trend_with_type¶

Name	Type	Description
id	integer
name	character varying
data_type	character varying

upgrade_record¶

Name	Type	Description
timestamp	timestamp with time zone
number_of_rows	integer

Tables¶

attribute_to_trend¶

Name	Type	Description
attributestore_id	integer
granularity	character varying
id	integer
enabled	boolean

attribute_to_trend_state¶

Name	Type	Description
attribute_to_trend_id	integer
timestamp	timestamp with time zone
processed_modified	timestamp with time zone

modified¶

Name	Type	Description
timestamp	timestamp with time zone
table_name	character varying
start	timestamp with time zone
end	timestamp with time zone

partition¶

Name	Type	Description
table_name	char[]
trendstore_id	integer
data_start	timestamp with time zone
data_end	timestamp with time zone
version	integer

to_be_vacuumed¶

Name	Type	Description
table_name	char[]

trend¶

Name	Type	Description
name	character varying
description	character varying
id	integer

trend_tag_link¶

Name	Type	Description
trend_id	integer
tag_id	integer

trendstore¶

Name	Type	Description
entitytype_id	integer
datasource_id	integer
granularity	character varying
partition_size	integer
type	trend.storetype
version	integer
retention_period	interval
id	integer

trendstore_trend_link¶

Name	Type	Description
trendstore_id	integer
trend_id	integer

view¶

Name	Type	Description
description	character varying
trendstore_id	integer
sql	text
id	integer

view_trendstore_link¶

Name	Type	Description
view_id	integer
trendstore_id	integer

Views¶

attribute_to_trend_todo¶

Name	Type	Description
done	boolean
attribute_to_trend_id	integer
granularity	character varying
timestamp	timestamp with time zone
processed_modified	timestamp with time zone
compacted	timestamp with time zone

view_dependencies¶

Name	Type	Description
src	char[]
column_name	char[]
dst	char[]

Functions¶

Name	Return Type	Description
add_trend_to_trendstore(trendstore_obj trend.trendstore, trend trend.trend_with_type)	void
add_trend_to_trendstore(trendstore trend.trendstore, trend_name char[], data_type character varying)	trend.trend
alter_column_types(namespace_name char[], table_name char[], columns column_info[])	void
alter_view(trend.view, text)	trend.view
attribute_at_trend_ptr_table_name(trend.attribute_to_trend)	char[]
attribute_at_trend_view_name(trend.attribute_to_trend)	char[]
attribute_at_trend_view_sql(trend.attribute_to_trend)	text
attribute_at_updated(attribute_to_trend_id integer, timestamp timestamp with time zone)	timestamp with time zone
attribute_at_updated(trend.trendstore, timestamp timestamp with time zone)	timestamp with time zone
attributes_to_partition(trendstore trend.trendstore, index integer)	trend.partition
attributes_to_trend(trend.trendstore, char[])	trend.trend
attributes_to_trendstore(datasource_name character varying, entitytype_name character varying, granularity character varying)	trend.trendstore
attributes_to_view_trendstore(datasource_name character varying, entitytype_name character varying, granularity character varying)	trend.trendstore
available_timestamps(partition trend.partition)	timestamp with time zone
changes_on_datasource_update()	trigger
changes_on_partition_update()	trigger
changes_on_trend_update()	trigger
cleanup_on_datasource_delete()	trigger
cleanup_trendstore_on_delete()	trigger
clear_attribute_at_ptr(trend.attribute_to_trend, timestamp with time zone)	trend.attribute_to_trend
clear_attribute_at_ptr_sql(trend.attribute_to_trend, timestamp with time zone)	text
cluster_table_on_timestamp(name text)	void
column_exists(table_name character varying, column_name character varying)	boolean
create_attribute_at_trend_ptr_table(trend.attribute_to_trend)	trend.attribute_to_trend
create_attribute_at_trend_ptr_table_sql(trend.attribute_to_trend)	text[]
create_attribute_at_trend_view(trend.attribute_to_trend)	trend.attribute_to_trend
create_attribute_at_trend_view_sql(trend.attribute_to_trend)	text
create_attribute_at_trendstore(attribute_directory.attributestore, granularity text)	trend.attribute_to_trend
create_attribute_to_trend_view(trend.attribute_to_trend)	trend.attribute_to_trend
create_base_table_on_insert()	trigger
create_partition(trendstore trend.trendstore, index integer)	trend.partition
create_partition_column(partition_name character varying, trend_id integer, datatype character varying)	void
create_partition_table(name text)	void
create_partition_table_on_insert()	trigger
create_partition_table_v4(base_name text, name text, data_start timestamp with time zone, data_end timestamp with time zone)	void
create_staging_table(trendstore trend.trendstore)	trend.trendstore
create_staging_table_sql(trendstore trend.trendstore)	text[]
create_trend(name character varying, description character varying)	trend.trend
create_trend_for_trendstore(trendstore trend.trendstore, trend_name character varying)	trend.trend
create_trends(trend.trendstore, trend_descr[])	trend.trend
create_trendstore(datasource_name character varying, entitytype_name character varying, granularity character varying)	trend.trendstore
create_trendstore(datasource_name character varying, entitytype_name character varying, granularity character varying, type trend.storetype)	trend.trendstore
create_trendstore(datasource_name character varying, entitytype_name character varying, granularity character varying, trends trend_descr[])	trend.trendstore
create_view(trend.view)	trend.view
create_view(text)	trend.view
create_view_sql(trend.view)	text[]
create_view_trends(view trend.view)	trend.trend
datatype_order(datatype character varying)	integer
define_attribute_to_trend(attribute_directory.attributestore, granularity text)	trend.attribute_to_trend
define_trendstore(datasource_name character varying, entitytype_name character varying, granularity character varying)	trend.trendstore	Add a new trendstore record, initialize the trendstore base table, and return
define_trendstore(datasource_name character varying, entitytype_name character varying, granularity character varying, type trend.storetype)	trend.trendstore
define_view(trendstore_id integer, sql text)	trend.view
define_view(trend.trendstore, sql text)	trend.view
delete_view_trends(view trend.view)	void
drop_attribute_at_trend_ptr_table(trend.attribute_to_trend)	trend.attribute_to_trend
drop_attribute_at_trend_view(trend.attribute_to_trend)	trend.attribute_to_trend
drop_attribute_at_trend_view_sql(trend.attribute_to_trend)	text
drop_partition_table_on_delete()	trigger
drop_view(view trend.view)	trend.view
drop_view_on_delete()	trigger
generate_table_name(datasource_id integer, entitytype_id integer, granularity character varying, data_start timestamp with time zone)	text
get_attribute_to_trend(trend.trendstore)	trend.attribute_to_trend
get_column_names(table_name character varying)	varchar[]
get_default_partition_size(granularity character varying)	integer
get_dependent_view_names(table_name char[])	char[]
get_dependent_view_names(table_name char[], column_name char[])	char[]
get_dependent_view_names(table_name char[], column_names name[])	char[]
get_dependent_views(table_name char[])	trend.view
get_dependent_views(trend.trendstore)	trend.view
get_dependent_views(trendstore_id integer)	trend.view
get_dependent_views(table_name char[], column_name char[])	trend.view
get_dependent_views(table_name char[], column_names name[])	trend.view
get_index_on(character varying, character varying)	char[]
get_max_modified(trend.trendstore, timestamp with time zone)	timestamp with time zone
get_most_recent_timestamp(dest_granularity integer, ts timestamp with time zone)	timestamp with time zone
get_most_recent_timestamp(dest_granularity character varying, ts timestamp with time zone)	timestamp with time zone
get_partition(trendstore trend.trendstore, index integer)	trend.partition
get_timestamp_for(granularity integer, ts timestamp with time zone)	timestamp with time zone
get_timestamp_for(granularity character varying, ts timestamp with time zone)	timestamp with time zone
get_trend(trendstore trend.trendstore, trend_name character varying)	trend.trend
get_trends(trendstore_id integer)	trend.trend_with_type
get_trends_for_v3_trendstore(trendstore_obj trend.trendstore)	trend.trend_with_type
get_trends_for_v4_trendstore(trendstore_obj trend.trendstore)	trend.trend_with_type
get_trendstore(view trend.view)	trend.trendstore
get_trendstore(id integer)	trend.trendstore
get_trendstore(trend.attribute_to_trend)	trend.trendstore
get_trendstore_by_attributes(datasource_name character varying, entitytype_name character varying, granularity character varying)	trend.trendstore
get_view_column_names(view_name character varying)	char[]
granularity_seconds(text)	integer
granularity_to_text(granularity character varying)	text
greatest_datatype(datatype_a character varying, datatype_b character varying)	character varying
index_to_timestamp(partition_size integer, index integer)	timestamp with time zone
infer_trendstore_type(trend.trendstore)	trend.storetype
initialize_trendstore(trend.trendstore)	trend.trendstore	Create all database objects required for the trendstore to be fully functional
insert_attribute_to_trend_state(trend.attribute_to_trend, timestamp with time zone, timestamp with time zone)	trend.attribute_to_trend_state
is_integer(character varying)	boolean
link_view_dependencies(trend.view)	trend.view
mark_attribute_to_trend_as_processed(trend.attribute_to_trend, timestamp with time zone, timestamp with time zone)	trend.attribute_to_trend_state
mark_modified(table_name char[], timestamp timestamp with time zone, modified timestamp with time zone)	trend.modified
mark_modified(table_name char[], timestamp timestamp with time zone)	trend.modified
max_datatype(character varying)	character varying
modified(trend.trendstore, timestamp with time zone)	timestamp with time zone
modify_partition_column(partition_name character varying, column_name character varying, datatype character varying)	void
modify_trendstore_column(trendstore_id integer, column_name character varying, datatype character varying)	void
modify_trendstore_columns(trendstore_id integer, columns column_info[])	void
parse_granularity(character varying)	interval
partition_exists(table_name character varying)	boolean
partition_name(trendstore trend.trendstore, index integer)	char[]
partition_name(trendstore trend.trendstore, timestamp with time zone)	char[]
populate_attribute_at_ptr(trend.attribute_to_trend, timestamp with time zone)	trend.attribute_to_trend
populate_attribute_at_ptr_sql(trend.attribute_to_trend, timestamp with time zone)	text
populate_modified(partition trend.partition)	trend.modified
populate_modified(trend.trendstore)	trend.modified
populate_modified(character varying)	trend.modified
recreate_view(view trend.view)	trend.view
recreate_view(text)	trend.view
remove_trend_from_trendstore(trendstore trend.trendstore, trend_name character varying)	void
remove_trend_from_trendstore(trendstore text, trend_name character varying)	void
render_view_query(view_id integer)	text
set_trendstore_defaults()	trigger
show_trends(trend.trendstore)	trend.trend_descr
show_trends(trendstore_id integer)	trend.trend_descr
staging_table_name(trend.trendstore)	char[]
store_modified(table_name char[], timestamp timestamp with time zone, modified timestamp with time zone)	trend.modified
table_columns(namespace char[], table char[])	trend.column_info
timestamp_to_index(partition_size integer, timestamp timestamp with time zone)	integer
to_base_table_name(trendstore trend.trendstore)	text
to_char(trend.trendstore)	text
to_char(trend.view)	text
to_char(trend.attribute_to_trend)	text
to_table_name_v3(partition trend.partition)	text
to_table_name_v4(partition trend.partition)	text
to_trendstore(text)	trend.trendstore
transfer(source trend.trendstore, target trend.trendstore, timestamp timestamp with time zone, trend_names text[])	trend.transfer_result
transfer_staged(trendstore trend.trendstore)	void
trendstore_has_trend_with_name(trendstore trend.trendstore, trend_name character varying)	boolean
unlink_view_dependencies(trend.view)	trend.view
update_attribute_at_ptr(trend.attribute_to_trend, timestamp with time zone)	trend.attribute_to_trend
update_attribute_to_trend_state(trend.attribute_to_trend, timestamp with time zone, timestamp with time zone)	trend.attribute_to_trend_state
update_modified(table_name char[], timestamp timestamp with time zone, modified timestamp with time zone)	trend.modified
update_modified_column()	trigger
update_view_sql(trend.view, text)	trend.view
view_name(trend.view)	character varying

add_trend_to_trendstore(trendstore_obj trend.trendstore, trend trend.trend_with_type) -> void¶

returns: void

add_trend_to_trendstore(trendstore trend.trendstore, trend_name char[], data_type character varying) -> trend.trend¶

returns: trend.trend

alter_column_types(namespace_name char[], table_name char[], columns column_info[]) -> void¶

returns: void

alter_view(trend.view, text) -> trend.view¶

returns: trend.view

attribute_at_trend_ptr_table_name(trend.attribute_to_trend) -> char[]¶

returns: char[]

attribute_at_trend_view_name(trend.attribute_to_trend) -> char[]¶

returns: char[]

attribute_at_trend_view_sql(trend.attribute_to_trend) -> text¶

returns: text

attribute_at_updated(attribute_to_trend_id integer, timestamp timestamp with time zone) -> timestamp with time zone¶

returns: timestamp with time zone

attribute_at_updated(trend.trendstore, timestamp timestamp with time zone) -> timestamp with time zone¶

returns: timestamp with time zone

attributes_to_partition(trendstore trend.trendstore, index integer) -> trend.partition¶

returns: trend.partition

attributes_to_trend(trend.trendstore, char[]) -> trend.trend¶

returns: trend.trend

attributes_to_trendstore(datasource_name character varying, entitytype_name character varying, granularity character varying) -> trend.trendstore¶

returns: trend.trendstore

attributes_to_view_trendstore(datasource_name character varying, entitytype_name character varying, granularity character varying) -> trend.trendstore¶

returns: trend.trendstore

available_timestamps(partition trend.partition) -> SETOF timestamp with time zone¶

returns: timestamp with time zone

changes_on_datasource_update() -> trigger¶

returns: trigger

changes_on_partition_update() -> trigger¶

returns: trigger

changes_on_trend_update() -> trigger¶

returns: trigger

cleanup_on_datasource_delete() -> trigger¶

returns: trigger

cleanup_trendstore_on_delete() -> trigger¶

returns: trigger

clear_attribute_at_ptr(trend.attribute_to_trend, timestamp with time zone) -> trend.attribute_to_trend¶

returns: trend.attribute_to_trend

clear_attribute_at_ptr_sql(trend.attribute_to_trend, timestamp with time zone) -> text¶

returns: text

cluster_table_on_timestamp(name text) -> void¶

returns: void

column_exists(table_name character varying, column_name character varying) -> boolean¶

returns: boolean

create_attribute_at_trend_ptr_table(trend.attribute_to_trend) -> trend.attribute_to_trend¶

returns: trend.attribute_to_trend

create_attribute_at_trend_ptr_table_sql(trend.attribute_to_trend) -> text[]¶

returns: text[]

create_attribute_at_trend_view(trend.attribute_to_trend) -> trend.attribute_to_trend¶

returns: trend.attribute_to_trend

create_attribute_at_trend_view_sql(trend.attribute_to_trend) -> text¶

returns: text

create_attribute_at_trendstore(attribute_directory.attributestore, granularity text) -> trend.attribute_to_trend¶

returns: trend.attribute_to_trend

create_attribute_to_trend_view(trend.attribute_to_trend) -> trend.attribute_to_trend¶

returns: trend.attribute_to_trend

create_base_table_on_insert() -> trigger¶

returns: trigger

create_partition(trendstore trend.trendstore, index integer) -> trend.partition¶

returns: trend.partition

create_partition_column(partition_name character varying, trend_id integer, datatype character varying) -> void¶

returns: void

create_partition_table(name text) -> void¶

returns: void

create_partition_table_on_insert() -> trigger¶

returns: trigger

create_partition_table_v4(base_name text, name text, data_start timestamp with time zone, data_end timestamp with time zone) -> void¶

returns: void

create_staging_table(trendstore trend.trendstore) -> trend.trendstore¶

returns: trend.trendstore

create_staging_table_sql(trendstore trend.trendstore) -> text[]¶

returns: text[]

create_trend(name character varying, description character varying) -> trend.trend¶

returns: trend.trend

create_trend_for_trendstore(trendstore trend.trendstore, trend_name character varying) -> trend.trend¶

returns: trend.trend

create_trends(trend.trendstore, trend_descr[]) -> SETOF trend.trend¶

returns: trend.trend

create_trendstore(datasource_name character varying, entitytype_name character varying, granularity character varying) -> trend.trendstore¶

returns: trend.trendstore

create_trendstore(datasource_name character varying, entitytype_name character varying, granularity character varying, type trend.storetype) -> trend.trendstore¶

returns: trend.trendstore

create_trendstore(datasource_name character varying, entitytype_name character varying, granularity character varying, trends trend_descr[]) -> trend.trendstore¶

returns: trend.trendstore

create_view(trend.view) -> trend.view¶

returns: trend.view

create_view(text) -> trend.view¶

returns: trend.view

create_view_sql(trend.view) -> text[]¶

returns: text[]

create_view_trends(view trend.view) -> SETOF trend.trend¶

returns: trend.trend

datatype_order(datatype character varying) -> integer¶

returns: integer

define_attribute_to_trend(attribute_directory.attributestore, granularity text) -> trend.attribute_to_trend¶

returns: trend.attribute_to_trend

define_trendstore(datasource_name character varying, entitytype_name character varying, granularity character varying) -> trend.trendstore¶

returns: trend.trendstore

Add a new trendstore record, initialize the trendstore base table, and return the new record.

Later on, the definition and initialization will be split into separate steps, but the old mechanism still uses triggers that automatically initialize the trendstore.

define_trendstore(datasource_name character varying, entitytype_name character varying, granularity character varying, type trend.storetype) -> trend.trendstore¶

returns: trend.trendstore

define_view(trendstore_id integer, sql text) -> trend.view¶

returns: trend.view

define_view(trend.trendstore, sql text) -> trend.view¶

returns: trend.view

delete_view_trends(view trend.view) -> void¶

returns: void

drop_attribute_at_trend_ptr_table(trend.attribute_to_trend) -> trend.attribute_to_trend¶

returns: trend.attribute_to_trend

drop_attribute_at_trend_view(trend.attribute_to_trend) -> trend.attribute_to_trend¶

returns: trend.attribute_to_trend

drop_attribute_at_trend_view_sql(trend.attribute_to_trend) -> text¶

returns: text

drop_partition_table_on_delete() -> trigger¶

returns: trigger

drop_view(view trend.view) -> trend.view¶

returns: trend.view

drop_view_on_delete() -> trigger¶

returns: trigger

generate_table_name(datasource_id integer, entitytype_id integer, granularity character varying, data_start timestamp with time zone) -> text¶

returns: text

get_attribute_to_trend(trend.trendstore) -> trend.attribute_to_trend¶

returns: trend.attribute_to_trend

get_column_names(table_name character varying) -> varchar[]¶

returns: varchar[]

get_default_partition_size(granularity character varying) -> integer¶

returns: integer

get_dependent_view_names(table_name char[]) -> SETOF char[]¶

returns: char[]

get_dependent_view_names(table_name char[], column_name char[]) -> SETOF char[]¶

returns: char[]

get_dependent_view_names(table_name char[], column_names name[]) -> SETOF char[]¶

returns: char[]

get_dependent_views(table_name char[]) -> SETOF trend.view¶

returns: trend.view

get_dependent_views(trend.trendstore) -> SETOF trend.view¶

returns: trend.view

get_dependent_views(trendstore_id integer) -> SETOF trend.view¶

returns: trend.view

get_dependent_views(table_name char[], column_name char[]) -> SETOF trend.view¶

returns: trend.view

get_dependent_views(table_name char[], column_names name[]) -> SETOF trend.view¶

returns: trend.view

get_index_on(character varying, character varying) -> char[]¶

returns: char[]

get_max_modified(trend.trendstore, timestamp with time zone) -> timestamp with time zone¶

returns: timestamp with time zone

get_most_recent_timestamp(dest_granularity integer, ts timestamp with time zone) -> timestamp with time zone¶

returns: timestamp with time zone

get_most_recent_timestamp(dest_granularity character varying, ts timestamp with time zone) -> timestamp with time zone¶

returns: timestamp with time zone

get_partition(trendstore trend.trendstore, index integer) -> trend.partition¶

returns: trend.partition

get_timestamp_for(granularity integer, ts timestamp with time zone) -> timestamp with time zone¶

returns: timestamp with time zone

get_timestamp_for(granularity character varying, ts timestamp with time zone) -> timestamp with time zone¶

returns: timestamp with time zone

get_trend(trendstore trend.trendstore, trend_name character varying) -> trend.trend¶

returns: trend.trend

get_trends(trendstore_id integer) -> SETOF trend.trend_with_type¶

returns: trend.trend_with_type

get_trends_for_v3_trendstore(trendstore_obj trend.trendstore) -> SETOF trend.trend_with_type¶

returns: trend.trend_with_type

get_trends_for_v4_trendstore(trendstore_obj trend.trendstore) -> SETOF trend.trend_with_type¶

returns: trend.trend_with_type

get_trendstore(view trend.view) -> trend.trendstore¶

returns: trend.trendstore

get_trendstore(id integer) -> trend.trendstore¶

returns: trend.trendstore

get_trendstore(trend.attribute_to_trend) -> trend.trendstore¶

returns: trend.trendstore

get_trendstore_by_attributes(datasource_name character varying, entitytype_name character varying, granularity character varying) -> trend.trendstore¶

returns: trend.trendstore

get_view_column_names(view_name character varying) -> SETOF char[]¶

returns: char[]

granularity_seconds(text) -> integer¶

returns: integer

granularity_to_text(granularity character varying) -> text¶

returns: text

greatest_datatype(datatype_a character varying, datatype_b character varying) -> character varying¶

returns: character varying

index_to_timestamp(partition_size integer, index integer) -> timestamp with time zone¶

returns: timestamp with time zone

infer_trendstore_type(trend.trendstore) -> trend.storetype¶

returns: trend.storetype

initialize_trendstore(trend.trendstore) -> trend.trendstore¶

view_name(trend.view) -> character varying¶

returns: character varying

trigger¶

Types¶

kpi_def¶

Name	Type	Description
name	char[]
data_type	char[]

notification¶

Name	Type	Description
entity_id	integer
timestamp	timestamp with time zone
weight	integer
details	text

threshold_def¶

Name	Type	Description
name	char[]
data_type	char[]

Tables¶

exception_base¶

Name	Type	Description
entity_id	integer
start	timestamp with time zone
expires	timestamp with time zone
id	integer
created	timestamp with time zone

rule¶

Name	Type	Description
name	char[]
notificationstore_id	integer
granularity	interval
default_interval	interval
id	integer
enabled	boolean

rule_state¶

Name	Type	Description
rule_id	integer
timestamp	timestamp with time zone
fingerprint	text

rule_tag_link¶

Name	Type	Description
rule_id	integer
tag_id	integer

Views¶

todo¶

Name	Type	Description
rule	trigger.rule
timestamp	timestamp with time zone
modified	boolean

Functions¶

Name	Return Type	Description
add_rule(char[])	trigger.rule
cleanup_on_rule_delete()	trigger
cleanup_rule(trigger.rule)	trigger.rule
contains_null(anyarray)	boolean
create_details_type(trigger.rule, threshold_def[])	trigger.rule
create_details_type_sql(trigger.rule, threshold_def[])	text
create_dummy_default_weight(trigger.rule)	trigger.rule
create_dummy_notification_message_fn(trigger.rule)	trigger.rule
create_dummy_thresholds(trigger.rule, threshold_def[])	trigger.rule
create_exception_threshold_table(trigger.rule, threshold_def[])	trigger.rule
create_exception_threshold_table_sql(trigger.rule, threshold_def[])	text
create_exception_weight_table(trigger.rule)	trigger.rule	Create the exception weight table for specified rule.
create_fingerprint_fn(trigger.rule)	trigger.rule
create_fingerprint_fn_sql(trigger.rule, fn_sql text)	text
create_fingerprint_fn_sql(trigger.rule)	text
create_notification_fn(trigger.rule)	trigger.rule
create_notification_fn_sql(trigger.rule)	text[]
create_notification_message_fn(trigger.rule, expression text)	trigger.rule
create_notifications(rule_name char[], interval)	integer
create_notifications(rule_name char[])	integer
create_notifications(trigger.rule, notification.notificationstore, timestamp with time zone)	integer
create_notifications(trigger.rule, timestamp with time zone)	integer
create_notifications(trigger.rule, notification.notificationstore, interval)	integer
create_notifications(trigger.rule, interval)	integer
create_notifications(trigger.rule)	integer
create_notifications(rule_name char[], notificationstore_name char[], timestamp with time zone)	integer
create_notifications(rule_name char[], timestamp with time zone)	integer
create_notifications(rule_name char[], notificationstore_name char[], interval)	integer
create_notifications_classic(trigger.rule, notification.notificationstore, timestamp with time zone)	integer
create_notifications_new(trigger.rule, notification.notificationstore, timestamp with time zone)	integer
create_rule(char[], threshold_def[])	trigger.rule	Define a new rule and create accompanyning functions and views.
create_rule_fn(trigger.rule, rule_view_sql text)	trigger.rule
create_rule_fn_sql(trigger.rule, rule_view_sql text)	text[]
create_runnable_fn(trigger.rule)	trigger.rule
create_runnable_fn_sql(trigger.rule, fn_body text)	text
create_runnable_fn_sql(trigger.rule)	text
create_set_thresholds_fn(trigger.rule)	trigger.rule
create_set_thresholds_fn_sql(trigger.rule)	text
create_trigger_notificationstore(char[])	notification.notificationstore
create_with_threshold_fn(trigger.rule)	trigger.rule
define(char[])	trigger.rule
define_notification(char[], expression text)	trigger.rule
define_thresholds(trigger.rule, threshold_def[])	trigger.rule
details_type_name(trigger.rule)	char[]
drop_details_type(trigger.rule)	trigger.rule
drop_details_type_sql(trigger.rule)	text
drop_exception_threshold_table_sql(trigger.rule)	text
drop_exception_weight_table_sql(trigger.rule)	text	Return code to drop the exception weight table for specified rule.
drop_fingerprint_fn(trigger.rule)	trigger.rule
drop_fingerprint_fn_sql(trigger.rule)	text
drop_kpi_fn_sql(trigger.rule)	text
drop_notification_fn_sql(trigger.rule)	text
drop_notification_message_fn_sql(trigger.rule)	text
drop_rule_fn_sql(trigger.rule)	text
drop_runnable_fn_sql(trigger.rule)	text
drop_set_thresholds_fn_sql(trigger.rule)	text
drop_thresholds_view_sql(trigger.rule)	text
drop_weight_fn_sql(trigger.rule)	text	Return code to drop weight function for specified rule.
drop_with_threshold_fn_sql(trigger.rule)	text
exception_threshold_table_name(trigger.rule)	char[]
exception_weight_table_name(trigger.rule)	char[]
exception_weight_table_sql(trigger.rule)	text	Return code to create the exception weight table for specified rule.
fingerprint(trigger.rule, timestamp with time zone)	text
fingerprint_fn_name(trigger.rule)	char[]
function_oid(obj_schema char[], obj_name char[], signature text[])	oid
get_function_def(schema_name char[], fn_name char[])	text
get_kpi_def(trigger.rule, char[])	trigger.kpi_def
get_kpi_defs(trigger.rule)	trigger.kpi_def
get_notification_message_fn_sql(trigger.rule)	text
get_rule(char[])	trigger.rule	Return rule with specified name.
get_threshold_defs(trigger.rule)	trigger.threshold_def
get_weight_fn_sql(trigger.rule)	text	Return current implementation of the weight function for specified rule.
has_notification_function(trigger.rule)	boolean
has_thresholds(trigger.rule)	boolean	Return true if there is a view with thresholds for the specified rule
insert_state(integer, timestamp with time zone, text)	trigger.rule_state
kpi_def_arr_from_proc(oid)	kpi_def[]
kpi_def_arr_from_type(namespace char[], type char[])	kpi_def[]
kpi_fn_name(trigger.rule)	char[]
kpi_type_name(trigger.rule)	char[]
modified_to_fingerprint(timestamptz[])	text
notification_fn_name(trigger.rule)	char[]
notification_fn_sql(trigger.rule)	text
notification_message_fn_name(trigger.rule)	char[]
notification_message_fn_sql(trigger.rule, expression text)	text
notification_test_threshold_fn_sql(trigger.rule)	text
notification_threshold_test_fn_name(trigger.rule)	char[]
rule_fn_name(trigger.rule)	char[]
rule_fn_sql(trigger.rule, where_clause text)	text
runnable_fn_name(trigger.rule)	char[]
set_condition(trigger.rule, sql text)	trigger.rule
set_condition(char[], sql text)	trigger.rule
set_fingerprint(trigger.rule, fn_sql text)	trigger.rule
set_fingerprint(char[], fn_sql text)	char[]
set_runnable(trigger.rule, fn_sql text)	trigger.rule
set_state(integer, timestamp with time zone, text)	trigger.rule_state
set_state(trigger.rule, timestamp with time zone)	trigger.rule
set_thresholds(trigger.rule, exprs text)	trigger.rule
set_thresholds(char[], exprs text)	trigger.rule
set_thresholds_fn_name(trigger.rule)	char[]
set_weight(trigger.rule, expression text)	trigger.rule
set_weight(char[], expression text)	trigger.rule
setup_rule(trigger.rule, threshold_def[])	trigger.rule
tag(tag_name character varying, rule_id integer)	trigger.rule_tag_link	Add tag with name tag_name to rule with id rule_id.
tag(tag_name character varying, rule_name char[])	trigger.rule_tag_link
threshold_view_name(trigger.rule)	char[]
timestamps(trigger.rule)	timestamp with time zone
transfer_notifications_from_staging(notification.notificationstore)	integer
truncate(timestamp with time zone, interval)	timestamp with time zone
update_state(integer, timestamp with time zone, text)	trigger.rule_state
weight_fn_name(trigger.rule)	char[]
weight_fn_sql(trigger.rule, expression text)	text	Return code to create weight function based on the provided expression.
with_threshold_fn_name(trigger.rule)	char[]
with_threshold_fn_sql(trigger.rule)	text
with_threshold_fn_sql_no_thresholds(trigger.rule)	text
with_threshold_fn_sql_normal(trigger.rule)	text

returns: text

returns: text

Return code to drop weight function for specified rule.

drop_with_threshold_fn_sql(trigger.rule) -> text¶

returns: text

exception_threshold_table_name(trigger.rule) -> char[]¶

returns: char[]

exception_weight_table_name(trigger.rule) -> char[]¶

returns: char[]

exception_weight_table_sql(trigger.rule) -> text¶

Return rule with specified name.

get_threshold_defs(trigger.rule) -> SETOF trigger.threshold_def¶

returns: trigger.threshold_def

get_weight_fn_sql(trigger.rule) -> text¶

returns: text

Return current implementation of the weight function for specified rule.

has_notification_function(trigger.rule) -> boolean¶

returns: boolean

has_thresholds(trigger.rule) -> boolean¶

Add tag with name tag_name to rule with id rule_id. The tag must already exist.

tag(tag_name character varying, rule_name char[]) -> trigger.rule_tag_link¶

returns: trigger.rule_tag_link

threshold_view_name(trigger.rule) -> char[]¶

returns: char[]

timestamps(trigger.rule) -> SETOF timestamp with time zone¶

returns: timestamp with time zone

transfer_notifications_from_staging(notification.notificationstore) -> integer¶

returns: integer

truncate(timestamp with time zone, interval) -> timestamp with time zone¶

returns: timestamp with time zone

update_state(integer, timestamp with time zone, text) -> trigger.rule_state¶

returns: trigger.rule_state

weight_fn_name(trigger.rule) -> char[]¶

returns: char[]

weight_fn_sql(trigger.rule, expression text) -> text¶

returns: text

Types¶

Tables¶

Views¶

Functions¶

Name	Return Type	Description

virtual_entity¶

Types¶

Tables¶

Views¶

Functions¶

Name	Return Type	Description
update(name char[])	integer

update(name char[]) -> integer¶

returns: integer