1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: improbable/grpcweb/test/test.proto 3 4package improbable_grpcweb_test 5 6import ( 7 context "context" 8 fmt "fmt" 9 proto "github.com/golang/protobuf/proto" 10 empty "github.com/golang/protobuf/ptypes/empty" 11 grpc "google.golang.org/grpc" 12 math "math" 13) 14 15// Reference imports to suppress errors if they are not otherwise used. 16var _ = proto.Marshal 17var _ = fmt.Errorf 18var _ = math.Inf 19 20// This is a compile-time assertion to ensure that this generated file 21// is compatible with the proto package it is being compiled against. 22// A compilation error at this line likely means your copy of the 23// proto package needs to be updated. 24const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package 25 26type PingRequest_FailureType int32 27 28const ( 29 PingRequest_NONE PingRequest_FailureType = 0 30 PingRequest_CODE PingRequest_FailureType = 1 31 PingRequest_CODE_UNICODE PingRequest_FailureType = 3 32) 33 34var PingRequest_FailureType_name = map[int32]string{ 35 0: "NONE", 36 1: "CODE", 37 3: "CODE_UNICODE", 38} 39 40var PingRequest_FailureType_value = map[string]int32{ 41 "NONE": 0, 42 "CODE": 1, 43 "CODE_UNICODE": 3, 44} 45 46func (x PingRequest_FailureType) String() string { 47 return proto.EnumName(PingRequest_FailureType_name, int32(x)) 48} 49 50func (PingRequest_FailureType) EnumDescriptor() ([]byte, []int) { 51 return fileDescriptor_18e8d9116297b46c, []int{0, 0} 52} 53 54type PingRequest struct { 55 Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` 56 ResponseCount int32 `protobuf:"varint,2,opt,name=response_count,json=responseCount,proto3" json:"response_count,omitempty"` 57 ErrorCodeReturned uint32 `protobuf:"varint,3,opt,name=error_code_returned,json=errorCodeReturned,proto3" json:"error_code_returned,omitempty"` 58 FailureType PingRequest_FailureType `protobuf:"varint,4,opt,name=failure_type,json=failureType,proto3,enum=improbable.grpcweb.test.PingRequest_FailureType" json:"failure_type,omitempty"` 59 CheckMetadata bool `protobuf:"varint,5,opt,name=check_metadata,json=checkMetadata,proto3" json:"check_metadata,omitempty"` 60 SendHeaders bool `protobuf:"varint,6,opt,name=send_headers,json=sendHeaders,proto3" json:"send_headers,omitempty"` 61 SendTrailers bool `protobuf:"varint,7,opt,name=send_trailers,json=sendTrailers,proto3" json:"send_trailers,omitempty"` 62 StreamIdentifier string `protobuf:"bytes,8,opt,name=stream_identifier,json=streamIdentifier,proto3" json:"stream_identifier,omitempty"` 63 XXX_NoUnkeyedLiteral struct{} `json:"-"` 64 XXX_unrecognized []byte `json:"-"` 65 XXX_sizecache int32 `json:"-"` 66} 67 68func (m *PingRequest) Reset() { *m = PingRequest{} } 69func (m *PingRequest) String() string { return proto.CompactTextString(m) } 70func (*PingRequest) ProtoMessage() {} 71func (*PingRequest) Descriptor() ([]byte, []int) { 72 return fileDescriptor_18e8d9116297b46c, []int{0} 73} 74 75func (m *PingRequest) XXX_Unmarshal(b []byte) error { 76 return xxx_messageInfo_PingRequest.Unmarshal(m, b) 77} 78func (m *PingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 79 return xxx_messageInfo_PingRequest.Marshal(b, m, deterministic) 80} 81func (m *PingRequest) XXX_Merge(src proto.Message) { 82 xxx_messageInfo_PingRequest.Merge(m, src) 83} 84func (m *PingRequest) XXX_Size() int { 85 return xxx_messageInfo_PingRequest.Size(m) 86} 87func (m *PingRequest) XXX_DiscardUnknown() { 88 xxx_messageInfo_PingRequest.DiscardUnknown(m) 89} 90 91var xxx_messageInfo_PingRequest proto.InternalMessageInfo 92 93func (m *PingRequest) GetValue() string { 94 if m != nil { 95 return m.Value 96 } 97 return "" 98} 99 100func (m *PingRequest) GetResponseCount() int32 { 101 if m != nil { 102 return m.ResponseCount 103 } 104 return 0 105} 106 107func (m *PingRequest) GetErrorCodeReturned() uint32 { 108 if m != nil { 109 return m.ErrorCodeReturned 110 } 111 return 0 112} 113 114func (m *PingRequest) GetFailureType() PingRequest_FailureType { 115 if m != nil { 116 return m.FailureType 117 } 118 return PingRequest_NONE 119} 120 121func (m *PingRequest) GetCheckMetadata() bool { 122 if m != nil { 123 return m.CheckMetadata 124 } 125 return false 126} 127 128func (m *PingRequest) GetSendHeaders() bool { 129 if m != nil { 130 return m.SendHeaders 131 } 132 return false 133} 134 135func (m *PingRequest) GetSendTrailers() bool { 136 if m != nil { 137 return m.SendTrailers 138 } 139 return false 140} 141 142func (m *PingRequest) GetStreamIdentifier() string { 143 if m != nil { 144 return m.StreamIdentifier 145 } 146 return "" 147} 148 149type PingResponse struct { 150 Value string `protobuf:"bytes,1,opt,name=Value,proto3" json:"Value,omitempty"` 151 Counter int32 `protobuf:"varint,2,opt,name=counter,proto3" json:"counter,omitempty"` 152 XXX_NoUnkeyedLiteral struct{} `json:"-"` 153 XXX_unrecognized []byte `json:"-"` 154 XXX_sizecache int32 `json:"-"` 155} 156 157func (m *PingResponse) Reset() { *m = PingResponse{} } 158func (m *PingResponse) String() string { return proto.CompactTextString(m) } 159func (*PingResponse) ProtoMessage() {} 160func (*PingResponse) Descriptor() ([]byte, []int) { 161 return fileDescriptor_18e8d9116297b46c, []int{1} 162} 163 164func (m *PingResponse) XXX_Unmarshal(b []byte) error { 165 return xxx_messageInfo_PingResponse.Unmarshal(m, b) 166} 167func (m *PingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 168 return xxx_messageInfo_PingResponse.Marshal(b, m, deterministic) 169} 170func (m *PingResponse) XXX_Merge(src proto.Message) { 171 xxx_messageInfo_PingResponse.Merge(m, src) 172} 173func (m *PingResponse) XXX_Size() int { 174 return xxx_messageInfo_PingResponse.Size(m) 175} 176func (m *PingResponse) XXX_DiscardUnknown() { 177 xxx_messageInfo_PingResponse.DiscardUnknown(m) 178} 179 180var xxx_messageInfo_PingResponse proto.InternalMessageInfo 181 182func (m *PingResponse) GetValue() string { 183 if m != nil { 184 return m.Value 185 } 186 return "" 187} 188 189func (m *PingResponse) GetCounter() int32 { 190 if m != nil { 191 return m.Counter 192 } 193 return 0 194} 195 196type TextMessage struct { 197 Text string `protobuf:"bytes,1,opt,name=text,proto3" json:"text,omitempty"` 198 SendHeaders bool `protobuf:"varint,2,opt,name=send_headers,json=sendHeaders,proto3" json:"send_headers,omitempty"` 199 SendTrailers bool `protobuf:"varint,3,opt,name=send_trailers,json=sendTrailers,proto3" json:"send_trailers,omitempty"` 200 XXX_NoUnkeyedLiteral struct{} `json:"-"` 201 XXX_unrecognized []byte `json:"-"` 202 XXX_sizecache int32 `json:"-"` 203} 204 205func (m *TextMessage) Reset() { *m = TextMessage{} } 206func (m *TextMessage) String() string { return proto.CompactTextString(m) } 207func (*TextMessage) ProtoMessage() {} 208func (*TextMessage) Descriptor() ([]byte, []int) { 209 return fileDescriptor_18e8d9116297b46c, []int{2} 210} 211 212func (m *TextMessage) XXX_Unmarshal(b []byte) error { 213 return xxx_messageInfo_TextMessage.Unmarshal(m, b) 214} 215func (m *TextMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 216 return xxx_messageInfo_TextMessage.Marshal(b, m, deterministic) 217} 218func (m *TextMessage) XXX_Merge(src proto.Message) { 219 xxx_messageInfo_TextMessage.Merge(m, src) 220} 221func (m *TextMessage) XXX_Size() int { 222 return xxx_messageInfo_TextMessage.Size(m) 223} 224func (m *TextMessage) XXX_DiscardUnknown() { 225 xxx_messageInfo_TextMessage.DiscardUnknown(m) 226} 227 228var xxx_messageInfo_TextMessage proto.InternalMessageInfo 229 230func (m *TextMessage) GetText() string { 231 if m != nil { 232 return m.Text 233 } 234 return "" 235} 236 237func (m *TextMessage) GetSendHeaders() bool { 238 if m != nil { 239 return m.SendHeaders 240 } 241 return false 242} 243 244func (m *TextMessage) GetSendTrailers() bool { 245 if m != nil { 246 return m.SendTrailers 247 } 248 return false 249} 250 251type ContinueStreamRequest struct { 252 StreamIdentifier string `protobuf:"bytes,1,opt,name=stream_identifier,json=streamIdentifier,proto3" json:"stream_identifier,omitempty"` 253 XXX_NoUnkeyedLiteral struct{} `json:"-"` 254 XXX_unrecognized []byte `json:"-"` 255 XXX_sizecache int32 `json:"-"` 256} 257 258func (m *ContinueStreamRequest) Reset() { *m = ContinueStreamRequest{} } 259func (m *ContinueStreamRequest) String() string { return proto.CompactTextString(m) } 260func (*ContinueStreamRequest) ProtoMessage() {} 261func (*ContinueStreamRequest) Descriptor() ([]byte, []int) { 262 return fileDescriptor_18e8d9116297b46c, []int{3} 263} 264 265func (m *ContinueStreamRequest) XXX_Unmarshal(b []byte) error { 266 return xxx_messageInfo_ContinueStreamRequest.Unmarshal(m, b) 267} 268func (m *ContinueStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 269 return xxx_messageInfo_ContinueStreamRequest.Marshal(b, m, deterministic) 270} 271func (m *ContinueStreamRequest) XXX_Merge(src proto.Message) { 272 xxx_messageInfo_ContinueStreamRequest.Merge(m, src) 273} 274func (m *ContinueStreamRequest) XXX_Size() int { 275 return xxx_messageInfo_ContinueStreamRequest.Size(m) 276} 277func (m *ContinueStreamRequest) XXX_DiscardUnknown() { 278 xxx_messageInfo_ContinueStreamRequest.DiscardUnknown(m) 279} 280 281var xxx_messageInfo_ContinueStreamRequest proto.InternalMessageInfo 282 283func (m *ContinueStreamRequest) GetStreamIdentifier() string { 284 if m != nil { 285 return m.StreamIdentifier 286 } 287 return "" 288} 289 290type CheckStreamClosedRequest struct { 291 StreamIdentifier string `protobuf:"bytes,1,opt,name=stream_identifier,json=streamIdentifier,proto3" json:"stream_identifier,omitempty"` 292 XXX_NoUnkeyedLiteral struct{} `json:"-"` 293 XXX_unrecognized []byte `json:"-"` 294 XXX_sizecache int32 `json:"-"` 295} 296 297func (m *CheckStreamClosedRequest) Reset() { *m = CheckStreamClosedRequest{} } 298func (m *CheckStreamClosedRequest) String() string { return proto.CompactTextString(m) } 299func (*CheckStreamClosedRequest) ProtoMessage() {} 300func (*CheckStreamClosedRequest) Descriptor() ([]byte, []int) { 301 return fileDescriptor_18e8d9116297b46c, []int{4} 302} 303 304func (m *CheckStreamClosedRequest) XXX_Unmarshal(b []byte) error { 305 return xxx_messageInfo_CheckStreamClosedRequest.Unmarshal(m, b) 306} 307func (m *CheckStreamClosedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 308 return xxx_messageInfo_CheckStreamClosedRequest.Marshal(b, m, deterministic) 309} 310func (m *CheckStreamClosedRequest) XXX_Merge(src proto.Message) { 311 xxx_messageInfo_CheckStreamClosedRequest.Merge(m, src) 312} 313func (m *CheckStreamClosedRequest) XXX_Size() int { 314 return xxx_messageInfo_CheckStreamClosedRequest.Size(m) 315} 316func (m *CheckStreamClosedRequest) XXX_DiscardUnknown() { 317 xxx_messageInfo_CheckStreamClosedRequest.DiscardUnknown(m) 318} 319 320var xxx_messageInfo_CheckStreamClosedRequest proto.InternalMessageInfo 321 322func (m *CheckStreamClosedRequest) GetStreamIdentifier() string { 323 if m != nil { 324 return m.StreamIdentifier 325 } 326 return "" 327} 328 329type CheckStreamClosedResponse struct { 330 Closed bool `protobuf:"varint,1,opt,name=closed,proto3" json:"closed,omitempty"` 331 XXX_NoUnkeyedLiteral struct{} `json:"-"` 332 XXX_unrecognized []byte `json:"-"` 333 XXX_sizecache int32 `json:"-"` 334} 335 336func (m *CheckStreamClosedResponse) Reset() { *m = CheckStreamClosedResponse{} } 337func (m *CheckStreamClosedResponse) String() string { return proto.CompactTextString(m) } 338func (*CheckStreamClosedResponse) ProtoMessage() {} 339func (*CheckStreamClosedResponse) Descriptor() ([]byte, []int) { 340 return fileDescriptor_18e8d9116297b46c, []int{5} 341} 342 343func (m *CheckStreamClosedResponse) XXX_Unmarshal(b []byte) error { 344 return xxx_messageInfo_CheckStreamClosedResponse.Unmarshal(m, b) 345} 346func (m *CheckStreamClosedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 347 return xxx_messageInfo_CheckStreamClosedResponse.Marshal(b, m, deterministic) 348} 349func (m *CheckStreamClosedResponse) XXX_Merge(src proto.Message) { 350 xxx_messageInfo_CheckStreamClosedResponse.Merge(m, src) 351} 352func (m *CheckStreamClosedResponse) XXX_Size() int { 353 return xxx_messageInfo_CheckStreamClosedResponse.Size(m) 354} 355func (m *CheckStreamClosedResponse) XXX_DiscardUnknown() { 356 xxx_messageInfo_CheckStreamClosedResponse.DiscardUnknown(m) 357} 358 359var xxx_messageInfo_CheckStreamClosedResponse proto.InternalMessageInfo 360 361func (m *CheckStreamClosedResponse) GetClosed() bool { 362 if m != nil { 363 return m.Closed 364 } 365 return false 366} 367 368func init() { 369 proto.RegisterEnum("improbable.grpcweb.test.PingRequest_FailureType", PingRequest_FailureType_name, PingRequest_FailureType_value) 370 proto.RegisterType((*PingRequest)(nil), "improbable.grpcweb.test.PingRequest") 371 proto.RegisterType((*PingResponse)(nil), "improbable.grpcweb.test.PingResponse") 372 proto.RegisterType((*TextMessage)(nil), "improbable.grpcweb.test.TextMessage") 373 proto.RegisterType((*ContinueStreamRequest)(nil), "improbable.grpcweb.test.ContinueStreamRequest") 374 proto.RegisterType((*CheckStreamClosedRequest)(nil), "improbable.grpcweb.test.CheckStreamClosedRequest") 375 proto.RegisterType((*CheckStreamClosedResponse)(nil), "improbable.grpcweb.test.CheckStreamClosedResponse") 376} 377 378func init() { proto.RegisterFile("improbable/grpcweb/test/test.proto", fileDescriptor_18e8d9116297b46c) } 379 380var fileDescriptor_18e8d9116297b46c = []byte{ 381 // 661 bytes of a gzipped FileDescriptorProto 382 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x54, 0xcd, 0x6e, 0xd3, 0x40, 383 0x10, 0x8e, 0x13, 0xb7, 0x4d, 0x27, 0x49, 0x49, 0x17, 0x28, 0x26, 0x5c, 0x82, 0xa1, 0x52, 0x24, 384 0x24, 0xa7, 0xa4, 0x27, 0x2e, 0x1c, 0x48, 0x03, 0x54, 0xb4, 0x69, 0xe5, 0xa6, 0x1c, 0xf8, 0x91, 385 0xe5, 0xd8, 0x93, 0x74, 0x55, 0xc7, 0x6b, 0xd6, 0xeb, 0xd2, 0x4a, 0x3c, 0x0f, 0x2f, 0xc7, 0x95, 386 0x07, 0x40, 0xbb, 0xb6, 0x69, 0x50, 0x93, 0x12, 0x50, 0x2e, 0xd6, 0xce, 0xb7, 0x33, 0xb3, 0x33, 387 0xdf, 0xcc, 0x67, 0x30, 0xe9, 0x24, 0xe2, 0x6c, 0xe8, 0x0e, 0x03, 0x6c, 0x8f, 0x79, 0xe4, 0x7d, 388 0xc5, 0x61, 0x5b, 0x60, 0x2c, 0xd4, 0xc7, 0x8a, 0x38, 0x13, 0x8c, 0x3c, 0xb8, 0xf6, 0xb1, 0x32, 389 0x1f, 0x4b, 0x5e, 0x37, 0x1e, 0x8d, 0x19, 0x1b, 0x07, 0xd8, 0x56, 0x6e, 0xc3, 0x64, 0xd4, 0xc6, 390 0x49, 0x24, 0xae, 0xd2, 0x28, 0xf3, 0x7b, 0x09, 0x2a, 0xc7, 0x34, 0x1c, 0xdb, 0xf8, 0x25, 0xc1, 391 0x58, 0x90, 0x7b, 0xb0, 0x72, 0xe1, 0x06, 0x09, 0x1a, 0x5a, 0x53, 0x6b, 0xad, 0xdb, 0xa9, 0x41, 392 0xb6, 0x61, 0x83, 0x63, 0x1c, 0xb1, 0x30, 0x46, 0xc7, 0x63, 0x49, 0x28, 0x8c, 0x62, 0x53, 0x6b, 393 0xad, 0xd8, 0xb5, 0x1c, 0xed, 0x4a, 0x90, 0x58, 0x70, 0x17, 0x39, 0x67, 0xdc, 0xf1, 0x98, 0x8f, 394 0x0e, 0x47, 0x91, 0xf0, 0x10, 0x7d, 0xa3, 0xd4, 0xd4, 0x5a, 0x35, 0x7b, 0x53, 0x5d, 0x75, 0x99, 395 0x8f, 0x76, 0x76, 0x41, 0x4e, 0xa0, 0x3a, 0x72, 0x69, 0x90, 0x70, 0x74, 0xc4, 0x55, 0x84, 0x86, 396 0xde, 0xd4, 0x5a, 0x1b, 0x9d, 0x1d, 0x6b, 0x4e, 0x27, 0xd6, 0x54, 0xa1, 0xd6, 0xeb, 0x34, 0x70, 397 0x70, 0x15, 0xa1, 0x5d, 0x19, 0x5d, 0x1b, 0xb2, 0x56, 0xef, 0x0c, 0xbd, 0x73, 0x67, 0x82, 0xc2, 398 0xf5, 0x5d, 0xe1, 0x1a, 0x2b, 0x4d, 0xad, 0x55, 0xb6, 0x6b, 0x0a, 0x3d, 0xcc, 0x40, 0xf2, 0x18, 399 0xaa, 0x31, 0x86, 0xbe, 0x73, 0x86, 0xae, 0x8f, 0x3c, 0x36, 0x56, 0x95, 0x53, 0x45, 0x62, 0x6f, 400 0x53, 0x88, 0x3c, 0x81, 0x9a, 0x72, 0x11, 0xdc, 0xa5, 0x81, 0xf4, 0x59, 0x53, 0x3e, 0x2a, 0x6e, 401 0x90, 0x61, 0xe4, 0x19, 0x6c, 0xc6, 0x82, 0xa3, 0x3b, 0x71, 0xa8, 0x8f, 0xa1, 0xa0, 0x23, 0x8a, 402 0xdc, 0x28, 0x2b, 0xf2, 0xea, 0xe9, 0xc5, 0xfe, 0x6f, 0xdc, 0x7c, 0x01, 0x95, 0xa9, 0xba, 0x49, 403 0x19, 0xf4, 0xfe, 0x51, 0xbf, 0x57, 0x2f, 0xc8, 0x53, 0xf7, 0x68, 0xaf, 0x57, 0xd7, 0x48, 0x1d, 404 0xaa, 0xf2, 0xe4, 0x9c, 0xf6, 0xf7, 0x15, 0x52, 0x32, 0xf5, 0x72, 0xb1, 0x5e, 0x34, 0x5f, 0x42, 405 0x35, 0x6d, 0x3f, 0x25, 0x5c, 0x0e, 0xea, 0xfd, 0xf4, 0xa0, 0x94, 0x41, 0x0c, 0x58, 0x53, 0xf3, 406 0x41, 0x9e, 0x4d, 0x28, 0x37, 0x4d, 0x0a, 0x95, 0x01, 0x5e, 0x8a, 0x43, 0x8c, 0x63, 0x77, 0x8c, 407 0x84, 0x80, 0x2e, 0xf0, 0x52, 0x64, 0xd1, 0xea, 0x7c, 0x83, 0x92, 0xe2, 0x02, 0x94, 0x94, 0x6e, 408 0x52, 0x62, 0xee, 0xc1, 0xfd, 0x2e, 0x0b, 0x05, 0x0d, 0x13, 0x3c, 0x51, 0x0c, 0xe4, 0xcb, 0x35, 409 0x93, 0x2b, 0x6d, 0x0e, 0x57, 0x6f, 0xc0, 0xe8, 0xca, 0x89, 0xa5, 0x29, 0xba, 0x01, 0x8b, 0xd1, 410 0xff, 0xaf, 0x44, 0xbb, 0xf0, 0x70, 0x46, 0xa2, 0x8c, 0xc6, 0x2d, 0x58, 0xf5, 0x14, 0xa2, 0xc2, 411 0xcb, 0x76, 0x66, 0x75, 0x7e, 0xea, 0x92, 0xaf, 0x58, 0x9c, 0x20, 0xbf, 0xa0, 0x1e, 0x92, 0x03, 412 0x58, 0x97, 0xf4, 0xf7, 0xa4, 0x74, 0xc8, 0x96, 0x95, 0x4a, 0xca, 0xca, 0x25, 0x65, 0x29, 0xbc, 413 0xb1, 0xfd, 0x97, 0xcd, 0x4d, 0xdf, 0x34, 0x0b, 0xe4, 0x14, 0x74, 0x89, 0x90, 0xa7, 0x8b, 0xac, 414 0xfa, 0xe2, 0x69, 0xdf, 0x65, 0x45, 0x4a, 0xa1, 0x2d, 0x98, 0x7b, 0x4e, 0x2b, 0x66, 0x81, 0x7c, 415 0x84, 0xb2, 0x74, 0x3c, 0xa0, 0xb1, 0x58, 0x72, 0x9d, 0x3b, 0x1a, 0x71, 0xd3, 0x6d, 0x3e, 0x66, 416 0xe1, 0xf8, 0x15, 0xf5, 0xe9, 0x92, 0x1f, 0x68, 0x69, 0x3b, 0x1a, 0xf9, 0x0c, 0x20, 0xd1, 0x74, 417 0xea, 0x4b, 0x7f, 0x80, 0x0c, 0x40, 0xef, 0x79, 0x67, 0xec, 0x96, 0xc4, 0x53, 0x72, 0x6b, 0x2c, 418 0xe4, 0x65, 0x16, 0x3a, 0x3f, 0x34, 0xb8, 0x23, 0xd7, 0xee, 0x54, 0xd0, 0x20, 0x5f, 0xbd, 0x0f, 419 0xb0, 0xf1, 0xa7, 0x9c, 0x88, 0x35, 0x37, 0xdb, 0x4c, 0xdd, 0xdd, 0x32, 0xe4, 0x6f, 0xb0, 0x79, 420 0x43, 0x1b, 0xe4, 0xf9, 0xfc, 0xf4, 0x73, 0x04, 0xd9, 0xe8, 0xfc, 0x4b, 0x48, 0xce, 0x62, 0xe7, 421 0x3c, 0xfd, 0x1d, 0xe6, 0x8d, 0x7e, 0x82, 0x4a, 0x9f, 0x85, 0xbd, 0x4b, 0x1a, 0x0b, 0x37, 0x5c, 422 0xf6, 0xd2, 0x0d, 0x57, 0x55, 0xf3, 0xbb, 0xbf, 0x02, 0x00, 0x00, 0xff, 0xff, 0xe7, 0xbe, 0xd7, 423 0xbd, 0x4c, 0x07, 0x00, 0x00, 424} 425 426// Reference imports to suppress errors if they are not otherwise used. 427var _ context.Context 428var _ grpc.ClientConn 429 430// This is a compile-time assertion to ensure that this generated file 431// is compatible with the grpc package it is being compiled against. 432const _ = grpc.SupportPackageIsVersion4 433 434// TestServiceClient is the client API for TestService service. 435// 436// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 437type TestServiceClient interface { 438 PingEmpty(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*PingResponse, error) 439 Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error) 440 PingError(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*empty.Empty, error) 441 PingList(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (TestService_PingListClient, error) 442 PingPongBidi(ctx context.Context, opts ...grpc.CallOption) (TestService_PingPongBidiClient, error) 443 PingStream(ctx context.Context, opts ...grpc.CallOption) (TestService_PingStreamClient, error) 444 Echo(ctx context.Context, in *TextMessage, opts ...grpc.CallOption) (*TextMessage, error) 445} 446 447type testServiceClient struct { 448 cc *grpc.ClientConn 449} 450 451func NewTestServiceClient(cc *grpc.ClientConn) TestServiceClient { 452 return &testServiceClient{cc} 453} 454 455func (c *testServiceClient) PingEmpty(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*PingResponse, error) { 456 out := new(PingResponse) 457 err := c.cc.Invoke(ctx, "/improbable.grpcweb.test.TestService/PingEmpty", in, out, opts...) 458 if err != nil { 459 return nil, err 460 } 461 return out, nil 462} 463 464func (c *testServiceClient) Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error) { 465 out := new(PingResponse) 466 err := c.cc.Invoke(ctx, "/improbable.grpcweb.test.TestService/Ping", in, out, opts...) 467 if err != nil { 468 return nil, err 469 } 470 return out, nil 471} 472 473func (c *testServiceClient) PingError(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 474 out := new(empty.Empty) 475 err := c.cc.Invoke(ctx, "/improbable.grpcweb.test.TestService/PingError", in, out, opts...) 476 if err != nil { 477 return nil, err 478 } 479 return out, nil 480} 481 482func (c *testServiceClient) PingList(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (TestService_PingListClient, error) { 483 stream, err := c.cc.NewStream(ctx, &_TestService_serviceDesc.Streams[0], "/improbable.grpcweb.test.TestService/PingList", opts...) 484 if err != nil { 485 return nil, err 486 } 487 x := &testServicePingListClient{stream} 488 if err := x.ClientStream.SendMsg(in); err != nil { 489 return nil, err 490 } 491 if err := x.ClientStream.CloseSend(); err != nil { 492 return nil, err 493 } 494 return x, nil 495} 496 497type TestService_PingListClient interface { 498 Recv() (*PingResponse, error) 499 grpc.ClientStream 500} 501 502type testServicePingListClient struct { 503 grpc.ClientStream 504} 505 506func (x *testServicePingListClient) Recv() (*PingResponse, error) { 507 m := new(PingResponse) 508 if err := x.ClientStream.RecvMsg(m); err != nil { 509 return nil, err 510 } 511 return m, nil 512} 513 514func (c *testServiceClient) PingPongBidi(ctx context.Context, opts ...grpc.CallOption) (TestService_PingPongBidiClient, error) { 515 stream, err := c.cc.NewStream(ctx, &_TestService_serviceDesc.Streams[1], "/improbable.grpcweb.test.TestService/PingPongBidi", opts...) 516 if err != nil { 517 return nil, err 518 } 519 x := &testServicePingPongBidiClient{stream} 520 return x, nil 521} 522 523type TestService_PingPongBidiClient interface { 524 Send(*PingRequest) error 525 Recv() (*PingResponse, error) 526 grpc.ClientStream 527} 528 529type testServicePingPongBidiClient struct { 530 grpc.ClientStream 531} 532 533func (x *testServicePingPongBidiClient) Send(m *PingRequest) error { 534 return x.ClientStream.SendMsg(m) 535} 536 537func (x *testServicePingPongBidiClient) Recv() (*PingResponse, error) { 538 m := new(PingResponse) 539 if err := x.ClientStream.RecvMsg(m); err != nil { 540 return nil, err 541 } 542 return m, nil 543} 544 545func (c *testServiceClient) PingStream(ctx context.Context, opts ...grpc.CallOption) (TestService_PingStreamClient, error) { 546 stream, err := c.cc.NewStream(ctx, &_TestService_serviceDesc.Streams[2], "/improbable.grpcweb.test.TestService/PingStream", opts...) 547 if err != nil { 548 return nil, err 549 } 550 x := &testServicePingStreamClient{stream} 551 return x, nil 552} 553 554type TestService_PingStreamClient interface { 555 Send(*PingRequest) error 556 CloseAndRecv() (*PingResponse, error) 557 grpc.ClientStream 558} 559 560type testServicePingStreamClient struct { 561 grpc.ClientStream 562} 563 564func (x *testServicePingStreamClient) Send(m *PingRequest) error { 565 return x.ClientStream.SendMsg(m) 566} 567 568func (x *testServicePingStreamClient) CloseAndRecv() (*PingResponse, error) { 569 if err := x.ClientStream.CloseSend(); err != nil { 570 return nil, err 571 } 572 m := new(PingResponse) 573 if err := x.ClientStream.RecvMsg(m); err != nil { 574 return nil, err 575 } 576 return m, nil 577} 578 579func (c *testServiceClient) Echo(ctx context.Context, in *TextMessage, opts ...grpc.CallOption) (*TextMessage, error) { 580 out := new(TextMessage) 581 err := c.cc.Invoke(ctx, "/improbable.grpcweb.test.TestService/Echo", in, out, opts...) 582 if err != nil { 583 return nil, err 584 } 585 return out, nil 586} 587 588// TestServiceServer is the server API for TestService service. 589type TestServiceServer interface { 590 PingEmpty(context.Context, *empty.Empty) (*PingResponse, error) 591 Ping(context.Context, *PingRequest) (*PingResponse, error) 592 PingError(context.Context, *PingRequest) (*empty.Empty, error) 593 PingList(*PingRequest, TestService_PingListServer) error 594 PingPongBidi(TestService_PingPongBidiServer) error 595 PingStream(TestService_PingStreamServer) error 596 Echo(context.Context, *TextMessage) (*TextMessage, error) 597} 598 599func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer) { 600 s.RegisterService(&_TestService_serviceDesc, srv) 601} 602 603func _TestService_PingEmpty_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 604 in := new(empty.Empty) 605 if err := dec(in); err != nil { 606 return nil, err 607 } 608 if interceptor == nil { 609 return srv.(TestServiceServer).PingEmpty(ctx, in) 610 } 611 info := &grpc.UnaryServerInfo{ 612 Server: srv, 613 FullMethod: "/improbable.grpcweb.test.TestService/PingEmpty", 614 } 615 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 616 return srv.(TestServiceServer).PingEmpty(ctx, req.(*empty.Empty)) 617 } 618 return interceptor(ctx, in, info, handler) 619} 620 621func _TestService_Ping_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 622 in := new(PingRequest) 623 if err := dec(in); err != nil { 624 return nil, err 625 } 626 if interceptor == nil { 627 return srv.(TestServiceServer).Ping(ctx, in) 628 } 629 info := &grpc.UnaryServerInfo{ 630 Server: srv, 631 FullMethod: "/improbable.grpcweb.test.TestService/Ping", 632 } 633 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 634 return srv.(TestServiceServer).Ping(ctx, req.(*PingRequest)) 635 } 636 return interceptor(ctx, in, info, handler) 637} 638 639func _TestService_PingError_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 640 in := new(PingRequest) 641 if err := dec(in); err != nil { 642 return nil, err 643 } 644 if interceptor == nil { 645 return srv.(TestServiceServer).PingError(ctx, in) 646 } 647 info := &grpc.UnaryServerInfo{ 648 Server: srv, 649 FullMethod: "/improbable.grpcweb.test.TestService/PingError", 650 } 651 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 652 return srv.(TestServiceServer).PingError(ctx, req.(*PingRequest)) 653 } 654 return interceptor(ctx, in, info, handler) 655} 656 657func _TestService_PingList_Handler(srv interface{}, stream grpc.ServerStream) error { 658 m := new(PingRequest) 659 if err := stream.RecvMsg(m); err != nil { 660 return err 661 } 662 return srv.(TestServiceServer).PingList(m, &testServicePingListServer{stream}) 663} 664 665type TestService_PingListServer interface { 666 Send(*PingResponse) error 667 grpc.ServerStream 668} 669 670type testServicePingListServer struct { 671 grpc.ServerStream 672} 673 674func (x *testServicePingListServer) Send(m *PingResponse) error { 675 return x.ServerStream.SendMsg(m) 676} 677 678func _TestService_PingPongBidi_Handler(srv interface{}, stream grpc.ServerStream) error { 679 return srv.(TestServiceServer).PingPongBidi(&testServicePingPongBidiServer{stream}) 680} 681 682type TestService_PingPongBidiServer interface { 683 Send(*PingResponse) error 684 Recv() (*PingRequest, error) 685 grpc.ServerStream 686} 687 688type testServicePingPongBidiServer struct { 689 grpc.ServerStream 690} 691 692func (x *testServicePingPongBidiServer) Send(m *PingResponse) error { 693 return x.ServerStream.SendMsg(m) 694} 695 696func (x *testServicePingPongBidiServer) Recv() (*PingRequest, error) { 697 m := new(PingRequest) 698 if err := x.ServerStream.RecvMsg(m); err != nil { 699 return nil, err 700 } 701 return m, nil 702} 703 704func _TestService_PingStream_Handler(srv interface{}, stream grpc.ServerStream) error { 705 return srv.(TestServiceServer).PingStream(&testServicePingStreamServer{stream}) 706} 707 708type TestService_PingStreamServer interface { 709 SendAndClose(*PingResponse) error 710 Recv() (*PingRequest, error) 711 grpc.ServerStream 712} 713 714type testServicePingStreamServer struct { 715 grpc.ServerStream 716} 717 718func (x *testServicePingStreamServer) SendAndClose(m *PingResponse) error { 719 return x.ServerStream.SendMsg(m) 720} 721 722func (x *testServicePingStreamServer) Recv() (*PingRequest, error) { 723 m := new(PingRequest) 724 if err := x.ServerStream.RecvMsg(m); err != nil { 725 return nil, err 726 } 727 return m, nil 728} 729 730func _TestService_Echo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 731 in := new(TextMessage) 732 if err := dec(in); err != nil { 733 return nil, err 734 } 735 if interceptor == nil { 736 return srv.(TestServiceServer).Echo(ctx, in) 737 } 738 info := &grpc.UnaryServerInfo{ 739 Server: srv, 740 FullMethod: "/improbable.grpcweb.test.TestService/Echo", 741 } 742 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 743 return srv.(TestServiceServer).Echo(ctx, req.(*TextMessage)) 744 } 745 return interceptor(ctx, in, info, handler) 746} 747 748var _TestService_serviceDesc = grpc.ServiceDesc{ 749 ServiceName: "improbable.grpcweb.test.TestService", 750 HandlerType: (*TestServiceServer)(nil), 751 Methods: []grpc.MethodDesc{ 752 { 753 MethodName: "PingEmpty", 754 Handler: _TestService_PingEmpty_Handler, 755 }, 756 { 757 MethodName: "Ping", 758 Handler: _TestService_Ping_Handler, 759 }, 760 { 761 MethodName: "PingError", 762 Handler: _TestService_PingError_Handler, 763 }, 764 { 765 MethodName: "Echo", 766 Handler: _TestService_Echo_Handler, 767 }, 768 }, 769 Streams: []grpc.StreamDesc{ 770 { 771 StreamName: "PingList", 772 Handler: _TestService_PingList_Handler, 773 ServerStreams: true, 774 }, 775 { 776 StreamName: "PingPongBidi", 777 Handler: _TestService_PingPongBidi_Handler, 778 ServerStreams: true, 779 ClientStreams: true, 780 }, 781 { 782 StreamName: "PingStream", 783 Handler: _TestService_PingStream_Handler, 784 ClientStreams: true, 785 }, 786 }, 787 Metadata: "improbable/grpcweb/test/test.proto", 788} 789 790// TestUtilServiceClient is the client API for TestUtilService service. 791// 792// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 793type TestUtilServiceClient interface { 794 ContinueStream(ctx context.Context, in *ContinueStreamRequest, opts ...grpc.CallOption) (*empty.Empty, error) 795 CheckStreamClosed(ctx context.Context, in *CheckStreamClosedRequest, opts ...grpc.CallOption) (*CheckStreamClosedResponse, error) 796} 797 798type testUtilServiceClient struct { 799 cc *grpc.ClientConn 800} 801 802func NewTestUtilServiceClient(cc *grpc.ClientConn) TestUtilServiceClient { 803 return &testUtilServiceClient{cc} 804} 805 806func (c *testUtilServiceClient) ContinueStream(ctx context.Context, in *ContinueStreamRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 807 out := new(empty.Empty) 808 err := c.cc.Invoke(ctx, "/improbable.grpcweb.test.TestUtilService/ContinueStream", in, out, opts...) 809 if err != nil { 810 return nil, err 811 } 812 return out, nil 813} 814 815func (c *testUtilServiceClient) CheckStreamClosed(ctx context.Context, in *CheckStreamClosedRequest, opts ...grpc.CallOption) (*CheckStreamClosedResponse, error) { 816 out := new(CheckStreamClosedResponse) 817 err := c.cc.Invoke(ctx, "/improbable.grpcweb.test.TestUtilService/CheckStreamClosed", in, out, opts...) 818 if err != nil { 819 return nil, err 820 } 821 return out, nil 822} 823 824// TestUtilServiceServer is the server API for TestUtilService service. 825type TestUtilServiceServer interface { 826 ContinueStream(context.Context, *ContinueStreamRequest) (*empty.Empty, error) 827 CheckStreamClosed(context.Context, *CheckStreamClosedRequest) (*CheckStreamClosedResponse, error) 828} 829 830func RegisterTestUtilServiceServer(s *grpc.Server, srv TestUtilServiceServer) { 831 s.RegisterService(&_TestUtilService_serviceDesc, srv) 832} 833 834func _TestUtilService_ContinueStream_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 835 in := new(ContinueStreamRequest) 836 if err := dec(in); err != nil { 837 return nil, err 838 } 839 if interceptor == nil { 840 return srv.(TestUtilServiceServer).ContinueStream(ctx, in) 841 } 842 info := &grpc.UnaryServerInfo{ 843 Server: srv, 844 FullMethod: "/improbable.grpcweb.test.TestUtilService/ContinueStream", 845 } 846 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 847 return srv.(TestUtilServiceServer).ContinueStream(ctx, req.(*ContinueStreamRequest)) 848 } 849 return interceptor(ctx, in, info, handler) 850} 851 852func _TestUtilService_CheckStreamClosed_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 853 in := new(CheckStreamClosedRequest) 854 if err := dec(in); err != nil { 855 return nil, err 856 } 857 if interceptor == nil { 858 return srv.(TestUtilServiceServer).CheckStreamClosed(ctx, in) 859 } 860 info := &grpc.UnaryServerInfo{ 861 Server: srv, 862 FullMethod: "/improbable.grpcweb.test.TestUtilService/CheckStreamClosed", 863 } 864 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 865 return srv.(TestUtilServiceServer).CheckStreamClosed(ctx, req.(*CheckStreamClosedRequest)) 866 } 867 return interceptor(ctx, in, info, handler) 868} 869 870var _TestUtilService_serviceDesc = grpc.ServiceDesc{ 871 ServiceName: "improbable.grpcweb.test.TestUtilService", 872 HandlerType: (*TestUtilServiceServer)(nil), 873 Methods: []grpc.MethodDesc{ 874 { 875 MethodName: "ContinueStream", 876 Handler: _TestUtilService_ContinueStream_Handler, 877 }, 878 { 879 MethodName: "CheckStreamClosed", 880 Handler: _TestUtilService_CheckStreamClosed_Handler, 881 }, 882 }, 883 Streams: []grpc.StreamDesc{}, 884 Metadata: "improbable/grpcweb/test/test.proto", 885} 886 887// FailServiceClient is the client API for FailService service. 888// 889// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 890type FailServiceClient interface { 891 NonExistant(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error) 892} 893 894type failServiceClient struct { 895 cc *grpc.ClientConn 896} 897 898func NewFailServiceClient(cc *grpc.ClientConn) FailServiceClient { 899 return &failServiceClient{cc} 900} 901 902func (c *failServiceClient) NonExistant(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error) { 903 out := new(PingResponse) 904 err := c.cc.Invoke(ctx, "/improbable.grpcweb.test.FailService/NonExistant", in, out, opts...) 905 if err != nil { 906 return nil, err 907 } 908 return out, nil 909} 910 911// FailServiceServer is the server API for FailService service. 912type FailServiceServer interface { 913 NonExistant(context.Context, *PingRequest) (*PingResponse, error) 914} 915 916func RegisterFailServiceServer(s *grpc.Server, srv FailServiceServer) { 917 s.RegisterService(&_FailService_serviceDesc, srv) 918} 919 920func _FailService_NonExistant_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 921 in := new(PingRequest) 922 if err := dec(in); err != nil { 923 return nil, err 924 } 925 if interceptor == nil { 926 return srv.(FailServiceServer).NonExistant(ctx, in) 927 } 928 info := &grpc.UnaryServerInfo{ 929 Server: srv, 930 FullMethod: "/improbable.grpcweb.test.FailService/NonExistant", 931 } 932 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 933 return srv.(FailServiceServer).NonExistant(ctx, req.(*PingRequest)) 934 } 935 return interceptor(ctx, in, info, handler) 936} 937 938var _FailService_serviceDesc = grpc.ServiceDesc{ 939 ServiceName: "improbable.grpcweb.test.FailService", 940 HandlerType: (*FailServiceServer)(nil), 941 Methods: []grpc.MethodDesc{ 942 { 943 MethodName: "NonExistant", 944 Handler: _FailService_NonExistant_Handler, 945 }, 946 }, 947 Streams: []grpc.StreamDesc{}, 948 Metadata: "improbable/grpcweb/test/test.proto", 949} 950