Documentation

Overview

    Package grpc_testing is a generated protocol buffer package.

    It is generated from these files:

    grpc_testing/test.proto
    

    It has these top-level messages:

    Empty
    Payload
    EchoStatus
    SimpleRequest
    SimpleResponse
    StreamingInputCallRequest
    StreamingInputCallResponse
    ResponseParameters
    StreamingOutputCallRequest
    StreamingOutputCallResponse
    

    Index

    Constants

    This section is empty.

    Variables

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

    Functions

    func RegisterTestServiceServer

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

    func RegisterUnimplementedServiceServer

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

    Types

    type EchoStatus

    type EchoStatus struct {
    	Code    int32  `protobuf:"varint,1,opt,name=code" json:"code,omitempty"`
    	Message string `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
    }

      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

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

      func (*EchoStatus) GetCode

      func (m *EchoStatus) GetCode() int32

      func (*EchoStatus) GetMessage

      func (m *EchoStatus) GetMessage() string

      func (*EchoStatus) ProtoMessage

      func (*EchoStatus) ProtoMessage()

      func (*EchoStatus) Reset

      func (m *EchoStatus) Reset()

      func (*EchoStatus) String

      func (m *EchoStatus) String() string

      type Empty

      type Empty struct {
      }

      func (*Empty) Descriptor

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

      func (*Empty) ProtoMessage

      func (*Empty) ProtoMessage()

      func (*Empty) Reset

      func (m *Empty) Reset()

      func (*Empty) String

      func (m *Empty) String() string

      type Payload

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

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

        func (*Payload) Descriptor

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

        func (*Payload) GetBody

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

        func (*Payload) GetType

        func (m *Payload) GetType() PayloadType

        func (*Payload) ProtoMessage

        func (*Payload) ProtoMessage()

        func (*Payload) Reset

        func (m *Payload) Reset()

        func (*Payload) String

        func (m *Payload) String() string

        type PayloadType

        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

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

          func (PayloadType) String

          func (x PayloadType) String() string

          type ResponseParameters

          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" 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" json:"interval_us,omitempty"`
          }

            Configuration for a particular response.

            func (*ResponseParameters) Descriptor

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

            func (*ResponseParameters) GetIntervalUs

            func (m *ResponseParameters) GetIntervalUs() int32

            func (*ResponseParameters) GetSize

            func (m *ResponseParameters) GetSize() int32

            func (*ResponseParameters) ProtoMessage

            func (*ResponseParameters) ProtoMessage()

            func (*ResponseParameters) Reset

            func (m *ResponseParameters) Reset()

            func (*ResponseParameters) String

            func (m *ResponseParameters) String() string

            type SimpleRequest

            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,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" json:"response_size,omitempty"`
            	// Optional input payload sent along with the request.
            	Payload *Payload `protobuf:"bytes,3,opt,name=payload" json:"payload,omitempty"`
            	// Whether SimpleResponse should include username.
            	FillUsername bool `protobuf:"varint,4,opt,name=fill_username,json=fillUsername" json:"fill_username,omitempty"`
            	// Whether SimpleResponse should include OAuth scope.
            	FillOauthScope bool `protobuf:"varint,5,opt,name=fill_oauth_scope,json=fillOauthScope" json:"fill_oauth_scope,omitempty"`
            	// Whether server should return a given status
            	ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus" json:"response_status,omitempty"`
            }

              Unary request.

              func (*SimpleRequest) Descriptor

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

              func (*SimpleRequest) GetFillOauthScope

              func (m *SimpleRequest) GetFillOauthScope() bool

              func (*SimpleRequest) GetFillUsername

              func (m *SimpleRequest) GetFillUsername() bool

              func (*SimpleRequest) GetPayload

              func (m *SimpleRequest) GetPayload() *Payload

              func (*SimpleRequest) GetResponseSize

              func (m *SimpleRequest) GetResponseSize() int32

              func (*SimpleRequest) GetResponseStatus

              func (m *SimpleRequest) GetResponseStatus() *EchoStatus

              func (*SimpleRequest) GetResponseType

              func (m *SimpleRequest) GetResponseType() PayloadType

              func (*SimpleRequest) ProtoMessage

              func (*SimpleRequest) ProtoMessage()

              func (*SimpleRequest) Reset

              func (m *SimpleRequest) Reset()

              func (*SimpleRequest) String

              func (m *SimpleRequest) String() string

              type SimpleResponse

              type SimpleResponse struct {
              	// Payload to increase message size.
              	Payload *Payload `protobuf:"bytes,1,opt,name=payload" 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" json:"username,omitempty"`
              	// OAuth scope.
              	OauthScope string `protobuf:"bytes,3,opt,name=oauth_scope,json=oauthScope" json:"oauth_scope,omitempty"`
              }

                Unary response, as configured by the request.

                func (*SimpleResponse) Descriptor

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

                func (*SimpleResponse) GetOauthScope

                func (m *SimpleResponse) GetOauthScope() string

                func (*SimpleResponse) GetPayload

                func (m *SimpleResponse) GetPayload() *Payload

                func (*SimpleResponse) GetUsername

                func (m *SimpleResponse) GetUsername() string

                func (*SimpleResponse) ProtoMessage

                func (*SimpleResponse) ProtoMessage()

                func (*SimpleResponse) Reset

                func (m *SimpleResponse) Reset()

                func (*SimpleResponse) String

                func (m *SimpleResponse) String() string

                type StreamingInputCallRequest

                type StreamingInputCallRequest struct {
                	// Optional input payload sent along with the request.
                	Payload *Payload `protobuf:"bytes,1,opt,name=payload" json:"payload,omitempty"`
                }

                  Client-streaming request.

                  func (*StreamingInputCallRequest) Descriptor

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

                  func (*StreamingInputCallRequest) GetPayload

                  func (m *StreamingInputCallRequest) GetPayload() *Payload

                  func (*StreamingInputCallRequest) ProtoMessage

                  func (*StreamingInputCallRequest) ProtoMessage()

                  func (*StreamingInputCallRequest) Reset

                  func (m *StreamingInputCallRequest) Reset()

                  func (*StreamingInputCallRequest) String

                  func (m *StreamingInputCallRequest) String() string

                  type StreamingInputCallResponse

                  type StreamingInputCallResponse struct {
                  	// Aggregated size of payloads received from the client.
                  	AggregatedPayloadSize int32 `protobuf:"varint,1,opt,name=aggregated_payload_size,json=aggregatedPayloadSize" json:"aggregated_payload_size,omitempty"`
                  }

                    Client-streaming response.

                    func (*StreamingInputCallResponse) Descriptor

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

                    func (*StreamingInputCallResponse) GetAggregatedPayloadSize

                    func (m *StreamingInputCallResponse) GetAggregatedPayloadSize() int32

                    func (*StreamingInputCallResponse) ProtoMessage

                    func (*StreamingInputCallResponse) ProtoMessage()

                    func (*StreamingInputCallResponse) Reset

                    func (m *StreamingInputCallResponse) Reset()

                    func (*StreamingInputCallResponse) String

                    func (m *StreamingInputCallResponse) String() string

                    type StreamingOutputCallRequest

                    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,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" json:"response_parameters,omitempty"`
                    	// Optional input payload sent along with the request.
                    	Payload *Payload `protobuf:"bytes,3,opt,name=payload" json:"payload,omitempty"`
                    	// Whether server should return a given status
                    	ResponseStatus *EchoStatus `protobuf:"bytes,7,opt,name=response_status,json=responseStatus" json:"response_status,omitempty"`
                    }

                      Server-streaming request.

                      func (*StreamingOutputCallRequest) Descriptor

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

                      func (*StreamingOutputCallRequest) GetPayload

                      func (m *StreamingOutputCallRequest) GetPayload() *Payload

                      func (*StreamingOutputCallRequest) GetResponseParameters

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

                      func (*StreamingOutputCallRequest) GetResponseStatus

                      func (m *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus

                      func (*StreamingOutputCallRequest) GetResponseType

                      func (m *StreamingOutputCallRequest) GetResponseType() PayloadType

                      func (*StreamingOutputCallRequest) ProtoMessage

                      func (*StreamingOutputCallRequest) ProtoMessage()

                      func (*StreamingOutputCallRequest) Reset

                      func (m *StreamingOutputCallRequest) Reset()

                      func (*StreamingOutputCallRequest) String

                      func (m *StreamingOutputCallRequest) String() string

                      type StreamingOutputCallResponse

                      type StreamingOutputCallResponse struct {
                      	// Payload to increase response size.
                      	Payload *Payload `protobuf:"bytes,1,opt,name=payload" json:"payload,omitempty"`
                      }

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

                        func (*StreamingOutputCallResponse) Descriptor

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

                        func (*StreamingOutputCallResponse) GetPayload

                        func (m *StreamingOutputCallResponse) GetPayload() *Payload

                        func (*StreamingOutputCallResponse) ProtoMessage

                        func (*StreamingOutputCallResponse) ProtoMessage()

                        func (*StreamingOutputCallResponse) Reset

                        func (m *StreamingOutputCallResponse) Reset()

                        func (*StreamingOutputCallResponse) String

                        func (m *StreamingOutputCallResponse) String() string

                        type TestServiceClient

                        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)
                        }

                        func NewTestServiceClient

                        func NewTestServiceClient(cc *grpc.ClientConn) TestServiceClient

                        type TestServiceServer

                        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
                        }

                        type TestService_FullDuplexCallClient

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

                        type TestService_FullDuplexCallServer

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

                        type TestService_HalfDuplexCallClient

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

                        type TestService_HalfDuplexCallServer

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

                        type TestService_StreamingInputCallClient

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

                        type TestService_StreamingInputCallServer

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

                        type TestService_StreamingOutputCallClient

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

                        type TestService_StreamingOutputCallServer

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

                        type UnimplementedServiceClient

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

                        func NewUnimplementedServiceClient

                        func NewUnimplementedServiceClient(cc *grpc.ClientConn) UnimplementedServiceClient

                        type UnimplementedServiceServer

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

                        Source Files