testing

package
v1.27.2 Latest Latest
Warning

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

Go to latest
Published: Jan 23, 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 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

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

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL