Shard query splitting: Split queries by stream shards

docker-compose.dev.yaml

@@ -5,7 +5,7 @@ services:
     container_name: 'grafana-logsapp'
     platform: 'linux/amd64'
     environment:
-      - GF_FEATURE_TOGGLES_ENABLE=accessControlOnCall lokiLogsDataplane exploreLogsShardSplitting
+      - GF_FEATURE_TOGGLES_ENABLE=accessControlOnCall lokiLogsDataplane
     build:
       context: ./.config
       args:

index.d.ts

@@ -0,0 +1,17 @@
+import { Observable } from 'rxjs';
+
+type ObservableType<T> = T extends Observable<infer V> ? V : never;
+
+declare global {
+  namespace jest {
+    interface Matchers<R, T = {}> {
+      toEmitValues<E = ObservableType<T>>(expected: E[]): Promise<CustomMatcherResult>;
+      /**
+       * Collect all the values emitted by the observables (also errors) and pass them to the expectations functions after
+       * the observable ended (or emitted error). If Observable does not complete within OBSERVABLE_TEST_TIMEOUT_IN_MS the
+       * test fails.
+       */
+      toEmitValuesWith<E = ObservableType<T>>(expectations: (received: E[]) => void): Promise<CustomMatcherResult>;
+    }
+  }
+}

jest-setup.js

@@ -3,9 +3,15 @@ import { TextDecoder, TextEncoder } from 'util';
 
 import './.config/jest-setup';
 
+import { toEmitValuesWith } from './tests/matchers';
+
 global.TextEncoder = TextEncoder;
 global.TextDecoder = TextDecoder;
 
+expect.extend({
+  toEmitValuesWith,
+});
+
 // mock the intersection observer and just say everything is in view
 const mockIntersectionObserver = jest.fn().mockImplementation((callback) => ({
   observe: jest.fn().mockImplementation((elem) => {

package.json

@@ -49,6 +49,7 @@
     "@types/react-scroll-sync": "^0.9.0",
     "@types/react-table": "^7.7.20",
     "@types/testing-library__jest-dom": "5.14.8",
+    "@types/uuid": "^10.0.0",
     "copy-webpack-plugin": "^11.0.0",
     "cspell": "6.13.3",
     "css-loader": "^6.7.3",
@@ -96,7 +97,8 @@
     "react-dom": "18.2.0",
     "react-router-dom": "^5.2.0",
     "rxjs": "7.8.1",
-    "tslib": "2.5.3"
+    "tslib": "2.5.3",
+    "uuid": "^10.0.0"
   },
   "resolutions": {
     "**/fast-loops": "^1.1.4"

project-words.txt

@@ -476,3 +476,11 @@ yass
 noparser
 whoopsie
 myproject
+decbytes
+frametype
+Nanos
+nanos
+subquery
+Subscription
+uuidv
+without