File tree
884 files changed
+17020
-7006
lines changed- datarouter-auth
- src/main/java/io/datarouter/auth
- config
- detail
- model/dto
- role
- service
- session
- storage
- account
- credential
- secret
- permission
- user
- datarouteruser
- deprovisioneduser
- permissionrequest
- saml
- session
- userhistory
- util
- datarouter-auth-web
- src
- main
- java/io/datarouter/auth/web
- cache
- client
- config
- routeset
- job
- readme
- service
- web
- adminedituser
- resources/META-INF/resources/js
- test/java/io/datarouter/auth/web/service
- datarouter-auto-config
- src/main/java/io/datarouter/autoconfig
- config
- service
- datarouter-aws-elb
- src/main/java/io/datarouter/aws/elb/service
- datarouter-aws-memcached
- datarouter-aws-rds
- src/main/java/io/datarouter/aws/rds
- config
- service
- datarouter-aws-s3
- src/main/java/io/datarouter/aws/s3
- config
- node
- request
- datarouter-aws-secrets-manager
- datarouter-aws-sqs
- src
- main/java/io/datarouter/aws/sqs
- config
- service
- test/java/io/datarouter/aws/sqs/test
- datarouter-binary-dto
- src
- main/java/io/datarouter/binarydto
- codec
- fieldcodec/other
- internal
- multi/iostream
- test/java/io/datarouter/binarydto
- datarouter-bytes
- src
- main/java/io/datarouter/bytes
- blockfile
- block
- decoded
- tokens
- io
- read
- metadata
- query
- storage
- impl
- write
- row
- codec/list/intlist
- compress/gzip
- test/java/io/datarouter/bytes/blockfile/test
- datarouter-changelog
- src/main/java/io/datarouter/changelog
- config
- service
- web
- datarouter-checkstyle
- src/main/resources
- datarouter-cluster-setting
- src/main/java/io/datarouter/clustersetting
- config
- service
- storage/clustersetting
- web
- browse
- override/handler
- datarouter-conveyor
- src/main/java/io/datarouter/conveyor
- config
- dto
- queue/configuration
- web
- datarouter-copy-table
- src/main/java/io/datarouter/plugin/copytable
- config
- web
- datarouter-data-export
- src
- main/java/io/datarouter/plugin/dataexport
- config
- util
- test/java/io/datarouter/plugin/dataexport/test
- datarouter-email
- src/main/java/io/datarouter/email
- email
- html
- datarouter-enum
- datarouter-exception
- src/main/java/io/datarouter/exception
- config
- dto
- filter
- service
- storage
- exceptionrecord
- httprecord
- web
- datarouter-filesystem
- src/main/java/io/datarouter/filesystem
- node/object
- raw
- small
- datarouter-gcp-bigtable
- src/main/java/io/datarouter/gcp/bigtable
- config/web
- service
- datarouter-gcp-gcs
- src/main/java/io/datarouter/gcp/gcs
- config
- node
- datarouter-gcp-pubsub
- src/main/java/io/datarouter/client/gcp/pubsub
- client
- config
- job
- datarouter-gcp-spanner
- src/main/java/io/datarouter/gcp/spanner
- config
- ddl
- field
- array
- date
- primitive
- string
- node
- op
- read
- write
- sql
- datarouter-git
- datarouter-graphql
- src/main/java/io/datarouter/graphql
- config
- fetcher
- playground
- util
- web/exception
- datarouter-graphql-client-util
- datarouter-gson
- src
- main/java/io/datarouter/gson
- serializer
- typeadapter
- typeadapterfactory
- test/java/io/datarouter/gson
- serializer
- typeadapter
- typeadapterfactory
- datarouter-http-client
- src
- main/java/io/datarouter/httpclient
- circuitbreaker
- client
- endpoint
- caller
- java
- web
- response
- security
- test/java/io/datarouter/httpclient
- circuitbreaker
- client
- endpoint
- example
- json
- datarouter-inject
- src/main/java/io/datarouter/inject/guice
- datarouter-instrumentation
- src
- main/java/io/datarouter/instrumentation
- exception
- metric
- collector
- node
- token
- relay
- dto
- rml
- type
- task
- trace
- typescript
- validation
- test/java/io/datarouter/instrumentation
- datarouter-job
- src
- main
- java/io/datarouter/job
- config
- detached
- job
- vacuum
- lock
- scheduler
- service
- storage
- joblock
- stopjobrequest
- triggerlock
- util
- web
- resources/META-INF/resources/jsp/admin/datarouter/job
- test/java/io/datarouter/job
- lock
- util
- datarouter-joblet
- src/main/java/io/datarouter/joblet
- codec
- config
- enums
- execute
- handler
- service
- setting
- storage/jobletrequest
- datarouter-joblet-mysql
- datarouter-load-test
- src/main/java/io/datarouter/loadtest/config
- datarouter-logger-config
- src/main/java/io/datarouter/loggerconfig
- config
- service
- storage/loggerconfig
- datarouter-logging
- datarouter-memcached
- src/main/java/io/datarouter/client/memcached
- client
- node
- datarouter-memory
- src/main/java/io/datarouter/client/memory/node/blob
- datarouter-metadata-parent
- datarouter-metric
- src/main/java/io/datarouter/metric
- config
- dashboard/web
- publisher
- service
- template
- datarouter-mockito
- datarouter-model
- src
- main/java/io/datarouter/model
- databean
- entity
- field
- codec
- encoding
- imp
- array
- comparable
- custom
- key
- entity
- base
- primary
- test/java/io/datarouter/model
- field/imp
- key/entity/base
- datarouter-mysql
- src
- main/java/io/datarouter/client/mysql
- ddl
- domain
- execute
- generate
- field/codec
- datetime
- factory
- node
- test/java/io/datarouter/client/mysql
- test/client/imp/mysql/ddl/generate
- datarouter-nodewatch
- src/main/java/io/datarouter/nodewatch
- config
- setting
- job
- joblet
- service
- shadowtable
- codec
- config
- job
- exportimpl
- service
- storage
- storage
- binarydto/storagestats
- clienttype
- service
- table
- latesttablecount
- tablecount
- tablesample
- util
- web/handler
- datarouter-opencensus
- src/main/java/io/datarouter/opencensus/adapter/physical
- datarouter-parent
- datarouter-path-node
- datarouter-rate-limiter
- src
- main/java/io/datarouter/ratelimiter
- config
- util
- web
- test/java/io/datarouter/ratelimiter
- datarouter-redis
- src/main/java/io/datarouter/client/redis
- client
- node
- datarouter-relay
- src
- main/java/io/datarouter/relay
- test/resources
- datarouter-scanner
- src/main/java/io/datarouter/scanner
- datarouter-secret
- src/main/java/io/datarouter/secret
- op/adapter
- service
- datarouter-secret-web
- src/main/java/io/datarouter/secretweb/config
- datarouter-service-config
- datarouter-snapshot
- datarouter-snapshot-manager
- src/main/java/io/datarouter/snapshotmanager
- datarouter-ssh
- src/main/java/io/datarouter/client/ssh
- exception
- datarouter-storage
- src
- main/java/io/datarouter/storage
- callsite
- client
- config
- schema
- dao
- file
- node
- adapter
- callsite/physical
- counter/physical
- trace/physical
- builder
- entity
- op
- combo
- raw/read
- tableconfig
- scratch
- blockfile
- serialize/fieldcache
- setting
- util
- test/java/io/datarouter/storage/test/node/basic
- manyfield
- sorted
- datarouter-task-tracker
- src/main/java/io/datarouter/tasktracker
- config
- service
- storage
- web
- datarouter-testng
- datarouter-trace
- src
- main/java/io/datarouter/trace
- filter
- settings
- storage/binarydto
- test/java/io/datarouter/trace
- datarouter-types
- src
- main/java/io/datarouter/types
- test/java/io/datarouter/types
- datarouter-util
- src
- main/java/io/datarouter/util
- cache
- cached
- io
- lang
- net
- process
- retry
- string
- tracer
- test/java/io/datarouter/util
- cache
- net
- string
- time
- datarouter-virtual-node
- datarouter-web
- src
- main
- java/io/datarouter/web
- api
- endpoint
- external
- mobile
- web
- browse
- config
- digest
- dispatcher
- email
- endpoint
- exception
- export
- handler
- documentation
- mav
- types
- validator
- handlerusage
- homepage
- html/j2html
- bootstrap4
- http
- listener
- monitoring
- latency
- plugins/opencencus/metrics
- relay
- requirejs
- security
- service
- util/http
- exception
- warmup
- resources/META-INF/resources
- jsp/docs
- requirejs
- test/java/io/datarouter/web
- api
- dispatcher
- handler
- documentation
- types
- util/http
- datarouter-webapp-instance
- src/main/java/io/datarouter/webappinstance
- config
- job
- service
- storage/webappinstancelog
- web
- datarouter-websocket
- src/main/java/io/datarouter/websocket
- config
- service
- session
- storage/session
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
884 files changed
+17020
-7006
lines changedLines 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: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
22 | 22 |
| |
23 | 23 |
| |
24 | 24 |
| |
25 |
| - | |
| 25 | + | |
26 | 26 |
| |
27 | 27 |
| |
28 | 28 |
| |
|
Lines changed: 3 additions & 3 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
19 | 19 |
| |
20 | 20 |
| |
21 | 21 |
| |
22 |
| - | |
| 22 | + | |
23 | 23 |
| |
24 | 24 |
| |
25 | 25 |
| |
26 | 26 |
| |
27 | 27 |
| |
28 | 28 |
| |
29 | 29 |
| |
30 |
| - | |
| 30 | + | |
31 | 31 |
| |
32 | 32 |
| |
33 | 33 |
| |
34 |
| - | |
| 34 | + | |
35 | 35 |
| |
36 | 36 |
| |
37 | 37 |
| |
|
Lines changed: 10 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
36 | 36 |
| |
37 | 37 |
| |
38 | 38 |
| |
| 39 | + | |
| 40 | + | |
| 41 | + | |
39 | 42 |
| |
40 | 43 |
| |
41 | 44 |
| |
42 | 45 |
| |
43 | 46 |
| |
| 47 | + | |
44 | 48 |
| |
45 | 49 |
| |
46 | 50 |
| |
| |||
50 | 54 |
| |
51 | 55 |
| |
52 | 56 |
| |
| 57 | + | |
53 | 58 |
| |
54 | 59 |
| |
55 | 60 |
| |
| |||
77 | 82 |
| |
78 | 83 |
| |
79 | 84 |
| |
| 85 | + | |
| 86 | + | |
| 87 | + | |
| 88 | + | |
| 89 | + | |
80 | 90 |
|
Lines changed: 0 additions & 7 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
34 | 34 |
| |
35 | 35 |
| |
36 | 36 |
| |
37 |
| - | |
38 | 37 |
| |
39 | 38 |
| |
40 | 39 |
| |
| |||
44 | 43 |
| |
45 | 44 |
| |
46 | 45 |
| |
47 |
| - | |
48 | 46 |
| |
49 | 47 |
| |
50 | 48 |
| |
| |||
59 | 57 |
| |
60 | 58 |
| |
61 | 59 |
| |
62 |
| - | |
63 |
| - | |
64 |
| - | |
65 |
| - | |
66 |
| - | |
67 | 60 |
| |
68 | 61 |
| |
69 | 62 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
34 | 34 |
| |
35 | 35 |
| |
36 | 36 |
| |
37 |
| - | |
| 37 | + | |
38 | 38 |
| |
39 | 39 |
| |
40 | 40 |
| |
|
Lines changed: 4 additions & 24 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
19 | 19 |
| |
20 | 20 |
| |
21 | 21 |
| |
22 |
| - | |
23 | 22 |
| |
24 | 23 |
| |
25 | 24 |
| |
26 | 25 |
| |
27 | 26 |
| |
28 |
| - | |
29 | 27 |
| |
30 | 28 |
| |
31 |
| - | |
32 | 29 |
| |
33 | 30 |
| |
34 |
| - | |
35 | 31 |
| |
36 | 32 |
| |
37 |
| - | |
38 | 33 |
| |
39 | 34 |
| |
40 | 35 |
| |
| |||
59 | 54 |
| |
60 | 55 |
| |
61 | 56 |
| |
| 57 | + | |
62 | 58 |
| |
63 | 59 |
| |
64 | 60 |
| |
65 | 61 |
| |
66 | 62 |
| |
67 |
| - | |
68 | 63 |
| |
| 64 | + | |
69 | 65 |
| |
70 | 66 |
| |
71 | 67 |
| |
| |||
96 | 92 |
| |
97 | 93 |
| |
98 | 94 |
| |
99 |
| - | |
100 | 95 |
| |
101 | 96 |
| |
102 | 97 |
| |
| |||
107 | 102 |
| |
108 | 103 |
| |
109 | 104 |
| |
110 |
| - | |
111 | 105 |
| |
112 | 106 |
| |
113 | 107 |
| |
114 | 108 |
| |
115 | 109 |
| |
116 | 110 |
| |
117 | 111 |
| |
118 |
| - | |
119 | 112 |
| |
120 | 113 |
| |
121 | 114 |
| |
| |||
139 | 132 |
| |
140 | 133 |
| |
141 | 134 |
| |
| 135 | + | |
142 | 136 |
| |
143 | 137 |
| |
144 | 138 |
| |
145 | 139 |
| |
146 | 140 |
| |
147 | 141 |
| |
148 | 142 |
| |
| 143 | + | |
149 | 144 |
| |
150 | 145 |
| |
151 | 146 |
| |
152 | 147 |
| |
153 | 148 |
| |
154 | 149 |
| |
155 | 150 |
| |
156 |
| - | |
157 |
| - | |
158 |
| - | |
159 |
| - | |
160 | 151 |
| |
161 | 152 |
| |
162 | 153 |
| |
| |||
166 | 157 |
| |
167 | 158 |
| |
168 | 159 |
| |
169 |
| - | |
170 | 160 |
| |
171 | 161 |
| |
172 | 162 |
| |
| |||
183 | 173 |
| |
184 | 174 |
| |
185 | 175 |
| |
186 |
| - | |
187 |
| - | |
188 | 176 |
| |
189 | 177 |
| |
190 | 178 |
| |
| |||
221 | 209 |
| |
222 | 210 |
| |
223 | 211 |
| |
224 |
| - | |
225 |
| - | |
226 |
| - | |
227 |
| - | |
228 |
| - | |
229 |
| - | |
230 |
| - | |
231 | 212 |
| |
232 | 213 |
| |
233 | 214 |
| |
| |||
259 | 240 |
| |
260 | 241 |
| |
261 | 242 |
| |
262 |
| - | |
263 | 243 |
| |
264 | 244 |
| |
265 | 245 |
| |
|
Lines changed: 2 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
16 | 16 |
| |
17 | 17 |
| |
18 | 18 |
| |
19 |
| - | |
| 19 | + | |
20 | 20 |
| |
21 | 21 |
| |
22 | 22 |
| |
| |||
39 | 39 |
| |
40 | 40 |
| |
41 | 41 |
| |
42 |
| - | |
| 42 | + | |
43 | 43 |
| |
44 | 44 |
| |
45 | 45 |
| |
|
Lines changed: 13 additions & 10 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
16 | 16 |
| |
17 | 17 |
| |
18 | 18 |
| |
19 |
| - | |
| 19 | + | |
20 | 20 |
| |
21 | 21 |
| |
22 | 22 |
| |
| |||
44 | 44 |
| |
45 | 45 |
| |
46 | 46 |
| |
47 |
| - | |
48 |
| - | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
49 | 52 |
| |
50 |
| - | |
| 53 | + | |
51 | 54 |
| |
52 | 55 |
| |
53 |
| - | |
| 56 | + | |
54 | 57 |
| |
55 |
| - | |
| 58 | + | |
56 | 59 |
| |
57 |
| - | |
| 60 | + | |
58 | 61 |
| |
59 | 62 |
| |
60 | 63 |
| |
61 |
| - | |
| 64 | + | |
62 | 65 |
| |
63 | 66 |
| |
64 | 67 |
| |
65 |
| - | |
| 68 | + | |
66 | 69 |
| |
67 | 70 |
| |
68 | 71 |
| |
69 | 72 |
| |
70 | 73 |
| |
71 |
| - | |
| 74 | + | |
72 | 75 |
| |
73 | 76 |
| |
74 | 77 |
| |
|
Lines changed: 7 additions & 7 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
16 | 16 |
| |
17 | 17 |
| |
18 | 18 |
| |
19 |
| - | |
| 19 | + | |
20 | 20 |
| |
21 | 21 |
| |
22 | 22 |
| |
| |||
27 | 27 |
| |
28 | 28 |
| |
29 | 29 |
| |
30 |
| - | |
31 | 30 |
| |
32 | 31 |
| |
33 |
| - | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
34 | 35 |
| |
35 | 36 |
| |
36 | 37 |
| |
37 | 38 |
| |
38 | 39 |
| |
39 | 40 |
| |
40 |
| - | |
41 |
| - | |
42 |
| - | |
43 |
| - | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
44 | 44 |
| |
45 | 45 |
| |
46 | 46 |
| |
|
Lines changed: 43 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 | + |
0 commit comments