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{17, 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{19, 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{20, 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{28, 0}
216 }
217
218 type ApplyBlockChaosRequest_Action int32
219
220 const (
221 ApplyBlockChaosRequest_Delay ApplyBlockChaosRequest_Action = 0
222 )
223
224
225 var (
226 ApplyBlockChaosRequest_Action_name = map[int32]string{
227 0: "Delay",
228 }
229 ApplyBlockChaosRequest_Action_value = map[string]int32{
230 "Delay": 0,
231 }
232 )
233
234 func (x ApplyBlockChaosRequest_Action) Enum() *ApplyBlockChaosRequest_Action {
235 p := new(ApplyBlockChaosRequest_Action)
236 *p = x
237 return p
238 }
239
240 func (x ApplyBlockChaosRequest_Action) String() string {
241 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
242 }
243
244 func (ApplyBlockChaosRequest_Action) Descriptor() protoreflect.EnumDescriptor {
245 return file_chaosdaemon_proto_enumTypes[4].Descriptor()
246 }
247
248 func (ApplyBlockChaosRequest_Action) Type() protoreflect.EnumType {
249 return &file_chaosdaemon_proto_enumTypes[4]
250 }
251
252 func (x ApplyBlockChaosRequest_Action) Number() protoreflect.EnumNumber {
253 return protoreflect.EnumNumber(x)
254 }
255
256
257 func (ApplyBlockChaosRequest_Action) EnumDescriptor() ([]byte, []int) {
258 return file_chaosdaemon_proto_rawDescGZIP(), []int{32, 0}
259 }
260
261 type TcHandle struct {
262 state protoimpl.MessageState
263 sizeCache protoimpl.SizeCache
264 unknownFields protoimpl.UnknownFields
265
266 Major uint32 `protobuf:"varint,1,opt,name=major,proto3" json:"major,omitempty"`
267 Minor uint32 `protobuf:"varint,2,opt,name=minor,proto3" json:"minor,omitempty"`
268 }
269
270 func (x *TcHandle) Reset() {
271 *x = TcHandle{}
272 if protoimpl.UnsafeEnabled {
273 mi := &file_chaosdaemon_proto_msgTypes[0]
274 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
275 ms.StoreMessageInfo(mi)
276 }
277 }
278
279 func (x *TcHandle) String() string {
280 return protoimpl.X.MessageStringOf(x)
281 }
282
283 func (*TcHandle) ProtoMessage() {}
284
285 func (x *TcHandle) ProtoReflect() protoreflect.Message {
286 mi := &file_chaosdaemon_proto_msgTypes[0]
287 if protoimpl.UnsafeEnabled && x != nil {
288 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
289 if ms.LoadMessageInfo() == nil {
290 ms.StoreMessageInfo(mi)
291 }
292 return ms
293 }
294 return mi.MessageOf(x)
295 }
296
297
298 func (*TcHandle) Descriptor() ([]byte, []int) {
299 return file_chaosdaemon_proto_rawDescGZIP(), []int{0}
300 }
301
302 func (x *TcHandle) GetMajor() uint32 {
303 if x != nil {
304 return x.Major
305 }
306 return 0
307 }
308
309 func (x *TcHandle) GetMinor() uint32 {
310 if x != nil {
311 return x.Minor
312 }
313 return 0
314 }
315
316 type ContainerRequest struct {
317 state protoimpl.MessageState
318 sizeCache protoimpl.SizeCache
319 unknownFields protoimpl.UnknownFields
320
321 Action *ContainerAction `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`
322 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
323 }
324
325 func (x *ContainerRequest) Reset() {
326 *x = ContainerRequest{}
327 if protoimpl.UnsafeEnabled {
328 mi := &file_chaosdaemon_proto_msgTypes[1]
329 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
330 ms.StoreMessageInfo(mi)
331 }
332 }
333
334 func (x *ContainerRequest) String() string {
335 return protoimpl.X.MessageStringOf(x)
336 }
337
338 func (*ContainerRequest) ProtoMessage() {}
339
340 func (x *ContainerRequest) ProtoReflect() protoreflect.Message {
341 mi := &file_chaosdaemon_proto_msgTypes[1]
342 if protoimpl.UnsafeEnabled && x != nil {
343 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
344 if ms.LoadMessageInfo() == nil {
345 ms.StoreMessageInfo(mi)
346 }
347 return ms
348 }
349 return mi.MessageOf(x)
350 }
351
352
353 func (*ContainerRequest) Descriptor() ([]byte, []int) {
354 return file_chaosdaemon_proto_rawDescGZIP(), []int{1}
355 }
356
357 func (x *ContainerRequest) GetAction() *ContainerAction {
358 if x != nil {
359 return x.Action
360 }
361 return nil
362 }
363
364 func (x *ContainerRequest) GetContainerId() string {
365 if x != nil {
366 return x.ContainerId
367 }
368 return ""
369 }
370
371 type ContainerResponse struct {
372 state protoimpl.MessageState
373 sizeCache protoimpl.SizeCache
374 unknownFields protoimpl.UnknownFields
375
376 Pid uint32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
377 }
378
379 func (x *ContainerResponse) Reset() {
380 *x = ContainerResponse{}
381 if protoimpl.UnsafeEnabled {
382 mi := &file_chaosdaemon_proto_msgTypes[2]
383 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
384 ms.StoreMessageInfo(mi)
385 }
386 }
387
388 func (x *ContainerResponse) String() string {
389 return protoimpl.X.MessageStringOf(x)
390 }
391
392 func (*ContainerResponse) ProtoMessage() {}
393
394 func (x *ContainerResponse) ProtoReflect() protoreflect.Message {
395 mi := &file_chaosdaemon_proto_msgTypes[2]
396 if protoimpl.UnsafeEnabled && x != nil {
397 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
398 if ms.LoadMessageInfo() == nil {
399 ms.StoreMessageInfo(mi)
400 }
401 return ms
402 }
403 return mi.MessageOf(x)
404 }
405
406
407 func (*ContainerResponse) Descriptor() ([]byte, []int) {
408 return file_chaosdaemon_proto_rawDescGZIP(), []int{2}
409 }
410
411 func (x *ContainerResponse) GetPid() uint32 {
412 if x != nil {
413 return x.Pid
414 }
415 return 0
416 }
417
418 type NetemRequest struct {
419 state protoimpl.MessageState
420 sizeCache protoimpl.SizeCache
421 unknownFields protoimpl.UnknownFields
422
423 Netem *Netem `protobuf:"bytes,1,opt,name=netem,proto3" json:"netem,omitempty"`
424 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
425 Handle *TcHandle `protobuf:"bytes,3,opt,name=handle,proto3" json:"handle,omitempty"`
426 Parent *TcHandle `protobuf:"bytes,4,opt,name=parent,proto3" json:"parent,omitempty"`
427 }
428
429 func (x *NetemRequest) Reset() {
430 *x = NetemRequest{}
431 if protoimpl.UnsafeEnabled {
432 mi := &file_chaosdaemon_proto_msgTypes[3]
433 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
434 ms.StoreMessageInfo(mi)
435 }
436 }
437
438 func (x *NetemRequest) String() string {
439 return protoimpl.X.MessageStringOf(x)
440 }
441
442 func (*NetemRequest) ProtoMessage() {}
443
444 func (x *NetemRequest) ProtoReflect() protoreflect.Message {
445 mi := &file_chaosdaemon_proto_msgTypes[3]
446 if protoimpl.UnsafeEnabled && x != nil {
447 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
448 if ms.LoadMessageInfo() == nil {
449 ms.StoreMessageInfo(mi)
450 }
451 return ms
452 }
453 return mi.MessageOf(x)
454 }
455
456
457 func (*NetemRequest) Descriptor() ([]byte, []int) {
458 return file_chaosdaemon_proto_rawDescGZIP(), []int{3}
459 }
460
461 func (x *NetemRequest) GetNetem() *Netem {
462 if x != nil {
463 return x.Netem
464 }
465 return nil
466 }
467
468 func (x *NetemRequest) GetContainerId() string {
469 if x != nil {
470 return x.ContainerId
471 }
472 return ""
473 }
474
475 func (x *NetemRequest) GetHandle() *TcHandle {
476 if x != nil {
477 return x.Handle
478 }
479 return nil
480 }
481
482 func (x *NetemRequest) GetParent() *TcHandle {
483 if x != nil {
484 return x.Parent
485 }
486 return nil
487 }
488
489 type Netem struct {
490 state protoimpl.MessageState
491 sizeCache protoimpl.SizeCache
492 unknownFields protoimpl.UnknownFields
493
494 Time uint32 `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
495 Jitter uint32 `protobuf:"varint,2,opt,name=jitter,proto3" json:"jitter,omitempty"`
496 DelayCorr float32 `protobuf:"fixed32,3,opt,name=delay_corr,json=delayCorr,proto3" json:"delay_corr,omitempty"`
497 Limit uint32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
498 Loss float32 `protobuf:"fixed32,5,opt,name=loss,proto3" json:"loss,omitempty"`
499 LossCorr float32 `protobuf:"fixed32,6,opt,name=loss_corr,json=lossCorr,proto3" json:"loss_corr,omitempty"`
500 Gap uint32 `protobuf:"varint,7,opt,name=gap,proto3" json:"gap,omitempty"`
501 Duplicate float32 `protobuf:"fixed32,8,opt,name=duplicate,proto3" json:"duplicate,omitempty"`
502 DuplicateCorr float32 `protobuf:"fixed32,9,opt,name=duplicate_corr,json=duplicateCorr,proto3" json:"duplicate_corr,omitempty"`
503 Reorder float32 `protobuf:"fixed32,10,opt,name=reorder,proto3" json:"reorder,omitempty"`
504 ReorderCorr float32 `protobuf:"fixed32,11,opt,name=reorder_corr,json=reorderCorr,proto3" json:"reorder_corr,omitempty"`
505 Corrupt float32 `protobuf:"fixed32,12,opt,name=corrupt,proto3" json:"corrupt,omitempty"`
506 CorruptCorr float32 `protobuf:"fixed32,13,opt,name=corrupt_corr,json=corruptCorr,proto3" json:"corrupt_corr,omitempty"`
507 Parent *TcHandle `protobuf:"bytes,14,opt,name=parent,proto3" json:"parent,omitempty"`
508 Handle *TcHandle `protobuf:"bytes,15,opt,name=handle,proto3" json:"handle,omitempty"`
509 Rate string `protobuf:"bytes,16,opt,name=rate,proto3" json:"rate,omitempty"`
510 }
511
512 func (x *Netem) Reset() {
513 *x = Netem{}
514 if protoimpl.UnsafeEnabled {
515 mi := &file_chaosdaemon_proto_msgTypes[4]
516 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
517 ms.StoreMessageInfo(mi)
518 }
519 }
520
521 func (x *Netem) String() string {
522 return protoimpl.X.MessageStringOf(x)
523 }
524
525 func (*Netem) ProtoMessage() {}
526
527 func (x *Netem) ProtoReflect() protoreflect.Message {
528 mi := &file_chaosdaemon_proto_msgTypes[4]
529 if protoimpl.UnsafeEnabled && x != nil {
530 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
531 if ms.LoadMessageInfo() == nil {
532 ms.StoreMessageInfo(mi)
533 }
534 return ms
535 }
536 return mi.MessageOf(x)
537 }
538
539
540 func (*Netem) Descriptor() ([]byte, []int) {
541 return file_chaosdaemon_proto_rawDescGZIP(), []int{4}
542 }
543
544 func (x *Netem) GetTime() uint32 {
545 if x != nil {
546 return x.Time
547 }
548 return 0
549 }
550
551 func (x *Netem) GetJitter() uint32 {
552 if x != nil {
553 return x.Jitter
554 }
555 return 0
556 }
557
558 func (x *Netem) GetDelayCorr() float32 {
559 if x != nil {
560 return x.DelayCorr
561 }
562 return 0
563 }
564
565 func (x *Netem) GetLimit() uint32 {
566 if x != nil {
567 return x.Limit
568 }
569 return 0
570 }
571
572 func (x *Netem) GetLoss() float32 {
573 if x != nil {
574 return x.Loss
575 }
576 return 0
577 }
578
579 func (x *Netem) GetLossCorr() float32 {
580 if x != nil {
581 return x.LossCorr
582 }
583 return 0
584 }
585
586 func (x *Netem) GetGap() uint32 {
587 if x != nil {
588 return x.Gap
589 }
590 return 0
591 }
592
593 func (x *Netem) GetDuplicate() float32 {
594 if x != nil {
595 return x.Duplicate
596 }
597 return 0
598 }
599
600 func (x *Netem) GetDuplicateCorr() float32 {
601 if x != nil {
602 return x.DuplicateCorr
603 }
604 return 0
605 }
606
607 func (x *Netem) GetReorder() float32 {
608 if x != nil {
609 return x.Reorder
610 }
611 return 0
612 }
613
614 func (x *Netem) GetReorderCorr() float32 {
615 if x != nil {
616 return x.ReorderCorr
617 }
618 return 0
619 }
620
621 func (x *Netem) GetCorrupt() float32 {
622 if x != nil {
623 return x.Corrupt
624 }
625 return 0
626 }
627
628 func (x *Netem) GetCorruptCorr() float32 {
629 if x != nil {
630 return x.CorruptCorr
631 }
632 return 0
633 }
634
635 func (x *Netem) GetParent() *TcHandle {
636 if x != nil {
637 return x.Parent
638 }
639 return nil
640 }
641
642 func (x *Netem) GetHandle() *TcHandle {
643 if x != nil {
644 return x.Handle
645 }
646 return nil
647 }
648
649 func (x *Netem) GetRate() string {
650 if x != nil {
651 return x.Rate
652 }
653 return ""
654 }
655
656 type TbfRequest struct {
657 state protoimpl.MessageState
658 sizeCache protoimpl.SizeCache
659 unknownFields protoimpl.UnknownFields
660
661 Tbf *Tbf `protobuf:"bytes,1,opt,name=tbf,proto3" json:"tbf,omitempty"`
662 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
663 }
664
665 func (x *TbfRequest) Reset() {
666 *x = TbfRequest{}
667 if protoimpl.UnsafeEnabled {
668 mi := &file_chaosdaemon_proto_msgTypes[5]
669 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
670 ms.StoreMessageInfo(mi)
671 }
672 }
673
674 func (x *TbfRequest) String() string {
675 return protoimpl.X.MessageStringOf(x)
676 }
677
678 func (*TbfRequest) ProtoMessage() {}
679
680 func (x *TbfRequest) ProtoReflect() protoreflect.Message {
681 mi := &file_chaosdaemon_proto_msgTypes[5]
682 if protoimpl.UnsafeEnabled && x != nil {
683 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
684 if ms.LoadMessageInfo() == nil {
685 ms.StoreMessageInfo(mi)
686 }
687 return ms
688 }
689 return mi.MessageOf(x)
690 }
691
692
693 func (*TbfRequest) Descriptor() ([]byte, []int) {
694 return file_chaosdaemon_proto_rawDescGZIP(), []int{5}
695 }
696
697 func (x *TbfRequest) GetTbf() *Tbf {
698 if x != nil {
699 return x.Tbf
700 }
701 return nil
702 }
703
704 func (x *TbfRequest) GetContainerId() string {
705 if x != nil {
706 return x.ContainerId
707 }
708 return ""
709 }
710
711 type Tbf struct {
712 state protoimpl.MessageState
713 sizeCache protoimpl.SizeCache
714 unknownFields protoimpl.UnknownFields
715
716 Rate string `protobuf:"bytes,1,opt,name=rate,proto3" json:"rate,omitempty"`
717 Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
718 Buffer uint32 `protobuf:"varint,3,opt,name=buffer,proto3" json:"buffer,omitempty"`
719 PeakRate uint64 `protobuf:"varint,4,opt,name=peak_rate,json=peakRate,proto3" json:"peak_rate,omitempty"`
720 MinBurst uint32 `protobuf:"varint,5,opt,name=min_burst,json=minBurst,proto3" json:"min_burst,omitempty"`
721 }
722
723 func (x *Tbf) Reset() {
724 *x = Tbf{}
725 if protoimpl.UnsafeEnabled {
726 mi := &file_chaosdaemon_proto_msgTypes[6]
727 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
728 ms.StoreMessageInfo(mi)
729 }
730 }
731
732 func (x *Tbf) String() string {
733 return protoimpl.X.MessageStringOf(x)
734 }
735
736 func (*Tbf) ProtoMessage() {}
737
738 func (x *Tbf) ProtoReflect() protoreflect.Message {
739 mi := &file_chaosdaemon_proto_msgTypes[6]
740 if protoimpl.UnsafeEnabled && x != nil {
741 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
742 if ms.LoadMessageInfo() == nil {
743 ms.StoreMessageInfo(mi)
744 }
745 return ms
746 }
747 return mi.MessageOf(x)
748 }
749
750
751 func (*Tbf) Descriptor() ([]byte, []int) {
752 return file_chaosdaemon_proto_rawDescGZIP(), []int{6}
753 }
754
755 func (x *Tbf) GetRate() string {
756 if x != nil {
757 return x.Rate
758 }
759 return ""
760 }
761
762 func (x *Tbf) GetLimit() uint32 {
763 if x != nil {
764 return x.Limit
765 }
766 return 0
767 }
768
769 func (x *Tbf) GetBuffer() uint32 {
770 if x != nil {
771 return x.Buffer
772 }
773 return 0
774 }
775
776 func (x *Tbf) GetPeakRate() uint64 {
777 if x != nil {
778 return x.PeakRate
779 }
780 return 0
781 }
782
783 func (x *Tbf) GetMinBurst() uint32 {
784 if x != nil {
785 return x.MinBurst
786 }
787 return 0
788 }
789
790 type QdiscRequest struct {
791 state protoimpl.MessageState
792 sizeCache protoimpl.SizeCache
793 unknownFields protoimpl.UnknownFields
794
795 Qdisc *Qdisc `protobuf:"bytes,1,opt,name=qdisc,proto3" json:"qdisc,omitempty"`
796 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
797 }
798
799 func (x *QdiscRequest) Reset() {
800 *x = QdiscRequest{}
801 if protoimpl.UnsafeEnabled {
802 mi := &file_chaosdaemon_proto_msgTypes[7]
803 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
804 ms.StoreMessageInfo(mi)
805 }
806 }
807
808 func (x *QdiscRequest) String() string {
809 return protoimpl.X.MessageStringOf(x)
810 }
811
812 func (*QdiscRequest) ProtoMessage() {}
813
814 func (x *QdiscRequest) ProtoReflect() protoreflect.Message {
815 mi := &file_chaosdaemon_proto_msgTypes[7]
816 if protoimpl.UnsafeEnabled && x != nil {
817 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
818 if ms.LoadMessageInfo() == nil {
819 ms.StoreMessageInfo(mi)
820 }
821 return ms
822 }
823 return mi.MessageOf(x)
824 }
825
826
827 func (*QdiscRequest) Descriptor() ([]byte, []int) {
828 return file_chaosdaemon_proto_rawDescGZIP(), []int{7}
829 }
830
831 func (x *QdiscRequest) GetQdisc() *Qdisc {
832 if x != nil {
833 return x.Qdisc
834 }
835 return nil
836 }
837
838 func (x *QdiscRequest) GetContainerId() string {
839 if x != nil {
840 return x.ContainerId
841 }
842 return ""
843 }
844
845 type Qdisc struct {
846 state protoimpl.MessageState
847 sizeCache protoimpl.SizeCache
848 unknownFields protoimpl.UnknownFields
849
850 Parent *TcHandle `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
851 Handle *TcHandle `protobuf:"bytes,2,opt,name=handle,proto3" json:"handle,omitempty"`
852 Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
853 Args []string `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
854 }
855
856 func (x *Qdisc) Reset() {
857 *x = Qdisc{}
858 if protoimpl.UnsafeEnabled {
859 mi := &file_chaosdaemon_proto_msgTypes[8]
860 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
861 ms.StoreMessageInfo(mi)
862 }
863 }
864
865 func (x *Qdisc) String() string {
866 return protoimpl.X.MessageStringOf(x)
867 }
868
869 func (*Qdisc) ProtoMessage() {}
870
871 func (x *Qdisc) ProtoReflect() protoreflect.Message {
872 mi := &file_chaosdaemon_proto_msgTypes[8]
873 if protoimpl.UnsafeEnabled && x != nil {
874 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
875 if ms.LoadMessageInfo() == nil {
876 ms.StoreMessageInfo(mi)
877 }
878 return ms
879 }
880 return mi.MessageOf(x)
881 }
882
883
884 func (*Qdisc) Descriptor() ([]byte, []int) {
885 return file_chaosdaemon_proto_rawDescGZIP(), []int{8}
886 }
887
888 func (x *Qdisc) GetParent() *TcHandle {
889 if x != nil {
890 return x.Parent
891 }
892 return nil
893 }
894
895 func (x *Qdisc) GetHandle() *TcHandle {
896 if x != nil {
897 return x.Handle
898 }
899 return nil
900 }
901
902 func (x *Qdisc) GetType() string {
903 if x != nil {
904 return x.Type
905 }
906 return ""
907 }
908
909 func (x *Qdisc) GetArgs() []string {
910 if x != nil {
911 return x.Args
912 }
913 return nil
914 }
915
916 type EmatchFilterRequest struct {
917 state protoimpl.MessageState
918 sizeCache protoimpl.SizeCache
919 unknownFields protoimpl.UnknownFields
920
921 Filter *EmatchFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
922 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
923 }
924
925 func (x *EmatchFilterRequest) Reset() {
926 *x = EmatchFilterRequest{}
927 if protoimpl.UnsafeEnabled {
928 mi := &file_chaosdaemon_proto_msgTypes[9]
929 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
930 ms.StoreMessageInfo(mi)
931 }
932 }
933
934 func (x *EmatchFilterRequest) String() string {
935 return protoimpl.X.MessageStringOf(x)
936 }
937
938 func (*EmatchFilterRequest) ProtoMessage() {}
939
940 func (x *EmatchFilterRequest) ProtoReflect() protoreflect.Message {
941 mi := &file_chaosdaemon_proto_msgTypes[9]
942 if protoimpl.UnsafeEnabled && x != nil {
943 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
944 if ms.LoadMessageInfo() == nil {
945 ms.StoreMessageInfo(mi)
946 }
947 return ms
948 }
949 return mi.MessageOf(x)
950 }
951
952
953 func (*EmatchFilterRequest) Descriptor() ([]byte, []int) {
954 return file_chaosdaemon_proto_rawDescGZIP(), []int{9}
955 }
956
957 func (x *EmatchFilterRequest) GetFilter() *EmatchFilter {
958 if x != nil {
959 return x.Filter
960 }
961 return nil
962 }
963
964 func (x *EmatchFilterRequest) GetContainerId() string {
965 if x != nil {
966 return x.ContainerId
967 }
968 return ""
969 }
970
971 type EmatchFilter struct {
972 state protoimpl.MessageState
973 sizeCache protoimpl.SizeCache
974 unknownFields protoimpl.UnknownFields
975
976 Match string `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
977 Parent *TcHandle `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"`
978 Classid *TcHandle `protobuf:"bytes,3,opt,name=classid,proto3" json:"classid,omitempty"`
979 }
980
981 func (x *EmatchFilter) Reset() {
982 *x = EmatchFilter{}
983 if protoimpl.UnsafeEnabled {
984 mi := &file_chaosdaemon_proto_msgTypes[10]
985 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
986 ms.StoreMessageInfo(mi)
987 }
988 }
989
990 func (x *EmatchFilter) String() string {
991 return protoimpl.X.MessageStringOf(x)
992 }
993
994 func (*EmatchFilter) ProtoMessage() {}
995
996 func (x *EmatchFilter) ProtoReflect() protoreflect.Message {
997 mi := &file_chaosdaemon_proto_msgTypes[10]
998 if protoimpl.UnsafeEnabled && x != nil {
999 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1000 if ms.LoadMessageInfo() == nil {
1001 ms.StoreMessageInfo(mi)
1002 }
1003 return ms
1004 }
1005 return mi.MessageOf(x)
1006 }
1007
1008
1009 func (*EmatchFilter) Descriptor() ([]byte, []int) {
1010 return file_chaosdaemon_proto_rawDescGZIP(), []int{10}
1011 }
1012
1013 func (x *EmatchFilter) GetMatch() string {
1014 if x != nil {
1015 return x.Match
1016 }
1017 return ""
1018 }
1019
1020 func (x *EmatchFilter) GetParent() *TcHandle {
1021 if x != nil {
1022 return x.Parent
1023 }
1024 return nil
1025 }
1026
1027 func (x *EmatchFilter) GetClassid() *TcHandle {
1028 if x != nil {
1029 return x.Classid
1030 }
1031 return nil
1032 }
1033
1034 type TcFilterRequest struct {
1035 state protoimpl.MessageState
1036 sizeCache protoimpl.SizeCache
1037 unknownFields protoimpl.UnknownFields
1038
1039 Filter *TcFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
1040 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
1041 }
1042
1043 func (x *TcFilterRequest) Reset() {
1044 *x = TcFilterRequest{}
1045 if protoimpl.UnsafeEnabled {
1046 mi := &file_chaosdaemon_proto_msgTypes[11]
1047 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1048 ms.StoreMessageInfo(mi)
1049 }
1050 }
1051
1052 func (x *TcFilterRequest) String() string {
1053 return protoimpl.X.MessageStringOf(x)
1054 }
1055
1056 func (*TcFilterRequest) ProtoMessage() {}
1057
1058 func (x *TcFilterRequest) ProtoReflect() protoreflect.Message {
1059 mi := &file_chaosdaemon_proto_msgTypes[11]
1060 if protoimpl.UnsafeEnabled && x != nil {
1061 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1062 if ms.LoadMessageInfo() == nil {
1063 ms.StoreMessageInfo(mi)
1064 }
1065 return ms
1066 }
1067 return mi.MessageOf(x)
1068 }
1069
1070
1071 func (*TcFilterRequest) Descriptor() ([]byte, []int) {
1072 return file_chaosdaemon_proto_rawDescGZIP(), []int{11}
1073 }
1074
1075 func (x *TcFilterRequest) GetFilter() *TcFilter {
1076 if x != nil {
1077 return x.Filter
1078 }
1079 return nil
1080 }
1081
1082 func (x *TcFilterRequest) GetContainerId() string {
1083 if x != nil {
1084 return x.ContainerId
1085 }
1086 return ""
1087 }
1088
1089 type TcFilter struct {
1090 state protoimpl.MessageState
1091 sizeCache protoimpl.SizeCache
1092 unknownFields protoimpl.UnknownFields
1093
1094 Parent *TcHandle `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
1095 }
1096
1097 func (x *TcFilter) Reset() {
1098 *x = TcFilter{}
1099 if protoimpl.UnsafeEnabled {
1100 mi := &file_chaosdaemon_proto_msgTypes[12]
1101 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1102 ms.StoreMessageInfo(mi)
1103 }
1104 }
1105
1106 func (x *TcFilter) String() string {
1107 return protoimpl.X.MessageStringOf(x)
1108 }
1109
1110 func (*TcFilter) ProtoMessage() {}
1111
1112 func (x *TcFilter) ProtoReflect() protoreflect.Message {
1113 mi := &file_chaosdaemon_proto_msgTypes[12]
1114 if protoimpl.UnsafeEnabled && x != nil {
1115 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1116 if ms.LoadMessageInfo() == nil {
1117 ms.StoreMessageInfo(mi)
1118 }
1119 return ms
1120 }
1121 return mi.MessageOf(x)
1122 }
1123
1124
1125 func (*TcFilter) Descriptor() ([]byte, []int) {
1126 return file_chaosdaemon_proto_rawDescGZIP(), []int{12}
1127 }
1128
1129 func (x *TcFilter) GetParent() *TcHandle {
1130 if x != nil {
1131 return x.Parent
1132 }
1133 return nil
1134 }
1135
1136 type IPSetsRequest struct {
1137 state protoimpl.MessageState
1138 sizeCache protoimpl.SizeCache
1139 unknownFields protoimpl.UnknownFields
1140
1141 Ipsets []*IPSet `protobuf:"bytes,1,rep,name=ipsets,proto3" json:"ipsets,omitempty"`
1142 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
1143 EnterNS bool `protobuf:"varint,3,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
1144 }
1145
1146 func (x *IPSetsRequest) Reset() {
1147 *x = IPSetsRequest{}
1148 if protoimpl.UnsafeEnabled {
1149 mi := &file_chaosdaemon_proto_msgTypes[13]
1150 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1151 ms.StoreMessageInfo(mi)
1152 }
1153 }
1154
1155 func (x *IPSetsRequest) String() string {
1156 return protoimpl.X.MessageStringOf(x)
1157 }
1158
1159 func (*IPSetsRequest) ProtoMessage() {}
1160
1161 func (x *IPSetsRequest) ProtoReflect() protoreflect.Message {
1162 mi := &file_chaosdaemon_proto_msgTypes[13]
1163 if protoimpl.UnsafeEnabled && x != nil {
1164 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1165 if ms.LoadMessageInfo() == nil {
1166 ms.StoreMessageInfo(mi)
1167 }
1168 return ms
1169 }
1170 return mi.MessageOf(x)
1171 }
1172
1173
1174 func (*IPSetsRequest) Descriptor() ([]byte, []int) {
1175 return file_chaosdaemon_proto_rawDescGZIP(), []int{13}
1176 }
1177
1178 func (x *IPSetsRequest) GetIpsets() []*IPSet {
1179 if x != nil {
1180 return x.Ipsets
1181 }
1182 return nil
1183 }
1184
1185 func (x *IPSetsRequest) GetContainerId() string {
1186 if x != nil {
1187 return x.ContainerId
1188 }
1189 return ""
1190 }
1191
1192 func (x *IPSetsRequest) GetEnterNS() bool {
1193 if x != nil {
1194 return x.EnterNS
1195 }
1196 return false
1197 }
1198
1199 type IPSet struct {
1200 state protoimpl.MessageState
1201 sizeCache protoimpl.SizeCache
1202 unknownFields protoimpl.UnknownFields
1203
1204 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
1205 Cidrs []string `protobuf:"bytes,2,rep,name=cidrs,proto3" json:"cidrs,omitempty"`
1206 CidrAndPorts []*CidrAndPort `protobuf:"bytes,3,rep,name=cidr_and_ports,json=cidrAndPorts,proto3" json:"cidr_and_ports,omitempty"`
1207 SetNames []string `protobuf:"bytes,4,rep,name=set_names,json=setNames,proto3" json:"set_names,omitempty"`
1208 Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"`
1209 }
1210
1211 func (x *IPSet) Reset() {
1212 *x = IPSet{}
1213 if protoimpl.UnsafeEnabled {
1214 mi := &file_chaosdaemon_proto_msgTypes[14]
1215 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1216 ms.StoreMessageInfo(mi)
1217 }
1218 }
1219
1220 func (x *IPSet) String() string {
1221 return protoimpl.X.MessageStringOf(x)
1222 }
1223
1224 func (*IPSet) ProtoMessage() {}
1225
1226 func (x *IPSet) ProtoReflect() protoreflect.Message {
1227 mi := &file_chaosdaemon_proto_msgTypes[14]
1228 if protoimpl.UnsafeEnabled && x != nil {
1229 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1230 if ms.LoadMessageInfo() == nil {
1231 ms.StoreMessageInfo(mi)
1232 }
1233 return ms
1234 }
1235 return mi.MessageOf(x)
1236 }
1237
1238
1239 func (*IPSet) Descriptor() ([]byte, []int) {
1240 return file_chaosdaemon_proto_rawDescGZIP(), []int{14}
1241 }
1242
1243 func (x *IPSet) GetName() string {
1244 if x != nil {
1245 return x.Name
1246 }
1247 return ""
1248 }
1249
1250 func (x *IPSet) GetCidrs() []string {
1251 if x != nil {
1252 return x.Cidrs
1253 }
1254 return nil
1255 }
1256
1257 func (x *IPSet) GetCidrAndPorts() []*CidrAndPort {
1258 if x != nil {
1259 return x.CidrAndPorts
1260 }
1261 return nil
1262 }
1263
1264 func (x *IPSet) GetSetNames() []string {
1265 if x != nil {
1266 return x.SetNames
1267 }
1268 return nil
1269 }
1270
1271 func (x *IPSet) GetType() string {
1272 if x != nil {
1273 return x.Type
1274 }
1275 return ""
1276 }
1277
1278 type CidrAndPort struct {
1279 state protoimpl.MessageState
1280 sizeCache protoimpl.SizeCache
1281 unknownFields protoimpl.UnknownFields
1282
1283 Cidr string `protobuf:"bytes,1,opt,name=cidr,proto3" json:"cidr,omitempty"`
1284 Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
1285 }
1286
1287 func (x *CidrAndPort) Reset() {
1288 *x = CidrAndPort{}
1289 if protoimpl.UnsafeEnabled {
1290 mi := &file_chaosdaemon_proto_msgTypes[15]
1291 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1292 ms.StoreMessageInfo(mi)
1293 }
1294 }
1295
1296 func (x *CidrAndPort) String() string {
1297 return protoimpl.X.MessageStringOf(x)
1298 }
1299
1300 func (*CidrAndPort) ProtoMessage() {}
1301
1302 func (x *CidrAndPort) ProtoReflect() protoreflect.Message {
1303 mi := &file_chaosdaemon_proto_msgTypes[15]
1304 if protoimpl.UnsafeEnabled && x != nil {
1305 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1306 if ms.LoadMessageInfo() == nil {
1307 ms.StoreMessageInfo(mi)
1308 }
1309 return ms
1310 }
1311 return mi.MessageOf(x)
1312 }
1313
1314
1315 func (*CidrAndPort) Descriptor() ([]byte, []int) {
1316 return file_chaosdaemon_proto_rawDescGZIP(), []int{15}
1317 }
1318
1319 func (x *CidrAndPort) GetCidr() string {
1320 if x != nil {
1321 return x.Cidr
1322 }
1323 return ""
1324 }
1325
1326 func (x *CidrAndPort) GetPort() uint32 {
1327 if x != nil {
1328 return x.Port
1329 }
1330 return 0
1331 }
1332
1333 type IptablesChainsRequest struct {
1334 state protoimpl.MessageState
1335 sizeCache protoimpl.SizeCache
1336 unknownFields protoimpl.UnknownFields
1337
1338 Chains []*Chain `protobuf:"bytes,1,rep,name=chains,proto3" json:"chains,omitempty"`
1339 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
1340 EnterNS bool `protobuf:"varint,3,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
1341 }
1342
1343 func (x *IptablesChainsRequest) Reset() {
1344 *x = IptablesChainsRequest{}
1345 if protoimpl.UnsafeEnabled {
1346 mi := &file_chaosdaemon_proto_msgTypes[16]
1347 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1348 ms.StoreMessageInfo(mi)
1349 }
1350 }
1351
1352 func (x *IptablesChainsRequest) String() string {
1353 return protoimpl.X.MessageStringOf(x)
1354 }
1355
1356 func (*IptablesChainsRequest) ProtoMessage() {}
1357
1358 func (x *IptablesChainsRequest) ProtoReflect() protoreflect.Message {
1359 mi := &file_chaosdaemon_proto_msgTypes[16]
1360 if protoimpl.UnsafeEnabled && x != nil {
1361 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1362 if ms.LoadMessageInfo() == nil {
1363 ms.StoreMessageInfo(mi)
1364 }
1365 return ms
1366 }
1367 return mi.MessageOf(x)
1368 }
1369
1370
1371 func (*IptablesChainsRequest) Descriptor() ([]byte, []int) {
1372 return file_chaosdaemon_proto_rawDescGZIP(), []int{16}
1373 }
1374
1375 func (x *IptablesChainsRequest) GetChains() []*Chain {
1376 if x != nil {
1377 return x.Chains
1378 }
1379 return nil
1380 }
1381
1382 func (x *IptablesChainsRequest) GetContainerId() string {
1383 if x != nil {
1384 return x.ContainerId
1385 }
1386 return ""
1387 }
1388
1389 func (x *IptablesChainsRequest) GetEnterNS() bool {
1390 if x != nil {
1391 return x.EnterNS
1392 }
1393 return false
1394 }
1395
1396 type Chain struct {
1397 state protoimpl.MessageState
1398 sizeCache protoimpl.SizeCache
1399 unknownFields protoimpl.UnknownFields
1400
1401 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
1402 Direction Chain_Direction `protobuf:"varint,2,opt,name=direction,proto3,enum=pb.Chain_Direction" json:"direction,omitempty"`
1403 Ipsets []string `protobuf:"bytes,3,rep,name=ipsets,proto3" json:"ipsets,omitempty"`
1404 Target string `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"`
1405 Protocol string `protobuf:"bytes,5,opt,name=protocol,proto3" json:"protocol,omitempty"`
1406 SourcePorts string `protobuf:"bytes,6,opt,name=source_ports,json=sourcePorts,proto3" json:"source_ports,omitempty"`
1407 DestinationPorts string `protobuf:"bytes,7,opt,name=destination_ports,json=destinationPorts,proto3" json:"destination_ports,omitempty"`
1408 TcpFlags string `protobuf:"bytes,8,opt,name=tcp_flags,json=tcpFlags,proto3" json:"tcp_flags,omitempty"`
1409 Device string `protobuf:"bytes,9,opt,name=device,proto3" json:"device,omitempty"`
1410 }
1411
1412 func (x *Chain) Reset() {
1413 *x = Chain{}
1414 if protoimpl.UnsafeEnabled {
1415 mi := &file_chaosdaemon_proto_msgTypes[17]
1416 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1417 ms.StoreMessageInfo(mi)
1418 }
1419 }
1420
1421 func (x *Chain) String() string {
1422 return protoimpl.X.MessageStringOf(x)
1423 }
1424
1425 func (*Chain) ProtoMessage() {}
1426
1427 func (x *Chain) ProtoReflect() protoreflect.Message {
1428 mi := &file_chaosdaemon_proto_msgTypes[17]
1429 if protoimpl.UnsafeEnabled && x != nil {
1430 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1431 if ms.LoadMessageInfo() == nil {
1432 ms.StoreMessageInfo(mi)
1433 }
1434 return ms
1435 }
1436 return mi.MessageOf(x)
1437 }
1438
1439
1440 func (*Chain) Descriptor() ([]byte, []int) {
1441 return file_chaosdaemon_proto_rawDescGZIP(), []int{17}
1442 }
1443
1444 func (x *Chain) GetName() string {
1445 if x != nil {
1446 return x.Name
1447 }
1448 return ""
1449 }
1450
1451 func (x *Chain) GetDirection() Chain_Direction {
1452 if x != nil {
1453 return x.Direction
1454 }
1455 return Chain_INPUT
1456 }
1457
1458 func (x *Chain) GetIpsets() []string {
1459 if x != nil {
1460 return x.Ipsets
1461 }
1462 return nil
1463 }
1464
1465 func (x *Chain) GetTarget() string {
1466 if x != nil {
1467 return x.Target
1468 }
1469 return ""
1470 }
1471
1472 func (x *Chain) GetProtocol() string {
1473 if x != nil {
1474 return x.Protocol
1475 }
1476 return ""
1477 }
1478
1479 func (x *Chain) GetSourcePorts() string {
1480 if x != nil {
1481 return x.SourcePorts
1482 }
1483 return ""
1484 }
1485
1486 func (x *Chain) GetDestinationPorts() string {
1487 if x != nil {
1488 return x.DestinationPorts
1489 }
1490 return ""
1491 }
1492
1493 func (x *Chain) GetTcpFlags() string {
1494 if x != nil {
1495 return x.TcpFlags
1496 }
1497 return ""
1498 }
1499
1500 func (x *Chain) GetDevice() string {
1501 if x != nil {
1502 return x.Device
1503 }
1504 return ""
1505 }
1506
1507 type TimeRequest struct {
1508 state protoimpl.MessageState
1509 sizeCache protoimpl.SizeCache
1510 unknownFields protoimpl.UnknownFields
1511
1512 ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
1513 Sec int64 `protobuf:"varint,2,opt,name=sec,proto3" json:"sec,omitempty"`
1514 Nsec int64 `protobuf:"varint,3,opt,name=nsec,proto3" json:"nsec,omitempty"`
1515 ClkIdsMask uint64 `protobuf:"varint,4,opt,name=clk_ids_mask,json=clkIdsMask,proto3" json:"clk_ids_mask,omitempty"`
1516 Uid string `protobuf:"bytes,5,opt,name=uid,proto3" json:"uid,omitempty"`
1517 PodContainerName string `protobuf:"bytes,6,opt,name=pod_container_name,json=podContainerName,proto3" json:"pod_container_name,omitempty"`
1518 }
1519
1520 func (x *TimeRequest) Reset() {
1521 *x = TimeRequest{}
1522 if protoimpl.UnsafeEnabled {
1523 mi := &file_chaosdaemon_proto_msgTypes[18]
1524 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1525 ms.StoreMessageInfo(mi)
1526 }
1527 }
1528
1529 func (x *TimeRequest) String() string {
1530 return protoimpl.X.MessageStringOf(x)
1531 }
1532
1533 func (*TimeRequest) ProtoMessage() {}
1534
1535 func (x *TimeRequest) ProtoReflect() protoreflect.Message {
1536 mi := &file_chaosdaemon_proto_msgTypes[18]
1537 if protoimpl.UnsafeEnabled && x != nil {
1538 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1539 if ms.LoadMessageInfo() == nil {
1540 ms.StoreMessageInfo(mi)
1541 }
1542 return ms
1543 }
1544 return mi.MessageOf(x)
1545 }
1546
1547
1548 func (*TimeRequest) Descriptor() ([]byte, []int) {
1549 return file_chaosdaemon_proto_rawDescGZIP(), []int{18}
1550 }
1551
1552 func (x *TimeRequest) GetContainerId() string {
1553 if x != nil {
1554 return x.ContainerId
1555 }
1556 return ""
1557 }
1558
1559 func (x *TimeRequest) GetSec() int64 {
1560 if x != nil {
1561 return x.Sec
1562 }
1563 return 0
1564 }
1565
1566 func (x *TimeRequest) GetNsec() int64 {
1567 if x != nil {
1568 return x.Nsec
1569 }
1570 return 0
1571 }
1572
1573 func (x *TimeRequest) GetClkIdsMask() uint64 {
1574 if x != nil {
1575 return x.ClkIdsMask
1576 }
1577 return 0
1578 }
1579
1580 func (x *TimeRequest) GetUid() string {
1581 if x != nil {
1582 return x.Uid
1583 }
1584 return ""
1585 }
1586
1587 func (x *TimeRequest) GetPodContainerName() string {
1588 if x != nil {
1589 return x.PodContainerName
1590 }
1591 return ""
1592 }
1593
1594 type ContainerAction struct {
1595 state protoimpl.MessageState
1596 sizeCache protoimpl.SizeCache
1597 unknownFields protoimpl.UnknownFields
1598
1599 Action ContainerAction_Action `protobuf:"varint,1,opt,name=action,proto3,enum=pb.ContainerAction_Action" json:"action,omitempty"`
1600 }
1601
1602 func (x *ContainerAction) Reset() {
1603 *x = ContainerAction{}
1604 if protoimpl.UnsafeEnabled {
1605 mi := &file_chaosdaemon_proto_msgTypes[19]
1606 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1607 ms.StoreMessageInfo(mi)
1608 }
1609 }
1610
1611 func (x *ContainerAction) String() string {
1612 return protoimpl.X.MessageStringOf(x)
1613 }
1614
1615 func (*ContainerAction) ProtoMessage() {}
1616
1617 func (x *ContainerAction) ProtoReflect() protoreflect.Message {
1618 mi := &file_chaosdaemon_proto_msgTypes[19]
1619 if protoimpl.UnsafeEnabled && x != nil {
1620 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1621 if ms.LoadMessageInfo() == nil {
1622 ms.StoreMessageInfo(mi)
1623 }
1624 return ms
1625 }
1626 return mi.MessageOf(x)
1627 }
1628
1629
1630 func (*ContainerAction) Descriptor() ([]byte, []int) {
1631 return file_chaosdaemon_proto_rawDescGZIP(), []int{19}
1632 }
1633
1634 func (x *ContainerAction) GetAction() ContainerAction_Action {
1635 if x != nil {
1636 return x.Action
1637 }
1638 return ContainerAction_KILL
1639 }
1640
1641 type ExecStressRequest struct {
1642 state protoimpl.MessageState
1643 sizeCache protoimpl.SizeCache
1644 unknownFields protoimpl.UnknownFields
1645
1646 Scope ExecStressRequest_Scope `protobuf:"varint,1,opt,name=scope,proto3,enum=pb.ExecStressRequest_Scope" json:"scope,omitempty"`
1647 Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
1648 CpuStressors string `protobuf:"bytes,3,opt,name=cpuStressors,proto3" json:"cpuStressors,omitempty"`
1649 EnterNS bool `protobuf:"varint,4,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
1650 MemoryStressors string `protobuf:"bytes,5,opt,name=memoryStressors,proto3" json:"memoryStressors,omitempty"`
1651 OomScoreAdj int32 `protobuf:"varint,7,opt,name=oomScoreAdj,proto3" json:"oomScoreAdj,omitempty"`
1652 }
1653
1654 func (x *ExecStressRequest) Reset() {
1655 *x = ExecStressRequest{}
1656 if protoimpl.UnsafeEnabled {
1657 mi := &file_chaosdaemon_proto_msgTypes[20]
1658 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1659 ms.StoreMessageInfo(mi)
1660 }
1661 }
1662
1663 func (x *ExecStressRequest) String() string {
1664 return protoimpl.X.MessageStringOf(x)
1665 }
1666
1667 func (*ExecStressRequest) ProtoMessage() {}
1668
1669 func (x *ExecStressRequest) ProtoReflect() protoreflect.Message {
1670 mi := &file_chaosdaemon_proto_msgTypes[20]
1671 if protoimpl.UnsafeEnabled && x != nil {
1672 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1673 if ms.LoadMessageInfo() == nil {
1674 ms.StoreMessageInfo(mi)
1675 }
1676 return ms
1677 }
1678 return mi.MessageOf(x)
1679 }
1680
1681
1682 func (*ExecStressRequest) Descriptor() ([]byte, []int) {
1683 return file_chaosdaemon_proto_rawDescGZIP(), []int{20}
1684 }
1685
1686 func (x *ExecStressRequest) GetScope() ExecStressRequest_Scope {
1687 if x != nil {
1688 return x.Scope
1689 }
1690 return ExecStressRequest_CONTAINER
1691 }
1692
1693 func (x *ExecStressRequest) GetTarget() string {
1694 if x != nil {
1695 return x.Target
1696 }
1697 return ""
1698 }
1699
1700 func (x *ExecStressRequest) GetCpuStressors() string {
1701 if x != nil {
1702 return x.CpuStressors
1703 }
1704 return ""
1705 }
1706
1707 func (x *ExecStressRequest) GetEnterNS() bool {
1708 if x != nil {
1709 return x.EnterNS
1710 }
1711 return false
1712 }
1713
1714 func (x *ExecStressRequest) GetMemoryStressors() string {
1715 if x != nil {
1716 return x.MemoryStressors
1717 }
1718 return ""
1719 }
1720
1721 func (x *ExecStressRequest) GetOomScoreAdj() int32 {
1722 if x != nil {
1723 return x.OomScoreAdj
1724 }
1725 return 0
1726 }
1727
1728 type ExecStressResponse struct {
1729 state protoimpl.MessageState
1730 sizeCache protoimpl.SizeCache
1731 unknownFields protoimpl.UnknownFields
1732
1733 CpuInstance string `protobuf:"bytes,1,opt,name=cpuInstance,proto3" json:"cpuInstance,omitempty"`
1734 CpuStartTime int64 `protobuf:"varint,2,opt,name=cpuStartTime,proto3" json:"cpuStartTime,omitempty"`
1735 MemoryInstance string `protobuf:"bytes,3,opt,name=memoryInstance,proto3" json:"memoryInstance,omitempty"`
1736 MemoryStartTime int64 `protobuf:"varint,4,opt,name=memoryStartTime,proto3" json:"memoryStartTime,omitempty"`
1737 CpuInstanceUid string `protobuf:"bytes,5,opt,name=cpuInstanceUid,proto3" json:"cpuInstanceUid,omitempty"`
1738 MemoryInstanceUid string `protobuf:"bytes,6,opt,name=memoryInstanceUid,proto3" json:"memoryInstanceUid,omitempty"`
1739 }
1740
1741 func (x *ExecStressResponse) Reset() {
1742 *x = ExecStressResponse{}
1743 if protoimpl.UnsafeEnabled {
1744 mi := &file_chaosdaemon_proto_msgTypes[21]
1745 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1746 ms.StoreMessageInfo(mi)
1747 }
1748 }
1749
1750 func (x *ExecStressResponse) String() string {
1751 return protoimpl.X.MessageStringOf(x)
1752 }
1753
1754 func (*ExecStressResponse) ProtoMessage() {}
1755
1756 func (x *ExecStressResponse) ProtoReflect() protoreflect.Message {
1757 mi := &file_chaosdaemon_proto_msgTypes[21]
1758 if protoimpl.UnsafeEnabled && x != nil {
1759 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1760 if ms.LoadMessageInfo() == nil {
1761 ms.StoreMessageInfo(mi)
1762 }
1763 return ms
1764 }
1765 return mi.MessageOf(x)
1766 }
1767
1768
1769 func (*ExecStressResponse) Descriptor() ([]byte, []int) {
1770 return file_chaosdaemon_proto_rawDescGZIP(), []int{21}
1771 }
1772
1773 func (x *ExecStressResponse) GetCpuInstance() string {
1774 if x != nil {
1775 return x.CpuInstance
1776 }
1777 return ""
1778 }
1779
1780 func (x *ExecStressResponse) GetCpuStartTime() int64 {
1781 if x != nil {
1782 return x.CpuStartTime
1783 }
1784 return 0
1785 }
1786
1787 func (x *ExecStressResponse) GetMemoryInstance() string {
1788 if x != nil {
1789 return x.MemoryInstance
1790 }
1791 return ""
1792 }
1793
1794 func (x *ExecStressResponse) GetMemoryStartTime() int64 {
1795 if x != nil {
1796 return x.MemoryStartTime
1797 }
1798 return 0
1799 }
1800
1801 func (x *ExecStressResponse) GetCpuInstanceUid() string {
1802 if x != nil {
1803 return x.CpuInstanceUid
1804 }
1805 return ""
1806 }
1807
1808 func (x *ExecStressResponse) GetMemoryInstanceUid() string {
1809 if x != nil {
1810 return x.MemoryInstanceUid
1811 }
1812 return ""
1813 }
1814
1815 type CancelStressRequest struct {
1816 state protoimpl.MessageState
1817 sizeCache protoimpl.SizeCache
1818 unknownFields protoimpl.UnknownFields
1819
1820 CpuInstance string `protobuf:"bytes,1,opt,name=cpuInstance,proto3" json:"cpuInstance,omitempty"`
1821 CpuStartTime int64 `protobuf:"varint,2,opt,name=cpuStartTime,proto3" json:"cpuStartTime,omitempty"`
1822 MemoryInstance string `protobuf:"bytes,3,opt,name=memoryInstance,proto3" json:"memoryInstance,omitempty"`
1823 MemoryStartTime int64 `protobuf:"varint,4,opt,name=memoryStartTime,proto3" json:"memoryStartTime,omitempty"`
1824 CpuInstanceUid string `protobuf:"bytes,5,opt,name=cpuInstanceUid,proto3" json:"cpuInstanceUid,omitempty"`
1825 MemoryInstanceUid string `protobuf:"bytes,6,opt,name=memoryInstanceUid,proto3" json:"memoryInstanceUid,omitempty"`
1826 }
1827
1828 func (x *CancelStressRequest) Reset() {
1829 *x = CancelStressRequest{}
1830 if protoimpl.UnsafeEnabled {
1831 mi := &file_chaosdaemon_proto_msgTypes[22]
1832 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1833 ms.StoreMessageInfo(mi)
1834 }
1835 }
1836
1837 func (x *CancelStressRequest) String() string {
1838 return protoimpl.X.MessageStringOf(x)
1839 }
1840
1841 func (*CancelStressRequest) ProtoMessage() {}
1842
1843 func (x *CancelStressRequest) ProtoReflect() protoreflect.Message {
1844 mi := &file_chaosdaemon_proto_msgTypes[22]
1845 if protoimpl.UnsafeEnabled && x != nil {
1846 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1847 if ms.LoadMessageInfo() == nil {
1848 ms.StoreMessageInfo(mi)
1849 }
1850 return ms
1851 }
1852 return mi.MessageOf(x)
1853 }
1854
1855
1856 func (*CancelStressRequest) Descriptor() ([]byte, []int) {
1857 return file_chaosdaemon_proto_rawDescGZIP(), []int{22}
1858 }
1859
1860 func (x *CancelStressRequest) GetCpuInstance() string {
1861 if x != nil {
1862 return x.CpuInstance
1863 }
1864 return ""
1865 }
1866
1867 func (x *CancelStressRequest) GetCpuStartTime() int64 {
1868 if x != nil {
1869 return x.CpuStartTime
1870 }
1871 return 0
1872 }
1873
1874 func (x *CancelStressRequest) GetMemoryInstance() string {
1875 if x != nil {
1876 return x.MemoryInstance
1877 }
1878 return ""
1879 }
1880
1881 func (x *CancelStressRequest) GetMemoryStartTime() int64 {
1882 if x != nil {
1883 return x.MemoryStartTime
1884 }
1885 return 0
1886 }
1887
1888 func (x *CancelStressRequest) GetCpuInstanceUid() string {
1889 if x != nil {
1890 return x.CpuInstanceUid
1891 }
1892 return ""
1893 }
1894
1895 func (x *CancelStressRequest) GetMemoryInstanceUid() string {
1896 if x != nil {
1897 return x.MemoryInstanceUid
1898 }
1899 return ""
1900 }
1901
1902 type ApplyIOChaosRequest struct {
1903 state protoimpl.MessageState
1904 sizeCache protoimpl.SizeCache
1905 unknownFields protoimpl.UnknownFields
1906
1907 Actions string `protobuf:"bytes,1,opt,name=actions,proto3" json:"actions,omitempty"`
1908 Volume string `protobuf:"bytes,2,opt,name=volume,proto3" json:"volume,omitempty"`
1909 ContainerId string `protobuf:"bytes,3,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
1910 Instance int64 `protobuf:"varint,4,opt,name=instance,proto3" json:"instance,omitempty"`
1911 StartTime int64 `protobuf:"varint,5,opt,name=startTime,proto3" json:"startTime,omitempty"`
1912 EnterNS bool `protobuf:"varint,6,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
1913 InstanceUid string `protobuf:"bytes,7,opt,name=instance_uid,json=instanceUid,proto3" json:"instance_uid,omitempty"`
1914 }
1915
1916 func (x *ApplyIOChaosRequest) Reset() {
1917 *x = ApplyIOChaosRequest{}
1918 if protoimpl.UnsafeEnabled {
1919 mi := &file_chaosdaemon_proto_msgTypes[23]
1920 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1921 ms.StoreMessageInfo(mi)
1922 }
1923 }
1924
1925 func (x *ApplyIOChaosRequest) String() string {
1926 return protoimpl.X.MessageStringOf(x)
1927 }
1928
1929 func (*ApplyIOChaosRequest) ProtoMessage() {}
1930
1931 func (x *ApplyIOChaosRequest) ProtoReflect() protoreflect.Message {
1932 mi := &file_chaosdaemon_proto_msgTypes[23]
1933 if protoimpl.UnsafeEnabled && x != nil {
1934 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1935 if ms.LoadMessageInfo() == nil {
1936 ms.StoreMessageInfo(mi)
1937 }
1938 return ms
1939 }
1940 return mi.MessageOf(x)
1941 }
1942
1943
1944 func (*ApplyIOChaosRequest) Descriptor() ([]byte, []int) {
1945 return file_chaosdaemon_proto_rawDescGZIP(), []int{23}
1946 }
1947
1948 func (x *ApplyIOChaosRequest) GetActions() string {
1949 if x != nil {
1950 return x.Actions
1951 }
1952 return ""
1953 }
1954
1955 func (x *ApplyIOChaosRequest) GetVolume() string {
1956 if x != nil {
1957 return x.Volume
1958 }
1959 return ""
1960 }
1961
1962 func (x *ApplyIOChaosRequest) GetContainerId() string {
1963 if x != nil {
1964 return x.ContainerId
1965 }
1966 return ""
1967 }
1968
1969 func (x *ApplyIOChaosRequest) GetInstance() int64 {
1970 if x != nil {
1971 return x.Instance
1972 }
1973 return 0
1974 }
1975
1976 func (x *ApplyIOChaosRequest) GetStartTime() int64 {
1977 if x != nil {
1978 return x.StartTime
1979 }
1980 return 0
1981 }
1982
1983 func (x *ApplyIOChaosRequest) GetEnterNS() bool {
1984 if x != nil {
1985 return x.EnterNS
1986 }
1987 return false
1988 }
1989
1990 func (x *ApplyIOChaosRequest) GetInstanceUid() string {
1991 if x != nil {
1992 return x.InstanceUid
1993 }
1994 return ""
1995 }
1996
1997 type ApplyIOChaosResponse struct {
1998 state protoimpl.MessageState
1999 sizeCache protoimpl.SizeCache
2000 unknownFields protoimpl.UnknownFields
2001
2002 Instance int64 `protobuf:"varint,1,opt,name=instance,proto3" json:"instance,omitempty"`
2003 StartTime int64 `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
2004 InstanceUid string `protobuf:"bytes,3,opt,name=instance_uid,json=instanceUid,proto3" json:"instance_uid,omitempty"`
2005 }
2006
2007 func (x *ApplyIOChaosResponse) Reset() {
2008 *x = ApplyIOChaosResponse{}
2009 if protoimpl.UnsafeEnabled {
2010 mi := &file_chaosdaemon_proto_msgTypes[24]
2011 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2012 ms.StoreMessageInfo(mi)
2013 }
2014 }
2015
2016 func (x *ApplyIOChaosResponse) String() string {
2017 return protoimpl.X.MessageStringOf(x)
2018 }
2019
2020 func (*ApplyIOChaosResponse) ProtoMessage() {}
2021
2022 func (x *ApplyIOChaosResponse) ProtoReflect() protoreflect.Message {
2023 mi := &file_chaosdaemon_proto_msgTypes[24]
2024 if protoimpl.UnsafeEnabled && x != nil {
2025 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2026 if ms.LoadMessageInfo() == nil {
2027 ms.StoreMessageInfo(mi)
2028 }
2029 return ms
2030 }
2031 return mi.MessageOf(x)
2032 }
2033
2034
2035 func (*ApplyIOChaosResponse) Descriptor() ([]byte, []int) {
2036 return file_chaosdaemon_proto_rawDescGZIP(), []int{24}
2037 }
2038
2039 func (x *ApplyIOChaosResponse) GetInstance() int64 {
2040 if x != nil {
2041 return x.Instance
2042 }
2043 return 0
2044 }
2045
2046 func (x *ApplyIOChaosResponse) GetStartTime() int64 {
2047 if x != nil {
2048 return x.StartTime
2049 }
2050 return 0
2051 }
2052
2053 func (x *ApplyIOChaosResponse) GetInstanceUid() string {
2054 if x != nil {
2055 return x.InstanceUid
2056 }
2057 return ""
2058 }
2059
2060 type ApplyHttpChaosRequest struct {
2061 state protoimpl.MessageState
2062 sizeCache protoimpl.SizeCache
2063 unknownFields protoimpl.UnknownFields
2064
2065 Rules string `protobuf:"bytes,1,opt,name=rules,proto3" json:"rules,omitempty"`
2066 ProxyPorts []uint32 `protobuf:"varint,2,rep,packed,name=proxy_ports,json=proxyPorts,proto3" json:"proxy_ports,omitempty"`
2067 ContainerId string `protobuf:"bytes,3,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
2068 Instance int64 `protobuf:"varint,4,opt,name=instance,proto3" json:"instance,omitempty"`
2069 StartTime int64 `protobuf:"varint,5,opt,name=startTime,proto3" json:"startTime,omitempty"`
2070 EnterNS bool `protobuf:"varint,6,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
2071 InstanceUid string `protobuf:"bytes,7,opt,name=instance_uid,json=instanceUid,proto3" json:"instance_uid,omitempty"`
2072 Tls string `protobuf:"bytes,8,opt,name=tls,proto3" json:"tls,omitempty"`
2073 }
2074
2075 func (x *ApplyHttpChaosRequest) Reset() {
2076 *x = ApplyHttpChaosRequest{}
2077 if protoimpl.UnsafeEnabled {
2078 mi := &file_chaosdaemon_proto_msgTypes[25]
2079 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2080 ms.StoreMessageInfo(mi)
2081 }
2082 }
2083
2084 func (x *ApplyHttpChaosRequest) String() string {
2085 return protoimpl.X.MessageStringOf(x)
2086 }
2087
2088 func (*ApplyHttpChaosRequest) ProtoMessage() {}
2089
2090 func (x *ApplyHttpChaosRequest) ProtoReflect() protoreflect.Message {
2091 mi := &file_chaosdaemon_proto_msgTypes[25]
2092 if protoimpl.UnsafeEnabled && x != nil {
2093 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2094 if ms.LoadMessageInfo() == nil {
2095 ms.StoreMessageInfo(mi)
2096 }
2097 return ms
2098 }
2099 return mi.MessageOf(x)
2100 }
2101
2102
2103 func (*ApplyHttpChaosRequest) Descriptor() ([]byte, []int) {
2104 return file_chaosdaemon_proto_rawDescGZIP(), []int{25}
2105 }
2106
2107 func (x *ApplyHttpChaosRequest) GetRules() string {
2108 if x != nil {
2109 return x.Rules
2110 }
2111 return ""
2112 }
2113
2114 func (x *ApplyHttpChaosRequest) GetProxyPorts() []uint32 {
2115 if x != nil {
2116 return x.ProxyPorts
2117 }
2118 return nil
2119 }
2120
2121 func (x *ApplyHttpChaosRequest) GetContainerId() string {
2122 if x != nil {
2123 return x.ContainerId
2124 }
2125 return ""
2126 }
2127
2128 func (x *ApplyHttpChaosRequest) GetInstance() int64 {
2129 if x != nil {
2130 return x.Instance
2131 }
2132 return 0
2133 }
2134
2135 func (x *ApplyHttpChaosRequest) GetStartTime() int64 {
2136 if x != nil {
2137 return x.StartTime
2138 }
2139 return 0
2140 }
2141
2142 func (x *ApplyHttpChaosRequest) GetEnterNS() bool {
2143 if x != nil {
2144 return x.EnterNS
2145 }
2146 return false
2147 }
2148
2149 func (x *ApplyHttpChaosRequest) GetInstanceUid() string {
2150 if x != nil {
2151 return x.InstanceUid
2152 }
2153 return ""
2154 }
2155
2156 func (x *ApplyHttpChaosRequest) GetTls() string {
2157 if x != nil {
2158 return x.Tls
2159 }
2160 return ""
2161 }
2162
2163 type ApplyHttpChaosResponse struct {
2164 state protoimpl.MessageState
2165 sizeCache protoimpl.SizeCache
2166 unknownFields protoimpl.UnknownFields
2167
2168 Instance int64 `protobuf:"varint,1,opt,name=instance,proto3" json:"instance,omitempty"`
2169 StartTime int64 `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
2170 StatusCode int32 `protobuf:"varint,3,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
2171 Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
2172 InstanceUid string `protobuf:"bytes,5,opt,name=instance_uid,json=instanceUid,proto3" json:"instance_uid,omitempty"`
2173 }
2174
2175 func (x *ApplyHttpChaosResponse) Reset() {
2176 *x = ApplyHttpChaosResponse{}
2177 if protoimpl.UnsafeEnabled {
2178 mi := &file_chaosdaemon_proto_msgTypes[26]
2179 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2180 ms.StoreMessageInfo(mi)
2181 }
2182 }
2183
2184 func (x *ApplyHttpChaosResponse) String() string {
2185 return protoimpl.X.MessageStringOf(x)
2186 }
2187
2188 func (*ApplyHttpChaosResponse) ProtoMessage() {}
2189
2190 func (x *ApplyHttpChaosResponse) ProtoReflect() protoreflect.Message {
2191 mi := &file_chaosdaemon_proto_msgTypes[26]
2192 if protoimpl.UnsafeEnabled && x != nil {
2193 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2194 if ms.LoadMessageInfo() == nil {
2195 ms.StoreMessageInfo(mi)
2196 }
2197 return ms
2198 }
2199 return mi.MessageOf(x)
2200 }
2201
2202
2203 func (*ApplyHttpChaosResponse) Descriptor() ([]byte, []int) {
2204 return file_chaosdaemon_proto_rawDescGZIP(), []int{26}
2205 }
2206
2207 func (x *ApplyHttpChaosResponse) GetInstance() int64 {
2208 if x != nil {
2209 return x.Instance
2210 }
2211 return 0
2212 }
2213
2214 func (x *ApplyHttpChaosResponse) GetStartTime() int64 {
2215 if x != nil {
2216 return x.StartTime
2217 }
2218 return 0
2219 }
2220
2221 func (x *ApplyHttpChaosResponse) GetStatusCode() int32 {
2222 if x != nil {
2223 return x.StatusCode
2224 }
2225 return 0
2226 }
2227
2228 func (x *ApplyHttpChaosResponse) GetError() string {
2229 if x != nil {
2230 return x.Error
2231 }
2232 return ""
2233 }
2234
2235 func (x *ApplyHttpChaosResponse) GetInstanceUid() string {
2236 if x != nil {
2237 return x.InstanceUid
2238 }
2239 return ""
2240 }
2241
2242 type TcsRequest struct {
2243 state protoimpl.MessageState
2244 sizeCache protoimpl.SizeCache
2245 unknownFields protoimpl.UnknownFields
2246
2247 Tcs []*Tc `protobuf:"bytes,1,rep,name=tcs,proto3" json:"tcs,omitempty"`
2248 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
2249 EnterNS bool `protobuf:"varint,4,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
2250 }
2251
2252 func (x *TcsRequest) Reset() {
2253 *x = TcsRequest{}
2254 if protoimpl.UnsafeEnabled {
2255 mi := &file_chaosdaemon_proto_msgTypes[27]
2256 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2257 ms.StoreMessageInfo(mi)
2258 }
2259 }
2260
2261 func (x *TcsRequest) String() string {
2262 return protoimpl.X.MessageStringOf(x)
2263 }
2264
2265 func (*TcsRequest) ProtoMessage() {}
2266
2267 func (x *TcsRequest) ProtoReflect() protoreflect.Message {
2268 mi := &file_chaosdaemon_proto_msgTypes[27]
2269 if protoimpl.UnsafeEnabled && x != nil {
2270 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2271 if ms.LoadMessageInfo() == nil {
2272 ms.StoreMessageInfo(mi)
2273 }
2274 return ms
2275 }
2276 return mi.MessageOf(x)
2277 }
2278
2279
2280 func (*TcsRequest) Descriptor() ([]byte, []int) {
2281 return file_chaosdaemon_proto_rawDescGZIP(), []int{27}
2282 }
2283
2284 func (x *TcsRequest) GetTcs() []*Tc {
2285 if x != nil {
2286 return x.Tcs
2287 }
2288 return nil
2289 }
2290
2291 func (x *TcsRequest) GetContainerId() string {
2292 if x != nil {
2293 return x.ContainerId
2294 }
2295 return ""
2296 }
2297
2298 func (x *TcsRequest) GetEnterNS() bool {
2299 if x != nil {
2300 return x.EnterNS
2301 }
2302 return false
2303 }
2304
2305 type Tc struct {
2306 state protoimpl.MessageState
2307 sizeCache protoimpl.SizeCache
2308 unknownFields protoimpl.UnknownFields
2309
2310 Type Tc_Type `protobuf:"varint,1,opt,name=type,proto3,enum=pb.Tc_Type" json:"type,omitempty"`
2311 Netem *Netem `protobuf:"bytes,2,opt,name=netem,proto3" json:"netem,omitempty"`
2312 Tbf *Tbf `protobuf:"bytes,3,opt,name=tbf,proto3" json:"tbf,omitempty"`
2313 Ipset string `protobuf:"bytes,4,opt,name=ipset,proto3" json:"ipset,omitempty"`
2314 Protocol string `protobuf:"bytes,5,opt,name=protocol,proto3" json:"protocol,omitempty"`
2315 SourcePort string `protobuf:"bytes,6,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"`
2316 EgressPort string `protobuf:"bytes,7,opt,name=egress_port,json=egressPort,proto3" json:"egress_port,omitempty"`
2317 Device string `protobuf:"bytes,9,opt,name=device,proto3" json:"device,omitempty"`
2318 }
2319
2320 func (x *Tc) Reset() {
2321 *x = Tc{}
2322 if protoimpl.UnsafeEnabled {
2323 mi := &file_chaosdaemon_proto_msgTypes[28]
2324 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2325 ms.StoreMessageInfo(mi)
2326 }
2327 }
2328
2329 func (x *Tc) String() string {
2330 return protoimpl.X.MessageStringOf(x)
2331 }
2332
2333 func (*Tc) ProtoMessage() {}
2334
2335 func (x *Tc) ProtoReflect() protoreflect.Message {
2336 mi := &file_chaosdaemon_proto_msgTypes[28]
2337 if protoimpl.UnsafeEnabled && x != nil {
2338 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2339 if ms.LoadMessageInfo() == nil {
2340 ms.StoreMessageInfo(mi)
2341 }
2342 return ms
2343 }
2344 return mi.MessageOf(x)
2345 }
2346
2347
2348 func (*Tc) Descriptor() ([]byte, []int) {
2349 return file_chaosdaemon_proto_rawDescGZIP(), []int{28}
2350 }
2351
2352 func (x *Tc) GetType() Tc_Type {
2353 if x != nil {
2354 return x.Type
2355 }
2356 return Tc_NETEM
2357 }
2358
2359 func (x *Tc) GetNetem() *Netem {
2360 if x != nil {
2361 return x.Netem
2362 }
2363 return nil
2364 }
2365
2366 func (x *Tc) GetTbf() *Tbf {
2367 if x != nil {
2368 return x.Tbf
2369 }
2370 return nil
2371 }
2372
2373 func (x *Tc) GetIpset() string {
2374 if x != nil {
2375 return x.Ipset
2376 }
2377 return ""
2378 }
2379
2380 func (x *Tc) GetProtocol() string {
2381 if x != nil {
2382 return x.Protocol
2383 }
2384 return ""
2385 }
2386
2387 func (x *Tc) GetSourcePort() string {
2388 if x != nil {
2389 return x.SourcePort
2390 }
2391 return ""
2392 }
2393
2394 func (x *Tc) GetEgressPort() string {
2395 if x != nil {
2396 return x.EgressPort
2397 }
2398 return ""
2399 }
2400
2401 func (x *Tc) GetDevice() string {
2402 if x != nil {
2403 return x.Device
2404 }
2405 return ""
2406 }
2407
2408 type SetDNSServerRequest struct {
2409 state protoimpl.MessageState
2410 sizeCache protoimpl.SizeCache
2411 unknownFields protoimpl.UnknownFields
2412
2413 ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
2414 DnsServer string `protobuf:"bytes,2,opt,name=dns_server,json=dnsServer,proto3" json:"dns_server,omitempty"`
2415 Enable bool `protobuf:"varint,3,opt,name=enable,proto3" json:"enable,omitempty"`
2416 EnterNS bool `protobuf:"varint,4,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
2417 }
2418
2419 func (x *SetDNSServerRequest) Reset() {
2420 *x = SetDNSServerRequest{}
2421 if protoimpl.UnsafeEnabled {
2422 mi := &file_chaosdaemon_proto_msgTypes[29]
2423 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2424 ms.StoreMessageInfo(mi)
2425 }
2426 }
2427
2428 func (x *SetDNSServerRequest) String() string {
2429 return protoimpl.X.MessageStringOf(x)
2430 }
2431
2432 func (*SetDNSServerRequest) ProtoMessage() {}
2433
2434 func (x *SetDNSServerRequest) ProtoReflect() protoreflect.Message {
2435 mi := &file_chaosdaemon_proto_msgTypes[29]
2436 if protoimpl.UnsafeEnabled && x != nil {
2437 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2438 if ms.LoadMessageInfo() == nil {
2439 ms.StoreMessageInfo(mi)
2440 }
2441 return ms
2442 }
2443 return mi.MessageOf(x)
2444 }
2445
2446
2447 func (*SetDNSServerRequest) Descriptor() ([]byte, []int) {
2448 return file_chaosdaemon_proto_rawDescGZIP(), []int{29}
2449 }
2450
2451 func (x *SetDNSServerRequest) GetContainerId() string {
2452 if x != nil {
2453 return x.ContainerId
2454 }
2455 return ""
2456 }
2457
2458 func (x *SetDNSServerRequest) GetDnsServer() string {
2459 if x != nil {
2460 return x.DnsServer
2461 }
2462 return ""
2463 }
2464
2465 func (x *SetDNSServerRequest) GetEnable() bool {
2466 if x != nil {
2467 return x.Enable
2468 }
2469 return false
2470 }
2471
2472 func (x *SetDNSServerRequest) GetEnterNS() bool {
2473 if x != nil {
2474 return x.EnterNS
2475 }
2476 return false
2477 }
2478
2479 type InstallJVMRulesRequest struct {
2480 state protoimpl.MessageState
2481 sizeCache protoimpl.SizeCache
2482 unknownFields protoimpl.UnknownFields
2483
2484 ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
2485 Rule string `protobuf:"bytes,2,opt,name=rule,proto3" json:"rule,omitempty"`
2486 Port int32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
2487 EnterNS bool `protobuf:"varint,4,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
2488 }
2489
2490 func (x *InstallJVMRulesRequest) Reset() {
2491 *x = InstallJVMRulesRequest{}
2492 if protoimpl.UnsafeEnabled {
2493 mi := &file_chaosdaemon_proto_msgTypes[30]
2494 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2495 ms.StoreMessageInfo(mi)
2496 }
2497 }
2498
2499 func (x *InstallJVMRulesRequest) String() string {
2500 return protoimpl.X.MessageStringOf(x)
2501 }
2502
2503 func (*InstallJVMRulesRequest) ProtoMessage() {}
2504
2505 func (x *InstallJVMRulesRequest) ProtoReflect() protoreflect.Message {
2506 mi := &file_chaosdaemon_proto_msgTypes[30]
2507 if protoimpl.UnsafeEnabled && x != nil {
2508 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2509 if ms.LoadMessageInfo() == nil {
2510 ms.StoreMessageInfo(mi)
2511 }
2512 return ms
2513 }
2514 return mi.MessageOf(x)
2515 }
2516
2517
2518 func (*InstallJVMRulesRequest) Descriptor() ([]byte, []int) {
2519 return file_chaosdaemon_proto_rawDescGZIP(), []int{30}
2520 }
2521
2522 func (x *InstallJVMRulesRequest) GetContainerId() string {
2523 if x != nil {
2524 return x.ContainerId
2525 }
2526 return ""
2527 }
2528
2529 func (x *InstallJVMRulesRequest) GetRule() string {
2530 if x != nil {
2531 return x.Rule
2532 }
2533 return ""
2534 }
2535
2536 func (x *InstallJVMRulesRequest) GetPort() int32 {
2537 if x != nil {
2538 return x.Port
2539 }
2540 return 0
2541 }
2542
2543 func (x *InstallJVMRulesRequest) GetEnterNS() bool {
2544 if x != nil {
2545 return x.EnterNS
2546 }
2547 return false
2548 }
2549
2550 type UninstallJVMRulesRequest struct {
2551 state protoimpl.MessageState
2552 sizeCache protoimpl.SizeCache
2553 unknownFields protoimpl.UnknownFields
2554
2555 ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
2556 Rule string `protobuf:"bytes,2,opt,name=rule,proto3" json:"rule,omitempty"`
2557 Port int32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
2558 EnterNS bool `protobuf:"varint,4,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
2559 }
2560
2561 func (x *UninstallJVMRulesRequest) Reset() {
2562 *x = UninstallJVMRulesRequest{}
2563 if protoimpl.UnsafeEnabled {
2564 mi := &file_chaosdaemon_proto_msgTypes[31]
2565 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2566 ms.StoreMessageInfo(mi)
2567 }
2568 }
2569
2570 func (x *UninstallJVMRulesRequest) String() string {
2571 return protoimpl.X.MessageStringOf(x)
2572 }
2573
2574 func (*UninstallJVMRulesRequest) ProtoMessage() {}
2575
2576 func (x *UninstallJVMRulesRequest) ProtoReflect() protoreflect.Message {
2577 mi := &file_chaosdaemon_proto_msgTypes[31]
2578 if protoimpl.UnsafeEnabled && x != nil {
2579 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2580 if ms.LoadMessageInfo() == nil {
2581 ms.StoreMessageInfo(mi)
2582 }
2583 return ms
2584 }
2585 return mi.MessageOf(x)
2586 }
2587
2588
2589 func (*UninstallJVMRulesRequest) Descriptor() ([]byte, []int) {
2590 return file_chaosdaemon_proto_rawDescGZIP(), []int{31}
2591 }
2592
2593 func (x *UninstallJVMRulesRequest) GetContainerId() string {
2594 if x != nil {
2595 return x.ContainerId
2596 }
2597 return ""
2598 }
2599
2600 func (x *UninstallJVMRulesRequest) GetRule() string {
2601 if x != nil {
2602 return x.Rule
2603 }
2604 return ""
2605 }
2606
2607 func (x *UninstallJVMRulesRequest) GetPort() int32 {
2608 if x != nil {
2609 return x.Port
2610 }
2611 return 0
2612 }
2613
2614 func (x *UninstallJVMRulesRequest) GetEnterNS() bool {
2615 if x != nil {
2616 return x.EnterNS
2617 }
2618 return false
2619 }
2620
2621 type ApplyBlockChaosRequest struct {
2622 state protoimpl.MessageState
2623 sizeCache protoimpl.SizeCache
2624 unknownFields protoimpl.UnknownFields
2625
2626 ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
2627 VolumePath string `protobuf:"bytes,2,opt,name=volume_path,json=volumePath,proto3" json:"volume_path,omitempty"`
2628 Action ApplyBlockChaosRequest_Action `protobuf:"varint,3,opt,name=action,proto3,enum=pb.ApplyBlockChaosRequest_Action" json:"action,omitempty"`
2629 Delay *BlockDelaySpec `protobuf:"bytes,5,opt,name=delay,proto3" json:"delay,omitempty"`
2630 EnterNS bool `protobuf:"varint,6,opt,name=enterNS,proto3" json:"enterNS,omitempty"`
2631 }
2632
2633 func (x *ApplyBlockChaosRequest) Reset() {
2634 *x = ApplyBlockChaosRequest{}
2635 if protoimpl.UnsafeEnabled {
2636 mi := &file_chaosdaemon_proto_msgTypes[32]
2637 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2638 ms.StoreMessageInfo(mi)
2639 }
2640 }
2641
2642 func (x *ApplyBlockChaosRequest) String() string {
2643 return protoimpl.X.MessageStringOf(x)
2644 }
2645
2646 func (*ApplyBlockChaosRequest) ProtoMessage() {}
2647
2648 func (x *ApplyBlockChaosRequest) ProtoReflect() protoreflect.Message {
2649 mi := &file_chaosdaemon_proto_msgTypes[32]
2650 if protoimpl.UnsafeEnabled && x != nil {
2651 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2652 if ms.LoadMessageInfo() == nil {
2653 ms.StoreMessageInfo(mi)
2654 }
2655 return ms
2656 }
2657 return mi.MessageOf(x)
2658 }
2659
2660
2661 func (*ApplyBlockChaosRequest) Descriptor() ([]byte, []int) {
2662 return file_chaosdaemon_proto_rawDescGZIP(), []int{32}
2663 }
2664
2665 func (x *ApplyBlockChaosRequest) GetContainerId() string {
2666 if x != nil {
2667 return x.ContainerId
2668 }
2669 return ""
2670 }
2671
2672 func (x *ApplyBlockChaosRequest) GetVolumePath() string {
2673 if x != nil {
2674 return x.VolumePath
2675 }
2676 return ""
2677 }
2678
2679 func (x *ApplyBlockChaosRequest) GetAction() ApplyBlockChaosRequest_Action {
2680 if x != nil {
2681 return x.Action
2682 }
2683 return ApplyBlockChaosRequest_Delay
2684 }
2685
2686 func (x *ApplyBlockChaosRequest) GetDelay() *BlockDelaySpec {
2687 if x != nil {
2688 return x.Delay
2689 }
2690 return nil
2691 }
2692
2693 func (x *ApplyBlockChaosRequest) GetEnterNS() bool {
2694 if x != nil {
2695 return x.EnterNS
2696 }
2697 return false
2698 }
2699
2700 type BlockDelaySpec struct {
2701 state protoimpl.MessageState
2702 sizeCache protoimpl.SizeCache
2703 unknownFields protoimpl.UnknownFields
2704
2705 Delay int64 `protobuf:"varint,1,opt,name=delay,proto3" json:"delay,omitempty"`
2706 Correlation float64 `protobuf:"fixed64,2,opt,name=correlation,proto3" json:"correlation,omitempty"`
2707 Jitter int64 `protobuf:"varint,3,opt,name=jitter,proto3" json:"jitter,omitempty"`
2708 }
2709
2710 func (x *BlockDelaySpec) Reset() {
2711 *x = BlockDelaySpec{}
2712 if protoimpl.UnsafeEnabled {
2713 mi := &file_chaosdaemon_proto_msgTypes[33]
2714 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2715 ms.StoreMessageInfo(mi)
2716 }
2717 }
2718
2719 func (x *BlockDelaySpec) String() string {
2720 return protoimpl.X.MessageStringOf(x)
2721 }
2722
2723 func (*BlockDelaySpec) ProtoMessage() {}
2724
2725 func (x *BlockDelaySpec) ProtoReflect() protoreflect.Message {
2726 mi := &file_chaosdaemon_proto_msgTypes[33]
2727 if protoimpl.UnsafeEnabled && x != nil {
2728 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2729 if ms.LoadMessageInfo() == nil {
2730 ms.StoreMessageInfo(mi)
2731 }
2732 return ms
2733 }
2734 return mi.MessageOf(x)
2735 }
2736
2737
2738 func (*BlockDelaySpec) Descriptor() ([]byte, []int) {
2739 return file_chaosdaemon_proto_rawDescGZIP(), []int{33}
2740 }
2741
2742 func (x *BlockDelaySpec) GetDelay() int64 {
2743 if x != nil {
2744 return x.Delay
2745 }
2746 return 0
2747 }
2748
2749 func (x *BlockDelaySpec) GetCorrelation() float64 {
2750 if x != nil {
2751 return x.Correlation
2752 }
2753 return 0
2754 }
2755
2756 func (x *BlockDelaySpec) GetJitter() int64 {
2757 if x != nil {
2758 return x.Jitter
2759 }
2760 return 0
2761 }
2762
2763 type BlockLimitSpec struct {
2764 state protoimpl.MessageState
2765 sizeCache protoimpl.SizeCache
2766 unknownFields protoimpl.UnknownFields
2767
2768 Quota uint64 `protobuf:"varint,1,opt,name=quota,proto3" json:"quota,omitempty"`
2769 PeriodUs uint64 `protobuf:"varint,2,opt,name=period_us,json=periodUs,proto3" json:"period_us,omitempty"`
2770 }
2771
2772 func (x *BlockLimitSpec) Reset() {
2773 *x = BlockLimitSpec{}
2774 if protoimpl.UnsafeEnabled {
2775 mi := &file_chaosdaemon_proto_msgTypes[34]
2776 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2777 ms.StoreMessageInfo(mi)
2778 }
2779 }
2780
2781 func (x *BlockLimitSpec) String() string {
2782 return protoimpl.X.MessageStringOf(x)
2783 }
2784
2785 func (*BlockLimitSpec) ProtoMessage() {}
2786
2787 func (x *BlockLimitSpec) ProtoReflect() protoreflect.Message {
2788 mi := &file_chaosdaemon_proto_msgTypes[34]
2789 if protoimpl.UnsafeEnabled && x != nil {
2790 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2791 if ms.LoadMessageInfo() == nil {
2792 ms.StoreMessageInfo(mi)
2793 }
2794 return ms
2795 }
2796 return mi.MessageOf(x)
2797 }
2798
2799
2800 func (*BlockLimitSpec) Descriptor() ([]byte, []int) {
2801 return file_chaosdaemon_proto_rawDescGZIP(), []int{34}
2802 }
2803
2804 func (x *BlockLimitSpec) GetQuota() uint64 {
2805 if x != nil {
2806 return x.Quota
2807 }
2808 return 0
2809 }
2810
2811 func (x *BlockLimitSpec) GetPeriodUs() uint64 {
2812 if x != nil {
2813 return x.PeriodUs
2814 }
2815 return 0
2816 }
2817
2818 type ApplyBlockChaosResponse struct {
2819 state protoimpl.MessageState
2820 sizeCache protoimpl.SizeCache
2821 unknownFields protoimpl.UnknownFields
2822
2823 InjectionId int32 `protobuf:"varint,1,opt,name=injection_id,json=injectionId,proto3" json:"injection_id,omitempty"`
2824 }
2825
2826 func (x *ApplyBlockChaosResponse) Reset() {
2827 *x = ApplyBlockChaosResponse{}
2828 if protoimpl.UnsafeEnabled {
2829 mi := &file_chaosdaemon_proto_msgTypes[35]
2830 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2831 ms.StoreMessageInfo(mi)
2832 }
2833 }
2834
2835 func (x *ApplyBlockChaosResponse) String() string {
2836 return protoimpl.X.MessageStringOf(x)
2837 }
2838
2839 func (*ApplyBlockChaosResponse) ProtoMessage() {}
2840
2841 func (x *ApplyBlockChaosResponse) ProtoReflect() protoreflect.Message {
2842 mi := &file_chaosdaemon_proto_msgTypes[35]
2843 if protoimpl.UnsafeEnabled && x != nil {
2844 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2845 if ms.LoadMessageInfo() == nil {
2846 ms.StoreMessageInfo(mi)
2847 }
2848 return ms
2849 }
2850 return mi.MessageOf(x)
2851 }
2852
2853
2854 func (*ApplyBlockChaosResponse) Descriptor() ([]byte, []int) {
2855 return file_chaosdaemon_proto_rawDescGZIP(), []int{35}
2856 }
2857
2858 func (x *ApplyBlockChaosResponse) GetInjectionId() int32 {
2859 if x != nil {
2860 return x.InjectionId
2861 }
2862 return 0
2863 }
2864
2865 type RecoverBlockChaosRequest struct {
2866 state protoimpl.MessageState
2867 sizeCache protoimpl.SizeCache
2868 unknownFields protoimpl.UnknownFields
2869
2870 InjectionId int32 `protobuf:"varint,1,opt,name=injection_id,json=injectionId,proto3" json:"injection_id,omitempty"`
2871 }
2872
2873 func (x *RecoverBlockChaosRequest) Reset() {
2874 *x = RecoverBlockChaosRequest{}
2875 if protoimpl.UnsafeEnabled {
2876 mi := &file_chaosdaemon_proto_msgTypes[36]
2877 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2878 ms.StoreMessageInfo(mi)
2879 }
2880 }
2881
2882 func (x *RecoverBlockChaosRequest) String() string {
2883 return protoimpl.X.MessageStringOf(x)
2884 }
2885
2886 func (*RecoverBlockChaosRequest) ProtoMessage() {}
2887
2888 func (x *RecoverBlockChaosRequest) ProtoReflect() protoreflect.Message {
2889 mi := &file_chaosdaemon_proto_msgTypes[36]
2890 if protoimpl.UnsafeEnabled && x != nil {
2891 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2892 if ms.LoadMessageInfo() == nil {
2893 ms.StoreMessageInfo(mi)
2894 }
2895 return ms
2896 }
2897 return mi.MessageOf(x)
2898 }
2899
2900
2901 func (*RecoverBlockChaosRequest) Descriptor() ([]byte, []int) {
2902 return file_chaosdaemon_proto_rawDescGZIP(), []int{36}
2903 }
2904
2905 func (x *RecoverBlockChaosRequest) GetInjectionId() int32 {
2906 if x != nil {
2907 return x.InjectionId
2908 }
2909 return 0
2910 }
2911
2912 var File_chaosdaemon_proto protoreflect.FileDescriptor
2913
2914 var file_chaosdaemon_proto_rawDesc = []byte{
2915 0x0a, 0x11, 0x63, 0x68, 0x61, 0x6f, 0x73, 0x64, 0x61, 0x65, 0x6d, 0x6f, 0x6e, 0x2e, 0x70, 0x72,
2916 0x6f, 0x74, 0x6f, 0x12, 0x02, 0x70, 0x62, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f,
2917 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70,
2918 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x36, 0x0a, 0x08, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65,
2919 0x12, 0x14, 0x0a, 0x05, 0x6d, 0x61, 0x6a, 0x6f, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52,
2920 0x05, 0x6d, 0x61, 0x6a, 0x6f, 0x72, 0x12, 0x14, 0x0a, 0x05, 0x6d, 0x69, 0x6e, 0x6f, 0x72, 0x18,
2921 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x05, 0x6d, 0x69, 0x6e, 0x6f, 0x72, 0x22, 0x62, 0x0a, 0x10,
2922 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
2923 0x12, 0x2b, 0x0a, 0x06, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b,
2924 0x32, 0x13, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x41,
2925 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x06, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x21, 0x0a,
2926 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20,
2927 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64,
2928 0x22, 0x25, 0x0a, 0x11, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x52, 0x65, 0x73,
2929 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x70, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01,
2930 0x28, 0x0d, 0x52, 0x03, 0x70, 0x69, 0x64, 0x22, 0x9e, 0x01, 0x0a, 0x0c, 0x4e, 0x65, 0x74, 0x65,
2931 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1f, 0x0a, 0x05, 0x6e, 0x65, 0x74, 0x65,
2932 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x09, 0x2e, 0x70, 0x62, 0x2e, 0x4e, 0x65, 0x74,
2933 0x65, 0x6d, 0x52, 0x05, 0x6e, 0x65, 0x74, 0x65, 0x6d, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e,
2934 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52,
2935 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x24, 0x0a, 0x06,
2936 0x68, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70,
2937 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x52, 0x06, 0x68, 0x61, 0x6e, 0x64,
2938 0x6c, 0x65, 0x12, 0x24, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x04, 0x20, 0x01,
2939 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65,
2940 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x22, 0xca, 0x03, 0x0a, 0x05, 0x4e, 0x65, 0x74,
2941 0x65, 0x6d, 0x12, 0x12, 0x0a, 0x04, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d,
2942 0x52, 0x04, 0x74, 0x69, 0x6d, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x6a, 0x69, 0x74, 0x74, 0x65, 0x72,
2943 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x06, 0x6a, 0x69, 0x74, 0x74, 0x65, 0x72, 0x12, 0x1d,
2944 0x0a, 0x0a, 0x64, 0x65, 0x6c, 0x61, 0x79, 0x5f, 0x63, 0x6f, 0x72, 0x72, 0x18, 0x03, 0x20, 0x01,
2945 0x28, 0x02, 0x52, 0x09, 0x64, 0x65, 0x6c, 0x61, 0x79, 0x43, 0x6f, 0x72, 0x72, 0x12, 0x14, 0x0a,
2946 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x05, 0x6c, 0x69,
2947 0x6d, 0x69, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x6c, 0x6f, 0x73, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28,
2948 0x02, 0x52, 0x04, 0x6c, 0x6f, 0x73, 0x73, 0x12, 0x1b, 0x0a, 0x09, 0x6c, 0x6f, 0x73, 0x73, 0x5f,
2949 0x63, 0x6f, 0x72, 0x72, 0x18, 0x06, 0x20, 0x01, 0x28, 0x02, 0x52, 0x08, 0x6c, 0x6f, 0x73, 0x73,
2950 0x43, 0x6f, 0x72, 0x72, 0x12, 0x10, 0x0a, 0x03, 0x67, 0x61, 0x70, 0x18, 0x07, 0x20, 0x01, 0x28,
2951 0x0d, 0x52, 0x03, 0x67, 0x61, 0x70, 0x12, 0x1c, 0x0a, 0x09, 0x64, 0x75, 0x70, 0x6c, 0x69, 0x63,
2952 0x61, 0x74, 0x65, 0x18, 0x08, 0x20, 0x01, 0x28, 0x02, 0x52, 0x09, 0x64, 0x75, 0x70, 0x6c, 0x69,
2953 0x63, 0x61, 0x74, 0x65, 0x12, 0x25, 0x0a, 0x0e, 0x64, 0x75, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74,
2954 0x65, 0x5f, 0x63, 0x6f, 0x72, 0x72, 0x18, 0x09, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0d, 0x64, 0x75,
2955 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x65, 0x43, 0x6f, 0x72, 0x72, 0x12, 0x18, 0x0a, 0x07, 0x72,
2956 0x65, 0x6f, 0x72, 0x64, 0x65, 0x72, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x02, 0x52, 0x07, 0x72, 0x65,
2957 0x6f, 0x72, 0x64, 0x65, 0x72, 0x12, 0x21, 0x0a, 0x0c, 0x72, 0x65, 0x6f, 0x72, 0x64, 0x65, 0x72,
2958 0x5f, 0x63, 0x6f, 0x72, 0x72, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0b, 0x72, 0x65, 0x6f,
2959 0x72, 0x64, 0x65, 0x72, 0x43, 0x6f, 0x72, 0x72, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x6f, 0x72, 0x72,
2960 0x75, 0x70, 0x74, 0x18, 0x0c, 0x20, 0x01, 0x28, 0x02, 0x52, 0x07, 0x63, 0x6f, 0x72, 0x72, 0x75,
2961 0x70, 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x72, 0x72, 0x75, 0x70, 0x74, 0x5f, 0x63, 0x6f,
2962 0x72, 0x72, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0b, 0x63, 0x6f, 0x72, 0x72, 0x75, 0x70,
2963 0x74, 0x43, 0x6f, 0x72, 0x72, 0x12, 0x24, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18,
2964 0x0e, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e,
2965 0x64, 0x6c, 0x65, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x24, 0x0a, 0x06, 0x68,
2966 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x18, 0x0f, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x62,
2967 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x52, 0x06, 0x68, 0x61, 0x6e, 0x64, 0x6c,
2968 0x65, 0x12, 0x12, 0x0a, 0x04, 0x72, 0x61, 0x74, 0x65, 0x18, 0x10, 0x20, 0x01, 0x28, 0x09, 0x52,
2969 0x04, 0x72, 0x61, 0x74, 0x65, 0x22, 0x4a, 0x0a, 0x0a, 0x54, 0x62, 0x66, 0x52, 0x65, 0x71, 0x75,
2970 0x65, 0x73, 0x74, 0x12, 0x19, 0x0a, 0x03, 0x74, 0x62, 0x66, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b,
2971 0x32, 0x07, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x62, 0x66, 0x52, 0x03, 0x74, 0x62, 0x66, 0x12, 0x21,
2972 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02,
2973 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49,
2974 0x64, 0x22, 0x81, 0x01, 0x0a, 0x03, 0x54, 0x62, 0x66, 0x12, 0x12, 0x0a, 0x04, 0x72, 0x61, 0x74,
2975 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x72, 0x61, 0x74, 0x65, 0x12, 0x14, 0x0a,
2976 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x05, 0x6c, 0x69,
2977 0x6d, 0x69, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x62, 0x75, 0x66, 0x66, 0x65, 0x72, 0x18, 0x03, 0x20,
2978 0x01, 0x28, 0x0d, 0x52, 0x06, 0x62, 0x75, 0x66, 0x66, 0x65, 0x72, 0x12, 0x1b, 0x0a, 0x09, 0x70,
2979 0x65, 0x61, 0x6b, 0x5f, 0x72, 0x61, 0x74, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x04, 0x52, 0x08,
2980 0x70, 0x65, 0x61, 0x6b, 0x52, 0x61, 0x74, 0x65, 0x12, 0x1b, 0x0a, 0x09, 0x6d, 0x69, 0x6e, 0x5f,
2981 0x62, 0x75, 0x72, 0x73, 0x74, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x08, 0x6d, 0x69, 0x6e,
2982 0x42, 0x75, 0x72, 0x73, 0x74, 0x22, 0x52, 0x0a, 0x0c, 0x51, 0x64, 0x69, 0x73, 0x63, 0x52, 0x65,
2983 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1f, 0x0a, 0x05, 0x71, 0x64, 0x69, 0x73, 0x63, 0x18, 0x01,
2984 0x20, 0x01, 0x28, 0x0b, 0x32, 0x09, 0x2e, 0x70, 0x62, 0x2e, 0x51, 0x64, 0x69, 0x73, 0x63, 0x52,
2985 0x05, 0x71, 0x64, 0x69, 0x73, 0x63, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69,
2986 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f,
2987 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x22, 0x7b, 0x0a, 0x05, 0x51, 0x64, 0x69,
2988 0x73, 0x63, 0x12, 0x24, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01,
2989 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65,
2990 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x24, 0x0a, 0x06, 0x68, 0x61, 0x6e, 0x64,
2991 0x6c, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63,
2992 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x52, 0x06, 0x68, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x12, 0x12,
2993 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x74, 0x79,
2994 0x70, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x61, 0x72, 0x67, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x09,
2995 0x52, 0x04, 0x61, 0x72, 0x67, 0x73, 0x22, 0x62, 0x0a, 0x13, 0x45, 0x6d, 0x61, 0x74, 0x63, 0x68,
2996 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x28, 0x0a,
2997 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x10, 0x2e,
2998 0x70, 0x62, 0x2e, 0x45, 0x6d, 0x61, 0x74, 0x63, 0x68, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x52,
2999 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61,
3000 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63,
3001 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x22, 0x72, 0x0a, 0x0c, 0x45, 0x6d,
3002 0x61, 0x74, 0x63, 0x68, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x12, 0x14, 0x0a, 0x05, 0x6d, 0x61,
3003 0x74, 0x63, 0x68, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x6d, 0x61, 0x74, 0x63, 0x68,
3004 0x12, 0x24, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b,
3005 0x32, 0x0c, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x52, 0x06,
3006 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x26, 0x0a, 0x07, 0x63, 0x6c, 0x61, 0x73, 0x73, 0x69,
3007 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x48,
3008 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x52, 0x07, 0x63, 0x6c, 0x61, 0x73, 0x73, 0x69, 0x64, 0x22, 0x5a,
3009 0x0a, 0x0f, 0x54, 0x63, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
3010 0x74, 0x12, 0x24, 0x0a, 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28,
3011 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x52,
3012 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61,
3013 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63,
3014 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x22, 0x30, 0x0a, 0x08, 0x54, 0x63,
3015 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x12, 0x24, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74,
3016 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x48, 0x61,
3017 0x6e, 0x64, 0x6c, 0x65, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x22, 0x6f, 0x0a, 0x0d,
3018 0x49, 0x50, 0x53, 0x65, 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x21, 0x0a,
3019 0x06, 0x69, 0x70, 0x73, 0x65, 0x74, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x09, 0x2e,
3020 0x70, 0x62, 0x2e, 0x49, 0x50, 0x53, 0x65, 0x74, 0x52, 0x06, 0x69, 0x70, 0x73, 0x65, 0x74, 0x73,
3021 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64,
3022 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65,
3023 0x72, 0x49, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x18, 0x03,
3024 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x22, 0x99, 0x01,
3025 0x0a, 0x05, 0x49, 0x50, 0x53, 0x65, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18,
3026 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x63,
3027 0x69, 0x64, 0x72, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x09, 0x52, 0x05, 0x63, 0x69, 0x64, 0x72,
3028 0x73, 0x12, 0x35, 0x0a, 0x0e, 0x63, 0x69, 0x64, 0x72, 0x5f, 0x61, 0x6e, 0x64, 0x5f, 0x70, 0x6f,
3029 0x72, 0x74, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x70, 0x62, 0x2e, 0x43,
3030 0x69, 0x64, 0x72, 0x41, 0x6e, 0x64, 0x50, 0x6f, 0x72, 0x74, 0x52, 0x0c, 0x63, 0x69, 0x64, 0x72,
3031 0x41, 0x6e, 0x64, 0x50, 0x6f, 0x72, 0x74, 0x73, 0x12, 0x1b, 0x0a, 0x09, 0x73, 0x65, 0x74, 0x5f,
3032 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x09, 0x52, 0x08, 0x73, 0x65, 0x74,
3033 0x4e, 0x61, 0x6d, 0x65, 0x73, 0x12, 0x12, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x05, 0x20,
3034 0x01, 0x28, 0x09, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x22, 0x35, 0x0a, 0x0b, 0x43, 0x69, 0x64,
3035 0x72, 0x41, 0x6e, 0x64, 0x50, 0x6f, 0x72, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x63, 0x69, 0x64, 0x72,
3036 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x63, 0x69, 0x64, 0x72, 0x12, 0x12, 0x0a, 0x04,
3037 0x70, 0x6f, 0x72, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x04, 0x70, 0x6f, 0x72, 0x74,
3038 0x22, 0x77, 0x0a, 0x15, 0x49, 0x70, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x43, 0x68, 0x61, 0x69,
3039 0x6e, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x21, 0x0a, 0x06, 0x63, 0x68, 0x61,
3040 0x69, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x09, 0x2e, 0x70, 0x62, 0x2e, 0x43,
3041 0x68, 0x61, 0x69, 0x6e, 0x52, 0x06, 0x63, 0x68, 0x61, 0x69, 0x6e, 0x73, 0x12, 0x21, 0x0a, 0x0c,
3042 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01,
3043 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12,
3044 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x18, 0x03, 0x20, 0x01, 0x28, 0x08,
3045 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x22, 0xc3, 0x02, 0x0a, 0x05, 0x43, 0x68,
3046 0x61, 0x69, 0x6e, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28,
3047 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x31, 0x0a, 0x09, 0x64, 0x69, 0x72, 0x65, 0x63,
3048 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x13, 0x2e, 0x70, 0x62, 0x2e,
3049 0x43, 0x68, 0x61, 0x69, 0x6e, 0x2e, 0x44, 0x69, 0x72, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52,
3050 0x09, 0x64, 0x69, 0x72, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x16, 0x0a, 0x06, 0x69, 0x70,
3051 0x73, 0x65, 0x74, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x09, 0x52, 0x06, 0x69, 0x70, 0x73, 0x65,
3052 0x74, 0x73, 0x12, 0x16, 0x0a, 0x06, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x18, 0x04, 0x20, 0x01,
3053 0x28, 0x09, 0x52, 0x06, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x12, 0x1a, 0x0a, 0x08, 0x70, 0x72,
3054 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x70, 0x72,
3055 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x12, 0x21, 0x0a, 0x0c, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65,
3056 0x5f, 0x70, 0x6f, 0x72, 0x74, 0x73, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x73, 0x6f,
3057 0x75, 0x72, 0x63, 0x65, 0x50, 0x6f, 0x72, 0x74, 0x73, 0x12, 0x2b, 0x0a, 0x11, 0x64, 0x65, 0x73,
3058 0x74, 0x69, 0x6e, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x70, 0x6f, 0x72, 0x74, 0x73, 0x18, 0x07,
3059 0x20, 0x01, 0x28, 0x09, 0x52, 0x10, 0x64, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x61, 0x74, 0x69, 0x6f,
3060 0x6e, 0x50, 0x6f, 0x72, 0x74, 0x73, 0x12, 0x1b, 0x0a, 0x09, 0x74, 0x63, 0x70, 0x5f, 0x66, 0x6c,
3061 0x61, 0x67, 0x73, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x74, 0x63, 0x70, 0x46, 0x6c,
3062 0x61, 0x67, 0x73, 0x12, 0x16, 0x0a, 0x06, 0x64, 0x65, 0x76, 0x69, 0x63, 0x65, 0x18, 0x09, 0x20,
3063 0x01, 0x28, 0x09, 0x52, 0x06, 0x64, 0x65, 0x76, 0x69, 0x63, 0x65, 0x22, 0x22, 0x0a, 0x09, 0x44,
3064 0x69, 0x72, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x09, 0x0a, 0x05, 0x49, 0x4e, 0x50, 0x55,
3065 0x54, 0x10, 0x00, 0x12, 0x0a, 0x0a, 0x06, 0x4f, 0x55, 0x54, 0x50, 0x55, 0x54, 0x10, 0x01, 0x22,
3066 0xb8, 0x01, 0x0a, 0x0b, 0x54, 0x69, 0x6d, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12,
3067 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18,
3068 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72,
3069 0x49, 0x64, 0x12, 0x10, 0x0a, 0x03, 0x73, 0x65, 0x63, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52,
3070 0x03, 0x73, 0x65, 0x63, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x73, 0x65, 0x63, 0x18, 0x03, 0x20, 0x01,
3071 0x28, 0x03, 0x52, 0x04, 0x6e, 0x73, 0x65, 0x63, 0x12, 0x20, 0x0a, 0x0c, 0x63, 0x6c, 0x6b, 0x5f,
3072 0x69, 0x64, 0x73, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x18, 0x04, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0a,
3073 0x63, 0x6c, 0x6b, 0x49, 0x64, 0x73, 0x4d, 0x61, 0x73, 0x6b, 0x12, 0x10, 0x0a, 0x03, 0x75, 0x69,
3074 0x64, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x75, 0x69, 0x64, 0x12, 0x2c, 0x0a, 0x12,
3075 0x70, 0x6f, 0x64, 0x5f, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x6e, 0x61,
3076 0x6d, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x10, 0x70, 0x6f, 0x64, 0x43, 0x6f, 0x6e,
3077 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0x65, 0x0a, 0x0f, 0x43, 0x6f,
3078 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x32, 0x0a,
3079 0x06, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1a, 0x2e,
3080 0x70, 0x62, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x41, 0x63, 0x74, 0x69,
3081 0x6f, 0x6e, 0x2e, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x06, 0x61, 0x63, 0x74, 0x69, 0x6f,
3082 0x6e, 0x22, 0x1e, 0x0a, 0x06, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x08, 0x0a, 0x04, 0x4b,
3083 0x49, 0x4c, 0x4c, 0x10, 0x00, 0x12, 0x0a, 0x0a, 0x06, 0x47, 0x45, 0x54, 0x50, 0x49, 0x44, 0x10,
3084 0x01, 0x22, 0x89, 0x02, 0x0a, 0x11, 0x45, 0x78, 0x65, 0x63, 0x53, 0x74, 0x72, 0x65, 0x73, 0x73,
3085 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x31, 0x0a, 0x05, 0x73, 0x63, 0x6f, 0x70, 0x65,
3086 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1b, 0x2e, 0x70, 0x62, 0x2e, 0x45, 0x78, 0x65, 0x63,
3087 0x53, 0x74, 0x72, 0x65, 0x73, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x53, 0x63,
3088 0x6f, 0x70, 0x65, 0x52, 0x05, 0x73, 0x63, 0x6f, 0x70, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x74, 0x61,
3089 0x72, 0x67, 0x65, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x74, 0x61, 0x72, 0x67,
3090 0x65, 0x74, 0x12, 0x22, 0x0a, 0x0c, 0x63, 0x70, 0x75, 0x53, 0x74, 0x72, 0x65, 0x73, 0x73, 0x6f,
3091 0x72, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x63, 0x70, 0x75, 0x53, 0x74, 0x72,
3092 0x65, 0x73, 0x73, 0x6f, 0x72, 0x73, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e,
3093 0x53, 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53,
3094 0x12, 0x28, 0x0a, 0x0f, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79, 0x53, 0x74, 0x72, 0x65, 0x73, 0x73,
3095 0x6f, 0x72, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0f, 0x6d, 0x65, 0x6d, 0x6f, 0x72,
3096 0x79, 0x53, 0x74, 0x72, 0x65, 0x73, 0x73, 0x6f, 0x72, 0x73, 0x12, 0x20, 0x0a, 0x0b, 0x6f, 0x6f,
3097 0x6d, 0x53, 0x63, 0x6f, 0x72, 0x65, 0x41, 0x64, 0x6a, 0x18, 0x07, 0x20, 0x01, 0x28, 0x05, 0x52,
3098 0x0b, 0x6f, 0x6f, 0x6d, 0x53, 0x63, 0x6f, 0x72, 0x65, 0x41, 0x64, 0x6a, 0x22, 0x1f, 0x0a, 0x05,
3099 0x53, 0x63, 0x6f, 0x70, 0x65, 0x12, 0x0d, 0x0a, 0x09, 0x43, 0x4f, 0x4e, 0x54, 0x41, 0x49, 0x4e,
3100 0x45, 0x52, 0x10, 0x00, 0x12, 0x07, 0x0a, 0x03, 0x50, 0x4f, 0x44, 0x10, 0x01, 0x22, 0x82, 0x02,
3101 0x0a, 0x12, 0x45, 0x78, 0x65, 0x63, 0x53, 0x74, 0x72, 0x65, 0x73, 0x73, 0x52, 0x65, 0x73, 0x70,
3102 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x20, 0x0a, 0x0b, 0x63, 0x70, 0x75, 0x49, 0x6e, 0x73, 0x74, 0x61,
3103 0x6e, 0x63, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x70, 0x75, 0x49, 0x6e,
3104 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x12, 0x22, 0x0a, 0x0c, 0x63, 0x70, 0x75, 0x53, 0x74, 0x61,
3105 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0c, 0x63, 0x70,
3106 0x75, 0x53, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x26, 0x0a, 0x0e, 0x6d, 0x65,
3107 0x6d, 0x6f, 0x72, 0x79, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x18, 0x03, 0x20, 0x01,
3108 0x28, 0x09, 0x52, 0x0e, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e,
3109 0x63, 0x65, 0x12, 0x28, 0x0a, 0x0f, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79, 0x53, 0x74, 0x61, 0x72,
3110 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0f, 0x6d, 0x65, 0x6d,
3111 0x6f, 0x72, 0x79, 0x53, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x26, 0x0a, 0x0e,
3112 0x63, 0x70, 0x75, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x55, 0x69, 0x64, 0x18, 0x05,
3113 0x20, 0x01, 0x28, 0x09, 0x52, 0x0e, 0x63, 0x70, 0x75, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63,
3114 0x65, 0x55, 0x69, 0x64, 0x12, 0x2c, 0x0a, 0x11, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79, 0x49, 0x6e,
3115 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x55, 0x69, 0x64, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52,
3116 0x11, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x55,
3117 0x69, 0x64, 0x22, 0x83, 0x02, 0x0a, 0x13, 0x43, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x53, 0x74, 0x72,
3118 0x65, 0x73, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x20, 0x0a, 0x0b, 0x63, 0x70,
3119 0x75, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52,
3120 0x0b, 0x63, 0x70, 0x75, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x12, 0x22, 0x0a, 0x0c,
3121 0x63, 0x70, 0x75, 0x53, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01,
3122 0x28, 0x03, 0x52, 0x0c, 0x63, 0x70, 0x75, 0x53, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65,
3123 0x12, 0x26, 0x0a, 0x0e, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e,
3124 0x63, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0e, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79,
3125 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x12, 0x28, 0x0a, 0x0f, 0x6d, 0x65, 0x6d, 0x6f,
3126 0x72, 0x79, 0x53, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28,
3127 0x03, 0x52, 0x0f, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79, 0x53, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69,
3128 0x6d, 0x65, 0x12, 0x26, 0x0a, 0x0e, 0x63, 0x70, 0x75, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63,
3129 0x65, 0x55, 0x69, 0x64, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0e, 0x63, 0x70, 0x75, 0x49,
3130 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x55, 0x69, 0x64, 0x12, 0x2c, 0x0a, 0x11, 0x6d, 0x65,
3131 0x6d, 0x6f, 0x72, 0x79, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x55, 0x69, 0x64, 0x18,
3132 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x11, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79, 0x49, 0x6e, 0x73,
3133 0x74, 0x61, 0x6e, 0x63, 0x65, 0x55, 0x69, 0x64, 0x22, 0xe1, 0x01, 0x0a, 0x13, 0x41, 0x70, 0x70,
3134 0x6c, 0x79, 0x49, 0x4f, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
3135 0x12, 0x18, 0x0a, 0x07, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28,
3136 0x09, 0x52, 0x07, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x16, 0x0a, 0x06, 0x76, 0x6f,
3137 0x6c, 0x75, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x76, 0x6f, 0x6c, 0x75,
3138 0x6d, 0x65, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f,
3139 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69,
3140 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x1a, 0x0a, 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63,
3141 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63,
3142 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x05,
3143 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12,
3144 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x18, 0x06, 0x20, 0x01, 0x28, 0x08,
3145 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x12, 0x21, 0x0a, 0x0c, 0x69, 0x6e, 0x73,
3146 0x74, 0x61, 0x6e, 0x63, 0x65, 0x5f, 0x75, 0x69, 0x64, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52,
3147 0x0b, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x55, 0x69, 0x64, 0x22, 0x73, 0x0a, 0x14,
3148 0x41, 0x70, 0x70, 0x6c, 0x79, 0x49, 0x4f, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x52, 0x65, 0x73, 0x70,
3149 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65,
3150 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65,
3151 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x02, 0x20,
3152 0x01, 0x28, 0x03, 0x52, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x21,
3153 0x0a, 0x0c, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x5f, 0x75, 0x69, 0x64, 0x18, 0x03,
3154 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x55, 0x69,
3155 0x64, 0x22, 0xfa, 0x01, 0x0a, 0x15, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x48, 0x74, 0x74, 0x70, 0x43,
3156 0x68, 0x61, 0x6f, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x72,
3157 0x75, 0x6c, 0x65, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x72, 0x75, 0x6c, 0x65,
3158 0x73, 0x12, 0x1f, 0x0a, 0x0b, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x5f, 0x70, 0x6f, 0x72, 0x74, 0x73,
3159 0x18, 0x02, 0x20, 0x03, 0x28, 0x0d, 0x52, 0x0a, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x50, 0x6f, 0x72,
3160 0x74, 0x73, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f,
3161 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69,
3162 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x1a, 0x0a, 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63,
3163 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63,
3164 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x05,
3165 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12,
3166 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x18, 0x06, 0x20, 0x01, 0x28, 0x08,
3167 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x12, 0x21, 0x0a, 0x0c, 0x69, 0x6e, 0x73,
3168 0x74, 0x61, 0x6e, 0x63, 0x65, 0x5f, 0x75, 0x69, 0x64, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52,
3169 0x0b, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x55, 0x69, 0x64, 0x12, 0x10, 0x0a, 0x03,
3170 0x74, 0x6c, 0x73, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x74, 0x6c, 0x73, 0x22, 0xab,
3171 0x01, 0x0a, 0x16, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x48, 0x74, 0x74, 0x70, 0x43, 0x68, 0x61, 0x6f,
3172 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x69, 0x6e, 0x73,
3173 0x74, 0x61, 0x6e, 0x63, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x69, 0x6e, 0x73,
3174 0x74, 0x61, 0x6e, 0x63, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69,
3175 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54,
3176 0x69, 0x6d, 0x65, 0x12, 0x1e, 0x0a, 0x0a, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x43, 0x6f, 0x64,
3177 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0a, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x43,
3178 0x6f, 0x64, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x04, 0x20, 0x01,
3179 0x28, 0x09, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x12, 0x21, 0x0a, 0x0c, 0x69, 0x6e, 0x73,
3180 0x74, 0x61, 0x6e, 0x63, 0x65, 0x5f, 0x75, 0x69, 0x64, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52,
3181 0x0b, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x55, 0x69, 0x64, 0x22, 0x63, 0x0a, 0x0a,
3182 0x54, 0x63, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x18, 0x0a, 0x03, 0x74, 0x63,
3183 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x06, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x52,
3184 0x03, 0x74, 0x63, 0x73, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65,
3185 0x72, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74,
3186 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72,
3187 0x4e, 0x53, 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e,
3188 0x53, 0x22, 0x8f, 0x02, 0x0a, 0x02, 0x54, 0x63, 0x12, 0x1f, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65,
3189 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x0b, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x2e, 0x54,
3190 0x79, 0x70, 0x65, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x1f, 0x0a, 0x05, 0x6e, 0x65, 0x74,
3191 0x65, 0x6d, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x09, 0x2e, 0x70, 0x62, 0x2e, 0x4e, 0x65,
3192 0x74, 0x65, 0x6d, 0x52, 0x05, 0x6e, 0x65, 0x74, 0x65, 0x6d, 0x12, 0x19, 0x0a, 0x03, 0x74, 0x62,
3193 0x66, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x07, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x62, 0x66,
3194 0x52, 0x03, 0x74, 0x62, 0x66, 0x12, 0x14, 0x0a, 0x05, 0x69, 0x70, 0x73, 0x65, 0x74, 0x18, 0x04,
3195 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x69, 0x70, 0x73, 0x65, 0x74, 0x12, 0x1a, 0x0a, 0x08, 0x70,
3196 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x70,
3197 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x12, 0x1f, 0x0a, 0x0b, 0x73, 0x6f, 0x75, 0x72, 0x63,
3198 0x65, 0x5f, 0x70, 0x6f, 0x72, 0x74, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x73, 0x6f,
3199 0x75, 0x72, 0x63, 0x65, 0x50, 0x6f, 0x72, 0x74, 0x12, 0x1f, 0x0a, 0x0b, 0x65, 0x67, 0x72, 0x65,
3200 0x73, 0x73, 0x5f, 0x70, 0x6f, 0x72, 0x74, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x65,
3201 0x67, 0x72, 0x65, 0x73, 0x73, 0x50, 0x6f, 0x72, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x64, 0x65, 0x76,
3202 0x69, 0x63, 0x65, 0x18, 0x09, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x64, 0x65, 0x76, 0x69, 0x63,
3203 0x65, 0x22, 0x20, 0x0a, 0x04, 0x54, 0x79, 0x70, 0x65, 0x12, 0x09, 0x0a, 0x05, 0x4e, 0x45, 0x54,
3204 0x45, 0x4d, 0x10, 0x00, 0x12, 0x0d, 0x0a, 0x09, 0x42, 0x41, 0x4e, 0x44, 0x57, 0x49, 0x44, 0x54,
3205 0x48, 0x10, 0x01, 0x22, 0x89, 0x01, 0x0a, 0x13, 0x53, 0x65, 0x74, 0x44, 0x4e, 0x53, 0x53, 0x65,
3206 0x72, 0x76, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x63,
3207 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28,
3208 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x1d,
3209 0x0a, 0x0a, 0x64, 0x6e, 0x73, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01,
3210 0x28, 0x09, 0x52, 0x09, 0x64, 0x6e, 0x73, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x12, 0x16, 0x0a,
3211 0x06, 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x08, 0x52, 0x06, 0x65,
3212 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53,
3213 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x22,
3214 0x7d, 0x0a, 0x16, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x4a, 0x56, 0x4d, 0x52, 0x75, 0x6c,
3215 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e,
3216 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52,
3217 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x12, 0x0a, 0x04,
3218 0x72, 0x75, 0x6c, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x72, 0x75, 0x6c, 0x65,
3219 0x12, 0x12, 0x0a, 0x04, 0x70, 0x6f, 0x72, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x04,
3220 0x70, 0x6f, 0x72, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x18,
3221 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x22, 0x7f,
3222 0x0a, 0x18, 0x55, 0x6e, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x4a, 0x56, 0x4d, 0x52, 0x75,
3223 0x6c, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f,
3224 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
3225 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x12, 0x0a,
3226 0x04, 0x72, 0x75, 0x6c, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x72, 0x75, 0x6c,
3227 0x65, 0x12, 0x12, 0x0a, 0x04, 0x70, 0x6f, 0x72, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52,
3228 0x04, 0x70, 0x6f, 0x72, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53,
3229 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x22,
3230 0xf0, 0x01, 0x0a, 0x16, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x42, 0x6c, 0x6f, 0x63, 0x6b, 0x43, 0x68,
3231 0x61, 0x6f, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f,
3232 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
3233 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x49, 0x64, 0x12, 0x1f, 0x0a,
3234 0x0b, 0x76, 0x6f, 0x6c, 0x75, 0x6d, 0x65, 0x5f, 0x70, 0x61, 0x74, 0x68, 0x18, 0x02, 0x20, 0x01,
3235 0x28, 0x09, 0x52, 0x0a, 0x76, 0x6f, 0x6c, 0x75, 0x6d, 0x65, 0x50, 0x61, 0x74, 0x68, 0x12, 0x39,
3236 0x0a, 0x06, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x21,
3237 0x2e, 0x70, 0x62, 0x2e, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x42, 0x6c, 0x6f, 0x63, 0x6b, 0x43, 0x68,
3238 0x61, 0x6f, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x41, 0x63, 0x74, 0x69, 0x6f,
3239 0x6e, 0x52, 0x06, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x28, 0x0a, 0x05, 0x64, 0x65, 0x6c,
3240 0x61, 0x79, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x70, 0x62, 0x2e, 0x42, 0x6c,
3241 0x6f, 0x63, 0x6b, 0x44, 0x65, 0x6c, 0x61, 0x79, 0x53, 0x70, 0x65, 0x63, 0x52, 0x05, 0x64, 0x65,
3242 0x6c, 0x61, 0x79, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x18, 0x06,
3243 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x4e, 0x53, 0x22, 0x13, 0x0a,
3244 0x06, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x09, 0x0a, 0x05, 0x44, 0x65, 0x6c, 0x61, 0x79,
3245 0x10, 0x00, 0x22, 0x60, 0x0a, 0x0e, 0x42, 0x6c, 0x6f, 0x63, 0x6b, 0x44, 0x65, 0x6c, 0x61, 0x79,
3246 0x53, 0x70, 0x65, 0x63, 0x12, 0x14, 0x0a, 0x05, 0x64, 0x65, 0x6c, 0x61, 0x79, 0x18, 0x01, 0x20,
3247 0x01, 0x28, 0x03, 0x52, 0x05, 0x64, 0x65, 0x6c, 0x61, 0x79, 0x12, 0x20, 0x0a, 0x0b, 0x63, 0x6f,
3248 0x72, 0x72, 0x65, 0x6c, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x01, 0x52,
3249 0x0b, 0x63, 0x6f, 0x72, 0x72, 0x65, 0x6c, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x16, 0x0a, 0x06,
3250 0x6a, 0x69, 0x74, 0x74, 0x65, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x6a, 0x69,
3251 0x74, 0x74, 0x65, 0x72, 0x22, 0x43, 0x0a, 0x0e, 0x42, 0x6c, 0x6f, 0x63, 0x6b, 0x4c, 0x69, 0x6d,
3252 0x69, 0x74, 0x53, 0x70, 0x65, 0x63, 0x12, 0x14, 0x0a, 0x05, 0x71, 0x75, 0x6f, 0x74, 0x61, 0x18,
3253 0x01, 0x20, 0x01, 0x28, 0x04, 0x52, 0x05, 0x71, 0x75, 0x6f, 0x74, 0x61, 0x12, 0x1b, 0x0a, 0x09,
3254 0x70, 0x65, 0x72, 0x69, 0x6f, 0x64, 0x5f, 0x75, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x52,
3255 0x08, 0x70, 0x65, 0x72, 0x69, 0x6f, 0x64, 0x55, 0x73, 0x22, 0x3c, 0x0a, 0x17, 0x41, 0x70, 0x70,
3256 0x6c, 0x79, 0x42, 0x6c, 0x6f, 0x63, 0x6b, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x52, 0x65, 0x73, 0x70,
3257 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x21, 0x0a, 0x0c, 0x69, 0x6e, 0x6a, 0x65, 0x63, 0x74, 0x69, 0x6f,
3258 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0b, 0x69, 0x6e, 0x6a, 0x65,
3259 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x22, 0x3d, 0x0a, 0x18, 0x52, 0x65, 0x63, 0x6f, 0x76,
3260 0x65, 0x72, 0x42, 0x6c, 0x6f, 0x63, 0x6b, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x52, 0x65, 0x71, 0x75,
3261 0x65, 0x73, 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x69, 0x6e, 0x6a, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e,
3262 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0b, 0x69, 0x6e, 0x6a, 0x65, 0x63,
3263 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x32, 0xd2, 0x08, 0x0a, 0x0b, 0x43, 0x68, 0x61, 0x6f, 0x73,
3264 0x44, 0x61, 0x65, 0x6d, 0x6f, 0x6e, 0x12, 0x32, 0x0a, 0x06, 0x53, 0x65, 0x74, 0x54, 0x63, 0x73,
3265 0x12, 0x0e, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x63, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
3266 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62,
3267 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x3a, 0x0a, 0x0b, 0x46, 0x6c,
3268 0x75, 0x73, 0x68, 0x49, 0x50, 0x53, 0x65, 0x74, 0x73, 0x12, 0x11, 0x2e, 0x70, 0x62, 0x2e, 0x49,
3269 0x50, 0x53, 0x65, 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67,
3270 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45,
3271 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x48, 0x0a, 0x11, 0x53, 0x65, 0x74, 0x49, 0x70, 0x74,
3272 0x61, 0x62, 0x6c, 0x65, 0x73, 0x43, 0x68, 0x61, 0x69, 0x6e, 0x73, 0x12, 0x19, 0x2e, 0x70, 0x62,
3273 0x2e, 0x49, 0x70, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x43, 0x68, 0x61, 0x69, 0x6e, 0x73, 0x52,
3274 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
3275 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00,
3276 0x12, 0x3a, 0x0a, 0x0d, 0x53, 0x65, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x4f, 0x66, 0x66, 0x73, 0x65,
3277 0x74, 0x12, 0x0f, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65,
3278 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74,
3279 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x3e, 0x0a, 0x11,
3280 0x52, 0x65, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x54, 0x69, 0x6d, 0x65, 0x4f, 0x66, 0x66, 0x73, 0x65,
3281 0x74, 0x12, 0x0f, 0x2e, 0x70, 0x62, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65,
3282 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74,
3283 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x3f, 0x0a, 0x0d,
3284 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x4b, 0x69, 0x6c, 0x6c, 0x12, 0x14, 0x2e,
3285 0x70, 0x62, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75,
3286 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f,
3287 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x40, 0x0a,
3288 0x0f, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x47, 0x65, 0x74, 0x50, 0x69, 0x64,
3289 0x12, 0x14, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x52,
3290 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x15, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x6f, 0x6e, 0x74,
3291 0x61, 0x69, 0x6e, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12,
3292 0x40, 0x0a, 0x0d, 0x45, 0x78, 0x65, 0x63, 0x53, 0x74, 0x72, 0x65, 0x73, 0x73, 0x6f, 0x72, 0x73,
3293 0x12, 0x15, 0x2e, 0x70, 0x62, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x53, 0x74, 0x72, 0x65, 0x73, 0x73,
3294 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x70, 0x62, 0x2e, 0x45, 0x78, 0x65,
3295 0x63, 0x53, 0x74, 0x72, 0x65, 0x73, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22,
3296 0x00, 0x12, 0x44, 0x0a, 0x0f, 0x43, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x53, 0x74, 0x72, 0x65, 0x73,
3297 0x73, 0x6f, 0x72, 0x73, 0x12, 0x17, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x61, 0x6e, 0x63, 0x65, 0x6c,
3298 0x53, 0x74, 0x72, 0x65, 0x73, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e,
3299 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e,
3300 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x43, 0x0a, 0x0c, 0x41, 0x70, 0x70, 0x6c, 0x79,
3301 0x49, 0x4f, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x12, 0x17, 0x2e, 0x70, 0x62, 0x2e, 0x41, 0x70, 0x70,
3302 0x6c, 0x79, 0x49, 0x4f, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
3303 0x1a, 0x18, 0x2e, 0x70, 0x62, 0x2e, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x49, 0x4f, 0x43, 0x68, 0x61,
3304 0x6f, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x49, 0x0a, 0x0e,
3305 0x41, 0x70, 0x70, 0x6c, 0x79, 0x48, 0x74, 0x74, 0x70, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x12, 0x19,
3306 0x2e, 0x70, 0x62, 0x2e, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x48, 0x74, 0x74, 0x70, 0x43, 0x68, 0x61,
3307 0x6f, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1a, 0x2e, 0x70, 0x62, 0x2e, 0x41,
3308 0x70, 0x70, 0x6c, 0x79, 0x48, 0x74, 0x74, 0x70, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x52, 0x65, 0x73,
3309 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x4c, 0x0a, 0x0f, 0x41, 0x70, 0x70, 0x6c, 0x79,
3310 0x42, 0x6c, 0x6f, 0x63, 0x6b, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x12, 0x1a, 0x2e, 0x70, 0x62, 0x2e,
3311 0x41, 0x70, 0x70, 0x6c, 0x79, 0x42, 0x6c, 0x6f, 0x63, 0x6b, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x52,
3312 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1b, 0x2e, 0x70, 0x62, 0x2e, 0x41, 0x70, 0x70, 0x6c,
3313 0x79, 0x42, 0x6c, 0x6f, 0x63, 0x6b, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f,
3314 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x4b, 0x0a, 0x11, 0x52, 0x65, 0x63, 0x6f, 0x76, 0x65, 0x72,
3315 0x42, 0x6c, 0x6f, 0x63, 0x6b, 0x43, 0x68, 0x61, 0x6f, 0x73, 0x12, 0x1c, 0x2e, 0x70, 0x62, 0x2e,
3316 0x52, 0x65, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x42, 0x6c, 0x6f, 0x63, 0x6b, 0x43, 0x68, 0x61, 0x6f,
3317 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
3318 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79,
3319 0x22, 0x00, 0x12, 0x41, 0x0a, 0x0c, 0x53, 0x65, 0x74, 0x44, 0x4e, 0x53, 0x53, 0x65, 0x72, 0x76,
3320 0x65, 0x72, 0x12, 0x17, 0x2e, 0x70, 0x62, 0x2e, 0x53, 0x65, 0x74, 0x44, 0x4e, 0x53, 0x53, 0x65,
3321 0x72, 0x76, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f,
3322 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d,
3323 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x47, 0x0a, 0x0f, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c,
3324 0x4a, 0x56, 0x4d, 0x52, 0x75, 0x6c, 0x65, 0x73, 0x12, 0x1a, 0x2e, 0x70, 0x62, 0x2e, 0x49, 0x6e,
3325 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x4a, 0x56, 0x4d, 0x52, 0x75, 0x6c, 0x65, 0x73, 0x52, 0x65, 0x71,
3326 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72,
3327 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x4b,
3328 0x0a, 0x11, 0x55, 0x6e, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x4a, 0x56, 0x4d, 0x52, 0x75,
3329 0x6c, 0x65, 0x73, 0x12, 0x1c, 0x2e, 0x70, 0x62, 0x2e, 0x55, 0x6e, 0x69, 0x6e, 0x73, 0x74, 0x61,
3330 0x6c, 0x6c, 0x4a, 0x56, 0x4d, 0x52, 0x75, 0x6c, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
3331 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
3332 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x62, 0x06, 0x70, 0x72, 0x6f,
3333 0x74, 0x6f, 0x33,
3334 }
3335
3336 var (
3337 file_chaosdaemon_proto_rawDescOnce sync.Once
3338 file_chaosdaemon_proto_rawDescData = file_chaosdaemon_proto_rawDesc
3339 )
3340
3341 func file_chaosdaemon_proto_rawDescGZIP() []byte {
3342 file_chaosdaemon_proto_rawDescOnce.Do(func() {
3343 file_chaosdaemon_proto_rawDescData = protoimpl.X.CompressGZIP(file_chaosdaemon_proto_rawDescData)
3344 })
3345 return file_chaosdaemon_proto_rawDescData
3346 }
3347
3348 var file_chaosdaemon_proto_enumTypes = make([]protoimpl.EnumInfo, 5)
3349 var file_chaosdaemon_proto_msgTypes = make([]protoimpl.MessageInfo, 37)
3350 var file_chaosdaemon_proto_goTypes = []interface{}{
3351 (Chain_Direction)(0),
3352 (ContainerAction_Action)(0),
3353 (ExecStressRequest_Scope)(0),
3354 (Tc_Type)(0),
3355 (ApplyBlockChaosRequest_Action)(0),
3356 (*TcHandle)(nil),
3357 (*ContainerRequest)(nil),
3358 (*ContainerResponse)(nil),
3359 (*NetemRequest)(nil),
3360 (*Netem)(nil),
3361 (*TbfRequest)(nil),
3362 (*Tbf)(nil),
3363 (*QdiscRequest)(nil),
3364 (*Qdisc)(nil),
3365 (*EmatchFilterRequest)(nil),
3366 (*EmatchFilter)(nil),
3367 (*TcFilterRequest)(nil),
3368 (*TcFilter)(nil),
3369 (*IPSetsRequest)(nil),
3370 (*IPSet)(nil),
3371 (*CidrAndPort)(nil),
3372 (*IptablesChainsRequest)(nil),
3373 (*Chain)(nil),
3374 (*TimeRequest)(nil),
3375 (*ContainerAction)(nil),
3376 (*ExecStressRequest)(nil),
3377 (*ExecStressResponse)(nil),
3378 (*CancelStressRequest)(nil),
3379 (*ApplyIOChaosRequest)(nil),
3380 (*ApplyIOChaosResponse)(nil),
3381 (*ApplyHttpChaosRequest)(nil),
3382 (*ApplyHttpChaosResponse)(nil),
3383 (*TcsRequest)(nil),
3384 (*Tc)(nil),
3385 (*SetDNSServerRequest)(nil),
3386 (*InstallJVMRulesRequest)(nil),
3387 (*UninstallJVMRulesRequest)(nil),
3388 (*ApplyBlockChaosRequest)(nil),
3389 (*BlockDelaySpec)(nil),
3390 (*BlockLimitSpec)(nil),
3391 (*ApplyBlockChaosResponse)(nil),
3392 (*RecoverBlockChaosRequest)(nil),
3393 (*empty.Empty)(nil),
3394 }
3395 var file_chaosdaemon_proto_depIdxs = []int32{
3396 24,
3397 9,
3398 5,
3399 5,
3400 5,
3401 5,
3402 11,
3403 13,
3404 5,
3405 5,
3406 15,
3407 5,
3408 5,
3409 17,
3410 5,
3411 19,
3412 20,
3413 22,
3414 0,
3415 1,
3416 2,
3417 33,
3418 3,
3419 9,
3420 11,
3421 4,
3422 38,
3423 32,
3424 18,
3425 21,
3426 23,
3427 23,
3428 6,
3429 6,
3430 25,
3431 27,
3432 28,
3433 30,
3434 37,
3435 41,
3436 34,
3437 35,
3438 36,
3439 42,
3440 42,
3441 42,
3442 42,
3443 42,
3444 42,
3445 7,
3446 26,
3447 42,
3448 29,
3449 31,
3450 40,
3451 42,
3452 42,
3453 42,
3454 42,
3455 43,
3456 27,
3457 27,
3458 27,
3459 0,
3460 }
3461
3462 func init() { file_chaosdaemon_proto_init() }
3463 func file_chaosdaemon_proto_init() {
3464 if File_chaosdaemon_proto != nil {
3465 return
3466 }
3467 if !protoimpl.UnsafeEnabled {
3468 file_chaosdaemon_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
3469 switch v := v.(*TcHandle); i {
3470 case 0:
3471 return &v.state
3472 case 1:
3473 return &v.sizeCache
3474 case 2:
3475 return &v.unknownFields
3476 default:
3477 return nil
3478 }
3479 }
3480 file_chaosdaemon_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
3481 switch v := v.(*ContainerRequest); i {
3482 case 0:
3483 return &v.state
3484 case 1:
3485 return &v.sizeCache
3486 case 2:
3487 return &v.unknownFields
3488 default:
3489 return nil
3490 }
3491 }
3492 file_chaosdaemon_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
3493 switch v := v.(*ContainerResponse); i {
3494 case 0:
3495 return &v.state
3496 case 1:
3497 return &v.sizeCache
3498 case 2:
3499 return &v.unknownFields
3500 default:
3501 return nil
3502 }
3503 }
3504 file_chaosdaemon_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
3505 switch v := v.(*NetemRequest); i {
3506 case 0:
3507 return &v.state
3508 case 1:
3509 return &v.sizeCache
3510 case 2:
3511 return &v.unknownFields
3512 default:
3513 return nil
3514 }
3515 }
3516 file_chaosdaemon_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
3517 switch v := v.(*Netem); i {
3518 case 0:
3519 return &v.state
3520 case 1:
3521 return &v.sizeCache
3522 case 2:
3523 return &v.unknownFields
3524 default:
3525 return nil
3526 }
3527 }
3528 file_chaosdaemon_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
3529 switch v := v.(*TbfRequest); i {
3530 case 0:
3531 return &v.state
3532 case 1:
3533 return &v.sizeCache
3534 case 2:
3535 return &v.unknownFields
3536 default:
3537 return nil
3538 }
3539 }
3540 file_chaosdaemon_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
3541 switch v := v.(*Tbf); i {
3542 case 0:
3543 return &v.state
3544 case 1:
3545 return &v.sizeCache
3546 case 2:
3547 return &v.unknownFields
3548 default:
3549 return nil
3550 }
3551 }
3552 file_chaosdaemon_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
3553 switch v := v.(*QdiscRequest); i {
3554 case 0:
3555 return &v.state
3556 case 1:
3557 return &v.sizeCache
3558 case 2:
3559 return &v.unknownFields
3560 default:
3561 return nil
3562 }
3563 }
3564 file_chaosdaemon_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
3565 switch v := v.(*Qdisc); i {
3566 case 0:
3567 return &v.state
3568 case 1:
3569 return &v.sizeCache
3570 case 2:
3571 return &v.unknownFields
3572 default:
3573 return nil
3574 }
3575 }
3576 file_chaosdaemon_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
3577 switch v := v.(*EmatchFilterRequest); i {
3578 case 0:
3579 return &v.state
3580 case 1:
3581 return &v.sizeCache
3582 case 2:
3583 return &v.unknownFields
3584 default:
3585 return nil
3586 }
3587 }
3588 file_chaosdaemon_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
3589 switch v := v.(*EmatchFilter); i {
3590 case 0:
3591 return &v.state
3592 case 1:
3593 return &v.sizeCache
3594 case 2:
3595 return &v.unknownFields
3596 default:
3597 return nil
3598 }
3599 }
3600 file_chaosdaemon_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
3601 switch v := v.(*TcFilterRequest); i {
3602 case 0:
3603 return &v.state
3604 case 1:
3605 return &v.sizeCache
3606 case 2:
3607 return &v.unknownFields
3608 default:
3609 return nil
3610 }
3611 }
3612 file_chaosdaemon_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
3613 switch v := v.(*TcFilter); i {
3614 case 0:
3615 return &v.state
3616 case 1:
3617 return &v.sizeCache
3618 case 2:
3619 return &v.unknownFields
3620 default:
3621 return nil
3622 }
3623 }
3624 file_chaosdaemon_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
3625 switch v := v.(*IPSetsRequest); i {
3626 case 0:
3627 return &v.state
3628 case 1:
3629 return &v.sizeCache
3630 case 2:
3631 return &v.unknownFields
3632 default:
3633 return nil
3634 }
3635 }
3636 file_chaosdaemon_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
3637 switch v := v.(*IPSet); i {
3638 case 0:
3639 return &v.state
3640 case 1:
3641 return &v.sizeCache
3642 case 2:
3643 return &v.unknownFields
3644 default:
3645 return nil
3646 }
3647 }
3648 file_chaosdaemon_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
3649 switch v := v.(*CidrAndPort); i {
3650 case 0:
3651 return &v.state
3652 case 1:
3653 return &v.sizeCache
3654 case 2:
3655 return &v.unknownFields
3656 default:
3657 return nil
3658 }
3659 }
3660 file_chaosdaemon_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
3661 switch v := v.(*IptablesChainsRequest); i {
3662 case 0:
3663 return &v.state
3664 case 1:
3665 return &v.sizeCache
3666 case 2:
3667 return &v.unknownFields
3668 default:
3669 return nil
3670 }
3671 }
3672 file_chaosdaemon_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
3673 switch v := v.(*Chain); i {
3674 case 0:
3675 return &v.state
3676 case 1:
3677 return &v.sizeCache
3678 case 2:
3679 return &v.unknownFields
3680 default:
3681 return nil
3682 }
3683 }
3684 file_chaosdaemon_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} {
3685 switch v := v.(*TimeRequest); i {
3686 case 0:
3687 return &v.state
3688 case 1:
3689 return &v.sizeCache
3690 case 2:
3691 return &v.unknownFields
3692 default:
3693 return nil
3694 }
3695 }
3696 file_chaosdaemon_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} {
3697 switch v := v.(*ContainerAction); i {
3698 case 0:
3699 return &v.state
3700 case 1:
3701 return &v.sizeCache
3702 case 2:
3703 return &v.unknownFields
3704 default:
3705 return nil
3706 }
3707 }
3708 file_chaosdaemon_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} {
3709 switch v := v.(*ExecStressRequest); i {
3710 case 0:
3711 return &v.state
3712 case 1:
3713 return &v.sizeCache
3714 case 2:
3715 return &v.unknownFields
3716 default:
3717 return nil
3718 }
3719 }
3720 file_chaosdaemon_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} {
3721 switch v := v.(*ExecStressResponse); i {
3722 case 0:
3723 return &v.state
3724 case 1:
3725 return &v.sizeCache
3726 case 2:
3727 return &v.unknownFields
3728 default:
3729 return nil
3730 }
3731 }
3732 file_chaosdaemon_proto_msgTypes[22].Exporter = func(v interface{}, i int) interface{} {
3733 switch v := v.(*CancelStressRequest); i {
3734 case 0:
3735 return &v.state
3736 case 1:
3737 return &v.sizeCache
3738 case 2:
3739 return &v.unknownFields
3740 default:
3741 return nil
3742 }
3743 }
3744 file_chaosdaemon_proto_msgTypes[23].Exporter = func(v interface{}, i int) interface{} {
3745 switch v := v.(*ApplyIOChaosRequest); i {
3746 case 0:
3747 return &v.state
3748 case 1:
3749 return &v.sizeCache
3750 case 2:
3751 return &v.unknownFields
3752 default:
3753 return nil
3754 }
3755 }
3756 file_chaosdaemon_proto_msgTypes[24].Exporter = func(v interface{}, i int) interface{} {
3757 switch v := v.(*ApplyIOChaosResponse); i {
3758 case 0:
3759 return &v.state
3760 case 1:
3761 return &v.sizeCache
3762 case 2:
3763 return &v.unknownFields
3764 default:
3765 return nil
3766 }
3767 }
3768 file_chaosdaemon_proto_msgTypes[25].Exporter = func(v interface{}, i int) interface{} {
3769 switch v := v.(*ApplyHttpChaosRequest); i {
3770 case 0:
3771 return &v.state
3772 case 1:
3773 return &v.sizeCache
3774 case 2:
3775 return &v.unknownFields
3776 default:
3777 return nil
3778 }
3779 }
3780 file_chaosdaemon_proto_msgTypes[26].Exporter = func(v interface{}, i int) interface{} {
3781 switch v := v.(*ApplyHttpChaosResponse); i {
3782 case 0:
3783 return &v.state
3784 case 1:
3785 return &v.sizeCache
3786 case 2:
3787 return &v.unknownFields
3788 default:
3789 return nil
3790 }
3791 }
3792 file_chaosdaemon_proto_msgTypes[27].Exporter = func(v interface{}, i int) interface{} {
3793 switch v := v.(*TcsRequest); i {
3794 case 0:
3795 return &v.state
3796 case 1:
3797 return &v.sizeCache
3798 case 2:
3799 return &v.unknownFields
3800 default:
3801 return nil
3802 }
3803 }
3804 file_chaosdaemon_proto_msgTypes[28].Exporter = func(v interface{}, i int) interface{} {
3805 switch v := v.(*Tc); i {
3806 case 0:
3807 return &v.state
3808 case 1:
3809 return &v.sizeCache
3810 case 2:
3811 return &v.unknownFields
3812 default:
3813 return nil
3814 }
3815 }
3816 file_chaosdaemon_proto_msgTypes[29].Exporter = func(v interface{}, i int) interface{} {
3817 switch v := v.(*SetDNSServerRequest); i {
3818 case 0:
3819 return &v.state
3820 case 1:
3821 return &v.sizeCache
3822 case 2:
3823 return &v.unknownFields
3824 default:
3825 return nil
3826 }
3827 }
3828 file_chaosdaemon_proto_msgTypes[30].Exporter = func(v interface{}, i int) interface{} {
3829 switch v := v.(*InstallJVMRulesRequest); i {
3830 case 0:
3831 return &v.state
3832 case 1:
3833 return &v.sizeCache
3834 case 2:
3835 return &v.unknownFields
3836 default:
3837 return nil
3838 }
3839 }
3840 file_chaosdaemon_proto_msgTypes[31].Exporter = func(v interface{}, i int) interface{} {
3841 switch v := v.(*UninstallJVMRulesRequest); i {
3842 case 0:
3843 return &v.state
3844 case 1:
3845 return &v.sizeCache
3846 case 2:
3847 return &v.unknownFields
3848 default:
3849 return nil
3850 }
3851 }
3852 file_chaosdaemon_proto_msgTypes[32].Exporter = func(v interface{}, i int) interface{} {
3853 switch v := v.(*ApplyBlockChaosRequest); i {
3854 case 0:
3855 return &v.state
3856 case 1:
3857 return &v.sizeCache
3858 case 2:
3859 return &v.unknownFields
3860 default:
3861 return nil
3862 }
3863 }
3864 file_chaosdaemon_proto_msgTypes[33].Exporter = func(v interface{}, i int) interface{} {
3865 switch v := v.(*BlockDelaySpec); i {
3866 case 0:
3867 return &v.state
3868 case 1:
3869 return &v.sizeCache
3870 case 2:
3871 return &v.unknownFields
3872 default:
3873 return nil
3874 }
3875 }
3876 file_chaosdaemon_proto_msgTypes[34].Exporter = func(v interface{}, i int) interface{} {
3877 switch v := v.(*BlockLimitSpec); i {
3878 case 0:
3879 return &v.state
3880 case 1:
3881 return &v.sizeCache
3882 case 2:
3883 return &v.unknownFields
3884 default:
3885 return nil
3886 }
3887 }
3888 file_chaosdaemon_proto_msgTypes[35].Exporter = func(v interface{}, i int) interface{} {
3889 switch v := v.(*ApplyBlockChaosResponse); i {
3890 case 0:
3891 return &v.state
3892 case 1:
3893 return &v.sizeCache
3894 case 2:
3895 return &v.unknownFields
3896 default:
3897 return nil
3898 }
3899 }
3900 file_chaosdaemon_proto_msgTypes[36].Exporter = func(v interface{}, i int) interface{} {
3901 switch v := v.(*RecoverBlockChaosRequest); i {
3902 case 0:
3903 return &v.state
3904 case 1:
3905 return &v.sizeCache
3906 case 2:
3907 return &v.unknownFields
3908 default:
3909 return nil
3910 }
3911 }
3912 }
3913 type x struct{}
3914 out := protoimpl.TypeBuilder{
3915 File: protoimpl.DescBuilder{
3916 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
3917 RawDescriptor: file_chaosdaemon_proto_rawDesc,
3918 NumEnums: 5,
3919 NumMessages: 37,
3920 NumExtensions: 0,
3921 NumServices: 1,
3922 },
3923 GoTypes: file_chaosdaemon_proto_goTypes,
3924 DependencyIndexes: file_chaosdaemon_proto_depIdxs,
3925 EnumInfos: file_chaosdaemon_proto_enumTypes,
3926 MessageInfos: file_chaosdaemon_proto_msgTypes,
3927 }.Build()
3928 File_chaosdaemon_proto = out.File
3929 file_chaosdaemon_proto_rawDesc = nil
3930 file_chaosdaemon_proto_goTypes = nil
3931 file_chaosdaemon_proto_depIdxs = nil
3932 }
3933
3934
3935 var _ context.Context
3936 var _ grpc.ClientConnInterface
3937
3938
3939
3940 const _ = grpc.SupportPackageIsVersion6
3941
3942
3943
3944
3945 type ChaosDaemonClient interface {
3946 SetTcs(ctx context.Context, in *TcsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3947 FlushIPSets(ctx context.Context, in *IPSetsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3948 SetIptablesChains(ctx context.Context, in *IptablesChainsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3949 SetTimeOffset(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3950 RecoverTimeOffset(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3951 ContainerKill(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3952 ContainerGetPid(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*ContainerResponse, error)
3953 ExecStressors(ctx context.Context, in *ExecStressRequest, opts ...grpc.CallOption) (*ExecStressResponse, error)
3954 CancelStressors(ctx context.Context, in *CancelStressRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3955 ApplyIOChaos(ctx context.Context, in *ApplyIOChaosRequest, opts ...grpc.CallOption) (*ApplyIOChaosResponse, error)
3956 ApplyHttpChaos(ctx context.Context, in *ApplyHttpChaosRequest, opts ...grpc.CallOption) (*ApplyHttpChaosResponse, error)
3957 ApplyBlockChaos(ctx context.Context, in *ApplyBlockChaosRequest, opts ...grpc.CallOption) (*ApplyBlockChaosResponse, error)
3958 RecoverBlockChaos(ctx context.Context, in *RecoverBlockChaosRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3959 SetDNSServer(ctx context.Context, in *SetDNSServerRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3960 InstallJVMRules(ctx context.Context, in *InstallJVMRulesRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3961 UninstallJVMRules(ctx context.Context, in *UninstallJVMRulesRequest, opts ...grpc.CallOption) (*empty.Empty, error)
3962 }
3963
3964 type chaosDaemonClient struct {
3965 cc grpc.ClientConnInterface
3966 }
3967
3968 func NewChaosDaemonClient(cc grpc.ClientConnInterface) ChaosDaemonClient {
3969 return &chaosDaemonClient{cc}
3970 }
3971
3972 func (c *chaosDaemonClient) SetTcs(ctx context.Context, in *TcsRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3973 out := new(empty.Empty)
3974 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/SetTcs", in, out, opts...)
3975 if err != nil {
3976 return nil, err
3977 }
3978 return out, nil
3979 }
3980
3981 func (c *chaosDaemonClient) FlushIPSets(ctx context.Context, in *IPSetsRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3982 out := new(empty.Empty)
3983 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/FlushIPSets", in, out, opts...)
3984 if err != nil {
3985 return nil, err
3986 }
3987 return out, nil
3988 }
3989
3990 func (c *chaosDaemonClient) SetIptablesChains(ctx context.Context, in *IptablesChainsRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
3991 out := new(empty.Empty)
3992 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/SetIptablesChains", in, out, opts...)
3993 if err != nil {
3994 return nil, err
3995 }
3996 return out, nil
3997 }
3998
3999 func (c *chaosDaemonClient) SetTimeOffset(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
4000 out := new(empty.Empty)
4001 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/SetTimeOffset", in, out, opts...)
4002 if err != nil {
4003 return nil, err
4004 }
4005 return out, nil
4006 }
4007
4008 func (c *chaosDaemonClient) RecoverTimeOffset(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
4009 out := new(empty.Empty)
4010 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/RecoverTimeOffset", in, out, opts...)
4011 if err != nil {
4012 return nil, err
4013 }
4014 return out, nil
4015 }
4016
4017 func (c *chaosDaemonClient) ContainerKill(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
4018 out := new(empty.Empty)
4019 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/ContainerKill", in, out, opts...)
4020 if err != nil {
4021 return nil, err
4022 }
4023 return out, nil
4024 }
4025
4026 func (c *chaosDaemonClient) ContainerGetPid(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*ContainerResponse, error) {
4027 out := new(ContainerResponse)
4028 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/ContainerGetPid", in, out, opts...)
4029 if err != nil {
4030 return nil, err
4031 }
4032 return out, nil
4033 }
4034
4035 func (c *chaosDaemonClient) ExecStressors(ctx context.Context, in *ExecStressRequest, opts ...grpc.CallOption) (*ExecStressResponse, error) {
4036 out := new(ExecStressResponse)
4037 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/ExecStressors", in, out, opts...)
4038 if err != nil {
4039 return nil, err
4040 }
4041 return out, nil
4042 }
4043
4044 func (c *chaosDaemonClient) CancelStressors(ctx context.Context, in *CancelStressRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
4045 out := new(empty.Empty)
4046 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/CancelStressors", in, out, opts...)
4047 if err != nil {
4048 return nil, err
4049 }
4050 return out, nil
4051 }
4052
4053 func (c *chaosDaemonClient) ApplyIOChaos(ctx context.Context, in *ApplyIOChaosRequest, opts ...grpc.CallOption) (*ApplyIOChaosResponse, error) {
4054 out := new(ApplyIOChaosResponse)
4055 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/ApplyIOChaos", in, out, opts...)
4056 if err != nil {
4057 return nil, err
4058 }
4059 return out, nil
4060 }
4061
4062 func (c *chaosDaemonClient) ApplyHttpChaos(ctx context.Context, in *ApplyHttpChaosRequest, opts ...grpc.CallOption) (*ApplyHttpChaosResponse, error) {
4063 out := new(ApplyHttpChaosResponse)
4064 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/ApplyHttpChaos", in, out, opts...)
4065 if err != nil {
4066 return nil, err
4067 }
4068 return out, nil
4069 }
4070
4071 func (c *chaosDaemonClient) ApplyBlockChaos(ctx context.Context, in *ApplyBlockChaosRequest, opts ...grpc.CallOption) (*ApplyBlockChaosResponse, error) {
4072 out := new(ApplyBlockChaosResponse)
4073 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/ApplyBlockChaos", in, out, opts...)
4074 if err != nil {
4075 return nil, err
4076 }
4077 return out, nil
4078 }
4079
4080 func (c *chaosDaemonClient) RecoverBlockChaos(ctx context.Context, in *RecoverBlockChaosRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
4081 out := new(empty.Empty)
4082 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/RecoverBlockChaos", in, out, opts...)
4083 if err != nil {
4084 return nil, err
4085 }
4086 return out, nil
4087 }
4088
4089 func (c *chaosDaemonClient) SetDNSServer(ctx context.Context, in *SetDNSServerRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
4090 out := new(empty.Empty)
4091 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/SetDNSServer", in, out, opts...)
4092 if err != nil {
4093 return nil, err
4094 }
4095 return out, nil
4096 }
4097
4098 func (c *chaosDaemonClient) InstallJVMRules(ctx context.Context, in *InstallJVMRulesRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
4099 out := new(empty.Empty)
4100 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/InstallJVMRules", in, out, opts...)
4101 if err != nil {
4102 return nil, err
4103 }
4104 return out, nil
4105 }
4106
4107 func (c *chaosDaemonClient) UninstallJVMRules(ctx context.Context, in *UninstallJVMRulesRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
4108 out := new(empty.Empty)
4109 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/UninstallJVMRules", in, out, opts...)
4110 if err != nil {
4111 return nil, err
4112 }
4113 return out, nil
4114 }
4115
4116
4117 type ChaosDaemonServer interface {
4118 SetTcs(context.Context, *TcsRequest) (*empty.Empty, error)
4119 FlushIPSets(context.Context, *IPSetsRequest) (*empty.Empty, error)
4120 SetIptablesChains(context.Context, *IptablesChainsRequest) (*empty.Empty, error)
4121 SetTimeOffset(context.Context, *TimeRequest) (*empty.Empty, error)
4122 RecoverTimeOffset(context.Context, *TimeRequest) (*empty.Empty, error)
4123 ContainerKill(context.Context, *ContainerRequest) (*empty.Empty, error)
4124 ContainerGetPid(context.Context, *ContainerRequest) (*ContainerResponse, error)
4125 ExecStressors(context.Context, *ExecStressRequest) (*ExecStressResponse, error)
4126 CancelStressors(context.Context, *CancelStressRequest) (*empty.Empty, error)
4127 ApplyIOChaos(context.Context, *ApplyIOChaosRequest) (*ApplyIOChaosResponse, error)
4128 ApplyHttpChaos(context.Context, *ApplyHttpChaosRequest) (*ApplyHttpChaosResponse, error)
4129 ApplyBlockChaos(context.Context, *ApplyBlockChaosRequest) (*ApplyBlockChaosResponse, error)
4130 RecoverBlockChaos(context.Context, *RecoverBlockChaosRequest) (*empty.Empty, error)
4131 SetDNSServer(context.Context, *SetDNSServerRequest) (*empty.Empty, error)
4132 InstallJVMRules(context.Context, *InstallJVMRulesRequest) (*empty.Empty, error)
4133 UninstallJVMRules(context.Context, *UninstallJVMRulesRequest) (*empty.Empty, error)
4134 }
4135
4136
4137 type UnimplementedChaosDaemonServer struct {
4138 }
4139
4140 func (*UnimplementedChaosDaemonServer) SetTcs(context.Context, *TcsRequest) (*empty.Empty, error) {
4141 return nil, status.Errorf(codes.Unimplemented, "method SetTcs not implemented")
4142 }
4143 func (*UnimplementedChaosDaemonServer) FlushIPSets(context.Context, *IPSetsRequest) (*empty.Empty, error) {
4144 return nil, status.Errorf(codes.Unimplemented, "method FlushIPSets not implemented")
4145 }
4146 func (*UnimplementedChaosDaemonServer) SetIptablesChains(context.Context, *IptablesChainsRequest) (*empty.Empty, error) {
4147 return nil, status.Errorf(codes.Unimplemented, "method SetIptablesChains not implemented")
4148 }
4149 func (*UnimplementedChaosDaemonServer) SetTimeOffset(context.Context, *TimeRequest) (*empty.Empty, error) {
4150 return nil, status.Errorf(codes.Unimplemented, "method SetTimeOffset not implemented")
4151 }
4152 func (*UnimplementedChaosDaemonServer) RecoverTimeOffset(context.Context, *TimeRequest) (*empty.Empty, error) {
4153 return nil, status.Errorf(codes.Unimplemented, "method RecoverTimeOffset not implemented")
4154 }
4155 func (*UnimplementedChaosDaemonServer) ContainerKill(context.Context, *ContainerRequest) (*empty.Empty, error) {
4156 return nil, status.Errorf(codes.Unimplemented, "method ContainerKill not implemented")
4157 }
4158 func (*UnimplementedChaosDaemonServer) ContainerGetPid(context.Context, *ContainerRequest) (*ContainerResponse, error) {
4159 return nil, status.Errorf(codes.Unimplemented, "method ContainerGetPid not implemented")
4160 }
4161 func (*UnimplementedChaosDaemonServer) ExecStressors(context.Context, *ExecStressRequest) (*ExecStressResponse, error) {
4162 return nil, status.Errorf(codes.Unimplemented, "method ExecStressors not implemented")
4163 }
4164 func (*UnimplementedChaosDaemonServer) CancelStressors(context.Context, *CancelStressRequest) (*empty.Empty, error) {
4165 return nil, status.Errorf(codes.Unimplemented, "method CancelStressors not implemented")
4166 }
4167 func (*UnimplementedChaosDaemonServer) ApplyIOChaos(context.Context, *ApplyIOChaosRequest) (*ApplyIOChaosResponse, error) {
4168 return nil, status.Errorf(codes.Unimplemented, "method ApplyIOChaos not implemented")
4169 }
4170 func (*UnimplementedChaosDaemonServer) ApplyHttpChaos(context.Context, *ApplyHttpChaosRequest) (*ApplyHttpChaosResponse, error) {
4171 return nil, status.Errorf(codes.Unimplemented, "method ApplyHttpChaos not implemented")
4172 }
4173 func (*UnimplementedChaosDaemonServer) ApplyBlockChaos(context.Context, *ApplyBlockChaosRequest) (*ApplyBlockChaosResponse, error) {
4174 return nil, status.Errorf(codes.Unimplemented, "method ApplyBlockChaos not implemented")
4175 }
4176 func (*UnimplementedChaosDaemonServer) RecoverBlockChaos(context.Context, *RecoverBlockChaosRequest) (*empty.Empty, error) {
4177 return nil, status.Errorf(codes.Unimplemented, "method RecoverBlockChaos not implemented")
4178 }
4179 func (*UnimplementedChaosDaemonServer) SetDNSServer(context.Context, *SetDNSServerRequest) (*empty.Empty, error) {
4180 return nil, status.Errorf(codes.Unimplemented, "method SetDNSServer not implemented")
4181 }
4182 func (*UnimplementedChaosDaemonServer) InstallJVMRules(context.Context, *InstallJVMRulesRequest) (*empty.Empty, error) {
4183 return nil, status.Errorf(codes.Unimplemented, "method InstallJVMRules not implemented")
4184 }
4185 func (*UnimplementedChaosDaemonServer) UninstallJVMRules(context.Context, *UninstallJVMRulesRequest) (*empty.Empty, error) {
4186 return nil, status.Errorf(codes.Unimplemented, "method UninstallJVMRules not implemented")
4187 }
4188
4189 func RegisterChaosDaemonServer(s *grpc.Server, srv ChaosDaemonServer) {
4190 s.RegisterService(&_ChaosDaemon_serviceDesc, srv)
4191 }
4192
4193 func _ChaosDaemon_SetTcs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
4194 in := new(TcsRequest)
4195 if err := dec(in); err != nil {
4196 return nil, err
4197 }
4198 if interceptor == nil {
4199 return srv.(ChaosDaemonServer).SetTcs(ctx, in)
4200 }
4201 info := &grpc.UnaryServerInfo{
4202 Server: srv,
4203 FullMethod: "/pb.ChaosDaemon/SetTcs",
4204 }
4205 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
4206 return srv.(ChaosDaemonServer).SetTcs(ctx, req.(*TcsRequest))
4207 }
4208 return interceptor(ctx, in, info, handler)
4209 }
4210
4211 func _ChaosDaemon_FlushIPSets_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
4212 in := new(IPSetsRequest)
4213 if err := dec(in); err != nil {
4214 return nil, err
4215 }
4216 if interceptor == nil {
4217 return srv.(ChaosDaemonServer).FlushIPSets(ctx, in)
4218 }
4219 info := &grpc.UnaryServerInfo{
4220 Server: srv,
4221 FullMethod: "/pb.ChaosDaemon/FlushIPSets",
4222 }
4223 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
4224 return srv.(ChaosDaemonServer).FlushIPSets(ctx, req.(*IPSetsRequest))
4225 }
4226 return interceptor(ctx, in, info, handler)
4227 }
4228
4229 func _ChaosDaemon_SetIptablesChains_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
4230 in := new(IptablesChainsRequest)
4231 if err := dec(in); err != nil {
4232 return nil, err
4233 }
4234 if interceptor == nil {
4235 return srv.(ChaosDaemonServer).SetIptablesChains(ctx, in)
4236 }
4237 info := &grpc.UnaryServerInfo{
4238 Server: srv,
4239 FullMethod: "/pb.ChaosDaemon/SetIptablesChains",
4240 }
4241 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
4242 return srv.(ChaosDaemonServer).SetIptablesChains(ctx, req.(*IptablesChainsRequest))
4243 }
4244 return interceptor(ctx, in, info, handler)
4245 }
4246
4247 func _ChaosDaemon_SetTimeOffset_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
4248 in := new(TimeRequest)
4249 if err := dec(in); err != nil {
4250 return nil, err
4251 }
4252 if interceptor == nil {
4253 return srv.(ChaosDaemonServer).SetTimeOffset(ctx, in)
4254 }
4255 info := &grpc.UnaryServerInfo{
4256 Server: srv,
4257 FullMethod: "/pb.ChaosDaemon/SetTimeOffset",
4258 }
4259 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
4260 return srv.(ChaosDaemonServer).SetTimeOffset(ctx, req.(*TimeRequest))
4261 }
4262 return interceptor(ctx, in, info, handler)
4263 }
4264
4265 func _ChaosDaemon_RecoverTimeOffset_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
4266 in := new(TimeRequest)
4267 if err := dec(in); err != nil {
4268 return nil, err
4269 }
4270 if interceptor == nil {
4271 return srv.(ChaosDaemonServer).RecoverTimeOffset(ctx, in)
4272 }
4273 info := &grpc.UnaryServerInfo{
4274 Server: srv,
4275 FullMethod: "/pb.ChaosDaemon/RecoverTimeOffset",
4276 }
4277 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
4278 return srv.(ChaosDaemonServer).RecoverTimeOffset(ctx, req.(*TimeRequest))
4279 }
4280 return interceptor(ctx, in, info, handler)
4281 }
4282
4283 func _ChaosDaemon_ContainerKill_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
4284 in := new(ContainerRequest)
4285 if err := dec(in); err != nil {
4286 return nil, err
4287 }
4288 if interceptor == nil {
4289 return srv.(ChaosDaemonServer).ContainerKill(ctx, in)
4290 }
4291 info := &grpc.UnaryServerInfo{
4292 Server: srv,
4293 FullMethod: "/pb.ChaosDaemon/ContainerKill",
4294 }
4295 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
4296 return srv.(ChaosDaemonServer).ContainerKill(ctx, req.(*ContainerRequest))
4297 }
4298 return interceptor(ctx, in, info, handler)
4299 }
4300
4301 func _ChaosDaemon_ContainerGetPid_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
4302 in := new(ContainerRequest)
4303 if err := dec(in); err != nil {
4304 return nil, err
4305 }
4306 if interceptor == nil {
4307 return srv.(ChaosDaemonServer).ContainerGetPid(ctx, in)
4308 }
4309 info := &grpc.UnaryServerInfo{
4310 Server: srv,
4311 FullMethod: "/pb.ChaosDaemon/ContainerGetPid",
4312 }
4313 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
4314 return srv.(ChaosDaemonServer).ContainerGetPid(ctx, req.(*ContainerRequest))
4315 }
4316 return interceptor(ctx, in, info, handler)
4317 }
4318
4319 func _ChaosDaemon_ExecStressors_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
4320 in := new(ExecStressRequest)
4321 if err := dec(in); err != nil {
4322 return nil, err
4323 }
4324 if interceptor == nil {
4325 return srv.(ChaosDaemonServer).ExecStressors(ctx, in)
4326 }
4327 info := &grpc.UnaryServerInfo{
4328 Server: srv,
4329 FullMethod: "/pb.ChaosDaemon/ExecStressors",
4330 }
4331 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
4332 return srv.(ChaosDaemonServer).ExecStressors(ctx, req.(*ExecStressRequest))
4333 }
4334 return interceptor(ctx, in, info, handler)
4335 }
4336
4337 func _ChaosDaemon_CancelStressors_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
4338 in := new(CancelStressRequest)
4339 if err := dec(in); err != nil {
4340 return nil, err
4341 }
4342 if interceptor == nil {
4343 return srv.(ChaosDaemonServer).CancelStressors(ctx, in)
4344 }
4345 info := &grpc.UnaryServerInfo{
4346 Server: srv,
4347 FullMethod: "/pb.ChaosDaemon/CancelStressors",
4348 }
4349 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
4350 return srv.(ChaosDaemonServer).CancelStressors(ctx, req.(*CancelStressRequest))
4351 }
4352 return interceptor(ctx, in, info, handler)
4353 }
4354
4355 func _ChaosDaemon_ApplyIOChaos_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
4356 in := new(ApplyIOChaosRequest)
4357 if err := dec(in); err != nil {
4358 return nil, err
4359 }
4360 if interceptor == nil {
4361 return srv.(ChaosDaemonServer).ApplyIOChaos(ctx, in)
4362 }
4363 info := &grpc.UnaryServerInfo{
4364 Server: srv,
4365 FullMethod: "/pb.ChaosDaemon/ApplyIOChaos",
4366 }
4367 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
4368 return srv.(ChaosDaemonServer).ApplyIOChaos(ctx, req.(*ApplyIOChaosRequest))
4369 }
4370 return interceptor(ctx, in, info, handler)
4371 }
4372
4373 func _ChaosDaemon_ApplyHttpChaos_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
4374 in := new(ApplyHttpChaosRequest)
4375 if err := dec(in); err != nil {
4376 return nil, err
4377 }
4378 if interceptor == nil {
4379 return srv.(ChaosDaemonServer).ApplyHttpChaos(ctx, in)
4380 }
4381 info := &grpc.UnaryServerInfo{
4382 Server: srv,
4383 FullMethod: "/pb.ChaosDaemon/ApplyHttpChaos",
4384 }
4385 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
4386 return srv.(ChaosDaemonServer).ApplyHttpChaos(ctx, req.(*ApplyHttpChaosRequest))
4387 }
4388 return interceptor(ctx, in, info, handler)
4389 }
4390
4391 func _ChaosDaemon_ApplyBlockChaos_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
4392 in := new(ApplyBlockChaosRequest)
4393 if err := dec(in); err != nil {
4394 return nil, err
4395 }
4396 if interceptor == nil {
4397 return srv.(ChaosDaemonServer).ApplyBlockChaos(ctx, in)
4398 }
4399 info := &grpc.UnaryServerInfo{
4400 Server: srv,
4401 FullMethod: "/pb.ChaosDaemon/ApplyBlockChaos",
4402 }
4403 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
4404 return srv.(ChaosDaemonServer).ApplyBlockChaos(ctx, req.(*ApplyBlockChaosRequest))
4405 }
4406 return interceptor(ctx, in, info, handler)
4407 }
4408
4409 func _ChaosDaemon_RecoverBlockChaos_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
4410 in := new(RecoverBlockChaosRequest)
4411 if err := dec(in); err != nil {
4412 return nil, err
4413 }
4414 if interceptor == nil {
4415 return srv.(ChaosDaemonServer).RecoverBlockChaos(ctx, in)
4416 }
4417 info := &grpc.UnaryServerInfo{
4418 Server: srv,
4419 FullMethod: "/pb.ChaosDaemon/RecoverBlockChaos",
4420 }
4421 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
4422 return srv.(ChaosDaemonServer).RecoverBlockChaos(ctx, req.(*RecoverBlockChaosRequest))
4423 }
4424 return interceptor(ctx, in, info, handler)
4425 }
4426
4427 func _ChaosDaemon_SetDNSServer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
4428 in := new(SetDNSServerRequest)
4429 if err := dec(in); err != nil {
4430 return nil, err
4431 }
4432 if interceptor == nil {
4433 return srv.(ChaosDaemonServer).SetDNSServer(ctx, in)
4434 }
4435 info := &grpc.UnaryServerInfo{
4436 Server: srv,
4437 FullMethod: "/pb.ChaosDaemon/SetDNSServer",
4438 }
4439 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
4440 return srv.(ChaosDaemonServer).SetDNSServer(ctx, req.(*SetDNSServerRequest))
4441 }
4442 return interceptor(ctx, in, info, handler)
4443 }
4444
4445 func _ChaosDaemon_InstallJVMRules_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
4446 in := new(InstallJVMRulesRequest)
4447 if err := dec(in); err != nil {
4448 return nil, err
4449 }
4450 if interceptor == nil {
4451 return srv.(ChaosDaemonServer).InstallJVMRules(ctx, in)
4452 }
4453 info := &grpc.UnaryServerInfo{
4454 Server: srv,
4455 FullMethod: "/pb.ChaosDaemon/InstallJVMRules",
4456 }
4457 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
4458 return srv.(ChaosDaemonServer).InstallJVMRules(ctx, req.(*InstallJVMRulesRequest))
4459 }
4460 return interceptor(ctx, in, info, handler)
4461 }
4462
4463 func _ChaosDaemon_UninstallJVMRules_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
4464 in := new(UninstallJVMRulesRequest)
4465 if err := dec(in); err != nil {
4466 return nil, err
4467 }
4468 if interceptor == nil {
4469 return srv.(ChaosDaemonServer).UninstallJVMRules(ctx, in)
4470 }
4471 info := &grpc.UnaryServerInfo{
4472 Server: srv,
4473 FullMethod: "/pb.ChaosDaemon/UninstallJVMRules",
4474 }
4475 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
4476 return srv.(ChaosDaemonServer).UninstallJVMRules(ctx, req.(*UninstallJVMRulesRequest))
4477 }
4478 return interceptor(ctx, in, info, handler)
4479 }
4480
4481 var _ChaosDaemon_serviceDesc = grpc.ServiceDesc{
4482 ServiceName: "pb.ChaosDaemon",
4483 HandlerType: (*ChaosDaemonServer)(nil),
4484 Methods: []grpc.MethodDesc{
4485 {
4486 MethodName: "SetTcs",
4487 Handler: _ChaosDaemon_SetTcs_Handler,
4488 },
4489 {
4490 MethodName: "FlushIPSets",
4491 Handler: _ChaosDaemon_FlushIPSets_Handler,
4492 },
4493 {
4494 MethodName: "SetIptablesChains",
4495 Handler: _ChaosDaemon_SetIptablesChains_Handler,
4496 },
4497 {
4498 MethodName: "SetTimeOffset",
4499 Handler: _ChaosDaemon_SetTimeOffset_Handler,
4500 },
4501 {
4502 MethodName: "RecoverTimeOffset",
4503 Handler: _ChaosDaemon_RecoverTimeOffset_Handler,
4504 },
4505 {
4506 MethodName: "ContainerKill",
4507 Handler: _ChaosDaemon_ContainerKill_Handler,
4508 },
4509 {
4510 MethodName: "ContainerGetPid",
4511 Handler: _ChaosDaemon_ContainerGetPid_Handler,
4512 },
4513 {
4514 MethodName: "ExecStressors",
4515 Handler: _ChaosDaemon_ExecStressors_Handler,
4516 },
4517 {
4518 MethodName: "CancelStressors",
4519 Handler: _ChaosDaemon_CancelStressors_Handler,
4520 },
4521 {
4522 MethodName: "ApplyIOChaos",
4523 Handler: _ChaosDaemon_ApplyIOChaos_Handler,
4524 },
4525 {
4526 MethodName: "ApplyHttpChaos",
4527 Handler: _ChaosDaemon_ApplyHttpChaos_Handler,
4528 },
4529 {
4530 MethodName: "ApplyBlockChaos",
4531 Handler: _ChaosDaemon_ApplyBlockChaos_Handler,
4532 },
4533 {
4534 MethodName: "RecoverBlockChaos",
4535 Handler: _ChaosDaemon_RecoverBlockChaos_Handler,
4536 },
4537 {
4538 MethodName: "SetDNSServer",
4539 Handler: _ChaosDaemon_SetDNSServer_Handler,
4540 },
4541 {
4542 MethodName: "InstallJVMRules",
4543 Handler: _ChaosDaemon_InstallJVMRules_Handler,
4544 },
4545 {
4546 MethodName: "UninstallJVMRules",
4547 Handler: _ChaosDaemon_UninstallJVMRules_Handler,
4548 },
4549 },
4550 Streams: []grpc.StreamDesc{},
4551 Metadata: "chaosdaemon.proto",
4552 }
4553