Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Contribute to GitLab
Sign in / Register
Toggle navigation
D
dlink
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
zhaowei
dlink
Commits
d88154a7
Commit
d88154a7
authored
Apr 10, 2022
by
wenmo
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
[Optimization-382][alert,metadata] Optimization SPI
parent
7b389ffc
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
14 additions
and
19 deletions
+14
-19
Alert.java
...dlink-alert-base/src/main/java/com/dlink/alert/Alert.java
+5
-8
Driver.java
...-base/src/main/java/com/dlink/metadata/driver/Driver.java
+9
-11
No files found.
dlink-alert/dlink-alert-base/src/main/java/com/dlink/alert/Alert.java
View file @
d88154a7
package
com
.
dlink
.
alert
;
import
com.dlink.assertion.Asserts
;
import
sun.misc.Service
;
import
java.util.Iterator
;
import
java.util.Optional
;
import
java.util.ServiceLoader
;
import
com.dlink.assertion.Asserts
;
/**
* Alert
...
...
@@ -17,9 +15,8 @@ public interface Alert {
static
Optional
<
Alert
>
get
(
AlertConfig
config
)
{
Asserts
.
checkNotNull
(
config
,
"报警组件配置不能为空"
);
Iterator
<
Alert
>
providers
=
Service
.
providers
(
Alert
.
class
);
while
(
providers
.
hasNext
())
{
Alert
alert
=
providers
.
next
();
ServiceLoader
<
Alert
>
alerts
=
ServiceLoader
.
load
(
Alert
.
class
);
for
(
Alert
alert
:
alerts
)
{
if
(
alert
.
canHandle
(
config
.
getType
()))
{
return
Optional
.
of
(
alert
.
setConfig
(
config
));
}
...
...
dlink-metadata/dlink-metadata-base/src/main/java/com/dlink/metadata/driver/Driver.java
View file @
d88154a7
package
com
.
dlink
.
metadata
.
driver
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.Optional
;
import
java.util.ServiceLoader
;
import
com.dlink.assertion.Asserts
;
import
com.dlink.exception.MetaDataException
;
import
com.dlink.metadata.result.JdbcSelectResult
;
...
...
@@ -7,12 +12,6 @@ import com.dlink.model.Column;
import
com.dlink.model.Schema
;
import
com.dlink.model.Table
;
import
com.dlink.result.SqlExplainResult
;
import
sun.misc.Service
;
import
java.util.Iterator
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.Optional
;
/**
* Driver
...
...
@@ -24,11 +23,10 @@ public interface Driver {
static
Optional
<
Driver
>
get
(
DriverConfig
config
)
{
Asserts
.
checkNotNull
(
config
,
"数据源配置不能为空"
);
Iterator
<
Driver
>
providers
=
Service
.
providers
(
Driver
.
class
);
while
(
providers
.
hasNext
())
{
Driver
gainer
=
providers
.
next
();
if
(
gainer
.
canHandle
(
config
.
getType
()))
{
return
Optional
.
of
(
gainer
.
setDriverConfig
(
config
));
ServiceLoader
<
Driver
>
drivers
=
ServiceLoader
.
load
(
Driver
.
class
);
for
(
Driver
driver
:
drivers
)
{
if
(
driver
.
canHandle
(
config
.
getType
()))
{
return
Optional
.
of
(
driver
.
setDriverConfig
(
config
));
}
}
return
Optional
.
empty
();
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment