foopb

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: May 29, 2018 License: MIT Imports: 26 Imported by: 0

Documentation

Overview

Package foopb is a generated protocol buffer package.

It is generated from these files:

foo/dep.proto
foo/foo.proto

It has these top-level messages:

Dep
Foo
Barr
Another
HasWKT
Bazz
BarRequest
FooResponse
ExclamationRequest
ExclamationResponse

Package foopb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

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 (
	ErrInvalidLengthFoo = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFoo   = fmt.Errorf("proto: integer overflow")
)
View Source
var Bar_name = map[int32]string{
	0: "BAR_INVALID",
}
View Source
var Bar_value = map[string]int32{
	"BAR_INVALID": 0,
}
View Source
var Foo_Bar_Bat_name = map[int32]string{
	0: "FOO_BAR_BAT_INVALID",
}
View Source
var Foo_Bar_Bat_value = map[string]int32{
	"FOO_BAR_BAT_INVALID": 0,
}
View Source
var Foo_Bar_Baz_name = map[int32]string{
	0: "FOO_BAR_BAZ_INVALID",
}
View Source
var Foo_Bar_Baz_value = map[string]int32{
	"FOO_BAR_BAZ_INVALID": 0,
}
View Source
var Hello_name = map[int32]string{
	0: "HELLO_INVALID",
	1: "HELLO_UNSET",
	2: "HELLO_TREE",
	3: "HELLO_BALLOON",
}
View Source
var Hello_value = map[string]int32{
	"HELLO_INVALID": 0,
	"HELLO_UNSET":   1,
	"HELLO_TREE":    2,
	"HELLO_BALLOON": 3,
}

Functions

func BuildExcitedServiceYARPCProcedures

func BuildExcitedServiceYARPCProcedures(server ExcitedServiceYARPCServer) []transport.Procedure

BuildExcitedServiceYARPCProcedures prepares an implementation of the ExcitedService service for YARPC registration.

func BuildHelloServiceYARPCProcedures

func BuildHelloServiceYARPCProcedures(server HelloServiceYARPCServer) []transport.Procedure

BuildHelloServiceYARPCProcedures prepares an implementation of the HelloService service for YARPC registration.

func NewFxExcitedServiceYARPCClient

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

NewFxExcitedServiceYARPCClient provides a ExcitedServiceYARPCClient to an Fx application using the given name for routing.

fx.Provide(
  foopb.NewFxExcitedServiceYARPCClient("service-name"),
  ...
)

func NewFxExcitedServiceYARPCProcedures

func NewFxExcitedServiceYARPCProcedures() interface{}

NewFxExcitedServiceYARPCProcedures provides ExcitedServiceYARPCServer procedures to an Fx application. It expects a ExcitedServiceYARPCServer to be present in the container.

fx.Provide(
  foopb.NewFxExcitedServiceYARPCProcedures(),
  ...
)

func NewFxHelloServiceYARPCClient

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

NewFxHelloServiceYARPCClient provides a HelloServiceYARPCClient to an Fx application using the given name for routing.

fx.Provide(
  foopb.NewFxHelloServiceYARPCClient("service-name"),
  ...
)

func NewFxHelloServiceYARPCProcedures

func NewFxHelloServiceYARPCProcedures() interface{}

NewFxHelloServiceYARPCProcedures provides HelloServiceYARPCServer procedures to an Fx application. It expects a HelloServiceYARPCServer to be present in the container.

fx.Provide(
  foopb.NewFxHelloServiceYARPCProcedures(),
  ...
)

func RegisterExcitedServiceServer

func RegisterExcitedServiceServer(s *grpc.Server, srv ExcitedServiceServer)

func RegisterHelloServiceHandler

func RegisterHelloServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterHelloServiceHandler registers the http handlers for service HelloService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterHelloServiceHandlerClient

func RegisterHelloServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client HelloServiceClient) error

RegisterHelloServiceHandler registers the http handlers for service HelloService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "HelloServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "HelloServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "HelloServiceClient" to call the correct interceptors.

func RegisterHelloServiceHandlerFromEndpoint

func RegisterHelloServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterHelloServiceHandlerFromEndpoint is same as RegisterHelloServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterHelloServiceServer

func RegisterHelloServiceServer(s *grpc.Server, srv HelloServiceServer)

Types

type Another

type Another struct {
	One     int64            `protobuf:"varint,1,opt,name=one,proto3" json:"one,omitempty"`
	Two     string           `protobuf:"bytes,2,opt,name=two,proto3" json:"two,omitempty"`
	Another *Another         `protobuf:"bytes,3,opt,name=another" json:"another,omitempty"`
	Four    []string         `protobuf:"bytes,4,rep,name=four" json:"four,omitempty"`
	Hello   Hello            `protobuf:"varint,5,opt,name=hello,proto3,enum=foo.Hello" json:"hello,omitempty"`
	M       map[string]int64 `` /* 137-byte string literal not displayed */
	// Types that are valid to be assigned to OneofOneof:
	//	*Another_Seven
	//	*Another_Eight
	OneofOneof isAnother_OneofOneof      `protobuf_oneof:"oneof_oneof"`
	Nine       []*Another                `protobuf:"bytes,9,rep,name=nine" json:"nine,omitempty"`
	Duration   *google_protobuf.Duration `protobuf:"bytes,10,opt,name=duration" json:"duration,omitempty"`
}

Another is another message.

func (*Another) Descriptor

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

func (*Another) Equal

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

func (*Another) GetAnother

func (m *Another) GetAnother() *Another

func (*Another) GetDuration

func (m *Another) GetDuration() *google_protobuf.Duration

func (*Another) GetEight

func (m *Another) GetEight() string

func (*Another) GetFour

func (m *Another) GetFour() []string

func (*Another) GetHello

func (m *Another) GetHello() Hello

func (*Another) GetM

func (m *Another) GetM() map[string]int64

func (*Another) GetNine

func (m *Another) GetNine() []*Another

func (*Another) GetOne

func (m *Another) GetOne() int64

func (*Another) GetOneofOneof

func (m *Another) GetOneofOneof() isAnother_OneofOneof

func (*Another) GetSeven

func (m *Another) GetSeven() int64

func (*Another) GetTwo

func (m *Another) GetTwo() string

func (*Another) GoString

func (this *Another) GoString() string

func (*Another) Marshal

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

func (*Another) MarshalTo

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

func (*Another) ProtoMessage

func (*Another) ProtoMessage()

func (*Another) Reset

func (m *Another) Reset()

func (*Another) Size

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

func (*Another) String

func (this *Another) String() string

func (*Another) Unmarshal

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

func (*Another) XXX_OneofFuncs

func (*Another) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type Another_Eight

type Another_Eight struct {
	Eight string `protobuf:"bytes,8,opt,name=eight,proto3,oneof"`
}

func (*Another_Eight) Equal

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

func (*Another_Eight) GoString

func (this *Another_Eight) GoString() string

func (*Another_Eight) MarshalTo

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

func (*Another_Eight) Size

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

func (*Another_Eight) String

func (this *Another_Eight) String() string

type Another_Seven

type Another_Seven struct {
	Seven int64 `protobuf:"varint,7,opt,name=seven,proto3,oneof"`
}

func (*Another_Seven) Equal

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

func (*Another_Seven) GoString

func (this *Another_Seven) GoString() string

func (*Another_Seven) MarshalTo

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

func (*Another_Seven) Size

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

func (*Another_Seven) String

func (this *Another_Seven) String() string

type Bar

type Bar int32

Bar is a bar.

const (
	BAR_INVALID Bar = 0
)

func (Bar) EnumDescriptor

func (Bar) EnumDescriptor() ([]byte, []int)

func (Bar) String

func (x Bar) String() string

type BarRequest

type BarRequest struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

BarRequest is a bar request.

func (*BarRequest) Descriptor

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

func (*BarRequest) Equal

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

func (*BarRequest) GetId

func (m *BarRequest) GetId() int64

func (*BarRequest) GoString

func (this *BarRequest) GoString() string

func (*BarRequest) Marshal

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

func (*BarRequest) MarshalTo

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

func (*BarRequest) ProtoMessage

func (*BarRequest) ProtoMessage()

func (*BarRequest) Reset

func (m *BarRequest) Reset()

func (*BarRequest) Size

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

func (*BarRequest) String

func (this *BarRequest) String() string

func (*BarRequest) Unmarshal

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

type Barr

type Barr struct {
	Hello     int64                       `protobuf:"varint,1,opt,name=hello,proto3" json:"hello,omitempty"`
	Dep       *Dep                        `protobuf:"bytes,2,opt,name=dep" json:"dep,omitempty"`
	Timestamp *google_protobuf1.Timestamp `protobuf:"bytes,3,opt,name=timestamp" json:"timestamp,omitempty"`
}

Barr is a barr.

func (*Barr) Descriptor

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

func (*Barr) Equal

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

func (*Barr) GetDep

func (m *Barr) GetDep() *Dep

func (*Barr) GetHello

func (m *Barr) GetHello() int64

func (*Barr) GetTimestamp

func (m *Barr) GetTimestamp() *google_protobuf1.Timestamp

func (*Barr) GoString

func (this *Barr) GoString() string

func (*Barr) Marshal

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

func (*Barr) MarshalTo

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

func (*Barr) ProtoMessage

func (*Barr) ProtoMessage()

func (*Barr) Reset

func (m *Barr) Reset()

func (*Barr) Size

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

func (*Barr) String

func (this *Barr) String() string

func (*Barr) Unmarshal

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

type Bazz

type Bazz struct {
}

Bazz is a bazzzz.

func (*Bazz) Descriptor

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

func (*Bazz) Equal

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

func (*Bazz) GoString

func (this *Bazz) GoString() string

func (*Bazz) Marshal

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

func (*Bazz) MarshalTo

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

func (*Bazz) ProtoMessage

func (*Bazz) ProtoMessage()

func (*Bazz) Reset

func (m *Bazz) Reset()

func (*Bazz) Size

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

func (*Bazz) String

func (this *Bazz) String() string

func (*Bazz) Unmarshal

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

type Dep

type Dep struct {
	Hello int64 `protobuf:"varint,1,opt,name=hello,proto3" json:"hello,omitempty"`
}

Dep is a dep.

func (*Dep) Descriptor

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

func (*Dep) Equal

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

func (*Dep) GetHello

func (m *Dep) GetHello() int64

func (*Dep) GoString

func (this *Dep) GoString() string

func (*Dep) Marshal

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

func (*Dep) MarshalTo

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

func (*Dep) ProtoMessage

func (*Dep) ProtoMessage()

func (*Dep) Reset

func (m *Dep) Reset()

func (*Dep) Size

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

func (*Dep) String

func (this *Dep) String() string

func (*Dep) Unmarshal

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

type ExcitedServiceClient

type ExcitedServiceClient interface {
	// Exclamation adds an exclamation to the request value.
	Exclamation(ctx context.Context, in *ExclamationRequest, opts ...grpc.CallOption) (*ExclamationResponse, error)
	// ExclamationClientStream adds an exclamation to the combined request values.
	ExclamationClientStream(ctx context.Context, opts ...grpc.CallOption) (ExcitedService_ExclamationClientStreamClient, error)
	// ExclamationServerStream adds an exclamation to the request value
	// and streams each character as a response.
	ExclamationServerStream(ctx context.Context, in *ExclamationRequest, opts ...grpc.CallOption) (ExcitedService_ExclamationServerStreamClient, error)
	// ExclamationBidiStream adds an exclamation to the each request value.
	ExclamationBidiStream(ctx context.Context, opts ...grpc.CallOption) (ExcitedService_ExclamationBidiStreamClient, error)
}

func NewExcitedServiceClient

func NewExcitedServiceClient(cc *grpc.ClientConn) ExcitedServiceClient

type ExcitedServiceServer

type ExcitedServiceServer interface {
	// Exclamation adds an exclamation to the request value.
	Exclamation(context.Context, *ExclamationRequest) (*ExclamationResponse, error)
	// ExclamationClientStream adds an exclamation to the combined request values.
	ExclamationClientStream(ExcitedService_ExclamationClientStreamServer) error
	// ExclamationServerStream adds an exclamation to the request value
	// and streams each character as a response.
	ExclamationServerStream(*ExclamationRequest, ExcitedService_ExclamationServerStreamServer) error
	// ExclamationBidiStream adds an exclamation to the each request value.
	ExclamationBidiStream(ExcitedService_ExclamationBidiStreamServer) error
}

type ExcitedServiceServiceExclamationBidiStreamYARPCClient

type ExcitedServiceServiceExclamationBidiStreamYARPCClient interface {
	Context() context.Context
	Send(*ExclamationRequest, ...yarpc.StreamOption) error
	Recv(...yarpc.StreamOption) (*ExclamationResponse, error)
	CloseSend(...yarpc.StreamOption) error
}

ExcitedServiceServiceExclamationBidiStreamYARPCClient sends ExclamationRequests and receives ExclamationResponses, returning io.EOF when the stream is complete.

type ExcitedServiceServiceExclamationBidiStreamYARPCServer

type ExcitedServiceServiceExclamationBidiStreamYARPCServer interface {
	Context() context.Context
	Recv(...yarpc.StreamOption) (*ExclamationRequest, error)
	Send(*ExclamationResponse, ...yarpc.StreamOption) error
}

ExcitedServiceServiceExclamationBidiStreamYARPCServer receives ExclamationRequests and sends ExclamationResponse.

type ExcitedServiceServiceExclamationClientStreamYARPCClient

type ExcitedServiceServiceExclamationClientStreamYARPCClient interface {
	Context() context.Context
	Send(*ExclamationRequest, ...yarpc.StreamOption) error
	CloseAndRecv(...yarpc.StreamOption) (*ExclamationResponse, error)
}

ExcitedServiceServiceExclamationClientStreamYARPCClient sends ExclamationRequests and receives the single ExclamationResponse when sending is done.

type ExcitedServiceServiceExclamationClientStreamYARPCServer

type ExcitedServiceServiceExclamationClientStreamYARPCServer interface {
	Context() context.Context
	Recv(...yarpc.StreamOption) (*ExclamationRequest, error)
}

ExcitedServiceServiceExclamationClientStreamYARPCServer receives ExclamationRequests.

type ExcitedServiceServiceExclamationServerStreamYARPCClient

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

ExcitedServiceServiceExclamationServerStreamYARPCClient receives ExclamationResponses, returning io.EOF when the stream is complete.

type ExcitedServiceServiceExclamationServerStreamYARPCServer

type ExcitedServiceServiceExclamationServerStreamYARPCServer interface {
	Context() context.Context
	Send(*ExclamationResponse, ...yarpc.StreamOption) error
}

ExcitedServiceServiceExclamationServerStreamYARPCServer sends ExclamationResponses.

type ExcitedServiceYARPCClient

ExcitedServiceYARPCClient is the YARPC client-side interface for the ExcitedService service.

func NewExcitedServiceYARPCClient

func NewExcitedServiceYARPCClient(clientConfig transport.ClientConfig, options ...protobuf.ClientOption) ExcitedServiceYARPCClient

NewExcitedServiceYARPCClient builds a new YARPC client for the ExcitedService service.

type ExcitedServiceYARPCServer

ExcitedServiceYARPCServer is the YARPC server-side interface for the ExcitedService service.

type ExcitedService_ExclamationBidiStreamClient

type ExcitedService_ExclamationBidiStreamClient interface {
	Send(*ExclamationRequest) error
	Recv() (*ExclamationResponse, error)
	grpc.ClientStream
}

type ExcitedService_ExclamationBidiStreamServer

type ExcitedService_ExclamationBidiStreamServer interface {
	Send(*ExclamationResponse) error
	Recv() (*ExclamationRequest, error)
	grpc.ServerStream
}

type ExcitedService_ExclamationClientStreamClient

type ExcitedService_ExclamationClientStreamClient interface {
	Send(*ExclamationRequest) error
	CloseAndRecv() (*ExclamationResponse, error)
	grpc.ClientStream
}

type ExcitedService_ExclamationClientStreamServer

type ExcitedService_ExclamationClientStreamServer interface {
	SendAndClose(*ExclamationResponse) error
	Recv() (*ExclamationRequest, error)
	grpc.ServerStream
}

type ExcitedService_ExclamationServerStreamClient

type ExcitedService_ExclamationServerStreamClient interface {
	Recv() (*ExclamationResponse, error)
	grpc.ClientStream
}

type ExcitedService_ExclamationServerStreamServer

type ExcitedService_ExclamationServerStreamServer interface {
	Send(*ExclamationResponse) error
	grpc.ServerStream
}

type ExclamationRequest

type ExclamationRequest struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*ExclamationRequest) Descriptor

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

func (*ExclamationRequest) Equal

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

func (*ExclamationRequest) GetValue

func (m *ExclamationRequest) GetValue() string

func (*ExclamationRequest) GoString

func (this *ExclamationRequest) GoString() string

func (*ExclamationRequest) Marshal

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

func (*ExclamationRequest) MarshalTo

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

func (*ExclamationRequest) ProtoMessage

func (*ExclamationRequest) ProtoMessage()

func (*ExclamationRequest) Reset

func (m *ExclamationRequest) Reset()

func (*ExclamationRequest) Size

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

func (*ExclamationRequest) String

func (this *ExclamationRequest) String() string

func (*ExclamationRequest) Unmarshal

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

type ExclamationResponse

type ExclamationResponse struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*ExclamationResponse) Descriptor

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

func (*ExclamationResponse) Equal

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

func (*ExclamationResponse) GetValue

func (m *ExclamationResponse) GetValue() string

func (*ExclamationResponse) GoString

func (this *ExclamationResponse) GoString() string

func (*ExclamationResponse) Marshal

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

func (*ExclamationResponse) MarshalTo

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

func (*ExclamationResponse) ProtoMessage

func (*ExclamationResponse) ProtoMessage()

func (*ExclamationResponse) Reset

func (m *ExclamationResponse) Reset()

func (*ExclamationResponse) Size

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

func (*ExclamationResponse) String

func (this *ExclamationResponse) String() string

func (*ExclamationResponse) Unmarshal

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

type Foo

type Foo struct {
	Bar *Foo_Bar `protobuf:"bytes,1,opt,name=bar" json:"bar,omitempty"`
}

Foo is a foo.

func (*Foo) Descriptor

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

func (*Foo) Equal

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

func (*Foo) GetBar

func (m *Foo) GetBar() *Foo_Bar

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

type FooResponse

type FooResponse struct {
	Dep *Dep `protobuf:"bytes,1,opt,name=dep" json:"dep,omitempty"`
}

FooResponse is an foo response.

func (*FooResponse) Descriptor

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

func (*FooResponse) Equal

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

func (*FooResponse) GetDep

func (m *FooResponse) GetDep() *Dep

func (*FooResponse) GoString

func (this *FooResponse) GoString() string

func (*FooResponse) Marshal

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

func (*FooResponse) MarshalTo

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

func (*FooResponse) ProtoMessage

func (*FooResponse) ProtoMessage()

func (*FooResponse) Reset

func (m *FooResponse) Reset()

func (*FooResponse) Size

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

func (*FooResponse) String

func (this *FooResponse) String() string

func (*FooResponse) Unmarshal

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

type Foo_Bar

type Foo_Bar struct {
	Baz Foo_Bar_Baz `protobuf:"varint,1,opt,name=baz,proto3,enum=foo.Foo_Bar_Baz" json:"baz,omitempty"`
	Bat Foo_Bar_Bat `protobuf:"varint,2,opt,name=bat,proto3,enum=foo.Foo_Bar_Bat" json:"bat,omitempty"`
}

Bar is a bar.

func (*Foo_Bar) Descriptor

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

func (*Foo_Bar) Equal

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

func (*Foo_Bar) GetBat

func (m *Foo_Bar) GetBat() Foo_Bar_Bat

func (*Foo_Bar) GetBaz

func (m *Foo_Bar) GetBaz() Foo_Bar_Baz

func (*Foo_Bar) GoString

func (this *Foo_Bar) GoString() string

func (*Foo_Bar) Marshal

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

func (*Foo_Bar) MarshalTo

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

func (*Foo_Bar) ProtoMessage

func (*Foo_Bar) ProtoMessage()

func (*Foo_Bar) Reset

func (m *Foo_Bar) Reset()

func (*Foo_Bar) Size

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

func (*Foo_Bar) String

func (this *Foo_Bar) String() string

func (*Foo_Bar) Unmarshal

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

type Foo_Bar_Bat

type Foo_Bar_Bat int32

Bat is a bat.

const (
	FOO_BAR_BAT_INVALID Foo_Bar_Bat = 0
)

func (Foo_Bar_Bat) EnumDescriptor

func (Foo_Bar_Bat) EnumDescriptor() ([]byte, []int)

func (Foo_Bar_Bat) String

func (x Foo_Bar_Bat) String() string

type Foo_Bar_Baz

type Foo_Bar_Baz int32

Baz is a baz.

const (
	FOO_BAR_BAZ_INVALID Foo_Bar_Baz = 0
)

func (Foo_Bar_Baz) EnumDescriptor

func (Foo_Bar_Baz) EnumDescriptor() ([]byte, []int)

func (Foo_Bar_Baz) String

func (x Foo_Bar_Baz) String() string

type FxExcitedServiceYARPCClientParams

type FxExcitedServiceYARPCClientParams struct {
	fx.In

	Provider yarpc.ClientConfig
}

FxExcitedServiceYARPCClientParams defines the input for NewFxExcitedServiceYARPCClient. It provides the paramaters to get a ExcitedServiceYARPCClient in an Fx application.

type FxExcitedServiceYARPCClientResult

type FxExcitedServiceYARPCClientResult struct {
	fx.Out

	Client ExcitedServiceYARPCClient
}

FxExcitedServiceYARPCClientResult defines the output of NewFxExcitedServiceYARPCClient. It provides a ExcitedServiceYARPCClient to an Fx application.

type FxExcitedServiceYARPCProceduresParams

type FxExcitedServiceYARPCProceduresParams struct {
	fx.In

	Server ExcitedServiceYARPCServer
}

FxExcitedServiceYARPCProceduresParams defines the input for NewFxExcitedServiceYARPCProcedures. It provides the paramaters to get ExcitedServiceYARPCServer procedures in an Fx application.

type FxExcitedServiceYARPCProceduresResult

type FxExcitedServiceYARPCProceduresResult struct {
	fx.Out

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

FxExcitedServiceYARPCProceduresResult defines the output of NewFxExcitedServiceYARPCProcedures. It provides ExcitedServiceYARPCServer 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 FxHelloServiceYARPCClientParams

type FxHelloServiceYARPCClientParams struct {
	fx.In

	Provider yarpc.ClientConfig
}

FxHelloServiceYARPCClientParams defines the input for NewFxHelloServiceYARPCClient. It provides the paramaters to get a HelloServiceYARPCClient in an Fx application.

type FxHelloServiceYARPCClientResult

type FxHelloServiceYARPCClientResult struct {
	fx.Out

	Client HelloServiceYARPCClient
}

FxHelloServiceYARPCClientResult defines the output of NewFxHelloServiceYARPCClient. It provides a HelloServiceYARPCClient to an Fx application.

type FxHelloServiceYARPCProceduresParams

type FxHelloServiceYARPCProceduresParams struct {
	fx.In

	Server HelloServiceYARPCServer
}

FxHelloServiceYARPCProceduresParams defines the input for NewFxHelloServiceYARPCProcedures. It provides the paramaters to get HelloServiceYARPCServer procedures in an Fx application.

type FxHelloServiceYARPCProceduresResult

type FxHelloServiceYARPCProceduresResult struct {
	fx.Out

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

FxHelloServiceYARPCProceduresResult defines the output of NewFxHelloServiceYARPCProcedures. It provides HelloServiceYARPCServer 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 HasWKT

type HasWKT struct {
	Duration *google_protobuf.Duration `protobuf:"bytes,1,opt,name=duration" json:"duration,omitempty"`
}

HasWKT has Well-Known Types.

func (*HasWKT) Descriptor

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

func (*HasWKT) Equal

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

func (*HasWKT) GetDuration

func (m *HasWKT) GetDuration() *google_protobuf.Duration

func (*HasWKT) GoString

func (this *HasWKT) GoString() string

func (*HasWKT) Marshal

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

func (*HasWKT) MarshalTo

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

func (*HasWKT) ProtoMessage

func (*HasWKT) ProtoMessage()

func (*HasWKT) Reset

func (m *HasWKT) Reset()

func (*HasWKT) Size

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

func (*HasWKT) String

func (this *HasWKT) String() string

func (*HasWKT) Unmarshal

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

type Hello

type Hello int32

Hello is a hello.

const (
	HELLO_INVALID Hello = 0
	HELLO_UNSET   Hello = 1
	HELLO_TREE    Hello = 2
	HELLO_BALLOON Hello = 3
)

func (Hello) EnumDescriptor

func (Hello) EnumDescriptor() ([]byte, []int)

func (Hello) String

func (x Hello) String() string

type HelloServiceClient

type HelloServiceClient interface {
	// Foo does a foo.
	Foo(ctx context.Context, in *sub.Dep, opts ...grpc.CallOption) (*FooResponse, error)
	// Bar does a bar.
	Bar(ctx context.Context, in *BarRequest, opts ...grpc.CallOption) (*Dep, error)
}

func NewHelloServiceClient

func NewHelloServiceClient(cc *grpc.ClientConn) HelloServiceClient

type HelloServiceServer

type HelloServiceServer interface {
	// Foo does a foo.
	Foo(context.Context, *sub.Dep) (*FooResponse, error)
	// Bar does a bar.
	Bar(context.Context, *BarRequest) (*Dep, error)
}

type HelloServiceYARPCClient

type HelloServiceYARPCClient interface {
	Foo(context.Context, *subpb.Dep, ...yarpc.CallOption) (*FooResponse, error)
	Bar(context.Context, *BarRequest, ...yarpc.CallOption) (*Dep, error)
}

HelloServiceYARPCClient is the YARPC client-side interface for the HelloService service.

func NewHelloServiceYARPCClient

func NewHelloServiceYARPCClient(clientConfig transport.ClientConfig, options ...protobuf.ClientOption) HelloServiceYARPCClient

NewHelloServiceYARPCClient builds a new YARPC client for the HelloService service.

type HelloServiceYARPCServer

type HelloServiceYARPCServer interface {
	Foo(context.Context, *subpb.Dep) (*FooResponse, error)
	Bar(context.Context, *BarRequest) (*Dep, error)
}

HelloServiceYARPCServer is the YARPC server-side interface for the HelloService service.

Jump to

Keyboard shortcuts

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