LogsContainer.tsx 5.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211
  1. import React, { PureComponent } from 'react';
  2. import { hot } from 'react-hot-loader';
  3. import { connect } from 'react-redux';
  4. import { DataSourceApi, Collapse, RefreshPicker } from '@grafana/ui';
  5. import {
  6. RawTimeRange,
  7. LogLevel,
  8. TimeZone,
  9. AbsoluteTimeRange,
  10. LogsModel,
  11. LogRowModel,
  12. LogsDedupStrategy,
  13. TimeRange,
  14. } from '@grafana/data';
  15. import { ExploreId, ExploreItemState } from 'app/types/explore';
  16. import { StoreState } from 'app/types';
  17. import { changeDedupStrategy, updateTimeRange } from './state/actions';
  18. import {
  19. toggleLogLevelAction,
  20. changeRefreshIntervalAction,
  21. setPausedStateAction,
  22. } from 'app/features/explore/state/actionTypes';
  23. import { deduplicatedLogsSelector, exploreItemUIStateSelector } from 'app/features/explore/state/selectors';
  24. import { getTimeZone } from '../profile/state/selectors';
  25. import { LiveLogsWithTheme } from './LiveLogs';
  26. import { Logs } from './Logs';
  27. import { LogsCrossFadeTransition } from './utils/LogsCrossFadeTransition';
  28. interface LogsContainerProps {
  29. datasourceInstance: DataSourceApi | null;
  30. exploreId: ExploreId;
  31. loading: boolean;
  32. logsHighlighterExpressions?: string[];
  33. logsResult?: LogsModel;
  34. dedupedResult?: LogsModel;
  35. onClickLabel: (key: string, value: string) => void;
  36. onStartScanning: () => void;
  37. onStopScanning: () => void;
  38. timeZone: TimeZone;
  39. scanning?: boolean;
  40. scanRange?: RawTimeRange;
  41. toggleLogLevelAction: typeof toggleLogLevelAction;
  42. changeDedupStrategy: typeof changeDedupStrategy;
  43. dedupStrategy: LogsDedupStrategy;
  44. width: number;
  45. isLive: boolean;
  46. stopLive: typeof changeRefreshIntervalAction;
  47. updateTimeRange: typeof updateTimeRange;
  48. range: TimeRange;
  49. absoluteRange: AbsoluteTimeRange;
  50. setPausedStateAction: typeof setPausedStateAction;
  51. isPaused: boolean;
  52. }
  53. export class LogsContainer extends PureComponent<LogsContainerProps> {
  54. onChangeTime = (absoluteRange: AbsoluteTimeRange) => {
  55. const { exploreId, updateTimeRange } = this.props;
  56. updateTimeRange({ exploreId, absoluteRange });
  57. };
  58. onStopLive = () => {
  59. const { exploreId } = this.props;
  60. this.onPause();
  61. this.props.stopLive({ exploreId, refreshInterval: RefreshPicker.offOption.value });
  62. };
  63. onPause = () => {
  64. const { exploreId } = this.props;
  65. this.props.setPausedStateAction({ exploreId, isPaused: true });
  66. };
  67. onResume = () => {
  68. const { exploreId } = this.props;
  69. this.props.setPausedStateAction({ exploreId, isPaused: false });
  70. };
  71. handleDedupStrategyChange = (dedupStrategy: LogsDedupStrategy) => {
  72. this.props.changeDedupStrategy(this.props.exploreId, dedupStrategy);
  73. };
  74. handleToggleLogLevel = (hiddenLogLevels: LogLevel[]) => {
  75. const { exploreId } = this.props;
  76. this.props.toggleLogLevelAction({
  77. exploreId,
  78. hiddenLogLevels,
  79. });
  80. };
  81. getLogRowContext = async (row: LogRowModel, options?: any): Promise<any> => {
  82. const { datasourceInstance } = this.props;
  83. if (datasourceInstance) {
  84. return datasourceInstance.getLogRowContext(row, options);
  85. }
  86. return [];
  87. };
  88. render() {
  89. const {
  90. loading,
  91. logsHighlighterExpressions,
  92. logsResult,
  93. dedupedResult,
  94. onClickLabel,
  95. onStartScanning,
  96. onStopScanning,
  97. absoluteRange,
  98. timeZone,
  99. scanning,
  100. range,
  101. width,
  102. isLive,
  103. } = this.props;
  104. return (
  105. <>
  106. <LogsCrossFadeTransition visible={isLive}>
  107. <Collapse label="Logs" loading={false} isOpen>
  108. <LiveLogsWithTheme
  109. logsResult={logsResult}
  110. timeZone={timeZone}
  111. stopLive={this.onStopLive}
  112. isPaused={this.props.isPaused}
  113. onPause={this.onPause}
  114. onResume={this.onResume}
  115. />
  116. </Collapse>
  117. </LogsCrossFadeTransition>
  118. <LogsCrossFadeTransition visible={!isLive}>
  119. <Collapse label="Logs" loading={loading} isOpen>
  120. <Logs
  121. dedupStrategy={this.props.dedupStrategy || LogsDedupStrategy.none}
  122. data={logsResult}
  123. dedupedData={dedupedResult}
  124. highlighterExpressions={logsHighlighterExpressions}
  125. loading={loading}
  126. onChangeTime={this.onChangeTime}
  127. onClickLabel={onClickLabel}
  128. onStartScanning={onStartScanning}
  129. onStopScanning={onStopScanning}
  130. onDedupStrategyChange={this.handleDedupStrategyChange}
  131. onToggleLogLevel={this.handleToggleLogLevel}
  132. absoluteRange={absoluteRange}
  133. timeZone={timeZone}
  134. scanning={scanning}
  135. scanRange={range.raw}
  136. width={width}
  137. getRowContext={this.getLogRowContext}
  138. />
  139. </Collapse>
  140. </LogsCrossFadeTransition>
  141. </>
  142. );
  143. }
  144. }
  145. function mapStateToProps(state: StoreState, { exploreId }: { exploreId: string }) {
  146. const explore = state.explore;
  147. // @ts-ignore
  148. const item: ExploreItemState = explore[exploreId];
  149. const {
  150. logsHighlighterExpressions,
  151. logsResult,
  152. loading,
  153. scanning,
  154. datasourceInstance,
  155. isLive,
  156. isPaused,
  157. range,
  158. absoluteRange,
  159. } = item;
  160. const { dedupStrategy } = exploreItemUIStateSelector(item);
  161. const dedupedResult = deduplicatedLogsSelector(item);
  162. const timeZone = getTimeZone(state.user);
  163. return {
  164. loading,
  165. logsHighlighterExpressions,
  166. logsResult,
  167. scanning,
  168. timeZone,
  169. dedupStrategy,
  170. dedupedResult,
  171. datasourceInstance,
  172. isLive,
  173. isPaused,
  174. range,
  175. absoluteRange,
  176. };
  177. }
  178. const mapDispatchToProps = {
  179. changeDedupStrategy,
  180. toggleLogLevelAction,
  181. stopLive: changeRefreshIntervalAction,
  182. updateTimeRange,
  183. setPausedStateAction,
  184. };
  185. export default hot(module)(
  186. connect(
  187. mapStateToProps,
  188. mapDispatchToProps
  189. )(LogsContainer)
  190. );