Documentation ¶
Overview ¶
Package improbable_grpcweb_test is a generated protocol buffer package.
It is generated from these files:
improbable/grpcweb/test/test.proto
It has these top-level messages:
PingRequest PingResponse TextMessage ContinueStreamRequest CheckStreamClosedRequest CheckStreamClosedResponse
Index ¶
- Variables
- func RegisterFailServiceServer(s *grpc.Server, srv FailServiceServer)
- func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer)
- func RegisterTestUtilServiceServer(s *grpc.Server, srv TestUtilServiceServer)
- type CheckStreamClosedRequest
- type CheckStreamClosedResponse
- type ContinueStreamRequest
- type FailServiceClient
- type FailServiceServer
- type PingRequest
- func (*PingRequest) Descriptor() ([]byte, []int)
- func (m *PingRequest) GetCheckMetadata() bool
- func (m *PingRequest) GetErrorCodeReturned() uint32
- func (m *PingRequest) GetFailureType() PingRequest_FailureType
- func (m *PingRequest) GetResponseCount() int32
- func (m *PingRequest) GetSendHeaders() bool
- func (m *PingRequest) GetSendTrailers() bool
- func (m *PingRequest) GetStreamIdentifier() string
- func (m *PingRequest) GetValue() string
- func (*PingRequest) ProtoMessage()
- func (m *PingRequest) Reset()
- func (m *PingRequest) String() string
- type PingRequest_FailureType
- type PingResponse
- type TestServiceClient
- type TestServiceServer
- type TestService_PingListClient
- type TestService_PingListServer
- type TestService_PingPongBidiClient
- type TestService_PingPongBidiServer
- type TestService_PingStreamClient
- type TestService_PingStreamServer
- type TestUtilServiceClient
- type TestUtilServiceServer
- type TextMessage
Constants ¶
This section is empty.
Variables ¶
View Source
var PingRequest_FailureType_name = map[int32]string{
0: "NONE",
1: "CODE",
2: "DROP",
3: "CODE_UNICODE",
}
View Source
var PingRequest_FailureType_value = map[string]int32{
"NONE": 0,
"CODE": 1,
"DROP": 2,
"CODE_UNICODE": 3,
}
Functions ¶
func RegisterFailServiceServer ¶
func RegisterFailServiceServer(s *grpc.Server, srv FailServiceServer)
func RegisterTestServiceServer ¶
func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer)
func RegisterTestUtilServiceServer ¶
func RegisterTestUtilServiceServer(s *grpc.Server, srv TestUtilServiceServer)
Types ¶
type CheckStreamClosedRequest ¶
type CheckStreamClosedRequest struct {
StreamIdentifier string `protobuf:"bytes,1,opt,name=stream_identifier,json=streamIdentifier" json:"stream_identifier,omitempty"`
}
func (*CheckStreamClosedRequest) Descriptor ¶
func (*CheckStreamClosedRequest) Descriptor() ([]byte, []int)
func (*CheckStreamClosedRequest) GetStreamIdentifier ¶
func (m *CheckStreamClosedRequest) GetStreamIdentifier() string
func (*CheckStreamClosedRequest) ProtoMessage ¶
func (*CheckStreamClosedRequest) ProtoMessage()
func (*CheckStreamClosedRequest) Reset ¶
func (m *CheckStreamClosedRequest) Reset()
func (*CheckStreamClosedRequest) String ¶
func (m *CheckStreamClosedRequest) String() string
type CheckStreamClosedResponse ¶
type CheckStreamClosedResponse struct {
Closed bool `protobuf:"varint,1,opt,name=closed" json:"closed,omitempty"`
}
func (*CheckStreamClosedResponse) Descriptor ¶
func (*CheckStreamClosedResponse) Descriptor() ([]byte, []int)
func (*CheckStreamClosedResponse) GetClosed ¶
func (m *CheckStreamClosedResponse) GetClosed() bool
func (*CheckStreamClosedResponse) ProtoMessage ¶
func (*CheckStreamClosedResponse) ProtoMessage()
func (*CheckStreamClosedResponse) Reset ¶
func (m *CheckStreamClosedResponse) Reset()
func (*CheckStreamClosedResponse) String ¶
func (m *CheckStreamClosedResponse) String() string
type ContinueStreamRequest ¶
type ContinueStreamRequest struct {
StreamIdentifier string `protobuf:"bytes,1,opt,name=stream_identifier,json=streamIdentifier" json:"stream_identifier,omitempty"`
}
func (*ContinueStreamRequest) Descriptor ¶
func (*ContinueStreamRequest) Descriptor() ([]byte, []int)
func (*ContinueStreamRequest) GetStreamIdentifier ¶
func (m *ContinueStreamRequest) GetStreamIdentifier() string
func (*ContinueStreamRequest) ProtoMessage ¶
func (*ContinueStreamRequest) ProtoMessage()
func (*ContinueStreamRequest) Reset ¶
func (m *ContinueStreamRequest) Reset()
func (*ContinueStreamRequest) String ¶
func (m *ContinueStreamRequest) String() string
type FailServiceClient ¶
type FailServiceClient interface {
NonExistant(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
}
func NewFailServiceClient ¶
func NewFailServiceClient(cc *grpc.ClientConn) FailServiceClient
type FailServiceServer ¶
type FailServiceServer interface {
NonExistant(context.Context, *PingRequest) (*PingResponse, error)
}
type PingRequest ¶
type PingRequest struct { Value string `protobuf:"bytes,1,opt,name=value" json:"value,omitempty"` ResponseCount int32 `protobuf:"varint,2,opt,name=response_count,json=responseCount" json:"response_count,omitempty"` ErrorCodeReturned uint32 `protobuf:"varint,3,opt,name=error_code_returned,json=errorCodeReturned" json:"error_code_returned,omitempty"` FailureType PingRequest_FailureType `` /* 141-byte string literal not displayed */ CheckMetadata bool `protobuf:"varint,5,opt,name=check_metadata,json=checkMetadata" json:"check_metadata,omitempty"` SendHeaders bool `protobuf:"varint,6,opt,name=send_headers,json=sendHeaders" json:"send_headers,omitempty"` SendTrailers bool `protobuf:"varint,7,opt,name=send_trailers,json=sendTrailers" json:"send_trailers,omitempty"` StreamIdentifier string `protobuf:"bytes,8,opt,name=stream_identifier,json=streamIdentifier" json:"stream_identifier,omitempty"` }
func (*PingRequest) Descriptor ¶
func (*PingRequest) Descriptor() ([]byte, []int)
func (*PingRequest) GetCheckMetadata ¶
func (m *PingRequest) GetCheckMetadata() bool
func (*PingRequest) GetErrorCodeReturned ¶
func (m *PingRequest) GetErrorCodeReturned() uint32
func (*PingRequest) GetFailureType ¶
func (m *PingRequest) GetFailureType() PingRequest_FailureType
func (*PingRequest) GetResponseCount ¶
func (m *PingRequest) GetResponseCount() int32
func (*PingRequest) GetSendHeaders ¶
func (m *PingRequest) GetSendHeaders() bool
func (*PingRequest) GetSendTrailers ¶
func (m *PingRequest) GetSendTrailers() bool
func (*PingRequest) GetStreamIdentifier ¶
func (m *PingRequest) GetStreamIdentifier() string
func (*PingRequest) GetValue ¶
func (m *PingRequest) GetValue() string
func (*PingRequest) ProtoMessage ¶
func (*PingRequest) ProtoMessage()
func (*PingRequest) Reset ¶
func (m *PingRequest) Reset()
func (*PingRequest) String ¶
func (m *PingRequest) String() string
type PingRequest_FailureType ¶
type PingRequest_FailureType int32
const ( PingRequest_NONE PingRequest_FailureType = 0 PingRequest_CODE PingRequest_FailureType = 1 PingRequest_DROP PingRequest_FailureType = 2 PingRequest_CODE_UNICODE PingRequest_FailureType = 3 )
func (PingRequest_FailureType) EnumDescriptor ¶
func (PingRequest_FailureType) EnumDescriptor() ([]byte, []int)
func (PingRequest_FailureType) String ¶
func (x PingRequest_FailureType) String() string
type PingResponse ¶
type PingResponse struct { Value string `protobuf:"bytes,1,opt,name=Value" json:"Value,omitempty"` Counter int32 `protobuf:"varint,2,opt,name=counter" json:"counter,omitempty"` }
func (*PingResponse) Descriptor ¶
func (*PingResponse) Descriptor() ([]byte, []int)
func (*PingResponse) GetCounter ¶
func (m *PingResponse) GetCounter() int32
func (*PingResponse) GetValue ¶
func (m *PingResponse) GetValue() string
func (*PingResponse) ProtoMessage ¶
func (*PingResponse) ProtoMessage()
func (*PingResponse) Reset ¶
func (m *PingResponse) Reset()
func (*PingResponse) String ¶
func (m *PingResponse) String() string
type TestServiceClient ¶
type TestServiceClient interface { PingEmpty(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*PingResponse, error) Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error) PingError(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error) PingList(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (TestService_PingListClient, error) PingPongBidi(ctx context.Context, opts ...grpc.CallOption) (TestService_PingPongBidiClient, error) PingStream(ctx context.Context, opts ...grpc.CallOption) (TestService_PingStreamClient, error) Echo(ctx context.Context, in *TextMessage, opts ...grpc.CallOption) (*TextMessage, error) }
func NewTestServiceClient ¶
func NewTestServiceClient(cc *grpc.ClientConn) TestServiceClient
type TestServiceServer ¶
type TestServiceServer interface { PingEmpty(context.Context, *google_protobuf.Empty) (*PingResponse, error) Ping(context.Context, *PingRequest) (*PingResponse, error) PingError(context.Context, *PingRequest) (*google_protobuf.Empty, error) PingList(*PingRequest, TestService_PingListServer) error PingPongBidi(TestService_PingPongBidiServer) error PingStream(TestService_PingStreamServer) error Echo(context.Context, *TextMessage) (*TextMessage, error) }
type TestService_PingListClient ¶
type TestService_PingListClient interface { Recv() (*PingResponse, error) grpc.ClientStream }
type TestService_PingListServer ¶
type TestService_PingListServer interface { Send(*PingResponse) error grpc.ServerStream }
type TestService_PingPongBidiClient ¶
type TestService_PingPongBidiClient interface { Send(*PingRequest) error Recv() (*PingResponse, error) grpc.ClientStream }
type TestService_PingPongBidiServer ¶
type TestService_PingPongBidiServer interface { Send(*PingResponse) error Recv() (*PingRequest, error) grpc.ServerStream }
type TestService_PingStreamClient ¶
type TestService_PingStreamClient interface { Send(*PingRequest) error CloseAndRecv() (*PingResponse, error) grpc.ClientStream }
type TestService_PingStreamServer ¶
type TestService_PingStreamServer interface { SendAndClose(*PingResponse) error Recv() (*PingRequest, error) grpc.ServerStream }
type TestUtilServiceClient ¶
type TestUtilServiceClient interface { ContinueStream(ctx context.Context, in *ContinueStreamRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error) CheckStreamClosed(ctx context.Context, in *CheckStreamClosedRequest, opts ...grpc.CallOption) (*CheckStreamClosedResponse, error) }
func NewTestUtilServiceClient ¶
func NewTestUtilServiceClient(cc *grpc.ClientConn) TestUtilServiceClient
type TestUtilServiceServer ¶
type TestUtilServiceServer interface { ContinueStream(context.Context, *ContinueStreamRequest) (*google_protobuf.Empty, error) CheckStreamClosed(context.Context, *CheckStreamClosedRequest) (*CheckStreamClosedResponse, error) }
type TextMessage ¶
type TextMessage struct { Text string `protobuf:"bytes,1,opt,name=text" json:"text,omitempty"` SendHeaders bool `protobuf:"varint,2,opt,name=send_headers,json=sendHeaders" json:"send_headers,omitempty"` SendTrailers bool `protobuf:"varint,3,opt,name=send_trailers,json=sendTrailers" json:"send_trailers,omitempty"` }
func (*TextMessage) Descriptor ¶
func (*TextMessage) Descriptor() ([]byte, []int)
func (*TextMessage) GetSendHeaders ¶
func (m *TextMessage) GetSendHeaders() bool
func (*TextMessage) GetSendTrailers ¶
func (m *TextMessage) GetSendTrailers() bool
func (*TextMessage) GetText ¶
func (m *TextMessage) GetText() string
func (*TextMessage) ProtoMessage ¶
func (*TextMessage) ProtoMessage()
func (*TextMessage) Reset ¶
func (m *TextMessage) Reset()
func (*TextMessage) String ¶
func (m *TextMessage) String() string
Click to show internal directories.
Click to hide internal directories.