@@ -23,18 +23,16 @@ import (
23
23
"sync"
24
24
25
25
"github.com/dapr/components-contrib/bindings"
26
- grpc_api "mosn.io/layotto/pkg/grpc"
27
- "mosn.io/layotto/pkg/grpc/dapr"
28
- dapr_common_v1pb "mosn.io/layotto/pkg/grpc/dapr/proto/common/v1"
29
- dapr_v1pb "mosn.io/layotto/pkg/grpc/dapr/proto/runtime/v1"
30
- mgrpc "mosn.io/mosn/pkg/filter/network/grpc"
31
-
32
26
"github.com/dapr/components-contrib/pubsub"
33
27
"github.com/dapr/components-contrib/state"
34
28
jsoniter "github.com/json-iterator/go"
35
29
"google.golang.org/grpc"
36
30
"google.golang.org/protobuf/types/known/emptypb"
37
31
"mosn.io/layotto/components/file"
32
+ grpc_api "mosn.io/layotto/pkg/grpc"
33
+ "mosn.io/layotto/pkg/grpc/dapr"
34
+ dapr_common_v1pb "mosn.io/layotto/pkg/grpc/dapr/proto/common/v1"
35
+ dapr_v1pb "mosn.io/layotto/pkg/grpc/dapr/proto/runtime/v1"
38
36
39
37
"mosn.io/layotto/components/configstores"
40
38
"mosn.io/layotto/components/hello"
@@ -136,10 +134,10 @@ func (a *api) Init(conn *grpc.ClientConn) error {
136
134
return a .startSubscribing ()
137
135
}
138
136
139
- func (a * api ) Register (s * grpc.Server , registeredServer mgrpc. RegisteredServer ) (mgrpc. RegisteredServer , error ) {
137
+ func (a * api ) Register (rawGrpServer * grpc.Server ) error {
140
138
LayottoAPISingleton = a
141
- runtimev1pb .RegisterRuntimeServer (s , a )
142
- return registeredServer , nil
139
+ runtimev1pb .RegisterRuntimeServer (rawGrpServer , a )
140
+ return nil
143
141
}
144
142
145
143
func NewGrpcAPI (ac * grpc_api.ApplicationContext ) grpc_api.GrpcAPI {
0 commit comments