diff options
| author | terminaldweller <thabogre@gmail.com> | 2021-11-20 17:21:43 +0000 | 
|---|---|---|
| committer | terminaldweller <thabogre@gmail.com> | 2021-11-20 17:21:43 +0000 | 
| commit | 2f7e632a3d876a8721bcfbeeb4624a338df46eb8 (patch) | |
| tree | 73cc6fa053158439107866a991c2675e1ee35c4b | |
| parent | fix (diff) | |
| download | grpc-main.tar.gz grpc-main.zip | |
Diffstat (limited to '')
| -rw-r--r-- | go.mod | 3 | ||||
| -rw-r--r-- | telebot/makefile | 4 | ||||
| -rw-r--r-- | telebot/v1/telegram.pb.go | 7 | ||||
| -rw-r--r-- | telebot/v1/telegram_grpc.pb.go | 101 | 
4 files changed, 107 insertions, 8 deletions
| @@ -3,6 +3,7 @@ module github.com/terminaldweller/grpc  go 1.15  require ( -	github.com/golang/protobuf v1.5.2 +	github.com/golang/protobuf v1.5.2 // indirect +	google.golang.org/grpc v1.42.0  	google.golang.org/protobuf v1.27.1  ) diff --git a/telebot/makefile b/telebot/makefile index 70c353b..b919633 100644 --- a/telebot/makefile +++ b/telebot/makefile @@ -8,7 +8,9 @@ DEFAULT: default  default: $(ARTIFACT_LIST)  $(SRC_DIR)/%.pb.go:$(SRC_DIR)/%.proto -	protoc --proto_path=$(SRC_DIR) --go_out=$(DST_DIR) --go_opt=paths=source_relative $< +	protoc --proto_path=$(SRC_DIR) \ +		--go_out=$(DST_DIR) --go_opt=paths=source_relative \ +		--go-grpc_out=$(DST_DIR) --go-grpc_opt=paths=source_relative $<  	if [ -d go.mod ];then : else;go mod init github.com/terminaldweller/grpc/telebot/v1;fi  	go mod tidy diff --git a/telebot/v1/telegram.pb.go b/telebot/v1/telegram.pb.go index ab46f67..85a653a 100644 --- a/telebot/v1/telegram.pb.go +++ b/telebot/v1/telegram.pb.go @@ -1,13 +1,12 @@  // Code generated by protoc-gen-go. DO NOT EDIT.  // versions: -// 	protoc-gen-go v1.23.0 +// 	protoc-gen-go v1.27.1  // 	protoc        v3.15.6  // source: telegram.proto  package v1  import ( -	proto "github.com/golang/protobuf/proto"  	protoreflect "google.golang.org/protobuf/reflect/protoreflect"  	protoimpl "google.golang.org/protobuf/runtime/protoimpl"  	timestamppb "google.golang.org/protobuf/types/known/timestamppb" @@ -22,10 +21,6 @@ const (  	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)  ) -// This is a compile-time assertion that a sufficiently up-to-date version -// of the legacy proto package is being used. -const _ = proto.ProtoPackageIsVersion4 -  type NotificationRequest struct {  	state         protoimpl.MessageState  	sizeCache     protoimpl.SizeCache diff --git a/telebot/v1/telegram_grpc.pb.go b/telebot/v1/telegram_grpc.pb.go new file mode 100644 index 0000000..7f55861 --- /dev/null +++ b/telebot/v1/telegram_grpc.pb.go @@ -0,0 +1,101 @@ +// Code generated by protoc-gen-go-grpc. DO NOT EDIT. + +package v1 + +import ( +	context "context" +	grpc "google.golang.org/grpc" +	codes "google.golang.org/grpc/codes" +	status "google.golang.org/grpc/status" +) + +// This is a compile-time assertion to ensure that this generated file +// is compatible with the grpc package it is being compiled against. +// Requires gRPC-Go v1.32.0 or later. +const _ = grpc.SupportPackageIsVersion7 + +// NotificationServiceClient is the client API for NotificationService service. +// +// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. +type NotificationServiceClient interface { +	Notify(ctx context.Context, in *NotificationRequest, opts ...grpc.CallOption) (*NotificationResponse, error) +} + +type notificationServiceClient struct { +	cc grpc.ClientConnInterface +} + +func NewNotificationServiceClient(cc grpc.ClientConnInterface) NotificationServiceClient { +	return ¬ificationServiceClient{cc} +} + +func (c *notificationServiceClient) Notify(ctx context.Context, in *NotificationRequest, opts ...grpc.CallOption) (*NotificationResponse, error) { +	out := new(NotificationResponse) +	err := c.cc.Invoke(ctx, "/hived.NotificationService/Notify", in, out, opts...) +	if err != nil { +		return nil, err +	} +	return out, nil +} + +// NotificationServiceServer is the server API for NotificationService service. +// All implementations must embed UnimplementedNotificationServiceServer +// for forward compatibility +type NotificationServiceServer interface { +	Notify(context.Context, *NotificationRequest) (*NotificationResponse, error) +	mustEmbedUnimplementedNotificationServiceServer() +} + +// UnimplementedNotificationServiceServer must be embedded to have forward compatible implementations. +type UnimplementedNotificationServiceServer struct { +} + +func (UnimplementedNotificationServiceServer) Notify(context.Context, *NotificationRequest) (*NotificationResponse, error) { +	return nil, status.Errorf(codes.Unimplemented, "method Notify not implemented") +} +func (UnimplementedNotificationServiceServer) mustEmbedUnimplementedNotificationServiceServer() {} + +// UnsafeNotificationServiceServer may be embedded to opt out of forward compatibility for this service. +// Use of this interface is not recommended, as added methods to NotificationServiceServer will +// result in compilation errors. +type UnsafeNotificationServiceServer interface { +	mustEmbedUnimplementedNotificationServiceServer() +} + +func RegisterNotificationServiceServer(s grpc.ServiceRegistrar, srv NotificationServiceServer) { +	s.RegisterService(&NotificationService_ServiceDesc, srv) +} + +func _NotificationService_Notify_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { +	in := new(NotificationRequest) +	if err := dec(in); err != nil { +		return nil, err +	} +	if interceptor == nil { +		return srv.(NotificationServiceServer).Notify(ctx, in) +	} +	info := &grpc.UnaryServerInfo{ +		Server:     srv, +		FullMethod: "/hived.NotificationService/Notify", +	} +	handler := func(ctx context.Context, req interface{}) (interface{}, error) { +		return srv.(NotificationServiceServer).Notify(ctx, req.(*NotificationRequest)) +	} +	return interceptor(ctx, in, info, handler) +} + +// NotificationService_ServiceDesc is the grpc.ServiceDesc for NotificationService service. +// It's only intended for direct use with grpc.RegisterService, +// and not to be introspected or modified (even as a copy) +var NotificationService_ServiceDesc = grpc.ServiceDesc{ +	ServiceName: "hived.NotificationService", +	HandlerType: (*NotificationServiceServer)(nil), +	Methods: []grpc.MethodDesc{ +		{ +			MethodName: "Notify", +			Handler:    _NotificationService_Notify_Handler, +		}, +	}, +	Streams:  []grpc.StreamDesc{}, +	Metadata: "telegram.proto", +} | 
