2 FEEDID INT UNSIGNED NOT NULL PRIMARY KEY,
3 GROUPID INT(10) UNSIGNED NOT NULL DEFAULT 0,
4 NAME VARCHAR(256) NOT NULL,
5 VERSION VARCHAR(20) NULL,
6 DESCRIPTION VARCHAR(1000),
7 BUSINESS_DESCRIPTION VARCHAR(1000) DEFAULT NULL,
8 AUTH_CLASS VARCHAR(32) NOT NULL,
9 PUBLISHER VARCHAR(8) NOT NULL,
10 SELF_LINK VARCHAR(256),
11 PUBLISH_LINK VARCHAR(256),
12 SUBSCRIBE_LINK VARCHAR(256),
13 LOG_LINK VARCHAR(256),
14 DELETED BOOLEAN DEFAULT FALSE,
15 LAST_MOD TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
16 SUSPENDED BOOLEAN DEFAULT FALSE,
17 CREATED_DATE TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
18 AAF_INSTANCE VARCHAR(256)
21 CREATE TABLE FEED_ENDPOINT_IDS (
22 FEEDID INT UNSIGNED NOT NULL,
23 USERID VARCHAR(60) NOT NULL,
24 PASSWORD VARCHAR(100) NOT NULL
27 CREATE TABLE FEED_ENDPOINT_ADDRS (
28 FEEDID INT UNSIGNED NOT NULL,
29 ADDR VARCHAR(44) NOT NULL
32 CREATE TABLE SUBSCRIPTIONS (
33 SUBID INT UNSIGNED NOT NULL PRIMARY KEY,
34 FEEDID INT UNSIGNED NOT NULL,
35 GROUPID INT(10) UNSIGNED NOT NULL DEFAULT 0,
36 DELIVERY_URL VARCHAR(256),
37 FOLLOW_REDIRECTS TINYINT(1) NOT NULL DEFAULT 0,
38 DELIVERY_USER VARCHAR(60),
39 DELIVERY_PASSWORD VARCHAR(100),
40 DELIVERY_USE100 BOOLEAN DEFAULT FALSE,
41 METADATA_ONLY BOOLEAN DEFAULT FALSE,
42 SUBSCRIBER VARCHAR(8) NOT NULL,
43 SELF_LINK VARCHAR(256),
44 LOG_LINK VARCHAR(256),
45 LAST_MOD TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
46 SUSPENDED BOOLEAN DEFAULT FALSE,
47 PRIVILEGED_SUBSCRIBER BOOLEAN DEFAULT FALSE,
48 CREATED_DATE TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
49 DECOMPRESS BOOLEAN DEFAULT FALSE,
50 AAF_INSTANCE VARCHAR(256)
54 CREATE TABLE PARAMETERS (
55 KEYNAME VARCHAR(32) NOT NULL PRIMARY KEY,
56 VALUE VARCHAR(4096) NOT NULL
59 CREATE TABLE LOG_RECORDS (
60 TYPE ENUM('pub', 'del', 'exp', 'pbf', 'dlx') NOT NULL,
61 EVENT_TIME BIGINT NOT NULL, /* time of the publish request */
62 PUBLISH_ID VARCHAR(64) NOT NULL, /* unique ID assigned to this publish attempt */
63 FEEDID INT UNSIGNED NOT NULL, /* pointer to feed in FEEDS */
64 REQURI VARCHAR(256) NOT NULL, /* request URI */
65 METHOD ENUM('DELETE', 'GET', 'HEAD', 'OPTIONS', 'PUT', 'POST', 'TRACE') NOT NULL, /* HTTP method */
66 CONTENT_TYPE VARCHAR(256) NOT NULL, /* content type of published file */
67 CONTENT_LENGTH BIGINT NOT NULL, /* content length of published file */
69 FEED_FILEID VARCHAR(256), /* file ID of published file */
70 REMOTE_ADDR VARCHAR(40), /* IP address of publishing endpoint */
71 USER VARCHAR(50), /* user name of publishing endpoint */
72 STATUS SMALLINT, /* status code returned to delivering agent */
74 DELIVERY_SUBID INT UNSIGNED, /* pointer to subscription in SUBSCRIPTIONS */
75 DELIVERY_FILEID VARCHAR(256), /* file ID of file being delivered */
76 RESULT SMALLINT, /* result received from subscribing agent */
78 ATTEMPTS INT, /* deliveries attempted */
79 REASON ENUM('notRetryable', 'retriesExhausted', 'diskFull', 'other'),
81 RECORD_ID BIGINT UNSIGNED NOT NULL PRIMARY KEY, /* unique ID for this record */
82 CONTENT_LENGTH_2 BIGINT,
83 FILENAME VARCHAR(256), /* Name of the file being published on DR */
85 INDEX (FEEDID) USING BTREE,
86 INDEX (DELIVERY_SUBID) USING BTREE,
87 INDEX (RECORD_ID) USING BTREE
90 CREATE TABLE INGRESS_ROUTES (
91 SEQUENCE INT UNSIGNED NOT NULL,
92 FEEDID INT UNSIGNED NOT NULL,
95 NODESET INT UNSIGNED NOT NULL
98 CREATE TABLE EGRESS_ROUTES (
99 SUBID INT UNSIGNED NOT NULL PRIMARY KEY,
100 NODEID INT UNSIGNED NOT NULL
103 CREATE TABLE NETWORK_ROUTES (
104 FROMNODE INT UNSIGNED NOT NULL,
105 TONODE INT UNSIGNED NOT NULL,
106 VIANODE INT UNSIGNED NOT NULL
109 CREATE TABLE NODESETS (
110 SETID INT UNSIGNED NOT NULL,
111 NODEID INT UNSIGNED NOT NULL
115 NODEID INT UNSIGNED NOT NULL PRIMARY KEY,
116 NAME VARCHAR(255) NOT NULL,
117 ACTIVE BOOLEAN DEFAULT TRUE
120 CREATE TABLE GROUPS (
121 GROUPID INT UNSIGNED NOT NULL PRIMARY KEY,
122 AUTHID VARCHAR(100) NOT NULL,
123 NAME VARCHAR(50) NOT NULL,
124 DESCRIPTION VARCHAR(255),
125 CLASSIFICATION VARCHAR(20) NOT NULL,
127 LAST_MOD TIMESTAMP DEFAULT CURRENT_TIMESTAMP
130 INSERT INTO PARAMETERS VALUES
131 ('ACTIVE_POD', 'dmaap-dr-prov'),
132 ('PROV_ACTIVE_NAME', 'dmaap-dr-prov'),
134 ('PROV_NAME', 'dmaap-dr-prov'),
135 ('NODES', 'dmaap-dr-node'),
137 ('DELIVERY_INIT_RETRY_INTERVAL', '10'),
138 ('DELIVERY_MAX_AGE', '86400'),
139 ('DELIVERY_MAX_RETRY_INTERVAL', '3600'),
140 ('DELIVERY_FILE_PROCESS_INTERVAL', '600'),
141 ('DELIVERY_RETRY_RATIO', '2'),
142 ('LOGROLL_INTERVAL', '30'),
143 ('PROV_AUTH_ADDRESSES', 'dmaap-dr-prov|dmaap-dr-node'),
144 ('PROV_AUTH_SUBJECTS', ''),
145 ('PROV_MAXFEED_COUNT', '10000'),
146 ('PROV_MAXSUB_COUNT', '100000'),
147 ('PROV_REQUIRE_CERT', 'false'),
148 ('PROV_REQUIRE_SECURE', 'true'),
149 ('_INT_VALUES', 'LOGROLL_INTERVAL|PROV_MAXFEED_COUNT|PROV_MAXSUB_COUNT|DELIVERY_INIT_RETRY_INTERVAL|DELIVERY_MAX_RETRY_INTERVAL|DELIVERY_RETRY_RATIO|DELIVERY_MAX_AGE|DELIVERY_FILE_PROCESS_INTERVAL')
152 INSERT INTO GROUPS(GROUPID, AUTHID, NAME, DESCRIPTION, CLASSIFICATION, MEMBERS)
153 VALUES (1, 'Basic dXNlcjE6cGFzc3dvcmQx', 'Group1', 'First Group for testing', 'Class1', 'Member1');
155 INSERT INTO SUBSCRIPTIONS(SUBID, FEEDID, DELIVERY_URL, FOLLOW_REDIRECTS, DELIVERY_USER, DELIVERY_PASSWORD, DELIVERY_USE100, METADATA_ONLY, SUBSCRIBER, SUSPENDED, GROUPID, PRIVILEGED_SUBSCRIBER, AAF_INSTANCE, DECOMPRESS)
156 VALUES (1, 1, 'https://172.100.0.5:8080', 0, 'user1', 'password1', true, false, 'user1', false, 1, false, 'legacy', false);
158 INSERT INTO SUBSCRIPTIONS(SUBID, FEEDID, DELIVERY_URL, FOLLOW_REDIRECTS, DELIVERY_USER, DELIVERY_PASSWORD, DELIVERY_USE100, METADATA_ONLY, SUBSCRIBER, SUSPENDED, GROUPID, AAF_INSTANCE)
159 VALUES (2, 1, 'https://172.100.0.5:8080', 0, 'user2', 'password2', true, true, 'subsc2', false, 1, '*');
161 INSERT INTO SUBSCRIPTIONS(SUBID, FEEDID, DELIVERY_URL, FOLLOW_REDIRECTS, DELIVERY_USER, DELIVERY_PASSWORD, DELIVERY_USE100, METADATA_ONLY, SUBSCRIBER, SUSPENDED, GROUPID, AAF_INSTANCE)
162 VALUES (3, 1, 'https://172.100.0.5:8080', 0, 'user3', 'password3', true, true, 'subsc3', false, 1, '*');
164 INSERT INTO SUBSCRIPTIONS(SUBID, FEEDID, DELIVERY_URL, DELIVERY_USER, DELIVERY_PASSWORD, SUBSCRIBER, SELF_LINK, LOG_LINK, AAF_INSTANCE)
165 VALUES (23, 1, 'http://delivery_url', 'user1', 'somepassword', 'sub123', 'selflink', 'loglink', 'legacy');
167 INSERT INTO FEED_ENDPOINT_IDS(FEEDID, USERID, PASSWORD)
168 VALUES (1, 'USER', 'PASSWORD');
170 INSERT INTO FEED_ENDPOINT_ADDRS(FEEDID, ADDR)
171 VALUES (1, '172.0.0.1');
173 INSERT INTO FEEDS(FEEDID, GROUPID, NAME, VERSION, DESCRIPTION, BUSINESS_DESCRIPTION, AUTH_CLASS, PUBLISHER, SELF_LINK, PUBLISH_LINK, SUBSCRIBE_LINK, LOG_LINK)
174 VALUES (1, 1,'Feed1','v0.1', 'First Feed for testing', 'First Feed for testing', 'auth_class', 'pub','self_link','publish_link','subscribe_link','log_link');
176 INSERT INTO FEEDS(FEEDID, GROUPID, NAME, VERSION, DESCRIPTION, BUSINESS_DESCRIPTION, AUTH_CLASS, PUBLISHER, SELF_LINK, PUBLISH_LINK, SUBSCRIBE_LINK, LOG_LINK, AAF_INSTANCE)
177 VALUES (2, 1,'AafFeed','v0.1', 'AAF Feed for testing', 'AAF Feed for testing', 'auth_class', 'pub','self_link','publish_link','subscribe_link','log_link','*');
179 INSERT INTO FEEDS(FEEDID, GROUPID, NAME, VERSION, DESCRIPTION, BUSINESS_DESCRIPTION, AUTH_CLASS, PUBLISHER, SELF_LINK, PUBLISH_LINK, SUBSCRIBE_LINK, LOG_LINK, AAF_INSTANCE)
180 VALUES (3, 1,'DeleteableAafFeed','v0.1', 'AAF Feed3 for testing', 'AAF Feed3 for testing', 'auth_class', 'pub','self_link','publish_link','subscribe_link','log_link','*');
182 insert into INGRESS_ROUTES(SEQUENCE, FEEDID , USERID, SUBNET, NODESET)
183 VALUES (1,1,'user','172.100.0.0/25',2);
185 insert into INGRESS_ROUTES(SEQUENCE, FEEDID , USERID, SUBNET, NODESET)
186 VALUES (2,1,'user2',null,2);
188 insert into NODESETS(SETID, NODEID)
191 insert into NODESETS(SETID, NODEID)
194 insert into LOG_RECORDS(RECORD_ID,TYPE,EVENT_TIME,PUBLISH_ID,FEEDID,REQURI,METHOD,CONTENT_TYPE,CONTENT_LENGTH,FEED_FILEID,REMOTE_ADDR,USER,STATUS,DELIVERY_SUBID,DELIVERY_FILEID,RESULT,ATTEMPTS,REASON,FILENAME)
195 VALUES(1,'pub',2536159564422,'ID',1,'URL/file123','PUT','application/vnd.dmaap-dr.log-list; version=1.0',100,1,'172.0.0.8','user',204,1,1,204,0,'other','file123');
197 insert into NETWORK_ROUTES(FROMNODE, TONODE, VIANODE)
200 insert into NODES(NODEID, NAME) values
208 insert into EGRESS_ROUTES(SUBID, NODEID) values (1, 1);