examplepb

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: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthExample = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowExample   = fmt.Errorf("proto: integer overflow")
)

Functions

func BuildFooYARPCProcedures added in v1.27.0 

func BuildFooYARPCProcedures(server FooYARPCServer) []transport.Procedure

BuildFooYARPCProcedures prepares an implementation of the Foo service for YARPC registration.

func BuildKeyValueYARPCProcedures added in v1.10.0 

func BuildKeyValueYARPCProcedures(server KeyValueYARPCServer) []transport.Procedure

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

func BuildSinkYARPCProcedures added in v1.10.0 

func BuildSinkYARPCProcedures(server SinkYARPCServer) []transport.Procedure

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

func NewFxFooYARPCClient added in v1.29.0 

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

NewFxFooYARPCClient provides a FooYARPCClient to an Fx application using the given name for routing. 

fx.Provide(
  examplepb.NewFxFooYARPCClient("service-name"),
  ...
)

func NewFxFooYARPCProcedures added in v1.29.0 

func NewFxFooYARPCProcedures() interface{}

NewFxFooYARPCProcedures provides FooYARPCServer procedures to an Fx application. It expects a FooYARPCServer to be present in the container. 

fx.Provide(
  examplepb.NewFxFooYARPCProcedures(),
  ...
)

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(
  examplepb.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(
  examplepb.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(
  examplepb.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(
  examplepb.NewFxSinkYARPCProcedures(),
  ...
)

func RegisterFooServer added in v1.27.0 

func RegisterFooServer(s *grpc.Server, srv FooServer)

func RegisterKeyValueServer 

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

func RegisterSinkServer 

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

Types

type EchoBothRequest added in v1.27.0 

type EchoBothRequest struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	NumResponses         int64    `protobuf:"varint,2,opt,name=num_responses,json=numResponses,proto3" json:"num_responses,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EchoBothRequest) Descriptor added in v1.27.0 

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

func (*EchoBothRequest) Equal added in v1.27.0 

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

func (*EchoBothRequest) GetMessage added in v1.27.0 

func (m *EchoBothRequest) GetMessage() string

func (*EchoBothRequest) GetNumResponses added in v1.27.0 

func (m *EchoBothRequest) GetNumResponses() int64

func (*EchoBothRequest) GoString added in v1.27.0 

func (this *EchoBothRequest) GoString() string

func (*EchoBothRequest) Marshal added in v1.27.0 

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

func (*EchoBothRequest) MarshalTo added in v1.27.0 

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

func (*EchoBothRequest) ProtoMessage added in v1.27.0 

func (*EchoBothRequest) ProtoMessage()

func (*EchoBothRequest) Reset added in v1.27.0 

func (m *EchoBothRequest) Reset()

func (*EchoBothRequest) Size added in v1.27.0 

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

func (*EchoBothRequest) String added in v1.27.0 

func (this *EchoBothRequest) String() string

func (*EchoBothRequest) Unmarshal added in v1.27.0 

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

func (*EchoBothRequest) XXX_DiscardUnknown added in v1.32.0 

func (m *EchoBothRequest) XXX_DiscardUnknown()

func (*EchoBothRequest) XXX_Marshal added in v1.32.0 

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

func (*EchoBothRequest) XXX_Merge added in v1.32.0 

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

func (*EchoBothRequest) XXX_Size added in v1.32.0 

func (m *EchoBothRequest) XXX_Size() int

func (*EchoBothRequest) XXX_Unmarshal added in v1.32.0 

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

type EchoBothResponse added in v1.27.0 

type EchoBothResponse struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EchoBothResponse) Descriptor added in v1.27.0 

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

func (*EchoBothResponse) Equal added in v1.27.0 

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

func (*EchoBothResponse) GetMessage added in v1.27.0 

func (m *EchoBothResponse) GetMessage() string

func (*EchoBothResponse) GoString added in v1.27.0 

func (this *EchoBothResponse) GoString() string

func (*EchoBothResponse) Marshal added in v1.27.0 

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

func (*EchoBothResponse) MarshalTo added in v1.27.0 

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

func (*EchoBothResponse) ProtoMessage added in v1.27.0 

func (*EchoBothResponse) ProtoMessage()

func (*EchoBothResponse) Reset added in v1.27.0 

func (m *EchoBothResponse) Reset()

func (*EchoBothResponse) Size added in v1.27.0 

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

func (*EchoBothResponse) String added in v1.27.0 

func (this *EchoBothResponse) String() string

func (*EchoBothResponse) Unmarshal added in v1.27.0 

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

func (*EchoBothResponse) XXX_DiscardUnknown added in v1.32.0 

func (m *EchoBothResponse) XXX_DiscardUnknown()

func (*EchoBothResponse) XXX_Marshal added in v1.32.0 

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

func (*EchoBothResponse) XXX_Merge added in v1.32.0 

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

func (*EchoBothResponse) XXX_Size added in v1.32.0 

func (m *EchoBothResponse) XXX_Size() int

func (*EchoBothResponse) XXX_Unmarshal added in v1.32.0 

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

type EchoInRequest added in v1.27.0 

type EchoInRequest struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	NumResponses         int64    `protobuf:"varint,2,opt,name=num_responses,json=numResponses,proto3" json:"num_responses,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EchoInRequest) Descriptor added in v1.27.0 

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

func (*EchoInRequest) Equal added in v1.27.0 

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

func (*EchoInRequest) GetMessage added in v1.27.0 

func (m *EchoInRequest) GetMessage() string

func (*EchoInRequest) GetNumResponses added in v1.27.0 

func (m *EchoInRequest) GetNumResponses() int64

func (*EchoInRequest) GoString added in v1.27.0 

func (this *EchoInRequest) GoString() string

func (*EchoInRequest) Marshal added in v1.27.0 

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

func (*EchoInRequest) MarshalTo added in v1.27.0 

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

func (*EchoInRequest) ProtoMessage added in v1.27.0 

func (*EchoInRequest) ProtoMessage()

func (*EchoInRequest) Reset added in v1.27.0 

func (m *EchoInRequest) Reset()

func (*EchoInRequest) Size added in v1.27.0 

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

func (*EchoInRequest) String added in v1.27.0 

func (this *EchoInRequest) String() string

func (*EchoInRequest) Unmarshal added in v1.27.0 

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

func (*EchoInRequest) XXX_DiscardUnknown added in v1.32.0 

func (m *EchoInRequest) XXX_DiscardUnknown()

func (*EchoInRequest) XXX_Marshal added in v1.32.0 

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

func (*EchoInRequest) XXX_Merge added in v1.32.0 

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

func (*EchoInRequest) XXX_Size added in v1.32.0 

func (m *EchoInRequest) XXX_Size() int

func (*EchoInRequest) XXX_Unmarshal added in v1.32.0 

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

type EchoInResponse added in v1.27.0 

type EchoInResponse struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EchoInResponse) Descriptor added in v1.27.0 

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

func (*EchoInResponse) Equal added in v1.27.0 

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

func (*EchoInResponse) GetMessage added in v1.27.0 

func (m *EchoInResponse) GetMessage() string

func (*EchoInResponse) GoString added in v1.27.0 

func (this *EchoInResponse) GoString() string

func (*EchoInResponse) Marshal added in v1.27.0 

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

func (*EchoInResponse) MarshalTo added in v1.27.0 

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

func (*EchoInResponse) ProtoMessage added in v1.27.0 

func (*EchoInResponse) ProtoMessage()

func (*EchoInResponse) Reset added in v1.27.0 

func (m *EchoInResponse) Reset()

func (*EchoInResponse) Size added in v1.27.0 

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

func (*EchoInResponse) String added in v1.27.0 

func (this *EchoInResponse) String() string

func (*EchoInResponse) Unmarshal added in v1.27.0 

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

func (*EchoInResponse) XXX_DiscardUnknown added in v1.32.0 

func (m *EchoInResponse) XXX_DiscardUnknown()

func (*EchoInResponse) XXX_Marshal added in v1.32.0 

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

func (*EchoInResponse) XXX_Merge added in v1.32.0 

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

func (*EchoInResponse) XXX_Size added in v1.32.0 

func (m *EchoInResponse) XXX_Size() int

func (*EchoInResponse) XXX_Unmarshal added in v1.32.0 

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

type EchoOutRequest added in v1.27.0 

type EchoOutRequest struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EchoOutRequest) Descriptor added in v1.27.0 

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

func (*EchoOutRequest) Equal added in v1.27.0 

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

func (*EchoOutRequest) GetMessage added in v1.27.0 

func (m *EchoOutRequest) GetMessage() string

func (*EchoOutRequest) GoString added in v1.27.0 

func (this *EchoOutRequest) GoString() string

func (*EchoOutRequest) Marshal added in v1.27.0 

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

func (*EchoOutRequest) MarshalTo added in v1.27.0 

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

func (*EchoOutRequest) ProtoMessage added in v1.27.0 

func (*EchoOutRequest) ProtoMessage()

func (*EchoOutRequest) Reset added in v1.27.0 

func (m *EchoOutRequest) Reset()

func (*EchoOutRequest) Size added in v1.27.0 

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

func (*EchoOutRequest) String added in v1.27.0 

func (this *EchoOutRequest) String() string

func (*EchoOutRequest) Unmarshal added in v1.27.0 

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

func (*EchoOutRequest) XXX_DiscardUnknown added in v1.32.0 

func (m *EchoOutRequest) XXX_DiscardUnknown()

func (*EchoOutRequest) XXX_Marshal added in v1.32.0 

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

func (*EchoOutRequest) XXX_Merge added in v1.32.0 

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

func (*EchoOutRequest) XXX_Size added in v1.32.0 

func (m *EchoOutRequest) XXX_Size() int

func (*EchoOutRequest) XXX_Unmarshal added in v1.32.0 

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

type EchoOutResponse added in v1.27.0 

type EchoOutResponse struct {
	AllMessages          []string `protobuf:"bytes,2,rep,name=all_messages,json=allMessages" json:"all_messages,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EchoOutResponse) Descriptor added in v1.27.0 

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

func (*EchoOutResponse) Equal added in v1.27.0 

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

func (*EchoOutResponse) GetAllMessages added in v1.27.0 

func (m *EchoOutResponse) GetAllMessages() []string

func (*EchoOutResponse) GoString added in v1.27.0 

func (this *EchoOutResponse) GoString() string

func (*EchoOutResponse) Marshal added in v1.27.0 

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

func (*EchoOutResponse) MarshalTo added in v1.27.0 

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

func (*EchoOutResponse) ProtoMessage added in v1.27.0 

func (*EchoOutResponse) ProtoMessage()

func (*EchoOutResponse) Reset added in v1.27.0 

func (m *EchoOutResponse) Reset()

func (*EchoOutResponse) Size added in v1.27.0 

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

func (*EchoOutResponse) String added in v1.27.0 

func (this *EchoOutResponse) String() string

func (*EchoOutResponse) Unmarshal added in v1.27.0 

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

func (*EchoOutResponse) XXX_DiscardUnknown added in v1.32.0 

func (m *EchoOutResponse) XXX_DiscardUnknown()

func (*EchoOutResponse) XXX_Marshal added in v1.32.0 

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

func (*EchoOutResponse) XXX_Merge added in v1.32.0 

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

func (*EchoOutResponse) XXX_Size added in v1.32.0 

func (m *EchoOutResponse) XXX_Size() int

func (*EchoOutResponse) XXX_Unmarshal added in v1.32.0 

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

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 FooClient added in v1.27.0 

type FooClient interface {
	EchoOut(ctx context.Context, opts ...grpc.CallOption) (Foo_EchoOutClient, error)
	EchoIn(ctx context.Context, in *EchoInRequest, opts ...grpc.CallOption) (Foo_EchoInClient, error)
	EchoBoth(ctx context.Context, opts ...grpc.CallOption) (Foo_EchoBothClient, error)
}

func NewFooClient added in v1.27.0 

func NewFooClient(cc *grpc.ClientConn) FooClient

type FooServer added in v1.27.0 

type FooServer interface {
	EchoOut(Foo_EchoOutServer) error
	EchoIn(*EchoInRequest, Foo_EchoInServer) error
	EchoBoth(Foo_EchoBothServer) error
}

type FooServiceEchoBothYARPCClient added in v1.27.0 

type FooServiceEchoBothYARPCClient interface {
	Context() context.Context
	Send(*EchoBothRequest, ...yarpc.StreamOption) error
	Recv(...yarpc.StreamOption) (*EchoBothResponse, error)
	CloseSend(...yarpc.StreamOption) error
}

FooServiceEchoBothYARPCClient sends EchoBothRequests and receives EchoBothResponses, returning io.EOF when the stream is complete.

type FooServiceEchoBothYARPCServer added in v1.27.0 

type FooServiceEchoBothYARPCServer interface {
	Context() context.Context
	Recv(...yarpc.StreamOption) (*EchoBothRequest, error)
	Send(*EchoBothResponse, ...yarpc.StreamOption) error
}

FooServiceEchoBothYARPCServer receives EchoBothRequests and sends EchoBothResponse.

type FooServiceEchoInYARPCClient added in v1.27.0 

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

FooServiceEchoInYARPCClient receives EchoInResponses, returning io.EOF when the stream is complete.

type FooServiceEchoInYARPCServer added in v1.27.0 

type FooServiceEchoInYARPCServer interface {
	Context() context.Context
	Send(*EchoInResponse, ...yarpc.StreamOption) error
}

FooServiceEchoInYARPCServer sends EchoInResponses.

type FooServiceEchoOutYARPCClient added in v1.27.0 

type FooServiceEchoOutYARPCClient interface {
	Context() context.Context
	Send(*EchoOutRequest, ...yarpc.StreamOption) error
	CloseAndRecv(...yarpc.StreamOption) (*EchoOutResponse, error)
}

FooServiceEchoOutYARPCClient sends EchoOutRequests and receives the single EchoOutResponse when sending is done.

type FooServiceEchoOutYARPCServer added in v1.27.0 

type FooServiceEchoOutYARPCServer interface {
	Context() context.Context
	Recv(...yarpc.StreamOption) (*EchoOutRequest, error)
}

FooServiceEchoOutYARPCServer receives EchoOutRequests.

type FooYARPCClient added in v1.27.0 

type FooYARPCClient interface {
	EchoOut(context.Context, ...yarpc.CallOption) (FooServiceEchoOutYARPCClient, error)
	EchoIn(context.Context, *EchoInRequest, ...yarpc.CallOption) (FooServiceEchoInYARPCClient, error)
	EchoBoth(context.Context, ...yarpc.CallOption) (FooServiceEchoBothYARPCClient, error)
}

FooYARPCClient is the YARPC client-side interface for the Foo service.

func NewFooYARPCClient added in v1.27.0 

func NewFooYARPCClient(clientConfig transport.ClientConfig, options ...protobuf.ClientOption) FooYARPCClient

NewFooYARPCClient builds a new YARPC client for the Foo service.

type FooYARPCServer added in v1.27.0 

type FooYARPCServer interface {
	EchoOut(FooServiceEchoOutYARPCServer) (*EchoOutResponse, error)
	EchoIn(*EchoInRequest, FooServiceEchoInYARPCServer) error
	EchoBoth(FooServiceEchoBothYARPCServer) error
}

FooYARPCServer is the YARPC server-side interface for the Foo service.

type Foo_EchoBothClient added in v1.27.0 

type Foo_EchoBothClient interface {
	Send(*EchoBothRequest) error
	Recv() (*EchoBothResponse, error)
	grpc.ClientStream
}

type Foo_EchoBothServer added in v1.27.0 

type Foo_EchoBothServer interface {
	Send(*EchoBothResponse) error
	Recv() (*EchoBothRequest, error)
	grpc.ServerStream
}

type Foo_EchoInClient added in v1.27.0 

type Foo_EchoInClient interface {
	Recv() (*EchoInResponse, error)
	grpc.ClientStream
}

type Foo_EchoInServer added in v1.27.0 

type Foo_EchoInServer interface {
	Send(*EchoInResponse) error
	grpc.ServerStream
}

type Foo_EchoOutClient added in v1.27.0 

type Foo_EchoOutClient interface {
	Send(*EchoOutRequest) error
	CloseAndRecv() (*EchoOutResponse, error)
	grpc.ClientStream
}

type Foo_EchoOutServer added in v1.27.0 

type Foo_EchoOutServer interface {
	SendAndClose(*EchoOutResponse) error
	Recv() (*EchoOutRequest, error)
	grpc.ServerStream
}

type FxFooYARPCClientParams added in v1.29.0 

type FxFooYARPCClientParams struct {
	fx.In

	Provider yarpc.ClientConfig
}

FxFooYARPCClientParams defines the input for NewFxFooYARPCClient. It provides the paramaters to get a FooYARPCClient in an Fx application.

type FxFooYARPCClientResult added in v1.29.0 

type FxFooYARPCClientResult struct {
	fx.Out

	Client FooYARPCClient
}

FxFooYARPCClientResult defines the output of NewFxFooYARPCClient. It provides a FooYARPCClient to an Fx application.

type FxFooYARPCProceduresParams added in v1.29.0 

type FxFooYARPCProceduresParams struct {
	fx.In

	Server FooYARPCServer
}

FxFooYARPCProceduresParams defines the input for NewFxFooYARPCProcedures. It provides the paramaters to get FooYARPCServer procedures in an Fx application.

type FxFooYARPCProceduresResult added in v1.29.0 

type FxFooYARPCProceduresResult struct {
	fx.Out

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

FxFooYARPCProceduresResult defines the output of NewFxFooYARPCProcedures. It provides FooYARPCServer 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 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 added in v1.10.0 

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

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

NewKeyValueYARPCClient builds a new YARPC client for the KeyValue service.

type KeyValueYARPCServer added in v1.10.0 

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

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

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

NewSinkYARPCClient builds a new YARPC client for the Sink service.

type SinkYARPCServer added in v1.10.0 

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.