1// Code generated by protoc-gen-gogo. DO NOT EDIT. 2// source: mixer/adapter/model/v1beta1/infrastructure_backend.proto 3 4// This package defines the service and types used by adapter code to serve requests from Mixer. 5// This package also defines the types that are used to create Mixer templates. 6 7package v1beta1 8 9import ( 10 context "context" 11 fmt "fmt" 12 proto "github.com/gogo/protobuf/proto" 13 github_com_gogo_protobuf_sortkeys "github.com/gogo/protobuf/sortkeys" 14 types "github.com/gogo/protobuf/types" 15 grpc "google.golang.org/grpc" 16 codes "google.golang.org/grpc/codes" 17 status "google.golang.org/grpc/status" 18 io "io" 19 rpc "istio.io/gogo-genproto/googleapis/google/rpc" 20 math "math" 21 math_bits "math/bits" 22 reflect "reflect" 23 strings "strings" 24) 25 26// Reference imports to suppress errors if they are not otherwise used. 27var _ = proto.Marshal 28var _ = fmt.Errorf 29var _ = math.Inf 30 31// This is a compile-time assertion to ensure that this generated file 32// is compatible with the proto package it is being compiled against. 33// A compilation error at this line likely means your copy of the 34// proto package needs to be updated. 35const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package 36 37// Request message for `CreateSession` method. 38type CreateSessionRequest struct { 39 // Adapter specific configuration. 40 AdapterConfig *types.Any `protobuf:"bytes,1,opt,name=adapter_config,json=adapterConfig,proto3" json:"adapter_config,omitempty"` 41 // Map of instance names to their template-specific inferred type. 42 InferredTypes map[string]*types.Any `protobuf:"bytes,2,rep,name=inferred_types,json=inferredTypes,proto3" json:"inferred_types,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 43} 44 45func (m *CreateSessionRequest) Reset() { *m = CreateSessionRequest{} } 46func (*CreateSessionRequest) ProtoMessage() {} 47func (*CreateSessionRequest) Descriptor() ([]byte, []int) { 48 return fileDescriptor_b62a0b3a6ebb4b55, []int{0} 49} 50func (m *CreateSessionRequest) XXX_Unmarshal(b []byte) error { 51 return m.Unmarshal(b) 52} 53func (m *CreateSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 54 if deterministic { 55 return xxx_messageInfo_CreateSessionRequest.Marshal(b, m, deterministic) 56 } else { 57 b = b[:cap(b)] 58 n, err := m.MarshalToSizedBuffer(b) 59 if err != nil { 60 return nil, err 61 } 62 return b[:n], nil 63 } 64} 65func (m *CreateSessionRequest) XXX_Merge(src proto.Message) { 66 xxx_messageInfo_CreateSessionRequest.Merge(m, src) 67} 68func (m *CreateSessionRequest) XXX_Size() int { 69 return m.Size() 70} 71func (m *CreateSessionRequest) XXX_DiscardUnknown() { 72 xxx_messageInfo_CreateSessionRequest.DiscardUnknown(m) 73} 74 75var xxx_messageInfo_CreateSessionRequest proto.InternalMessageInfo 76 77func (m *CreateSessionRequest) GetAdapterConfig() *types.Any { 78 if m != nil { 79 return m.AdapterConfig 80 } 81 return nil 82} 83 84func (m *CreateSessionRequest) GetInferredTypes() map[string]*types.Any { 85 if m != nil { 86 return m.InferredTypes 87 } 88 return nil 89} 90 91// Response message for `CreateSession` method. 92type CreateSessionResponse struct { 93 // Id of the created session. 94 SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` 95 // The success/failure status of create session call. 96 Status *rpc.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` 97} 98 99func (m *CreateSessionResponse) Reset() { *m = CreateSessionResponse{} } 100func (*CreateSessionResponse) ProtoMessage() {} 101func (*CreateSessionResponse) Descriptor() ([]byte, []int) { 102 return fileDescriptor_b62a0b3a6ebb4b55, []int{1} 103} 104func (m *CreateSessionResponse) XXX_Unmarshal(b []byte) error { 105 return m.Unmarshal(b) 106} 107func (m *CreateSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 108 if deterministic { 109 return xxx_messageInfo_CreateSessionResponse.Marshal(b, m, deterministic) 110 } else { 111 b = b[:cap(b)] 112 n, err := m.MarshalToSizedBuffer(b) 113 if err != nil { 114 return nil, err 115 } 116 return b[:n], nil 117 } 118} 119func (m *CreateSessionResponse) XXX_Merge(src proto.Message) { 120 xxx_messageInfo_CreateSessionResponse.Merge(m, src) 121} 122func (m *CreateSessionResponse) XXX_Size() int { 123 return m.Size() 124} 125func (m *CreateSessionResponse) XXX_DiscardUnknown() { 126 xxx_messageInfo_CreateSessionResponse.DiscardUnknown(m) 127} 128 129var xxx_messageInfo_CreateSessionResponse proto.InternalMessageInfo 130 131func (m *CreateSessionResponse) GetSessionId() string { 132 if m != nil { 133 return m.SessionId 134 } 135 return "" 136} 137 138func (m *CreateSessionResponse) GetStatus() *rpc.Status { 139 if m != nil { 140 return m.Status 141 } 142 return nil 143} 144 145// Request message for `Validate` method. 146type ValidateRequest struct { 147 // Adapter specific configuration. 148 AdapterConfig *types.Any `protobuf:"bytes,1,opt,name=adapter_config,json=adapterConfig,proto3" json:"adapter_config,omitempty"` 149 // Map of instance names to their template-specific inferred type. 150 InferredTypes map[string]*types.Any `protobuf:"bytes,2,rep,name=inferred_types,json=inferredTypes,proto3" json:"inferred_types,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 151} 152 153func (m *ValidateRequest) Reset() { *m = ValidateRequest{} } 154func (*ValidateRequest) ProtoMessage() {} 155func (*ValidateRequest) Descriptor() ([]byte, []int) { 156 return fileDescriptor_b62a0b3a6ebb4b55, []int{2} 157} 158func (m *ValidateRequest) XXX_Unmarshal(b []byte) error { 159 return m.Unmarshal(b) 160} 161func (m *ValidateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 162 if deterministic { 163 return xxx_messageInfo_ValidateRequest.Marshal(b, m, deterministic) 164 } else { 165 b = b[:cap(b)] 166 n, err := m.MarshalToSizedBuffer(b) 167 if err != nil { 168 return nil, err 169 } 170 return b[:n], nil 171 } 172} 173func (m *ValidateRequest) XXX_Merge(src proto.Message) { 174 xxx_messageInfo_ValidateRequest.Merge(m, src) 175} 176func (m *ValidateRequest) XXX_Size() int { 177 return m.Size() 178} 179func (m *ValidateRequest) XXX_DiscardUnknown() { 180 xxx_messageInfo_ValidateRequest.DiscardUnknown(m) 181} 182 183var xxx_messageInfo_ValidateRequest proto.InternalMessageInfo 184 185func (m *ValidateRequest) GetAdapterConfig() *types.Any { 186 if m != nil { 187 return m.AdapterConfig 188 } 189 return nil 190} 191 192func (m *ValidateRequest) GetInferredTypes() map[string]*types.Any { 193 if m != nil { 194 return m.InferredTypes 195 } 196 return nil 197} 198 199// Response message for `Validate` method. 200type ValidateResponse struct { 201 // The success/failure status of validation call. 202 Status *rpc.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` 203} 204 205func (m *ValidateResponse) Reset() { *m = ValidateResponse{} } 206func (*ValidateResponse) ProtoMessage() {} 207func (*ValidateResponse) Descriptor() ([]byte, []int) { 208 return fileDescriptor_b62a0b3a6ebb4b55, []int{3} 209} 210func (m *ValidateResponse) XXX_Unmarshal(b []byte) error { 211 return m.Unmarshal(b) 212} 213func (m *ValidateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 214 if deterministic { 215 return xxx_messageInfo_ValidateResponse.Marshal(b, m, deterministic) 216 } else { 217 b = b[:cap(b)] 218 n, err := m.MarshalToSizedBuffer(b) 219 if err != nil { 220 return nil, err 221 } 222 return b[:n], nil 223 } 224} 225func (m *ValidateResponse) XXX_Merge(src proto.Message) { 226 xxx_messageInfo_ValidateResponse.Merge(m, src) 227} 228func (m *ValidateResponse) XXX_Size() int { 229 return m.Size() 230} 231func (m *ValidateResponse) XXX_DiscardUnknown() { 232 xxx_messageInfo_ValidateResponse.DiscardUnknown(m) 233} 234 235var xxx_messageInfo_ValidateResponse proto.InternalMessageInfo 236 237func (m *ValidateResponse) GetStatus() *rpc.Status { 238 if m != nil { 239 return m.Status 240 } 241 return nil 242} 243 244// Request message for `CloseSession` method. 245type CloseSessionRequest struct { 246 // Id of the session to be closed. 247 SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` 248} 249 250func (m *CloseSessionRequest) Reset() { *m = CloseSessionRequest{} } 251func (*CloseSessionRequest) ProtoMessage() {} 252func (*CloseSessionRequest) Descriptor() ([]byte, []int) { 253 return fileDescriptor_b62a0b3a6ebb4b55, []int{4} 254} 255func (m *CloseSessionRequest) XXX_Unmarshal(b []byte) error { 256 return m.Unmarshal(b) 257} 258func (m *CloseSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 259 if deterministic { 260 return xxx_messageInfo_CloseSessionRequest.Marshal(b, m, deterministic) 261 } else { 262 b = b[:cap(b)] 263 n, err := m.MarshalToSizedBuffer(b) 264 if err != nil { 265 return nil, err 266 } 267 return b[:n], nil 268 } 269} 270func (m *CloseSessionRequest) XXX_Merge(src proto.Message) { 271 xxx_messageInfo_CloseSessionRequest.Merge(m, src) 272} 273func (m *CloseSessionRequest) XXX_Size() int { 274 return m.Size() 275} 276func (m *CloseSessionRequest) XXX_DiscardUnknown() { 277 xxx_messageInfo_CloseSessionRequest.DiscardUnknown(m) 278} 279 280var xxx_messageInfo_CloseSessionRequest proto.InternalMessageInfo 281 282func (m *CloseSessionRequest) GetSessionId() string { 283 if m != nil { 284 return m.SessionId 285 } 286 return "" 287} 288 289// Response message for `CloseSession` method. 290type CloseSessionResponse struct { 291 // The success/failure status of close session call. 292 Status *rpc.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` 293} 294 295func (m *CloseSessionResponse) Reset() { *m = CloseSessionResponse{} } 296func (*CloseSessionResponse) ProtoMessage() {} 297func (*CloseSessionResponse) Descriptor() ([]byte, []int) { 298 return fileDescriptor_b62a0b3a6ebb4b55, []int{5} 299} 300func (m *CloseSessionResponse) XXX_Unmarshal(b []byte) error { 301 return m.Unmarshal(b) 302} 303func (m *CloseSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 304 if deterministic { 305 return xxx_messageInfo_CloseSessionResponse.Marshal(b, m, deterministic) 306 } else { 307 b = b[:cap(b)] 308 n, err := m.MarshalToSizedBuffer(b) 309 if err != nil { 310 return nil, err 311 } 312 return b[:n], nil 313 } 314} 315func (m *CloseSessionResponse) XXX_Merge(src proto.Message) { 316 xxx_messageInfo_CloseSessionResponse.Merge(m, src) 317} 318func (m *CloseSessionResponse) XXX_Size() int { 319 return m.Size() 320} 321func (m *CloseSessionResponse) XXX_DiscardUnknown() { 322 xxx_messageInfo_CloseSessionResponse.DiscardUnknown(m) 323} 324 325var xxx_messageInfo_CloseSessionResponse proto.InternalMessageInfo 326 327func (m *CloseSessionResponse) GetStatus() *rpc.Status { 328 if m != nil { 329 return m.Status 330 } 331 return nil 332} 333 334func init() { 335 proto.RegisterType((*CreateSessionRequest)(nil), "istio.mixer.adapter.model.v1beta1.CreateSessionRequest") 336 proto.RegisterMapType((map[string]*types.Any)(nil), "istio.mixer.adapter.model.v1beta1.CreateSessionRequest.InferredTypesEntry") 337 proto.RegisterType((*CreateSessionResponse)(nil), "istio.mixer.adapter.model.v1beta1.CreateSessionResponse") 338 proto.RegisterType((*ValidateRequest)(nil), "istio.mixer.adapter.model.v1beta1.ValidateRequest") 339 proto.RegisterMapType((map[string]*types.Any)(nil), "istio.mixer.adapter.model.v1beta1.ValidateRequest.InferredTypesEntry") 340 proto.RegisterType((*ValidateResponse)(nil), "istio.mixer.adapter.model.v1beta1.ValidateResponse") 341 proto.RegisterType((*CloseSessionRequest)(nil), "istio.mixer.adapter.model.v1beta1.CloseSessionRequest") 342 proto.RegisterType((*CloseSessionResponse)(nil), "istio.mixer.adapter.model.v1beta1.CloseSessionResponse") 343} 344 345func init() { 346 proto.RegisterFile("mixer/adapter/model/v1beta1/infrastructure_backend.proto", fileDescriptor_b62a0b3a6ebb4b55) 347} 348 349var fileDescriptor_b62a0b3a6ebb4b55 = []byte{ 350 // 530 bytes of a gzipped FileDescriptorProto 351 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xc4, 0x54, 0x41, 0x6f, 0xd3, 0x4c, 352 0x10, 0xf5, 0x26, 0xfa, 0xaa, 0xaf, 0x5b, 0x52, 0xaa, 0x25, 0x15, 0xc1, 0x12, 0xab, 0x92, 0x53, 353 0xd4, 0xc3, 0x5a, 0x4d, 0x11, 0x8d, 0x40, 0x42, 0x22, 0x51, 0x0f, 0xe1, 0xe8, 0xa2, 0x1e, 0xb8, 354 0x44, 0x6b, 0x7b, 0x13, 0xad, 0xea, 0x7a, 0xdd, 0xdd, 0x75, 0x85, 0x4f, 0x54, 0xfc, 0x02, 0x84, 355 0x38, 0x73, 0xe6, 0xa7, 0x70, 0xcc, 0xb1, 0x47, 0xe2, 0x5c, 0x38, 0xf6, 0x27, 0xa0, 0xda, 0x1b, 356 0xb5, 0x49, 0x21, 0xad, 0x11, 0x12, 0x37, 0x6b, 0x67, 0xde, 0xbc, 0x37, 0x6f, 0x66, 0x0c, 0x3b, 357 0xc7, 0xfc, 0x1d, 0x93, 0x0e, 0x0d, 0x68, 0xac, 0x99, 0x74, 0x8e, 0x45, 0xc0, 0x42, 0xe7, 0x74, 358 0xc7, 0x63, 0x9a, 0xee, 0x38, 0x3c, 0x1a, 0x4a, 0xaa, 0xb4, 0x4c, 0x7c, 0x9d, 0x48, 0x36, 0xf0, 359 0xa8, 0x7f, 0xc4, 0xa2, 0x80, 0xc4, 0x52, 0x68, 0x81, 0x9e, 0x70, 0xa5, 0xb9, 0x20, 0x39, 0x9e, 360 0x18, 0x3c, 0xc9, 0xf1, 0xc4, 0xe0, 0xed, 0x47, 0x23, 0x21, 0x46, 0x21, 0x73, 0x72, 0x80, 0x97, 361 0x0c, 0x1d, 0x1a, 0xa5, 0x05, 0xda, 0x7e, 0x68, 0x42, 0x32, 0xf6, 0x1d, 0xa5, 0xa9, 0x4e, 0x54, 362 0x11, 0x68, 0x7e, 0xa9, 0xc0, 0x7a, 0x4f, 0x32, 0xaa, 0xd9, 0x01, 0x53, 0x8a, 0x8b, 0xc8, 0x65, 363 0x27, 0x09, 0x53, 0x1a, 0xbd, 0x80, 0xeb, 0x86, 0x65, 0xe0, 0x8b, 0x68, 0xc8, 0x47, 0x0d, 0xb0, 364 0x05, 0x5a, 0x6b, 0xed, 0x3a, 0x29, 0x4a, 0x91, 0x19, 0x0b, 0x79, 0x15, 0xa5, 0x6e, 0xcd, 0xe4, 365 0xf6, 0xf2, 0x54, 0x74, 0x02, 0xd7, 0x79, 0x34, 0x64, 0x52, 0xb2, 0x60, 0xa0, 0xd3, 0x98, 0xa9, 366 0x46, 0x65, 0xab, 0xda, 0x5a, 0x6b, 0xbf, 0x26, 0xb7, 0x76, 0x41, 0x7e, 0xa5, 0x86, 0xf4, 0x4d, 367 0xb5, 0x37, 0x97, 0xc5, 0xf6, 0x23, 0x2d, 0x53, 0xb7, 0xc6, 0xaf, 0xbf, 0xd9, 0x87, 0x10, 0xdd, 368 0x4c, 0x42, 0x1b, 0xb0, 0x7a, 0xc4, 0xd2, 0x5c, 0xfa, 0xaa, 0x7b, 0xf9, 0x89, 0xb6, 0xe1, 0x7f, 369 0xa7, 0x34, 0x4c, 0x58, 0xa3, 0xb2, 0xa4, 0x9d, 0x22, 0xe5, 0x79, 0xa5, 0x03, 0x9a, 0x1e, 0xdc, 370 0x5c, 0x50, 0xa4, 0x62, 0x11, 0x29, 0x86, 0x1e, 0x43, 0xa8, 0x8a, 0xa7, 0x01, 0x0f, 0x0c, 0xc3, 371 0xaa, 0x79, 0xe9, 0x07, 0x68, 0x1b, 0xae, 0x14, 0x46, 0x1b, 0x22, 0x34, 0x23, 0x92, 0xb1, 0x4f, 372 0x0e, 0xf2, 0x88, 0x6b, 0x32, 0x9a, 0x9f, 0x2b, 0xf0, 0xfe, 0x21, 0x0d, 0x79, 0x40, 0x35, 0xfb, 373 0x2b, 0xfe, 0x87, 0xbf, 0xf1, 0x7f, 0xff, 0x0e, 0xfe, 0x2f, 0x08, 0xf9, 0x87, 0xd6, 0xbf, 0x84, 374 0x1b, 0x57, 0x62, 0x8c, 0xeb, 0x57, 0xb6, 0x82, 0x5b, 0x6d, 0x7d, 0x0a, 0x1f, 0xf4, 0x42, 0xa1, 375 0x16, 0x37, 0x7b, 0xf9, 0xe0, 0x9a, 0x5d, 0x58, 0x9f, 0x47, 0x95, 0x67, 0x6e, 0x7f, 0xaa, 0xc2, 376 0xcd, 0xfe, 0xdc, 0x35, 0x77, 0x8b, 0x63, 0x46, 0x0a, 0xfe, 0x3f, 0xeb, 0x09, 0xb5, 0xcb, 0x4f, 377 0xc3, 0xde, 0x2d, 0x85, 0x31, 0xd2, 0x3f, 0x00, 0x58, 0x9b, 0x5b, 0x62, 0xb4, 0xf7, 0x87, 0x87, 378 0x68, 0x77, 0xca, 0x03, 0x8d, 0x88, 0xf7, 0xf0, 0xde, 0x75, 0x5f, 0xd1, 0xb3, 0xbb, 0x54, 0xba, 379 0x39, 0x3e, 0x7b, 0xaf, 0x34, 0xae, 0x10, 0xd0, 0xa5, 0xe3, 0x09, 0xb6, 0xce, 0x27, 0xd8, 0xba, 380 0x98, 0x60, 0x70, 0x96, 0x61, 0xf0, 0x35, 0xc3, 0xe0, 0x5b, 0x86, 0xc1, 0x38, 0xc3, 0xe0, 0x7b, 381 0x86, 0xc1, 0x8f, 0x0c, 0x5b, 0x17, 0x19, 0x06, 0x1f, 0xa7, 0xd8, 0x1a, 0x4f, 0xb1, 0x75, 0x3e, 382 0xc5, 0xd6, 0xdb, 0x56, 0xc1, 0xc6, 0x85, 0x43, 0x63, 0xee, 0x2c, 0xf9, 0x7d, 0x9f, 0x01, 0xe0, 383 0xad, 0xe4, 0xab, 0xbc, 0xfb, 0x33, 0x00, 0x00, 0xff, 0xff, 0x35, 0xb4, 0xbe, 0x68, 0xe7, 0x05, 384 0x00, 0x00, 385} 386 387func (this *CreateSessionRequest) Equal(that interface{}) bool { 388 if that == nil { 389 return this == nil 390 } 391 392 that1, ok := that.(*CreateSessionRequest) 393 if !ok { 394 that2, ok := that.(CreateSessionRequest) 395 if ok { 396 that1 = &that2 397 } else { 398 return false 399 } 400 } 401 if that1 == nil { 402 return this == nil 403 } else if this == nil { 404 return false 405 } 406 if !this.AdapterConfig.Equal(that1.AdapterConfig) { 407 return false 408 } 409 if len(this.InferredTypes) != len(that1.InferredTypes) { 410 return false 411 } 412 for i := range this.InferredTypes { 413 if !this.InferredTypes[i].Equal(that1.InferredTypes[i]) { 414 return false 415 } 416 } 417 return true 418} 419func (this *CreateSessionResponse) Equal(that interface{}) bool { 420 if that == nil { 421 return this == nil 422 } 423 424 that1, ok := that.(*CreateSessionResponse) 425 if !ok { 426 that2, ok := that.(CreateSessionResponse) 427 if ok { 428 that1 = &that2 429 } else { 430 return false 431 } 432 } 433 if that1 == nil { 434 return this == nil 435 } else if this == nil { 436 return false 437 } 438 if this.SessionId != that1.SessionId { 439 return false 440 } 441 if !this.Status.Equal(that1.Status) { 442 return false 443 } 444 return true 445} 446func (this *ValidateRequest) Equal(that interface{}) bool { 447 if that == nil { 448 return this == nil 449 } 450 451 that1, ok := that.(*ValidateRequest) 452 if !ok { 453 that2, ok := that.(ValidateRequest) 454 if ok { 455 that1 = &that2 456 } else { 457 return false 458 } 459 } 460 if that1 == nil { 461 return this == nil 462 } else if this == nil { 463 return false 464 } 465 if !this.AdapterConfig.Equal(that1.AdapterConfig) { 466 return false 467 } 468 if len(this.InferredTypes) != len(that1.InferredTypes) { 469 return false 470 } 471 for i := range this.InferredTypes { 472 if !this.InferredTypes[i].Equal(that1.InferredTypes[i]) { 473 return false 474 } 475 } 476 return true 477} 478func (this *ValidateResponse) Equal(that interface{}) bool { 479 if that == nil { 480 return this == nil 481 } 482 483 that1, ok := that.(*ValidateResponse) 484 if !ok { 485 that2, ok := that.(ValidateResponse) 486 if ok { 487 that1 = &that2 488 } else { 489 return false 490 } 491 } 492 if that1 == nil { 493 return this == nil 494 } else if this == nil { 495 return false 496 } 497 if !this.Status.Equal(that1.Status) { 498 return false 499 } 500 return true 501} 502func (this *CloseSessionRequest) Equal(that interface{}) bool { 503 if that == nil { 504 return this == nil 505 } 506 507 that1, ok := that.(*CloseSessionRequest) 508 if !ok { 509 that2, ok := that.(CloseSessionRequest) 510 if ok { 511 that1 = &that2 512 } else { 513 return false 514 } 515 } 516 if that1 == nil { 517 return this == nil 518 } else if this == nil { 519 return false 520 } 521 if this.SessionId != that1.SessionId { 522 return false 523 } 524 return true 525} 526func (this *CloseSessionResponse) Equal(that interface{}) bool { 527 if that == nil { 528 return this == nil 529 } 530 531 that1, ok := that.(*CloseSessionResponse) 532 if !ok { 533 that2, ok := that.(CloseSessionResponse) 534 if ok { 535 that1 = &that2 536 } else { 537 return false 538 } 539 } 540 if that1 == nil { 541 return this == nil 542 } else if this == nil { 543 return false 544 } 545 if !this.Status.Equal(that1.Status) { 546 return false 547 } 548 return true 549} 550func (this *CreateSessionRequest) GoString() string { 551 if this == nil { 552 return "nil" 553 } 554 s := make([]string, 0, 6) 555 s = append(s, "&v1beta1.CreateSessionRequest{") 556 if this.AdapterConfig != nil { 557 s = append(s, "AdapterConfig: "+fmt.Sprintf("%#v", this.AdapterConfig)+",\n") 558 } 559 keysForInferredTypes := make([]string, 0, len(this.InferredTypes)) 560 for k, _ := range this.InferredTypes { 561 keysForInferredTypes = append(keysForInferredTypes, k) 562 } 563 github_com_gogo_protobuf_sortkeys.Strings(keysForInferredTypes) 564 mapStringForInferredTypes := "map[string]*types.Any{" 565 for _, k := range keysForInferredTypes { 566 mapStringForInferredTypes += fmt.Sprintf("%#v: %#v,", k, this.InferredTypes[k]) 567 } 568 mapStringForInferredTypes += "}" 569 if this.InferredTypes != nil { 570 s = append(s, "InferredTypes: "+mapStringForInferredTypes+",\n") 571 } 572 s = append(s, "}") 573 return strings.Join(s, "") 574} 575func (this *CreateSessionResponse) GoString() string { 576 if this == nil { 577 return "nil" 578 } 579 s := make([]string, 0, 6) 580 s = append(s, "&v1beta1.CreateSessionResponse{") 581 s = append(s, "SessionId: "+fmt.Sprintf("%#v", this.SessionId)+",\n") 582 if this.Status != nil { 583 s = append(s, "Status: "+fmt.Sprintf("%#v", this.Status)+",\n") 584 } 585 s = append(s, "}") 586 return strings.Join(s, "") 587} 588func (this *ValidateRequest) GoString() string { 589 if this == nil { 590 return "nil" 591 } 592 s := make([]string, 0, 6) 593 s = append(s, "&v1beta1.ValidateRequest{") 594 if this.AdapterConfig != nil { 595 s = append(s, "AdapterConfig: "+fmt.Sprintf("%#v", this.AdapterConfig)+",\n") 596 } 597 keysForInferredTypes := make([]string, 0, len(this.InferredTypes)) 598 for k, _ := range this.InferredTypes { 599 keysForInferredTypes = append(keysForInferredTypes, k) 600 } 601 github_com_gogo_protobuf_sortkeys.Strings(keysForInferredTypes) 602 mapStringForInferredTypes := "map[string]*types.Any{" 603 for _, k := range keysForInferredTypes { 604 mapStringForInferredTypes += fmt.Sprintf("%#v: %#v,", k, this.InferredTypes[k]) 605 } 606 mapStringForInferredTypes += "}" 607 if this.InferredTypes != nil { 608 s = append(s, "InferredTypes: "+mapStringForInferredTypes+",\n") 609 } 610 s = append(s, "}") 611 return strings.Join(s, "") 612} 613func (this *ValidateResponse) GoString() string { 614 if this == nil { 615 return "nil" 616 } 617 s := make([]string, 0, 5) 618 s = append(s, "&v1beta1.ValidateResponse{") 619 if this.Status != nil { 620 s = append(s, "Status: "+fmt.Sprintf("%#v", this.Status)+",\n") 621 } 622 s = append(s, "}") 623 return strings.Join(s, "") 624} 625func (this *CloseSessionRequest) GoString() string { 626 if this == nil { 627 return "nil" 628 } 629 s := make([]string, 0, 5) 630 s = append(s, "&v1beta1.CloseSessionRequest{") 631 s = append(s, "SessionId: "+fmt.Sprintf("%#v", this.SessionId)+",\n") 632 s = append(s, "}") 633 return strings.Join(s, "") 634} 635func (this *CloseSessionResponse) GoString() string { 636 if this == nil { 637 return "nil" 638 } 639 s := make([]string, 0, 5) 640 s = append(s, "&v1beta1.CloseSessionResponse{") 641 if this.Status != nil { 642 s = append(s, "Status: "+fmt.Sprintf("%#v", this.Status)+",\n") 643 } 644 s = append(s, "}") 645 return strings.Join(s, "") 646} 647func valueToGoStringInfrastructureBackend(v interface{}, typ string) string { 648 rv := reflect.ValueOf(v) 649 if rv.IsNil() { 650 return "nil" 651 } 652 pv := reflect.Indirect(rv).Interface() 653 return fmt.Sprintf("func(v %v) *%v { return &v } ( %#v )", typ, typ, pv) 654} 655 656// Reference imports to suppress errors if they are not otherwise used. 657var _ context.Context 658var _ grpc.ClientConn 659 660// This is a compile-time assertion to ensure that this generated file 661// is compatible with the grpc package it is being compiled against. 662const _ = grpc.SupportPackageIsVersion4 663 664// InfrastructureBackendClient is the client API for InfrastructureBackend service. 665// 666// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 667type InfrastructureBackendClient interface { 668 // Validates the handler configuration along with the template-specific instances that would be routed to that 669 // handler. The `CreateSession` for a specific handler configuration is invoked only if its associated `Validate` 670 // call has returned success. 671 Validate(ctx context.Context, in *ValidateRequest, opts ...grpc.CallOption) (*ValidateResponse, error) 672 // Creates a session for a given handler configuration and the template-specific instances that would be routed to 673 // that handler. For every handler configuration, Mixer creates a separate session by invoking `CreateSession` 674 // on the backend. 675 // 676 // `CreateSessionRequest` contains the adapter specific handler configuration and the inferred type information about 677 // the instances the handler would receive during request processing. 678 // 679 // `CreateSession` must return a `session_id` which Mixer uses to invoke template-specific Handle functions during 680 // request processing. The `session_id` provides the Handle functions a way to retrieve the necessary configuration 681 // associated with the session. Upon Mixer configuration change, Mixer will re-invoke `CreateSession` for all 682 // handler configurations whose existing sessions are invalidated or didn't existed. 683 // 684 // Backend is allowed to return the same session id if given the same configuration block. 685 // This would happen when multiple instances of Mixer in a deployment all create sessions with the same configuration. 686 // Note that given individual instances of Mixer can call `CloseSession`, reusing `session_id` by the backend 687 // assumes that the backend is doing reference counting. 688 // 689 // If the backend couldn't create a session for a specific handler configuration and 690 // returns non S_OK status, Mixer will not make request-time Handle calls associated with that handler configuration. 691 CreateSession(ctx context.Context, in *CreateSessionRequest, opts ...grpc.CallOption) (*CreateSessionResponse, error) 692 // Closes the session associated with the `session_id`. Mixer closes a session when its associated handler 693 // configuration or the instance configuration changes. Backend is supposed to cleanup all the resources associated 694 // with the session_id referenced by CloseSessionRequest. 695 CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error) 696} 697 698type infrastructureBackendClient struct { 699 cc *grpc.ClientConn 700} 701 702func NewInfrastructureBackendClient(cc *grpc.ClientConn) InfrastructureBackendClient { 703 return &infrastructureBackendClient{cc} 704} 705 706func (c *infrastructureBackendClient) Validate(ctx context.Context, in *ValidateRequest, opts ...grpc.CallOption) (*ValidateResponse, error) { 707 out := new(ValidateResponse) 708 err := c.cc.Invoke(ctx, "/istio.mixer.adapter.model.v1beta1.InfrastructureBackend/Validate", in, out, opts...) 709 if err != nil { 710 return nil, err 711 } 712 return out, nil 713} 714 715func (c *infrastructureBackendClient) CreateSession(ctx context.Context, in *CreateSessionRequest, opts ...grpc.CallOption) (*CreateSessionResponse, error) { 716 out := new(CreateSessionResponse) 717 err := c.cc.Invoke(ctx, "/istio.mixer.adapter.model.v1beta1.InfrastructureBackend/CreateSession", in, out, opts...) 718 if err != nil { 719 return nil, err 720 } 721 return out, nil 722} 723 724func (c *infrastructureBackendClient) CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error) { 725 out := new(CloseSessionResponse) 726 err := c.cc.Invoke(ctx, "/istio.mixer.adapter.model.v1beta1.InfrastructureBackend/CloseSession", in, out, opts...) 727 if err != nil { 728 return nil, err 729 } 730 return out, nil 731} 732 733// InfrastructureBackendServer is the server API for InfrastructureBackend service. 734type InfrastructureBackendServer interface { 735 // Validates the handler configuration along with the template-specific instances that would be routed to that 736 // handler. The `CreateSession` for a specific handler configuration is invoked only if its associated `Validate` 737 // call has returned success. 738 Validate(context.Context, *ValidateRequest) (*ValidateResponse, error) 739 // Creates a session for a given handler configuration and the template-specific instances that would be routed to 740 // that handler. For every handler configuration, Mixer creates a separate session by invoking `CreateSession` 741 // on the backend. 742 // 743 // `CreateSessionRequest` contains the adapter specific handler configuration and the inferred type information about 744 // the instances the handler would receive during request processing. 745 // 746 // `CreateSession` must return a `session_id` which Mixer uses to invoke template-specific Handle functions during 747 // request processing. The `session_id` provides the Handle functions a way to retrieve the necessary configuration 748 // associated with the session. Upon Mixer configuration change, Mixer will re-invoke `CreateSession` for all 749 // handler configurations whose existing sessions are invalidated or didn't existed. 750 // 751 // Backend is allowed to return the same session id if given the same configuration block. 752 // This would happen when multiple instances of Mixer in a deployment all create sessions with the same configuration. 753 // Note that given individual instances of Mixer can call `CloseSession`, reusing `session_id` by the backend 754 // assumes that the backend is doing reference counting. 755 // 756 // If the backend couldn't create a session for a specific handler configuration and 757 // returns non S_OK status, Mixer will not make request-time Handle calls associated with that handler configuration. 758 CreateSession(context.Context, *CreateSessionRequest) (*CreateSessionResponse, error) 759 // Closes the session associated with the `session_id`. Mixer closes a session when its associated handler 760 // configuration or the instance configuration changes. Backend is supposed to cleanup all the resources associated 761 // with the session_id referenced by CloseSessionRequest. 762 CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error) 763} 764 765// UnimplementedInfrastructureBackendServer can be embedded to have forward compatible implementations. 766type UnimplementedInfrastructureBackendServer struct { 767} 768 769func (*UnimplementedInfrastructureBackendServer) Validate(ctx context.Context, req *ValidateRequest) (*ValidateResponse, error) { 770 return nil, status.Errorf(codes.Unimplemented, "method Validate not implemented") 771} 772func (*UnimplementedInfrastructureBackendServer) CreateSession(ctx context.Context, req *CreateSessionRequest) (*CreateSessionResponse, error) { 773 return nil, status.Errorf(codes.Unimplemented, "method CreateSession not implemented") 774} 775func (*UnimplementedInfrastructureBackendServer) CloseSession(ctx context.Context, req *CloseSessionRequest) (*CloseSessionResponse, error) { 776 return nil, status.Errorf(codes.Unimplemented, "method CloseSession not implemented") 777} 778 779func RegisterInfrastructureBackendServer(s *grpc.Server, srv InfrastructureBackendServer) { 780 s.RegisterService(&_InfrastructureBackend_serviceDesc, srv) 781} 782 783func _InfrastructureBackend_Validate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 784 in := new(ValidateRequest) 785 if err := dec(in); err != nil { 786 return nil, err 787 } 788 if interceptor == nil { 789 return srv.(InfrastructureBackendServer).Validate(ctx, in) 790 } 791 info := &grpc.UnaryServerInfo{ 792 Server: srv, 793 FullMethod: "/istio.mixer.adapter.model.v1beta1.InfrastructureBackend/Validate", 794 } 795 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 796 return srv.(InfrastructureBackendServer).Validate(ctx, req.(*ValidateRequest)) 797 } 798 return interceptor(ctx, in, info, handler) 799} 800 801func _InfrastructureBackend_CreateSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 802 in := new(CreateSessionRequest) 803 if err := dec(in); err != nil { 804 return nil, err 805 } 806 if interceptor == nil { 807 return srv.(InfrastructureBackendServer).CreateSession(ctx, in) 808 } 809 info := &grpc.UnaryServerInfo{ 810 Server: srv, 811 FullMethod: "/istio.mixer.adapter.model.v1beta1.InfrastructureBackend/CreateSession", 812 } 813 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 814 return srv.(InfrastructureBackendServer).CreateSession(ctx, req.(*CreateSessionRequest)) 815 } 816 return interceptor(ctx, in, info, handler) 817} 818 819func _InfrastructureBackend_CloseSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 820 in := new(CloseSessionRequest) 821 if err := dec(in); err != nil { 822 return nil, err 823 } 824 if interceptor == nil { 825 return srv.(InfrastructureBackendServer).CloseSession(ctx, in) 826 } 827 info := &grpc.UnaryServerInfo{ 828 Server: srv, 829 FullMethod: "/istio.mixer.adapter.model.v1beta1.InfrastructureBackend/CloseSession", 830 } 831 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 832 return srv.(InfrastructureBackendServer).CloseSession(ctx, req.(*CloseSessionRequest)) 833 } 834 return interceptor(ctx, in, info, handler) 835} 836 837var _InfrastructureBackend_serviceDesc = grpc.ServiceDesc{ 838 ServiceName: "istio.mixer.adapter.model.v1beta1.InfrastructureBackend", 839 HandlerType: (*InfrastructureBackendServer)(nil), 840 Methods: []grpc.MethodDesc{ 841 { 842 MethodName: "Validate", 843 Handler: _InfrastructureBackend_Validate_Handler, 844 }, 845 { 846 MethodName: "CreateSession", 847 Handler: _InfrastructureBackend_CreateSession_Handler, 848 }, 849 { 850 MethodName: "CloseSession", 851 Handler: _InfrastructureBackend_CloseSession_Handler, 852 }, 853 }, 854 Streams: []grpc.StreamDesc{}, 855 Metadata: "mixer/adapter/model/v1beta1/infrastructure_backend.proto", 856} 857 858func (m *CreateSessionRequest) Marshal() (dAtA []byte, err error) { 859 size := m.Size() 860 dAtA = make([]byte, size) 861 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 862 if err != nil { 863 return nil, err 864 } 865 return dAtA[:n], nil 866} 867 868func (m *CreateSessionRequest) MarshalTo(dAtA []byte) (int, error) { 869 size := m.Size() 870 return m.MarshalToSizedBuffer(dAtA[:size]) 871} 872 873func (m *CreateSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 874 i := len(dAtA) 875 _ = i 876 var l int 877 _ = l 878 if len(m.InferredTypes) > 0 { 879 for k := range m.InferredTypes { 880 v := m.InferredTypes[k] 881 baseI := i 882 if v != nil { 883 { 884 size, err := v.MarshalToSizedBuffer(dAtA[:i]) 885 if err != nil { 886 return 0, err 887 } 888 i -= size 889 i = encodeVarintInfrastructureBackend(dAtA, i, uint64(size)) 890 } 891 i-- 892 dAtA[i] = 0x12 893 } 894 i -= len(k) 895 copy(dAtA[i:], k) 896 i = encodeVarintInfrastructureBackend(dAtA, i, uint64(len(k))) 897 i-- 898 dAtA[i] = 0xa 899 i = encodeVarintInfrastructureBackend(dAtA, i, uint64(baseI-i)) 900 i-- 901 dAtA[i] = 0x12 902 } 903 } 904 if m.AdapterConfig != nil { 905 { 906 size, err := m.AdapterConfig.MarshalToSizedBuffer(dAtA[:i]) 907 if err != nil { 908 return 0, err 909 } 910 i -= size 911 i = encodeVarintInfrastructureBackend(dAtA, i, uint64(size)) 912 } 913 i-- 914 dAtA[i] = 0xa 915 } 916 return len(dAtA) - i, nil 917} 918 919func (m *CreateSessionResponse) Marshal() (dAtA []byte, err error) { 920 size := m.Size() 921 dAtA = make([]byte, size) 922 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 923 if err != nil { 924 return nil, err 925 } 926 return dAtA[:n], nil 927} 928 929func (m *CreateSessionResponse) MarshalTo(dAtA []byte) (int, error) { 930 size := m.Size() 931 return m.MarshalToSizedBuffer(dAtA[:size]) 932} 933 934func (m *CreateSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 935 i := len(dAtA) 936 _ = i 937 var l int 938 _ = l 939 if m.Status != nil { 940 { 941 size, err := m.Status.MarshalToSizedBuffer(dAtA[:i]) 942 if err != nil { 943 return 0, err 944 } 945 i -= size 946 i = encodeVarintInfrastructureBackend(dAtA, i, uint64(size)) 947 } 948 i-- 949 dAtA[i] = 0x12 950 } 951 if len(m.SessionId) > 0 { 952 i -= len(m.SessionId) 953 copy(dAtA[i:], m.SessionId) 954 i = encodeVarintInfrastructureBackend(dAtA, i, uint64(len(m.SessionId))) 955 i-- 956 dAtA[i] = 0xa 957 } 958 return len(dAtA) - i, nil 959} 960 961func (m *ValidateRequest) Marshal() (dAtA []byte, err error) { 962 size := m.Size() 963 dAtA = make([]byte, size) 964 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 965 if err != nil { 966 return nil, err 967 } 968 return dAtA[:n], nil 969} 970 971func (m *ValidateRequest) MarshalTo(dAtA []byte) (int, error) { 972 size := m.Size() 973 return m.MarshalToSizedBuffer(dAtA[:size]) 974} 975 976func (m *ValidateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 977 i := len(dAtA) 978 _ = i 979 var l int 980 _ = l 981 if len(m.InferredTypes) > 0 { 982 for k := range m.InferredTypes { 983 v := m.InferredTypes[k] 984 baseI := i 985 if v != nil { 986 { 987 size, err := v.MarshalToSizedBuffer(dAtA[:i]) 988 if err != nil { 989 return 0, err 990 } 991 i -= size 992 i = encodeVarintInfrastructureBackend(dAtA, i, uint64(size)) 993 } 994 i-- 995 dAtA[i] = 0x12 996 } 997 i -= len(k) 998 copy(dAtA[i:], k) 999 i = encodeVarintInfrastructureBackend(dAtA, i, uint64(len(k))) 1000 i-- 1001 dAtA[i] = 0xa 1002 i = encodeVarintInfrastructureBackend(dAtA, i, uint64(baseI-i)) 1003 i-- 1004 dAtA[i] = 0x12 1005 } 1006 } 1007 if m.AdapterConfig != nil { 1008 { 1009 size, err := m.AdapterConfig.MarshalToSizedBuffer(dAtA[:i]) 1010 if err != nil { 1011 return 0, err 1012 } 1013 i -= size 1014 i = encodeVarintInfrastructureBackend(dAtA, i, uint64(size)) 1015 } 1016 i-- 1017 dAtA[i] = 0xa 1018 } 1019 return len(dAtA) - i, nil 1020} 1021 1022func (m *ValidateResponse) Marshal() (dAtA []byte, err error) { 1023 size := m.Size() 1024 dAtA = make([]byte, size) 1025 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1026 if err != nil { 1027 return nil, err 1028 } 1029 return dAtA[:n], nil 1030} 1031 1032func (m *ValidateResponse) MarshalTo(dAtA []byte) (int, error) { 1033 size := m.Size() 1034 return m.MarshalToSizedBuffer(dAtA[:size]) 1035} 1036 1037func (m *ValidateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1038 i := len(dAtA) 1039 _ = i 1040 var l int 1041 _ = l 1042 if m.Status != nil { 1043 { 1044 size, err := m.Status.MarshalToSizedBuffer(dAtA[:i]) 1045 if err != nil { 1046 return 0, err 1047 } 1048 i -= size 1049 i = encodeVarintInfrastructureBackend(dAtA, i, uint64(size)) 1050 } 1051 i-- 1052 dAtA[i] = 0xa 1053 } 1054 return len(dAtA) - i, nil 1055} 1056 1057func (m *CloseSessionRequest) Marshal() (dAtA []byte, err error) { 1058 size := m.Size() 1059 dAtA = make([]byte, size) 1060 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1061 if err != nil { 1062 return nil, err 1063 } 1064 return dAtA[:n], nil 1065} 1066 1067func (m *CloseSessionRequest) MarshalTo(dAtA []byte) (int, error) { 1068 size := m.Size() 1069 return m.MarshalToSizedBuffer(dAtA[:size]) 1070} 1071 1072func (m *CloseSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1073 i := len(dAtA) 1074 _ = i 1075 var l int 1076 _ = l 1077 if len(m.SessionId) > 0 { 1078 i -= len(m.SessionId) 1079 copy(dAtA[i:], m.SessionId) 1080 i = encodeVarintInfrastructureBackend(dAtA, i, uint64(len(m.SessionId))) 1081 i-- 1082 dAtA[i] = 0xa 1083 } 1084 return len(dAtA) - i, nil 1085} 1086 1087func (m *CloseSessionResponse) Marshal() (dAtA []byte, err error) { 1088 size := m.Size() 1089 dAtA = make([]byte, size) 1090 n, err := m.MarshalToSizedBuffer(dAtA[:size]) 1091 if err != nil { 1092 return nil, err 1093 } 1094 return dAtA[:n], nil 1095} 1096 1097func (m *CloseSessionResponse) MarshalTo(dAtA []byte) (int, error) { 1098 size := m.Size() 1099 return m.MarshalToSizedBuffer(dAtA[:size]) 1100} 1101 1102func (m *CloseSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { 1103 i := len(dAtA) 1104 _ = i 1105 var l int 1106 _ = l 1107 if m.Status != nil { 1108 { 1109 size, err := m.Status.MarshalToSizedBuffer(dAtA[:i]) 1110 if err != nil { 1111 return 0, err 1112 } 1113 i -= size 1114 i = encodeVarintInfrastructureBackend(dAtA, i, uint64(size)) 1115 } 1116 i-- 1117 dAtA[i] = 0xa 1118 } 1119 return len(dAtA) - i, nil 1120} 1121 1122func encodeVarintInfrastructureBackend(dAtA []byte, offset int, v uint64) int { 1123 offset -= sovInfrastructureBackend(v) 1124 base := offset 1125 for v >= 1<<7 { 1126 dAtA[offset] = uint8(v&0x7f | 0x80) 1127 v >>= 7 1128 offset++ 1129 } 1130 dAtA[offset] = uint8(v) 1131 return base 1132} 1133func (m *CreateSessionRequest) Size() (n int) { 1134 if m == nil { 1135 return 0 1136 } 1137 var l int 1138 _ = l 1139 if m.AdapterConfig != nil { 1140 l = m.AdapterConfig.Size() 1141 n += 1 + l + sovInfrastructureBackend(uint64(l)) 1142 } 1143 if len(m.InferredTypes) > 0 { 1144 for k, v := range m.InferredTypes { 1145 _ = k 1146 _ = v 1147 l = 0 1148 if v != nil { 1149 l = v.Size() 1150 l += 1 + sovInfrastructureBackend(uint64(l)) 1151 } 1152 mapEntrySize := 1 + len(k) + sovInfrastructureBackend(uint64(len(k))) + l 1153 n += mapEntrySize + 1 + sovInfrastructureBackend(uint64(mapEntrySize)) 1154 } 1155 } 1156 return n 1157} 1158 1159func (m *CreateSessionResponse) Size() (n int) { 1160 if m == nil { 1161 return 0 1162 } 1163 var l int 1164 _ = l 1165 l = len(m.SessionId) 1166 if l > 0 { 1167 n += 1 + l + sovInfrastructureBackend(uint64(l)) 1168 } 1169 if m.Status != nil { 1170 l = m.Status.Size() 1171 n += 1 + l + sovInfrastructureBackend(uint64(l)) 1172 } 1173 return n 1174} 1175 1176func (m *ValidateRequest) Size() (n int) { 1177 if m == nil { 1178 return 0 1179 } 1180 var l int 1181 _ = l 1182 if m.AdapterConfig != nil { 1183 l = m.AdapterConfig.Size() 1184 n += 1 + l + sovInfrastructureBackend(uint64(l)) 1185 } 1186 if len(m.InferredTypes) > 0 { 1187 for k, v := range m.InferredTypes { 1188 _ = k 1189 _ = v 1190 l = 0 1191 if v != nil { 1192 l = v.Size() 1193 l += 1 + sovInfrastructureBackend(uint64(l)) 1194 } 1195 mapEntrySize := 1 + len(k) + sovInfrastructureBackend(uint64(len(k))) + l 1196 n += mapEntrySize + 1 + sovInfrastructureBackend(uint64(mapEntrySize)) 1197 } 1198 } 1199 return n 1200} 1201 1202func (m *ValidateResponse) Size() (n int) { 1203 if m == nil { 1204 return 0 1205 } 1206 var l int 1207 _ = l 1208 if m.Status != nil { 1209 l = m.Status.Size() 1210 n += 1 + l + sovInfrastructureBackend(uint64(l)) 1211 } 1212 return n 1213} 1214 1215func (m *CloseSessionRequest) Size() (n int) { 1216 if m == nil { 1217 return 0 1218 } 1219 var l int 1220 _ = l 1221 l = len(m.SessionId) 1222 if l > 0 { 1223 n += 1 + l + sovInfrastructureBackend(uint64(l)) 1224 } 1225 return n 1226} 1227 1228func (m *CloseSessionResponse) Size() (n int) { 1229 if m == nil { 1230 return 0 1231 } 1232 var l int 1233 _ = l 1234 if m.Status != nil { 1235 l = m.Status.Size() 1236 n += 1 + l + sovInfrastructureBackend(uint64(l)) 1237 } 1238 return n 1239} 1240 1241func sovInfrastructureBackend(x uint64) (n int) { 1242 return (math_bits.Len64(x|1) + 6) / 7 1243} 1244func sozInfrastructureBackend(x uint64) (n int) { 1245 return sovInfrastructureBackend(uint64((x << 1) ^ uint64((int64(x) >> 63)))) 1246} 1247func (this *CreateSessionRequest) String() string { 1248 if this == nil { 1249 return "nil" 1250 } 1251 keysForInferredTypes := make([]string, 0, len(this.InferredTypes)) 1252 for k, _ := range this.InferredTypes { 1253 keysForInferredTypes = append(keysForInferredTypes, k) 1254 } 1255 github_com_gogo_protobuf_sortkeys.Strings(keysForInferredTypes) 1256 mapStringForInferredTypes := "map[string]*types.Any{" 1257 for _, k := range keysForInferredTypes { 1258 mapStringForInferredTypes += fmt.Sprintf("%v: %v,", k, this.InferredTypes[k]) 1259 } 1260 mapStringForInferredTypes += "}" 1261 s := strings.Join([]string{`&CreateSessionRequest{`, 1262 `AdapterConfig:` + strings.Replace(fmt.Sprintf("%v", this.AdapterConfig), "Any", "types.Any", 1) + `,`, 1263 `InferredTypes:` + mapStringForInferredTypes + `,`, 1264 `}`, 1265 }, "") 1266 return s 1267} 1268func (this *CreateSessionResponse) String() string { 1269 if this == nil { 1270 return "nil" 1271 } 1272 s := strings.Join([]string{`&CreateSessionResponse{`, 1273 `SessionId:` + fmt.Sprintf("%v", this.SessionId) + `,`, 1274 `Status:` + strings.Replace(fmt.Sprintf("%v", this.Status), "Status", "rpc.Status", 1) + `,`, 1275 `}`, 1276 }, "") 1277 return s 1278} 1279func (this *ValidateRequest) String() string { 1280 if this == nil { 1281 return "nil" 1282 } 1283 keysForInferredTypes := make([]string, 0, len(this.InferredTypes)) 1284 for k, _ := range this.InferredTypes { 1285 keysForInferredTypes = append(keysForInferredTypes, k) 1286 } 1287 github_com_gogo_protobuf_sortkeys.Strings(keysForInferredTypes) 1288 mapStringForInferredTypes := "map[string]*types.Any{" 1289 for _, k := range keysForInferredTypes { 1290 mapStringForInferredTypes += fmt.Sprintf("%v: %v,", k, this.InferredTypes[k]) 1291 } 1292 mapStringForInferredTypes += "}" 1293 s := strings.Join([]string{`&ValidateRequest{`, 1294 `AdapterConfig:` + strings.Replace(fmt.Sprintf("%v", this.AdapterConfig), "Any", "types.Any", 1) + `,`, 1295 `InferredTypes:` + mapStringForInferredTypes + `,`, 1296 `}`, 1297 }, "") 1298 return s 1299} 1300func (this *ValidateResponse) String() string { 1301 if this == nil { 1302 return "nil" 1303 } 1304 s := strings.Join([]string{`&ValidateResponse{`, 1305 `Status:` + strings.Replace(fmt.Sprintf("%v", this.Status), "Status", "rpc.Status", 1) + `,`, 1306 `}`, 1307 }, "") 1308 return s 1309} 1310func (this *CloseSessionRequest) String() string { 1311 if this == nil { 1312 return "nil" 1313 } 1314 s := strings.Join([]string{`&CloseSessionRequest{`, 1315 `SessionId:` + fmt.Sprintf("%v", this.SessionId) + `,`, 1316 `}`, 1317 }, "") 1318 return s 1319} 1320func (this *CloseSessionResponse) String() string { 1321 if this == nil { 1322 return "nil" 1323 } 1324 s := strings.Join([]string{`&CloseSessionResponse{`, 1325 `Status:` + strings.Replace(fmt.Sprintf("%v", this.Status), "Status", "rpc.Status", 1) + `,`, 1326 `}`, 1327 }, "") 1328 return s 1329} 1330func valueToStringInfrastructureBackend(v interface{}) string { 1331 rv := reflect.ValueOf(v) 1332 if rv.IsNil() { 1333 return "nil" 1334 } 1335 pv := reflect.Indirect(rv).Interface() 1336 return fmt.Sprintf("*%v", pv) 1337} 1338func (m *CreateSessionRequest) Unmarshal(dAtA []byte) error { 1339 l := len(dAtA) 1340 iNdEx := 0 1341 for iNdEx < l { 1342 preIndex := iNdEx 1343 var wire uint64 1344 for shift := uint(0); ; shift += 7 { 1345 if shift >= 64 { 1346 return ErrIntOverflowInfrastructureBackend 1347 } 1348 if iNdEx >= l { 1349 return io.ErrUnexpectedEOF 1350 } 1351 b := dAtA[iNdEx] 1352 iNdEx++ 1353 wire |= uint64(b&0x7F) << shift 1354 if b < 0x80 { 1355 break 1356 } 1357 } 1358 fieldNum := int32(wire >> 3) 1359 wireType := int(wire & 0x7) 1360 if wireType == 4 { 1361 return fmt.Errorf("proto: CreateSessionRequest: wiretype end group for non-group") 1362 } 1363 if fieldNum <= 0 { 1364 return fmt.Errorf("proto: CreateSessionRequest: illegal tag %d (wire type %d)", fieldNum, wire) 1365 } 1366 switch fieldNum { 1367 case 1: 1368 if wireType != 2 { 1369 return fmt.Errorf("proto: wrong wireType = %d for field AdapterConfig", wireType) 1370 } 1371 var msglen int 1372 for shift := uint(0); ; shift += 7 { 1373 if shift >= 64 { 1374 return ErrIntOverflowInfrastructureBackend 1375 } 1376 if iNdEx >= l { 1377 return io.ErrUnexpectedEOF 1378 } 1379 b := dAtA[iNdEx] 1380 iNdEx++ 1381 msglen |= int(b&0x7F) << shift 1382 if b < 0x80 { 1383 break 1384 } 1385 } 1386 if msglen < 0 { 1387 return ErrInvalidLengthInfrastructureBackend 1388 } 1389 postIndex := iNdEx + msglen 1390 if postIndex < 0 { 1391 return ErrInvalidLengthInfrastructureBackend 1392 } 1393 if postIndex > l { 1394 return io.ErrUnexpectedEOF 1395 } 1396 if m.AdapterConfig == nil { 1397 m.AdapterConfig = &types.Any{} 1398 } 1399 if err := m.AdapterConfig.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 1400 return err 1401 } 1402 iNdEx = postIndex 1403 case 2: 1404 if wireType != 2 { 1405 return fmt.Errorf("proto: wrong wireType = %d for field InferredTypes", wireType) 1406 } 1407 var msglen int 1408 for shift := uint(0); ; shift += 7 { 1409 if shift >= 64 { 1410 return ErrIntOverflowInfrastructureBackend 1411 } 1412 if iNdEx >= l { 1413 return io.ErrUnexpectedEOF 1414 } 1415 b := dAtA[iNdEx] 1416 iNdEx++ 1417 msglen |= int(b&0x7F) << shift 1418 if b < 0x80 { 1419 break 1420 } 1421 } 1422 if msglen < 0 { 1423 return ErrInvalidLengthInfrastructureBackend 1424 } 1425 postIndex := iNdEx + msglen 1426 if postIndex < 0 { 1427 return ErrInvalidLengthInfrastructureBackend 1428 } 1429 if postIndex > l { 1430 return io.ErrUnexpectedEOF 1431 } 1432 if m.InferredTypes == nil { 1433 m.InferredTypes = make(map[string]*types.Any) 1434 } 1435 var mapkey string 1436 var mapvalue *types.Any 1437 for iNdEx < postIndex { 1438 entryPreIndex := iNdEx 1439 var wire uint64 1440 for shift := uint(0); ; shift += 7 { 1441 if shift >= 64 { 1442 return ErrIntOverflowInfrastructureBackend 1443 } 1444 if iNdEx >= l { 1445 return io.ErrUnexpectedEOF 1446 } 1447 b := dAtA[iNdEx] 1448 iNdEx++ 1449 wire |= uint64(b&0x7F) << shift 1450 if b < 0x80 { 1451 break 1452 } 1453 } 1454 fieldNum := int32(wire >> 3) 1455 if fieldNum == 1 { 1456 var stringLenmapkey uint64 1457 for shift := uint(0); ; shift += 7 { 1458 if shift >= 64 { 1459 return ErrIntOverflowInfrastructureBackend 1460 } 1461 if iNdEx >= l { 1462 return io.ErrUnexpectedEOF 1463 } 1464 b := dAtA[iNdEx] 1465 iNdEx++ 1466 stringLenmapkey |= uint64(b&0x7F) << shift 1467 if b < 0x80 { 1468 break 1469 } 1470 } 1471 intStringLenmapkey := int(stringLenmapkey) 1472 if intStringLenmapkey < 0 { 1473 return ErrInvalidLengthInfrastructureBackend 1474 } 1475 postStringIndexmapkey := iNdEx + intStringLenmapkey 1476 if postStringIndexmapkey < 0 { 1477 return ErrInvalidLengthInfrastructureBackend 1478 } 1479 if postStringIndexmapkey > l { 1480 return io.ErrUnexpectedEOF 1481 } 1482 mapkey = string(dAtA[iNdEx:postStringIndexmapkey]) 1483 iNdEx = postStringIndexmapkey 1484 } else if fieldNum == 2 { 1485 var mapmsglen int 1486 for shift := uint(0); ; shift += 7 { 1487 if shift >= 64 { 1488 return ErrIntOverflowInfrastructureBackend 1489 } 1490 if iNdEx >= l { 1491 return io.ErrUnexpectedEOF 1492 } 1493 b := dAtA[iNdEx] 1494 iNdEx++ 1495 mapmsglen |= int(b&0x7F) << shift 1496 if b < 0x80 { 1497 break 1498 } 1499 } 1500 if mapmsglen < 0 { 1501 return ErrInvalidLengthInfrastructureBackend 1502 } 1503 postmsgIndex := iNdEx + mapmsglen 1504 if postmsgIndex < 0 { 1505 return ErrInvalidLengthInfrastructureBackend 1506 } 1507 if postmsgIndex > l { 1508 return io.ErrUnexpectedEOF 1509 } 1510 mapvalue = &types.Any{} 1511 if err := mapvalue.Unmarshal(dAtA[iNdEx:postmsgIndex]); err != nil { 1512 return err 1513 } 1514 iNdEx = postmsgIndex 1515 } else { 1516 iNdEx = entryPreIndex 1517 skippy, err := skipInfrastructureBackend(dAtA[iNdEx:]) 1518 if err != nil { 1519 return err 1520 } 1521 if skippy < 0 { 1522 return ErrInvalidLengthInfrastructureBackend 1523 } 1524 if (iNdEx + skippy) > postIndex { 1525 return io.ErrUnexpectedEOF 1526 } 1527 iNdEx += skippy 1528 } 1529 } 1530 m.InferredTypes[mapkey] = mapvalue 1531 iNdEx = postIndex 1532 default: 1533 iNdEx = preIndex 1534 skippy, err := skipInfrastructureBackend(dAtA[iNdEx:]) 1535 if err != nil { 1536 return err 1537 } 1538 if skippy < 0 { 1539 return ErrInvalidLengthInfrastructureBackend 1540 } 1541 if (iNdEx + skippy) < 0 { 1542 return ErrInvalidLengthInfrastructureBackend 1543 } 1544 if (iNdEx + skippy) > l { 1545 return io.ErrUnexpectedEOF 1546 } 1547 iNdEx += skippy 1548 } 1549 } 1550 1551 if iNdEx > l { 1552 return io.ErrUnexpectedEOF 1553 } 1554 return nil 1555} 1556func (m *CreateSessionResponse) Unmarshal(dAtA []byte) error { 1557 l := len(dAtA) 1558 iNdEx := 0 1559 for iNdEx < l { 1560 preIndex := iNdEx 1561 var wire uint64 1562 for shift := uint(0); ; shift += 7 { 1563 if shift >= 64 { 1564 return ErrIntOverflowInfrastructureBackend 1565 } 1566 if iNdEx >= l { 1567 return io.ErrUnexpectedEOF 1568 } 1569 b := dAtA[iNdEx] 1570 iNdEx++ 1571 wire |= uint64(b&0x7F) << shift 1572 if b < 0x80 { 1573 break 1574 } 1575 } 1576 fieldNum := int32(wire >> 3) 1577 wireType := int(wire & 0x7) 1578 if wireType == 4 { 1579 return fmt.Errorf("proto: CreateSessionResponse: wiretype end group for non-group") 1580 } 1581 if fieldNum <= 0 { 1582 return fmt.Errorf("proto: CreateSessionResponse: illegal tag %d (wire type %d)", fieldNum, wire) 1583 } 1584 switch fieldNum { 1585 case 1: 1586 if wireType != 2 { 1587 return fmt.Errorf("proto: wrong wireType = %d for field SessionId", wireType) 1588 } 1589 var stringLen uint64 1590 for shift := uint(0); ; shift += 7 { 1591 if shift >= 64 { 1592 return ErrIntOverflowInfrastructureBackend 1593 } 1594 if iNdEx >= l { 1595 return io.ErrUnexpectedEOF 1596 } 1597 b := dAtA[iNdEx] 1598 iNdEx++ 1599 stringLen |= uint64(b&0x7F) << shift 1600 if b < 0x80 { 1601 break 1602 } 1603 } 1604 intStringLen := int(stringLen) 1605 if intStringLen < 0 { 1606 return ErrInvalidLengthInfrastructureBackend 1607 } 1608 postIndex := iNdEx + intStringLen 1609 if postIndex < 0 { 1610 return ErrInvalidLengthInfrastructureBackend 1611 } 1612 if postIndex > l { 1613 return io.ErrUnexpectedEOF 1614 } 1615 m.SessionId = string(dAtA[iNdEx:postIndex]) 1616 iNdEx = postIndex 1617 case 2: 1618 if wireType != 2 { 1619 return fmt.Errorf("proto: wrong wireType = %d for field Status", wireType) 1620 } 1621 var msglen int 1622 for shift := uint(0); ; shift += 7 { 1623 if shift >= 64 { 1624 return ErrIntOverflowInfrastructureBackend 1625 } 1626 if iNdEx >= l { 1627 return io.ErrUnexpectedEOF 1628 } 1629 b := dAtA[iNdEx] 1630 iNdEx++ 1631 msglen |= int(b&0x7F) << shift 1632 if b < 0x80 { 1633 break 1634 } 1635 } 1636 if msglen < 0 { 1637 return ErrInvalidLengthInfrastructureBackend 1638 } 1639 postIndex := iNdEx + msglen 1640 if postIndex < 0 { 1641 return ErrInvalidLengthInfrastructureBackend 1642 } 1643 if postIndex > l { 1644 return io.ErrUnexpectedEOF 1645 } 1646 if m.Status == nil { 1647 m.Status = &rpc.Status{} 1648 } 1649 if err := m.Status.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 1650 return err 1651 } 1652 iNdEx = postIndex 1653 default: 1654 iNdEx = preIndex 1655 skippy, err := skipInfrastructureBackend(dAtA[iNdEx:]) 1656 if err != nil { 1657 return err 1658 } 1659 if skippy < 0 { 1660 return ErrInvalidLengthInfrastructureBackend 1661 } 1662 if (iNdEx + skippy) < 0 { 1663 return ErrInvalidLengthInfrastructureBackend 1664 } 1665 if (iNdEx + skippy) > l { 1666 return io.ErrUnexpectedEOF 1667 } 1668 iNdEx += skippy 1669 } 1670 } 1671 1672 if iNdEx > l { 1673 return io.ErrUnexpectedEOF 1674 } 1675 return nil 1676} 1677func (m *ValidateRequest) Unmarshal(dAtA []byte) error { 1678 l := len(dAtA) 1679 iNdEx := 0 1680 for iNdEx < l { 1681 preIndex := iNdEx 1682 var wire uint64 1683 for shift := uint(0); ; shift += 7 { 1684 if shift >= 64 { 1685 return ErrIntOverflowInfrastructureBackend 1686 } 1687 if iNdEx >= l { 1688 return io.ErrUnexpectedEOF 1689 } 1690 b := dAtA[iNdEx] 1691 iNdEx++ 1692 wire |= uint64(b&0x7F) << shift 1693 if b < 0x80 { 1694 break 1695 } 1696 } 1697 fieldNum := int32(wire >> 3) 1698 wireType := int(wire & 0x7) 1699 if wireType == 4 { 1700 return fmt.Errorf("proto: ValidateRequest: wiretype end group for non-group") 1701 } 1702 if fieldNum <= 0 { 1703 return fmt.Errorf("proto: ValidateRequest: illegal tag %d (wire type %d)", fieldNum, wire) 1704 } 1705 switch fieldNum { 1706 case 1: 1707 if wireType != 2 { 1708 return fmt.Errorf("proto: wrong wireType = %d for field AdapterConfig", wireType) 1709 } 1710 var msglen int 1711 for shift := uint(0); ; shift += 7 { 1712 if shift >= 64 { 1713 return ErrIntOverflowInfrastructureBackend 1714 } 1715 if iNdEx >= l { 1716 return io.ErrUnexpectedEOF 1717 } 1718 b := dAtA[iNdEx] 1719 iNdEx++ 1720 msglen |= int(b&0x7F) << shift 1721 if b < 0x80 { 1722 break 1723 } 1724 } 1725 if msglen < 0 { 1726 return ErrInvalidLengthInfrastructureBackend 1727 } 1728 postIndex := iNdEx + msglen 1729 if postIndex < 0 { 1730 return ErrInvalidLengthInfrastructureBackend 1731 } 1732 if postIndex > l { 1733 return io.ErrUnexpectedEOF 1734 } 1735 if m.AdapterConfig == nil { 1736 m.AdapterConfig = &types.Any{} 1737 } 1738 if err := m.AdapterConfig.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 1739 return err 1740 } 1741 iNdEx = postIndex 1742 case 2: 1743 if wireType != 2 { 1744 return fmt.Errorf("proto: wrong wireType = %d for field InferredTypes", wireType) 1745 } 1746 var msglen int 1747 for shift := uint(0); ; shift += 7 { 1748 if shift >= 64 { 1749 return ErrIntOverflowInfrastructureBackend 1750 } 1751 if iNdEx >= l { 1752 return io.ErrUnexpectedEOF 1753 } 1754 b := dAtA[iNdEx] 1755 iNdEx++ 1756 msglen |= int(b&0x7F) << shift 1757 if b < 0x80 { 1758 break 1759 } 1760 } 1761 if msglen < 0 { 1762 return ErrInvalidLengthInfrastructureBackend 1763 } 1764 postIndex := iNdEx + msglen 1765 if postIndex < 0 { 1766 return ErrInvalidLengthInfrastructureBackend 1767 } 1768 if postIndex > l { 1769 return io.ErrUnexpectedEOF 1770 } 1771 if m.InferredTypes == nil { 1772 m.InferredTypes = make(map[string]*types.Any) 1773 } 1774 var mapkey string 1775 var mapvalue *types.Any 1776 for iNdEx < postIndex { 1777 entryPreIndex := iNdEx 1778 var wire uint64 1779 for shift := uint(0); ; shift += 7 { 1780 if shift >= 64 { 1781 return ErrIntOverflowInfrastructureBackend 1782 } 1783 if iNdEx >= l { 1784 return io.ErrUnexpectedEOF 1785 } 1786 b := dAtA[iNdEx] 1787 iNdEx++ 1788 wire |= uint64(b&0x7F) << shift 1789 if b < 0x80 { 1790 break 1791 } 1792 } 1793 fieldNum := int32(wire >> 3) 1794 if fieldNum == 1 { 1795 var stringLenmapkey uint64 1796 for shift := uint(0); ; shift += 7 { 1797 if shift >= 64 { 1798 return ErrIntOverflowInfrastructureBackend 1799 } 1800 if iNdEx >= l { 1801 return io.ErrUnexpectedEOF 1802 } 1803 b := dAtA[iNdEx] 1804 iNdEx++ 1805 stringLenmapkey |= uint64(b&0x7F) << shift 1806 if b < 0x80 { 1807 break 1808 } 1809 } 1810 intStringLenmapkey := int(stringLenmapkey) 1811 if intStringLenmapkey < 0 { 1812 return ErrInvalidLengthInfrastructureBackend 1813 } 1814 postStringIndexmapkey := iNdEx + intStringLenmapkey 1815 if postStringIndexmapkey < 0 { 1816 return ErrInvalidLengthInfrastructureBackend 1817 } 1818 if postStringIndexmapkey > l { 1819 return io.ErrUnexpectedEOF 1820 } 1821 mapkey = string(dAtA[iNdEx:postStringIndexmapkey]) 1822 iNdEx = postStringIndexmapkey 1823 } else if fieldNum == 2 { 1824 var mapmsglen int 1825 for shift := uint(0); ; shift += 7 { 1826 if shift >= 64 { 1827 return ErrIntOverflowInfrastructureBackend 1828 } 1829 if iNdEx >= l { 1830 return io.ErrUnexpectedEOF 1831 } 1832 b := dAtA[iNdEx] 1833 iNdEx++ 1834 mapmsglen |= int(b&0x7F) << shift 1835 if b < 0x80 { 1836 break 1837 } 1838 } 1839 if mapmsglen < 0 { 1840 return ErrInvalidLengthInfrastructureBackend 1841 } 1842 postmsgIndex := iNdEx + mapmsglen 1843 if postmsgIndex < 0 { 1844 return ErrInvalidLengthInfrastructureBackend 1845 } 1846 if postmsgIndex > l { 1847 return io.ErrUnexpectedEOF 1848 } 1849 mapvalue = &types.Any{} 1850 if err := mapvalue.Unmarshal(dAtA[iNdEx:postmsgIndex]); err != nil { 1851 return err 1852 } 1853 iNdEx = postmsgIndex 1854 } else { 1855 iNdEx = entryPreIndex 1856 skippy, err := skipInfrastructureBackend(dAtA[iNdEx:]) 1857 if err != nil { 1858 return err 1859 } 1860 if skippy < 0 { 1861 return ErrInvalidLengthInfrastructureBackend 1862 } 1863 if (iNdEx + skippy) > postIndex { 1864 return io.ErrUnexpectedEOF 1865 } 1866 iNdEx += skippy 1867 } 1868 } 1869 m.InferredTypes[mapkey] = mapvalue 1870 iNdEx = postIndex 1871 default: 1872 iNdEx = preIndex 1873 skippy, err := skipInfrastructureBackend(dAtA[iNdEx:]) 1874 if err != nil { 1875 return err 1876 } 1877 if skippy < 0 { 1878 return ErrInvalidLengthInfrastructureBackend 1879 } 1880 if (iNdEx + skippy) < 0 { 1881 return ErrInvalidLengthInfrastructureBackend 1882 } 1883 if (iNdEx + skippy) > l { 1884 return io.ErrUnexpectedEOF 1885 } 1886 iNdEx += skippy 1887 } 1888 } 1889 1890 if iNdEx > l { 1891 return io.ErrUnexpectedEOF 1892 } 1893 return nil 1894} 1895func (m *ValidateResponse) Unmarshal(dAtA []byte) error { 1896 l := len(dAtA) 1897 iNdEx := 0 1898 for iNdEx < l { 1899 preIndex := iNdEx 1900 var wire uint64 1901 for shift := uint(0); ; shift += 7 { 1902 if shift >= 64 { 1903 return ErrIntOverflowInfrastructureBackend 1904 } 1905 if iNdEx >= l { 1906 return io.ErrUnexpectedEOF 1907 } 1908 b := dAtA[iNdEx] 1909 iNdEx++ 1910 wire |= uint64(b&0x7F) << shift 1911 if b < 0x80 { 1912 break 1913 } 1914 } 1915 fieldNum := int32(wire >> 3) 1916 wireType := int(wire & 0x7) 1917 if wireType == 4 { 1918 return fmt.Errorf("proto: ValidateResponse: wiretype end group for non-group") 1919 } 1920 if fieldNum <= 0 { 1921 return fmt.Errorf("proto: ValidateResponse: illegal tag %d (wire type %d)", fieldNum, wire) 1922 } 1923 switch fieldNum { 1924 case 1: 1925 if wireType != 2 { 1926 return fmt.Errorf("proto: wrong wireType = %d for field Status", wireType) 1927 } 1928 var msglen int 1929 for shift := uint(0); ; shift += 7 { 1930 if shift >= 64 { 1931 return ErrIntOverflowInfrastructureBackend 1932 } 1933 if iNdEx >= l { 1934 return io.ErrUnexpectedEOF 1935 } 1936 b := dAtA[iNdEx] 1937 iNdEx++ 1938 msglen |= int(b&0x7F) << shift 1939 if b < 0x80 { 1940 break 1941 } 1942 } 1943 if msglen < 0 { 1944 return ErrInvalidLengthInfrastructureBackend 1945 } 1946 postIndex := iNdEx + msglen 1947 if postIndex < 0 { 1948 return ErrInvalidLengthInfrastructureBackend 1949 } 1950 if postIndex > l { 1951 return io.ErrUnexpectedEOF 1952 } 1953 if m.Status == nil { 1954 m.Status = &rpc.Status{} 1955 } 1956 if err := m.Status.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 1957 return err 1958 } 1959 iNdEx = postIndex 1960 default: 1961 iNdEx = preIndex 1962 skippy, err := skipInfrastructureBackend(dAtA[iNdEx:]) 1963 if err != nil { 1964 return err 1965 } 1966 if skippy < 0 { 1967 return ErrInvalidLengthInfrastructureBackend 1968 } 1969 if (iNdEx + skippy) < 0 { 1970 return ErrInvalidLengthInfrastructureBackend 1971 } 1972 if (iNdEx + skippy) > l { 1973 return io.ErrUnexpectedEOF 1974 } 1975 iNdEx += skippy 1976 } 1977 } 1978 1979 if iNdEx > l { 1980 return io.ErrUnexpectedEOF 1981 } 1982 return nil 1983} 1984func (m *CloseSessionRequest) Unmarshal(dAtA []byte) error { 1985 l := len(dAtA) 1986 iNdEx := 0 1987 for iNdEx < l { 1988 preIndex := iNdEx 1989 var wire uint64 1990 for shift := uint(0); ; shift += 7 { 1991 if shift >= 64 { 1992 return ErrIntOverflowInfrastructureBackend 1993 } 1994 if iNdEx >= l { 1995 return io.ErrUnexpectedEOF 1996 } 1997 b := dAtA[iNdEx] 1998 iNdEx++ 1999 wire |= uint64(b&0x7F) << shift 2000 if b < 0x80 { 2001 break 2002 } 2003 } 2004 fieldNum := int32(wire >> 3) 2005 wireType := int(wire & 0x7) 2006 if wireType == 4 { 2007 return fmt.Errorf("proto: CloseSessionRequest: wiretype end group for non-group") 2008 } 2009 if fieldNum <= 0 { 2010 return fmt.Errorf("proto: CloseSessionRequest: illegal tag %d (wire type %d)", fieldNum, wire) 2011 } 2012 switch fieldNum { 2013 case 1: 2014 if wireType != 2 { 2015 return fmt.Errorf("proto: wrong wireType = %d for field SessionId", wireType) 2016 } 2017 var stringLen uint64 2018 for shift := uint(0); ; shift += 7 { 2019 if shift >= 64 { 2020 return ErrIntOverflowInfrastructureBackend 2021 } 2022 if iNdEx >= l { 2023 return io.ErrUnexpectedEOF 2024 } 2025 b := dAtA[iNdEx] 2026 iNdEx++ 2027 stringLen |= uint64(b&0x7F) << shift 2028 if b < 0x80 { 2029 break 2030 } 2031 } 2032 intStringLen := int(stringLen) 2033 if intStringLen < 0 { 2034 return ErrInvalidLengthInfrastructureBackend 2035 } 2036 postIndex := iNdEx + intStringLen 2037 if postIndex < 0 { 2038 return ErrInvalidLengthInfrastructureBackend 2039 } 2040 if postIndex > l { 2041 return io.ErrUnexpectedEOF 2042 } 2043 m.SessionId = string(dAtA[iNdEx:postIndex]) 2044 iNdEx = postIndex 2045 default: 2046 iNdEx = preIndex 2047 skippy, err := skipInfrastructureBackend(dAtA[iNdEx:]) 2048 if err != nil { 2049 return err 2050 } 2051 if skippy < 0 { 2052 return ErrInvalidLengthInfrastructureBackend 2053 } 2054 if (iNdEx + skippy) < 0 { 2055 return ErrInvalidLengthInfrastructureBackend 2056 } 2057 if (iNdEx + skippy) > l { 2058 return io.ErrUnexpectedEOF 2059 } 2060 iNdEx += skippy 2061 } 2062 } 2063 2064 if iNdEx > l { 2065 return io.ErrUnexpectedEOF 2066 } 2067 return nil 2068} 2069func (m *CloseSessionResponse) Unmarshal(dAtA []byte) error { 2070 l := len(dAtA) 2071 iNdEx := 0 2072 for iNdEx < l { 2073 preIndex := iNdEx 2074 var wire uint64 2075 for shift := uint(0); ; shift += 7 { 2076 if shift >= 64 { 2077 return ErrIntOverflowInfrastructureBackend 2078 } 2079 if iNdEx >= l { 2080 return io.ErrUnexpectedEOF 2081 } 2082 b := dAtA[iNdEx] 2083 iNdEx++ 2084 wire |= uint64(b&0x7F) << shift 2085 if b < 0x80 { 2086 break 2087 } 2088 } 2089 fieldNum := int32(wire >> 3) 2090 wireType := int(wire & 0x7) 2091 if wireType == 4 { 2092 return fmt.Errorf("proto: CloseSessionResponse: wiretype end group for non-group") 2093 } 2094 if fieldNum <= 0 { 2095 return fmt.Errorf("proto: CloseSessionResponse: illegal tag %d (wire type %d)", fieldNum, wire) 2096 } 2097 switch fieldNum { 2098 case 1: 2099 if wireType != 2 { 2100 return fmt.Errorf("proto: wrong wireType = %d for field Status", wireType) 2101 } 2102 var msglen int 2103 for shift := uint(0); ; shift += 7 { 2104 if shift >= 64 { 2105 return ErrIntOverflowInfrastructureBackend 2106 } 2107 if iNdEx >= l { 2108 return io.ErrUnexpectedEOF 2109 } 2110 b := dAtA[iNdEx] 2111 iNdEx++ 2112 msglen |= int(b&0x7F) << shift 2113 if b < 0x80 { 2114 break 2115 } 2116 } 2117 if msglen < 0 { 2118 return ErrInvalidLengthInfrastructureBackend 2119 } 2120 postIndex := iNdEx + msglen 2121 if postIndex < 0 { 2122 return ErrInvalidLengthInfrastructureBackend 2123 } 2124 if postIndex > l { 2125 return io.ErrUnexpectedEOF 2126 } 2127 if m.Status == nil { 2128 m.Status = &rpc.Status{} 2129 } 2130 if err := m.Status.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { 2131 return err 2132 } 2133 iNdEx = postIndex 2134 default: 2135 iNdEx = preIndex 2136 skippy, err := skipInfrastructureBackend(dAtA[iNdEx:]) 2137 if err != nil { 2138 return err 2139 } 2140 if skippy < 0 { 2141 return ErrInvalidLengthInfrastructureBackend 2142 } 2143 if (iNdEx + skippy) < 0 { 2144 return ErrInvalidLengthInfrastructureBackend 2145 } 2146 if (iNdEx + skippy) > l { 2147 return io.ErrUnexpectedEOF 2148 } 2149 iNdEx += skippy 2150 } 2151 } 2152 2153 if iNdEx > l { 2154 return io.ErrUnexpectedEOF 2155 } 2156 return nil 2157} 2158func skipInfrastructureBackend(dAtA []byte) (n int, err error) { 2159 l := len(dAtA) 2160 iNdEx := 0 2161 for iNdEx < l { 2162 var wire uint64 2163 for shift := uint(0); ; shift += 7 { 2164 if shift >= 64 { 2165 return 0, ErrIntOverflowInfrastructureBackend 2166 } 2167 if iNdEx >= l { 2168 return 0, io.ErrUnexpectedEOF 2169 } 2170 b := dAtA[iNdEx] 2171 iNdEx++ 2172 wire |= (uint64(b) & 0x7F) << shift 2173 if b < 0x80 { 2174 break 2175 } 2176 } 2177 wireType := int(wire & 0x7) 2178 switch wireType { 2179 case 0: 2180 for shift := uint(0); ; shift += 7 { 2181 if shift >= 64 { 2182 return 0, ErrIntOverflowInfrastructureBackend 2183 } 2184 if iNdEx >= l { 2185 return 0, io.ErrUnexpectedEOF 2186 } 2187 iNdEx++ 2188 if dAtA[iNdEx-1] < 0x80 { 2189 break 2190 } 2191 } 2192 return iNdEx, nil 2193 case 1: 2194 iNdEx += 8 2195 return iNdEx, nil 2196 case 2: 2197 var length int 2198 for shift := uint(0); ; shift += 7 { 2199 if shift >= 64 { 2200 return 0, ErrIntOverflowInfrastructureBackend 2201 } 2202 if iNdEx >= l { 2203 return 0, io.ErrUnexpectedEOF 2204 } 2205 b := dAtA[iNdEx] 2206 iNdEx++ 2207 length |= (int(b) & 0x7F) << shift 2208 if b < 0x80 { 2209 break 2210 } 2211 } 2212 if length < 0 { 2213 return 0, ErrInvalidLengthInfrastructureBackend 2214 } 2215 iNdEx += length 2216 if iNdEx < 0 { 2217 return 0, ErrInvalidLengthInfrastructureBackend 2218 } 2219 return iNdEx, nil 2220 case 3: 2221 for { 2222 var innerWire uint64 2223 var start int = iNdEx 2224 for shift := uint(0); ; shift += 7 { 2225 if shift >= 64 { 2226 return 0, ErrIntOverflowInfrastructureBackend 2227 } 2228 if iNdEx >= l { 2229 return 0, io.ErrUnexpectedEOF 2230 } 2231 b := dAtA[iNdEx] 2232 iNdEx++ 2233 innerWire |= (uint64(b) & 0x7F) << shift 2234 if b < 0x80 { 2235 break 2236 } 2237 } 2238 innerWireType := int(innerWire & 0x7) 2239 if innerWireType == 4 { 2240 break 2241 } 2242 next, err := skipInfrastructureBackend(dAtA[start:]) 2243 if err != nil { 2244 return 0, err 2245 } 2246 iNdEx = start + next 2247 if iNdEx < 0 { 2248 return 0, ErrInvalidLengthInfrastructureBackend 2249 } 2250 } 2251 return iNdEx, nil 2252 case 4: 2253 return iNdEx, nil 2254 case 5: 2255 iNdEx += 4 2256 return iNdEx, nil 2257 default: 2258 return 0, fmt.Errorf("proto: illegal wireType %d", wireType) 2259 } 2260 } 2261 panic("unreachable") 2262} 2263 2264var ( 2265 ErrInvalidLengthInfrastructureBackend = fmt.Errorf("proto: negative length found during unmarshaling") 2266 ErrIntOverflowInfrastructureBackend = fmt.Errorf("proto: integer overflow") 2267) 2268