diff --git a/common/constant/key.go b/common/constant/key.go index c7db08a55cf8c00c152f319e562e78fe4f4bc673..9525511cdaac64083cc595e1c0a6327a4ded6f9c 100644 --- a/common/constant/key.go +++ b/common/constant/key.go @@ -25,7 +25,7 @@ const ( GROUP_KEY = "group" VERSION_KEY = "version" INTERFACE_KEY = "interface" - GRPC_MESSAGE_SIZE_KEY = "message_size" + MESSAGE_SIZE_KEY = "message_size" PATH_KEY = "path" SERVICE_KEY = "service" METHODS_KEY = "methods" diff --git a/config/service_config.go b/config/service_config.go index 764d5dc86881af5fbf770437b5011fa8b20c730b..9a274436dd510ce18d2dda6f11dd6d5ef298f0be 100644 --- a/config/service_config.go +++ b/config/service_config.go @@ -272,7 +272,7 @@ func (c *ServiceConfig) getUrlMap() url.Values { urlMap.Set(constant.ROLE_KEY, strconv.Itoa(common.PROVIDER)) urlMap.Set(constant.RELEASE_KEY, "dubbo-golang-"+constant.Version) urlMap.Set(constant.SIDE_KEY, (common.RoleType(common.PROVIDER)).Role()) - urlMap.Set(constant.GRPC_MESSAGE_SIZE_KEY, strconv.Itoa(c.GrpcMaxMessageSize)) + urlMap.Set(constant.MESSAGE_SIZE_KEY, strconv.Itoa(c.GrpcMaxMessageSize)) // todo: move urlMap.Set(constant.SERIALIZATION_KEY, c.Serialization) // application info diff --git a/protocol/grpc/client.go b/protocol/grpc/client.go index 6f9fc22a0265a7fa0e20cf6ee0a9fe303fe9cb07..9b31a8c626ab0cdec8404da6712d88376be28f2f 100644 --- a/protocol/grpc/client.go +++ b/protocol/grpc/client.go @@ -94,7 +94,7 @@ func NewClient(url common.URL) *Client { // if global trace instance was set , it means trace function enabled. If not , will return Nooptracer tracer := opentracing.GlobalTracer() dailOpts := make([]grpc.DialOption, 0, 4) - maxMessageSize, _ := strconv.Atoi(url.GetParam(constant.GRPC_MESSAGE_SIZE_KEY, "4")) + maxMessageSize, _ := strconv.Atoi(url.GetParam(constant.MESSAGE_SIZE_KEY, "4")) dailOpts = append(dailOpts, grpc.WithInsecure(), grpc.WithBlock(), grpc.WithUnaryInterceptor( otgrpc.OpenTracingClientInterceptor(tracer, otgrpc.LogPayloads())), grpc.WithDefaultCallOptions( diff --git a/protocol/grpc/grpc_protocol.go b/protocol/grpc/grpc_protocol.go index f488dda73231551b2b0c1b9b2d79f74b773ff1bf..396ff473f24f525c41bf117af9c12df3fbad1ebe 100644 --- a/protocol/grpc/grpc_protocol.go +++ b/protocol/grpc/grpc_protocol.go @@ -78,7 +78,7 @@ func (gp *GrpcProtocol) openServer(url common.URL) { gp.serverLock.Lock() _, ok = gp.serverMap[url.Location] if !ok { - grpcMessageSize, _ := strconv.Atoi(url.GetParam(constant.GRPC_MESSAGE_SIZE_KEY, "4")) + grpcMessageSize, _ := strconv.Atoi(url.GetParam(constant.MESSAGE_SIZE_KEY, "4")) srv := NewServer() srv.SetBufferSize(grpcMessageSize) gp.serverMap[url.Location] = srv