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

import { createAsyncAction} from 'typesafe-actions';
import { ActionType } from 'redux/actionType';
import {
  Broker,
  BrokerMetrics,
  Cluster,
  Topic,
  TopicConfig,
  TopicDetails,
  TopicName,
} from 'redux/interfaces';

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

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

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

export const fetchTopicListAction = createAsyncAction(
  ActionType.GET_TOPICS__REQUEST,
  ActionType.GET_TOPICS__SUCCESS,
  ActionType.GET_TOPICS__FAILURE,
)<undefined, Topic[], undefined>();

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

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

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