gfunc.ts 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173
  1. import _ from "lodash";
  2. import $ from "jquery";
  3. import {isVersionGtOrEq} from "app/core/utils/version";
  4. var index = [];
  5. var categories = {
  6. Combine: [],
  7. Transform: [],
  8. Calculate: [],
  9. Filter: [],
  10. Special: []
  11. };
  12. function addFuncDef(funcDef) {
  13. funcDef.params = funcDef.params || [];
  14. funcDef.defaultParams = funcDef.defaultParams || [];
  15. if (funcDef.category) {
  16. funcDef.category.push(funcDef);
  17. }
  18. index[funcDef.name] = funcDef;
  19. index[funcDef.shortName || funcDef.name] = funcDef;
  20. }
  21. var optionalSeriesRefArgs = [
  22. { name: "other", type: "value_or_series", optional: true },
  23. { name: "other", type: "value_or_series", optional: true },
  24. { name: "other", type: "value_or_series", optional: true },
  25. { name: "other", type: "value_or_series", optional: true },
  26. { name: "other", type: "value_or_series", optional: true }
  27. ];
  28. addFuncDef({
  29. name: "scaleToSeconds",
  30. category: categories.Transform,
  31. params: [{ name: "seconds", type: "int" }],
  32. defaultParams: [1]
  33. });
  34. addFuncDef({
  35. name: "perSecond",
  36. category: categories.Transform,
  37. params: [{ name: "max value", type: "int", optional: true }],
  38. defaultParams: []
  39. });
  40. addFuncDef({
  41. name: "holtWintersForecast",
  42. category: categories.Calculate
  43. });
  44. addFuncDef({
  45. name: "holtWintersConfidenceBands",
  46. category: categories.Calculate,
  47. params: [{ name: "delta", type: "int" }],
  48. defaultParams: [3]
  49. });
  50. addFuncDef({
  51. name: "holtWintersAberration",
  52. category: categories.Calculate,
  53. params: [{ name: "delta", type: "int" }],
  54. defaultParams: [3]
  55. });
  56. addFuncDef({
  57. name: "nPercentile",
  58. category: categories.Calculate,
  59. params: [{ name: "Nth percentile", type: "int" }],
  60. defaultParams: [95]
  61. });
  62. addFuncDef({
  63. name: "diffSeries",
  64. params: optionalSeriesRefArgs,
  65. defaultParams: ["#A"],
  66. category: categories.Calculate
  67. });
  68. addFuncDef({
  69. name: "stddevSeries",
  70. params: optionalSeriesRefArgs,
  71. defaultParams: [""],
  72. category: categories.Calculate
  73. });
  74. addFuncDef({
  75. name: "divideSeries",
  76. params: optionalSeriesRefArgs,
  77. defaultParams: ["#A"],
  78. category: categories.Calculate
  79. });
  80. addFuncDef({
  81. name: "multiplySeries",
  82. params: optionalSeriesRefArgs,
  83. defaultParams: ["#A"],
  84. category: categories.Calculate
  85. });
  86. addFuncDef({
  87. name: "asPercent",
  88. params: optionalSeriesRefArgs,
  89. defaultParams: ["#A"],
  90. category: categories.Calculate
  91. });
  92. addFuncDef({
  93. name: "group",
  94. params: optionalSeriesRefArgs,
  95. defaultParams: ["#A", "#B"],
  96. category: categories.Combine
  97. });
  98. addFuncDef({
  99. name: "sumSeries",
  100. shortName: "sum",
  101. category: categories.Combine,
  102. params: optionalSeriesRefArgs,
  103. defaultParams: [""]
  104. });
  105. addFuncDef({
  106. name: "averageSeries",
  107. shortName: "avg",
  108. category: categories.Combine,
  109. params: optionalSeriesRefArgs,
  110. defaultParams: [""]
  111. });
  112. addFuncDef({
  113. name: "rangeOfSeries",
  114. category: categories.Combine
  115. });
  116. addFuncDef({
  117. name: "percentileOfSeries",
  118. category: categories.Combine,
  119. params: [
  120. { name: "n", type: "int" },
  121. { name: "interpolate", type: "boolean", options: ["true", "false"] }
  122. ],
  123. defaultParams: [95, "false"]
  124. });
  125. addFuncDef({
  126. name: "sumSeriesWithWildcards",
  127. category: categories.Combine,
  128. params: [
  129. { name: "node", type: "int" },
  130. { name: "node", type: "int", optional: true },
  131. { name: "node", type: "int", optional: true },
  132. { name: "node", type: "int", optional: true }
  133. ],
  134. defaultParams: [3]
  135. });
  136. addFuncDef({
  137. name: "maxSeries",
  138. shortName: "max",
  139. category: categories.Combine
  140. });
  141. addFuncDef({
  142. name: "minSeries",
  143. shortName: "min",
  144. category: categories.Combine
  145. });
  146. addFuncDef({
  147. name: "averageSeriesWithWildcards",
  148. category: categories.Combine,
  149. params: [
  150. { name: "node", type: "int" },
  151. { name: "node", type: "int", optional: true }
  152. ],
  153. defaultParams: [3]
  154. });
  155. addFuncDef({
  156. name: "alias",
  157. category: categories.Special,
  158. params: [{ name: "alias", type: "string" }],
  159. defaultParams: ["alias"]
  160. });
  161. addFuncDef({
  162. name: "aliasSub",
  163. category: categories.Special,
  164. params: [
  165. { name: "search", type: "string" },
  166. { name: "replace", type: "string" }
  167. ],
  168. defaultParams: ["", "\\1"]
  169. });
  170. addFuncDef({
  171. name: "stacked",
  172. category: categories.Special,
  173. params: [{ name: "stack", type: "string" }],
  174. defaultParams: ["stacked"]
  175. });
  176. addFuncDef({
  177. name: "consolidateBy",
  178. category: categories.Special,
  179. params: [
  180. {
  181. name: "function",
  182. type: "string",
  183. options: ["sum", "average", "min", "max"]
  184. }
  185. ],
  186. defaultParams: ["max"]
  187. });
  188. addFuncDef({
  189. name: "cumulative",
  190. category: categories.Special,
  191. params: [],
  192. defaultParams: []
  193. });
  194. addFuncDef({
  195. name: "groupByNode",
  196. category: categories.Special,
  197. params: [
  198. {
  199. name: "node",
  200. type: "int",
  201. options: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 12]
  202. },
  203. {
  204. name: "function",
  205. type: "string",
  206. options: ["sum", "avg", "maxSeries"]
  207. }
  208. ],
  209. defaultParams: [3, "sum"]
  210. });
  211. addFuncDef({
  212. name: "aliasByNode",
  213. category: categories.Special,
  214. params: [
  215. {
  216. name: "node",
  217. type: "int",
  218. options: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 12]
  219. },
  220. {
  221. name: "node",
  222. type: "int",
  223. options: [0, -1, -2, -3, -4, -5, -6, -7],
  224. optional: true
  225. },
  226. {
  227. name: "node",
  228. type: "int",
  229. options: [0, -1, -2, -3, -4, -5, -6, -7],
  230. optional: true
  231. },
  232. {
  233. name: "node",
  234. type: "int",
  235. options: [0, -1, -2, -3, -4, -5, -6, -7],
  236. optional: true
  237. }
  238. ],
  239. defaultParams: [3]
  240. });
  241. addFuncDef({
  242. name: "substr",
  243. category: categories.Special,
  244. params: [
  245. {
  246. name: "start",
  247. type: "int",
  248. options: [-6, -5, -4, -3, -2, -1, 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 12]
  249. },
  250. {
  251. name: "stop",
  252. type: "int",
  253. options: [-6, -5, -4, -3, -2, -1, 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 12]
  254. }
  255. ],
  256. defaultParams: [0, 0]
  257. });
  258. addFuncDef({
  259. name: "sortByName",
  260. category: categories.Special,
  261. params: [
  262. {
  263. name: "natural",
  264. type: "boolean",
  265. options: ["true", "false"],
  266. optional: true
  267. }
  268. ],
  269. defaultParams: ["false"]
  270. });
  271. addFuncDef({
  272. name: "sortByMaxima",
  273. category: categories.Special
  274. });
  275. addFuncDef({
  276. name: "sortByMinima",
  277. category: categories.Special
  278. });
  279. addFuncDef({
  280. name: "sortByTotal",
  281. category: categories.Special
  282. });
  283. addFuncDef({
  284. name: "aliasByMetric",
  285. category: categories.Special
  286. });
  287. addFuncDef({
  288. name: "randomWalk",
  289. fake: true,
  290. category: categories.Special,
  291. params: [{ name: "name", type: "string" }],
  292. defaultParams: ["randomWalk"]
  293. });
  294. addFuncDef({
  295. name: "countSeries",
  296. category: categories.Special
  297. });
  298. addFuncDef({
  299. name: "constantLine",
  300. category: categories.Special,
  301. params: [{ name: "value", type: "int" }],
  302. defaultParams: [10]
  303. });
  304. addFuncDef({
  305. name: "cactiStyle",
  306. category: categories.Special
  307. });
  308. addFuncDef({
  309. name: "keepLastValue",
  310. category: categories.Special,
  311. params: [{ name: "n", type: "int" }],
  312. defaultParams: [100]
  313. });
  314. addFuncDef({
  315. name: "changed",
  316. category: categories.Special,
  317. params: [],
  318. defaultParams: []
  319. });
  320. addFuncDef({
  321. name: "scale",
  322. category: categories.Transform,
  323. params: [{ name: "factor", type: "int" }],
  324. defaultParams: [1]
  325. });
  326. addFuncDef({
  327. name: "offset",
  328. category: categories.Transform,
  329. params: [{ name: "amount", type: "int" }],
  330. defaultParams: [10]
  331. });
  332. addFuncDef({
  333. name: "transformNull",
  334. category: categories.Transform,
  335. params: [{ name: "amount", type: "int" }],
  336. defaultParams: [0]
  337. });
  338. addFuncDef({
  339. name: "integral",
  340. category: categories.Transform
  341. });
  342. addFuncDef({
  343. name: "derivative",
  344. category: categories.Transform
  345. });
  346. addFuncDef({
  347. name: "nonNegativeDerivative",
  348. category: categories.Transform,
  349. params: [{ name: "max value or 0", type: "int", optional: true }],
  350. defaultParams: [""]
  351. });
  352. addFuncDef({
  353. name: "timeShift",
  354. category: categories.Transform,
  355. params: [
  356. {
  357. name: "amount",
  358. type: "select",
  359. options: ["1h", "6h", "12h", "1d", "2d", "7d", "14d", "30d"]
  360. }
  361. ],
  362. defaultParams: ["1d"]
  363. });
  364. addFuncDef({
  365. name: "timeStack",
  366. category: categories.Transform,
  367. params: [
  368. {
  369. name: "timeShiftUnit",
  370. type: "select",
  371. options: ["1h", "6h", "12h", "1d", "2d", "7d", "14d", "30d"]
  372. },
  373. { name: "timeShiftStart", type: "int" },
  374. { name: "timeShiftEnd", type: "int" }
  375. ],
  376. defaultParams: ["1d", 0, 7]
  377. });
  378. addFuncDef({
  379. name: "summarize",
  380. category: categories.Transform,
  381. params: [
  382. { name: "interval", type: "string" },
  383. {
  384. name: "func",
  385. type: "select",
  386. options: ["sum", "avg", "min", "max", "last"]
  387. },
  388. {
  389. name: "alignToFrom",
  390. type: "boolean",
  391. optional: true,
  392. options: ["false", "true"]
  393. }
  394. ],
  395. defaultParams: ["1h", "sum", "false"]
  396. });
  397. addFuncDef({
  398. name: "smartSummarize",
  399. category: categories.Transform,
  400. params: [
  401. { name: "interval", type: "string" },
  402. {
  403. name: "func",
  404. type: "select",
  405. options: ["sum", "avg", "min", "max", "last"]
  406. }
  407. ],
  408. defaultParams: ["1h", "sum"]
  409. });
  410. addFuncDef({
  411. name: "absolute",
  412. category: categories.Transform
  413. });
  414. addFuncDef({
  415. name: "hitcount",
  416. category: categories.Transform,
  417. params: [{ name: "interval", type: "string" }],
  418. defaultParams: ["10s"]
  419. });
  420. addFuncDef({
  421. name: "log",
  422. category: categories.Transform,
  423. params: [{ name: "base", type: "int" }],
  424. defaultParams: ["10"]
  425. });
  426. addFuncDef({
  427. name: "averageAbove",
  428. category: categories.Filter,
  429. params: [{ name: "n", type: "int" }],
  430. defaultParams: [25]
  431. });
  432. addFuncDef({
  433. name: "averageBelow",
  434. category: categories.Filter,
  435. params: [{ name: "n", type: "int" }],
  436. defaultParams: [25]
  437. });
  438. addFuncDef({
  439. name: "currentAbove",
  440. category: categories.Filter,
  441. params: [{ name: "n", type: "int" }],
  442. defaultParams: [25]
  443. });
  444. addFuncDef({
  445. name: "currentBelow",
  446. category: categories.Filter,
  447. params: [{ name: "n", type: "int" }],
  448. defaultParams: [25]
  449. });
  450. addFuncDef({
  451. name: "maximumAbove",
  452. category: categories.Filter,
  453. params: [{ name: "value", type: "int" }],
  454. defaultParams: [0]
  455. });
  456. addFuncDef({
  457. name: "maximumBelow",
  458. category: categories.Filter,
  459. params: [{ name: "value", type: "int" }],
  460. defaultParams: [0]
  461. });
  462. addFuncDef({
  463. name: "minimumAbove",
  464. category: categories.Filter,
  465. params: [{ name: "value", type: "int" }],
  466. defaultParams: [0]
  467. });
  468. addFuncDef({
  469. name: "minimumBelow",
  470. category: categories.Filter,
  471. params: [{ name: "value", type: "int" }],
  472. defaultParams: [0]
  473. });
  474. addFuncDef({
  475. name: "limit",
  476. category: categories.Filter,
  477. params: [{ name: "n", type: "int" }],
  478. defaultParams: [5]
  479. });
  480. addFuncDef({
  481. name: "mostDeviant",
  482. category: categories.Filter,
  483. params: [{ name: "n", type: "int" }],
  484. defaultParams: [10]
  485. });
  486. addFuncDef({
  487. name: "exclude",
  488. category: categories.Filter,
  489. params: [{ name: "exclude", type: "string" }],
  490. defaultParams: ["exclude"]
  491. });
  492. addFuncDef({
  493. name: "highestCurrent",
  494. category: categories.Filter,
  495. params: [{ name: "count", type: "int" }],
  496. defaultParams: [5]
  497. });
  498. addFuncDef({
  499. name: "highestMax",
  500. category: categories.Filter,
  501. params: [{ name: "count", type: "int" }],
  502. defaultParams: [5]
  503. });
  504. addFuncDef({
  505. name: "lowestCurrent",
  506. category: categories.Filter,
  507. params: [{ name: "count", type: "int" }],
  508. defaultParams: [5]
  509. });
  510. addFuncDef({
  511. name: "movingAverage",
  512. category: categories.Filter,
  513. params: [
  514. {
  515. name: "windowSize",
  516. type: "int_or_interval",
  517. options: ["5", "7", "10", "5min", "10min", "30min", "1hour"]
  518. }
  519. ],
  520. defaultParams: [10]
  521. });
  522. addFuncDef({
  523. name: "movingMedian",
  524. category: categories.Filter,
  525. params: [
  526. {
  527. name: "windowSize",
  528. type: "int_or_interval",
  529. options: ["5", "7", "10", "5min", "10min", "30min", "1hour"]
  530. }
  531. ],
  532. defaultParams: ["5"]
  533. });
  534. addFuncDef({
  535. name: "stdev",
  536. category: categories.Filter,
  537. params: [{ name: "n", type: "int" }, { name: "tolerance", type: "int" }],
  538. defaultParams: [5, 0.1]
  539. });
  540. addFuncDef({
  541. name: "highestAverage",
  542. category: categories.Filter,
  543. params: [{ name: "count", type: "int" }],
  544. defaultParams: [5]
  545. });
  546. addFuncDef({
  547. name: "lowestAverage",
  548. category: categories.Filter,
  549. params: [{ name: "count", type: "int" }],
  550. defaultParams: [5]
  551. });
  552. addFuncDef({
  553. name: "removeAbovePercentile",
  554. category: categories.Filter,
  555. params: [{ name: "n", type: "int" }],
  556. defaultParams: [5]
  557. });
  558. addFuncDef({
  559. name: "removeAboveValue",
  560. category: categories.Filter,
  561. params: [{ name: "n", type: "int" }],
  562. defaultParams: [5]
  563. });
  564. addFuncDef({
  565. name: "removeBelowPercentile",
  566. category: categories.Filter,
  567. params: [{ name: "n", type: "int" }],
  568. defaultParams: [5]
  569. });
  570. addFuncDef({
  571. name: "removeBelowValue",
  572. category: categories.Filter,
  573. params: [{ name: "n", type: "int" }],
  574. defaultParams: [5]
  575. });
  576. addFuncDef({
  577. name: "useSeriesAbove",
  578. category: categories.Filter,
  579. params: [
  580. { name: "value", type: "int" },
  581. { name: "search", type: "string" },
  582. { name: "replace", type: "string" }
  583. ],
  584. defaultParams: [0, "search", "replace"]
  585. });
  586. ////////////////////
  587. // Graphite 1.0.x //
  588. ////////////////////
  589. addFuncDef({
  590. name: "aggregateLine",
  591. category: categories.Combine,
  592. params: [
  593. {
  594. name: "func",
  595. type: "select",
  596. options: ["sum", "avg", "min", "max", "last"]
  597. }
  598. ],
  599. defaultParams: ["avg"],
  600. version: "1.0"
  601. });
  602. addFuncDef({
  603. name: "averageOutsidePercentile",
  604. category: categories.Filter,
  605. params: [{ name: "n", type: "int" }],
  606. defaultParams: [95],
  607. version: "1.0"
  608. });
  609. addFuncDef({
  610. name: "delay",
  611. category: categories.Transform,
  612. params: [{ name: "steps", type: "int" }],
  613. defaultParams: [1],
  614. version: "1.0"
  615. });
  616. addFuncDef({
  617. name: "exponentialMovingAverage",
  618. category: categories.Calculate,
  619. params: [
  620. {
  621. name: "windowSize",
  622. type: "int_or_interval",
  623. options: ["5", "7", "10", "5min", "10min", "30min", "1hour"]
  624. }
  625. ],
  626. defaultParams: [10],
  627. version: "1.0"
  628. });
  629. addFuncDef({
  630. name: "fallbackSeries",
  631. category: categories.Special,
  632. params: [{ name: "fallback", type: "string" }],
  633. defaultParams: ["constantLine(0)"],
  634. version: "1.0"
  635. });
  636. addFuncDef({
  637. name: "grep",
  638. category: categories.Filter,
  639. params: [{ name: "grep", type: "string" }],
  640. defaultParams: ["grep"],
  641. version: "1.0"
  642. });
  643. addFuncDef({
  644. name: "groupByNodes",
  645. category: categories.Special,
  646. params: [
  647. {
  648. name: "function",
  649. type: "string",
  650. options: ["sum", "avg", "maxSeries"]
  651. },
  652. {
  653. name: "node",
  654. type: "int",
  655. options: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 12]
  656. },
  657. {
  658. name: "node",
  659. type: "int",
  660. options: [0, -1, -2, -3, -4, -5, -6, -7],
  661. optional: true
  662. },
  663. {
  664. name: "node",
  665. type: "int",
  666. options: [0, -1, -2, -3, -4, -5, -6, -7],
  667. optional: true
  668. },
  669. {
  670. name: "node",
  671. type: "int",
  672. options: [0, -1, -2, -3, -4, -5, -6, -7],
  673. optional: true
  674. }
  675. ],
  676. defaultParams: ["sum", 3],
  677. version: "1.0"
  678. });
  679. addFuncDef({
  680. name: "integralByInterval",
  681. category: categories.Transform,
  682. params: [
  683. {
  684. name: "intervalUnit",
  685. type: "select",
  686. options: ["1h", "6h", "12h", "1d", "2d", "7d", "14d", "30d"]
  687. }
  688. ],
  689. defaultParams: ["1d"],
  690. version: "1.0"
  691. });
  692. addFuncDef({
  693. name: "interpolate",
  694. category: categories.Transform,
  695. params: [{ name: "limit", type: "int", optional: true }],
  696. defaultParams: [],
  697. version: "1.0"
  698. });
  699. addFuncDef({
  700. name: "invert",
  701. category: categories.Transform,
  702. version: "1.0"
  703. });
  704. addFuncDef({
  705. name: "isNonNull",
  706. category: categories.Combine,
  707. version: "1.0"
  708. });
  709. addFuncDef({
  710. name: "linearRegression",
  711. category: categories.Calculate,
  712. params: [
  713. {
  714. name: "startSourceAt",
  715. type: "select",
  716. options: ["-1h", "-6h", "-12h", "-1d", "-2d", "-7d", "-14d", "-30d"],
  717. optional: true
  718. },
  719. {
  720. name: "endSourceAt",
  721. type: "select",
  722. options: ["-1h", "-6h", "-12h", "-1d", "-2d", "-7d", "-14d", "-30d"],
  723. optional: true
  724. }
  725. ],
  726. defaultParams: [],
  727. version: "1.0"
  728. });
  729. addFuncDef({
  730. name: "mapSeries",
  731. shortName: "map",
  732. params: [{ name: "node", type: "int" }],
  733. defaultParams: [3],
  734. category: categories.Combine,
  735. version: "1.0"
  736. });
  737. addFuncDef({
  738. name: "movingMin",
  739. category: categories.Calculate,
  740. params: [
  741. {
  742. name: "windowSize",
  743. type: "int_or_interval",
  744. options: ["5", "7", "10", "5min", "10min", "30min", "1hour"]
  745. }
  746. ],
  747. defaultParams: [10],
  748. version: "1.0"
  749. });
  750. addFuncDef({
  751. name: "movingMax",
  752. category: categories.Calculate,
  753. params: [
  754. {
  755. name: "windowSize",
  756. type: "int_or_interval",
  757. options: ["5", "7", "10", "5min", "10min", "30min", "1hour"]
  758. }
  759. ],
  760. defaultParams: [10],
  761. version: "1.0"
  762. });
  763. addFuncDef({
  764. name: "movingSum",
  765. category: categories.Calculate,
  766. params: [
  767. {
  768. name: "windowSize",
  769. type: "int_or_interval",
  770. options: ["5", "7", "10", "5min", "10min", "30min", "1hour"]
  771. }
  772. ],
  773. defaultParams: [10],
  774. version: "1.0"
  775. });
  776. addFuncDef({
  777. name: "multiplySeriesWithWildcards",
  778. category: categories.Calculate,
  779. params: [
  780. {
  781. name: "position",
  782. type: "int",
  783. options: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 12]
  784. },
  785. {
  786. name: "position",
  787. type: "int",
  788. options: [0, -1, -2, -3, -4, -5, -6, -7],
  789. optional: true
  790. },
  791. {
  792. name: "position",
  793. type: "int",
  794. options: [0, -1, -2, -3, -4, -5, -6, -7],
  795. optional: true
  796. },
  797. {
  798. name: "position",
  799. type: "int",
  800. options: [0, -1, -2, -3, -4, -5, -6, -7],
  801. optional: true
  802. }
  803. ],
  804. defaultParams: [2],
  805. version: "1.0"
  806. });
  807. addFuncDef({
  808. name: "offsetToZero",
  809. category: categories.Transform,
  810. version: "1.0"
  811. });
  812. addFuncDef({
  813. name: "pow",
  814. category: categories.Transform,
  815. params: [{ name: "factor", type: "int" }],
  816. defaultParams: [10],
  817. version: "1.0"
  818. });
  819. addFuncDef({
  820. name: "powSeries",
  821. category: categories.Transform,
  822. params: optionalSeriesRefArgs,
  823. defaultParams: [""],
  824. version: "1.0"
  825. });
  826. addFuncDef({
  827. name: "reduceSeries",
  828. shortName: "reduce",
  829. params: [
  830. {
  831. name: "function",
  832. type: "string",
  833. options: ["asPercent", "diffSeries", "divideSeries"]
  834. },
  835. {
  836. name: "reduceNode",
  837. type: "int",
  838. options: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13]
  839. },
  840. { name: "reduceMatchers", type: "string" },
  841. { name: "reduceMatchers", type: "string" }
  842. ],
  843. defaultParams: ["asPercent", 2, "used_bytes", "total_bytes"],
  844. category: categories.Combine,
  845. version: "1.0"
  846. });
  847. addFuncDef({
  848. name: "removeBetweenPercentile",
  849. category: categories.Filter,
  850. params: [{ name: "n", type: "int" }],
  851. defaultParams: [95],
  852. version: "1.0"
  853. });
  854. addFuncDef({
  855. name: "removeEmptySeries",
  856. category: categories.Filter,
  857. version: "1.0"
  858. });
  859. addFuncDef({
  860. name: "squareRoot",
  861. category: categories.Transform,
  862. version: "1.0"
  863. });
  864. addFuncDef({
  865. name: "timeSlice",
  866. category: categories.Transform,
  867. params: [
  868. {
  869. name: "startSliceAt",
  870. type: "select",
  871. options: ["-1h", "-6h", "-12h", "-1d", "-2d", "-7d", "-14d", "-30d"]
  872. },
  873. {
  874. name: "endSliceAt",
  875. type: "select",
  876. options: ["-1h", "-6h", "-12h", "-1d", "-2d", "-7d", "-14d", "-30d"],
  877. optional: true
  878. }
  879. ],
  880. defaultParams: ["-1h"],
  881. version: "1.0"
  882. });
  883. addFuncDef({
  884. name: "weightedAverage",
  885. category: categories.Filter,
  886. params: [
  887. { name: "other", type: "value_or_series", optional: true },
  888. {
  889. name: "node",
  890. type: "int",
  891. options: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 12]
  892. }
  893. ],
  894. defaultParams: ["#A", 4],
  895. version: "1.0"
  896. });
  897. addFuncDef({
  898. name: "seriesByTag",
  899. category: categories.Special,
  900. params: [
  901. { name: "tagExpression", type: "string" },
  902. { name: "tagExpression", type: "string", optional: true },
  903. { name: "tagExpression", type: "string", optional: true },
  904. { name: "tagExpression", type: "string", optional: true }
  905. ],
  906. version: "1.1"
  907. });
  908. addFuncDef({
  909. name: "groupByTags",
  910. category: categories.Special,
  911. params: [
  912. {
  913. name: "function",
  914. type: "string",
  915. options: ["sum", "avg", "maxSeries"]
  916. },
  917. { name: "tag", type: "string" },
  918. { name: "tag", type: "string", optional: true },
  919. { name: "tag", type: "string", optional: true },
  920. { name: "tag", type: "string", optional: true }
  921. ],
  922. defaultParams: ["sum", "tag"],
  923. version: "1.1"
  924. });
  925. addFuncDef({
  926. name: "aliasByTags",
  927. category: categories.Special,
  928. params: [
  929. { name: "tag", type: "string" },
  930. { name: "tag", type: "string", optional: true },
  931. { name: "tag", type: "string", optional: true },
  932. { name: "tag", type: "string", optional: true }
  933. ],
  934. defaultParams: ["tag"],
  935. version: "1.1"
  936. });
  937. _.each(categories, function(funcList, catName) {
  938. categories[catName] = _.sortBy(funcList, "name");
  939. });
  940. function isVersionRelatedFunction(func, graphiteVersion) {
  941. return (
  942. isVersionGtOrEq(graphiteVersion, func.version) || !func.version
  943. );
  944. }
  945. export class FuncInstance {
  946. def: any;
  947. params: any;
  948. text: any;
  949. added: boolean;
  950. constructor(funcDef, options) {
  951. this.def = funcDef;
  952. this.params = [];
  953. if (options && options.withDefaultParams) {
  954. this.params = funcDef.defaultParams.slice(0);
  955. }
  956. this.updateText();
  957. }
  958. render(metricExp) {
  959. var str = this.def.name + "(";
  960. var parameters = _.map(
  961. this.params,
  962. function(value, index) {
  963. var paramType = this.def.params[index].type;
  964. if (
  965. paramType === "int" ||
  966. paramType === "value_or_series" ||
  967. paramType === "boolean"
  968. ) {
  969. return value;
  970. } else if (paramType === "int_or_interval" && $.isNumeric(value)) {
  971. return value;
  972. }
  973. return "'" + value + "'";
  974. }.bind(this)
  975. );
  976. if (metricExp) {
  977. parameters.unshift(metricExp);
  978. }
  979. return str + parameters.join(", ") + ")";
  980. }
  981. _hasMultipleParamsInString(strValue, index) {
  982. if (strValue.indexOf(",") === -1) {
  983. return false;
  984. }
  985. return this.def.params[index + 1] && this.def.params[index + 1].optional;
  986. }
  987. updateParam(strValue, index) {
  988. // handle optional parameters
  989. // if string contains ',' and next param is optional, split and update both
  990. if (this._hasMultipleParamsInString(strValue, index)) {
  991. _.each(
  992. strValue.split(","),
  993. function(partVal, idx) {
  994. this.updateParam(partVal.trim(), index + idx);
  995. }.bind(this)
  996. );
  997. return;
  998. }
  999. if (strValue === "" && this.def.params[index].optional) {
  1000. this.params.splice(index, 1);
  1001. } else {
  1002. this.params[index] = strValue;
  1003. }
  1004. this.updateText();
  1005. }
  1006. updateText() {
  1007. if (this.params.length === 0) {
  1008. this.text = this.def.name + "()";
  1009. return;
  1010. }
  1011. var text = this.def.name + "(";
  1012. text += this.params.join(", ");
  1013. text += ")";
  1014. this.text = text;
  1015. }
  1016. }
  1017. export default {
  1018. createFuncInstance: function(funcDef, options?) {
  1019. if (_.isString(funcDef)) {
  1020. if (!index[funcDef]) {
  1021. throw { message: "Method not found " + name };
  1022. }
  1023. funcDef = index[funcDef];
  1024. }
  1025. return new FuncInstance(funcDef, options);
  1026. },
  1027. getFuncDef: function(name) {
  1028. return index[name];
  1029. },
  1030. getCategories: function(graphiteVersion) {
  1031. var filteredCategories: any = {};
  1032. _.each(categories, function(functions, category) {
  1033. var filteredFuncs = _.filter(functions, function(func) {
  1034. return isVersionRelatedFunction(func, graphiteVersion);
  1035. });
  1036. if (filteredFuncs.length) {
  1037. filteredCategories[category] = filteredFuncs;
  1038. }
  1039. });
  1040. return filteredCategories;
  1041. }
  1042. };