From c74f6995fd90269de15dcd5a8dd98cda28100f79 Mon Sep 17 00:00:00 2001 From: Johan Brandhorst Date: Wed, 3 Feb 2021 10:46:25 +0000 Subject: [PATCH] Replace prototool with buf --- .circleci/config.yml | 8 +- CONTRIBUTING.md | 10 +- buf.yaml | 25 + install-buf.sh | 17 + install-protoc.sh | 21 + install-prototool.sh | 17 - .../_proto/improbable/grpcweb/test/test.pb.go | 908 ++++++++++++------ integration_test/package.json | 2 +- integration_test/proto/buf.gen.yaml | 16 + integration_test/proto/prototool.yaml | 24 - .../_proto/improbable/grpcweb/test/test_pb.js | 113 ++- lint-all.sh | 3 + 12 files changed, 797 insertions(+), 367 deletions(-) create mode 100644 buf.yaml create mode 100755 install-buf.sh create mode 100755 install-protoc.sh delete mode 100755 install-prototool.sh create mode 100644 integration_test/proto/buf.gen.yaml delete mode 100644 integration_test/proto/prototool.yaml diff --git a/.circleci/config.yml b/.circleci/config.yml index 1a55752a..3ee2a3ba 100644 --- a/.circleci/config.yml +++ b/.circleci/config.yml @@ -8,7 +8,8 @@ executors: username: mydockerhub-user password: $DOCKERHUB_PASSWORD environment: - PROTOTOOL_VER: 1.10.0 + BUF_VER: 0.36.0 + PROTOC_VER: 3.14.0 working_directory: /go/src/github.com/improbable-eng/grpc-web jobs: @@ -23,7 +24,8 @@ jobs: steps: - checkout - run: sudo apt-get install unzip - - run: . ./install-prototool.sh + - run: . ./install-buf.sh + - run: . ./install-protoc.sh - run: echo 'export GOBIN=/go/bin' >> $BASH_ENV - run: go get -u golang.org/x/tools/cmd/goimports - run: go get -u github.com/robertkrimen/godocdown/godocdown @@ -114,4 +116,4 @@ workflows: - BROWSER=ie11_win DISABLE_WEBSOCKET_TESTS=true - BROWSER=nodejs requires: - - initial-unit-test-lint-prebuild \ No newline at end of file + - initial-unit-test-lint-prebuild diff --git a/CONTRIBUTING.md b/CONTRIBUTING.md index d83f04f6..99b94222 100644 --- a/CONTRIBUTING.md +++ b/CONTRIBUTING.md @@ -13,7 +13,7 @@ export GOPATH=$(pwd) # Checkout project sources into your new go workspace go get -u github.com/improbable-eng/grpc-web/go -cd $GOPATH/src/github.com/improbable-eng/grpc-web +cd $GOPATH/src/github.com/improbable-eng/grpc-web # Install go dependencies dep ensure @@ -23,9 +23,9 @@ nvm use npm install ``` -Note you will also need to [install prototool](https://github.com/uber/prototool/blob/dev/docs/install.md) and add it to your `PATH` environment variable if you wish to re-generate the integration test proto files. +Note you will also need to [install buf](https://github.com/bufbuild/buf) and add it to your `PATH` environment variable if you wish to re-generate the integration test proto files. -## Testing Prerequisites +## Testing Prerequisites Before you run the tests for the first time, please follow these steps: ### Installing the Local Certificate @@ -38,7 +38,7 @@ In order to run the Karma (Integration) tests, you will need to add the certific 4. Select `misc/localhost.crt` 5. Double click on the new `GRPC Web example dev server` certificate 6. Expand the `Trust' section -7. Change the `When using this certificate` option to `Always Trust` +7. Change the `When using this certificate` option to `Always Trust` 8. Close the certificate details pop-up. Repeat the above process for `misc/localhostCA.pem`. @@ -75,4 +75,4 @@ This is your prompt to open a web browser on https://localhost:9876 at which poi 2. Update `CHANGELOG.md` by comparing commits to master since the last Github Release 3. Raise a pull request for your changes, have it reviewed and landed into master. 4. Switch your local checkout back to the master branch, pull your merged changes and run `./publish-release.sh`. -5. Create the ARM binaries and attach them to the Github release. \ No newline at end of file +5. Create the ARM binaries and attach them to the Github release. diff --git a/buf.yaml b/buf.yaml new file mode 100644 index 00000000..31bb7a77 --- /dev/null +++ b/buf.yaml @@ -0,0 +1,25 @@ +version: v1beta1 +build: + roots: + - integration_test/proto +lint: + use: + - DEFAULT + ignore_only: + ENUM_VALUE_PREFIX: + - improbable/grpcweb/test/test.proto + ENUM_ZERO_VALUE_SUFFIX: + - improbable/grpcweb/test/test.proto + FIELD_LOWER_SNAKE_CASE: + - improbable/grpcweb/test/test.proto + PACKAGE_VERSION_SUFFIX: + - improbable/grpcweb/test/test.proto + RPC_REQUEST_RESPONSE_UNIQUE: + - improbable/grpcweb/test/test.proto + RPC_REQUEST_STANDARD_NAME: + - improbable/grpcweb/test/test.proto + RPC_RESPONSE_STANDARD_NAME: + - improbable/grpcweb/test/test.proto +breaking: + use: + - FILE diff --git a/install-buf.sh b/install-buf.sh new file mode 100755 index 00000000..4c17bfb2 --- /dev/null +++ b/install-buf.sh @@ -0,0 +1,17 @@ +#!/bin/bash +# Installs buf; used for generating and linting protofiles. +# This script is intended to be run by CI + +set -ex + +if [[ -z "$BUF_VER" ]]; then + echo "BUF_VER environment variable not set" + exit 1 +fi + +curl -sSL \ + https://github.com/bufbuild/buf/releases/download/v${BUF_VER}/buf-$(uname -s)-$(uname -m) \ + -o ./buf && \ + chmod +x ./buf + +echo 'export PATH=$PATH:$PWD' >> $BASH_ENV diff --git a/install-protoc.sh b/install-protoc.sh new file mode 100755 index 00000000..caf5ce45 --- /dev/null +++ b/install-protoc.sh @@ -0,0 +1,21 @@ +#!/bin/bash +# Installs protoc; used for generating JS protobuf stubs. +# This script is intended to be run by CI + +set -ex + +if [[ -z "$PROTOC_VER" ]]; then + echo "PROTOC_VER environment variable not set" + exit 1 +fi + +curl -sSL \ + https://github.com/protocolbuffers/protobuf/releases/download/v${PROTOC_VER}/protoc-${PROTOC_VER}-linux-$(uname -m).zip \ + -o protoc.zip +rm -rf protoc +mkdir -p protoc +unzip protoc.zip -d protoc +rm protoc.zip +chmod +x ./protoc/bin/protoc + +echo 'export PATH=$PATH:$PWD/protoc/bin' >> $BASH_ENV diff --git a/install-prototool.sh b/install-prototool.sh deleted file mode 100755 index 199f0ebc..00000000 --- a/install-prototool.sh +++ /dev/null @@ -1,17 +0,0 @@ -#!/bin/bash -# Installs prototool; used for managing protoc the installation and compilation flags. -# This script is intended to be run by CI - -set -ex - -if [[ -z "$PROTOTOOL_VER" ]]; then - echo "PROTOTOOL_VER environment variable not set" - exit 1 -fi - -curl -sSL \ - https://github.com/uber/prototool/releases/download/v${PROTOTOOL_VER}/prototool-$(uname -s)-$(uname -m) \ - -o ./prototool && \ - chmod +x ./prototool - -echo 'export PATH=$PATH:$PWD' >> $BASH_ENV diff --git a/integration_test/go/_proto/improbable/grpcweb/test/test.pb.go b/integration_test/go/_proto/improbable/grpcweb/test/test.pb.go index 3e4cfd57..ff375ea0 100644 --- a/integration_test/go/_proto/improbable/grpcweb/test/test.pb.go +++ b/integration_test/go/_proto/improbable/grpcweb/test/test.pb.go @@ -1,27 +1,34 @@ // Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.24.0-devel +// protoc v3.13.0 // source: improbable/grpcweb/test/test.proto package test import ( context "context" - fmt "fmt" proto "github.com/golang/protobuf/proto" empty "github.com/golang/protobuf/ptypes/empty" grpc "google.golang.org/grpc" - math "math" + codes "google.golang.org/grpc/codes" + status "google.golang.org/grpc/status" + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" ) -// Reference imports to suppress errors if they are not otherwise used. -var _ = proto.Marshal -var _ = fmt.Errorf -var _ = math.Inf +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) -// This is a compile-time assertion to ensure that this generated file -// is compatible with the proto package it is being compiled against. -// A compilation error at this line likely means your copy of the -// proto package needs to be updated. -const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package +// This is a compile-time assertion that a sufficiently up-to-date version +// of the legacy proto package is being used. +const _ = proto.ProtoPackageIsVersion4 type PingRequest_FailureType int32 @@ -31,407 +38,693 @@ const ( PingRequest_CODE_UNICODE PingRequest_FailureType = 3 ) -var PingRequest_FailureType_name = map[int32]string{ - 0: "NONE", - 1: "CODE", - 3: "CODE_UNICODE", -} +// Enum value maps for PingRequest_FailureType. +var ( + PingRequest_FailureType_name = map[int32]string{ + 0: "NONE", + 1: "CODE", + 3: "CODE_UNICODE", + } + PingRequest_FailureType_value = map[string]int32{ + "NONE": 0, + "CODE": 1, + "CODE_UNICODE": 3, + } +) -var PingRequest_FailureType_value = map[string]int32{ - "NONE": 0, - "CODE": 1, - "CODE_UNICODE": 3, +func (x PingRequest_FailureType) Enum() *PingRequest_FailureType { + p := new(PingRequest_FailureType) + *p = x + return p } func (x PingRequest_FailureType) String() string { - return proto.EnumName(PingRequest_FailureType_name, int32(x)) + return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } -func (PingRequest_FailureType) EnumDescriptor() ([]byte, []int) { - return fileDescriptor_18e8d9116297b46c, []int{0, 0} +func (PingRequest_FailureType) Descriptor() protoreflect.EnumDescriptor { + return file_improbable_grpcweb_test_test_proto_enumTypes[0].Descriptor() } -type PingRequest struct { - Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` - ResponseCount int32 `protobuf:"varint,2,opt,name=response_count,json=responseCount,proto3" json:"response_count,omitempty"` - ErrorCodeReturned uint32 `protobuf:"varint,3,opt,name=error_code_returned,json=errorCodeReturned,proto3" json:"error_code_returned,omitempty"` - FailureType PingRequest_FailureType `protobuf:"varint,4,opt,name=failure_type,json=failureType,proto3,enum=improbable.grpcweb.test.PingRequest_FailureType" json:"failure_type,omitempty"` - CheckMetadata bool `protobuf:"varint,5,opt,name=check_metadata,json=checkMetadata,proto3" json:"check_metadata,omitempty"` - SendHeaders bool `protobuf:"varint,6,opt,name=send_headers,json=sendHeaders,proto3" json:"send_headers,omitempty"` - SendTrailers bool `protobuf:"varint,7,opt,name=send_trailers,json=sendTrailers,proto3" json:"send_trailers,omitempty"` - StreamIdentifier string `protobuf:"bytes,8,opt,name=stream_identifier,json=streamIdentifier,proto3" json:"stream_identifier,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` -} - -func (m *PingRequest) Reset() { *m = PingRequest{} } -func (m *PingRequest) String() string { return proto.CompactTextString(m) } -func (*PingRequest) ProtoMessage() {} -func (*PingRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_18e8d9116297b46c, []int{0} +func (PingRequest_FailureType) Type() protoreflect.EnumType { + return &file_improbable_grpcweb_test_test_proto_enumTypes[0] } -func (m *PingRequest) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_PingRequest.Unmarshal(m, b) +func (x PingRequest_FailureType) Number() protoreflect.EnumNumber { + return protoreflect.EnumNumber(x) } -func (m *PingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_PingRequest.Marshal(b, m, deterministic) + +// Deprecated: Use PingRequest_FailureType.Descriptor instead. +func (PingRequest_FailureType) EnumDescriptor() ([]byte, []int) { + return file_improbable_grpcweb_test_test_proto_rawDescGZIP(), []int{0, 0} } -func (m *PingRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_PingRequest.Merge(m, src) + +type PingRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` + ResponseCount int32 `protobuf:"varint,2,opt,name=response_count,json=responseCount,proto3" json:"response_count,omitempty"` + ErrorCodeReturned uint32 `protobuf:"varint,3,opt,name=error_code_returned,json=errorCodeReturned,proto3" json:"error_code_returned,omitempty"` + FailureType PingRequest_FailureType `protobuf:"varint,4,opt,name=failure_type,json=failureType,proto3,enum=improbable.grpcweb.test.PingRequest_FailureType" json:"failure_type,omitempty"` + CheckMetadata bool `protobuf:"varint,5,opt,name=check_metadata,json=checkMetadata,proto3" json:"check_metadata,omitempty"` + SendHeaders bool `protobuf:"varint,6,opt,name=send_headers,json=sendHeaders,proto3" json:"send_headers,omitempty"` + SendTrailers bool `protobuf:"varint,7,opt,name=send_trailers,json=sendTrailers,proto3" json:"send_trailers,omitempty"` + StreamIdentifier string `protobuf:"bytes,8,opt,name=stream_identifier,json=streamIdentifier,proto3" json:"stream_identifier,omitempty"` +} + +func (x *PingRequest) Reset() { + *x = PingRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_improbable_grpcweb_test_test_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } -func (m *PingRequest) XXX_Size() int { - return xxx_messageInfo_PingRequest.Size(m) + +func (x *PingRequest) String() string { + return protoimpl.X.MessageStringOf(x) } -func (m *PingRequest) XXX_DiscardUnknown() { - xxx_messageInfo_PingRequest.DiscardUnknown(m) + +func (*PingRequest) ProtoMessage() {} + +func (x *PingRequest) ProtoReflect() protoreflect.Message { + mi := &file_improbable_grpcweb_test_test_proto_msgTypes[0] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -var xxx_messageInfo_PingRequest proto.InternalMessageInfo +// Deprecated: Use PingRequest.ProtoReflect.Descriptor instead. +func (*PingRequest) Descriptor() ([]byte, []int) { + return file_improbable_grpcweb_test_test_proto_rawDescGZIP(), []int{0} +} -func (m *PingRequest) GetValue() string { - if m != nil { - return m.Value +func (x *PingRequest) GetValue() string { + if x != nil { + return x.Value } return "" } -func (m *PingRequest) GetResponseCount() int32 { - if m != nil { - return m.ResponseCount +func (x *PingRequest) GetResponseCount() int32 { + if x != nil { + return x.ResponseCount } return 0 } -func (m *PingRequest) GetErrorCodeReturned() uint32 { - if m != nil { - return m.ErrorCodeReturned +func (x *PingRequest) GetErrorCodeReturned() uint32 { + if x != nil { + return x.ErrorCodeReturned } return 0 } -func (m *PingRequest) GetFailureType() PingRequest_FailureType { - if m != nil { - return m.FailureType +func (x *PingRequest) GetFailureType() PingRequest_FailureType { + if x != nil { + return x.FailureType } return PingRequest_NONE } -func (m *PingRequest) GetCheckMetadata() bool { - if m != nil { - return m.CheckMetadata +func (x *PingRequest) GetCheckMetadata() bool { + if x != nil { + return x.CheckMetadata } return false } -func (m *PingRequest) GetSendHeaders() bool { - if m != nil { - return m.SendHeaders +func (x *PingRequest) GetSendHeaders() bool { + if x != nil { + return x.SendHeaders } return false } -func (m *PingRequest) GetSendTrailers() bool { - if m != nil { - return m.SendTrailers +func (x *PingRequest) GetSendTrailers() bool { + if x != nil { + return x.SendTrailers } return false } -func (m *PingRequest) GetStreamIdentifier() string { - if m != nil { - return m.StreamIdentifier +func (x *PingRequest) GetStreamIdentifier() string { + if x != nil { + return x.StreamIdentifier } return "" } type PingResponse struct { - Value string `protobuf:"bytes,1,opt,name=Value,proto3" json:"Value,omitempty"` - Counter int32 `protobuf:"varint,2,opt,name=counter,proto3" json:"counter,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` -} + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields -func (m *PingResponse) Reset() { *m = PingResponse{} } -func (m *PingResponse) String() string { return proto.CompactTextString(m) } -func (*PingResponse) ProtoMessage() {} -func (*PingResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_18e8d9116297b46c, []int{1} + Value string `protobuf:"bytes,1,opt,name=Value,proto3" json:"Value,omitempty"` + Counter int32 `protobuf:"varint,2,opt,name=counter,proto3" json:"counter,omitempty"` } -func (m *PingResponse) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_PingResponse.Unmarshal(m, b) -} -func (m *PingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_PingResponse.Marshal(b, m, deterministic) -} -func (m *PingResponse) XXX_Merge(src proto.Message) { - xxx_messageInfo_PingResponse.Merge(m, src) +func (x *PingResponse) Reset() { + *x = PingResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_improbable_grpcweb_test_test_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } -func (m *PingResponse) XXX_Size() int { - return xxx_messageInfo_PingResponse.Size(m) + +func (x *PingResponse) String() string { + return protoimpl.X.MessageStringOf(x) } -func (m *PingResponse) XXX_DiscardUnknown() { - xxx_messageInfo_PingResponse.DiscardUnknown(m) + +func (*PingResponse) ProtoMessage() {} + +func (x *PingResponse) ProtoReflect() protoreflect.Message { + mi := &file_improbable_grpcweb_test_test_proto_msgTypes[1] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -var xxx_messageInfo_PingResponse proto.InternalMessageInfo +// Deprecated: Use PingResponse.ProtoReflect.Descriptor instead. +func (*PingResponse) Descriptor() ([]byte, []int) { + return file_improbable_grpcweb_test_test_proto_rawDescGZIP(), []int{1} +} -func (m *PingResponse) GetValue() string { - if m != nil { - return m.Value +func (x *PingResponse) GetValue() string { + if x != nil { + return x.Value } return "" } -func (m *PingResponse) GetCounter() int32 { - if m != nil { - return m.Counter +func (x *PingResponse) GetCounter() int32 { + if x != nil { + return x.Counter } return 0 } type TextMessage struct { - Text string `protobuf:"bytes,1,opt,name=text,proto3" json:"text,omitempty"` - SendHeaders bool `protobuf:"varint,2,opt,name=send_headers,json=sendHeaders,proto3" json:"send_headers,omitempty"` - SendTrailers bool `protobuf:"varint,3,opt,name=send_trailers,json=sendTrailers,proto3" json:"send_trailers,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` -} + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields -func (m *TextMessage) Reset() { *m = TextMessage{} } -func (m *TextMessage) String() string { return proto.CompactTextString(m) } -func (*TextMessage) ProtoMessage() {} -func (*TextMessage) Descriptor() ([]byte, []int) { - return fileDescriptor_18e8d9116297b46c, []int{2} + Text string `protobuf:"bytes,1,opt,name=text,proto3" json:"text,omitempty"` + SendHeaders bool `protobuf:"varint,2,opt,name=send_headers,json=sendHeaders,proto3" json:"send_headers,omitempty"` + SendTrailers bool `protobuf:"varint,3,opt,name=send_trailers,json=sendTrailers,proto3" json:"send_trailers,omitempty"` } -func (m *TextMessage) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_TextMessage.Unmarshal(m, b) -} -func (m *TextMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_TextMessage.Marshal(b, m, deterministic) -} -func (m *TextMessage) XXX_Merge(src proto.Message) { - xxx_messageInfo_TextMessage.Merge(m, src) +func (x *TextMessage) Reset() { + *x = TextMessage{} + if protoimpl.UnsafeEnabled { + mi := &file_improbable_grpcweb_test_test_proto_msgTypes[2] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } -func (m *TextMessage) XXX_Size() int { - return xxx_messageInfo_TextMessage.Size(m) + +func (x *TextMessage) String() string { + return protoimpl.X.MessageStringOf(x) } -func (m *TextMessage) XXX_DiscardUnknown() { - xxx_messageInfo_TextMessage.DiscardUnknown(m) + +func (*TextMessage) ProtoMessage() {} + +func (x *TextMessage) ProtoReflect() protoreflect.Message { + mi := &file_improbable_grpcweb_test_test_proto_msgTypes[2] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -var xxx_messageInfo_TextMessage proto.InternalMessageInfo +// Deprecated: Use TextMessage.ProtoReflect.Descriptor instead. +func (*TextMessage) Descriptor() ([]byte, []int) { + return file_improbable_grpcweb_test_test_proto_rawDescGZIP(), []int{2} +} -func (m *TextMessage) GetText() string { - if m != nil { - return m.Text +func (x *TextMessage) GetText() string { + if x != nil { + return x.Text } return "" } -func (m *TextMessage) GetSendHeaders() bool { - if m != nil { - return m.SendHeaders +func (x *TextMessage) GetSendHeaders() bool { + if x != nil { + return x.SendHeaders } return false } -func (m *TextMessage) GetSendTrailers() bool { - if m != nil { - return m.SendTrailers +func (x *TextMessage) GetSendTrailers() bool { + if x != nil { + return x.SendTrailers } return false } type ContinueStreamRequest struct { - StreamIdentifier string `protobuf:"bytes,1,opt,name=stream_identifier,json=streamIdentifier,proto3" json:"stream_identifier,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` -} + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields -func (m *ContinueStreamRequest) Reset() { *m = ContinueStreamRequest{} } -func (m *ContinueStreamRequest) String() string { return proto.CompactTextString(m) } -func (*ContinueStreamRequest) ProtoMessage() {} -func (*ContinueStreamRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_18e8d9116297b46c, []int{3} + StreamIdentifier string `protobuf:"bytes,1,opt,name=stream_identifier,json=streamIdentifier,proto3" json:"stream_identifier,omitempty"` } -func (m *ContinueStreamRequest) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_ContinueStreamRequest.Unmarshal(m, b) -} -func (m *ContinueStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_ContinueStreamRequest.Marshal(b, m, deterministic) -} -func (m *ContinueStreamRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_ContinueStreamRequest.Merge(m, src) +func (x *ContinueStreamRequest) Reset() { + *x = ContinueStreamRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_improbable_grpcweb_test_test_proto_msgTypes[3] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } -func (m *ContinueStreamRequest) XXX_Size() int { - return xxx_messageInfo_ContinueStreamRequest.Size(m) + +func (x *ContinueStreamRequest) String() string { + return protoimpl.X.MessageStringOf(x) } -func (m *ContinueStreamRequest) XXX_DiscardUnknown() { - xxx_messageInfo_ContinueStreamRequest.DiscardUnknown(m) + +func (*ContinueStreamRequest) ProtoMessage() {} + +func (x *ContinueStreamRequest) ProtoReflect() protoreflect.Message { + mi := &file_improbable_grpcweb_test_test_proto_msgTypes[3] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -var xxx_messageInfo_ContinueStreamRequest proto.InternalMessageInfo +// Deprecated: Use ContinueStreamRequest.ProtoReflect.Descriptor instead. +func (*ContinueStreamRequest) Descriptor() ([]byte, []int) { + return file_improbable_grpcweb_test_test_proto_rawDescGZIP(), []int{3} +} -func (m *ContinueStreamRequest) GetStreamIdentifier() string { - if m != nil { - return m.StreamIdentifier +func (x *ContinueStreamRequest) GetStreamIdentifier() string { + if x != nil { + return x.StreamIdentifier } return "" } type CheckStreamClosedRequest struct { - StreamIdentifier string `protobuf:"bytes,1,opt,name=stream_identifier,json=streamIdentifier,proto3" json:"stream_identifier,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` -} + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields -func (m *CheckStreamClosedRequest) Reset() { *m = CheckStreamClosedRequest{} } -func (m *CheckStreamClosedRequest) String() string { return proto.CompactTextString(m) } -func (*CheckStreamClosedRequest) ProtoMessage() {} -func (*CheckStreamClosedRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_18e8d9116297b46c, []int{4} + StreamIdentifier string `protobuf:"bytes,1,opt,name=stream_identifier,json=streamIdentifier,proto3" json:"stream_identifier,omitempty"` } -func (m *CheckStreamClosedRequest) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_CheckStreamClosedRequest.Unmarshal(m, b) -} -func (m *CheckStreamClosedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_CheckStreamClosedRequest.Marshal(b, m, deterministic) -} -func (m *CheckStreamClosedRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_CheckStreamClosedRequest.Merge(m, src) +func (x *CheckStreamClosedRequest) Reset() { + *x = CheckStreamClosedRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_improbable_grpcweb_test_test_proto_msgTypes[4] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } -func (m *CheckStreamClosedRequest) XXX_Size() int { - return xxx_messageInfo_CheckStreamClosedRequest.Size(m) + +func (x *CheckStreamClosedRequest) String() string { + return protoimpl.X.MessageStringOf(x) } -func (m *CheckStreamClosedRequest) XXX_DiscardUnknown() { - xxx_messageInfo_CheckStreamClosedRequest.DiscardUnknown(m) + +func (*CheckStreamClosedRequest) ProtoMessage() {} + +func (x *CheckStreamClosedRequest) ProtoReflect() protoreflect.Message { + mi := &file_improbable_grpcweb_test_test_proto_msgTypes[4] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -var xxx_messageInfo_CheckStreamClosedRequest proto.InternalMessageInfo +// Deprecated: Use CheckStreamClosedRequest.ProtoReflect.Descriptor instead. +func (*CheckStreamClosedRequest) Descriptor() ([]byte, []int) { + return file_improbable_grpcweb_test_test_proto_rawDescGZIP(), []int{4} +} -func (m *CheckStreamClosedRequest) GetStreamIdentifier() string { - if m != nil { - return m.StreamIdentifier +func (x *CheckStreamClosedRequest) GetStreamIdentifier() string { + if x != nil { + return x.StreamIdentifier } return "" } type CheckStreamClosedResponse struct { - Closed bool `protobuf:"varint,1,opt,name=closed,proto3" json:"closed,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` -} + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields -func (m *CheckStreamClosedResponse) Reset() { *m = CheckStreamClosedResponse{} } -func (m *CheckStreamClosedResponse) String() string { return proto.CompactTextString(m) } -func (*CheckStreamClosedResponse) ProtoMessage() {} -func (*CheckStreamClosedResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_18e8d9116297b46c, []int{5} + Closed bool `protobuf:"varint,1,opt,name=closed,proto3" json:"closed,omitempty"` } -func (m *CheckStreamClosedResponse) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_CheckStreamClosedResponse.Unmarshal(m, b) -} -func (m *CheckStreamClosedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_CheckStreamClosedResponse.Marshal(b, m, deterministic) -} -func (m *CheckStreamClosedResponse) XXX_Merge(src proto.Message) { - xxx_messageInfo_CheckStreamClosedResponse.Merge(m, src) +func (x *CheckStreamClosedResponse) Reset() { + *x = CheckStreamClosedResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_improbable_grpcweb_test_test_proto_msgTypes[5] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } -func (m *CheckStreamClosedResponse) XXX_Size() int { - return xxx_messageInfo_CheckStreamClosedResponse.Size(m) + +func (x *CheckStreamClosedResponse) String() string { + return protoimpl.X.MessageStringOf(x) } -func (m *CheckStreamClosedResponse) XXX_DiscardUnknown() { - xxx_messageInfo_CheckStreamClosedResponse.DiscardUnknown(m) + +func (*CheckStreamClosedResponse) ProtoMessage() {} + +func (x *CheckStreamClosedResponse) ProtoReflect() protoreflect.Message { + mi := &file_improbable_grpcweb_test_test_proto_msgTypes[5] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -var xxx_messageInfo_CheckStreamClosedResponse proto.InternalMessageInfo +// Deprecated: Use CheckStreamClosedResponse.ProtoReflect.Descriptor instead. +func (*CheckStreamClosedResponse) Descriptor() ([]byte, []int) { + return file_improbable_grpcweb_test_test_proto_rawDescGZIP(), []int{5} +} -func (m *CheckStreamClosedResponse) GetClosed() bool { - if m != nil { - return m.Closed +func (x *CheckStreamClosedResponse) GetClosed() bool { + if x != nil { + return x.Closed } return false } -func init() { - proto.RegisterEnum("improbable.grpcweb.test.PingRequest_FailureType", PingRequest_FailureType_name, PingRequest_FailureType_value) - proto.RegisterType((*PingRequest)(nil), "improbable.grpcweb.test.PingRequest") - proto.RegisterType((*PingResponse)(nil), "improbable.grpcweb.test.PingResponse") - proto.RegisterType((*TextMessage)(nil), "improbable.grpcweb.test.TextMessage") - proto.RegisterType((*ContinueStreamRequest)(nil), "improbable.grpcweb.test.ContinueStreamRequest") - proto.RegisterType((*CheckStreamClosedRequest)(nil), "improbable.grpcweb.test.CheckStreamClosedRequest") - proto.RegisterType((*CheckStreamClosedResponse)(nil), "improbable.grpcweb.test.CheckStreamClosedResponse") -} - -func init() { - proto.RegisterFile("improbable/grpcweb/test/test.proto", fileDescriptor_18e8d9116297b46c) -} - -var fileDescriptor_18e8d9116297b46c = []byte{ - // 671 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x55, 0x41, 0x4f, 0xdb, 0x4a, - 0x10, 0x8e, 0x93, 0x00, 0x61, 0x92, 0xf0, 0xc2, 0xbe, 0xf7, 0xc0, 0xa4, 0x97, 0xd4, 0x2d, 0x52, - 0xa4, 0x4a, 0x0e, 0x0d, 0xa7, 0x5e, 0x7a, 0x20, 0xa4, 0x2d, 0x2a, 0x04, 0x64, 0x42, 0x0f, 0xb4, - 0x95, 0xe5, 0xd8, 0x93, 0xb0, 0xc2, 0xf1, 0xba, 0xeb, 0x35, 0x05, 0xa9, 0xbf, 0xa7, 0x7f, 0xae, - 0xd7, 0xfe, 0x80, 0x6a, 0xd7, 0x76, 0x49, 0x05, 0xa6, 0x69, 0x95, 0x4b, 0xb4, 0xfb, 0xed, 0x37, - 0xb3, 0xb3, 0xdf, 0xcc, 0x17, 0x83, 0x41, 0xa7, 0x21, 0x67, 0x23, 0x67, 0xe4, 0x63, 0x67, 0xc2, - 0x43, 0xf7, 0x33, 0x8e, 0x3a, 0x02, 0x23, 0xa1, 0x7e, 0xcc, 0x90, 0x33, 0xc1, 0xc8, 0xe6, 0x2d, - 0xc7, 0x4c, 0x39, 0xa6, 0x3c, 0x6e, 0x3e, 0x9a, 0x30, 0x36, 0xf1, 0xb1, 0xa3, 0x68, 0xa3, 0x78, - 0xdc, 0xc1, 0x69, 0x28, 0x6e, 0x92, 0x28, 0xe3, 0x6b, 0x09, 0xaa, 0x27, 0x34, 0x98, 0x58, 0xf8, - 0x29, 0xc6, 0x48, 0x90, 0xff, 0x60, 0xe9, 0xca, 0xf1, 0x63, 0xd4, 0xb5, 0x96, 0xd6, 0x5e, 0xb5, - 0x92, 0x0d, 0xd9, 0x86, 0x35, 0x8e, 0x51, 0xc8, 0x82, 0x08, 0x6d, 0x97, 0xc5, 0x81, 0xd0, 0x8b, - 0x2d, 0xad, 0xbd, 0x64, 0xd5, 0x33, 0xb4, 0x27, 0x41, 0x62, 0xc2, 0xbf, 0xc8, 0x39, 0xe3, 0xb6, - 0xcb, 0x3c, 0xb4, 0x39, 0x8a, 0x98, 0x07, 0xe8, 0xe9, 0xa5, 0x96, 0xd6, 0xae, 0x5b, 0xeb, 0xea, - 0xa8, 0xc7, 0x3c, 0xb4, 0xd2, 0x03, 0x72, 0x0a, 0xb5, 0xb1, 0x43, 0xfd, 0x98, 0xa3, 0x2d, 0x6e, - 0x42, 0xd4, 0xcb, 0x2d, 0xad, 0xbd, 0xd6, 0xdd, 0x31, 0x73, 0x5e, 0x62, 0xce, 0x14, 0x6a, 0xbe, - 0x4a, 0x02, 0x87, 0x37, 0x21, 0x5a, 0xd5, 0xf1, 0xed, 0x46, 0xd6, 0xea, 0x5e, 0xa0, 0x7b, 0x69, - 0x4f, 0x51, 0x38, 0x9e, 0x23, 0x1c, 0x7d, 0xa9, 0xa5, 0xb5, 0x2b, 0x56, 0x5d, 0xa1, 0x47, 0x29, - 0x48, 0x1e, 0x43, 0x2d, 0xc2, 0xc0, 0xb3, 0x2f, 0xd0, 0xf1, 0x90, 0x47, 0xfa, 0xb2, 0x22, 0x55, - 0x25, 0xf6, 0x26, 0x81, 0xc8, 0x13, 0xa8, 0x2b, 0x8a, 0xe0, 0x0e, 0xf5, 0x25, 0x67, 0x45, 0x71, - 0x54, 0xdc, 0x30, 0xc5, 0xc8, 0x33, 0x58, 0x8f, 0x04, 0x47, 0x67, 0x6a, 0x53, 0x0f, 0x03, 0x41, - 0xc7, 0x14, 0xb9, 0x5e, 0x51, 0xe2, 0x35, 0x92, 0x83, 0x83, 0x9f, 0xb8, 0xf1, 0x02, 0xaa, 0x33, - 0x75, 0x93, 0x0a, 0x94, 0x07, 0xc7, 0x83, 0x7e, 0xa3, 0x20, 0x57, 0xbd, 0xe3, 0xfd, 0x7e, 0x43, - 0x23, 0x0d, 0xa8, 0xc9, 0x95, 0x7d, 0x36, 0x38, 0x50, 0x48, 0xc9, 0x28, 0x57, 0x8a, 0x8d, 0xa2, - 0xf1, 0x12, 0x6a, 0xc9, 0xf3, 0x13, 0xc1, 0x65, 0xa3, 0xde, 0xcd, 0x36, 0x4a, 0x6d, 0x88, 0x0e, - 0x2b, 0xaa, 0x3f, 0xc8, 0xd3, 0x0e, 0x65, 0x5b, 0x83, 0x42, 0x75, 0x88, 0xd7, 0xe2, 0x08, 0xa3, - 0xc8, 0x99, 0x20, 0x21, 0x50, 0x16, 0x78, 0x2d, 0xd2, 0x68, 0xb5, 0xbe, 0x23, 0x49, 0x71, 0x0e, - 0x49, 0x4a, 0x77, 0x25, 0x31, 0xf6, 0xe1, 0xff, 0x1e, 0x0b, 0x04, 0x0d, 0x62, 0x3c, 0x55, 0x0a, - 0x64, 0xc3, 0x75, 0xaf, 0x56, 0x5a, 0x8e, 0x56, 0xaf, 0x41, 0xef, 0xc9, 0x8e, 0x25, 0x29, 0x7a, - 0x3e, 0x8b, 0xd0, 0xfb, 0xab, 0x44, 0xbb, 0xb0, 0x75, 0x4f, 0xa2, 0x54, 0xc6, 0x0d, 0x58, 0x76, - 0x15, 0xa2, 0xc2, 0x2b, 0x56, 0xba, 0xeb, 0x7e, 0x2f, 0x4b, 0xbd, 0x22, 0x71, 0x8a, 0xfc, 0x8a, - 0xba, 0x48, 0x0e, 0x61, 0x55, 0xca, 0xdf, 0x97, 0xd6, 0x21, 0x1b, 0x66, 0x62, 0x29, 0x33, 0xb3, - 0x94, 0xa9, 0xf0, 0xe6, 0xf6, 0x6f, 0x26, 0x37, 0xb9, 0xd3, 0x28, 0x90, 0x33, 0x28, 0x4b, 0x84, - 0x3c, 0x9d, 0x67, 0xd4, 0xe7, 0x4f, 0xfb, 0x36, 0x2d, 0x52, 0x1a, 0x6d, 0xce, 0xdc, 0x39, 0x4f, - 0x31, 0x0a, 0xe4, 0x3d, 0x54, 0x24, 0xf1, 0x90, 0x46, 0x62, 0xc1, 0x75, 0xee, 0x68, 0xc4, 0x49, - 0xa6, 0xf9, 0x84, 0x05, 0x93, 0x3d, 0xea, 0xd1, 0x05, 0x5f, 0xd0, 0xd6, 0x76, 0x34, 0xf2, 0x11, - 0x40, 0xa2, 0x49, 0xd7, 0x17, 0x7e, 0x01, 0x19, 0x42, 0xb9, 0xef, 0x5e, 0xb0, 0x07, 0x12, 0xcf, - 0xd8, 0xad, 0x39, 0x17, 0xcb, 0x28, 0x74, 0xbf, 0x69, 0xf0, 0x8f, 0x1c, 0xbb, 0x33, 0x41, 0xfd, - 0x6c, 0xf4, 0xce, 0x61, 0xed, 0x57, 0x3b, 0x11, 0x33, 0x37, 0xdb, 0xbd, 0xbe, 0x7b, 0xa0, 0xc9, - 0x5f, 0x60, 0xfd, 0x8e, 0x37, 0xc8, 0xf3, 0xfc, 0xf4, 0x39, 0x86, 0x6c, 0x76, 0xff, 0x24, 0x24, - 0x53, 0xb1, 0x7b, 0x99, 0xfc, 0x1d, 0x66, 0x0f, 0xfd, 0x00, 0xd5, 0x01, 0x0b, 0xfa, 0xd7, 0x34, - 0x12, 0x4e, 0xb0, 0xe8, 0xa1, 0xdb, 0xdb, 0x3a, 0xdf, 0xcc, 0xf9, 0x8a, 0x8e, 0x96, 0x95, 0x2e, - 0xbb, 0x3f, 0x02, 0x00, 0x00, 0xff, 0xff, 0x82, 0xcb, 0x10, 0xd2, 0x67, 0x07, 0x00, 0x00, +var File_improbable_grpcweb_test_test_proto protoreflect.FileDescriptor + +var file_improbable_grpcweb_test_test_proto_rawDesc = []byte{ + 0x0a, 0x22, 0x69, 0x6d, 0x70, 0x72, 0x6f, 0x62, 0x61, 0x62, 0x6c, 0x65, 0x2f, 0x67, 0x72, 0x70, + 0x63, 0x77, 0x65, 0x62, 0x2f, 0x74, 0x65, 0x73, 0x74, 0x2f, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x70, + 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x17, 0x69, 0x6d, 0x70, 0x72, 0x6f, 0x62, 0x61, 0x62, 0x6c, 0x65, + 0x2e, 0x67, 0x72, 0x70, 0x63, 0x77, 0x65, 0x62, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x1a, 0x1b, 0x67, + 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, + 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xa6, 0x03, 0x0a, 0x0b, 0x50, + 0x69, 0x6e, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, + 0x6c, 0x75, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, + 0x12, 0x25, 0x0a, 0x0e, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x5f, 0x63, 0x6f, 0x75, + 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0d, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, + 0x73, 0x65, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x2e, 0x0a, 0x13, 0x65, 0x72, 0x72, 0x6f, 0x72, + 0x5f, 0x63, 0x6f, 0x64, 0x65, 0x5f, 0x72, 0x65, 0x74, 0x75, 0x72, 0x6e, 0x65, 0x64, 0x18, 0x03, + 0x20, 0x01, 0x28, 0x0d, 0x52, 0x11, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x43, 0x6f, 0x64, 0x65, 0x52, + 0x65, 0x74, 0x75, 0x72, 0x6e, 0x65, 0x64, 0x12, 0x53, 0x0a, 0x0c, 0x66, 0x61, 0x69, 0x6c, 0x75, + 0x72, 0x65, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x30, 0x2e, + 0x69, 0x6d, 0x70, 0x72, 0x6f, 0x62, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x77, + 0x65, 0x62, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x50, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x71, 0x75, + 0x65, 0x73, 0x74, 0x2e, 0x46, 0x61, 0x69, 0x6c, 0x75, 0x72, 0x65, 0x54, 0x79, 0x70, 0x65, 0x52, + 0x0b, 0x66, 0x61, 0x69, 0x6c, 0x75, 0x72, 0x65, 0x54, 0x79, 0x70, 0x65, 0x12, 0x25, 0x0a, 0x0e, + 0x63, 0x68, 0x65, 0x63, 0x6b, 0x5f, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x05, + 0x20, 0x01, 0x28, 0x08, 0x52, 0x0d, 0x63, 0x68, 0x65, 0x63, 0x6b, 0x4d, 0x65, 0x74, 0x61, 0x64, + 0x61, 0x74, 0x61, 0x12, 0x21, 0x0a, 0x0c, 0x73, 0x65, 0x6e, 0x64, 0x5f, 0x68, 0x65, 0x61, 0x64, + 0x65, 0x72, 0x73, 0x18, 0x06, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0b, 0x73, 0x65, 0x6e, 0x64, 0x48, + 0x65, 0x61, 0x64, 0x65, 0x72, 0x73, 0x12, 0x23, 0x0a, 0x0d, 0x73, 0x65, 0x6e, 0x64, 0x5f, 0x74, + 0x72, 0x61, 0x69, 0x6c, 0x65, 0x72, 0x73, 0x18, 0x07, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0c, 0x73, + 0x65, 0x6e, 0x64, 0x54, 0x72, 0x61, 0x69, 0x6c, 0x65, 0x72, 0x73, 0x12, 0x2b, 0x0a, 0x11, 0x73, + 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, + 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x10, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x49, 0x64, + 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x22, 0x39, 0x0a, 0x0b, 0x46, 0x61, 0x69, 0x6c, + 0x75, 0x72, 0x65, 0x54, 0x79, 0x70, 0x65, 0x12, 0x08, 0x0a, 0x04, 0x4e, 0x4f, 0x4e, 0x45, 0x10, + 0x00, 0x12, 0x08, 0x0a, 0x04, 0x43, 0x4f, 0x44, 0x45, 0x10, 0x01, 0x12, 0x10, 0x0a, 0x0c, 0x43, + 0x4f, 0x44, 0x45, 0x5f, 0x55, 0x4e, 0x49, 0x43, 0x4f, 0x44, 0x45, 0x10, 0x03, 0x22, 0x04, 0x08, + 0x02, 0x10, 0x02, 0x22, 0x3e, 0x0a, 0x0c, 0x50, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x73, 0x70, 0x6f, + 0x6e, 0x73, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x01, 0x20, 0x01, + 0x28, 0x09, 0x52, 0x05, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x6f, 0x75, + 0x6e, 0x74, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x07, 0x63, 0x6f, 0x75, 0x6e, + 0x74, 0x65, 0x72, 0x22, 0x69, 0x0a, 0x0b, 0x54, 0x65, 0x78, 0x74, 0x4d, 0x65, 0x73, 0x73, 0x61, + 0x67, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x74, 0x65, 0x78, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, + 0x52, 0x04, 0x74, 0x65, 0x78, 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x73, 0x65, 0x6e, 0x64, 0x5f, 0x68, + 0x65, 0x61, 0x64, 0x65, 0x72, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0b, 0x73, 0x65, + 0x6e, 0x64, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x73, 0x12, 0x23, 0x0a, 0x0d, 0x73, 0x65, 0x6e, + 0x64, 0x5f, 0x74, 0x72, 0x61, 0x69, 0x6c, 0x65, 0x72, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x08, + 0x52, 0x0c, 0x73, 0x65, 0x6e, 0x64, 0x54, 0x72, 0x61, 0x69, 0x6c, 0x65, 0x72, 0x73, 0x22, 0x44, + 0x0a, 0x15, 0x43, 0x6f, 0x6e, 0x74, 0x69, 0x6e, 0x75, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, + 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x2b, 0x0a, 0x11, 0x73, 0x74, 0x72, 0x65, 0x61, + 0x6d, 0x5f, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, + 0x28, 0x09, 0x52, 0x10, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, + 0x66, 0x69, 0x65, 0x72, 0x22, 0x47, 0x0a, 0x18, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x53, 0x74, 0x72, + 0x65, 0x61, 0x6d, 0x43, 0x6c, 0x6f, 0x73, 0x65, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, + 0x12, 0x2b, 0x0a, 0x11, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x69, 0x64, 0x65, 0x6e, 0x74, + 0x69, 0x66, 0x69, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x10, 0x73, 0x74, 0x72, + 0x65, 0x61, 0x6d, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x22, 0x33, 0x0a, + 0x19, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x43, 0x6c, 0x6f, 0x73, + 0x65, 0x64, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x63, 0x6c, + 0x6f, 0x73, 0x65, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x06, 0x63, 0x6c, 0x6f, 0x73, + 0x65, 0x64, 0x32, 0xf4, 0x04, 0x0a, 0x0b, 0x54, 0x65, 0x73, 0x74, 0x53, 0x65, 0x72, 0x76, 0x69, + 0x63, 0x65, 0x12, 0x4c, 0x0a, 0x09, 0x50, 0x69, 0x6e, 0x67, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x12, + 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, + 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x1a, 0x25, 0x2e, 0x69, 0x6d, 0x70, 0x72, 0x6f, 0x62, + 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x77, 0x65, 0x62, 0x2e, 0x74, 0x65, 0x73, + 0x74, 0x2e, 0x50, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, + 0x12, 0x55, 0x0a, 0x04, 0x50, 0x69, 0x6e, 0x67, 0x12, 0x24, 0x2e, 0x69, 0x6d, 0x70, 0x72, 0x6f, + 0x62, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x77, 0x65, 0x62, 0x2e, 0x74, 0x65, + 0x73, 0x74, 0x2e, 0x50, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x25, + 0x2e, 0x69, 0x6d, 0x70, 0x72, 0x6f, 0x62, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x67, 0x72, 0x70, 0x63, + 0x77, 0x65, 0x62, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x50, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x73, + 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x4b, 0x0a, 0x09, 0x50, 0x69, 0x6e, 0x67, 0x45, + 0x72, 0x72, 0x6f, 0x72, 0x12, 0x24, 0x2e, 0x69, 0x6d, 0x70, 0x72, 0x6f, 0x62, 0x61, 0x62, 0x6c, + 0x65, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x77, 0x65, 0x62, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x50, + 0x69, 0x6e, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, + 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, + 0x74, 0x79, 0x22, 0x00, 0x12, 0x5b, 0x0a, 0x08, 0x50, 0x69, 0x6e, 0x67, 0x4c, 0x69, 0x73, 0x74, + 0x12, 0x24, 0x2e, 0x69, 0x6d, 0x70, 0x72, 0x6f, 0x62, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x67, 0x72, + 0x70, 0x63, 0x77, 0x65, 0x62, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x50, 0x69, 0x6e, 0x67, 0x52, + 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x25, 0x2e, 0x69, 0x6d, 0x70, 0x72, 0x6f, 0x62, 0x61, + 0x62, 0x6c, 0x65, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x77, 0x65, 0x62, 0x2e, 0x74, 0x65, 0x73, 0x74, + 0x2e, 0x50, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x30, + 0x01, 0x12, 0x61, 0x0a, 0x0c, 0x50, 0x69, 0x6e, 0x67, 0x50, 0x6f, 0x6e, 0x67, 0x42, 0x69, 0x64, + 0x69, 0x12, 0x24, 0x2e, 0x69, 0x6d, 0x70, 0x72, 0x6f, 0x62, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x67, + 0x72, 0x70, 0x63, 0x77, 0x65, 0x62, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x50, 0x69, 0x6e, 0x67, + 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x25, 0x2e, 0x69, 0x6d, 0x70, 0x72, 0x6f, 0x62, + 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x77, 0x65, 0x62, 0x2e, 0x74, 0x65, 0x73, + 0x74, 0x2e, 0x50, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, + 0x28, 0x01, 0x30, 0x01, 0x12, 0x5d, 0x0a, 0x0a, 0x50, 0x69, 0x6e, 0x67, 0x53, 0x74, 0x72, 0x65, + 0x61, 0x6d, 0x12, 0x24, 0x2e, 0x69, 0x6d, 0x70, 0x72, 0x6f, 0x62, 0x61, 0x62, 0x6c, 0x65, 0x2e, + 0x67, 0x72, 0x70, 0x63, 0x77, 0x65, 0x62, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x50, 0x69, 0x6e, + 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x25, 0x2e, 0x69, 0x6d, 0x70, 0x72, 0x6f, + 0x62, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x77, 0x65, 0x62, 0x2e, 0x74, 0x65, + 0x73, 0x74, 0x2e, 0x50, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, + 0x00, 0x28, 0x01, 0x12, 0x54, 0x0a, 0x04, 0x45, 0x63, 0x68, 0x6f, 0x12, 0x24, 0x2e, 0x69, 0x6d, + 0x70, 0x72, 0x6f, 0x62, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x77, 0x65, 0x62, + 0x2e, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x54, 0x65, 0x78, 0x74, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, + 0x65, 0x1a, 0x24, 0x2e, 0x69, 0x6d, 0x70, 0x72, 0x6f, 0x62, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x67, + 0x72, 0x70, 0x63, 0x77, 0x65, 0x62, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x54, 0x65, 0x78, 0x74, + 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x22, 0x00, 0x32, 0xeb, 0x01, 0x0a, 0x0f, 0x54, 0x65, + 0x73, 0x74, 0x55, 0x74, 0x69, 0x6c, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x5a, 0x0a, + 0x0e, 0x43, 0x6f, 0x6e, 0x74, 0x69, 0x6e, 0x75, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, + 0x2e, 0x2e, 0x69, 0x6d, 0x70, 0x72, 0x6f, 0x62, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x67, 0x72, 0x70, + 0x63, 0x77, 0x65, 0x62, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x69, 0x6e, + 0x75, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, + 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, + 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x7c, 0x0a, 0x11, 0x43, 0x68, 0x65, + 0x63, 0x6b, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x43, 0x6c, 0x6f, 0x73, 0x65, 0x64, 0x12, 0x31, + 0x2e, 0x69, 0x6d, 0x70, 0x72, 0x6f, 0x62, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x67, 0x72, 0x70, 0x63, + 0x77, 0x65, 0x62, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x53, 0x74, + 0x72, 0x65, 0x61, 0x6d, 0x43, 0x6c, 0x6f, 0x73, 0x65, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, + 0x74, 0x1a, 0x32, 0x2e, 0x69, 0x6d, 0x70, 0x72, 0x6f, 0x62, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x67, + 0x72, 0x70, 0x63, 0x77, 0x65, 0x62, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x43, 0x68, 0x65, 0x63, + 0x6b, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x43, 0x6c, 0x6f, 0x73, 0x65, 0x64, 0x52, 0x65, 0x73, + 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x32, 0x6b, 0x0a, 0x0b, 0x46, 0x61, 0x69, 0x6c, 0x53, + 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x5c, 0x0a, 0x0b, 0x4e, 0x6f, 0x6e, 0x45, 0x78, 0x69, + 0x73, 0x74, 0x61, 0x6e, 0x74, 0x12, 0x24, 0x2e, 0x69, 0x6d, 0x70, 0x72, 0x6f, 0x62, 0x61, 0x62, + 0x6c, 0x65, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x77, 0x65, 0x62, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x2e, + 0x50, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x25, 0x2e, 0x69, 0x6d, + 0x70, 0x72, 0x6f, 0x62, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x77, 0x65, 0x62, + 0x2e, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x50, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, + 0x73, 0x65, 0x22, 0x00, 0x42, 0x19, 0x5a, 0x17, 0x69, 0x6d, 0x70, 0x72, 0x6f, 0x62, 0x61, 0x62, + 0x6c, 0x65, 0x2f, 0x67, 0x72, 0x70, 0x63, 0x77, 0x65, 0x62, 0x2f, 0x74, 0x65, 0x73, 0x74, 0x62, + 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, +} + +var ( + file_improbable_grpcweb_test_test_proto_rawDescOnce sync.Once + file_improbable_grpcweb_test_test_proto_rawDescData = file_improbable_grpcweb_test_test_proto_rawDesc +) + +func file_improbable_grpcweb_test_test_proto_rawDescGZIP() []byte { + file_improbable_grpcweb_test_test_proto_rawDescOnce.Do(func() { + file_improbable_grpcweb_test_test_proto_rawDescData = protoimpl.X.CompressGZIP(file_improbable_grpcweb_test_test_proto_rawDescData) + }) + return file_improbable_grpcweb_test_test_proto_rawDescData +} + +var file_improbable_grpcweb_test_test_proto_enumTypes = make([]protoimpl.EnumInfo, 1) +var file_improbable_grpcweb_test_test_proto_msgTypes = make([]protoimpl.MessageInfo, 6) +var file_improbable_grpcweb_test_test_proto_goTypes = []interface{}{ + (PingRequest_FailureType)(0), // 0: improbable.grpcweb.test.PingRequest.FailureType + (*PingRequest)(nil), // 1: improbable.grpcweb.test.PingRequest + (*PingResponse)(nil), // 2: improbable.grpcweb.test.PingResponse + (*TextMessage)(nil), // 3: improbable.grpcweb.test.TextMessage + (*ContinueStreamRequest)(nil), // 4: improbable.grpcweb.test.ContinueStreamRequest + (*CheckStreamClosedRequest)(nil), // 5: improbable.grpcweb.test.CheckStreamClosedRequest + (*CheckStreamClosedResponse)(nil), // 6: improbable.grpcweb.test.CheckStreamClosedResponse + (*empty.Empty)(nil), // 7: google.protobuf.Empty +} +var file_improbable_grpcweb_test_test_proto_depIdxs = []int32{ + 0, // 0: improbable.grpcweb.test.PingRequest.failure_type:type_name -> improbable.grpcweb.test.PingRequest.FailureType + 7, // 1: improbable.grpcweb.test.TestService.PingEmpty:input_type -> google.protobuf.Empty + 1, // 2: improbable.grpcweb.test.TestService.Ping:input_type -> improbable.grpcweb.test.PingRequest + 1, // 3: improbable.grpcweb.test.TestService.PingError:input_type -> improbable.grpcweb.test.PingRequest + 1, // 4: improbable.grpcweb.test.TestService.PingList:input_type -> improbable.grpcweb.test.PingRequest + 1, // 5: improbable.grpcweb.test.TestService.PingPongBidi:input_type -> improbable.grpcweb.test.PingRequest + 1, // 6: improbable.grpcweb.test.TestService.PingStream:input_type -> improbable.grpcweb.test.PingRequest + 3, // 7: improbable.grpcweb.test.TestService.Echo:input_type -> improbable.grpcweb.test.TextMessage + 4, // 8: improbable.grpcweb.test.TestUtilService.ContinueStream:input_type -> improbable.grpcweb.test.ContinueStreamRequest + 5, // 9: improbable.grpcweb.test.TestUtilService.CheckStreamClosed:input_type -> improbable.grpcweb.test.CheckStreamClosedRequest + 1, // 10: improbable.grpcweb.test.FailService.NonExistant:input_type -> improbable.grpcweb.test.PingRequest + 2, // 11: improbable.grpcweb.test.TestService.PingEmpty:output_type -> improbable.grpcweb.test.PingResponse + 2, // 12: improbable.grpcweb.test.TestService.Ping:output_type -> improbable.grpcweb.test.PingResponse + 7, // 13: improbable.grpcweb.test.TestService.PingError:output_type -> google.protobuf.Empty + 2, // 14: improbable.grpcweb.test.TestService.PingList:output_type -> improbable.grpcweb.test.PingResponse + 2, // 15: improbable.grpcweb.test.TestService.PingPongBidi:output_type -> improbable.grpcweb.test.PingResponse + 2, // 16: improbable.grpcweb.test.TestService.PingStream:output_type -> improbable.grpcweb.test.PingResponse + 3, // 17: improbable.grpcweb.test.TestService.Echo:output_type -> improbable.grpcweb.test.TextMessage + 7, // 18: improbable.grpcweb.test.TestUtilService.ContinueStream:output_type -> google.protobuf.Empty + 6, // 19: improbable.grpcweb.test.TestUtilService.CheckStreamClosed:output_type -> improbable.grpcweb.test.CheckStreamClosedResponse + 2, // 20: improbable.grpcweb.test.FailService.NonExistant:output_type -> improbable.grpcweb.test.PingResponse + 11, // [11:21] is the sub-list for method output_type + 1, // [1:11] is the sub-list for method input_type + 1, // [1:1] is the sub-list for extension type_name + 1, // [1:1] is the sub-list for extension extendee + 0, // [0:1] is the sub-list for field type_name +} + +func init() { file_improbable_grpcweb_test_test_proto_init() } +func file_improbable_grpcweb_test_test_proto_init() { + if File_improbable_grpcweb_test_test_proto != nil { + return + } + if !protoimpl.UnsafeEnabled { + file_improbable_grpcweb_test_test_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*PingRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_improbable_grpcweb_test_test_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*PingResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_improbable_grpcweb_test_test_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*TextMessage); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_improbable_grpcweb_test_test_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*ContinueStreamRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_improbable_grpcweb_test_test_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*CheckStreamClosedRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_improbable_grpcweb_test_test_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*CheckStreamClosedResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + } + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: file_improbable_grpcweb_test_test_proto_rawDesc, + NumEnums: 1, + NumMessages: 6, + NumExtensions: 0, + NumServices: 3, + }, + GoTypes: file_improbable_grpcweb_test_test_proto_goTypes, + DependencyIndexes: file_improbable_grpcweb_test_test_proto_depIdxs, + EnumInfos: file_improbable_grpcweb_test_test_proto_enumTypes, + MessageInfos: file_improbable_grpcweb_test_test_proto_msgTypes, + }.Build() + File_improbable_grpcweb_test_test_proto = out.File + file_improbable_grpcweb_test_test_proto_rawDesc = nil + file_improbable_grpcweb_test_test_proto_goTypes = nil + file_improbable_grpcweb_test_test_proto_depIdxs = nil } // Reference imports to suppress errors if they are not otherwise used. var _ context.Context -var _ grpc.ClientConn +var _ grpc.ClientConnInterface // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. -const _ = grpc.SupportPackageIsVersion4 +const _ = grpc.SupportPackageIsVersion6 // TestServiceClient is the client API for TestService service. // @@ -447,10 +740,10 @@ type TestServiceClient interface { } type testServiceClient struct { - cc *grpc.ClientConn + cc grpc.ClientConnInterface } -func NewTestServiceClient(cc *grpc.ClientConn) TestServiceClient { +func NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient { return &testServiceClient{cc} } @@ -598,6 +891,32 @@ type TestServiceServer interface { Echo(context.Context, *TextMessage) (*TextMessage, error) } +// UnimplementedTestServiceServer can be embedded to have forward compatible implementations. +type UnimplementedTestServiceServer struct { +} + +func (*UnimplementedTestServiceServer) PingEmpty(context.Context, *empty.Empty) (*PingResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method PingEmpty not implemented") +} +func (*UnimplementedTestServiceServer) Ping(context.Context, *PingRequest) (*PingResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method Ping not implemented") +} +func (*UnimplementedTestServiceServer) PingError(context.Context, *PingRequest) (*empty.Empty, error) { + return nil, status.Errorf(codes.Unimplemented, "method PingError not implemented") +} +func (*UnimplementedTestServiceServer) PingList(*PingRequest, TestService_PingListServer) error { + return status.Errorf(codes.Unimplemented, "method PingList not implemented") +} +func (*UnimplementedTestServiceServer) PingPongBidi(TestService_PingPongBidiServer) error { + return status.Errorf(codes.Unimplemented, "method PingPongBidi not implemented") +} +func (*UnimplementedTestServiceServer) PingStream(TestService_PingStreamServer) error { + return status.Errorf(codes.Unimplemented, "method PingStream not implemented") +} +func (*UnimplementedTestServiceServer) Echo(context.Context, *TextMessage) (*TextMessage, error) { + return nil, status.Errorf(codes.Unimplemented, "method Echo not implemented") +} + func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer) { s.RegisterService(&_TestService_serviceDesc, srv) } @@ -798,10 +1117,10 @@ type TestUtilServiceClient interface { } type testUtilServiceClient struct { - cc *grpc.ClientConn + cc grpc.ClientConnInterface } -func NewTestUtilServiceClient(cc *grpc.ClientConn) TestUtilServiceClient { +func NewTestUtilServiceClient(cc grpc.ClientConnInterface) TestUtilServiceClient { return &testUtilServiceClient{cc} } @@ -829,6 +1148,17 @@ type TestUtilServiceServer interface { CheckStreamClosed(context.Context, *CheckStreamClosedRequest) (*CheckStreamClosedResponse, error) } +// UnimplementedTestUtilServiceServer can be embedded to have forward compatible implementations. +type UnimplementedTestUtilServiceServer struct { +} + +func (*UnimplementedTestUtilServiceServer) ContinueStream(context.Context, *ContinueStreamRequest) (*empty.Empty, error) { + return nil, status.Errorf(codes.Unimplemented, "method ContinueStream not implemented") +} +func (*UnimplementedTestUtilServiceServer) CheckStreamClosed(context.Context, *CheckStreamClosedRequest) (*CheckStreamClosedResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method CheckStreamClosed not implemented") +} + func RegisterTestUtilServiceServer(s *grpc.Server, srv TestUtilServiceServer) { s.RegisterService(&_TestUtilService_serviceDesc, srv) } @@ -894,10 +1224,10 @@ type FailServiceClient interface { } type failServiceClient struct { - cc *grpc.ClientConn + cc grpc.ClientConnInterface } -func NewFailServiceClient(cc *grpc.ClientConn) FailServiceClient { +func NewFailServiceClient(cc grpc.ClientConnInterface) FailServiceClient { return &failServiceClient{cc} } @@ -915,6 +1245,14 @@ type FailServiceServer interface { NonExistant(context.Context, *PingRequest) (*PingResponse, error) } +// UnimplementedFailServiceServer can be embedded to have forward compatible implementations. +type UnimplementedFailServiceServer struct { +} + +func (*UnimplementedFailServiceServer) NonExistant(context.Context, *PingRequest) (*PingResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method NonExistant not implemented") +} + func RegisterFailServiceServer(s *grpc.Server, srv FailServiceServer) { s.RegisterService(&_FailService_serviceDesc, srv) } diff --git a/integration_test/package.json b/integration_test/package.json index c1b9cb64..f823a224 100644 --- a/integration_test/package.json +++ b/integration_test/package.json @@ -5,7 +5,7 @@ "scripts": { "clean": "rm -rf ts/build && rm -rf ts/build-node", "build:testserver": "cd go && go build -o ./build/testserver ./testserver/testserver.go", - "build:proto": "cd proto && prototool generate", + "build:proto": "cd proto && buf generate", "build:ts": "cd ts && rm -rf build && webpack-cli", "build:dev": "cd ts && rm -rf build && webpack-cli --watch", "build:node": "cd ts && rm -rf build-node && (cd node-src && tsc) && (cp -R _proto build-node/integration_test/ts)", diff --git a/integration_test/proto/buf.gen.yaml b/integration_test/proto/buf.gen.yaml new file mode 100644 index 00000000..fa8410e3 --- /dev/null +++ b/integration_test/proto/buf.gen.yaml @@ -0,0 +1,16 @@ +version: v1beta1 +plugins: + - name: go + out: ../go/_proto + opt: + - plugins=grpc + - name: js + out: ../ts/_proto + opt: + - import_style=commonjs + - binary + - name: ts + out: ../ts/_proto + path: ../node_modules/.bin/protoc-gen-ts + opt: + - service=grpc-web diff --git a/integration_test/proto/prototool.yaml b/integration_test/proto/prototool.yaml deleted file mode 100644 index bc723ed1..00000000 --- a/integration_test/proto/prototool.yaml +++ /dev/null @@ -1,24 +0,0 @@ -protoc: - version: 3.8.0 -lint: - group: uber2 -generate: - go_options: - # The base import path. This should be the go path of the prototool.yaml file. - # This is required if you have any go plugins. - import_path: integration_test/proto - - plugins: - - name: go - type: go - flags: plugins=grpc - output: ../go/_proto - - - name: js - flags: import_style=commonjs,binary - output: ../ts/_proto - - - name: ts - path: ../node_modules/.bin/protoc-gen-ts - flags: service=grpc-web - output: ../ts/_proto diff --git a/integration_test/ts/_proto/improbable/grpcweb/test/test_pb.js b/integration_test/ts/_proto/improbable/grpcweb/test/test_pb.js index 7b0c9032..2c1ed9d0 100644 --- a/integration_test/ts/_proto/improbable/grpcweb/test/test_pb.js +++ b/integration_test/ts/_proto/improbable/grpcweb/test/test_pb.js @@ -1,3 +1,4 @@ +// source: improbable/grpcweb/test/test.proto /** * @fileoverview * @enhanceable @@ -360,9 +361,12 @@ proto.improbable.grpcweb.test.PingRequest.prototype.getValue = function() { }; -/** @param {string} value */ +/** + * @param {string} value + * @return {!proto.improbable.grpcweb.test.PingRequest} returns this + */ proto.improbable.grpcweb.test.PingRequest.prototype.setValue = function(value) { - jspb.Message.setProto3StringField(this, 1, value); + return jspb.Message.setProto3StringField(this, 1, value); }; @@ -375,9 +379,12 @@ proto.improbable.grpcweb.test.PingRequest.prototype.getResponseCount = function( }; -/** @param {number} value */ +/** + * @param {number} value + * @return {!proto.improbable.grpcweb.test.PingRequest} returns this + */ proto.improbable.grpcweb.test.PingRequest.prototype.setResponseCount = function(value) { - jspb.Message.setProto3IntField(this, 2, value); + return jspb.Message.setProto3IntField(this, 2, value); }; @@ -390,9 +397,12 @@ proto.improbable.grpcweb.test.PingRequest.prototype.getErrorCodeReturned = funct }; -/** @param {number} value */ +/** + * @param {number} value + * @return {!proto.improbable.grpcweb.test.PingRequest} returns this + */ proto.improbable.grpcweb.test.PingRequest.prototype.setErrorCodeReturned = function(value) { - jspb.Message.setProto3IntField(this, 3, value); + return jspb.Message.setProto3IntField(this, 3, value); }; @@ -405,9 +415,12 @@ proto.improbable.grpcweb.test.PingRequest.prototype.getFailureType = function() }; -/** @param {!proto.improbable.grpcweb.test.PingRequest.FailureType} value */ +/** + * @param {!proto.improbable.grpcweb.test.PingRequest.FailureType} value + * @return {!proto.improbable.grpcweb.test.PingRequest} returns this + */ proto.improbable.grpcweb.test.PingRequest.prototype.setFailureType = function(value) { - jspb.Message.setProto3EnumField(this, 4, value); + return jspb.Message.setProto3EnumField(this, 4, value); }; @@ -420,9 +433,12 @@ proto.improbable.grpcweb.test.PingRequest.prototype.getCheckMetadata = function( }; -/** @param {boolean} value */ +/** + * @param {boolean} value + * @return {!proto.improbable.grpcweb.test.PingRequest} returns this + */ proto.improbable.grpcweb.test.PingRequest.prototype.setCheckMetadata = function(value) { - jspb.Message.setProto3BooleanField(this, 5, value); + return jspb.Message.setProto3BooleanField(this, 5, value); }; @@ -435,9 +451,12 @@ proto.improbable.grpcweb.test.PingRequest.prototype.getSendHeaders = function() }; -/** @param {boolean} value */ +/** + * @param {boolean} value + * @return {!proto.improbable.grpcweb.test.PingRequest} returns this + */ proto.improbable.grpcweb.test.PingRequest.prototype.setSendHeaders = function(value) { - jspb.Message.setProto3BooleanField(this, 6, value); + return jspb.Message.setProto3BooleanField(this, 6, value); }; @@ -450,9 +469,12 @@ proto.improbable.grpcweb.test.PingRequest.prototype.getSendTrailers = function() }; -/** @param {boolean} value */ +/** + * @param {boolean} value + * @return {!proto.improbable.grpcweb.test.PingRequest} returns this + */ proto.improbable.grpcweb.test.PingRequest.prototype.setSendTrailers = function(value) { - jspb.Message.setProto3BooleanField(this, 7, value); + return jspb.Message.setProto3BooleanField(this, 7, value); }; @@ -465,9 +487,12 @@ proto.improbable.grpcweb.test.PingRequest.prototype.getStreamIdentifier = functi }; -/** @param {string} value */ +/** + * @param {string} value + * @return {!proto.improbable.grpcweb.test.PingRequest} returns this + */ proto.improbable.grpcweb.test.PingRequest.prototype.setStreamIdentifier = function(value) { - jspb.Message.setProto3StringField(this, 8, value); + return jspb.Message.setProto3StringField(this, 8, value); }; @@ -604,9 +629,12 @@ proto.improbable.grpcweb.test.PingResponse.prototype.getValue = function() { }; -/** @param {string} value */ +/** + * @param {string} value + * @return {!proto.improbable.grpcweb.test.PingResponse} returns this + */ proto.improbable.grpcweb.test.PingResponse.prototype.setValue = function(value) { - jspb.Message.setProto3StringField(this, 1, value); + return jspb.Message.setProto3StringField(this, 1, value); }; @@ -619,9 +647,12 @@ proto.improbable.grpcweb.test.PingResponse.prototype.getCounter = function() { }; -/** @param {number} value */ +/** + * @param {number} value + * @return {!proto.improbable.grpcweb.test.PingResponse} returns this + */ proto.improbable.grpcweb.test.PingResponse.prototype.setCounter = function(value) { - jspb.Message.setProto3IntField(this, 2, value); + return jspb.Message.setProto3IntField(this, 2, value); }; @@ -770,9 +801,12 @@ proto.improbable.grpcweb.test.TextMessage.prototype.getText = function() { }; -/** @param {string} value */ +/** + * @param {string} value + * @return {!proto.improbable.grpcweb.test.TextMessage} returns this + */ proto.improbable.grpcweb.test.TextMessage.prototype.setText = function(value) { - jspb.Message.setProto3StringField(this, 1, value); + return jspb.Message.setProto3StringField(this, 1, value); }; @@ -785,9 +819,12 @@ proto.improbable.grpcweb.test.TextMessage.prototype.getSendHeaders = function() }; -/** @param {boolean} value */ +/** + * @param {boolean} value + * @return {!proto.improbable.grpcweb.test.TextMessage} returns this + */ proto.improbable.grpcweb.test.TextMessage.prototype.setSendHeaders = function(value) { - jspb.Message.setProto3BooleanField(this, 2, value); + return jspb.Message.setProto3BooleanField(this, 2, value); }; @@ -800,9 +837,12 @@ proto.improbable.grpcweb.test.TextMessage.prototype.getSendTrailers = function() }; -/** @param {boolean} value */ +/** + * @param {boolean} value + * @return {!proto.improbable.grpcweb.test.TextMessage} returns this + */ proto.improbable.grpcweb.test.TextMessage.prototype.setSendTrailers = function(value) { - jspb.Message.setProto3BooleanField(this, 3, value); + return jspb.Message.setProto3BooleanField(this, 3, value); }; @@ -927,9 +967,12 @@ proto.improbable.grpcweb.test.ContinueStreamRequest.prototype.getStreamIdentifie }; -/** @param {string} value */ +/** + * @param {string} value + * @return {!proto.improbable.grpcweb.test.ContinueStreamRequest} returns this + */ proto.improbable.grpcweb.test.ContinueStreamRequest.prototype.setStreamIdentifier = function(value) { - jspb.Message.setProto3StringField(this, 1, value); + return jspb.Message.setProto3StringField(this, 1, value); }; @@ -1054,9 +1097,12 @@ proto.improbable.grpcweb.test.CheckStreamClosedRequest.prototype.getStreamIdenti }; -/** @param {string} value */ +/** + * @param {string} value + * @return {!proto.improbable.grpcweb.test.CheckStreamClosedRequest} returns this + */ proto.improbable.grpcweb.test.CheckStreamClosedRequest.prototype.setStreamIdentifier = function(value) { - jspb.Message.setProto3StringField(this, 1, value); + return jspb.Message.setProto3StringField(this, 1, value); }; @@ -1181,9 +1227,12 @@ proto.improbable.grpcweb.test.CheckStreamClosedResponse.prototype.getClosed = fu }; -/** @param {boolean} value */ +/** + * @param {boolean} value + * @return {!proto.improbable.grpcweb.test.CheckStreamClosedResponse} returns this + */ proto.improbable.grpcweb.test.CheckStreamClosedResponse.prototype.setClosed = function(value) { - jspb.Message.setProto3BooleanField(this, 1, value); + return jspb.Message.setProto3BooleanField(this, 1, value); }; diff --git a/lint-all.sh b/lint-all.sh index dada6e79..17540bc4 100755 --- a/lint-all.sh +++ b/lint-all.sh @@ -5,3 +5,6 @@ cd go && . ./lint.sh && cd .. echo "Linting TypeScript sources" npm run lint + +echo "Linting protobuf sources" +buf lint