Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
398 commits
Select commit Hold shift + click to select a range
a3a2835
fixbug: register subscriber with dataId which not exist, add retry …
Jan 16, 2021
af722b4
async log appender
dzdx Jan 16, 2021
74ef73d
read write lock
dzdx Jan 18, 2021
9a1a0df
preempt for ChangeFetchTask
Jan 18, 2021
1dc9d92
- clientoff do not iterate the datastore
Jan 18, 2021
c3e8812
fix pmd
Jan 19, 2021
beef5e1
datachange request with batch notify
Jan 19, 2021
c2fdfd3
config netty watermark
Jan 20, 2021
070e544
- control sync session parallelly
Jan 20, 2021
5975374
- sub_interface use datum.version as push.version
Jan 21, 2021
265c738
[bugfix] not fetch all revision
dzdx Jan 21, 2021
ba6bca7
PullRequest: 145 leader epoch change only when slot leader changes &&…
Jan 21, 2021
6a42ea9
batch pub data
Jan 22, 2021
ff0445d
- threadpoll check full
Jan 23, 2021
a88c8cf
- fix pmd
Jan 23, 2021
7fd1708
refactor boltserver
Jan 23, 2021
e035ba3
- fix test
Jan 23, 2021
2f559af
break loop in slotsyncing when slot owner modify
Jan 26, 2021
1243367
fix: sync add dataInfoIds, get summary could not skip the dataInfoId…
Jan 26, 2021
0e1154a
fix checkempty of sync result
Jan 26, 2021
c6ade5d
PullRequest: 162 fix bug that slot table may has dup leader and follower
Jan 26, 2021
11800a4
fix sync loop
Jan 26, 2021
b8a95de
fix pmd
Jan 26, 2021
4b185a9
session compact do not incr publisher version
Jan 27, 2021
e8ca1ea
PullRequest: 169 change threshold
Jan 28, 2021
ee293ff
- fix log
Jan 28, 2021
606d7d3
fix testcase
Jan 28, 2021
8cea1b4
add put log
Jan 28, 2021
39eb3a3
add log
Jan 29, 2021
5bea3ff
add log
Jan 29, 2021
9554642
PullRequest: 170 maven reformat
Feb 1, 2021
74ebfe8
- get slotconfig from env
Feb 1, 2021
789c67f
fix bug that balance-slot will crash when targetSlots is smaller than…
Feb 1, 2021
952a6ed
add log for max move and candidates
Feb 1, 2021
024bbd4
slot chaos
nocvalight Feb 3, 2021
375532b
retry && exit on bootstrap failed
dzdx Feb 2, 2021
a11ffad
slot chaos
nocvalight Feb 3, 2021
3676d5f
balance improve
Feb 2, 2021
a2c32fe
fix pmd
Feb 4, 2021
c960d36
add log for slot assign
Feb 4, 2021
bffaa86
fix balance follower dups
Feb 5, 2021
cd88132
add leader low watermark check
Feb 5, 2021
870bef1
addlog
Feb 5, 2021
a60e56c
inter the sessionprocessId in datanode
Feb 5, 2021
0e6062e
fix get slot config
Feb 5, 2021
b0f39e7
bugfix/session update meta ips by heartbeat
dzdx Feb 7, 2021
5ab5d33
fix rate dump
dzdx Feb 7, 2021
4d257fa
PullRequest: 188 hotfix/logback-to-log4j2
Feb 8, 2021
d8806fd
cache digest fixed rate
dzdx Feb 7, 2021
9eac00a
cleanup app subscriber
dzdx Feb 8, 2021
e0750b6
cleanup app publisher
dzdx Feb 19, 2021
4b5ad2f
optimize network and cpu savings of syncing
Feb 8, 2021
6dfc820
fix pmd
Feb 20, 2021
9b8cf36
add test case for forever loop
Feb 20, 2021
9d8d7fb
fix balance
Feb 20, 2021
d05991a
format
Feb 20, 2021
96eb92b
fix pmd
Feb 20, 2021
66b9d18
- fix sync leader interval
Feb 20, 2021
06b5ecf
fix config name
Feb 21, 2021
b46f7db
fix push delay
Feb 21, 2021
66e34ba
support handle change delay
Feb 22, 2021
23cac1a
make it default for maven test running
Feb 23, 2021
01c6301
remove all logback dependencies except sofa-registry-client maven module
Feb 22, 2021
2886faf
remove all logback config files
Feb 22, 2021
1232d87
add additional on-mis-match
Feb 22, 2021
bfa7d27
spring-boot-test logger default change to log4j2
Feb 22, 2021
8dd6787
all tests passed
Feb 23, 2021
bddc374
- double check slot access of get datum/datumversion
Feb 23, 2021
77dacd6
log skip change reason
Feb 24, 2021
cdf81e2
fix CR
Feb 24, 2021
07c2b68
PullRequest: 202 slot monitoring
Feb 24, 2021
d054983
PullRequest: 204 fix the weak dependency bug
Feb 25, 2021
0d27735
replace Datum with SubDatum in sub/push, SubDatum is smaller
Feb 24, 2021
953aab3
PullRequest: 205 application run
Feb 25, 2021
2908f41
- fetch datum version by sub dataId, avoid the slot contains too muc…
Feb 25, 2021
4edae92
PullRequest: 207 fix bug that SlotTableStats throws NPE
Feb 26, 2021
b8f5329
add trace for push
Feb 26, 2021
94991a8
add ut
Feb 28, 2021
7f73489
add UT
Mar 1, 2021
cd4402d
support save metadata into db
nocvalight Jan 15, 2021
49014e0
refactor
Mar 1, 2021
c7a6908
commit metadata log
nocvalight Mar 2, 2021
128f129
1. MetaServer is now available to trace follower status from data thr…
Feb 25, 2021
1e45d14
sleep more for unit test
Mar 2, 2021
9ea6cd4
commit log appender
nocvalight Mar 2, 2021
4438755
[bugfix] slot stats need to update when follower updates
Mar 3, 2021
4996e7c
slot stats also change when leaderEpoch same but slot is diff
Mar 3, 2021
715f02a
make it easier for trace data lag
Mar 3, 2021
1cfde3e
new empty datum if dataId which in sub(session) but not in dataNode
Mar 3, 2021
f12d185
add prometheus metrics for meta-server
Mar 3, 2021
f53c851
make metrics name valid
Mar 3, 2021
82be7ad
add log
Mar 4, 2021
76ec7dc
add log
Mar 8, 2021
cb83be3
[bugfix]fix bug that balance task will generate a lower slot leader e…
Mar 8, 2021
5b19cdd
all unit test passed
Mar 8, 2021
abda3ed
[feature]slot arrange could stop through REST API
Mar 8, 2021
e6e3916
[bugfix]fix bug that balance task will generate a lower slot leader e…
Mar 8, 2021
86e3371
all unit test passed
Mar 8, 2021
6d0afb0
[feature]slot arrange could stop through REST API
Mar 8, 2021
6bdc6af
Merge branch 'feature/meta-slot-autoassign-stoppable' of code.alipay.…
Mar 8, 2021
2e1a534
remove un-used imports
Mar 8, 2021
50c7ba6
optimize object state due to comments
Mar 8, 2021
de63823
avoid running too much
Mar 8, 2021
1e9ba62
fix unit test
Mar 8, 2021
f17167e
slot stats isolate stable datas reported by data-server
Mar 8, 2021
b6ac515
data server lag report more accurate
Mar 8, 2021
73e0171
remove un-used import
Mar 8, 2021
2681b48
will not report once leader sync task is null
Mar 8, 2021
a543a3e
make changes due to git comments
Mar 8, 2021
b36e2e1
remove un-used imports
Mar 8, 2021
40b00e3
fix unit tests
Mar 8, 2021
39d6fe8
remove un-unsed imports
Mar 8, 2021
a41d096
1. data reports will be ignored and warned if info is not matched (li…
Mar 8, 2021
f1047f9
Merge branch 'hotfix/slotstats-isolate-stable-data' of code.alipay.co…
Mar 8, 2021
51ddd21
reformat
Mar 8, 2021
b0d8193
add ut
Mar 1, 2021
3f6cb6b
add test for slotManager
Mar 11, 2021
bf623fb
query meta address by http api
dzdx Feb 13, 2021
8f61e8d
fix cpu: not copy map for iter
Mar 14, 2021
5a87e74
reduce the overhead of getdatumversions
Mar 14, 2021
f676fa8
fix temp test
Mar 15, 2021
5c5d912
- ut:slot.sync
Mar 15, 2021
dd0b50e
add ut
Mar 16, 2021
c5ab53f
change io wait time
Mar 16, 2021
f740dc0
remove useless field
dzdx Mar 16, 2021
0332e06
fix unit test
Mar 8, 2021
cd88445
slot stats isolate stable datas reported by data-server
Mar 8, 2021
6192619
data server lag report more accurate
Mar 8, 2021
046b0ad
1. data reports will be ignored and warned if info is not matched (li…
Mar 8, 2021
c24080b
make changes due to git comments
Mar 8, 2021
4700c3b
remove un-used imports
Mar 8, 2021
60fa5b6
reformat
Mar 8, 2021
530561c
Merge branch 'hotfix/slotstats-isolate-stable-data' of code.alipay.co…
Mar 17, 2021
6a8a99c
remove un-used imports
Mar 17, 2021
54be550
remove raft from meta-server and data/session
Mar 8, 2021
815dbf2
Merge branch 'EI61836181_20201222' into feature/anti-raft
Mar 18, 2021
64a9829
[bugfix] trigger push when subscriber version inconsistency
dzdx Mar 18, 2021
1138a39
PullRequest: 232 add filter for all rest controllers to redirect http…
Mar 18, 2021
6bd3e64
fix comment
nocvalight Mar 18, 2021
9dc1171
format with google style
Mar 19, 2021
9b9d560
fix bug meta warmup time error
Mar 19, 2021
0354897
remove un-used import
Mar 19, 2021
9784089
reformat
Mar 19, 2021
ee2307a
make it correct
Mar 19, 2021
867604e
remove useless unit test
Mar 19, 2021
22d96f5
set watermark
Mar 22, 2021
2e8e48d
1. set meta elector cluster; 2. return meta leader when session and d…
nocvalight Mar 21, 2021
0442d28
resolve meta leader from http request
nocvalight Mar 22, 2021
38a0d35
fetch metadata datacenter from jdbc common config instead of from ses…
nocvalight Mar 22, 2021
0f5adf5
fix conflict error
nocvalight Mar 22, 2021
16bcd9a
proto generate
dzdx Mar 23, 2021
116fc5e
[feature]seamless upgrade api support
Mar 24, 2021
e863ccd
adjust for test cases
Mar 26, 2021
bff6be0
check highWaterMark when assign leader
Mar 25, 2021
2c35193
client off boardcast
dzdx Mar 28, 2021
c49a418
meta heartbeat on leader
nocvalight Mar 29, 2021
6a0296d
fix registry-elector.log
nocvalight Mar 29, 2021
b7a2947
format code
nocvalight Mar 29, 2021
5bb4479
- add registerId in subpublisher
Mar 29, 2021
ac7d68b
PullRequest: 243 config start with 'registry'
Mar 29, 2021
b47ad89
fix compile
Mar 30, 2021
7666d20
fix meta heartbeat
nocvalight Mar 30, 2021
cb13684
fix meta heartbeat
nocvalight Mar 30, 2021
2a66b6c
fix meta heartbeat
nocvalight Mar 30, 2021
f8040a3
add log when meta renew
nocvalight Mar 30, 2021
146992f
remove unuse import
nocvalight Mar 30, 2021
e534ae5
fix test
Mar 30, 2021
8d5e137
add meta heartbeat handler
nocvalight Mar 30, 2021
bbfb04d
formet code
nocvalight Mar 30, 2021
487ff8d
set slotnum=256
Mar 31, 2021
6ae3dfc
add ut for datachange
Apr 1, 2021
ab398ba
zone clientoff fault-tolerant
dzdx Apr 6, 2021
b30bbf2
PullRequest: 255 hotfix/increase-meta-test-coverage
Apr 8, 2021
67f57ef
add notify port
Apr 8, 2021
153f837
add provide data cache on meta leader && add metadata heartbeat testcase
nocvalight Apr 6, 2021
c39022a
add provide data version
nocvalight Apr 8, 2021
bcb7c94
remove DATE_SUB function and AppRevisionQueryModel cache
nocvalight Apr 9, 2021
9bbb979
remove unuse import
nocvalight Apr 9, 2021
2ddc6e4
improve: all channel managed by boltserver
Apr 9, 2021
801a426
improve metadata sql
nocvalight Apr 10, 2021
0d89c7a
ut test
Apr 10, 2021
2312a8e
ut
Apr 11, 2021
125999d
PullRequest: 264 refactor DefaultExecutorFactory
Apr 12, 2021
c491f73
ut
Apr 11, 2021
7e73b21
remove batch insert on dupicate key update
nocvalight Apr 12, 2021
aeb9427
interface_apps_index increment update by id
nocvalight Apr 12, 2021
83971d0
app datum syncer
dzdx Apr 9, 2021
223ecf5
ut
Apr 12, 2021
dc96439
boltExchange bean format
nocvalight Apr 14, 2021
b116d58
code format
nocvalight Apr 14, 2021
1fd4164
ut
Apr 12, 2021
c6bdff6
autowired by profile
nocvalight Apr 14, 2021
8551991
ut
Apr 15, 2021
6b8cd3d
ut
Apr 15, 2021
0628daa
six stop push switch
nocvalight Apr 16, 2021
ef51f01
add attributes
dzdx Apr 16, 2021
3c1b242
ut
Apr 15, 2021
f95fa06
excludes jraft test
Apr 16, 2021
17b03ac
fix stop push test case
nocvalight Apr 16, 2021
c1c925a
[feature]meta shall learn slot-table form data heart-beat
Apr 19, 2021
6258a98
remove useless imports
Apr 19, 2021
347aa07
changes due to comments
Apr 19, 2021
45c03f8
fix issued unit test
Apr 19, 2021
98194e6
update
nocvalight Apr 15, 2021
a2a0dd2
format code
nocvalight Apr 19, 2021
efc29e9
format code
nocvalight Apr 19, 2021
9c26e3e
ut
Apr 19, 2021
4b3ce51
fix issued unit test
Apr 19, 2021
5bc364a
ut
Apr 19, 2021
2f92a40
add meta scheduler
nocvalight Apr 20, 2021
9ba0303
ut
Apr 19, 2021
d64ef9b
fix h2 replace into
dzdx Apr 21, 2021
d414c99
ut
Apr 19, 2021
6920a69
retry load metadata
dzdx Apr 21, 2021
4a8366c
ut
Apr 21, 2021
323902e
调试aci
Apr 23, 2021
42cfbdc
fix data startup error
Apr 24, 2021
bcb2c54
ut
Apr 23, 2021
4252853
ut
Apr 25, 2021
1bc6d97
ut
Apr 26, 2021
6e6d5c3
fix sql
dzdx Apr 26, 2021
49d208d
fix calc delay when push is not sub
Apr 27, 2021
0fcb8f2
fix ut
Apr 27, 2021
2389ecc
fix map size & slot updating set with cas
May 7, 2021
c1f811e
fix map size & slot updating set with cas
May 7, 2021
2de6532
check leader before refresh table
Apr 30, 2021
2ba66b6
set bolt tp size
May 7, 2021
5926500
set bolt tp size
May 7, 2021
781c136
- app.interval=100
May 7, 2021
48ef575
PullRequest: 295 fix bug that meta will not update slot state when le…
May 8, 2021
1e38759
fix pushtrace delay of sub
May 8, 2021
d95016c
add executor for meta change
May 9, 2021
5e23db7
- fix getV too much log
May 9, 2021
6dd44eb
fix interface apps mapping cache
May 9, 2021
82ebb03
code format
May 10, 2021
f9f7746
add env to switch to confreg version generator
May 11, 2021
551222b
watch datum version
May 11, 2021
51f9cf0
add trigger timestamp for push.trace
May 11, 2021
b989f21
1.remove heartbeat loading cache; 2.query db when register; 3.batch q…
May 11, 2021
6c398d7
PullRequest: 308 add more logs for http control api
May 12, 2021
2265c0a
- add renew log
May 12, 2021
9f5d89f
fix push trace
May 13, 2021
0136e9a
add git props
May 13, 2021
fda5f8a
fix
May 13, 2021
9fd79d8
Migrate from TravisCI to Github Actions (#155)
NickNYU Mar 25, 2021
1a4451b
1.在JDBC模块中复制DefaultCommonConfigBean、MetadataConfigBean、MetaElectorCon…
LXPWing Jul 12, 2021
1bdf871
提交保存
LXPWing Jul 30, 2021
666680d
提交保存
LXPWing Jul 30, 2021
6a0c535
1.增加ProvideDataDomain类。
LXPWing Aug 8, 2021
db9100d
MetaRaftLeaderElector增加NullPointException捕获
LXPWing Aug 15, 2021
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
60 changes: 60 additions & 0 deletions .aci.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,60 @@
stages: # 定义了一条pipeline
- 代码检测 # 定义了stage
- 测试
- 编译

#- 发布JAR包

PMD扫描: # 定义了一个job
stage: 代码检测 # 绑定到stage
plugin: PMD # 指定使用的插件
checkRule: # 校验结果
- pmd1 = 0 && pmd2 = 0

STC扫描:
stage: 代码检测
plugin: STC
checkRule:
- stc = 0

# see https://yuque.antfin.com/linke/help/kg1p34#pBvc2
单元测试:
stage: 测试
plugin: LINKQ-UT # java单元测试插件
checkRule:
- passRate = 100
tools:
jdk: '1.8' #jdk版本枚举:1.6、1.7、1.8
maven: 3.2.5
parameters:
encoding: UTF-8 # 编码设置
COVERAGE_EXCLUSIONS: '**/bootstrap/**,**/integration/**,**/client/pb/**,**/MetaApplication,**/registry/jraft/**,**/DataApplication,**/SessionApplication' # 覆盖率排除
pluginConfig:
markdown: admin/result.md # 向页面输出一些自定义内容
aciTags: 8G

#see https://code.alipay.com/common_release/avatarpoc/blob/master/.aci.test.yml
集成测试:
stage: 测试
plugin: LINKQ-IT # java集成测试插件
checkRule:
- passRate = 100
tools:
jdk: '1.8'
parameters:
encoding: UTF-8 # 编码设置
pluginConfig:
privateRepo: false, # 是否是私有仓库
parallelCount: 1 # 并发执行个数
enableOracle: false # 是否依赖Oracle

编译:
stage: 编译
plugin: ANT-BUILD # 使用插件ANT-BUILD
pluginConfig:
image: reg.docker.alibaba-inc.com/antb/sofa-build:0.0.2
script:
- export PATH=$PATH:/opt/taobao/java/bin:/opt/taobao/maven/bin
- java -version
- mvn -version
- mvn clean package -Dmaven.test.skip=true -Pdev
28 changes: 28 additions & 0 deletions .github/workflows/maven.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,28 @@
# This workflow will build a Java project with Maven
# For more information see: https://help.github.com/actions/language-and-framework-guides/building-and-testing-java-with-maven

name: Java CI with Maven

on:
push:
branches: [ master ]
pull_request:
branches: [ master ]

jobs:
build:

runs-on: ubuntu-latest

steps:
- uses: actions/checkout@v2
- name: Set up JDK 1.8
uses: actions/setup-java@v1
with:
java-version: 1.8
- name: Build with Maven
run: mvn clean install -DskipTests -B -V
&& sh ./tools/check_format.sh
&& mvn clean test
- name: Codecov
uses: codecov/codecov-action@v1
3 changes: 2 additions & 1 deletion .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -16,4 +16,5 @@ dependency-reduced-pom.xml

# log
logs/
*.log
*.log
LOG_HOME_IS_UNDEFINED
65 changes: 65 additions & 0 deletions .master.aci.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,65 @@
stages: # 定义了一条pipeline
- 代码检测 # 定义了stage
- 测试
- 编译
- 发布JAR包

PMD扫描: # 定义了一个job
stage: 代码检测 # 绑定到stage
plugin: PMD # 指定使用的插件
checkRule: # 校验结果
- pmd1 = 0 && pmd2 = 0

STC扫描:
stage: 代码检测
plugin: STC
checkRule:
- stc = 0

单元测试:
stage: 测试
plugin: LINKQ-UT # java单元测试插件
checkRule:
- passRate = 100
pluginConfig:
markdown: admin/result.md # 向页面输出一些自定义内容

#see https://code.alipay.com/common_release/avatarpoc/blob/master/.aci.test.yml
集成测试:
stage: 测试
plugin: LINKQ-IT # java集成测试插件
checkRule:
- passRate = 100
tools:
jdk: '1.8'
parameters:
encoding: UTF-8 # 编码设置
pluginConfig:
privateRepo: false, # 是否是私有仓库
parallelCount: 1 # 并发执行个数
enableOracle: false # 是否依赖Oracle

编译:
stage: 编译
plugin: ANT-BUILD # 使用插件ANT-BUILD
pluginConfig:
image: reg.docker.alibaba-inc.com/antb/sofa-build:0.0.2
script:
- export PATH=$PATH:/opt/taobao/java/bin:/opt/taobao/maven/bin
- java -version
- mvn -version
- mvn clean package -Dmaven.test.skip=true -Pdev

发布JAR包:
stage: 发布JAR包
plugin: ANT-BUILD
pluginConfig:
image: reg.docker.alibaba-inc.com/antb/jarbuild:0.0.1
script:
- java -version
- mvn -version
- sed -i '/<mirrors>/,/<\/mirrors>/d' /opt/taobao/maven_settings/settings-release.xml
- sed -i '/<profiles>/,/<\/profiles>/d' /opt/taobao/maven_settings/settings-release.xml
- echo '#############relase'
- cat /opt/taobao/maven_settings/settings-release.xml
- mvn clean deploy -Dmaven.test.skip=true -s /opt/taobao/maven_settings/settings-release.xml -Pdev -Pantcode-release
4 changes: 3 additions & 1 deletion .travis.yml
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
language: java
sudo: false

dist: trusty

jdk:
- oraclejdk8

Expand All @@ -12,4 +14,4 @@ script:
- sh ./tools/check_format.sh

after_success:
- bash <(curl -s https://codecov.io/bash)
- bash <(curl -s https://codecov.io/bash)
2 changes: 2 additions & 0 deletions Makefile
Original file line number Diff line number Diff line change
@@ -0,0 +1,2 @@
proto:
protoc-3.5.1 --proto_path=./server/common/model/src/main/resources/proto --java_out=server/common/model/src/main/java server/common/model/src/main/resources/proto/*.proto
8 changes: 4 additions & 4 deletions README.md
Original file line number Diff line number Diff line change
@@ -1,13 +1,13 @@
# SOFARegistry

[![Build Status](https://travis-ci.com/alipay/sofa-registry.svg?branch=master)](https://travis-ci.com/alipay/sofa-registry)
[![Java CI with Maven](https://github.com/sofastack/sofa-registry/actions/workflows/maven.yml/badge.svg)](https://github.com/sofastack/sofa-registry/actions/workflows/maven.yml)
![license](https://img.shields.io/badge/license-Apache--2.0-green.svg)
[![Coverage Status](https://codecov.io/gh/alipay/sofa-registry/branch/master/graph/badge.svg)](https://codecov.io/gh/alipay/sofa-registry)
![maven](https://img.shields.io/github/release/alipay/sofa-registry.svg)
[![Coverage Status](https://codecov.io/gh/alipay/sofa-registry/branch/master/graph/badge.svg)](https://codecov.io/gh/sofastack/sofa-registry)
![maven](https://img.shields.io/github/release/sofastack/sofa-registry.svg)

SOFARegistry 是蚂蚁金服开源的一个生产级、高时效、高可用的服务注册中心。SOFARegistry 最早源自于淘宝的 ConfigServer,十年来,随着蚂蚁金服的业务发展,注册中心架构已经演进至第五代。目前 SOFARegistry 不仅全面服务于蚂蚁金服的自有业务,还随着蚂蚁金融科技服务众多合作伙伴,同时也兼容开源生态。SOFARegistry 采用 AP 架构,支持秒级时效性推送,同时采用分层架构支持无限水平扩展。

## 功能特性
## 功能特性

- 支持服务发布与服务订阅
- 支持服务变更时的主动推送
Expand Down
8 changes: 4 additions & 4 deletions client/all/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@

<groupId>com.alipay.sofa</groupId>
<artifactId>registry-client-all</artifactId>
<version>5.2.0-SNAPSHOT</version>
<version>6.0.1</version>

<name>${project.groupId}:${project.artifactId}</name>
<url>http://github.com/alipay/sofa-registry</url>
Expand Down Expand Up @@ -52,11 +52,11 @@
<maven.compiler.source>1.6</maven.compiler.source>
<maven.compiler.target>1.6</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<bolt.version>1.4.6</bolt.version>
<hessian.version>3.3.6</hessian.version>
<bolt.version>1.6.2</bolt.version>
<hessian.version>3.3.8</hessian.version>
<lookout.version>1.5.2</lookout.version>
<sofa.common.tools.version>1.0.12</sofa.common.tools.version>
<netty.version>4.1.25.Final</netty.version>
<netty.version>4.1.42.Final</netty.version>
<slf4j.version>1.7.21</slf4j.version>
<main.user.dir>../../</main.user.dir>
</properties>
Expand Down
2 changes: 1 addition & 1 deletion client/api/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
<parent>
<groupId>com.alipay.sofa</groupId>
<artifactId>registry-client-parent</artifactId>
<version>5.2.0-SNAPSHOT</version>
<version>6.0.1</version>
<relativePath>../pom.xml</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,16 +20,17 @@

/**
* The interface Persistence data observer.
*
* @author zhuoyu.sjw
* @version $Id : ConfigDataObserver.java, v 0.1 2018-04-17 17:02 zhuoyu.sjw Exp $$
*/
public interface ConfigDataObserver {

/**
* Handle data.
*
* @param dataId the data id
* @param configData the persistence data
*/
void handleData(String dataId, ConfigData configData);
/**
* Handle data.
*
* @param dataId the data id
* @param configData the persistence data
*/
void handleData(String dataId, ConfigData configData);
}
Original file line number Diff line number Diff line change
Expand Up @@ -20,29 +20,30 @@

/**
* The interface Configurator.
*
* @author zhuoyu.sjw
* @version $Id : Configurator.java, v 0.1 2018-04-17 17:26 zhuoyu.sjw Exp $$
*/
public interface Configurator extends Register {

/**
* Gets data observer.
*
* @return the data observer
*/
ConfigDataObserver getDataObserver();
/**
* Gets data observer.
*
* @return the data observer
*/
ConfigDataObserver getDataObserver();

/**
* Sets config data observer.
*
* @param configDataObserver the config data observer
*/
void setDataObserver(ConfigDataObserver configDataObserver);
/**
* Sets config data observer.
*
* @param configDataObserver the config data observer
*/
void setDataObserver(ConfigDataObserver configDataObserver);

/**
* Peek data config data.
*
* @return the config data
*/
ConfigData peekData();
/**
* Peek data config data.
*
* @return the config data
*/
ConfigData peekData();
}
Original file line number Diff line number Diff line change
Expand Up @@ -20,46 +20,47 @@

/**
* The interface Event bus.
*
* @author zhuoyu.sjw
* @version $Id : EventBus.java, v 0.1 2018-07-12 21:11 zhuoyu.sjw Exp $$
*/
public interface EventBus {

/**
* Is enable boolean.
*
* @return the boolean
*/
boolean isEnable();
/**
* Is enable boolean.
*
* @return the boolean
*/
boolean isEnable();

/**
* Is enable boolean.
*
* @param eventClass the event class
* @return the boolean
*/
boolean isEnable(Class<? extends Event> eventClass);
/**
* Is enable boolean.
*
* @param eventClass the event class
* @return the boolean
*/
boolean isEnable(Class<? extends Event> eventClass);

/**
* Register.
*
* @param eventClass the event class
* @param eventSubscriber the event subscriber
*/
void register(Class<? extends Event> eventClass, EventSubscriber eventSubscriber);
/**
* Register.
*
* @param eventClass the event class
* @param eventSubscriber the event subscriber
*/
void register(Class<? extends Event> eventClass, EventSubscriber eventSubscriber);

/**
* Un register.
*
* @param eventClass the event class
* @param eventSubscriber the event subscriber
*/
void unRegister(Class<? extends Event> eventClass, EventSubscriber eventSubscriber);
/**
* Un register.
*
* @param eventClass the event class
* @param eventSubscriber the event subscriber
*/
void unRegister(Class<? extends Event> eventClass, EventSubscriber eventSubscriber);

/**
* Post event.
*
* @param event the event
*/
void post(final Event event);
/**
* Post event.
*
* @param event the event
*/
void post(final Event event);
}
Loading