Documentation
¶
Index ¶
- Variables
- func RegisterMultiServiceServer(s grpc.ServiceRegistrar, srv MultiServiceServer)
- func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer)
- type Empty
- type EmptyReply
- type EmptyResponse
- type MultiPingReply
- type MultiPingResponse
- func (*MultiPingResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MultiPingResponse) GetCounter() int32
- func (x *MultiPingResponse) GetMetadata() *ResponseMetadata
- func (x *MultiPingResponse) GetServer() string
- func (x *MultiPingResponse) GetValue() string
- func (*MultiPingResponse) ProtoMessage()
- func (x *MultiPingResponse) ProtoReflect() protoreflect.Message
- func (x *MultiPingResponse) Reset()
- func (x *MultiPingResponse) String() string
- type MultiServiceClient
- type MultiServiceServer
- type MultiService_PingListClient
- type MultiService_PingListServer
- type MultiService_PingStreamClient
- type MultiService_PingStreamErrorClient
- type MultiService_PingStreamErrorServer
- type MultiService_PingStreamServer
- type PingRequest
- type PingResponse
- func (*PingResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PingResponse) GetCounter() int32
- func (x *PingResponse) GetValue() string
- func (*PingResponse) ProtoMessage()
- func (x *PingResponse) ProtoReflect() protoreflect.Message
- func (x *PingResponse) Reset()
- func (x *PingResponse) String() string
- type ResponseMetadata
- func (*ResponseMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *ResponseMetadata) GetHostname() string
- func (x *ResponseMetadata) GetUpstreamError() string
- func (*ResponseMetadata) ProtoMessage()
- func (x *ResponseMetadata) ProtoReflect() protoreflect.Message
- func (x *ResponseMetadata) Reset()
- func (x *ResponseMetadata) String() string
- type ResponseMetadataPrepender
- func (*ResponseMetadataPrepender) Descriptor() ([]byte, []int)deprecated
- func (x *ResponseMetadataPrepender) GetMetadata() *ResponseMetadata
- func (*ResponseMetadataPrepender) ProtoMessage()
- func (x *ResponseMetadataPrepender) ProtoReflect() protoreflect.Message
- func (x *ResponseMetadataPrepender) Reset()
- func (x *ResponseMetadataPrepender) String() string
- type TestServiceClient
- type TestServiceServer
- type TestService_PingListClient
- type TestService_PingListServer
- type TestService_PingStreamClient
- type TestService_PingStreamServer
- type UnimplementedMultiServiceServer
- func (UnimplementedMultiServiceServer) Ping(context.Context, *PingRequest) (*MultiPingReply, error)
- func (UnimplementedMultiServiceServer) PingEmpty(context.Context, *Empty) (*MultiPingReply, error)
- func (UnimplementedMultiServiceServer) PingError(context.Context, *PingRequest) (*EmptyReply, error)
- func (UnimplementedMultiServiceServer) PingList(*PingRequest, MultiService_PingListServer) error
- func (UnimplementedMultiServiceServer) PingStream(MultiService_PingStreamServer) error
- func (UnimplementedMultiServiceServer) PingStreamError(MultiService_PingStreamErrorServer) error
- type UnimplementedTestServiceServer
- func (UnimplementedTestServiceServer) Ping(context.Context, *PingRequest) (*PingResponse, error)
- func (UnimplementedTestServiceServer) PingEmpty(context.Context, *Empty) (*PingResponse, error)
- func (UnimplementedTestServiceServer) PingError(context.Context, *PingRequest) (*Empty, error)
- func (UnimplementedTestServiceServer) PingList(*PingRequest, TestService_PingListServer) error
- func (UnimplementedTestServiceServer) PingStream(TestService_PingStreamServer) error
- type UnsafeMultiServiceServer
- type UnsafeTestServiceServer
Constants ¶
This section is empty.
Variables ¶
var File_test_proto protoreflect.FileDescriptor
var MultiService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "talos.testproto.MultiService", HandlerType: (*MultiServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "PingEmpty", Handler: _MultiService_PingEmpty_Handler, }, { MethodName: "Ping", Handler: _MultiService_Ping_Handler, }, { MethodName: "PingError", Handler: _MultiService_PingError_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "PingList", Handler: _MultiService_PingList_Handler, ServerStreams: true, }, { StreamName: "PingStream", Handler: _MultiService_PingStream_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "PingStreamError", Handler: _MultiService_PingStreamError_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "test.proto", }
MultiService_ServiceDesc is the grpc.ServiceDesc for MultiService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var TestService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "talos.testproto.TestService", HandlerType: (*TestServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "PingEmpty", Handler: _TestService_PingEmpty_Handler, }, { MethodName: "Ping", Handler: _TestService_Ping_Handler, }, { MethodName: "PingError", Handler: _TestService_PingError_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "PingList", Handler: _TestService_PingList_Handler, ServerStreams: true, }, { StreamName: "PingStream", Handler: _TestService_PingStream_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "test.proto", }
TestService_ServiceDesc is the grpc.ServiceDesc for TestService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMultiServiceServer ¶
func RegisterMultiServiceServer(s grpc.ServiceRegistrar, srv MultiServiceServer)
func RegisterTestServiceServer ¶
func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer)
Types ¶
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor
deprecated
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶ added in v0.3.0
func (x *Empty) ProtoReflect() protoreflect.Message
type EmptyReply ¶
type EmptyReply struct {
Response []*EmptyResponse `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
// contains filtered or unexported fields
}
func (*EmptyReply) Descriptor
deprecated
func (*EmptyReply) Descriptor() ([]byte, []int)
Deprecated: Use EmptyReply.ProtoReflect.Descriptor instead.
func (*EmptyReply) GetResponse ¶
func (x *EmptyReply) GetResponse() []*EmptyResponse
func (*EmptyReply) ProtoMessage ¶
func (*EmptyReply) ProtoMessage()
func (*EmptyReply) ProtoReflect ¶ added in v0.3.0
func (x *EmptyReply) ProtoReflect() protoreflect.Message
func (*EmptyReply) Reset ¶
func (x *EmptyReply) Reset()
func (*EmptyReply) String ¶
func (x *EmptyReply) String() string
type EmptyResponse ¶
type EmptyResponse struct {
Metadata *ResponseMetadata `protobuf:"bytes,99,opt,name=metadata,proto3" json:"metadata,omitempty"`
// contains filtered or unexported fields
}
func (*EmptyResponse) Descriptor
deprecated
func (*EmptyResponse) Descriptor() ([]byte, []int)
Deprecated: Use EmptyResponse.ProtoReflect.Descriptor instead.
func (*EmptyResponse) GetMetadata ¶
func (x *EmptyResponse) GetMetadata() *ResponseMetadata
func (*EmptyResponse) ProtoMessage ¶
func (*EmptyResponse) ProtoMessage()
func (*EmptyResponse) ProtoReflect ¶ added in v0.3.0
func (x *EmptyResponse) ProtoReflect() protoreflect.Message
func (*EmptyResponse) Reset ¶
func (x *EmptyResponse) Reset()
func (*EmptyResponse) String ¶
func (x *EmptyResponse) String() string
type MultiPingReply ¶
type MultiPingReply struct {
Response []*MultiPingResponse `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
// contains filtered or unexported fields
}
func (*MultiPingReply) Descriptor
deprecated
func (*MultiPingReply) Descriptor() ([]byte, []int)
Deprecated: Use MultiPingReply.ProtoReflect.Descriptor instead.
func (*MultiPingReply) GetResponse ¶
func (x *MultiPingReply) GetResponse() []*MultiPingResponse
func (*MultiPingReply) ProtoMessage ¶
func (*MultiPingReply) ProtoMessage()
func (*MultiPingReply) ProtoReflect ¶ added in v0.3.0
func (x *MultiPingReply) ProtoReflect() protoreflect.Message
func (*MultiPingReply) Reset ¶
func (x *MultiPingReply) Reset()
func (*MultiPingReply) String ¶
func (x *MultiPingReply) String() string
type MultiPingResponse ¶
type MultiPingResponse struct {
Metadata *ResponseMetadata `protobuf:"bytes,99,opt,name=metadata,proto3" json:"metadata,omitempty"`
Value string `protobuf:"bytes,1,opt,name=Value,proto3" json:"Value,omitempty"`
Counter int32 `protobuf:"varint,2,opt,name=counter,proto3" json:"counter,omitempty"`
Server string `protobuf:"bytes,3,opt,name=server,proto3" json:"server,omitempty"`
// contains filtered or unexported fields
}
func (*MultiPingResponse) Descriptor
deprecated
func (*MultiPingResponse) Descriptor() ([]byte, []int)
Deprecated: Use MultiPingResponse.ProtoReflect.Descriptor instead.
func (*MultiPingResponse) GetCounter ¶
func (x *MultiPingResponse) GetCounter() int32
func (*MultiPingResponse) GetMetadata ¶
func (x *MultiPingResponse) GetMetadata() *ResponseMetadata
func (*MultiPingResponse) GetServer ¶
func (x *MultiPingResponse) GetServer() string
func (*MultiPingResponse) GetValue ¶
func (x *MultiPingResponse) GetValue() string
func (*MultiPingResponse) ProtoMessage ¶
func (*MultiPingResponse) ProtoMessage()
func (*MultiPingResponse) ProtoReflect ¶ added in v0.3.0
func (x *MultiPingResponse) ProtoReflect() protoreflect.Message
func (*MultiPingResponse) Reset ¶
func (x *MultiPingResponse) Reset()
func (*MultiPingResponse) String ¶
func (x *MultiPingResponse) String() string
type MultiServiceClient ¶
type MultiServiceClient interface {
PingEmpty(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*MultiPingReply, error)
Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*MultiPingReply, error)
PingError(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*EmptyReply, error)
PingList(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (MultiService_PingListClient, error)
PingStream(ctx context.Context, opts ...grpc.CallOption) (MultiService_PingStreamClient, error)
PingStreamError(ctx context.Context, opts ...grpc.CallOption) (MultiService_PingStreamErrorClient, error)
}
MultiServiceClient is the client API for MultiService 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.
func NewMultiServiceClient ¶
func NewMultiServiceClient(cc grpc.ClientConnInterface) MultiServiceClient
type MultiServiceServer ¶
type MultiServiceServer interface {
PingEmpty(context.Context, *Empty) (*MultiPingReply, error)
Ping(context.Context, *PingRequest) (*MultiPingReply, error)
PingError(context.Context, *PingRequest) (*EmptyReply, error)
PingList(*PingRequest, MultiService_PingListServer) error
PingStream(MultiService_PingStreamServer) error
PingStreamError(MultiService_PingStreamErrorServer) error
// contains filtered or unexported methods
}
MultiServiceServer is the server API for MultiService service. All implementations must embed UnimplementedMultiServiceServer for forward compatibility
type MultiService_PingListClient ¶
type MultiService_PingListClient interface {
Recv() (*MultiPingResponse, error)
grpc.ClientStream
}
type MultiService_PingListServer ¶
type MultiService_PingListServer interface {
Send(*MultiPingResponse) error
grpc.ServerStream
}
type MultiService_PingStreamClient ¶
type MultiService_PingStreamClient interface {
Send(*PingRequest) error
Recv() (*MultiPingResponse, error)
grpc.ClientStream
}
type MultiService_PingStreamErrorClient ¶
type MultiService_PingStreamErrorClient interface {
Send(*PingRequest) error
Recv() (*MultiPingResponse, error)
grpc.ClientStream
}
type MultiService_PingStreamErrorServer ¶
type MultiService_PingStreamErrorServer interface {
Send(*MultiPingResponse) error
Recv() (*PingRequest, error)
grpc.ServerStream
}
type MultiService_PingStreamServer ¶
type MultiService_PingStreamServer interface {
Send(*MultiPingResponse) error
Recv() (*PingRequest, error)
grpc.ServerStream
}
type PingRequest ¶
type PingRequest struct {
Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
func (*PingRequest) Descriptor
deprecated
func (*PingRequest) Descriptor() ([]byte, []int)
Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.
func (*PingRequest) GetValue ¶
func (x *PingRequest) GetValue() string
func (*PingRequest) ProtoMessage ¶
func (*PingRequest) ProtoMessage()
func (*PingRequest) ProtoReflect ¶ added in v0.3.0
func (x *PingRequest) ProtoReflect() protoreflect.Message
func (*PingRequest) Reset ¶
func (x *PingRequest) Reset()
func (*PingRequest) String ¶
func (x *PingRequest) String() string
type PingResponse ¶
type PingResponse struct {
Value string `protobuf:"bytes,1,opt,name=Value,proto3" json:"Value,omitempty"`
Counter int32 `protobuf:"varint,2,opt,name=counter,proto3" json:"counter,omitempty"`
// contains filtered or unexported fields
}
func (*PingResponse) Descriptor
deprecated
func (*PingResponse) Descriptor() ([]byte, []int)
Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.
func (*PingResponse) GetCounter ¶
func (x *PingResponse) GetCounter() int32
func (*PingResponse) GetValue ¶
func (x *PingResponse) GetValue() string
func (*PingResponse) ProtoMessage ¶
func (*PingResponse) ProtoMessage()
func (*PingResponse) ProtoReflect ¶ added in v0.3.0
func (x *PingResponse) ProtoReflect() protoreflect.Message
func (*PingResponse) Reset ¶
func (x *PingResponse) Reset()
func (*PingResponse) String ¶
func (x *PingResponse) String() string
type ResponseMetadata ¶
type ResponseMetadata struct {
Hostname string `protobuf:"bytes,99,opt,name=hostname,proto3" json:"hostname,omitempty"`
UpstreamError string `protobuf:"bytes,100,opt,name=upstream_error,json=upstreamError,proto3" json:"upstream_error,omitempty"`
// contains filtered or unexported fields
}
func (*ResponseMetadata) Descriptor
deprecated
func (*ResponseMetadata) Descriptor() ([]byte, []int)
Deprecated: Use ResponseMetadata.ProtoReflect.Descriptor instead.
func (*ResponseMetadata) GetHostname ¶
func (x *ResponseMetadata) GetHostname() string
func (*ResponseMetadata) GetUpstreamError ¶
func (x *ResponseMetadata) GetUpstreamError() string
func (*ResponseMetadata) ProtoMessage ¶
func (*ResponseMetadata) ProtoMessage()
func (*ResponseMetadata) ProtoReflect ¶ added in v0.3.0
func (x *ResponseMetadata) ProtoReflect() protoreflect.Message
func (*ResponseMetadata) Reset ¶
func (x *ResponseMetadata) Reset()
func (*ResponseMetadata) String ¶
func (x *ResponseMetadata) String() string
type ResponseMetadataPrepender ¶
type ResponseMetadataPrepender struct {
Metadata *ResponseMetadata `protobuf:"bytes,99,opt,name=metadata,proto3" json:"metadata,omitempty"`
// contains filtered or unexported fields
}
func (*ResponseMetadataPrepender) Descriptor
deprecated
func (*ResponseMetadataPrepender) Descriptor() ([]byte, []int)
Deprecated: Use ResponseMetadataPrepender.ProtoReflect.Descriptor instead.
func (*ResponseMetadataPrepender) GetMetadata ¶
func (x *ResponseMetadataPrepender) GetMetadata() *ResponseMetadata
func (*ResponseMetadataPrepender) ProtoMessage ¶
func (*ResponseMetadataPrepender) ProtoMessage()
func (*ResponseMetadataPrepender) ProtoReflect ¶ added in v0.3.0
func (x *ResponseMetadataPrepender) ProtoReflect() protoreflect.Message
func (*ResponseMetadataPrepender) Reset ¶
func (x *ResponseMetadataPrepender) Reset()
func (*ResponseMetadataPrepender) String ¶
func (x *ResponseMetadataPrepender) String() string
type TestServiceClient ¶
type TestServiceClient interface {
PingEmpty(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PingResponse, error)
Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
PingError(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*Empty, error)
PingList(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (TestService_PingListClient, error)
PingStream(ctx context.Context, opts ...grpc.CallOption) (TestService_PingStreamClient, error)
}
TestServiceClient is the client API for TestService 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.
func NewTestServiceClient ¶
func NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient
type TestServiceServer ¶
type TestServiceServer interface {
PingEmpty(context.Context, *Empty) (*PingResponse, error)
Ping(context.Context, *PingRequest) (*PingResponse, error)
PingError(context.Context, *PingRequest) (*Empty, error)
PingList(*PingRequest, TestService_PingListServer) error
PingStream(TestService_PingStreamServer) error
// contains filtered or unexported methods
}
TestServiceServer is the server API for TestService service. All implementations must embed UnimplementedTestServiceServer for forward compatibility
type TestService_PingListClient ¶
type TestService_PingListClient interface {
Recv() (*PingResponse, error)
grpc.ClientStream
}
type TestService_PingListServer ¶
type TestService_PingListServer interface {
Send(*PingResponse) error
grpc.ServerStream
}
type TestService_PingStreamClient ¶
type TestService_PingStreamClient interface {
Send(*PingRequest) error
Recv() (*PingResponse, error)
grpc.ClientStream
}
type TestService_PingStreamServer ¶
type TestService_PingStreamServer interface {
Send(*PingResponse) error
Recv() (*PingRequest, error)
grpc.ServerStream
}
type UnimplementedMultiServiceServer ¶
type UnimplementedMultiServiceServer struct{}
UnimplementedMultiServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedMultiServiceServer) Ping ¶
func (UnimplementedMultiServiceServer) Ping(context.Context, *PingRequest) (*MultiPingReply, error)
func (UnimplementedMultiServiceServer) PingEmpty ¶
func (UnimplementedMultiServiceServer) PingEmpty(context.Context, *Empty) (*MultiPingReply, error)
func (UnimplementedMultiServiceServer) PingError ¶
func (UnimplementedMultiServiceServer) PingError(context.Context, *PingRequest) (*EmptyReply, error)
func (UnimplementedMultiServiceServer) PingList ¶
func (UnimplementedMultiServiceServer) PingList(*PingRequest, MultiService_PingListServer) error
func (UnimplementedMultiServiceServer) PingStream ¶
func (UnimplementedMultiServiceServer) PingStream(MultiService_PingStreamServer) error
func (UnimplementedMultiServiceServer) PingStreamError ¶
func (UnimplementedMultiServiceServer) PingStreamError(MultiService_PingStreamErrorServer) error
type UnimplementedTestServiceServer ¶
type UnimplementedTestServiceServer struct{}
UnimplementedTestServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedTestServiceServer) Ping ¶
func (UnimplementedTestServiceServer) Ping(context.Context, *PingRequest) (*PingResponse, error)
func (UnimplementedTestServiceServer) PingEmpty ¶
func (UnimplementedTestServiceServer) PingEmpty(context.Context, *Empty) (*PingResponse, error)
func (UnimplementedTestServiceServer) PingError ¶
func (UnimplementedTestServiceServer) PingError(context.Context, *PingRequest) (*Empty, error)
func (UnimplementedTestServiceServer) PingList ¶
func (UnimplementedTestServiceServer) PingList(*PingRequest, TestService_PingListServer) error
func (UnimplementedTestServiceServer) PingStream ¶
func (UnimplementedTestServiceServer) PingStream(TestService_PingStreamServer) error
type UnsafeMultiServiceServer ¶ added in v0.3.0
type UnsafeMultiServiceServer interface {
// contains filtered or unexported methods
}
UnsafeMultiServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MultiServiceServer will result in compilation errors.
type UnsafeTestServiceServer ¶ added in v0.3.0
type UnsafeTestServiceServer interface {
// contains filtered or unexported methods
}
UnsafeTestServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TestServiceServer will result in compilation errors.