Versions in this module Expand all Collapse all v1 v1.21.0 Jul 1, 2024 Changes in this version + const TestService_EmptyCall_FullMethodName + const TestService_FullDuplexCall_FullMethodName + const TestService_HalfDuplexCall_FullMethodName + const TestService_StreamingInputCall_FullMethodName + const TestService_StreamingOutputCall_FullMethodName + const TestService_UnaryAny_FullMethodName + const TestService_UnaryCall_FullMethodName + const TestService_UnaryUpdateCall_FullMethodName + var File_test_proto protoreflect.FileDescriptor + var TestService_ServiceDesc = grpc.ServiceDesc + func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer) + type EchoStatus struct + Code int32 + Message string + func (*EchoStatus) Descriptor() ([]byte, []int) + func (*EchoStatus) ProtoMessage() + func (x *EchoStatus) GetCode() int32 + func (x *EchoStatus) GetMessage() string + func (x *EchoStatus) ProtoReflect() protoreflect.Message + func (x *EchoStatus) Reset() + func (x *EchoStatus) String() string + type ResponseParameters struct + IntervalUs int32 + Size int32 + func (*ResponseParameters) Descriptor() ([]byte, []int) + func (*ResponseParameters) ProtoMessage() + func (x *ResponseParameters) GetIntervalUs() int32 + func (x *ResponseParameters) GetSize() int32 + func (x *ResponseParameters) ProtoReflect() protoreflect.Message + func (x *ResponseParameters) Reset() + func (x *ResponseParameters) String() string + type SimpleAnyRequest struct + UserId int32 + UserProps *anypb.Any + func (*SimpleAnyRequest) Descriptor() ([]byte, []int) + func (*SimpleAnyRequest) ProtoMessage() + func (x *SimpleAnyRequest) GetUserId() int32 + func (x *SimpleAnyRequest) GetUserProps() *anypb.Any + func (x *SimpleAnyRequest) ProtoReflect() protoreflect.Message + func (x *SimpleAnyRequest) Reset() + func (x *SimpleAnyRequest) String() string + type SimpleAnyResponse struct + UserId int32 + UserProps *anypb.Any + func (*SimpleAnyResponse) Descriptor() ([]byte, []int) + func (*SimpleAnyResponse) ProtoMessage() + func (x *SimpleAnyResponse) GetUserId() int32 + func (x *SimpleAnyResponse) GetUserProps() *anypb.Any + func (x *SimpleAnyResponse) ProtoReflect() protoreflect.Message + func (x *SimpleAnyResponse) Reset() + func (x *SimpleAnyResponse) String() string + type SimpleRequest struct + ResponseStatus *EchoStatus + User *User + func (*SimpleRequest) Descriptor() ([]byte, []int) + func (*SimpleRequest) ProtoMessage() + func (x *SimpleRequest) GetResponseStatus() *EchoStatus + func (x *SimpleRequest) GetUser() *User + func (x *SimpleRequest) ProtoReflect() protoreflect.Message + func (x *SimpleRequest) Reset() + func (x *SimpleRequest) String() string + type SimpleResponse struct + User *User + func (*SimpleResponse) Descriptor() ([]byte, []int) + func (*SimpleResponse) ProtoMessage() + func (x *SimpleResponse) GetUser() *User + func (x *SimpleResponse) ProtoReflect() protoreflect.Message + func (x *SimpleResponse) Reset() + func (x *SimpleResponse) String() string + type StreamingInputCallRequest struct + User *User + func (*StreamingInputCallRequest) Descriptor() ([]byte, []int) + func (*StreamingInputCallRequest) ProtoMessage() + func (x *StreamingInputCallRequest) GetUser() *User + func (x *StreamingInputCallRequest) ProtoReflect() protoreflect.Message + func (x *StreamingInputCallRequest) Reset() + func (x *StreamingInputCallRequest) String() string + type StreamingInputCallResponse struct + AggregatedPayloadSize int32 + User *User + func (*StreamingInputCallResponse) Descriptor() ([]byte, []int) + func (*StreamingInputCallResponse) ProtoMessage() + func (x *StreamingInputCallResponse) GetAggregatedPayloadSize() int32 + func (x *StreamingInputCallResponse) GetUser() *User + func (x *StreamingInputCallResponse) ProtoReflect() protoreflect.Message + func (x *StreamingInputCallResponse) Reset() + func (x *StreamingInputCallResponse) String() string + type StreamingOutputCallRequest struct + ResponseParameters []*ResponseParameters + ResponseStatus *EchoStatus + User *User + func (*StreamingOutputCallRequest) Descriptor() ([]byte, []int) + func (*StreamingOutputCallRequest) ProtoMessage() + func (x *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters + func (x *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus + func (x *StreamingOutputCallRequest) GetUser() *User + func (x *StreamingOutputCallRequest) ProtoReflect() protoreflect.Message + func (x *StreamingOutputCallRequest) Reset() + func (x *StreamingOutputCallRequest) String() string + type StreamingOutputCallResponse struct + User *User + func (*StreamingOutputCallResponse) Descriptor() ([]byte, []int) + func (*StreamingOutputCallResponse) ProtoMessage() + func (x *StreamingOutputCallResponse) GetUser() *User + func (x *StreamingOutputCallResponse) ProtoReflect() protoreflect.Message + func (x *StreamingOutputCallResponse) Reset() + func (x *StreamingOutputCallResponse) String() string + type TestServiceClient interface + EmptyCall func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) + FullDuplexCall func(ctx context.Context, opts ...grpc.CallOption) (TestService_FullDuplexCallClient, error) + HalfDuplexCall func(ctx context.Context, opts ...grpc.CallOption) (TestService_HalfDuplexCallClient, error) + StreamingInputCall func(ctx context.Context, opts ...grpc.CallOption) (TestService_StreamingInputCallClient, error) + StreamingOutputCall func(ctx context.Context, in *StreamingOutputCallRequest, opts ...grpc.CallOption) (TestService_StreamingOutputCallClient, error) + UnaryAny func(ctx context.Context, in *SimpleAnyRequest, opts ...grpc.CallOption) (*SimpleAnyResponse, error) + UnaryCall func(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error) + UnaryUpdateCall func(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error) + func NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient + type TestServiceServer interface + EmptyCall func(context.Context, *emptypb.Empty) (*emptypb.Empty, error) + FullDuplexCall func(TestService_FullDuplexCallServer) error + HalfDuplexCall func(TestService_HalfDuplexCallServer) error + StreamingInputCall func(TestService_StreamingInputCallServer) error + StreamingOutputCall func(*StreamingOutputCallRequest, TestService_StreamingOutputCallServer) error + UnaryAny func(context.Context, *SimpleAnyRequest) (*SimpleAnyResponse, error) + UnaryCall func(context.Context, *SimpleRequest) (*SimpleResponse, error) + UnaryUpdateCall func(context.Context, *UpdateRequest) (*UpdateResponse, error) + type TestService_FullDuplexCallClient interface + Recv func() (*StreamingOutputCallResponse, error) + Send func(*StreamingOutputCallRequest) error + type TestService_FullDuplexCallServer interface + Recv func() (*StreamingOutputCallRequest, error) + Send func(*StreamingOutputCallResponse) error + type TestService_HalfDuplexCallClient interface + Recv func() (*StreamingOutputCallResponse, error) + Send func(*StreamingOutputCallRequest) error + type TestService_HalfDuplexCallServer interface + Recv func() (*StreamingOutputCallRequest, error) + Send func(*StreamingOutputCallResponse) error + type TestService_StreamingInputCallClient interface + CloseAndRecv func() (*StreamingInputCallResponse, error) + Send func(*StreamingInputCallRequest) error + type TestService_StreamingInputCallServer interface + Recv func() (*StreamingInputCallRequest, error) + SendAndClose func(*StreamingInputCallResponse) error + type TestService_StreamingOutputCallClient interface + Recv func() (*StreamingOutputCallResponse, error) + type TestService_StreamingOutputCallServer interface + Send func(*StreamingOutputCallResponse) error + type UnimplementedTestServiceServer struct + func (UnimplementedTestServiceServer) EmptyCall(context.Context, *emptypb.Empty) (*emptypb.Empty, error) + func (UnimplementedTestServiceServer) FullDuplexCall(TestService_FullDuplexCallServer) error + func (UnimplementedTestServiceServer) HalfDuplexCall(TestService_HalfDuplexCallServer) error + func (UnimplementedTestServiceServer) StreamingInputCall(TestService_StreamingInputCallServer) error + func (UnimplementedTestServiceServer) StreamingOutputCall(*StreamingOutputCallRequest, TestService_StreamingOutputCallServer) error + func (UnimplementedTestServiceServer) UnaryAny(context.Context, *SimpleAnyRequest) (*SimpleAnyResponse, error) + func (UnimplementedTestServiceServer) UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error) + func (UnimplementedTestServiceServer) UnaryUpdateCall(context.Context, *UpdateRequest) (*UpdateResponse, error) + type UnsafeTestServiceServer interface + type UpdateRequest struct + UpdateMask *fieldmaskpb.FieldMask + func (*UpdateRequest) Descriptor() ([]byte, []int) + func (*UpdateRequest) ProtoMessage() + func (x *UpdateRequest) GetUpdateMask() *fieldmaskpb.FieldMask + func (x *UpdateRequest) ProtoReflect() protoreflect.Message + func (x *UpdateRequest) Reset() + func (x *UpdateRequest) String() string + type UpdateResponse struct + UpdateMask *fieldmaskpb.FieldMask + func (*UpdateResponse) Descriptor() ([]byte, []int) + func (*UpdateResponse) ProtoMessage() + func (x *UpdateResponse) GetUpdateMask() *fieldmaskpb.FieldMask + func (x *UpdateResponse) ProtoReflect() protoreflect.Message + func (x *UpdateResponse) Reset() + func (x *UpdateResponse) String() string + type User struct + Id int32 + Name string + func (*User) Descriptor() ([]byte, []int) + func (*User) ProtoMessage() + func (x *User) GetId() int32 + func (x *User) GetName() string + func (x *User) ProtoReflect() protoreflect.Message + func (x *User) Reset() + func (x *User) String() string