protobuf: upgrade protoc to 3.14 (#1832)

This commit is contained in:
Caleb Doxsey 2021-01-27 10:06:40 -07:00 committed by GitHub
parent bec98051ae
commit 9c34fcbf29
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
7 changed files with 217 additions and 218 deletions

View file

@ -1,7 +1,7 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.25.0
// protoc v4.0.0
// protoc v3.14.0
// source: databroker.proto
package databroker
@ -9,14 +9,14 @@ package databroker
import (
context "context"
proto "github.com/golang/protobuf/proto"
any "github.com/golang/protobuf/ptypes/any"
empty "github.com/golang/protobuf/ptypes/empty"
timestamp "github.com/golang/protobuf/ptypes/timestamp"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
anypb "google.golang.org/protobuf/types/known/anypb"
emptypb "google.golang.org/protobuf/types/known/emptypb"
timestamppb "google.golang.org/protobuf/types/known/timestamppb"
reflect "reflect"
sync "sync"
)
@ -84,13 +84,13 @@ type Record struct {
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
Data *any.Any `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
CreatedAt *timestamp.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
ModifiedAt *timestamp.Timestamp `protobuf:"bytes,6,opt,name=modified_at,json=modifiedAt,proto3" json:"modified_at,omitempty"`
DeletedAt *timestamp.Timestamp `protobuf:"bytes,7,opt,name=deleted_at,json=deletedAt,proto3" json:"deleted_at,omitempty"`
Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
Data *anypb.Any `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
CreatedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
ModifiedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=modified_at,json=modifiedAt,proto3" json:"modified_at,omitempty"`
DeletedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=deleted_at,json=deletedAt,proto3" json:"deleted_at,omitempty"`
}
func (x *Record) Reset() {
@ -146,28 +146,28 @@ func (x *Record) GetId() string {
return ""
}
func (x *Record) GetData() *any.Any {
func (x *Record) GetData() *anypb.Any {
if x != nil {
return x.Data
}
return nil
}
func (x *Record) GetCreatedAt() *timestamp.Timestamp {
func (x *Record) GetCreatedAt() *timestamppb.Timestamp {
if x != nil {
return x.CreatedAt
}
return nil
}
func (x *Record) GetModifiedAt() *timestamp.Timestamp {
func (x *Record) GetModifiedAt() *timestamppb.Timestamp {
if x != nil {
return x.ModifiedAt
}
return nil
}
func (x *Record) GetDeletedAt() *timestamp.Timestamp {
func (x *Record) GetDeletedAt() *timestamppb.Timestamp {
if x != nil {
return x.DeletedAt
}
@ -588,9 +588,9 @@ type SetRequest struct {
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
Data *any.Any `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
Data *anypb.Any `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}
func (x *SetRequest) Reset() {
@ -639,7 +639,7 @@ func (x *SetRequest) GetId() string {
return ""
}
func (x *SetRequest) GetData() *any.Any {
func (x *SetRequest) GetData() *anypb.Any {
if x != nil {
return x.Data
}
@ -1026,23 +1026,23 @@ func file_databroker_proto_rawDescGZIP() []byte {
var file_databroker_proto_msgTypes = make([]protoimpl.MessageInfo, 14)
var file_databroker_proto_goTypes = []interface{}{
(*ServerVersion)(nil), // 0: databroker.ServerVersion
(*Record)(nil), // 1: databroker.Record
(*DeleteRequest)(nil), // 2: databroker.DeleteRequest
(*GetRequest)(nil), // 3: databroker.GetRequest
(*GetResponse)(nil), // 4: databroker.GetResponse
(*GetAllRequest)(nil), // 5: databroker.GetAllRequest
(*GetAllResponse)(nil), // 6: databroker.GetAllResponse
(*QueryRequest)(nil), // 7: databroker.QueryRequest
(*QueryResponse)(nil), // 8: databroker.QueryResponse
(*SetRequest)(nil), // 9: databroker.SetRequest
(*SetResponse)(nil), // 10: databroker.SetResponse
(*SyncRequest)(nil), // 11: databroker.SyncRequest
(*SyncResponse)(nil), // 12: databroker.SyncResponse
(*GetTypesResponse)(nil), // 13: databroker.GetTypesResponse
(*any.Any)(nil), // 14: google.protobuf.Any
(*timestamp.Timestamp)(nil), // 15: google.protobuf.Timestamp
(*empty.Empty)(nil), // 16: google.protobuf.Empty
(*ServerVersion)(nil), // 0: databroker.ServerVersion
(*Record)(nil), // 1: databroker.Record
(*DeleteRequest)(nil), // 2: databroker.DeleteRequest
(*GetRequest)(nil), // 3: databroker.GetRequest
(*GetResponse)(nil), // 4: databroker.GetResponse
(*GetAllRequest)(nil), // 5: databroker.GetAllRequest
(*GetAllResponse)(nil), // 6: databroker.GetAllResponse
(*QueryRequest)(nil), // 7: databroker.QueryRequest
(*QueryResponse)(nil), // 8: databroker.QueryResponse
(*SetRequest)(nil), // 9: databroker.SetRequest
(*SetResponse)(nil), // 10: databroker.SetResponse
(*SyncRequest)(nil), // 11: databroker.SyncRequest
(*SyncResponse)(nil), // 12: databroker.SyncResponse
(*GetTypesResponse)(nil), // 13: databroker.GetTypesResponse
(*anypb.Any)(nil), // 14: google.protobuf.Any
(*timestamppb.Timestamp)(nil), // 15: google.protobuf.Timestamp
(*emptypb.Empty)(nil), // 16: google.protobuf.Empty
}
var file_databroker_proto_depIdxs = []int32{
14, // 0: databroker.Record.data:type_name -> google.protobuf.Any
@ -1285,14 +1285,14 @@ const _ = grpc.SupportPackageIsVersion6
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type DataBrokerServiceClient interface {
Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*empty.Empty, error)
Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
GetAll(ctx context.Context, in *GetAllRequest, opts ...grpc.CallOption) (*GetAllResponse, error)
Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error)
Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (DataBrokerService_SyncClient, error)
GetTypes(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetTypesResponse, error)
SyncTypes(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (DataBrokerService_SyncTypesClient, error)
GetTypes(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetTypesResponse, error)
SyncTypes(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (DataBrokerService_SyncTypesClient, error)
}
type dataBrokerServiceClient struct {
@ -1303,8 +1303,8 @@ func NewDataBrokerServiceClient(cc grpc.ClientConnInterface) DataBrokerServiceCl
return &dataBrokerServiceClient{cc}
}
func (c *dataBrokerServiceClient) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
out := new(empty.Empty)
func (c *dataBrokerServiceClient) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/databroker.DataBrokerService/Delete", in, out, opts...)
if err != nil {
return nil, err
@ -1380,7 +1380,7 @@ func (x *dataBrokerServiceSyncClient) Recv() (*SyncResponse, error) {
return m, nil
}
func (c *dataBrokerServiceClient) GetTypes(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetTypesResponse, error) {
func (c *dataBrokerServiceClient) GetTypes(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetTypesResponse, error) {
out := new(GetTypesResponse)
err := c.cc.Invoke(ctx, "/databroker.DataBrokerService/GetTypes", in, out, opts...)
if err != nil {
@ -1389,7 +1389,7 @@ func (c *dataBrokerServiceClient) GetTypes(ctx context.Context, in *empty.Empty,
return out, nil
}
func (c *dataBrokerServiceClient) SyncTypes(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (DataBrokerService_SyncTypesClient, error) {
func (c *dataBrokerServiceClient) SyncTypes(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (DataBrokerService_SyncTypesClient, error) {
stream, err := c.cc.NewStream(ctx, &_DataBrokerService_serviceDesc.Streams[1], "/databroker.DataBrokerService/SyncTypes", opts...)
if err != nil {
return nil, err
@ -1423,21 +1423,21 @@ func (x *dataBrokerServiceSyncTypesClient) Recv() (*GetTypesResponse, error) {
// DataBrokerServiceServer is the server API for DataBrokerService service.
type DataBrokerServiceServer interface {
Delete(context.Context, *DeleteRequest) (*empty.Empty, error)
Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error)
Get(context.Context, *GetRequest) (*GetResponse, error)
GetAll(context.Context, *GetAllRequest) (*GetAllResponse, error)
Query(context.Context, *QueryRequest) (*QueryResponse, error)
Set(context.Context, *SetRequest) (*SetResponse, error)
Sync(*SyncRequest, DataBrokerService_SyncServer) error
GetTypes(context.Context, *empty.Empty) (*GetTypesResponse, error)
SyncTypes(*empty.Empty, DataBrokerService_SyncTypesServer) error
GetTypes(context.Context, *emptypb.Empty) (*GetTypesResponse, error)
SyncTypes(*emptypb.Empty, DataBrokerService_SyncTypesServer) error
}
// UnimplementedDataBrokerServiceServer can be embedded to have forward compatible implementations.
type UnimplementedDataBrokerServiceServer struct {
}
func (*UnimplementedDataBrokerServiceServer) Delete(context.Context, *DeleteRequest) (*empty.Empty, error) {
func (*UnimplementedDataBrokerServiceServer) Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method Delete not implemented")
}
func (*UnimplementedDataBrokerServiceServer) Get(context.Context, *GetRequest) (*GetResponse, error) {
@ -1455,10 +1455,10 @@ func (*UnimplementedDataBrokerServiceServer) Set(context.Context, *SetRequest) (
func (*UnimplementedDataBrokerServiceServer) Sync(*SyncRequest, DataBrokerService_SyncServer) error {
return status.Errorf(codes.Unimplemented, "method Sync not implemented")
}
func (*UnimplementedDataBrokerServiceServer) GetTypes(context.Context, *empty.Empty) (*GetTypesResponse, error) {
func (*UnimplementedDataBrokerServiceServer) GetTypes(context.Context, *emptypb.Empty) (*GetTypesResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetTypes not implemented")
}
func (*UnimplementedDataBrokerServiceServer) SyncTypes(*empty.Empty, DataBrokerService_SyncTypesServer) error {
func (*UnimplementedDataBrokerServiceServer) SyncTypes(*emptypb.Empty, DataBrokerService_SyncTypesServer) error {
return status.Errorf(codes.Unimplemented, "method SyncTypes not implemented")
}
@ -1578,7 +1578,7 @@ func (x *dataBrokerServiceSyncServer) Send(m *SyncResponse) error {
}
func _DataBrokerService_GetTypes_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(empty.Empty)
in := new(emptypb.Empty)
if err := dec(in); err != nil {
return nil, err
}
@ -1590,13 +1590,13 @@ func _DataBrokerService_GetTypes_Handler(srv interface{}, ctx context.Context, d
FullMethod: "/databroker.DataBrokerService/GetTypes",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DataBrokerServiceServer).GetTypes(ctx, req.(*empty.Empty))
return srv.(DataBrokerServiceServer).GetTypes(ctx, req.(*emptypb.Empty))
}
return interceptor(ctx, in, info, handler)
}
func _DataBrokerService_SyncTypes_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(empty.Empty)
m := new(emptypb.Empty)
if err := stream.RecvMsg(m); err != nil {
return err
}