diff --git a/api/mocks/topics.js b/api/mocks/topics.js new file mode 100644 index 0000000000..ae05127fd1 --- /dev/null +++ b/api/mocks/topics.js @@ -0,0 +1,224 @@ +module.exports = { + 'wrYGf-csNgiGdK7B_ADF7Z': [ + { + name: 'docker-connect-status', + internal: false, + partitions: [ + { + partition: 0, + leader: 1, + replicas: [ + { + broker: 1, + leader: true, + inSync: false, + } + ] + }, + { + partition: 1, + leader: 1, + replicas: [ + { + broker: 1, + leader: true, + inSync: true, + } + ] + }, + { + partition: 2, + leader: 1, + replicas: [ + { + broker: 1, + leader: true, + inSync: true, + } + ] + }, + { + partition: 3, + leader: 1, + replicas: [ + { + broker: 1, + leader: true, + inSync: true, + } + ] + }, + { + partition: 4, + leader: 1, + replicas: [ + { + broker: 1, + leader: true, + inSync: true, + } + ] + }, + ], + }, + { + name: 'dsadsda', + internal: false, + partitions: [ + { + partition: 0, + leader: 1, + replicas: [ + { + broker: 1, + leader: true, + inSync: true, + } + ] + } + ], + }, + { + name: 'my-topic', + internal: false, + partitions: [ + { + partition: 0, + leader: 1, + replicas: [ + { + broker: 1, + leader: true, + inSync: true, + } + ] + }, + ], + }, + { + name: 'docker-connect-offsets', + internal: false, + partitions: [ + { + partition: 0, + leader: 1, + replicas: [ + { + broker: 1, + leader: true, + inSync: true, + }, + ], + }, + { + partition: 1, + leader: 1, + replicas: [ + { + broker: 1, + leader: true, + inSync: true, + }, + ], + }, + { + partition: 2, + leader: 1, + replicas: [ + { + broker: 1, + leader: true, + inSync: true, + }, + ], + }, + { + partition: 3, + leader: 1, + replicas: [ + { + broker: 1, + leader: true, + inSync: true, + }, + ], + }, + { + partition: 4, + leader: 1, + replicas: [ + { + broker: 1, + leader: true, + inSync: true, + }, + ], + }, + { + partition: 5, + leader: 1, + replicas: [ + { + broker: 1, + leader: true, + inSync: true, + } + ], + }, + ], + }, + ], + 'dMMQx-WRh77BKYas_g2ZTz': [ + { + name: '_schemas', + internal: false, + partitions: [ + { + partition: 0, + leader: 1, + replicas: [ + { + broker: 1, + leader: true, + inSync: true, + } + ] + }, + ], + }, + { + name: 'docker-connect-configs', + internal: false, + partitions: [ + { + partition: 0, + leader: 1, + replicas: [ + { + broker: 1, + leader: true, + inSync: true, + } + ] + }, + ], + }, + { + name: '_kafka-ui-test-topic-monitoring-message-rekey-store', + internal: false, + partitions: [ + { + partition: 0, + leader: 1, + replicas: [ + { + broker: 1, + leader: true, + inSync: true, + } + ] + }, + ], + }, + ], +} diff --git a/api/services/brokers.js b/api/services/brokers.js new file mode 100644 index 0000000000..eba0c17573 --- /dev/null +++ b/api/services/brokers.js @@ -0,0 +1,11 @@ +'use strict' + +module.exports = function (fastify, opts, next) { + fastify.get('/brokers', function (request, reply) { + reply.send([ + + ]); + }); + + next(); +} diff --git a/api/services/clasters.js b/api/services/clusters.js similarity index 69% rename from api/services/clasters.js rename to api/services/clusters.js index 6d3bd4bfa4..2c10f69c85 100644 --- a/api/services/clasters.js +++ b/api/services/clusters.js @@ -4,17 +4,17 @@ module.exports = function (fastify, opts, next) { fastify.get('/clusters', function (request, reply) { reply.send([ { - clusterId: 'wrYGf-csNgiGdK7B_ADF7Z', - displayName: 'fake.cluster', - default: true, + id: 'wrYGf-csNgiGdK7B_ADF7Z', + name: 'fake.cluster', + defaultCluster: true, status: 'online', brokerCount: 1, onlinePartitionCount: 20, topicCount: 2, }, { - clusterId: 'dMMQx-WRh77BKYas_g2ZTz', - displayName: 'kafka-ui.cluster', + id: 'dMMQx-WRh77BKYas_g2ZTz', + name: 'kafka-ui.cluster', default: false, status: 'offline', brokerCount: 0, diff --git a/api/services/topics.js b/api/services/topics.js new file mode 100644 index 0000000000..857cb46291 --- /dev/null +++ b/api/services/topics.js @@ -0,0 +1,11 @@ +'use strict' + +const topics = require('../mocks/topics'); + +module.exports = function (fastify, opts, next) { + fastify.get('/clusters/:clusterId/topics', function (request, reply) { + reply.send(topics[request.params.clusterId]); + }); + + next(); +}