foopb

package
v0.5.0 Latest Latest
Warning

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

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

Documentation

Overview

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

RegisterHelloServiceHandlerClient 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             *types.Duration      `protobuf:"bytes,10,opt,name=duration" json:"duration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

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() *types.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_DiscardUnknown added in v0.5.0 

func (m *Another) XXX_DiscardUnknown()

func (*Another) XXX_Marshal added in v0.5.0 

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

func (*Another) XXX_Merge added in v0.5.0 

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

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.

func (*Another) XXX_Size added in v0.5.0 

func (m *Another) XXX_Size() int

func (*Another) XXX_Unmarshal added in v0.5.0 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*BarRequest) XXX_DiscardUnknown added in v0.5.0 

func (m *BarRequest) XXX_DiscardUnknown()

func (*BarRequest) XXX_Marshal added in v0.5.0 

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

func (*BarRequest) XXX_Merge added in v0.5.0 

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

func (*BarRequest) XXX_Size added in v0.5.0 

func (m *BarRequest) XXX_Size() int

func (*BarRequest) XXX_Unmarshal added in v0.5.0 

func (m *BarRequest) XXX_Unmarshal(b []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            *types.Timestamp `protobuf:"bytes,3,opt,name=timestamp" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

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() *types.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

func (*Barr) XXX_DiscardUnknown added in v0.5.0 

func (m *Barr) XXX_DiscardUnknown()

func (*Barr) XXX_Marshal added in v0.5.0 

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

func (*Barr) XXX_Merge added in v0.5.0 

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

func (*Barr) XXX_Size added in v0.5.0 

func (m *Barr) XXX_Size() int

func (*Barr) XXX_Unmarshal added in v0.5.0 

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

type Bazz 

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

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

func (*Bazz) XXX_DiscardUnknown added in v0.5.0 

func (m *Bazz) XXX_DiscardUnknown()

func (*Bazz) XXX_Marshal added in v0.5.0 

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

func (*Bazz) XXX_Merge added in v0.5.0 

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

func (*Bazz) XXX_Size added in v0.5.0 

func (m *Bazz) XXX_Size() int

func (*Bazz) XXX_Unmarshal added in v0.5.0 

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

type Dep 

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

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

func (*Dep) XXX_DiscardUnknown added in v0.5.0 

func (m *Dep) XXX_DiscardUnknown()

func (*Dep) XXX_Marshal added in v0.5.0 

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

func (*Dep) XXX_Merge added in v0.5.0 

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

func (*Dep) XXX_Size added in v0.5.0 

func (m *Dep) XXX_Size() int

func (*Dep) XXX_Unmarshal added in v0.5.0 

func (m *Dep) XXX_Unmarshal(b []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 

type ExcitedServiceYARPCClient interface {
	Exclamation(context.Context, *ExclamationRequest, ...yarpc.CallOption) (*ExclamationResponse, error)
	ExclamationClientStream(context.Context, ...yarpc.CallOption) (ExcitedServiceServiceExclamationClientStreamYARPCClient, error)
	ExclamationServerStream(context.Context, *ExclamationRequest, ...yarpc.CallOption) (ExcitedServiceServiceExclamationServerStreamYARPCClient, error)
	ExclamationBidiStream(context.Context, ...yarpc.CallOption) (ExcitedServiceServiceExclamationBidiStreamYARPCClient, error)
}

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 

type ExcitedServiceYARPCServer interface {
	Exclamation(context.Context, *ExclamationRequest) (*ExclamationResponse, error)
	ExclamationClientStream(ExcitedServiceServiceExclamationClientStreamYARPCServer) (*ExclamationResponse, error)
	ExclamationServerStream(*ExclamationRequest, ExcitedServiceServiceExclamationServerStreamYARPCServer) error
	ExclamationBidiStream(ExcitedServiceServiceExclamationBidiStreamYARPCServer) error
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ExclamationRequest) XXX_DiscardUnknown added in v0.5.0 

func (m *ExclamationRequest) XXX_DiscardUnknown()

func (*ExclamationRequest) XXX_Marshal added in v0.5.0 

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

func (*ExclamationRequest) XXX_Merge added in v0.5.0 

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

func (*ExclamationRequest) XXX_Size added in v0.5.0 

func (m *ExclamationRequest) XXX_Size() int

func (*ExclamationRequest) XXX_Unmarshal added in v0.5.0 

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

type ExclamationResponse 

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

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

func (*ExclamationResponse) XXX_DiscardUnknown added in v0.5.0 

func (m *ExclamationResponse) XXX_DiscardUnknown()

func (*ExclamationResponse) XXX_Marshal added in v0.5.0 

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

func (*ExclamationResponse) XXX_Merge added in v0.5.0 

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

func (*ExclamationResponse) XXX_Size added in v0.5.0 

func (m *ExclamationResponse) XXX_Size() int

func (*ExclamationResponse) XXX_Unmarshal added in v0.5.0 

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

type Foo 

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

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

func (*Foo) XXX_DiscardUnknown added in v0.5.0 

func (m *Foo) XXX_DiscardUnknown()

func (*Foo) XXX_Marshal added in v0.5.0 

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

func (*Foo) XXX_Merge added in v0.5.0 

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

func (*Foo) XXX_Size added in v0.5.0 

func (m *Foo) XXX_Size() int

func (*Foo) XXX_Unmarshal added in v0.5.0 

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

type FooResponse 

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

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

func (*FooResponse) XXX_DiscardUnknown added in v0.5.0 

func (m *FooResponse) XXX_DiscardUnknown()

func (*FooResponse) XXX_Marshal added in v0.5.0 

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

func (*FooResponse) XXX_Merge added in v0.5.0 

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

func (*FooResponse) XXX_Size added in v0.5.0 

func (m *FooResponse) XXX_Size() int

func (*FooResponse) XXX_Unmarshal added in v0.5.0 

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

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

func (*Foo_Bar) XXX_DiscardUnknown added in v0.5.0 

func (m *Foo_Bar) XXX_DiscardUnknown()

func (*Foo_Bar) XXX_Marshal added in v0.5.0 

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

func (*Foo_Bar) XXX_Merge added in v0.5.0 

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

func (*Foo_Bar) XXX_Size added in v0.5.0 

func (m *Foo_Bar) XXX_Size() int

func (*Foo_Bar) XXX_Unmarshal added in v0.5.0 

func (m *Foo_Bar) XXX_Unmarshal(b []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             *types.Duration `protobuf:"bytes,1,opt,name=duration" json:"duration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

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() *types.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

func (*HasWKT) XXX_DiscardUnknown added in v0.5.0 

func (m *HasWKT) XXX_DiscardUnknown()

func (*HasWKT) XXX_Marshal added in v0.5.0 

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

func (*HasWKT) XXX_Merge added in v0.5.0 

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

func (*HasWKT) XXX_Size added in v0.5.0 

func (m *HasWKT) XXX_Size() int

func (*HasWKT) XXX_Unmarshal added in v0.5.0 

func (m *HasWKT) XXX_Unmarshal(b []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.

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.