examplepb

package
v1.27.0 Latest Latest
Warning

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

 Go to latest Published: Jan 22, 2018 License: MIT Imports: 14 Imported by: 0

Documentation

Overview

Package examplepb is a generated protocol buffer package.

It is generated from these files: 

internal/examples/protobuf/examplepb/example.proto

It has these top-level messages: 

GetValueRequest
GetValueResponse
SetValueRequest
SetValueResponse
FireRequest
EchoOutRequest
EchoOutResponse
EchoInRequest
EchoInResponse
EchoBothRequest
EchoBothResponse

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 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"`
}

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

type EchoBothResponse added in v1.27.0 

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

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

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"`
}

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

type EchoInResponse added in v1.27.0 

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

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

type EchoOutRequest added in v1.27.0 

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

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

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"`
}

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

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 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 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 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"`
}

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 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.