testing

package
v1.32.4 Latest Latest
Warning

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

 Go to latest Published: Aug 8, 2018 License: MIT Imports: 16 Imported by: 0

Documentation

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 NewFxAllYARPCClient added in v1.29.0 

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

NewFxAllYARPCClient provides a AllYARPCClient to an Fx application using the given name for routing. 

fx.Provide(
  testing.NewFxAllYARPCClient("service-name"),
  ...
)

func NewFxAllYARPCProcedures added in v1.29.0 

func NewFxAllYARPCProcedures() interface{}

NewFxAllYARPCProcedures provides AllYARPCServer procedures to an Fx application. It expects a AllYARPCServer to be present in the container. 

fx.Provide(
  testing.NewFxAllYARPCProcedures(),
  ...
)

func NewFxKeyValueYARPCClient added in v1.29.0 

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

NewFxKeyValueYARPCClient provides a KeyValueYARPCClient to an Fx application using the given name for routing. 

fx.Provide(
  testing.NewFxKeyValueYARPCClient("service-name"),
  ...
)

func NewFxKeyValueYARPCProcedures added in v1.29.0 

func NewFxKeyValueYARPCProcedures() interface{}

NewFxKeyValueYARPCProcedures provides KeyValueYARPCServer procedures to an Fx application. It expects a KeyValueYARPCServer to be present in the container. 

fx.Provide(
  testing.NewFxKeyValueYARPCProcedures(),
  ...
)

func NewFxSinkYARPCClient added in v1.29.0 

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

NewFxSinkYARPCClient provides a SinkYARPCClient to an Fx application using the given name for routing. 

fx.Provide(
  testing.NewFxSinkYARPCClient("service-name"),
  ...
)

func NewFxSinkYARPCProcedures added in v1.29.0 

func NewFxSinkYARPCProcedures() interface{}

NewFxSinkYARPCProcedures provides SinkYARPCServer procedures to an Fx application. It expects a SinkYARPCServer to be present in the container. 

fx.Provide(
  testing.NewFxSinkYARPCProcedures(),
  ...
)

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) (*yarpcproto.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) (*yarpcproto.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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*FireRequest) XXX_DiscardUnknown added in v1.32.0 

func (m *FireRequest) XXX_DiscardUnknown()

func (*FireRequest) XXX_Marshal added in v1.32.0 

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

func (*FireRequest) XXX_Merge added in v1.32.0 

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

func (*FireRequest) XXX_Size added in v1.32.0 

func (m *FireRequest) XXX_Size() int

func (*FireRequest) XXX_Unmarshal added in v1.32.0 

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

type Foo 

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

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

func (*Foo) XXX_DiscardUnknown added in v1.32.0 

func (m *Foo) XXX_DiscardUnknown()

func (*Foo) XXX_Marshal added in v1.32.0 

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

func (*Foo) XXX_Merge added in v1.32.0 

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

func (*Foo) XXX_Size added in v1.32.0 

func (m *Foo) XXX_Size() int

func (*Foo) XXX_Unmarshal added in v1.32.0 

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

type FxAllYARPCClientParams added in v1.29.0 

type FxAllYARPCClientParams struct {
	fx.In

	Provider yarpc.ClientConfig
}

FxAllYARPCClientParams defines the input for NewFxAllYARPCClient. It provides the paramaters to get a AllYARPCClient in an Fx application.

type FxAllYARPCClientResult added in v1.29.0 

type FxAllYARPCClientResult struct {
	fx.Out

	Client AllYARPCClient
}

FxAllYARPCClientResult defines the output of NewFxAllYARPCClient. It provides a AllYARPCClient to an Fx application.

type FxAllYARPCProceduresParams added in v1.29.0 

type FxAllYARPCProceduresParams struct {
	fx.In

	Server AllYARPCServer
}

FxAllYARPCProceduresParams defines the input for NewFxAllYARPCProcedures. It provides the paramaters to get AllYARPCServer procedures in an Fx application.

type FxAllYARPCProceduresResult added in v1.29.0 

type FxAllYARPCProceduresResult struct {
	fx.Out

	Procedures []transport.Procedure `group:"yarpcfx"`
}

FxAllYARPCProceduresResult defines the output of NewFxAllYARPCProcedures. It provides AllYARPCServer procedures to an Fx application.

The procedures are provided to the "yarpcfx" value group. Dig 1.2 or newer must be used for this feature to work.

type FxKeyValueYARPCClientParams added in v1.29.0 

type FxKeyValueYARPCClientParams struct {
	fx.In

	Provider yarpc.ClientConfig
}

FxKeyValueYARPCClientParams defines the input for NewFxKeyValueYARPCClient. It provides the paramaters to get a KeyValueYARPCClient in an Fx application.

type FxKeyValueYARPCClientResult added in v1.29.0 

type FxKeyValueYARPCClientResult struct {
	fx.Out

	Client KeyValueYARPCClient
}

FxKeyValueYARPCClientResult defines the output of NewFxKeyValueYARPCClient. It provides a KeyValueYARPCClient to an Fx application.

type FxKeyValueYARPCProceduresParams added in v1.29.0 

type FxKeyValueYARPCProceduresParams struct {
	fx.In

	Server KeyValueYARPCServer
}

FxKeyValueYARPCProceduresParams defines the input for NewFxKeyValueYARPCProcedures. It provides the paramaters to get KeyValueYARPCServer procedures in an Fx application.

type FxKeyValueYARPCProceduresResult added in v1.29.0 

type FxKeyValueYARPCProceduresResult struct {
	fx.Out

	Procedures []transport.Procedure `group:"yarpcfx"`
}

FxKeyValueYARPCProceduresResult defines the output of NewFxKeyValueYARPCProcedures. It provides KeyValueYARPCServer procedures to an Fx application.

The procedures are provided to the "yarpcfx" value group. Dig 1.2 or newer must be used for this feature to work.

type FxSinkYARPCClientParams added in v1.29.0 

type FxSinkYARPCClientParams struct {
	fx.In

	Provider yarpc.ClientConfig
}

FxSinkYARPCClientParams defines the input for NewFxSinkYARPCClient. It provides the paramaters to get a SinkYARPCClient in an Fx application.

type FxSinkYARPCClientResult added in v1.29.0 

type FxSinkYARPCClientResult struct {
	fx.Out

	Client SinkYARPCClient
}

FxSinkYARPCClientResult defines the output of NewFxSinkYARPCClient. It provides a SinkYARPCClient to an Fx application.

type FxSinkYARPCProceduresParams added in v1.29.0 

type FxSinkYARPCProceduresParams struct {
	fx.In

	Server SinkYARPCServer
}

FxSinkYARPCProceduresParams defines the input for NewFxSinkYARPCProcedures. It provides the paramaters to get SinkYARPCServer procedures in an Fx application.

type FxSinkYARPCProceduresResult added in v1.29.0 

type FxSinkYARPCProceduresResult struct {
	fx.Out

	Procedures []transport.Procedure `group:"yarpcfx"`
}

FxSinkYARPCProceduresResult defines the output of NewFxSinkYARPCProcedures. It provides SinkYARPCServer procedures to an Fx application.

The procedures are provided to the "yarpcfx" value group. Dig 1.2 or newer must be used for this feature to work.

type GetValueRequest 

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

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

func (*GetValueRequest) XXX_DiscardUnknown added in v1.32.0 

func (m *GetValueRequest) XXX_DiscardUnknown()

func (*GetValueRequest) XXX_Marshal added in v1.32.0 

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

func (*GetValueRequest) XXX_Merge added in v1.32.0 

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

func (*GetValueRequest) XXX_Size added in v1.32.0 

func (m *GetValueRequest) XXX_Size() int

func (*GetValueRequest) XXX_Unmarshal added in v1.32.0 

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

type GetValueResponse 

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

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

func (*GetValueResponse) XXX_DiscardUnknown added in v1.32.0 

func (m *GetValueResponse) XXX_DiscardUnknown()

func (*GetValueResponse) XXX_Marshal added in v1.32.0 

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

func (*GetValueResponse) XXX_Merge added in v1.32.0 

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

func (*GetValueResponse) XXX_Size added in v1.32.0 

func (m *GetValueResponse) XXX_Size() int

func (*GetValueResponse) XXX_Unmarshal added in v1.32.0 

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

type HelloRequest added in v1.27.0 

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

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

func (*HelloRequest) XXX_DiscardUnknown added in v1.32.0 

func (m *HelloRequest) XXX_DiscardUnknown()

func (*HelloRequest) XXX_Marshal added in v1.32.0 

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

func (*HelloRequest) XXX_Merge added in v1.32.0 

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

func (*HelloRequest) XXX_Size added in v1.32.0 

func (m *HelloRequest) XXX_Size() int

func (*HelloRequest) XXX_Unmarshal added in v1.32.0 

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

type HelloResponse added in v1.27.0 

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

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

func (*HelloResponse) XXX_DiscardUnknown added in v1.32.0 

func (m *HelloResponse) XXX_DiscardUnknown()

func (*HelloResponse) XXX_Marshal added in v1.32.0 

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

func (*HelloResponse) XXX_Merge added in v1.32.0 

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

func (*HelloResponse) XXX_Size added in v1.32.0 

func (m *HelloResponse) XXX_Size() int

func (*HelloResponse) XXX_Unmarshal added in v1.32.0 

func (m *HelloResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*SetValueRequest) XXX_DiscardUnknown added in v1.32.0 

func (m *SetValueRequest) XXX_DiscardUnknown()

func (*SetValueRequest) XXX_Marshal added in v1.32.0 

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

func (*SetValueRequest) XXX_Merge added in v1.32.0 

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

func (*SetValueRequest) XXX_Size added in v1.32.0 

func (m *SetValueRequest) XXX_Size() int

func (*SetValueRequest) XXX_Unmarshal added in v1.32.0 

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

type SetValueResponse 

type SetValueResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*SetValueResponse) XXX_DiscardUnknown added in v1.32.0 

func (m *SetValueResponse) XXX_DiscardUnknown()

func (*SetValueResponse) XXX_Marshal added in v1.32.0 

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

func (*SetValueResponse) XXX_Merge added in v1.32.0 

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

func (*SetValueResponse) XXX_Size added in v1.32.0 

func (m *SetValueResponse) XXX_Size() int

func (*SetValueResponse) XXX_Unmarshal added in v1.32.0 

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

type SinkClient 

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

func NewSinkClient 

func NewSinkClient(cc *grpc.ClientConn) SinkClient

type SinkServer 

type SinkServer interface {
	Fire(context.Context, *FireRequest) (*yarpcproto.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.