File tree
1,014 files changed
+17589
-13262
lines changed- datarouter-auth
- src/main/java/io/datarouter/auth
- authenticate
- authenticator
- impl
- saml
- cached
- config
- link
- model/dto
- role
- security
- service
- deprovisioning
- session
- storage
- account
- credential
- secret
- user
- datarouteruser
- cache
- deprovisioneduser
- saml
- session
- userhistory
- util
- datarouter-auth-web
- src/main
- java/io/datarouter/auth/web
- config
- routeset
- job
- link
- readme
- service
- util
- web
- adminedituser
- dto
- resources/META-INF/resources/js
- datarouter-auto-config
- src/main/java/io/datarouter/autoconfig/config
- datarouter-aws-elb
- src/main/java/io/datarouter/aws/elb/service
- datarouter-aws-memcached
- src/main/java/io/datarouter/aws/memcached/client
- datarouter-aws-rds
- src/main/java/io/datarouter/aws/rds
- config
- service
- tool
- datarouter-aws-route53
- src/main/java/io/datarouter/aws/route53/config
- datarouter-aws-s3
- src
- main/java/io/datarouter/aws/s3
- client
- config
- node
- request
- web
- bulkcopy
- bulkdelete
- test/java/io/datarouter/aws/s3
- datarouter-aws-secrets-manager
- src/main/java/io/datarouter/aws/secretsmanager
- datarouter-aws-sqs
- src
- main/java/io/datarouter/aws/sqs
- blob
- op
- config
- group/op
- job
- op
- service
- single/op
- web
- handler
- test/java/io/datarouter/aws/sqs/test
- datarouter-binary-dto
- src/main/java/io/datarouter/binarydto/internal
- datarouter-bytes
- src
- main/java/io/datarouter/bytes
- blockfile
- encoding/checksum
- io
- merge
- read
- query
- storage
- impl
- write
- row
- compress/gzip
- digest
- io
- primitivelist
- accumulator
- test/java/io/datarouter/bytes
- blockfile/test
- row
- primitivelist/accumulator
- datarouter-changelog
- src/main/java/io/datarouter/changelog
- config
- link
- service
- web
- datarouter-checkstyle
- datarouter-cluster-setting
- src/main/java/io/datarouter/clustersetting
- config
- job
- link
- service
- storage/clustersettinglog
- web
- browse
- setting
- log
- override
- handler
- tag
- datarouter-conveyor
- src/main/java/io/datarouter/conveyor
- config
- queue/configuration
- trace
- conveyor
- web
- datarouter-copy-table
- src/main/java/io/datarouter/plugin/copytable
- config
- link
- tableprocessor
- web
- datarouter-data-export
- src
- main/java/io/datarouter/plugin/dataexport
- config
- service
- exporting
- importing
- test/java/io/datarouter/plugin/dataexport/test
- datarouter-email
- src/main/java/io/datarouter/email
- config
- dto
- email
- html
- link
- type
- datarouter-enum
- datarouter-exception
- src/main
- java/io/datarouter/exception
- config
- conveyors
- filter
- service
- storage
- exceptionrecord
- httprecord
- taskexecutorrecord
- web
- resources/META-INF/resources/jsp/datarouter/exception
- datarouter-filesystem
- src/main/java/io/datarouter/filesystem/client
- datarouter-gcp-bigtable
- src/main/java/io/datarouter/gcp/bigtable
- config
- service
- datarouter-gcp-gcs
- src/main/java/io/datarouter/gcp/gcs
- client
- config
- node
- request
- util
- vacuum
- web
- datarouter-gcp-pubsub
- src/main/java/io/datarouter/client/gcp/pubsub
- client
- config
- job
- node
- datarouter-gcp-spanner
- src
- main/java/io/datarouter/gcp/spanner
- client
- config
- ddl
- execute
- field
- array
- node
- op/read
- test/java/io/datarouter/gcp/spanner/test
- datarouter-git
- src/main/java/io/datarouter/client/git
- datarouter-graphql
- src/main/java/io/datarouter/graphql
- config
- fetcher
- loader
- service
- util
- datarouter-graphql-client-util
- datarouter-gson
- src/main/java/io/datarouter/gson
- datarouter-http-client
- src
- main/java/io/datarouter/httpclient
- client
- endpoint
- java
- link
- link
- request
- response
- test/java/io/datarouter/httpclient
- client
- endpoint
- datarouter-inject
- src/main/java/io/datarouter/inject
- datarouter-instrumentation
- src
- main/java/io/datarouter/instrumentation
- doc
- exception
- metric
- platformtask
- relay
- dto
- rml
- type
- schema
- validation
- web
- webappinstance
- test/java/io/datarouter/instrumentation/doc
- datarouter-job
- src
- main/java/io/datarouter/job
- config
- detached
- lock
- scheduler
- service
- storage
- joblock
- stopjobrequest
- triggerlock
- util
- test/java/io/datarouter/job/util
- datarouter-joblet
- src/main/java/io/datarouter/joblet
- codec
- config
- dto
- execute
- handler
- job
- service
- storage/jobletrequest
- test
- type
- datarouter-joblet-mysql
- datarouter-load-test
- src/main/java/io/datarouter/loadtest
- config
- util
- web
- datarouter-logger-config
- src/main/java/io/datarouter/loggerconfig
- config
- service
- datarouter-logging
- datarouter-memcached
- src/main/java/io/datarouter/client/memcached
- client
- codec
- node
- datarouter-memory
- src/main/java/io/datarouter/client/memory/node
- blob
- databean
- groupqueue
- queue
- tally
- datarouter-metadata-parent
- datarouter-metric
- src
- main/java/io/datarouter/metric
- config
- dashboard/web
- link
- publisher
- service
- template
- test/java/io/datarouter
- metric/service
- storage/dao
- datarouter-mockito
- datarouter-model
- src/main/java/io/datarouter/model
- field
- codec
- util
- datarouter-mysql
- src/main/java/io/datarouter/client/mysql
- config
- connection
- ddl
- execute
- generate
- execution
- factory
- field/codec
- node
- op
- read/index
- write
- util
- datarouter-nodewatch
- src/main/java/io/datarouter/nodewatch
- config
- job
- joblet
- link
- service
- shadowtable
- codec
- config
- job
- service
- storage
- util
- web
- handler
- datarouter-opencensus
- src/main/java/io/datarouter/opencensus
- adapter
- mixin
- physical
- datarouter-parent
- datarouter-path-node
- src
- main/java/io/datarouter/pathnode
- test/java/io/datarouter/pathnode
- datarouter-rate-limiter
- src/main/java/io/datarouter/ratelimiter/config
- datarouter-redis
- src/main/java/io/datarouter/client/redis
- client
- codec
- node
- datarouter-relay
- src
- main/java/io/datarouter/relay
- test/java/io/datarouter/relay
- datarouter-scanner
- src
- main/java/io/datarouter/scanner
- test/java/io/datarouter/scanner
- datarouter-secret
- src/main/java/io/datarouter/secret/client/memory
- datarouter-secret-web
- src/main/java/io/datarouter/secretweb
- config
- link
- web
- datarouter-service-config
- src/main/java/io/datarouter/serviceconfig/config
- datarouter-snapshot
- src/main/java/io/datarouter/filesystem/snapshot
- cache
- group
- groupops
- writer
- datarouter-snapshot-manager
- src/main/java/io/datarouter/snapshotmanager
- datarouter-ssh
- src/main/java/io/datarouter/client/ssh
- request
- datarouter-storage
- src
- main/java/io/datarouter/storage
- cache
- client
- imp
- config
- schema
- file
- node
- adapter
- counter/mixin
- trace
- mixin
- physical
- builder
- factory
- op
- index
- raw
- index
- read
- write
- tableconfig
- type/index
- op/scan
- privacy
- scratch/blockfile
- serialize/fieldcache
- setting
- util
- vacuum
- predicate
- test/java/io/datarouter/storage
- test
- vacuum
- datarouter-task-tracker
- src/main/java/io/datarouter/tasktracker
- config
- readme
- service
- datarouter-testng
- datarouter-trace
- src/main/java/io/datarouter/trace
- conveyor
- filter
- service
- settings
- datarouter-types
- src
- main/java/io/datarouter/types
- test/java/io/datarouter/types
- datarouter-util
- src
- main/java/io/datarouter/util
- array
- cache
- cached
- concurrent
- duration
- lang
- net
- retry
- string
- time
- tracer
- test/java/io/datarouter/util
- cache
- net
- string
- datarouter-virtual-node
- src/main/java/io/datarouter/virtualnode
- redundant
- replication
- datarouter-web
- src
- main
- java/io/datarouter/web
- browse
- cache
- config
- settings
- digest
- dispatcher
- filter/metric
- handler
- documentation
- encoder
- params
- types
- optional
- handlerusage
- homepage
- html
- form
- j2html
- bootstrap4
- pager
- http
- indexusage
- link
- listener
- monitoring
- latency
- plugins
- forwarder
- opencencus/metrics
- service
- shutdown
- user/authenticate
- authenticator/impl
- saml
- util/http
- exception
- resources/META-INF/resources
- js/docs
- jsp
- admin
- docs
- http
- test/java/io/datarouter/web
- api
- handler
- documentation
- types
- security
- util
- http
- datarouter-webapp-instance
- src/main/java/io/datarouter/webappinstance
- config
- service
- storage
- webappinstance
- webappinstancelog
- web
- datarouter-websocket
- src/main/java/io/datarouter/websocket
- config
- job
- service
- session
- storage/subscription
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
1,014 files changed
+17589
-13262
lines changedLines changed: 4 additions & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
10 | 10 |
| |
11 | 11 |
| |
12 | 12 |
| |
13 |
| - | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + |
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
8 | 8 |
| |
9 | 9 |
| |
10 | 10 |
| |
11 |
| - | |
| 11 | + | |
12 | 12 |
| |
13 | 13 |
| |
14 | 14 |
| |
|
Lines changed: 5 additions & 5 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
22 | 22 |
| |
23 | 23 |
| |
24 | 24 |
| |
25 |
| - | |
| 25 | + | |
26 | 26 |
| |
27 | 27 |
| |
28 | 28 |
| |
| |||
40 | 40 |
| |
41 | 41 |
| |
42 | 42 |
| |
43 |
| - | |
| 43 | + | |
44 | 44 |
| |
45 | 45 |
| |
46 | 46 |
| |
47 |
| - | |
48 |
| - | |
49 |
| - | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
50 | 50 |
| |
51 | 51 |
| |
52 | 52 |
| |
|
Lines changed: 50 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + |
Lines changed: 9 additions & 3 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
15 | 15 |
| |
16 | 16 |
| |
17 | 17 |
| |
18 |
| - | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
19 | 23 |
| |
20 | 24 |
| |
21 | 25 |
| |
22 | 26 |
| |
23 | 27 |
| |
24 | 28 |
| |
| 29 | + | |
25 | 30 |
| |
26 | 31 |
| |
27 |
| - | |
| 32 | + | |
28 | 33 |
| |
29 | 34 |
| |
30 | 35 |
| |
31 |
| - | |
| 36 | + | |
| 37 | + | |
32 | 38 |
| |
33 | 39 |
| |
34 | 40 |
|
Lines changed: 0 additions & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
26 | 26 |
| |
27 | 27 |
| |
28 | 28 |
| |
29 |
| - | |
30 | 29 |
| |
31 | 30 |
| |
32 | 31 |
| |
|
Lines changed: 12 additions & 28 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
22 | 22 |
| |
23 | 23 |
| |
24 | 24 |
| |
| 25 | + | |
25 | 26 |
| |
| 27 | + | |
26 | 28 |
| |
27 | 29 |
| |
28 | 30 |
| |
| |||
34 | 36 |
| |
35 | 37 |
| |
36 | 38 |
| |
37 |
| - | |
38 |
| - | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
39 | 42 |
| |
40 | 43 |
| |
41 | 44 |
| |
| |||
55 | 58 |
| |
56 | 59 |
| |
57 | 60 |
| |
58 |
| - | |
59 | 61 |
| |
60 |
| - | |
61 |
| - | |
62 | 62 |
| |
63 | 63 |
| |
64 | 64 |
| |
65 | 65 |
| |
66 | 66 |
| |
67 |
| - | |
68 | 67 |
| |
69 | 68 |
| |
70 | 69 |
| |
71 | 70 |
| |
72 | 71 |
| |
73 |
| - | |
| 72 | + | |
74 | 73 |
| |
75 | 74 |
| |
76 | 75 |
| |
77 | 76 |
| |
78 | 77 |
| |
| 78 | + | |
79 | 79 |
| |
80 | 80 |
| |
81 | 81 |
| |
| |||
88 | 88 |
| |
89 | 89 |
| |
90 | 90 |
| |
91 |
| - | |
92 | 91 |
| |
93 | 92 |
| |
94 | 93 |
| |
| |||
98 | 97 |
| |
99 | 98 |
| |
100 | 99 |
| |
101 |
| - | |
102 | 100 |
| |
103 | 101 |
| |
104 | 102 |
| |
105 | 103 |
| |
106 | 104 |
| |
107 | 105 |
| |
108 |
| - | |
109 | 106 |
| |
110 | 107 |
| |
111 | 108 |
| |
| |||
126 | 123 |
| |
127 | 124 |
| |
128 | 125 |
| |
129 |
| - | |
130 | 126 |
| |
| 127 | + | |
131 | 128 |
| |
132 | 129 |
| |
133 | 130 |
| |
134 |
| - | |
135 | 131 |
| |
136 | 132 |
| |
| 133 | + | |
137 | 134 |
| |
| 135 | + | |
| 136 | + | |
| 137 | + | |
138 | 138 |
| |
139 | 139 |
| |
140 | 140 |
| |
| |||
152 | 152 |
| |
153 | 153 |
| |
154 | 154 |
| |
155 |
| - | |
156 | 155 |
| |
157 | 156 |
| |
158 | 157 |
| |
| |||
169 | 168 |
| |
170 | 169 |
| |
171 | 170 |
| |
172 |
| - | |
173 | 171 |
| |
174 | 172 |
| |
175 | 173 |
| |
| |||
203 | 201 |
| |
204 | 202 |
| |
205 | 203 |
| |
206 |
| - | |
207 |
| - | |
208 |
| - | |
209 |
| - | |
210 |
| - | |
211 |
| - | |
212 | 204 |
| |
213 | 205 |
| |
214 | 206 |
| |
| |||
233 | 225 |
| |
234 | 226 |
| |
235 | 227 |
| |
236 |
| - | |
237 | 228 |
| |
238 | 229 |
| |
239 |
| - | |
240 | 230 |
| |
241 | 231 |
| |
242 | 232 |
| |
| |||
257 | 247 |
| |
258 | 248 |
| |
259 | 249 |
| |
260 |
| - | |
261 | 250 |
| |
262 | 251 |
| |
263 | 252 |
| |
| |||
270 | 259 |
| |
271 | 260 |
| |
272 | 261 |
| |
273 |
| - | |
274 | 262 |
| |
275 | 263 |
| |
276 | 264 |
| |
| |||
281 | 269 |
| |
282 | 270 |
| |
283 | 271 |
| |
284 |
| - | |
285 | 272 |
| |
286 | 273 |
| |
287 | 274 |
| |
| |||
297 | 284 |
| |
298 | 285 |
| |
299 | 286 |
| |
300 |
| - | |
301 | 287 |
| |
302 | 288 |
| |
303 | 289 |
| |
| |||
322 | 308 |
| |
323 | 309 |
| |
324 | 310 |
| |
325 |
| - | |
326 |
| - | |
327 | 311 |
| |
328 | 312 |
| |
329 | 313 |
| |
|
Lines changed: 8 additions & 5 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
15 | 15 |
| |
16 | 16 |
| |
17 | 17 |
| |
| 18 | + | |
18 | 19 |
| |
19 | 20 |
| |
20 | 21 |
| |
| |||
33 | 34 |
| |
34 | 35 |
| |
35 | 36 |
| |
36 |
| - | |
37 |
| - | |
| 37 | + | |
| 38 | + | |
38 | 39 |
| |
39 | 40 |
| |
| 41 | + | |
40 | 42 |
| |
41 | 43 |
| |
42 | 44 |
| |
| |||
47 | 49 |
| |
48 | 50 |
| |
49 | 51 |
| |
50 |
| - | |
51 |
| - | |
52 |
| - | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
53 | 55 |
| |
54 | 56 |
| |
55 | 57 |
| |
| 58 | + | |
56 | 59 |
| |
57 | 60 |
| |
58 | 61 |
|
0 commit comments