containers.pb.go 61 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758
  1. //
  2. // Copyright 2020 Docker, Inc.
  3. // Licensed under the Apache License, Version 2.0 (the "License");
  4. // you may not use this file except in compliance with the License.
  5. // You may obtain a copy of the License at
  6. // http://www.apache.org/licenses/LICENSE-2.0
  7. // Unless required by applicable law or agreed to in writing, software
  8. // distributed under the License is distributed on an "AS IS" BASIS,
  9. // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  10. // See the License for the specific language governing permissions and
  11. // limitations under the License.
  12. // Code generated by protoc-gen-go. DO NOT EDIT.
  13. // versions:
  14. // protoc-gen-go v1.25.0
  15. // protoc v3.11.2
  16. // source: protos/containers/v1/containers.proto
  17. package v1
  18. import (
  19. context "context"
  20. proto "github.com/golang/protobuf/proto"
  21. grpc "google.golang.org/grpc"
  22. codes "google.golang.org/grpc/codes"
  23. status "google.golang.org/grpc/status"
  24. protoreflect "google.golang.org/protobuf/reflect/protoreflect"
  25. protoimpl "google.golang.org/protobuf/runtime/protoimpl"
  26. reflect "reflect"
  27. sync "sync"
  28. )
  29. const (
  30. // Verify that this generated code is sufficiently up-to-date.
  31. _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
  32. // Verify that runtime/protoimpl is sufficiently up-to-date.
  33. _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
  34. )
  35. // This is a compile-time assertion that a sufficiently up-to-date version
  36. // of the legacy proto package is being used.
  37. const _ = proto.ProtoPackageIsVersion4
  38. type Port struct {
  39. state protoimpl.MessageState
  40. sizeCache protoimpl.SizeCache
  41. unknownFields protoimpl.UnknownFields
  42. HostPort uint32 `protobuf:"varint,1,opt,name=host_port,json=hostPort,proto3" json:"host_port,omitempty"`
  43. ContainerPort uint32 `protobuf:"varint,2,opt,name=container_port,json=containerPort,proto3" json:"container_port,omitempty"`
  44. Protocol string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"`
  45. HostIp string `protobuf:"bytes,4,opt,name=host_ip,json=hostIp,proto3" json:"host_ip,omitempty"`
  46. }
  47. func (x *Port) Reset() {
  48. *x = Port{}
  49. if protoimpl.UnsafeEnabled {
  50. mi := &file_protos_containers_v1_containers_proto_msgTypes[0]
  51. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  52. ms.StoreMessageInfo(mi)
  53. }
  54. }
  55. func (x *Port) String() string {
  56. return protoimpl.X.MessageStringOf(x)
  57. }
  58. func (*Port) ProtoMessage() {}
  59. func (x *Port) ProtoReflect() protoreflect.Message {
  60. mi := &file_protos_containers_v1_containers_proto_msgTypes[0]
  61. if protoimpl.UnsafeEnabled && x != nil {
  62. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  63. if ms.LoadMessageInfo() == nil {
  64. ms.StoreMessageInfo(mi)
  65. }
  66. return ms
  67. }
  68. return mi.MessageOf(x)
  69. }
  70. // Deprecated: Use Port.ProtoReflect.Descriptor instead.
  71. func (*Port) Descriptor() ([]byte, []int) {
  72. return file_protos_containers_v1_containers_proto_rawDescGZIP(), []int{0}
  73. }
  74. func (x *Port) GetHostPort() uint32 {
  75. if x != nil {
  76. return x.HostPort
  77. }
  78. return 0
  79. }
  80. func (x *Port) GetContainerPort() uint32 {
  81. if x != nil {
  82. return x.ContainerPort
  83. }
  84. return 0
  85. }
  86. func (x *Port) GetProtocol() string {
  87. if x != nil {
  88. return x.Protocol
  89. }
  90. return ""
  91. }
  92. func (x *Port) GetHostIp() string {
  93. if x != nil {
  94. return x.HostIp
  95. }
  96. return ""
  97. }
  98. type Container struct {
  99. state protoimpl.MessageState
  100. sizeCache protoimpl.SizeCache
  101. unknownFields protoimpl.UnknownFields
  102. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
  103. Image string `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
  104. Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
  105. Command string `protobuf:"bytes,4,opt,name=command,proto3" json:"command,omitempty"`
  106. CpuTime uint64 `protobuf:"varint,5,opt,name=cpu_time,json=cpuTime,proto3" json:"cpu_time,omitempty"`
  107. MemoryUsage uint64 `protobuf:"varint,6,opt,name=memory_usage,json=memoryUsage,proto3" json:"memory_usage,omitempty"`
  108. MemoryLimit uint64 `protobuf:"varint,7,opt,name=memory_limit,json=memoryLimit,proto3" json:"memory_limit,omitempty"`
  109. PidsCurrent uint64 `protobuf:"varint,8,opt,name=pids_current,json=pidsCurrent,proto3" json:"pids_current,omitempty"`
  110. PidsLimit uint64 `protobuf:"varint,9,opt,name=pids_limit,json=pidsLimit,proto3" json:"pids_limit,omitempty"`
  111. Labels []string `protobuf:"bytes,10,rep,name=labels,proto3" json:"labels,omitempty"`
  112. Ports []*Port `protobuf:"bytes,11,rep,name=ports,proto3" json:"ports,omitempty"`
  113. CpuLimit uint64 `protobuf:"varint,12,opt,name=cpu_limit,json=cpuLimit,proto3" json:"cpu_limit,omitempty"`
  114. }
  115. func (x *Container) Reset() {
  116. *x = Container{}
  117. if protoimpl.UnsafeEnabled {
  118. mi := &file_protos_containers_v1_containers_proto_msgTypes[1]
  119. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  120. ms.StoreMessageInfo(mi)
  121. }
  122. }
  123. func (x *Container) String() string {
  124. return protoimpl.X.MessageStringOf(x)
  125. }
  126. func (*Container) ProtoMessage() {}
  127. func (x *Container) ProtoReflect() protoreflect.Message {
  128. mi := &file_protos_containers_v1_containers_proto_msgTypes[1]
  129. if protoimpl.UnsafeEnabled && x != nil {
  130. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  131. if ms.LoadMessageInfo() == nil {
  132. ms.StoreMessageInfo(mi)
  133. }
  134. return ms
  135. }
  136. return mi.MessageOf(x)
  137. }
  138. // Deprecated: Use Container.ProtoReflect.Descriptor instead.
  139. func (*Container) Descriptor() ([]byte, []int) {
  140. return file_protos_containers_v1_containers_proto_rawDescGZIP(), []int{1}
  141. }
  142. func (x *Container) GetId() string {
  143. if x != nil {
  144. return x.Id
  145. }
  146. return ""
  147. }
  148. func (x *Container) GetImage() string {
  149. if x != nil {
  150. return x.Image
  151. }
  152. return ""
  153. }
  154. func (x *Container) GetStatus() string {
  155. if x != nil {
  156. return x.Status
  157. }
  158. return ""
  159. }
  160. func (x *Container) GetCommand() string {
  161. if x != nil {
  162. return x.Command
  163. }
  164. return ""
  165. }
  166. func (x *Container) GetCpuTime() uint64 {
  167. if x != nil {
  168. return x.CpuTime
  169. }
  170. return 0
  171. }
  172. func (x *Container) GetMemoryUsage() uint64 {
  173. if x != nil {
  174. return x.MemoryUsage
  175. }
  176. return 0
  177. }
  178. func (x *Container) GetMemoryLimit() uint64 {
  179. if x != nil {
  180. return x.MemoryLimit
  181. }
  182. return 0
  183. }
  184. func (x *Container) GetPidsCurrent() uint64 {
  185. if x != nil {
  186. return x.PidsCurrent
  187. }
  188. return 0
  189. }
  190. func (x *Container) GetPidsLimit() uint64 {
  191. if x != nil {
  192. return x.PidsLimit
  193. }
  194. return 0
  195. }
  196. func (x *Container) GetLabels() []string {
  197. if x != nil {
  198. return x.Labels
  199. }
  200. return nil
  201. }
  202. func (x *Container) GetPorts() []*Port {
  203. if x != nil {
  204. return x.Ports
  205. }
  206. return nil
  207. }
  208. func (x *Container) GetCpuLimit() uint64 {
  209. if x != nil {
  210. return x.CpuLimit
  211. }
  212. return 0
  213. }
  214. type InspectRequest struct {
  215. state protoimpl.MessageState
  216. sizeCache protoimpl.SizeCache
  217. unknownFields protoimpl.UnknownFields
  218. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
  219. }
  220. func (x *InspectRequest) Reset() {
  221. *x = InspectRequest{}
  222. if protoimpl.UnsafeEnabled {
  223. mi := &file_protos_containers_v1_containers_proto_msgTypes[2]
  224. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  225. ms.StoreMessageInfo(mi)
  226. }
  227. }
  228. func (x *InspectRequest) String() string {
  229. return protoimpl.X.MessageStringOf(x)
  230. }
  231. func (*InspectRequest) ProtoMessage() {}
  232. func (x *InspectRequest) ProtoReflect() protoreflect.Message {
  233. mi := &file_protos_containers_v1_containers_proto_msgTypes[2]
  234. if protoimpl.UnsafeEnabled && x != nil {
  235. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  236. if ms.LoadMessageInfo() == nil {
  237. ms.StoreMessageInfo(mi)
  238. }
  239. return ms
  240. }
  241. return mi.MessageOf(x)
  242. }
  243. // Deprecated: Use InspectRequest.ProtoReflect.Descriptor instead.
  244. func (*InspectRequest) Descriptor() ([]byte, []int) {
  245. return file_protos_containers_v1_containers_proto_rawDescGZIP(), []int{2}
  246. }
  247. func (x *InspectRequest) GetId() string {
  248. if x != nil {
  249. return x.Id
  250. }
  251. return ""
  252. }
  253. type InspectResponse struct {
  254. state protoimpl.MessageState
  255. sizeCache protoimpl.SizeCache
  256. unknownFields protoimpl.UnknownFields
  257. Container *Container `protobuf:"bytes,1,opt,name=container,proto3" json:"container,omitempty"`
  258. }
  259. func (x *InspectResponse) Reset() {
  260. *x = InspectResponse{}
  261. if protoimpl.UnsafeEnabled {
  262. mi := &file_protos_containers_v1_containers_proto_msgTypes[3]
  263. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  264. ms.StoreMessageInfo(mi)
  265. }
  266. }
  267. func (x *InspectResponse) String() string {
  268. return protoimpl.X.MessageStringOf(x)
  269. }
  270. func (*InspectResponse) ProtoMessage() {}
  271. func (x *InspectResponse) ProtoReflect() protoreflect.Message {
  272. mi := &file_protos_containers_v1_containers_proto_msgTypes[3]
  273. if protoimpl.UnsafeEnabled && x != nil {
  274. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  275. if ms.LoadMessageInfo() == nil {
  276. ms.StoreMessageInfo(mi)
  277. }
  278. return ms
  279. }
  280. return mi.MessageOf(x)
  281. }
  282. // Deprecated: Use InspectResponse.ProtoReflect.Descriptor instead.
  283. func (*InspectResponse) Descriptor() ([]byte, []int) {
  284. return file_protos_containers_v1_containers_proto_rawDescGZIP(), []int{3}
  285. }
  286. func (x *InspectResponse) GetContainer() *Container {
  287. if x != nil {
  288. return x.Container
  289. }
  290. return nil
  291. }
  292. type DeleteRequest struct {
  293. state protoimpl.MessageState
  294. sizeCache protoimpl.SizeCache
  295. unknownFields protoimpl.UnknownFields
  296. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
  297. Force bool `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
  298. }
  299. func (x *DeleteRequest) Reset() {
  300. *x = DeleteRequest{}
  301. if protoimpl.UnsafeEnabled {
  302. mi := &file_protos_containers_v1_containers_proto_msgTypes[4]
  303. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  304. ms.StoreMessageInfo(mi)
  305. }
  306. }
  307. func (x *DeleteRequest) String() string {
  308. return protoimpl.X.MessageStringOf(x)
  309. }
  310. func (*DeleteRequest) ProtoMessage() {}
  311. func (x *DeleteRequest) ProtoReflect() protoreflect.Message {
  312. mi := &file_protos_containers_v1_containers_proto_msgTypes[4]
  313. if protoimpl.UnsafeEnabled && x != nil {
  314. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  315. if ms.LoadMessageInfo() == nil {
  316. ms.StoreMessageInfo(mi)
  317. }
  318. return ms
  319. }
  320. return mi.MessageOf(x)
  321. }
  322. // Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.
  323. func (*DeleteRequest) Descriptor() ([]byte, []int) {
  324. return file_protos_containers_v1_containers_proto_rawDescGZIP(), []int{4}
  325. }
  326. func (x *DeleteRequest) GetId() string {
  327. if x != nil {
  328. return x.Id
  329. }
  330. return ""
  331. }
  332. func (x *DeleteRequest) GetForce() bool {
  333. if x != nil {
  334. return x.Force
  335. }
  336. return false
  337. }
  338. type DeleteResponse struct {
  339. state protoimpl.MessageState
  340. sizeCache protoimpl.SizeCache
  341. unknownFields protoimpl.UnknownFields
  342. }
  343. func (x *DeleteResponse) Reset() {
  344. *x = DeleteResponse{}
  345. if protoimpl.UnsafeEnabled {
  346. mi := &file_protos_containers_v1_containers_proto_msgTypes[5]
  347. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  348. ms.StoreMessageInfo(mi)
  349. }
  350. }
  351. func (x *DeleteResponse) String() string {
  352. return protoimpl.X.MessageStringOf(x)
  353. }
  354. func (*DeleteResponse) ProtoMessage() {}
  355. func (x *DeleteResponse) ProtoReflect() protoreflect.Message {
  356. mi := &file_protos_containers_v1_containers_proto_msgTypes[5]
  357. if protoimpl.UnsafeEnabled && x != nil {
  358. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  359. if ms.LoadMessageInfo() == nil {
  360. ms.StoreMessageInfo(mi)
  361. }
  362. return ms
  363. }
  364. return mi.MessageOf(x)
  365. }
  366. // Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.
  367. func (*DeleteResponse) Descriptor() ([]byte, []int) {
  368. return file_protos_containers_v1_containers_proto_rawDescGZIP(), []int{5}
  369. }
  370. type StopRequest struct {
  371. state protoimpl.MessageState
  372. sizeCache protoimpl.SizeCache
  373. unknownFields protoimpl.UnknownFields
  374. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
  375. Timeout uint32 `protobuf:"varint,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
  376. }
  377. func (x *StopRequest) Reset() {
  378. *x = StopRequest{}
  379. if protoimpl.UnsafeEnabled {
  380. mi := &file_protos_containers_v1_containers_proto_msgTypes[6]
  381. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  382. ms.StoreMessageInfo(mi)
  383. }
  384. }
  385. func (x *StopRequest) String() string {
  386. return protoimpl.X.MessageStringOf(x)
  387. }
  388. func (*StopRequest) ProtoMessage() {}
  389. func (x *StopRequest) ProtoReflect() protoreflect.Message {
  390. mi := &file_protos_containers_v1_containers_proto_msgTypes[6]
  391. if protoimpl.UnsafeEnabled && x != nil {
  392. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  393. if ms.LoadMessageInfo() == nil {
  394. ms.StoreMessageInfo(mi)
  395. }
  396. return ms
  397. }
  398. return mi.MessageOf(x)
  399. }
  400. // Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.
  401. func (*StopRequest) Descriptor() ([]byte, []int) {
  402. return file_protos_containers_v1_containers_proto_rawDescGZIP(), []int{6}
  403. }
  404. func (x *StopRequest) GetId() string {
  405. if x != nil {
  406. return x.Id
  407. }
  408. return ""
  409. }
  410. func (x *StopRequest) GetTimeout() uint32 {
  411. if x != nil {
  412. return x.Timeout
  413. }
  414. return 0
  415. }
  416. type StopResponse struct {
  417. state protoimpl.MessageState
  418. sizeCache protoimpl.SizeCache
  419. unknownFields protoimpl.UnknownFields
  420. }
  421. func (x *StopResponse) Reset() {
  422. *x = StopResponse{}
  423. if protoimpl.UnsafeEnabled {
  424. mi := &file_protos_containers_v1_containers_proto_msgTypes[7]
  425. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  426. ms.StoreMessageInfo(mi)
  427. }
  428. }
  429. func (x *StopResponse) String() string {
  430. return protoimpl.X.MessageStringOf(x)
  431. }
  432. func (*StopResponse) ProtoMessage() {}
  433. func (x *StopResponse) ProtoReflect() protoreflect.Message {
  434. mi := &file_protos_containers_v1_containers_proto_msgTypes[7]
  435. if protoimpl.UnsafeEnabled && x != nil {
  436. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  437. if ms.LoadMessageInfo() == nil {
  438. ms.StoreMessageInfo(mi)
  439. }
  440. return ms
  441. }
  442. return mi.MessageOf(x)
  443. }
  444. // Deprecated: Use StopResponse.ProtoReflect.Descriptor instead.
  445. func (*StopResponse) Descriptor() ([]byte, []int) {
  446. return file_protos_containers_v1_containers_proto_rawDescGZIP(), []int{7}
  447. }
  448. type RunRequest struct {
  449. state protoimpl.MessageState
  450. sizeCache protoimpl.SizeCache
  451. unknownFields protoimpl.UnknownFields
  452. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
  453. Image string `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
  454. Ports []*Port `protobuf:"bytes,3,rep,name=ports,proto3" json:"ports,omitempty"`
  455. Labels map[string]string `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
  456. Volumes []string `protobuf:"bytes,5,rep,name=volumes,proto3" json:"volumes,omitempty"`
  457. MemoryLimit uint64 `protobuf:"varint,6,opt,name=memory_limit,json=memoryLimit,proto3" json:"memory_limit,omitempty"`
  458. CpuLimit uint64 `protobuf:"varint,7,opt,name=cpu_limit,json=cpuLimit,proto3" json:"cpu_limit,omitempty"`
  459. }
  460. func (x *RunRequest) Reset() {
  461. *x = RunRequest{}
  462. if protoimpl.UnsafeEnabled {
  463. mi := &file_protos_containers_v1_containers_proto_msgTypes[8]
  464. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  465. ms.StoreMessageInfo(mi)
  466. }
  467. }
  468. func (x *RunRequest) String() string {
  469. return protoimpl.X.MessageStringOf(x)
  470. }
  471. func (*RunRequest) ProtoMessage() {}
  472. func (x *RunRequest) ProtoReflect() protoreflect.Message {
  473. mi := &file_protos_containers_v1_containers_proto_msgTypes[8]
  474. if protoimpl.UnsafeEnabled && x != nil {
  475. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  476. if ms.LoadMessageInfo() == nil {
  477. ms.StoreMessageInfo(mi)
  478. }
  479. return ms
  480. }
  481. return mi.MessageOf(x)
  482. }
  483. // Deprecated: Use RunRequest.ProtoReflect.Descriptor instead.
  484. func (*RunRequest) Descriptor() ([]byte, []int) {
  485. return file_protos_containers_v1_containers_proto_rawDescGZIP(), []int{8}
  486. }
  487. func (x *RunRequest) GetId() string {
  488. if x != nil {
  489. return x.Id
  490. }
  491. return ""
  492. }
  493. func (x *RunRequest) GetImage() string {
  494. if x != nil {
  495. return x.Image
  496. }
  497. return ""
  498. }
  499. func (x *RunRequest) GetPorts() []*Port {
  500. if x != nil {
  501. return x.Ports
  502. }
  503. return nil
  504. }
  505. func (x *RunRequest) GetLabels() map[string]string {
  506. if x != nil {
  507. return x.Labels
  508. }
  509. return nil
  510. }
  511. func (x *RunRequest) GetVolumes() []string {
  512. if x != nil {
  513. return x.Volumes
  514. }
  515. return nil
  516. }
  517. func (x *RunRequest) GetMemoryLimit() uint64 {
  518. if x != nil {
  519. return x.MemoryLimit
  520. }
  521. return 0
  522. }
  523. func (x *RunRequest) GetCpuLimit() uint64 {
  524. if x != nil {
  525. return x.CpuLimit
  526. }
  527. return 0
  528. }
  529. type RunResponse struct {
  530. state protoimpl.MessageState
  531. sizeCache protoimpl.SizeCache
  532. unknownFields protoimpl.UnknownFields
  533. }
  534. func (x *RunResponse) Reset() {
  535. *x = RunResponse{}
  536. if protoimpl.UnsafeEnabled {
  537. mi := &file_protos_containers_v1_containers_proto_msgTypes[9]
  538. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  539. ms.StoreMessageInfo(mi)
  540. }
  541. }
  542. func (x *RunResponse) String() string {
  543. return protoimpl.X.MessageStringOf(x)
  544. }
  545. func (*RunResponse) ProtoMessage() {}
  546. func (x *RunResponse) ProtoReflect() protoreflect.Message {
  547. mi := &file_protos_containers_v1_containers_proto_msgTypes[9]
  548. if protoimpl.UnsafeEnabled && x != nil {
  549. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  550. if ms.LoadMessageInfo() == nil {
  551. ms.StoreMessageInfo(mi)
  552. }
  553. return ms
  554. }
  555. return mi.MessageOf(x)
  556. }
  557. // Deprecated: Use RunResponse.ProtoReflect.Descriptor instead.
  558. func (*RunResponse) Descriptor() ([]byte, []int) {
  559. return file_protos_containers_v1_containers_proto_rawDescGZIP(), []int{9}
  560. }
  561. type ExecRequest struct {
  562. state protoimpl.MessageState
  563. sizeCache protoimpl.SizeCache
  564. unknownFields protoimpl.UnknownFields
  565. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
  566. Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
  567. StreamId string `protobuf:"bytes,3,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
  568. Args []string `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
  569. Env []string `protobuf:"bytes,5,rep,name=env,proto3" json:"env,omitempty"`
  570. Tty bool `protobuf:"varint,6,opt,name=tty,proto3" json:"tty,omitempty"`
  571. }
  572. func (x *ExecRequest) Reset() {
  573. *x = ExecRequest{}
  574. if protoimpl.UnsafeEnabled {
  575. mi := &file_protos_containers_v1_containers_proto_msgTypes[10]
  576. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  577. ms.StoreMessageInfo(mi)
  578. }
  579. }
  580. func (x *ExecRequest) String() string {
  581. return protoimpl.X.MessageStringOf(x)
  582. }
  583. func (*ExecRequest) ProtoMessage() {}
  584. func (x *ExecRequest) ProtoReflect() protoreflect.Message {
  585. mi := &file_protos_containers_v1_containers_proto_msgTypes[10]
  586. if protoimpl.UnsafeEnabled && x != nil {
  587. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  588. if ms.LoadMessageInfo() == nil {
  589. ms.StoreMessageInfo(mi)
  590. }
  591. return ms
  592. }
  593. return mi.MessageOf(x)
  594. }
  595. // Deprecated: Use ExecRequest.ProtoReflect.Descriptor instead.
  596. func (*ExecRequest) Descriptor() ([]byte, []int) {
  597. return file_protos_containers_v1_containers_proto_rawDescGZIP(), []int{10}
  598. }
  599. func (x *ExecRequest) GetId() string {
  600. if x != nil {
  601. return x.Id
  602. }
  603. return ""
  604. }
  605. func (x *ExecRequest) GetCommand() string {
  606. if x != nil {
  607. return x.Command
  608. }
  609. return ""
  610. }
  611. func (x *ExecRequest) GetStreamId() string {
  612. if x != nil {
  613. return x.StreamId
  614. }
  615. return ""
  616. }
  617. func (x *ExecRequest) GetArgs() []string {
  618. if x != nil {
  619. return x.Args
  620. }
  621. return nil
  622. }
  623. func (x *ExecRequest) GetEnv() []string {
  624. if x != nil {
  625. return x.Env
  626. }
  627. return nil
  628. }
  629. func (x *ExecRequest) GetTty() bool {
  630. if x != nil {
  631. return x.Tty
  632. }
  633. return false
  634. }
  635. type ExecResponse struct {
  636. state protoimpl.MessageState
  637. sizeCache protoimpl.SizeCache
  638. unknownFields protoimpl.UnknownFields
  639. Output []byte `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
  640. }
  641. func (x *ExecResponse) Reset() {
  642. *x = ExecResponse{}
  643. if protoimpl.UnsafeEnabled {
  644. mi := &file_protos_containers_v1_containers_proto_msgTypes[11]
  645. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  646. ms.StoreMessageInfo(mi)
  647. }
  648. }
  649. func (x *ExecResponse) String() string {
  650. return protoimpl.X.MessageStringOf(x)
  651. }
  652. func (*ExecResponse) ProtoMessage() {}
  653. func (x *ExecResponse) ProtoReflect() protoreflect.Message {
  654. mi := &file_protos_containers_v1_containers_proto_msgTypes[11]
  655. if protoimpl.UnsafeEnabled && x != nil {
  656. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  657. if ms.LoadMessageInfo() == nil {
  658. ms.StoreMessageInfo(mi)
  659. }
  660. return ms
  661. }
  662. return mi.MessageOf(x)
  663. }
  664. // Deprecated: Use ExecResponse.ProtoReflect.Descriptor instead.
  665. func (*ExecResponse) Descriptor() ([]byte, []int) {
  666. return file_protos_containers_v1_containers_proto_rawDescGZIP(), []int{11}
  667. }
  668. func (x *ExecResponse) GetOutput() []byte {
  669. if x != nil {
  670. return x.Output
  671. }
  672. return nil
  673. }
  674. type ListRequest struct {
  675. state protoimpl.MessageState
  676. sizeCache protoimpl.SizeCache
  677. unknownFields protoimpl.UnknownFields
  678. All bool `protobuf:"varint,1,opt,name=all,proto3" json:"all,omitempty"`
  679. }
  680. func (x *ListRequest) Reset() {
  681. *x = ListRequest{}
  682. if protoimpl.UnsafeEnabled {
  683. mi := &file_protos_containers_v1_containers_proto_msgTypes[12]
  684. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  685. ms.StoreMessageInfo(mi)
  686. }
  687. }
  688. func (x *ListRequest) String() string {
  689. return protoimpl.X.MessageStringOf(x)
  690. }
  691. func (*ListRequest) ProtoMessage() {}
  692. func (x *ListRequest) ProtoReflect() protoreflect.Message {
  693. mi := &file_protos_containers_v1_containers_proto_msgTypes[12]
  694. if protoimpl.UnsafeEnabled && x != nil {
  695. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  696. if ms.LoadMessageInfo() == nil {
  697. ms.StoreMessageInfo(mi)
  698. }
  699. return ms
  700. }
  701. return mi.MessageOf(x)
  702. }
  703. // Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.
  704. func (*ListRequest) Descriptor() ([]byte, []int) {
  705. return file_protos_containers_v1_containers_proto_rawDescGZIP(), []int{12}
  706. }
  707. func (x *ListRequest) GetAll() bool {
  708. if x != nil {
  709. return x.All
  710. }
  711. return false
  712. }
  713. type ListResponse struct {
  714. state protoimpl.MessageState
  715. sizeCache protoimpl.SizeCache
  716. unknownFields protoimpl.UnknownFields
  717. Containers []*Container `protobuf:"bytes,1,rep,name=containers,proto3" json:"containers,omitempty"`
  718. }
  719. func (x *ListResponse) Reset() {
  720. *x = ListResponse{}
  721. if protoimpl.UnsafeEnabled {
  722. mi := &file_protos_containers_v1_containers_proto_msgTypes[13]
  723. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  724. ms.StoreMessageInfo(mi)
  725. }
  726. }
  727. func (x *ListResponse) String() string {
  728. return protoimpl.X.MessageStringOf(x)
  729. }
  730. func (*ListResponse) ProtoMessage() {}
  731. func (x *ListResponse) ProtoReflect() protoreflect.Message {
  732. mi := &file_protos_containers_v1_containers_proto_msgTypes[13]
  733. if protoimpl.UnsafeEnabled && x != nil {
  734. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  735. if ms.LoadMessageInfo() == nil {
  736. ms.StoreMessageInfo(mi)
  737. }
  738. return ms
  739. }
  740. return mi.MessageOf(x)
  741. }
  742. // Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.
  743. func (*ListResponse) Descriptor() ([]byte, []int) {
  744. return file_protos_containers_v1_containers_proto_rawDescGZIP(), []int{13}
  745. }
  746. func (x *ListResponse) GetContainers() []*Container {
  747. if x != nil {
  748. return x.Containers
  749. }
  750. return nil
  751. }
  752. type LogsRequest struct {
  753. state protoimpl.MessageState
  754. sizeCache protoimpl.SizeCache
  755. unknownFields protoimpl.UnknownFields
  756. ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
  757. Follow bool `protobuf:"varint,3,opt,name=follow,proto3" json:"follow,omitempty"`
  758. }
  759. func (x *LogsRequest) Reset() {
  760. *x = LogsRequest{}
  761. if protoimpl.UnsafeEnabled {
  762. mi := &file_protos_containers_v1_containers_proto_msgTypes[14]
  763. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  764. ms.StoreMessageInfo(mi)
  765. }
  766. }
  767. func (x *LogsRequest) String() string {
  768. return protoimpl.X.MessageStringOf(x)
  769. }
  770. func (*LogsRequest) ProtoMessage() {}
  771. func (x *LogsRequest) ProtoReflect() protoreflect.Message {
  772. mi := &file_protos_containers_v1_containers_proto_msgTypes[14]
  773. if protoimpl.UnsafeEnabled && x != nil {
  774. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  775. if ms.LoadMessageInfo() == nil {
  776. ms.StoreMessageInfo(mi)
  777. }
  778. return ms
  779. }
  780. return mi.MessageOf(x)
  781. }
  782. // Deprecated: Use LogsRequest.ProtoReflect.Descriptor instead.
  783. func (*LogsRequest) Descriptor() ([]byte, []int) {
  784. return file_protos_containers_v1_containers_proto_rawDescGZIP(), []int{14}
  785. }
  786. func (x *LogsRequest) GetContainerId() string {
  787. if x != nil {
  788. return x.ContainerId
  789. }
  790. return ""
  791. }
  792. func (x *LogsRequest) GetFollow() bool {
  793. if x != nil {
  794. return x.Follow
  795. }
  796. return false
  797. }
  798. type LogsResponse struct {
  799. state protoimpl.MessageState
  800. sizeCache protoimpl.SizeCache
  801. unknownFields protoimpl.UnknownFields
  802. Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
  803. }
  804. func (x *LogsResponse) Reset() {
  805. *x = LogsResponse{}
  806. if protoimpl.UnsafeEnabled {
  807. mi := &file_protos_containers_v1_containers_proto_msgTypes[15]
  808. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  809. ms.StoreMessageInfo(mi)
  810. }
  811. }
  812. func (x *LogsResponse) String() string {
  813. return protoimpl.X.MessageStringOf(x)
  814. }
  815. func (*LogsResponse) ProtoMessage() {}
  816. func (x *LogsResponse) ProtoReflect() protoreflect.Message {
  817. mi := &file_protos_containers_v1_containers_proto_msgTypes[15]
  818. if protoimpl.UnsafeEnabled && x != nil {
  819. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  820. if ms.LoadMessageInfo() == nil {
  821. ms.StoreMessageInfo(mi)
  822. }
  823. return ms
  824. }
  825. return mi.MessageOf(x)
  826. }
  827. // Deprecated: Use LogsResponse.ProtoReflect.Descriptor instead.
  828. func (*LogsResponse) Descriptor() ([]byte, []int) {
  829. return file_protos_containers_v1_containers_proto_rawDescGZIP(), []int{15}
  830. }
  831. func (x *LogsResponse) GetValue() []byte {
  832. if x != nil {
  833. return x.Value
  834. }
  835. return nil
  836. }
  837. var File_protos_containers_v1_containers_proto protoreflect.FileDescriptor
  838. var file_protos_containers_v1_containers_proto_rawDesc = []byte{
  839. 0x0a, 0x25, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2f, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e,
  840. 0x65, 0x72, 0x73, 0x2f, 0x76, 0x31, 0x2f, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72,
  841. 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x23, 0x63, 0x6f, 0x6d, 0x2e, 0x64, 0x6f, 0x63,
  842. 0x6b, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2e, 0x63,
  843. 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x73, 0x2e, 0x76, 0x31, 0x22, 0x7f, 0x0a, 0x04,
  844. 0x50, 0x6f, 0x72, 0x74, 0x12, 0x1b, 0x0a, 0x09, 0x68, 0x6f, 0x73, 0x74, 0x5f, 0x70, 0x6f, 0x72,
  845. 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x08, 0x68, 0x6f, 0x73, 0x74, 0x50, 0x6f, 0x72,
  846. 0x74, 0x12, 0x25, 0x0a, 0x0e, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x70,
  847. 0x6f, 0x72, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0d, 0x63, 0x6f, 0x6e, 0x74, 0x61,
  848. 0x69, 0x6e, 0x65, 0x72, 0x50, 0x6f, 0x72, 0x74, 0x12, 0x1a, 0x0a, 0x08, 0x70, 0x72, 0x6f, 0x74,
  849. 0x6f, 0x63, 0x6f, 0x6c, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x70, 0x72, 0x6f, 0x74,
  850. 0x6f, 0x63, 0x6f, 0x6c, 0x12, 0x17, 0x0a, 0x07, 0x68, 0x6f, 0x73, 0x74, 0x5f, 0x69, 0x70, 0x18,
  851. 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x68, 0x6f, 0x73, 0x74, 0x49, 0x70, 0x22, 0xfc, 0x02,
  852. 0x0a, 0x09, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x12, 0x0e, 0x0a, 0x02, 0x69,
  853. 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x69,
  854. 0x6d, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x69, 0x6d, 0x61, 0x67,
  855. 0x65, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28,
  856. 0x09, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x6f, 0x6d,
  857. 0x6d, 0x61, 0x6e, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x6f, 0x6d, 0x6d,
  858. 0x61, 0x6e, 0x64, 0x12, 0x19, 0x0a, 0x08, 0x63, 0x70, 0x75, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18,
  859. 0x05, 0x20, 0x01, 0x28, 0x04, 0x52, 0x07, 0x63, 0x70, 0x75, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x21,
  860. 0x0a, 0x0c, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79, 0x5f, 0x75, 0x73, 0x61, 0x67, 0x65, 0x18, 0x06,
  861. 0x20, 0x01, 0x28, 0x04, 0x52, 0x0b, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79, 0x55, 0x73, 0x61, 0x67,
  862. 0x65, 0x12, 0x21, 0x0a, 0x0c, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79, 0x5f, 0x6c, 0x69, 0x6d, 0x69,
  863. 0x74, 0x18, 0x07, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0b, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79, 0x4c,
  864. 0x69, 0x6d, 0x69, 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x70, 0x69, 0x64, 0x73, 0x5f, 0x63, 0x75, 0x72,
  865. 0x72, 0x65, 0x6e, 0x74, 0x18, 0x08, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0b, 0x70, 0x69, 0x64, 0x73,
  866. 0x43, 0x75, 0x72, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x69, 0x64, 0x73, 0x5f,
  867. 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x09, 0x20, 0x01, 0x28, 0x04, 0x52, 0x09, 0x70, 0x69, 0x64,
  868. 0x73, 0x4c, 0x69, 0x6d, 0x69, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73,
  869. 0x18, 0x0a, 0x20, 0x03, 0x28, 0x09, 0x52, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x12, 0x3f,
  870. 0x0a, 0x05, 0x70, 0x6f, 0x72, 0x74, 0x73, 0x18, 0x0b, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x29, 0x2e,
  871. 0x63, 0x6f, 0x6d, 0x2e, 0x64, 0x6f, 0x63, 0x6b, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70,
  872. 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x73,
  873. 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x6f, 0x72, 0x74, 0x52, 0x05, 0x70, 0x6f, 0x72, 0x74, 0x73, 0x12,
  874. 0x1b, 0x0a, 0x09, 0x63, 0x70, 0x75, 0x5f, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x0c, 0x20, 0x01,
  875. 0x28, 0x04, 0x52, 0x08, 0x63, 0x70, 0x75, 0x4c, 0x69, 0x6d, 0x69, 0x74, 0x22, 0x20, 0x0a, 0x0e,
  876. 0x49, 0x6e, 0x73, 0x70, 0x65, 0x63, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x0e,
  877. 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64, 0x22, 0x5f,
  878. 0x0a, 0x0f, 0x49, 0x6e, 0x73, 0x70, 0x65, 0x63, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
  879. 0x65, 0x12, 0x4c, 0x0a, 0x09, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x18, 0x01,
  880. 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2e, 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x64, 0x6f, 0x63, 0x6b, 0x65,
  881. 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2e, 0x63, 0x6f, 0x6e,
  882. 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x61,
  883. 0x69, 0x6e, 0x65, 0x72, 0x52, 0x09, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x22,
  884. 0x35, 0x0a, 0x0d, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
  885. 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64,
  886. 0x12, 0x14, 0x0a, 0x05, 0x66, 0x6f, 0x72, 0x63, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52,
  887. 0x05, 0x66, 0x6f, 0x72, 0x63, 0x65, 0x22, 0x10, 0x0a, 0x0e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65,
  888. 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x37, 0x0a, 0x0b, 0x53, 0x74, 0x6f, 0x70,
  889. 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20,
  890. 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x74, 0x69, 0x6d, 0x65, 0x6f,
  891. 0x75, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x07, 0x74, 0x69, 0x6d, 0x65, 0x6f, 0x75,
  892. 0x74, 0x22, 0x0e, 0x0a, 0x0c, 0x53, 0x74, 0x6f, 0x70, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
  893. 0x65, 0x22, 0xdd, 0x02, 0x0a, 0x0a, 0x52, 0x75, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
  894. 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64,
  895. 0x12, 0x14, 0x0a, 0x05, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52,
  896. 0x05, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x12, 0x3f, 0x0a, 0x05, 0x70, 0x6f, 0x72, 0x74, 0x73, 0x18,
  897. 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x29, 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x64, 0x6f, 0x63, 0x6b,
  898. 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2e, 0x63, 0x6f,
  899. 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x6f, 0x72, 0x74,
  900. 0x52, 0x05, 0x70, 0x6f, 0x72, 0x74, 0x73, 0x12, 0x53, 0x0a, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c,
  901. 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x3b, 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x64, 0x6f,
  902. 0x63, 0x6b, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2e,
  903. 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x75,
  904. 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45,
  905. 0x6e, 0x74, 0x72, 0x79, 0x52, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x12, 0x18, 0x0a, 0x07,
  906. 0x76, 0x6f, 0x6c, 0x75, 0x6d, 0x65, 0x73, 0x18, 0x05, 0x20, 0x03, 0x28, 0x09, 0x52, 0x07, 0x76,
  907. 0x6f, 0x6c, 0x75, 0x6d, 0x65, 0x73, 0x12, 0x21, 0x0a, 0x0c, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79,
  908. 0x5f, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x06, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0b, 0x6d, 0x65,
  909. 0x6d, 0x6f, 0x72, 0x79, 0x4c, 0x69, 0x6d, 0x69, 0x74, 0x12, 0x1b, 0x0a, 0x09, 0x63, 0x70, 0x75,
  910. 0x5f, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x07, 0x20, 0x01, 0x28, 0x04, 0x52, 0x08, 0x63, 0x70,
  911. 0x75, 0x4c, 0x69, 0x6d, 0x69, 0x74, 0x1a, 0x39, 0x0a, 0x0b, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73,
  912. 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01,
  913. 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65,
  914. 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38,
  915. 0x01, 0x22, 0x0d, 0x0a, 0x0b, 0x52, 0x75, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
  916. 0x22, 0x8c, 0x01, 0x0a, 0x0b, 0x45, 0x78, 0x65, 0x63, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
  917. 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64,
  918. 0x12, 0x18, 0x0a, 0x07, 0x63, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28,
  919. 0x09, 0x52, 0x07, 0x63, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x12, 0x1b, 0x0a, 0x09, 0x73, 0x74,
  920. 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x73,
  921. 0x74, 0x72, 0x65, 0x61, 0x6d, 0x49, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x61, 0x72, 0x67, 0x73, 0x18,
  922. 0x04, 0x20, 0x03, 0x28, 0x09, 0x52, 0x04, 0x61, 0x72, 0x67, 0x73, 0x12, 0x10, 0x0a, 0x03, 0x65,
  923. 0x6e, 0x76, 0x18, 0x05, 0x20, 0x03, 0x28, 0x09, 0x52, 0x03, 0x65, 0x6e, 0x76, 0x12, 0x10, 0x0a,
  924. 0x03, 0x74, 0x74, 0x79, 0x18, 0x06, 0x20, 0x01, 0x28, 0x08, 0x52, 0x03, 0x74, 0x74, 0x79, 0x22,
  925. 0x26, 0x0a, 0x0c, 0x45, 0x78, 0x65, 0x63, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12,
  926. 0x16, 0x0a, 0x06, 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52,
  927. 0x06, 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x22, 0x1f, 0x0a, 0x0b, 0x4c, 0x69, 0x73, 0x74, 0x52,
  928. 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x10, 0x0a, 0x03, 0x61, 0x6c, 0x6c, 0x18, 0x01, 0x20,
  929. 0x01, 0x28, 0x08, 0x52, 0x03, 0x61, 0x6c, 0x6c, 0x22, 0x5e, 0x0a, 0x0c, 0x4c, 0x69, 0x73, 0x74,
  930. 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x4e, 0x0a, 0x0a, 0x63, 0x6f, 0x6e, 0x74,
  931. 0x61, 0x69, 0x6e, 0x65, 0x72, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2e, 0x2e, 0x63,
  932. 0x6f, 0x6d, 0x2e, 0x64, 0x6f, 0x63, 0x6b, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x72,
  933. 0x6f, 0x74, 0x6f, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x73, 0x2e,
  934. 0x76, 0x31, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x52, 0x0a, 0x63, 0x6f,
  935. 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x73, 0x22, 0x48, 0x0a, 0x0b, 0x4c, 0x6f, 0x67, 0x73,
  936. 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61,
  937. 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63,
  938. 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x16, 0x0a, 0x06, 0x66, 0x6f,
  939. 0x6c, 0x6c, 0x6f, 0x77, 0x18, 0x03, 0x20, 0x01, 0x28, 0x08, 0x52, 0x06, 0x66, 0x6f, 0x6c, 0x6c,
  940. 0x6f, 0x77, 0x22, 0x24, 0x0a, 0x0c, 0x4c, 0x6f, 0x67, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
  941. 0x73, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28,
  942. 0x0c, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x32, 0x95, 0x06, 0x0a, 0x0a, 0x43, 0x6f, 0x6e,
  943. 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x73, 0x12, 0x6b, 0x0a, 0x04, 0x4c, 0x69, 0x73, 0x74, 0x12,
  944. 0x30, 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x64, 0x6f, 0x63, 0x6b, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69,
  945. 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65,
  946. 0x72, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
  947. 0x74, 0x1a, 0x31, 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x64, 0x6f, 0x63, 0x6b, 0x65, 0x72, 0x2e, 0x61,
  948. 0x70, 0x69, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69,
  949. 0x6e, 0x65, 0x72, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x52, 0x65, 0x73, 0x70,
  950. 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x6b, 0x0a, 0x04, 0x53, 0x74, 0x6f, 0x70, 0x12, 0x30, 0x2e, 0x63,
  951. 0x6f, 0x6d, 0x2e, 0x64, 0x6f, 0x63, 0x6b, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x72,
  952. 0x6f, 0x74, 0x6f, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x73, 0x2e,
  953. 0x76, 0x31, 0x2e, 0x53, 0x74, 0x6f, 0x70, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x31,
  954. 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x64, 0x6f, 0x63, 0x6b, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e,
  955. 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72,
  956. 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x74, 0x6f, 0x70, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
  957. 0x65, 0x12, 0x68, 0x0a, 0x03, 0x52, 0x75, 0x6e, 0x12, 0x2f, 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x64,
  958. 0x6f, 0x63, 0x6b, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73,
  959. 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x52,
  960. 0x75, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x30, 0x2e, 0x63, 0x6f, 0x6d, 0x2e,
  961. 0x64, 0x6f, 0x63, 0x6b, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
  962. 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x73, 0x2e, 0x76, 0x31, 0x2e,
  963. 0x52, 0x75, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x6b, 0x0a, 0x04, 0x45,
  964. 0x78, 0x65, 0x63, 0x12, 0x30, 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x64, 0x6f, 0x63, 0x6b, 0x65, 0x72,
  965. 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74,
  966. 0x61, 0x69, 0x6e, 0x65, 0x72, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x52, 0x65,
  967. 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x31, 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x64, 0x6f, 0x63, 0x6b,
  968. 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2e, 0x63, 0x6f,
  969. 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x45, 0x78, 0x65, 0x63,
  970. 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x6d, 0x0a, 0x04, 0x4c, 0x6f, 0x67, 0x73,
  971. 0x12, 0x30, 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x64, 0x6f, 0x63, 0x6b, 0x65, 0x72, 0x2e, 0x61, 0x70,
  972. 0x69, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e,
  973. 0x65, 0x72, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x4c, 0x6f, 0x67, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65,
  974. 0x73, 0x74, 0x1a, 0x31, 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x64, 0x6f, 0x63, 0x6b, 0x65, 0x72, 0x2e,
  975. 0x61, 0x70, 0x69, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x61,
  976. 0x69, 0x6e, 0x65, 0x72, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x4c, 0x6f, 0x67, 0x73, 0x52, 0x65, 0x73,
  977. 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x30, 0x01, 0x12, 0x71, 0x0a, 0x06, 0x44, 0x65, 0x6c, 0x65, 0x74,
  978. 0x65, 0x12, 0x32, 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x64, 0x6f, 0x63, 0x6b, 0x65, 0x72, 0x2e, 0x61,
  979. 0x70, 0x69, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69,
  980. 0x6e, 0x65, 0x72, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x52, 0x65,
  981. 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x33, 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x64, 0x6f, 0x63, 0x6b,
  982. 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2e, 0x63, 0x6f,
  983. 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x44, 0x65, 0x6c, 0x65,
  984. 0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x74, 0x0a, 0x07, 0x49, 0x6e,
  985. 0x73, 0x70, 0x65, 0x63, 0x74, 0x12, 0x33, 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x64, 0x6f, 0x63, 0x6b,
  986. 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2e, 0x63, 0x6f,
  987. 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x49, 0x6e, 0x73, 0x70,
  988. 0x65, 0x63, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x34, 0x2e, 0x63, 0x6f, 0x6d,
  989. 0x2e, 0x64, 0x6f, 0x63, 0x6b, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x72, 0x6f, 0x74,
  990. 0x6f, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x73, 0x2e, 0x76, 0x31,
  991. 0x2e, 0x49, 0x6e, 0x73, 0x70, 0x65, 0x63, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
  992. 0x42, 0x2f, 0x5a, 0x2d, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x64,
  993. 0x6f, 0x63, 0x6b, 0x65, 0x72, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73,
  994. 0x2f, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x73, 0x2f, 0x76, 0x31, 0x3b, 0x76,
  995. 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
  996. }
  997. var (
  998. file_protos_containers_v1_containers_proto_rawDescOnce sync.Once
  999. file_protos_containers_v1_containers_proto_rawDescData = file_protos_containers_v1_containers_proto_rawDesc
  1000. )
  1001. func file_protos_containers_v1_containers_proto_rawDescGZIP() []byte {
  1002. file_protos_containers_v1_containers_proto_rawDescOnce.Do(func() {
  1003. file_protos_containers_v1_containers_proto_rawDescData = protoimpl.X.CompressGZIP(file_protos_containers_v1_containers_proto_rawDescData)
  1004. })
  1005. return file_protos_containers_v1_containers_proto_rawDescData
  1006. }
  1007. var file_protos_containers_v1_containers_proto_msgTypes = make([]protoimpl.MessageInfo, 17)
  1008. var file_protos_containers_v1_containers_proto_goTypes = []interface{}{
  1009. (*Port)(nil), // 0: com.docker.api.protos.containers.v1.Port
  1010. (*Container)(nil), // 1: com.docker.api.protos.containers.v1.Container
  1011. (*InspectRequest)(nil), // 2: com.docker.api.protos.containers.v1.InspectRequest
  1012. (*InspectResponse)(nil), // 3: com.docker.api.protos.containers.v1.InspectResponse
  1013. (*DeleteRequest)(nil), // 4: com.docker.api.protos.containers.v1.DeleteRequest
  1014. (*DeleteResponse)(nil), // 5: com.docker.api.protos.containers.v1.DeleteResponse
  1015. (*StopRequest)(nil), // 6: com.docker.api.protos.containers.v1.StopRequest
  1016. (*StopResponse)(nil), // 7: com.docker.api.protos.containers.v1.StopResponse
  1017. (*RunRequest)(nil), // 8: com.docker.api.protos.containers.v1.RunRequest
  1018. (*RunResponse)(nil), // 9: com.docker.api.protos.containers.v1.RunResponse
  1019. (*ExecRequest)(nil), // 10: com.docker.api.protos.containers.v1.ExecRequest
  1020. (*ExecResponse)(nil), // 11: com.docker.api.protos.containers.v1.ExecResponse
  1021. (*ListRequest)(nil), // 12: com.docker.api.protos.containers.v1.ListRequest
  1022. (*ListResponse)(nil), // 13: com.docker.api.protos.containers.v1.ListResponse
  1023. (*LogsRequest)(nil), // 14: com.docker.api.protos.containers.v1.LogsRequest
  1024. (*LogsResponse)(nil), // 15: com.docker.api.protos.containers.v1.LogsResponse
  1025. nil, // 16: com.docker.api.protos.containers.v1.RunRequest.LabelsEntry
  1026. }
  1027. var file_protos_containers_v1_containers_proto_depIdxs = []int32{
  1028. 0, // 0: com.docker.api.protos.containers.v1.Container.ports:type_name -> com.docker.api.protos.containers.v1.Port
  1029. 1, // 1: com.docker.api.protos.containers.v1.InspectResponse.container:type_name -> com.docker.api.protos.containers.v1.Container
  1030. 0, // 2: com.docker.api.protos.containers.v1.RunRequest.ports:type_name -> com.docker.api.protos.containers.v1.Port
  1031. 16, // 3: com.docker.api.protos.containers.v1.RunRequest.labels:type_name -> com.docker.api.protos.containers.v1.RunRequest.LabelsEntry
  1032. 1, // 4: com.docker.api.protos.containers.v1.ListResponse.containers:type_name -> com.docker.api.protos.containers.v1.Container
  1033. 12, // 5: com.docker.api.protos.containers.v1.Containers.List:input_type -> com.docker.api.protos.containers.v1.ListRequest
  1034. 6, // 6: com.docker.api.protos.containers.v1.Containers.Stop:input_type -> com.docker.api.protos.containers.v1.StopRequest
  1035. 8, // 7: com.docker.api.protos.containers.v1.Containers.Run:input_type -> com.docker.api.protos.containers.v1.RunRequest
  1036. 10, // 8: com.docker.api.protos.containers.v1.Containers.Exec:input_type -> com.docker.api.protos.containers.v1.ExecRequest
  1037. 14, // 9: com.docker.api.protos.containers.v1.Containers.Logs:input_type -> com.docker.api.protos.containers.v1.LogsRequest
  1038. 4, // 10: com.docker.api.protos.containers.v1.Containers.Delete:input_type -> com.docker.api.protos.containers.v1.DeleteRequest
  1039. 2, // 11: com.docker.api.protos.containers.v1.Containers.Inspect:input_type -> com.docker.api.protos.containers.v1.InspectRequest
  1040. 13, // 12: com.docker.api.protos.containers.v1.Containers.List:output_type -> com.docker.api.protos.containers.v1.ListResponse
  1041. 7, // 13: com.docker.api.protos.containers.v1.Containers.Stop:output_type -> com.docker.api.protos.containers.v1.StopResponse
  1042. 9, // 14: com.docker.api.protos.containers.v1.Containers.Run:output_type -> com.docker.api.protos.containers.v1.RunResponse
  1043. 11, // 15: com.docker.api.protos.containers.v1.Containers.Exec:output_type -> com.docker.api.protos.containers.v1.ExecResponse
  1044. 15, // 16: com.docker.api.protos.containers.v1.Containers.Logs:output_type -> com.docker.api.protos.containers.v1.LogsResponse
  1045. 5, // 17: com.docker.api.protos.containers.v1.Containers.Delete:output_type -> com.docker.api.protos.containers.v1.DeleteResponse
  1046. 3, // 18: com.docker.api.protos.containers.v1.Containers.Inspect:output_type -> com.docker.api.protos.containers.v1.InspectResponse
  1047. 12, // [12:19] is the sub-list for method output_type
  1048. 5, // [5:12] is the sub-list for method input_type
  1049. 5, // [5:5] is the sub-list for extension type_name
  1050. 5, // [5:5] is the sub-list for extension extendee
  1051. 0, // [0:5] is the sub-list for field type_name
  1052. }
  1053. func init() { file_protos_containers_v1_containers_proto_init() }
  1054. func file_protos_containers_v1_containers_proto_init() {
  1055. if File_protos_containers_v1_containers_proto != nil {
  1056. return
  1057. }
  1058. if !protoimpl.UnsafeEnabled {
  1059. file_protos_containers_v1_containers_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
  1060. switch v := v.(*Port); i {
  1061. case 0:
  1062. return &v.state
  1063. case 1:
  1064. return &v.sizeCache
  1065. case 2:
  1066. return &v.unknownFields
  1067. default:
  1068. return nil
  1069. }
  1070. }
  1071. file_protos_containers_v1_containers_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
  1072. switch v := v.(*Container); i {
  1073. case 0:
  1074. return &v.state
  1075. case 1:
  1076. return &v.sizeCache
  1077. case 2:
  1078. return &v.unknownFields
  1079. default:
  1080. return nil
  1081. }
  1082. }
  1083. file_protos_containers_v1_containers_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
  1084. switch v := v.(*InspectRequest); i {
  1085. case 0:
  1086. return &v.state
  1087. case 1:
  1088. return &v.sizeCache
  1089. case 2:
  1090. return &v.unknownFields
  1091. default:
  1092. return nil
  1093. }
  1094. }
  1095. file_protos_containers_v1_containers_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
  1096. switch v := v.(*InspectResponse); i {
  1097. case 0:
  1098. return &v.state
  1099. case 1:
  1100. return &v.sizeCache
  1101. case 2:
  1102. return &v.unknownFields
  1103. default:
  1104. return nil
  1105. }
  1106. }
  1107. file_protos_containers_v1_containers_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
  1108. switch v := v.(*DeleteRequest); i {
  1109. case 0:
  1110. return &v.state
  1111. case 1:
  1112. return &v.sizeCache
  1113. case 2:
  1114. return &v.unknownFields
  1115. default:
  1116. return nil
  1117. }
  1118. }
  1119. file_protos_containers_v1_containers_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
  1120. switch v := v.(*DeleteResponse); i {
  1121. case 0:
  1122. return &v.state
  1123. case 1:
  1124. return &v.sizeCache
  1125. case 2:
  1126. return &v.unknownFields
  1127. default:
  1128. return nil
  1129. }
  1130. }
  1131. file_protos_containers_v1_containers_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
  1132. switch v := v.(*StopRequest); i {
  1133. case 0:
  1134. return &v.state
  1135. case 1:
  1136. return &v.sizeCache
  1137. case 2:
  1138. return &v.unknownFields
  1139. default:
  1140. return nil
  1141. }
  1142. }
  1143. file_protos_containers_v1_containers_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
  1144. switch v := v.(*StopResponse); i {
  1145. case 0:
  1146. return &v.state
  1147. case 1:
  1148. return &v.sizeCache
  1149. case 2:
  1150. return &v.unknownFields
  1151. default:
  1152. return nil
  1153. }
  1154. }
  1155. file_protos_containers_v1_containers_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
  1156. switch v := v.(*RunRequest); i {
  1157. case 0:
  1158. return &v.state
  1159. case 1:
  1160. return &v.sizeCache
  1161. case 2:
  1162. return &v.unknownFields
  1163. default:
  1164. return nil
  1165. }
  1166. }
  1167. file_protos_containers_v1_containers_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
  1168. switch v := v.(*RunResponse); i {
  1169. case 0:
  1170. return &v.state
  1171. case 1:
  1172. return &v.sizeCache
  1173. case 2:
  1174. return &v.unknownFields
  1175. default:
  1176. return nil
  1177. }
  1178. }
  1179. file_protos_containers_v1_containers_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
  1180. switch v := v.(*ExecRequest); i {
  1181. case 0:
  1182. return &v.state
  1183. case 1:
  1184. return &v.sizeCache
  1185. case 2:
  1186. return &v.unknownFields
  1187. default:
  1188. return nil
  1189. }
  1190. }
  1191. file_protos_containers_v1_containers_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
  1192. switch v := v.(*ExecResponse); i {
  1193. case 0:
  1194. return &v.state
  1195. case 1:
  1196. return &v.sizeCache
  1197. case 2:
  1198. return &v.unknownFields
  1199. default:
  1200. return nil
  1201. }
  1202. }
  1203. file_protos_containers_v1_containers_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
  1204. switch v := v.(*ListRequest); i {
  1205. case 0:
  1206. return &v.state
  1207. case 1:
  1208. return &v.sizeCache
  1209. case 2:
  1210. return &v.unknownFields
  1211. default:
  1212. return nil
  1213. }
  1214. }
  1215. file_protos_containers_v1_containers_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
  1216. switch v := v.(*ListResponse); i {
  1217. case 0:
  1218. return &v.state
  1219. case 1:
  1220. return &v.sizeCache
  1221. case 2:
  1222. return &v.unknownFields
  1223. default:
  1224. return nil
  1225. }
  1226. }
  1227. file_protos_containers_v1_containers_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
  1228. switch v := v.(*LogsRequest); i {
  1229. case 0:
  1230. return &v.state
  1231. case 1:
  1232. return &v.sizeCache
  1233. case 2:
  1234. return &v.unknownFields
  1235. default:
  1236. return nil
  1237. }
  1238. }
  1239. file_protos_containers_v1_containers_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
  1240. switch v := v.(*LogsResponse); i {
  1241. case 0:
  1242. return &v.state
  1243. case 1:
  1244. return &v.sizeCache
  1245. case 2:
  1246. return &v.unknownFields
  1247. default:
  1248. return nil
  1249. }
  1250. }
  1251. }
  1252. type x struct{}
  1253. out := protoimpl.TypeBuilder{
  1254. File: protoimpl.DescBuilder{
  1255. GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
  1256. RawDescriptor: file_protos_containers_v1_containers_proto_rawDesc,
  1257. NumEnums: 0,
  1258. NumMessages: 17,
  1259. NumExtensions: 0,
  1260. NumServices: 1,
  1261. },
  1262. GoTypes: file_protos_containers_v1_containers_proto_goTypes,
  1263. DependencyIndexes: file_protos_containers_v1_containers_proto_depIdxs,
  1264. MessageInfos: file_protos_containers_v1_containers_proto_msgTypes,
  1265. }.Build()
  1266. File_protos_containers_v1_containers_proto = out.File
  1267. file_protos_containers_v1_containers_proto_rawDesc = nil
  1268. file_protos_containers_v1_containers_proto_goTypes = nil
  1269. file_protos_containers_v1_containers_proto_depIdxs = nil
  1270. }
  1271. // Reference imports to suppress errors if they are not otherwise used.
  1272. var _ context.Context
  1273. var _ grpc.ClientConnInterface
  1274. // This is a compile-time assertion to ensure that this generated file
  1275. // is compatible with the grpc package it is being compiled against.
  1276. const _ = grpc.SupportPackageIsVersion6
  1277. // ContainersClient is the client API for Containers service.
  1278. //
  1279. // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
  1280. type ContainersClient interface {
  1281. List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
  1282. Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
  1283. Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunResponse, error)
  1284. Exec(ctx context.Context, in *ExecRequest, opts ...grpc.CallOption) (*ExecResponse, error)
  1285. Logs(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (Containers_LogsClient, error)
  1286. Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
  1287. Inspect(ctx context.Context, in *InspectRequest, opts ...grpc.CallOption) (*InspectResponse, error)
  1288. }
  1289. type containersClient struct {
  1290. cc grpc.ClientConnInterface
  1291. }
  1292. func NewContainersClient(cc grpc.ClientConnInterface) ContainersClient {
  1293. return &containersClient{cc}
  1294. }
  1295. func (c *containersClient) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) {
  1296. out := new(ListResponse)
  1297. err := c.cc.Invoke(ctx, "/com.docker.api.protos.containers.v1.Containers/List", in, out, opts...)
  1298. if err != nil {
  1299. return nil, err
  1300. }
  1301. return out, nil
  1302. }
  1303. func (c *containersClient) Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error) {
  1304. out := new(StopResponse)
  1305. err := c.cc.Invoke(ctx, "/com.docker.api.protos.containers.v1.Containers/Stop", in, out, opts...)
  1306. if err != nil {
  1307. return nil, err
  1308. }
  1309. return out, nil
  1310. }
  1311. func (c *containersClient) Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunResponse, error) {
  1312. out := new(RunResponse)
  1313. err := c.cc.Invoke(ctx, "/com.docker.api.protos.containers.v1.Containers/Run", in, out, opts...)
  1314. if err != nil {
  1315. return nil, err
  1316. }
  1317. return out, nil
  1318. }
  1319. func (c *containersClient) Exec(ctx context.Context, in *ExecRequest, opts ...grpc.CallOption) (*ExecResponse, error) {
  1320. out := new(ExecResponse)
  1321. err := c.cc.Invoke(ctx, "/com.docker.api.protos.containers.v1.Containers/Exec", in, out, opts...)
  1322. if err != nil {
  1323. return nil, err
  1324. }
  1325. return out, nil
  1326. }
  1327. func (c *containersClient) Logs(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (Containers_LogsClient, error) {
  1328. stream, err := c.cc.NewStream(ctx, &_Containers_serviceDesc.Streams[0], "/com.docker.api.protos.containers.v1.Containers/Logs", opts...)
  1329. if err != nil {
  1330. return nil, err
  1331. }
  1332. x := &containersLogsClient{stream}
  1333. if err := x.ClientStream.SendMsg(in); err != nil {
  1334. return nil, err
  1335. }
  1336. if err := x.ClientStream.CloseSend(); err != nil {
  1337. return nil, err
  1338. }
  1339. return x, nil
  1340. }
  1341. type Containers_LogsClient interface {
  1342. Recv() (*LogsResponse, error)
  1343. grpc.ClientStream
  1344. }
  1345. type containersLogsClient struct {
  1346. grpc.ClientStream
  1347. }
  1348. func (x *containersLogsClient) Recv() (*LogsResponse, error) {
  1349. m := new(LogsResponse)
  1350. if err := x.ClientStream.RecvMsg(m); err != nil {
  1351. return nil, err
  1352. }
  1353. return m, nil
  1354. }
  1355. func (c *containersClient) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) {
  1356. out := new(DeleteResponse)
  1357. err := c.cc.Invoke(ctx, "/com.docker.api.protos.containers.v1.Containers/Delete", in, out, opts...)
  1358. if err != nil {
  1359. return nil, err
  1360. }
  1361. return out, nil
  1362. }
  1363. func (c *containersClient) Inspect(ctx context.Context, in *InspectRequest, opts ...grpc.CallOption) (*InspectResponse, error) {
  1364. out := new(InspectResponse)
  1365. err := c.cc.Invoke(ctx, "/com.docker.api.protos.containers.v1.Containers/Inspect", in, out, opts...)
  1366. if err != nil {
  1367. return nil, err
  1368. }
  1369. return out, nil
  1370. }
  1371. // ContainersServer is the server API for Containers service.
  1372. type ContainersServer interface {
  1373. List(context.Context, *ListRequest) (*ListResponse, error)
  1374. Stop(context.Context, *StopRequest) (*StopResponse, error)
  1375. Run(context.Context, *RunRequest) (*RunResponse, error)
  1376. Exec(context.Context, *ExecRequest) (*ExecResponse, error)
  1377. Logs(*LogsRequest, Containers_LogsServer) error
  1378. Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
  1379. Inspect(context.Context, *InspectRequest) (*InspectResponse, error)
  1380. }
  1381. // UnimplementedContainersServer can be embedded to have forward compatible implementations.
  1382. type UnimplementedContainersServer struct {
  1383. }
  1384. func (*UnimplementedContainersServer) List(context.Context, *ListRequest) (*ListResponse, error) {
  1385. return nil, status.Errorf(codes.Unimplemented, "method List not implemented")
  1386. }
  1387. func (*UnimplementedContainersServer) Stop(context.Context, *StopRequest) (*StopResponse, error) {
  1388. return nil, status.Errorf(codes.Unimplemented, "method Stop not implemented")
  1389. }
  1390. func (*UnimplementedContainersServer) Run(context.Context, *RunRequest) (*RunResponse, error) {
  1391. return nil, status.Errorf(codes.Unimplemented, "method Run not implemented")
  1392. }
  1393. func (*UnimplementedContainersServer) Exec(context.Context, *ExecRequest) (*ExecResponse, error) {
  1394. return nil, status.Errorf(codes.Unimplemented, "method Exec not implemented")
  1395. }
  1396. func (*UnimplementedContainersServer) Logs(*LogsRequest, Containers_LogsServer) error {
  1397. return status.Errorf(codes.Unimplemented, "method Logs not implemented")
  1398. }
  1399. func (*UnimplementedContainersServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error) {
  1400. return nil, status.Errorf(codes.Unimplemented, "method Delete not implemented")
  1401. }
  1402. func (*UnimplementedContainersServer) Inspect(context.Context, *InspectRequest) (*InspectResponse, error) {
  1403. return nil, status.Errorf(codes.Unimplemented, "method Inspect not implemented")
  1404. }
  1405. func RegisterContainersServer(s *grpc.Server, srv ContainersServer) {
  1406. s.RegisterService(&_Containers_serviceDesc, srv)
  1407. }
  1408. func _Containers_List_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1409. in := new(ListRequest)
  1410. if err := dec(in); err != nil {
  1411. return nil, err
  1412. }
  1413. if interceptor == nil {
  1414. return srv.(ContainersServer).List(ctx, in)
  1415. }
  1416. info := &grpc.UnaryServerInfo{
  1417. Server: srv,
  1418. FullMethod: "/com.docker.api.protos.containers.v1.Containers/List",
  1419. }
  1420. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1421. return srv.(ContainersServer).List(ctx, req.(*ListRequest))
  1422. }
  1423. return interceptor(ctx, in, info, handler)
  1424. }
  1425. func _Containers_Stop_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1426. in := new(StopRequest)
  1427. if err := dec(in); err != nil {
  1428. return nil, err
  1429. }
  1430. if interceptor == nil {
  1431. return srv.(ContainersServer).Stop(ctx, in)
  1432. }
  1433. info := &grpc.UnaryServerInfo{
  1434. Server: srv,
  1435. FullMethod: "/com.docker.api.protos.containers.v1.Containers/Stop",
  1436. }
  1437. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1438. return srv.(ContainersServer).Stop(ctx, req.(*StopRequest))
  1439. }
  1440. return interceptor(ctx, in, info, handler)
  1441. }
  1442. func _Containers_Run_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1443. in := new(RunRequest)
  1444. if err := dec(in); err != nil {
  1445. return nil, err
  1446. }
  1447. if interceptor == nil {
  1448. return srv.(ContainersServer).Run(ctx, in)
  1449. }
  1450. info := &grpc.UnaryServerInfo{
  1451. Server: srv,
  1452. FullMethod: "/com.docker.api.protos.containers.v1.Containers/Run",
  1453. }
  1454. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1455. return srv.(ContainersServer).Run(ctx, req.(*RunRequest))
  1456. }
  1457. return interceptor(ctx, in, info, handler)
  1458. }
  1459. func _Containers_Exec_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1460. in := new(ExecRequest)
  1461. if err := dec(in); err != nil {
  1462. return nil, err
  1463. }
  1464. if interceptor == nil {
  1465. return srv.(ContainersServer).Exec(ctx, in)
  1466. }
  1467. info := &grpc.UnaryServerInfo{
  1468. Server: srv,
  1469. FullMethod: "/com.docker.api.protos.containers.v1.Containers/Exec",
  1470. }
  1471. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1472. return srv.(ContainersServer).Exec(ctx, req.(*ExecRequest))
  1473. }
  1474. return interceptor(ctx, in, info, handler)
  1475. }
  1476. func _Containers_Logs_Handler(srv interface{}, stream grpc.ServerStream) error {
  1477. m := new(LogsRequest)
  1478. if err := stream.RecvMsg(m); err != nil {
  1479. return err
  1480. }
  1481. return srv.(ContainersServer).Logs(m, &containersLogsServer{stream})
  1482. }
  1483. type Containers_LogsServer interface {
  1484. Send(*LogsResponse) error
  1485. grpc.ServerStream
  1486. }
  1487. type containersLogsServer struct {
  1488. grpc.ServerStream
  1489. }
  1490. func (x *containersLogsServer) Send(m *LogsResponse) error {
  1491. return x.ServerStream.SendMsg(m)
  1492. }
  1493. func _Containers_Delete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1494. in := new(DeleteRequest)
  1495. if err := dec(in); err != nil {
  1496. return nil, err
  1497. }
  1498. if interceptor == nil {
  1499. return srv.(ContainersServer).Delete(ctx, in)
  1500. }
  1501. info := &grpc.UnaryServerInfo{
  1502. Server: srv,
  1503. FullMethod: "/com.docker.api.protos.containers.v1.Containers/Delete",
  1504. }
  1505. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1506. return srv.(ContainersServer).Delete(ctx, req.(*DeleteRequest))
  1507. }
  1508. return interceptor(ctx, in, info, handler)
  1509. }
  1510. func _Containers_Inspect_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1511. in := new(InspectRequest)
  1512. if err := dec(in); err != nil {
  1513. return nil, err
  1514. }
  1515. if interceptor == nil {
  1516. return srv.(ContainersServer).Inspect(ctx, in)
  1517. }
  1518. info := &grpc.UnaryServerInfo{
  1519. Server: srv,
  1520. FullMethod: "/com.docker.api.protos.containers.v1.Containers/Inspect",
  1521. }
  1522. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1523. return srv.(ContainersServer).Inspect(ctx, req.(*InspectRequest))
  1524. }
  1525. return interceptor(ctx, in, info, handler)
  1526. }
  1527. var _Containers_serviceDesc = grpc.ServiceDesc{
  1528. ServiceName: "com.docker.api.protos.containers.v1.Containers",
  1529. HandlerType: (*ContainersServer)(nil),
  1530. Methods: []grpc.MethodDesc{
  1531. {
  1532. MethodName: "List",
  1533. Handler: _Containers_List_Handler,
  1534. },
  1535. {
  1536. MethodName: "Stop",
  1537. Handler: _Containers_Stop_Handler,
  1538. },
  1539. {
  1540. MethodName: "Run",
  1541. Handler: _Containers_Run_Handler,
  1542. },
  1543. {
  1544. MethodName: "Exec",
  1545. Handler: _Containers_Exec_Handler,
  1546. },
  1547. {
  1548. MethodName: "Delete",
  1549. Handler: _Containers_Delete_Handler,
  1550. },
  1551. {
  1552. MethodName: "Inspect",
  1553. Handler: _Containers_Inspect_Handler,
  1554. },
  1555. },
  1556. Streams: []grpc.StreamDesc{
  1557. {
  1558. StreamName: "Logs",
  1559. Handler: _Containers_Logs_Handler,
  1560. ServerStreams: true,
  1561. },
  1562. },
  1563. Metadata: "protos/containers/v1/containers.proto",
  1564. }