func RegisterFooServer(s *grpc.Server, srv FooServer)
type FooClient interface {
Single(ctx context.Context, in *FooRequest, opts ...grpc.CallOption) (*FooResponse, error)
Multiple(ctx context.Context, opts ...grpc.CallOption) (Foo_MultipleClient, error)
}
func NewFooClient(cc *grpc.ClientConn) FooClient
func NewTestClient(l *testing.T) (client FooClient, cleanup func())
NewTestClient returns a new TestClient.
type FooRequest struct {
Fail bool `protobuf:"varint,1,opt,name=fail" json:"fail,omitempty"`
SleepNanos int64 `protobuf:"varint,2,opt,name=sleep_nanos,json=sleepNanos" json:"sleep_nanos,omitempty"`
}
func (*FooRequest) Descriptor() ([]byte, []int)
func (m *FooRequest) GetFail() bool
func (m *FooRequest) GetSleepNanos() int64
func (*FooRequest) ProtoMessage()
func (m *FooRequest) Reset()
func (m *FooRequest) String() string
type FooResponse struct {
}
func (*FooResponse) Descriptor() ([]byte, []int)
func (*FooResponse) ProtoMessage()
func (m *FooResponse) Reset()
func (m *FooResponse) String() string
type FooServer interface {
Single(context.Context, *FooRequest) (*FooResponse, error)
Multiple(Foo_MultipleServer) error
}
type Foo_MultipleClient interface {
Send(*FooRequest) error
Recv() (*FooResponse, error)
grpc.ClientStream
}
type Foo_MultipleServer interface {
Send(*FooResponse) error
Recv() (*FooRequest, error)
grpc.ServerStream
}