src/main/resources/META-INF/sql/sqlite-schema.sql

--
-- Licensed under the Apache License, Version 2.0 (the "License");
-- you may not use this file except in compliance with the License.
-- You may obtain a copy of the License at
--
--     http://www.apache.org/licenses/LICENSE-2.0
--
-- Unless required by applicable law or agreed to in writing, software
-- distributed under the License is distributed on an "AS IS" BASIS,
-- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-- See the License for the specific language governing permissions and
-- limitations under the License.
--

CREATE TABLE IF NOT EXISTS environments (
  name varchar(256) NOT NULL,
  broker varchar(1024) NOT NULL,
  CONSTRAINT PK_name PRIMARY KEY (name),
  UNIQUE (broker)
);

CREATE TABLE IF NOT EXISTS topics_stats (
  topic_stats_id INTEGER PRIMARY KEY AUTOINCREMENT,
  environment varchar(255) NOT NULL,
  cluster varchar(255) NOT NULL,
  broker varchar(255) NOT NULL,
  tenant varchar(255) NOT NULL,
  namespace varchar(255) NOT NULL,
  bundle varchar(255) NOT NULL,
  persistent varchar(36) NOT NULL,
  topic varchar(255) NOT NULL,
  producer_count INTEGER,
  subscription_count INTEGER,
  msg_rate_in double,
  msg_throughput_in double,
  msg_rate_out double,
  msg_throughput_out double,
  average_msg_size double,
  storage_size double,
  time_stamp integer
);

CREATE TABLE IF NOT EXISTS publishers_stats (
  publisher_stats_id  INTEGER PRIMARY KEY AUTOINCREMENT,
  producer_id INTEGER,
  topic_stats_id INTEGER NOT NULL,
  producer_name varchar(255) NOT NULL,
  msg_rate_in double,
  msg_throughput_in double,
  average_msg_size double,
  address varchar(255),
  connected_since varchar(128),
  client_version varchar(36),
  metadata text,
  time_stamp integer,
  CONSTRAINT FK_publishers_stats_topic_stats_id FOREIGN KEY (topic_stats_id) References topics_stats(topic_stats_id)
);

CREATE TABLE IF NOT EXISTS replications_stats (
  replication_stats_id INTEGER PRIMARY KEY AUTOINCREMENT,
  topic_stats_id INTEGER NOT NULL,
  cluster varchar(255) NOT NULL,
  connected false,
  msg_rate_in double,
  msg_rate_out double,
  msg_rate_expired double,
  msg_throughput_in double,
  msg_throughput_out double,
  msg_rate_redeliver double,
  replication_backlog INTEGER,
  replication_delay_in_seconds integer,
  inbound_connection varchar(255),
  inbound_connected_since varchar(255),
  outbound_connection varchar(255),
  outbound_connected_since varchar(255),
  time_stamp integer,
  CONSTRAINT FK_replications_stats_topic_stats_id FOREIGN KEY (topic_stats_id) References topics_stats(topic_stats_id)
);

CREATE TABLE IF NOT EXISTS subscriptions_stats (
  subscription_stats_id INTEGER PRIMARY KEY AUTOINCREMENT,
  topic_stats_id INTEGER NOT NULL,
  subscription varchar(255) NULL,
  msg_backlog integer,
  msg_rate_expired double,
  msg_rate_out double,
  msg_throughput_out double,
  msg_rate_redeliver double,
  number_of_entries_since_first_not_acked_message integer,
  total_non_contiguous_deleted_messages_range integer,
  subscription_type varchar(16),
  blocked_subscription_on_unacked_msgs false,
  time_stamp integer,
  UNIQUE (topic_stats_id, subscription),
  CONSTRAINT FK_subscriptions_stats_topic_stats_id FOREIGN KEY (topic_stats_id) References topics_stats(topic_stats_id)
);

CREATE TABLE IF NOT EXISTS consumers_stats (
  consumer_stats_id INTEGER PRIMARY KEY AUTOINCREMENT,
  consumer varchar(255) NOT NULL,
  topic_stats_id INTEGER NOT NUll,
  replication_stats_id integer,
  subscription_stats_id integer,
  address varchar(255),
  available_permits integer,
  connected_since varchar(255),
  msg_rate_out double,
  msg_throughput_out double,
  msg_rate_redeliver double,
  client_version varchar(36),
  time_stamp integer,
  metadata text
);

CREATE TABLE IF NOT EXISTS tokens (
  token_id integer PRIMARY KEY AUTOINCREMENT,
  role varchar(256) NOT NULL,
  description varchar(128),
  token varchar(1024) NOT NULL,
  UNIQUE (role)
);