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