unistack-org/micro-broker-service
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 8 Wiki Activity

regen with never protoc-gen-go

Browse Source 
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
Василий Толстов 2021-03-22 09:00:44 +03:00
parent d8871e07ee
commit dd51dad2e0
3 changed files with 21 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
.github/renovate.json vendored
View File

@ -2,6 +2,7 @@
"extends": [ "extends": [
"config:base" "config:base"
], ],
"postUpdateOptions": ["gomodTidy"],
"packageRules": [ "packageRules": [
{ {
"matchUpdateTypes": ["minor", "patch", "pin", "digest"], "matchUpdateTypes": ["minor", "patch", "pin", "digest"],

2
proto/broker.pb.go
View File

@ -1,6 +1,6 @@
// Code generated by protoc-gen-go. DO NOT EDIT. // Code generated by protoc-gen-go. DO NOT EDIT.
// versions: // versions:
// protoc-gen-go v1.26.0-devel // protoc-gen-go v1.26.0
// protoc v3.6.1 // protoc v3.6.1
// source: broker.proto // source: broker.proto

27
proto/broker_grpc.pb.go
View File

@ -11,7 +11,8 @@ import (
// This is a compile-time assertion to ensure that this generated file // This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against. // is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion6 // Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
// BrokerClient is the client API for Broker service. // BrokerClient is the client API for Broker service.
// //
@ -39,7 +40,7 @@ func (c *brokerClient) Publish(ctx context.Context, in *PublishRequest, opts ...
} }
func (c *brokerClient) Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Broker_SubscribeClient, error) { func (c *brokerClient) Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Broker_SubscribeClient, error) {
stream, err := c.cc.NewStream(ctx, &_Broker_serviceDesc.Streams[0], "/service.Broker/Subscribe", opts...) stream, err := c.cc.NewStream(ctx, &Broker_ServiceDesc.Streams[0], "/service.Broker/Subscribe", opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -83,16 +84,23 @@ type BrokerServer interface {
type UnimplementedBrokerServer struct { type UnimplementedBrokerServer struct {
} }
func (*UnimplementedBrokerServer) Publish(context.Context, *PublishRequest) (*Empty, error) { func (UnimplementedBrokerServer) Publish(context.Context, *PublishRequest) (*Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method Publish not implemented") return nil, status.Errorf(codes.Unimplemented, "method Publish not implemented")
} }
func (*UnimplementedBrokerServer) Subscribe(*SubscribeRequest, Broker_SubscribeServer) error { func (UnimplementedBrokerServer) Subscribe(*SubscribeRequest, Broker_SubscribeServer) error {
return status.Errorf(codes.Unimplemented, "method Subscribe not implemented") return status.Errorf(codes.Unimplemented, "method Subscribe not implemented")
} }
func (*UnimplementedBrokerServer) mustEmbedUnimplementedBrokerServer() {} func (UnimplementedBrokerServer) mustEmbedUnimplementedBrokerServer() {}
func RegisterBrokerServer(s *grpc.Server, srv BrokerServer) { // UnsafeBrokerServer may be embedded to opt out of forward compatibility for this service.
s.RegisterService(&_Broker_serviceDesc, srv) // Use of this interface is not recommended, as added methods to BrokerServer will
// result in compilation errors.
type UnsafeBrokerServer interface {
mustEmbedUnimplementedBrokerServer()
}
func RegisterBrokerServer(s grpc.ServiceRegistrar, srv BrokerServer) {
s.RegisterService(&Broker_ServiceDesc, srv)
} }
func _Broker_Publish_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { func _Broker_Publish_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
@ -134,7 +142,10 @@ func (x *brokerSubscribeServer) Send(m *Message) error {
return x.ServerStream.SendMsg(m) return x.ServerStream.SendMsg(m)
} }
var _Broker_serviceDesc = grpc.ServiceDesc{ // Broker_ServiceDesc is the grpc.ServiceDesc for Broker service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var Broker_ServiceDesc = grpc.ServiceDesc{
ServiceName: "service.Broker", ServiceName: "service.Broker",
HandlerType: (*BrokerServer)(nil), HandlerType: (*BrokerServer)(nil),
Methods: []grpc.MethodDesc{ Methods: []grpc.MethodDesc{