File tree
492 files changed
+87207
-16183
lines changed- .github/workflows
- api
- json-schema
- openapi-spec
- cmd/commands
- config
- advanced-install
- base
- crds
- full
- minimal
- numaflow-server
- cluster-install/rbac
- controller-manager
- numaflow-server
- extensions/webhook
- rbac
- namespace-install/rbac
- controller-manager
- numaflow-server
- docs
- core-concepts
- development
- operations/metrics
- user-guide
- reference
- configuration
- sdks
- sinks
- sources
- user-defined-functions/map
- examples
- hack
- pkg
- apis
- numaflow/v1alpha1
- proto
- accumulator/v1
- daemon
- isb
- mvtxdaemon
- reduce/wal
- serving/v1
- sink/v1
- watermark
- wmb
- client
- clientset/versioned
- typed/numaflow/v1alpha1
- fake
- informers/externalversions
- numaflow/v1alpha1
- listers/numaflow/v1alpha1
- daemon
- client
- server
- service
- rater
- runtime
- isbsvc
- isb/stores/redis
- metrics
- mvtxdaemon
- client
- server
- service
- rater
- runtime
- reconciler
- cmd
- isbsvc
- monovertex
- scaling
- pipeline
- servingpipeline
- validator
- vertex
- scaling
- reduce
- pbq/wal/unaligned/fs
- pnf
- sdkclient
- accumulator
- reducer
- serverinfo
- sessionreducer
- sideinput
- sinker
- source
- sideinputs/synchronizer
- sinks
- udsink
- sources
- forward
- generator
- udsource
- udf
- rpc
- watermark
- fetch
- publish
- wmb
- webhook
- cmd
- validator
- window
- strategy
- accumulate
- session
- rust
- backoff
- src
- extns
- numaflow-jetstream
- src
- numaflow-pulsar
- src
- numaflow-sqs
- src
- numaflow-core
- src
- config
- pipeline
- mapper
- map
- monovertex
- pipeline
- forwarder
- isb
- jetstream
- reduce
- wal
- segment
- sink
- serve
- source
- transformer
- watermark
- idle
- isb
- processor
- source
- numaflow-models
- hack
- src/models
- templates
- numaflow-monitor
- src
- numaflow-pb
- src
- clients
- objects
- numaflow
- src
- bin
- servesink
- src
- serving
- src
- app
- callback
- store
- store
- cbstore
- datastore
- server
- apis
- v1
- cmd/server
- routes
- test
- api-e2e
- testdata
- e2e-api
- fixtures
- monovertex-e2e
- testdata
- reduce-two-e2e
- testdata/accumulator
- serving-e2e
- testdata
- ui
- src
- components
- common
- MetricsModalWrapper
- partials/MetricsModal
- SlidingSidebar/partials
- K8sEvents
- VertexDetails
- partials
- Buffers
- Errors
- partials/CollapsableError
- ProcessingRates
- pages/Pipeline/partials/Graph/partials/NodeInfo/partials/Pods
- partials/PodDetails
- partials
- ContainerInfo
- Metrics
- partials
- EmptyChart
- LineChart
- common
- Dropdown
- FiltersDropdown
- TimeRange
- utils
- PodLogs
- types/declarations
- utils
- fetchWrappers
- fetcherHooks
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
492 files changed
+87207
-16183
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
7 | 7 | | |
8 | 8 | | |
9 | 9 | | |
10 | | - | |
| 10 | + | |
11 | 11 | | |
12 | 12 | | |
13 | 13 | | |
| |||
19 | 19 | | |
20 | 20 | | |
21 | 21 | | |
22 | | - | |
23 | | - | |
| 22 | + | |
| 23 | + | |
24 | 24 | | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
9 | 9 | | |
10 | 10 | | |
11 | 11 | | |
12 | | - | |
| 12 | + | |
13 | 13 | | |
14 | 14 | | |
15 | 15 | | |
| |||
30 | 30 | | |
31 | 31 | | |
32 | 32 | | |
33 | | - | |
| 33 | + | |
34 | 34 | | |
35 | 35 | | |
36 | 36 | | |
| |||
43 | 43 | | |
44 | 44 | | |
45 | 45 | | |
46 | | - | |
| 46 | + | |
47 | 47 | | |
48 | 48 | | |
49 | 49 | | |
| |||
59 | 59 | | |
60 | 60 | | |
61 | 61 | | |
62 | | - | |
| 62 | + | |
63 | 63 | | |
64 | 64 | | |
65 | 65 | | |
| |||
71 | 71 | | |
72 | 72 | | |
73 | 73 | | |
74 | | - | |
75 | | - | |
76 | | - | |
77 | | - | |
78 | | - | |
79 | | - | |
80 | 74 | | |
81 | 75 | | |
| 76 | + | |
| 77 | + | |
| 78 | + | |
82 | 79 | | |
83 | 80 | | |
84 | 81 | | |
85 | 82 | | |
86 | 83 | | |
87 | 84 | | |
88 | | - | |
| 85 | + | |
89 | 86 | | |
90 | 87 | | |
91 | 88 | | |
| |||
129 | 126 | | |
130 | 127 | | |
131 | 128 | | |
132 | | - | |
| 129 | + | |
133 | 130 | | |
134 | 131 | | |
135 | 132 | | |
| |||
140 | 137 | | |
141 | 138 | | |
142 | 139 | | |
143 | | - | |
| 140 | + | |
144 | 141 | | |
145 | 142 | | |
146 | 143 | | |
| |||
149 | 146 | | |
150 | 147 | | |
151 | 148 | | |
152 | | - | |
| 149 | + | |
153 | 150 | | |
154 | 151 | | |
155 | 152 | | |
| |||
175 | 172 | | |
176 | 173 | | |
177 | 174 | | |
178 | | - | |
| 175 | + | |
179 | 176 | | |
180 | | - | |
| 177 | + | |
181 | 178 | | |
182 | 179 | | |
183 | 180 | | |
184 | 181 | | |
185 | | - | |
186 | | - | |
187 | | - | |
188 | | - | |
| 182 | + | |
| 183 | + | |
| 184 | + | |
| 185 | + | |
| 186 | + | |
| 187 | + | |
| 188 | + | |
| 189 | + | |
| 190 | + | |
| 191 | + | |
| 192 | + | |
| 193 | + | |
189 | 194 | | |
190 | 195 | | |
191 | 196 | | |
192 | 197 | | |
193 | 198 | | |
194 | 199 | | |
| 200 | + | |
| 201 | + | |
| 202 | + | |
| 203 | + | |
| 204 | + | |
| 205 | + | |
195 | 206 | | |
196 | 207 | | |
197 | 208 | | |
198 | | - | |
| 209 | + | |
199 | 210 | | |
200 | 211 | | |
201 | 212 | | |
| |||
218 | 229 | | |
219 | 230 | | |
220 | 231 | | |
| 232 | + | |
221 | 233 | | |
222 | 234 | | |
223 | 235 | | |
| |||
238 | 250 | | |
239 | 251 | | |
240 | 252 | | |
241 | | - | |
| 253 | + | |
242 | 254 | | |
243 | 255 | | |
244 | 256 | | |
| |||
256 | 268 | | |
257 | 269 | | |
258 | 270 | | |
| 271 | + | |
| 272 | + | |
| 273 | + | |
| 274 | + | |
259 | 275 | | |
260 | 276 | | |
261 | 277 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
11 | 11 | | |
12 | 12 | | |
13 | 13 | | |
14 | | - | |
| 14 | + | |
15 | 15 | | |
16 | 16 | | |
17 | 17 | | |
| |||
21 | 21 | | |
22 | 22 | | |
23 | 23 | | |
24 | | - | |
| 24 | + | |
25 | 25 | | |
26 | 26 | | |
27 | 27 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
2 | 2 | | |
3 | 3 | | |
4 | 4 | | |
5 | | - | |
| 5 | + | |
6 | 6 | | |
7 | 7 | | |
8 | 8 | | |
| |||
16 | 16 | | |
17 | 17 | | |
18 | 18 | | |
19 | | - | |
| 19 | + | |
20 | 20 | | |
21 | 21 | | |
22 | 22 | | |
| |||
26 | 26 | | |
27 | 27 | | |
28 | 28 | | |
29 | | - | |
| 29 | + | |
30 | 30 | | |
31 | 31 | | |
32 | 32 | | |
| |||
51 | 51 | | |
52 | 52 | | |
53 | 53 | | |
54 | | - | |
| 54 | + | |
55 | 55 | | |
56 | 56 | | |
57 | 57 | | |
58 | 58 | | |
59 | 59 | | |
60 | | - | |
| 60 | + | |
61 | 61 | | |
62 | | - | |
| 62 | + | |
63 | 63 | | |
64 | 64 | | |
65 | 65 | | |
66 | | - | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
67 | 69 | | |
68 | 70 | | |
69 | 71 | | |
70 | 72 | | |
71 | 73 | | |
| 74 | + | |
| 75 | + | |
| 76 | + | |
| 77 | + | |
| 78 | + | |
| 79 | + | |
72 | 80 | | |
73 | 81 | | |
74 | 82 | | |
| |||
84 | 92 | | |
85 | 93 | | |
86 | 94 | | |
87 | | - | |
| 95 | + | |
88 | 96 | | |
89 | 97 | | |
90 | 98 | | |
91 | 99 | | |
92 | 100 | | |
93 | | - | |
| 101 | + | |
94 | 102 | | |
95 | | - | |
| 103 | + | |
96 | 104 | | |
97 | 105 | | |
98 | 106 | | |
99 | | - | |
| 107 | + | |
| 108 | + | |
| 109 | + | |
100 | 110 | | |
101 | 111 | | |
102 | 112 | | |
103 | 113 | | |
104 | 114 | | |
| 115 | + | |
| 116 | + | |
| 117 | + | |
| 118 | + | |
| 119 | + | |
105 | 120 | | |
106 | 121 | | |
107 | 122 | | |
108 | | - | |
109 | | - | |
| 123 | + | |
| 124 | + | |
110 | 125 | | |
111 | 126 | | |
112 | 127 | | |
113 | | - | |
| 128 | + | |
114 | 129 | | |
115 | 130 | | |
116 | 131 | | |
| |||
138 | 153 | | |
139 | 154 | | |
140 | 155 | | |
| 156 | + | |
| 157 | + | |
| 158 | + | |
| 159 | + | |
| 160 | + | |
| 161 | + | |
141 | 162 | | |
142 | 163 | | |
143 | 164 | | |
144 | 165 | | |
145 | 166 | | |
146 | 167 | | |
| 168 | + | |
| 169 | + | |
| 170 | + | |
| 171 | + | |
| 172 | + | |
| 173 | + | |
147 | 174 | | |
148 | 175 | | |
149 | 176 | | |
| |||
0 commit comments