Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

grpctest

package

Go to main page

Versions in this module

v0

v0.1.1

Aug 10, 2023

v0.1.0

Aug 6, 2023

v0.0.1

Jul 21, 2023

Changes in this version

+ const MetadataFailEarly

+ const MetadataFailLate

+ const MetadataReplyHeaders

+ var File_test_proto protoreflect.FileDescriptor

+ var PayloadType_name = map[int32]string

+ var PayloadType_value = map[string]int32

+ func RegisterTestServiceService(srv *ttrpc.Server, svc TestServiceService)

+ func RegisterUnimplementedServiceService(srv *ttrpc.Server, svc UnimplementedServiceService)

+ func Run() error

+ func ScriptMain() int

+ type EchoStatus struct

+ Code int32

+ Message string

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

+ func (*EchoStatus) ProtoMessage()

+ func (x *EchoStatus) GetCode() int32

+ func (x *EchoStatus) GetMessage() string

+ func (x *EchoStatus) ProtoReflect() protoreflect.Message

+ func (x *EchoStatus) Reset()

+ func (x *EchoStatus) String() string

+ type Empty struct

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

+ func (*Empty) ProtoMessage()

+ func (x *Empty) ProtoReflect() protoreflect.Message

+ func (x *Empty) Reset()

+ func (x *Empty) String() string

+ type Payload struct

+ Body []byte

+ Type PayloadType

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

+ func (*Payload) ProtoMessage()

+ func (x *Payload) GetBody() []byte

+ func (x *Payload) GetType() PayloadType

+ func (x *Payload) ProtoReflect() protoreflect.Message

+ func (x *Payload) Reset()

+ func (x *Payload) String() string

+ type PayloadType int32

+ const PayloadType_COMPRESSABLE

+ const PayloadType_RANDOM

+ const PayloadType_UNCOMPRESSABLE

+ func (PayloadType) Descriptor() protoreflect.EnumDescriptor

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

+ func (PayloadType) Type() protoreflect.EnumType

+ func (x PayloadType) Enum() *PayloadType

+ func (x PayloadType) Number() protoreflect.EnumNumber

+ func (x PayloadType) String() string

+ type ResponseParameters struct

+ IntervalUs int32

+ Size int32

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

+ func (*ResponseParameters) ProtoMessage()

+ func (x *ResponseParameters) GetIntervalUs() int32

+ func (x *ResponseParameters) GetSize() int32

+ func (x *ResponseParameters) ProtoReflect() protoreflect.Message

+ func (x *ResponseParameters) Reset()

+ func (x *ResponseParameters) String() string

+ type SimpleRequest struct

+ FillOauthScope bool

+ FillUsername bool

+ Payload *Payload

+ ResponseSize int32

+ ResponseStatus *EchoStatus

+ ResponseType PayloadType

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

+ func (*SimpleRequest) ProtoMessage()

+ func (x *SimpleRequest) GetFillOauthScope() bool

+ func (x *SimpleRequest) GetFillUsername() bool

+ func (x *SimpleRequest) GetPayload() *Payload

+ func (x *SimpleRequest) GetResponseSize() int32

+ func (x *SimpleRequest) GetResponseStatus() *EchoStatus

+ func (x *SimpleRequest) GetResponseType() PayloadType

+ func (x *SimpleRequest) ProtoReflect() protoreflect.Message

+ func (x *SimpleRequest) Reset()

+ func (x *SimpleRequest) String() string

+ type SimpleResponse struct

+ OauthScope string

+ Payload *Payload

+ Username string

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

+ func (*SimpleResponse) ProtoMessage()

+ func (x *SimpleResponse) GetOauthScope() string

+ func (x *SimpleResponse) GetPayload() *Payload

+ func (x *SimpleResponse) GetUsername() string

+ func (x *SimpleResponse) ProtoReflect() protoreflect.Message

+ func (x *SimpleResponse) Reset()

+ func (x *SimpleResponse) String() string

+ type StreamingInputCallRequest struct

+ Payload *Payload

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

+ func (*StreamingInputCallRequest) ProtoMessage()

+ func (x *StreamingInputCallRequest) GetPayload() *Payload

+ func (x *StreamingInputCallRequest) ProtoReflect() protoreflect.Message

+ func (x *StreamingInputCallRequest) Reset()

+ func (x *StreamingInputCallRequest) String() string

+ type StreamingInputCallResponse struct

+ AggregatedPayloadSize int32

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

+ func (*StreamingInputCallResponse) ProtoMessage()

+ func (x *StreamingInputCallResponse) GetAggregatedPayloadSize() int32

+ func (x *StreamingInputCallResponse) ProtoReflect() protoreflect.Message

+ func (x *StreamingInputCallResponse) Reset()

+ func (x *StreamingInputCallResponse) String() string

+ type StreamingOutputCallRequest struct

+ Payload *Payload

+ ResponseParameters []*ResponseParameters

+ ResponseStatus *EchoStatus

+ ResponseType PayloadType

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

+ func (*StreamingOutputCallRequest) ProtoMessage()

+ func (x *StreamingOutputCallRequest) GetPayload() *Payload

+ func (x *StreamingOutputCallRequest) GetResponseParameters() []*ResponseParameters

+ func (x *StreamingOutputCallRequest) GetResponseStatus() *EchoStatus

+ func (x *StreamingOutputCallRequest) GetResponseType() PayloadType

+ func (x *StreamingOutputCallRequest) ProtoReflect() protoreflect.Message

+ func (x *StreamingOutputCallRequest) Reset()

+ func (x *StreamingOutputCallRequest) String() string

+ type StreamingOutputCallResponse struct

+ Payload *Payload

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

+ func (*StreamingOutputCallResponse) ProtoMessage()

+ func (x *StreamingOutputCallResponse) GetPayload() *Payload

+ func (x *StreamingOutputCallResponse) ProtoReflect() protoreflect.Message

+ func (x *StreamingOutputCallResponse) Reset()

+ func (x *StreamingOutputCallResponse) String() string

+ type TestServer struct

+ func (TestServer) EmptyCall(ctx context.Context, req *Empty) (*Empty, error)

+ func (TestServer) FullDuplexCall(ctx context.Context, str TestService_FullDuplexCallServer) error

+ func (TestServer) HalfDuplexCall(ctx context.Context, str TestService_HalfDuplexCallServer) error

+ func (TestServer) StreamingInputCall(ctx context.Context, str TestService_StreamingInputCallServer) (*StreamingInputCallResponse, error)

+ func (TestServer) StreamingOutputCall(ctx context.Context, req *StreamingOutputCallRequest, ...) error

+ func (TestServer) UnaryCall(ctx context.Context, req *SimpleRequest) (*SimpleResponse, error)

+ type TestServiceClient interface

+ EmptyCall func(context.Context, *Empty) (*Empty, error)

+ FullDuplexCall func(context.Context) (TestService_FullDuplexCallClient, error)

+ HalfDuplexCall func(context.Context) (TestService_HalfDuplexCallClient, error)

+ StreamingInputCall func(context.Context) (TestService_StreamingInputCallClient, error)

+ StreamingOutputCall func(context.Context, *StreamingOutputCallRequest) (TestService_StreamingOutputCallClient, error)

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

+ func NewTestServiceClient(client *ttrpc.Client) TestServiceClient

+ type TestServiceService interface

+ EmptyCall func(context.Context, *Empty) (*Empty, error)

+ FullDuplexCall func(context.Context, TestService_FullDuplexCallServer) error

+ HalfDuplexCall func(context.Context, TestService_HalfDuplexCallServer) error

+ StreamingInputCall func(context.Context, TestService_StreamingInputCallServer) (*StreamingInputCallResponse, error)

+ StreamingOutputCall func(context.Context, *StreamingOutputCallRequest, ...) error

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

+ type TestService_FullDuplexCallClient interface

+ Recv func() (*StreamingOutputCallResponse, error)

+ Send func(*StreamingOutputCallRequest) error

+ type TestService_FullDuplexCallServer interface

+ Recv func() (*StreamingOutputCallRequest, error)

+ Send func(*StreamingOutputCallResponse) error

+ type TestService_HalfDuplexCallClient interface

+ Recv func() (*StreamingOutputCallResponse, error)

+ Send func(*StreamingOutputCallRequest) error

+ type TestService_HalfDuplexCallServer interface

+ Recv func() (*StreamingOutputCallRequest, error)

+ Send func(*StreamingOutputCallResponse) error

+ type TestService_StreamingInputCallClient interface

+ CloseAndRecv func() (*StreamingInputCallResponse, error)

+ Send func(*StreamingInputCallRequest) error

+ type TestService_StreamingInputCallServer interface

+ Recv func() (*StreamingInputCallRequest, error)

+ type TestService_StreamingOutputCallClient interface

+ Recv func() (*StreamingOutputCallResponse, error)

+ type TestService_StreamingOutputCallServer interface

+ Send func(*StreamingOutputCallResponse) error

+ type UnimplementedServiceService interface

+ UnimplementedCall func(context.Context, *Empty) (*Empty, error)

+ func NewUnimplementedServiceClient(client *ttrpc.Client) UnimplementedServiceService