examplepb

package
v1.7.0 Latest Latest
Warning

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

 Go to latest Published: Jan 23, 2019 License: BSD-3-Clause Imports: 22 Imported by: 0

Documentation

Overview

Package examplepb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package examplepb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package examplepb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package examplepb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package examplepb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package examplepb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package examplepb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var ABitOfEverything_Nested_DeepEnum_name = map[int32]string{
	0: "FALSE",
	1: "TRUE",
}
View Source 
var ABitOfEverything_Nested_DeepEnum_value = map[string]int32{
	"FALSE": 0,
	"TRUE":  1,
}
View Source 
var NumericEnum_name = map[int32]string{
	0: "ZERO",
	1: "ONE",
}
View Source 
var NumericEnum_value = map[string]int32{
	"ZERO": 0,
	"ONE":  1,
}
View Source 
var RepeatedResponseBodyOut_Response_ResponseType_name = map[int32]string{
	0: "UNKNOWN",
	1: "A",
	2: "B",
}
View Source 
var RepeatedResponseBodyOut_Response_ResponseType_value = map[string]int32{
	"UNKNOWN": 0,
	"A":       1,
	"B":       2,
}

Functions

func RegisterABitOfEverythingServiceHandler 

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

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

func RegisterABitOfEverythingServiceHandlerClient 

func RegisterABitOfEverythingServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ABitOfEverythingServiceClient) error

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

func RegisterABitOfEverythingServiceHandlerFromEndpoint 

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

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

func RegisterABitOfEverythingServiceServer 

func RegisterABitOfEverythingServiceServer(s *grpc.Server, srv ABitOfEverythingServiceServer)

func RegisterAnotherServiceWithNoBindingsServer 

func RegisterAnotherServiceWithNoBindingsServer(s *grpc.Server, srv AnotherServiceWithNoBindingsServer)

func RegisterCamelCaseServiceNameHandler 

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

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

func RegisterCamelCaseServiceNameHandlerClient 

func RegisterCamelCaseServiceNameHandlerClient(ctx context.Context, mux *runtime.ServeMux, client CamelCaseServiceNameClient) error

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

func RegisterCamelCaseServiceNameHandlerFromEndpoint 

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

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

func RegisterCamelCaseServiceNameServer 

func RegisterCamelCaseServiceNameServer(s *grpc.Server, srv CamelCaseServiceNameServer)

func RegisterEchoServiceHandler 

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

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

func RegisterEchoServiceHandlerClient 

func RegisterEchoServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EchoServiceClient) error

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

func RegisterEchoServiceHandlerFromEndpoint 

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

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

func RegisterEchoServiceServer 

func RegisterEchoServiceServer(s *grpc.Server, srv EchoServiceServer)

func RegisterFlowCombinationHandler 

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

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

func RegisterFlowCombinationHandlerClient 

func RegisterFlowCombinationHandlerClient(ctx context.Context, mux *runtime.ServeMux, client FlowCombinationClient) error

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

func RegisterFlowCombinationHandlerFromEndpoint 

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

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

func RegisterFlowCombinationServer 

func RegisterFlowCombinationServer(s *grpc.Server, srv FlowCombinationServer)

func RegisterResponseBodyServiceHandler 

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

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

func RegisterResponseBodyServiceHandlerClient 

func RegisterResponseBodyServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ResponseBodyServiceClient) error

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

func RegisterResponseBodyServiceHandlerFromEndpoint 

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

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

func RegisterResponseBodyServiceServer 

func RegisterResponseBodyServiceServer(s *grpc.Server, srv ResponseBodyServiceServer)

func RegisterStreamServiceHandler 

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

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

func RegisterStreamServiceHandlerClient 

func RegisterStreamServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client StreamServiceClient) error

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

func RegisterStreamServiceHandlerFromEndpoint 

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

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

func RegisterStreamServiceServer 

func RegisterStreamServiceServer(s *grpc.Server, srv StreamServiceServer)

func RegisterUnannotatedEchoServiceHandler 

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

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

func RegisterUnannotatedEchoServiceHandlerClient 

func RegisterUnannotatedEchoServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client UnannotatedEchoServiceClient) error

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

func RegisterUnannotatedEchoServiceHandlerFromEndpoint 

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

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

func RegisterUnannotatedEchoServiceServer 

func RegisterUnannotatedEchoServiceServer(s *grpc.Server, srv UnannotatedEchoServiceServer)

func RegisterWrappersServiceHandler 

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

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

func RegisterWrappersServiceHandlerClient 

func RegisterWrappersServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WrappersServiceClient) error

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

func RegisterWrappersServiceHandlerFromEndpoint 

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

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

func RegisterWrappersServiceServer 

func RegisterWrappersServiceServer(s *grpc.Server, srv WrappersServiceServer)

Types

type ABitOfEverything 

type ABitOfEverything struct {
	SingleNested        *ABitOfEverything_Nested                `protobuf:"bytes,25,opt,name=single_nested,json=singleNested,proto3" json:"single_nested,omitempty"`
	Uuid                string                                  `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Nested              []*ABitOfEverything_Nested              `protobuf:"bytes,2,rep,name=nested,proto3" json:"nested,omitempty"`
	FloatValue          float32                                 `protobuf:"fixed32,3,opt,name=float_value,json=floatValue,proto3" json:"float_value,omitempty"`
	DoubleValue         float64                                 `protobuf:"fixed64,4,opt,name=double_value,json=doubleValue,proto3" json:"double_value,omitempty"`
	Int64Value          int64                                   `protobuf:"varint,5,opt,name=int64_value,json=int64Value,proto3" json:"int64_value,omitempty"`
	Uint64Value         uint64                                  `protobuf:"varint,6,opt,name=uint64_value,json=uint64Value,proto3" json:"uint64_value,omitempty"`
	Int32Value          int32                                   `protobuf:"varint,7,opt,name=int32_value,json=int32Value,proto3" json:"int32_value,omitempty"`
	Fixed64Value        uint64                                  `protobuf:"fixed64,8,opt,name=fixed64_value,json=fixed64Value,proto3" json:"fixed64_value,omitempty"`
	Fixed32Value        uint32                                  `protobuf:"fixed32,9,opt,name=fixed32_value,json=fixed32Value,proto3" json:"fixed32_value,omitempty"`
	BoolValue           bool                                    `protobuf:"varint,10,opt,name=bool_value,json=boolValue,proto3" json:"bool_value,omitempty"`
	StringValue         string                                  `protobuf:"bytes,11,opt,name=string_value,json=stringValue,proto3" json:"string_value,omitempty"`
	BytesValue          []byte                                  `protobuf:"bytes,29,opt,name=bytes_value,json=bytesValue,proto3" json:"bytes_value,omitempty"`
	Uint32Value         uint32                                  `protobuf:"varint,13,opt,name=uint32_value,json=uint32Value,proto3" json:"uint32_value,omitempty"`
	EnumValue           NumericEnum                             `` /* 139-byte string literal not displayed */
	PathEnumValue       pathenum.PathEnum                       `` /* 149-byte string literal not displayed */
	NestedPathEnumValue pathenum.MessagePathEnum_NestedPathEnum `` /* 191-byte string literal not displayed */
	Sfixed32Value       int32                                   `protobuf:"fixed32,15,opt,name=sfixed32_value,json=sfixed32Value,proto3" json:"sfixed32_value,omitempty"`
	Sfixed64Value       int64                                   `protobuf:"fixed64,16,opt,name=sfixed64_value,json=sfixed64Value,proto3" json:"sfixed64_value,omitempty"`
	Sint32Value         int32                                   `protobuf:"zigzag32,17,opt,name=sint32_value,json=sint32Value,proto3" json:"sint32_value,omitempty"`
	Sint64Value         int64                                   `protobuf:"zigzag64,18,opt,name=sint64_value,json=sint64Value,proto3" json:"sint64_value,omitempty"`
	RepeatedStringValue []string                                `protobuf:"bytes,19,rep,name=repeated_string_value,json=repeatedStringValue,proto3" json:"repeated_string_value,omitempty"`
	// Types that are valid to be assigned to OneofValue:
	//	*ABitOfEverything_OneofEmpty
	//	*ABitOfEverything_OneofString
	OneofValue               isABitOfEverything_OneofValue       `protobuf_oneof:"oneof_value"`
	MapValue                 map[string]NumericEnum              `` /* 224-byte string literal not displayed */
	MappedStringValue        map[string]string                   `` /* 203-byte string literal not displayed */
	MappedNestedValue        map[string]*ABitOfEverything_Nested `` /* 203-byte string literal not displayed */
	NonConventionalNameValue string                              `protobuf:"bytes,26,opt,name=nonConventionalNameValue,proto3" json:"nonConventionalNameValue,omitempty"`
	TimestampValue           *timestamp.Timestamp                `protobuf:"bytes,27,opt,name=timestamp_value,json=timestampValue,proto3" json:"timestamp_value,omitempty"`
	// repeated enum value. it is comma-separated in query
	RepeatedEnumValue    []NumericEnum `` /* 172-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Intentionaly complicated message type to cover many features of Protobuf. NEXT ID: 30

func (*ABitOfEverything) Descriptor 

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

func (*ABitOfEverything) GetBoolValue 

func (m *ABitOfEverything) GetBoolValue() bool

func (*ABitOfEverything) GetBytesValue 

func (m *ABitOfEverything) GetBytesValue() []byte

func (*ABitOfEverything) GetDoubleValue 

func (m *ABitOfEverything) GetDoubleValue() float64

func (*ABitOfEverything) GetEnumValue 

func (m *ABitOfEverything) GetEnumValue() NumericEnum

func (*ABitOfEverything) GetFixed32Value 

func (m *ABitOfEverything) GetFixed32Value() uint32

func (*ABitOfEverything) GetFixed64Value 

func (m *ABitOfEverything) GetFixed64Value() uint64

func (*ABitOfEverything) GetFloatValue 

func (m *ABitOfEverything) GetFloatValue() float32

func (*ABitOfEverything) GetInt32Value 

func (m *ABitOfEverything) GetInt32Value() int32

func (*ABitOfEverything) GetInt64Value 

func (m *ABitOfEverything) GetInt64Value() int64

func (*ABitOfEverything) GetMapValue 

func (m *ABitOfEverything) GetMapValue() map[string]NumericEnum

func (*ABitOfEverything) GetMappedNestedValue 

func (m *ABitOfEverything) GetMappedNestedValue() map[string]*ABitOfEverything_Nested

func (*ABitOfEverything) GetMappedStringValue 

func (m *ABitOfEverything) GetMappedStringValue() map[string]string

func (*ABitOfEverything) GetNested 

func (m *ABitOfEverything) GetNested() []*ABitOfEverything_Nested

func (*ABitOfEverything) GetNestedPathEnumValue 

func (m *ABitOfEverything) GetNestedPathEnumValue() pathenum.MessagePathEnum_NestedPathEnum

func (*ABitOfEverything) GetNonConventionalNameValue 

func (m *ABitOfEverything) GetNonConventionalNameValue() string

func (*ABitOfEverything) GetOneofEmpty 

func (m *ABitOfEverything) GetOneofEmpty() *empty.Empty

func (*ABitOfEverything) GetOneofString 

func (m *ABitOfEverything) GetOneofString() string

func (*ABitOfEverything) GetOneofValue 

func (m *ABitOfEverything) GetOneofValue() isABitOfEverything_OneofValue

func (*ABitOfEverything) GetPathEnumValue 

func (m *ABitOfEverything) GetPathEnumValue() pathenum.PathEnum

func (*ABitOfEverything) GetRepeatedEnumValue 

func (m *ABitOfEverything) GetRepeatedEnumValue() []NumericEnum

func (*ABitOfEverything) GetRepeatedStringValue 

func (m *ABitOfEverything) GetRepeatedStringValue() []string

func (*ABitOfEverything) GetSfixed32Value 

func (m *ABitOfEverything) GetSfixed32Value() int32

func (*ABitOfEverything) GetSfixed64Value 

func (m *ABitOfEverything) GetSfixed64Value() int64

func (*ABitOfEverything) GetSingleNested 

func (m *ABitOfEverything) GetSingleNested() *ABitOfEverything_Nested

func (*ABitOfEverything) GetSint32Value 

func (m *ABitOfEverything) GetSint32Value() int32

func (*ABitOfEverything) GetSint64Value 

func (m *ABitOfEverything) GetSint64Value() int64

func (*ABitOfEverything) GetStringValue 

func (m *ABitOfEverything) GetStringValue() string

func (*ABitOfEverything) GetTimestampValue 

func (m *ABitOfEverything) GetTimestampValue() *timestamp.Timestamp

func (*ABitOfEverything) GetUint32Value 

func (m *ABitOfEverything) GetUint32Value() uint32

func (*ABitOfEverything) GetUint64Value 

func (m *ABitOfEverything) GetUint64Value() uint64

func (*ABitOfEverything) GetUuid 

func (m *ABitOfEverything) GetUuid() string

func (*ABitOfEverything) ProtoMessage 

func (*ABitOfEverything) ProtoMessage()

func (*ABitOfEverything) Reset 

func (m *ABitOfEverything) Reset()

func (*ABitOfEverything) String 

func (m *ABitOfEverything) String() string

func (*ABitOfEverything) XXX_DiscardUnknown 

func (m *ABitOfEverything) XXX_DiscardUnknown()

func (*ABitOfEverything) XXX_Marshal 

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

func (*ABitOfEverything) XXX_Merge 

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

func (*ABitOfEverything) XXX_OneofFuncs 

func (*ABitOfEverything) 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 (*ABitOfEverything) XXX_Size 

func (m *ABitOfEverything) XXX_Size() int

func (*ABitOfEverything) XXX_Unmarshal 

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

type ABitOfEverythingRepeated 

type ABitOfEverythingRepeated struct {
	// repeated values. they are comma-separated in path
	PathRepeatedFloatValue    []float32     `` /* 140-byte string literal not displayed */
	PathRepeatedDoubleValue   []float64     `` /* 143-byte string literal not displayed */
	PathRepeatedInt64Value    []int64       `` /* 139-byte string literal not displayed */
	PathRepeatedUint64Value   []uint64      `` /* 142-byte string literal not displayed */
	PathRepeatedInt32Value    []int32       `` /* 139-byte string literal not displayed */
	PathRepeatedFixed64Value  []uint64      `` /* 146-byte string literal not displayed */
	PathRepeatedFixed32Value  []uint32      `` /* 146-byte string literal not displayed */
	PathRepeatedBoolValue     []bool        `` /* 136-byte string literal not displayed */
	PathRepeatedStringValue   []string      `` /* 134-byte string literal not displayed */
	PathRepeatedBytesValue    [][]byte      `` /* 132-byte string literal not displayed */
	PathRepeatedUint32Value   []uint32      `` /* 143-byte string literal not displayed */
	PathRepeatedEnumValue     []NumericEnum `` /* 186-byte string literal not displayed */
	PathRepeatedSfixed32Value []int32       `` /* 150-byte string literal not displayed */
	PathRepeatedSfixed64Value []int64       `` /* 150-byte string literal not displayed */
	PathRepeatedSint32Value   []int32       `` /* 145-byte string literal not displayed */
	PathRepeatedSint64Value   []int64       `` /* 145-byte string literal not displayed */
	XXX_NoUnkeyedLiteral      struct{}      `json:"-"`
	XXX_unrecognized          []byte        `json:"-"`
	XXX_sizecache             int32         `json:"-"`
}

ABitOfEverythingRepeated is used to validate repeated path parameter functionality

func (*ABitOfEverythingRepeated) Descriptor 

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

func (*ABitOfEverythingRepeated) GetPathRepeatedBoolValue 

func (m *ABitOfEverythingRepeated) GetPathRepeatedBoolValue() []bool

func (*ABitOfEverythingRepeated) GetPathRepeatedBytesValue 

func (m *ABitOfEverythingRepeated) GetPathRepeatedBytesValue() [][]byte

func (*ABitOfEverythingRepeated) GetPathRepeatedDoubleValue 

func (m *ABitOfEverythingRepeated) GetPathRepeatedDoubleValue() []float64

func (*ABitOfEverythingRepeated) GetPathRepeatedEnumValue 

func (m *ABitOfEverythingRepeated) GetPathRepeatedEnumValue() []NumericEnum

func (*ABitOfEverythingRepeated) GetPathRepeatedFixed32Value 

func (m *ABitOfEverythingRepeated) GetPathRepeatedFixed32Value() []uint32

func (*ABitOfEverythingRepeated) GetPathRepeatedFixed64Value 

func (m *ABitOfEverythingRepeated) GetPathRepeatedFixed64Value() []uint64

func (*ABitOfEverythingRepeated) GetPathRepeatedFloatValue 

func (m *ABitOfEverythingRepeated) GetPathRepeatedFloatValue() []float32

func (*ABitOfEverythingRepeated) GetPathRepeatedInt32Value 

func (m *ABitOfEverythingRepeated) GetPathRepeatedInt32Value() []int32

func (*ABitOfEverythingRepeated) GetPathRepeatedInt64Value 

func (m *ABitOfEverythingRepeated) GetPathRepeatedInt64Value() []int64

func (*ABitOfEverythingRepeated) GetPathRepeatedSfixed32Value 

func (m *ABitOfEverythingRepeated) GetPathRepeatedSfixed32Value() []int32

func (*ABitOfEverythingRepeated) GetPathRepeatedSfixed64Value 

func (m *ABitOfEverythingRepeated) GetPathRepeatedSfixed64Value() []int64

func (*ABitOfEverythingRepeated) GetPathRepeatedSint32Value 

func (m *ABitOfEverythingRepeated) GetPathRepeatedSint32Value() []int32

func (*ABitOfEverythingRepeated) GetPathRepeatedSint64Value 

func (m *ABitOfEverythingRepeated) GetPathRepeatedSint64Value() []int64

func (*ABitOfEverythingRepeated) GetPathRepeatedStringValue 

func (m *ABitOfEverythingRepeated) GetPathRepeatedStringValue() []string

func (*ABitOfEverythingRepeated) GetPathRepeatedUint32Value 

func (m *ABitOfEverythingRepeated) GetPathRepeatedUint32Value() []uint32

func (*ABitOfEverythingRepeated) GetPathRepeatedUint64Value 

func (m *ABitOfEverythingRepeated) GetPathRepeatedUint64Value() []uint64

func (*ABitOfEverythingRepeated) ProtoMessage 

func (*ABitOfEverythingRepeated) ProtoMessage()

func (*ABitOfEverythingRepeated) Reset 

func (m *ABitOfEverythingRepeated) Reset()

func (*ABitOfEverythingRepeated) String 

func (m *ABitOfEverythingRepeated) String() string

func (*ABitOfEverythingRepeated) XXX_DiscardUnknown 

func (m *ABitOfEverythingRepeated) XXX_DiscardUnknown()

func (*ABitOfEverythingRepeated) XXX_Marshal 

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

func (*ABitOfEverythingRepeated) XXX_Merge 

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

func (*ABitOfEverythingRepeated) XXX_Size 

func (m *ABitOfEverythingRepeated) XXX_Size() int

func (*ABitOfEverythingRepeated) XXX_Unmarshal 

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

type ABitOfEverythingServiceClient 

type ABitOfEverythingServiceClient interface {
	// Create a new ABitOfEverything
	//
	// This API creates a new ABitOfEverything
	Create(ctx context.Context, in *ABitOfEverything, opts ...grpc.CallOption) (*ABitOfEverything, error)
	CreateBody(ctx context.Context, in *ABitOfEverything, opts ...grpc.CallOption) (*ABitOfEverything, error)
	Lookup(ctx context.Context, in *sub2.IdMessage, opts ...grpc.CallOption) (*ABitOfEverything, error)
	Update(ctx context.Context, in *ABitOfEverything, opts ...grpc.CallOption) (*empty.Empty, error)
	UpdateV2(ctx context.Context, in *UpdateV2Request, opts ...grpc.CallOption) (*empty.Empty, error)
	PatchWithFieldMaskInBody(ctx context.Context, in *UpdateV2Request, opts ...grpc.CallOption) (*empty.Empty, error)
	Delete(ctx context.Context, in *sub2.IdMessage, opts ...grpc.CallOption) (*empty.Empty, error)
	GetQuery(ctx context.Context, in *ABitOfEverything, opts ...grpc.CallOption) (*empty.Empty, error)
	GetRepeatedQuery(ctx context.Context, in *ABitOfEverythingRepeated, opts ...grpc.CallOption) (*ABitOfEverythingRepeated, error)
	// Echo allows posting a StringMessage value.
	//
	// It also exposes multiple bindings.
	//
	// This makes it useful when validating that the OpenAPI v2 API
	// description exposes documentation correctly on all paths
	// defined as additional_bindings in the proto.
	Echo(ctx context.Context, in *sub.StringMessage, opts ...grpc.CallOption) (*sub.StringMessage, error)
	DeepPathEcho(ctx context.Context, in *ABitOfEverything, opts ...grpc.CallOption) (*ABitOfEverything, error)
	NoBindings(ctx context.Context, in *duration.Duration, opts ...grpc.CallOption) (*empty.Empty, error)
	Timeout(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	ErrorWithDetails(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	GetMessageWithBody(ctx context.Context, in *MessageWithBody, opts ...grpc.CallOption) (*empty.Empty, error)
	PostWithEmptyBody(ctx context.Context, in *Body, opts ...grpc.CallOption) (*empty.Empty, error)
}

ABitOfEverythingServiceClient is the client API for ABitOfEverythingService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewABitOfEverythingServiceClient 

func NewABitOfEverythingServiceClient(cc *grpc.ClientConn) ABitOfEverythingServiceClient

type ABitOfEverythingServiceServer 

type ABitOfEverythingServiceServer interface {
	// Create a new ABitOfEverything
	//
	// This API creates a new ABitOfEverything
	Create(context.Context, *ABitOfEverything) (*ABitOfEverything, error)
	CreateBody(context.Context, *ABitOfEverything) (*ABitOfEverything, error)
	Lookup(context.Context, *sub2.IdMessage) (*ABitOfEverything, error)
	Update(context.Context, *ABitOfEverything) (*empty.Empty, error)
	UpdateV2(context.Context, *UpdateV2Request) (*empty.Empty, error)
	PatchWithFieldMaskInBody(context.Context, *UpdateV2Request) (*empty.Empty, error)
	Delete(context.Context, *sub2.IdMessage) (*empty.Empty, error)
	GetQuery(context.Context, *ABitOfEverything) (*empty.Empty, error)
	GetRepeatedQuery(context.Context, *ABitOfEverythingRepeated) (*ABitOfEverythingRepeated, error)
	// Echo allows posting a StringMessage value.
	//
	// It also exposes multiple bindings.
	//
	// This makes it useful when validating that the OpenAPI v2 API
	// description exposes documentation correctly on all paths
	// defined as additional_bindings in the proto.
	Echo(context.Context, *sub.StringMessage) (*sub.StringMessage, error)
	DeepPathEcho(context.Context, *ABitOfEverything) (*ABitOfEverything, error)
	NoBindings(context.Context, *duration.Duration) (*empty.Empty, error)
	Timeout(context.Context, *empty.Empty) (*empty.Empty, error)
	ErrorWithDetails(context.Context, *empty.Empty) (*empty.Empty, error)
	GetMessageWithBody(context.Context, *MessageWithBody) (*empty.Empty, error)
	PostWithEmptyBody(context.Context, *Body) (*empty.Empty, error)
}

ABitOfEverythingServiceServer is the server API for ABitOfEverythingService service.

type ABitOfEverything_Nested 

type ABitOfEverything_Nested struct {
	// name is nested field.
	Name                 string                           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Amount               uint32                           `protobuf:"varint,2,opt,name=amount,proto3" json:"amount,omitempty"`
	Ok                   ABitOfEverything_Nested_DeepEnum `` /* 128-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

Nested is nested type.

func (*ABitOfEverything_Nested) Descriptor 

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

func (*ABitOfEverything_Nested) GetAmount 

func (m *ABitOfEverything_Nested) GetAmount() uint32

func (*ABitOfEverything_Nested) GetName 

func (m *ABitOfEverything_Nested) GetName() string

func (*ABitOfEverything_Nested) GetOk 

func (m *ABitOfEverything_Nested) GetOk() ABitOfEverything_Nested_DeepEnum

func (*ABitOfEverything_Nested) ProtoMessage 

func (*ABitOfEverything_Nested) ProtoMessage()

func (*ABitOfEverything_Nested) Reset 

func (m *ABitOfEverything_Nested) Reset()

func (*ABitOfEverything_Nested) String 

func (m *ABitOfEverything_Nested) String() string

func (*ABitOfEverything_Nested) XXX_DiscardUnknown 

func (m *ABitOfEverything_Nested) XXX_DiscardUnknown()

func (*ABitOfEverything_Nested) XXX_Marshal 

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

func (*ABitOfEverything_Nested) XXX_Merge 

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

func (*ABitOfEverything_Nested) XXX_Size 

func (m *ABitOfEverything_Nested) XXX_Size() int

func (*ABitOfEverything_Nested) XXX_Unmarshal 

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

type ABitOfEverything_Nested_DeepEnum 

type ABitOfEverything_Nested_DeepEnum int32

DeepEnum is one or zero. 

const (
	// FALSE is false.
	ABitOfEverything_Nested_FALSE ABitOfEverything_Nested_DeepEnum = 0
	// TRUE is true.
	ABitOfEverything_Nested_TRUE ABitOfEverything_Nested_DeepEnum = 1
)

func (ABitOfEverything_Nested_DeepEnum) EnumDescriptor 

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

func (ABitOfEverything_Nested_DeepEnum) String 

func (x ABitOfEverything_Nested_DeepEnum) String() string

type ABitOfEverything_OneofEmpty 

type ABitOfEverything_OneofEmpty struct {
	OneofEmpty *empty.Empty `protobuf:"bytes,20,opt,name=oneof_empty,json=oneofEmpty,proto3,oneof"`
}

type ABitOfEverything_OneofString 

type ABitOfEverything_OneofString struct {
	OneofString string `protobuf:"bytes,21,opt,name=oneof_string,json=oneofString,proto3,oneof"`
}

type AnotherServiceWithNoBindingsClient 

type AnotherServiceWithNoBindingsClient interface {
	NoBindings(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
}

AnotherServiceWithNoBindingsClient is the client API for AnotherServiceWithNoBindings service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewAnotherServiceWithNoBindingsClient 

func NewAnotherServiceWithNoBindingsClient(cc *grpc.ClientConn) AnotherServiceWithNoBindingsClient

type AnotherServiceWithNoBindingsServer 

type AnotherServiceWithNoBindingsServer interface {
	NoBindings(context.Context, *empty.Empty) (*empty.Empty, error)
}

AnotherServiceWithNoBindingsServer is the server API for AnotherServiceWithNoBindings service.

type Body 

type Body struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Body) Descriptor 

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

func (*Body) GetName 

func (m *Body) GetName() string

func (*Body) ProtoMessage 

func (*Body) ProtoMessage()

func (*Body) Reset 

func (m *Body) Reset()

func (*Body) String 

func (m *Body) String() string

func (*Body) XXX_DiscardUnknown 

func (m *Body) XXX_DiscardUnknown()

func (*Body) XXX_Marshal 

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

func (*Body) XXX_Merge 

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

func (*Body) XXX_Size 

func (m *Body) XXX_Size() int

func (*Body) XXX_Unmarshal 

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

type CamelCaseServiceNameClient 

type CamelCaseServiceNameClient interface {
	Empty(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
}

CamelCaseServiceNameClient is the client API for CamelCaseServiceName service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCamelCaseServiceNameClient 

func NewCamelCaseServiceNameClient(cc *grpc.ClientConn) CamelCaseServiceNameClient

type CamelCaseServiceNameServer 

type CamelCaseServiceNameServer interface {
	Empty(context.Context, *empty.Empty) (*empty.Empty, error)
}

CamelCaseServiceNameServer is the server API for CamelCaseServiceName service.

type EchoServiceClient 

type EchoServiceClient interface {
	// Echo method receives a simple message and returns it.
	//
	// The message posted as the id parameter will also be
	// returned.
	Echo(ctx context.Context, in *SimpleMessage, opts ...grpc.CallOption) (*SimpleMessage, error)
	// EchoBody method receives a simple message and returns it.
	EchoBody(ctx context.Context, in *SimpleMessage, opts ...grpc.CallOption) (*SimpleMessage, error)
	// EchoDelete method receives a simple message and returns it.
	EchoDelete(ctx context.Context, in *SimpleMessage, opts ...grpc.CallOption) (*SimpleMessage, error)
}

EchoServiceClient is the client API for EchoService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEchoServiceClient 

func NewEchoServiceClient(cc *grpc.ClientConn) EchoServiceClient

type EchoServiceServer 

type EchoServiceServer interface {
	// Echo method receives a simple message and returns it.
	//
	// The message posted as the id parameter will also be
	// returned.
	Echo(context.Context, *SimpleMessage) (*SimpleMessage, error)
	// EchoBody method receives a simple message and returns it.
	EchoBody(context.Context, *SimpleMessage) (*SimpleMessage, error)
	// EchoDelete method receives a simple message and returns it.
	EchoDelete(context.Context, *SimpleMessage) (*SimpleMessage, error)
}

EchoServiceServer is the server API for EchoService service.

type Embedded 

type Embedded struct {
	// Types that are valid to be assigned to Mark:
	//	*Embedded_Progress
	//	*Embedded_Note
	Mark                 isEmbedded_Mark `protobuf_oneof:"mark"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Embedded represents a message embedded in SimpleMessage.

func (*Embedded) Descriptor 

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

func (*Embedded) GetMark 

func (m *Embedded) GetMark() isEmbedded_Mark

func (*Embedded) GetNote 

func (m *Embedded) GetNote() string

func (*Embedded) GetProgress 

func (m *Embedded) GetProgress() int64

func (*Embedded) ProtoMessage 

func (*Embedded) ProtoMessage()

func (*Embedded) Reset 

func (m *Embedded) Reset()

func (*Embedded) String 

func (m *Embedded) String() string

func (*Embedded) XXX_DiscardUnknown 

func (m *Embedded) XXX_DiscardUnknown()

func (*Embedded) XXX_Marshal 

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

func (*Embedded) XXX_Merge 

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

func (*Embedded) XXX_OneofFuncs 

func (*Embedded) 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 (*Embedded) XXX_Size 

func (m *Embedded) XXX_Size() int

func (*Embedded) XXX_Unmarshal 

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

type Embedded_Note 

type Embedded_Note struct {
	Note string `protobuf:"bytes,2,opt,name=note,proto3,oneof"`
}

type Embedded_Progress 

type Embedded_Progress struct {
	Progress int64 `protobuf:"varint,1,opt,name=progress,proto3,oneof"`
}

type EmptyProto 

type EmptyProto struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EmptyProto) Descriptor 

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

func (*EmptyProto) ProtoMessage 

func (*EmptyProto) ProtoMessage()

func (*EmptyProto) Reset 

func (m *EmptyProto) Reset()

func (*EmptyProto) String 

func (m *EmptyProto) String() string

func (*EmptyProto) XXX_DiscardUnknown 

func (m *EmptyProto) XXX_DiscardUnknown()

func (*EmptyProto) XXX_Marshal 

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

func (*EmptyProto) XXX_Merge 

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

func (*EmptyProto) XXX_Size 

func (m *EmptyProto) XXX_Size() int

func (*EmptyProto) XXX_Unmarshal 

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

type FlowCombinationClient 

type FlowCombinationClient interface {
	RpcEmptyRpc(ctx context.Context, in *EmptyProto, opts ...grpc.CallOption) (*EmptyProto, error)
	RpcEmptyStream(ctx context.Context, in *EmptyProto, opts ...grpc.CallOption) (FlowCombination_RpcEmptyStreamClient, error)
	StreamEmptyRpc(ctx context.Context, opts ...grpc.CallOption) (FlowCombination_StreamEmptyRpcClient, error)
	StreamEmptyStream(ctx context.Context, opts ...grpc.CallOption) (FlowCombination_StreamEmptyStreamClient, error)
	RpcBodyRpc(ctx context.Context, in *NonEmptyProto, opts ...grpc.CallOption) (*EmptyProto, error)
	RpcPathSingleNestedRpc(ctx context.Context, in *SingleNestedProto, opts ...grpc.CallOption) (*EmptyProto, error)
	RpcPathNestedRpc(ctx context.Context, in *NestedProto, opts ...grpc.CallOption) (*EmptyProto, error)
	RpcBodyStream(ctx context.Context, in *NonEmptyProto, opts ...grpc.CallOption) (FlowCombination_RpcBodyStreamClient, error)
	RpcPathSingleNestedStream(ctx context.Context, in *SingleNestedProto, opts ...grpc.CallOption) (FlowCombination_RpcPathSingleNestedStreamClient, error)
	RpcPathNestedStream(ctx context.Context, in *NestedProto, opts ...grpc.CallOption) (FlowCombination_RpcPathNestedStreamClient, error)
}

FlowCombinationClient is the client API for FlowCombination service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewFlowCombinationClient 

func NewFlowCombinationClient(cc *grpc.ClientConn) FlowCombinationClient

type FlowCombinationServer 

type FlowCombinationServer interface {
	RpcEmptyRpc(context.Context, *EmptyProto) (*EmptyProto, error)
	RpcEmptyStream(*EmptyProto, FlowCombination_RpcEmptyStreamServer) error
	StreamEmptyRpc(FlowCombination_StreamEmptyRpcServer) error
	StreamEmptyStream(FlowCombination_StreamEmptyStreamServer) error
	RpcBodyRpc(context.Context, *NonEmptyProto) (*EmptyProto, error)
	RpcPathSingleNestedRpc(context.Context, *SingleNestedProto) (*EmptyProto, error)
	RpcPathNestedRpc(context.Context, *NestedProto) (*EmptyProto, error)
	RpcBodyStream(*NonEmptyProto, FlowCombination_RpcBodyStreamServer) error
	RpcPathSingleNestedStream(*SingleNestedProto, FlowCombination_RpcPathSingleNestedStreamServer) error
	RpcPathNestedStream(*NestedProto, FlowCombination_RpcPathNestedStreamServer) error
}

FlowCombinationServer is the server API for FlowCombination service.

type FlowCombination_RpcBodyStreamClient 

type FlowCombination_RpcBodyStreamClient interface {
	Recv() (*EmptyProto, error)
	grpc.ClientStream
}

type FlowCombination_RpcBodyStreamServer 

type FlowCombination_RpcBodyStreamServer interface {
	Send(*EmptyProto) error
	grpc.ServerStream
}

type FlowCombination_RpcEmptyStreamClient 

type FlowCombination_RpcEmptyStreamClient interface {
	Recv() (*EmptyProto, error)
	grpc.ClientStream
}

type FlowCombination_RpcEmptyStreamServer 

type FlowCombination_RpcEmptyStreamServer interface {
	Send(*EmptyProto) error
	grpc.ServerStream
}

type FlowCombination_RpcPathNestedStreamClient 

type FlowCombination_RpcPathNestedStreamClient interface {
	Recv() (*EmptyProto, error)
	grpc.ClientStream
}

type FlowCombination_RpcPathNestedStreamServer 

type FlowCombination_RpcPathNestedStreamServer interface {
	Send(*EmptyProto) error
	grpc.ServerStream
}

type FlowCombination_RpcPathSingleNestedStreamClient 

type FlowCombination_RpcPathSingleNestedStreamClient interface {
	Recv() (*EmptyProto, error)
	grpc.ClientStream
}

type FlowCombination_RpcPathSingleNestedStreamServer 

type FlowCombination_RpcPathSingleNestedStreamServer interface {
	Send(*EmptyProto) error
	grpc.ServerStream
}

type FlowCombination_StreamEmptyRpcClient 

type FlowCombination_StreamEmptyRpcClient interface {
	Send(*EmptyProto) error
	CloseAndRecv() (*EmptyProto, error)
	grpc.ClientStream
}

type FlowCombination_StreamEmptyRpcServer 

type FlowCombination_StreamEmptyRpcServer interface {
	SendAndClose(*EmptyProto) error
	Recv() (*EmptyProto, error)
	grpc.ServerStream
}

type FlowCombination_StreamEmptyStreamClient 

type FlowCombination_StreamEmptyStreamClient interface {
	Send(*EmptyProto) error
	Recv() (*EmptyProto, error)
	grpc.ClientStream
}

type FlowCombination_StreamEmptyStreamServer 

type FlowCombination_StreamEmptyStreamServer interface {
	Send(*EmptyProto) error
	Recv() (*EmptyProto, error)
	grpc.ServerStream
}

type MessageWithBody 

type MessageWithBody struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Data                 *Body    `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MessageWithBody) Descriptor 

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

func (*MessageWithBody) GetData 

func (m *MessageWithBody) GetData() *Body

func (*MessageWithBody) GetId 

func (m *MessageWithBody) GetId() string

func (*MessageWithBody) ProtoMessage 

func (*MessageWithBody) ProtoMessage()

func (*MessageWithBody) Reset 

func (m *MessageWithBody) Reset()

func (*MessageWithBody) String 

func (m *MessageWithBody) String() string

func (*MessageWithBody) XXX_DiscardUnknown 

func (m *MessageWithBody) XXX_DiscardUnknown()

func (*MessageWithBody) XXX_Marshal 

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

func (*MessageWithBody) XXX_Merge 

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

func (*MessageWithBody) XXX_Size 

func (m *MessageWithBody) XXX_Size() int

func (*MessageWithBody) XXX_Unmarshal 

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

type NestedProto 

type NestedProto struct {
	A                    *UnaryProto `protobuf:"bytes,1,opt,name=a,proto3" json:"a,omitempty"`
	B                    string      `protobuf:"bytes,2,opt,name=b,proto3" json:"b,omitempty"`
	C                    string      `protobuf:"bytes,3,opt,name=c,proto3" json:"c,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*NestedProto) Descriptor 

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

func (*NestedProto) GetA 

func (m *NestedProto) GetA() *UnaryProto

func (*NestedProto) GetB 

func (m *NestedProto) GetB() string

func (*NestedProto) GetC 

func (m *NestedProto) GetC() string

func (*NestedProto) ProtoMessage 

func (*NestedProto) ProtoMessage()

func (*NestedProto) Reset 

func (m *NestedProto) Reset()

func (*NestedProto) String 

func (m *NestedProto) String() string

func (*NestedProto) XXX_DiscardUnknown 

func (m *NestedProto) XXX_DiscardUnknown()

func (*NestedProto) XXX_Marshal 

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

func (*NestedProto) XXX_Merge 

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

func (*NestedProto) XXX_Size 

func (m *NestedProto) XXX_Size() int

func (*NestedProto) XXX_Unmarshal 

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

type NonEmptyProto 

type NonEmptyProto struct {
	A                    string   `protobuf:"bytes,1,opt,name=a,proto3" json:"a,omitempty"`
	B                    string   `protobuf:"bytes,2,opt,name=b,proto3" json:"b,omitempty"`
	C                    string   `protobuf:"bytes,3,opt,name=c,proto3" json:"c,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NonEmptyProto) Descriptor 

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

func (*NonEmptyProto) GetA 

func (m *NonEmptyProto) GetA() string

func (*NonEmptyProto) GetB 

func (m *NonEmptyProto) GetB() string

func (*NonEmptyProto) GetC 

func (m *NonEmptyProto) GetC() string

func (*NonEmptyProto) ProtoMessage 

func (*NonEmptyProto) ProtoMessage()

func (*NonEmptyProto) Reset 

func (m *NonEmptyProto) Reset()

func (*NonEmptyProto) String 

func (m *NonEmptyProto) String() string

func (*NonEmptyProto) XXX_DiscardUnknown 

func (m *NonEmptyProto) XXX_DiscardUnknown()

func (*NonEmptyProto) XXX_Marshal 

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

func (*NonEmptyProto) XXX_Merge 

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

func (*NonEmptyProto) XXX_Size 

func (m *NonEmptyProto) XXX_Size() int

func (*NonEmptyProto) XXX_Unmarshal 

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

type NumericEnum 

type NumericEnum int32

NumericEnum is one or zero. 

const (
	// ZERO means 0
	NumericEnum_ZERO NumericEnum = 0
	// ONE means 1
	NumericEnum_ONE NumericEnum = 1
)

func (NumericEnum) EnumDescriptor 

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

func (NumericEnum) String 

func (x NumericEnum) String() string

type RepeatedResponseBodyOut 

type RepeatedResponseBodyOut struct {
	Response             []*RepeatedResponseBodyOut_Response `protobuf:"bytes,2,rep,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

func (*RepeatedResponseBodyOut) Descriptor 

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

func (*RepeatedResponseBodyOut) GetResponse 

func (m *RepeatedResponseBodyOut) GetResponse() []*RepeatedResponseBodyOut_Response

func (*RepeatedResponseBodyOut) ProtoMessage 

func (*RepeatedResponseBodyOut) ProtoMessage()

func (*RepeatedResponseBodyOut) Reset 

func (m *RepeatedResponseBodyOut) Reset()

func (*RepeatedResponseBodyOut) String 

func (m *RepeatedResponseBodyOut) String() string

func (*RepeatedResponseBodyOut) XXX_DiscardUnknown 

func (m *RepeatedResponseBodyOut) XXX_DiscardUnknown()

func (*RepeatedResponseBodyOut) XXX_Marshal 

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

func (*RepeatedResponseBodyOut) XXX_Merge 

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

func (*RepeatedResponseBodyOut) XXX_Size 

func (m *RepeatedResponseBodyOut) XXX_Size() int

func (*RepeatedResponseBodyOut) XXX_Unmarshal 

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

type RepeatedResponseBodyOut_Response 

type RepeatedResponseBodyOut_Response struct {
	Data                 string                                        `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Type                 RepeatedResponseBodyOut_Response_ResponseType `` /* 145-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                      `json:"-"`
	XXX_unrecognized     []byte                                        `json:"-"`
	XXX_sizecache        int32                                         `json:"-"`
}

func (*RepeatedResponseBodyOut_Response) Descriptor 

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

func (*RepeatedResponseBodyOut_Response) GetData 

func (m *RepeatedResponseBodyOut_Response) GetData() string

func (*RepeatedResponseBodyOut_Response) GetType 

func (m *RepeatedResponseBodyOut_Response) GetType() RepeatedResponseBodyOut_Response_ResponseType

func (*RepeatedResponseBodyOut_Response) ProtoMessage 

func (*RepeatedResponseBodyOut_Response) ProtoMessage()

func (*RepeatedResponseBodyOut_Response) Reset 

func (m *RepeatedResponseBodyOut_Response) Reset()

func (*RepeatedResponseBodyOut_Response) String 

func (m *RepeatedResponseBodyOut_Response) String() string

func (*RepeatedResponseBodyOut_Response) XXX_DiscardUnknown 

func (m *RepeatedResponseBodyOut_Response) XXX_DiscardUnknown()

func (*RepeatedResponseBodyOut_Response) XXX_Marshal 

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

func (*RepeatedResponseBodyOut_Response) XXX_Merge 

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

func (*RepeatedResponseBodyOut_Response) XXX_Size 

func (m *RepeatedResponseBodyOut_Response) XXX_Size() int

func (*RepeatedResponseBodyOut_Response) XXX_Unmarshal 

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

type RepeatedResponseBodyOut_Response_ResponseType 

type RepeatedResponseBodyOut_Response_ResponseType int32
const (
	// UNKNOWN
	RepeatedResponseBodyOut_Response_UNKNOWN RepeatedResponseBodyOut_Response_ResponseType = 0
	// A is 1
	RepeatedResponseBodyOut_Response_A RepeatedResponseBodyOut_Response_ResponseType = 1
	// B is 2
	RepeatedResponseBodyOut_Response_B RepeatedResponseBodyOut_Response_ResponseType = 2
)

func (RepeatedResponseBodyOut_Response_ResponseType) EnumDescriptor 

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

func (RepeatedResponseBodyOut_Response_ResponseType) String 

func (x RepeatedResponseBodyOut_Response_ResponseType) String() string

type RepeatedResponseStrings 

type RepeatedResponseStrings struct {
	Values               []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RepeatedResponseStrings) Descriptor 

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

func (*RepeatedResponseStrings) GetValues 

func (m *RepeatedResponseStrings) GetValues() []string

func (*RepeatedResponseStrings) ProtoMessage 

func (*RepeatedResponseStrings) ProtoMessage()

func (*RepeatedResponseStrings) Reset 

func (m *RepeatedResponseStrings) Reset()

func (*RepeatedResponseStrings) String 

func (m *RepeatedResponseStrings) String() string

func (*RepeatedResponseStrings) XXX_DiscardUnknown 

func (m *RepeatedResponseStrings) XXX_DiscardUnknown()

func (*RepeatedResponseStrings) XXX_Marshal 

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

func (*RepeatedResponseStrings) XXX_Merge 

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

func (*RepeatedResponseStrings) XXX_Size 

func (m *RepeatedResponseStrings) XXX_Size() int

func (*RepeatedResponseStrings) XXX_Unmarshal 

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

type ResponseBodyIn 

type ResponseBodyIn struct {
	Data                 string   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResponseBodyIn) Descriptor 

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

func (*ResponseBodyIn) GetData 

func (m *ResponseBodyIn) GetData() string

func (*ResponseBodyIn) ProtoMessage 

func (*ResponseBodyIn) ProtoMessage()

func (*ResponseBodyIn) Reset 

func (m *ResponseBodyIn) Reset()

func (*ResponseBodyIn) String 

func (m *ResponseBodyIn) String() string

func (*ResponseBodyIn) XXX_DiscardUnknown 

func (m *ResponseBodyIn) XXX_DiscardUnknown()

func (*ResponseBodyIn) XXX_Marshal 

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

func (*ResponseBodyIn) XXX_Merge 

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

func (*ResponseBodyIn) XXX_Size 

func (m *ResponseBodyIn) XXX_Size() int

func (*ResponseBodyIn) XXX_Unmarshal 

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

type ResponseBodyOut 

type ResponseBodyOut struct {
	Response             *ResponseBodyOut_Response `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*ResponseBodyOut) Descriptor 

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

func (*ResponseBodyOut) GetResponse 

func (m *ResponseBodyOut) GetResponse() *ResponseBodyOut_Response

func (*ResponseBodyOut) ProtoMessage 

func (*ResponseBodyOut) ProtoMessage()

func (*ResponseBodyOut) Reset 

func (m *ResponseBodyOut) Reset()

func (*ResponseBodyOut) String 

func (m *ResponseBodyOut) String() string

func (*ResponseBodyOut) XXX_DiscardUnknown 

func (m *ResponseBodyOut) XXX_DiscardUnknown()

func (*ResponseBodyOut) XXX_Marshal 

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

func (*ResponseBodyOut) XXX_Merge 

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

func (*ResponseBodyOut) XXX_Size 

func (m *ResponseBodyOut) XXX_Size() int

func (*ResponseBodyOut) XXX_Unmarshal 

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

type ResponseBodyOut_Response 

type ResponseBodyOut_Response struct {
	Data                 string   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResponseBodyOut_Response) Descriptor 

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

func (*ResponseBodyOut_Response) GetData 

func (m *ResponseBodyOut_Response) GetData() string

func (*ResponseBodyOut_Response) ProtoMessage 

func (*ResponseBodyOut_Response) ProtoMessage()

func (*ResponseBodyOut_Response) Reset 

func (m *ResponseBodyOut_Response) Reset()

func (*ResponseBodyOut_Response) String 

func (m *ResponseBodyOut_Response) String() string

func (*ResponseBodyOut_Response) XXX_DiscardUnknown 

func (m *ResponseBodyOut_Response) XXX_DiscardUnknown()

func (*ResponseBodyOut_Response) XXX_Marshal 

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

func (*ResponseBodyOut_Response) XXX_Merge 

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

func (*ResponseBodyOut_Response) XXX_Size 

func (m *ResponseBodyOut_Response) XXX_Size() int

func (*ResponseBodyOut_Response) XXX_Unmarshal 

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

type ResponseBodyServiceClient 

type ResponseBodyServiceClient interface {
	GetResponseBody(ctx context.Context, in *ResponseBodyIn, opts ...grpc.CallOption) (*ResponseBodyOut, error)
	ListResponseBodies(ctx context.Context, in *ResponseBodyIn, opts ...grpc.CallOption) (*RepeatedResponseBodyOut, error)
	ListResponseStrings(ctx context.Context, in *ResponseBodyIn, opts ...grpc.CallOption) (*RepeatedResponseStrings, error)
}

ResponseBodyServiceClient is the client API for ResponseBodyService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewResponseBodyServiceClient 

func NewResponseBodyServiceClient(cc *grpc.ClientConn) ResponseBodyServiceClient

type ResponseBodyServiceServer 

type ResponseBodyServiceServer interface {
	GetResponseBody(context.Context, *ResponseBodyIn) (*ResponseBodyOut, error)
	ListResponseBodies(context.Context, *ResponseBodyIn) (*RepeatedResponseBodyOut, error)
	ListResponseStrings(context.Context, *ResponseBodyIn) (*RepeatedResponseStrings, error)
}

ResponseBodyServiceServer is the server API for ResponseBodyService service.

type SimpleMessage 

type SimpleMessage struct {
	// Id represents the message identifier.
	Id  string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Num int64  `protobuf:"varint,2,opt,name=num,proto3" json:"num,omitempty"`
	// Types that are valid to be assigned to Code:
	//	*SimpleMessage_LineNum
	//	*SimpleMessage_Lang
	Code   isSimpleMessage_Code `protobuf_oneof:"code"`
	Status *Embedded            `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	// Types that are valid to be assigned to Ext:
	//	*SimpleMessage_En
	//	*SimpleMessage_No
	Ext                  isSimpleMessage_Ext `protobuf_oneof:"ext"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

SimpleMessage represents a simple message sent to the Echo service.

func (*SimpleMessage) Descriptor 

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

func (*SimpleMessage) GetCode 

func (m *SimpleMessage) GetCode() isSimpleMessage_Code

func (*SimpleMessage) GetEn 

func (m *SimpleMessage) GetEn() int64

func (*SimpleMessage) GetExt 

func (m *SimpleMessage) GetExt() isSimpleMessage_Ext

func (*SimpleMessage) GetId 

func (m *SimpleMessage) GetId() string

func (*SimpleMessage) GetLang 

func (m *SimpleMessage) GetLang() string

func (*SimpleMessage) GetLineNum 

func (m *SimpleMessage) GetLineNum() int64

func (*SimpleMessage) GetNo 

func (m *SimpleMessage) GetNo() *Embedded

func (*SimpleMessage) GetNum 

func (m *SimpleMessage) GetNum() int64

func (*SimpleMessage) GetStatus 

func (m *SimpleMessage) GetStatus() *Embedded

func (*SimpleMessage) ProtoMessage 

func (*SimpleMessage) ProtoMessage()

func (*SimpleMessage) Reset 

func (m *SimpleMessage) Reset()

func (*SimpleMessage) String 

func (m *SimpleMessage) String() string

func (*SimpleMessage) XXX_DiscardUnknown 

func (m *SimpleMessage) XXX_DiscardUnknown()

func (*SimpleMessage) XXX_Marshal 

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

func (*SimpleMessage) XXX_Merge 

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

func (*SimpleMessage) XXX_OneofFuncs 

func (*SimpleMessage) 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 (*SimpleMessage) XXX_Size 

func (m *SimpleMessage) XXX_Size() int

func (*SimpleMessage) XXX_Unmarshal 

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

type SimpleMessage_En 

type SimpleMessage_En struct {
	En int64 `protobuf:"varint,6,opt,name=en,proto3,oneof"`
}

type SimpleMessage_Lang 

type SimpleMessage_Lang struct {
	Lang string `protobuf:"bytes,4,opt,name=lang,proto3,oneof"`
}

type SimpleMessage_LineNum 

type SimpleMessage_LineNum struct {
	LineNum int64 `protobuf:"varint,3,opt,name=line_num,json=lineNum,proto3,oneof"`
}

type SimpleMessage_No 

type SimpleMessage_No struct {
	No *Embedded `protobuf:"bytes,7,opt,name=no,proto3,oneof"`
}

type SingleNestedProto 

type SingleNestedProto struct {
	A                    *UnaryProto `protobuf:"bytes,1,opt,name=a,proto3" json:"a,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*SingleNestedProto) Descriptor 

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

func (*SingleNestedProto) GetA 

func (m *SingleNestedProto) GetA() *UnaryProto

func (*SingleNestedProto) ProtoMessage 

func (*SingleNestedProto) ProtoMessage()

func (*SingleNestedProto) Reset 

func (m *SingleNestedProto) Reset()

func (*SingleNestedProto) String 

func (m *SingleNestedProto) String() string

func (*SingleNestedProto) XXX_DiscardUnknown 

func (m *SingleNestedProto) XXX_DiscardUnknown()

func (*SingleNestedProto) XXX_Marshal 

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

func (*SingleNestedProto) XXX_Merge 

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

func (*SingleNestedProto) XXX_Size 

func (m *SingleNestedProto) XXX_Size() int

func (*SingleNestedProto) XXX_Unmarshal 

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

type StreamServiceClient 

type StreamServiceClient interface {
	BulkCreate(ctx context.Context, opts ...grpc.CallOption) (StreamService_BulkCreateClient, error)
	List(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (StreamService_ListClient, error)
	BulkEcho(ctx context.Context, opts ...grpc.CallOption) (StreamService_BulkEchoClient, error)
}

StreamServiceClient is the client API for StreamService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewStreamServiceClient 

func NewStreamServiceClient(cc *grpc.ClientConn) StreamServiceClient

type StreamServiceServer 

type StreamServiceServer interface {
	BulkCreate(StreamService_BulkCreateServer) error
	List(*empty.Empty, StreamService_ListServer) error
	BulkEcho(StreamService_BulkEchoServer) error
}

StreamServiceServer is the server API for StreamService service.

type StreamService_BulkCreateClient 

type StreamService_BulkCreateClient interface {
	Send(*ABitOfEverything) error
	CloseAndRecv() (*empty.Empty, error)
	grpc.ClientStream
}

type StreamService_BulkCreateServer 

type StreamService_BulkCreateServer interface {
	SendAndClose(*empty.Empty) error
	Recv() (*ABitOfEverything, error)
	grpc.ServerStream
}

type StreamService_BulkEchoClient 

type StreamService_BulkEchoClient interface {
	Send(*sub.StringMessage) error
	Recv() (*sub.StringMessage, error)
	grpc.ClientStream
}

type StreamService_BulkEchoServer 

type StreamService_BulkEchoServer interface {
	Send(*sub.StringMessage) error
	Recv() (*sub.StringMessage, error)
	grpc.ServerStream
}

type StreamService_ListClient 

type StreamService_ListClient interface {
	Recv() (*ABitOfEverything, error)
	grpc.ClientStream
}

type StreamService_ListServer 

type StreamService_ListServer interface {
	Send(*ABitOfEverything) error
	grpc.ServerStream
}

type UnannotatedEchoServiceClient 

type UnannotatedEchoServiceClient interface {
	// Echo method receives a simple message and returns it.
	//
	// The message posted as the id parameter will also be
	// returned.
	Echo(ctx context.Context, in *UnannotatedSimpleMessage, opts ...grpc.CallOption) (*UnannotatedSimpleMessage, error)
	// EchoBody method receives a simple message and returns it.
	EchoBody(ctx context.Context, in *UnannotatedSimpleMessage, opts ...grpc.CallOption) (*UnannotatedSimpleMessage, error)
	// EchoDelete method receives a simple message and returns it.
	EchoDelete(ctx context.Context, in *UnannotatedSimpleMessage, opts ...grpc.CallOption) (*UnannotatedSimpleMessage, error)
}

UnannotatedEchoServiceClient is the client API for UnannotatedEchoService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewUnannotatedEchoServiceClient 

func NewUnannotatedEchoServiceClient(cc *grpc.ClientConn) UnannotatedEchoServiceClient

type UnannotatedEchoServiceServer 

type UnannotatedEchoServiceServer interface {
	// Echo method receives a simple message and returns it.
	//
	// The message posted as the id parameter will also be
	// returned.
	Echo(context.Context, *UnannotatedSimpleMessage) (*UnannotatedSimpleMessage, error)
	// EchoBody method receives a simple message and returns it.
	EchoBody(context.Context, *UnannotatedSimpleMessage) (*UnannotatedSimpleMessage, error)
	// EchoDelete method receives a simple message and returns it.
	EchoDelete(context.Context, *UnannotatedSimpleMessage) (*UnannotatedSimpleMessage, error)
}

UnannotatedEchoServiceServer is the server API for UnannotatedEchoService service.

type UnannotatedSimpleMessage 

type UnannotatedSimpleMessage struct {
	// Id represents the message identifier.
	Id                   string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Num                  int64              `protobuf:"varint,2,opt,name=num,proto3" json:"num,omitempty"`
	Duration             *duration.Duration `protobuf:"bytes,3,opt,name=duration,proto3" json:"duration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

UnannotatedSimpleMessage represents a simple message sent to the unannotated Echo service.

func (*UnannotatedSimpleMessage) Descriptor 

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

func (*UnannotatedSimpleMessage) GetDuration 

func (m *UnannotatedSimpleMessage) GetDuration() *duration.Duration

func (*UnannotatedSimpleMessage) GetId 

func (m *UnannotatedSimpleMessage) GetId() string

func (*UnannotatedSimpleMessage) GetNum 

func (m *UnannotatedSimpleMessage) GetNum() int64

func (*UnannotatedSimpleMessage) ProtoMessage 

func (*UnannotatedSimpleMessage) ProtoMessage()

func (*UnannotatedSimpleMessage) Reset 

func (m *UnannotatedSimpleMessage) Reset()

func (*UnannotatedSimpleMessage) String 

func (m *UnannotatedSimpleMessage) String() string

func (*UnannotatedSimpleMessage) XXX_DiscardUnknown 

func (m *UnannotatedSimpleMessage) XXX_DiscardUnknown()

func (*UnannotatedSimpleMessage) XXX_Marshal 

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

func (*UnannotatedSimpleMessage) XXX_Merge 

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

func (*UnannotatedSimpleMessage) XXX_Size 

func (m *UnannotatedSimpleMessage) XXX_Size() int

func (*UnannotatedSimpleMessage) XXX_Unmarshal 

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

type UnaryProto 

type UnaryProto struct {
	Str                  string   `protobuf:"bytes,1,opt,name=str,proto3" json:"str,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnaryProto) Descriptor 

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

func (*UnaryProto) GetStr 

func (m *UnaryProto) GetStr() string

func (*UnaryProto) ProtoMessage 

func (*UnaryProto) ProtoMessage()

func (*UnaryProto) Reset 

func (m *UnaryProto) Reset()

func (*UnaryProto) String 

func (m *UnaryProto) String() string

func (*UnaryProto) XXX_DiscardUnknown 

func (m *UnaryProto) XXX_DiscardUnknown()

func (*UnaryProto) XXX_Marshal 

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

func (*UnaryProto) XXX_Merge 

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

func (*UnaryProto) XXX_Size 

func (m *UnaryProto) XXX_Size() int

func (*UnaryProto) XXX_Unmarshal 

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

type UpdateV2Request 

type UpdateV2Request struct {
	Abe                  *ABitOfEverything     `protobuf:"bytes,1,opt,name=abe,proto3" json:"abe,omitempty"`
	UpdateMask           *field_mask.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

UpdateV2Request request for update includes the message and the update mask

func (*UpdateV2Request) Descriptor 

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

func (*UpdateV2Request) GetAbe 

func (m *UpdateV2Request) GetAbe() *ABitOfEverything

func (*UpdateV2Request) GetUpdateMask 

func (m *UpdateV2Request) GetUpdateMask() *field_mask.FieldMask

func (*UpdateV2Request) ProtoMessage 

func (*UpdateV2Request) ProtoMessage()

func (*UpdateV2Request) Reset 

func (m *UpdateV2Request) Reset()

func (*UpdateV2Request) String 

func (m *UpdateV2Request) String() string

func (*UpdateV2Request) XXX_DiscardUnknown 

func (m *UpdateV2Request) XXX_DiscardUnknown()

func (*UpdateV2Request) XXX_Marshal 

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

func (*UpdateV2Request) XXX_Merge 

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

func (*UpdateV2Request) XXX_Size 

func (m *UpdateV2Request) XXX_Size() int

func (*UpdateV2Request) XXX_Unmarshal 

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

type Wrappers 

type Wrappers struct {
	StringValue          *wrappers.StringValue `protobuf:"bytes,1,opt,name=string_value,json=stringValue,proto3" json:"string_value,omitempty"`
	Int32Value           *wrappers.Int32Value  `protobuf:"bytes,2,opt,name=int32_value,json=int32Value,proto3" json:"int32_value,omitempty"`
	Int64Value           *wrappers.Int64Value  `protobuf:"bytes,3,opt,name=int64_value,json=int64Value,proto3" json:"int64_value,omitempty"`
	FloatValue           *wrappers.FloatValue  `protobuf:"bytes,4,opt,name=float_value,json=floatValue,proto3" json:"float_value,omitempty"`
	DoubleValue          *wrappers.DoubleValue `protobuf:"bytes,5,opt,name=double_value,json=doubleValue,proto3" json:"double_value,omitempty"`
	BoolValue            *wrappers.BoolValue   `protobuf:"bytes,6,opt,name=bool_value,json=boolValue,proto3" json:"bool_value,omitempty"`
	Uint32Value          *wrappers.UInt32Value `protobuf:"bytes,7,opt,name=uint32_value,json=uint32Value,proto3" json:"uint32_value,omitempty"`
	Uint64Value          *wrappers.UInt64Value `protobuf:"bytes,8,opt,name=uint64_value,json=uint64Value,proto3" json:"uint64_value,omitempty"`
	BytesValue           *wrappers.BytesValue  `protobuf:"bytes,9,opt,name=bytes_value,json=bytesValue,proto3" json:"bytes_value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*Wrappers) Descriptor 

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

func (*Wrappers) GetBoolValue 

func (m *Wrappers) GetBoolValue() *wrappers.BoolValue

func (*Wrappers) GetBytesValue 

func (m *Wrappers) GetBytesValue() *wrappers.BytesValue

func (*Wrappers) GetDoubleValue 

func (m *Wrappers) GetDoubleValue() *wrappers.DoubleValue

func (*Wrappers) GetFloatValue 

func (m *Wrappers) GetFloatValue() *wrappers.FloatValue

func (*Wrappers) GetInt32Value 

func (m *Wrappers) GetInt32Value() *wrappers.Int32Value

func (*Wrappers) GetInt64Value 

func (m *Wrappers) GetInt64Value() *wrappers.Int64Value

func (*Wrappers) GetStringValue 

func (m *Wrappers) GetStringValue() *wrappers.StringValue

func (*Wrappers) GetUint32Value 

func (m *Wrappers) GetUint32Value() *wrappers.UInt32Value

func (*Wrappers) GetUint64Value 

func (m *Wrappers) GetUint64Value() *wrappers.UInt64Value

func (*Wrappers) ProtoMessage 

func (*Wrappers) ProtoMessage()

func (*Wrappers) Reset 

func (m *Wrappers) Reset()

func (*Wrappers) String 

func (m *Wrappers) String() string

func (*Wrappers) XXX_DiscardUnknown 

func (m *Wrappers) XXX_DiscardUnknown()

func (*Wrappers) XXX_Marshal 

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

func (*Wrappers) XXX_Merge 

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

func (*Wrappers) XXX_Size 

func (m *Wrappers) XXX_Size() int

func (*Wrappers) XXX_Unmarshal 

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

type WrappersServiceClient 

type WrappersServiceClient interface {
	Create(ctx context.Context, in *Wrappers, opts ...grpc.CallOption) (*Wrappers, error)
	CreateStringValue(ctx context.Context, in *wrappers.StringValue, opts ...grpc.CallOption) (*wrappers.StringValue, error)
	CreateInt32Value(ctx context.Context, in *wrappers.Int32Value, opts ...grpc.CallOption) (*wrappers.Int32Value, error)
	CreateInt64Value(ctx context.Context, in *wrappers.Int64Value, opts ...grpc.CallOption) (*wrappers.Int64Value, error)
	CreateFloatValue(ctx context.Context, in *wrappers.FloatValue, opts ...grpc.CallOption) (*wrappers.FloatValue, error)
	CreateDoubleValue(ctx context.Context, in *wrappers.DoubleValue, opts ...grpc.CallOption) (*wrappers.DoubleValue, error)
	CreateBoolValue(ctx context.Context, in *wrappers.BoolValue, opts ...grpc.CallOption) (*wrappers.BoolValue, error)
	CreateUInt32Value(ctx context.Context, in *wrappers.UInt32Value, opts ...grpc.CallOption) (*wrappers.UInt32Value, error)
	CreateUInt64Value(ctx context.Context, in *wrappers.UInt64Value, opts ...grpc.CallOption) (*wrappers.UInt64Value, error)
	CreateBytesValue(ctx context.Context, in *wrappers.BytesValue, opts ...grpc.CallOption) (*wrappers.BytesValue, error)
	CreateEmpty(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
}

WrappersServiceClient is the client API for WrappersService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewWrappersServiceClient 

func NewWrappersServiceClient(cc *grpc.ClientConn) WrappersServiceClient

type WrappersServiceServer 

type WrappersServiceServer interface {
	Create(context.Context, *Wrappers) (*Wrappers, error)
	CreateStringValue(context.Context, *wrappers.StringValue) (*wrappers.StringValue, error)
	CreateInt32Value(context.Context, *wrappers.Int32Value) (*wrappers.Int32Value, error)
	CreateInt64Value(context.Context, *wrappers.Int64Value) (*wrappers.Int64Value, error)
	CreateFloatValue(context.Context, *wrappers.FloatValue) (*wrappers.FloatValue, error)
	CreateDoubleValue(context.Context, *wrappers.DoubleValue) (*wrappers.DoubleValue, error)
	CreateBoolValue(context.Context, *wrappers.BoolValue) (*wrappers.BoolValue, error)
	CreateUInt32Value(context.Context, *wrappers.UInt32Value) (*wrappers.UInt32Value, error)
	CreateUInt64Value(context.Context, *wrappers.UInt64Value) (*wrappers.UInt64Value, error)
	CreateBytesValue(context.Context, *wrappers.BytesValue) (*wrappers.BytesValue, error)
	CreateEmpty(context.Context, *empty.Empty) (*empty.Empty, error)
}

WrappersServiceServer is the server API for WrappersService 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.