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 }
1280
1281 func (x *Chain) Reset() {
1282 *x = Chain{}
1283 if protoimpl.UnsafeEnabled {
1284 mi := &file_chaosdaemon_proto_msgTypes[16]
1285 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1286 ms.StoreMessageInfo(mi)
1287 }
1288 }
1289
1290 func (x *Chain) String() string {
1291 return protoimpl.X.MessageStringOf(x)
1292 }
1293
1294 func (*Chain) ProtoMessage() {}
1295
1296 func (x *Chain) ProtoReflect() protoreflect.Message {
1297 mi := &file_chaosdaemon_proto_msgTypes[16]
1298 if protoimpl.UnsafeEnabled && x != nil {
1299 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1300 if ms.LoadMessageInfo() == nil {
1301 ms.StoreMessageInfo(mi)
1302 }
1303 return ms
1304 }
1305 return mi.MessageOf(x)
1306 }
1307
1308
1309 func (*Chain) Descriptor() ([]byte, []int) {
1310 return file_chaosdaemon_proto_rawDescGZIP(), []int{16}
1311 }
1312
1313 func (x *Chain) GetName() string {
1314 if x != nil {
1315 return x.Name
1316 }
1317 return ""
1318 }
1319
1320 func (x *Chain) GetDirection() Chain_Direction {
1321 if x != nil {
1322 return x.Direction
1323 }
1324 return Chain_INPUT
1325 }
1326
1327 func (x *Chain) GetIpsets() []string {
1328 if x != nil {
1329 return x.Ipsets
1330 }
1331 return nil
1332 }
1333
1334 func (x *Chain) GetTarget() string {
1335 if x != nil {
1336 return x.Target
1337 }
1338 return ""
1339 }
1340
1341 func (x *Chain) GetProtocol() string {
1342 if x != nil {
1343 return x.Protocol
1344 }
1345 return ""
1346 }
1347
1348 func (x *Chain) GetSourcePorts() string {
1349 if x != nil {
1350 return x.SourcePorts
1351 }
1352 return ""
1353 }
1354
1355 func (x *Chain) GetDestinationPorts() string {
1356 if x != nil {
1357 return x.DestinationPorts
1358 }
1359 return ""
1360 }
1361
1362 func (x *Chain) GetTcpFlags() string {
1363 if x != nil {
1364 return x.TcpFlags
1365 }
1366 return ""
1367 }
1368
1369 type TimeRequest struct {
1370 state protoimpl.MessageState
1371 sizeCache protoimpl.SizeCache
1372 unknownFields protoimpl.UnknownFields
1373
1374 ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
1375 Sec int64 `protobuf:"varint,2,opt,name=sec,proto3" json:"sec,omitempty"`
1376 Nsec int64 `protobuf:"varint,3,opt,name=nsec,proto3" json:"nsec,omitempty"`
1377 ClkIdsMask uint64 `protobuf:"varint,4,opt,name=clk_ids_mask,json=clkIdsMask,proto3" json:"clk_ids_mask,omitempty"`
1378 }
1379
1380 func (x *TimeRequest) Reset() {
1381 *x = TimeRequest{}
1382 if protoimpl.UnsafeEnabled {
1383 mi := &file_chaosdaemon_proto_msgTypes[17]
1384 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1385 ms.StoreMessageInfo(mi)
1386 }
1387 }
1388
1389 func (x *TimeRequest) String() string {
1390 return protoimpl.X.MessageStringOf(x)
1391 }
1392
1393 func (*TimeRequest) ProtoMessage() {}
1394
1395 func (x *TimeRequest) ProtoReflect() protoreflect.Message {
1396 mi := &file_chaosdaemon_proto_msgTypes[17]
1397 if protoimpl.UnsafeEnabled && x != nil {
1398 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1399 if ms.LoadMessageInfo() == nil {
1400 ms.StoreMessageInfo(mi)
1401 }
1402 return ms
1403 }
1404 return mi.MessageOf(x)
1405 }
1406
1407
1408 func (*TimeRequest) Descriptor() ([]byte, []int) {
1409 return file_chaosdaemon_proto_rawDescGZIP(), []int{17}
1410 }
1411
1412 func (x *TimeRequest) GetContainerId() string {
1413 if x != nil {
1414 return x.ContainerId
1415 }
1416 return ""
1417 }
1418
1419 func (x *TimeRequest) GetSec() int64 {
1420 if x != nil {
1421 return x.Sec
1422 }
1423 return 0
1424 }
1425
1426 func (x *TimeRequest) GetNsec() int64 {
1427 if x != nil {
1428 return x.Nsec
1429 }
1430 return 0
1431 }
1432
1433 func (x *TimeRequest) GetClkIdsMask() uint64 {
1434 if x != nil {
1435 return x.ClkIdsMask
1436 }
1437 return 0
1438 }
1439
1440 type ContainerAction struct {
1441 state protoimpl.MessageState
1442 sizeCache protoimpl.SizeCache
1443 unknownFields protoimpl.UnknownFields
1444
1445 Action ContainerAction_Action `protobuf:"varint,1,opt,name=action,proto3,enum=pb.ContainerAction_Action" json:"action,omitempty"`
1446 }
1447
1448 func (x *ContainerAction) Reset() {
1449 *x = ContainerAction{}
1450 if protoimpl.UnsafeEnabled {
1451 mi := &file_chaosdaemon_proto_msgTypes[18]
1452 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1453 ms.StoreMessageInfo(mi)
1454 }
1455 }
1456
1457 func (x *ContainerAction) String() string {
1458 return protoimpl.X.MessageStringOf(x)
1459 }
1460
1461 func (*ContainerAction) ProtoMessage() {}
1462
1463 func (x *ContainerAction) ProtoReflect() protoreflect.Message {
1464 mi := &file_chaosdaemon_proto_msgTypes[18]
1465 if protoimpl.UnsafeEnabled && x != nil {
1466 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1467 if ms.LoadMessageInfo() == nil {
1468 ms.StoreMessageInfo(mi)
1469 }
1470 return ms
1471 }
1472 return mi.MessageOf(x)
1473 }
1474
1475
1476 func (*ContainerAction) Descriptor() ([]byte, []int) {
1477 return file_chaosdaemon_proto_rawDescGZIP(), []int{18}
1478 }
1479
1480 func (x *ContainerAction) GetAction() ContainerAction_Action {
1481 if x != nil {
1482 return x.Action
1483 }
1484 return ContainerAction_KILL
1485 }
1486
1487 type ExecStressRequest struct {
1488 state protoimpl.MessageState
1489 sizeCache protoimpl.SizeCache
1490 unknownFields protoimpl.UnknownFields
1491
1492 Scope ExecStressRequest_Scope `protobuf:"varint,1,opt,name=scope,proto3,enum=pb.ExecStressRequest_Scope" json:"scope,omitempty"`
1493 Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
1494 Stressors string `protobuf:"bytes,3,opt,name=stressors,proto3" json:"stressors,omitempty"`
1495 EnterNS bool `protobuf:"varint,4,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
1496 }
1497
1498 func (x *ExecStressRequest) Reset() {
1499 *x = ExecStressRequest{}
1500 if protoimpl.UnsafeEnabled {
1501 mi := &file_chaosdaemon_proto_msgTypes[19]
1502 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1503 ms.StoreMessageInfo(mi)
1504 }
1505 }
1506
1507 func (x *ExecStressRequest) String() string {
1508 return protoimpl.X.MessageStringOf(x)
1509 }
1510
1511 func (*ExecStressRequest) ProtoMessage() {}
1512
1513 func (x *ExecStressRequest) ProtoReflect() protoreflect.Message {
1514 mi := &file_chaosdaemon_proto_msgTypes[19]
1515 if protoimpl.UnsafeEnabled && x != nil {
1516 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1517 if ms.LoadMessageInfo() == nil {
1518 ms.StoreMessageInfo(mi)
1519 }
1520 return ms
1521 }
1522 return mi.MessageOf(x)
1523 }
1524
1525
1526 func (*ExecStressRequest) Descriptor() ([]byte, []int) {
1527 return file_chaosdaemon_proto_rawDescGZIP(), []int{19}
1528 }
1529
1530 func (x *ExecStressRequest) GetScope() ExecStressRequest_Scope {
1531 if x != nil {
1532 return x.Scope
1533 }
1534 return ExecStressRequest_CONTAINER
1535 }
1536
1537 func (x *ExecStressRequest) GetTarget() string {
1538 if x != nil {
1539 return x.Target
1540 }
1541 return ""
1542 }
1543
1544 func (x *ExecStressRequest) GetStressors() string {
1545 if x != nil {
1546 return x.Stressors
1547 }
1548 return ""
1549 }
1550
1551 func (x *ExecStressRequest) GetEnterNS() bool {
1552 if x != nil {
1553 return x.EnterNS
1554 }
1555 return false
1556 }
1557
1558 type ExecStressResponse struct {
1559 state protoimpl.MessageState
1560 sizeCache protoimpl.SizeCache
1561 unknownFields protoimpl.UnknownFields
1562
1563 Instance string `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
1564 StartTime int64 `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
1565 }
1566
1567 func (x *ExecStressResponse) Reset() {
1568 *x = ExecStressResponse{}
1569 if protoimpl.UnsafeEnabled {
1570 mi := &file_chaosdaemon_proto_msgTypes[20]
1571 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1572 ms.StoreMessageInfo(mi)
1573 }
1574 }
1575
1576 func (x *ExecStressResponse) String() string {
1577 return protoimpl.X.MessageStringOf(x)
1578 }
1579
1580 func (*ExecStressResponse) ProtoMessage() {}
1581
1582 func (x *ExecStressResponse) ProtoReflect() protoreflect.Message {
1583 mi := &file_chaosdaemon_proto_msgTypes[20]
1584 if protoimpl.UnsafeEnabled && x != nil {
1585 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1586 if ms.LoadMessageInfo() == nil {
1587 ms.StoreMessageInfo(mi)
1588 }
1589 return ms
1590 }
1591 return mi.MessageOf(x)
1592 }
1593
1594
1595 func (*ExecStressResponse) Descriptor() ([]byte, []int) {
1596 return file_chaosdaemon_proto_rawDescGZIP(), []int{20}
1597 }
1598
1599 func (x *ExecStressResponse) GetInstance() string {
1600 if x != nil {
1601 return x.Instance
1602 }
1603 return ""
1604 }
1605
1606 func (x *ExecStressResponse) GetStartTime() int64 {
1607 if x != nil {
1608 return x.StartTime
1609 }
1610 return 0
1611 }
1612
1613 type CancelStressRequest struct {
1614 state protoimpl.MessageState
1615 sizeCache protoimpl.SizeCache
1616 unknownFields protoimpl.UnknownFields
1617
1618 Instance string `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
1619 StartTime int64 `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
1620 }
1621
1622 func (x *CancelStressRequest) Reset() {
1623 *x = CancelStressRequest{}
1624 if protoimpl.UnsafeEnabled {
1625 mi := &file_chaosdaemon_proto_msgTypes[21]
1626 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1627 ms.StoreMessageInfo(mi)
1628 }
1629 }
1630
1631 func (x *CancelStressRequest) String() string {
1632 return protoimpl.X.MessageStringOf(x)
1633 }
1634
1635 func (*CancelStressRequest) ProtoMessage() {}
1636
1637 func (x *CancelStressRequest) ProtoReflect() protoreflect.Message {
1638 mi := &file_chaosdaemon_proto_msgTypes[21]
1639 if protoimpl.UnsafeEnabled && x != nil {
1640 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1641 if ms.LoadMessageInfo() == nil {
1642 ms.StoreMessageInfo(mi)
1643 }
1644 return ms
1645 }
1646 return mi.MessageOf(x)
1647 }
1648
1649
1650 func (*CancelStressRequest) Descriptor() ([]byte, []int) {
1651 return file_chaosdaemon_proto_rawDescGZIP(), []int{21}
1652 }
1653
1654 func (x *CancelStressRequest) GetInstance() string {
1655 if x != nil {
1656 return x.Instance
1657 }
1658 return ""
1659 }
1660
1661 func (x *CancelStressRequest) GetStartTime() int64 {
1662 if x != nil {
1663 return x.StartTime
1664 }
1665 return 0
1666 }
1667
1668 type ApplyIOChaosRequest struct {
1669 state protoimpl.MessageState
1670 sizeCache protoimpl.SizeCache
1671 unknownFields protoimpl.UnknownFields
1672
1673 Actions string `protobuf:"bytes,1,opt,name=actions,proto3" json:"actions,omitempty"`
1674 Volume string `protobuf:"bytes,2,opt,name=volume,proto3" json:"volume,omitempty"`
1675 ContainerId string `protobuf:"bytes,3,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
1676 Instance int64 `protobuf:"varint,4,opt,name=instance,proto3" json:"instance,omitempty"`
1677 StartTime int64 `protobuf:"varint,5,opt,name=startTime,proto3" json:"startTime,omitempty"`
1678 EnterNS bool `protobuf:"varint,6,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
1679 }
1680
1681 func (x *ApplyIOChaosRequest) Reset() {
1682 *x = ApplyIOChaosRequest{}
1683 if protoimpl.UnsafeEnabled {
1684 mi := &file_chaosdaemon_proto_msgTypes[22]
1685 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1686 ms.StoreMessageInfo(mi)
1687 }
1688 }
1689
1690 func (x *ApplyIOChaosRequest) String() string {
1691 return protoimpl.X.MessageStringOf(x)
1692 }
1693
1694 func (*ApplyIOChaosRequest) ProtoMessage() {}
1695
1696 func (x *ApplyIOChaosRequest) ProtoReflect() protoreflect.Message {
1697 mi := &file_chaosdaemon_proto_msgTypes[22]
1698 if protoimpl.UnsafeEnabled && x != nil {
1699 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1700 if ms.LoadMessageInfo() == nil {
1701 ms.StoreMessageInfo(mi)
1702 }
1703 return ms
1704 }
1705 return mi.MessageOf(x)
1706 }
1707
1708
1709 func (*ApplyIOChaosRequest) Descriptor() ([]byte, []int) {
1710 return file_chaosdaemon_proto_rawDescGZIP(), []int{22}
1711 }
1712
1713 func (x *ApplyIOChaosRequest) GetActions() string {
1714 if x != nil {
1715 return x.Actions
1716 }
1717 return ""
1718 }
1719
1720 func (x *ApplyIOChaosRequest) GetVolume() string {
1721 if x != nil {
1722 return x.Volume
1723 }
1724 return ""
1725 }
1726
1727 func (x *ApplyIOChaosRequest) GetContainerId() string {
1728 if x != nil {
1729 return x.ContainerId
1730 }
1731 return ""
1732 }
1733
1734 func (x *ApplyIOChaosRequest) GetInstance() int64 {
1735 if x != nil {
1736 return x.Instance
1737 }
1738 return 0
1739 }
1740
1741 func (x *ApplyIOChaosRequest) GetStartTime() int64 {
1742 if x != nil {
1743 return x.StartTime
1744 }
1745 return 0
1746 }
1747
1748 func (x *ApplyIOChaosRequest) GetEnterNS() bool {
1749 if x != nil {
1750 return x.EnterNS
1751 }
1752 return false
1753 }
1754
1755 type ApplyIOChaosResponse struct {
1756 state protoimpl.MessageState
1757 sizeCache protoimpl.SizeCache
1758 unknownFields protoimpl.UnknownFields
1759
1760 Instance int64 `protobuf:"varint,1,opt,name=instance,proto3" json:"instance,omitempty"`
1761 StartTime int64 `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
1762 }
1763
1764 func (x *ApplyIOChaosResponse) Reset() {
1765 *x = ApplyIOChaosResponse{}
1766 if protoimpl.UnsafeEnabled {
1767 mi := &file_chaosdaemon_proto_msgTypes[23]
1768 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1769 ms.StoreMessageInfo(mi)
1770 }
1771 }
1772
1773 func (x *ApplyIOChaosResponse) String() string {
1774 return protoimpl.X.MessageStringOf(x)
1775 }
1776
1777 func (*ApplyIOChaosResponse) ProtoMessage() {}
1778
1779 func (x *ApplyIOChaosResponse) ProtoReflect() protoreflect.Message {
1780 mi := &file_chaosdaemon_proto_msgTypes[23]
1781 if protoimpl.UnsafeEnabled && x != nil {
1782 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1783 if ms.LoadMessageInfo() == nil {
1784 ms.StoreMessageInfo(mi)
1785 }
1786 return ms
1787 }
1788 return mi.MessageOf(x)
1789 }
1790
1791
1792 func (*ApplyIOChaosResponse) Descriptor() ([]byte, []int) {
1793 return file_chaosdaemon_proto_rawDescGZIP(), []int{23}
1794 }
1795
1796 func (x *ApplyIOChaosResponse) GetInstance() int64 {
1797 if x != nil {
1798 return x.Instance
1799 }
1800 return 0
1801 }
1802
1803 func (x *ApplyIOChaosResponse) GetStartTime() int64 {
1804 if x != nil {
1805 return x.StartTime
1806 }
1807 return 0
1808 }
1809
1810 type ApplyHttpChaosRequest struct {
1811 state protoimpl.MessageState
1812 sizeCache protoimpl.SizeCache
1813 unknownFields protoimpl.UnknownFields
1814
1815 Rules string `protobuf:"bytes,1,opt,name=rules,proto3" json:"rules,omitempty"`
1816 ProxyPorts []uint32 `protobuf:"varint,2,rep,packed,name=proxy_ports,json=proxyPorts,proto3" json:"proxy_ports,omitempty"`
1817 ContainerId string `protobuf:"bytes,3,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
1818 Instance int64 `protobuf:"varint,4,opt,name=instance,proto3" json:"instance,omitempty"`
1819 StartTime int64 `protobuf:"varint,5,opt,name=startTime,proto3" json:"startTime,omitempty"`
1820 EnterNS bool `protobuf:"varint,6,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
1821 }
1822
1823 func (x *ApplyHttpChaosRequest) Reset() {
1824 *x = ApplyHttpChaosRequest{}
1825 if protoimpl.UnsafeEnabled {
1826 mi := &file_chaosdaemon_proto_msgTypes[24]
1827 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1828 ms.StoreMessageInfo(mi)
1829 }
1830 }
1831
1832 func (x *ApplyHttpChaosRequest) String() string {
1833 return protoimpl.X.MessageStringOf(x)
1834 }
1835
1836 func (*ApplyHttpChaosRequest) ProtoMessage() {}
1837
1838 func (x *ApplyHttpChaosRequest) ProtoReflect() protoreflect.Message {
1839 mi := &file_chaosdaemon_proto_msgTypes[24]
1840 if protoimpl.UnsafeEnabled && x != nil {
1841 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1842 if ms.LoadMessageInfo() == nil {
1843 ms.StoreMessageInfo(mi)
1844 }
1845 return ms
1846 }
1847 return mi.MessageOf(x)
1848 }
1849
1850
1851 func (*ApplyHttpChaosRequest) Descriptor() ([]byte, []int) {
1852 return file_chaosdaemon_proto_rawDescGZIP(), []int{24}
1853 }
1854
1855 func (x *ApplyHttpChaosRequest) GetRules() string {
1856 if x != nil {
1857 return x.Rules
1858 }
1859 return ""
1860 }
1861
1862 func (x *ApplyHttpChaosRequest) GetProxyPorts() []uint32 {
1863 if x != nil {
1864 return x.ProxyPorts
1865 }
1866 return nil
1867 }
1868
1869 func (x *ApplyHttpChaosRequest) GetContainerId() string {
1870 if x != nil {
1871 return x.ContainerId
1872 }
1873 return ""
1874 }
1875
1876 func (x *ApplyHttpChaosRequest) GetInstance() int64 {
1877 if x != nil {
1878 return x.Instance
1879 }
1880 return 0
1881 }
1882
1883 func (x *ApplyHttpChaosRequest) GetStartTime() int64 {
1884 if x != nil {
1885 return x.StartTime
1886 }
1887 return 0
1888 }
1889
1890 func (x *ApplyHttpChaosRequest) GetEnterNS() bool {
1891 if x != nil {
1892 return x.EnterNS
1893 }
1894 return false
1895 }
1896
1897 type ApplyHttpChaosResponse struct {
1898 state protoimpl.MessageState
1899 sizeCache protoimpl.SizeCache
1900 unknownFields protoimpl.UnknownFields
1901
1902 Instance int64 `protobuf:"varint,1,opt,name=instance,proto3" json:"instance,omitempty"`
1903 StartTime int64 `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
1904 StatusCode int32 `protobuf:"varint,3,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
1905 Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
1906 }
1907
1908 func (x *ApplyHttpChaosResponse) Reset() {
1909 *x = ApplyHttpChaosResponse{}
1910 if protoimpl.UnsafeEnabled {
1911 mi := &file_chaosdaemon_proto_msgTypes[25]
1912 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1913 ms.StoreMessageInfo(mi)
1914 }
1915 }
1916
1917 func (x *ApplyHttpChaosResponse) String() string {
1918 return protoimpl.X.MessageStringOf(x)
1919 }
1920
1921 func (*ApplyHttpChaosResponse) ProtoMessage() {}
1922
1923 func (x *ApplyHttpChaosResponse) ProtoReflect() protoreflect.Message {
1924 mi := &file_chaosdaemon_proto_msgTypes[25]
1925 if protoimpl.UnsafeEnabled && x != nil {
1926 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1927 if ms.LoadMessageInfo() == nil {
1928 ms.StoreMessageInfo(mi)
1929 }
1930 return ms
1931 }
1932 return mi.MessageOf(x)
1933 }
1934
1935
1936 func (*ApplyHttpChaosResponse) Descriptor() ([]byte, []int) {
1937 return file_chaosdaemon_proto_rawDescGZIP(), []int{25}
1938 }
1939
1940 func (x *ApplyHttpChaosResponse) GetInstance() int64 {
1941 if x != nil {
1942 return x.Instance
1943 }
1944 return 0
1945 }
1946
1947 func (x *ApplyHttpChaosResponse) GetStartTime() int64 {
1948 if x != nil {
1949 return x.StartTime
1950 }
1951 return 0
1952 }
1953
1954 func (x *ApplyHttpChaosResponse) GetStatusCode() int32 {
1955 if x != nil {
1956 return x.StatusCode
1957 }
1958 return 0
1959 }
1960
1961 func (x *ApplyHttpChaosResponse) GetError() string {
1962 if x != nil {
1963 return x.Error
1964 }
1965 return ""
1966 }
1967
1968 type TcsRequest struct {
1969 state protoimpl.MessageState
1970 sizeCache protoimpl.SizeCache
1971 unknownFields protoimpl.UnknownFields
1972
1973 Tcs []*Tc `protobuf:"bytes,1,rep,name=tcs,proto3" json:"tcs,omitempty"`
1974 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
1975 Device string `protobuf:"bytes,3,opt,name=device,proto3" json:"device,omitempty"`
1976 EnterNS bool `protobuf:"varint,4,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
1977 }
1978
1979 func (x *TcsRequest) Reset() {
1980 *x = TcsRequest{}
1981 if protoimpl.UnsafeEnabled {
1982 mi := &file_chaosdaemon_proto_msgTypes[26]
1983 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1984 ms.StoreMessageInfo(mi)
1985 }
1986 }
1987
1988 func (x *TcsRequest) String() string {
1989 return protoimpl.X.MessageStringOf(x)
1990 }
1991
1992 func (*TcsRequest) ProtoMessage() {}
1993
1994 func (x *TcsRequest) ProtoReflect() protoreflect.Message {
1995 mi := &file_chaosdaemon_proto_msgTypes[26]
1996 if protoimpl.UnsafeEnabled && x != nil {
1997 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1998 if ms.LoadMessageInfo() == nil {
1999 ms.StoreMessageInfo(mi)
2000 }
2001 return ms
2002 }
2003 return mi.MessageOf(x)
2004 }
2005
2006
2007 func (*TcsRequest) Descriptor() ([]byte, []int) {
2008 return file_chaosdaemon_proto_rawDescGZIP(), []int{26}
2009 }
2010
2011 func (x *TcsRequest) GetTcs() []*Tc {
2012 if x != nil {
2013 return x.Tcs
2014 }
2015 return nil
2016 }
2017
2018 func (x *TcsRequest) GetContainerId() string {
2019 if x != nil {
2020 return x.ContainerId
2021 }
2022 return ""
2023 }
2024
2025 func (x *TcsRequest) GetDevice() string {
2026 if x != nil {
2027 return x.Device
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 }
2052
2053 func (x *Tc) Reset() {
2054 *x = Tc{}
2055 if protoimpl.UnsafeEnabled {
2056 mi := &file_chaosdaemon_proto_msgTypes[27]
2057 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2058 ms.StoreMessageInfo(mi)
2059 }
2060 }
2061
2062 func (x *Tc) String() string {
2063 return protoimpl.X.MessageStringOf(x)
2064 }
2065
2066 func (*Tc) ProtoMessage() {}
2067
2068 func (x *Tc) ProtoReflect() protoreflect.Message {
2069 mi := &file_chaosdaemon_proto_msgTypes[27]
2070 if protoimpl.UnsafeEnabled && x != nil {
2071 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2072 if ms.LoadMessageInfo() == nil {
2073 ms.StoreMessageInfo(mi)
2074 }
2075 return ms
2076 }
2077 return mi.MessageOf(x)
2078 }
2079
2080
2081 func (*Tc) Descriptor() ([]byte, []int) {
2082 return file_chaosdaemon_proto_rawDescGZIP(), []int{27}
2083 }
2084
2085 func (x *Tc) GetType() Tc_Type {
2086 if x != nil {
2087 return x.Type
2088 }
2089 return Tc_NETEM
2090 }
2091
2092 func (x *Tc) GetNetem() *Netem {
2093 if x != nil {
2094 return x.Netem
2095 }
2096 return nil
2097 }
2098
2099 func (x *Tc) GetTbf() *Tbf {
2100 if x != nil {
2101 return x.Tbf
2102 }
2103 return nil
2104 }
2105
2106 func (x *Tc) GetIpset() string {
2107 if x != nil {
2108 return x.Ipset
2109 }
2110 return ""
2111 }
2112
2113 func (x *Tc) GetProtocol() string {
2114 if x != nil {
2115 return x.Protocol
2116 }
2117 return ""
2118 }
2119
2120 func (x *Tc) GetSourcePort() string {
2121 if x != nil {
2122 return x.SourcePort
2123 }
2124 return ""
2125 }
2126
2127 func (x *Tc) GetEgressPort() string {
2128 if x != nil {
2129 return x.EgressPort
2130 }
2131 return ""
2132 }
2133
2134 type SetDNSServerRequest struct {
2135 state protoimpl.MessageState
2136 sizeCache protoimpl.SizeCache
2137 unknownFields protoimpl.UnknownFields
2138
2139 ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
2140 DnsServer string `protobuf:"bytes,2,opt,name=dns_server,json=dnsServer,proto3" json:"dns_server,omitempty"`
2141 Enable bool `protobuf:"varint,3,opt,name=enable,proto3" json:"enable,omitempty"`
2142 EnterNS bool `protobuf:"varint,4,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
2143 }
2144
2145 func (x *SetDNSServerRequest) Reset() {
2146 *x = SetDNSServerRequest{}
2147 if protoimpl.UnsafeEnabled {
2148 mi := &file_chaosdaemon_proto_msgTypes[28]
2149 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2150 ms.StoreMessageInfo(mi)
2151 }
2152 }
2153
2154 func (x *SetDNSServerRequest) String() string {
2155 return protoimpl.X.MessageStringOf(x)
2156 }
2157
2158 func (*SetDNSServerRequest) ProtoMessage() {}
2159
2160 func (x *SetDNSServerRequest) ProtoReflect() protoreflect.Message {
2161 mi := &file_chaosdaemon_proto_msgTypes[28]
2162 if protoimpl.UnsafeEnabled && x != nil {
2163 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2164 if ms.LoadMessageInfo() == nil {
2165 ms.StoreMessageInfo(mi)
2166 }
2167 return ms
2168 }
2169 return mi.MessageOf(x)
2170 }
2171
2172
2173 func (*SetDNSServerRequest) Descriptor() ([]byte, []int) {
2174 return file_chaosdaemon_proto_rawDescGZIP(), []int{28}
2175 }
2176
2177 func (x *SetDNSServerRequest) GetContainerId() string {
2178 if x != nil {
2179 return x.ContainerId
2180 }
2181 return ""
2182 }
2183
2184 func (x *SetDNSServerRequest) GetDnsServer() string {
2185 if x != nil {
2186 return x.DnsServer
2187 }
2188 return ""
2189 }
2190
2191 func (x *SetDNSServerRequest) GetEnable() bool {
2192 if x != nil {
2193 return x.Enable
2194 }
2195 return false
2196 }
2197
2198 func (x *SetDNSServerRequest) GetEnterNS() bool {
2199 if x != nil {
2200 return x.EnterNS
2201 }
2202 return false
2203 }
2204
2205 var File_chaosdaemon_proto protoreflect.FileDescriptor
2206
2207 var file_chaosdaemon_proto_rawDesc = []byte{
2208 0x0a, 0x11, 0x63, 0x68, 0x61, 0x6f, 0x73, 0x64, 0x61, 0x65, 0x6d, 0x6f, 0x6e, 0x2e, 0x70, 0x72,
2209 0x6f, 0x74, 0x6f, 0x12, 0x02, 0x70, 0x62, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f,
2210 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70,
2211 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x36, 0x0a, 0x08, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65,
2212 0x12, 0x14, 0x0a, 0x05, 0x6d, 0x61, 0x6a, 0x6f, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52,
2213 0x05, 0x6d, 0x61, 0x6a, 0x6f, 0x72, 0x12, 0x14, 0x0a, 0x05, 0x6d, 0x69, 0x6e, 0x6f, 0x72, 0x18,
2214 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x05, 0x6d, 0x69, 0x6e, 0x6f, 0x72, 0x22, 0x62, 0x0a, 0x10,
2215 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
2216 0x12, 0x2b, 0x0a, 0x06, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b,
2217 0x32, 0x13, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x41,
2218 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x06, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x21, 0x0a,
2219 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20,
2220 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64,
2221 0x22, 0x25, 0x0a, 0x11, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x52, 0x65, 0x73,
2222 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x70, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01,
2223 0x28, 0x0d, 0x52, 0x03, 0x70, 0x69, 0x64, 0x22, 0x9e, 0x01, 0x0a, 0x0c, 0x4e, 0x65, 0x74, 0x65,
2224 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1f, 0x0a, 0x05, 0x6e, 0x65, 0x74, 0x65,
2225 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x09, 0x2e, 0x70, 0x62, 0x2e, 0x4e, 0x65, 0x74,
2226 0x65, 0x6d, 0x52, 0x05, 0x6e, 0x65, 0x74, 0x65, 0x6d, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e,
2227 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52,
2228 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x24, 0x0a, 0x06,
2229 0x68, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70,
2230 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x52, 0x06, 0x68, 0x61, 0x6e, 0x64,
2231 0x6c, 0x65, 0x12, 0x24, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x04, 0x20, 0x01,
2232 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65,
2233 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x22, 0xb6, 0x03, 0x0a, 0x05, 0x4e, 0x65, 0x74,
2234 0x65, 0x6d, 0x12, 0x12, 0x0a, 0x04, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d,
2235 0x52, 0x04, 0x74, 0x69, 0x6d, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x6a, 0x69, 0x74, 0x74, 0x65, 0x72,
2236 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x06, 0x6a, 0x69, 0x74, 0x74, 0x65, 0x72, 0x12, 0x1d,
2237 0x0a, 0x0a, 0x64, 0x65, 0x6c, 0x61, 0x79, 0x5f, 0x63, 0x6f, 0x72, 0x72, 0x18, 0x03, 0x20, 0x01,
2238 0x28, 0x02, 0x52, 0x09, 0x64, 0x65, 0x6c, 0x61, 0x79, 0x43, 0x6f, 0x72, 0x72, 0x12, 0x14, 0x0a,
2239 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x05, 0x6c, 0x69,
2240 0x6d, 0x69, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x6c, 0x6f, 0x73, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28,
2241 0x02, 0x52, 0x04, 0x6c, 0x6f, 0x73, 0x73, 0x12, 0x1b, 0x0a, 0x09, 0x6c, 0x6f, 0x73, 0x73, 0x5f,
2242 0x63, 0x6f, 0x72, 0x72, 0x18, 0x06, 0x20, 0x01, 0x28, 0x02, 0x52, 0x08, 0x6c, 0x6f, 0x73, 0x73,
2243 0x43, 0x6f, 0x72, 0x72, 0x12, 0x10, 0x0a, 0x03, 0x67, 0x61, 0x70, 0x18, 0x07, 0x20, 0x01, 0x28,
2244 0x0d, 0x52, 0x03, 0x67, 0x61, 0x70, 0x12, 0x1c, 0x0a, 0x09, 0x64, 0x75, 0x70, 0x6c, 0x69, 0x63,
2245 0x61, 0x74, 0x65, 0x18, 0x08, 0x20, 0x01, 0x28, 0x02, 0x52, 0x09, 0x64, 0x75, 0x70, 0x6c, 0x69,
2246 0x63, 0x61, 0x74, 0x65, 0x12, 0x25, 0x0a, 0x0e, 0x64, 0x75, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74,
2247 0x65, 0x5f, 0x63, 0x6f, 0x72, 0x72, 0x18, 0x09, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0d, 0x64, 0x75,
2248 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x65, 0x43, 0x6f, 0x72, 0x72, 0x12, 0x18, 0x0a, 0x07, 0x72,
2249 0x65, 0x6f, 0x72, 0x64, 0x65, 0x72, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x02, 0x52, 0x07, 0x72, 0x65,
2250 0x6f, 0x72, 0x64, 0x65, 0x72, 0x12, 0x21, 0x0a, 0x0c, 0x72, 0x65, 0x6f, 0x72, 0x64, 0x65, 0x72,
2251 0x5f, 0x63, 0x6f, 0x72, 0x72, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0b, 0x72, 0x65, 0x6f,
2252 0x72, 0x64, 0x65, 0x72, 0x43, 0x6f, 0x72, 0x72, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x6f, 0x72, 0x72,
2253 0x75, 0x70, 0x74, 0x18, 0x0c, 0x20, 0x01, 0x28, 0x02, 0x52, 0x07, 0x63, 0x6f, 0x72, 0x72, 0x75,
2254 0x70, 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x72, 0x72, 0x75, 0x70, 0x74, 0x5f, 0x63, 0x6f,
2255 0x72, 0x72, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0b, 0x63, 0x6f, 0x72, 0x72, 0x75, 0x70,
2256 0x74, 0x43, 0x6f, 0x72, 0x72, 0x12, 0x24, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18,
2257 0x0e, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e,
2258 0x64, 0x6c, 0x65, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x24, 0x0a, 0x06, 0x68,
2259 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x18, 0x0f, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x62,
2260 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x52, 0x06, 0x68, 0x61, 0x6e, 0x64, 0x6c,
2261 0x65, 0x22, 0x4a, 0x0a, 0x0a, 0x54, 0x62, 0x66, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12,
2262 0x19, 0x0a, 0x03, 0x74, 0x62, 0x66, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x07, 0x2e, 0x70,
2263 0x62, 0x2e, 0x54, 0x62, 0x66, 0x52, 0x03, 0x74, 0x62, 0x66, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f,
2264 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09,
2265 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x22, 0x81, 0x01,
2266 0x0a, 0x03, 0x54, 0x62, 0x66, 0x12, 0x12, 0x0a, 0x04, 0x72, 0x61, 0x74, 0x65, 0x18, 0x01, 0x20,
2267 0x01, 0x28, 0x04, 0x52, 0x04, 0x72, 0x61, 0x74, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x6c, 0x69, 0x6d,
2268 0x69, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x12,
2269 0x16, 0x0a, 0x06, 0x62, 0x75, 0x66, 0x66, 0x65, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0d, 0x52,
2270 0x06, 0x62, 0x75, 0x66, 0x66, 0x65, 0x72, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x65, 0x61, 0x6b, 0x5f,
2271 0x72, 0x61, 0x74, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x04, 0x52, 0x08, 0x70, 0x65, 0x61, 0x6b,
2272 0x52, 0x61, 0x74, 0x65, 0x12, 0x1b, 0x0a, 0x09, 0x6d, 0x69, 0x6e, 0x5f, 0x62, 0x75, 0x72, 0x73,
2273 0x74, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x08, 0x6d, 0x69, 0x6e, 0x42, 0x75, 0x72, 0x73,
2274 0x74, 0x22, 0x52, 0x0a, 0x0c, 0x51, 0x64, 0x69, 0x73, 0x63, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
2275 0x74, 0x12, 0x1f, 0x0a, 0x05, 0x71, 0x64, 0x69, 0x73, 0x63, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b,
2276 0x32, 0x09, 0x2e, 0x70, 0x62, 0x2e, 0x51, 0x64, 0x69, 0x73, 0x63, 0x52, 0x05, 0x71, 0x64, 0x69,
2277 0x73, 0x63, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f,
2278 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69,
2279 0x6e, 0x65, 0x72, 0x49, 0x64, 0x22, 0x7b, 0x0a, 0x05, 0x51, 0x64, 0x69, 0x73, 0x63, 0x12, 0x24,
2280 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c,
2281 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x52, 0x06, 0x70, 0x61,
2282 0x72, 0x65, 0x6e, 0x74, 0x12, 0x24, 0x0a, 0x06, 0x68, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x18, 0x02,
2283 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64,
2284 0x6c, 0x65, 0x52, 0x06, 0x68, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x74, 0x79,
2285 0x70, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x12,
2286 0x0a, 0x04, 0x61, 0x72, 0x67, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x09, 0x52, 0x04, 0x61, 0x72,
2287 0x67, 0x73, 0x22, 0x62, 0x0a, 0x13, 0x45, 0x6d, 0x61, 0x74, 0x63, 0x68, 0x46, 0x69, 0x6c, 0x74,
2288 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x28, 0x0a, 0x06, 0x66, 0x69, 0x6c,
2289 0x74, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x10, 0x2e, 0x70, 0x62, 0x2e, 0x45,
2290 0x6d, 0x61, 0x74, 0x63, 0x68, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x52, 0x06, 0x66, 0x69, 0x6c,
2291 0x74, 0x65, 0x72, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72,
2292 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61,
2293 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x22, 0x72, 0x0a, 0x0c, 0x45, 0x6d, 0x61, 0x74, 0x63, 0x68,
2294 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x12, 0x14, 0x0a, 0x05, 0x6d, 0x61, 0x74, 0x63, 0x68, 0x18,
2295 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x6d, 0x61, 0x74, 0x63, 0x68, 0x12, 0x24, 0x0a, 0x06,
2296 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70,
2297 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65,
2298 0x6e, 0x74, 0x12, 0x26, 0x0a, 0x07, 0x63, 0x6c, 0x61, 0x73, 0x73, 0x69, 0x64, 0x18, 0x03, 0x20,
2299 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c,
2300 0x65, 0x52, 0x07, 0x63, 0x6c, 0x61, 0x73, 0x73, 0x69, 0x64, 0x22, 0x5a, 0x0a, 0x0f, 0x54, 0x63,
2301 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x24, 0x0a,
2302 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e,
2303 0x70, 0x62, 0x2e, 0x54, 0x63, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x52, 0x06, 0x66, 0x69, 0x6c,
2304 0x74, 0x65, 0x72, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72,
2305 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61,
2306 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x22, 0x30, 0x0a, 0x08, 0x54, 0x63, 0x46, 0x69, 0x6c, 0x74,
2307 0x65, 0x72, 0x12, 0x24, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01,
2308 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65,
2309 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x22, 0x6f, 0x0a, 0x0d, 0x49, 0x50, 0x53, 0x65,
2310 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x21, 0x0a, 0x06, 0x69, 0x70, 0x73,
2311 0x65, 0x74, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x09, 0x2e, 0x70, 0x62, 0x2e, 0x49,
2312 0x50, 0x53, 0x65, 0x74, 0x52, 0x06, 0x69, 0x70, 0x73, 0x65, 0x74, 0x73, 0x12, 0x21, 0x0a, 0x0c,
2313 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01,
2314 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12,
2315 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x18, 0x03, 0x20, 0x01, 0x28, 0x08,
2316 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x22, 0x31, 0x0a, 0x05, 0x49, 0x50, 0x53,
2317 0x65, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
2318 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x63, 0x69, 0x64, 0x72, 0x73, 0x18,
2319 0x02, 0x20, 0x03, 0x28, 0x09, 0x52, 0x05, 0x63, 0x69, 0x64, 0x72, 0x73, 0x22, 0x77, 0x0a, 0x15,
2320 0x49, 0x70, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x43, 0x68, 0x61, 0x69, 0x6e, 0x73, 0x52, 0x65,
2321 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x21, 0x0a, 0x06, 0x63, 0x68, 0x61, 0x69, 0x6e, 0x73, 0x18,
2322 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x09, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x68, 0x61, 0x69, 0x6e,
2323 0x52, 0x06, 0x63, 0x68, 0x61, 0x69, 0x6e, 0x73, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74,
2324 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b,
2325 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x65,
2326 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x18, 0x03, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e,
2327 0x74, 0x65, 0x72, 0x4e, 0x53, 0x22, 0xab, 0x02, 0x0a, 0x05, 0x43, 0x68, 0x61, 0x69, 0x6e, 0x12,
2328 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e,
2329 0x61, 0x6d, 0x65, 0x12, 0x31, 0x0a, 0x09, 0x64, 0x69, 0x72, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e,
2330 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x13, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x68, 0x61, 0x69,
2331 0x6e, 0x2e, 0x44, 0x69, 0x72, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x09, 0x64, 0x69, 0x72,
2332 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x16, 0x0a, 0x06, 0x69, 0x70, 0x73, 0x65, 0x74, 0x73,
2333 0x18, 0x03, 0x20, 0x03, 0x28, 0x09, 0x52, 0x06, 0x69, 0x70, 0x73, 0x65, 0x74, 0x73, 0x12, 0x16,
2334 0x0a, 0x06, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06,
2335 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x12, 0x1a, 0x0a, 0x08, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63,
2336 0x6f, 0x6c, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63,
2337 0x6f, 0x6c, 0x12, 0x21, 0x0a, 0x0c, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x5f, 0x70, 0x6f, 0x72,
2338 0x74, 0x73, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65,
2339 0x50, 0x6f, 0x72, 0x74, 0x73, 0x12, 0x2b, 0x0a, 0x11, 0x64, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x61,
2340 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x70, 0x6f, 0x72, 0x74, 0x73, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09,
2341 0x52, 0x10, 0x64, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x50, 0x6f, 0x72,
2342 0x74, 0x73, 0x12, 0x1b, 0x0a, 0x09, 0x74, 0x63, 0x70, 0x5f, 0x66, 0x6c, 0x61, 0x67, 0x73, 0x18,
2343 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x74, 0x63, 0x70, 0x46, 0x6c, 0x61, 0x67, 0x73, 0x22,
2344 0x22, 0x0a, 0x09, 0x44, 0x69, 0x72, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x09, 0x0a, 0x05,
2345 0x49, 0x4e, 0x50, 0x55, 0x54, 0x10, 0x00, 0x12, 0x0a, 0x0a, 0x06, 0x4f, 0x55, 0x54, 0x50, 0x55,
2346 0x54, 0x10, 0x01, 0x22, 0x78, 0x0a, 0x0b, 0x54, 0x69, 0x6d, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65,
2347 0x73, 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f,
2348 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69,
2349 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x10, 0x0a, 0x03, 0x73, 0x65, 0x63, 0x18, 0x02, 0x20, 0x01,
2350 0x28, 0x03, 0x52, 0x03, 0x73, 0x65, 0x63, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x73, 0x65, 0x63, 0x18,
2351 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x04, 0x6e, 0x73, 0x65, 0x63, 0x12, 0x20, 0x0a, 0x0c, 0x63,
2352 0x6c, 0x6b, 0x5f, 0x69, 0x64, 0x73, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x18, 0x04, 0x20, 0x01, 0x28,
2353 0x04, 0x52, 0x0a, 0x63, 0x6c, 0x6b, 0x49, 0x64, 0x73, 0x4d, 0x61, 0x73, 0x6b, 0x22, 0x65, 0x0a,
2354 0x0f, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e,
2355 0x12, 0x32, 0x0a, 0x06, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e,
2356 0x32, 0x1a, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x41,
2357 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x06, 0x61, 0x63,
2358 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x1e, 0x0a, 0x06, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x08,
2359 0x0a, 0x04, 0x4b, 0x49, 0x4c, 0x4c, 0x10, 0x00, 0x12, 0x0a, 0x0a, 0x06, 0x47, 0x45, 0x54, 0x50,
2360 0x49, 0x44, 0x10, 0x01, 0x22, 0xb7, 0x01, 0x0a, 0x11, 0x45, 0x78, 0x65, 0x63, 0x53, 0x74, 0x72,
2361 0x65, 0x73, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x31, 0x0a, 0x05, 0x73, 0x63,
2362 0x6f, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1b, 0x2e, 0x70, 0x62, 0x2e, 0x45,
2363 0x78, 0x65, 0x63, 0x53, 0x74, 0x72, 0x65, 0x73, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
2364 0x2e, 0x53, 0x63, 0x6f, 0x70, 0x65, 0x52, 0x05, 0x73, 0x63, 0x6f, 0x70, 0x65, 0x12, 0x16, 0x0a,
2365 0x06, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x74,
2366 0x61, 0x72, 0x67, 0x65, 0x74, 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x74, 0x72, 0x65, 0x73, 0x73, 0x6f,
2367 0x72, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x73, 0x74, 0x72, 0x65, 0x73, 0x73,
2368 0x6f, 0x72, 0x73, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x18, 0x04,
2369 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x22, 0x1f, 0x0a,
2370 0x05, 0x53, 0x63, 0x6f, 0x70, 0x65, 0x12, 0x0d, 0x0a, 0x09, 0x43, 0x4f, 0x4e, 0x54, 0x41, 0x49,
2371 0x4e, 0x45, 0x52, 0x10, 0x00, 0x12, 0x07, 0x0a, 0x03, 0x50, 0x4f, 0x44, 0x10, 0x01, 0x22, 0x4e,
2372 0x0a, 0x12, 0x45, 0x78, 0x65, 0x63, 0x53, 0x74, 0x72, 0x65, 0x73, 0x73, 0x52, 0x65, 0x73, 0x70,
2373 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65,
2374 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65,
2375 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x02, 0x20,
2376 0x01, 0x28, 0x03, 0x52, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x22, 0x4f,
2377 0x0a, 0x13, 0x43, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x53, 0x74, 0x72, 0x65, 0x73, 0x73, 0x52, 0x65,
2378 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1a, 0x0a, 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63,
2379 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63,
2380 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x02,
2381 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x22,
2382 0xbe, 0x01, 0x0a, 0x13, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x49, 0x6f, 0x43, 0x68, 0x61, 0x6f, 0x73,
2383 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x61, 0x63, 0x74, 0x69, 0x6f,
2384 0x6e, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e,
2385 0x73, 0x12, 0x16, 0x0a, 0x06, 0x76, 0x6f, 0x6c, 0x75, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28,
2386 0x09, 0x52, 0x06, 0x76, 0x6f, 0x6c, 0x75, 0x6d, 0x65, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e,
2387 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52,
2388 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x1a, 0x0a, 0x08,
2389 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08,
2390 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x74, 0x61, 0x72,
2391 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x73, 0x74, 0x61,
2392 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e,
2393 0x53, 0x18, 0x06, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53,
2394 0x22, 0x50, 0x0a, 0x14, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x49, 0x6f, 0x43, 0x68, 0x61, 0x6f, 0x73,
2395 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x69, 0x6e, 0x73, 0x74,
2396 0x61, 0x6e, 0x63, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x69, 0x6e, 0x73, 0x74,
2397 0x61, 0x6e, 0x63, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d,
2398 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69,
2399 0x6d, 0x65, 0x22, 0xc5, 0x01, 0x0a, 0x15, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x48, 0x74, 0x74, 0x70,
2400 0x43, 0x68, 0x61, 0x6f, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x14, 0x0a, 0x05,
2401 0x72, 0x75, 0x6c, 0x65, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x72, 0x75, 0x6c,
2402 0x65, 0x73, 0x12, 0x1f, 0x0a, 0x0b, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x5f, 0x70, 0x6f, 0x72, 0x74,
2403 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0d, 0x52, 0x0a, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x50, 0x6f,
2404 0x72, 0x74, 0x73, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72,
2405 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61,
2406 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x1a, 0x0a, 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e,
2407 0x63, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e,
2408 0x63, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18,
2409 0x05, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65,
2410 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x18, 0x06, 0x20, 0x01, 0x28,
2411 0x08, 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x22, 0x88, 0x01, 0x0a, 0x16, 0x41,
2412 0x70, 0x70, 0x6c, 0x79, 0x48, 0x74, 0x74, 0x70, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x52, 0x65, 0x73,
2413 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63,
2414 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63,
2415 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x02,
2416 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12,
2417 0x1e, 0x0a, 0x0a, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x43, 0x6f, 0x64, 0x65, 0x18, 0x03, 0x20,
2418 0x01, 0x28, 0x05, 0x52, 0x0a, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x43, 0x6f, 0x64, 0x65, 0x12,
2419 0x14, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05,
2420 0x65, 0x72, 0x72, 0x6f, 0x72, 0x22, 0x7b, 0x0a, 0x0a, 0x54, 0x63, 0x73, 0x52, 0x65, 0x71, 0x75,
2421 0x65, 0x73, 0x74, 0x12, 0x18, 0x0a, 0x03, 0x74, 0x63, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b,
2422 0x32, 0x06, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x52, 0x03, 0x74, 0x63, 0x73, 0x12, 0x21, 0x0a,
2423 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20,
2424 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64,
2425 0x12, 0x16, 0x0a, 0x06, 0x64, 0x65, 0x76, 0x69, 0x63, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09,
2426 0x52, 0x06, 0x64, 0x65, 0x76, 0x69, 0x63, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65,
2427 0x72, 0x4e, 0x53, 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72,
2428 0x4e, 0x53, 0x22, 0xf7, 0x01, 0x0a, 0x02, 0x54, 0x63, 0x12, 0x1f, 0x0a, 0x04, 0x74, 0x79, 0x70,
2429 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x0b, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x2e,
2430 0x54, 0x79, 0x70, 0x65, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x1f, 0x0a, 0x05, 0x6e, 0x65,
2431 0x74, 0x65, 0x6d, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x09, 0x2e, 0x70, 0x62, 0x2e, 0x4e,
2432 0x65, 0x74, 0x65, 0x6d, 0x52, 0x05, 0x6e, 0x65, 0x74, 0x65, 0x6d, 0x12, 0x19, 0x0a, 0x03, 0x74,
2433 0x62, 0x66, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x07, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x62,
2434 0x66, 0x52, 0x03, 0x74, 0x62, 0x66, 0x12, 0x14, 0x0a, 0x05, 0x69, 0x70, 0x73, 0x65, 0x74, 0x18,
2435 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x69, 0x70, 0x73, 0x65, 0x74, 0x12, 0x1a, 0x0a, 0x08,
2436 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08,
2437 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x12, 0x1f, 0x0a, 0x0b, 0x73, 0x6f, 0x75, 0x72,
2438 0x63, 0x65, 0x5f, 0x70, 0x6f, 0x72, 0x74, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x73,
2439 0x6f, 0x75, 0x72, 0x63, 0x65, 0x50, 0x6f, 0x72, 0x74, 0x12, 0x1f, 0x0a, 0x0b, 0x65, 0x67, 0x72,
2440 0x65, 0x73, 0x73, 0x5f, 0x70, 0x6f, 0x72, 0x74, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a,
2441 0x65, 0x67, 0x72, 0x65, 0x73, 0x73, 0x50, 0x6f, 0x72, 0x74, 0x22, 0x20, 0x0a, 0x04, 0x54, 0x79,
2442 0x70, 0x65, 0x12, 0x09, 0x0a, 0x05, 0x4e, 0x45, 0x54, 0x45, 0x4d, 0x10, 0x00, 0x12, 0x0d, 0x0a,
2443 0x09, 0x42, 0x41, 0x4e, 0x44, 0x57, 0x49, 0x44, 0x54, 0x48, 0x10, 0x01, 0x22, 0x89, 0x01, 0x0a,
2444 0x13, 0x53, 0x65, 0x74, 0x44, 0x4e, 0x53, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x52, 0x65, 0x71,
2445 0x75, 0x65, 0x73, 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65,
2446 0x72, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74,
2447 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x1d, 0x0a, 0x0a, 0x64, 0x6e, 0x73, 0x5f, 0x73,
2448 0x65, 0x72, 0x76, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x64, 0x6e, 0x73,
2449 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x12, 0x16, 0x0a, 0x06, 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65,
2450 0x18, 0x03, 0x20, 0x01, 0x28, 0x08, 0x52, 0x06, 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x18,
2451 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52,
2452 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x32, 0xa1, 0x06, 0x0a, 0x0b, 0x43, 0x68, 0x61,
2453 0x6f, 0x73, 0x44, 0x61, 0x65, 0x6d, 0x6f, 0x6e, 0x12, 0x32, 0x0a, 0x06, 0x53, 0x65, 0x74, 0x54,
2454 0x63, 0x73, 0x12, 0x0e, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65,
2455 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74,
2456 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x3a, 0x0a, 0x0b,
2457 0x46, 0x6c, 0x75, 0x73, 0x68, 0x49, 0x50, 0x53, 0x65, 0x74, 0x73, 0x12, 0x11, 0x2e, 0x70, 0x62,
2458 0x2e, 0x49, 0x50, 0x53, 0x65, 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16,
2459 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66,
2460 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x48, 0x0a, 0x11, 0x53, 0x65, 0x74, 0x49,
2461 0x70, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x43, 0x68, 0x61, 0x69, 0x6e, 0x73, 0x12, 0x19, 0x2e,
2462 0x70, 0x62, 0x2e, 0x49, 0x70, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x43, 0x68, 0x61, 0x69, 0x6e,
2463 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
2464 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79,
2465 0x22, 0x00, 0x12, 0x3a, 0x0a, 0x0d, 0x53, 0x65, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x4f, 0x66, 0x66,
2466 0x73, 0x65, 0x74, 0x12, 0x0f, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x52, 0x65, 0x71,
2467 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72,
2468 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x3e,
2469 0x0a, 0x11, 0x52, 0x65, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x54, 0x69, 0x6d, 0x65, 0x4f, 0x66, 0x66,
2470 0x73, 0x65, 0x74, 0x12, 0x0f, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x52, 0x65, 0x71,
2471 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72,
2472 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x3f,
2473 0x0a, 0x0d, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x4b, 0x69, 0x6c, 0x6c, 0x12,
2474 0x14, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x52, 0x65,
2475 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70,
2476 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12,
2477 0x40, 0x0a, 0x0f, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x47, 0x65, 0x74, 0x50,
2478 0x69, 0x64, 0x12, 0x14, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65,
2479 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x15, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x6f,
2480 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22,
2481 0x00, 0x12, 0x40, 0x0a, 0x0d, 0x45, 0x78, 0x65, 0x63, 0x53, 0x74, 0x72, 0x65, 0x73, 0x73, 0x6f,
2482 0x72, 0x73, 0x12, 0x15, 0x2e, 0x70, 0x62, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x53, 0x74, 0x72, 0x65,
2483 0x73, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x70, 0x62, 0x2e, 0x45,
2484 0x78, 0x65, 0x63, 0x53, 0x74, 0x72, 0x65, 0x73, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
2485 0x65, 0x22, 0x00, 0x12, 0x44, 0x0a, 0x0f, 0x43, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x53, 0x74, 0x72,
2486 0x65, 0x73, 0x73, 0x6f, 0x72, 0x73, 0x12, 0x17, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x61, 0x6e, 0x63,
2487 0x65, 0x6c, 0x53, 0x74, 0x72, 0x65, 0x73, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a,
2488 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75,
2489 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x43, 0x0a, 0x0c, 0x41, 0x70, 0x70,
2490 0x6c, 0x79, 0x49, 0x6f, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x12, 0x17, 0x2e, 0x70, 0x62, 0x2e, 0x41,
2491 0x70, 0x70, 0x6c, 0x79, 0x49, 0x6f, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65,
2492 0x73, 0x74, 0x1a, 0x18, 0x2e, 0x70, 0x62, 0x2e, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x49, 0x6f, 0x43,
2493 0x68, 0x61, 0x6f, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x49,
2494 0x0a, 0x0e, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x48, 0x74, 0x74, 0x70, 0x43, 0x68, 0x61, 0x6f, 0x73,
2495 0x12, 0x19, 0x2e, 0x70, 0x62, 0x2e, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x48, 0x74, 0x74, 0x70, 0x43,
2496 0x68, 0x61, 0x6f, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1a, 0x2e, 0x70, 0x62,
2497 0x2e, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x48, 0x74, 0x74, 0x70, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x52,
2498 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x41, 0x0a, 0x0c, 0x53, 0x65, 0x74,
2499 0x44, 0x4e, 0x53, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x12, 0x17, 0x2e, 0x70, 0x62, 0x2e, 0x53,
2500 0x65, 0x74, 0x44, 0x4e, 0x53, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65,
2501 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74,
2502 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x62, 0x06, 0x70, 0x72,
2503 0x6f, 0x74, 0x6f, 0x33,
2504 }
2505
2506 var (
2507 file_chaosdaemon_proto_rawDescOnce sync.Once
2508 file_chaosdaemon_proto_rawDescData = file_chaosdaemon_proto_rawDesc
2509 )
2510
2511 func file_chaosdaemon_proto_rawDescGZIP() []byte {
2512 file_chaosdaemon_proto_rawDescOnce.Do(func() {
2513 file_chaosdaemon_proto_rawDescData = protoimpl.X.CompressGZIP(file_chaosdaemon_proto_rawDescData)
2514 })
2515 return file_chaosdaemon_proto_rawDescData
2516 }
2517
2518 var file_chaosdaemon_proto_enumTypes = make([]protoimpl.EnumInfo, 4)
2519 var file_chaosdaemon_proto_msgTypes = make([]protoimpl.MessageInfo, 29)
2520 var file_chaosdaemon_proto_goTypes = []interface{}{
2521 (Chain_Direction)(0),
2522 (ContainerAction_Action)(0),
2523 (ExecStressRequest_Scope)(0),
2524 (Tc_Type)(0),
2525 (*TcHandle)(nil),
2526 (*ContainerRequest)(nil),
2527 (*ContainerResponse)(nil),
2528 (*NetemRequest)(nil),
2529 (*Netem)(nil),
2530 (*TbfRequest)(nil),
2531 (*Tbf)(nil),
2532 (*QdiscRequest)(nil),
2533 (*Qdisc)(nil),
2534 (*EmatchFilterRequest)(nil),
2535 (*EmatchFilter)(nil),
2536 (*TcFilterRequest)(nil),
2537 (*TcFilter)(nil),
2538 (*IPSetsRequest)(nil),
2539 (*IPSet)(nil),
2540 (*IptablesChainsRequest)(nil),
2541 (*Chain)(nil),
2542 (*TimeRequest)(nil),
2543 (*ContainerAction)(nil),
2544 (*ExecStressRequest)(nil),
2545 (*ExecStressResponse)(nil),
2546 (*CancelStressRequest)(nil),
2547 (*ApplyIOChaosRequest)(nil),
2548 (*ApplyIOChaosResponse)(nil),
2549 (*ApplyHttpChaosRequest)(nil),
2550 (*ApplyHttpChaosResponse)(nil),
2551 (*TcsRequest)(nil),
2552 (*Tc)(nil),
2553 (*SetDNSServerRequest)(nil),
2554 (*empty.Empty)(nil),
2555 }
2556 var file_chaosdaemon_proto_depIdxs = []int32{
2557 22,
2558 8,
2559 4,
2560 4,
2561 4,
2562 4,
2563 10,
2564 12,
2565 4,
2566 4,
2567 14,
2568 4,
2569 4,
2570 16,
2571 4,
2572 18,
2573 20,
2574 0,
2575 1,
2576 2,
2577 31,
2578 3,
2579 8,
2580 10,
2581 30,
2582 17,
2583 19,
2584 21,
2585 21,
2586 5,
2587 5,
2588 23,
2589 25,
2590 26,
2591 28,
2592 32,
2593 33,
2594 33,
2595 33,
2596 33,
2597 33,
2598 33,
2599 6,
2600 24,
2601 33,
2602 27,
2603 29,
2604 33,
2605 36,
2606 24,
2607 24,
2608 24,
2609 0,
2610 }
2611
2612 func init() { file_chaosdaemon_proto_init() }
2613 func file_chaosdaemon_proto_init() {
2614 if File_chaosdaemon_proto != nil {
2615 return
2616 }
2617 if !protoimpl.UnsafeEnabled {
2618 file_chaosdaemon_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
2619 switch v := v.(*TcHandle); i {
2620 case 0:
2621 return &v.state
2622 case 1:
2623 return &v.sizeCache
2624 case 2:
2625 return &v.unknownFields
2626 default:
2627 return nil
2628 }
2629 }
2630 file_chaosdaemon_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
2631 switch v := v.(*ContainerRequest); i {
2632 case 0:
2633 return &v.state
2634 case 1:
2635 return &v.sizeCache
2636 case 2:
2637 return &v.unknownFields
2638 default:
2639 return nil
2640 }
2641 }
2642 file_chaosdaemon_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
2643 switch v := v.(*ContainerResponse); i {
2644 case 0:
2645 return &v.state
2646 case 1:
2647 return &v.sizeCache
2648 case 2:
2649 return &v.unknownFields
2650 default:
2651 return nil
2652 }
2653 }
2654 file_chaosdaemon_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
2655 switch v := v.(*NetemRequest); i {
2656 case 0:
2657 return &v.state
2658 case 1:
2659 return &v.sizeCache
2660 case 2:
2661 return &v.unknownFields
2662 default:
2663 return nil
2664 }
2665 }
2666 file_chaosdaemon_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
2667 switch v := v.(*Netem); i {
2668 case 0:
2669 return &v.state
2670 case 1:
2671 return &v.sizeCache
2672 case 2:
2673 return &v.unknownFields
2674 default:
2675 return nil
2676 }
2677 }
2678 file_chaosdaemon_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
2679 switch v := v.(*TbfRequest); i {
2680 case 0:
2681 return &v.state
2682 case 1:
2683 return &v.sizeCache
2684 case 2:
2685 return &v.unknownFields
2686 default:
2687 return nil
2688 }
2689 }
2690 file_chaosdaemon_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
2691 switch v := v.(*Tbf); i {
2692 case 0:
2693 return &v.state
2694 case 1:
2695 return &v.sizeCache
2696 case 2:
2697 return &v.unknownFields
2698 default:
2699 return nil
2700 }
2701 }
2702 file_chaosdaemon_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
2703 switch v := v.(*QdiscRequest); i {
2704 case 0:
2705 return &v.state
2706 case 1:
2707 return &v.sizeCache
2708 case 2:
2709 return &v.unknownFields
2710 default:
2711 return nil
2712 }
2713 }
2714 file_chaosdaemon_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
2715 switch v := v.(*Qdisc); i {
2716 case 0:
2717 return &v.state
2718 case 1:
2719 return &v.sizeCache
2720 case 2:
2721 return &v.unknownFields
2722 default:
2723 return nil
2724 }
2725 }
2726 file_chaosdaemon_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
2727 switch v := v.(*EmatchFilterRequest); i {
2728 case 0:
2729 return &v.state
2730 case 1:
2731 return &v.sizeCache
2732 case 2:
2733 return &v.unknownFields
2734 default:
2735 return nil
2736 }
2737 }
2738 file_chaosdaemon_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
2739 switch v := v.(*EmatchFilter); i {
2740 case 0:
2741 return &v.state
2742 case 1:
2743 return &v.sizeCache
2744 case 2:
2745 return &v.unknownFields
2746 default:
2747 return nil
2748 }
2749 }
2750 file_chaosdaemon_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
2751 switch v := v.(*TcFilterRequest); i {
2752 case 0:
2753 return &v.state
2754 case 1:
2755 return &v.sizeCache
2756 case 2:
2757 return &v.unknownFields
2758 default:
2759 return nil
2760 }
2761 }
2762 file_chaosdaemon_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
2763 switch v := v.(*TcFilter); i {
2764 case 0:
2765 return &v.state
2766 case 1:
2767 return &v.sizeCache
2768 case 2:
2769 return &v.unknownFields
2770 default:
2771 return nil
2772 }
2773 }
2774 file_chaosdaemon_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
2775 switch v := v.(*IPSetsRequest); i {
2776 case 0:
2777 return &v.state
2778 case 1:
2779 return &v.sizeCache
2780 case 2:
2781 return &v.unknownFields
2782 default:
2783 return nil
2784 }
2785 }
2786 file_chaosdaemon_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
2787 switch v := v.(*IPSet); i {
2788 case 0:
2789 return &v.state
2790 case 1:
2791 return &v.sizeCache
2792 case 2:
2793 return &v.unknownFields
2794 default:
2795 return nil
2796 }
2797 }
2798 file_chaosdaemon_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
2799 switch v := v.(*IptablesChainsRequest); i {
2800 case 0:
2801 return &v.state
2802 case 1:
2803 return &v.sizeCache
2804 case 2:
2805 return &v.unknownFields
2806 default:
2807 return nil
2808 }
2809 }
2810 file_chaosdaemon_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
2811 switch v := v.(*Chain); i {
2812 case 0:
2813 return &v.state
2814 case 1:
2815 return &v.sizeCache
2816 case 2:
2817 return &v.unknownFields
2818 default:
2819 return nil
2820 }
2821 }
2822 file_chaosdaemon_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
2823 switch v := v.(*TimeRequest); i {
2824 case 0:
2825 return &v.state
2826 case 1:
2827 return &v.sizeCache
2828 case 2:
2829 return &v.unknownFields
2830 default:
2831 return nil
2832 }
2833 }
2834 file_chaosdaemon_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} {
2835 switch v := v.(*ContainerAction); i {
2836 case 0:
2837 return &v.state
2838 case 1:
2839 return &v.sizeCache
2840 case 2:
2841 return &v.unknownFields
2842 default:
2843 return nil
2844 }
2845 }
2846 file_chaosdaemon_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} {
2847 switch v := v.(*ExecStressRequest); i {
2848 case 0:
2849 return &v.state
2850 case 1:
2851 return &v.sizeCache
2852 case 2:
2853 return &v.unknownFields
2854 default:
2855 return nil
2856 }
2857 }
2858 file_chaosdaemon_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} {
2859 switch v := v.(*ExecStressResponse); i {
2860 case 0:
2861 return &v.state
2862 case 1:
2863 return &v.sizeCache
2864 case 2:
2865 return &v.unknownFields
2866 default:
2867 return nil
2868 }
2869 }
2870 file_chaosdaemon_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} {
2871 switch v := v.(*CancelStressRequest); i {
2872 case 0:
2873 return &v.state
2874 case 1:
2875 return &v.sizeCache
2876 case 2:
2877 return &v.unknownFields
2878 default:
2879 return nil
2880 }
2881 }
2882 file_chaosdaemon_proto_msgTypes[22].Exporter = func(v interface{}, i int) interface{} {
2883 switch v := v.(*ApplyIOChaosRequest); i {
2884 case 0:
2885 return &v.state
2886 case 1:
2887 return &v.sizeCache
2888 case 2:
2889 return &v.unknownFields
2890 default:
2891 return nil
2892 }
2893 }
2894 file_chaosdaemon_proto_msgTypes[23].Exporter = func(v interface{}, i int) interface{} {
2895 switch v := v.(*ApplyIOChaosResponse); i {
2896 case 0:
2897 return &v.state
2898 case 1:
2899 return &v.sizeCache
2900 case 2:
2901 return &v.unknownFields
2902 default:
2903 return nil
2904 }
2905 }
2906 file_chaosdaemon_proto_msgTypes[24].Exporter = func(v interface{}, i int) interface{} {
2907 switch v := v.(*ApplyHttpChaosRequest); i {
2908 case 0:
2909 return &v.state
2910 case 1:
2911 return &v.sizeCache
2912 case 2:
2913 return &v.unknownFields
2914 default:
2915 return nil
2916 }
2917 }
2918 file_chaosdaemon_proto_msgTypes[25].Exporter = func(v interface{}, i int) interface{} {
2919 switch v := v.(*ApplyHttpChaosResponse); i {
2920 case 0:
2921 return &v.state
2922 case 1:
2923 return &v.sizeCache
2924 case 2:
2925 return &v.unknownFields
2926 default:
2927 return nil
2928 }
2929 }
2930 file_chaosdaemon_proto_msgTypes[26].Exporter = func(v interface{}, i int) interface{} {
2931 switch v := v.(*TcsRequest); i {
2932 case 0:
2933 return &v.state
2934 case 1:
2935 return &v.sizeCache
2936 case 2:
2937 return &v.unknownFields
2938 default:
2939 return nil
2940 }
2941 }
2942 file_chaosdaemon_proto_msgTypes[27].Exporter = func(v interface{}, i int) interface{} {
2943 switch v := v.(*Tc); i {
2944 case 0:
2945 return &v.state
2946 case 1:
2947 return &v.sizeCache
2948 case 2:
2949 return &v.unknownFields
2950 default:
2951 return nil
2952 }
2953 }
2954 file_chaosdaemon_proto_msgTypes[28].Exporter = func(v interface{}, i int) interface{} {
2955 switch v := v.(*SetDNSServerRequest); i {
2956 case 0:
2957 return &v.state
2958 case 1:
2959 return &v.sizeCache
2960 case 2:
2961 return &v.unknownFields
2962 default:
2963 return nil
2964 }
2965 }
2966 }
2967 type x struct{}
2968 out := protoimpl.TypeBuilder{
2969 File: protoimpl.DescBuilder{
2970 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
2971 RawDescriptor: file_chaosdaemon_proto_rawDesc,
2972 NumEnums: 4,
2973 NumMessages: 29,
2974 NumExtensions: 0,
2975 NumServices: 1,
2976 },
2977 GoTypes: file_chaosdaemon_proto_goTypes,
2978 DependencyIndexes: file_chaosdaemon_proto_depIdxs,
2979 EnumInfos: file_chaosdaemon_proto_enumTypes,
2980 MessageInfos: file_chaosdaemon_proto_msgTypes,
2981 }.Build()
2982 File_chaosdaemon_proto = out.File
2983 file_chaosdaemon_proto_rawDesc = nil
2984 file_chaosdaemon_proto_goTypes = nil
2985 file_chaosdaemon_proto_depIdxs = nil
2986 }
2987
2988
2989 var _ context.Context
2990 var _ grpc.ClientConnInterface
2991
2992
2993
2994 const _ = grpc.SupportPackageIsVersion6
2995
2996
2997
2998
2999 type ChaosDaemonClient interface {
3000 SetTcs(ctx context.Context, in *TcsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3001 FlushIPSets(ctx context.Context, in *IPSetsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3002 SetIptablesChains(ctx context.Context, in *IptablesChainsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3003 SetTimeOffset(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3004 RecoverTimeOffset(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3005 ContainerKill(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3006 ContainerGetPid(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*ContainerResponse, error)
3007 ExecStressors(ctx context.Context, in *ExecStressRequest, opts ...grpc.CallOption) (*ExecStressResponse, error)
3008 CancelStressors(ctx context.Context, in *CancelStressRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3009 ApplyIOChaos(ctx context.Context, in *ApplyIOChaosRequest, opts ...grpc.CallOption) (*ApplyIOChaosResponse, error)
3010 ApplyHttpChaos(ctx context.Context, in *ApplyHttpChaosRequest, opts ...grpc.CallOption) (*ApplyHttpChaosResponse, error)
3011 SetDNSServer(ctx context.Context, in *SetDNSServerRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3012 }
3013
3014 type chaosDaemonClient struct {
3015 cc grpc.ClientConnInterface
3016 }
3017
3018 func NewChaosDaemonClient(cc grpc.ClientConnInterface) ChaosDaemonClient {
3019 return &chaosDaemonClient{cc}
3020 }
3021
3022 func (c *chaosDaemonClient) SetTcs(ctx context.Context, in *TcsRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3023 out := new(empty.Empty)
3024 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/SetTcs", in, out, opts...)
3025 if err != nil {
3026 return nil, err
3027 }
3028 return out, nil
3029 }
3030
3031 func (c *chaosDaemonClient) FlushIPSets(ctx context.Context, in *IPSetsRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3032 out := new(empty.Empty)
3033 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/FlushIPSets", in, out, opts...)
3034 if err != nil {
3035 return nil, err
3036 }
3037 return out, nil
3038 }
3039
3040 func (c *chaosDaemonClient) SetIptablesChains(ctx context.Context, in *IptablesChainsRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3041 out := new(empty.Empty)
3042 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/SetIptablesChains", in, out, opts...)
3043 if err != nil {
3044 return nil, err
3045 }
3046 return out, nil
3047 }
3048
3049 func (c *chaosDaemonClient) SetTimeOffset(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3050 out := new(empty.Empty)
3051 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/SetTimeOffset", in, out, opts...)
3052 if err != nil {
3053 return nil, err
3054 }
3055 return out, nil
3056 }
3057
3058 func (c *chaosDaemonClient) RecoverTimeOffset(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3059 out := new(empty.Empty)
3060 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/RecoverTimeOffset", in, out, opts...)
3061 if err != nil {
3062 return nil, err
3063 }
3064 return out, nil
3065 }
3066
3067 func (c *chaosDaemonClient) ContainerKill(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3068 out := new(empty.Empty)
3069 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/ContainerKill", in, out, opts...)
3070 if err != nil {
3071 return nil, err
3072 }
3073 return out, nil
3074 }
3075
3076 func (c *chaosDaemonClient) ContainerGetPid(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*ContainerResponse, error) {
3077 out := new(ContainerResponse)
3078 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/ContainerGetPid", in, out, opts...)
3079 if err != nil {
3080 return nil, err
3081 }
3082 return out, nil
3083 }
3084
3085 func (c *chaosDaemonClient) ExecStressors(ctx context.Context, in *ExecStressRequest, opts ...grpc.CallOption) (*ExecStressResponse, error) {
3086 out := new(ExecStressResponse)
3087 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/ExecStressors", in, out, opts...)
3088 if err != nil {
3089 return nil, err
3090 }
3091 return out, nil
3092 }
3093
3094 func (c *chaosDaemonClient) CancelStressors(ctx context.Context, in *CancelStressRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3095 out := new(empty.Empty)
3096 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/CancelStressors", in, out, opts...)
3097 if err != nil {
3098 return nil, err
3099 }
3100 return out, nil
3101 }
3102
3103 func (c *chaosDaemonClient) ApplyIOChaos(ctx context.Context, in *ApplyIOChaosRequest, opts ...grpc.CallOption) (*ApplyIOChaosResponse, error) {
3104 out := new(ApplyIOChaosResponse)
3105 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/ApplyIOChaos", in, out, opts...)
3106 if err != nil {
3107 return nil, err
3108 }
3109 return out, nil
3110 }
3111
3112 func (c *chaosDaemonClient) ApplyHttpChaos(ctx context.Context, in *ApplyHttpChaosRequest, opts ...grpc.CallOption) (*ApplyHttpChaosResponse, error) {
3113 out := new(ApplyHttpChaosResponse)
3114 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/ApplyHttpChaos", in, out, opts...)
3115 if err != nil {
3116 return nil, err
3117 }
3118 return out, nil
3119 }
3120
3121 func (c *chaosDaemonClient) SetDNSServer(ctx context.Context, in *SetDNSServerRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3122 out := new(empty.Empty)
3123 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/SetDNSServer", in, out, opts...)
3124 if err != nil {
3125 return nil, err
3126 }
3127 return out, nil
3128 }
3129
3130
3131 type ChaosDaemonServer interface {
3132 SetTcs(context.Context, *TcsRequest) (*empty.Empty, error)
3133 FlushIPSets(context.Context, *IPSetsRequest) (*empty.Empty, error)
3134 SetIptablesChains(context.Context, *IptablesChainsRequest) (*empty.Empty, error)
3135 SetTimeOffset(context.Context, *TimeRequest) (*empty.Empty, error)
3136 RecoverTimeOffset(context.Context, *TimeRequest) (*empty.Empty, error)
3137 ContainerKill(context.Context, *ContainerRequest) (*empty.Empty, error)
3138 ContainerGetPid(context.Context, *ContainerRequest) (*ContainerResponse, error)
3139 ExecStressors(context.Context, *ExecStressRequest) (*ExecStressResponse, error)
3140 CancelStressors(context.Context, *CancelStressRequest) (*empty.Empty, error)
3141 ApplyIOChaos(context.Context, *ApplyIOChaosRequest) (*ApplyIOChaosResponse, error)
3142 ApplyHttpChaos(context.Context, *ApplyHttpChaosRequest) (*ApplyHttpChaosResponse, error)
3143 SetDNSServer(context.Context, *SetDNSServerRequest) (*empty.Empty, error)
3144 }
3145
3146
3147 type UnimplementedChaosDaemonServer struct {
3148 }
3149
3150 func (*UnimplementedChaosDaemonServer) SetTcs(context.Context, *TcsRequest) (*empty.Empty, error) {
3151 return nil, status.Errorf(codes.Unimplemented, "method SetTcs not implemented")
3152 }
3153 func (*UnimplementedChaosDaemonServer) FlushIPSets(context.Context, *IPSetsRequest) (*empty.Empty, error) {
3154 return nil, status.Errorf(codes.Unimplemented, "method FlushIPSets not implemented")
3155 }
3156 func (*UnimplementedChaosDaemonServer) SetIptablesChains(context.Context, *IptablesChainsRequest) (*empty.Empty, error) {
3157 return nil, status.Errorf(codes.Unimplemented, "method SetIptablesChains not implemented")
3158 }
3159 func (*UnimplementedChaosDaemonServer) SetTimeOffset(context.Context, *TimeRequest) (*empty.Empty, error) {
3160 return nil, status.Errorf(codes.Unimplemented, "method SetTimeOffset not implemented")
3161 }
3162 func (*UnimplementedChaosDaemonServer) RecoverTimeOffset(context.Context, *TimeRequest) (*empty.Empty, error) {
3163 return nil, status.Errorf(codes.Unimplemented, "method RecoverTimeOffset not implemented")
3164 }
3165 func (*UnimplementedChaosDaemonServer) ContainerKill(context.Context, *ContainerRequest) (*empty.Empty, error) {
3166 return nil, status.Errorf(codes.Unimplemented, "method ContainerKill not implemented")
3167 }
3168 func (*UnimplementedChaosDaemonServer) ContainerGetPid(context.Context, *ContainerRequest) (*ContainerResponse, error) {
3169 return nil, status.Errorf(codes.Unimplemented, "method ContainerGetPid not implemented")
3170 }
3171 func (*UnimplementedChaosDaemonServer) ExecStressors(context.Context, *ExecStressRequest) (*ExecStressResponse, error) {
3172 return nil, status.Errorf(codes.Unimplemented, "method ExecStressors not implemented")
3173 }
3174 func (*UnimplementedChaosDaemonServer) CancelStressors(context.Context, *CancelStressRequest) (*empty.Empty, error) {
3175 return nil, status.Errorf(codes.Unimplemented, "method CancelStressors not implemented")
3176 }
3177 func (*UnimplementedChaosDaemonServer) ApplyIOChaos(context.Context, *ApplyIOChaosRequest) (*ApplyIOChaosResponse, error) {
3178 return nil, status.Errorf(codes.Unimplemented, "method ApplyIOChaos not implemented")
3179 }
3180 func (*UnimplementedChaosDaemonServer) ApplyHttpChaos(context.Context, *ApplyHttpChaosRequest) (*ApplyHttpChaosResponse, error) {
3181 return nil, status.Errorf(codes.Unimplemented, "method ApplyHttpChaos not implemented")
3182 }
3183 func (*UnimplementedChaosDaemonServer) SetDNSServer(context.Context, *SetDNSServerRequest) (*empty.Empty, error) {
3184 return nil, status.Errorf(codes.Unimplemented, "method SetDNSServer not implemented")
3185 }
3186
3187 func RegisterChaosDaemonServer(s *grpc.Server, srv ChaosDaemonServer) {
3188 s.RegisterService(&_ChaosDaemon_serviceDesc, srv)
3189 }
3190
3191 func _ChaosDaemon_SetTcs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3192 in := new(TcsRequest)
3193 if err := dec(in); err != nil {
3194 return nil, err
3195 }
3196 if interceptor == nil {
3197 return srv.(ChaosDaemonServer).SetTcs(ctx, in)
3198 }
3199 info := &grpc.UnaryServerInfo{
3200 Server: srv,
3201 FullMethod: "/pb.ChaosDaemon/SetTcs",
3202 }
3203 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3204 return srv.(ChaosDaemonServer).SetTcs(ctx, req.(*TcsRequest))
3205 }
3206 return interceptor(ctx, in, info, handler)
3207 }
3208
3209 func _ChaosDaemon_FlushIPSets_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3210 in := new(IPSetsRequest)
3211 if err := dec(in); err != nil {
3212 return nil, err
3213 }
3214 if interceptor == nil {
3215 return srv.(ChaosDaemonServer).FlushIPSets(ctx, in)
3216 }
3217 info := &grpc.UnaryServerInfo{
3218 Server: srv,
3219 FullMethod: "/pb.ChaosDaemon/FlushIPSets",
3220 }
3221 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3222 return srv.(ChaosDaemonServer).FlushIPSets(ctx, req.(*IPSetsRequest))
3223 }
3224 return interceptor(ctx, in, info, handler)
3225 }
3226
3227 func _ChaosDaemon_SetIptablesChains_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3228 in := new(IptablesChainsRequest)
3229 if err := dec(in); err != nil {
3230 return nil, err
3231 }
3232 if interceptor == nil {
3233 return srv.(ChaosDaemonServer).SetIptablesChains(ctx, in)
3234 }
3235 info := &grpc.UnaryServerInfo{
3236 Server: srv,
3237 FullMethod: "/pb.ChaosDaemon/SetIptablesChains",
3238 }
3239 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3240 return srv.(ChaosDaemonServer).SetIptablesChains(ctx, req.(*IptablesChainsRequest))
3241 }
3242 return interceptor(ctx, in, info, handler)
3243 }
3244
3245 func _ChaosDaemon_SetTimeOffset_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3246 in := new(TimeRequest)
3247 if err := dec(in); err != nil {
3248 return nil, err
3249 }
3250 if interceptor == nil {
3251 return srv.(ChaosDaemonServer).SetTimeOffset(ctx, in)
3252 }
3253 info := &grpc.UnaryServerInfo{
3254 Server: srv,
3255 FullMethod: "/pb.ChaosDaemon/SetTimeOffset",
3256 }
3257 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3258 return srv.(ChaosDaemonServer).SetTimeOffset(ctx, req.(*TimeRequest))
3259 }
3260 return interceptor(ctx, in, info, handler)
3261 }
3262
3263 func _ChaosDaemon_RecoverTimeOffset_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3264 in := new(TimeRequest)
3265 if err := dec(in); err != nil {
3266 return nil, err
3267 }
3268 if interceptor == nil {
3269 return srv.(ChaosDaemonServer).RecoverTimeOffset(ctx, in)
3270 }
3271 info := &grpc.UnaryServerInfo{
3272 Server: srv,
3273 FullMethod: "/pb.ChaosDaemon/RecoverTimeOffset",
3274 }
3275 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3276 return srv.(ChaosDaemonServer).RecoverTimeOffset(ctx, req.(*TimeRequest))
3277 }
3278 return interceptor(ctx, in, info, handler)
3279 }
3280
3281 func _ChaosDaemon_ContainerKill_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3282 in := new(ContainerRequest)
3283 if err := dec(in); err != nil {
3284 return nil, err
3285 }
3286 if interceptor == nil {
3287 return srv.(ChaosDaemonServer).ContainerKill(ctx, in)
3288 }
3289 info := &grpc.UnaryServerInfo{
3290 Server: srv,
3291 FullMethod: "/pb.ChaosDaemon/ContainerKill",
3292 }
3293 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3294 return srv.(ChaosDaemonServer).ContainerKill(ctx, req.(*ContainerRequest))
3295 }
3296 return interceptor(ctx, in, info, handler)
3297 }
3298
3299 func _ChaosDaemon_ContainerGetPid_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3300 in := new(ContainerRequest)
3301 if err := dec(in); err != nil {
3302 return nil, err
3303 }
3304 if interceptor == nil {
3305 return srv.(ChaosDaemonServer).ContainerGetPid(ctx, in)
3306 }
3307 info := &grpc.UnaryServerInfo{
3308 Server: srv,
3309 FullMethod: "/pb.ChaosDaemon/ContainerGetPid",
3310 }
3311 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3312 return srv.(ChaosDaemonServer).ContainerGetPid(ctx, req.(*ContainerRequest))
3313 }
3314 return interceptor(ctx, in, info, handler)
3315 }
3316
3317 func _ChaosDaemon_ExecStressors_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3318 in := new(ExecStressRequest)
3319 if err := dec(in); err != nil {
3320 return nil, err
3321 }
3322 if interceptor == nil {
3323 return srv.(ChaosDaemonServer).ExecStressors(ctx, in)
3324 }
3325 info := &grpc.UnaryServerInfo{
3326 Server: srv,
3327 FullMethod: "/pb.ChaosDaemon/ExecStressors",
3328 }
3329 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3330 return srv.(ChaosDaemonServer).ExecStressors(ctx, req.(*ExecStressRequest))
3331 }
3332 return interceptor(ctx, in, info, handler)
3333 }
3334
3335 func _ChaosDaemon_CancelStressors_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3336 in := new(CancelStressRequest)
3337 if err := dec(in); err != nil {
3338 return nil, err
3339 }
3340 if interceptor == nil {
3341 return srv.(ChaosDaemonServer).CancelStressors(ctx, in)
3342 }
3343 info := &grpc.UnaryServerInfo{
3344 Server: srv,
3345 FullMethod: "/pb.ChaosDaemon/CancelStressors",
3346 }
3347 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3348 return srv.(ChaosDaemonServer).CancelStressors(ctx, req.(*CancelStressRequest))
3349 }
3350 return interceptor(ctx, in, info, handler)
3351 }
3352
3353 func _ChaosDaemon_ApplyIOChaos_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3354 in := new(ApplyIOChaosRequest)
3355 if err := dec(in); err != nil {
3356 return nil, err
3357 }
3358 if interceptor == nil {
3359 return srv.(ChaosDaemonServer).ApplyIOChaos(ctx, in)
3360 }
3361 info := &grpc.UnaryServerInfo{
3362 Server: srv,
3363 FullMethod: "/pb.ChaosDaemon/ApplyIOChaos",
3364 }
3365 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3366 return srv.(ChaosDaemonServer).ApplyIOChaos(ctx, req.(*ApplyIOChaosRequest))
3367 }
3368 return interceptor(ctx, in, info, handler)
3369 }
3370
3371 func _ChaosDaemon_ApplyHttpChaos_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3372 in := new(ApplyHttpChaosRequest)
3373 if err := dec(in); err != nil {
3374 return nil, err
3375 }
3376 if interceptor == nil {
3377 return srv.(ChaosDaemonServer).ApplyHttpChaos(ctx, in)
3378 }
3379 info := &grpc.UnaryServerInfo{
3380 Server: srv,
3381 FullMethod: "/pb.ChaosDaemon/ApplyHttpChaos",
3382 }
3383 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3384 return srv.(ChaosDaemonServer).ApplyHttpChaos(ctx, req.(*ApplyHttpChaosRequest))
3385 }
3386 return interceptor(ctx, in, info, handler)
3387 }
3388
3389 func _ChaosDaemon_SetDNSServer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3390 in := new(SetDNSServerRequest)
3391 if err := dec(in); err != nil {
3392 return nil, err
3393 }
3394 if interceptor == nil {
3395 return srv.(ChaosDaemonServer).SetDNSServer(ctx, in)
3396 }
3397 info := &grpc.UnaryServerInfo{
3398 Server: srv,
3399 FullMethod: "/pb.ChaosDaemon/SetDNSServer",
3400 }
3401 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3402 return srv.(ChaosDaemonServer).SetDNSServer(ctx, req.(*SetDNSServerRequest))
3403 }
3404 return interceptor(ctx, in, info, handler)
3405 }
3406
3407 var _ChaosDaemon_serviceDesc = grpc.ServiceDesc{
3408 ServiceName: "pb.ChaosDaemon",
3409 HandlerType: (*ChaosDaemonServer)(nil),
3410 Methods: []grpc.MethodDesc{
3411 {
3412 MethodName: "SetTcs",
3413 Handler: _ChaosDaemon_SetTcs_Handler,
3414 },
3415 {
3416 MethodName: "FlushIPSets",
3417 Handler: _ChaosDaemon_FlushIPSets_Handler,
3418 },
3419 {
3420 MethodName: "SetIptablesChains",
3421 Handler: _ChaosDaemon_SetIptablesChains_Handler,
3422 },
3423 {
3424 MethodName: "SetTimeOffset",
3425 Handler: _ChaosDaemon_SetTimeOffset_Handler,
3426 },
3427 {
3428 MethodName: "RecoverTimeOffset",
3429 Handler: _ChaosDaemon_RecoverTimeOffset_Handler,
3430 },
3431 {
3432 MethodName: "ContainerKill",
3433 Handler: _ChaosDaemon_ContainerKill_Handler,
3434 },
3435 {
3436 MethodName: "ContainerGetPid",
3437 Handler: _ChaosDaemon_ContainerGetPid_Handler,
3438 },
3439 {
3440 MethodName: "ExecStressors",
3441 Handler: _ChaosDaemon_ExecStressors_Handler,
3442 },
3443 {
3444 MethodName: "CancelStressors",
3445 Handler: _ChaosDaemon_CancelStressors_Handler,
3446 },
3447 {
3448 MethodName: "ApplyIOChaos",
3449 Handler: _ChaosDaemon_ApplyIOChaos_Handler,
3450 },
3451 {
3452 MethodName: "ApplyHttpChaos",
3453 Handler: _ChaosDaemon_ApplyHttpChaos_Handler,
3454 },
3455 {
3456 MethodName: "SetDNSServer",
3457 Handler: _ChaosDaemon_SetDNSServer_Handler,
3458 },
3459 },
3460 Streams: []grpc.StreamDesc{},
3461 Metadata: "chaosdaemon.proto",
3462 }
3463