1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: grpc/channelz/v1/channelz.proto 3 4package grpc_channelz_v1 5 6import ( 7 context "context" 8 fmt "fmt" 9 proto "github.com/golang/protobuf/proto" 10 any "github.com/golang/protobuf/ptypes/any" 11 duration "github.com/golang/protobuf/ptypes/duration" 12 timestamp "github.com/golang/protobuf/ptypes/timestamp" 13 wrappers "github.com/golang/protobuf/ptypes/wrappers" 14 grpc "google.golang.org/grpc" 15 codes "google.golang.org/grpc/codes" 16 status "google.golang.org/grpc/status" 17 math "math" 18) 19 20// Reference imports to suppress errors if they are not otherwise used. 21var _ = proto.Marshal 22var _ = fmt.Errorf 23var _ = math.Inf 24 25// This is a compile-time assertion to ensure that this generated file 26// is compatible with the proto package it is being compiled against. 27// A compilation error at this line likely means your copy of the 28// proto package needs to be updated. 29const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package 30 31type ChannelConnectivityState_State int32 32 33const ( 34 ChannelConnectivityState_UNKNOWN ChannelConnectivityState_State = 0 35 ChannelConnectivityState_IDLE ChannelConnectivityState_State = 1 36 ChannelConnectivityState_CONNECTING ChannelConnectivityState_State = 2 37 ChannelConnectivityState_READY ChannelConnectivityState_State = 3 38 ChannelConnectivityState_TRANSIENT_FAILURE ChannelConnectivityState_State = 4 39 ChannelConnectivityState_SHUTDOWN ChannelConnectivityState_State = 5 40) 41 42var ChannelConnectivityState_State_name = map[int32]string{ 43 0: "UNKNOWN", 44 1: "IDLE", 45 2: "CONNECTING", 46 3: "READY", 47 4: "TRANSIENT_FAILURE", 48 5: "SHUTDOWN", 49} 50 51var ChannelConnectivityState_State_value = map[string]int32{ 52 "UNKNOWN": 0, 53 "IDLE": 1, 54 "CONNECTING": 2, 55 "READY": 3, 56 "TRANSIENT_FAILURE": 4, 57 "SHUTDOWN": 5, 58} 59 60func (x ChannelConnectivityState_State) String() string { 61 return proto.EnumName(ChannelConnectivityState_State_name, int32(x)) 62} 63 64func (ChannelConnectivityState_State) EnumDescriptor() ([]byte, []int) { 65 return fileDescriptor_6ee37dfd35a8ab00, []int{2, 0} 66} 67 68// The supported severity levels of trace events. 69type ChannelTraceEvent_Severity int32 70 71const ( 72 ChannelTraceEvent_CT_UNKNOWN ChannelTraceEvent_Severity = 0 73 ChannelTraceEvent_CT_INFO ChannelTraceEvent_Severity = 1 74 ChannelTraceEvent_CT_WARNING ChannelTraceEvent_Severity = 2 75 ChannelTraceEvent_CT_ERROR ChannelTraceEvent_Severity = 3 76) 77 78var ChannelTraceEvent_Severity_name = map[int32]string{ 79 0: "CT_UNKNOWN", 80 1: "CT_INFO", 81 2: "CT_WARNING", 82 3: "CT_ERROR", 83} 84 85var ChannelTraceEvent_Severity_value = map[string]int32{ 86 "CT_UNKNOWN": 0, 87 "CT_INFO": 1, 88 "CT_WARNING": 2, 89 "CT_ERROR": 3, 90} 91 92func (x ChannelTraceEvent_Severity) String() string { 93 return proto.EnumName(ChannelTraceEvent_Severity_name, int32(x)) 94} 95 96func (ChannelTraceEvent_Severity) EnumDescriptor() ([]byte, []int) { 97 return fileDescriptor_6ee37dfd35a8ab00, []int{4, 0} 98} 99 100// Channel is a logical grouping of channels, subchannels, and sockets. 101type Channel struct { 102 // The identifier for this channel. This should bet set. 103 Ref *ChannelRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"` 104 // Data specific to this channel. 105 Data *ChannelData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` 106 // There are no ordering guarantees on the order of channel refs. 107 // There may not be cycles in the ref graph. 108 // A channel ref may be present in more than one channel or subchannel. 109 ChannelRef []*ChannelRef `protobuf:"bytes,3,rep,name=channel_ref,json=channelRef,proto3" json:"channel_ref,omitempty"` 110 // At most one of 'channel_ref+subchannel_ref' and 'socket' is set. 111 // There are no ordering guarantees on the order of subchannel refs. 112 // There may not be cycles in the ref graph. 113 // A sub channel ref may be present in more than one channel or subchannel. 114 SubchannelRef []*SubchannelRef `protobuf:"bytes,4,rep,name=subchannel_ref,json=subchannelRef,proto3" json:"subchannel_ref,omitempty"` 115 // There are no ordering guarantees on the order of sockets. 116 SocketRef []*SocketRef `protobuf:"bytes,5,rep,name=socket_ref,json=socketRef,proto3" json:"socket_ref,omitempty"` 117 XXX_NoUnkeyedLiteral struct{} `json:"-"` 118 XXX_unrecognized []byte `json:"-"` 119 XXX_sizecache int32 `json:"-"` 120} 121 122func (m *Channel) Reset() { *m = Channel{} } 123func (m *Channel) String() string { return proto.CompactTextString(m) } 124func (*Channel) ProtoMessage() {} 125func (*Channel) Descriptor() ([]byte, []int) { 126 return fileDescriptor_6ee37dfd35a8ab00, []int{0} 127} 128 129func (m *Channel) XXX_Unmarshal(b []byte) error { 130 return xxx_messageInfo_Channel.Unmarshal(m, b) 131} 132func (m *Channel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 133 return xxx_messageInfo_Channel.Marshal(b, m, deterministic) 134} 135func (m *Channel) XXX_Merge(src proto.Message) { 136 xxx_messageInfo_Channel.Merge(m, src) 137} 138func (m *Channel) XXX_Size() int { 139 return xxx_messageInfo_Channel.Size(m) 140} 141func (m *Channel) XXX_DiscardUnknown() { 142 xxx_messageInfo_Channel.DiscardUnknown(m) 143} 144 145var xxx_messageInfo_Channel proto.InternalMessageInfo 146 147func (m *Channel) GetRef() *ChannelRef { 148 if m != nil { 149 return m.Ref 150 } 151 return nil 152} 153 154func (m *Channel) GetData() *ChannelData { 155 if m != nil { 156 return m.Data 157 } 158 return nil 159} 160 161func (m *Channel) GetChannelRef() []*ChannelRef { 162 if m != nil { 163 return m.ChannelRef 164 } 165 return nil 166} 167 168func (m *Channel) GetSubchannelRef() []*SubchannelRef { 169 if m != nil { 170 return m.SubchannelRef 171 } 172 return nil 173} 174 175func (m *Channel) GetSocketRef() []*SocketRef { 176 if m != nil { 177 return m.SocketRef 178 } 179 return nil 180} 181 182// Subchannel is a logical grouping of channels, subchannels, and sockets. 183// A subchannel is load balanced over by it's ancestor 184type Subchannel struct { 185 // The identifier for this channel. 186 Ref *SubchannelRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"` 187 // Data specific to this channel. 188 Data *ChannelData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` 189 // There are no ordering guarantees on the order of channel refs. 190 // There may not be cycles in the ref graph. 191 // A channel ref may be present in more than one channel or subchannel. 192 ChannelRef []*ChannelRef `protobuf:"bytes,3,rep,name=channel_ref,json=channelRef,proto3" json:"channel_ref,omitempty"` 193 // At most one of 'channel_ref+subchannel_ref' and 'socket' is set. 194 // There are no ordering guarantees on the order of subchannel refs. 195 // There may not be cycles in the ref graph. 196 // A sub channel ref may be present in more than one channel or subchannel. 197 SubchannelRef []*SubchannelRef `protobuf:"bytes,4,rep,name=subchannel_ref,json=subchannelRef,proto3" json:"subchannel_ref,omitempty"` 198 // There are no ordering guarantees on the order of sockets. 199 SocketRef []*SocketRef `protobuf:"bytes,5,rep,name=socket_ref,json=socketRef,proto3" json:"socket_ref,omitempty"` 200 XXX_NoUnkeyedLiteral struct{} `json:"-"` 201 XXX_unrecognized []byte `json:"-"` 202 XXX_sizecache int32 `json:"-"` 203} 204 205func (m *Subchannel) Reset() { *m = Subchannel{} } 206func (m *Subchannel) String() string { return proto.CompactTextString(m) } 207func (*Subchannel) ProtoMessage() {} 208func (*Subchannel) Descriptor() ([]byte, []int) { 209 return fileDescriptor_6ee37dfd35a8ab00, []int{1} 210} 211 212func (m *Subchannel) XXX_Unmarshal(b []byte) error { 213 return xxx_messageInfo_Subchannel.Unmarshal(m, b) 214} 215func (m *Subchannel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 216 return xxx_messageInfo_Subchannel.Marshal(b, m, deterministic) 217} 218func (m *Subchannel) XXX_Merge(src proto.Message) { 219 xxx_messageInfo_Subchannel.Merge(m, src) 220} 221func (m *Subchannel) XXX_Size() int { 222 return xxx_messageInfo_Subchannel.Size(m) 223} 224func (m *Subchannel) XXX_DiscardUnknown() { 225 xxx_messageInfo_Subchannel.DiscardUnknown(m) 226} 227 228var xxx_messageInfo_Subchannel proto.InternalMessageInfo 229 230func (m *Subchannel) GetRef() *SubchannelRef { 231 if m != nil { 232 return m.Ref 233 } 234 return nil 235} 236 237func (m *Subchannel) GetData() *ChannelData { 238 if m != nil { 239 return m.Data 240 } 241 return nil 242} 243 244func (m *Subchannel) GetChannelRef() []*ChannelRef { 245 if m != nil { 246 return m.ChannelRef 247 } 248 return nil 249} 250 251func (m *Subchannel) GetSubchannelRef() []*SubchannelRef { 252 if m != nil { 253 return m.SubchannelRef 254 } 255 return nil 256} 257 258func (m *Subchannel) GetSocketRef() []*SocketRef { 259 if m != nil { 260 return m.SocketRef 261 } 262 return nil 263} 264 265// These come from the specified states in this document: 266// https://github.com/grpc/grpc/blob/master/doc/connectivity-semantics-and-api.md 267type ChannelConnectivityState struct { 268 State ChannelConnectivityState_State `protobuf:"varint,1,opt,name=state,proto3,enum=grpc.channelz.v1.ChannelConnectivityState_State" json:"state,omitempty"` 269 XXX_NoUnkeyedLiteral struct{} `json:"-"` 270 XXX_unrecognized []byte `json:"-"` 271 XXX_sizecache int32 `json:"-"` 272} 273 274func (m *ChannelConnectivityState) Reset() { *m = ChannelConnectivityState{} } 275func (m *ChannelConnectivityState) String() string { return proto.CompactTextString(m) } 276func (*ChannelConnectivityState) ProtoMessage() {} 277func (*ChannelConnectivityState) Descriptor() ([]byte, []int) { 278 return fileDescriptor_6ee37dfd35a8ab00, []int{2} 279} 280 281func (m *ChannelConnectivityState) XXX_Unmarshal(b []byte) error { 282 return xxx_messageInfo_ChannelConnectivityState.Unmarshal(m, b) 283} 284func (m *ChannelConnectivityState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 285 return xxx_messageInfo_ChannelConnectivityState.Marshal(b, m, deterministic) 286} 287func (m *ChannelConnectivityState) XXX_Merge(src proto.Message) { 288 xxx_messageInfo_ChannelConnectivityState.Merge(m, src) 289} 290func (m *ChannelConnectivityState) XXX_Size() int { 291 return xxx_messageInfo_ChannelConnectivityState.Size(m) 292} 293func (m *ChannelConnectivityState) XXX_DiscardUnknown() { 294 xxx_messageInfo_ChannelConnectivityState.DiscardUnknown(m) 295} 296 297var xxx_messageInfo_ChannelConnectivityState proto.InternalMessageInfo 298 299func (m *ChannelConnectivityState) GetState() ChannelConnectivityState_State { 300 if m != nil { 301 return m.State 302 } 303 return ChannelConnectivityState_UNKNOWN 304} 305 306// Channel data is data related to a specific Channel or Subchannel. 307type ChannelData struct { 308 // The connectivity state of the channel or subchannel. Implementations 309 // should always set this. 310 State *ChannelConnectivityState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"` 311 // The target this channel originally tried to connect to. May be absent 312 Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"` 313 // A trace of recent events on the channel. May be absent. 314 Trace *ChannelTrace `protobuf:"bytes,3,opt,name=trace,proto3" json:"trace,omitempty"` 315 // The number of calls started on the channel 316 CallsStarted int64 `protobuf:"varint,4,opt,name=calls_started,json=callsStarted,proto3" json:"calls_started,omitempty"` 317 // The number of calls that have completed with an OK status 318 CallsSucceeded int64 `protobuf:"varint,5,opt,name=calls_succeeded,json=callsSucceeded,proto3" json:"calls_succeeded,omitempty"` 319 // The number of calls that have completed with a non-OK status 320 CallsFailed int64 `protobuf:"varint,6,opt,name=calls_failed,json=callsFailed,proto3" json:"calls_failed,omitempty"` 321 // The last time a call was started on the channel. 322 LastCallStartedTimestamp *timestamp.Timestamp `protobuf:"bytes,7,opt,name=last_call_started_timestamp,json=lastCallStartedTimestamp,proto3" json:"last_call_started_timestamp,omitempty"` 323 XXX_NoUnkeyedLiteral struct{} `json:"-"` 324 XXX_unrecognized []byte `json:"-"` 325 XXX_sizecache int32 `json:"-"` 326} 327 328func (m *ChannelData) Reset() { *m = ChannelData{} } 329func (m *ChannelData) String() string { return proto.CompactTextString(m) } 330func (*ChannelData) ProtoMessage() {} 331func (*ChannelData) Descriptor() ([]byte, []int) { 332 return fileDescriptor_6ee37dfd35a8ab00, []int{3} 333} 334 335func (m *ChannelData) XXX_Unmarshal(b []byte) error { 336 return xxx_messageInfo_ChannelData.Unmarshal(m, b) 337} 338func (m *ChannelData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 339 return xxx_messageInfo_ChannelData.Marshal(b, m, deterministic) 340} 341func (m *ChannelData) XXX_Merge(src proto.Message) { 342 xxx_messageInfo_ChannelData.Merge(m, src) 343} 344func (m *ChannelData) XXX_Size() int { 345 return xxx_messageInfo_ChannelData.Size(m) 346} 347func (m *ChannelData) XXX_DiscardUnknown() { 348 xxx_messageInfo_ChannelData.DiscardUnknown(m) 349} 350 351var xxx_messageInfo_ChannelData proto.InternalMessageInfo 352 353func (m *ChannelData) GetState() *ChannelConnectivityState { 354 if m != nil { 355 return m.State 356 } 357 return nil 358} 359 360func (m *ChannelData) GetTarget() string { 361 if m != nil { 362 return m.Target 363 } 364 return "" 365} 366 367func (m *ChannelData) GetTrace() *ChannelTrace { 368 if m != nil { 369 return m.Trace 370 } 371 return nil 372} 373 374func (m *ChannelData) GetCallsStarted() int64 { 375 if m != nil { 376 return m.CallsStarted 377 } 378 return 0 379} 380 381func (m *ChannelData) GetCallsSucceeded() int64 { 382 if m != nil { 383 return m.CallsSucceeded 384 } 385 return 0 386} 387 388func (m *ChannelData) GetCallsFailed() int64 { 389 if m != nil { 390 return m.CallsFailed 391 } 392 return 0 393} 394 395func (m *ChannelData) GetLastCallStartedTimestamp() *timestamp.Timestamp { 396 if m != nil { 397 return m.LastCallStartedTimestamp 398 } 399 return nil 400} 401 402// A trace event is an interesting thing that happened to a channel or 403// subchannel, such as creation, address resolution, subchannel creation, etc. 404type ChannelTraceEvent struct { 405 // High level description of the event. 406 Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"` 407 // the severity of the trace event 408 Severity ChannelTraceEvent_Severity `protobuf:"varint,2,opt,name=severity,proto3,enum=grpc.channelz.v1.ChannelTraceEvent_Severity" json:"severity,omitempty"` 409 // When this event occurred. 410 Timestamp *timestamp.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` 411 // ref of referenced channel or subchannel. 412 // Optional, only present if this event refers to a child object. For example, 413 // this field would be filled if this trace event was for a subchannel being 414 // created. 415 // 416 // Types that are valid to be assigned to ChildRef: 417 // *ChannelTraceEvent_ChannelRef 418 // *ChannelTraceEvent_SubchannelRef 419 ChildRef isChannelTraceEvent_ChildRef `protobuf_oneof:"child_ref"` 420 XXX_NoUnkeyedLiteral struct{} `json:"-"` 421 XXX_unrecognized []byte `json:"-"` 422 XXX_sizecache int32 `json:"-"` 423} 424 425func (m *ChannelTraceEvent) Reset() { *m = ChannelTraceEvent{} } 426func (m *ChannelTraceEvent) String() string { return proto.CompactTextString(m) } 427func (*ChannelTraceEvent) ProtoMessage() {} 428func (*ChannelTraceEvent) Descriptor() ([]byte, []int) { 429 return fileDescriptor_6ee37dfd35a8ab00, []int{4} 430} 431 432func (m *ChannelTraceEvent) XXX_Unmarshal(b []byte) error { 433 return xxx_messageInfo_ChannelTraceEvent.Unmarshal(m, b) 434} 435func (m *ChannelTraceEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 436 return xxx_messageInfo_ChannelTraceEvent.Marshal(b, m, deterministic) 437} 438func (m *ChannelTraceEvent) XXX_Merge(src proto.Message) { 439 xxx_messageInfo_ChannelTraceEvent.Merge(m, src) 440} 441func (m *ChannelTraceEvent) XXX_Size() int { 442 return xxx_messageInfo_ChannelTraceEvent.Size(m) 443} 444func (m *ChannelTraceEvent) XXX_DiscardUnknown() { 445 xxx_messageInfo_ChannelTraceEvent.DiscardUnknown(m) 446} 447 448var xxx_messageInfo_ChannelTraceEvent proto.InternalMessageInfo 449 450func (m *ChannelTraceEvent) GetDescription() string { 451 if m != nil { 452 return m.Description 453 } 454 return "" 455} 456 457func (m *ChannelTraceEvent) GetSeverity() ChannelTraceEvent_Severity { 458 if m != nil { 459 return m.Severity 460 } 461 return ChannelTraceEvent_CT_UNKNOWN 462} 463 464func (m *ChannelTraceEvent) GetTimestamp() *timestamp.Timestamp { 465 if m != nil { 466 return m.Timestamp 467 } 468 return nil 469} 470 471type isChannelTraceEvent_ChildRef interface { 472 isChannelTraceEvent_ChildRef() 473} 474 475type ChannelTraceEvent_ChannelRef struct { 476 ChannelRef *ChannelRef `protobuf:"bytes,4,opt,name=channel_ref,json=channelRef,proto3,oneof"` 477} 478 479type ChannelTraceEvent_SubchannelRef struct { 480 SubchannelRef *SubchannelRef `protobuf:"bytes,5,opt,name=subchannel_ref,json=subchannelRef,proto3,oneof"` 481} 482 483func (*ChannelTraceEvent_ChannelRef) isChannelTraceEvent_ChildRef() {} 484 485func (*ChannelTraceEvent_SubchannelRef) isChannelTraceEvent_ChildRef() {} 486 487func (m *ChannelTraceEvent) GetChildRef() isChannelTraceEvent_ChildRef { 488 if m != nil { 489 return m.ChildRef 490 } 491 return nil 492} 493 494func (m *ChannelTraceEvent) GetChannelRef() *ChannelRef { 495 if x, ok := m.GetChildRef().(*ChannelTraceEvent_ChannelRef); ok { 496 return x.ChannelRef 497 } 498 return nil 499} 500 501func (m *ChannelTraceEvent) GetSubchannelRef() *SubchannelRef { 502 if x, ok := m.GetChildRef().(*ChannelTraceEvent_SubchannelRef); ok { 503 return x.SubchannelRef 504 } 505 return nil 506} 507 508// XXX_OneofWrappers is for the internal use of the proto package. 509func (*ChannelTraceEvent) XXX_OneofWrappers() []interface{} { 510 return []interface{}{ 511 (*ChannelTraceEvent_ChannelRef)(nil), 512 (*ChannelTraceEvent_SubchannelRef)(nil), 513 } 514} 515 516// ChannelTrace represents the recent events that have occurred on the channel. 517type ChannelTrace struct { 518 // Number of events ever logged in this tracing object. This can differ from 519 // events.size() because events can be overwritten or garbage collected by 520 // implementations. 521 NumEventsLogged int64 `protobuf:"varint,1,opt,name=num_events_logged,json=numEventsLogged,proto3" json:"num_events_logged,omitempty"` 522 // Time that this channel was created. 523 CreationTimestamp *timestamp.Timestamp `protobuf:"bytes,2,opt,name=creation_timestamp,json=creationTimestamp,proto3" json:"creation_timestamp,omitempty"` 524 // List of events that have occurred on this channel. 525 Events []*ChannelTraceEvent `protobuf:"bytes,3,rep,name=events,proto3" json:"events,omitempty"` 526 XXX_NoUnkeyedLiteral struct{} `json:"-"` 527 XXX_unrecognized []byte `json:"-"` 528 XXX_sizecache int32 `json:"-"` 529} 530 531func (m *ChannelTrace) Reset() { *m = ChannelTrace{} } 532func (m *ChannelTrace) String() string { return proto.CompactTextString(m) } 533func (*ChannelTrace) ProtoMessage() {} 534func (*ChannelTrace) Descriptor() ([]byte, []int) { 535 return fileDescriptor_6ee37dfd35a8ab00, []int{5} 536} 537 538func (m *ChannelTrace) XXX_Unmarshal(b []byte) error { 539 return xxx_messageInfo_ChannelTrace.Unmarshal(m, b) 540} 541func (m *ChannelTrace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 542 return xxx_messageInfo_ChannelTrace.Marshal(b, m, deterministic) 543} 544func (m *ChannelTrace) XXX_Merge(src proto.Message) { 545 xxx_messageInfo_ChannelTrace.Merge(m, src) 546} 547func (m *ChannelTrace) XXX_Size() int { 548 return xxx_messageInfo_ChannelTrace.Size(m) 549} 550func (m *ChannelTrace) XXX_DiscardUnknown() { 551 xxx_messageInfo_ChannelTrace.DiscardUnknown(m) 552} 553 554var xxx_messageInfo_ChannelTrace proto.InternalMessageInfo 555 556func (m *ChannelTrace) GetNumEventsLogged() int64 { 557 if m != nil { 558 return m.NumEventsLogged 559 } 560 return 0 561} 562 563func (m *ChannelTrace) GetCreationTimestamp() *timestamp.Timestamp { 564 if m != nil { 565 return m.CreationTimestamp 566 } 567 return nil 568} 569 570func (m *ChannelTrace) GetEvents() []*ChannelTraceEvent { 571 if m != nil { 572 return m.Events 573 } 574 return nil 575} 576 577// ChannelRef is a reference to a Channel. 578type ChannelRef struct { 579 // The globally unique id for this channel. Must be a positive number. 580 ChannelId int64 `protobuf:"varint,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` 581 // An optional name associated with the channel. 582 Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` 583 XXX_NoUnkeyedLiteral struct{} `json:"-"` 584 XXX_unrecognized []byte `json:"-"` 585 XXX_sizecache int32 `json:"-"` 586} 587 588func (m *ChannelRef) Reset() { *m = ChannelRef{} } 589func (m *ChannelRef) String() string { return proto.CompactTextString(m) } 590func (*ChannelRef) ProtoMessage() {} 591func (*ChannelRef) Descriptor() ([]byte, []int) { 592 return fileDescriptor_6ee37dfd35a8ab00, []int{6} 593} 594 595func (m *ChannelRef) XXX_Unmarshal(b []byte) error { 596 return xxx_messageInfo_ChannelRef.Unmarshal(m, b) 597} 598func (m *ChannelRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 599 return xxx_messageInfo_ChannelRef.Marshal(b, m, deterministic) 600} 601func (m *ChannelRef) XXX_Merge(src proto.Message) { 602 xxx_messageInfo_ChannelRef.Merge(m, src) 603} 604func (m *ChannelRef) XXX_Size() int { 605 return xxx_messageInfo_ChannelRef.Size(m) 606} 607func (m *ChannelRef) XXX_DiscardUnknown() { 608 xxx_messageInfo_ChannelRef.DiscardUnknown(m) 609} 610 611var xxx_messageInfo_ChannelRef proto.InternalMessageInfo 612 613func (m *ChannelRef) GetChannelId() int64 { 614 if m != nil { 615 return m.ChannelId 616 } 617 return 0 618} 619 620func (m *ChannelRef) GetName() string { 621 if m != nil { 622 return m.Name 623 } 624 return "" 625} 626 627// SubchannelRef is a reference to a Subchannel. 628type SubchannelRef struct { 629 // The globally unique id for this subchannel. Must be a positive number. 630 SubchannelId int64 `protobuf:"varint,7,opt,name=subchannel_id,json=subchannelId,proto3" json:"subchannel_id,omitempty"` 631 // An optional name associated with the subchannel. 632 Name string `protobuf:"bytes,8,opt,name=name,proto3" json:"name,omitempty"` 633 XXX_NoUnkeyedLiteral struct{} `json:"-"` 634 XXX_unrecognized []byte `json:"-"` 635 XXX_sizecache int32 `json:"-"` 636} 637 638func (m *SubchannelRef) Reset() { *m = SubchannelRef{} } 639func (m *SubchannelRef) String() string { return proto.CompactTextString(m) } 640func (*SubchannelRef) ProtoMessage() {} 641func (*SubchannelRef) Descriptor() ([]byte, []int) { 642 return fileDescriptor_6ee37dfd35a8ab00, []int{7} 643} 644 645func (m *SubchannelRef) XXX_Unmarshal(b []byte) error { 646 return xxx_messageInfo_SubchannelRef.Unmarshal(m, b) 647} 648func (m *SubchannelRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 649 return xxx_messageInfo_SubchannelRef.Marshal(b, m, deterministic) 650} 651func (m *SubchannelRef) XXX_Merge(src proto.Message) { 652 xxx_messageInfo_SubchannelRef.Merge(m, src) 653} 654func (m *SubchannelRef) XXX_Size() int { 655 return xxx_messageInfo_SubchannelRef.Size(m) 656} 657func (m *SubchannelRef) XXX_DiscardUnknown() { 658 xxx_messageInfo_SubchannelRef.DiscardUnknown(m) 659} 660 661var xxx_messageInfo_SubchannelRef proto.InternalMessageInfo 662 663func (m *SubchannelRef) GetSubchannelId() int64 { 664 if m != nil { 665 return m.SubchannelId 666 } 667 return 0 668} 669 670func (m *SubchannelRef) GetName() string { 671 if m != nil { 672 return m.Name 673 } 674 return "" 675} 676 677// SocketRef is a reference to a Socket. 678type SocketRef struct { 679 // The globally unique id for this socket. Must be a positive number. 680 SocketId int64 `protobuf:"varint,3,opt,name=socket_id,json=socketId,proto3" json:"socket_id,omitempty"` 681 // An optional name associated with the socket. 682 Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` 683 XXX_NoUnkeyedLiteral struct{} `json:"-"` 684 XXX_unrecognized []byte `json:"-"` 685 XXX_sizecache int32 `json:"-"` 686} 687 688func (m *SocketRef) Reset() { *m = SocketRef{} } 689func (m *SocketRef) String() string { return proto.CompactTextString(m) } 690func (*SocketRef) ProtoMessage() {} 691func (*SocketRef) Descriptor() ([]byte, []int) { 692 return fileDescriptor_6ee37dfd35a8ab00, []int{8} 693} 694 695func (m *SocketRef) XXX_Unmarshal(b []byte) error { 696 return xxx_messageInfo_SocketRef.Unmarshal(m, b) 697} 698func (m *SocketRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 699 return xxx_messageInfo_SocketRef.Marshal(b, m, deterministic) 700} 701func (m *SocketRef) XXX_Merge(src proto.Message) { 702 xxx_messageInfo_SocketRef.Merge(m, src) 703} 704func (m *SocketRef) XXX_Size() int { 705 return xxx_messageInfo_SocketRef.Size(m) 706} 707func (m *SocketRef) XXX_DiscardUnknown() { 708 xxx_messageInfo_SocketRef.DiscardUnknown(m) 709} 710 711var xxx_messageInfo_SocketRef proto.InternalMessageInfo 712 713func (m *SocketRef) GetSocketId() int64 { 714 if m != nil { 715 return m.SocketId 716 } 717 return 0 718} 719 720func (m *SocketRef) GetName() string { 721 if m != nil { 722 return m.Name 723 } 724 return "" 725} 726 727// ServerRef is a reference to a Server. 728type ServerRef struct { 729 // A globally unique identifier for this server. Must be a positive number. 730 ServerId int64 `protobuf:"varint,5,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"` 731 // An optional name associated with the server. 732 Name string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"` 733 XXX_NoUnkeyedLiteral struct{} `json:"-"` 734 XXX_unrecognized []byte `json:"-"` 735 XXX_sizecache int32 `json:"-"` 736} 737 738func (m *ServerRef) Reset() { *m = ServerRef{} } 739func (m *ServerRef) String() string { return proto.CompactTextString(m) } 740func (*ServerRef) ProtoMessage() {} 741func (*ServerRef) Descriptor() ([]byte, []int) { 742 return fileDescriptor_6ee37dfd35a8ab00, []int{9} 743} 744 745func (m *ServerRef) XXX_Unmarshal(b []byte) error { 746 return xxx_messageInfo_ServerRef.Unmarshal(m, b) 747} 748func (m *ServerRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 749 return xxx_messageInfo_ServerRef.Marshal(b, m, deterministic) 750} 751func (m *ServerRef) XXX_Merge(src proto.Message) { 752 xxx_messageInfo_ServerRef.Merge(m, src) 753} 754func (m *ServerRef) XXX_Size() int { 755 return xxx_messageInfo_ServerRef.Size(m) 756} 757func (m *ServerRef) XXX_DiscardUnknown() { 758 xxx_messageInfo_ServerRef.DiscardUnknown(m) 759} 760 761var xxx_messageInfo_ServerRef proto.InternalMessageInfo 762 763func (m *ServerRef) GetServerId() int64 { 764 if m != nil { 765 return m.ServerId 766 } 767 return 0 768} 769 770func (m *ServerRef) GetName() string { 771 if m != nil { 772 return m.Name 773 } 774 return "" 775} 776 777// Server represents a single server. There may be multiple servers in a single 778// program. 779type Server struct { 780 // The identifier for a Server. This should be set. 781 Ref *ServerRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"` 782 // The associated data of the Server. 783 Data *ServerData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` 784 // The sockets that the server is listening on. There are no ordering 785 // guarantees. This may be absent. 786 ListenSocket []*SocketRef `protobuf:"bytes,3,rep,name=listen_socket,json=listenSocket,proto3" json:"listen_socket,omitempty"` 787 XXX_NoUnkeyedLiteral struct{} `json:"-"` 788 XXX_unrecognized []byte `json:"-"` 789 XXX_sizecache int32 `json:"-"` 790} 791 792func (m *Server) Reset() { *m = Server{} } 793func (m *Server) String() string { return proto.CompactTextString(m) } 794func (*Server) ProtoMessage() {} 795func (*Server) Descriptor() ([]byte, []int) { 796 return fileDescriptor_6ee37dfd35a8ab00, []int{10} 797} 798 799func (m *Server) XXX_Unmarshal(b []byte) error { 800 return xxx_messageInfo_Server.Unmarshal(m, b) 801} 802func (m *Server) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 803 return xxx_messageInfo_Server.Marshal(b, m, deterministic) 804} 805func (m *Server) XXX_Merge(src proto.Message) { 806 xxx_messageInfo_Server.Merge(m, src) 807} 808func (m *Server) XXX_Size() int { 809 return xxx_messageInfo_Server.Size(m) 810} 811func (m *Server) XXX_DiscardUnknown() { 812 xxx_messageInfo_Server.DiscardUnknown(m) 813} 814 815var xxx_messageInfo_Server proto.InternalMessageInfo 816 817func (m *Server) GetRef() *ServerRef { 818 if m != nil { 819 return m.Ref 820 } 821 return nil 822} 823 824func (m *Server) GetData() *ServerData { 825 if m != nil { 826 return m.Data 827 } 828 return nil 829} 830 831func (m *Server) GetListenSocket() []*SocketRef { 832 if m != nil { 833 return m.ListenSocket 834 } 835 return nil 836} 837 838// ServerData is data for a specific Server. 839type ServerData struct { 840 // A trace of recent events on the server. May be absent. 841 Trace *ChannelTrace `protobuf:"bytes,1,opt,name=trace,proto3" json:"trace,omitempty"` 842 // The number of incoming calls started on the server 843 CallsStarted int64 `protobuf:"varint,2,opt,name=calls_started,json=callsStarted,proto3" json:"calls_started,omitempty"` 844 // The number of incoming calls that have completed with an OK status 845 CallsSucceeded int64 `protobuf:"varint,3,opt,name=calls_succeeded,json=callsSucceeded,proto3" json:"calls_succeeded,omitempty"` 846 // The number of incoming calls that have a completed with a non-OK status 847 CallsFailed int64 `protobuf:"varint,4,opt,name=calls_failed,json=callsFailed,proto3" json:"calls_failed,omitempty"` 848 // The last time a call was started on the server. 849 LastCallStartedTimestamp *timestamp.Timestamp `protobuf:"bytes,5,opt,name=last_call_started_timestamp,json=lastCallStartedTimestamp,proto3" json:"last_call_started_timestamp,omitempty"` 850 XXX_NoUnkeyedLiteral struct{} `json:"-"` 851 XXX_unrecognized []byte `json:"-"` 852 XXX_sizecache int32 `json:"-"` 853} 854 855func (m *ServerData) Reset() { *m = ServerData{} } 856func (m *ServerData) String() string { return proto.CompactTextString(m) } 857func (*ServerData) ProtoMessage() {} 858func (*ServerData) Descriptor() ([]byte, []int) { 859 return fileDescriptor_6ee37dfd35a8ab00, []int{11} 860} 861 862func (m *ServerData) XXX_Unmarshal(b []byte) error { 863 return xxx_messageInfo_ServerData.Unmarshal(m, b) 864} 865func (m *ServerData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 866 return xxx_messageInfo_ServerData.Marshal(b, m, deterministic) 867} 868func (m *ServerData) XXX_Merge(src proto.Message) { 869 xxx_messageInfo_ServerData.Merge(m, src) 870} 871func (m *ServerData) XXX_Size() int { 872 return xxx_messageInfo_ServerData.Size(m) 873} 874func (m *ServerData) XXX_DiscardUnknown() { 875 xxx_messageInfo_ServerData.DiscardUnknown(m) 876} 877 878var xxx_messageInfo_ServerData proto.InternalMessageInfo 879 880func (m *ServerData) GetTrace() *ChannelTrace { 881 if m != nil { 882 return m.Trace 883 } 884 return nil 885} 886 887func (m *ServerData) GetCallsStarted() int64 { 888 if m != nil { 889 return m.CallsStarted 890 } 891 return 0 892} 893 894func (m *ServerData) GetCallsSucceeded() int64 { 895 if m != nil { 896 return m.CallsSucceeded 897 } 898 return 0 899} 900 901func (m *ServerData) GetCallsFailed() int64 { 902 if m != nil { 903 return m.CallsFailed 904 } 905 return 0 906} 907 908func (m *ServerData) GetLastCallStartedTimestamp() *timestamp.Timestamp { 909 if m != nil { 910 return m.LastCallStartedTimestamp 911 } 912 return nil 913} 914 915// Information about an actual connection. Pronounced "sock-ay". 916type Socket struct { 917 // The identifier for the Socket. 918 Ref *SocketRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"` 919 // Data specific to this Socket. 920 Data *SocketData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` 921 // The locally bound address. 922 Local *Address `protobuf:"bytes,3,opt,name=local,proto3" json:"local,omitempty"` 923 // The remote bound address. May be absent. 924 Remote *Address `protobuf:"bytes,4,opt,name=remote,proto3" json:"remote,omitempty"` 925 // Security details for this socket. May be absent if not available, or 926 // there is no security on the socket. 927 Security *Security `protobuf:"bytes,5,opt,name=security,proto3" json:"security,omitempty"` 928 // Optional, represents the name of the remote endpoint, if different than 929 // the original target name. 930 RemoteName string `protobuf:"bytes,6,opt,name=remote_name,json=remoteName,proto3" json:"remote_name,omitempty"` 931 XXX_NoUnkeyedLiteral struct{} `json:"-"` 932 XXX_unrecognized []byte `json:"-"` 933 XXX_sizecache int32 `json:"-"` 934} 935 936func (m *Socket) Reset() { *m = Socket{} } 937func (m *Socket) String() string { return proto.CompactTextString(m) } 938func (*Socket) ProtoMessage() {} 939func (*Socket) Descriptor() ([]byte, []int) { 940 return fileDescriptor_6ee37dfd35a8ab00, []int{12} 941} 942 943func (m *Socket) XXX_Unmarshal(b []byte) error { 944 return xxx_messageInfo_Socket.Unmarshal(m, b) 945} 946func (m *Socket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 947 return xxx_messageInfo_Socket.Marshal(b, m, deterministic) 948} 949func (m *Socket) XXX_Merge(src proto.Message) { 950 xxx_messageInfo_Socket.Merge(m, src) 951} 952func (m *Socket) XXX_Size() int { 953 return xxx_messageInfo_Socket.Size(m) 954} 955func (m *Socket) XXX_DiscardUnknown() { 956 xxx_messageInfo_Socket.DiscardUnknown(m) 957} 958 959var xxx_messageInfo_Socket proto.InternalMessageInfo 960 961func (m *Socket) GetRef() *SocketRef { 962 if m != nil { 963 return m.Ref 964 } 965 return nil 966} 967 968func (m *Socket) GetData() *SocketData { 969 if m != nil { 970 return m.Data 971 } 972 return nil 973} 974 975func (m *Socket) GetLocal() *Address { 976 if m != nil { 977 return m.Local 978 } 979 return nil 980} 981 982func (m *Socket) GetRemote() *Address { 983 if m != nil { 984 return m.Remote 985 } 986 return nil 987} 988 989func (m *Socket) GetSecurity() *Security { 990 if m != nil { 991 return m.Security 992 } 993 return nil 994} 995 996func (m *Socket) GetRemoteName() string { 997 if m != nil { 998 return m.RemoteName 999 } 1000 return "" 1001} 1002 1003// SocketData is data associated for a specific Socket. The fields present 1004// are specific to the implementation, so there may be minor differences in 1005// the semantics. (e.g. flow control windows) 1006type SocketData struct { 1007 // The number of streams that have been started. 1008 StreamsStarted int64 `protobuf:"varint,1,opt,name=streams_started,json=streamsStarted,proto3" json:"streams_started,omitempty"` 1009 // The number of streams that have ended successfully: 1010 // On client side, received frame with eos bit set; 1011 // On server side, sent frame with eos bit set. 1012 StreamsSucceeded int64 `protobuf:"varint,2,opt,name=streams_succeeded,json=streamsSucceeded,proto3" json:"streams_succeeded,omitempty"` 1013 // The number of streams that have ended unsuccessfully: 1014 // On client side, ended without receiving frame with eos bit set; 1015 // On server side, ended without sending frame with eos bit set. 1016 StreamsFailed int64 `protobuf:"varint,3,opt,name=streams_failed,json=streamsFailed,proto3" json:"streams_failed,omitempty"` 1017 // The number of grpc messages successfully sent on this socket. 1018 MessagesSent int64 `protobuf:"varint,4,opt,name=messages_sent,json=messagesSent,proto3" json:"messages_sent,omitempty"` 1019 // The number of grpc messages received on this socket. 1020 MessagesReceived int64 `protobuf:"varint,5,opt,name=messages_received,json=messagesReceived,proto3" json:"messages_received,omitempty"` 1021 // The number of keep alives sent. This is typically implemented with HTTP/2 1022 // ping messages. 1023 KeepAlivesSent int64 `protobuf:"varint,6,opt,name=keep_alives_sent,json=keepAlivesSent,proto3" json:"keep_alives_sent,omitempty"` 1024 // The last time a stream was created by this endpoint. Usually unset for 1025 // servers. 1026 LastLocalStreamCreatedTimestamp *timestamp.Timestamp `protobuf:"bytes,7,opt,name=last_local_stream_created_timestamp,json=lastLocalStreamCreatedTimestamp,proto3" json:"last_local_stream_created_timestamp,omitempty"` 1027 // The last time a stream was created by the remote endpoint. Usually unset 1028 // for clients. 1029 LastRemoteStreamCreatedTimestamp *timestamp.Timestamp `protobuf:"bytes,8,opt,name=last_remote_stream_created_timestamp,json=lastRemoteStreamCreatedTimestamp,proto3" json:"last_remote_stream_created_timestamp,omitempty"` 1030 // The last time a message was sent by this endpoint. 1031 LastMessageSentTimestamp *timestamp.Timestamp `protobuf:"bytes,9,opt,name=last_message_sent_timestamp,json=lastMessageSentTimestamp,proto3" json:"last_message_sent_timestamp,omitempty"` 1032 // The last time a message was received by this endpoint. 1033 LastMessageReceivedTimestamp *timestamp.Timestamp `protobuf:"bytes,10,opt,name=last_message_received_timestamp,json=lastMessageReceivedTimestamp,proto3" json:"last_message_received_timestamp,omitempty"` 1034 // The amount of window, granted to the local endpoint by the remote endpoint. 1035 // This may be slightly out of date due to network latency. This does NOT 1036 // include stream level or TCP level flow control info. 1037 LocalFlowControlWindow *wrappers.Int64Value `protobuf:"bytes,11,opt,name=local_flow_control_window,json=localFlowControlWindow,proto3" json:"local_flow_control_window,omitempty"` 1038 // The amount of window, granted to the remote endpoint by the local endpoint. 1039 // This may be slightly out of date due to network latency. This does NOT 1040 // include stream level or TCP level flow control info. 1041 RemoteFlowControlWindow *wrappers.Int64Value `protobuf:"bytes,12,opt,name=remote_flow_control_window,json=remoteFlowControlWindow,proto3" json:"remote_flow_control_window,omitempty"` 1042 // Socket options set on this socket. May be absent if 'summary' is set 1043 // on GetSocketRequest. 1044 Option []*SocketOption `protobuf:"bytes,13,rep,name=option,proto3" json:"option,omitempty"` 1045 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1046 XXX_unrecognized []byte `json:"-"` 1047 XXX_sizecache int32 `json:"-"` 1048} 1049 1050func (m *SocketData) Reset() { *m = SocketData{} } 1051func (m *SocketData) String() string { return proto.CompactTextString(m) } 1052func (*SocketData) ProtoMessage() {} 1053func (*SocketData) Descriptor() ([]byte, []int) { 1054 return fileDescriptor_6ee37dfd35a8ab00, []int{13} 1055} 1056 1057func (m *SocketData) XXX_Unmarshal(b []byte) error { 1058 return xxx_messageInfo_SocketData.Unmarshal(m, b) 1059} 1060func (m *SocketData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1061 return xxx_messageInfo_SocketData.Marshal(b, m, deterministic) 1062} 1063func (m *SocketData) XXX_Merge(src proto.Message) { 1064 xxx_messageInfo_SocketData.Merge(m, src) 1065} 1066func (m *SocketData) XXX_Size() int { 1067 return xxx_messageInfo_SocketData.Size(m) 1068} 1069func (m *SocketData) XXX_DiscardUnknown() { 1070 xxx_messageInfo_SocketData.DiscardUnknown(m) 1071} 1072 1073var xxx_messageInfo_SocketData proto.InternalMessageInfo 1074 1075func (m *SocketData) GetStreamsStarted() int64 { 1076 if m != nil { 1077 return m.StreamsStarted 1078 } 1079 return 0 1080} 1081 1082func (m *SocketData) GetStreamsSucceeded() int64 { 1083 if m != nil { 1084 return m.StreamsSucceeded 1085 } 1086 return 0 1087} 1088 1089func (m *SocketData) GetStreamsFailed() int64 { 1090 if m != nil { 1091 return m.StreamsFailed 1092 } 1093 return 0 1094} 1095 1096func (m *SocketData) GetMessagesSent() int64 { 1097 if m != nil { 1098 return m.MessagesSent 1099 } 1100 return 0 1101} 1102 1103func (m *SocketData) GetMessagesReceived() int64 { 1104 if m != nil { 1105 return m.MessagesReceived 1106 } 1107 return 0 1108} 1109 1110func (m *SocketData) GetKeepAlivesSent() int64 { 1111 if m != nil { 1112 return m.KeepAlivesSent 1113 } 1114 return 0 1115} 1116 1117func (m *SocketData) GetLastLocalStreamCreatedTimestamp() *timestamp.Timestamp { 1118 if m != nil { 1119 return m.LastLocalStreamCreatedTimestamp 1120 } 1121 return nil 1122} 1123 1124func (m *SocketData) GetLastRemoteStreamCreatedTimestamp() *timestamp.Timestamp { 1125 if m != nil { 1126 return m.LastRemoteStreamCreatedTimestamp 1127 } 1128 return nil 1129} 1130 1131func (m *SocketData) GetLastMessageSentTimestamp() *timestamp.Timestamp { 1132 if m != nil { 1133 return m.LastMessageSentTimestamp 1134 } 1135 return nil 1136} 1137 1138func (m *SocketData) GetLastMessageReceivedTimestamp() *timestamp.Timestamp { 1139 if m != nil { 1140 return m.LastMessageReceivedTimestamp 1141 } 1142 return nil 1143} 1144 1145func (m *SocketData) GetLocalFlowControlWindow() *wrappers.Int64Value { 1146 if m != nil { 1147 return m.LocalFlowControlWindow 1148 } 1149 return nil 1150} 1151 1152func (m *SocketData) GetRemoteFlowControlWindow() *wrappers.Int64Value { 1153 if m != nil { 1154 return m.RemoteFlowControlWindow 1155 } 1156 return nil 1157} 1158 1159func (m *SocketData) GetOption() []*SocketOption { 1160 if m != nil { 1161 return m.Option 1162 } 1163 return nil 1164} 1165 1166// Address represents the address used to create the socket. 1167type Address struct { 1168 // Types that are valid to be assigned to Address: 1169 // *Address_TcpipAddress 1170 // *Address_UdsAddress_ 1171 // *Address_OtherAddress_ 1172 Address isAddress_Address `protobuf_oneof:"address"` 1173 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1174 XXX_unrecognized []byte `json:"-"` 1175 XXX_sizecache int32 `json:"-"` 1176} 1177 1178func (m *Address) Reset() { *m = Address{} } 1179func (m *Address) String() string { return proto.CompactTextString(m) } 1180func (*Address) ProtoMessage() {} 1181func (*Address) Descriptor() ([]byte, []int) { 1182 return fileDescriptor_6ee37dfd35a8ab00, []int{14} 1183} 1184 1185func (m *Address) XXX_Unmarshal(b []byte) error { 1186 return xxx_messageInfo_Address.Unmarshal(m, b) 1187} 1188func (m *Address) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1189 return xxx_messageInfo_Address.Marshal(b, m, deterministic) 1190} 1191func (m *Address) XXX_Merge(src proto.Message) { 1192 xxx_messageInfo_Address.Merge(m, src) 1193} 1194func (m *Address) XXX_Size() int { 1195 return xxx_messageInfo_Address.Size(m) 1196} 1197func (m *Address) XXX_DiscardUnknown() { 1198 xxx_messageInfo_Address.DiscardUnknown(m) 1199} 1200 1201var xxx_messageInfo_Address proto.InternalMessageInfo 1202 1203type isAddress_Address interface { 1204 isAddress_Address() 1205} 1206 1207type Address_TcpipAddress struct { 1208 TcpipAddress *Address_TcpIpAddress `protobuf:"bytes,1,opt,name=tcpip_address,json=tcpipAddress,proto3,oneof"` 1209} 1210 1211type Address_UdsAddress_ struct { 1212 UdsAddress *Address_UdsAddress `protobuf:"bytes,2,opt,name=uds_address,json=udsAddress,proto3,oneof"` 1213} 1214 1215type Address_OtherAddress_ struct { 1216 OtherAddress *Address_OtherAddress `protobuf:"bytes,3,opt,name=other_address,json=otherAddress,proto3,oneof"` 1217} 1218 1219func (*Address_TcpipAddress) isAddress_Address() {} 1220 1221func (*Address_UdsAddress_) isAddress_Address() {} 1222 1223func (*Address_OtherAddress_) isAddress_Address() {} 1224 1225func (m *Address) GetAddress() isAddress_Address { 1226 if m != nil { 1227 return m.Address 1228 } 1229 return nil 1230} 1231 1232func (m *Address) GetTcpipAddress() *Address_TcpIpAddress { 1233 if x, ok := m.GetAddress().(*Address_TcpipAddress); ok { 1234 return x.TcpipAddress 1235 } 1236 return nil 1237} 1238 1239func (m *Address) GetUdsAddress() *Address_UdsAddress { 1240 if x, ok := m.GetAddress().(*Address_UdsAddress_); ok { 1241 return x.UdsAddress 1242 } 1243 return nil 1244} 1245 1246func (m *Address) GetOtherAddress() *Address_OtherAddress { 1247 if x, ok := m.GetAddress().(*Address_OtherAddress_); ok { 1248 return x.OtherAddress 1249 } 1250 return nil 1251} 1252 1253// XXX_OneofWrappers is for the internal use of the proto package. 1254func (*Address) XXX_OneofWrappers() []interface{} { 1255 return []interface{}{ 1256 (*Address_TcpipAddress)(nil), 1257 (*Address_UdsAddress_)(nil), 1258 (*Address_OtherAddress_)(nil), 1259 } 1260} 1261 1262type Address_TcpIpAddress struct { 1263 // Either the IPv4 or IPv6 address in bytes. Will be either 4 bytes or 16 1264 // bytes in length. 1265 IpAddress []byte `protobuf:"bytes,1,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"` 1266 // 0-64k, or -1 if not appropriate. 1267 Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` 1268 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1269 XXX_unrecognized []byte `json:"-"` 1270 XXX_sizecache int32 `json:"-"` 1271} 1272 1273func (m *Address_TcpIpAddress) Reset() { *m = Address_TcpIpAddress{} } 1274func (m *Address_TcpIpAddress) String() string { return proto.CompactTextString(m) } 1275func (*Address_TcpIpAddress) ProtoMessage() {} 1276func (*Address_TcpIpAddress) Descriptor() ([]byte, []int) { 1277 return fileDescriptor_6ee37dfd35a8ab00, []int{14, 0} 1278} 1279 1280func (m *Address_TcpIpAddress) XXX_Unmarshal(b []byte) error { 1281 return xxx_messageInfo_Address_TcpIpAddress.Unmarshal(m, b) 1282} 1283func (m *Address_TcpIpAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1284 return xxx_messageInfo_Address_TcpIpAddress.Marshal(b, m, deterministic) 1285} 1286func (m *Address_TcpIpAddress) XXX_Merge(src proto.Message) { 1287 xxx_messageInfo_Address_TcpIpAddress.Merge(m, src) 1288} 1289func (m *Address_TcpIpAddress) XXX_Size() int { 1290 return xxx_messageInfo_Address_TcpIpAddress.Size(m) 1291} 1292func (m *Address_TcpIpAddress) XXX_DiscardUnknown() { 1293 xxx_messageInfo_Address_TcpIpAddress.DiscardUnknown(m) 1294} 1295 1296var xxx_messageInfo_Address_TcpIpAddress proto.InternalMessageInfo 1297 1298func (m *Address_TcpIpAddress) GetIpAddress() []byte { 1299 if m != nil { 1300 return m.IpAddress 1301 } 1302 return nil 1303} 1304 1305func (m *Address_TcpIpAddress) GetPort() int32 { 1306 if m != nil { 1307 return m.Port 1308 } 1309 return 0 1310} 1311 1312// A Unix Domain Socket address. 1313type Address_UdsAddress struct { 1314 Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"` 1315 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1316 XXX_unrecognized []byte `json:"-"` 1317 XXX_sizecache int32 `json:"-"` 1318} 1319 1320func (m *Address_UdsAddress) Reset() { *m = Address_UdsAddress{} } 1321func (m *Address_UdsAddress) String() string { return proto.CompactTextString(m) } 1322func (*Address_UdsAddress) ProtoMessage() {} 1323func (*Address_UdsAddress) Descriptor() ([]byte, []int) { 1324 return fileDescriptor_6ee37dfd35a8ab00, []int{14, 1} 1325} 1326 1327func (m *Address_UdsAddress) XXX_Unmarshal(b []byte) error { 1328 return xxx_messageInfo_Address_UdsAddress.Unmarshal(m, b) 1329} 1330func (m *Address_UdsAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1331 return xxx_messageInfo_Address_UdsAddress.Marshal(b, m, deterministic) 1332} 1333func (m *Address_UdsAddress) XXX_Merge(src proto.Message) { 1334 xxx_messageInfo_Address_UdsAddress.Merge(m, src) 1335} 1336func (m *Address_UdsAddress) XXX_Size() int { 1337 return xxx_messageInfo_Address_UdsAddress.Size(m) 1338} 1339func (m *Address_UdsAddress) XXX_DiscardUnknown() { 1340 xxx_messageInfo_Address_UdsAddress.DiscardUnknown(m) 1341} 1342 1343var xxx_messageInfo_Address_UdsAddress proto.InternalMessageInfo 1344 1345func (m *Address_UdsAddress) GetFilename() string { 1346 if m != nil { 1347 return m.Filename 1348 } 1349 return "" 1350} 1351 1352// An address type not included above. 1353type Address_OtherAddress struct { 1354 // The human readable version of the value. This value should be set. 1355 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 1356 // The actual address message. 1357 Value *any.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` 1358 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1359 XXX_unrecognized []byte `json:"-"` 1360 XXX_sizecache int32 `json:"-"` 1361} 1362 1363func (m *Address_OtherAddress) Reset() { *m = Address_OtherAddress{} } 1364func (m *Address_OtherAddress) String() string { return proto.CompactTextString(m) } 1365func (*Address_OtherAddress) ProtoMessage() {} 1366func (*Address_OtherAddress) Descriptor() ([]byte, []int) { 1367 return fileDescriptor_6ee37dfd35a8ab00, []int{14, 2} 1368} 1369 1370func (m *Address_OtherAddress) XXX_Unmarshal(b []byte) error { 1371 return xxx_messageInfo_Address_OtherAddress.Unmarshal(m, b) 1372} 1373func (m *Address_OtherAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1374 return xxx_messageInfo_Address_OtherAddress.Marshal(b, m, deterministic) 1375} 1376func (m *Address_OtherAddress) XXX_Merge(src proto.Message) { 1377 xxx_messageInfo_Address_OtherAddress.Merge(m, src) 1378} 1379func (m *Address_OtherAddress) XXX_Size() int { 1380 return xxx_messageInfo_Address_OtherAddress.Size(m) 1381} 1382func (m *Address_OtherAddress) XXX_DiscardUnknown() { 1383 xxx_messageInfo_Address_OtherAddress.DiscardUnknown(m) 1384} 1385 1386var xxx_messageInfo_Address_OtherAddress proto.InternalMessageInfo 1387 1388func (m *Address_OtherAddress) GetName() string { 1389 if m != nil { 1390 return m.Name 1391 } 1392 return "" 1393} 1394 1395func (m *Address_OtherAddress) GetValue() *any.Any { 1396 if m != nil { 1397 return m.Value 1398 } 1399 return nil 1400} 1401 1402// Security represents details about how secure the socket is. 1403type Security struct { 1404 // Types that are valid to be assigned to Model: 1405 // *Security_Tls_ 1406 // *Security_Other 1407 Model isSecurity_Model `protobuf_oneof:"model"` 1408 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1409 XXX_unrecognized []byte `json:"-"` 1410 XXX_sizecache int32 `json:"-"` 1411} 1412 1413func (m *Security) Reset() { *m = Security{} } 1414func (m *Security) String() string { return proto.CompactTextString(m) } 1415func (*Security) ProtoMessage() {} 1416func (*Security) Descriptor() ([]byte, []int) { 1417 return fileDescriptor_6ee37dfd35a8ab00, []int{15} 1418} 1419 1420func (m *Security) XXX_Unmarshal(b []byte) error { 1421 return xxx_messageInfo_Security.Unmarshal(m, b) 1422} 1423func (m *Security) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1424 return xxx_messageInfo_Security.Marshal(b, m, deterministic) 1425} 1426func (m *Security) XXX_Merge(src proto.Message) { 1427 xxx_messageInfo_Security.Merge(m, src) 1428} 1429func (m *Security) XXX_Size() int { 1430 return xxx_messageInfo_Security.Size(m) 1431} 1432func (m *Security) XXX_DiscardUnknown() { 1433 xxx_messageInfo_Security.DiscardUnknown(m) 1434} 1435 1436var xxx_messageInfo_Security proto.InternalMessageInfo 1437 1438type isSecurity_Model interface { 1439 isSecurity_Model() 1440} 1441 1442type Security_Tls_ struct { 1443 Tls *Security_Tls `protobuf:"bytes,1,opt,name=tls,proto3,oneof"` 1444} 1445 1446type Security_Other struct { 1447 Other *Security_OtherSecurity `protobuf:"bytes,2,opt,name=other,proto3,oneof"` 1448} 1449 1450func (*Security_Tls_) isSecurity_Model() {} 1451 1452func (*Security_Other) isSecurity_Model() {} 1453 1454func (m *Security) GetModel() isSecurity_Model { 1455 if m != nil { 1456 return m.Model 1457 } 1458 return nil 1459} 1460 1461func (m *Security) GetTls() *Security_Tls { 1462 if x, ok := m.GetModel().(*Security_Tls_); ok { 1463 return x.Tls 1464 } 1465 return nil 1466} 1467 1468func (m *Security) GetOther() *Security_OtherSecurity { 1469 if x, ok := m.GetModel().(*Security_Other); ok { 1470 return x.Other 1471 } 1472 return nil 1473} 1474 1475// XXX_OneofWrappers is for the internal use of the proto package. 1476func (*Security) XXX_OneofWrappers() []interface{} { 1477 return []interface{}{ 1478 (*Security_Tls_)(nil), 1479 (*Security_Other)(nil), 1480 } 1481} 1482 1483type Security_Tls struct { 1484 // Types that are valid to be assigned to CipherSuite: 1485 // *Security_Tls_StandardName 1486 // *Security_Tls_OtherName 1487 CipherSuite isSecurity_Tls_CipherSuite `protobuf_oneof:"cipher_suite"` 1488 // the certificate used by this endpoint. 1489 LocalCertificate []byte `protobuf:"bytes,3,opt,name=local_certificate,json=localCertificate,proto3" json:"local_certificate,omitempty"` 1490 // the certificate used by the remote endpoint. 1491 RemoteCertificate []byte `protobuf:"bytes,4,opt,name=remote_certificate,json=remoteCertificate,proto3" json:"remote_certificate,omitempty"` 1492 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1493 XXX_unrecognized []byte `json:"-"` 1494 XXX_sizecache int32 `json:"-"` 1495} 1496 1497func (m *Security_Tls) Reset() { *m = Security_Tls{} } 1498func (m *Security_Tls) String() string { return proto.CompactTextString(m) } 1499func (*Security_Tls) ProtoMessage() {} 1500func (*Security_Tls) Descriptor() ([]byte, []int) { 1501 return fileDescriptor_6ee37dfd35a8ab00, []int{15, 0} 1502} 1503 1504func (m *Security_Tls) XXX_Unmarshal(b []byte) error { 1505 return xxx_messageInfo_Security_Tls.Unmarshal(m, b) 1506} 1507func (m *Security_Tls) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1508 return xxx_messageInfo_Security_Tls.Marshal(b, m, deterministic) 1509} 1510func (m *Security_Tls) XXX_Merge(src proto.Message) { 1511 xxx_messageInfo_Security_Tls.Merge(m, src) 1512} 1513func (m *Security_Tls) XXX_Size() int { 1514 return xxx_messageInfo_Security_Tls.Size(m) 1515} 1516func (m *Security_Tls) XXX_DiscardUnknown() { 1517 xxx_messageInfo_Security_Tls.DiscardUnknown(m) 1518} 1519 1520var xxx_messageInfo_Security_Tls proto.InternalMessageInfo 1521 1522type isSecurity_Tls_CipherSuite interface { 1523 isSecurity_Tls_CipherSuite() 1524} 1525 1526type Security_Tls_StandardName struct { 1527 StandardName string `protobuf:"bytes,1,opt,name=standard_name,json=standardName,proto3,oneof"` 1528} 1529 1530type Security_Tls_OtherName struct { 1531 OtherName string `protobuf:"bytes,2,opt,name=other_name,json=otherName,proto3,oneof"` 1532} 1533 1534func (*Security_Tls_StandardName) isSecurity_Tls_CipherSuite() {} 1535 1536func (*Security_Tls_OtherName) isSecurity_Tls_CipherSuite() {} 1537 1538func (m *Security_Tls) GetCipherSuite() isSecurity_Tls_CipherSuite { 1539 if m != nil { 1540 return m.CipherSuite 1541 } 1542 return nil 1543} 1544 1545func (m *Security_Tls) GetStandardName() string { 1546 if x, ok := m.GetCipherSuite().(*Security_Tls_StandardName); ok { 1547 return x.StandardName 1548 } 1549 return "" 1550} 1551 1552func (m *Security_Tls) GetOtherName() string { 1553 if x, ok := m.GetCipherSuite().(*Security_Tls_OtherName); ok { 1554 return x.OtherName 1555 } 1556 return "" 1557} 1558 1559func (m *Security_Tls) GetLocalCertificate() []byte { 1560 if m != nil { 1561 return m.LocalCertificate 1562 } 1563 return nil 1564} 1565 1566func (m *Security_Tls) GetRemoteCertificate() []byte { 1567 if m != nil { 1568 return m.RemoteCertificate 1569 } 1570 return nil 1571} 1572 1573// XXX_OneofWrappers is for the internal use of the proto package. 1574func (*Security_Tls) XXX_OneofWrappers() []interface{} { 1575 return []interface{}{ 1576 (*Security_Tls_StandardName)(nil), 1577 (*Security_Tls_OtherName)(nil), 1578 } 1579} 1580 1581type Security_OtherSecurity struct { 1582 // The human readable version of the value. 1583 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 1584 // The actual security details message. 1585 Value *any.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` 1586 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1587 XXX_unrecognized []byte `json:"-"` 1588 XXX_sizecache int32 `json:"-"` 1589} 1590 1591func (m *Security_OtherSecurity) Reset() { *m = Security_OtherSecurity{} } 1592func (m *Security_OtherSecurity) String() string { return proto.CompactTextString(m) } 1593func (*Security_OtherSecurity) ProtoMessage() {} 1594func (*Security_OtherSecurity) Descriptor() ([]byte, []int) { 1595 return fileDescriptor_6ee37dfd35a8ab00, []int{15, 1} 1596} 1597 1598func (m *Security_OtherSecurity) XXX_Unmarshal(b []byte) error { 1599 return xxx_messageInfo_Security_OtherSecurity.Unmarshal(m, b) 1600} 1601func (m *Security_OtherSecurity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1602 return xxx_messageInfo_Security_OtherSecurity.Marshal(b, m, deterministic) 1603} 1604func (m *Security_OtherSecurity) XXX_Merge(src proto.Message) { 1605 xxx_messageInfo_Security_OtherSecurity.Merge(m, src) 1606} 1607func (m *Security_OtherSecurity) XXX_Size() int { 1608 return xxx_messageInfo_Security_OtherSecurity.Size(m) 1609} 1610func (m *Security_OtherSecurity) XXX_DiscardUnknown() { 1611 xxx_messageInfo_Security_OtherSecurity.DiscardUnknown(m) 1612} 1613 1614var xxx_messageInfo_Security_OtherSecurity proto.InternalMessageInfo 1615 1616func (m *Security_OtherSecurity) GetName() string { 1617 if m != nil { 1618 return m.Name 1619 } 1620 return "" 1621} 1622 1623func (m *Security_OtherSecurity) GetValue() *any.Any { 1624 if m != nil { 1625 return m.Value 1626 } 1627 return nil 1628} 1629 1630// SocketOption represents socket options for a socket. Specifically, these 1631// are the options returned by getsockopt(). 1632type SocketOption struct { 1633 // The full name of the socket option. Typically this will be the upper case 1634 // name, such as "SO_REUSEPORT". 1635 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 1636 // The human readable value of this socket option. At least one of value or 1637 // additional will be set. 1638 Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` 1639 // Additional data associated with the socket option. At least one of value 1640 // or additional will be set. 1641 Additional *any.Any `protobuf:"bytes,3,opt,name=additional,proto3" json:"additional,omitempty"` 1642 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1643 XXX_unrecognized []byte `json:"-"` 1644 XXX_sizecache int32 `json:"-"` 1645} 1646 1647func (m *SocketOption) Reset() { *m = SocketOption{} } 1648func (m *SocketOption) String() string { return proto.CompactTextString(m) } 1649func (*SocketOption) ProtoMessage() {} 1650func (*SocketOption) Descriptor() ([]byte, []int) { 1651 return fileDescriptor_6ee37dfd35a8ab00, []int{16} 1652} 1653 1654func (m *SocketOption) XXX_Unmarshal(b []byte) error { 1655 return xxx_messageInfo_SocketOption.Unmarshal(m, b) 1656} 1657func (m *SocketOption) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1658 return xxx_messageInfo_SocketOption.Marshal(b, m, deterministic) 1659} 1660func (m *SocketOption) XXX_Merge(src proto.Message) { 1661 xxx_messageInfo_SocketOption.Merge(m, src) 1662} 1663func (m *SocketOption) XXX_Size() int { 1664 return xxx_messageInfo_SocketOption.Size(m) 1665} 1666func (m *SocketOption) XXX_DiscardUnknown() { 1667 xxx_messageInfo_SocketOption.DiscardUnknown(m) 1668} 1669 1670var xxx_messageInfo_SocketOption proto.InternalMessageInfo 1671 1672func (m *SocketOption) GetName() string { 1673 if m != nil { 1674 return m.Name 1675 } 1676 return "" 1677} 1678 1679func (m *SocketOption) GetValue() string { 1680 if m != nil { 1681 return m.Value 1682 } 1683 return "" 1684} 1685 1686func (m *SocketOption) GetAdditional() *any.Any { 1687 if m != nil { 1688 return m.Additional 1689 } 1690 return nil 1691} 1692 1693// For use with SocketOption's additional field. This is primarily used for 1694// SO_RCVTIMEO and SO_SNDTIMEO 1695type SocketOptionTimeout struct { 1696 Duration *duration.Duration `protobuf:"bytes,1,opt,name=duration,proto3" json:"duration,omitempty"` 1697 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1698 XXX_unrecognized []byte `json:"-"` 1699 XXX_sizecache int32 `json:"-"` 1700} 1701 1702func (m *SocketOptionTimeout) Reset() { *m = SocketOptionTimeout{} } 1703func (m *SocketOptionTimeout) String() string { return proto.CompactTextString(m) } 1704func (*SocketOptionTimeout) ProtoMessage() {} 1705func (*SocketOptionTimeout) Descriptor() ([]byte, []int) { 1706 return fileDescriptor_6ee37dfd35a8ab00, []int{17} 1707} 1708 1709func (m *SocketOptionTimeout) XXX_Unmarshal(b []byte) error { 1710 return xxx_messageInfo_SocketOptionTimeout.Unmarshal(m, b) 1711} 1712func (m *SocketOptionTimeout) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1713 return xxx_messageInfo_SocketOptionTimeout.Marshal(b, m, deterministic) 1714} 1715func (m *SocketOptionTimeout) XXX_Merge(src proto.Message) { 1716 xxx_messageInfo_SocketOptionTimeout.Merge(m, src) 1717} 1718func (m *SocketOptionTimeout) XXX_Size() int { 1719 return xxx_messageInfo_SocketOptionTimeout.Size(m) 1720} 1721func (m *SocketOptionTimeout) XXX_DiscardUnknown() { 1722 xxx_messageInfo_SocketOptionTimeout.DiscardUnknown(m) 1723} 1724 1725var xxx_messageInfo_SocketOptionTimeout proto.InternalMessageInfo 1726 1727func (m *SocketOptionTimeout) GetDuration() *duration.Duration { 1728 if m != nil { 1729 return m.Duration 1730 } 1731 return nil 1732} 1733 1734// For use with SocketOption's additional field. This is primarily used for 1735// SO_LINGER. 1736type SocketOptionLinger struct { 1737 // active maps to `struct linger.l_onoff` 1738 Active bool `protobuf:"varint,1,opt,name=active,proto3" json:"active,omitempty"` 1739 // duration maps to `struct linger.l_linger` 1740 Duration *duration.Duration `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"` 1741 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1742 XXX_unrecognized []byte `json:"-"` 1743 XXX_sizecache int32 `json:"-"` 1744} 1745 1746func (m *SocketOptionLinger) Reset() { *m = SocketOptionLinger{} } 1747func (m *SocketOptionLinger) String() string { return proto.CompactTextString(m) } 1748func (*SocketOptionLinger) ProtoMessage() {} 1749func (*SocketOptionLinger) Descriptor() ([]byte, []int) { 1750 return fileDescriptor_6ee37dfd35a8ab00, []int{18} 1751} 1752 1753func (m *SocketOptionLinger) XXX_Unmarshal(b []byte) error { 1754 return xxx_messageInfo_SocketOptionLinger.Unmarshal(m, b) 1755} 1756func (m *SocketOptionLinger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1757 return xxx_messageInfo_SocketOptionLinger.Marshal(b, m, deterministic) 1758} 1759func (m *SocketOptionLinger) XXX_Merge(src proto.Message) { 1760 xxx_messageInfo_SocketOptionLinger.Merge(m, src) 1761} 1762func (m *SocketOptionLinger) XXX_Size() int { 1763 return xxx_messageInfo_SocketOptionLinger.Size(m) 1764} 1765func (m *SocketOptionLinger) XXX_DiscardUnknown() { 1766 xxx_messageInfo_SocketOptionLinger.DiscardUnknown(m) 1767} 1768 1769var xxx_messageInfo_SocketOptionLinger proto.InternalMessageInfo 1770 1771func (m *SocketOptionLinger) GetActive() bool { 1772 if m != nil { 1773 return m.Active 1774 } 1775 return false 1776} 1777 1778func (m *SocketOptionLinger) GetDuration() *duration.Duration { 1779 if m != nil { 1780 return m.Duration 1781 } 1782 return nil 1783} 1784 1785// For use with SocketOption's additional field. Tcp info for 1786// SOL_TCP and TCP_INFO. 1787type SocketOptionTcpInfo struct { 1788 TcpiState uint32 `protobuf:"varint,1,opt,name=tcpi_state,json=tcpiState,proto3" json:"tcpi_state,omitempty"` 1789 TcpiCaState uint32 `protobuf:"varint,2,opt,name=tcpi_ca_state,json=tcpiCaState,proto3" json:"tcpi_ca_state,omitempty"` 1790 TcpiRetransmits uint32 `protobuf:"varint,3,opt,name=tcpi_retransmits,json=tcpiRetransmits,proto3" json:"tcpi_retransmits,omitempty"` 1791 TcpiProbes uint32 `protobuf:"varint,4,opt,name=tcpi_probes,json=tcpiProbes,proto3" json:"tcpi_probes,omitempty"` 1792 TcpiBackoff uint32 `protobuf:"varint,5,opt,name=tcpi_backoff,json=tcpiBackoff,proto3" json:"tcpi_backoff,omitempty"` 1793 TcpiOptions uint32 `protobuf:"varint,6,opt,name=tcpi_options,json=tcpiOptions,proto3" json:"tcpi_options,omitempty"` 1794 TcpiSndWscale uint32 `protobuf:"varint,7,opt,name=tcpi_snd_wscale,json=tcpiSndWscale,proto3" json:"tcpi_snd_wscale,omitempty"` 1795 TcpiRcvWscale uint32 `protobuf:"varint,8,opt,name=tcpi_rcv_wscale,json=tcpiRcvWscale,proto3" json:"tcpi_rcv_wscale,omitempty"` 1796 TcpiRto uint32 `protobuf:"varint,9,opt,name=tcpi_rto,json=tcpiRto,proto3" json:"tcpi_rto,omitempty"` 1797 TcpiAto uint32 `protobuf:"varint,10,opt,name=tcpi_ato,json=tcpiAto,proto3" json:"tcpi_ato,omitempty"` 1798 TcpiSndMss uint32 `protobuf:"varint,11,opt,name=tcpi_snd_mss,json=tcpiSndMss,proto3" json:"tcpi_snd_mss,omitempty"` 1799 TcpiRcvMss uint32 `protobuf:"varint,12,opt,name=tcpi_rcv_mss,json=tcpiRcvMss,proto3" json:"tcpi_rcv_mss,omitempty"` 1800 TcpiUnacked uint32 `protobuf:"varint,13,opt,name=tcpi_unacked,json=tcpiUnacked,proto3" json:"tcpi_unacked,omitempty"` 1801 TcpiSacked uint32 `protobuf:"varint,14,opt,name=tcpi_sacked,json=tcpiSacked,proto3" json:"tcpi_sacked,omitempty"` 1802 TcpiLost uint32 `protobuf:"varint,15,opt,name=tcpi_lost,json=tcpiLost,proto3" json:"tcpi_lost,omitempty"` 1803 TcpiRetrans uint32 `protobuf:"varint,16,opt,name=tcpi_retrans,json=tcpiRetrans,proto3" json:"tcpi_retrans,omitempty"` 1804 TcpiFackets uint32 `protobuf:"varint,17,opt,name=tcpi_fackets,json=tcpiFackets,proto3" json:"tcpi_fackets,omitempty"` 1805 TcpiLastDataSent uint32 `protobuf:"varint,18,opt,name=tcpi_last_data_sent,json=tcpiLastDataSent,proto3" json:"tcpi_last_data_sent,omitempty"` 1806 TcpiLastAckSent uint32 `protobuf:"varint,19,opt,name=tcpi_last_ack_sent,json=tcpiLastAckSent,proto3" json:"tcpi_last_ack_sent,omitempty"` 1807 TcpiLastDataRecv uint32 `protobuf:"varint,20,opt,name=tcpi_last_data_recv,json=tcpiLastDataRecv,proto3" json:"tcpi_last_data_recv,omitempty"` 1808 TcpiLastAckRecv uint32 `protobuf:"varint,21,opt,name=tcpi_last_ack_recv,json=tcpiLastAckRecv,proto3" json:"tcpi_last_ack_recv,omitempty"` 1809 TcpiPmtu uint32 `protobuf:"varint,22,opt,name=tcpi_pmtu,json=tcpiPmtu,proto3" json:"tcpi_pmtu,omitempty"` 1810 TcpiRcvSsthresh uint32 `protobuf:"varint,23,opt,name=tcpi_rcv_ssthresh,json=tcpiRcvSsthresh,proto3" json:"tcpi_rcv_ssthresh,omitempty"` 1811 TcpiRtt uint32 `protobuf:"varint,24,opt,name=tcpi_rtt,json=tcpiRtt,proto3" json:"tcpi_rtt,omitempty"` 1812 TcpiRttvar uint32 `protobuf:"varint,25,opt,name=tcpi_rttvar,json=tcpiRttvar,proto3" json:"tcpi_rttvar,omitempty"` 1813 TcpiSndSsthresh uint32 `protobuf:"varint,26,opt,name=tcpi_snd_ssthresh,json=tcpiSndSsthresh,proto3" json:"tcpi_snd_ssthresh,omitempty"` 1814 TcpiSndCwnd uint32 `protobuf:"varint,27,opt,name=tcpi_snd_cwnd,json=tcpiSndCwnd,proto3" json:"tcpi_snd_cwnd,omitempty"` 1815 TcpiAdvmss uint32 `protobuf:"varint,28,opt,name=tcpi_advmss,json=tcpiAdvmss,proto3" json:"tcpi_advmss,omitempty"` 1816 TcpiReordering uint32 `protobuf:"varint,29,opt,name=tcpi_reordering,json=tcpiReordering,proto3" json:"tcpi_reordering,omitempty"` 1817 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1818 XXX_unrecognized []byte `json:"-"` 1819 XXX_sizecache int32 `json:"-"` 1820} 1821 1822func (m *SocketOptionTcpInfo) Reset() { *m = SocketOptionTcpInfo{} } 1823func (m *SocketOptionTcpInfo) String() string { return proto.CompactTextString(m) } 1824func (*SocketOptionTcpInfo) ProtoMessage() {} 1825func (*SocketOptionTcpInfo) Descriptor() ([]byte, []int) { 1826 return fileDescriptor_6ee37dfd35a8ab00, []int{19} 1827} 1828 1829func (m *SocketOptionTcpInfo) XXX_Unmarshal(b []byte) error { 1830 return xxx_messageInfo_SocketOptionTcpInfo.Unmarshal(m, b) 1831} 1832func (m *SocketOptionTcpInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1833 return xxx_messageInfo_SocketOptionTcpInfo.Marshal(b, m, deterministic) 1834} 1835func (m *SocketOptionTcpInfo) XXX_Merge(src proto.Message) { 1836 xxx_messageInfo_SocketOptionTcpInfo.Merge(m, src) 1837} 1838func (m *SocketOptionTcpInfo) XXX_Size() int { 1839 return xxx_messageInfo_SocketOptionTcpInfo.Size(m) 1840} 1841func (m *SocketOptionTcpInfo) XXX_DiscardUnknown() { 1842 xxx_messageInfo_SocketOptionTcpInfo.DiscardUnknown(m) 1843} 1844 1845var xxx_messageInfo_SocketOptionTcpInfo proto.InternalMessageInfo 1846 1847func (m *SocketOptionTcpInfo) GetTcpiState() uint32 { 1848 if m != nil { 1849 return m.TcpiState 1850 } 1851 return 0 1852} 1853 1854func (m *SocketOptionTcpInfo) GetTcpiCaState() uint32 { 1855 if m != nil { 1856 return m.TcpiCaState 1857 } 1858 return 0 1859} 1860 1861func (m *SocketOptionTcpInfo) GetTcpiRetransmits() uint32 { 1862 if m != nil { 1863 return m.TcpiRetransmits 1864 } 1865 return 0 1866} 1867 1868func (m *SocketOptionTcpInfo) GetTcpiProbes() uint32 { 1869 if m != nil { 1870 return m.TcpiProbes 1871 } 1872 return 0 1873} 1874 1875func (m *SocketOptionTcpInfo) GetTcpiBackoff() uint32 { 1876 if m != nil { 1877 return m.TcpiBackoff 1878 } 1879 return 0 1880} 1881 1882func (m *SocketOptionTcpInfo) GetTcpiOptions() uint32 { 1883 if m != nil { 1884 return m.TcpiOptions 1885 } 1886 return 0 1887} 1888 1889func (m *SocketOptionTcpInfo) GetTcpiSndWscale() uint32 { 1890 if m != nil { 1891 return m.TcpiSndWscale 1892 } 1893 return 0 1894} 1895 1896func (m *SocketOptionTcpInfo) GetTcpiRcvWscale() uint32 { 1897 if m != nil { 1898 return m.TcpiRcvWscale 1899 } 1900 return 0 1901} 1902 1903func (m *SocketOptionTcpInfo) GetTcpiRto() uint32 { 1904 if m != nil { 1905 return m.TcpiRto 1906 } 1907 return 0 1908} 1909 1910func (m *SocketOptionTcpInfo) GetTcpiAto() uint32 { 1911 if m != nil { 1912 return m.TcpiAto 1913 } 1914 return 0 1915} 1916 1917func (m *SocketOptionTcpInfo) GetTcpiSndMss() uint32 { 1918 if m != nil { 1919 return m.TcpiSndMss 1920 } 1921 return 0 1922} 1923 1924func (m *SocketOptionTcpInfo) GetTcpiRcvMss() uint32 { 1925 if m != nil { 1926 return m.TcpiRcvMss 1927 } 1928 return 0 1929} 1930 1931func (m *SocketOptionTcpInfo) GetTcpiUnacked() uint32 { 1932 if m != nil { 1933 return m.TcpiUnacked 1934 } 1935 return 0 1936} 1937 1938func (m *SocketOptionTcpInfo) GetTcpiSacked() uint32 { 1939 if m != nil { 1940 return m.TcpiSacked 1941 } 1942 return 0 1943} 1944 1945func (m *SocketOptionTcpInfo) GetTcpiLost() uint32 { 1946 if m != nil { 1947 return m.TcpiLost 1948 } 1949 return 0 1950} 1951 1952func (m *SocketOptionTcpInfo) GetTcpiRetrans() uint32 { 1953 if m != nil { 1954 return m.TcpiRetrans 1955 } 1956 return 0 1957} 1958 1959func (m *SocketOptionTcpInfo) GetTcpiFackets() uint32 { 1960 if m != nil { 1961 return m.TcpiFackets 1962 } 1963 return 0 1964} 1965 1966func (m *SocketOptionTcpInfo) GetTcpiLastDataSent() uint32 { 1967 if m != nil { 1968 return m.TcpiLastDataSent 1969 } 1970 return 0 1971} 1972 1973func (m *SocketOptionTcpInfo) GetTcpiLastAckSent() uint32 { 1974 if m != nil { 1975 return m.TcpiLastAckSent 1976 } 1977 return 0 1978} 1979 1980func (m *SocketOptionTcpInfo) GetTcpiLastDataRecv() uint32 { 1981 if m != nil { 1982 return m.TcpiLastDataRecv 1983 } 1984 return 0 1985} 1986 1987func (m *SocketOptionTcpInfo) GetTcpiLastAckRecv() uint32 { 1988 if m != nil { 1989 return m.TcpiLastAckRecv 1990 } 1991 return 0 1992} 1993 1994func (m *SocketOptionTcpInfo) GetTcpiPmtu() uint32 { 1995 if m != nil { 1996 return m.TcpiPmtu 1997 } 1998 return 0 1999} 2000 2001func (m *SocketOptionTcpInfo) GetTcpiRcvSsthresh() uint32 { 2002 if m != nil { 2003 return m.TcpiRcvSsthresh 2004 } 2005 return 0 2006} 2007 2008func (m *SocketOptionTcpInfo) GetTcpiRtt() uint32 { 2009 if m != nil { 2010 return m.TcpiRtt 2011 } 2012 return 0 2013} 2014 2015func (m *SocketOptionTcpInfo) GetTcpiRttvar() uint32 { 2016 if m != nil { 2017 return m.TcpiRttvar 2018 } 2019 return 0 2020} 2021 2022func (m *SocketOptionTcpInfo) GetTcpiSndSsthresh() uint32 { 2023 if m != nil { 2024 return m.TcpiSndSsthresh 2025 } 2026 return 0 2027} 2028 2029func (m *SocketOptionTcpInfo) GetTcpiSndCwnd() uint32 { 2030 if m != nil { 2031 return m.TcpiSndCwnd 2032 } 2033 return 0 2034} 2035 2036func (m *SocketOptionTcpInfo) GetTcpiAdvmss() uint32 { 2037 if m != nil { 2038 return m.TcpiAdvmss 2039 } 2040 return 0 2041} 2042 2043func (m *SocketOptionTcpInfo) GetTcpiReordering() uint32 { 2044 if m != nil { 2045 return m.TcpiReordering 2046 } 2047 return 0 2048} 2049 2050type GetTopChannelsRequest struct { 2051 // start_channel_id indicates that only channels at or above this id should be 2052 // included in the results. 2053 // To request the first page, this should be set to 0. To request 2054 // subsequent pages, the client generates this value by adding 1 to 2055 // the highest seen result ID. 2056 StartChannelId int64 `protobuf:"varint,1,opt,name=start_channel_id,json=startChannelId,proto3" json:"start_channel_id,omitempty"` 2057 // If non-zero, the server will return a page of results containing 2058 // at most this many items. If zero, the server will choose a 2059 // reasonable page size. Must never be negative. 2060 MaxResults int64 `protobuf:"varint,2,opt,name=max_results,json=maxResults,proto3" json:"max_results,omitempty"` 2061 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2062 XXX_unrecognized []byte `json:"-"` 2063 XXX_sizecache int32 `json:"-"` 2064} 2065 2066func (m *GetTopChannelsRequest) Reset() { *m = GetTopChannelsRequest{} } 2067func (m *GetTopChannelsRequest) String() string { return proto.CompactTextString(m) } 2068func (*GetTopChannelsRequest) ProtoMessage() {} 2069func (*GetTopChannelsRequest) Descriptor() ([]byte, []int) { 2070 return fileDescriptor_6ee37dfd35a8ab00, []int{20} 2071} 2072 2073func (m *GetTopChannelsRequest) XXX_Unmarshal(b []byte) error { 2074 return xxx_messageInfo_GetTopChannelsRequest.Unmarshal(m, b) 2075} 2076func (m *GetTopChannelsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2077 return xxx_messageInfo_GetTopChannelsRequest.Marshal(b, m, deterministic) 2078} 2079func (m *GetTopChannelsRequest) XXX_Merge(src proto.Message) { 2080 xxx_messageInfo_GetTopChannelsRequest.Merge(m, src) 2081} 2082func (m *GetTopChannelsRequest) XXX_Size() int { 2083 return xxx_messageInfo_GetTopChannelsRequest.Size(m) 2084} 2085func (m *GetTopChannelsRequest) XXX_DiscardUnknown() { 2086 xxx_messageInfo_GetTopChannelsRequest.DiscardUnknown(m) 2087} 2088 2089var xxx_messageInfo_GetTopChannelsRequest proto.InternalMessageInfo 2090 2091func (m *GetTopChannelsRequest) GetStartChannelId() int64 { 2092 if m != nil { 2093 return m.StartChannelId 2094 } 2095 return 0 2096} 2097 2098func (m *GetTopChannelsRequest) GetMaxResults() int64 { 2099 if m != nil { 2100 return m.MaxResults 2101 } 2102 return 0 2103} 2104 2105type GetTopChannelsResponse struct { 2106 // list of channels that the connection detail service knows about. Sorted in 2107 // ascending channel_id order. 2108 // Must contain at least 1 result, otherwise 'end' must be true. 2109 Channel []*Channel `protobuf:"bytes,1,rep,name=channel,proto3" json:"channel,omitempty"` 2110 // If set, indicates that the list of channels is the final list. Requesting 2111 // more channels can only return more if they are created after this RPC 2112 // completes. 2113 End bool `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"` 2114 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2115 XXX_unrecognized []byte `json:"-"` 2116 XXX_sizecache int32 `json:"-"` 2117} 2118 2119func (m *GetTopChannelsResponse) Reset() { *m = GetTopChannelsResponse{} } 2120func (m *GetTopChannelsResponse) String() string { return proto.CompactTextString(m) } 2121func (*GetTopChannelsResponse) ProtoMessage() {} 2122func (*GetTopChannelsResponse) Descriptor() ([]byte, []int) { 2123 return fileDescriptor_6ee37dfd35a8ab00, []int{21} 2124} 2125 2126func (m *GetTopChannelsResponse) XXX_Unmarshal(b []byte) error { 2127 return xxx_messageInfo_GetTopChannelsResponse.Unmarshal(m, b) 2128} 2129func (m *GetTopChannelsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2130 return xxx_messageInfo_GetTopChannelsResponse.Marshal(b, m, deterministic) 2131} 2132func (m *GetTopChannelsResponse) XXX_Merge(src proto.Message) { 2133 xxx_messageInfo_GetTopChannelsResponse.Merge(m, src) 2134} 2135func (m *GetTopChannelsResponse) XXX_Size() int { 2136 return xxx_messageInfo_GetTopChannelsResponse.Size(m) 2137} 2138func (m *GetTopChannelsResponse) XXX_DiscardUnknown() { 2139 xxx_messageInfo_GetTopChannelsResponse.DiscardUnknown(m) 2140} 2141 2142var xxx_messageInfo_GetTopChannelsResponse proto.InternalMessageInfo 2143 2144func (m *GetTopChannelsResponse) GetChannel() []*Channel { 2145 if m != nil { 2146 return m.Channel 2147 } 2148 return nil 2149} 2150 2151func (m *GetTopChannelsResponse) GetEnd() bool { 2152 if m != nil { 2153 return m.End 2154 } 2155 return false 2156} 2157 2158type GetServersRequest struct { 2159 // start_server_id indicates that only servers at or above this id should be 2160 // included in the results. 2161 // To request the first page, this must be set to 0. To request 2162 // subsequent pages, the client generates this value by adding 1 to 2163 // the highest seen result ID. 2164 StartServerId int64 `protobuf:"varint,1,opt,name=start_server_id,json=startServerId,proto3" json:"start_server_id,omitempty"` 2165 // If non-zero, the server will return a page of results containing 2166 // at most this many items. If zero, the server will choose a 2167 // reasonable page size. Must never be negative. 2168 MaxResults int64 `protobuf:"varint,2,opt,name=max_results,json=maxResults,proto3" json:"max_results,omitempty"` 2169 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2170 XXX_unrecognized []byte `json:"-"` 2171 XXX_sizecache int32 `json:"-"` 2172} 2173 2174func (m *GetServersRequest) Reset() { *m = GetServersRequest{} } 2175func (m *GetServersRequest) String() string { return proto.CompactTextString(m) } 2176func (*GetServersRequest) ProtoMessage() {} 2177func (*GetServersRequest) Descriptor() ([]byte, []int) { 2178 return fileDescriptor_6ee37dfd35a8ab00, []int{22} 2179} 2180 2181func (m *GetServersRequest) XXX_Unmarshal(b []byte) error { 2182 return xxx_messageInfo_GetServersRequest.Unmarshal(m, b) 2183} 2184func (m *GetServersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2185 return xxx_messageInfo_GetServersRequest.Marshal(b, m, deterministic) 2186} 2187func (m *GetServersRequest) XXX_Merge(src proto.Message) { 2188 xxx_messageInfo_GetServersRequest.Merge(m, src) 2189} 2190func (m *GetServersRequest) XXX_Size() int { 2191 return xxx_messageInfo_GetServersRequest.Size(m) 2192} 2193func (m *GetServersRequest) XXX_DiscardUnknown() { 2194 xxx_messageInfo_GetServersRequest.DiscardUnknown(m) 2195} 2196 2197var xxx_messageInfo_GetServersRequest proto.InternalMessageInfo 2198 2199func (m *GetServersRequest) GetStartServerId() int64 { 2200 if m != nil { 2201 return m.StartServerId 2202 } 2203 return 0 2204} 2205 2206func (m *GetServersRequest) GetMaxResults() int64 { 2207 if m != nil { 2208 return m.MaxResults 2209 } 2210 return 0 2211} 2212 2213type GetServersResponse struct { 2214 // list of servers that the connection detail service knows about. Sorted in 2215 // ascending server_id order. 2216 // Must contain at least 1 result, otherwise 'end' must be true. 2217 Server []*Server `protobuf:"bytes,1,rep,name=server,proto3" json:"server,omitempty"` 2218 // If set, indicates that the list of servers is the final list. Requesting 2219 // more servers will only return more if they are created after this RPC 2220 // completes. 2221 End bool `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"` 2222 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2223 XXX_unrecognized []byte `json:"-"` 2224 XXX_sizecache int32 `json:"-"` 2225} 2226 2227func (m *GetServersResponse) Reset() { *m = GetServersResponse{} } 2228func (m *GetServersResponse) String() string { return proto.CompactTextString(m) } 2229func (*GetServersResponse) ProtoMessage() {} 2230func (*GetServersResponse) Descriptor() ([]byte, []int) { 2231 return fileDescriptor_6ee37dfd35a8ab00, []int{23} 2232} 2233 2234func (m *GetServersResponse) XXX_Unmarshal(b []byte) error { 2235 return xxx_messageInfo_GetServersResponse.Unmarshal(m, b) 2236} 2237func (m *GetServersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2238 return xxx_messageInfo_GetServersResponse.Marshal(b, m, deterministic) 2239} 2240func (m *GetServersResponse) XXX_Merge(src proto.Message) { 2241 xxx_messageInfo_GetServersResponse.Merge(m, src) 2242} 2243func (m *GetServersResponse) XXX_Size() int { 2244 return xxx_messageInfo_GetServersResponse.Size(m) 2245} 2246func (m *GetServersResponse) XXX_DiscardUnknown() { 2247 xxx_messageInfo_GetServersResponse.DiscardUnknown(m) 2248} 2249 2250var xxx_messageInfo_GetServersResponse proto.InternalMessageInfo 2251 2252func (m *GetServersResponse) GetServer() []*Server { 2253 if m != nil { 2254 return m.Server 2255 } 2256 return nil 2257} 2258 2259func (m *GetServersResponse) GetEnd() bool { 2260 if m != nil { 2261 return m.End 2262 } 2263 return false 2264} 2265 2266type GetServerRequest struct { 2267 // server_id is the identifier of the specific server to get. 2268 ServerId int64 `protobuf:"varint,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"` 2269 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2270 XXX_unrecognized []byte `json:"-"` 2271 XXX_sizecache int32 `json:"-"` 2272} 2273 2274func (m *GetServerRequest) Reset() { *m = GetServerRequest{} } 2275func (m *GetServerRequest) String() string { return proto.CompactTextString(m) } 2276func (*GetServerRequest) ProtoMessage() {} 2277func (*GetServerRequest) Descriptor() ([]byte, []int) { 2278 return fileDescriptor_6ee37dfd35a8ab00, []int{24} 2279} 2280 2281func (m *GetServerRequest) XXX_Unmarshal(b []byte) error { 2282 return xxx_messageInfo_GetServerRequest.Unmarshal(m, b) 2283} 2284func (m *GetServerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2285 return xxx_messageInfo_GetServerRequest.Marshal(b, m, deterministic) 2286} 2287func (m *GetServerRequest) XXX_Merge(src proto.Message) { 2288 xxx_messageInfo_GetServerRequest.Merge(m, src) 2289} 2290func (m *GetServerRequest) XXX_Size() int { 2291 return xxx_messageInfo_GetServerRequest.Size(m) 2292} 2293func (m *GetServerRequest) XXX_DiscardUnknown() { 2294 xxx_messageInfo_GetServerRequest.DiscardUnknown(m) 2295} 2296 2297var xxx_messageInfo_GetServerRequest proto.InternalMessageInfo 2298 2299func (m *GetServerRequest) GetServerId() int64 { 2300 if m != nil { 2301 return m.ServerId 2302 } 2303 return 0 2304} 2305 2306type GetServerResponse struct { 2307 // The Server that corresponds to the requested server_id. This field 2308 // should be set. 2309 Server *Server `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` 2310 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2311 XXX_unrecognized []byte `json:"-"` 2312 XXX_sizecache int32 `json:"-"` 2313} 2314 2315func (m *GetServerResponse) Reset() { *m = GetServerResponse{} } 2316func (m *GetServerResponse) String() string { return proto.CompactTextString(m) } 2317func (*GetServerResponse) ProtoMessage() {} 2318func (*GetServerResponse) Descriptor() ([]byte, []int) { 2319 return fileDescriptor_6ee37dfd35a8ab00, []int{25} 2320} 2321 2322func (m *GetServerResponse) XXX_Unmarshal(b []byte) error { 2323 return xxx_messageInfo_GetServerResponse.Unmarshal(m, b) 2324} 2325func (m *GetServerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2326 return xxx_messageInfo_GetServerResponse.Marshal(b, m, deterministic) 2327} 2328func (m *GetServerResponse) XXX_Merge(src proto.Message) { 2329 xxx_messageInfo_GetServerResponse.Merge(m, src) 2330} 2331func (m *GetServerResponse) XXX_Size() int { 2332 return xxx_messageInfo_GetServerResponse.Size(m) 2333} 2334func (m *GetServerResponse) XXX_DiscardUnknown() { 2335 xxx_messageInfo_GetServerResponse.DiscardUnknown(m) 2336} 2337 2338var xxx_messageInfo_GetServerResponse proto.InternalMessageInfo 2339 2340func (m *GetServerResponse) GetServer() *Server { 2341 if m != nil { 2342 return m.Server 2343 } 2344 return nil 2345} 2346 2347type GetServerSocketsRequest struct { 2348 ServerId int64 `protobuf:"varint,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"` 2349 // start_socket_id indicates that only sockets at or above this id should be 2350 // included in the results. 2351 // To request the first page, this must be set to 0. To request 2352 // subsequent pages, the client generates this value by adding 1 to 2353 // the highest seen result ID. 2354 StartSocketId int64 `protobuf:"varint,2,opt,name=start_socket_id,json=startSocketId,proto3" json:"start_socket_id,omitempty"` 2355 // If non-zero, the server will return a page of results containing 2356 // at most this many items. If zero, the server will choose a 2357 // reasonable page size. Must never be negative. 2358 MaxResults int64 `protobuf:"varint,3,opt,name=max_results,json=maxResults,proto3" json:"max_results,omitempty"` 2359 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2360 XXX_unrecognized []byte `json:"-"` 2361 XXX_sizecache int32 `json:"-"` 2362} 2363 2364func (m *GetServerSocketsRequest) Reset() { *m = GetServerSocketsRequest{} } 2365func (m *GetServerSocketsRequest) String() string { return proto.CompactTextString(m) } 2366func (*GetServerSocketsRequest) ProtoMessage() {} 2367func (*GetServerSocketsRequest) Descriptor() ([]byte, []int) { 2368 return fileDescriptor_6ee37dfd35a8ab00, []int{26} 2369} 2370 2371func (m *GetServerSocketsRequest) XXX_Unmarshal(b []byte) error { 2372 return xxx_messageInfo_GetServerSocketsRequest.Unmarshal(m, b) 2373} 2374func (m *GetServerSocketsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2375 return xxx_messageInfo_GetServerSocketsRequest.Marshal(b, m, deterministic) 2376} 2377func (m *GetServerSocketsRequest) XXX_Merge(src proto.Message) { 2378 xxx_messageInfo_GetServerSocketsRequest.Merge(m, src) 2379} 2380func (m *GetServerSocketsRequest) XXX_Size() int { 2381 return xxx_messageInfo_GetServerSocketsRequest.Size(m) 2382} 2383func (m *GetServerSocketsRequest) XXX_DiscardUnknown() { 2384 xxx_messageInfo_GetServerSocketsRequest.DiscardUnknown(m) 2385} 2386 2387var xxx_messageInfo_GetServerSocketsRequest proto.InternalMessageInfo 2388 2389func (m *GetServerSocketsRequest) GetServerId() int64 { 2390 if m != nil { 2391 return m.ServerId 2392 } 2393 return 0 2394} 2395 2396func (m *GetServerSocketsRequest) GetStartSocketId() int64 { 2397 if m != nil { 2398 return m.StartSocketId 2399 } 2400 return 0 2401} 2402 2403func (m *GetServerSocketsRequest) GetMaxResults() int64 { 2404 if m != nil { 2405 return m.MaxResults 2406 } 2407 return 0 2408} 2409 2410type GetServerSocketsResponse struct { 2411 // list of socket refs that the connection detail service knows about. Sorted in 2412 // ascending socket_id order. 2413 // Must contain at least 1 result, otherwise 'end' must be true. 2414 SocketRef []*SocketRef `protobuf:"bytes,1,rep,name=socket_ref,json=socketRef,proto3" json:"socket_ref,omitempty"` 2415 // If set, indicates that the list of sockets is the final list. Requesting 2416 // more sockets will only return more if they are created after this RPC 2417 // completes. 2418 End bool `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"` 2419 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2420 XXX_unrecognized []byte `json:"-"` 2421 XXX_sizecache int32 `json:"-"` 2422} 2423 2424func (m *GetServerSocketsResponse) Reset() { *m = GetServerSocketsResponse{} } 2425func (m *GetServerSocketsResponse) String() string { return proto.CompactTextString(m) } 2426func (*GetServerSocketsResponse) ProtoMessage() {} 2427func (*GetServerSocketsResponse) Descriptor() ([]byte, []int) { 2428 return fileDescriptor_6ee37dfd35a8ab00, []int{27} 2429} 2430 2431func (m *GetServerSocketsResponse) XXX_Unmarshal(b []byte) error { 2432 return xxx_messageInfo_GetServerSocketsResponse.Unmarshal(m, b) 2433} 2434func (m *GetServerSocketsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2435 return xxx_messageInfo_GetServerSocketsResponse.Marshal(b, m, deterministic) 2436} 2437func (m *GetServerSocketsResponse) XXX_Merge(src proto.Message) { 2438 xxx_messageInfo_GetServerSocketsResponse.Merge(m, src) 2439} 2440func (m *GetServerSocketsResponse) XXX_Size() int { 2441 return xxx_messageInfo_GetServerSocketsResponse.Size(m) 2442} 2443func (m *GetServerSocketsResponse) XXX_DiscardUnknown() { 2444 xxx_messageInfo_GetServerSocketsResponse.DiscardUnknown(m) 2445} 2446 2447var xxx_messageInfo_GetServerSocketsResponse proto.InternalMessageInfo 2448 2449func (m *GetServerSocketsResponse) GetSocketRef() []*SocketRef { 2450 if m != nil { 2451 return m.SocketRef 2452 } 2453 return nil 2454} 2455 2456func (m *GetServerSocketsResponse) GetEnd() bool { 2457 if m != nil { 2458 return m.End 2459 } 2460 return false 2461} 2462 2463type GetChannelRequest struct { 2464 // channel_id is the identifier of the specific channel to get. 2465 ChannelId int64 `protobuf:"varint,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` 2466 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2467 XXX_unrecognized []byte `json:"-"` 2468 XXX_sizecache int32 `json:"-"` 2469} 2470 2471func (m *GetChannelRequest) Reset() { *m = GetChannelRequest{} } 2472func (m *GetChannelRequest) String() string { return proto.CompactTextString(m) } 2473func (*GetChannelRequest) ProtoMessage() {} 2474func (*GetChannelRequest) Descriptor() ([]byte, []int) { 2475 return fileDescriptor_6ee37dfd35a8ab00, []int{28} 2476} 2477 2478func (m *GetChannelRequest) XXX_Unmarshal(b []byte) error { 2479 return xxx_messageInfo_GetChannelRequest.Unmarshal(m, b) 2480} 2481func (m *GetChannelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2482 return xxx_messageInfo_GetChannelRequest.Marshal(b, m, deterministic) 2483} 2484func (m *GetChannelRequest) XXX_Merge(src proto.Message) { 2485 xxx_messageInfo_GetChannelRequest.Merge(m, src) 2486} 2487func (m *GetChannelRequest) XXX_Size() int { 2488 return xxx_messageInfo_GetChannelRequest.Size(m) 2489} 2490func (m *GetChannelRequest) XXX_DiscardUnknown() { 2491 xxx_messageInfo_GetChannelRequest.DiscardUnknown(m) 2492} 2493 2494var xxx_messageInfo_GetChannelRequest proto.InternalMessageInfo 2495 2496func (m *GetChannelRequest) GetChannelId() int64 { 2497 if m != nil { 2498 return m.ChannelId 2499 } 2500 return 0 2501} 2502 2503type GetChannelResponse struct { 2504 // The Channel that corresponds to the requested channel_id. This field 2505 // should be set. 2506 Channel *Channel `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` 2507 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2508 XXX_unrecognized []byte `json:"-"` 2509 XXX_sizecache int32 `json:"-"` 2510} 2511 2512func (m *GetChannelResponse) Reset() { *m = GetChannelResponse{} } 2513func (m *GetChannelResponse) String() string { return proto.CompactTextString(m) } 2514func (*GetChannelResponse) ProtoMessage() {} 2515func (*GetChannelResponse) Descriptor() ([]byte, []int) { 2516 return fileDescriptor_6ee37dfd35a8ab00, []int{29} 2517} 2518 2519func (m *GetChannelResponse) XXX_Unmarshal(b []byte) error { 2520 return xxx_messageInfo_GetChannelResponse.Unmarshal(m, b) 2521} 2522func (m *GetChannelResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2523 return xxx_messageInfo_GetChannelResponse.Marshal(b, m, deterministic) 2524} 2525func (m *GetChannelResponse) XXX_Merge(src proto.Message) { 2526 xxx_messageInfo_GetChannelResponse.Merge(m, src) 2527} 2528func (m *GetChannelResponse) XXX_Size() int { 2529 return xxx_messageInfo_GetChannelResponse.Size(m) 2530} 2531func (m *GetChannelResponse) XXX_DiscardUnknown() { 2532 xxx_messageInfo_GetChannelResponse.DiscardUnknown(m) 2533} 2534 2535var xxx_messageInfo_GetChannelResponse proto.InternalMessageInfo 2536 2537func (m *GetChannelResponse) GetChannel() *Channel { 2538 if m != nil { 2539 return m.Channel 2540 } 2541 return nil 2542} 2543 2544type GetSubchannelRequest struct { 2545 // subchannel_id is the identifier of the specific subchannel to get. 2546 SubchannelId int64 `protobuf:"varint,1,opt,name=subchannel_id,json=subchannelId,proto3" json:"subchannel_id,omitempty"` 2547 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2548 XXX_unrecognized []byte `json:"-"` 2549 XXX_sizecache int32 `json:"-"` 2550} 2551 2552func (m *GetSubchannelRequest) Reset() { *m = GetSubchannelRequest{} } 2553func (m *GetSubchannelRequest) String() string { return proto.CompactTextString(m) } 2554func (*GetSubchannelRequest) ProtoMessage() {} 2555func (*GetSubchannelRequest) Descriptor() ([]byte, []int) { 2556 return fileDescriptor_6ee37dfd35a8ab00, []int{30} 2557} 2558 2559func (m *GetSubchannelRequest) XXX_Unmarshal(b []byte) error { 2560 return xxx_messageInfo_GetSubchannelRequest.Unmarshal(m, b) 2561} 2562func (m *GetSubchannelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2563 return xxx_messageInfo_GetSubchannelRequest.Marshal(b, m, deterministic) 2564} 2565func (m *GetSubchannelRequest) XXX_Merge(src proto.Message) { 2566 xxx_messageInfo_GetSubchannelRequest.Merge(m, src) 2567} 2568func (m *GetSubchannelRequest) XXX_Size() int { 2569 return xxx_messageInfo_GetSubchannelRequest.Size(m) 2570} 2571func (m *GetSubchannelRequest) XXX_DiscardUnknown() { 2572 xxx_messageInfo_GetSubchannelRequest.DiscardUnknown(m) 2573} 2574 2575var xxx_messageInfo_GetSubchannelRequest proto.InternalMessageInfo 2576 2577func (m *GetSubchannelRequest) GetSubchannelId() int64 { 2578 if m != nil { 2579 return m.SubchannelId 2580 } 2581 return 0 2582} 2583 2584type GetSubchannelResponse struct { 2585 // The Subchannel that corresponds to the requested subchannel_id. This 2586 // field should be set. 2587 Subchannel *Subchannel `protobuf:"bytes,1,opt,name=subchannel,proto3" json:"subchannel,omitempty"` 2588 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2589 XXX_unrecognized []byte `json:"-"` 2590 XXX_sizecache int32 `json:"-"` 2591} 2592 2593func (m *GetSubchannelResponse) Reset() { *m = GetSubchannelResponse{} } 2594func (m *GetSubchannelResponse) String() string { return proto.CompactTextString(m) } 2595func (*GetSubchannelResponse) ProtoMessage() {} 2596func (*GetSubchannelResponse) Descriptor() ([]byte, []int) { 2597 return fileDescriptor_6ee37dfd35a8ab00, []int{31} 2598} 2599 2600func (m *GetSubchannelResponse) XXX_Unmarshal(b []byte) error { 2601 return xxx_messageInfo_GetSubchannelResponse.Unmarshal(m, b) 2602} 2603func (m *GetSubchannelResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2604 return xxx_messageInfo_GetSubchannelResponse.Marshal(b, m, deterministic) 2605} 2606func (m *GetSubchannelResponse) XXX_Merge(src proto.Message) { 2607 xxx_messageInfo_GetSubchannelResponse.Merge(m, src) 2608} 2609func (m *GetSubchannelResponse) XXX_Size() int { 2610 return xxx_messageInfo_GetSubchannelResponse.Size(m) 2611} 2612func (m *GetSubchannelResponse) XXX_DiscardUnknown() { 2613 xxx_messageInfo_GetSubchannelResponse.DiscardUnknown(m) 2614} 2615 2616var xxx_messageInfo_GetSubchannelResponse proto.InternalMessageInfo 2617 2618func (m *GetSubchannelResponse) GetSubchannel() *Subchannel { 2619 if m != nil { 2620 return m.Subchannel 2621 } 2622 return nil 2623} 2624 2625type GetSocketRequest struct { 2626 // socket_id is the identifier of the specific socket to get. 2627 SocketId int64 `protobuf:"varint,1,opt,name=socket_id,json=socketId,proto3" json:"socket_id,omitempty"` 2628 // If true, the response will contain only high level information 2629 // that is inexpensive to obtain. Fields thay may be omitted are 2630 // documented. 2631 Summary bool `protobuf:"varint,2,opt,name=summary,proto3" json:"summary,omitempty"` 2632 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2633 XXX_unrecognized []byte `json:"-"` 2634 XXX_sizecache int32 `json:"-"` 2635} 2636 2637func (m *GetSocketRequest) Reset() { *m = GetSocketRequest{} } 2638func (m *GetSocketRequest) String() string { return proto.CompactTextString(m) } 2639func (*GetSocketRequest) ProtoMessage() {} 2640func (*GetSocketRequest) Descriptor() ([]byte, []int) { 2641 return fileDescriptor_6ee37dfd35a8ab00, []int{32} 2642} 2643 2644func (m *GetSocketRequest) XXX_Unmarshal(b []byte) error { 2645 return xxx_messageInfo_GetSocketRequest.Unmarshal(m, b) 2646} 2647func (m *GetSocketRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2648 return xxx_messageInfo_GetSocketRequest.Marshal(b, m, deterministic) 2649} 2650func (m *GetSocketRequest) XXX_Merge(src proto.Message) { 2651 xxx_messageInfo_GetSocketRequest.Merge(m, src) 2652} 2653func (m *GetSocketRequest) XXX_Size() int { 2654 return xxx_messageInfo_GetSocketRequest.Size(m) 2655} 2656func (m *GetSocketRequest) XXX_DiscardUnknown() { 2657 xxx_messageInfo_GetSocketRequest.DiscardUnknown(m) 2658} 2659 2660var xxx_messageInfo_GetSocketRequest proto.InternalMessageInfo 2661 2662func (m *GetSocketRequest) GetSocketId() int64 { 2663 if m != nil { 2664 return m.SocketId 2665 } 2666 return 0 2667} 2668 2669func (m *GetSocketRequest) GetSummary() bool { 2670 if m != nil { 2671 return m.Summary 2672 } 2673 return false 2674} 2675 2676type GetSocketResponse struct { 2677 // The Socket that corresponds to the requested socket_id. This field 2678 // should be set. 2679 Socket *Socket `protobuf:"bytes,1,opt,name=socket,proto3" json:"socket,omitempty"` 2680 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2681 XXX_unrecognized []byte `json:"-"` 2682 XXX_sizecache int32 `json:"-"` 2683} 2684 2685func (m *GetSocketResponse) Reset() { *m = GetSocketResponse{} } 2686func (m *GetSocketResponse) String() string { return proto.CompactTextString(m) } 2687func (*GetSocketResponse) ProtoMessage() {} 2688func (*GetSocketResponse) Descriptor() ([]byte, []int) { 2689 return fileDescriptor_6ee37dfd35a8ab00, []int{33} 2690} 2691 2692func (m *GetSocketResponse) XXX_Unmarshal(b []byte) error { 2693 return xxx_messageInfo_GetSocketResponse.Unmarshal(m, b) 2694} 2695func (m *GetSocketResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2696 return xxx_messageInfo_GetSocketResponse.Marshal(b, m, deterministic) 2697} 2698func (m *GetSocketResponse) XXX_Merge(src proto.Message) { 2699 xxx_messageInfo_GetSocketResponse.Merge(m, src) 2700} 2701func (m *GetSocketResponse) XXX_Size() int { 2702 return xxx_messageInfo_GetSocketResponse.Size(m) 2703} 2704func (m *GetSocketResponse) XXX_DiscardUnknown() { 2705 xxx_messageInfo_GetSocketResponse.DiscardUnknown(m) 2706} 2707 2708var xxx_messageInfo_GetSocketResponse proto.InternalMessageInfo 2709 2710func (m *GetSocketResponse) GetSocket() *Socket { 2711 if m != nil { 2712 return m.Socket 2713 } 2714 return nil 2715} 2716 2717func init() { 2718 proto.RegisterEnum("grpc.channelz.v1.ChannelConnectivityState_State", ChannelConnectivityState_State_name, ChannelConnectivityState_State_value) 2719 proto.RegisterEnum("grpc.channelz.v1.ChannelTraceEvent_Severity", ChannelTraceEvent_Severity_name, ChannelTraceEvent_Severity_value) 2720 proto.RegisterType((*Channel)(nil), "grpc.channelz.v1.Channel") 2721 proto.RegisterType((*Subchannel)(nil), "grpc.channelz.v1.Subchannel") 2722 proto.RegisterType((*ChannelConnectivityState)(nil), "grpc.channelz.v1.ChannelConnectivityState") 2723 proto.RegisterType((*ChannelData)(nil), "grpc.channelz.v1.ChannelData") 2724 proto.RegisterType((*ChannelTraceEvent)(nil), "grpc.channelz.v1.ChannelTraceEvent") 2725 proto.RegisterType((*ChannelTrace)(nil), "grpc.channelz.v1.ChannelTrace") 2726 proto.RegisterType((*ChannelRef)(nil), "grpc.channelz.v1.ChannelRef") 2727 proto.RegisterType((*SubchannelRef)(nil), "grpc.channelz.v1.SubchannelRef") 2728 proto.RegisterType((*SocketRef)(nil), "grpc.channelz.v1.SocketRef") 2729 proto.RegisterType((*ServerRef)(nil), "grpc.channelz.v1.ServerRef") 2730 proto.RegisterType((*Server)(nil), "grpc.channelz.v1.Server") 2731 proto.RegisterType((*ServerData)(nil), "grpc.channelz.v1.ServerData") 2732 proto.RegisterType((*Socket)(nil), "grpc.channelz.v1.Socket") 2733 proto.RegisterType((*SocketData)(nil), "grpc.channelz.v1.SocketData") 2734 proto.RegisterType((*Address)(nil), "grpc.channelz.v1.Address") 2735 proto.RegisterType((*Address_TcpIpAddress)(nil), "grpc.channelz.v1.Address.TcpIpAddress") 2736 proto.RegisterType((*Address_UdsAddress)(nil), "grpc.channelz.v1.Address.UdsAddress") 2737 proto.RegisterType((*Address_OtherAddress)(nil), "grpc.channelz.v1.Address.OtherAddress") 2738 proto.RegisterType((*Security)(nil), "grpc.channelz.v1.Security") 2739 proto.RegisterType((*Security_Tls)(nil), "grpc.channelz.v1.Security.Tls") 2740 proto.RegisterType((*Security_OtherSecurity)(nil), "grpc.channelz.v1.Security.OtherSecurity") 2741 proto.RegisterType((*SocketOption)(nil), "grpc.channelz.v1.SocketOption") 2742 proto.RegisterType((*SocketOptionTimeout)(nil), "grpc.channelz.v1.SocketOptionTimeout") 2743 proto.RegisterType((*SocketOptionLinger)(nil), "grpc.channelz.v1.SocketOptionLinger") 2744 proto.RegisterType((*SocketOptionTcpInfo)(nil), "grpc.channelz.v1.SocketOptionTcpInfo") 2745 proto.RegisterType((*GetTopChannelsRequest)(nil), "grpc.channelz.v1.GetTopChannelsRequest") 2746 proto.RegisterType((*GetTopChannelsResponse)(nil), "grpc.channelz.v1.GetTopChannelsResponse") 2747 proto.RegisterType((*GetServersRequest)(nil), "grpc.channelz.v1.GetServersRequest") 2748 proto.RegisterType((*GetServersResponse)(nil), "grpc.channelz.v1.GetServersResponse") 2749 proto.RegisterType((*GetServerRequest)(nil), "grpc.channelz.v1.GetServerRequest") 2750 proto.RegisterType((*GetServerResponse)(nil), "grpc.channelz.v1.GetServerResponse") 2751 proto.RegisterType((*GetServerSocketsRequest)(nil), "grpc.channelz.v1.GetServerSocketsRequest") 2752 proto.RegisterType((*GetServerSocketsResponse)(nil), "grpc.channelz.v1.GetServerSocketsResponse") 2753 proto.RegisterType((*GetChannelRequest)(nil), "grpc.channelz.v1.GetChannelRequest") 2754 proto.RegisterType((*GetChannelResponse)(nil), "grpc.channelz.v1.GetChannelResponse") 2755 proto.RegisterType((*GetSubchannelRequest)(nil), "grpc.channelz.v1.GetSubchannelRequest") 2756 proto.RegisterType((*GetSubchannelResponse)(nil), "grpc.channelz.v1.GetSubchannelResponse") 2757 proto.RegisterType((*GetSocketRequest)(nil), "grpc.channelz.v1.GetSocketRequest") 2758 proto.RegisterType((*GetSocketResponse)(nil), "grpc.channelz.v1.GetSocketResponse") 2759} 2760 2761func init() { proto.RegisterFile("grpc/channelz/v1/channelz.proto", fileDescriptor_6ee37dfd35a8ab00) } 2762 2763var fileDescriptor_6ee37dfd35a8ab00 = []byte{ 2764 // 2584 bytes of a gzipped FileDescriptorProto 2765 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe4, 0x59, 0x4b, 0x6f, 0xdb, 0xd8, 2766 0xf5, 0xb7, 0xde, 0xd4, 0xd1, 0x23, 0xf2, 0x4d, 0x26, 0x43, 0x2b, 0x99, 0xb1, 0xff, 0xf4, 0x4c, 2767 0xc6, 0x93, 0xfc, 0x23, 0xc7, 0x9e, 0x34, 0x28, 0x3a, 0x2d, 0x3a, 0xb6, 0x62, 0xc7, 0x72, 0x1d, 2768 0x39, 0xa0, 0xe4, 0x49, 0xa6, 0x28, 0xca, 0xa1, 0xc9, 0x6b, 0x99, 0x35, 0x45, 0xaa, 0xbc, 0x57, 2769 0xf2, 0x24, 0x9b, 0x2e, 0xba, 0xef, 0xb2, 0x28, 0xfa, 0x01, 0xba, 0xe9, 0xa2, 0x40, 0x81, 0x02, 2770 0xed, 0xb6, 0xdf, 0xa6, 0xdf, 0xa2, 0xb8, 0x0f, 0x3e, 0xf4, 0xb2, 0x14, 0x64, 0xd9, 0x8d, 0x21, 2771 0x1e, 0xfe, 0xce, 0xef, 0x9c, 0x7b, 0x5e, 0xf7, 0xf2, 0x1a, 0xd6, 0x7b, 0xc1, 0xc0, 0xda, 0xb6, 2772 0x2e, 0x4d, 0xcf, 0xc3, 0xee, 0xbb, 0xed, 0xd1, 0x4e, 0xf4, 0xbb, 0x31, 0x08, 0x7c, 0xea, 0xa3, 2773 0x1a, 0x03, 0x34, 0x22, 0xe1, 0x68, 0xa7, 0xbe, 0xd6, 0xf3, 0xfd, 0x9e, 0x8b, 0xb7, 0xf9, 0xfb, 2774 0xf3, 0xe1, 0xc5, 0xb6, 0xe9, 0xbd, 0x15, 0xe0, 0xfa, 0xa7, 0x93, 0xaf, 0xec, 0x61, 0x60, 0x52, 2775 0xc7, 0xf7, 0xe4, 0xfb, 0xf5, 0xc9, 0xf7, 0xd4, 0xe9, 0x63, 0x42, 0xcd, 0xfe, 0x60, 0x1e, 0xc1, 2776 0x75, 0x60, 0x0e, 0x06, 0x38, 0x20, 0xe2, 0xbd, 0xf6, 0xb7, 0x34, 0x14, 0x9a, 0xc2, 0x17, 0xd4, 2777 0x80, 0x4c, 0x80, 0x2f, 0xd4, 0xd4, 0x46, 0x6a, 0xab, 0xb4, 0x7b, 0xbf, 0x31, 0xe9, 0x67, 0x43, 2778 0xe2, 0x74, 0x7c, 0xa1, 0x33, 0x20, 0xda, 0x81, 0xac, 0x6d, 0x52, 0x53, 0x4d, 0x73, 0x85, 0x4f, 2779 0xe6, 0x2a, 0x3c, 0x37, 0xa9, 0xa9, 0x73, 0x28, 0xfa, 0x19, 0x94, 0x24, 0xc0, 0x60, 0xa6, 0x32, 2780 0x1b, 0x99, 0x85, 0xa6, 0xc0, 0x8a, 0x7e, 0xa3, 0x43, 0xa8, 0x92, 0xe1, 0x79, 0x92, 0x21, 0xcb, 2781 0x19, 0xd6, 0xa7, 0x19, 0x3a, 0x11, 0x8e, 0x91, 0x54, 0x48, 0xf2, 0x11, 0xfd, 0x04, 0x80, 0xf8, 2782 0xd6, 0x15, 0xa6, 0x9c, 0x23, 0xc7, 0x39, 0xee, 0xcd, 0xe0, 0xe0, 0x18, 0xa6, 0x5f, 0x24, 0xe1, 2783 0x4f, 0xed, 0x1f, 0x69, 0x80, 0x98, 0x1c, 0xed, 0x24, 0x83, 0xb6, 0xd0, 0x8f, 0xff, 0xe1, 0xb8, 2784 0xfd, 0x3b, 0x05, 0xaa, 0x74, 0xaf, 0xe9, 0x7b, 0x1e, 0xb6, 0xa8, 0x33, 0x72, 0xe8, 0xdb, 0x0e, 2785 0x35, 0x29, 0x46, 0x87, 0x90, 0x23, 0xec, 0x07, 0x8f, 0x63, 0x75, 0xf7, 0xc9, 0xdc, 0x95, 0x4d, 2786 0xa9, 0x36, 0xf8, 0x5f, 0x5d, 0xa8, 0x6b, 0xbf, 0x86, 0x9c, 0x20, 0x2c, 0x41, 0xe1, 0xac, 0xfd, 2787 0x8b, 0xf6, 0xe9, 0xeb, 0x76, 0x6d, 0x05, 0x29, 0x90, 0x6d, 0x3d, 0x3f, 0x39, 0xa8, 0xa5, 0x50, 2788 0x15, 0xa0, 0x79, 0xda, 0x6e, 0x1f, 0x34, 0xbb, 0xad, 0xf6, 0x8b, 0x5a, 0x1a, 0x15, 0x21, 0xa7, 2789 0x1f, 0xec, 0x3d, 0xff, 0xae, 0x96, 0x41, 0x1f, 0xc1, 0x6a, 0x57, 0xdf, 0x6b, 0x77, 0x5a, 0x07, 2790 0xed, 0xae, 0x71, 0xb8, 0xd7, 0x3a, 0x39, 0xd3, 0x0f, 0x6a, 0x59, 0x54, 0x06, 0xa5, 0x73, 0x74, 2791 0xd6, 0x7d, 0xce, 0x98, 0x72, 0xda, 0x7f, 0xd2, 0x50, 0x4a, 0x64, 0x07, 0x7d, 0x93, 0xf4, 0xbb, 2792 0xb4, 0xfb, 0x70, 0x79, 0xbf, 0xa5, 0xc7, 0xe8, 0x2e, 0xe4, 0xa9, 0x19, 0xf4, 0x30, 0xe5, 0xe5, 2793 0x50, 0xd4, 0xe5, 0x13, 0x7a, 0x0a, 0x39, 0x1a, 0x98, 0x16, 0x56, 0x33, 0x9c, 0xf9, 0xd3, 0xb9, 2794 0xcc, 0x5d, 0x86, 0xd2, 0x05, 0x18, 0x6d, 0x42, 0xc5, 0x32, 0x5d, 0x97, 0x18, 0x84, 0x9a, 0x01, 2795 0xc5, 0xb6, 0x9a, 0xdd, 0x48, 0x6d, 0x65, 0xf4, 0x32, 0x17, 0x76, 0x84, 0x0c, 0x7d, 0x01, 0xb7, 2796 0x24, 0x68, 0x68, 0x59, 0x18, 0xdb, 0xd8, 0x56, 0x73, 0x1c, 0x56, 0x15, 0xb0, 0x50, 0x8a, 0xfe, 2797 0x0f, 0x84, 0xa2, 0x71, 0x61, 0x3a, 0x2e, 0xb6, 0xd5, 0x3c, 0x47, 0x95, 0xb8, 0xec, 0x90, 0x8b, 2798 0xd0, 0x77, 0x70, 0xcf, 0x35, 0x09, 0x35, 0x98, 0x2c, 0x34, 0x6a, 0x44, 0x43, 0x48, 0x2d, 0x70, 2799 0xe7, 0xeb, 0x0d, 0x31, 0x85, 0x1a, 0xe1, 0x14, 0x6a, 0x74, 0x43, 0x84, 0xae, 0x32, 0xf5, 0xa6, 2800 0xe9, 0xba, 0xd2, 0xbb, 0xe8, 0x8d, 0xf6, 0xa7, 0x0c, 0xac, 0x26, 0xd7, 0x78, 0x30, 0xc2, 0x1e, 2801 0x45, 0x1b, 0x50, 0xb2, 0x31, 0xb1, 0x02, 0x67, 0xc0, 0xc6, 0x20, 0x8f, 0x7b, 0x51, 0x4f, 0x8a, 2802 0xd0, 0x11, 0x28, 0x04, 0x8f, 0x70, 0xe0, 0xd0, 0xb7, 0x3c, 0xa6, 0xd5, 0xdd, 0xff, 0xbf, 0x39, 2803 0x78, 0x9c, 0xb8, 0xd1, 0x91, 0x3a, 0x7a, 0xa4, 0x8d, 0x7e, 0x0c, 0xc5, 0x78, 0x29, 0x99, 0x85, 2804 0x4b, 0x89, 0xc1, 0xe8, 0xe7, 0xe3, 0xfd, 0x9a, 0x5d, 0x3c, 0x52, 0x8f, 0x56, 0xc6, 0x3a, 0xf6, 2805 0x68, 0xaa, 0x63, 0x73, 0x4b, 0x4d, 0x98, 0xa3, 0x95, 0x89, 0x9e, 0xd5, 0x0e, 0x40, 0x09, 0x97, 2806 0xc6, 0xcb, 0xbf, 0x6b, 0xc4, 0x8d, 0x51, 0x82, 0x42, 0xb3, 0x6b, 0xb4, 0xda, 0x87, 0xa7, 0xb2, 2807 0x37, 0xba, 0xc6, 0xeb, 0x3d, 0xbd, 0x2d, 0x7a, 0xa3, 0x0c, 0x4a, 0xb3, 0x6b, 0x1c, 0xe8, 0xfa, 2808 0xa9, 0x5e, 0xcb, 0xec, 0x97, 0xa0, 0x68, 0x5d, 0x3a, 0xae, 0xcd, 0x7c, 0x61, 0xbd, 0x5c, 0x4e, 2809 0x46, 0x10, 0x3d, 0x84, 0x55, 0x6f, 0xd8, 0x37, 0x30, 0x8b, 0x24, 0x31, 0x5c, 0xbf, 0xd7, 0xc3, 2810 0x36, 0xcf, 0x4d, 0x46, 0xbf, 0xe5, 0x0d, 0xfb, 0x3c, 0xc2, 0xe4, 0x84, 0x8b, 0x51, 0x0b, 0x90, 2811 0x15, 0x60, 0xbe, 0x8b, 0x25, 0x2a, 0x25, 0xbd, 0x30, 0xbc, 0xab, 0xa1, 0x56, 0x24, 0x42, 0x5f, 2812 0x43, 0x5e, 0x98, 0x94, 0x13, 0x71, 0x73, 0x89, 0x44, 0xeb, 0x52, 0x45, 0xb3, 0x00, 0xe2, 0xf0, 2813 0xa3, 0x4f, 0x20, 0x0c, 0xbf, 0xe1, 0x84, 0xae, 0x17, 0xa5, 0xa4, 0x65, 0x23, 0x04, 0x59, 0xcf, 2814 0xec, 0x63, 0xd9, 0xa4, 0xfc, 0xf7, 0x71, 0x56, 0xc9, 0xd4, 0xb2, 0xc7, 0x59, 0x25, 0x5b, 0xcb, 2815 0x1d, 0x67, 0x95, 0x5c, 0x2d, 0x7f, 0x9c, 0x55, 0xf2, 0xb5, 0xc2, 0x71, 0x56, 0x29, 0xd4, 0x94, 2816 0xe3, 0xac, 0xa2, 0xd4, 0x8a, 0x9a, 0x0b, 0x95, 0xb1, 0xfc, 0xb0, 0x0e, 0x4d, 0x24, 0xd6, 0xb1, 2817 0x79, 0x8b, 0x64, 0xf4, 0x72, 0x2c, 0x4c, 0x58, 0x53, 0xc6, 0xac, 0xa5, 0x6a, 0xe9, 0xe3, 0xac, 2818 0x92, 0xae, 0x65, 0xe6, 0x59, 0xd6, 0xbe, 0x87, 0x62, 0x34, 0x7b, 0xd1, 0x3d, 0x90, 0xd3, 0x97, 2819 0x59, 0xc9, 0x70, 0x2b, 0x8a, 0x10, 0x24, 0x2c, 0x64, 0xe7, 0x5a, 0x98, 0xbd, 0x1e, 0x66, 0x01, 2820 0x07, 0x23, 0x1c, 0x84, 0x16, 0xf8, 0x03, 0xb3, 0x90, 0x93, 0x16, 0xb8, 0x20, 0x61, 0x21, 0xbf, 2821 0xd4, 0x1a, 0x62, 0x0b, 0x7f, 0x4d, 0x41, 0x5e, 0x98, 0x40, 0x8f, 0x93, 0x7b, 0xeb, 0xac, 0x7d, 2822 0x26, 0xf4, 0x44, 0xec, 0xab, 0x4f, 0xc6, 0xf6, 0xd5, 0xfb, 0xf3, 0xf0, 0x89, 0x6d, 0xf5, 0x1b, 2823 0xa8, 0xb8, 0x0e, 0xa1, 0xd8, 0x33, 0x44, 0x60, 0x64, 0x19, 0xdd, 0xb8, 0xa5, 0x95, 0x85, 0x86, 2824 0x10, 0x68, 0x7f, 0x60, 0xa7, 0x81, 0x88, 0x36, 0x9e, 0xda, 0xa9, 0x0f, 0x9a, 0xda, 0xe9, 0xe5, 2825 0xa6, 0x76, 0x66, 0xa9, 0xa9, 0x9d, 0x7d, 0xef, 0xa9, 0x9d, 0xfb, 0x80, 0xa9, 0xfd, 0x97, 0x34, 2826 0xe4, 0x45, 0x6c, 0x16, 0xa7, 0x2f, 0x8a, 0xe9, 0x92, 0xe9, 0xe3, 0xf8, 0x44, 0xfa, 0xb6, 0x21, 2827 0xe7, 0xfa, 0x96, 0xe9, 0xca, 0xd9, 0xbc, 0x36, 0xad, 0xb2, 0x67, 0xdb, 0x01, 0x26, 0x44, 0x17, 2828 0x38, 0xb4, 0x03, 0xf9, 0x00, 0xf7, 0x7d, 0x8a, 0xe5, 0x44, 0xbe, 0x41, 0x43, 0x02, 0xd1, 0x33, 2829 0xb6, 0x9b, 0x58, 0x43, 0xbe, 0x9b, 0x44, 0x71, 0x99, 0x2e, 0x2c, 0x81, 0xd0, 0x23, 0x2c, 0x5a, 2830 0x87, 0x92, 0x60, 0x30, 0x12, 0x5d, 0x00, 0x42, 0xd4, 0x36, 0xfb, 0x58, 0xfb, 0x7d, 0x01, 0x20, 2831 0x5e, 0x11, 0x4b, 0x2f, 0xa1, 0x01, 0x36, 0xfb, 0x71, 0x15, 0x88, 0x21, 0x54, 0x95, 0xe2, 0xb0, 2832 0x0e, 0x1e, 0xc1, 0x6a, 0x04, 0x8c, 0x2a, 0x41, 0x14, 0x4c, 0x2d, 0x84, 0x46, 0xb5, 0xf0, 0x39, 2833 0x84, 0xea, 0x61, 0x35, 0x88, 0x9a, 0xa9, 0x48, 0xa9, 0xac, 0x87, 0x4d, 0xa8, 0xf4, 0x31, 0x21, 2834 0x66, 0x0f, 0x13, 0x83, 0x60, 0x8f, 0x86, 0xc7, 0x86, 0x50, 0xd8, 0x61, 0x3b, 0xef, 0x23, 0x58, 2835 0x8d, 0x40, 0x01, 0xb6, 0xb0, 0x33, 0x8a, 0x0e, 0x0e, 0xb5, 0xf0, 0x85, 0x2e, 0xe5, 0x68, 0x0b, 2836 0x6a, 0x57, 0x18, 0x0f, 0x0c, 0xd3, 0x75, 0x46, 0x21, 0xa9, 0x38, 0x3e, 0x54, 0x99, 0x7c, 0x8f, 2837 0x8b, 0x39, 0xed, 0x25, 0x6c, 0xf2, 0x5a, 0xe4, 0x19, 0x32, 0x84, 0x5f, 0x06, 0x1f, 0xf5, 0xef, 2838 0x79, 0x92, 0x58, 0x67, 0x34, 0x27, 0x8c, 0xa5, 0xc3, 0x49, 0x9a, 0x82, 0x23, 0xde, 0x2d, 0x7e, 2839 0x03, 0x9f, 0x71, 0x4b, 0x32, 0x2f, 0x73, 0x4d, 0x29, 0x0b, 0x4d, 0x6d, 0x30, 0x1e, 0x9d, 0xd3, 2840 0xcc, 0xb1, 0x15, 0x76, 0x98, 0x0c, 0x0c, 0x0f, 0x40, 0xc2, 0x44, 0x71, 0xb9, 0x0e, 0x7b, 0x29, 2841 0xb4, 0x59, 0x9c, 0x62, 0x6a, 0x13, 0xd6, 0xc7, 0xa8, 0xc3, 0x5c, 0x24, 0xe8, 0x61, 0x21, 0xfd, 2842 0xfd, 0x04, 0x7d, 0x98, 0xb4, 0xd8, 0xc4, 0xb7, 0xb0, 0x26, 0xd2, 0x71, 0xe1, 0xfa, 0xd7, 0x86, 2843 0xe5, 0x7b, 0x34, 0xf0, 0x5d, 0xe3, 0xda, 0xf1, 0x6c, 0xff, 0x5a, 0x2d, 0x85, 0xfd, 0x3c, 0x41, 2844 0xde, 0xf2, 0xe8, 0xb3, 0xa7, 0xdf, 0x9a, 0xee, 0x10, 0xeb, 0x77, 0xb9, 0xf6, 0xa1, 0xeb, 0x5f, 2845 0x37, 0x85, 0xee, 0x6b, 0xae, 0x8a, 0xde, 0x40, 0x5d, 0x06, 0x7f, 0x16, 0x71, 0x79, 0x31, 0xf1, 2846 0xc7, 0x42, 0x7d, 0x9a, 0xf9, 0x19, 0xe4, 0x7d, 0x71, 0x22, 0xac, 0xf0, 0x11, 0xfe, 0xe9, 0xbc, 2847 0xf1, 0x71, 0xca, 0x51, 0xba, 0x44, 0x6b, 0xff, 0xcc, 0x40, 0x41, 0xb6, 0x3c, 0x7a, 0x09, 0x15, 2848 0x6a, 0x0d, 0x9c, 0x81, 0x61, 0x0a, 0x81, 0x9c, 0x5c, 0x0f, 0xe6, 0x0e, 0x89, 0x46, 0xd7, 0x1a, 2849 0xb4, 0x06, 0xf2, 0xe1, 0x68, 0x45, 0x2f, 0x73, 0xf5, 0x90, 0xee, 0x05, 0x94, 0x86, 0x36, 0x89, 2850 0xc8, 0xc4, 0x58, 0xfb, 0x6c, 0x3e, 0xd9, 0x99, 0x4d, 0x62, 0x2a, 0x18, 0x46, 0x4f, 0xcc, 0x2f, 2851 0x9f, 0x5e, 0xe2, 0x20, 0xa2, 0xca, 0x2c, 0xf2, 0xeb, 0x94, 0xc1, 0x13, 0x7e, 0xf9, 0x89, 0xe7, 2852 0xfa, 0x1e, 0x94, 0x93, 0x7e, 0xb3, 0x93, 0xcf, 0xc4, 0x9a, 0xcb, 0x7a, 0x31, 0x5e, 0x06, 0x82, 2853 0xec, 0xc0, 0x0f, 0xc4, 0xe7, 0x49, 0x4e, 0xe7, 0xbf, 0xeb, 0x5b, 0x00, 0xb1, 0xb7, 0xa8, 0x0e, 2854 0xca, 0x85, 0xe3, 0x62, 0x3e, 0xe7, 0xc4, 0x79, 0x3c, 0x7a, 0xae, 0xb7, 0xa1, 0x9c, 0x74, 0x26, 2855 0x3a, 0x15, 0xa4, 0xe2, 0x53, 0x01, 0x7a, 0x08, 0xb9, 0x11, 0xcb, 0xae, 0x0c, 0xd1, 0x9d, 0xa9, 2856 0x02, 0xd8, 0xf3, 0xde, 0xea, 0x02, 0xb2, 0x5f, 0x84, 0x82, 0xf4, 0x54, 0xfb, 0x63, 0x86, 0x9d, 2857 0x6c, 0xe5, 0xb8, 0xdd, 0x85, 0x0c, 0x75, 0xc9, 0xfc, 0x6d, 0x37, 0x04, 0x36, 0xba, 0x2e, 0x8b, 2858 0x08, 0x03, 0xb3, 0x8f, 0x37, 0x1e, 0x18, 0x69, 0x77, 0xeb, 0x06, 0x2d, 0xbe, 0x86, 0xf0, 0xe9, 2859 0x68, 0x45, 0x17, 0x8a, 0xf5, 0x7f, 0xa5, 0x20, 0xd3, 0x75, 0x09, 0xfa, 0x1c, 0x2a, 0x84, 0x9a, 2860 0x9e, 0x6d, 0x06, 0xb6, 0x11, 0x2f, 0x8f, 0x45, 0x3e, 0x14, 0xb3, 0x91, 0x8f, 0xd6, 0x01, 0x44, 2861 0x22, 0xe3, 0xa3, 0xe4, 0xd1, 0x8a, 0x5e, 0xe4, 0x32, 0x0e, 0x78, 0x04, 0xab, 0xa2, 0xef, 0x2c, 2862 0x1c, 0x50, 0xe7, 0xc2, 0xb1, 0xd8, 0xa7, 0x65, 0x86, 0x67, 0xa4, 0xc6, 0x5f, 0x34, 0x63, 0x39, 2863 0x7a, 0x0c, 0x48, 0x36, 0x53, 0x12, 0x9d, 0xe5, 0xe8, 0x55, 0xf1, 0x26, 0x01, 0xdf, 0xaf, 0x42, 2864 0xd9, 0x72, 0x06, 0xcc, 0x3a, 0x19, 0x3a, 0x14, 0xd7, 0x4f, 0xa1, 0x32, 0xb6, 0xaa, 0x0f, 0x4e, 2865 0x4d, 0x01, 0x72, 0x7d, 0xdf, 0xc6, 0xae, 0xe6, 0x41, 0x39, 0xd9, 0x6b, 0x33, 0x89, 0xef, 0x24, 2866 0x89, 0x8b, 0x92, 0x02, 0x3d, 0x05, 0x30, 0x6d, 0xdb, 0x61, 0x5a, 0xd1, 0xae, 0x3e, 0xdb, 0x66, 2867 0x02, 0xa7, 0x9d, 0xc0, 0xed, 0xa4, 0x3d, 0x36, 0xc6, 0xfc, 0x21, 0x45, 0x3f, 0x02, 0x25, 0xbc, 2868 0x2d, 0x93, 0x75, 0xb1, 0x36, 0x45, 0xf5, 0x5c, 0x02, 0xf4, 0x08, 0xaa, 0x59, 0x80, 0x92, 0x6c, 2869 0x27, 0x8e, 0xd7, 0xc3, 0x01, 0xfb, 0x4c, 0x37, 0xd9, 0xe7, 0xbb, 0x58, 0x85, 0xa2, 0xcb, 0xa7, 2870 0x31, 0x23, 0xe9, 0xe5, 0x8d, 0xfc, 0x5d, 0x99, 0xf0, 0xd9, 0x1a, 0xb4, 0xbc, 0x0b, 0x9f, 0xf5, 2871 0x22, 0x9b, 0x21, 0x46, 0x7c, 0xa9, 0x50, 0xd1, 0x8b, 0x4c, 0x22, 0x6e, 0x35, 0x34, 0x31, 0xa1, 2872 0x0c, 0xcb, 0x94, 0x88, 0x34, 0x47, 0x94, 0x98, 0xb0, 0x69, 0x0a, 0xcc, 0x97, 0x50, 0xe3, 0x98, 2873 0x00, 0xd3, 0xc0, 0xf4, 0x48, 0xdf, 0xa1, 0x62, 0x60, 0x54, 0xf4, 0x5b, 0x4c, 0xae, 0xc7, 0x62, 2874 0x76, 0x46, 0xe1, 0xd0, 0x41, 0xe0, 0x9f, 0x63, 0xc2, 0x4b, 0xa7, 0xa2, 0x73, 0x07, 0x5e, 0x71, 2875 0x09, 0x3b, 0x4a, 0x72, 0xc0, 0xb9, 0x69, 0x5d, 0xf9, 0x17, 0xe2, 0x1b, 0x54, 0x9a, 0xdb, 0x17, 2876 0xa2, 0x08, 0x22, 0xe6, 0x29, 0xe1, 0x9b, 0xbc, 0x84, 0x88, 0xa5, 0x11, 0xf4, 0x00, 0x6e, 0x89, 2877 0x45, 0x79, 0xb6, 0x71, 0x4d, 0x2c, 0xd3, 0xc5, 0x7c, 0x37, 0xaf, 0xe8, 0x7c, 0x31, 0x1d, 0xcf, 2878 0x7e, 0xcd, 0x85, 0x11, 0x2e, 0xb0, 0x46, 0x21, 0x4e, 0x89, 0x71, 0xba, 0x35, 0x92, 0xb8, 0x35, 2879 0x50, 0x04, 0x8e, 0xfa, 0x7c, 0x23, 0xad, 0xe8, 0x05, 0x0e, 0xa0, 0x7e, 0xf4, 0xca, 0xa4, 0x3e, 2880 0xdf, 0x04, 0xe5, 0xab, 0x3d, 0xea, 0xa3, 0x0d, 0xe9, 0x28, 0xf3, 0xa2, 0x4f, 0x08, 0xdf, 0xc6, 2881 0xe4, 0x6a, 0x3b, 0x9e, 0xfd, 0x92, 0x90, 0x08, 0xc1, 0xec, 0x33, 0x44, 0x39, 0x46, 0xe8, 0xd6, 2882 0x88, 0x21, 0xc2, 0xc5, 0x0e, 0x3d, 0xd3, 0xba, 0xc2, 0xb6, 0x5a, 0x89, 0x17, 0x7b, 0x26, 0x44, 2883 0x51, 0x4c, 0x89, 0x40, 0x54, 0x13, 0x56, 0x04, 0xe0, 0x1e, 0xf0, 0x84, 0x1a, 0xae, 0x4f, 0xa8, 2884 0x7a, 0x8b, 0xbf, 0xe6, 0x3e, 0x9f, 0xf8, 0x84, 0x46, 0x06, 0x64, 0xf2, 0xd4, 0x5a, 0x6c, 0x40, 2885 0x26, 0x2e, 0x82, 0x5c, 0x30, 0x3a, 0x4a, 0xd4, 0xd5, 0x18, 0x72, 0x28, 0x44, 0xe8, 0x31, 0xdc, 2886 0x16, 0x26, 0xd8, 0x31, 0x81, 0x9d, 0x94, 0xc5, 0xf9, 0x0b, 0x71, 0x24, 0xaf, 0x8e, 0x13, 0x93, 2887 0xf0, 0x63, 0xa7, 0x3c, 0xd8, 0xa1, 0x18, 0x6e, 0x5a, 0x57, 0x02, 0x7d, 0x3b, 0xae, 0x19, 0x86, 2888 0xde, 0xb3, 0xae, 0x38, 0x78, 0x9a, 0x3b, 0xc0, 0xd6, 0x48, 0xbd, 0x33, 0xcd, 0xad, 0x63, 0x6b, 2889 0x34, 0xcd, 0xcd, 0xd1, 0x1f, 0x4d, 0x71, 0x73, 0x70, 0x18, 0x9a, 0x41, 0x9f, 0x0e, 0xd5, 0xbb, 2890 0x71, 0x68, 0x5e, 0xf5, 0xe9, 0x10, 0x3d, 0x84, 0xd5, 0x28, 0x3b, 0x84, 0xd0, 0xcb, 0x00, 0x93, 2891 0x4b, 0xf5, 0xe3, 0x44, 0x61, 0x5b, 0xa3, 0x8e, 0x14, 0x27, 0x2a, 0x84, 0xaa, 0x6a, 0xb2, 0x42, 2892 0x68, 0x94, 0x9f, 0x80, 0xd2, 0x91, 0x19, 0xa8, 0x6b, 0x89, 0x1c, 0x73, 0x49, 0x64, 0x87, 0xd5, 2893 0x49, 0x64, 0xa7, 0x1e, 0xdb, 0xe9, 0x78, 0x76, 0x64, 0x27, 0xec, 0x47, 0x86, 0xb5, 0xae, 0x3d, 2894 0x5b, 0xbd, 0x17, 0x27, 0xa3, 0xe3, 0xd9, 0xcd, 0x6b, 0x2f, 0x2e, 0x08, 0xd3, 0x1e, 0xb1, 0xa2, 2895 0xba, 0x1f, 0x1b, 0xdc, 0xe3, 0x12, 0x76, 0xf2, 0x97, 0x39, 0xf7, 0x03, 0x1b, 0x07, 0x8e, 0xd7, 2896 0x53, 0x3f, 0xe1, 0xa0, 0xaa, 0x48, 0x7b, 0x28, 0xd5, 0xce, 0xe1, 0xa3, 0x17, 0x98, 0x76, 0xfd, 2897 0x81, 0xfc, 0x86, 0x24, 0x3a, 0xfe, 0xed, 0x10, 0x13, 0xca, 0x0e, 0xdb, 0xfc, 0x9b, 0xc1, 0x98, 2898 0xba, 0xc1, 0xa8, 0x72, 0x79, 0x33, 0xba, 0x58, 0x58, 0x87, 0x52, 0xdf, 0xfc, 0xc1, 0x08, 0x30, 2899 0x19, 0xba, 0x94, 0xc8, 0xcf, 0x06, 0xe8, 0x9b, 0x3f, 0xe8, 0x42, 0xa2, 0x19, 0x70, 0x77, 0xd2, 2900 0x06, 0x19, 0xf8, 0x1e, 0xc1, 0xe8, 0x2b, 0x28, 0x48, 0x7a, 0x35, 0xc5, 0x8f, 0x58, 0x6b, 0xf3, 2901 0xaf, 0xb3, 0x42, 0x24, 0xaa, 0x41, 0x06, 0x7b, 0xe2, 0xf3, 0x44, 0xd1, 0xd9, 0x4f, 0xed, 0x57, 2902 0xb0, 0xfa, 0x02, 0x53, 0xf1, 0xc9, 0x1c, 0x2d, 0xe0, 0x01, 0xfb, 0xf8, 0x61, 0x0b, 0x88, 0xaf, 2903 0x13, 0x52, 0xe1, 0x77, 0x8a, 0x19, 0x48, 0xf4, 0x32, 0xee, 0xbf, 0x01, 0x94, 0x64, 0x97, 0xae, 2904 0x3f, 0x81, 0xbc, 0x20, 0x96, 0x9e, 0xab, 0x73, 0xaf, 0x12, 0x24, 0x6e, 0x86, 0xdf, 0xdb, 0x50, 2905 0x8b, 0x98, 0x43, 0xb7, 0xc7, 0xee, 0x3f, 0x52, 0xe3, 0xf7, 0x1f, 0xda, 0x41, 0x62, 0xa1, 0x33, 2906 0x3d, 0x49, 0x2d, 0xe3, 0x89, 0xf6, 0x3b, 0xf8, 0x38, 0xa2, 0x11, 0x3b, 0x06, 0x59, 0xc6, 0x7c, 2907 0x22, 0xa4, 0xd1, 0x1d, 0x50, 0x3a, 0x19, 0xd2, 0xf0, 0x22, 0x68, 0x22, 0xa4, 0x99, 0xa9, 0x90, 2908 0x5e, 0x82, 0x3a, 0xed, 0x80, 0x5c, 0xce, 0xf8, 0xff, 0x03, 0x52, 0xef, 0xf3, 0xff, 0x80, 0x19, 2909 0x21, 0xde, 0xe5, 0x11, 0x8b, 0xee, 0xe4, 0xc4, 0x22, 0x6f, 0xbe, 0x97, 0xd3, 0x5a, 0x3c, 0xe1, 2910 0x91, 0xce, 0xac, 0x5a, 0x4d, 0x2d, 0x57, 0xab, 0xda, 0xd7, 0x70, 0x87, 0x2d, 0x34, 0x71, 0x5b, 2911 0x27, 0x3c, 0x98, 0xba, 0xb1, 0x4b, 0x4d, 0xdf, 0xd8, 0x69, 0x67, 0xbc, 0x37, 0x93, 0xca, 0xd2, 2912 0x95, 0x9f, 0x02, 0xc4, 0xc0, 0xf9, 0xff, 0x5b, 0x4b, 0x68, 0x26, 0xf0, 0x5a, 0x4b, 0x54, 0x9d, 2913 0x0c, 0x5a, 0x9c, 0xf6, 0x28, 0xa7, 0xa9, 0x89, 0x7b, 0x3d, 0x15, 0x0a, 0x64, 0xd8, 0xef, 0x9b, 2914 0xc1, 0x5b, 0x19, 0xd9, 0xf0, 0x31, 0xac, 0x47, 0x49, 0x95, 0xa8, 0x47, 0x71, 0xf3, 0x35, 0xbf, 2915 0x1e, 0x85, 0x86, 0xc4, 0xed, 0xfe, 0x39, 0x07, 0x8a, 0x0c, 0xdd, 0x3b, 0x64, 0x41, 0x75, 0x7c, 2916 0x5a, 0xa0, 0x2f, 0xa6, 0x09, 0x66, 0xce, 0xac, 0xfa, 0xd6, 0x62, 0xa0, 0xf4, 0xf1, 0x35, 0x40, 2917 0xdc, 0xd3, 0x68, 0x73, 0xa6, 0xde, 0xf8, 0x3c, 0xa9, 0x7f, 0x76, 0x33, 0x48, 0x12, 0x77, 0xa1, 2918 0x18, 0x49, 0x91, 0x76, 0x83, 0x4a, 0x48, 0xbb, 0x79, 0x23, 0x46, 0xb2, 0x3a, 0x89, 0x41, 0x21, 2919 0xfb, 0x05, 0x7d, 0x79, 0x83, 0xe2, 0x78, 0x53, 0xd7, 0x1f, 0x2e, 0x03, 0x1d, 0x8b, 0x4c, 0xf8, 2920 0xef, 0xdb, 0xd9, 0xde, 0x8d, 0xb7, 0xd3, 0x9c, 0xc8, 0x4c, 0xf6, 0xcf, 0xf7, 0x50, 0x19, 0xab, 2921 0x66, 0xf4, 0x60, 0xb6, 0x57, 0x93, 0xbd, 0x52, 0xff, 0x62, 0x21, 0x6e, 0x3c, 0xf6, 0xe2, 0xa2, 2922 0x70, 0x4e, 0xec, 0x93, 0x55, 0x3f, 0x2f, 0xf6, 0x63, 0xe5, 0xbc, 0xff, 0x06, 0x6e, 0x3b, 0xfe, 2923 0x14, 0x70, 0xbf, 0x12, 0x16, 0xec, 0x2b, 0x76, 0x24, 0x7f, 0x95, 0xfa, 0xe5, 0x13, 0x79, 0x44, 2924 0xef, 0xf9, 0xae, 0xe9, 0xf5, 0x1a, 0x7e, 0xd0, 0xdb, 0x1e, 0xff, 0xb7, 0x3d, 0x7b, 0x0a, 0x77, 2925 0xd3, 0x77, 0xc6, 0x68, 0xe7, 0x3c, 0xcf, 0x4f, 0xf3, 0x5f, 0xfd, 0x37, 0x00, 0x00, 0xff, 0xff, 2926 0x54, 0xae, 0x0b, 0x93, 0xdf, 0x1f, 0x00, 0x00, 2927} 2928 2929// Reference imports to suppress errors if they are not otherwise used. 2930var _ context.Context 2931var _ grpc.ClientConn 2932 2933// This is a compile-time assertion to ensure that this generated file 2934// is compatible with the grpc package it is being compiled against. 2935const _ = grpc.SupportPackageIsVersion4 2936 2937// ChannelzClient is the client API for Channelz service. 2938// 2939// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 2940type ChannelzClient interface { 2941 // Gets all root channels (i.e. channels the application has directly 2942 // created). This does not include subchannels nor non-top level channels. 2943 GetTopChannels(ctx context.Context, in *GetTopChannelsRequest, opts ...grpc.CallOption) (*GetTopChannelsResponse, error) 2944 // Gets all servers that exist in the process. 2945 GetServers(ctx context.Context, in *GetServersRequest, opts ...grpc.CallOption) (*GetServersResponse, error) 2946 // Returns a single Server, or else a NOT_FOUND code. 2947 GetServer(ctx context.Context, in *GetServerRequest, opts ...grpc.CallOption) (*GetServerResponse, error) 2948 // Gets all server sockets that exist in the process. 2949 GetServerSockets(ctx context.Context, in *GetServerSocketsRequest, opts ...grpc.CallOption) (*GetServerSocketsResponse, error) 2950 // Returns a single Channel, or else a NOT_FOUND code. 2951 GetChannel(ctx context.Context, in *GetChannelRequest, opts ...grpc.CallOption) (*GetChannelResponse, error) 2952 // Returns a single Subchannel, or else a NOT_FOUND code. 2953 GetSubchannel(ctx context.Context, in *GetSubchannelRequest, opts ...grpc.CallOption) (*GetSubchannelResponse, error) 2954 // Returns a single Socket or else a NOT_FOUND code. 2955 GetSocket(ctx context.Context, in *GetSocketRequest, opts ...grpc.CallOption) (*GetSocketResponse, error) 2956} 2957 2958type channelzClient struct { 2959 cc *grpc.ClientConn 2960} 2961 2962func NewChannelzClient(cc *grpc.ClientConn) ChannelzClient { 2963 return &channelzClient{cc} 2964} 2965 2966func (c *channelzClient) GetTopChannels(ctx context.Context, in *GetTopChannelsRequest, opts ...grpc.CallOption) (*GetTopChannelsResponse, error) { 2967 out := new(GetTopChannelsResponse) 2968 err := c.cc.Invoke(ctx, "/grpc.channelz.v1.Channelz/GetTopChannels", in, out, opts...) 2969 if err != nil { 2970 return nil, err 2971 } 2972 return out, nil 2973} 2974 2975func (c *channelzClient) GetServers(ctx context.Context, in *GetServersRequest, opts ...grpc.CallOption) (*GetServersResponse, error) { 2976 out := new(GetServersResponse) 2977 err := c.cc.Invoke(ctx, "/grpc.channelz.v1.Channelz/GetServers", in, out, opts...) 2978 if err != nil { 2979 return nil, err 2980 } 2981 return out, nil 2982} 2983 2984func (c *channelzClient) GetServer(ctx context.Context, in *GetServerRequest, opts ...grpc.CallOption) (*GetServerResponse, error) { 2985 out := new(GetServerResponse) 2986 err := c.cc.Invoke(ctx, "/grpc.channelz.v1.Channelz/GetServer", in, out, opts...) 2987 if err != nil { 2988 return nil, err 2989 } 2990 return out, nil 2991} 2992 2993func (c *channelzClient) GetServerSockets(ctx context.Context, in *GetServerSocketsRequest, opts ...grpc.CallOption) (*GetServerSocketsResponse, error) { 2994 out := new(GetServerSocketsResponse) 2995 err := c.cc.Invoke(ctx, "/grpc.channelz.v1.Channelz/GetServerSockets", in, out, opts...) 2996 if err != nil { 2997 return nil, err 2998 } 2999 return out, nil 3000} 3001 3002func (c *channelzClient) GetChannel(ctx context.Context, in *GetChannelRequest, opts ...grpc.CallOption) (*GetChannelResponse, error) { 3003 out := new(GetChannelResponse) 3004 err := c.cc.Invoke(ctx, "/grpc.channelz.v1.Channelz/GetChannel", in, out, opts...) 3005 if err != nil { 3006 return nil, err 3007 } 3008 return out, nil 3009} 3010 3011func (c *channelzClient) GetSubchannel(ctx context.Context, in *GetSubchannelRequest, opts ...grpc.CallOption) (*GetSubchannelResponse, error) { 3012 out := new(GetSubchannelResponse) 3013 err := c.cc.Invoke(ctx, "/grpc.channelz.v1.Channelz/GetSubchannel", in, out, opts...) 3014 if err != nil { 3015 return nil, err 3016 } 3017 return out, nil 3018} 3019 3020func (c *channelzClient) GetSocket(ctx context.Context, in *GetSocketRequest, opts ...grpc.CallOption) (*GetSocketResponse, error) { 3021 out := new(GetSocketResponse) 3022 err := c.cc.Invoke(ctx, "/grpc.channelz.v1.Channelz/GetSocket", in, out, opts...) 3023 if err != nil { 3024 return nil, err 3025 } 3026 return out, nil 3027} 3028 3029// ChannelzServer is the server API for Channelz service. 3030type ChannelzServer interface { 3031 // Gets all root channels (i.e. channels the application has directly 3032 // created). This does not include subchannels nor non-top level channels. 3033 GetTopChannels(context.Context, *GetTopChannelsRequest) (*GetTopChannelsResponse, error) 3034 // Gets all servers that exist in the process. 3035 GetServers(context.Context, *GetServersRequest) (*GetServersResponse, error) 3036 // Returns a single Server, or else a NOT_FOUND code. 3037 GetServer(context.Context, *GetServerRequest) (*GetServerResponse, error) 3038 // Gets all server sockets that exist in the process. 3039 GetServerSockets(context.Context, *GetServerSocketsRequest) (*GetServerSocketsResponse, error) 3040 // Returns a single Channel, or else a NOT_FOUND code. 3041 GetChannel(context.Context, *GetChannelRequest) (*GetChannelResponse, error) 3042 // Returns a single Subchannel, or else a NOT_FOUND code. 3043 GetSubchannel(context.Context, *GetSubchannelRequest) (*GetSubchannelResponse, error) 3044 // Returns a single Socket or else a NOT_FOUND code. 3045 GetSocket(context.Context, *GetSocketRequest) (*GetSocketResponse, error) 3046} 3047 3048// UnimplementedChannelzServer can be embedded to have forward compatible implementations. 3049type UnimplementedChannelzServer struct { 3050} 3051 3052func (*UnimplementedChannelzServer) GetTopChannels(ctx context.Context, req *GetTopChannelsRequest) (*GetTopChannelsResponse, error) { 3053 return nil, status.Errorf(codes.Unimplemented, "method GetTopChannels not implemented") 3054} 3055func (*UnimplementedChannelzServer) GetServers(ctx context.Context, req *GetServersRequest) (*GetServersResponse, error) { 3056 return nil, status.Errorf(codes.Unimplemented, "method GetServers not implemented") 3057} 3058func (*UnimplementedChannelzServer) GetServer(ctx context.Context, req *GetServerRequest) (*GetServerResponse, error) { 3059 return nil, status.Errorf(codes.Unimplemented, "method GetServer not implemented") 3060} 3061func (*UnimplementedChannelzServer) GetServerSockets(ctx context.Context, req *GetServerSocketsRequest) (*GetServerSocketsResponse, error) { 3062 return nil, status.Errorf(codes.Unimplemented, "method GetServerSockets not implemented") 3063} 3064func (*UnimplementedChannelzServer) GetChannel(ctx context.Context, req *GetChannelRequest) (*GetChannelResponse, error) { 3065 return nil, status.Errorf(codes.Unimplemented, "method GetChannel not implemented") 3066} 3067func (*UnimplementedChannelzServer) GetSubchannel(ctx context.Context, req *GetSubchannelRequest) (*GetSubchannelResponse, error) { 3068 return nil, status.Errorf(codes.Unimplemented, "method GetSubchannel not implemented") 3069} 3070func (*UnimplementedChannelzServer) GetSocket(ctx context.Context, req *GetSocketRequest) (*GetSocketResponse, error) { 3071 return nil, status.Errorf(codes.Unimplemented, "method GetSocket not implemented") 3072} 3073 3074func RegisterChannelzServer(s *grpc.Server, srv ChannelzServer) { 3075 s.RegisterService(&_Channelz_serviceDesc, srv) 3076} 3077 3078func _Channelz_GetTopChannels_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3079 in := new(GetTopChannelsRequest) 3080 if err := dec(in); err != nil { 3081 return nil, err 3082 } 3083 if interceptor == nil { 3084 return srv.(ChannelzServer).GetTopChannels(ctx, in) 3085 } 3086 info := &grpc.UnaryServerInfo{ 3087 Server: srv, 3088 FullMethod: "/grpc.channelz.v1.Channelz/GetTopChannels", 3089 } 3090 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3091 return srv.(ChannelzServer).GetTopChannels(ctx, req.(*GetTopChannelsRequest)) 3092 } 3093 return interceptor(ctx, in, info, handler) 3094} 3095 3096func _Channelz_GetServers_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3097 in := new(GetServersRequest) 3098 if err := dec(in); err != nil { 3099 return nil, err 3100 } 3101 if interceptor == nil { 3102 return srv.(ChannelzServer).GetServers(ctx, in) 3103 } 3104 info := &grpc.UnaryServerInfo{ 3105 Server: srv, 3106 FullMethod: "/grpc.channelz.v1.Channelz/GetServers", 3107 } 3108 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3109 return srv.(ChannelzServer).GetServers(ctx, req.(*GetServersRequest)) 3110 } 3111 return interceptor(ctx, in, info, handler) 3112} 3113 3114func _Channelz_GetServer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3115 in := new(GetServerRequest) 3116 if err := dec(in); err != nil { 3117 return nil, err 3118 } 3119 if interceptor == nil { 3120 return srv.(ChannelzServer).GetServer(ctx, in) 3121 } 3122 info := &grpc.UnaryServerInfo{ 3123 Server: srv, 3124 FullMethod: "/grpc.channelz.v1.Channelz/GetServer", 3125 } 3126 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3127 return srv.(ChannelzServer).GetServer(ctx, req.(*GetServerRequest)) 3128 } 3129 return interceptor(ctx, in, info, handler) 3130} 3131 3132func _Channelz_GetServerSockets_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3133 in := new(GetServerSocketsRequest) 3134 if err := dec(in); err != nil { 3135 return nil, err 3136 } 3137 if interceptor == nil { 3138 return srv.(ChannelzServer).GetServerSockets(ctx, in) 3139 } 3140 info := &grpc.UnaryServerInfo{ 3141 Server: srv, 3142 FullMethod: "/grpc.channelz.v1.Channelz/GetServerSockets", 3143 } 3144 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3145 return srv.(ChannelzServer).GetServerSockets(ctx, req.(*GetServerSocketsRequest)) 3146 } 3147 return interceptor(ctx, in, info, handler) 3148} 3149 3150func _Channelz_GetChannel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3151 in := new(GetChannelRequest) 3152 if err := dec(in); err != nil { 3153 return nil, err 3154 } 3155 if interceptor == nil { 3156 return srv.(ChannelzServer).GetChannel(ctx, in) 3157 } 3158 info := &grpc.UnaryServerInfo{ 3159 Server: srv, 3160 FullMethod: "/grpc.channelz.v1.Channelz/GetChannel", 3161 } 3162 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3163 return srv.(ChannelzServer).GetChannel(ctx, req.(*GetChannelRequest)) 3164 } 3165 return interceptor(ctx, in, info, handler) 3166} 3167 3168func _Channelz_GetSubchannel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3169 in := new(GetSubchannelRequest) 3170 if err := dec(in); err != nil { 3171 return nil, err 3172 } 3173 if interceptor == nil { 3174 return srv.(ChannelzServer).GetSubchannel(ctx, in) 3175 } 3176 info := &grpc.UnaryServerInfo{ 3177 Server: srv, 3178 FullMethod: "/grpc.channelz.v1.Channelz/GetSubchannel", 3179 } 3180 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3181 return srv.(ChannelzServer).GetSubchannel(ctx, req.(*GetSubchannelRequest)) 3182 } 3183 return interceptor(ctx, in, info, handler) 3184} 3185 3186func _Channelz_GetSocket_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3187 in := new(GetSocketRequest) 3188 if err := dec(in); err != nil { 3189 return nil, err 3190 } 3191 if interceptor == nil { 3192 return srv.(ChannelzServer).GetSocket(ctx, in) 3193 } 3194 info := &grpc.UnaryServerInfo{ 3195 Server: srv, 3196 FullMethod: "/grpc.channelz.v1.Channelz/GetSocket", 3197 } 3198 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3199 return srv.(ChannelzServer).GetSocket(ctx, req.(*GetSocketRequest)) 3200 } 3201 return interceptor(ctx, in, info, handler) 3202} 3203 3204var _Channelz_serviceDesc = grpc.ServiceDesc{ 3205 ServiceName: "grpc.channelz.v1.Channelz", 3206 HandlerType: (*ChannelzServer)(nil), 3207 Methods: []grpc.MethodDesc{ 3208 { 3209 MethodName: "GetTopChannels", 3210 Handler: _Channelz_GetTopChannels_Handler, 3211 }, 3212 { 3213 MethodName: "GetServers", 3214 Handler: _Channelz_GetServers_Handler, 3215 }, 3216 { 3217 MethodName: "GetServer", 3218 Handler: _Channelz_GetServer_Handler, 3219 }, 3220 { 3221 MethodName: "GetServerSockets", 3222 Handler: _Channelz_GetServerSockets_Handler, 3223 }, 3224 { 3225 MethodName: "GetChannel", 3226 Handler: _Channelz_GetChannel_Handler, 3227 }, 3228 { 3229 MethodName: "GetSubchannel", 3230 Handler: _Channelz_GetSubchannel_Handler, 3231 }, 3232 { 3233 MethodName: "GetSocket", 3234 Handler: _Channelz_GetSocket_Handler, 3235 }, 3236 }, 3237 Streams: []grpc.StreamDesc{}, 3238 Metadata: "grpc/channelz/v1/channelz.proto", 3239} 3240