1
2
3
4
5
6
7 package pb
8
9 import (
10 context "context"
11 reflect "reflect"
12 sync "sync"
13
14 proto "github.com/golang/protobuf/proto"
15 empty "github.com/golang/protobuf/ptypes/empty"
16 grpc "google.golang.org/grpc"
17 codes "google.golang.org/grpc/codes"
18 status "google.golang.org/grpc/status"
19 protoreflect "google.golang.org/protobuf/reflect/protoreflect"
20 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
21 )
22
23 const (
24
25 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
26
27 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
28 )
29
30
31
32 const _ = proto.ProtoPackageIsVersion4
33
34 type Chain_Direction int32
35
36 const (
37 Chain_INPUT Chain_Direction = 0
38 Chain_OUTPUT Chain_Direction = 1
39 )
40
41
42 var (
43 Chain_Direction_name = map[int32]string{
44 0: "INPUT",
45 1: "OUTPUT",
46 }
47 Chain_Direction_value = map[string]int32{
48 "INPUT": 0,
49 "OUTPUT": 1,
50 }
51 )
52
53 func (x Chain_Direction) Enum() *Chain_Direction {
54 p := new(Chain_Direction)
55 *p = x
56 return p
57 }
58
59 func (x Chain_Direction) String() string {
60 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
61 }
62
63 func (Chain_Direction) Descriptor() protoreflect.EnumDescriptor {
64 return file_chaosdaemon_proto_enumTypes[0].Descriptor()
65 }
66
67 func (Chain_Direction) Type() protoreflect.EnumType {
68 return &file_chaosdaemon_proto_enumTypes[0]
69 }
70
71 func (x Chain_Direction) Number() protoreflect.EnumNumber {
72 return protoreflect.EnumNumber(x)
73 }
74
75
76 func (Chain_Direction) EnumDescriptor() ([]byte, []int) {
77 return file_chaosdaemon_proto_rawDescGZIP(), []int{16, 0}
78 }
79
80 type ContainerAction_Action int32
81
82 const (
83 ContainerAction_KILL ContainerAction_Action = 0
84 ContainerAction_GETPID ContainerAction_Action = 1
85 )
86
87
88 var (
89 ContainerAction_Action_name = map[int32]string{
90 0: "KILL",
91 1: "GETPID",
92 }
93 ContainerAction_Action_value = map[string]int32{
94 "KILL": 0,
95 "GETPID": 1,
96 }
97 )
98
99 func (x ContainerAction_Action) Enum() *ContainerAction_Action {
100 p := new(ContainerAction_Action)
101 *p = x
102 return p
103 }
104
105 func (x ContainerAction_Action) String() string {
106 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
107 }
108
109 func (ContainerAction_Action) Descriptor() protoreflect.EnumDescriptor {
110 return file_chaosdaemon_proto_enumTypes[1].Descriptor()
111 }
112
113 func (ContainerAction_Action) Type() protoreflect.EnumType {
114 return &file_chaosdaemon_proto_enumTypes[1]
115 }
116
117 func (x ContainerAction_Action) Number() protoreflect.EnumNumber {
118 return protoreflect.EnumNumber(x)
119 }
120
121
122 func (ContainerAction_Action) EnumDescriptor() ([]byte, []int) {
123 return file_chaosdaemon_proto_rawDescGZIP(), []int{18, 0}
124 }
125
126 type ExecStressRequest_Scope int32
127
128 const (
129 ExecStressRequest_CONTAINER ExecStressRequest_Scope = 0
130 ExecStressRequest_POD ExecStressRequest_Scope = 1
131 )
132
133
134 var (
135 ExecStressRequest_Scope_name = map[int32]string{
136 0: "CONTAINER",
137 1: "POD",
138 }
139 ExecStressRequest_Scope_value = map[string]int32{
140 "CONTAINER": 0,
141 "POD": 1,
142 }
143 )
144
145 func (x ExecStressRequest_Scope) Enum() *ExecStressRequest_Scope {
146 p := new(ExecStressRequest_Scope)
147 *p = x
148 return p
149 }
150
151 func (x ExecStressRequest_Scope) String() string {
152 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
153 }
154
155 func (ExecStressRequest_Scope) Descriptor() protoreflect.EnumDescriptor {
156 return file_chaosdaemon_proto_enumTypes[2].Descriptor()
157 }
158
159 func (ExecStressRequest_Scope) Type() protoreflect.EnumType {
160 return &file_chaosdaemon_proto_enumTypes[2]
161 }
162
163 func (x ExecStressRequest_Scope) Number() protoreflect.EnumNumber {
164 return protoreflect.EnumNumber(x)
165 }
166
167
168 func (ExecStressRequest_Scope) EnumDescriptor() ([]byte, []int) {
169 return file_chaosdaemon_proto_rawDescGZIP(), []int{19, 0}
170 }
171
172 type Tc_Type int32
173
174 const (
175 Tc_NETEM Tc_Type = 0
176 Tc_BANDWIDTH Tc_Type = 1
177 )
178
179
180 var (
181 Tc_Type_name = map[int32]string{
182 0: "NETEM",
183 1: "BANDWIDTH",
184 }
185 Tc_Type_value = map[string]int32{
186 "NETEM": 0,
187 "BANDWIDTH": 1,
188 }
189 )
190
191 func (x Tc_Type) Enum() *Tc_Type {
192 p := new(Tc_Type)
193 *p = x
194 return p
195 }
196
197 func (x Tc_Type) String() string {
198 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
199 }
200
201 func (Tc_Type) Descriptor() protoreflect.EnumDescriptor {
202 return file_chaosdaemon_proto_enumTypes[3].Descriptor()
203 }
204
205 func (Tc_Type) Type() protoreflect.EnumType {
206 return &file_chaosdaemon_proto_enumTypes[3]
207 }
208
209 func (x Tc_Type) Number() protoreflect.EnumNumber {
210 return protoreflect.EnumNumber(x)
211 }
212
213
214 func (Tc_Type) EnumDescriptor() ([]byte, []int) {
215 return file_chaosdaemon_proto_rawDescGZIP(), []int{27, 0}
216 }
217
218 type TcHandle struct {
219 state protoimpl.MessageState
220 sizeCache protoimpl.SizeCache
221 unknownFields protoimpl.UnknownFields
222
223 Major uint32 `protobuf:"varint,1,opt,name=major,proto3" json:"major,omitempty"`
224 Minor uint32 `protobuf:"varint,2,opt,name=minor,proto3" json:"minor,omitempty"`
225 }
226
227 func (x *TcHandle) Reset() {
228 *x = TcHandle{}
229 if protoimpl.UnsafeEnabled {
230 mi := &file_chaosdaemon_proto_msgTypes[0]
231 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
232 ms.StoreMessageInfo(mi)
233 }
234 }
235
236 func (x *TcHandle) String() string {
237 return protoimpl.X.MessageStringOf(x)
238 }
239
240 func (*TcHandle) ProtoMessage() {}
241
242 func (x *TcHandle) ProtoReflect() protoreflect.Message {
243 mi := &file_chaosdaemon_proto_msgTypes[0]
244 if protoimpl.UnsafeEnabled && x != nil {
245 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
246 if ms.LoadMessageInfo() == nil {
247 ms.StoreMessageInfo(mi)
248 }
249 return ms
250 }
251 return mi.MessageOf(x)
252 }
253
254
255 func (*TcHandle) Descriptor() ([]byte, []int) {
256 return file_chaosdaemon_proto_rawDescGZIP(), []int{0}
257 }
258
259 func (x *TcHandle) GetMajor() uint32 {
260 if x != nil {
261 return x.Major
262 }
263 return 0
264 }
265
266 func (x *TcHandle) GetMinor() uint32 {
267 if x != nil {
268 return x.Minor
269 }
270 return 0
271 }
272
273 type ContainerRequest struct {
274 state protoimpl.MessageState
275 sizeCache protoimpl.SizeCache
276 unknownFields protoimpl.UnknownFields
277
278 Action *ContainerAction `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`
279 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
280 }
281
282 func (x *ContainerRequest) Reset() {
283 *x = ContainerRequest{}
284 if protoimpl.UnsafeEnabled {
285 mi := &file_chaosdaemon_proto_msgTypes[1]
286 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
287 ms.StoreMessageInfo(mi)
288 }
289 }
290
291 func (x *ContainerRequest) String() string {
292 return protoimpl.X.MessageStringOf(x)
293 }
294
295 func (*ContainerRequest) ProtoMessage() {}
296
297 func (x *ContainerRequest) ProtoReflect() protoreflect.Message {
298 mi := &file_chaosdaemon_proto_msgTypes[1]
299 if protoimpl.UnsafeEnabled && x != nil {
300 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
301 if ms.LoadMessageInfo() == nil {
302 ms.StoreMessageInfo(mi)
303 }
304 return ms
305 }
306 return mi.MessageOf(x)
307 }
308
309
310 func (*ContainerRequest) Descriptor() ([]byte, []int) {
311 return file_chaosdaemon_proto_rawDescGZIP(), []int{1}
312 }
313
314 func (x *ContainerRequest) GetAction() *ContainerAction {
315 if x != nil {
316 return x.Action
317 }
318 return nil
319 }
320
321 func (x *ContainerRequest) GetContainerId() string {
322 if x != nil {
323 return x.ContainerId
324 }
325 return ""
326 }
327
328 type ContainerResponse struct {
329 state protoimpl.MessageState
330 sizeCache protoimpl.SizeCache
331 unknownFields protoimpl.UnknownFields
332
333 Pid uint32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
334 }
335
336 func (x *ContainerResponse) Reset() {
337 *x = ContainerResponse{}
338 if protoimpl.UnsafeEnabled {
339 mi := &file_chaosdaemon_proto_msgTypes[2]
340 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
341 ms.StoreMessageInfo(mi)
342 }
343 }
344
345 func (x *ContainerResponse) String() string {
346 return protoimpl.X.MessageStringOf(x)
347 }
348
349 func (*ContainerResponse) ProtoMessage() {}
350
351 func (x *ContainerResponse) ProtoReflect() protoreflect.Message {
352 mi := &file_chaosdaemon_proto_msgTypes[2]
353 if protoimpl.UnsafeEnabled && x != nil {
354 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
355 if ms.LoadMessageInfo() == nil {
356 ms.StoreMessageInfo(mi)
357 }
358 return ms
359 }
360 return mi.MessageOf(x)
361 }
362
363
364 func (*ContainerResponse) Descriptor() ([]byte, []int) {
365 return file_chaosdaemon_proto_rawDescGZIP(), []int{2}
366 }
367
368 func (x *ContainerResponse) GetPid() uint32 {
369 if x != nil {
370 return x.Pid
371 }
372 return 0
373 }
374
375 type NetemRequest struct {
376 state protoimpl.MessageState
377 sizeCache protoimpl.SizeCache
378 unknownFields protoimpl.UnknownFields
379
380 Netem *Netem `protobuf:"bytes,1,opt,name=netem,proto3" json:"netem,omitempty"`
381 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
382 Handle *TcHandle `protobuf:"bytes,3,opt,name=handle,proto3" json:"handle,omitempty"`
383 Parent *TcHandle `protobuf:"bytes,4,opt,name=parent,proto3" json:"parent,omitempty"`
384 }
385
386 func (x *NetemRequest) Reset() {
387 *x = NetemRequest{}
388 if protoimpl.UnsafeEnabled {
389 mi := &file_chaosdaemon_proto_msgTypes[3]
390 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
391 ms.StoreMessageInfo(mi)
392 }
393 }
394
395 func (x *NetemRequest) String() string {
396 return protoimpl.X.MessageStringOf(x)
397 }
398
399 func (*NetemRequest) ProtoMessage() {}
400
401 func (x *NetemRequest) ProtoReflect() protoreflect.Message {
402 mi := &file_chaosdaemon_proto_msgTypes[3]
403 if protoimpl.UnsafeEnabled && x != nil {
404 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
405 if ms.LoadMessageInfo() == nil {
406 ms.StoreMessageInfo(mi)
407 }
408 return ms
409 }
410 return mi.MessageOf(x)
411 }
412
413
414 func (*NetemRequest) Descriptor() ([]byte, []int) {
415 return file_chaosdaemon_proto_rawDescGZIP(), []int{3}
416 }
417
418 func (x *NetemRequest) GetNetem() *Netem {
419 if x != nil {
420 return x.Netem
421 }
422 return nil
423 }
424
425 func (x *NetemRequest) GetContainerId() string {
426 if x != nil {
427 return x.ContainerId
428 }
429 return ""
430 }
431
432 func (x *NetemRequest) GetHandle() *TcHandle {
433 if x != nil {
434 return x.Handle
435 }
436 return nil
437 }
438
439 func (x *NetemRequest) GetParent() *TcHandle {
440 if x != nil {
441 return x.Parent
442 }
443 return nil
444 }
445
446 type Netem struct {
447 state protoimpl.MessageState
448 sizeCache protoimpl.SizeCache
449 unknownFields protoimpl.UnknownFields
450
451 Time uint32 `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
452 Jitter uint32 `protobuf:"varint,2,opt,name=jitter,proto3" json:"jitter,omitempty"`
453 DelayCorr float32 `protobuf:"fixed32,3,opt,name=delay_corr,json=delayCorr,proto3" json:"delay_corr,omitempty"`
454 Limit uint32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
455 Loss float32 `protobuf:"fixed32,5,opt,name=loss,proto3" json:"loss,omitempty"`
456 LossCorr float32 `protobuf:"fixed32,6,opt,name=loss_corr,json=lossCorr,proto3" json:"loss_corr,omitempty"`
457 Gap uint32 `protobuf:"varint,7,opt,name=gap,proto3" json:"gap,omitempty"`
458 Duplicate float32 `protobuf:"fixed32,8,opt,name=duplicate,proto3" json:"duplicate,omitempty"`
459 DuplicateCorr float32 `protobuf:"fixed32,9,opt,name=duplicate_corr,json=duplicateCorr,proto3" json:"duplicate_corr,omitempty"`
460 Reorder float32 `protobuf:"fixed32,10,opt,name=reorder,proto3" json:"reorder,omitempty"`
461 ReorderCorr float32 `protobuf:"fixed32,11,opt,name=reorder_corr,json=reorderCorr,proto3" json:"reorder_corr,omitempty"`
462 Corrupt float32 `protobuf:"fixed32,12,opt,name=corrupt,proto3" json:"corrupt,omitempty"`
463 CorruptCorr float32 `protobuf:"fixed32,13,opt,name=corrupt_corr,json=corruptCorr,proto3" json:"corrupt_corr,omitempty"`
464 Parent *TcHandle `protobuf:"bytes,14,opt,name=parent,proto3" json:"parent,omitempty"`
465 Handle *TcHandle `protobuf:"bytes,15,opt,name=handle,proto3" json:"handle,omitempty"`
466 }
467
468 func (x *Netem) Reset() {
469 *x = Netem{}
470 if protoimpl.UnsafeEnabled {
471 mi := &file_chaosdaemon_proto_msgTypes[4]
472 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
473 ms.StoreMessageInfo(mi)
474 }
475 }
476
477 func (x *Netem) String() string {
478 return protoimpl.X.MessageStringOf(x)
479 }
480
481 func (*Netem) ProtoMessage() {}
482
483 func (x *Netem) ProtoReflect() protoreflect.Message {
484 mi := &file_chaosdaemon_proto_msgTypes[4]
485 if protoimpl.UnsafeEnabled && x != nil {
486 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
487 if ms.LoadMessageInfo() == nil {
488 ms.StoreMessageInfo(mi)
489 }
490 return ms
491 }
492 return mi.MessageOf(x)
493 }
494
495
496 func (*Netem) Descriptor() ([]byte, []int) {
497 return file_chaosdaemon_proto_rawDescGZIP(), []int{4}
498 }
499
500 func (x *Netem) GetTime() uint32 {
501 if x != nil {
502 return x.Time
503 }
504 return 0
505 }
506
507 func (x *Netem) GetJitter() uint32 {
508 if x != nil {
509 return x.Jitter
510 }
511 return 0
512 }
513
514 func (x *Netem) GetDelayCorr() float32 {
515 if x != nil {
516 return x.DelayCorr
517 }
518 return 0
519 }
520
521 func (x *Netem) GetLimit() uint32 {
522 if x != nil {
523 return x.Limit
524 }
525 return 0
526 }
527
528 func (x *Netem) GetLoss() float32 {
529 if x != nil {
530 return x.Loss
531 }
532 return 0
533 }
534
535 func (x *Netem) GetLossCorr() float32 {
536 if x != nil {
537 return x.LossCorr
538 }
539 return 0
540 }
541
542 func (x *Netem) GetGap() uint32 {
543 if x != nil {
544 return x.Gap
545 }
546 return 0
547 }
548
549 func (x *Netem) GetDuplicate() float32 {
550 if x != nil {
551 return x.Duplicate
552 }
553 return 0
554 }
555
556 func (x *Netem) GetDuplicateCorr() float32 {
557 if x != nil {
558 return x.DuplicateCorr
559 }
560 return 0
561 }
562
563 func (x *Netem) GetReorder() float32 {
564 if x != nil {
565 return x.Reorder
566 }
567 return 0
568 }
569
570 func (x *Netem) GetReorderCorr() float32 {
571 if x != nil {
572 return x.ReorderCorr
573 }
574 return 0
575 }
576
577 func (x *Netem) GetCorrupt() float32 {
578 if x != nil {
579 return x.Corrupt
580 }
581 return 0
582 }
583
584 func (x *Netem) GetCorruptCorr() float32 {
585 if x != nil {
586 return x.CorruptCorr
587 }
588 return 0
589 }
590
591 func (x *Netem) GetParent() *TcHandle {
592 if x != nil {
593 return x.Parent
594 }
595 return nil
596 }
597
598 func (x *Netem) GetHandle() *TcHandle {
599 if x != nil {
600 return x.Handle
601 }
602 return nil
603 }
604
605 type TbfRequest struct {
606 state protoimpl.MessageState
607 sizeCache protoimpl.SizeCache
608 unknownFields protoimpl.UnknownFields
609
610 Tbf *Tbf `protobuf:"bytes,1,opt,name=tbf,proto3" json:"tbf,omitempty"`
611 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
612 }
613
614 func (x *TbfRequest) Reset() {
615 *x = TbfRequest{}
616 if protoimpl.UnsafeEnabled {
617 mi := &file_chaosdaemon_proto_msgTypes[5]
618 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
619 ms.StoreMessageInfo(mi)
620 }
621 }
622
623 func (x *TbfRequest) String() string {
624 return protoimpl.X.MessageStringOf(x)
625 }
626
627 func (*TbfRequest) ProtoMessage() {}
628
629 func (x *TbfRequest) ProtoReflect() protoreflect.Message {
630 mi := &file_chaosdaemon_proto_msgTypes[5]
631 if protoimpl.UnsafeEnabled && x != nil {
632 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
633 if ms.LoadMessageInfo() == nil {
634 ms.StoreMessageInfo(mi)
635 }
636 return ms
637 }
638 return mi.MessageOf(x)
639 }
640
641
642 func (*TbfRequest) Descriptor() ([]byte, []int) {
643 return file_chaosdaemon_proto_rawDescGZIP(), []int{5}
644 }
645
646 func (x *TbfRequest) GetTbf() *Tbf {
647 if x != nil {
648 return x.Tbf
649 }
650 return nil
651 }
652
653 func (x *TbfRequest) GetContainerId() string {
654 if x != nil {
655 return x.ContainerId
656 }
657 return ""
658 }
659
660 type Tbf struct {
661 state protoimpl.MessageState
662 sizeCache protoimpl.SizeCache
663 unknownFields protoimpl.UnknownFields
664
665 Rate uint64 `protobuf:"varint,1,opt,name=rate,proto3" json:"rate,omitempty"`
666 Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
667 Buffer uint32 `protobuf:"varint,3,opt,name=buffer,proto3" json:"buffer,omitempty"`
668 PeakRate uint64 `protobuf:"varint,4,opt,name=peak_rate,json=peakRate,proto3" json:"peak_rate,omitempty"`
669 MinBurst uint32 `protobuf:"varint,5,opt,name=min_burst,json=minBurst,proto3" json:"min_burst,omitempty"`
670 }
671
672 func (x *Tbf) Reset() {
673 *x = Tbf{}
674 if protoimpl.UnsafeEnabled {
675 mi := &file_chaosdaemon_proto_msgTypes[6]
676 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
677 ms.StoreMessageInfo(mi)
678 }
679 }
680
681 func (x *Tbf) String() string {
682 return protoimpl.X.MessageStringOf(x)
683 }
684
685 func (*Tbf) ProtoMessage() {}
686
687 func (x *Tbf) ProtoReflect() protoreflect.Message {
688 mi := &file_chaosdaemon_proto_msgTypes[6]
689 if protoimpl.UnsafeEnabled && x != nil {
690 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
691 if ms.LoadMessageInfo() == nil {
692 ms.StoreMessageInfo(mi)
693 }
694 return ms
695 }
696 return mi.MessageOf(x)
697 }
698
699
700 func (*Tbf) Descriptor() ([]byte, []int) {
701 return file_chaosdaemon_proto_rawDescGZIP(), []int{6}
702 }
703
704 func (x *Tbf) GetRate() uint64 {
705 if x != nil {
706 return x.Rate
707 }
708 return 0
709 }
710
711 func (x *Tbf) GetLimit() uint32 {
712 if x != nil {
713 return x.Limit
714 }
715 return 0
716 }
717
718 func (x *Tbf) GetBuffer() uint32 {
719 if x != nil {
720 return x.Buffer
721 }
722 return 0
723 }
724
725 func (x *Tbf) GetPeakRate() uint64 {
726 if x != nil {
727 return x.PeakRate
728 }
729 return 0
730 }
731
732 func (x *Tbf) GetMinBurst() uint32 {
733 if x != nil {
734 return x.MinBurst
735 }
736 return 0
737 }
738
739 type QdiscRequest struct {
740 state protoimpl.MessageState
741 sizeCache protoimpl.SizeCache
742 unknownFields protoimpl.UnknownFields
743
744 Qdisc *Qdisc `protobuf:"bytes,1,opt,name=qdisc,proto3" json:"qdisc,omitempty"`
745 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
746 }
747
748 func (x *QdiscRequest) Reset() {
749 *x = QdiscRequest{}
750 if protoimpl.UnsafeEnabled {
751 mi := &file_chaosdaemon_proto_msgTypes[7]
752 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
753 ms.StoreMessageInfo(mi)
754 }
755 }
756
757 func (x *QdiscRequest) String() string {
758 return protoimpl.X.MessageStringOf(x)
759 }
760
761 func (*QdiscRequest) ProtoMessage() {}
762
763 func (x *QdiscRequest) ProtoReflect() protoreflect.Message {
764 mi := &file_chaosdaemon_proto_msgTypes[7]
765 if protoimpl.UnsafeEnabled && x != nil {
766 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
767 if ms.LoadMessageInfo() == nil {
768 ms.StoreMessageInfo(mi)
769 }
770 return ms
771 }
772 return mi.MessageOf(x)
773 }
774
775
776 func (*QdiscRequest) Descriptor() ([]byte, []int) {
777 return file_chaosdaemon_proto_rawDescGZIP(), []int{7}
778 }
779
780 func (x *QdiscRequest) GetQdisc() *Qdisc {
781 if x != nil {
782 return x.Qdisc
783 }
784 return nil
785 }
786
787 func (x *QdiscRequest) GetContainerId() string {
788 if x != nil {
789 return x.ContainerId
790 }
791 return ""
792 }
793
794 type Qdisc struct {
795 state protoimpl.MessageState
796 sizeCache protoimpl.SizeCache
797 unknownFields protoimpl.UnknownFields
798
799 Parent *TcHandle `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
800 Handle *TcHandle `protobuf:"bytes,2,opt,name=handle,proto3" json:"handle,omitempty"`
801 Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
802 Args []string `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
803 }
804
805 func (x *Qdisc) Reset() {
806 *x = Qdisc{}
807 if protoimpl.UnsafeEnabled {
808 mi := &file_chaosdaemon_proto_msgTypes[8]
809 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
810 ms.StoreMessageInfo(mi)
811 }
812 }
813
814 func (x *Qdisc) String() string {
815 return protoimpl.X.MessageStringOf(x)
816 }
817
818 func (*Qdisc) ProtoMessage() {}
819
820 func (x *Qdisc) ProtoReflect() protoreflect.Message {
821 mi := &file_chaosdaemon_proto_msgTypes[8]
822 if protoimpl.UnsafeEnabled && x != nil {
823 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
824 if ms.LoadMessageInfo() == nil {
825 ms.StoreMessageInfo(mi)
826 }
827 return ms
828 }
829 return mi.MessageOf(x)
830 }
831
832
833 func (*Qdisc) Descriptor() ([]byte, []int) {
834 return file_chaosdaemon_proto_rawDescGZIP(), []int{8}
835 }
836
837 func (x *Qdisc) GetParent() *TcHandle {
838 if x != nil {
839 return x.Parent
840 }
841 return nil
842 }
843
844 func (x *Qdisc) GetHandle() *TcHandle {
845 if x != nil {
846 return x.Handle
847 }
848 return nil
849 }
850
851 func (x *Qdisc) GetType() string {
852 if x != nil {
853 return x.Type
854 }
855 return ""
856 }
857
858 func (x *Qdisc) GetArgs() []string {
859 if x != nil {
860 return x.Args
861 }
862 return nil
863 }
864
865 type EmatchFilterRequest struct {
866 state protoimpl.MessageState
867 sizeCache protoimpl.SizeCache
868 unknownFields protoimpl.UnknownFields
869
870 Filter *EmatchFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
871 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
872 }
873
874 func (x *EmatchFilterRequest) Reset() {
875 *x = EmatchFilterRequest{}
876 if protoimpl.UnsafeEnabled {
877 mi := &file_chaosdaemon_proto_msgTypes[9]
878 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
879 ms.StoreMessageInfo(mi)
880 }
881 }
882
883 func (x *EmatchFilterRequest) String() string {
884 return protoimpl.X.MessageStringOf(x)
885 }
886
887 func (*EmatchFilterRequest) ProtoMessage() {}
888
889 func (x *EmatchFilterRequest) ProtoReflect() protoreflect.Message {
890 mi := &file_chaosdaemon_proto_msgTypes[9]
891 if protoimpl.UnsafeEnabled && x != nil {
892 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
893 if ms.LoadMessageInfo() == nil {
894 ms.StoreMessageInfo(mi)
895 }
896 return ms
897 }
898 return mi.MessageOf(x)
899 }
900
901
902 func (*EmatchFilterRequest) Descriptor() ([]byte, []int) {
903 return file_chaosdaemon_proto_rawDescGZIP(), []int{9}
904 }
905
906 func (x *EmatchFilterRequest) GetFilter() *EmatchFilter {
907 if x != nil {
908 return x.Filter
909 }
910 return nil
911 }
912
913 func (x *EmatchFilterRequest) GetContainerId() string {
914 if x != nil {
915 return x.ContainerId
916 }
917 return ""
918 }
919
920 type EmatchFilter struct {
921 state protoimpl.MessageState
922 sizeCache protoimpl.SizeCache
923 unknownFields protoimpl.UnknownFields
924
925 Match string `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
926 Parent *TcHandle `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"`
927 Classid *TcHandle `protobuf:"bytes,3,opt,name=classid,proto3" json:"classid,omitempty"`
928 }
929
930 func (x *EmatchFilter) Reset() {
931 *x = EmatchFilter{}
932 if protoimpl.UnsafeEnabled {
933 mi := &file_chaosdaemon_proto_msgTypes[10]
934 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
935 ms.StoreMessageInfo(mi)
936 }
937 }
938
939 func (x *EmatchFilter) String() string {
940 return protoimpl.X.MessageStringOf(x)
941 }
942
943 func (*EmatchFilter) ProtoMessage() {}
944
945 func (x *EmatchFilter) ProtoReflect() protoreflect.Message {
946 mi := &file_chaosdaemon_proto_msgTypes[10]
947 if protoimpl.UnsafeEnabled && x != nil {
948 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
949 if ms.LoadMessageInfo() == nil {
950 ms.StoreMessageInfo(mi)
951 }
952 return ms
953 }
954 return mi.MessageOf(x)
955 }
956
957
958 func (*EmatchFilter) Descriptor() ([]byte, []int) {
959 return file_chaosdaemon_proto_rawDescGZIP(), []int{10}
960 }
961
962 func (x *EmatchFilter) GetMatch() string {
963 if x != nil {
964 return x.Match
965 }
966 return ""
967 }
968
969 func (x *EmatchFilter) GetParent() *TcHandle {
970 if x != nil {
971 return x.Parent
972 }
973 return nil
974 }
975
976 func (x *EmatchFilter) GetClassid() *TcHandle {
977 if x != nil {
978 return x.Classid
979 }
980 return nil
981 }
982
983 type TcFilterRequest struct {
984 state protoimpl.MessageState
985 sizeCache protoimpl.SizeCache
986 unknownFields protoimpl.UnknownFields
987
988 Filter *TcFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
989 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
990 }
991
992 func (x *TcFilterRequest) Reset() {
993 *x = TcFilterRequest{}
994 if protoimpl.UnsafeEnabled {
995 mi := &file_chaosdaemon_proto_msgTypes[11]
996 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
997 ms.StoreMessageInfo(mi)
998 }
999 }
1000
1001 func (x *TcFilterRequest) String() string {
1002 return protoimpl.X.MessageStringOf(x)
1003 }
1004
1005 func (*TcFilterRequest) ProtoMessage() {}
1006
1007 func (x *TcFilterRequest) ProtoReflect() protoreflect.Message {
1008 mi := &file_chaosdaemon_proto_msgTypes[11]
1009 if protoimpl.UnsafeEnabled && x != nil {
1010 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1011 if ms.LoadMessageInfo() == nil {
1012 ms.StoreMessageInfo(mi)
1013 }
1014 return ms
1015 }
1016 return mi.MessageOf(x)
1017 }
1018
1019
1020 func (*TcFilterRequest) Descriptor() ([]byte, []int) {
1021 return file_chaosdaemon_proto_rawDescGZIP(), []int{11}
1022 }
1023
1024 func (x *TcFilterRequest) GetFilter() *TcFilter {
1025 if x != nil {
1026 return x.Filter
1027 }
1028 return nil
1029 }
1030
1031 func (x *TcFilterRequest) GetContainerId() string {
1032 if x != nil {
1033 return x.ContainerId
1034 }
1035 return ""
1036 }
1037
1038 type TcFilter struct {
1039 state protoimpl.MessageState
1040 sizeCache protoimpl.SizeCache
1041 unknownFields protoimpl.UnknownFields
1042
1043 Parent *TcHandle `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
1044 }
1045
1046 func (x *TcFilter) Reset() {
1047 *x = TcFilter{}
1048 if protoimpl.UnsafeEnabled {
1049 mi := &file_chaosdaemon_proto_msgTypes[12]
1050 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1051 ms.StoreMessageInfo(mi)
1052 }
1053 }
1054
1055 func (x *TcFilter) String() string {
1056 return protoimpl.X.MessageStringOf(x)
1057 }
1058
1059 func (*TcFilter) ProtoMessage() {}
1060
1061 func (x *TcFilter) ProtoReflect() protoreflect.Message {
1062 mi := &file_chaosdaemon_proto_msgTypes[12]
1063 if protoimpl.UnsafeEnabled && x != nil {
1064 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1065 if ms.LoadMessageInfo() == nil {
1066 ms.StoreMessageInfo(mi)
1067 }
1068 return ms
1069 }
1070 return mi.MessageOf(x)
1071 }
1072
1073
1074 func (*TcFilter) Descriptor() ([]byte, []int) {
1075 return file_chaosdaemon_proto_rawDescGZIP(), []int{12}
1076 }
1077
1078 func (x *TcFilter) GetParent() *TcHandle {
1079 if x != nil {
1080 return x.Parent
1081 }
1082 return nil
1083 }
1084
1085 type IPSetsRequest struct {
1086 state protoimpl.MessageState
1087 sizeCache protoimpl.SizeCache
1088 unknownFields protoimpl.UnknownFields
1089
1090 Ipsets []*IPSet `protobuf:"bytes,1,rep,name=ipsets,proto3" json:"ipsets,omitempty"`
1091 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
1092 EnterNS bool `protobuf:"varint,3,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
1093 }
1094
1095 func (x *IPSetsRequest) Reset() {
1096 *x = IPSetsRequest{}
1097 if protoimpl.UnsafeEnabled {
1098 mi := &file_chaosdaemon_proto_msgTypes[13]
1099 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1100 ms.StoreMessageInfo(mi)
1101 }
1102 }
1103
1104 func (x *IPSetsRequest) String() string {
1105 return protoimpl.X.MessageStringOf(x)
1106 }
1107
1108 func (*IPSetsRequest) ProtoMessage() {}
1109
1110 func (x *IPSetsRequest) ProtoReflect() protoreflect.Message {
1111 mi := &file_chaosdaemon_proto_msgTypes[13]
1112 if protoimpl.UnsafeEnabled && x != nil {
1113 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1114 if ms.LoadMessageInfo() == nil {
1115 ms.StoreMessageInfo(mi)
1116 }
1117 return ms
1118 }
1119 return mi.MessageOf(x)
1120 }
1121
1122
1123 func (*IPSetsRequest) Descriptor() ([]byte, []int) {
1124 return file_chaosdaemon_proto_rawDescGZIP(), []int{13}
1125 }
1126
1127 func (x *IPSetsRequest) GetIpsets() []*IPSet {
1128 if x != nil {
1129 return x.Ipsets
1130 }
1131 return nil
1132 }
1133
1134 func (x *IPSetsRequest) GetContainerId() string {
1135 if x != nil {
1136 return x.ContainerId
1137 }
1138 return ""
1139 }
1140
1141 func (x *IPSetsRequest) GetEnterNS() bool {
1142 if x != nil {
1143 return x.EnterNS
1144 }
1145 return false
1146 }
1147
1148 type IPSet struct {
1149 state protoimpl.MessageState
1150 sizeCache protoimpl.SizeCache
1151 unknownFields protoimpl.UnknownFields
1152
1153 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
1154 Cidrs []string `protobuf:"bytes,2,rep,name=cidrs,proto3" json:"cidrs,omitempty"`
1155 }
1156
1157 func (x *IPSet) Reset() {
1158 *x = IPSet{}
1159 if protoimpl.UnsafeEnabled {
1160 mi := &file_chaosdaemon_proto_msgTypes[14]
1161 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1162 ms.StoreMessageInfo(mi)
1163 }
1164 }
1165
1166 func (x *IPSet) String() string {
1167 return protoimpl.X.MessageStringOf(x)
1168 }
1169
1170 func (*IPSet) ProtoMessage() {}
1171
1172 func (x *IPSet) ProtoReflect() protoreflect.Message {
1173 mi := &file_chaosdaemon_proto_msgTypes[14]
1174 if protoimpl.UnsafeEnabled && x != nil {
1175 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1176 if ms.LoadMessageInfo() == nil {
1177 ms.StoreMessageInfo(mi)
1178 }
1179 return ms
1180 }
1181 return mi.MessageOf(x)
1182 }
1183
1184
1185 func (*IPSet) Descriptor() ([]byte, []int) {
1186 return file_chaosdaemon_proto_rawDescGZIP(), []int{14}
1187 }
1188
1189 func (x *IPSet) GetName() string {
1190 if x != nil {
1191 return x.Name
1192 }
1193 return ""
1194 }
1195
1196 func (x *IPSet) GetCidrs() []string {
1197 if x != nil {
1198 return x.Cidrs
1199 }
1200 return nil
1201 }
1202
1203 type IptablesChainsRequest struct {
1204 state protoimpl.MessageState
1205 sizeCache protoimpl.SizeCache
1206 unknownFields protoimpl.UnknownFields
1207
1208 Chains []*Chain `protobuf:"bytes,1,rep,name=chains,proto3" json:"chains,omitempty"`
1209 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
1210 EnterNS bool `protobuf:"varint,3,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
1211 }
1212
1213 func (x *IptablesChainsRequest) Reset() {
1214 *x = IptablesChainsRequest{}
1215 if protoimpl.UnsafeEnabled {
1216 mi := &file_chaosdaemon_proto_msgTypes[15]
1217 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1218 ms.StoreMessageInfo(mi)
1219 }
1220 }
1221
1222 func (x *IptablesChainsRequest) String() string {
1223 return protoimpl.X.MessageStringOf(x)
1224 }
1225
1226 func (*IptablesChainsRequest) ProtoMessage() {}
1227
1228 func (x *IptablesChainsRequest) ProtoReflect() protoreflect.Message {
1229 mi := &file_chaosdaemon_proto_msgTypes[15]
1230 if protoimpl.UnsafeEnabled && x != nil {
1231 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1232 if ms.LoadMessageInfo() == nil {
1233 ms.StoreMessageInfo(mi)
1234 }
1235 return ms
1236 }
1237 return mi.MessageOf(x)
1238 }
1239
1240
1241 func (*IptablesChainsRequest) Descriptor() ([]byte, []int) {
1242 return file_chaosdaemon_proto_rawDescGZIP(), []int{15}
1243 }
1244
1245 func (x *IptablesChainsRequest) GetChains() []*Chain {
1246 if x != nil {
1247 return x.Chains
1248 }
1249 return nil
1250 }
1251
1252 func (x *IptablesChainsRequest) GetContainerId() string {
1253 if x != nil {
1254 return x.ContainerId
1255 }
1256 return ""
1257 }
1258
1259 func (x *IptablesChainsRequest) GetEnterNS() bool {
1260 if x != nil {
1261 return x.EnterNS
1262 }
1263 return false
1264 }
1265
1266 type Chain struct {
1267 state protoimpl.MessageState
1268 sizeCache protoimpl.SizeCache
1269 unknownFields protoimpl.UnknownFields
1270
1271 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
1272 Direction Chain_Direction `protobuf:"varint,2,opt,name=direction,proto3,enum=pb.Chain_Direction" json:"direction,omitempty"`
1273 Ipsets []string `protobuf:"bytes,3,rep,name=ipsets,proto3" json:"ipsets,omitempty"`
1274 Target string `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"`
1275 Protocol string `protobuf:"bytes,5,opt,name=protocol,proto3" json:"protocol,omitempty"`
1276 SourcePorts string `protobuf:"bytes,6,opt,name=source_ports,json=sourcePorts,proto3" json:"source_ports,omitempty"`
1277 DestinationPorts string `protobuf:"bytes,7,opt,name=destination_ports,json=destinationPorts,proto3" json:"destination_ports,omitempty"`
1278 TcpFlags string `protobuf:"bytes,8,opt,name=tcp_flags,json=tcpFlags,proto3" json:"tcp_flags,omitempty"`
1279 Device string `protobuf:"bytes,9,opt,name=device,proto3" json:"device,omitempty"`
1280 }
1281
1282 func (x *Chain) Reset() {
1283 *x = Chain{}
1284 if protoimpl.UnsafeEnabled {
1285 mi := &file_chaosdaemon_proto_msgTypes[16]
1286 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1287 ms.StoreMessageInfo(mi)
1288 }
1289 }
1290
1291 func (x *Chain) String() string {
1292 return protoimpl.X.MessageStringOf(x)
1293 }
1294
1295 func (*Chain) ProtoMessage() {}
1296
1297 func (x *Chain) ProtoReflect() protoreflect.Message {
1298 mi := &file_chaosdaemon_proto_msgTypes[16]
1299 if protoimpl.UnsafeEnabled && x != nil {
1300 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1301 if ms.LoadMessageInfo() == nil {
1302 ms.StoreMessageInfo(mi)
1303 }
1304 return ms
1305 }
1306 return mi.MessageOf(x)
1307 }
1308
1309
1310 func (*Chain) Descriptor() ([]byte, []int) {
1311 return file_chaosdaemon_proto_rawDescGZIP(), []int{16}
1312 }
1313
1314 func (x *Chain) GetName() string {
1315 if x != nil {
1316 return x.Name
1317 }
1318 return ""
1319 }
1320
1321 func (x *Chain) GetDirection() Chain_Direction {
1322 if x != nil {
1323 return x.Direction
1324 }
1325 return Chain_INPUT
1326 }
1327
1328 func (x *Chain) GetIpsets() []string {
1329 if x != nil {
1330 return x.Ipsets
1331 }
1332 return nil
1333 }
1334
1335 func (x *Chain) GetTarget() string {
1336 if x != nil {
1337 return x.Target
1338 }
1339 return ""
1340 }
1341
1342 func (x *Chain) GetProtocol() string {
1343 if x != nil {
1344 return x.Protocol
1345 }
1346 return ""
1347 }
1348
1349 func (x *Chain) GetSourcePorts() string {
1350 if x != nil {
1351 return x.SourcePorts
1352 }
1353 return ""
1354 }
1355
1356 func (x *Chain) GetDestinationPorts() string {
1357 if x != nil {
1358 return x.DestinationPorts
1359 }
1360 return ""
1361 }
1362
1363 func (x *Chain) GetTcpFlags() string {
1364 if x != nil {
1365 return x.TcpFlags
1366 }
1367 return ""
1368 }
1369
1370 func (x *Chain) GetDevice() string {
1371 if x != nil {
1372 return x.Device
1373 }
1374 return ""
1375 }
1376
1377 type TimeRequest struct {
1378 state protoimpl.MessageState
1379 sizeCache protoimpl.SizeCache
1380 unknownFields protoimpl.UnknownFields
1381
1382 ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
1383 Sec int64 `protobuf:"varint,2,opt,name=sec,proto3" json:"sec,omitempty"`
1384 Nsec int64 `protobuf:"varint,3,opt,name=nsec,proto3" json:"nsec,omitempty"`
1385 ClkIdsMask uint64 `protobuf:"varint,4,opt,name=clk_ids_mask,json=clkIdsMask,proto3" json:"clk_ids_mask,omitempty"`
1386 }
1387
1388 func (x *TimeRequest) Reset() {
1389 *x = TimeRequest{}
1390 if protoimpl.UnsafeEnabled {
1391 mi := &file_chaosdaemon_proto_msgTypes[17]
1392 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1393 ms.StoreMessageInfo(mi)
1394 }
1395 }
1396
1397 func (x *TimeRequest) String() string {
1398 return protoimpl.X.MessageStringOf(x)
1399 }
1400
1401 func (*TimeRequest) ProtoMessage() {}
1402
1403 func (x *TimeRequest) ProtoReflect() protoreflect.Message {
1404 mi := &file_chaosdaemon_proto_msgTypes[17]
1405 if protoimpl.UnsafeEnabled && x != nil {
1406 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1407 if ms.LoadMessageInfo() == nil {
1408 ms.StoreMessageInfo(mi)
1409 }
1410 return ms
1411 }
1412 return mi.MessageOf(x)
1413 }
1414
1415
1416 func (*TimeRequest) Descriptor() ([]byte, []int) {
1417 return file_chaosdaemon_proto_rawDescGZIP(), []int{17}
1418 }
1419
1420 func (x *TimeRequest) GetContainerId() string {
1421 if x != nil {
1422 return x.ContainerId
1423 }
1424 return ""
1425 }
1426
1427 func (x *TimeRequest) GetSec() int64 {
1428 if x != nil {
1429 return x.Sec
1430 }
1431 return 0
1432 }
1433
1434 func (x *TimeRequest) GetNsec() int64 {
1435 if x != nil {
1436 return x.Nsec
1437 }
1438 return 0
1439 }
1440
1441 func (x *TimeRequest) GetClkIdsMask() uint64 {
1442 if x != nil {
1443 return x.ClkIdsMask
1444 }
1445 return 0
1446 }
1447
1448 type ContainerAction struct {
1449 state protoimpl.MessageState
1450 sizeCache protoimpl.SizeCache
1451 unknownFields protoimpl.UnknownFields
1452
1453 Action ContainerAction_Action `protobuf:"varint,1,opt,name=action,proto3,enum=pb.ContainerAction_Action" json:"action,omitempty"`
1454 }
1455
1456 func (x *ContainerAction) Reset() {
1457 *x = ContainerAction{}
1458 if protoimpl.UnsafeEnabled {
1459 mi := &file_chaosdaemon_proto_msgTypes[18]
1460 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1461 ms.StoreMessageInfo(mi)
1462 }
1463 }
1464
1465 func (x *ContainerAction) String() string {
1466 return protoimpl.X.MessageStringOf(x)
1467 }
1468
1469 func (*ContainerAction) ProtoMessage() {}
1470
1471 func (x *ContainerAction) ProtoReflect() protoreflect.Message {
1472 mi := &file_chaosdaemon_proto_msgTypes[18]
1473 if protoimpl.UnsafeEnabled && x != nil {
1474 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1475 if ms.LoadMessageInfo() == nil {
1476 ms.StoreMessageInfo(mi)
1477 }
1478 return ms
1479 }
1480 return mi.MessageOf(x)
1481 }
1482
1483
1484 func (*ContainerAction) Descriptor() ([]byte, []int) {
1485 return file_chaosdaemon_proto_rawDescGZIP(), []int{18}
1486 }
1487
1488 func (x *ContainerAction) GetAction() ContainerAction_Action {
1489 if x != nil {
1490 return x.Action
1491 }
1492 return ContainerAction_KILL
1493 }
1494
1495 type ExecStressRequest struct {
1496 state protoimpl.MessageState
1497 sizeCache protoimpl.SizeCache
1498 unknownFields protoimpl.UnknownFields
1499
1500 Scope ExecStressRequest_Scope `protobuf:"varint,1,opt,name=scope,proto3,enum=pb.ExecStressRequest_Scope" json:"scope,omitempty"`
1501 Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
1502 Stressors string `protobuf:"bytes,3,opt,name=stressors,proto3" json:"stressors,omitempty"`
1503 EnterNS bool `protobuf:"varint,4,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
1504 }
1505
1506 func (x *ExecStressRequest) Reset() {
1507 *x = ExecStressRequest{}
1508 if protoimpl.UnsafeEnabled {
1509 mi := &file_chaosdaemon_proto_msgTypes[19]
1510 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1511 ms.StoreMessageInfo(mi)
1512 }
1513 }
1514
1515 func (x *ExecStressRequest) String() string {
1516 return protoimpl.X.MessageStringOf(x)
1517 }
1518
1519 func (*ExecStressRequest) ProtoMessage() {}
1520
1521 func (x *ExecStressRequest) ProtoReflect() protoreflect.Message {
1522 mi := &file_chaosdaemon_proto_msgTypes[19]
1523 if protoimpl.UnsafeEnabled && x != nil {
1524 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1525 if ms.LoadMessageInfo() == nil {
1526 ms.StoreMessageInfo(mi)
1527 }
1528 return ms
1529 }
1530 return mi.MessageOf(x)
1531 }
1532
1533
1534 func (*ExecStressRequest) Descriptor() ([]byte, []int) {
1535 return file_chaosdaemon_proto_rawDescGZIP(), []int{19}
1536 }
1537
1538 func (x *ExecStressRequest) GetScope() ExecStressRequest_Scope {
1539 if x != nil {
1540 return x.Scope
1541 }
1542 return ExecStressRequest_CONTAINER
1543 }
1544
1545 func (x *ExecStressRequest) GetTarget() string {
1546 if x != nil {
1547 return x.Target
1548 }
1549 return ""
1550 }
1551
1552 func (x *ExecStressRequest) GetStressors() string {
1553 if x != nil {
1554 return x.Stressors
1555 }
1556 return ""
1557 }
1558
1559 func (x *ExecStressRequest) GetEnterNS() bool {
1560 if x != nil {
1561 return x.EnterNS
1562 }
1563 return false
1564 }
1565
1566 type ExecStressResponse struct {
1567 state protoimpl.MessageState
1568 sizeCache protoimpl.SizeCache
1569 unknownFields protoimpl.UnknownFields
1570
1571 Instance string `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
1572 StartTime int64 `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
1573 }
1574
1575 func (x *ExecStressResponse) Reset() {
1576 *x = ExecStressResponse{}
1577 if protoimpl.UnsafeEnabled {
1578 mi := &file_chaosdaemon_proto_msgTypes[20]
1579 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1580 ms.StoreMessageInfo(mi)
1581 }
1582 }
1583
1584 func (x *ExecStressResponse) String() string {
1585 return protoimpl.X.MessageStringOf(x)
1586 }
1587
1588 func (*ExecStressResponse) ProtoMessage() {}
1589
1590 func (x *ExecStressResponse) ProtoReflect() protoreflect.Message {
1591 mi := &file_chaosdaemon_proto_msgTypes[20]
1592 if protoimpl.UnsafeEnabled && x != nil {
1593 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1594 if ms.LoadMessageInfo() == nil {
1595 ms.StoreMessageInfo(mi)
1596 }
1597 return ms
1598 }
1599 return mi.MessageOf(x)
1600 }
1601
1602
1603 func (*ExecStressResponse) Descriptor() ([]byte, []int) {
1604 return file_chaosdaemon_proto_rawDescGZIP(), []int{20}
1605 }
1606
1607 func (x *ExecStressResponse) GetInstance() string {
1608 if x != nil {
1609 return x.Instance
1610 }
1611 return ""
1612 }
1613
1614 func (x *ExecStressResponse) GetStartTime() int64 {
1615 if x != nil {
1616 return x.StartTime
1617 }
1618 return 0
1619 }
1620
1621 type CancelStressRequest struct {
1622 state protoimpl.MessageState
1623 sizeCache protoimpl.SizeCache
1624 unknownFields protoimpl.UnknownFields
1625
1626 Instance string `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
1627 StartTime int64 `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
1628 }
1629
1630 func (x *CancelStressRequest) Reset() {
1631 *x = CancelStressRequest{}
1632 if protoimpl.UnsafeEnabled {
1633 mi := &file_chaosdaemon_proto_msgTypes[21]
1634 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1635 ms.StoreMessageInfo(mi)
1636 }
1637 }
1638
1639 func (x *CancelStressRequest) String() string {
1640 return protoimpl.X.MessageStringOf(x)
1641 }
1642
1643 func (*CancelStressRequest) ProtoMessage() {}
1644
1645 func (x *CancelStressRequest) ProtoReflect() protoreflect.Message {
1646 mi := &file_chaosdaemon_proto_msgTypes[21]
1647 if protoimpl.UnsafeEnabled && x != nil {
1648 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1649 if ms.LoadMessageInfo() == nil {
1650 ms.StoreMessageInfo(mi)
1651 }
1652 return ms
1653 }
1654 return mi.MessageOf(x)
1655 }
1656
1657
1658 func (*CancelStressRequest) Descriptor() ([]byte, []int) {
1659 return file_chaosdaemon_proto_rawDescGZIP(), []int{21}
1660 }
1661
1662 func (x *CancelStressRequest) GetInstance() string {
1663 if x != nil {
1664 return x.Instance
1665 }
1666 return ""
1667 }
1668
1669 func (x *CancelStressRequest) GetStartTime() int64 {
1670 if x != nil {
1671 return x.StartTime
1672 }
1673 return 0
1674 }
1675
1676 type ApplyIOChaosRequest struct {
1677 state protoimpl.MessageState
1678 sizeCache protoimpl.SizeCache
1679 unknownFields protoimpl.UnknownFields
1680
1681 Actions string `protobuf:"bytes,1,opt,name=actions,proto3" json:"actions,omitempty"`
1682 Volume string `protobuf:"bytes,2,opt,name=volume,proto3" json:"volume,omitempty"`
1683 ContainerId string `protobuf:"bytes,3,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
1684 Instance int64 `protobuf:"varint,4,opt,name=instance,proto3" json:"instance,omitempty"`
1685 StartTime int64 `protobuf:"varint,5,opt,name=startTime,proto3" json:"startTime,omitempty"`
1686 EnterNS bool `protobuf:"varint,6,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
1687 }
1688
1689 func (x *ApplyIOChaosRequest) Reset() {
1690 *x = ApplyIOChaosRequest{}
1691 if protoimpl.UnsafeEnabled {
1692 mi := &file_chaosdaemon_proto_msgTypes[22]
1693 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1694 ms.StoreMessageInfo(mi)
1695 }
1696 }
1697
1698 func (x *ApplyIOChaosRequest) String() string {
1699 return protoimpl.X.MessageStringOf(x)
1700 }
1701
1702 func (*ApplyIOChaosRequest) ProtoMessage() {}
1703
1704 func (x *ApplyIOChaosRequest) ProtoReflect() protoreflect.Message {
1705 mi := &file_chaosdaemon_proto_msgTypes[22]
1706 if protoimpl.UnsafeEnabled && x != nil {
1707 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1708 if ms.LoadMessageInfo() == nil {
1709 ms.StoreMessageInfo(mi)
1710 }
1711 return ms
1712 }
1713 return mi.MessageOf(x)
1714 }
1715
1716
1717 func (*ApplyIOChaosRequest) Descriptor() ([]byte, []int) {
1718 return file_chaosdaemon_proto_rawDescGZIP(), []int{22}
1719 }
1720
1721 func (x *ApplyIOChaosRequest) GetActions() string {
1722 if x != nil {
1723 return x.Actions
1724 }
1725 return ""
1726 }
1727
1728 func (x *ApplyIOChaosRequest) GetVolume() string {
1729 if x != nil {
1730 return x.Volume
1731 }
1732 return ""
1733 }
1734
1735 func (x *ApplyIOChaosRequest) GetContainerId() string {
1736 if x != nil {
1737 return x.ContainerId
1738 }
1739 return ""
1740 }
1741
1742 func (x *ApplyIOChaosRequest) GetInstance() int64 {
1743 if x != nil {
1744 return x.Instance
1745 }
1746 return 0
1747 }
1748
1749 func (x *ApplyIOChaosRequest) GetStartTime() int64 {
1750 if x != nil {
1751 return x.StartTime
1752 }
1753 return 0
1754 }
1755
1756 func (x *ApplyIOChaosRequest) GetEnterNS() bool {
1757 if x != nil {
1758 return x.EnterNS
1759 }
1760 return false
1761 }
1762
1763 type ApplyIOChaosResponse struct {
1764 state protoimpl.MessageState
1765 sizeCache protoimpl.SizeCache
1766 unknownFields protoimpl.UnknownFields
1767
1768 Instance int64 `protobuf:"varint,1,opt,name=instance,proto3" json:"instance,omitempty"`
1769 StartTime int64 `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
1770 }
1771
1772 func (x *ApplyIOChaosResponse) Reset() {
1773 *x = ApplyIOChaosResponse{}
1774 if protoimpl.UnsafeEnabled {
1775 mi := &file_chaosdaemon_proto_msgTypes[23]
1776 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1777 ms.StoreMessageInfo(mi)
1778 }
1779 }
1780
1781 func (x *ApplyIOChaosResponse) String() string {
1782 return protoimpl.X.MessageStringOf(x)
1783 }
1784
1785 func (*ApplyIOChaosResponse) ProtoMessage() {}
1786
1787 func (x *ApplyIOChaosResponse) ProtoReflect() protoreflect.Message {
1788 mi := &file_chaosdaemon_proto_msgTypes[23]
1789 if protoimpl.UnsafeEnabled && x != nil {
1790 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1791 if ms.LoadMessageInfo() == nil {
1792 ms.StoreMessageInfo(mi)
1793 }
1794 return ms
1795 }
1796 return mi.MessageOf(x)
1797 }
1798
1799
1800 func (*ApplyIOChaosResponse) Descriptor() ([]byte, []int) {
1801 return file_chaosdaemon_proto_rawDescGZIP(), []int{23}
1802 }
1803
1804 func (x *ApplyIOChaosResponse) GetInstance() int64 {
1805 if x != nil {
1806 return x.Instance
1807 }
1808 return 0
1809 }
1810
1811 func (x *ApplyIOChaosResponse) GetStartTime() int64 {
1812 if x != nil {
1813 return x.StartTime
1814 }
1815 return 0
1816 }
1817
1818 type ApplyHttpChaosRequest struct {
1819 state protoimpl.MessageState
1820 sizeCache protoimpl.SizeCache
1821 unknownFields protoimpl.UnknownFields
1822
1823 Rules string `protobuf:"bytes,1,opt,name=rules,proto3" json:"rules,omitempty"`
1824 ProxyPorts []uint32 `protobuf:"varint,2,rep,packed,name=proxy_ports,json=proxyPorts,proto3" json:"proxy_ports,omitempty"`
1825 ContainerId string `protobuf:"bytes,3,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
1826 Instance int64 `protobuf:"varint,4,opt,name=instance,proto3" json:"instance,omitempty"`
1827 StartTime int64 `protobuf:"varint,5,opt,name=startTime,proto3" json:"startTime,omitempty"`
1828 EnterNS bool `protobuf:"varint,6,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
1829 }
1830
1831 func (x *ApplyHttpChaosRequest) Reset() {
1832 *x = ApplyHttpChaosRequest{}
1833 if protoimpl.UnsafeEnabled {
1834 mi := &file_chaosdaemon_proto_msgTypes[24]
1835 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1836 ms.StoreMessageInfo(mi)
1837 }
1838 }
1839
1840 func (x *ApplyHttpChaosRequest) String() string {
1841 return protoimpl.X.MessageStringOf(x)
1842 }
1843
1844 func (*ApplyHttpChaosRequest) ProtoMessage() {}
1845
1846 func (x *ApplyHttpChaosRequest) ProtoReflect() protoreflect.Message {
1847 mi := &file_chaosdaemon_proto_msgTypes[24]
1848 if protoimpl.UnsafeEnabled && x != nil {
1849 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1850 if ms.LoadMessageInfo() == nil {
1851 ms.StoreMessageInfo(mi)
1852 }
1853 return ms
1854 }
1855 return mi.MessageOf(x)
1856 }
1857
1858
1859 func (*ApplyHttpChaosRequest) Descriptor() ([]byte, []int) {
1860 return file_chaosdaemon_proto_rawDescGZIP(), []int{24}
1861 }
1862
1863 func (x *ApplyHttpChaosRequest) GetRules() string {
1864 if x != nil {
1865 return x.Rules
1866 }
1867 return ""
1868 }
1869
1870 func (x *ApplyHttpChaosRequest) GetProxyPorts() []uint32 {
1871 if x != nil {
1872 return x.ProxyPorts
1873 }
1874 return nil
1875 }
1876
1877 func (x *ApplyHttpChaosRequest) GetContainerId() string {
1878 if x != nil {
1879 return x.ContainerId
1880 }
1881 return ""
1882 }
1883
1884 func (x *ApplyHttpChaosRequest) GetInstance() int64 {
1885 if x != nil {
1886 return x.Instance
1887 }
1888 return 0
1889 }
1890
1891 func (x *ApplyHttpChaosRequest) GetStartTime() int64 {
1892 if x != nil {
1893 return x.StartTime
1894 }
1895 return 0
1896 }
1897
1898 func (x *ApplyHttpChaosRequest) GetEnterNS() bool {
1899 if x != nil {
1900 return x.EnterNS
1901 }
1902 return false
1903 }
1904
1905 type ApplyHttpChaosResponse struct {
1906 state protoimpl.MessageState
1907 sizeCache protoimpl.SizeCache
1908 unknownFields protoimpl.UnknownFields
1909
1910 Instance int64 `protobuf:"varint,1,opt,name=instance,proto3" json:"instance,omitempty"`
1911 StartTime int64 `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
1912 StatusCode int32 `protobuf:"varint,3,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
1913 Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
1914 }
1915
1916 func (x *ApplyHttpChaosResponse) Reset() {
1917 *x = ApplyHttpChaosResponse{}
1918 if protoimpl.UnsafeEnabled {
1919 mi := &file_chaosdaemon_proto_msgTypes[25]
1920 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1921 ms.StoreMessageInfo(mi)
1922 }
1923 }
1924
1925 func (x *ApplyHttpChaosResponse) String() string {
1926 return protoimpl.X.MessageStringOf(x)
1927 }
1928
1929 func (*ApplyHttpChaosResponse) ProtoMessage() {}
1930
1931 func (x *ApplyHttpChaosResponse) ProtoReflect() protoreflect.Message {
1932 mi := &file_chaosdaemon_proto_msgTypes[25]
1933 if protoimpl.UnsafeEnabled && x != nil {
1934 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1935 if ms.LoadMessageInfo() == nil {
1936 ms.StoreMessageInfo(mi)
1937 }
1938 return ms
1939 }
1940 return mi.MessageOf(x)
1941 }
1942
1943
1944 func (*ApplyHttpChaosResponse) Descriptor() ([]byte, []int) {
1945 return file_chaosdaemon_proto_rawDescGZIP(), []int{25}
1946 }
1947
1948 func (x *ApplyHttpChaosResponse) GetInstance() int64 {
1949 if x != nil {
1950 return x.Instance
1951 }
1952 return 0
1953 }
1954
1955 func (x *ApplyHttpChaosResponse) GetStartTime() int64 {
1956 if x != nil {
1957 return x.StartTime
1958 }
1959 return 0
1960 }
1961
1962 func (x *ApplyHttpChaosResponse) GetStatusCode() int32 {
1963 if x != nil {
1964 return x.StatusCode
1965 }
1966 return 0
1967 }
1968
1969 func (x *ApplyHttpChaosResponse) GetError() string {
1970 if x != nil {
1971 return x.Error
1972 }
1973 return ""
1974 }
1975
1976 type TcsRequest struct {
1977 state protoimpl.MessageState
1978 sizeCache protoimpl.SizeCache
1979 unknownFields protoimpl.UnknownFields
1980
1981 Tcs []*Tc `protobuf:"bytes,1,rep,name=tcs,proto3" json:"tcs,omitempty"`
1982 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
1983 EnterNS bool `protobuf:"varint,4,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
1984 }
1985
1986 func (x *TcsRequest) Reset() {
1987 *x = TcsRequest{}
1988 if protoimpl.UnsafeEnabled {
1989 mi := &file_chaosdaemon_proto_msgTypes[26]
1990 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1991 ms.StoreMessageInfo(mi)
1992 }
1993 }
1994
1995 func (x *TcsRequest) String() string {
1996 return protoimpl.X.MessageStringOf(x)
1997 }
1998
1999 func (*TcsRequest) ProtoMessage() {}
2000
2001 func (x *TcsRequest) ProtoReflect() protoreflect.Message {
2002 mi := &file_chaosdaemon_proto_msgTypes[26]
2003 if protoimpl.UnsafeEnabled && x != nil {
2004 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2005 if ms.LoadMessageInfo() == nil {
2006 ms.StoreMessageInfo(mi)
2007 }
2008 return ms
2009 }
2010 return mi.MessageOf(x)
2011 }
2012
2013
2014 func (*TcsRequest) Descriptor() ([]byte, []int) {
2015 return file_chaosdaemon_proto_rawDescGZIP(), []int{26}
2016 }
2017
2018 func (x *TcsRequest) GetTcs() []*Tc {
2019 if x != nil {
2020 return x.Tcs
2021 }
2022 return nil
2023 }
2024
2025 func (x *TcsRequest) GetContainerId() string {
2026 if x != nil {
2027 return x.ContainerId
2028 }
2029 return ""
2030 }
2031
2032 func (x *TcsRequest) GetEnterNS() bool {
2033 if x != nil {
2034 return x.EnterNS
2035 }
2036 return false
2037 }
2038
2039 type Tc struct {
2040 state protoimpl.MessageState
2041 sizeCache protoimpl.SizeCache
2042 unknownFields protoimpl.UnknownFields
2043
2044 Type Tc_Type `protobuf:"varint,1,opt,name=type,proto3,enum=pb.Tc_Type" json:"type,omitempty"`
2045 Netem *Netem `protobuf:"bytes,2,opt,name=netem,proto3" json:"netem,omitempty"`
2046 Tbf *Tbf `protobuf:"bytes,3,opt,name=tbf,proto3" json:"tbf,omitempty"`
2047 Ipset string `protobuf:"bytes,4,opt,name=ipset,proto3" json:"ipset,omitempty"`
2048 Protocol string `protobuf:"bytes,5,opt,name=protocol,proto3" json:"protocol,omitempty"`
2049 SourcePort string `protobuf:"bytes,6,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"`
2050 EgressPort string `protobuf:"bytes,7,opt,name=egress_port,json=egressPort,proto3" json:"egress_port,omitempty"`
2051 Device string `protobuf:"bytes,9,opt,name=device,proto3" json:"device,omitempty"`
2052 }
2053
2054 func (x *Tc) Reset() {
2055 *x = Tc{}
2056 if protoimpl.UnsafeEnabled {
2057 mi := &file_chaosdaemon_proto_msgTypes[27]
2058 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2059 ms.StoreMessageInfo(mi)
2060 }
2061 }
2062
2063 func (x *Tc) String() string {
2064 return protoimpl.X.MessageStringOf(x)
2065 }
2066
2067 func (*Tc) ProtoMessage() {}
2068
2069 func (x *Tc) ProtoReflect() protoreflect.Message {
2070 mi := &file_chaosdaemon_proto_msgTypes[27]
2071 if protoimpl.UnsafeEnabled && x != nil {
2072 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2073 if ms.LoadMessageInfo() == nil {
2074 ms.StoreMessageInfo(mi)
2075 }
2076 return ms
2077 }
2078 return mi.MessageOf(x)
2079 }
2080
2081
2082 func (*Tc) Descriptor() ([]byte, []int) {
2083 return file_chaosdaemon_proto_rawDescGZIP(), []int{27}
2084 }
2085
2086 func (x *Tc) GetType() Tc_Type {
2087 if x != nil {
2088 return x.Type
2089 }
2090 return Tc_NETEM
2091 }
2092
2093 func (x *Tc) GetNetem() *Netem {
2094 if x != nil {
2095 return x.Netem
2096 }
2097 return nil
2098 }
2099
2100 func (x *Tc) GetTbf() *Tbf {
2101 if x != nil {
2102 return x.Tbf
2103 }
2104 return nil
2105 }
2106
2107 func (x *Tc) GetIpset() string {
2108 if x != nil {
2109 return x.Ipset
2110 }
2111 return ""
2112 }
2113
2114 func (x *Tc) GetProtocol() string {
2115 if x != nil {
2116 return x.Protocol
2117 }
2118 return ""
2119 }
2120
2121 func (x *Tc) GetSourcePort() string {
2122 if x != nil {
2123 return x.SourcePort
2124 }
2125 return ""
2126 }
2127
2128 func (x *Tc) GetEgressPort() string {
2129 if x != nil {
2130 return x.EgressPort
2131 }
2132 return ""
2133 }
2134
2135 func (x *Tc) GetDevice() string {
2136 if x != nil {
2137 return x.Device
2138 }
2139 return ""
2140 }
2141
2142 type SetDNSServerRequest struct {
2143 state protoimpl.MessageState
2144 sizeCache protoimpl.SizeCache
2145 unknownFields protoimpl.UnknownFields
2146
2147 ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
2148 DnsServer string `protobuf:"bytes,2,opt,name=dns_server,json=dnsServer,proto3" json:"dns_server,omitempty"`
2149 Enable bool `protobuf:"varint,3,opt,name=enable,proto3" json:"enable,omitempty"`
2150 EnterNS bool `protobuf:"varint,4,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
2151 }
2152
2153 func (x *SetDNSServerRequest) Reset() {
2154 *x = SetDNSServerRequest{}
2155 if protoimpl.UnsafeEnabled {
2156 mi := &file_chaosdaemon_proto_msgTypes[28]
2157 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2158 ms.StoreMessageInfo(mi)
2159 }
2160 }
2161
2162 func (x *SetDNSServerRequest) String() string {
2163 return protoimpl.X.MessageStringOf(x)
2164 }
2165
2166 func (*SetDNSServerRequest) ProtoMessage() {}
2167
2168 func (x *SetDNSServerRequest) ProtoReflect() protoreflect.Message {
2169 mi := &file_chaosdaemon_proto_msgTypes[28]
2170 if protoimpl.UnsafeEnabled && x != nil {
2171 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2172 if ms.LoadMessageInfo() == nil {
2173 ms.StoreMessageInfo(mi)
2174 }
2175 return ms
2176 }
2177 return mi.MessageOf(x)
2178 }
2179
2180
2181 func (*SetDNSServerRequest) Descriptor() ([]byte, []int) {
2182 return file_chaosdaemon_proto_rawDescGZIP(), []int{28}
2183 }
2184
2185 func (x *SetDNSServerRequest) GetContainerId() string {
2186 if x != nil {
2187 return x.ContainerId
2188 }
2189 return ""
2190 }
2191
2192 func (x *SetDNSServerRequest) GetDnsServer() string {
2193 if x != nil {
2194 return x.DnsServer
2195 }
2196 return ""
2197 }
2198
2199 func (x *SetDNSServerRequest) GetEnable() bool {
2200 if x != nil {
2201 return x.Enable
2202 }
2203 return false
2204 }
2205
2206 func (x *SetDNSServerRequest) GetEnterNS() bool {
2207 if x != nil {
2208 return x.EnterNS
2209 }
2210 return false
2211 }
2212
2213 type InstallJVMRulesRequest struct {
2214 state protoimpl.MessageState
2215 sizeCache protoimpl.SizeCache
2216 unknownFields protoimpl.UnknownFields
2217
2218 ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
2219 Rule string `protobuf:"bytes,2,opt,name=rule,proto3" json:"rule,omitempty"`
2220 Port int32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
2221 EnterNS bool `protobuf:"varint,4,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
2222 }
2223
2224 func (x *InstallJVMRulesRequest) Reset() {
2225 *x = InstallJVMRulesRequest{}
2226 if protoimpl.UnsafeEnabled {
2227 mi := &file_chaosdaemon_proto_msgTypes[29]
2228 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2229 ms.StoreMessageInfo(mi)
2230 }
2231 }
2232
2233 func (x *InstallJVMRulesRequest) String() string {
2234 return protoimpl.X.MessageStringOf(x)
2235 }
2236
2237 func (*InstallJVMRulesRequest) ProtoMessage() {}
2238
2239 func (x *InstallJVMRulesRequest) ProtoReflect() protoreflect.Message {
2240 mi := &file_chaosdaemon_proto_msgTypes[29]
2241 if protoimpl.UnsafeEnabled && x != nil {
2242 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2243 if ms.LoadMessageInfo() == nil {
2244 ms.StoreMessageInfo(mi)
2245 }
2246 return ms
2247 }
2248 return mi.MessageOf(x)
2249 }
2250
2251
2252 func (*InstallJVMRulesRequest) Descriptor() ([]byte, []int) {
2253 return file_chaosdaemon_proto_rawDescGZIP(), []int{29}
2254 }
2255
2256 func (x *InstallJVMRulesRequest) GetContainerId() string {
2257 if x != nil {
2258 return x.ContainerId
2259 }
2260 return ""
2261 }
2262
2263 func (x *InstallJVMRulesRequest) GetRule() string {
2264 if x != nil {
2265 return x.Rule
2266 }
2267 return ""
2268 }
2269
2270 func (x *InstallJVMRulesRequest) GetPort() int32 {
2271 if x != nil {
2272 return x.Port
2273 }
2274 return 0
2275 }
2276
2277 func (x *InstallJVMRulesRequest) GetEnterNS() bool {
2278 if x != nil {
2279 return x.EnterNS
2280 }
2281 return false
2282 }
2283
2284 type UninstallJVMRulesRequest struct {
2285 state protoimpl.MessageState
2286 sizeCache protoimpl.SizeCache
2287 unknownFields protoimpl.UnknownFields
2288
2289 ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
2290 Rule string `protobuf:"bytes,2,opt,name=rule,proto3" json:"rule,omitempty"`
2291 Port int32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
2292 EnterNS bool `protobuf:"varint,4,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
2293 }
2294
2295 func (x *UninstallJVMRulesRequest) Reset() {
2296 *x = UninstallJVMRulesRequest{}
2297 if protoimpl.UnsafeEnabled {
2298 mi := &file_chaosdaemon_proto_msgTypes[30]
2299 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2300 ms.StoreMessageInfo(mi)
2301 }
2302 }
2303
2304 func (x *UninstallJVMRulesRequest) String() string {
2305 return protoimpl.X.MessageStringOf(x)
2306 }
2307
2308 func (*UninstallJVMRulesRequest) ProtoMessage() {}
2309
2310 func (x *UninstallJVMRulesRequest) ProtoReflect() protoreflect.Message {
2311 mi := &file_chaosdaemon_proto_msgTypes[30]
2312 if protoimpl.UnsafeEnabled && x != nil {
2313 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2314 if ms.LoadMessageInfo() == nil {
2315 ms.StoreMessageInfo(mi)
2316 }
2317 return ms
2318 }
2319 return mi.MessageOf(x)
2320 }
2321
2322
2323 func (*UninstallJVMRulesRequest) Descriptor() ([]byte, []int) {
2324 return file_chaosdaemon_proto_rawDescGZIP(), []int{30}
2325 }
2326
2327 func (x *UninstallJVMRulesRequest) GetContainerId() string {
2328 if x != nil {
2329 return x.ContainerId
2330 }
2331 return ""
2332 }
2333
2334 func (x *UninstallJVMRulesRequest) GetRule() string {
2335 if x != nil {
2336 return x.Rule
2337 }
2338 return ""
2339 }
2340
2341 func (x *UninstallJVMRulesRequest) GetPort() int32 {
2342 if x != nil {
2343 return x.Port
2344 }
2345 return 0
2346 }
2347
2348 func (x *UninstallJVMRulesRequest) GetEnterNS() bool {
2349 if x != nil {
2350 return x.EnterNS
2351 }
2352 return false
2353 }
2354
2355 var File_chaosdaemon_proto protoreflect.FileDescriptor
2356
2357 var file_chaosdaemon_proto_rawDesc = []byte{
2358 0x0a, 0x11, 0x63, 0x68, 0x61, 0x6f, 0x73, 0x64, 0x61, 0x65, 0x6d, 0x6f, 0x6e, 0x2e, 0x70, 0x72,
2359 0x6f, 0x74, 0x6f, 0x12, 0x02, 0x70, 0x62, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f,
2360 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70,
2361 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x36, 0x0a, 0x08, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65,
2362 0x12, 0x14, 0x0a, 0x05, 0x6d, 0x61, 0x6a, 0x6f, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52,
2363 0x05, 0x6d, 0x61, 0x6a, 0x6f, 0x72, 0x12, 0x14, 0x0a, 0x05, 0x6d, 0x69, 0x6e, 0x6f, 0x72, 0x18,
2364 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x05, 0x6d, 0x69, 0x6e, 0x6f, 0x72, 0x22, 0x62, 0x0a, 0x10,
2365 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
2366 0x12, 0x2b, 0x0a, 0x06, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b,
2367 0x32, 0x13, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x41,
2368 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x06, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x21, 0x0a,
2369 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20,
2370 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64,
2371 0x22, 0x25, 0x0a, 0x11, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x52, 0x65, 0x73,
2372 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x70, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01,
2373 0x28, 0x0d, 0x52, 0x03, 0x70, 0x69, 0x64, 0x22, 0x9e, 0x01, 0x0a, 0x0c, 0x4e, 0x65, 0x74, 0x65,
2374 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1f, 0x0a, 0x05, 0x6e, 0x65, 0x74, 0x65,
2375 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x09, 0x2e, 0x70, 0x62, 0x2e, 0x4e, 0x65, 0x74,
2376 0x65, 0x6d, 0x52, 0x05, 0x6e, 0x65, 0x74, 0x65, 0x6d, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e,
2377 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52,
2378 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x24, 0x0a, 0x06,
2379 0x68, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70,
2380 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x52, 0x06, 0x68, 0x61, 0x6e, 0x64,
2381 0x6c, 0x65, 0x12, 0x24, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x04, 0x20, 0x01,
2382 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65,
2383 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x22, 0xb6, 0x03, 0x0a, 0x05, 0x4e, 0x65, 0x74,
2384 0x65, 0x6d, 0x12, 0x12, 0x0a, 0x04, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d,
2385 0x52, 0x04, 0x74, 0x69, 0x6d, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x6a, 0x69, 0x74, 0x74, 0x65, 0x72,
2386 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x06, 0x6a, 0x69, 0x74, 0x74, 0x65, 0x72, 0x12, 0x1d,
2387 0x0a, 0x0a, 0x64, 0x65, 0x6c, 0x61, 0x79, 0x5f, 0x63, 0x6f, 0x72, 0x72, 0x18, 0x03, 0x20, 0x01,
2388 0x28, 0x02, 0x52, 0x09, 0x64, 0x65, 0x6c, 0x61, 0x79, 0x43, 0x6f, 0x72, 0x72, 0x12, 0x14, 0x0a,
2389 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x05, 0x6c, 0x69,
2390 0x6d, 0x69, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x6c, 0x6f, 0x73, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28,
2391 0x02, 0x52, 0x04, 0x6c, 0x6f, 0x73, 0x73, 0x12, 0x1b, 0x0a, 0x09, 0x6c, 0x6f, 0x73, 0x73, 0x5f,
2392 0x63, 0x6f, 0x72, 0x72, 0x18, 0x06, 0x20, 0x01, 0x28, 0x02, 0x52, 0x08, 0x6c, 0x6f, 0x73, 0x73,
2393 0x43, 0x6f, 0x72, 0x72, 0x12, 0x10, 0x0a, 0x03, 0x67, 0x61, 0x70, 0x18, 0x07, 0x20, 0x01, 0x28,
2394 0x0d, 0x52, 0x03, 0x67, 0x61, 0x70, 0x12, 0x1c, 0x0a, 0x09, 0x64, 0x75, 0x70, 0x6c, 0x69, 0x63,
2395 0x61, 0x74, 0x65, 0x18, 0x08, 0x20, 0x01, 0x28, 0x02, 0x52, 0x09, 0x64, 0x75, 0x70, 0x6c, 0x69,
2396 0x63, 0x61, 0x74, 0x65, 0x12, 0x25, 0x0a, 0x0e, 0x64, 0x75, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74,
2397 0x65, 0x5f, 0x63, 0x6f, 0x72, 0x72, 0x18, 0x09, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0d, 0x64, 0x75,
2398 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x65, 0x43, 0x6f, 0x72, 0x72, 0x12, 0x18, 0x0a, 0x07, 0x72,
2399 0x65, 0x6f, 0x72, 0x64, 0x65, 0x72, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x02, 0x52, 0x07, 0x72, 0x65,
2400 0x6f, 0x72, 0x64, 0x65, 0x72, 0x12, 0x21, 0x0a, 0x0c, 0x72, 0x65, 0x6f, 0x72, 0x64, 0x65, 0x72,
2401 0x5f, 0x63, 0x6f, 0x72, 0x72, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0b, 0x72, 0x65, 0x6f,
2402 0x72, 0x64, 0x65, 0x72, 0x43, 0x6f, 0x72, 0x72, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x6f, 0x72, 0x72,
2403 0x75, 0x70, 0x74, 0x18, 0x0c, 0x20, 0x01, 0x28, 0x02, 0x52, 0x07, 0x63, 0x6f, 0x72, 0x72, 0x75,
2404 0x70, 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x72, 0x72, 0x75, 0x70, 0x74, 0x5f, 0x63, 0x6f,
2405 0x72, 0x72, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0b, 0x63, 0x6f, 0x72, 0x72, 0x75, 0x70,
2406 0x74, 0x43, 0x6f, 0x72, 0x72, 0x12, 0x24, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18,
2407 0x0e, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e,
2408 0x64, 0x6c, 0x65, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x24, 0x0a, 0x06, 0x68,
2409 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x18, 0x0f, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x62,
2410 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x52, 0x06, 0x68, 0x61, 0x6e, 0x64, 0x6c,
2411 0x65, 0x22, 0x4a, 0x0a, 0x0a, 0x54, 0x62, 0x66, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12,
2412 0x19, 0x0a, 0x03, 0x74, 0x62, 0x66, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x07, 0x2e, 0x70,
2413 0x62, 0x2e, 0x54, 0x62, 0x66, 0x52, 0x03, 0x74, 0x62, 0x66, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f,
2414 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09,
2415 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x22, 0x81, 0x01,
2416 0x0a, 0x03, 0x54, 0x62, 0x66, 0x12, 0x12, 0x0a, 0x04, 0x72, 0x61, 0x74, 0x65, 0x18, 0x01, 0x20,
2417 0x01, 0x28, 0x04, 0x52, 0x04, 0x72, 0x61, 0x74, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x6c, 0x69, 0x6d,
2418 0x69, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x12,
2419 0x16, 0x0a, 0x06, 0x62, 0x75, 0x66, 0x66, 0x65, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0d, 0x52,
2420 0x06, 0x62, 0x75, 0x66, 0x66, 0x65, 0x72, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x65, 0x61, 0x6b, 0x5f,
2421 0x72, 0x61, 0x74, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x04, 0x52, 0x08, 0x70, 0x65, 0x61, 0x6b,
2422 0x52, 0x61, 0x74, 0x65, 0x12, 0x1b, 0x0a, 0x09, 0x6d, 0x69, 0x6e, 0x5f, 0x62, 0x75, 0x72, 0x73,
2423 0x74, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x08, 0x6d, 0x69, 0x6e, 0x42, 0x75, 0x72, 0x73,
2424 0x74, 0x22, 0x52, 0x0a, 0x0c, 0x51, 0x64, 0x69, 0x73, 0x63, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
2425 0x74, 0x12, 0x1f, 0x0a, 0x05, 0x71, 0x64, 0x69, 0x73, 0x63, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b,
2426 0x32, 0x09, 0x2e, 0x70, 0x62, 0x2e, 0x51, 0x64, 0x69, 0x73, 0x63, 0x52, 0x05, 0x71, 0x64, 0x69,
2427 0x73, 0x63, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f,
2428 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69,
2429 0x6e, 0x65, 0x72, 0x49, 0x64, 0x22, 0x7b, 0x0a, 0x05, 0x51, 0x64, 0x69, 0x73, 0x63, 0x12, 0x24,
2430 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c,
2431 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x52, 0x06, 0x70, 0x61,
2432 0x72, 0x65, 0x6e, 0x74, 0x12, 0x24, 0x0a, 0x06, 0x68, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x18, 0x02,
2433 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64,
2434 0x6c, 0x65, 0x52, 0x06, 0x68, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x74, 0x79,
2435 0x70, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x12,
2436 0x0a, 0x04, 0x61, 0x72, 0x67, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x09, 0x52, 0x04, 0x61, 0x72,
2437 0x67, 0x73, 0x22, 0x62, 0x0a, 0x13, 0x45, 0x6d, 0x61, 0x74, 0x63, 0x68, 0x46, 0x69, 0x6c, 0x74,
2438 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x28, 0x0a, 0x06, 0x66, 0x69, 0x6c,
2439 0x74, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x10, 0x2e, 0x70, 0x62, 0x2e, 0x45,
2440 0x6d, 0x61, 0x74, 0x63, 0x68, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x52, 0x06, 0x66, 0x69, 0x6c,
2441 0x74, 0x65, 0x72, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72,
2442 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61,
2443 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x22, 0x72, 0x0a, 0x0c, 0x45, 0x6d, 0x61, 0x74, 0x63, 0x68,
2444 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x12, 0x14, 0x0a, 0x05, 0x6d, 0x61, 0x74, 0x63, 0x68, 0x18,
2445 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x6d, 0x61, 0x74, 0x63, 0x68, 0x12, 0x24, 0x0a, 0x06,
2446 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70,
2447 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65,
2448 0x6e, 0x74, 0x12, 0x26, 0x0a, 0x07, 0x63, 0x6c, 0x61, 0x73, 0x73, 0x69, 0x64, 0x18, 0x03, 0x20,
2449 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c,
2450 0x65, 0x52, 0x07, 0x63, 0x6c, 0x61, 0x73, 0x73, 0x69, 0x64, 0x22, 0x5a, 0x0a, 0x0f, 0x54, 0x63,
2451 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x24, 0x0a,
2452 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e,
2453 0x70, 0x62, 0x2e, 0x54, 0x63, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x52, 0x06, 0x66, 0x69, 0x6c,
2454 0x74, 0x65, 0x72, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72,
2455 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61,
2456 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x22, 0x30, 0x0a, 0x08, 0x54, 0x63, 0x46, 0x69, 0x6c, 0x74,
2457 0x65, 0x72, 0x12, 0x24, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01,
2458 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65,
2459 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x22, 0x6f, 0x0a, 0x0d, 0x49, 0x50, 0x53, 0x65,
2460 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x21, 0x0a, 0x06, 0x69, 0x70, 0x73,
2461 0x65, 0x74, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x09, 0x2e, 0x70, 0x62, 0x2e, 0x49,
2462 0x50, 0x53, 0x65, 0x74, 0x52, 0x06, 0x69, 0x70, 0x73, 0x65, 0x74, 0x73, 0x12, 0x21, 0x0a, 0x0c,
2463 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01,
2464 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12,
2465 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x18, 0x03, 0x20, 0x01, 0x28, 0x08,
2466 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x22, 0x31, 0x0a, 0x05, 0x49, 0x50, 0x53,
2467 0x65, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
2468 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x63, 0x69, 0x64, 0x72, 0x73, 0x18,
2469 0x02, 0x20, 0x03, 0x28, 0x09, 0x52, 0x05, 0x63, 0x69, 0x64, 0x72, 0x73, 0x22, 0x77, 0x0a, 0x15,
2470 0x49, 0x70, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x43, 0x68, 0x61, 0x69, 0x6e, 0x73, 0x52, 0x65,
2471 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x21, 0x0a, 0x06, 0x63, 0x68, 0x61, 0x69, 0x6e, 0x73, 0x18,
2472 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x09, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x68, 0x61, 0x69, 0x6e,
2473 0x52, 0x06, 0x63, 0x68, 0x61, 0x69, 0x6e, 0x73, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74,
2474 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b,
2475 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x65,
2476 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x18, 0x03, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e,
2477 0x74, 0x65, 0x72, 0x4e, 0x53, 0x22, 0xc3, 0x02, 0x0a, 0x05, 0x43, 0x68, 0x61, 0x69, 0x6e, 0x12,
2478 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e,
2479 0x61, 0x6d, 0x65, 0x12, 0x31, 0x0a, 0x09, 0x64, 0x69, 0x72, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e,
2480 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x13, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x68, 0x61, 0x69,
2481 0x6e, 0x2e, 0x44, 0x69, 0x72, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x09, 0x64, 0x69, 0x72,
2482 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x16, 0x0a, 0x06, 0x69, 0x70, 0x73, 0x65, 0x74, 0x73,
2483 0x18, 0x03, 0x20, 0x03, 0x28, 0x09, 0x52, 0x06, 0x69, 0x70, 0x73, 0x65, 0x74, 0x73, 0x12, 0x16,
2484 0x0a, 0x06, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06,
2485 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x12, 0x1a, 0x0a, 0x08, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63,
2486 0x6f, 0x6c, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63,
2487 0x6f, 0x6c, 0x12, 0x21, 0x0a, 0x0c, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x5f, 0x70, 0x6f, 0x72,
2488 0x74, 0x73, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65,
2489 0x50, 0x6f, 0x72, 0x74, 0x73, 0x12, 0x2b, 0x0a, 0x11, 0x64, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x61,
2490 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x70, 0x6f, 0x72, 0x74, 0x73, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09,
2491 0x52, 0x10, 0x64, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x50, 0x6f, 0x72,
2492 0x74, 0x73, 0x12, 0x1b, 0x0a, 0x09, 0x74, 0x63, 0x70, 0x5f, 0x66, 0x6c, 0x61, 0x67, 0x73, 0x18,
2493 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x74, 0x63, 0x70, 0x46, 0x6c, 0x61, 0x67, 0x73, 0x12,
2494 0x16, 0x0a, 0x06, 0x64, 0x65, 0x76, 0x69, 0x63, 0x65, 0x18, 0x09, 0x20, 0x01, 0x28, 0x09, 0x52,
2495 0x06, 0x64, 0x65, 0x76, 0x69, 0x63, 0x65, 0x22, 0x22, 0x0a, 0x09, 0x44, 0x69, 0x72, 0x65, 0x63,
2496 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x09, 0x0a, 0x05, 0x49, 0x4e, 0x50, 0x55, 0x54, 0x10, 0x00, 0x12,
2497 0x0a, 0x0a, 0x06, 0x4f, 0x55, 0x54, 0x50, 0x55, 0x54, 0x10, 0x01, 0x22, 0x78, 0x0a, 0x0b, 0x54,
2498 0x69, 0x6d, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f,
2499 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
2500 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x10, 0x0a,
2501 0x03, 0x73, 0x65, 0x63, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x03, 0x73, 0x65, 0x63, 0x12,
2502 0x12, 0x0a, 0x04, 0x6e, 0x73, 0x65, 0x63, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x04, 0x6e,
2503 0x73, 0x65, 0x63, 0x12, 0x20, 0x0a, 0x0c, 0x63, 0x6c, 0x6b, 0x5f, 0x69, 0x64, 0x73, 0x5f, 0x6d,
2504 0x61, 0x73, 0x6b, 0x18, 0x04, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0a, 0x63, 0x6c, 0x6b, 0x49, 0x64,
2505 0x73, 0x4d, 0x61, 0x73, 0x6b, 0x22, 0x65, 0x0a, 0x0f, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e,
2506 0x65, 0x72, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x32, 0x0a, 0x06, 0x61, 0x63, 0x74, 0x69,
2507 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1a, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x6f,
2508 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x41, 0x63,
2509 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x06, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x1e, 0x0a, 0x06,
2510 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x08, 0x0a, 0x04, 0x4b, 0x49, 0x4c, 0x4c, 0x10, 0x00,
2511 0x12, 0x0a, 0x0a, 0x06, 0x47, 0x45, 0x54, 0x50, 0x49, 0x44, 0x10, 0x01, 0x22, 0xb7, 0x01, 0x0a,
2512 0x11, 0x45, 0x78, 0x65, 0x63, 0x53, 0x74, 0x72, 0x65, 0x73, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65,
2513 0x73, 0x74, 0x12, 0x31, 0x0a, 0x05, 0x73, 0x63, 0x6f, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28,
2514 0x0e, 0x32, 0x1b, 0x2e, 0x70, 0x62, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x53, 0x74, 0x72, 0x65, 0x73,
2515 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x53, 0x63, 0x6f, 0x70, 0x65, 0x52, 0x05,
2516 0x73, 0x63, 0x6f, 0x70, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x18,
2517 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x12, 0x1c, 0x0a,
2518 0x09, 0x73, 0x74, 0x72, 0x65, 0x73, 0x73, 0x6f, 0x72, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09,
2519 0x52, 0x09, 0x73, 0x74, 0x72, 0x65, 0x73, 0x73, 0x6f, 0x72, 0x73, 0x12, 0x18, 0x0a, 0x07, 0x65,
2520 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e,
2521 0x74, 0x65, 0x72, 0x4e, 0x53, 0x22, 0x1f, 0x0a, 0x05, 0x53, 0x63, 0x6f, 0x70, 0x65, 0x12, 0x0d,
2522 0x0a, 0x09, 0x43, 0x4f, 0x4e, 0x54, 0x41, 0x49, 0x4e, 0x45, 0x52, 0x10, 0x00, 0x12, 0x07, 0x0a,
2523 0x03, 0x50, 0x4f, 0x44, 0x10, 0x01, 0x22, 0x4e, 0x0a, 0x12, 0x45, 0x78, 0x65, 0x63, 0x53, 0x74,
2524 0x72, 0x65, 0x73, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1a, 0x0a, 0x08,
2525 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08,
2526 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x74, 0x61, 0x72,
2527 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x73, 0x74, 0x61,
2528 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x22, 0x4f, 0x0a, 0x13, 0x43, 0x61, 0x6e, 0x63, 0x65, 0x6c,
2529 0x53, 0x74, 0x72, 0x65, 0x73, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1a, 0x0a,
2530 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52,
2531 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x74, 0x61,
2532 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x73, 0x74,
2533 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x22, 0xbe, 0x01, 0x0a, 0x13, 0x41, 0x70, 0x70, 0x6c,
2534 0x79, 0x49, 0x4f, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12,
2535 0x18, 0x0a, 0x07, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
2536 0x52, 0x07, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x16, 0x0a, 0x06, 0x76, 0x6f, 0x6c,
2537 0x75, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x76, 0x6f, 0x6c, 0x75, 0x6d,
2538 0x65, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69,
2539 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e,
2540 0x65, 0x72, 0x49, 0x64, 0x12, 0x1a, 0x0a, 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65,
2541 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65,
2542 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x05, 0x20,
2543 0x01, 0x28, 0x03, 0x52, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x18,
2544 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x18, 0x06, 0x20, 0x01, 0x28, 0x08, 0x52,
2545 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x22, 0x50, 0x0a, 0x14, 0x41, 0x70, 0x70, 0x6c,
2546 0x79, 0x49, 0x4f, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
2547 0x12, 0x1a, 0x0a, 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x18, 0x01, 0x20, 0x01,
2548 0x28, 0x03, 0x52, 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x12, 0x1c, 0x0a, 0x09,
2549 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52,
2550 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x22, 0xc5, 0x01, 0x0a, 0x15, 0x41,
2551 0x70, 0x70, 0x6c, 0x79, 0x48, 0x74, 0x74, 0x70, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x52, 0x65, 0x71,
2552 0x75, 0x65, 0x73, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x72, 0x75, 0x6c, 0x65, 0x73, 0x18, 0x01, 0x20,
2553 0x01, 0x28, 0x09, 0x52, 0x05, 0x72, 0x75, 0x6c, 0x65, 0x73, 0x12, 0x1f, 0x0a, 0x0b, 0x70, 0x72,
2554 0x6f, 0x78, 0x79, 0x5f, 0x70, 0x6f, 0x72, 0x74, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0d, 0x52,
2555 0x0a, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x50, 0x6f, 0x72, 0x74, 0x73, 0x12, 0x21, 0x0a, 0x0c, 0x63,
2556 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28,
2557 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x1a,
2558 0x0a, 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03,
2559 0x52, 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x74,
2560 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x73,
2561 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65,
2562 0x72, 0x4e, 0x53, 0x18, 0x06, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72,
2563 0x4e, 0x53, 0x22, 0x88, 0x01, 0x0a, 0x16, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x48, 0x74, 0x74, 0x70,
2564 0x43, 0x68, 0x61, 0x6f, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1a, 0x0a,
2565 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52,
2566 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x74, 0x61,
2567 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x73, 0x74,
2568 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x1e, 0x0a, 0x0a, 0x73, 0x74, 0x61, 0x74, 0x75,
2569 0x73, 0x43, 0x6f, 0x64, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0a, 0x73, 0x74, 0x61,
2570 0x74, 0x75, 0x73, 0x43, 0x6f, 0x64, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72,
2571 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x22, 0x63, 0x0a,
2572 0x0a, 0x54, 0x63, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x18, 0x0a, 0x03, 0x74,
2573 0x63, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x06, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63,
2574 0x52, 0x03, 0x74, 0x63, 0x73, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e,
2575 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e,
2576 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65,
2577 0x72, 0x4e, 0x53, 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72,
2578 0x4e, 0x53, 0x22, 0x8f, 0x02, 0x0a, 0x02, 0x54, 0x63, 0x12, 0x1f, 0x0a, 0x04, 0x74, 0x79, 0x70,
2579 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x0b, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x2e,
2580 0x54, 0x79, 0x70, 0x65, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x1f, 0x0a, 0x05, 0x6e, 0x65,
2581 0x74, 0x65, 0x6d, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x09, 0x2e, 0x70, 0x62, 0x2e, 0x4e,
2582 0x65, 0x74, 0x65, 0x6d, 0x52, 0x05, 0x6e, 0x65, 0x74, 0x65, 0x6d, 0x12, 0x19, 0x0a, 0x03, 0x74,
2583 0x62, 0x66, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x07, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x62,
2584 0x66, 0x52, 0x03, 0x74, 0x62, 0x66, 0x12, 0x14, 0x0a, 0x05, 0x69, 0x70, 0x73, 0x65, 0x74, 0x18,
2585 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x69, 0x70, 0x73, 0x65, 0x74, 0x12, 0x1a, 0x0a, 0x08,
2586 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08,
2587 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x12, 0x1f, 0x0a, 0x0b, 0x73, 0x6f, 0x75, 0x72,
2588 0x63, 0x65, 0x5f, 0x70, 0x6f, 0x72, 0x74, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x73,
2589 0x6f, 0x75, 0x72, 0x63, 0x65, 0x50, 0x6f, 0x72, 0x74, 0x12, 0x1f, 0x0a, 0x0b, 0x65, 0x67, 0x72,
2590 0x65, 0x73, 0x73, 0x5f, 0x70, 0x6f, 0x72, 0x74, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a,
2591 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 0x50, 0x6f, 0x72, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x64, 0x65,
2592 0x76, 0x69, 0x63, 0x65, 0x18, 0x09, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x64, 0x65, 0x76, 0x69,
2593 0x63, 0x65, 0x22, 0x20, 0x0a, 0x04, 0x54, 0x79, 0x70, 0x65, 0x12, 0x09, 0x0a, 0x05, 0x4e, 0x45,
2594 0x54, 0x45, 0x4d, 0x10, 0x00, 0x12, 0x0d, 0x0a, 0x09, 0x42, 0x41, 0x4e, 0x44, 0x57, 0x49, 0x44,
2595 0x54, 0x48, 0x10, 0x01, 0x22, 0x89, 0x01, 0x0a, 0x13, 0x53, 0x65, 0x74, 0x44, 0x4e, 0x53, 0x53,
2596 0x65, 0x72, 0x76, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x21, 0x0a, 0x0c,
2597 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01,
2598 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12,
2599 0x1d, 0x0a, 0x0a, 0x64, 0x6e, 0x73, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x18, 0x02, 0x20,
2600 0x01, 0x28, 0x09, 0x52, 0x09, 0x64, 0x6e, 0x73, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x12, 0x16,
2601 0x0a, 0x06, 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x08, 0x52, 0x06,
2602 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e,
2603 0x53, 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53,
2604 0x22, 0x7d, 0x0a, 0x16, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x4a, 0x56, 0x4d, 0x52, 0x75,
2605 0x6c, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f,
2606 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
2607 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x12, 0x0a,
2608 0x04, 0x72, 0x75, 0x6c, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x72, 0x75, 0x6c,
2609 0x65, 0x12, 0x12, 0x0a, 0x04, 0x70, 0x6f, 0x72, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52,
2610 0x04, 0x70, 0x6f, 0x72, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53,
2611 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x22,
2612 0x7f, 0x0a, 0x18, 0x55, 0x6e, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x4a, 0x56, 0x4d, 0x52,
2613 0x75, 0x6c, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x63,
2614 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28,
2615 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x12,
2616 0x0a, 0x04, 0x72, 0x75, 0x6c, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x72, 0x75,
2617 0x6c, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x70, 0x6f, 0x72, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05,
2618 0x52, 0x04, 0x70, 0x6f, 0x72, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e,
2619 0x53, 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53,
2620 0x32, 0xb7, 0x07, 0x0a, 0x0b, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x44, 0x61, 0x65, 0x6d, 0x6f, 0x6e,
2621 0x12, 0x32, 0x0a, 0x06, 0x53, 0x65, 0x74, 0x54, 0x63, 0x73, 0x12, 0x0e, 0x2e, 0x70, 0x62, 0x2e,
2622 0x54, 0x63, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f,
2623 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70,
2624 0x74, 0x79, 0x22, 0x00, 0x12, 0x3a, 0x0a, 0x0b, 0x46, 0x6c, 0x75, 0x73, 0x68, 0x49, 0x50, 0x53,
2625 0x65, 0x74, 0x73, 0x12, 0x11, 0x2e, 0x70, 0x62, 0x2e, 0x49, 0x50, 0x53, 0x65, 0x74, 0x73, 0x52,
2626 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
2627 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00,
2628 0x12, 0x48, 0x0a, 0x11, 0x53, 0x65, 0x74, 0x49, 0x70, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x43,
2629 0x68, 0x61, 0x69, 0x6e, 0x73, 0x12, 0x19, 0x2e, 0x70, 0x62, 0x2e, 0x49, 0x70, 0x74, 0x61, 0x62,
2630 0x6c, 0x65, 0x73, 0x43, 0x68, 0x61, 0x69, 0x6e, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
2631 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62,
2632 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x3a, 0x0a, 0x0d, 0x53, 0x65,
2633 0x74, 0x54, 0x69, 0x6d, 0x65, 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x12, 0x0f, 0x2e, 0x70, 0x62,
2634 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67,
2635 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45,
2636 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x3e, 0x0a, 0x11, 0x52, 0x65, 0x63, 0x6f, 0x76, 0x65,
2637 0x72, 0x54, 0x69, 0x6d, 0x65, 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x12, 0x0f, 0x2e, 0x70, 0x62,
2638 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67,
2639 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45,
2640 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x3f, 0x0a, 0x0d, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69,
2641 0x6e, 0x65, 0x72, 0x4b, 0x69, 0x6c, 0x6c, 0x12, 0x14, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x6f, 0x6e,
2642 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e,
2643 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e,
2644 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x40, 0x0a, 0x0f, 0x43, 0x6f, 0x6e, 0x74, 0x61,
2645 0x69, 0x6e, 0x65, 0x72, 0x47, 0x65, 0x74, 0x50, 0x69, 0x64, 0x12, 0x14, 0x2e, 0x70, 0x62, 0x2e,
2646 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
2647 0x1a, 0x15, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x52,
2648 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x40, 0x0a, 0x0d, 0x45, 0x78, 0x65,
2649 0x63, 0x53, 0x74, 0x72, 0x65, 0x73, 0x73, 0x6f, 0x72, 0x73, 0x12, 0x15, 0x2e, 0x70, 0x62, 0x2e,
2650 0x45, 0x78, 0x65, 0x63, 0x53, 0x74, 0x72, 0x65, 0x73, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
2651 0x74, 0x1a, 0x16, 0x2e, 0x70, 0x62, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x53, 0x74, 0x72, 0x65, 0x73,
2652 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x44, 0x0a, 0x0f, 0x43,
2653 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x53, 0x74, 0x72, 0x65, 0x73, 0x73, 0x6f, 0x72, 0x73, 0x12, 0x17,
2654 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x53, 0x74, 0x72, 0x65, 0x73, 0x73,
2655 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
2656 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22,
2657 0x00, 0x12, 0x43, 0x0a, 0x0c, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x49, 0x4f, 0x43, 0x68, 0x61, 0x6f,
2658 0x73, 0x12, 0x17, 0x2e, 0x70, 0x62, 0x2e, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x49, 0x4f, 0x43, 0x68,
2659 0x61, 0x6f, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x18, 0x2e, 0x70, 0x62, 0x2e,
2660 0x41, 0x70, 0x70, 0x6c, 0x79, 0x49, 0x4f, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x52, 0x65, 0x73, 0x70,
2661 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x49, 0x0a, 0x0e, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x48,
2662 0x74, 0x74, 0x70, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x12, 0x19, 0x2e, 0x70, 0x62, 0x2e, 0x41, 0x70,
2663 0x70, 0x6c, 0x79, 0x48, 0x74, 0x74, 0x70, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x52, 0x65, 0x71, 0x75,
2664 0x65, 0x73, 0x74, 0x1a, 0x1a, 0x2e, 0x70, 0x62, 0x2e, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x48, 0x74,
2665 0x74, 0x70, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22,
2666 0x00, 0x12, 0x41, 0x0a, 0x0c, 0x53, 0x65, 0x74, 0x44, 0x4e, 0x53, 0x53, 0x65, 0x72, 0x76, 0x65,
2667 0x72, 0x12, 0x17, 0x2e, 0x70, 0x62, 0x2e, 0x53, 0x65, 0x74, 0x44, 0x4e, 0x53, 0x53, 0x65, 0x72,
2668 0x76, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f,
2669 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70,
2670 0x74, 0x79, 0x22, 0x00, 0x12, 0x47, 0x0a, 0x0f, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x4a,
2671 0x56, 0x4d, 0x52, 0x75, 0x6c, 0x65, 0x73, 0x12, 0x1a, 0x2e, 0x70, 0x62, 0x2e, 0x49, 0x6e, 0x73,
2672 0x74, 0x61, 0x6c, 0x6c, 0x4a, 0x56, 0x4d, 0x52, 0x75, 0x6c, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75,
2673 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f,
2674 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x4b, 0x0a,
2675 0x11, 0x55, 0x6e, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x4a, 0x56, 0x4d, 0x52, 0x75, 0x6c,
2676 0x65, 0x73, 0x12, 0x1c, 0x2e, 0x70, 0x62, 0x2e, 0x55, 0x6e, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6c,
2677 0x6c, 0x4a, 0x56, 0x4d, 0x52, 0x75, 0x6c, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
2678 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62,
2679 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74,
2680 0x6f, 0x33,
2681 }
2682
2683 var (
2684 file_chaosdaemon_proto_rawDescOnce sync.Once
2685 file_chaosdaemon_proto_rawDescData = file_chaosdaemon_proto_rawDesc
2686 )
2687
2688 func file_chaosdaemon_proto_rawDescGZIP() []byte {
2689 file_chaosdaemon_proto_rawDescOnce.Do(func() {
2690 file_chaosdaemon_proto_rawDescData = protoimpl.X.CompressGZIP(file_chaosdaemon_proto_rawDescData)
2691 })
2692 return file_chaosdaemon_proto_rawDescData
2693 }
2694
2695 var file_chaosdaemon_proto_enumTypes = make([]protoimpl.EnumInfo, 4)
2696 var file_chaosdaemon_proto_msgTypes = make([]protoimpl.MessageInfo, 31)
2697 var file_chaosdaemon_proto_goTypes = []interface{}{
2698 (Chain_Direction)(0),
2699 (ContainerAction_Action)(0),
2700 (ExecStressRequest_Scope)(0),
2701 (Tc_Type)(0),
2702 (*TcHandle)(nil),
2703 (*ContainerRequest)(nil),
2704 (*ContainerResponse)(nil),
2705 (*NetemRequest)(nil),
2706 (*Netem)(nil),
2707 (*TbfRequest)(nil),
2708 (*Tbf)(nil),
2709 (*QdiscRequest)(nil),
2710 (*Qdisc)(nil),
2711 (*EmatchFilterRequest)(nil),
2712 (*EmatchFilter)(nil),
2713 (*TcFilterRequest)(nil),
2714 (*TcFilter)(nil),
2715 (*IPSetsRequest)(nil),
2716 (*IPSet)(nil),
2717 (*IptablesChainsRequest)(nil),
2718 (*Chain)(nil),
2719 (*TimeRequest)(nil),
2720 (*ContainerAction)(nil),
2721 (*ExecStressRequest)(nil),
2722 (*ExecStressResponse)(nil),
2723 (*CancelStressRequest)(nil),
2724 (*ApplyIOChaosRequest)(nil),
2725 (*ApplyIOChaosResponse)(nil),
2726 (*ApplyHttpChaosRequest)(nil),
2727 (*ApplyHttpChaosResponse)(nil),
2728 (*TcsRequest)(nil),
2729 (*Tc)(nil),
2730 (*SetDNSServerRequest)(nil),
2731 (*InstallJVMRulesRequest)(nil),
2732 (*UninstallJVMRulesRequest)(nil),
2733 (*empty.Empty)(nil),
2734 }
2735 var file_chaosdaemon_proto_depIdxs = []int32{
2736 22,
2737 8,
2738 4,
2739 4,
2740 4,
2741 4,
2742 10,
2743 12,
2744 4,
2745 4,
2746 14,
2747 4,
2748 4,
2749 16,
2750 4,
2751 18,
2752 20,
2753 0,
2754 1,
2755 2,
2756 31,
2757 3,
2758 8,
2759 10,
2760 30,
2761 17,
2762 19,
2763 21,
2764 21,
2765 5,
2766 5,
2767 23,
2768 25,
2769 26,
2770 28,
2771 32,
2772 33,
2773 34,
2774 35,
2775 35,
2776 35,
2777 35,
2778 35,
2779 35,
2780 6,
2781 24,
2782 35,
2783 27,
2784 29,
2785 35,
2786 35,
2787 35,
2788 38,
2789 24,
2790 24,
2791 24,
2792 0,
2793 }
2794
2795 func init() { file_chaosdaemon_proto_init() }
2796 func file_chaosdaemon_proto_init() {
2797 if File_chaosdaemon_proto != nil {
2798 return
2799 }
2800 if !protoimpl.UnsafeEnabled {
2801 file_chaosdaemon_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
2802 switch v := v.(*TcHandle); i {
2803 case 0:
2804 return &v.state
2805 case 1:
2806 return &v.sizeCache
2807 case 2:
2808 return &v.unknownFields
2809 default:
2810 return nil
2811 }
2812 }
2813 file_chaosdaemon_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
2814 switch v := v.(*ContainerRequest); i {
2815 case 0:
2816 return &v.state
2817 case 1:
2818 return &v.sizeCache
2819 case 2:
2820 return &v.unknownFields
2821 default:
2822 return nil
2823 }
2824 }
2825 file_chaosdaemon_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
2826 switch v := v.(*ContainerResponse); i {
2827 case 0:
2828 return &v.state
2829 case 1:
2830 return &v.sizeCache
2831 case 2:
2832 return &v.unknownFields
2833 default:
2834 return nil
2835 }
2836 }
2837 file_chaosdaemon_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
2838 switch v := v.(*NetemRequest); i {
2839 case 0:
2840 return &v.state
2841 case 1:
2842 return &v.sizeCache
2843 case 2:
2844 return &v.unknownFields
2845 default:
2846 return nil
2847 }
2848 }
2849 file_chaosdaemon_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
2850 switch v := v.(*Netem); i {
2851 case 0:
2852 return &v.state
2853 case 1:
2854 return &v.sizeCache
2855 case 2:
2856 return &v.unknownFields
2857 default:
2858 return nil
2859 }
2860 }
2861 file_chaosdaemon_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
2862 switch v := v.(*TbfRequest); i {
2863 case 0:
2864 return &v.state
2865 case 1:
2866 return &v.sizeCache
2867 case 2:
2868 return &v.unknownFields
2869 default:
2870 return nil
2871 }
2872 }
2873 file_chaosdaemon_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
2874 switch v := v.(*Tbf); i {
2875 case 0:
2876 return &v.state
2877 case 1:
2878 return &v.sizeCache
2879 case 2:
2880 return &v.unknownFields
2881 default:
2882 return nil
2883 }
2884 }
2885 file_chaosdaemon_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
2886 switch v := v.(*QdiscRequest); i {
2887 case 0:
2888 return &v.state
2889 case 1:
2890 return &v.sizeCache
2891 case 2:
2892 return &v.unknownFields
2893 default:
2894 return nil
2895 }
2896 }
2897 file_chaosdaemon_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
2898 switch v := v.(*Qdisc); i {
2899 case 0:
2900 return &v.state
2901 case 1:
2902 return &v.sizeCache
2903 case 2:
2904 return &v.unknownFields
2905 default:
2906 return nil
2907 }
2908 }
2909 file_chaosdaemon_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
2910 switch v := v.(*EmatchFilterRequest); i {
2911 case 0:
2912 return &v.state
2913 case 1:
2914 return &v.sizeCache
2915 case 2:
2916 return &v.unknownFields
2917 default:
2918 return nil
2919 }
2920 }
2921 file_chaosdaemon_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
2922 switch v := v.(*EmatchFilter); i {
2923 case 0:
2924 return &v.state
2925 case 1:
2926 return &v.sizeCache
2927 case 2:
2928 return &v.unknownFields
2929 default:
2930 return nil
2931 }
2932 }
2933 file_chaosdaemon_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
2934 switch v := v.(*TcFilterRequest); i {
2935 case 0:
2936 return &v.state
2937 case 1:
2938 return &v.sizeCache
2939 case 2:
2940 return &v.unknownFields
2941 default:
2942 return nil
2943 }
2944 }
2945 file_chaosdaemon_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
2946 switch v := v.(*TcFilter); i {
2947 case 0:
2948 return &v.state
2949 case 1:
2950 return &v.sizeCache
2951 case 2:
2952 return &v.unknownFields
2953 default:
2954 return nil
2955 }
2956 }
2957 file_chaosdaemon_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
2958 switch v := v.(*IPSetsRequest); i {
2959 case 0:
2960 return &v.state
2961 case 1:
2962 return &v.sizeCache
2963 case 2:
2964 return &v.unknownFields
2965 default:
2966 return nil
2967 }
2968 }
2969 file_chaosdaemon_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
2970 switch v := v.(*IPSet); i {
2971 case 0:
2972 return &v.state
2973 case 1:
2974 return &v.sizeCache
2975 case 2:
2976 return &v.unknownFields
2977 default:
2978 return nil
2979 }
2980 }
2981 file_chaosdaemon_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
2982 switch v := v.(*IptablesChainsRequest); i {
2983 case 0:
2984 return &v.state
2985 case 1:
2986 return &v.sizeCache
2987 case 2:
2988 return &v.unknownFields
2989 default:
2990 return nil
2991 }
2992 }
2993 file_chaosdaemon_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
2994 switch v := v.(*Chain); i {
2995 case 0:
2996 return &v.state
2997 case 1:
2998 return &v.sizeCache
2999 case 2:
3000 return &v.unknownFields
3001 default:
3002 return nil
3003 }
3004 }
3005 file_chaosdaemon_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
3006 switch v := v.(*TimeRequest); i {
3007 case 0:
3008 return &v.state
3009 case 1:
3010 return &v.sizeCache
3011 case 2:
3012 return &v.unknownFields
3013 default:
3014 return nil
3015 }
3016 }
3017 file_chaosdaemon_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} {
3018 switch v := v.(*ContainerAction); i {
3019 case 0:
3020 return &v.state
3021 case 1:
3022 return &v.sizeCache
3023 case 2:
3024 return &v.unknownFields
3025 default:
3026 return nil
3027 }
3028 }
3029 file_chaosdaemon_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} {
3030 switch v := v.(*ExecStressRequest); i {
3031 case 0:
3032 return &v.state
3033 case 1:
3034 return &v.sizeCache
3035 case 2:
3036 return &v.unknownFields
3037 default:
3038 return nil
3039 }
3040 }
3041 file_chaosdaemon_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} {
3042 switch v := v.(*ExecStressResponse); i {
3043 case 0:
3044 return &v.state
3045 case 1:
3046 return &v.sizeCache
3047 case 2:
3048 return &v.unknownFields
3049 default:
3050 return nil
3051 }
3052 }
3053 file_chaosdaemon_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} {
3054 switch v := v.(*CancelStressRequest); i {
3055 case 0:
3056 return &v.state
3057 case 1:
3058 return &v.sizeCache
3059 case 2:
3060 return &v.unknownFields
3061 default:
3062 return nil
3063 }
3064 }
3065 file_chaosdaemon_proto_msgTypes[22].Exporter = func(v interface{}, i int) interface{} {
3066 switch v := v.(*ApplyIOChaosRequest); i {
3067 case 0:
3068 return &v.state
3069 case 1:
3070 return &v.sizeCache
3071 case 2:
3072 return &v.unknownFields
3073 default:
3074 return nil
3075 }
3076 }
3077 file_chaosdaemon_proto_msgTypes[23].Exporter = func(v interface{}, i int) interface{} {
3078 switch v := v.(*ApplyIOChaosResponse); i {
3079 case 0:
3080 return &v.state
3081 case 1:
3082 return &v.sizeCache
3083 case 2:
3084 return &v.unknownFields
3085 default:
3086 return nil
3087 }
3088 }
3089 file_chaosdaemon_proto_msgTypes[24].Exporter = func(v interface{}, i int) interface{} {
3090 switch v := v.(*ApplyHttpChaosRequest); i {
3091 case 0:
3092 return &v.state
3093 case 1:
3094 return &v.sizeCache
3095 case 2:
3096 return &v.unknownFields
3097 default:
3098 return nil
3099 }
3100 }
3101 file_chaosdaemon_proto_msgTypes[25].Exporter = func(v interface{}, i int) interface{} {
3102 switch v := v.(*ApplyHttpChaosResponse); i {
3103 case 0:
3104 return &v.state
3105 case 1:
3106 return &v.sizeCache
3107 case 2:
3108 return &v.unknownFields
3109 default:
3110 return nil
3111 }
3112 }
3113 file_chaosdaemon_proto_msgTypes[26].Exporter = func(v interface{}, i int) interface{} {
3114 switch v := v.(*TcsRequest); i {
3115 case 0:
3116 return &v.state
3117 case 1:
3118 return &v.sizeCache
3119 case 2:
3120 return &v.unknownFields
3121 default:
3122 return nil
3123 }
3124 }
3125 file_chaosdaemon_proto_msgTypes[27].Exporter = func(v interface{}, i int) interface{} {
3126 switch v := v.(*Tc); i {
3127 case 0:
3128 return &v.state
3129 case 1:
3130 return &v.sizeCache
3131 case 2:
3132 return &v.unknownFields
3133 default:
3134 return nil
3135 }
3136 }
3137 file_chaosdaemon_proto_msgTypes[28].Exporter = func(v interface{}, i int) interface{} {
3138 switch v := v.(*SetDNSServerRequest); i {
3139 case 0:
3140 return &v.state
3141 case 1:
3142 return &v.sizeCache
3143 case 2:
3144 return &v.unknownFields
3145 default:
3146 return nil
3147 }
3148 }
3149 file_chaosdaemon_proto_msgTypes[29].Exporter = func(v interface{}, i int) interface{} {
3150 switch v := v.(*InstallJVMRulesRequest); i {
3151 case 0:
3152 return &v.state
3153 case 1:
3154 return &v.sizeCache
3155 case 2:
3156 return &v.unknownFields
3157 default:
3158 return nil
3159 }
3160 }
3161 file_chaosdaemon_proto_msgTypes[30].Exporter = func(v interface{}, i int) interface{} {
3162 switch v := v.(*UninstallJVMRulesRequest); i {
3163 case 0:
3164 return &v.state
3165 case 1:
3166 return &v.sizeCache
3167 case 2:
3168 return &v.unknownFields
3169 default:
3170 return nil
3171 }
3172 }
3173 }
3174 type x struct{}
3175 out := protoimpl.TypeBuilder{
3176 File: protoimpl.DescBuilder{
3177 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
3178 RawDescriptor: file_chaosdaemon_proto_rawDesc,
3179 NumEnums: 4,
3180 NumMessages: 31,
3181 NumExtensions: 0,
3182 NumServices: 1,
3183 },
3184 GoTypes: file_chaosdaemon_proto_goTypes,
3185 DependencyIndexes: file_chaosdaemon_proto_depIdxs,
3186 EnumInfos: file_chaosdaemon_proto_enumTypes,
3187 MessageInfos: file_chaosdaemon_proto_msgTypes,
3188 }.Build()
3189 File_chaosdaemon_proto = out.File
3190 file_chaosdaemon_proto_rawDesc = nil
3191 file_chaosdaemon_proto_goTypes = nil
3192 file_chaosdaemon_proto_depIdxs = nil
3193 }
3194
3195
3196 var _ context.Context
3197 var _ grpc.ClientConnInterface
3198
3199
3200
3201 const _ = grpc.SupportPackageIsVersion6
3202
3203
3204
3205
3206 type ChaosDaemonClient interface {
3207 SetTcs(ctx context.Context, in *TcsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3208 FlushIPSets(ctx context.Context, in *IPSetsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3209 SetIptablesChains(ctx context.Context, in *IptablesChainsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3210 SetTimeOffset(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3211 RecoverTimeOffset(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3212 ContainerKill(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3213 ContainerGetPid(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*ContainerResponse, error)
3214 ExecStressors(ctx context.Context, in *ExecStressRequest, opts ...grpc.CallOption) (*ExecStressResponse, error)
3215 CancelStressors(ctx context.Context, in *CancelStressRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3216 ApplyIOChaos(ctx context.Context, in *ApplyIOChaosRequest, opts ...grpc.CallOption) (*ApplyIOChaosResponse, error)
3217 ApplyHttpChaos(ctx context.Context, in *ApplyHttpChaosRequest, opts ...grpc.CallOption) (*ApplyHttpChaosResponse, error)
3218 SetDNSServer(ctx context.Context, in *SetDNSServerRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3219 InstallJVMRules(ctx context.Context, in *InstallJVMRulesRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3220 UninstallJVMRules(ctx context.Context, in *UninstallJVMRulesRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3221 }
3222
3223 type chaosDaemonClient struct {
3224 cc grpc.ClientConnInterface
3225 }
3226
3227 func NewChaosDaemonClient(cc grpc.ClientConnInterface) ChaosDaemonClient {
3228 return &chaosDaemonClient{cc}
3229 }
3230
3231 func (c *chaosDaemonClient) SetTcs(ctx context.Context, in *TcsRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3232 out := new(empty.Empty)
3233 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/SetTcs", in, out, opts...)
3234 if err != nil {
3235 return nil, err
3236 }
3237 return out, nil
3238 }
3239
3240 func (c *chaosDaemonClient) FlushIPSets(ctx context.Context, in *IPSetsRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3241 out := new(empty.Empty)
3242 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/FlushIPSets", in, out, opts...)
3243 if err != nil {
3244 return nil, err
3245 }
3246 return out, nil
3247 }
3248
3249 func (c *chaosDaemonClient) SetIptablesChains(ctx context.Context, in *IptablesChainsRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3250 out := new(empty.Empty)
3251 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/SetIptablesChains", in, out, opts...)
3252 if err != nil {
3253 return nil, err
3254 }
3255 return out, nil
3256 }
3257
3258 func (c *chaosDaemonClient) SetTimeOffset(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3259 out := new(empty.Empty)
3260 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/SetTimeOffset", in, out, opts...)
3261 if err != nil {
3262 return nil, err
3263 }
3264 return out, nil
3265 }
3266
3267 func (c *chaosDaemonClient) RecoverTimeOffset(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3268 out := new(empty.Empty)
3269 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/RecoverTimeOffset", in, out, opts...)
3270 if err != nil {
3271 return nil, err
3272 }
3273 return out, nil
3274 }
3275
3276 func (c *chaosDaemonClient) ContainerKill(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3277 out := new(empty.Empty)
3278 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/ContainerKill", in, out, opts...)
3279 if err != nil {
3280 return nil, err
3281 }
3282 return out, nil
3283 }
3284
3285 func (c *chaosDaemonClient) ContainerGetPid(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*ContainerResponse, error) {
3286 out := new(ContainerResponse)
3287 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/ContainerGetPid", in, out, opts...)
3288 if err != nil {
3289 return nil, err
3290 }
3291 return out, nil
3292 }
3293
3294 func (c *chaosDaemonClient) ExecStressors(ctx context.Context, in *ExecStressRequest, opts ...grpc.CallOption) (*ExecStressResponse, error) {
3295 out := new(ExecStressResponse)
3296 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/ExecStressors", in, out, opts...)
3297 if err != nil {
3298 return nil, err
3299 }
3300 return out, nil
3301 }
3302
3303 func (c *chaosDaemonClient) CancelStressors(ctx context.Context, in *CancelStressRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3304 out := new(empty.Empty)
3305 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/CancelStressors", in, out, opts...)
3306 if err != nil {
3307 return nil, err
3308 }
3309 return out, nil
3310 }
3311
3312 func (c *chaosDaemonClient) ApplyIOChaos(ctx context.Context, in *ApplyIOChaosRequest, opts ...grpc.CallOption) (*ApplyIOChaosResponse, error) {
3313 out := new(ApplyIOChaosResponse)
3314 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/ApplyIOChaos", in, out, opts...)
3315 if err != nil {
3316 return nil, err
3317 }
3318 return out, nil
3319 }
3320
3321 func (c *chaosDaemonClient) ApplyHttpChaos(ctx context.Context, in *ApplyHttpChaosRequest, opts ...grpc.CallOption) (*ApplyHttpChaosResponse, error) {
3322 out := new(ApplyHttpChaosResponse)
3323 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/ApplyHttpChaos", in, out, opts...)
3324 if err != nil {
3325 return nil, err
3326 }
3327 return out, nil
3328 }
3329
3330 func (c *chaosDaemonClient) SetDNSServer(ctx context.Context, in *SetDNSServerRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3331 out := new(empty.Empty)
3332 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/SetDNSServer", in, out, opts...)
3333 if err != nil {
3334 return nil, err
3335 }
3336 return out, nil
3337 }
3338
3339 func (c *chaosDaemonClient) InstallJVMRules(ctx context.Context, in *InstallJVMRulesRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3340 out := new(empty.Empty)
3341 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/InstallJVMRules", in, out, opts...)
3342 if err != nil {
3343 return nil, err
3344 }
3345 return out, nil
3346 }
3347
3348 func (c *chaosDaemonClient) UninstallJVMRules(ctx context.Context, in *UninstallJVMRulesRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3349 out := new(empty.Empty)
3350 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/UninstallJVMRules", in, out, opts...)
3351 if err != nil {
3352 return nil, err
3353 }
3354 return out, nil
3355 }
3356
3357
3358 type ChaosDaemonServer interface {
3359 SetTcs(context.Context, *TcsRequest) (*empty.Empty, error)
3360 FlushIPSets(context.Context, *IPSetsRequest) (*empty.Empty, error)
3361 SetIptablesChains(context.Context, *IptablesChainsRequest) (*empty.Empty, error)
3362 SetTimeOffset(context.Context, *TimeRequest) (*empty.Empty, error)
3363 RecoverTimeOffset(context.Context, *TimeRequest) (*empty.Empty, error)
3364 ContainerKill(context.Context, *ContainerRequest) (*empty.Empty, error)
3365 ContainerGetPid(context.Context, *ContainerRequest) (*ContainerResponse, error)
3366 ExecStressors(context.Context, *ExecStressRequest) (*ExecStressResponse, error)
3367 CancelStressors(context.Context, *CancelStressRequest) (*empty.Empty, error)
3368 ApplyIOChaos(context.Context, *ApplyIOChaosRequest) (*ApplyIOChaosResponse, error)
3369 ApplyHttpChaos(context.Context, *ApplyHttpChaosRequest) (*ApplyHttpChaosResponse, error)
3370 SetDNSServer(context.Context, *SetDNSServerRequest) (*empty.Empty, error)
3371 InstallJVMRules(context.Context, *InstallJVMRulesRequest) (*empty.Empty, error)
3372 UninstallJVMRules(context.Context, *UninstallJVMRulesRequest) (*empty.Empty, error)
3373 }
3374
3375
3376 type UnimplementedChaosDaemonServer struct {
3377 }
3378
3379 func (*UnimplementedChaosDaemonServer) SetTcs(context.Context, *TcsRequest) (*empty.Empty, error) {
3380 return nil, status.Errorf(codes.Unimplemented, "method SetTcs not implemented")
3381 }
3382 func (*UnimplementedChaosDaemonServer) FlushIPSets(context.Context, *IPSetsRequest) (*empty.Empty, error) {
3383 return nil, status.Errorf(codes.Unimplemented, "method FlushIPSets not implemented")
3384 }
3385 func (*UnimplementedChaosDaemonServer) SetIptablesChains(context.Context, *IptablesChainsRequest) (*empty.Empty, error) {
3386 return nil, status.Errorf(codes.Unimplemented, "method SetIptablesChains not implemented")
3387 }
3388 func (*UnimplementedChaosDaemonServer) SetTimeOffset(context.Context, *TimeRequest) (*empty.Empty, error) {
3389 return nil, status.Errorf(codes.Unimplemented, "method SetTimeOffset not implemented")
3390 }
3391 func (*UnimplementedChaosDaemonServer) RecoverTimeOffset(context.Context, *TimeRequest) (*empty.Empty, error) {
3392 return nil, status.Errorf(codes.Unimplemented, "method RecoverTimeOffset not implemented")
3393 }
3394 func (*UnimplementedChaosDaemonServer) ContainerKill(context.Context, *ContainerRequest) (*empty.Empty, error) {
3395 return nil, status.Errorf(codes.Unimplemented, "method ContainerKill not implemented")
3396 }
3397 func (*UnimplementedChaosDaemonServer) ContainerGetPid(context.Context, *ContainerRequest) (*ContainerResponse, error) {
3398 return nil, status.Errorf(codes.Unimplemented, "method ContainerGetPid not implemented")
3399 }
3400 func (*UnimplementedChaosDaemonServer) ExecStressors(context.Context, *ExecStressRequest) (*ExecStressResponse, error) {
3401 return nil, status.Errorf(codes.Unimplemented, "method ExecStressors not implemented")
3402 }
3403 func (*UnimplementedChaosDaemonServer) CancelStressors(context.Context, *CancelStressRequest) (*empty.Empty, error) {
3404 return nil, status.Errorf(codes.Unimplemented, "method CancelStressors not implemented")
3405 }
3406 func (*UnimplementedChaosDaemonServer) ApplyIOChaos(context.Context, *ApplyIOChaosRequest) (*ApplyIOChaosResponse, error) {
3407 return nil, status.Errorf(codes.Unimplemented, "method ApplyIOChaos not implemented")
3408 }
3409 func (*UnimplementedChaosDaemonServer) ApplyHttpChaos(context.Context, *ApplyHttpChaosRequest) (*ApplyHttpChaosResponse, error) {
3410 return nil, status.Errorf(codes.Unimplemented, "method ApplyHttpChaos not implemented")
3411 }
3412 func (*UnimplementedChaosDaemonServer) SetDNSServer(context.Context, *SetDNSServerRequest) (*empty.Empty, error) {
3413 return nil, status.Errorf(codes.Unimplemented, "method SetDNSServer not implemented")
3414 }
3415 func (*UnimplementedChaosDaemonServer) InstallJVMRules(context.Context, *InstallJVMRulesRequest) (*empty.Empty, error) {
3416 return nil, status.Errorf(codes.Unimplemented, "method InstallJVMRules not implemented")
3417 }
3418 func (*UnimplementedChaosDaemonServer) UninstallJVMRules(context.Context, *UninstallJVMRulesRequest) (*empty.Empty, error) {
3419 return nil, status.Errorf(codes.Unimplemented, "method UninstallJVMRules not implemented")
3420 }
3421
3422 func RegisterChaosDaemonServer(s *grpc.Server, srv ChaosDaemonServer) {
3423 s.RegisterService(&_ChaosDaemon_serviceDesc, srv)
3424 }
3425
3426 func _ChaosDaemon_SetTcs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3427 in := new(TcsRequest)
3428 if err := dec(in); err != nil {
3429 return nil, err
3430 }
3431 if interceptor == nil {
3432 return srv.(ChaosDaemonServer).SetTcs(ctx, in)
3433 }
3434 info := &grpc.UnaryServerInfo{
3435 Server: srv,
3436 FullMethod: "/pb.ChaosDaemon/SetTcs",
3437 }
3438 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3439 return srv.(ChaosDaemonServer).SetTcs(ctx, req.(*TcsRequest))
3440 }
3441 return interceptor(ctx, in, info, handler)
3442 }
3443
3444 func _ChaosDaemon_FlushIPSets_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3445 in := new(IPSetsRequest)
3446 if err := dec(in); err != nil {
3447 return nil, err
3448 }
3449 if interceptor == nil {
3450 return srv.(ChaosDaemonServer).FlushIPSets(ctx, in)
3451 }
3452 info := &grpc.UnaryServerInfo{
3453 Server: srv,
3454 FullMethod: "/pb.ChaosDaemon/FlushIPSets",
3455 }
3456 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3457 return srv.(ChaosDaemonServer).FlushIPSets(ctx, req.(*IPSetsRequest))
3458 }
3459 return interceptor(ctx, in, info, handler)
3460 }
3461
3462 func _ChaosDaemon_SetIptablesChains_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3463 in := new(IptablesChainsRequest)
3464 if err := dec(in); err != nil {
3465 return nil, err
3466 }
3467 if interceptor == nil {
3468 return srv.(ChaosDaemonServer).SetIptablesChains(ctx, in)
3469 }
3470 info := &grpc.UnaryServerInfo{
3471 Server: srv,
3472 FullMethod: "/pb.ChaosDaemon/SetIptablesChains",
3473 }
3474 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3475 return srv.(ChaosDaemonServer).SetIptablesChains(ctx, req.(*IptablesChainsRequest))
3476 }
3477 return interceptor(ctx, in, info, handler)
3478 }
3479
3480 func _ChaosDaemon_SetTimeOffset_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3481 in := new(TimeRequest)
3482 if err := dec(in); err != nil {
3483 return nil, err
3484 }
3485 if interceptor == nil {
3486 return srv.(ChaosDaemonServer).SetTimeOffset(ctx, in)
3487 }
3488 info := &grpc.UnaryServerInfo{
3489 Server: srv,
3490 FullMethod: "/pb.ChaosDaemon/SetTimeOffset",
3491 }
3492 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3493 return srv.(ChaosDaemonServer).SetTimeOffset(ctx, req.(*TimeRequest))
3494 }
3495 return interceptor(ctx, in, info, handler)
3496 }
3497
3498 func _ChaosDaemon_RecoverTimeOffset_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3499 in := new(TimeRequest)
3500 if err := dec(in); err != nil {
3501 return nil, err
3502 }
3503 if interceptor == nil {
3504 return srv.(ChaosDaemonServer).RecoverTimeOffset(ctx, in)
3505 }
3506 info := &grpc.UnaryServerInfo{
3507 Server: srv,
3508 FullMethod: "/pb.ChaosDaemon/RecoverTimeOffset",
3509 }
3510 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3511 return srv.(ChaosDaemonServer).RecoverTimeOffset(ctx, req.(*TimeRequest))
3512 }
3513 return interceptor(ctx, in, info, handler)
3514 }
3515
3516 func _ChaosDaemon_ContainerKill_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3517 in := new(ContainerRequest)
3518 if err := dec(in); err != nil {
3519 return nil, err
3520 }
3521 if interceptor == nil {
3522 return srv.(ChaosDaemonServer).ContainerKill(ctx, in)
3523 }
3524 info := &grpc.UnaryServerInfo{
3525 Server: srv,
3526 FullMethod: "/pb.ChaosDaemon/ContainerKill",
3527 }
3528 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3529 return srv.(ChaosDaemonServer).ContainerKill(ctx, req.(*ContainerRequest))
3530 }
3531 return interceptor(ctx, in, info, handler)
3532 }
3533
3534 func _ChaosDaemon_ContainerGetPid_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3535 in := new(ContainerRequest)
3536 if err := dec(in); err != nil {
3537 return nil, err
3538 }
3539 if interceptor == nil {
3540 return srv.(ChaosDaemonServer).ContainerGetPid(ctx, in)
3541 }
3542 info := &grpc.UnaryServerInfo{
3543 Server: srv,
3544 FullMethod: "/pb.ChaosDaemon/ContainerGetPid",
3545 }
3546 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3547 return srv.(ChaosDaemonServer).ContainerGetPid(ctx, req.(*ContainerRequest))
3548 }
3549 return interceptor(ctx, in, info, handler)
3550 }
3551
3552 func _ChaosDaemon_ExecStressors_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3553 in := new(ExecStressRequest)
3554 if err := dec(in); err != nil {
3555 return nil, err
3556 }
3557 if interceptor == nil {
3558 return srv.(ChaosDaemonServer).ExecStressors(ctx, in)
3559 }
3560 info := &grpc.UnaryServerInfo{
3561 Server: srv,
3562 FullMethod: "/pb.ChaosDaemon/ExecStressors",
3563 }
3564 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3565 return srv.(ChaosDaemonServer).ExecStressors(ctx, req.(*ExecStressRequest))
3566 }
3567 return interceptor(ctx, in, info, handler)
3568 }
3569
3570 func _ChaosDaemon_CancelStressors_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3571 in := new(CancelStressRequest)
3572 if err := dec(in); err != nil {
3573 return nil, err
3574 }
3575 if interceptor == nil {
3576 return srv.(ChaosDaemonServer).CancelStressors(ctx, in)
3577 }
3578 info := &grpc.UnaryServerInfo{
3579 Server: srv,
3580 FullMethod: "/pb.ChaosDaemon/CancelStressors",
3581 }
3582 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3583 return srv.(ChaosDaemonServer).CancelStressors(ctx, req.(*CancelStressRequest))
3584 }
3585 return interceptor(ctx, in, info, handler)
3586 }
3587
3588 func _ChaosDaemon_ApplyIOChaos_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3589 in := new(ApplyIOChaosRequest)
3590 if err := dec(in); err != nil {
3591 return nil, err
3592 }
3593 if interceptor == nil {
3594 return srv.(ChaosDaemonServer).ApplyIOChaos(ctx, in)
3595 }
3596 info := &grpc.UnaryServerInfo{
3597 Server: srv,
3598 FullMethod: "/pb.ChaosDaemon/ApplyIOChaos",
3599 }
3600 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3601 return srv.(ChaosDaemonServer).ApplyIOChaos(ctx, req.(*ApplyIOChaosRequest))
3602 }
3603 return interceptor(ctx, in, info, handler)
3604 }
3605
3606 func _ChaosDaemon_ApplyHttpChaos_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3607 in := new(ApplyHttpChaosRequest)
3608 if err := dec(in); err != nil {
3609 return nil, err
3610 }
3611 if interceptor == nil {
3612 return srv.(ChaosDaemonServer).ApplyHttpChaos(ctx, in)
3613 }
3614 info := &grpc.UnaryServerInfo{
3615 Server: srv,
3616 FullMethod: "/pb.ChaosDaemon/ApplyHttpChaos",
3617 }
3618 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3619 return srv.(ChaosDaemonServer).ApplyHttpChaos(ctx, req.(*ApplyHttpChaosRequest))
3620 }
3621 return interceptor(ctx, in, info, handler)
3622 }
3623
3624 func _ChaosDaemon_SetDNSServer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3625 in := new(SetDNSServerRequest)
3626 if err := dec(in); err != nil {
3627 return nil, err
3628 }
3629 if interceptor == nil {
3630 return srv.(ChaosDaemonServer).SetDNSServer(ctx, in)
3631 }
3632 info := &grpc.UnaryServerInfo{
3633 Server: srv,
3634 FullMethod: "/pb.ChaosDaemon/SetDNSServer",
3635 }
3636 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3637 return srv.(ChaosDaemonServer).SetDNSServer(ctx, req.(*SetDNSServerRequest))
3638 }
3639 return interceptor(ctx, in, info, handler)
3640 }
3641
3642 func _ChaosDaemon_InstallJVMRules_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3643 in := new(InstallJVMRulesRequest)
3644 if err := dec(in); err != nil {
3645 return nil, err
3646 }
3647 if interceptor == nil {
3648 return srv.(ChaosDaemonServer).InstallJVMRules(ctx, in)
3649 }
3650 info := &grpc.UnaryServerInfo{
3651 Server: srv,
3652 FullMethod: "/pb.ChaosDaemon/InstallJVMRules",
3653 }
3654 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3655 return srv.(ChaosDaemonServer).InstallJVMRules(ctx, req.(*InstallJVMRulesRequest))
3656 }
3657 return interceptor(ctx, in, info, handler)
3658 }
3659
3660 func _ChaosDaemon_UninstallJVMRules_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3661 in := new(UninstallJVMRulesRequest)
3662 if err := dec(in); err != nil {
3663 return nil, err
3664 }
3665 if interceptor == nil {
3666 return srv.(ChaosDaemonServer).UninstallJVMRules(ctx, in)
3667 }
3668 info := &grpc.UnaryServerInfo{
3669 Server: srv,
3670 FullMethod: "/pb.ChaosDaemon/UninstallJVMRules",
3671 }
3672 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3673 return srv.(ChaosDaemonServer).UninstallJVMRules(ctx, req.(*UninstallJVMRulesRequest))
3674 }
3675 return interceptor(ctx, in, info, handler)
3676 }
3677
3678 var _ChaosDaemon_serviceDesc = grpc.ServiceDesc{
3679 ServiceName: "pb.ChaosDaemon",
3680 HandlerType: (*ChaosDaemonServer)(nil),
3681 Methods: []grpc.MethodDesc{
3682 {
3683 MethodName: "SetTcs",
3684 Handler: _ChaosDaemon_SetTcs_Handler,
3685 },
3686 {
3687 MethodName: "FlushIPSets",
3688 Handler: _ChaosDaemon_FlushIPSets_Handler,
3689 },
3690 {
3691 MethodName: "SetIptablesChains",
3692 Handler: _ChaosDaemon_SetIptablesChains_Handler,
3693 },
3694 {
3695 MethodName: "SetTimeOffset",
3696 Handler: _ChaosDaemon_SetTimeOffset_Handler,
3697 },
3698 {
3699 MethodName: "RecoverTimeOffset",
3700 Handler: _ChaosDaemon_RecoverTimeOffset_Handler,
3701 },
3702 {
3703 MethodName: "ContainerKill",
3704 Handler: _ChaosDaemon_ContainerKill_Handler,
3705 },
3706 {
3707 MethodName: "ContainerGetPid",
3708 Handler: _ChaosDaemon_ContainerGetPid_Handler,
3709 },
3710 {
3711 MethodName: "ExecStressors",
3712 Handler: _ChaosDaemon_ExecStressors_Handler,
3713 },
3714 {
3715 MethodName: "CancelStressors",
3716 Handler: _ChaosDaemon_CancelStressors_Handler,
3717 },
3718 {
3719 MethodName: "ApplyIOChaos",
3720 Handler: _ChaosDaemon_ApplyIOChaos_Handler,
3721 },
3722 {
3723 MethodName: "ApplyHttpChaos",
3724 Handler: _ChaosDaemon_ApplyHttpChaos_Handler,
3725 },
3726 {
3727 MethodName: "SetDNSServer",
3728 Handler: _ChaosDaemon_SetDNSServer_Handler,
3729 },
3730 {
3731 MethodName: "InstallJVMRules",
3732 Handler: _ChaosDaemon_InstallJVMRules_Handler,
3733 },
3734 {
3735 MethodName: "UninstallJVMRules",
3736 Handler: _ChaosDaemon_UninstallJVMRules_Handler,
3737 },
3738 },
3739 Streams: []grpc.StreamDesc{},
3740 Metadata: "chaosdaemon.proto",
3741 }
3742