regen

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

micro/broker_micro.pb.go

@@ -1,5 +1,7 @@
 // Code generated by protoc-gen-go-micro. DO NOT EDIT.
-// protoc-gen-go-micro version: v3.5.3
+// versions:
+// - protoc-gen-go-micro v3.10.2
+// - protoc              v3.21.12
 // source: broker.proto
 
 package servicepb
@@ -7,19 +9,16 @@ package servicepb
 import (
 	context "context"
 	proto "go.unistack.org/micro-broker-service/v3/proto"
-	api "go.unistack.org/micro/v3/api"
+	v3 "go.unistack.org/micro-server-http/v3"
 	client "go.unistack.org/micro/v3/client"
 )
 
 var (
 	BrokerServiceName = "BrokerService"
-
-	BrokerServiceEndpoints = []api.Endpoint{}
 )
-
-func NewBrokerServiceEndpoints() []api.Endpoint {
-	return BrokerServiceEndpoints
-}
+var (
+	BrokerServiceServerEndpoints = []v3.EndpointMetadata{}
+)
 
 type BrokerServiceClient interface {
 	Publish(ctx context.Context, req *proto.PublishRequest, opts ...client.CallOption) (*proto.PublishResponse, error)

micro/broker_micro_grpc.pb.go

@@ -1,5 +1,5 @@
 // Code generated by protoc-gen-go-micro. DO NOT EDIT.
-// protoc-gen-go-micro version: v3.5.3
+// protoc-gen-go-micro version: v3.10.2
 // source: broker.proto
 
 package servicepb
@@ -7,7 +7,6 @@ package servicepb
 import (
 	context "context"
 	proto "go.unistack.org/micro-broker-service/v3/proto"
-	api "go.unistack.org/micro/v3/api"
 	client "go.unistack.org/micro/v3/client"
 	server "go.unistack.org/micro/v3/server"
 )
@@ -58,6 +57,10 @@ func (s *brokerServiceClientSubscribe) Close() error {
 	return s.stream.Close()
 }
 
+func (s *brokerServiceClientSubscribe) CloseSend() error {
+	return s.stream.CloseSend()
+}
+
 func (s *brokerServiceClientSubscribe) Context() context.Context {
 	return s.stream.Context()
 }
@@ -97,6 +100,10 @@ func (s *brokerServiceClientBatchSubscribe) Close() error {
 	return s.stream.Close()
 }
 
+func (s *brokerServiceClientBatchSubscribe) CloseSend() error {
+	return s.stream.CloseSend()
+}
+
 func (s *brokerServiceClientBatchSubscribe) Context() context.Context {
 	return s.stream.Context()
 }
@@ -205,8 +212,5 @@ func RegisterBrokerServiceServer(s server.Server, sh BrokerServiceServer, opts .
 	}
 	h := &brokerServiceServer{sh}
 	var nopts []server.HandlerOption
-	for _, endpoint := range BrokerServiceEndpoints {
-		nopts = append(nopts, api.WithEndpoint(&endpoint))
-	}
 	return s.Handle(s.NewHandler(&BrokerService{h}, append(nopts, opts...)...))
 }