1283
1281
v = notifications.Pool(mock.Mock())
1284
1282
samples = list(v.process_notification(NOTIFICATION_POOL_CREATE))
1285
1283
self.assertEqual(2, len(samples))
1286
self.assertEqual("pool", samples[0].name)
1284
self.assertEqual("network.services.lb.pool", samples[0].name)
1288
1286
def test_vip_create(self):
1289
1287
v = notifications.Vip(mock.Mock())
1290
1288
samples = list(v.process_notification(NOTIFICATION_VIP_CREATE))
1291
1289
self.assertEqual(2, len(samples))
1292
self.assertEqual("vip", samples[0].name)
1290
self.assertEqual("network.services.lb.vip", samples[0].name)
1294
1292
def test_member_create(self):
1295
1293
v = notifications.Member(mock.Mock())
1296
1294
samples = list(v.process_notification(NOTIFICATION_MEMBERS_CREATE))
1297
1295
self.assertEqual(2, len(samples))
1298
self.assertEqual("member", samples[0].name)
1296
self.assertEqual("network.services.lb.member", samples[0].name)
1300
1298
def test_health_monitor_create(self):
1301
1299
v = notifications.HealthMonitor(mock.Mock())
1302
1300
samples = list(v.process_notification(
1303
1301
NOTIFICATION_HEALTH_MONITORS_CREATE))
1304
1302
self.assertEqual(2, len(samples))
1305
self.assertEqual("health_monitor", samples[0].name)
1303
self.assertEqual("network.services.lb.health_monitor", samples[0].name)
1307
1305
def test_firewall_create(self):
1308
1306
v = notifications.Firewall(mock.Mock())
1309
1307
samples = list(v.process_notification(NOTIFICATION_FIREWALL_CREATE))
1310
1308
self.assertEqual(2, len(samples))
1311
self.assertEqual("firewall", samples[0].name)
1309
self.assertEqual("network.services.firewall", samples[0].name)
1313
1311
def test_vpnservice_create(self):
1314
1312
v = notifications.VPNService(mock.Mock())
1315
1313
samples = list(v.process_notification(NOTIFICATION_VPNSERVICE_CREATE))
1316
1314
self.assertEqual(2, len(samples))
1317
self.assertEqual("vpnservice", samples[0].name)
1315
self.assertEqual("network.services.vpn", samples[0].name)
1319
1317
def test_ipsec_connection_create(self):
1320
1318
v = notifications.IPSecSiteConnection(mock.Mock())
1321
1319
samples = list(v.process_notification(
1322
1320
NOTIFICATION_IPSEC_SITE_CONN_CREATE))
1323
1321
self.assertEqual(2, len(samples))
1324
self.assertEqual("ipsec_site_connection", samples[0].name)
1322
self.assertEqual("network.services.vpn.connections", samples[0].name)
1326
1324
def test_firewall_policy_create(self):
1327
1325
v = notifications.FirewallPolicy(mock.Mock())
1328
1326
samples = list(v.process_notification(
1329
1327
NOTIFICATION_FIREWALL_POLICY_CREATE))
1330
1328
self.assertEqual(2, len(samples))
1331
self.assertEqual("firewall_policy", samples[0].name)
1329
self.assertEqual("network.services.firewall.policy", samples[0].name)
1333
1331
def test_firewall_rule_create(self):
1334
1332
v = notifications.FirewallRule(mock.Mock())
1335
1333
samples = list(v.process_notification(
1336
1334
NOTIFICATION_FIREWALL_RULE_CREATE))
1337
1335
self.assertEqual(2, len(samples))
1338
self.assertEqual("firewall_rule", samples[0].name)
1336
self.assertEqual("network.services.firewall.rule", samples[0].name)
1340
1338
def test_ipsec_policy_create(self):
1341
1339
v = notifications.IPSecPolicy(mock.Mock())
1342
1340
samples = list(v.process_notification(
1343
1341
NOTIFICATION_IPSEC_POLICY_CREATE))
1344
1342
self.assertEqual(2, len(samples))
1345
self.assertEqual("ipsecpolicy", samples[0].name)
1343
self.assertEqual("network.services.vpn.ipsecpolicy", samples[0].name)
1347
1345
def test_ike_policy_create(self):
1348
1346
v = notifications.IKEPolicy(mock.Mock())
1349
1347
samples = list(v.process_notification(
1350
1348
NOTIFICATION_IKE_POLICY_CREATE))
1351
1349
self.assertEqual(2, len(samples))
1352
self.assertEqual("ikepolicy", samples[0].name)
1350
self.assertEqual("network.services.vpn.ikepolicy", samples[0].name)
1354
1352
def test_pool_update(self):
1355
1353
v = notifications.Pool(mock.Mock())
1356
1354
samples = list(v.process_notification(NOTIFICATION_POOL_UPDATE))
1357
1355
self.assertEqual(2, len(samples))
1358
self.assertEqual("pool", samples[0].name)
1356
self.assertEqual("network.services.lb.pool", samples[0].name)
1360
1358
def test_vip_update(self):
1361
1359
v = notifications.Vip(mock.Mock())
1362
1360
samples = list(v.process_notification(NOTIFICATION_VIP_UPDATE))
1363
1361
self.assertEqual(2, len(samples))
1364
self.assertEqual("vip", samples[0].name)
1362
self.assertEqual("network.services.lb.vip", samples[0].name)
1366
1364
def test_member_update(self):
1367
1365
v = notifications.Member(mock.Mock())
1368
1366
samples = list(v.process_notification(NOTIFICATION_MEMBERS_UPDATE))
1369
1367
self.assertEqual(2, len(samples))
1370
self.assertEqual("member", samples[0].name)
1368
self.assertEqual("network.services.lb.member", samples[0].name)
1372
1370
def test_health_monitor_update(self):
1373
1371
v = notifications.HealthMonitor(mock.Mock())
1374
1372
samples = list(v.process_notification(
1375
1373
NOTIFICATION_HEALTH_MONITORS_UPDATE))
1376
1374
self.assertEqual(2, len(samples))
1377
self.assertEqual("health_monitor", samples[0].name)
1375
self.assertEqual("network.services.lb.health_monitor", samples[0].name)
1379
1377
def test_firewall_update(self):
1380
1378
v = notifications.Firewall(mock.Mock())
1381
1379
samples = list(v.process_notification(NOTIFICATION_FIREWALL_UPDATE))
1382
1380
self.assertEqual(2, len(samples))
1383
self.assertEqual("firewall", samples[0].name)
1381
self.assertEqual("network.services.firewall", samples[0].name)
1385
1383
def test_vpnservice_update(self):
1386
1384
v = notifications.VPNService(mock.Mock())
1387
1385
samples = list(v.process_notification(NOTIFICATION_VPNSERVICE_UPDATE))
1388
1386
self.assertEqual(2, len(samples))
1389
self.assertEqual("vpnservice", samples[0].name)
1387
self.assertEqual("network.services.vpn", samples[0].name)
1391
1389
def test_ipsec_connection_update(self):
1392
1390
v = notifications.IPSecSiteConnection(mock.Mock())
1393
1391
samples = list(v.process_notification(
1394
1392
NOTIFICATION_IPSEC_SITE_CONN_UPDATE))
1395
1393
self.assertEqual(2, len(samples))
1396
self.assertEqual("ipsec_site_connection", samples[0].name)
1394
self.assertEqual("network.services.vpn.connections", samples[0].name)
1398
1396
def test_firewall_policy_update(self):
1399
1397
v = notifications.FirewallPolicy(mock.Mock())
1400
1398
samples = list(v.process_notification(
1401
1399
NOTIFICATION_FIREWALL_POLICY_UPDATE))
1402
1400
self.assertEqual(2, len(samples))
1403
self.assertEqual("firewall_policy", samples[0].name)
1401
self.assertEqual("network.services.firewall.policy", samples[0].name)
1405
1403
def test_firewall_rule_update(self):
1406
1404
v = notifications.FirewallRule(mock.Mock())
1407
1405
samples = list(v.process_notification(
1408
1406
NOTIFICATION_FIREWALL_RULE_UPDATE))
1409
1407
self.assertEqual(2, len(samples))
1410
self.assertEqual("firewall_rule", samples[0].name)
1408
self.assertEqual("network.services.firewall.rule", samples[0].name)
1412
1410
def test_ipsec_policy_update(self):
1413
1411
v = notifications.IPSecPolicy(mock.Mock())
1414
1412
samples = list(v.process_notification(
1415
1413
NOTIFICATION_IPSEC_POLICY_UPDATE))
1416
1414
self.assertEqual(2, len(samples))
1417
self.assertEqual("ipsecpolicy", samples[0].name)
1415
self.assertEqual("network.services.vpn.ipsecpolicy", samples[0].name)
1419
1417
def test_ike_policy_update(self):
1420
1418
v = notifications.IKEPolicy(mock.Mock())
1421
1419
samples = list(v.process_notification(
1422
1420
NOTIFICATION_IKE_POLICY_UPDATE))
1423
1421
self.assertEqual(2, len(samples))
1424
self.assertEqual("ikepolicy", samples[0].name)
1422
self.assertEqual("network.services.vpn.ikepolicy", samples[0].name)
1427
1425
class TestEventTypes(test.BaseTestCase):