testing

Oct 15, 2018

Changes in this version

type FxAllYARPCProceduresResult

+ ReflectionMeta reflection.ServerMeta

type FxKeyValueYARPCProceduresResult

+ ReflectionMeta reflection.ServerMeta

type FxSinkYARPCProceduresResult

+ ReflectionMeta reflection.ServerMeta

type GetValueRequest

+ WktTest *types.Duration

+ func (m *GetValueRequest) GetWktTest() *types.Duration

Aug 6, 2018

Changes in this version

type FireRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (dst *FireRequest) XXX_Merge(src proto.Message)

+ func (m *FireRequest) XXX_DiscardUnknown()

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

+ func (m *FireRequest) XXX_Size() int

+ func (m *FireRequest) XXX_Unmarshal(b []byte) error

type Foo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (dst *Foo) XXX_Merge(src proto.Message)

+ func (m *Foo) XXX_DiscardUnknown()

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

+ func (m *Foo) XXX_Size() int

+ func (m *Foo) XXX_Unmarshal(b []byte) error

type GetValueRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (dst *GetValueRequest) XXX_Merge(src proto.Message)

+ func (m *GetValueRequest) XXX_DiscardUnknown()

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

+ func (m *GetValueRequest) XXX_Size() int

+ func (m *GetValueRequest) XXX_Unmarshal(b []byte) error

type GetValueResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (dst *GetValueResponse) XXX_Merge(src proto.Message)

+ func (m *GetValueResponse) XXX_DiscardUnknown()

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

+ func (m *GetValueResponse) XXX_Size() int

+ func (m *GetValueResponse) XXX_Unmarshal(b []byte) error

type HelloRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (dst *HelloRequest) XXX_Merge(src proto.Message)

+ func (m *HelloRequest) XXX_DiscardUnknown()

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

+ func (m *HelloRequest) XXX_Size() int

+ func (m *HelloRequest) XXX_Unmarshal(b []byte) error

type HelloResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (dst *HelloResponse) XXX_Merge(src proto.Message)

+ func (m *HelloResponse) XXX_DiscardUnknown()

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

+ func (m *HelloResponse) XXX_Size() int

+ func (m *HelloResponse) XXX_Unmarshal(b []byte) error

type SetValueRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (dst *SetValueRequest) XXX_Merge(src proto.Message)

+ func (m *SetValueRequest) XXX_DiscardUnknown()

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

+ func (m *SetValueRequest) XXX_Size() int

+ func (m *SetValueRequest) XXX_Unmarshal(b []byte) error

type SetValueResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (dst *SetValueResponse) XXX_Merge(src proto.Message)

+ func (m *SetValueResponse) XXX_DiscardUnknown()

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

+ func (m *SetValueResponse) XXX_Size() int

+ func (m *SetValueResponse) XXX_Unmarshal(b []byte) error

Mar 21, 2018

Changes in this version

+ func NewFxAllYARPCClient(name string, options ...protobuf.ClientOption) interface

+ func NewFxAllYARPCProcedures() interface

+ func NewFxKeyValueYARPCClient(name string, options ...protobuf.ClientOption) interface

+ func NewFxKeyValueYARPCProcedures() interface

+ func NewFxSinkYARPCClient(name string, options ...protobuf.ClientOption) interface

+ func NewFxSinkYARPCProcedures() interface

+ type FxAllYARPCClientParams struct

+ Provider yarpc.ClientConfig

+ type FxAllYARPCClientResult struct

+ Client AllYARPCClient

+ type FxAllYARPCProceduresParams struct

+ Server AllYARPCServer

+ type FxAllYARPCProceduresResult struct

+ Procedures []transport.Procedure

+ type FxKeyValueYARPCClientParams struct

+ Provider yarpc.ClientConfig

+ type FxKeyValueYARPCClientResult struct

+ Client KeyValueYARPCClient

+ type FxKeyValueYARPCProceduresParams struct

+ Server KeyValueYARPCServer

+ type FxKeyValueYARPCProceduresResult struct

+ Procedures []transport.Procedure

+ type FxSinkYARPCClientParams struct

+ Provider yarpc.ClientConfig

+ type FxSinkYARPCClientResult struct

+ Client SinkYARPCClient

+ type FxSinkYARPCProceduresParams struct

+ Server SinkYARPCServer

+ type FxSinkYARPCProceduresResult struct

+ Procedures []transport.Procedure

Jan 22, 2018

Changes in this version

+ func BuildAllYARPCProcedures(server AllYARPCServer) []transport.Procedure

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

+ type AllClient interface

+ Fire func(ctx context.Context, in *FireRequest, opts ...grpc.CallOption) (*uber_yarpc.Oneway, error)

+ GetValue func(ctx context.Context, in *GetValueRequest, opts ...grpc.CallOption) (*GetValueResponse, error)

+ HelloOne func(ctx context.Context, opts ...grpc.CallOption) (All_HelloOneClient, error)

+ HelloThree func(ctx context.Context, opts ...grpc.CallOption) (All_HelloThreeClient, error)

+ HelloTwo func(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (All_HelloTwoClient, error)

+ SetValue func(ctx context.Context, in *SetValueRequest, opts ...grpc.CallOption) (*SetValueResponse, error)

+ func NewAllClient(cc *grpc.ClientConn) AllClient

+ type AllServer interface

+ Fire func(context.Context, *FireRequest) (*uber_yarpc.Oneway, error)

+ GetValue func(context.Context, *GetValueRequest) (*GetValueResponse, error)

+ HelloOne func(All_HelloOneServer) error

+ HelloThree func(All_HelloThreeServer) error

+ HelloTwo func(*HelloRequest, All_HelloTwoServer) error

+ SetValue func(context.Context, *SetValueRequest) (*SetValueResponse, error)

+ type AllServiceHelloOneYARPCClient interface

+ CloseAndRecv func(...yarpc.StreamOption) (*HelloResponse, error)

+ Context func() context.Context

+ Send func(*HelloRequest, ...yarpc.StreamOption) error

+ type AllServiceHelloOneYARPCServer interface

+ Context func() context.Context

+ Recv func(...yarpc.StreamOption) (*HelloRequest, error)

+ type AllServiceHelloThreeYARPCClient interface

+ CloseSend func(...yarpc.StreamOption) error

+ Context func() context.Context

+ Recv func(...yarpc.StreamOption) (*HelloResponse, error)

+ Send func(*HelloRequest, ...yarpc.StreamOption) error

+ type AllServiceHelloThreeYARPCServer interface

+ Context func() context.Context

+ Recv func(...yarpc.StreamOption) (*HelloRequest, error)

+ Send func(*HelloResponse, ...yarpc.StreamOption) error

+ type AllServiceHelloTwoYARPCClient interface

+ CloseSend func(...yarpc.StreamOption) error

+ Context func() context.Context

+ Recv func(...yarpc.StreamOption) (*HelloResponse, error)

+ type AllServiceHelloTwoYARPCServer interface

+ Context func() context.Context

+ Send func(*HelloResponse, ...yarpc.StreamOption) error

+ type AllYARPCClient interface

+ Fire func(context.Context, *FireRequest, ...yarpc.CallOption) (yarpc.Ack, error)

+ GetValue func(context.Context, *GetValueRequest, ...yarpc.CallOption) (*GetValueResponse, error)

+ HelloOne func(context.Context, ...yarpc.CallOption) (AllServiceHelloOneYARPCClient, error)

+ HelloThree func(context.Context, ...yarpc.CallOption) (AllServiceHelloThreeYARPCClient, error)

+ HelloTwo func(context.Context, *HelloRequest, ...yarpc.CallOption) (AllServiceHelloTwoYARPCClient, error)

+ SetValue func(context.Context, *SetValueRequest, ...yarpc.CallOption) (*SetValueResponse, error)

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

+ type AllYARPCServer interface

+ Fire func(context.Context, *FireRequest) error

+ GetValue func(context.Context, *GetValueRequest) (*GetValueResponse, error)

+ HelloOne func(AllServiceHelloOneYARPCServer) (*HelloResponse, error)

+ HelloThree func(AllServiceHelloThreeYARPCServer) error

+ HelloTwo func(*HelloRequest, AllServiceHelloTwoYARPCServer) error

+ SetValue func(context.Context, *SetValueRequest) (*SetValueResponse, error)

+ type All_HelloOneClient interface

+ CloseAndRecv func() (*HelloResponse, error)

+ Send func(*HelloRequest) error

+ type All_HelloOneServer interface

+ Recv func() (*HelloRequest, error)

+ SendAndClose func(*HelloResponse) error

+ type All_HelloThreeClient interface

+ Recv func() (*HelloResponse, error)

+ Send func(*HelloRequest) error

+ type All_HelloThreeServer interface

+ Recv func() (*HelloRequest, error)

+ Send func(*HelloResponse) error

+ type All_HelloTwoClient interface

+ Recv func() (*HelloResponse, error)

+ type All_HelloTwoServer interface

+ Send func(*HelloResponse) error

+ type HelloRequest struct

+ Id string

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

+ func (*HelloRequest) ProtoMessage()

+ func (m *HelloRequest) GetId() string

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

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

+ func (m *HelloRequest) Reset()

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

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

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

+ func (this *HelloRequest) GoString() string

+ func (this *HelloRequest) String() string

+ type HelloResponse struct

+ Id string

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

+ func (*HelloResponse) ProtoMessage()

+ func (m *HelloResponse) GetId() string

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

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

+ func (m *HelloResponse) Reset()

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

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

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

+ func (this *HelloResponse) GoString() string

+ func (this *HelloResponse) String() string

Dec 4, 2017

Changes in this version

+ var ErrIntOverflowDep = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthDep = fmt.Errorf("proto: negative length found during unmarshaling")

Jul 11, 2017

Changes in this version

+ var ErrIntOverflowTesting = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowTestingNoService = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthTesting = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthTestingNoService = fmt.Errorf("proto: negative length found during unmarshaling")

+ func BuildKeyValueYARPCProcedures(server KeyValueYARPCServer) []transport.Procedure

+ func BuildSinkYARPCProcedures(server SinkYARPCServer) []transport.Procedure

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

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

+ type FireRequest struct

+ Value string

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

+ func (*FireRequest) ProtoMessage()

+ func (m *FireRequest) GetValue() string

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

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

+ func (m *FireRequest) Reset()

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

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

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

+ func (this *FireRequest) GoString() string

+ func (this *FireRequest) String() string

+ type Foo struct

+ Id string

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

+ func (*Foo) ProtoMessage()

+ func (m *Foo) GetId() string

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

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

+ func (m *Foo) Reset()

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

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

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

+ func (this *Foo) GoString() string

+ func (this *Foo) String() string

+ type GetValueRequest struct

+ Key string

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

+ func (*GetValueRequest) ProtoMessage()

+ func (m *GetValueRequest) GetKey() string

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

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

+ func (m *GetValueRequest) Reset()

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

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

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

+ func (this *GetValueRequest) GoString() string

+ func (this *GetValueRequest) String() string

+ type GetValueResponse struct

+ Value string

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

+ func (*GetValueResponse) ProtoMessage()

+ func (m *GetValueResponse) GetValue() string

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

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

+ func (m *GetValueResponse) Reset()

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

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

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

+ func (this *GetValueResponse) GoString() string

+ func (this *GetValueResponse) String() string

+ type KeyValueClient interface

+ GetValue func(ctx context.Context, in *GetValueRequest, opts ...grpc.CallOption) (*GetValueResponse, error)

+ SetValue func(ctx context.Context, in *SetValueRequest, opts ...grpc.CallOption) (*SetValueResponse, error)

+ func NewKeyValueClient(cc *grpc.ClientConn) KeyValueClient

+ type KeyValueServer interface

+ GetValue func(context.Context, *GetValueRequest) (*GetValueResponse, error)

+ SetValue func(context.Context, *SetValueRequest) (*SetValueResponse, error)

+ type KeyValueYARPCClient interface

+ GetValue func(context.Context, *GetValueRequest, ...yarpc.CallOption) (*GetValueResponse, error)

+ SetValue func(context.Context, *SetValueRequest, ...yarpc.CallOption) (*SetValueResponse, error)

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

+ type KeyValueYARPCServer interface

+ GetValue func(context.Context, *GetValueRequest) (*GetValueResponse, error)

+ SetValue func(context.Context, *SetValueRequest) (*SetValueResponse, error)

+ type SetValueRequest struct

+ Key string

+ Value string

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

+ func (*SetValueRequest) ProtoMessage()

+ func (m *SetValueRequest) GetKey() string

+ func (m *SetValueRequest) GetValue() string

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

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

+ func (m *SetValueRequest) Reset()

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

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

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

+ func (this *SetValueRequest) GoString() string

+ func (this *SetValueRequest) String() string

+ type SetValueResponse struct

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

+ func (*SetValueResponse) ProtoMessage()

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

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

+ func (m *SetValueResponse) Reset()

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

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

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

+ func (this *SetValueResponse) GoString() string

+ func (this *SetValueResponse) String() string

+ type SinkClient interface

+ Fire func(ctx context.Context, in *FireRequest, opts ...grpc.CallOption) (*uber_yarpc.Oneway, error)

+ func NewSinkClient(cc *grpc.ClientConn) SinkClient

+ type SinkServer interface

+ Fire func(context.Context, *FireRequest) (*uber_yarpc.Oneway, error)

+ type SinkYARPCClient interface

+ Fire func(context.Context, *FireRequest, ...yarpc.CallOption) (yarpc.Ack, error)

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

+ type SinkYARPCServer interface

+ Fire func(context.Context, *FireRequest) error