grpc: google.golang.org/grpc/interop/grpc_testing Index | Files

package grpc_testing

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

Index

Package Files

test.pb.go

Variables

var PayloadType_name = map[int32]string{
    0:  "COMPRESSABLE",
    1:  "UNCOMPRESSABLE",
    2:  "RANDOM",
}
var PayloadType_value = map[string]int32{
    "COMPRESSABLE":   0,
    "UNCOMPRESSABLE": 1,
    "RANDOM":         2,
}

func RegisterTestServiceServer Uses

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

func RegisterUnimplementedServiceServer Uses

func RegisterUnimplementedServiceServer(s *grpc.Server, srv UnimplementedServiceServer)

type EchoStatus Uses

type EchoStatus struct {
    Code                 int32    `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
    Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A protobuf representation for grpc status. This is used by test clients to specify a status that the server should attempt to return.

func (*EchoStatus) Descriptor Uses

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

func (*EchoStatus) GetCode Uses

func (m *EchoStatus) GetCode() int32

func (*EchoStatus) GetMessage Uses

func (m *EchoStatus) GetMessage() string

func (*EchoStatus) ProtoMessage Uses

func (*EchoStatus) ProtoMessage()

func (*EchoStatus) Reset Uses

func (m *EchoStatus) Reset()

func (*EchoStatus) String Uses

func (m *EchoStatus) String() string

func (*EchoStatus) XXX_DiscardUnknown Uses

func (m *EchoStatus) XXX_DiscardUnknown()

func (*EchoStatus) XXX_Marshal Uses

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

func (*EchoStatus) XXX_Merge Uses

func (dst *EchoStatus) XXX_Merge(src proto.Message)

func (*EchoStatus) XXX_Size Uses

func (m *EchoStatus) XXX_Size() int

func (*EchoStatus) XXX_Unmarshal Uses

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

type Empty Uses

type Empty struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor Uses

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

func (*Empty) ProtoMessage Uses

func (*Empty) ProtoMessage()

func (*Empty) Reset Uses

func (m *Empty) Reset()

func (*Empty) String Uses

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown Uses

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal Uses

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

func (*Empty) XXX_Merge Uses

func (dst *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size Uses

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal Uses

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

type Payload Uses

type Payload struct {
    // The type of data in body.
    Type PayloadType `protobuf:"varint,1,opt,name=type,proto3,enum=grpc.testing.PayloadType" json:"type,omitempty"`
    // Primary contents of payload.
    Body                 []byte   `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A block of data, to simply increase gRPC message size.

func (*Payload) Descriptor Uses

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

func (*Payload) GetBody Uses

func (m *Payload) GetBody() []byte

func (*Payload) GetType Uses

func (m *Payload) GetType() PayloadType

func (*Payload) ProtoMessage Uses

func (*Payload) ProtoMessage()

func (*Payload) Reset Uses

func (m *Payload) Reset()

func (*Payload) String Uses

func (m *Payload) String() string

func (*Payload) XXX_DiscardUnknown Uses

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal Uses

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

func (*Payload) XXX_Merge Uses

func (dst *Payload) XXX_Merge(src proto.Message)

func (*Payload) XXX_Size Uses

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal Uses

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

type PayloadType Uses

type PayloadType int32

The type of payload that should be returned.

const (
    // Compressable text format.
    PayloadType_COMPRESSABLE PayloadType = 0
    // Uncompressable binary format.
    PayloadType_UNCOMPRESSABLE PayloadType = 1
    // Randomly chosen from all other formats defined in this enum.
    PayloadType_RANDOM PayloadType = 2
)

func (PayloadType) EnumDescriptor Uses

func (PayloadType) EnumDescriptor() ([]byte, []int)

func (PayloadType) String Uses

func (x PayloadType) String() string

type ResponseParameters Uses

type ResponseParameters struct {
    // Desired payload sizes in responses from the server.
    // If response_type is COMPRESSABLE, this denotes the size before compression.
    Size int32 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
    // Desired interval between consecutive responses in the response stream in
    // microseconds.
    IntervalUs           int32    `protobuf:"varint,2,opt,name=interval_us,json=intervalUs,proto3" json:"interval_us,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Configuration for a particular response.

func (*ResponseParameters) Descriptor Uses

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

func (*ResponseParameters) GetIntervalUs Uses

func (m *ResponseParameters) GetIntervalUs() int32

func (*ResponseParameters) GetSize Uses

func (m *ResponseParameters) GetSize() int32

func (*ResponseParameters) ProtoMessage Uses

func (*ResponseParameters) ProtoMessage()

func (*ResponseParameters) Reset Uses

func (m *ResponseParameters) Reset()

func (*ResponseParameters) String Uses

func (m *ResponseParameters) String() string

func (*ResponseParameters) XXX_DiscardUnknown Uses

func (m *ResponseParameters) XXX_DiscardUnknown()

func (*ResponseParameters) XXX_Marshal Uses

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

func (*ResponseParameters) XXX_Merge Uses

func (dst *ResponseParameters) XXX_Merge(src proto.Message)

func (*ResponseParameters) XXX_Size Uses

func (m *ResponseParameters) XXX_Size() int

func (*ResponseParameters) XXX_Unmarshal Uses

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

type SimpleRequest Uses

type SimpleRequest struct {
    // Desired payload type in the response from the server.
    // If response_type is RANDOM, server randomly chooses one from other formats.
    ResponseType PayloadType `protobuf:"varint,1,opt,name=response_type,json=responseType,proto3,enum=grpc.testing.PayloadType" json:"response_type,omitempty"`
    // Desired payload size in the response from the server.
    // If response_type is COMPRESSABLE, this denotes the size before compression.
    ResponseSize int32 `protobuf:"varint,2,opt,name=response_size,json=responseSize,proto3" json:"response_size,omitempty"`
    // Optional input payload sent along with the request.
    Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
    // Whether SimpleResponse should include username.
    FillUsername bool `protobuf:"varint,4,opt,name=fill_username,json=fillUsername,proto3" json:"fill_username,omitempty"`
    // Whether SimpleResponse should include OAuth scope.
    FillOauthScope bool `protobuf:"varint,5,opt,name=fill_oauth_scope,json=fillOauthScope,proto3" json:"fill_oauth_scope,omitempty"`
    // Whether server should return a given status
    ResponseStatus       *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

Unary request.

func (*SimpleRequest) Descriptor Uses

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

func (*SimpleRequest) GetFillOauthScope Uses

func (m *SimpleRequest) GetFillOauthScope() bool

func (*SimpleRequest) GetFillUsername Uses

func (m *SimpleRequest) GetFillUsername() bool

func (*SimpleRequest) GetPayload Uses

func (m *SimpleRequest) GetPayload() *Payload

func (*SimpleRequest) GetResponseSize Uses

func (m *SimpleRequest) GetResponseSize() int32

func (*SimpleRequest) GetResponseStatus Uses

func (m *SimpleRequest) GetResponseStatus() *EchoStatus

func (*SimpleRequest) GetResponseType Uses

func (m *SimpleRequest) GetResponseType() PayloadType

func (*SimpleRequest) ProtoMessage Uses

func (*SimpleRequest) ProtoMessage()

func (*SimpleRequest) Reset Uses

func (m *SimpleRequest) Reset()

func (*SimpleRequest) String Uses

func (m *SimpleRequest) String() string

func (*SimpleRequest) XXX_DiscardUnknown Uses

func (m *SimpleRequest) XXX_DiscardUnknown()

func (*SimpleRequest) XXX_Marshal Uses

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

func (*SimpleRequest) XXX_Merge Uses

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

func (*SimpleRequest) XXX_Size Uses

func (m *SimpleRequest) XXX_Size() int

func (*SimpleRequest) XXX_Unmarshal Uses

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

type SimpleResponse Uses

type SimpleResponse struct {
    // Payload to increase message size.
    Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
    // The user the request came from, for verifying authentication was
    // successful when the client expected it.
    Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
    // OAuth scope.
    OauthScope           string   `protobuf:"bytes,3,opt,name=oauth_scope,json=oauthScope,proto3" json:"oauth_scope,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Unary response, as configured by the request.

func (*SimpleResponse) Descriptor Uses

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

func (*SimpleResponse) GetOauthScope Uses

func (m *SimpleResponse) GetOauthScope() string

func (*SimpleResponse) GetPayload Uses

func (m *SimpleResponse) GetPayload() *Payload

func (*SimpleResponse) GetUsername Uses

func (m *SimpleResponse) GetUsername() string

func (*SimpleResponse) ProtoMessage Uses

func (*SimpleResponse) ProtoMessage()

func (*SimpleResponse) Reset Uses

func (m *SimpleResponse) Reset()

func (*SimpleResponse) String Uses

func (m *SimpleResponse) String() string

func (*SimpleResponse) XXX_DiscardUnknown Uses

func (m *SimpleResponse) XXX_DiscardUnknown()

func (*SimpleResponse) XXX_Marshal Uses

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

func (*SimpleResponse) XXX_Merge Uses

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

func (*SimpleResponse) XXX_Size Uses

func (m *SimpleResponse) XXX_Size() int

func (*SimpleResponse) XXX_Unmarshal Uses

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

type StreamingInputCallRequest Uses

type StreamingInputCallRequest struct {
    // Optional input payload sent along with the request.
    Payload              *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Client-streaming request.

func (*StreamingInputCallRequest) Descriptor Uses

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

func (*StreamingInputCallRequest) GetPayload Uses

func (m *StreamingInputCallRequest) GetPayload() *Payload

func (*StreamingInputCallRequest) ProtoMessage Uses

func (*StreamingInputCallRequest) ProtoMessage()

func (*StreamingInputCallRequest) Reset Uses

func (m *StreamingInputCallRequest) Reset()

func (*StreamingInputCallRequest) String Uses

func (m *StreamingInputCallRequest) String() string

func (*StreamingInputCallRequest) XXX_DiscardUnknown Uses

func (m *StreamingInputCallRequest) XXX_DiscardUnknown()

func (*StreamingInputCallRequest) XXX_Marshal Uses

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

func (*StreamingInputCallRequest) XXX_Merge Uses

func (dst *StreamingInputCallRequest) XXX_Merge(src proto.Message)

func (*StreamingInputCallRequest) XXX_Size Uses

func (m *StreamingInputCallRequest) XXX_Size() int

func (*StreamingInputCallRequest) XXX_Unmarshal Uses

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

type StreamingInputCallResponse Uses

type StreamingInputCallResponse struct {
    // Aggregated size of payloads received from the client.
    AggregatedPayloadSize int32    `protobuf:"varint,1,opt,name=aggregated_payload_size,json=aggregatedPayloadSize,proto3" json:"aggregated_payload_size,omitempty"`
    XXX_NoUnkeyedLiteral  struct{} `json:"-"`
    XXX_unrecognized      []byte   `json:"-"`
    XXX_sizecache         int32    `json:"-"`
}

Client-streaming response.

func (*StreamingInputCallResponse) Descriptor Uses

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

func (*StreamingInputCallResponse) GetAggregatedPayloadSize Uses

func (m *StreamingInputCallResponse) GetAggregatedPayloadSize() int32

func (*StreamingInputCallResponse) ProtoMessage Uses

func (*StreamingInputCallResponse) ProtoMessage()

func (*StreamingInputCallResponse) Reset Uses

func (m *StreamingInputCallResponse) Reset()

func (*StreamingInputCallResponse) String Uses

func (m *StreamingInputCallResponse) String() string

func (*StreamingInputCallResponse) XXX_DiscardUnknown Uses

func (m *StreamingInputCallResponse) XXX_DiscardUnknown()

func (*StreamingInputCallResponse) XXX_Marshal Uses

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

func (*StreamingInputCallResponse) XXX_Merge Uses

func (dst *StreamingInputCallResponse) XXX_Merge(src proto.Message)

func (*StreamingInputCallResponse) XXX_Size Uses

func (m *StreamingInputCallResponse) XXX_Size() int

func (*StreamingInputCallResponse) XXX_Unmarshal Uses

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

type StreamingOutputCallRequest Uses

type StreamingOutputCallRequest struct {
    // Desired payload type in the response from the server.
    // If response_type is RANDOM, the payload from each response in the stream
    // might be of different types. This is to simulate a mixed type of payload
    // stream.
    ResponseType PayloadType `protobuf:"varint,1,opt,name=response_type,json=responseType,proto3,enum=grpc.testing.PayloadType" json:"response_type,omitempty"`
    // Configuration for each expected response message.
    ResponseParameters []*ResponseParameters `protobuf:"bytes,2,rep,name=response_parameters,json=responseParameters,proto3" json:"response_parameters,omitempty"`
    // Optional input payload sent along with the request.
    Payload *Payload `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
    // Whether server should return a given status
    ResponseStatus       *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

Server-streaming request.

func (*StreamingOutputCallRequest) Descriptor Uses

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

func (*StreamingOutputCallRequest) GetPayload Uses

func (m *StreamingOutputCallRequest) GetPayload() *Payload

func (*StreamingOutputCallRequest) GetResponseParameters Uses

func (m *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters

func (*StreamingOutputCallRequest) GetResponseStatus Uses

func (m *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus

func (*StreamingOutputCallRequest) GetResponseType Uses

func (m *StreamingOutputCallRequest) GetResponseType() PayloadType

func (*StreamingOutputCallRequest) ProtoMessage Uses

func (*StreamingOutputCallRequest) ProtoMessage()

func (*StreamingOutputCallRequest) Reset Uses

func (m *StreamingOutputCallRequest) Reset()

func (*StreamingOutputCallRequest) String Uses

func (m *StreamingOutputCallRequest) String() string

func (*StreamingOutputCallRequest) XXX_DiscardUnknown Uses

func (m *StreamingOutputCallRequest) XXX_DiscardUnknown()

func (*StreamingOutputCallRequest) XXX_Marshal Uses

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

func (*StreamingOutputCallRequest) XXX_Merge Uses

func (dst *StreamingOutputCallRequest) XXX_Merge(src proto.Message)

func (*StreamingOutputCallRequest) XXX_Size Uses

func (m *StreamingOutputCallRequest) XXX_Size() int

func (*StreamingOutputCallRequest) XXX_Unmarshal Uses

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

type StreamingOutputCallResponse Uses

type StreamingOutputCallResponse struct {
    // Payload to increase response size.
    Payload              *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Server-streaming response, as configured by the request and parameters.

func (*StreamingOutputCallResponse) Descriptor Uses

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

func (*StreamingOutputCallResponse) GetPayload Uses

func (m *StreamingOutputCallResponse) GetPayload() *Payload

func (*StreamingOutputCallResponse) ProtoMessage Uses

func (*StreamingOutputCallResponse) ProtoMessage()

func (*StreamingOutputCallResponse) Reset Uses

func (m *StreamingOutputCallResponse) Reset()

func (*StreamingOutputCallResponse) String Uses

func (m *StreamingOutputCallResponse) String() string

func (*StreamingOutputCallResponse) XXX_DiscardUnknown Uses

func (m *StreamingOutputCallResponse) XXX_DiscardUnknown()

func (*StreamingOutputCallResponse) XXX_Marshal Uses

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

func (*StreamingOutputCallResponse) XXX_Merge Uses

func (dst *StreamingOutputCallResponse) XXX_Merge(src proto.Message)

func (*StreamingOutputCallResponse) XXX_Size Uses

func (m *StreamingOutputCallResponse) XXX_Size() int

func (*StreamingOutputCallResponse) XXX_Unmarshal Uses

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

type TestServiceClient Uses

type TestServiceClient interface {
    // One empty request followed by one empty response.
    EmptyCall(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
    // One request followed by one response.
    // The server returns the client payload as-is.
    UnaryCall(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error)
    // One request followed by a sequence of responses (streamed download).
    // The server returns the payload with client desired type and sizes.
    StreamingOutputCall(ctx context.Context, in *StreamingOutputCallRequest, opts ...grpc.CallOption) (TestService_StreamingOutputCallClient, error)
    // A sequence of requests followed by one response (streamed upload).
    // The server returns the aggregated size of client payload as the result.
    StreamingInputCall(ctx context.Context, opts ...grpc.CallOption) (TestService_StreamingInputCallClient, 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)
    // A sequence of requests followed by a sequence of responses.
    // The server buffers all the client requests and then serves them in order. A
    // stream of responses are returned to the client when the server starts with
    // first request.
    HalfDuplexCall(ctx context.Context, opts ...grpc.CallOption) (TestService_HalfDuplexCallClient, 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 Uses

func NewTestServiceClient(cc *grpc.ClientConn) TestServiceClient

type TestServiceServer Uses

type TestServiceServer interface {
    // One empty request followed by one empty response.
    EmptyCall(context.Context, *Empty) (*Empty, error)
    // One request followed by one response.
    // The server returns the client payload as-is.
    UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
    // One request followed by a sequence of responses (streamed download).
    // The server returns the payload with client desired type and sizes.
    StreamingOutputCall(*StreamingOutputCallRequest, TestService_StreamingOutputCallServer) error
    // A sequence of requests followed by one response (streamed upload).
    // The server returns the aggregated size of client payload as the result.
    StreamingInputCall(TestService_StreamingInputCallServer) 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
    // A sequence of requests followed by a sequence of responses.
    // The server buffers all the client requests and then serves them in order. A
    // stream of responses are returned to the client when the server starts with
    // first request.
    HalfDuplexCall(TestService_HalfDuplexCallServer) error
}

TestServiceServer is the server API for TestService service.

type TestService_FullDuplexCallClient Uses

type TestService_FullDuplexCallClient interface {
    Send(*StreamingOutputCallRequest) error
    Recv() (*StreamingOutputCallResponse, error)
    grpc.ClientStream
}

type TestService_FullDuplexCallServer Uses

type TestService_FullDuplexCallServer interface {
    Send(*StreamingOutputCallResponse) error
    Recv() (*StreamingOutputCallRequest, error)
    grpc.ServerStream
}

type TestService_HalfDuplexCallClient Uses

type TestService_HalfDuplexCallClient interface {
    Send(*StreamingOutputCallRequest) error
    Recv() (*StreamingOutputCallResponse, error)
    grpc.ClientStream
}

type TestService_HalfDuplexCallServer Uses

type TestService_HalfDuplexCallServer interface {
    Send(*StreamingOutputCallResponse) error
    Recv() (*StreamingOutputCallRequest, error)
    grpc.ServerStream
}

type TestService_StreamingInputCallClient Uses

type TestService_StreamingInputCallClient interface {
    Send(*StreamingInputCallRequest) error
    CloseAndRecv() (*StreamingInputCallResponse, error)
    grpc.ClientStream
}

type TestService_StreamingInputCallServer Uses

type TestService_StreamingInputCallServer interface {
    SendAndClose(*StreamingInputCallResponse) error
    Recv() (*StreamingInputCallRequest, error)
    grpc.ServerStream
}

type TestService_StreamingOutputCallClient Uses

type TestService_StreamingOutputCallClient interface {
    Recv() (*StreamingOutputCallResponse, error)
    grpc.ClientStream
}

type TestService_StreamingOutputCallServer Uses

type TestService_StreamingOutputCallServer interface {
    Send(*StreamingOutputCallResponse) error
    grpc.ServerStream
}

type UnimplementedServiceClient Uses

type UnimplementedServiceClient interface {
    // A call that no server should implement
    UnimplementedCall(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
}

UnimplementedServiceClient is the client API for UnimplementedService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewUnimplementedServiceClient Uses

func NewUnimplementedServiceClient(cc *grpc.ClientConn) UnimplementedServiceClient

type UnimplementedServiceServer Uses

type UnimplementedServiceServer interface {
    // A call that no server should implement
    UnimplementedCall(context.Context, *Empty) (*Empty, error)
}

UnimplementedServiceServer is the server API for UnimplementedService service.

Package grpc_testing imports 5 packages (graph) and is imported by 100 packages. Updated 2018-06-10. Refresh now. Tools for package owners.