package grpc_testing

import "google.golang.org/grpc/stats/grpc_testing"

Index ¶

• func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer)
• type SimpleRequest
• func (*SimpleRequest) Descriptor() ([]byte, []int)
• func (m *SimpleRequest) GetId() int32
• func (*SimpleRequest) ProtoMessage()
• func (m *SimpleRequest) Reset()
• func (m *SimpleRequest) String() string
• func (m *SimpleRequest) XXX_DiscardUnknown()
• func (m *SimpleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
• func (m *SimpleRequest) XXX_Merge(src proto.Message)
• func (m *SimpleRequest) XXX_Size() int
• func (m *SimpleRequest) XXX_Unmarshal(b []byte) error
• type SimpleResponse
• func (*SimpleResponse) Descriptor() ([]byte, []int)
• func (m *SimpleResponse) GetId() int32
• func (*SimpleResponse) ProtoMessage()
• func (m *SimpleResponse) Reset()
• func (m *SimpleResponse) String() string
• func (m *SimpleResponse) XXX_DiscardUnknown()
• func (m *SimpleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
• func (m *SimpleResponse) XXX_Merge(src proto.Message)
• func (m *SimpleResponse) XXX_Size() int
• func (m *SimpleResponse) XXX_Unmarshal(b []byte) error
• type TestServiceClient
• func NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient
• type TestServiceServer
• type TestService_ClientStreamCallClient
• type TestService_ClientStreamCallServer
• type TestService_FullDuplexCallClient
• type TestService_FullDuplexCallServer
• type TestService_ServerStreamCallClient
• type TestService_ServerStreamCallServer
• type UnimplementedTestServiceServer
• func (UnimplementedTestServiceServer) ClientStreamCall(TestService_ClientStreamCallServer) error
• func (UnimplementedTestServiceServer) FullDuplexCall(TestService_FullDuplexCallServer) error
• func (UnimplementedTestServiceServer) ServerStreamCall(*SimpleRequest, TestService_ServerStreamCallServer) error
• func (UnimplementedTestServiceServer) UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
• type UnsafeTestServiceServer

Functions ¶

func RegisterTestServiceServer ¶

func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer)

Types ¶

type SimpleRequest ¶

type SimpleRequest struct {
	Id                   int32    `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SimpleRequest) Descriptor ¶

func (*SimpleRequest) Descriptor() ([]byte, []int)

func (*SimpleRequest) GetId ¶

func (m *SimpleRequest) GetId() int32

func (*SimpleRequest) ProtoMessage ¶

func (*SimpleRequest) ProtoMessage()

func (*SimpleRequest) Reset ¶

func (m *SimpleRequest) Reset()

func (*SimpleRequest) String ¶

func (m *SimpleRequest) String() string

func (*SimpleRequest) XXX_DiscardUnknown ¶

func (m *SimpleRequest) XXX_DiscardUnknown()

func (*SimpleRequest) XXX_Marshal ¶

func (m *SimpleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SimpleRequest) XXX_Merge ¶

func (m *SimpleRequest) XXX_Merge(src proto.Message)

func (*SimpleRequest) XXX_Size ¶

func (m *SimpleRequest) XXX_Size() int

func (*SimpleRequest) XXX_Unmarshal ¶

func (m *SimpleRequest) XXX_Unmarshal(b []byte) error

type SimpleResponse ¶

type SimpleResponse struct {
	Id                   int32    `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SimpleResponse) Descriptor ¶

func (*SimpleResponse) Descriptor() ([]byte, []int)

func (*SimpleResponse) GetId ¶

func (m *SimpleResponse) GetId() int32

func (*SimpleResponse) ProtoMessage ¶

func (*SimpleResponse) ProtoMessage()

func (*SimpleResponse) Reset ¶

func (m *SimpleResponse) Reset()

func (*SimpleResponse) String ¶

func (m *SimpleResponse) String() string

func (*SimpleResponse) XXX_DiscardUnknown ¶

func (m *SimpleResponse) XXX_DiscardUnknown()

func (*SimpleResponse) XXX_Marshal ¶

func (m *SimpleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SimpleResponse) XXX_Merge ¶

func (m *SimpleResponse) XXX_Merge(src proto.Message)

func (*SimpleResponse) XXX_Size ¶

func (m *SimpleResponse) XXX_Size() int

func (*SimpleResponse) XXX_Unmarshal ¶

func (m *SimpleResponse) XXX_Unmarshal(b []byte) error

type TestServiceClient ¶

type TestServiceClient interface {
	// One request followed by one response.
	// The server returns the client id as-is.
	UnaryCall(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error)
	// A sequence of requests with each request served by the server immediately.
	// As one request could lead to multiple responses, this interface
	// demonstrates the idea of full duplexing.
	FullDuplexCall(ctx context.Context, opts ...grpc.CallOption) (TestService_FullDuplexCallClient, error)
	// Client stream
	ClientStreamCall(ctx context.Context, opts ...grpc.CallOption) (TestService_ClientStreamCallClient, error)
	// Server stream
	ServerStreamCall(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (TestService_ServerStreamCallClient, 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 {
	// One request followed by one response.
	// The server returns the client id as-is.
	UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
	// A sequence of requests with each request served by the server immediately.
	// As one request could lead to multiple responses, this interface
	// demonstrates the idea of full duplexing.
	FullDuplexCall(TestService_FullDuplexCallServer) error
	// Client stream
	ClientStreamCall(TestService_ClientStreamCallServer) error
	// Server stream
	ServerStreamCall(*SimpleRequest, TestService_ServerStreamCallServer) error
	// contains filtered or unexported methods
}

TestServiceServer is the server API for TestService service. All implementations must embed UnimplementedTestServiceServer for forward compatibility

type TestService_ClientStreamCallClient ¶

type TestService_ClientStreamCallClient interface {
	Send(*SimpleRequest) error
	CloseAndRecv() (*SimpleResponse, error)
	grpc.ClientStream
}

type TestService_ClientStreamCallServer ¶

type TestService_ClientStreamCallServer interface {
	SendAndClose(*SimpleResponse) error
	Recv() (*SimpleRequest, error)
	grpc.ServerStream
}

type TestService_FullDuplexCallClient ¶

type TestService_FullDuplexCallClient interface {
	Send(*SimpleRequest) error
	Recv() (*SimpleResponse, error)
	grpc.ClientStream
}

type TestService_FullDuplexCallServer ¶

type TestService_FullDuplexCallServer interface {
	Send(*SimpleResponse) error
	Recv() (*SimpleRequest, error)
	grpc.ServerStream
}

type TestService_ServerStreamCallClient ¶

type TestService_ServerStreamCallClient interface {
	Recv() (*SimpleResponse, error)
	grpc.ClientStream
}

type TestService_ServerStreamCallServer ¶

type TestService_ServerStreamCallServer interface {
	Send(*SimpleResponse) error
	grpc.ServerStream
}

type UnimplementedTestServiceServer ¶

type UnimplementedTestServiceServer struct {
}

UnimplementedTestServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTestServiceServer) ClientStreamCall ¶

func (UnimplementedTestServiceServer) ClientStreamCall(TestService_ClientStreamCallServer) error

func (UnimplementedTestServiceServer) FullDuplexCall ¶

func (UnimplementedTestServiceServer) FullDuplexCall(TestService_FullDuplexCallServer) error

func (UnimplementedTestServiceServer) ServerStreamCall ¶

func (UnimplementedTestServiceServer) ServerStreamCall(*SimpleRequest, TestService_ServerStreamCallServer) error

func (UnimplementedTestServiceServer) UnaryCall ¶

func (UnimplementedTestServiceServer) UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)

type UnsafeTestServiceServer ¶

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.

Source Files ¶

test.pb.go test_grpc.pb.go