-
- Downloads
Initial commit of LogService and HAKeeper (#2970)
* logservice: initial commit * logservice: added LogShardManager * logservice: renamed service.go -> shards.go * logservice: added hakeeper and tests * logservice: some cleanups * logservice: added stateMachine.LeaseHistory * logservice: added the ability to filter internal entries * logservice: fixed various issues in LogStore * logservice: updated store APIs to expose LogRecord and LSN * logservice: pass meta info to NodeHost * logservice: allow NodeHostID to be specified * logservice: added the ability to query serviceAddress * logservice: added the ability to query shard info * logservice: minor update * logservice: truncate log asynchronously in a worker goroutine * logservice: fixed copyright notice * logservice: added heartbeat message ready to be sent to HAKeeper * logservice: use gogofaster to generate .pb.go * logservice: minor update to reflect dragonboat v4 changes * logservice: added pb/rpc * logservice: added server side rpc support * logservice: bumped cube version to avoid pebble version conflicts * logservice: added error handling * logservice: more error handling * logservice: added some tests * logservice: minor fixess for errors.go * logservice: added DN heartbeat messages * logservice: minor cleanups * logservice: minor fix for error handling * logservice: moved hakeeper code to its own directory * logservice: made logservice rsm a IStateMachine * hakeeper: use Lookup() for querying shard ID * logservice: move pb file to matrixone/proto, some other cleanups * hakeeper: added hakeeper/state.go * logservice: added methods for updating hakeeper * hakeeper: minor fix, added some tests * logservice: added ticker for hakeeper replica * logservice: minor fix for service.go * logservice: fixed some issues in transport.go * logservice: added client.go * logservice: minor refactoring * logservice: added client_test.go, fixed a few bugs * logservice: readonly clients now reject write requests * logservice: refactored query shard info API * logservice: added tests for Servide.GetShardInfo * logservice: fixed a few static-check reported issues
Showing
- go.mod 25 additions, 10 deletionsgo.mod
- go.sum 95 additions, 18 deletionsgo.sum
- pkg/common/moerr/error.go 7 additions, 0 deletionspkg/common/moerr/error.go
- pkg/hakeeper/rsm.go 243 additions, 0 deletionspkg/hakeeper/rsm.go
- pkg/hakeeper/rsm_test.go 211 additions, 0 deletionspkg/hakeeper/rsm_test.go
- pkg/hakeeper/state.go 138 additions, 0 deletionspkg/hakeeper/state.go
- pkg/hakeeper/state_test.go 168 additions, 0 deletionspkg/hakeeper/state_test.go
- pkg/logservice/README.md 3 additions, 0 deletionspkg/logservice/README.md
- pkg/logservice/client.go 199 additions, 0 deletionspkg/logservice/client.go
- pkg/logservice/client_test.go 159 additions, 0 deletionspkg/logservice/client_test.go
- pkg/logservice/config.go 99 additions, 0 deletionspkg/logservice/config.go
- pkg/logservice/config_test.go 92 additions, 0 deletionspkg/logservice/config_test.go
- pkg/logservice/errors.go 85 additions, 0 deletionspkg/logservice/errors.go
- pkg/logservice/errors_test.go 46 additions, 0 deletionspkg/logservice/errors_test.go
- pkg/logservice/rsm.go 233 additions, 0 deletionspkg/logservice/rsm.go
- pkg/logservice/rsm_test.go 246 additions, 0 deletionspkg/logservice/rsm_test.go
- pkg/logservice/service.go 270 additions, 0 deletionspkg/logservice/service.go
- pkg/logservice/service_test.go 372 additions, 0 deletionspkg/logservice/service_test.go
- pkg/logservice/shardinfo.go 63 additions, 0 deletionspkg/logservice/shardinfo.go
- pkg/logservice/store.go 517 additions, 0 deletionspkg/logservice/store.go
Loading
Please register or sign in to comment