Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer)
- type Combined
- type Digits
- type FlowAction
- func (*FlowAction) Descriptor() ([]byte, []int)deprecated
- func (m *FlowAction) GetAction() isFlowAction_Action
- func (x *FlowAction) GetExpectClose() bool
- func (x *FlowAction) GetExpectMessage() *FlowMessage
- func (x *FlowAction) GetSendMessage() *FlowMessage
- func (x *FlowAction) GetSendStatus() *status.Status
- func (x *FlowAction) GetSleep() *durationpb.Duration
- func (*FlowAction) ProtoMessage()
- func (x *FlowAction) ProtoReflect() protoreflect.Message
- func (x *FlowAction) Reset()
- func (x *FlowAction) String() string
- type FlowAction_ExpectClose
- type FlowAction_ExpectMessage
- type FlowAction_SendMessage
- type FlowAction_SendStatus
- type FlowAction_Sleep
- type FlowMessage
- type NonScalars
- func (*NonScalars) Descriptor() ([]byte, []int)deprecated
- func (x *NonScalars) GetChild() *NonScalars_Child
- func (x *NonScalars) GetDuration() *durationpb.Duration
- func (x *NonScalars) GetInt2EmptyMap() map[int32]*emptypb.Empty
- func (x *NonScalars) GetMsgList() []*NonScalars_Child
- func (x *NonScalars) GetRootDigits() Digits
- func (x *NonScalars) GetStr2Int32Map() map[string]int32
- func (x *NonScalars) GetStr2StrMap() map[string]string
- func (x *NonScalars) GetStrList() []string
- func (*NonScalars) ProtoMessage()
- func (x *NonScalars) ProtoReflect() protoreflect.Message
- func (x *NonScalars) Reset()
- func (x *NonScalars) String() string
- type NonScalars_Child
- func (*NonScalars_Child) Descriptor() ([]byte, []int)deprecated
- func (x *NonScalars_Child) GetDigits() Digits
- func (x *NonScalars_Child) GetExtraScalars() *Scalars
- func (x *NonScalars_Child) GetGrandChild() *NonScalars_Child_GrandChild
- func (m *NonScalars_Child) GetNested() isNonScalars_Child_Nested
- func (*NonScalars_Child) ProtoMessage()
- func (x *NonScalars_Child) ProtoReflect() protoreflect.Message
- func (x *NonScalars_Child) Reset()
- func (x *NonScalars_Child) String() string
- type NonScalars_Child_Digits
- type NonScalars_Child_GrandChild
- func (*NonScalars_Child_GrandChild) Descriptor() ([]byte, []int)deprecated
- func (x *NonScalars_Child_GrandChild) GetBytesValue() []byte
- func (*NonScalars_Child_GrandChild) ProtoMessage()
- func (x *NonScalars_Child_GrandChild) ProtoReflect() protoreflect.Message
- func (x *NonScalars_Child_GrandChild) Reset()
- func (x *NonScalars_Child_GrandChild) String() string
- type NonScalars_Child_GrandChild_
- type PreparedResponse
- type Scalars
- func (*Scalars) Descriptor() ([]byte, []int)deprecated
- func (x *Scalars) GetBoolValue() bool
- func (x *Scalars) GetBytesValue() []byte
- func (x *Scalars) GetDoubleValue() float64
- func (x *Scalars) GetFixed32Value() uint32
- func (x *Scalars) GetFixed64Value() uint64
- func (x *Scalars) GetFloatValue() float32
- func (x *Scalars) GetInt32Value() int32
- func (x *Scalars) GetInt64Value() int64
- func (x *Scalars) GetSfixed32Value() int32
- func (x *Scalars) GetSfixed64Value() int64
- func (x *Scalars) GetSint32Value() int32
- func (x *Scalars) GetSint64Value() int64
- func (x *Scalars) GetStringValue() string
- func (x *Scalars) GetUint32Value() uint32
- func (x *Scalars) GetUint64Value() uint64
- func (*Scalars) ProtoMessage()
- func (x *Scalars) ProtoReflect() protoreflect.Message
- func (x *Scalars) Reset()
- func (x *Scalars) String() string
- type TestService
- func (s *TestService) AddFlow(flow []*FlowAction) string
- func (s *TestService) BadResponsePath(context.Context, *Scalars) (*Combined, error)
- func (s *TestService) Echo(ctx context.Context, req *Combined) (*Combined, error)
- func (s *TestService) ServerFlow(msg *FlowMessage, stream TestService_ServerFlowServer) error
- func (s *TestService) UnaryBound(ctx context.Context, req *Scalars) (*Combined, error)
- type TestServiceClient
- type TestServiceServer
- type TestService_BiDiFlowClient
- type TestService_BiDiFlowServer
- type TestService_ClientFlowClient
- type TestService_ClientFlowServer
- type TestService_ServerFlowClient
- type TestService_ServerFlowServer
- type UnimplementedTestServiceServer
- func (UnimplementedTestServiceServer) BadResponsePath(context.Context, *Scalars) (*Combined, error)
- func (UnimplementedTestServiceServer) BiDiFlow(TestService_BiDiFlowServer) error
- func (UnimplementedTestServiceServer) ClientFlow(TestService_ClientFlowServer) error
- func (UnimplementedTestServiceServer) Echo(context.Context, *Combined) (*Combined, error)
- func (UnimplementedTestServiceServer) ServerFlow(*FlowMessage, TestService_ServerFlowServer) error
- func (UnimplementedTestServiceServer) UnaryBound(context.Context, *Scalars) (*Combined, error)
- func (UnimplementedTestServiceServer) UnaryCombined(context.Context, *Combined) (*Combined, error)
- func (UnimplementedTestServiceServer) UnaryFlow(context.Context, *FlowMessage) (*FlowMessage, error)
- func (UnimplementedTestServiceServer) UnaryUnbound(context.Context, *Scalars) (*Scalars, error)
- type UnsafeTestServiceServer
- type WellKnown
Constants ¶
const ( TestService_UnaryUnbound_FullMethodName = "/grpcbridge.internal.bridgetest.testpb.TestService/UnaryUnbound" TestService_UnaryBound_FullMethodName = "/grpcbridge.internal.bridgetest.testpb.TestService/UnaryBound" TestService_UnaryCombined_FullMethodName = "/grpcbridge.internal.bridgetest.testpb.TestService/UnaryCombined" TestService_BadResponsePath_FullMethodName = "/grpcbridge.internal.bridgetest.testpb.TestService/BadResponsePath" TestService_Echo_FullMethodName = "/grpcbridge.internal.bridgetest.testpb.TestService/Echo" TestService_UnaryFlow_FullMethodName = "/grpcbridge.internal.bridgetest.testpb.TestService/UnaryFlow" TestService_ClientFlow_FullMethodName = "/grpcbridge.internal.bridgetest.testpb.TestService/ClientFlow" TestService_ServerFlow_FullMethodName = "/grpcbridge.internal.bridgetest.testpb.TestService/ServerFlow" TestService_BiDiFlow_FullMethodName = "/grpcbridge.internal.bridgetest.testpb.TestService/BiDiFlow" )
const FlowMetadataKey = "flow-id"
Variables ¶
var ( Digits_name = map[int32]string{ 0: "ZERO", 1: "ONE", 2: "TWO", } Digits_value = map[string]int32{ "ZERO": 0, "NONE": 0, "ONE": 1, "TWO": 2, } )
Enum value maps for Digits.
var ( TestServiceFDs *descriptorpb.FileDescriptorSet TestServiceFileResolver *protoregistry.Files TestServiceTypesResolver *dynamicpb.Types TestServiceDesc *bridgedesc.Target )
TestServiceFDs is a set of the raw protobuf file descriptors for TestService.
var File_messages_proto protoreflect.FileDescriptor
var File_testsvc_proto protoreflect.FileDescriptor
var TestService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpcbridge.internal.bridgetest.testpb.TestService", HandlerType: (*TestServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "UnaryUnbound", Handler: _TestService_UnaryUnbound_Handler, }, { MethodName: "UnaryBound", Handler: _TestService_UnaryBound_Handler, }, { MethodName: "UnaryCombined", Handler: _TestService_UnaryCombined_Handler, }, { MethodName: "BadResponsePath", Handler: _TestService_BadResponsePath_Handler, }, { MethodName: "Echo", Handler: _TestService_Echo_Handler, }, { MethodName: "UnaryFlow", Handler: _TestService_UnaryFlow_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "ClientFlow", Handler: _TestService_ClientFlow_Handler, ClientStreams: true, }, { StreamName: "ServerFlow", Handler: _TestService_ServerFlow_Handler, ServerStreams: true, }, { StreamName: "BiDiFlow", Handler: _TestService_BiDiFlow_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "testsvc.proto", }
TestService_ServiceDesc is the grpc.ServiceDesc for TestService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterTestServiceServer ¶
func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer)
Types ¶
type Combined ¶
type Combined struct { Scalars *Scalars `protobuf:"bytes,1,opt,name=scalars,proto3" json:"scalars,omitempty"` NonScalars *NonScalars `protobuf:"bytes,2,opt,name=non_scalars,json=nonScalars,proto3" json:"non_scalars,omitempty"` // contains filtered or unexported fields }
func (*Combined) Descriptor
deprecated
func (*Combined) GetNonScalars ¶
func (x *Combined) GetNonScalars() *NonScalars
func (*Combined) GetScalars ¶
func (*Combined) ProtoMessage ¶
func (*Combined) ProtoMessage()
func (*Combined) ProtoReflect ¶
func (x *Combined) ProtoReflect() protoreflect.Message
type Digits ¶
type Digits int32
func (Digits) Descriptor ¶
func (Digits) Descriptor() protoreflect.EnumDescriptor
func (Digits) EnumDescriptor
deprecated
func (Digits) Number ¶
func (x Digits) Number() protoreflect.EnumNumber
func (Digits) Type ¶
func (Digits) Type() protoreflect.EnumType
type FlowAction ¶ added in v0.1.0
type FlowAction struct { // Types that are assignable to Action: // // *FlowAction_ExpectMessage // *FlowAction_ExpectClose // *FlowAction_SendMessage // *FlowAction_SendStatus // *FlowAction_Sleep Action isFlowAction_Action `protobuf_oneof:"action"` // contains filtered or unexported fields }
FlowAction is used by TestService to control the execution of Flow endpoints.
func (*FlowAction) Descriptor
deprecated
added in
v0.1.0
func (*FlowAction) Descriptor() ([]byte, []int)
Deprecated: Use FlowAction.ProtoReflect.Descriptor instead.
func (*FlowAction) GetAction ¶ added in v0.1.0
func (m *FlowAction) GetAction() isFlowAction_Action
func (*FlowAction) GetExpectClose ¶ added in v0.1.0
func (x *FlowAction) GetExpectClose() bool
func (*FlowAction) GetExpectMessage ¶ added in v0.1.0
func (x *FlowAction) GetExpectMessage() *FlowMessage
func (*FlowAction) GetSendMessage ¶ added in v0.1.0
func (x *FlowAction) GetSendMessage() *FlowMessage
func (*FlowAction) GetSendStatus ¶ added in v0.1.0
func (x *FlowAction) GetSendStatus() *status.Status
func (*FlowAction) GetSleep ¶ added in v0.1.0
func (x *FlowAction) GetSleep() *durationpb.Duration
func (*FlowAction) ProtoMessage ¶ added in v0.1.0
func (*FlowAction) ProtoMessage()
func (*FlowAction) ProtoReflect ¶ added in v0.1.0
func (x *FlowAction) ProtoReflect() protoreflect.Message
func (*FlowAction) Reset ¶ added in v0.1.0
func (x *FlowAction) Reset()
func (*FlowAction) String ¶ added in v0.1.0
func (x *FlowAction) String() string
type FlowAction_ExpectClose ¶ added in v0.1.0
type FlowAction_ExpectClose struct {
ExpectClose bool `protobuf:"varint,2,opt,name=expect_close,json=expectClose,proto3,oneof"`
}
type FlowAction_ExpectMessage ¶ added in v0.1.0
type FlowAction_ExpectMessage struct {
ExpectMessage *FlowMessage `protobuf:"bytes,1,opt,name=expect_message,json=expectMessage,proto3,oneof"`
}
type FlowAction_SendMessage ¶ added in v0.1.0
type FlowAction_SendMessage struct {
SendMessage *FlowMessage `protobuf:"bytes,3,opt,name=send_message,json=sendMessage,proto3,oneof"`
}
type FlowAction_SendStatus ¶ added in v0.1.0
type FlowAction_Sleep ¶ added in v0.1.0
type FlowAction_Sleep struct {
Sleep *durationpb.Duration `protobuf:"bytes,5,opt,name=sleep,proto3,oneof"`
}
type FlowMessage ¶ added in v0.1.0
type FlowMessage struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*FlowMessage) Descriptor
deprecated
added in
v0.1.0
func (*FlowMessage) Descriptor() ([]byte, []int)
Deprecated: Use FlowMessage.ProtoReflect.Descriptor instead.
func (*FlowMessage) GetMessage ¶ added in v0.1.0
func (x *FlowMessage) GetMessage() string
func (*FlowMessage) ProtoMessage ¶ added in v0.1.0
func (*FlowMessage) ProtoMessage()
func (*FlowMessage) ProtoReflect ¶ added in v0.1.0
func (x *FlowMessage) ProtoReflect() protoreflect.Message
func (*FlowMessage) Reset ¶ added in v0.1.0
func (x *FlowMessage) Reset()
func (*FlowMessage) String ¶ added in v0.1.0
func (x *FlowMessage) String() string
type NonScalars ¶
type NonScalars struct { Str2StrMap map[string]string `` /* 179-byte string literal not displayed */ Str2Int32Map map[string]int32 `` /* 186-byte string literal not displayed */ Int2EmptyMap map[int32]*emptypb.Empty `` /* 186-byte string literal not displayed */ StrList []string `protobuf:"bytes,4,rep,name=str_list,json=strList,proto3" json:"str_list,omitempty"` MsgList []*NonScalars_Child `protobuf:"bytes,5,rep,name=msg_list,json=msgList,proto3" json:"msg_list,omitempty"` RootDigits Digits `` /* 142-byte string literal not displayed */ Duration *durationpb.Duration `protobuf:"bytes,7,opt,name=duration,proto3" json:"duration,omitempty"` Child *NonScalars_Child `protobuf:"bytes,8,opt,name=child,proto3" json:"child,omitempty"` // contains filtered or unexported fields }
func (*NonScalars) Descriptor
deprecated
func (*NonScalars) Descriptor() ([]byte, []int)
Deprecated: Use NonScalars.ProtoReflect.Descriptor instead.
func (*NonScalars) GetChild ¶
func (x *NonScalars) GetChild() *NonScalars_Child
func (*NonScalars) GetDuration ¶
func (x *NonScalars) GetDuration() *durationpb.Duration
func (*NonScalars) GetInt2EmptyMap ¶
func (x *NonScalars) GetInt2EmptyMap() map[int32]*emptypb.Empty
func (*NonScalars) GetMsgList ¶
func (x *NonScalars) GetMsgList() []*NonScalars_Child
func (*NonScalars) GetRootDigits ¶
func (x *NonScalars) GetRootDigits() Digits
func (*NonScalars) GetStr2Int32Map ¶
func (x *NonScalars) GetStr2Int32Map() map[string]int32
func (*NonScalars) GetStr2StrMap ¶
func (x *NonScalars) GetStr2StrMap() map[string]string
func (*NonScalars) GetStrList ¶
func (x *NonScalars) GetStrList() []string
func (*NonScalars) ProtoMessage ¶
func (*NonScalars) ProtoMessage()
func (*NonScalars) ProtoReflect ¶
func (x *NonScalars) ProtoReflect() protoreflect.Message
func (*NonScalars) Reset ¶
func (x *NonScalars) Reset()
func (*NonScalars) String ¶
func (x *NonScalars) String() string
type NonScalars_Child ¶
type NonScalars_Child struct { // Types that are assignable to Nested: // // *NonScalars_Child_Digits // *NonScalars_Child_GrandChild_ Nested isNonScalars_Child_Nested `protobuf_oneof:"nested"` ExtraScalars *Scalars `protobuf:"bytes,3,opt,name=extra_scalars,json=extraScalars,proto3" json:"extra_scalars,omitempty"` // contains filtered or unexported fields }
func (*NonScalars_Child) Descriptor
deprecated
func (*NonScalars_Child) Descriptor() ([]byte, []int)
Deprecated: Use NonScalars_Child.ProtoReflect.Descriptor instead.
func (*NonScalars_Child) GetDigits ¶
func (x *NonScalars_Child) GetDigits() Digits
func (*NonScalars_Child) GetExtraScalars ¶
func (x *NonScalars_Child) GetExtraScalars() *Scalars
func (*NonScalars_Child) GetGrandChild ¶
func (x *NonScalars_Child) GetGrandChild() *NonScalars_Child_GrandChild
func (*NonScalars_Child) GetNested ¶
func (m *NonScalars_Child) GetNested() isNonScalars_Child_Nested
func (*NonScalars_Child) ProtoMessage ¶
func (*NonScalars_Child) ProtoMessage()
func (*NonScalars_Child) ProtoReflect ¶
func (x *NonScalars_Child) ProtoReflect() protoreflect.Message
func (*NonScalars_Child) Reset ¶
func (x *NonScalars_Child) Reset()
func (*NonScalars_Child) String ¶
func (x *NonScalars_Child) String() string
type NonScalars_Child_Digits ¶
type NonScalars_Child_Digits struct {
Digits Digits `protobuf:"varint,1,opt,name=digits,proto3,enum=grpcbridge.internal.bridgetest.testpb.Digits,oneof"`
}
type NonScalars_Child_GrandChild ¶
type NonScalars_Child_GrandChild struct { BytesValue []byte `protobuf:"bytes,1,opt,name=bytes_value,json=bytesValue,proto3" json:"bytes_value,omitempty"` // contains filtered or unexported fields }
func (*NonScalars_Child_GrandChild) Descriptor
deprecated
func (*NonScalars_Child_GrandChild) Descriptor() ([]byte, []int)
Deprecated: Use NonScalars_Child_GrandChild.ProtoReflect.Descriptor instead.
func (*NonScalars_Child_GrandChild) GetBytesValue ¶
func (x *NonScalars_Child_GrandChild) GetBytesValue() []byte
func (*NonScalars_Child_GrandChild) ProtoMessage ¶
func (*NonScalars_Child_GrandChild) ProtoMessage()
func (*NonScalars_Child_GrandChild) ProtoReflect ¶
func (x *NonScalars_Child_GrandChild) ProtoReflect() protoreflect.Message
func (*NonScalars_Child_GrandChild) Reset ¶
func (x *NonScalars_Child_GrandChild) Reset()
func (*NonScalars_Child_GrandChild) String ¶
func (x *NonScalars_Child_GrandChild) String() string
type NonScalars_Child_GrandChild_ ¶
type NonScalars_Child_GrandChild_ struct {
GrandChild *NonScalars_Child_GrandChild `protobuf:"bytes,2,opt,name=grand_child,json=grandChild,proto3,oneof"`
}
type PreparedResponse ¶
func PrepareResponse ¶
func PrepareResponse[T proto.Message](response T, err error) *PreparedResponse[T]
type Scalars ¶
type Scalars struct { BoolValue bool `protobuf:"varint,1,opt,name=bool_value,json=boolValue,proto3" json:"bool_value,omitempty"` Int32Value int32 `protobuf:"varint,2,opt,name=int32_value,json=int32Value,proto3" json:"int32_value,omitempty"` Int64Value int64 `protobuf:"varint,3,opt,name=int64_value,json=int64Value,proto3" json:"int64_value,omitempty"` Uint32Value uint32 `protobuf:"varint,4,opt,name=uint32_value,json=uint32Value,proto3" json:"uint32_value,omitempty"` Uint64Value uint64 `protobuf:"varint,5,opt,name=uint64_value,json=uint64Value,proto3" json:"uint64_value,omitempty"` Sint32Value int32 `protobuf:"zigzag32,6,opt,name=sint32_value,json=sint32Value,proto3" json:"sint32_value,omitempty"` Sint64Value int64 `protobuf:"zigzag64,7,opt,name=sint64_value,json=sint64Value,proto3" json:"sint64_value,omitempty"` Fixed32Value uint32 `protobuf:"fixed32,8,opt,name=fixed32_value,json=fixed32Value,proto3" json:"fixed32_value,omitempty"` Fixed64Value uint64 `protobuf:"fixed64,9,opt,name=fixed64_value,json=fixed64Value,proto3" json:"fixed64_value,omitempty"` Sfixed32Value int32 `protobuf:"fixed32,10,opt,name=sfixed32_value,json=sfixed32Value,proto3" json:"sfixed32_value,omitempty"` Sfixed64Value int64 `protobuf:"fixed64,11,opt,name=sfixed64_value,json=sfixed64Value,proto3" json:"sfixed64_value,omitempty"` FloatValue float32 `protobuf:"fixed32,12,opt,name=float_value,json=floatValue,proto3" json:"float_value,omitempty"` DoubleValue float64 `protobuf:"fixed64,13,opt,name=double_value,json=doubleValue,proto3" json:"double_value,omitempty"` StringValue string `protobuf:"bytes,14,opt,name=string_value,json=stringValue,proto3" json:"string_value,omitempty"` BytesValue []byte `protobuf:"bytes,15,opt,name=bytes_value,json=bytesValue,proto3" json:"bytes_value,omitempty"` // contains filtered or unexported fields }
func (*Scalars) Descriptor
deprecated
func (*Scalars) GetBoolValue ¶
func (*Scalars) GetBytesValue ¶
func (*Scalars) GetDoubleValue ¶
func (*Scalars) GetFixed32Value ¶
func (*Scalars) GetFixed64Value ¶
func (*Scalars) GetFloatValue ¶
func (*Scalars) GetInt32Value ¶
func (*Scalars) GetInt64Value ¶
func (*Scalars) GetSfixed32Value ¶
func (*Scalars) GetSfixed64Value ¶
func (*Scalars) GetSint32Value ¶
func (*Scalars) GetSint64Value ¶
func (*Scalars) GetStringValue ¶
func (*Scalars) GetUint32Value ¶
func (*Scalars) GetUint64Value ¶
func (*Scalars) ProtoMessage ¶
func (*Scalars) ProtoMessage()
func (*Scalars) ProtoReflect ¶
func (x *Scalars) ProtoReflect() protoreflect.Message
type TestService ¶
type TestService struct { UnimplementedTestServiceServer UnaryBoundRequest *Scalars UnaryBoundResponse *PreparedResponse[*Combined] // contains filtered or unexported fields }
TestService implements the test gRPC service with handlers which simply record the requests and return predetermined responses.
func NewTestService ¶ added in v0.1.0
func NewTestService() *TestService
func (*TestService) AddFlow ¶ added in v0.1.0
func (s *TestService) AddFlow(flow []*FlowAction) string
AddFlow adds a flow and returns its ID to be sent in the metadata.
func (*TestService) BadResponsePath ¶
func (*TestService) ServerFlow ¶ added in v0.1.0
func (s *TestService) ServerFlow(msg *FlowMessage, stream TestService_ServerFlowServer) error
ServerFlow simulates a pre-defined flow for a server-side stream.
func (*TestService) UnaryBound ¶
type TestServiceClient ¶
type TestServiceClient interface { UnaryUnbound(ctx context.Context, in *Scalars, opts ...grpc.CallOption) (*Scalars, error) UnaryBound(ctx context.Context, in *Scalars, opts ...grpc.CallOption) (*Combined, error) UnaryCombined(ctx context.Context, in *Combined, opts ...grpc.CallOption) (*Combined, error) BadResponsePath(ctx context.Context, in *Scalars, opts ...grpc.CallOption) (*Combined, error) Echo(ctx context.Context, in *Combined, opts ...grpc.CallOption) (*Combined, error) // Flow handlers are used to test various streaming flow scenarios. UnaryFlow(ctx context.Context, in *FlowMessage, opts ...grpc.CallOption) (*FlowMessage, error) ClientFlow(ctx context.Context, opts ...grpc.CallOption) (TestService_ClientFlowClient, error) ServerFlow(ctx context.Context, in *FlowMessage, opts ...grpc.CallOption) (TestService_ServerFlowClient, error) BiDiFlow(ctx context.Context, opts ...grpc.CallOption) (TestService_BiDiFlowClient, error) }
TestServiceClient is the client API for TestService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkgo.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewTestServiceClient ¶
func NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient
type TestServiceServer ¶
type TestServiceServer interface { UnaryUnbound(context.Context, *Scalars) (*Scalars, error) UnaryBound(context.Context, *Scalars) (*Combined, error) UnaryCombined(context.Context, *Combined) (*Combined, error) BadResponsePath(context.Context, *Scalars) (*Combined, error) Echo(context.Context, *Combined) (*Combined, error) // Flow handlers are used to test various streaming flow scenarios. UnaryFlow(context.Context, *FlowMessage) (*FlowMessage, error) ClientFlow(TestService_ClientFlowServer) error ServerFlow(*FlowMessage, TestService_ServerFlowServer) error BiDiFlow(TestService_BiDiFlowServer) error // contains filtered or unexported methods }
TestServiceServer is the server API for TestService service. All implementations must embed UnimplementedTestServiceServer for forward compatibility
type TestService_BiDiFlowClient ¶ added in v0.1.0
type TestService_BiDiFlowClient interface { Send(*FlowMessage) error Recv() (*FlowMessage, error) grpc.ClientStream }
type TestService_BiDiFlowServer ¶ added in v0.1.0
type TestService_BiDiFlowServer interface { Send(*FlowMessage) error Recv() (*FlowMessage, error) grpc.ServerStream }
type TestService_ClientFlowClient ¶ added in v0.1.0
type TestService_ClientFlowClient interface { Send(*FlowMessage) error CloseAndRecv() (*FlowMessage, error) grpc.ClientStream }
type TestService_ClientFlowServer ¶ added in v0.1.0
type TestService_ClientFlowServer interface { SendAndClose(*FlowMessage) error Recv() (*FlowMessage, error) grpc.ServerStream }
type TestService_ServerFlowClient ¶ added in v0.1.0
type TestService_ServerFlowClient interface { Recv() (*FlowMessage, error) grpc.ClientStream }
type TestService_ServerFlowServer ¶ added in v0.1.0
type TestService_ServerFlowServer interface { Send(*FlowMessage) error grpc.ServerStream }
type UnimplementedTestServiceServer ¶
type UnimplementedTestServiceServer struct { }
UnimplementedTestServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedTestServiceServer) BadResponsePath ¶
func (UnimplementedTestServiceServer) BiDiFlow ¶ added in v0.1.0
func (UnimplementedTestServiceServer) BiDiFlow(TestService_BiDiFlowServer) error
func (UnimplementedTestServiceServer) ClientFlow ¶ added in v0.1.0
func (UnimplementedTestServiceServer) ClientFlow(TestService_ClientFlowServer) error
func (UnimplementedTestServiceServer) ServerFlow ¶ added in v0.1.0
func (UnimplementedTestServiceServer) ServerFlow(*FlowMessage, TestService_ServerFlowServer) error
func (UnimplementedTestServiceServer) UnaryBound ¶
func (UnimplementedTestServiceServer) UnaryCombined ¶
func (UnimplementedTestServiceServer) UnaryFlow ¶ added in v0.1.0
func (UnimplementedTestServiceServer) UnaryFlow(context.Context, *FlowMessage) (*FlowMessage, error)
func (UnimplementedTestServiceServer) UnaryUnbound ¶
type UnsafeTestServiceServer ¶
type UnsafeTestServiceServer interface {
// contains filtered or unexported methods
}
UnsafeTestServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TestServiceServer will result in compilation errors.
type WellKnown ¶
type WellKnown struct { NullValue structpb.NullValue `protobuf:"varint,1,opt,name=null_value,json=nullValue,proto3,enum=google.protobuf.NullValue" json:"null_value,omitempty"` // contains filtered or unexported fields }
func (*WellKnown) Descriptor
deprecated
func (*WellKnown) GetNullValue ¶
func (*WellKnown) ProtoMessage ¶
func (*WellKnown) ProtoMessage()
func (*WellKnown) ProtoReflect ¶
func (x *WellKnown) ProtoReflect() protoreflect.Message