kafka-ui/kafka-ui-react-app/src/redux/actions/actions.ts

import { createAsyncAction } from 'typesafe-actions';
import { TopicName, ConsumerGroupID } from 'redux/interfaces';

import {
  Cluster,
  ClusterStats,
  ClusterMetrics,
  Broker,
  BrokerMetrics,
  Topic,
  TopicDetails,
  TopicConfig,
  TopicMessage,
  ConsumerGroup,
  ConsumerGroupDetails,
  SchemaSubject,
} from 'generated-sources';

export const fetchClusterStatsAction = createAsyncAction(
  'GET_CLUSTER_STATUS__REQUEST',
  'GET_CLUSTER_STATUS__SUCCESS',
  'GET_CLUSTER_STATUS__FAILURE'
)<undefined, ClusterStats, undefined>();

export const fetchClusterMetricsAction = createAsyncAction(
  'GET_CLUSTER_METRICS__REQUEST',
  'GET_CLUSTER_METRICS__SUCCESS',
  'GET_CLUSTER_METRICS__FAILURE'
)<undefined, ClusterMetrics, undefined>();

export const fetchBrokersAction = createAsyncAction(
  'GET_BROKERS__REQUEST',
  'GET_BROKERS__SUCCESS',
  'GET_BROKERS__FAILURE'
)<undefined, Broker[], undefined>();

export const fetchBrokerMetricsAction = createAsyncAction(
  'GET_BROKER_METRICS__REQUEST',
  'GET_BROKER_METRICS__SUCCESS',
  'GET_BROKER_METRICS__FAILURE'
)<undefined, BrokerMetrics, undefined>();

export const fetchClusterListAction = createAsyncAction(
  'GET_CLUSTERS__REQUEST',
  'GET_CLUSTERS__SUCCESS',
  'GET_CLUSTERS__FAILURE'
)<undefined, Cluster[], undefined>();

export const fetchTopicsListAction = createAsyncAction(
  'GET_TOPICS__REQUEST',
  'GET_TOPICS__SUCCESS',
  'GET_TOPICS__FAILURE'
)<undefined, Topic[], undefined>();

export const fetchTopicMessagesAction = createAsyncAction(
  'GET_TOPIC_MESSAGES__REQUEST',
  'GET_TOPIC_MESSAGES__SUCCESS',
  'GET_TOPIC_MESSAGES__FAILURE'
)<undefined, TopicMessage[], undefined>();

export const fetchTopicDetailsAction = createAsyncAction(
  'GET_TOPIC_DETAILS__REQUEST',
  'GET_TOPIC_DETAILS__SUCCESS',
  'GET_TOPIC_DETAILS__FAILURE'
)<undefined, { topicName: TopicName; details: TopicDetails }, undefined>();

export const fetchTopicConfigAction = createAsyncAction(
  'GET_TOPIC_CONFIG__REQUEST',
  'GET_TOPIC_CONFIG__SUCCESS',
  'GET_TOPIC_CONFIG__FAILURE'
)<undefined, { topicName: TopicName; config: TopicConfig[] }, undefined>();

export const createTopicAction = createAsyncAction(
  'POST_TOPIC__REQUEST',
  'POST_TOPIC__SUCCESS',
  'POST_TOPIC__FAILURE'
)<undefined, Topic, undefined>();

export const updateTopicAction = createAsyncAction(
  'PATCH_TOPIC__REQUEST',
  'PATCH_TOPIC__SUCCESS',
  'PATCH_TOPIC__FAILURE'
)<undefined, Topic, undefined>();

export const fetchConsumerGroupsAction = createAsyncAction(
  'GET_CONSUMER_GROUPS__REQUEST',
  'GET_CONSUMER_GROUPS__SUCCESS',
  'GET_CONSUMER_GROUPS__FAILURE'
)<undefined, ConsumerGroup[], undefined>();

export const fetchConsumerGroupDetailsAction = createAsyncAction(
  'GET_CONSUMER_GROUP_DETAILS__REQUEST',
  'GET_CONSUMER_GROUP_DETAILS__SUCCESS',
  'GET_CONSUMER_GROUP_DETAILS__FAILURE'
)<
  undefined,
  { consumerGroupID: ConsumerGroupID; details: ConsumerGroupDetails },
  undefined
>();

export const fetchSchemasByClusterNameAction = createAsyncAction(
  'GET_CLUSTER_SCHEMAS__REQUEST',
  'GET_CLUSTER_SCHEMAS__SUCCESS',
  'GET_CLUSTER_SCHEMAS__FAILURE'
)<undefined, SchemaSubject[], undefined>();