examplepb

package
v1.14.0 Latest Latest
Warning

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

Go to latest
Published: Sep 8, 2017 License: MIT Imports: 13 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

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

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

func RegisterSinkServer

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

Types

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

Jump to

Keyboard shortcuts

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