testing

package
v1.28.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 13, 2018 License: MIT Imports: 15 Imported by: 0

Documentation

Overview

Package testing is a generated protocol buffer package.

It is generated from these files: 

encoding/protobuf/protoc-gen-yarpc-go/internal/testing/dep.proto
encoding/protobuf/protoc-gen-yarpc-go/internal/testing/testing.proto
encoding/protobuf/protoc-gen-yarpc-go/internal/testing/testing_no_service.proto

It has these top-level messages: 

SetValueResponse
GetValueRequest
GetValueResponse
SetValueRequest
FireRequest
HelloRequest
HelloResponse
Foo

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthDep = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDep   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthTesting = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTesting   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthTestingNoService = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTestingNoService   = fmt.Errorf("proto: integer overflow")
)

Functions

func BuildAllYARPCProcedures added in v1.27.0 

func BuildAllYARPCProcedures(server AllYARPCServer) []transport.Procedure

BuildAllYARPCProcedures prepares an implementation of the All service for YARPC registration.

func BuildKeyValueYARPCProcedures 

func BuildKeyValueYARPCProcedures(server KeyValueYARPCServer) []transport.Procedure

BuildKeyValueYARPCProcedures prepares an implementation of the KeyValue service for YARPC registration.

func BuildSinkYARPCProcedures 

func BuildSinkYARPCProcedures(server SinkYARPCServer) []transport.Procedure

BuildSinkYARPCProcedures prepares an implementation of the Sink service for YARPC registration.

func RegisterAllServer added in v1.27.0 

func RegisterAllServer(s *grpc.Server, srv AllServer)

func RegisterKeyValueServer 

func RegisterKeyValueServer(s *grpc.Server, srv KeyValueServer)

func RegisterSinkServer 

func RegisterSinkServer(s *grpc.Server, srv SinkServer)

Types

type AllClient added in v1.27.0 

type AllClient interface {
	GetValue(ctx context.Context, in *GetValueRequest, opts ...grpc.CallOption) (*GetValueResponse, error)
	SetValue(ctx context.Context, in *SetValueRequest, opts ...grpc.CallOption) (*SetValueResponse, error)
	Fire(ctx context.Context, in *FireRequest, opts ...grpc.CallOption) (*uber_yarpc.Oneway, error)
	HelloOne(ctx context.Context, opts ...grpc.CallOption) (All_HelloOneClient, error)
	HelloTwo(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (All_HelloTwoClient, error)
	HelloThree(ctx context.Context, opts ...grpc.CallOption) (All_HelloThreeClient, error)
}

func NewAllClient added in v1.27.0 

func NewAllClient(cc *grpc.ClientConn) AllClient

type AllServer added in v1.27.0 

type AllServer interface {
	GetValue(context.Context, *GetValueRequest) (*GetValueResponse, error)
	SetValue(context.Context, *SetValueRequest) (*SetValueResponse, error)
	Fire(context.Context, *FireRequest) (*uber_yarpc.Oneway, error)
	HelloOne(All_HelloOneServer) error
	HelloTwo(*HelloRequest, All_HelloTwoServer) error
	HelloThree(All_HelloThreeServer) error
}

type AllServiceHelloOneYARPCClient added in v1.27.0 

type AllServiceHelloOneYARPCClient interface {
	Context() context.Context
	Send(*HelloRequest, ...yarpc.StreamOption) error
	CloseAndRecv(...yarpc.StreamOption) (*HelloResponse, error)
}

AllServiceHelloOneYARPCClient sends HelloRequests and receives the single HelloResponse when sending is done.

type AllServiceHelloOneYARPCServer added in v1.27.0 

type AllServiceHelloOneYARPCServer interface {
	Context() context.Context
	Recv(...yarpc.StreamOption) (*HelloRequest, error)
}

AllServiceHelloOneYARPCServer receives HelloRequests.

type AllServiceHelloThreeYARPCClient added in v1.27.0 

type AllServiceHelloThreeYARPCClient interface {
	Context() context.Context
	Send(*HelloRequest, ...yarpc.StreamOption) error
	Recv(...yarpc.StreamOption) (*HelloResponse, error)
	CloseSend(...yarpc.StreamOption) error
}

AllServiceHelloThreeYARPCClient sends HelloRequests and receives HelloResponses, returning io.EOF when the stream is complete.

type AllServiceHelloThreeYARPCServer added in v1.27.0 

type AllServiceHelloThreeYARPCServer interface {
	Context() context.Context
	Recv(...yarpc.StreamOption) (*HelloRequest, error)
	Send(*HelloResponse, ...yarpc.StreamOption) error
}

AllServiceHelloThreeYARPCServer receives HelloRequests and sends HelloResponse.

type AllServiceHelloTwoYARPCClient added in v1.27.0 

type AllServiceHelloTwoYARPCClient interface {
	Context() context.Context
	Recv(...yarpc.StreamOption) (*HelloResponse, error)
	CloseSend(...yarpc.StreamOption) error
}

AllServiceHelloTwoYARPCClient receives HelloResponses, returning io.EOF when the stream is complete.

type AllServiceHelloTwoYARPCServer added in v1.27.0 

type AllServiceHelloTwoYARPCServer interface {
	Context() context.Context
	Send(*HelloResponse, ...yarpc.StreamOption) error
}

AllServiceHelloTwoYARPCServer sends HelloResponses.

type AllYARPCClient added in v1.27.0 

type AllYARPCClient interface {
	GetValue(context.Context, *GetValueRequest, ...yarpc.CallOption) (*GetValueResponse, error)
	SetValue(context.Context, *SetValueRequest, ...yarpc.CallOption) (*SetValueResponse, error)
	Fire(context.Context, *FireRequest, ...yarpc.CallOption) (yarpc.Ack, error)
	HelloOne(context.Context, ...yarpc.CallOption) (AllServiceHelloOneYARPCClient, error)
	HelloTwo(context.Context, *HelloRequest, ...yarpc.CallOption) (AllServiceHelloTwoYARPCClient, error)
	HelloThree(context.Context, ...yarpc.CallOption) (AllServiceHelloThreeYARPCClient, error)
}

AllYARPCClient is the YARPC client-side interface for the All service.

func NewAllYARPCClient added in v1.27.0 

func NewAllYARPCClient(clientConfig transport.ClientConfig, options ...protobuf.ClientOption) AllYARPCClient

NewAllYARPCClient builds a new YARPC client for the All service.

type AllYARPCServer added in v1.27.0 

type AllYARPCServer interface {
	GetValue(context.Context, *GetValueRequest) (*GetValueResponse, error)
	SetValue(context.Context, *SetValueRequest) (*SetValueResponse, error)
	Fire(context.Context, *FireRequest) error
	HelloOne(AllServiceHelloOneYARPCServer) (*HelloResponse, error)
	HelloTwo(*HelloRequest, AllServiceHelloTwoYARPCServer) error
	HelloThree(AllServiceHelloThreeYARPCServer) error
}

AllYARPCServer is the YARPC server-side interface for the All service.

type All_HelloOneClient added in v1.27.0 

type All_HelloOneClient interface {
	Send(*HelloRequest) error
	CloseAndRecv() (*HelloResponse, error)
	grpc.ClientStream
}

type All_HelloOneServer added in v1.27.0 

type All_HelloOneServer interface {
	SendAndClose(*HelloResponse) error
	Recv() (*HelloRequest, error)
	grpc.ServerStream
}

type All_HelloThreeClient added in v1.27.0 

type All_HelloThreeClient interface {
	Send(*HelloRequest) error
	Recv() (*HelloResponse, error)
	grpc.ClientStream
}

type All_HelloThreeServer added in v1.27.0 

type All_HelloThreeServer interface {
	Send(*HelloResponse) error
	Recv() (*HelloRequest, error)
	grpc.ServerStream
}

type All_HelloTwoClient added in v1.27.0 

type All_HelloTwoClient interface {
	Recv() (*HelloResponse, error)
	grpc.ClientStream
}

type All_HelloTwoServer added in v1.27.0 

type All_HelloTwoServer interface {
	Send(*HelloResponse) error
	grpc.ServerStream
}

type FireRequest 

type FireRequest struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*FireRequest) Descriptor 

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

func (*FireRequest) Equal 

func (this *FireRequest) Equal(that interface{}) bool

func (*FireRequest) GetValue 

func (m *FireRequest) GetValue() string

func (*FireRequest) GoString 

func (this *FireRequest) GoString() string

func (*FireRequest) Marshal 

func (m *FireRequest) Marshal() (dAtA []byte, err error)

func (*FireRequest) MarshalTo 

func (m *FireRequest) MarshalTo(dAtA []byte) (int, error)

func (*FireRequest) ProtoMessage 

func (*FireRequest) ProtoMessage()

func (*FireRequest) Reset 

func (m *FireRequest) Reset()

func (*FireRequest) Size 

func (m *FireRequest) Size() (n int)

func (*FireRequest) String 

func (this *FireRequest) String() string

func (*FireRequest) Unmarshal 

func (m *FireRequest) Unmarshal(dAtA []byte) error

type Foo 

type Foo struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*Foo) Descriptor 

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

func (*Foo) Equal 

func (this *Foo) Equal(that interface{}) bool

func (*Foo) GetId 

func (m *Foo) GetId() string

func (*Foo) GoString 

func (this *Foo) GoString() string

func (*Foo) Marshal 

func (m *Foo) Marshal() (dAtA []byte, err error)

func (*Foo) MarshalTo 

func (m *Foo) MarshalTo(dAtA []byte) (int, error)

func (*Foo) ProtoMessage 

func (*Foo) ProtoMessage()

func (*Foo) Reset 

func (m *Foo) Reset()

func (*Foo) Size 

func (m *Foo) Size() (n int)

func (*Foo) String 

func (this *Foo) String() string

func (*Foo) Unmarshal 

func (m *Foo) Unmarshal(dAtA []byte) error

type GetValueRequest 

type GetValueRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
}

func (*GetValueRequest) Descriptor 

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

func (*GetValueRequest) Equal 

func (this *GetValueRequest) Equal(that interface{}) bool

func (*GetValueRequest) GetKey 

func (m *GetValueRequest) GetKey() string

func (*GetValueRequest) GoString 

func (this *GetValueRequest) GoString() string

func (*GetValueRequest) Marshal 

func (m *GetValueRequest) Marshal() (dAtA []byte, err error)

func (*GetValueRequest) MarshalTo 

func (m *GetValueRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetValueRequest) ProtoMessage 

func (*GetValueRequest) ProtoMessage()

func (*GetValueRequest) Reset 

func (m *GetValueRequest) Reset()

func (*GetValueRequest) Size 

func (m *GetValueRequest) Size() (n int)

func (*GetValueRequest) String 

func (this *GetValueRequest) String() string

func (*GetValueRequest) Unmarshal 

func (m *GetValueRequest) Unmarshal(dAtA []byte) error

type GetValueResponse 

type GetValueResponse struct {
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*GetValueResponse) Descriptor 

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

func (*GetValueResponse) Equal 

func (this *GetValueResponse) Equal(that interface{}) bool

func (*GetValueResponse) GetValue 

func (m *GetValueResponse) GetValue() string

func (*GetValueResponse) GoString 

func (this *GetValueResponse) GoString() string

func (*GetValueResponse) Marshal 

func (m *GetValueResponse) Marshal() (dAtA []byte, err error)

func (*GetValueResponse) MarshalTo 

func (m *GetValueResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetValueResponse) ProtoMessage 

func (*GetValueResponse) ProtoMessage()

func (*GetValueResponse) Reset 

func (m *GetValueResponse) Reset()

func (*GetValueResponse) Size 

func (m *GetValueResponse) Size() (n int)

func (*GetValueResponse) String 

func (this *GetValueResponse) String() string

func (*GetValueResponse) Unmarshal 

func (m *GetValueResponse) Unmarshal(dAtA []byte) error

type HelloRequest added in v1.27.0 

type HelloRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*HelloRequest) Descriptor added in v1.27.0 

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

func (*HelloRequest) Equal added in v1.27.0 

func (this *HelloRequest) Equal(that interface{}) bool

func (*HelloRequest) GetId added in v1.27.0 

func (m *HelloRequest) GetId() string

func (*HelloRequest) GoString added in v1.27.0 

func (this *HelloRequest) GoString() string

func (*HelloRequest) Marshal added in v1.27.0 

func (m *HelloRequest) Marshal() (dAtA []byte, err error)

func (*HelloRequest) MarshalTo added in v1.27.0 

func (m *HelloRequest) MarshalTo(dAtA []byte) (int, error)

func (*HelloRequest) ProtoMessage added in v1.27.0 

func (*HelloRequest) ProtoMessage()

func (*HelloRequest) Reset added in v1.27.0 

func (m *HelloRequest) Reset()

func (*HelloRequest) Size added in v1.27.0 

func (m *HelloRequest) Size() (n int)

func (*HelloRequest) String added in v1.27.0 

func (this *HelloRequest) String() string

func (*HelloRequest) Unmarshal added in v1.27.0 

func (m *HelloRequest) Unmarshal(dAtA []byte) error

type HelloResponse added in v1.27.0 

type HelloResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*HelloResponse) Descriptor added in v1.27.0 

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

func (*HelloResponse) Equal added in v1.27.0 

func (this *HelloResponse) Equal(that interface{}) bool

func (*HelloResponse) GetId added in v1.27.0 

func (m *HelloResponse) GetId() string

func (*HelloResponse) GoString added in v1.27.0 

func (this *HelloResponse) GoString() string

func (*HelloResponse) Marshal added in v1.27.0 

func (m *HelloResponse) Marshal() (dAtA []byte, err error)

func (*HelloResponse) MarshalTo added in v1.27.0 

func (m *HelloResponse) MarshalTo(dAtA []byte) (int, error)

func (*HelloResponse) ProtoMessage added in v1.27.0 

func (*HelloResponse) ProtoMessage()

func (*HelloResponse) Reset added in v1.27.0 

func (m *HelloResponse) Reset()

func (*HelloResponse) Size added in v1.27.0 

func (m *HelloResponse) Size() (n int)

func (*HelloResponse) String added in v1.27.0 

func (this *HelloResponse) String() string

func (*HelloResponse) Unmarshal added in v1.27.0 

func (m *HelloResponse) Unmarshal(dAtA []byte) error

type KeyValueClient 

type KeyValueClient interface {
	GetValue(ctx context.Context, in *GetValueRequest, opts ...grpc.CallOption) (*GetValueResponse, error)
	SetValue(ctx context.Context, in *SetValueRequest, opts ...grpc.CallOption) (*SetValueResponse, error)
}

func NewKeyValueClient 

func NewKeyValueClient(cc *grpc.ClientConn) KeyValueClient

type KeyValueServer 

type KeyValueServer interface {
	GetValue(context.Context, *GetValueRequest) (*GetValueResponse, error)
	SetValue(context.Context, *SetValueRequest) (*SetValueResponse, error)
}

type KeyValueYARPCClient 

type KeyValueYARPCClient interface {
	GetValue(context.Context, *GetValueRequest, ...yarpc.CallOption) (*GetValueResponse, error)
	SetValue(context.Context, *SetValueRequest, ...yarpc.CallOption) (*SetValueResponse, error)
}

KeyValueYARPCClient is the YARPC client-side interface for the KeyValue service.

func NewKeyValueYARPCClient 

func NewKeyValueYARPCClient(clientConfig transport.ClientConfig, options ...protobuf.ClientOption) KeyValueYARPCClient

NewKeyValueYARPCClient builds a new YARPC client for the KeyValue service.

type KeyValueYARPCServer 

type KeyValueYARPCServer interface {
	GetValue(context.Context, *GetValueRequest) (*GetValueResponse, error)
	SetValue(context.Context, *SetValueRequest) (*SetValueResponse, error)
}

KeyValueYARPCServer is the YARPC server-side interface for the KeyValue service.

type SetValueRequest 

type SetValueRequest struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*SetValueRequest) Descriptor 

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

func (*SetValueRequest) Equal 

func (this *SetValueRequest) Equal(that interface{}) bool

func (*SetValueRequest) GetKey 

func (m *SetValueRequest) GetKey() string

func (*SetValueRequest) GetValue 

func (m *SetValueRequest) GetValue() string

func (*SetValueRequest) GoString 

func (this *SetValueRequest) GoString() string

func (*SetValueRequest) Marshal 

func (m *SetValueRequest) Marshal() (dAtA []byte, err error)

func (*SetValueRequest) MarshalTo 

func (m *SetValueRequest) MarshalTo(dAtA []byte) (int, error)

func (*SetValueRequest) ProtoMessage 

func (*SetValueRequest) ProtoMessage()

func (*SetValueRequest) Reset 

func (m *SetValueRequest) Reset()

func (*SetValueRequest) Size 

func (m *SetValueRequest) Size() (n int)

func (*SetValueRequest) String 

func (this *SetValueRequest) String() string

func (*SetValueRequest) Unmarshal 

func (m *SetValueRequest) Unmarshal(dAtA []byte) error

type SetValueResponse 

type SetValueResponse struct {
}

func (*SetValueResponse) Descriptor 

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

func (*SetValueResponse) Equal 

func (this *SetValueResponse) Equal(that interface{}) bool

func (*SetValueResponse) GoString 

func (this *SetValueResponse) GoString() string

func (*SetValueResponse) Marshal 

func (m *SetValueResponse) Marshal() (dAtA []byte, err error)

func (*SetValueResponse) MarshalTo 

func (m *SetValueResponse) MarshalTo(dAtA []byte) (int, error)

func (*SetValueResponse) ProtoMessage 

func (*SetValueResponse) ProtoMessage()

func (*SetValueResponse) Reset 

func (m *SetValueResponse) Reset()

func (*SetValueResponse) Size 

func (m *SetValueResponse) Size() (n int)

func (*SetValueResponse) String 

func (this *SetValueResponse) String() string

func (*SetValueResponse) Unmarshal 

func (m *SetValueResponse) Unmarshal(dAtA []byte) error

type SinkClient 

type SinkClient interface {
	Fire(ctx context.Context, in *FireRequest, opts ...grpc.CallOption) (*uber_yarpc.Oneway, error)
}

func NewSinkClient 

func NewSinkClient(cc *grpc.ClientConn) SinkClient

type SinkServer 

type SinkServer interface {
	Fire(context.Context, *FireRequest) (*uber_yarpc.Oneway, error)
}

type SinkYARPCClient 

type SinkYARPCClient interface {
	Fire(context.Context, *FireRequest, ...yarpc.CallOption) (yarpc.Ack, error)
}

SinkYARPCClient is the YARPC client-side interface for the Sink service.

func NewSinkYARPCClient 

func NewSinkYARPCClient(clientConfig transport.ClientConfig, options ...protobuf.ClientOption) SinkYARPCClient

NewSinkYARPCClient builds a new YARPC client for the Sink service.

type SinkYARPCServer 

type SinkYARPCServer interface {
	Fire(context.Context, *FireRequest) error
}

SinkYARPCServer is the YARPC server-side interface for the Sink service.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.