Skip to content

Commit 2e569d8

Browse files
authored
better not implemented messages (#889)
1 parent d2a49d5 commit 2e569d8

File tree

5 files changed

+7
-10
lines changed

5 files changed

+7
-10
lines changed

coordinator/provider/coordinator.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -1878,7 +1878,7 @@ func (qc *qdbCoordinator) AddDataShard(ctx context.Context, shard *datashards.Da
18781878
}
18791879

18801880
func (qc *qdbCoordinator) AddWorldShard(_ context.Context, _ *datashards.DataShard) error {
1881-
panic("implement me")
1881+
panic("qdbCoordinator.AddWorldShard not implemented")
18821882
}
18831883

18841884
func (qc *qdbCoordinator) DropShard(ctx context.Context, shardId string) error {

coordinator/provider/shards.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ func (s *ShardServer) AddDataShard(ctx context.Context, request *protos.AddShard
3838
}
3939

4040
func (s *ShardServer) AddWorldShard(ctx context.Context, request *protos.AddWorldShardRequest) (*emptypb.Empty, error) {
41-
panic("implement me")
41+
panic("ShardServer.AddWorldShard not implemented")
4242
}
4343

4444
// TODO : unit tests

pkg/coord/adapter.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -46,11 +46,11 @@ func NewAdapter(conn *grpc.ClientConn) *Adapter {
4646
// Returns:
4747
// - qdb.QDB: The QDB object.
4848
func (a *Adapter) QDB() qdb.QDB {
49-
panic("implement me?")
49+
panic("Adapter.QDB not implemented")
5050
}
5151

5252
func (a *Adapter) Cache() *cache.SchemaCache {
53-
panic("implement me?")
53+
panic("Adapter.Cache not implemented")
5454
}
5555

5656
// TODO : unit tests

router/grpc/qrouter.go

+2-4
Original file line numberDiff line numberDiff line change
@@ -62,8 +62,7 @@ func (l *LocalQrouterServer) AddDataShard(ctx context.Context, request *protos.A
6262
}
6363

6464
func (l *LocalQrouterServer) AddWorldShard(ctx context.Context, request *protos.AddWorldShardRequest) (*emptypb.Empty, error) {
65-
//TODO implement me
66-
panic("implement me")
65+
panic("LocalQrouterServer.AddWorldShard not implemented")
6766
}
6867

6968
func (l *LocalQrouterServer) GetShard(ctx context.Context, request *protos.ShardRequest) (*protos.ShardReply, error) {
@@ -183,8 +182,7 @@ func (l *LocalQrouterServer) GetRouterStatus(ctx context.Context, _ *emptypb.Emp
183182

184183
// TODO : implement, unit tests
185184
func (l *LocalQrouterServer) CloseRouter(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error) {
186-
//TODO implement me
187-
panic("implement me")
185+
panic("LocalQrouterServer.CloseRouter not implemented")
188186
}
189187

190188
// TODO : unit tests

router/server/multishard.go

+1-2
Original file line numberDiff line numberDiff line change
@@ -453,8 +453,7 @@ func (m *MultiShardServer) Cleanup(rule config.FrontendRule) error {
453453
}
454454

455455
func (m *MultiShardServer) Sync() int64 {
456-
//TODO implement me
457-
panic("implement me")
456+
panic("MultiShardServer.Sync not implemented")
458457
}
459458

460459
func (m *MultiShardServer) Cancel() error {

0 commit comments

Comments
 (0)