Merge pull request #92 from whdalsrnt/master

feat: implement alert manager APIs

Author: Jongmin Kim

src/controllers/alert-manager/alert/index.ts

@@ -0,0 +1,11 @@
+import grpcClient from '@lib/grpc-client';
+
+
+const listAlerts = async (params) => {
+    const alertManagerV1 = await grpcClient.get('alert_manager', 'v1');
+    return await alertManagerV1.Alert.list(params);
+};
+
+export {
+    listAlerts
+};

src/controllers/alert-manager/escalation-policy/index.ts

@@ -0,0 +1,11 @@
+import grpcClient from '@lib/grpc-client';
+
+
+const listEscalationPolicies = async (params) => {
+    const alertManagerV1 = await grpcClient.get('alert_manager', 'v1');
+    return await alertManagerV1.EscalationPolicy.list(params);
+};
+
+export {
+    listEscalationPolicies
+};

src/controllers/alert-manager/event-rule/index.ts

@@ -0,0 +1,11 @@
+import grpcClient from '@lib/grpc-client';
+
+
+const listEventRules = async (params) => {
+    const alertManagerV1 = await grpcClient.get('alert_manager', 'v1');
+    return await alertManagerV1.EventRule.list(params);
+};
+
+export {
+    listEventRules
+};

src/controllers/alert-manager/note/index.ts

@@ -0,0 +1,11 @@
+import grpcClient from '@lib/grpc-client';
+
+
+const listNotes = async (params) => {
+    const alertManagerV1 = await grpcClient.get('alert_manager', 'v1');
+    return await alertManagerV1.Note.list(params);
+};
+
+export {
+    listNotes
+};

src/controllers/alert-manager/notification-protocol/index.ts

@@ -0,0 +1,11 @@
+import grpcClient from '@lib/grpc-client';
+
+
+const listNotificationProtocols = async (params) => {
+    const alertManagerV1 = await grpcClient.get('alert_manager', 'v1');
+    return await alertManagerV1.NotificationProtocol.list(params);
+};
+
+export {
+    listNotificationProtocols
+};

src/controllers/alert-manager/service-channel/index.ts

@@ -0,0 +1,11 @@
+import grpcClient from '@lib/grpc-client';
+
+
+const listServiceChannels = async (params) => {
+    const alertManagerV1 = await grpcClient.get('alert_manager', 'v1');
+    return await alertManagerV1.ServiceChannel.list(params);
+};
+
+export {
+    listServiceChannels
+};

src/controllers/alert-manager/service/index.ts

@@ -0,0 +1,11 @@
+import grpcClient from '@lib/grpc-client';
+
+
+const listServices = async (params) => {
+    const alertManagerV1 = await grpcClient.get('alert_manager', 'v1');
+    return await alertManagerV1.Service.list(params);
+};
+
+export {
+    listServices
+};

src/controllers/alert-manager/user-channel/index.ts

@@ -0,0 +1,11 @@
+import grpcClient from '@lib/grpc-client';
+
+
+const listUserChannels = async (params) => {
+    const alertManagerV1 = await grpcClient.get('alert_manager', 'v1');
+    return await alertManagerV1.UserChannel.list(params);
+};
+
+export {
+    listUserChannels
+};

src/controllers/alert-manager/user-group-channel/index.ts

@@ -0,0 +1,11 @@
+import grpcClient from '@lib/grpc-client';
+
+
+const listUserGroupChannels = async (params) => {
+    const alertManagerV1 = await grpcClient.get('alert_manager', 'v1');
+    return await alertManagerV1.UserGroupChannel.list(params);
+};
+
+export {
+    listUserGroupChannels
+};

src/controllers/alert-manager/webhook/index.ts

@@ -0,0 +1,11 @@
+import grpcClient from '@lib/grpc-client';
+
+
+const listWebhooks = async (params) => {
+    const alertManagerV1 = await grpcClient.get('alert_manager', 'v1');
+    return await alertManagerV1.Webhook.list(params);
+};
+
+export {
+    listWebhooks
+};

src/lib/grpc-client/proto/plugin.proto

@@ -19,7 +19,7 @@ message PluginRequest {
   string version = 2;
   UpgradeMode upgrade_mode = 3;
   google.protobuf.Struct options = 4;
-  string schema = 5;
+  string schema_id = 5;
   google.protobuf.Struct secret_data = 6;
 }
 
@@ -35,7 +35,7 @@ message PluginInfo {
   UpgradeMode upgrade_mode = 3;
   google.protobuf.Struct options = 4;
   google.protobuf.Struct metadata = 5;
-  string schema = 6;
+  string schema_id = 6;
   string secret_id = 7;
 }
 

src/lib/grpc-client/proto/query_v2.proto

@@ -140,17 +140,13 @@ message AggregateProject {
   bool exclude_keys = 2;
 }
 
-message AggregateUnwind {
-  string path = 1;
-}
-
 message AggregateCount {
   string name = 1;
 }
 
 message StatisticsAggregate {
   oneof aggregate_alias {
-    AggregateUnwind unwind = 1;
+    Unwind unwind = 1;
     AggregateGroup group = 2;
     AggregateCount count = 3;
     google.protobuf.ListValue sort = 4;
@@ -180,7 +176,7 @@ message TimeSeriesAnalyzeQuery {
   Granularity granularity = 1;
   string start = 2;
   string end = 3;
-  repeated string group_by = 4;
+  google.protobuf.ListValue group_by = 4;
   repeated string field_group = 5;
   repeated Filter filter = 6;
   repeated Filter filter_or = 7;
@@ -189,10 +185,11 @@ message TimeSeriesAnalyzeQuery {
   google.protobuf.Struct fields = 10;
   google.protobuf.Struct select = 11;
   string keyword = 12;
+  Unwind unwind = 13;
 }
 
 message AnalyzeQuery {
-  repeated string group_by = 1;
+  google.protobuf.ListValue group_by = 1;
   repeated string field_group = 2;
   repeated Filter filter = 3;
   repeated Filter filter_or = 4;
@@ -201,6 +198,7 @@ message AnalyzeQuery {
   google.protobuf.Struct fields = 7;
   google.protobuf.Struct select = 8;
   string keyword = 9;
+  Unwind unwind = 10;
 }
 
 message ExportSearchQuery {
@@ -218,7 +216,7 @@ message ExportAnalyzeQuery {
   repeated Filter filter_or = 2;
   string keyword = 3;
   repeated Sort sort = 4;
-  repeated string group_by = 5;
+  google.protobuf.ListValue group_by = 5;
   google.protobuf.Struct fields = 6;
   google.protobuf.Struct select = 7;
   Page page = 8;

src/routes/alert-manager/alert.ts

@@ -0,0 +1,18 @@
+import express from 'express';
+import asyncHandler from 'express-async-handler';
+
+import * as alert from '@controllers/alert-manager/alert';
+
+const router = express.Router();
+
+const controllers = [
+    { url: '/list', func: alert.listAlerts }
+];
+
+controllers.forEach((config) => {
+    router.post(config.url, asyncHandler(async (req, res) => {
+        res.json(await config.func(req.body));
+    }));
+});
+
+export default router;

src/routes/alert-manager/escalation-policy.ts

@@ -0,0 +1,18 @@
+import express from 'express';
+import asyncHandler from 'express-async-handler';
+
+import * as escalationPolicy from '@controllers/alert-manager/escalation-policy';
+
+const router = express.Router();
+
+const controllers = [
+    { url: '/list', func: escalationPolicy.listEscalationPolicies }
+];
+
+controllers.forEach((config) => {
+    router.post(config.url, asyncHandler(async (req, res) => {
+        res.json(await config.func(req.body));
+    }));
+});
+
+export default router;

src/routes/alert-manager/event-rule.ts

@@ -0,0 +1,18 @@
+import express from 'express';
+import asyncHandler from 'express-async-handler';
+
+import * as eventRule from '@controllers/alert-manager/event-rule';
+
+const router = express.Router();
+
+const controllers = [
+    { url: '/list', func: eventRule.listEventRules }
+];
+
+controllers.forEach((config) => {
+    router.post(config.url, asyncHandler(async (req, res) => {
+        res.json(await config.func(req.body));
+    }));
+});
+
+export default router;

src/routes/alert-manager/index.ts

@@ -0,0 +1,27 @@
+import express from 'express';
+
+import alertRouter from './alert';
+import escalationPolicyRouter from './escalation-policy';
+import eventRuleRouter from './event-rule';
+import noteRouter from './note';
+import notificationProtocolRouter from './notification-protocol';
+import serviceRouter from './service';
+import serviceChannelRouter from './service-channel';
+import userChannelRouter from './user-channel';
+import userGroupChannelRouter from './user-group-channel';
+import webhookRouter from './webhook';
+
+const router = express.Router();
+
+router.use('/alert', alertRouter);
+router.use('/escalation-policy', escalationPolicyRouter);
+router.use('/event-rule', eventRuleRouter);
+router.use('/note', noteRouter);
+router.use('/notification-protocol', notificationProtocolRouter);
+router.use('/service', serviceRouter);
+router.use('/service-channel', serviceChannelRouter);
+router.use('/user-channel', userChannelRouter);
+router.use('/user-group-channel', userGroupChannelRouter);
+router.use('/webhook', webhookRouter);
+
+export default router;

src/routes/alert-manager/note.ts

@@ -0,0 +1,18 @@
+import express from 'express';
+import asyncHandler from 'express-async-handler';
+
+import * as note from '@controllers/alert-manager/note';
+
+const router = express.Router();
+
+const controllers = [
+    { url: '/list', func: note.listNotes }
+];
+
+controllers.forEach((config) => {
+    router.post(config.url, asyncHandler(async (req, res) => {
+        res.json(await config.func(req.body));
+    }));
+});
+
+export default router;

src/routes/alert-manager/notification-protocol.ts

@@ -0,0 +1,18 @@
+import express from 'express';
+import asyncHandler from 'express-async-handler';
+
+import * as notificationProtocol from '@controllers/alert-manager/notification-protocol';
+
+const router = express.Router();
+
+const controllers = [
+    { url: '/list', func: notificationProtocol.listNotificationProtocols }
+];
+
+controllers.forEach((config) => {
+    router.post(config.url, asyncHandler(async (req, res) => {
+        res.json(await config.func(req.body));
+    }));
+});
+
+export default router;

src/routes/alert-manager/service-channel.ts

@@ -0,0 +1,18 @@
+import express from 'express';
+import asyncHandler from 'express-async-handler';
+
+import * as serviceChannel from '@controllers/alert-manager/service-channel';
+
+const router = express.Router();
+
+const controllers = [
+    { url: '/list', func: serviceChannel.listServiceChannels }
+];
+
+controllers.forEach((config) => {
+    router.post(config.url, asyncHandler(async (req, res) => {
+        res.json(await config.func(req.body));
+    }));
+});
+
+export default router;

src/routes/alert-manager/service.ts

@@ -0,0 +1,18 @@
+import express from 'express';
+import asyncHandler from 'express-async-handler';
+
+import * as service from '@controllers/alert-manager/service';
+
+const router = express.Router();
+
+const controllers = [
+    { url: '/list', func: service.listServices }
+];
+
+controllers.forEach((config) => {
+    router.post(config.url, asyncHandler(async (req, res) => {
+        res.json(await config.func(req.body));
+    }));
+});
+
+export default router;

src/routes/alert-manager/user-channel.ts

@@ -0,0 +1,18 @@
+import express from 'express';
+import asyncHandler from 'express-async-handler';
+
+import * as userChannel from '@controllers/alert-manager/user-channel';
+
+const router = express.Router();
+
+const controllers = [
+    { url: '/list', func: userChannel.listUserChannels }
+];
+
+controllers.forEach((config) => {
+    router.post(config.url, asyncHandler(async (req, res) => {
+        res.json(await config.func(req.body));
+    }));
+});
+
+export default router;

src/routes/alert-manager/user-group-channel.ts

@@ -0,0 +1,18 @@
+import express from 'express';
+import asyncHandler from 'express-async-handler';
+
+import * as userGroupChannel from '@controllers/alert-manager/user-group-channel';
+
+const router = express.Router();
+
+const controllers = [
+    { url: '/list', func: userGroupChannel.listUserGroupChannels }
+];
+
+controllers.forEach((config) => {
+    router.post(config.url, asyncHandler(async (req, res) => {
+        res.json(await config.func(req.body));
+    }));
+});
+
+export default router;