Documentation
¶
Index ¶
- func RegisterMultiServiceServer(s *grpc.Server, srv MultiServiceServer)
- func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer)
- type Empty
- func (*Empty) Descriptor() ([]byte, []int)
- func (*Empty) ProtoMessage()
- func (m *Empty) Reset()
- func (m *Empty) String() string
- func (m *Empty) XXX_DiscardUnknown()
- func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Empty) XXX_Merge(src proto.Message)
- func (m *Empty) XXX_Size() int
- func (m *Empty) XXX_Unmarshal(b []byte) error
- type EmptyReply
- func (*EmptyReply) Descriptor() ([]byte, []int)
- func (m *EmptyReply) GetResponse() []*EmptyResponse
- func (*EmptyReply) ProtoMessage()
- func (m *EmptyReply) Reset()
- func (m *EmptyReply) String() string
- func (m *EmptyReply) XXX_DiscardUnknown()
- func (m *EmptyReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EmptyReply) XXX_Merge(src proto.Message)
- func (m *EmptyReply) XXX_Size() int
- func (m *EmptyReply) XXX_Unmarshal(b []byte) error
- type EmptyResponse
- func (*EmptyResponse) Descriptor() ([]byte, []int)
- func (m *EmptyResponse) GetMetadata() *ResponseMetadata
- func (*EmptyResponse) ProtoMessage()
- func (m *EmptyResponse) Reset()
- func (m *EmptyResponse) String() string
- func (m *EmptyResponse) XXX_DiscardUnknown()
- func (m *EmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EmptyResponse) XXX_Merge(src proto.Message)
- func (m *EmptyResponse) XXX_Size() int
- func (m *EmptyResponse) XXX_Unmarshal(b []byte) error
- type MultiPingReply
- func (*MultiPingReply) Descriptor() ([]byte, []int)
- func (m *MultiPingReply) GetResponse() []*MultiPingResponse
- func (*MultiPingReply) ProtoMessage()
- func (m *MultiPingReply) Reset()
- func (m *MultiPingReply) String() string
- func (m *MultiPingReply) XXX_DiscardUnknown()
- func (m *MultiPingReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MultiPingReply) XXX_Merge(src proto.Message)
- func (m *MultiPingReply) XXX_Size() int
- func (m *MultiPingReply) XXX_Unmarshal(b []byte) error
- type MultiPingResponse
- func (*MultiPingResponse) Descriptor() ([]byte, []int)
- func (m *MultiPingResponse) GetCounter() int32
- func (m *MultiPingResponse) GetMetadata() *ResponseMetadata
- func (m *MultiPingResponse) GetServer() string
- func (m *MultiPingResponse) GetValue() string
- func (*MultiPingResponse) ProtoMessage()
- func (m *MultiPingResponse) Reset()
- func (m *MultiPingResponse) String() string
- func (m *MultiPingResponse) XXX_DiscardUnknown()
- func (m *MultiPingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MultiPingResponse) XXX_Merge(src proto.Message)
- func (m *MultiPingResponse) XXX_Size() int
- func (m *MultiPingResponse) XXX_Unmarshal(b []byte) error
- type MultiServiceClient
- type MultiServiceServer
- type MultiService_PingListClient
- type MultiService_PingListServer
- type MultiService_PingStreamClient
- type MultiService_PingStreamErrorClient
- type MultiService_PingStreamErrorServer
- type MultiService_PingStreamServer
- type PingRequest
- func (*PingRequest) Descriptor() ([]byte, []int)
- func (m *PingRequest) GetValue() string
- func (*PingRequest) ProtoMessage()
- func (m *PingRequest) Reset()
- func (m *PingRequest) String() string
- func (m *PingRequest) XXX_DiscardUnknown()
- func (m *PingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PingRequest) XXX_Merge(src proto.Message)
- func (m *PingRequest) XXX_Size() int
- func (m *PingRequest) XXX_Unmarshal(b []byte) error
- type PingResponse
- func (*PingResponse) Descriptor() ([]byte, []int)
- func (m *PingResponse) GetCounter() int32
- func (m *PingResponse) GetValue() string
- func (*PingResponse) ProtoMessage()
- func (m *PingResponse) Reset()
- func (m *PingResponse) String() string
- func (m *PingResponse) XXX_DiscardUnknown()
- func (m *PingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PingResponse) XXX_Merge(src proto.Message)
- func (m *PingResponse) XXX_Size() int
- func (m *PingResponse) XXX_Unmarshal(b []byte) error
- type ResponseMetadata
- func (*ResponseMetadata) Descriptor() ([]byte, []int)
- func (m *ResponseMetadata) GetHostname() string
- func (m *ResponseMetadata) GetUpstreamError() string
- func (*ResponseMetadata) ProtoMessage()
- func (m *ResponseMetadata) Reset()
- func (m *ResponseMetadata) String() string
- func (m *ResponseMetadata) XXX_DiscardUnknown()
- func (m *ResponseMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResponseMetadata) XXX_Merge(src proto.Message)
- func (m *ResponseMetadata) XXX_Size() int
- func (m *ResponseMetadata) XXX_Unmarshal(b []byte) error
- type ResponseMetadataPrepender
- func (*ResponseMetadataPrepender) Descriptor() ([]byte, []int)
- func (m *ResponseMetadataPrepender) GetMetadata() *ResponseMetadata
- func (*ResponseMetadataPrepender) ProtoMessage()
- func (m *ResponseMetadataPrepender) Reset()
- func (m *ResponseMetadataPrepender) String() string
- func (m *ResponseMetadataPrepender) XXX_DiscardUnknown()
- func (m *ResponseMetadataPrepender) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResponseMetadataPrepender) XXX_Merge(src proto.Message)
- func (m *ResponseMetadataPrepender) XXX_Size() int
- func (m *ResponseMetadataPrepender) XXX_Unmarshal(b []byte) error
- type TestServiceClient
- type TestServiceServer
- type TestService_PingListClient
- type TestService_PingListServer
- type TestService_PingStreamClient
- type TestService_PingStreamServer
- type UnimplementedMultiServiceServer
- func (*UnimplementedMultiServiceServer) Ping(ctx context.Context, req *PingRequest) (*MultiPingReply, error)
- func (*UnimplementedMultiServiceServer) PingEmpty(ctx context.Context, req *Empty) (*MultiPingReply, error)
- func (*UnimplementedMultiServiceServer) PingError(ctx context.Context, req *PingRequest) (*EmptyReply, error)
- func (*UnimplementedMultiServiceServer) PingList(req *PingRequest, srv MultiService_PingListServer) error
- func (*UnimplementedMultiServiceServer) PingStream(srv MultiService_PingStreamServer) error
- func (*UnimplementedMultiServiceServer) PingStreamError(srv MultiService_PingStreamErrorServer) error
- type UnimplementedTestServiceServer
- func (*UnimplementedTestServiceServer) Ping(ctx context.Context, req *PingRequest) (*PingResponse, error)
- func (*UnimplementedTestServiceServer) PingEmpty(ctx context.Context, req *Empty) (*PingResponse, error)
- func (*UnimplementedTestServiceServer) PingError(ctx context.Context, req *PingRequest) (*Empty, error)
- func (*UnimplementedTestServiceServer) PingList(req *PingRequest, srv TestService_PingListServer) error
- func (*UnimplementedTestServiceServer) PingStream(srv TestService_PingStreamServer) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterMultiServiceServer ¶
func RegisterMultiServiceServer(s *grpc.Server, srv MultiServiceServer)
func RegisterTestServiceServer ¶
func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer)
Types ¶
type Empty ¶
type Empty struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) XXX_DiscardUnknown ¶
func (m *Empty) XXX_DiscardUnknown()
func (*Empty) XXX_Marshal ¶
func (*Empty) XXX_Unmarshal ¶
type EmptyReply ¶
type EmptyReply struct {
Response []*EmptyResponse `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*EmptyReply) Descriptor ¶
func (*EmptyReply) Descriptor() ([]byte, []int)
func (*EmptyReply) GetResponse ¶
func (m *EmptyReply) GetResponse() []*EmptyResponse
func (*EmptyReply) ProtoMessage ¶
func (*EmptyReply) ProtoMessage()
func (*EmptyReply) Reset ¶
func (m *EmptyReply) Reset()
func (*EmptyReply) String ¶
func (m *EmptyReply) String() string
func (*EmptyReply) XXX_DiscardUnknown ¶
func (m *EmptyReply) XXX_DiscardUnknown()
func (*EmptyReply) XXX_Marshal ¶
func (m *EmptyReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EmptyReply) XXX_Merge ¶
func (m *EmptyReply) XXX_Merge(src proto.Message)
func (*EmptyReply) XXX_Size ¶
func (m *EmptyReply) XXX_Size() int
func (*EmptyReply) XXX_Unmarshal ¶
func (m *EmptyReply) XXX_Unmarshal(b []byte) error
type EmptyResponse ¶
type EmptyResponse struct {
Metadata *ResponseMetadata `protobuf:"bytes,99,opt,name=metadata,proto3" json:"metadata,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*EmptyResponse) Descriptor ¶
func (*EmptyResponse) Descriptor() ([]byte, []int)
func (*EmptyResponse) GetMetadata ¶
func (m *EmptyResponse) GetMetadata() *ResponseMetadata
func (*EmptyResponse) ProtoMessage ¶
func (*EmptyResponse) ProtoMessage()
func (*EmptyResponse) Reset ¶
func (m *EmptyResponse) Reset()
func (*EmptyResponse) String ¶
func (m *EmptyResponse) String() string
func (*EmptyResponse) XXX_DiscardUnknown ¶
func (m *EmptyResponse) XXX_DiscardUnknown()
func (*EmptyResponse) XXX_Marshal ¶
func (m *EmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EmptyResponse) XXX_Merge ¶
func (m *EmptyResponse) XXX_Merge(src proto.Message)
func (*EmptyResponse) XXX_Size ¶
func (m *EmptyResponse) XXX_Size() int
func (*EmptyResponse) XXX_Unmarshal ¶
func (m *EmptyResponse) XXX_Unmarshal(b []byte) error
type MultiPingReply ¶
type MultiPingReply struct {
Response []*MultiPingResponse `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*MultiPingReply) Descriptor ¶
func (*MultiPingReply) Descriptor() ([]byte, []int)
func (*MultiPingReply) GetResponse ¶
func (m *MultiPingReply) GetResponse() []*MultiPingResponse
func (*MultiPingReply) ProtoMessage ¶
func (*MultiPingReply) ProtoMessage()
func (*MultiPingReply) Reset ¶
func (m *MultiPingReply) Reset()
func (*MultiPingReply) String ¶
func (m *MultiPingReply) String() string
func (*MultiPingReply) XXX_DiscardUnknown ¶
func (m *MultiPingReply) XXX_DiscardUnknown()
func (*MultiPingReply) XXX_Marshal ¶
func (m *MultiPingReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MultiPingReply) XXX_Merge ¶
func (m *MultiPingReply) XXX_Merge(src proto.Message)
func (*MultiPingReply) XXX_Size ¶
func (m *MultiPingReply) XXX_Size() int
func (*MultiPingReply) XXX_Unmarshal ¶
func (m *MultiPingReply) XXX_Unmarshal(b []byte) error
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*MultiPingResponse) Descriptor ¶
func (*MultiPingResponse) Descriptor() ([]byte, []int)
func (*MultiPingResponse) GetCounter ¶
func (m *MultiPingResponse) GetCounter() int32
func (*MultiPingResponse) GetMetadata ¶
func (m *MultiPingResponse) GetMetadata() *ResponseMetadata
func (*MultiPingResponse) GetServer ¶
func (m *MultiPingResponse) GetServer() string
func (*MultiPingResponse) GetValue ¶
func (m *MultiPingResponse) GetValue() string
func (*MultiPingResponse) ProtoMessage ¶
func (*MultiPingResponse) ProtoMessage()
func (*MultiPingResponse) Reset ¶
func (m *MultiPingResponse) Reset()
func (*MultiPingResponse) String ¶
func (m *MultiPingResponse) String() string
func (*MultiPingResponse) XXX_DiscardUnknown ¶
func (m *MultiPingResponse) XXX_DiscardUnknown()
func (*MultiPingResponse) XXX_Marshal ¶
func (m *MultiPingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MultiPingResponse) XXX_Merge ¶
func (m *MultiPingResponse) XXX_Merge(src proto.Message)
func (*MultiPingResponse) XXX_Size ¶
func (m *MultiPingResponse) XXX_Size() int
func (*MultiPingResponse) XXX_Unmarshal ¶
func (m *MultiPingResponse) XXX_Unmarshal(b []byte) error
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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMultiServiceClient ¶
func NewMultiServiceClient(cc *grpc.ClientConn) 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
}
MultiServiceServer is the server API for MultiService service.
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*PingRequest) Descriptor ¶
func (*PingRequest) Descriptor() ([]byte, []int)
func (*PingRequest) GetValue ¶
func (m *PingRequest) GetValue() string
func (*PingRequest) ProtoMessage ¶
func (*PingRequest) ProtoMessage()
func (*PingRequest) Reset ¶
func (m *PingRequest) Reset()
func (*PingRequest) String ¶
func (m *PingRequest) String() string
func (*PingRequest) XXX_DiscardUnknown ¶
func (m *PingRequest) XXX_DiscardUnknown()
func (*PingRequest) XXX_Marshal ¶
func (m *PingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PingRequest) XXX_Merge ¶
func (m *PingRequest) XXX_Merge(src proto.Message)
func (*PingRequest) XXX_Size ¶
func (m *PingRequest) XXX_Size() int
func (*PingRequest) XXX_Unmarshal ¶
func (m *PingRequest) XXX_Unmarshal(b []byte) error
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*PingResponse) Descriptor ¶
func (*PingResponse) Descriptor() ([]byte, []int)
func (*PingResponse) GetCounter ¶
func (m *PingResponse) GetCounter() int32
func (*PingResponse) GetValue ¶
func (m *PingResponse) GetValue() string
func (*PingResponse) ProtoMessage ¶
func (*PingResponse) ProtoMessage()
func (*PingResponse) Reset ¶
func (m *PingResponse) Reset()
func (*PingResponse) String ¶
func (m *PingResponse) String() string
func (*PingResponse) XXX_DiscardUnknown ¶
func (m *PingResponse) XXX_DiscardUnknown()
func (*PingResponse) XXX_Marshal ¶
func (m *PingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PingResponse) XXX_Merge ¶
func (m *PingResponse) XXX_Merge(src proto.Message)
func (*PingResponse) XXX_Size ¶
func (m *PingResponse) XXX_Size() int
func (*PingResponse) XXX_Unmarshal ¶
func (m *PingResponse) XXX_Unmarshal(b []byte) error
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ResponseMetadata) Descriptor ¶
func (*ResponseMetadata) Descriptor() ([]byte, []int)
func (*ResponseMetadata) GetHostname ¶
func (m *ResponseMetadata) GetHostname() string
func (*ResponseMetadata) GetUpstreamError ¶
func (m *ResponseMetadata) GetUpstreamError() string
func (*ResponseMetadata) ProtoMessage ¶
func (*ResponseMetadata) ProtoMessage()
func (*ResponseMetadata) Reset ¶
func (m *ResponseMetadata) Reset()
func (*ResponseMetadata) String ¶
func (m *ResponseMetadata) String() string
func (*ResponseMetadata) XXX_DiscardUnknown ¶
func (m *ResponseMetadata) XXX_DiscardUnknown()
func (*ResponseMetadata) XXX_Marshal ¶
func (m *ResponseMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResponseMetadata) XXX_Merge ¶
func (m *ResponseMetadata) XXX_Merge(src proto.Message)
func (*ResponseMetadata) XXX_Size ¶
func (m *ResponseMetadata) XXX_Size() int
func (*ResponseMetadata) XXX_Unmarshal ¶
func (m *ResponseMetadata) XXX_Unmarshal(b []byte) error
type ResponseMetadataPrepender ¶
type ResponseMetadataPrepender struct {
Metadata *ResponseMetadata `protobuf:"bytes,99,opt,name=metadata,proto3" json:"metadata,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ResponseMetadataPrepender) Descriptor ¶
func (*ResponseMetadataPrepender) Descriptor() ([]byte, []int)
func (*ResponseMetadataPrepender) GetMetadata ¶
func (m *ResponseMetadataPrepender) GetMetadata() *ResponseMetadata
func (*ResponseMetadataPrepender) ProtoMessage ¶
func (*ResponseMetadataPrepender) ProtoMessage()
func (*ResponseMetadataPrepender) Reset ¶
func (m *ResponseMetadataPrepender) Reset()
func (*ResponseMetadataPrepender) String ¶
func (m *ResponseMetadataPrepender) String() string
func (*ResponseMetadataPrepender) XXX_DiscardUnknown ¶
func (m *ResponseMetadataPrepender) XXX_DiscardUnknown()
func (*ResponseMetadataPrepender) XXX_Marshal ¶
func (m *ResponseMetadataPrepender) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResponseMetadataPrepender) XXX_Merge ¶
func (m *ResponseMetadataPrepender) XXX_Merge(src proto.Message)
func (*ResponseMetadataPrepender) XXX_Size ¶
func (m *ResponseMetadataPrepender) XXX_Size() int
func (*ResponseMetadataPrepender) XXX_Unmarshal ¶
func (m *ResponseMetadataPrepender) XXX_Unmarshal(b []byte) error
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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewTestServiceClient ¶
func NewTestServiceClient(cc *grpc.ClientConn) 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
}
TestServiceServer is the server API for TestService service.
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 can be embedded to have forward compatible implementations.
func (*UnimplementedMultiServiceServer) Ping ¶
func (*UnimplementedMultiServiceServer) Ping(ctx context.Context, req *PingRequest) (*MultiPingReply, error)
func (*UnimplementedMultiServiceServer) PingEmpty ¶
func (*UnimplementedMultiServiceServer) PingEmpty(ctx context.Context, req *Empty) (*MultiPingReply, error)
func (*UnimplementedMultiServiceServer) PingError ¶
func (*UnimplementedMultiServiceServer) PingError(ctx context.Context, req *PingRequest) (*EmptyReply, error)
func (*UnimplementedMultiServiceServer) PingList ¶
func (*UnimplementedMultiServiceServer) PingList(req *PingRequest, srv MultiService_PingListServer) error
func (*UnimplementedMultiServiceServer) PingStream ¶
func (*UnimplementedMultiServiceServer) PingStream(srv MultiService_PingStreamServer) error
func (*UnimplementedMultiServiceServer) PingStreamError ¶
func (*UnimplementedMultiServiceServer) PingStreamError(srv MultiService_PingStreamErrorServer) error
type UnimplementedTestServiceServer ¶
type UnimplementedTestServiceServer struct {
}
UnimplementedTestServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedTestServiceServer) Ping ¶
func (*UnimplementedTestServiceServer) Ping(ctx context.Context, req *PingRequest) (*PingResponse, error)
func (*UnimplementedTestServiceServer) PingEmpty ¶
func (*UnimplementedTestServiceServer) PingEmpty(ctx context.Context, req *Empty) (*PingResponse, error)
func (*UnimplementedTestServiceServer) PingError ¶
func (*UnimplementedTestServiceServer) PingError(ctx context.Context, req *PingRequest) (*Empty, error)
func (*UnimplementedTestServiceServer) PingList ¶
func (*UnimplementedTestServiceServer) PingList(req *PingRequest, srv TestService_PingListServer) error
func (*UnimplementedTestServiceServer) PingStream ¶
func (*UnimplementedTestServiceServer) PingStream(srv TestService_PingStreamServer) error