diff options
Diffstat (limited to 'internal/middleware/cache/testdata/stream.pb.go')
| -rw-r--r-- | internal/middleware/cache/testdata/stream.pb.go | 313 |
1 files changed, 215 insertions, 98 deletions
diff --git a/internal/middleware/cache/testdata/stream.pb.go b/internal/middleware/cache/testdata/stream.pb.go index f8013cf87..101792469 100644 --- a/internal/middleware/cache/testdata/stream.pb.go +++ b/internal/middleware/cache/testdata/stream.pb.go @@ -1,139 +1,256 @@ // Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.23.0 +// protoc v3.12.4 // source: middleware/cache/testdata/stream.proto package testdata import ( context "context" - fmt "fmt" proto "github.com/golang/protobuf/proto" gitalypb "gitlab.com/gitlab-org/gitaly/proto/go/gitalypb" grpc "google.golang.org/grpc" codes "google.golang.org/grpc/codes" status "google.golang.org/grpc/status" - math "math" + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" ) -// Reference imports to suppress errors if they are not otherwise used. -var _ = proto.Marshal -var _ = fmt.Errorf -var _ = math.Inf +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) -// This is a compile-time assertion to ensure that this generated file -// is compatible with the proto package it is being compiled against. -// A compilation error at this line likely means your copy of the -// proto package needs to be updated. -const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package +// 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 Request struct { - Destination *gitalypb.Repository `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` -} + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields -func (m *Request) Reset() { *m = Request{} } -func (m *Request) String() string { return proto.CompactTextString(m) } -func (*Request) ProtoMessage() {} -func (*Request) Descriptor() ([]byte, []int) { - return fileDescriptor_a8c7bc703e280c1d, []int{0} + Destination *gitalypb.Repository `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"` } -func (m *Request) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_Request.Unmarshal(m, b) -} -func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_Request.Marshal(b, m, deterministic) -} -func (m *Request) XXX_Merge(src proto.Message) { - xxx_messageInfo_Request.Merge(m, src) +func (x *Request) Reset() { + *x = Request{} + if protoimpl.UnsafeEnabled { + mi := &file_middleware_cache_testdata_stream_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } -func (m *Request) XXX_Size() int { - return xxx_messageInfo_Request.Size(m) + +func (x *Request) String() string { + return protoimpl.X.MessageStringOf(x) } -func (m *Request) XXX_DiscardUnknown() { - xxx_messageInfo_Request.DiscardUnknown(m) + +func (*Request) ProtoMessage() {} + +func (x *Request) ProtoReflect() protoreflect.Message { + mi := &file_middleware_cache_testdata_stream_proto_msgTypes[0] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -var xxx_messageInfo_Request proto.InternalMessageInfo +// Deprecated: Use Request.ProtoReflect.Descriptor instead. +func (*Request) Descriptor() ([]byte, []int) { + return file_middleware_cache_testdata_stream_proto_rawDescGZIP(), []int{0} +} -func (m *Request) GetDestination() *gitalypb.Repository { - if m != nil { - return m.Destination +func (x *Request) GetDestination() *gitalypb.Repository { + if x != nil { + return x.Destination } return nil } type Response struct { - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields } -func (m *Response) Reset() { *m = Response{} } -func (m *Response) String() string { return proto.CompactTextString(m) } -func (*Response) ProtoMessage() {} -func (*Response) Descriptor() ([]byte, []int) { - return fileDescriptor_a8c7bc703e280c1d, []int{1} +func (x *Response) Reset() { + *x = Response{} + if protoimpl.UnsafeEnabled { + mi := &file_middleware_cache_testdata_stream_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } -func (m *Response) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_Response.Unmarshal(m, b) -} -func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_Response.Marshal(b, m, deterministic) -} -func (m *Response) XXX_Merge(src proto.Message) { - xxx_messageInfo_Response.Merge(m, src) -} -func (m *Response) XXX_Size() int { - return xxx_messageInfo_Response.Size(m) -} -func (m *Response) XXX_DiscardUnknown() { - xxx_messageInfo_Response.DiscardUnknown(m) +func (x *Response) String() string { + return protoimpl.X.MessageStringOf(x) } -var xxx_messageInfo_Response proto.InternalMessageInfo +func (*Response) ProtoMessage() {} -func init() { - proto.RegisterType((*Request)(nil), "testdata.Request") - proto.RegisterType((*Response)(nil), "testdata.Response") +func (x *Response) ProtoReflect() protoreflect.Message { + mi := &file_middleware_cache_testdata_stream_proto_msgTypes[1] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -func init() { - proto.RegisterFile("middleware/cache/testdata/stream.proto", fileDescriptor_a8c7bc703e280c1d) -} +// Deprecated: Use Response.ProtoReflect.Descriptor instead. +func (*Response) Descriptor() ([]byte, []int) { + return file_middleware_cache_testdata_stream_proto_rawDescGZIP(), []int{1} +} + +var File_middleware_cache_testdata_stream_proto protoreflect.FileDescriptor + +var file_middleware_cache_testdata_stream_proto_rawDesc = []byte{ + 0x0a, 0x26, 0x6d, 0x69, 0x64, 0x64, 0x6c, 0x65, 0x77, 0x61, 0x72, 0x65, 0x2f, 0x63, 0x61, 0x63, + 0x68, 0x65, 0x2f, 0x74, 0x65, 0x73, 0x74, 0x64, 0x61, 0x74, 0x61, 0x2f, 0x73, 0x74, 0x72, 0x65, + 0x61, 0x6d, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x08, 0x74, 0x65, 0x73, 0x74, 0x64, 0x61, + 0x74, 0x61, 0x1a, 0x0a, 0x6c, 0x69, 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x0c, + 0x73, 0x68, 0x61, 0x72, 0x65, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x45, 0x0a, 0x07, + 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3a, 0x0a, 0x0b, 0x64, 0x65, 0x73, 0x74, 0x69, + 0x6e, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x67, + 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x52, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, + 0x42, 0x04, 0x98, 0xc6, 0x2c, 0x01, 0x52, 0x0b, 0x64, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x61, 0x74, + 0x69, 0x6f, 0x6e, 0x22, 0x0a, 0x0a, 0x08, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x32, + 0x52, 0x0a, 0x12, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x63, 0x65, 0x70, 0x74, 0x65, 0x64, 0x53, 0x65, + 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x36, 0x0a, 0x0d, 0x49, 0x67, 0x6e, 0x6f, 0x72, 0x65, 0x64, + 0x4d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x12, 0x11, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x64, 0x61, 0x74, + 0x61, 0x2e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x12, 0x2e, 0x74, 0x65, 0x73, 0x74, + 0x64, 0x61, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x1a, 0x04, 0xf0, + 0x97, 0x28, 0x01, 0x32, 0xb9, 0x02, 0x0a, 0x0b, 0x54, 0x65, 0x73, 0x74, 0x53, 0x65, 0x72, 0x76, + 0x69, 0x63, 0x65, 0x12, 0x4a, 0x0a, 0x17, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x72, + 0x65, 0x61, 0x6d, 0x52, 0x65, 0x70, 0x6f, 0x4d, 0x75, 0x74, 0x61, 0x74, 0x6f, 0x72, 0x12, 0x11, + 0x2e, 0x74, 0x65, 0x73, 0x74, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, + 0x74, 0x1a, 0x12, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x73, + 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x06, 0xfa, 0x97, 0x28, 0x02, 0x08, 0x01, 0x30, 0x01, 0x12, + 0x4b, 0x0a, 0x18, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, + 0x65, 0x70, 0x6f, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x6f, 0x72, 0x12, 0x11, 0x2e, 0x74, 0x65, + 0x73, 0x74, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x12, + 0x2e, 0x74, 0x65, 0x73, 0x74, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, + 0x73, 0x65, 0x22, 0x06, 0xfa, 0x97, 0x28, 0x02, 0x08, 0x02, 0x30, 0x01, 0x12, 0x47, 0x0a, 0x16, + 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x55, 0x6e, 0x61, 0x72, 0x79, 0x52, 0x65, 0x70, 0x6f, 0x4d, + 0x75, 0x74, 0x61, 0x74, 0x6f, 0x72, 0x12, 0x11, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x64, 0x61, 0x74, + 0x61, 0x2e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x12, 0x2e, 0x74, 0x65, 0x73, 0x74, + 0x64, 0x61, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x06, 0xfa, + 0x97, 0x28, 0x02, 0x08, 0x01, 0x12, 0x48, 0x0a, 0x17, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x55, + 0x6e, 0x61, 0x72, 0x79, 0x52, 0x65, 0x70, 0x6f, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x6f, 0x72, + 0x12, 0x11, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x71, 0x75, + 0x65, 0x73, 0x74, 0x1a, 0x12, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x52, + 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x06, 0xfa, 0x97, 0x28, 0x02, 0x08, 0x02, 0x62, + 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, +} + +var ( + file_middleware_cache_testdata_stream_proto_rawDescOnce sync.Once + file_middleware_cache_testdata_stream_proto_rawDescData = file_middleware_cache_testdata_stream_proto_rawDesc +) -var fileDescriptor_a8c7bc703e280c1d = []byte{ - // 293 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x91, 0x41, 0x4a, 0xc3, 0x40, - 0x14, 0x86, 0x99, 0x52, 0x6a, 0x78, 0xd1, 0x85, 0xb3, 0xd0, 0x92, 0x95, 0x64, 0x21, 0x59, 0x48, - 0x52, 0x22, 0xb8, 0x70, 0xa7, 0x22, 0x5a, 0xa5, 0x9b, 0x54, 0x0f, 0x30, 0xce, 0x3c, 0x9a, 0x81, - 0x74, 0x26, 0xce, 0xbc, 0x2a, 0x39, 0x49, 0xbd, 0x8a, 0x17, 0xf0, 0x3c, 0xae, 0x5d, 0x89, 0x8d, - 0x91, 0xe2, 0x4a, 0xbb, 0x9c, 0x8f, 0xe1, 0xe3, 0xfb, 0x79, 0x70, 0x38, 0xd7, 0x4a, 0x55, 0xf8, - 0x2c, 0x1c, 0x66, 0x52, 0xc8, 0x12, 0x33, 0x42, 0x4f, 0x4a, 0x90, 0xc8, 0x3c, 0x39, 0x14, 0xf3, - 0xb4, 0x76, 0x96, 0x2c, 0x0f, 0x3a, 0x1c, 0x41, 0xa5, 0x0d, 0xb5, 0x34, 0xda, 0xf6, 0xa5, 0x70, - 0xa8, 0xda, 0x57, 0x7c, 0x09, 0x5b, 0x05, 0x3e, 0x2e, 0xd0, 0x13, 0x3f, 0x85, 0x50, 0xa1, 0x27, - 0x6d, 0x04, 0x69, 0x6b, 0x86, 0xec, 0x80, 0x25, 0x61, 0xce, 0xd3, 0x99, 0x26, 0x51, 0x35, 0x69, - 0x81, 0xb5, 0xf5, 0x9a, 0xac, 0x6b, 0xce, 0xfb, 0x2f, 0x6f, 0x47, 0xac, 0x58, 0xff, 0x1c, 0x03, - 0x04, 0x05, 0xfa, 0xda, 0x1a, 0x8f, 0x79, 0x01, 0x7c, 0x6c, 0x08, 0x9d, 0xc4, 0x9a, 0x50, 0x4d, - 0xd1, 0x3d, 0x69, 0x89, 0xfc, 0x04, 0x76, 0xc6, 0x33, 0x63, 0x1d, 0xaa, 0x09, 0x52, 0x69, 0x15, - 0xdf, 0x4d, 0xbb, 0xbc, 0xf4, 0xbb, 0x20, 0xe2, 0xeb, 0xa8, 0xb5, 0x45, 0xfd, 0xf7, 0x65, 0xc2, - 0xf2, 0xd7, 0x1e, 0x84, 0x77, 0xe8, 0xa9, 0xb3, 0xdd, 0xc0, 0xfe, 0x45, 0xa5, 0xd1, 0xd0, 0x74, - 0x35, 0xf8, 0x2b, 0x6e, 0xb2, 0x20, 0x41, 0xd6, 0xfd, 0xd1, 0x1b, 0x0f, 0x3e, 0x96, 0x49, 0x2f, - 0x60, 0x23, 0xc6, 0x6f, 0x61, 0xf8, 0xdb, 0x75, 0x26, 0x25, 0x7a, 0xff, 0x5f, 0x59, 0x6f, 0xc4, - 0xf8, 0x15, 0xec, 0xb5, 0xb2, 0x7b, 0x23, 0x5c, 0xb3, 0x79, 0x17, 0xbf, 0xee, 0x16, 0xfe, 0x88, - 0x36, 0x8c, 0x7a, 0x18, 0xac, 0x2e, 0x7d, 0xfc, 0x19, 0x00, 0x00, 0xff, 0xff, 0x34, 0xce, 0x60, - 0xcf, 0x37, 0x02, 0x00, 0x00, +func file_middleware_cache_testdata_stream_proto_rawDescGZIP() []byte { + file_middleware_cache_testdata_stream_proto_rawDescOnce.Do(func() { + file_middleware_cache_testdata_stream_proto_rawDescData = protoimpl.X.CompressGZIP(file_middleware_cache_testdata_stream_proto_rawDescData) + }) + return file_middleware_cache_testdata_stream_proto_rawDescData +} + +var file_middleware_cache_testdata_stream_proto_msgTypes = make([]protoimpl.MessageInfo, 2) +var file_middleware_cache_testdata_stream_proto_goTypes = []interface{}{ + (*Request)(nil), // 0: testdata.Request + (*Response)(nil), // 1: testdata.Response + (*gitalypb.Repository)(nil), // 2: gitaly.Repository +} +var file_middleware_cache_testdata_stream_proto_depIdxs = []int32{ + 2, // 0: testdata.Request.destination:type_name -> gitaly.Repository + 0, // 1: testdata.InterceptedService.IgnoredMethod:input_type -> testdata.Request + 0, // 2: testdata.TestService.ClientStreamRepoMutator:input_type -> testdata.Request + 0, // 3: testdata.TestService.ClientStreamRepoAccessor:input_type -> testdata.Request + 0, // 4: testdata.TestService.ClientUnaryRepoMutator:input_type -> testdata.Request + 0, // 5: testdata.TestService.ClientUnaryRepoAccessor:input_type -> testdata.Request + 1, // 6: testdata.InterceptedService.IgnoredMethod:output_type -> testdata.Response + 1, // 7: testdata.TestService.ClientStreamRepoMutator:output_type -> testdata.Response + 1, // 8: testdata.TestService.ClientStreamRepoAccessor:output_type -> testdata.Response + 1, // 9: testdata.TestService.ClientUnaryRepoMutator:output_type -> testdata.Response + 1, // 10: testdata.TestService.ClientUnaryRepoAccessor:output_type -> testdata.Response + 6, // [6:11] is the sub-list for method output_type + 1, // [1:6] is the sub-list for method input_type + 1, // [1:1] is the sub-list for extension type_name + 1, // [1:1] is the sub-list for extension extendee + 0, // [0:1] is the sub-list for field type_name +} + +func init() { file_middleware_cache_testdata_stream_proto_init() } +func file_middleware_cache_testdata_stream_proto_init() { + if File_middleware_cache_testdata_stream_proto != nil { + return + } + if !protoimpl.UnsafeEnabled { + file_middleware_cache_testdata_stream_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*Request); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_middleware_cache_testdata_stream_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*Response); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + } + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: file_middleware_cache_testdata_stream_proto_rawDesc, + NumEnums: 0, + NumMessages: 2, + NumExtensions: 0, + NumServices: 2, + }, + GoTypes: file_middleware_cache_testdata_stream_proto_goTypes, + DependencyIndexes: file_middleware_cache_testdata_stream_proto_depIdxs, + MessageInfos: file_middleware_cache_testdata_stream_proto_msgTypes, + }.Build() + File_middleware_cache_testdata_stream_proto = out.File + file_middleware_cache_testdata_stream_proto_rawDesc = nil + file_middleware_cache_testdata_stream_proto_goTypes = nil + file_middleware_cache_testdata_stream_proto_depIdxs = nil } // Reference imports to suppress errors if they are not otherwise used. var _ context.Context -var _ grpc.ClientConn +var _ grpc.ClientConnInterface // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. -const _ = grpc.SupportPackageIsVersion4 +const _ = grpc.SupportPackageIsVersion6 // InterceptedServiceClient is the client API for InterceptedService service. // @@ -143,10 +260,10 @@ type InterceptedServiceClient interface { } type interceptedServiceClient struct { - cc *grpc.ClientConn + cc grpc.ClientConnInterface } -func NewInterceptedServiceClient(cc *grpc.ClientConn) InterceptedServiceClient { +func NewInterceptedServiceClient(cc grpc.ClientConnInterface) InterceptedServiceClient { return &interceptedServiceClient{cc} } @@ -168,7 +285,7 @@ type InterceptedServiceServer interface { type UnimplementedInterceptedServiceServer struct { } -func (*UnimplementedInterceptedServiceServer) IgnoredMethod(ctx context.Context, req *Request) (*Response, error) { +func (*UnimplementedInterceptedServiceServer) IgnoredMethod(context.Context, *Request) (*Response, error) { return nil, status.Errorf(codes.Unimplemented, "method IgnoredMethod not implemented") } @@ -218,10 +335,10 @@ type TestServiceClient interface { } type testServiceClient struct { - cc *grpc.ClientConn + cc grpc.ClientConnInterface } -func NewTestServiceClient(cc *grpc.ClientConn) TestServiceClient { +func NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient { return &testServiceClient{cc} } @@ -319,16 +436,16 @@ type TestServiceServer interface { type UnimplementedTestServiceServer struct { } -func (*UnimplementedTestServiceServer) ClientStreamRepoMutator(req *Request, srv TestService_ClientStreamRepoMutatorServer) error { +func (*UnimplementedTestServiceServer) ClientStreamRepoMutator(*Request, TestService_ClientStreamRepoMutatorServer) error { return status.Errorf(codes.Unimplemented, "method ClientStreamRepoMutator not implemented") } -func (*UnimplementedTestServiceServer) ClientStreamRepoAccessor(req *Request, srv TestService_ClientStreamRepoAccessorServer) error { +func (*UnimplementedTestServiceServer) ClientStreamRepoAccessor(*Request, TestService_ClientStreamRepoAccessorServer) error { return status.Errorf(codes.Unimplemented, "method ClientStreamRepoAccessor not implemented") } -func (*UnimplementedTestServiceServer) ClientUnaryRepoMutator(ctx context.Context, req *Request) (*Response, error) { +func (*UnimplementedTestServiceServer) ClientUnaryRepoMutator(context.Context, *Request) (*Response, error) { return nil, status.Errorf(codes.Unimplemented, "method ClientUnaryRepoMutator not implemented") } -func (*UnimplementedTestServiceServer) ClientUnaryRepoAccessor(ctx context.Context, req *Request) (*Response, error) { +func (*UnimplementedTestServiceServer) ClientUnaryRepoAccessor(context.Context, *Request) (*Response, error) { return nil, status.Errorf(codes.Unimplemented, "method ClientUnaryRepoAccessor not implemented") } |