channelz.pb.go 120 KB

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