containers.pb.go 62 KB

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