1
2
3
4 package pb
5
6 import (
7 fmt "fmt"
8
9 proto "github.com/golang/protobuf/proto"
10
11 math "math"
12
13 empty "github.com/golang/protobuf/ptypes/empty"
14
15 context "golang.org/x/net/context"
16
17 grpc "google.golang.org/grpc"
18 )
19
20
21 var _ = proto.Marshal
22 var _ = fmt.Errorf
23 var _ = math.Inf
24
25
26
27
28
29 const _ = proto.ProtoPackageIsVersion2
30
31 type Chain_Direction int32
32
33 const (
34 Chain_INPUT Chain_Direction = 0
35 Chain_OUTPUT Chain_Direction = 1
36 )
37
38 var Chain_Direction_name = map[int32]string{
39 0: "INPUT",
40 1: "OUTPUT",
41 }
42 var Chain_Direction_value = map[string]int32{
43 "INPUT": 0,
44 "OUTPUT": 1,
45 }
46
47 func (x Chain_Direction) String() string {
48 return proto.EnumName(Chain_Direction_name, int32(x))
49 }
50 func (Chain_Direction) EnumDescriptor() ([]byte, []int) {
51 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{16, 0}
52 }
53
54 type ContainerAction_Action int32
55
56 const (
57 ContainerAction_KILL ContainerAction_Action = 0
58 ContainerAction_GETPID ContainerAction_Action = 1
59 )
60
61 var ContainerAction_Action_name = map[int32]string{
62 0: "KILL",
63 1: "GETPID",
64 }
65 var ContainerAction_Action_value = map[string]int32{
66 "KILL": 0,
67 "GETPID": 1,
68 }
69
70 func (x ContainerAction_Action) String() string {
71 return proto.EnumName(ContainerAction_Action_name, int32(x))
72 }
73 func (ContainerAction_Action) EnumDescriptor() ([]byte, []int) {
74 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{18, 0}
75 }
76
77 type ExecStressRequest_Scope int32
78
79 const (
80 ExecStressRequest_CONTAINER ExecStressRequest_Scope = 0
81 ExecStressRequest_POD ExecStressRequest_Scope = 1
82 )
83
84 var ExecStressRequest_Scope_name = map[int32]string{
85 0: "CONTAINER",
86 1: "POD",
87 }
88 var ExecStressRequest_Scope_value = map[string]int32{
89 "CONTAINER": 0,
90 "POD": 1,
91 }
92
93 func (x ExecStressRequest_Scope) String() string {
94 return proto.EnumName(ExecStressRequest_Scope_name, int32(x))
95 }
96 func (ExecStressRequest_Scope) EnumDescriptor() ([]byte, []int) {
97 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{19, 0}
98 }
99
100 type Tc_Type int32
101
102 const (
103 Tc_NETEM Tc_Type = 0
104 Tc_BANDWIDTH Tc_Type = 1
105 )
106
107 var Tc_Type_name = map[int32]string{
108 0: "NETEM",
109 1: "BANDWIDTH",
110 }
111 var Tc_Type_value = map[string]int32{
112 "NETEM": 0,
113 "BANDWIDTH": 1,
114 }
115
116 func (x Tc_Type) String() string {
117 return proto.EnumName(Tc_Type_name, int32(x))
118 }
119 func (Tc_Type) EnumDescriptor() ([]byte, []int) {
120 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{25, 0}
121 }
122
123 type TcHandle struct {
124 Major uint32 `protobuf:"varint,1,opt,name=major,proto3" json:"major,omitempty"`
125 Minor uint32 `protobuf:"varint,2,opt,name=minor,proto3" json:"minor,omitempty"`
126 XXX_NoUnkeyedLiteral struct{} `json:"-"`
127 XXX_unrecognized []byte `json:"-"`
128 XXX_sizecache int32 `json:"-"`
129 }
130
131 func (m *TcHandle) Reset() { *m = TcHandle{} }
132 func (m *TcHandle) String() string { return proto.CompactTextString(m) }
133 func (*TcHandle) ProtoMessage() {}
134 func (*TcHandle) Descriptor() ([]byte, []int) {
135 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{0}
136 }
137 func (m *TcHandle) XXX_Unmarshal(b []byte) error {
138 return xxx_messageInfo_TcHandle.Unmarshal(m, b)
139 }
140 func (m *TcHandle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
141 return xxx_messageInfo_TcHandle.Marshal(b, m, deterministic)
142 }
143 func (dst *TcHandle) XXX_Merge(src proto.Message) {
144 xxx_messageInfo_TcHandle.Merge(dst, src)
145 }
146 func (m *TcHandle) XXX_Size() int {
147 return xxx_messageInfo_TcHandle.Size(m)
148 }
149 func (m *TcHandle) XXX_DiscardUnknown() {
150 xxx_messageInfo_TcHandle.DiscardUnknown(m)
151 }
152
153 var xxx_messageInfo_TcHandle proto.InternalMessageInfo
154
155 func (m *TcHandle) GetMajor() uint32 {
156 if m != nil {
157 return m.Major
158 }
159 return 0
160 }
161
162 func (m *TcHandle) GetMinor() uint32 {
163 if m != nil {
164 return m.Minor
165 }
166 return 0
167 }
168
169 type ContainerRequest struct {
170 Action *ContainerAction `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`
171 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
172 XXX_NoUnkeyedLiteral struct{} `json:"-"`
173 XXX_unrecognized []byte `json:"-"`
174 XXX_sizecache int32 `json:"-"`
175 }
176
177 func (m *ContainerRequest) Reset() { *m = ContainerRequest{} }
178 func (m *ContainerRequest) String() string { return proto.CompactTextString(m) }
179 func (*ContainerRequest) ProtoMessage() {}
180 func (*ContainerRequest) Descriptor() ([]byte, []int) {
181 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{1}
182 }
183 func (m *ContainerRequest) XXX_Unmarshal(b []byte) error {
184 return xxx_messageInfo_ContainerRequest.Unmarshal(m, b)
185 }
186 func (m *ContainerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
187 return xxx_messageInfo_ContainerRequest.Marshal(b, m, deterministic)
188 }
189 func (dst *ContainerRequest) XXX_Merge(src proto.Message) {
190 xxx_messageInfo_ContainerRequest.Merge(dst, src)
191 }
192 func (m *ContainerRequest) XXX_Size() int {
193 return xxx_messageInfo_ContainerRequest.Size(m)
194 }
195 func (m *ContainerRequest) XXX_DiscardUnknown() {
196 xxx_messageInfo_ContainerRequest.DiscardUnknown(m)
197 }
198
199 var xxx_messageInfo_ContainerRequest proto.InternalMessageInfo
200
201 func (m *ContainerRequest) GetAction() *ContainerAction {
202 if m != nil {
203 return m.Action
204 }
205 return nil
206 }
207
208 func (m *ContainerRequest) GetContainerId() string {
209 if m != nil {
210 return m.ContainerId
211 }
212 return ""
213 }
214
215 type ContainerResponse struct {
216 Pid uint32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
217 XXX_NoUnkeyedLiteral struct{} `json:"-"`
218 XXX_unrecognized []byte `json:"-"`
219 XXX_sizecache int32 `json:"-"`
220 }
221
222 func (m *ContainerResponse) Reset() { *m = ContainerResponse{} }
223 func (m *ContainerResponse) String() string { return proto.CompactTextString(m) }
224 func (*ContainerResponse) ProtoMessage() {}
225 func (*ContainerResponse) Descriptor() ([]byte, []int) {
226 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{2}
227 }
228 func (m *ContainerResponse) XXX_Unmarshal(b []byte) error {
229 return xxx_messageInfo_ContainerResponse.Unmarshal(m, b)
230 }
231 func (m *ContainerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
232 return xxx_messageInfo_ContainerResponse.Marshal(b, m, deterministic)
233 }
234 func (dst *ContainerResponse) XXX_Merge(src proto.Message) {
235 xxx_messageInfo_ContainerResponse.Merge(dst, src)
236 }
237 func (m *ContainerResponse) XXX_Size() int {
238 return xxx_messageInfo_ContainerResponse.Size(m)
239 }
240 func (m *ContainerResponse) XXX_DiscardUnknown() {
241 xxx_messageInfo_ContainerResponse.DiscardUnknown(m)
242 }
243
244 var xxx_messageInfo_ContainerResponse proto.InternalMessageInfo
245
246 func (m *ContainerResponse) GetPid() uint32 {
247 if m != nil {
248 return m.Pid
249 }
250 return 0
251 }
252
253 type NetemRequest struct {
254 Netem *Netem `protobuf:"bytes,1,opt,name=netem,proto3" json:"netem,omitempty"`
255 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
256 Handle *TcHandle `protobuf:"bytes,3,opt,name=handle,proto3" json:"handle,omitempty"`
257 Parent *TcHandle `protobuf:"bytes,4,opt,name=parent,proto3" json:"parent,omitempty"`
258 XXX_NoUnkeyedLiteral struct{} `json:"-"`
259 XXX_unrecognized []byte `json:"-"`
260 XXX_sizecache int32 `json:"-"`
261 }
262
263 func (m *NetemRequest) Reset() { *m = NetemRequest{} }
264 func (m *NetemRequest) String() string { return proto.CompactTextString(m) }
265 func (*NetemRequest) ProtoMessage() {}
266 func (*NetemRequest) Descriptor() ([]byte, []int) {
267 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{3}
268 }
269 func (m *NetemRequest) XXX_Unmarshal(b []byte) error {
270 return xxx_messageInfo_NetemRequest.Unmarshal(m, b)
271 }
272 func (m *NetemRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
273 return xxx_messageInfo_NetemRequest.Marshal(b, m, deterministic)
274 }
275 func (dst *NetemRequest) XXX_Merge(src proto.Message) {
276 xxx_messageInfo_NetemRequest.Merge(dst, src)
277 }
278 func (m *NetemRequest) XXX_Size() int {
279 return xxx_messageInfo_NetemRequest.Size(m)
280 }
281 func (m *NetemRequest) XXX_DiscardUnknown() {
282 xxx_messageInfo_NetemRequest.DiscardUnknown(m)
283 }
284
285 var xxx_messageInfo_NetemRequest proto.InternalMessageInfo
286
287 func (m *NetemRequest) GetNetem() *Netem {
288 if m != nil {
289 return m.Netem
290 }
291 return nil
292 }
293
294 func (m *NetemRequest) GetContainerId() string {
295 if m != nil {
296 return m.ContainerId
297 }
298 return ""
299 }
300
301 func (m *NetemRequest) GetHandle() *TcHandle {
302 if m != nil {
303 return m.Handle
304 }
305 return nil
306 }
307
308 func (m *NetemRequest) GetParent() *TcHandle {
309 if m != nil {
310 return m.Parent
311 }
312 return nil
313 }
314
315 type Netem struct {
316 Time uint32 `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
317 Jitter uint32 `protobuf:"varint,2,opt,name=jitter,proto3" json:"jitter,omitempty"`
318 DelayCorr float32 `protobuf:"fixed32,3,opt,name=delay_corr,json=delayCorr,proto3" json:"delay_corr,omitempty"`
319 Limit uint32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
320 Loss float32 `protobuf:"fixed32,5,opt,name=loss,proto3" json:"loss,omitempty"`
321 LossCorr float32 `protobuf:"fixed32,6,opt,name=loss_corr,json=lossCorr,proto3" json:"loss_corr,omitempty"`
322 Gap uint32 `protobuf:"varint,7,opt,name=gap,proto3" json:"gap,omitempty"`
323 Duplicate float32 `protobuf:"fixed32,8,opt,name=duplicate,proto3" json:"duplicate,omitempty"`
324 DuplicateCorr float32 `protobuf:"fixed32,9,opt,name=duplicate_corr,json=duplicateCorr,proto3" json:"duplicate_corr,omitempty"`
325 Reorder float32 `protobuf:"fixed32,10,opt,name=reorder,proto3" json:"reorder,omitempty"`
326 ReorderCorr float32 `protobuf:"fixed32,11,opt,name=reorder_corr,json=reorderCorr,proto3" json:"reorder_corr,omitempty"`
327 Corrupt float32 `protobuf:"fixed32,12,opt,name=corrupt,proto3" json:"corrupt,omitempty"`
328 CorruptCorr float32 `protobuf:"fixed32,13,opt,name=corrupt_corr,json=corruptCorr,proto3" json:"corrupt_corr,omitempty"`
329 Parent *TcHandle `protobuf:"bytes,14,opt,name=parent,proto3" json:"parent,omitempty"`
330 Handle *TcHandle `protobuf:"bytes,15,opt,name=handle,proto3" json:"handle,omitempty"`
331 XXX_NoUnkeyedLiteral struct{} `json:"-"`
332 XXX_unrecognized []byte `json:"-"`
333 XXX_sizecache int32 `json:"-"`
334 }
335
336 func (m *Netem) Reset() { *m = Netem{} }
337 func (m *Netem) String() string { return proto.CompactTextString(m) }
338 func (*Netem) ProtoMessage() {}
339 func (*Netem) Descriptor() ([]byte, []int) {
340 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{4}
341 }
342 func (m *Netem) XXX_Unmarshal(b []byte) error {
343 return xxx_messageInfo_Netem.Unmarshal(m, b)
344 }
345 func (m *Netem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
346 return xxx_messageInfo_Netem.Marshal(b, m, deterministic)
347 }
348 func (dst *Netem) XXX_Merge(src proto.Message) {
349 xxx_messageInfo_Netem.Merge(dst, src)
350 }
351 func (m *Netem) XXX_Size() int {
352 return xxx_messageInfo_Netem.Size(m)
353 }
354 func (m *Netem) XXX_DiscardUnknown() {
355 xxx_messageInfo_Netem.DiscardUnknown(m)
356 }
357
358 var xxx_messageInfo_Netem proto.InternalMessageInfo
359
360 func (m *Netem) GetTime() uint32 {
361 if m != nil {
362 return m.Time
363 }
364 return 0
365 }
366
367 func (m *Netem) GetJitter() uint32 {
368 if m != nil {
369 return m.Jitter
370 }
371 return 0
372 }
373
374 func (m *Netem) GetDelayCorr() float32 {
375 if m != nil {
376 return m.DelayCorr
377 }
378 return 0
379 }
380
381 func (m *Netem) GetLimit() uint32 {
382 if m != nil {
383 return m.Limit
384 }
385 return 0
386 }
387
388 func (m *Netem) GetLoss() float32 {
389 if m != nil {
390 return m.Loss
391 }
392 return 0
393 }
394
395 func (m *Netem) GetLossCorr() float32 {
396 if m != nil {
397 return m.LossCorr
398 }
399 return 0
400 }
401
402 func (m *Netem) GetGap() uint32 {
403 if m != nil {
404 return m.Gap
405 }
406 return 0
407 }
408
409 func (m *Netem) GetDuplicate() float32 {
410 if m != nil {
411 return m.Duplicate
412 }
413 return 0
414 }
415
416 func (m *Netem) GetDuplicateCorr() float32 {
417 if m != nil {
418 return m.DuplicateCorr
419 }
420 return 0
421 }
422
423 func (m *Netem) GetReorder() float32 {
424 if m != nil {
425 return m.Reorder
426 }
427 return 0
428 }
429
430 func (m *Netem) GetReorderCorr() float32 {
431 if m != nil {
432 return m.ReorderCorr
433 }
434 return 0
435 }
436
437 func (m *Netem) GetCorrupt() float32 {
438 if m != nil {
439 return m.Corrupt
440 }
441 return 0
442 }
443
444 func (m *Netem) GetCorruptCorr() float32 {
445 if m != nil {
446 return m.CorruptCorr
447 }
448 return 0
449 }
450
451 func (m *Netem) GetParent() *TcHandle {
452 if m != nil {
453 return m.Parent
454 }
455 return nil
456 }
457
458 func (m *Netem) GetHandle() *TcHandle {
459 if m != nil {
460 return m.Handle
461 }
462 return nil
463 }
464
465 type TbfRequest struct {
466 Tbf *Tbf `protobuf:"bytes,1,opt,name=tbf,proto3" json:"tbf,omitempty"`
467 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
468 XXX_NoUnkeyedLiteral struct{} `json:"-"`
469 XXX_unrecognized []byte `json:"-"`
470 XXX_sizecache int32 `json:"-"`
471 }
472
473 func (m *TbfRequest) Reset() { *m = TbfRequest{} }
474 func (m *TbfRequest) String() string { return proto.CompactTextString(m) }
475 func (*TbfRequest) ProtoMessage() {}
476 func (*TbfRequest) Descriptor() ([]byte, []int) {
477 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{5}
478 }
479 func (m *TbfRequest) XXX_Unmarshal(b []byte) error {
480 return xxx_messageInfo_TbfRequest.Unmarshal(m, b)
481 }
482 func (m *TbfRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
483 return xxx_messageInfo_TbfRequest.Marshal(b, m, deterministic)
484 }
485 func (dst *TbfRequest) XXX_Merge(src proto.Message) {
486 xxx_messageInfo_TbfRequest.Merge(dst, src)
487 }
488 func (m *TbfRequest) XXX_Size() int {
489 return xxx_messageInfo_TbfRequest.Size(m)
490 }
491 func (m *TbfRequest) XXX_DiscardUnknown() {
492 xxx_messageInfo_TbfRequest.DiscardUnknown(m)
493 }
494
495 var xxx_messageInfo_TbfRequest proto.InternalMessageInfo
496
497 func (m *TbfRequest) GetTbf() *Tbf {
498 if m != nil {
499 return m.Tbf
500 }
501 return nil
502 }
503
504 func (m *TbfRequest) GetContainerId() string {
505 if m != nil {
506 return m.ContainerId
507 }
508 return ""
509 }
510
511 type Tbf struct {
512 Rate uint64 `protobuf:"varint,1,opt,name=rate,proto3" json:"rate,omitempty"`
513 Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
514 Buffer uint32 `protobuf:"varint,3,opt,name=buffer,proto3" json:"buffer,omitempty"`
515 PeakRate uint64 `protobuf:"varint,4,opt,name=peak_rate,json=peakRate,proto3" json:"peak_rate,omitempty"`
516 MinBurst uint32 `protobuf:"varint,5,opt,name=min_burst,json=minBurst,proto3" json:"min_burst,omitempty"`
517 XXX_NoUnkeyedLiteral struct{} `json:"-"`
518 XXX_unrecognized []byte `json:"-"`
519 XXX_sizecache int32 `json:"-"`
520 }
521
522 func (m *Tbf) Reset() { *m = Tbf{} }
523 func (m *Tbf) String() string { return proto.CompactTextString(m) }
524 func (*Tbf) ProtoMessage() {}
525 func (*Tbf) Descriptor() ([]byte, []int) {
526 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{6}
527 }
528 func (m *Tbf) XXX_Unmarshal(b []byte) error {
529 return xxx_messageInfo_Tbf.Unmarshal(m, b)
530 }
531 func (m *Tbf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
532 return xxx_messageInfo_Tbf.Marshal(b, m, deterministic)
533 }
534 func (dst *Tbf) XXX_Merge(src proto.Message) {
535 xxx_messageInfo_Tbf.Merge(dst, src)
536 }
537 func (m *Tbf) XXX_Size() int {
538 return xxx_messageInfo_Tbf.Size(m)
539 }
540 func (m *Tbf) XXX_DiscardUnknown() {
541 xxx_messageInfo_Tbf.DiscardUnknown(m)
542 }
543
544 var xxx_messageInfo_Tbf proto.InternalMessageInfo
545
546 func (m *Tbf) GetRate() uint64 {
547 if m != nil {
548 return m.Rate
549 }
550 return 0
551 }
552
553 func (m *Tbf) GetLimit() uint32 {
554 if m != nil {
555 return m.Limit
556 }
557 return 0
558 }
559
560 func (m *Tbf) GetBuffer() uint32 {
561 if m != nil {
562 return m.Buffer
563 }
564 return 0
565 }
566
567 func (m *Tbf) GetPeakRate() uint64 {
568 if m != nil {
569 return m.PeakRate
570 }
571 return 0
572 }
573
574 func (m *Tbf) GetMinBurst() uint32 {
575 if m != nil {
576 return m.MinBurst
577 }
578 return 0
579 }
580
581 type QdiscRequest struct {
582 Qdisc *Qdisc `protobuf:"bytes,1,opt,name=qdisc,proto3" json:"qdisc,omitempty"`
583 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
584 XXX_NoUnkeyedLiteral struct{} `json:"-"`
585 XXX_unrecognized []byte `json:"-"`
586 XXX_sizecache int32 `json:"-"`
587 }
588
589 func (m *QdiscRequest) Reset() { *m = QdiscRequest{} }
590 func (m *QdiscRequest) String() string { return proto.CompactTextString(m) }
591 func (*QdiscRequest) ProtoMessage() {}
592 func (*QdiscRequest) Descriptor() ([]byte, []int) {
593 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{7}
594 }
595 func (m *QdiscRequest) XXX_Unmarshal(b []byte) error {
596 return xxx_messageInfo_QdiscRequest.Unmarshal(m, b)
597 }
598 func (m *QdiscRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
599 return xxx_messageInfo_QdiscRequest.Marshal(b, m, deterministic)
600 }
601 func (dst *QdiscRequest) XXX_Merge(src proto.Message) {
602 xxx_messageInfo_QdiscRequest.Merge(dst, src)
603 }
604 func (m *QdiscRequest) XXX_Size() int {
605 return xxx_messageInfo_QdiscRequest.Size(m)
606 }
607 func (m *QdiscRequest) XXX_DiscardUnknown() {
608 xxx_messageInfo_QdiscRequest.DiscardUnknown(m)
609 }
610
611 var xxx_messageInfo_QdiscRequest proto.InternalMessageInfo
612
613 func (m *QdiscRequest) GetQdisc() *Qdisc {
614 if m != nil {
615 return m.Qdisc
616 }
617 return nil
618 }
619
620 func (m *QdiscRequest) GetContainerId() string {
621 if m != nil {
622 return m.ContainerId
623 }
624 return ""
625 }
626
627 type Qdisc struct {
628 Parent *TcHandle `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
629 Handle *TcHandle `protobuf:"bytes,2,opt,name=handle,proto3" json:"handle,omitempty"`
630 Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
631 Args []string `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
632 XXX_NoUnkeyedLiteral struct{} `json:"-"`
633 XXX_unrecognized []byte `json:"-"`
634 XXX_sizecache int32 `json:"-"`
635 }
636
637 func (m *Qdisc) Reset() { *m = Qdisc{} }
638 func (m *Qdisc) String() string { return proto.CompactTextString(m) }
639 func (*Qdisc) ProtoMessage() {}
640 func (*Qdisc) Descriptor() ([]byte, []int) {
641 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{8}
642 }
643 func (m *Qdisc) XXX_Unmarshal(b []byte) error {
644 return xxx_messageInfo_Qdisc.Unmarshal(m, b)
645 }
646 func (m *Qdisc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
647 return xxx_messageInfo_Qdisc.Marshal(b, m, deterministic)
648 }
649 func (dst *Qdisc) XXX_Merge(src proto.Message) {
650 xxx_messageInfo_Qdisc.Merge(dst, src)
651 }
652 func (m *Qdisc) XXX_Size() int {
653 return xxx_messageInfo_Qdisc.Size(m)
654 }
655 func (m *Qdisc) XXX_DiscardUnknown() {
656 xxx_messageInfo_Qdisc.DiscardUnknown(m)
657 }
658
659 var xxx_messageInfo_Qdisc proto.InternalMessageInfo
660
661 func (m *Qdisc) GetParent() *TcHandle {
662 if m != nil {
663 return m.Parent
664 }
665 return nil
666 }
667
668 func (m *Qdisc) GetHandle() *TcHandle {
669 if m != nil {
670 return m.Handle
671 }
672 return nil
673 }
674
675 func (m *Qdisc) GetType() string {
676 if m != nil {
677 return m.Type
678 }
679 return ""
680 }
681
682 func (m *Qdisc) GetArgs() []string {
683 if m != nil {
684 return m.Args
685 }
686 return nil
687 }
688
689 type EmatchFilterRequest struct {
690 Filter *EmatchFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
691 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
692 XXX_NoUnkeyedLiteral struct{} `json:"-"`
693 XXX_unrecognized []byte `json:"-"`
694 XXX_sizecache int32 `json:"-"`
695 }
696
697 func (m *EmatchFilterRequest) Reset() { *m = EmatchFilterRequest{} }
698 func (m *EmatchFilterRequest) String() string { return proto.CompactTextString(m) }
699 func (*EmatchFilterRequest) ProtoMessage() {}
700 func (*EmatchFilterRequest) Descriptor() ([]byte, []int) {
701 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{9}
702 }
703 func (m *EmatchFilterRequest) XXX_Unmarshal(b []byte) error {
704 return xxx_messageInfo_EmatchFilterRequest.Unmarshal(m, b)
705 }
706 func (m *EmatchFilterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
707 return xxx_messageInfo_EmatchFilterRequest.Marshal(b, m, deterministic)
708 }
709 func (dst *EmatchFilterRequest) XXX_Merge(src proto.Message) {
710 xxx_messageInfo_EmatchFilterRequest.Merge(dst, src)
711 }
712 func (m *EmatchFilterRequest) XXX_Size() int {
713 return xxx_messageInfo_EmatchFilterRequest.Size(m)
714 }
715 func (m *EmatchFilterRequest) XXX_DiscardUnknown() {
716 xxx_messageInfo_EmatchFilterRequest.DiscardUnknown(m)
717 }
718
719 var xxx_messageInfo_EmatchFilterRequest proto.InternalMessageInfo
720
721 func (m *EmatchFilterRequest) GetFilter() *EmatchFilter {
722 if m != nil {
723 return m.Filter
724 }
725 return nil
726 }
727
728 func (m *EmatchFilterRequest) GetContainerId() string {
729 if m != nil {
730 return m.ContainerId
731 }
732 return ""
733 }
734
735 type EmatchFilter struct {
736 Match string `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
737 Parent *TcHandle `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"`
738 Classid *TcHandle `protobuf:"bytes,3,opt,name=classid,proto3" json:"classid,omitempty"`
739 XXX_NoUnkeyedLiteral struct{} `json:"-"`
740 XXX_unrecognized []byte `json:"-"`
741 XXX_sizecache int32 `json:"-"`
742 }
743
744 func (m *EmatchFilter) Reset() { *m = EmatchFilter{} }
745 func (m *EmatchFilter) String() string { return proto.CompactTextString(m) }
746 func (*EmatchFilter) ProtoMessage() {}
747 func (*EmatchFilter) Descriptor() ([]byte, []int) {
748 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{10}
749 }
750 func (m *EmatchFilter) XXX_Unmarshal(b []byte) error {
751 return xxx_messageInfo_EmatchFilter.Unmarshal(m, b)
752 }
753 func (m *EmatchFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
754 return xxx_messageInfo_EmatchFilter.Marshal(b, m, deterministic)
755 }
756 func (dst *EmatchFilter) XXX_Merge(src proto.Message) {
757 xxx_messageInfo_EmatchFilter.Merge(dst, src)
758 }
759 func (m *EmatchFilter) XXX_Size() int {
760 return xxx_messageInfo_EmatchFilter.Size(m)
761 }
762 func (m *EmatchFilter) XXX_DiscardUnknown() {
763 xxx_messageInfo_EmatchFilter.DiscardUnknown(m)
764 }
765
766 var xxx_messageInfo_EmatchFilter proto.InternalMessageInfo
767
768 func (m *EmatchFilter) GetMatch() string {
769 if m != nil {
770 return m.Match
771 }
772 return ""
773 }
774
775 func (m *EmatchFilter) GetParent() *TcHandle {
776 if m != nil {
777 return m.Parent
778 }
779 return nil
780 }
781
782 func (m *EmatchFilter) GetClassid() *TcHandle {
783 if m != nil {
784 return m.Classid
785 }
786 return nil
787 }
788
789 type TcFilterRequest struct {
790 Filter *TcFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
791 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
792 XXX_NoUnkeyedLiteral struct{} `json:"-"`
793 XXX_unrecognized []byte `json:"-"`
794 XXX_sizecache int32 `json:"-"`
795 }
796
797 func (m *TcFilterRequest) Reset() { *m = TcFilterRequest{} }
798 func (m *TcFilterRequest) String() string { return proto.CompactTextString(m) }
799 func (*TcFilterRequest) ProtoMessage() {}
800 func (*TcFilterRequest) Descriptor() ([]byte, []int) {
801 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{11}
802 }
803 func (m *TcFilterRequest) XXX_Unmarshal(b []byte) error {
804 return xxx_messageInfo_TcFilterRequest.Unmarshal(m, b)
805 }
806 func (m *TcFilterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
807 return xxx_messageInfo_TcFilterRequest.Marshal(b, m, deterministic)
808 }
809 func (dst *TcFilterRequest) XXX_Merge(src proto.Message) {
810 xxx_messageInfo_TcFilterRequest.Merge(dst, src)
811 }
812 func (m *TcFilterRequest) XXX_Size() int {
813 return xxx_messageInfo_TcFilterRequest.Size(m)
814 }
815 func (m *TcFilterRequest) XXX_DiscardUnknown() {
816 xxx_messageInfo_TcFilterRequest.DiscardUnknown(m)
817 }
818
819 var xxx_messageInfo_TcFilterRequest proto.InternalMessageInfo
820
821 func (m *TcFilterRequest) GetFilter() *TcFilter {
822 if m != nil {
823 return m.Filter
824 }
825 return nil
826 }
827
828 func (m *TcFilterRequest) GetContainerId() string {
829 if m != nil {
830 return m.ContainerId
831 }
832 return ""
833 }
834
835 type TcFilter struct {
836 Parent *TcHandle `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
837 XXX_NoUnkeyedLiteral struct{} `json:"-"`
838 XXX_unrecognized []byte `json:"-"`
839 XXX_sizecache int32 `json:"-"`
840 }
841
842 func (m *TcFilter) Reset() { *m = TcFilter{} }
843 func (m *TcFilter) String() string { return proto.CompactTextString(m) }
844 func (*TcFilter) ProtoMessage() {}
845 func (*TcFilter) Descriptor() ([]byte, []int) {
846 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{12}
847 }
848 func (m *TcFilter) XXX_Unmarshal(b []byte) error {
849 return xxx_messageInfo_TcFilter.Unmarshal(m, b)
850 }
851 func (m *TcFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
852 return xxx_messageInfo_TcFilter.Marshal(b, m, deterministic)
853 }
854 func (dst *TcFilter) XXX_Merge(src proto.Message) {
855 xxx_messageInfo_TcFilter.Merge(dst, src)
856 }
857 func (m *TcFilter) XXX_Size() int {
858 return xxx_messageInfo_TcFilter.Size(m)
859 }
860 func (m *TcFilter) XXX_DiscardUnknown() {
861 xxx_messageInfo_TcFilter.DiscardUnknown(m)
862 }
863
864 var xxx_messageInfo_TcFilter proto.InternalMessageInfo
865
866 func (m *TcFilter) GetParent() *TcHandle {
867 if m != nil {
868 return m.Parent
869 }
870 return nil
871 }
872
873 type IPSetsRequest struct {
874 Ipsets []*IPSet `protobuf:"bytes,1,rep,name=ipsets,proto3" json:"ipsets,omitempty"`
875 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
876 XXX_NoUnkeyedLiteral struct{} `json:"-"`
877 XXX_unrecognized []byte `json:"-"`
878 XXX_sizecache int32 `json:"-"`
879 }
880
881 func (m *IPSetsRequest) Reset() { *m = IPSetsRequest{} }
882 func (m *IPSetsRequest) String() string { return proto.CompactTextString(m) }
883 func (*IPSetsRequest) ProtoMessage() {}
884 func (*IPSetsRequest) Descriptor() ([]byte, []int) {
885 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{13}
886 }
887 func (m *IPSetsRequest) XXX_Unmarshal(b []byte) error {
888 return xxx_messageInfo_IPSetsRequest.Unmarshal(m, b)
889 }
890 func (m *IPSetsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
891 return xxx_messageInfo_IPSetsRequest.Marshal(b, m, deterministic)
892 }
893 func (dst *IPSetsRequest) XXX_Merge(src proto.Message) {
894 xxx_messageInfo_IPSetsRequest.Merge(dst, src)
895 }
896 func (m *IPSetsRequest) XXX_Size() int {
897 return xxx_messageInfo_IPSetsRequest.Size(m)
898 }
899 func (m *IPSetsRequest) XXX_DiscardUnknown() {
900 xxx_messageInfo_IPSetsRequest.DiscardUnknown(m)
901 }
902
903 var xxx_messageInfo_IPSetsRequest proto.InternalMessageInfo
904
905 func (m *IPSetsRequest) GetIpsets() []*IPSet {
906 if m != nil {
907 return m.Ipsets
908 }
909 return nil
910 }
911
912 func (m *IPSetsRequest) GetContainerId() string {
913 if m != nil {
914 return m.ContainerId
915 }
916 return ""
917 }
918
919 type IPSet struct {
920 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
921 Cidrs []string `protobuf:"bytes,2,rep,name=cidrs,proto3" json:"cidrs,omitempty"`
922 XXX_NoUnkeyedLiteral struct{} `json:"-"`
923 XXX_unrecognized []byte `json:"-"`
924 XXX_sizecache int32 `json:"-"`
925 }
926
927 func (m *IPSet) Reset() { *m = IPSet{} }
928 func (m *IPSet) String() string { return proto.CompactTextString(m) }
929 func (*IPSet) ProtoMessage() {}
930 func (*IPSet) Descriptor() ([]byte, []int) {
931 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{14}
932 }
933 func (m *IPSet) XXX_Unmarshal(b []byte) error {
934 return xxx_messageInfo_IPSet.Unmarshal(m, b)
935 }
936 func (m *IPSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
937 return xxx_messageInfo_IPSet.Marshal(b, m, deterministic)
938 }
939 func (dst *IPSet) XXX_Merge(src proto.Message) {
940 xxx_messageInfo_IPSet.Merge(dst, src)
941 }
942 func (m *IPSet) XXX_Size() int {
943 return xxx_messageInfo_IPSet.Size(m)
944 }
945 func (m *IPSet) XXX_DiscardUnknown() {
946 xxx_messageInfo_IPSet.DiscardUnknown(m)
947 }
948
949 var xxx_messageInfo_IPSet proto.InternalMessageInfo
950
951 func (m *IPSet) GetName() string {
952 if m != nil {
953 return m.Name
954 }
955 return ""
956 }
957
958 func (m *IPSet) GetCidrs() []string {
959 if m != nil {
960 return m.Cidrs
961 }
962 return nil
963 }
964
965 type IptablesChainsRequest struct {
966 Chains []*Chain `protobuf:"bytes,1,rep,name=chains,proto3" json:"chains,omitempty"`
967 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
968 XXX_NoUnkeyedLiteral struct{} `json:"-"`
969 XXX_unrecognized []byte `json:"-"`
970 XXX_sizecache int32 `json:"-"`
971 }
972
973 func (m *IptablesChainsRequest) Reset() { *m = IptablesChainsRequest{} }
974 func (m *IptablesChainsRequest) String() string { return proto.CompactTextString(m) }
975 func (*IptablesChainsRequest) ProtoMessage() {}
976 func (*IptablesChainsRequest) Descriptor() ([]byte, []int) {
977 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{15}
978 }
979 func (m *IptablesChainsRequest) XXX_Unmarshal(b []byte) error {
980 return xxx_messageInfo_IptablesChainsRequest.Unmarshal(m, b)
981 }
982 func (m *IptablesChainsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
983 return xxx_messageInfo_IptablesChainsRequest.Marshal(b, m, deterministic)
984 }
985 func (dst *IptablesChainsRequest) XXX_Merge(src proto.Message) {
986 xxx_messageInfo_IptablesChainsRequest.Merge(dst, src)
987 }
988 func (m *IptablesChainsRequest) XXX_Size() int {
989 return xxx_messageInfo_IptablesChainsRequest.Size(m)
990 }
991 func (m *IptablesChainsRequest) XXX_DiscardUnknown() {
992 xxx_messageInfo_IptablesChainsRequest.DiscardUnknown(m)
993 }
994
995 var xxx_messageInfo_IptablesChainsRequest proto.InternalMessageInfo
996
997 func (m *IptablesChainsRequest) GetChains() []*Chain {
998 if m != nil {
999 return m.Chains
1000 }
1001 return nil
1002 }
1003
1004 func (m *IptablesChainsRequest) GetContainerId() string {
1005 if m != nil {
1006 return m.ContainerId
1007 }
1008 return ""
1009 }
1010
1011 type Chain struct {
1012 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
1013 Direction Chain_Direction `protobuf:"varint,2,opt,name=direction,proto3,enum=pb.Chain_Direction" json:"direction,omitempty"`
1014 Ipsets []string `protobuf:"bytes,3,rep,name=ipsets,proto3" json:"ipsets,omitempty"`
1015 Target string `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"`
1016 XXX_NoUnkeyedLiteral struct{} `json:"-"`
1017 XXX_unrecognized []byte `json:"-"`
1018 XXX_sizecache int32 `json:"-"`
1019 }
1020
1021 func (m *Chain) Reset() { *m = Chain{} }
1022 func (m *Chain) String() string { return proto.CompactTextString(m) }
1023 func (*Chain) ProtoMessage() {}
1024 func (*Chain) Descriptor() ([]byte, []int) {
1025 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{16}
1026 }
1027 func (m *Chain) XXX_Unmarshal(b []byte) error {
1028 return xxx_messageInfo_Chain.Unmarshal(m, b)
1029 }
1030 func (m *Chain) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1031 return xxx_messageInfo_Chain.Marshal(b, m, deterministic)
1032 }
1033 func (dst *Chain) XXX_Merge(src proto.Message) {
1034 xxx_messageInfo_Chain.Merge(dst, src)
1035 }
1036 func (m *Chain) XXX_Size() int {
1037 return xxx_messageInfo_Chain.Size(m)
1038 }
1039 func (m *Chain) XXX_DiscardUnknown() {
1040 xxx_messageInfo_Chain.DiscardUnknown(m)
1041 }
1042
1043 var xxx_messageInfo_Chain proto.InternalMessageInfo
1044
1045 func (m *Chain) GetName() string {
1046 if m != nil {
1047 return m.Name
1048 }
1049 return ""
1050 }
1051
1052 func (m *Chain) GetDirection() Chain_Direction {
1053 if m != nil {
1054 return m.Direction
1055 }
1056 return Chain_INPUT
1057 }
1058
1059 func (m *Chain) GetIpsets() []string {
1060 if m != nil {
1061 return m.Ipsets
1062 }
1063 return nil
1064 }
1065
1066 func (m *Chain) GetTarget() string {
1067 if m != nil {
1068 return m.Target
1069 }
1070 return ""
1071 }
1072
1073 type TimeRequest struct {
1074 ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
1075 Sec int64 `protobuf:"varint,2,opt,name=sec,proto3" json:"sec,omitempty"`
1076 Nsec int64 `protobuf:"varint,3,opt,name=nsec,proto3" json:"nsec,omitempty"`
1077 ClkIdsMask uint64 `protobuf:"varint,4,opt,name=clk_ids_mask,json=clkIdsMask,proto3" json:"clk_ids_mask,omitempty"`
1078 XXX_NoUnkeyedLiteral struct{} `json:"-"`
1079 XXX_unrecognized []byte `json:"-"`
1080 XXX_sizecache int32 `json:"-"`
1081 }
1082
1083 func (m *TimeRequest) Reset() { *m = TimeRequest{} }
1084 func (m *TimeRequest) String() string { return proto.CompactTextString(m) }
1085 func (*TimeRequest) ProtoMessage() {}
1086 func (*TimeRequest) Descriptor() ([]byte, []int) {
1087 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{17}
1088 }
1089 func (m *TimeRequest) XXX_Unmarshal(b []byte) error {
1090 return xxx_messageInfo_TimeRequest.Unmarshal(m, b)
1091 }
1092 func (m *TimeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1093 return xxx_messageInfo_TimeRequest.Marshal(b, m, deterministic)
1094 }
1095 func (dst *TimeRequest) XXX_Merge(src proto.Message) {
1096 xxx_messageInfo_TimeRequest.Merge(dst, src)
1097 }
1098 func (m *TimeRequest) XXX_Size() int {
1099 return xxx_messageInfo_TimeRequest.Size(m)
1100 }
1101 func (m *TimeRequest) XXX_DiscardUnknown() {
1102 xxx_messageInfo_TimeRequest.DiscardUnknown(m)
1103 }
1104
1105 var xxx_messageInfo_TimeRequest proto.InternalMessageInfo
1106
1107 func (m *TimeRequest) GetContainerId() string {
1108 if m != nil {
1109 return m.ContainerId
1110 }
1111 return ""
1112 }
1113
1114 func (m *TimeRequest) GetSec() int64 {
1115 if m != nil {
1116 return m.Sec
1117 }
1118 return 0
1119 }
1120
1121 func (m *TimeRequest) GetNsec() int64 {
1122 if m != nil {
1123 return m.Nsec
1124 }
1125 return 0
1126 }
1127
1128 func (m *TimeRequest) GetClkIdsMask() uint64 {
1129 if m != nil {
1130 return m.ClkIdsMask
1131 }
1132 return 0
1133 }
1134
1135 type ContainerAction struct {
1136 Action ContainerAction_Action `protobuf:"varint,1,opt,name=action,proto3,enum=pb.ContainerAction_Action" json:"action,omitempty"`
1137 XXX_NoUnkeyedLiteral struct{} `json:"-"`
1138 XXX_unrecognized []byte `json:"-"`
1139 XXX_sizecache int32 `json:"-"`
1140 }
1141
1142 func (m *ContainerAction) Reset() { *m = ContainerAction{} }
1143 func (m *ContainerAction) String() string { return proto.CompactTextString(m) }
1144 func (*ContainerAction) ProtoMessage() {}
1145 func (*ContainerAction) Descriptor() ([]byte, []int) {
1146 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{18}
1147 }
1148 func (m *ContainerAction) XXX_Unmarshal(b []byte) error {
1149 return xxx_messageInfo_ContainerAction.Unmarshal(m, b)
1150 }
1151 func (m *ContainerAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1152 return xxx_messageInfo_ContainerAction.Marshal(b, m, deterministic)
1153 }
1154 func (dst *ContainerAction) XXX_Merge(src proto.Message) {
1155 xxx_messageInfo_ContainerAction.Merge(dst, src)
1156 }
1157 func (m *ContainerAction) XXX_Size() int {
1158 return xxx_messageInfo_ContainerAction.Size(m)
1159 }
1160 func (m *ContainerAction) XXX_DiscardUnknown() {
1161 xxx_messageInfo_ContainerAction.DiscardUnknown(m)
1162 }
1163
1164 var xxx_messageInfo_ContainerAction proto.InternalMessageInfo
1165
1166 func (m *ContainerAction) GetAction() ContainerAction_Action {
1167 if m != nil {
1168 return m.Action
1169 }
1170 return ContainerAction_KILL
1171 }
1172
1173 type ExecStressRequest struct {
1174 Scope ExecStressRequest_Scope `protobuf:"varint,1,opt,name=scope,proto3,enum=pb.ExecStressRequest_Scope" json:"scope,omitempty"`
1175 Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
1176 Stressors string `protobuf:"bytes,3,opt,name=stressors,proto3" json:"stressors,omitempty"`
1177 XXX_NoUnkeyedLiteral struct{} `json:"-"`
1178 XXX_unrecognized []byte `json:"-"`
1179 XXX_sizecache int32 `json:"-"`
1180 }
1181
1182 func (m *ExecStressRequest) Reset() { *m = ExecStressRequest{} }
1183 func (m *ExecStressRequest) String() string { return proto.CompactTextString(m) }
1184 func (*ExecStressRequest) ProtoMessage() {}
1185 func (*ExecStressRequest) Descriptor() ([]byte, []int) {
1186 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{19}
1187 }
1188 func (m *ExecStressRequest) XXX_Unmarshal(b []byte) error {
1189 return xxx_messageInfo_ExecStressRequest.Unmarshal(m, b)
1190 }
1191 func (m *ExecStressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1192 return xxx_messageInfo_ExecStressRequest.Marshal(b, m, deterministic)
1193 }
1194 func (dst *ExecStressRequest) XXX_Merge(src proto.Message) {
1195 xxx_messageInfo_ExecStressRequest.Merge(dst, src)
1196 }
1197 func (m *ExecStressRequest) XXX_Size() int {
1198 return xxx_messageInfo_ExecStressRequest.Size(m)
1199 }
1200 func (m *ExecStressRequest) XXX_DiscardUnknown() {
1201 xxx_messageInfo_ExecStressRequest.DiscardUnknown(m)
1202 }
1203
1204 var xxx_messageInfo_ExecStressRequest proto.InternalMessageInfo
1205
1206 func (m *ExecStressRequest) GetScope() ExecStressRequest_Scope {
1207 if m != nil {
1208 return m.Scope
1209 }
1210 return ExecStressRequest_CONTAINER
1211 }
1212
1213 func (m *ExecStressRequest) GetTarget() string {
1214 if m != nil {
1215 return m.Target
1216 }
1217 return ""
1218 }
1219
1220 func (m *ExecStressRequest) GetStressors() string {
1221 if m != nil {
1222 return m.Stressors
1223 }
1224 return ""
1225 }
1226
1227 type ExecStressResponse struct {
1228 Instance string `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
1229 StartTime int64 `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
1230 XXX_NoUnkeyedLiteral struct{} `json:"-"`
1231 XXX_unrecognized []byte `json:"-"`
1232 XXX_sizecache int32 `json:"-"`
1233 }
1234
1235 func (m *ExecStressResponse) Reset() { *m = ExecStressResponse{} }
1236 func (m *ExecStressResponse) String() string { return proto.CompactTextString(m) }
1237 func (*ExecStressResponse) ProtoMessage() {}
1238 func (*ExecStressResponse) Descriptor() ([]byte, []int) {
1239 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{20}
1240 }
1241 func (m *ExecStressResponse) XXX_Unmarshal(b []byte) error {
1242 return xxx_messageInfo_ExecStressResponse.Unmarshal(m, b)
1243 }
1244 func (m *ExecStressResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1245 return xxx_messageInfo_ExecStressResponse.Marshal(b, m, deterministic)
1246 }
1247 func (dst *ExecStressResponse) XXX_Merge(src proto.Message) {
1248 xxx_messageInfo_ExecStressResponse.Merge(dst, src)
1249 }
1250 func (m *ExecStressResponse) XXX_Size() int {
1251 return xxx_messageInfo_ExecStressResponse.Size(m)
1252 }
1253 func (m *ExecStressResponse) XXX_DiscardUnknown() {
1254 xxx_messageInfo_ExecStressResponse.DiscardUnknown(m)
1255 }
1256
1257 var xxx_messageInfo_ExecStressResponse proto.InternalMessageInfo
1258
1259 func (m *ExecStressResponse) GetInstance() string {
1260 if m != nil {
1261 return m.Instance
1262 }
1263 return ""
1264 }
1265
1266 func (m *ExecStressResponse) GetStartTime() int64 {
1267 if m != nil {
1268 return m.StartTime
1269 }
1270 return 0
1271 }
1272
1273 type CancelStressRequest struct {
1274 Instance string `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
1275 StartTime int64 `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
1276 XXX_NoUnkeyedLiteral struct{} `json:"-"`
1277 XXX_unrecognized []byte `json:"-"`
1278 XXX_sizecache int32 `json:"-"`
1279 }
1280
1281 func (m *CancelStressRequest) Reset() { *m = CancelStressRequest{} }
1282 func (m *CancelStressRequest) String() string { return proto.CompactTextString(m) }
1283 func (*CancelStressRequest) ProtoMessage() {}
1284 func (*CancelStressRequest) Descriptor() ([]byte, []int) {
1285 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{21}
1286 }
1287 func (m *CancelStressRequest) XXX_Unmarshal(b []byte) error {
1288 return xxx_messageInfo_CancelStressRequest.Unmarshal(m, b)
1289 }
1290 func (m *CancelStressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1291 return xxx_messageInfo_CancelStressRequest.Marshal(b, m, deterministic)
1292 }
1293 func (dst *CancelStressRequest) XXX_Merge(src proto.Message) {
1294 xxx_messageInfo_CancelStressRequest.Merge(dst, src)
1295 }
1296 func (m *CancelStressRequest) XXX_Size() int {
1297 return xxx_messageInfo_CancelStressRequest.Size(m)
1298 }
1299 func (m *CancelStressRequest) XXX_DiscardUnknown() {
1300 xxx_messageInfo_CancelStressRequest.DiscardUnknown(m)
1301 }
1302
1303 var xxx_messageInfo_CancelStressRequest proto.InternalMessageInfo
1304
1305 func (m *CancelStressRequest) GetInstance() string {
1306 if m != nil {
1307 return m.Instance
1308 }
1309 return ""
1310 }
1311
1312 func (m *CancelStressRequest) GetStartTime() int64 {
1313 if m != nil {
1314 return m.StartTime
1315 }
1316 return 0
1317 }
1318
1319 type ApplyIoChaosRequest struct {
1320 Actions string `protobuf:"bytes,1,opt,name=actions,proto3" json:"actions,omitempty"`
1321 Volume string `protobuf:"bytes,2,opt,name=volume,proto3" json:"volume,omitempty"`
1322 ContainerId string `protobuf:"bytes,3,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
1323 Instance int64 `protobuf:"varint,4,opt,name=instance,proto3" json:"instance,omitempty"`
1324 StartTime int64 `protobuf:"varint,5,opt,name=startTime,proto3" json:"startTime,omitempty"`
1325 XXX_NoUnkeyedLiteral struct{} `json:"-"`
1326 XXX_unrecognized []byte `json:"-"`
1327 XXX_sizecache int32 `json:"-"`
1328 }
1329
1330 func (m *ApplyIoChaosRequest) Reset() { *m = ApplyIoChaosRequest{} }
1331 func (m *ApplyIoChaosRequest) String() string { return proto.CompactTextString(m) }
1332 func (*ApplyIoChaosRequest) ProtoMessage() {}
1333 func (*ApplyIoChaosRequest) Descriptor() ([]byte, []int) {
1334 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{22}
1335 }
1336 func (m *ApplyIoChaosRequest) XXX_Unmarshal(b []byte) error {
1337 return xxx_messageInfo_ApplyIoChaosRequest.Unmarshal(m, b)
1338 }
1339 func (m *ApplyIoChaosRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1340 return xxx_messageInfo_ApplyIoChaosRequest.Marshal(b, m, deterministic)
1341 }
1342 func (dst *ApplyIoChaosRequest) XXX_Merge(src proto.Message) {
1343 xxx_messageInfo_ApplyIoChaosRequest.Merge(dst, src)
1344 }
1345 func (m *ApplyIoChaosRequest) XXX_Size() int {
1346 return xxx_messageInfo_ApplyIoChaosRequest.Size(m)
1347 }
1348 func (m *ApplyIoChaosRequest) XXX_DiscardUnknown() {
1349 xxx_messageInfo_ApplyIoChaosRequest.DiscardUnknown(m)
1350 }
1351
1352 var xxx_messageInfo_ApplyIoChaosRequest proto.InternalMessageInfo
1353
1354 func (m *ApplyIoChaosRequest) GetActions() string {
1355 if m != nil {
1356 return m.Actions
1357 }
1358 return ""
1359 }
1360
1361 func (m *ApplyIoChaosRequest) GetVolume() string {
1362 if m != nil {
1363 return m.Volume
1364 }
1365 return ""
1366 }
1367
1368 func (m *ApplyIoChaosRequest) GetContainerId() string {
1369 if m != nil {
1370 return m.ContainerId
1371 }
1372 return ""
1373 }
1374
1375 func (m *ApplyIoChaosRequest) GetInstance() int64 {
1376 if m != nil {
1377 return m.Instance
1378 }
1379 return 0
1380 }
1381
1382 func (m *ApplyIoChaosRequest) GetStartTime() int64 {
1383 if m != nil {
1384 return m.StartTime
1385 }
1386 return 0
1387 }
1388
1389 type ApplyIoChaosResponse struct {
1390 Instance int64 `protobuf:"varint,1,opt,name=instance,proto3" json:"instance,omitempty"`
1391 StartTime int64 `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
1392 XXX_NoUnkeyedLiteral struct{} `json:"-"`
1393 XXX_unrecognized []byte `json:"-"`
1394 XXX_sizecache int32 `json:"-"`
1395 }
1396
1397 func (m *ApplyIoChaosResponse) Reset() { *m = ApplyIoChaosResponse{} }
1398 func (m *ApplyIoChaosResponse) String() string { return proto.CompactTextString(m) }
1399 func (*ApplyIoChaosResponse) ProtoMessage() {}
1400 func (*ApplyIoChaosResponse) Descriptor() ([]byte, []int) {
1401 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{23}
1402 }
1403 func (m *ApplyIoChaosResponse) XXX_Unmarshal(b []byte) error {
1404 return xxx_messageInfo_ApplyIoChaosResponse.Unmarshal(m, b)
1405 }
1406 func (m *ApplyIoChaosResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1407 return xxx_messageInfo_ApplyIoChaosResponse.Marshal(b, m, deterministic)
1408 }
1409 func (dst *ApplyIoChaosResponse) XXX_Merge(src proto.Message) {
1410 xxx_messageInfo_ApplyIoChaosResponse.Merge(dst, src)
1411 }
1412 func (m *ApplyIoChaosResponse) XXX_Size() int {
1413 return xxx_messageInfo_ApplyIoChaosResponse.Size(m)
1414 }
1415 func (m *ApplyIoChaosResponse) XXX_DiscardUnknown() {
1416 xxx_messageInfo_ApplyIoChaosResponse.DiscardUnknown(m)
1417 }
1418
1419 var xxx_messageInfo_ApplyIoChaosResponse proto.InternalMessageInfo
1420
1421 func (m *ApplyIoChaosResponse) GetInstance() int64 {
1422 if m != nil {
1423 return m.Instance
1424 }
1425 return 0
1426 }
1427
1428 func (m *ApplyIoChaosResponse) GetStartTime() int64 {
1429 if m != nil {
1430 return m.StartTime
1431 }
1432 return 0
1433 }
1434
1435 type TcsRequest struct {
1436 Tcs []*Tc `protobuf:"bytes,1,rep,name=tcs,proto3" json:"tcs,omitempty"`
1437 ContainerId string `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
1438 XXX_NoUnkeyedLiteral struct{} `json:"-"`
1439 XXX_unrecognized []byte `json:"-"`
1440 XXX_sizecache int32 `json:"-"`
1441 }
1442
1443 func (m *TcsRequest) Reset() { *m = TcsRequest{} }
1444 func (m *TcsRequest) String() string { return proto.CompactTextString(m) }
1445 func (*TcsRequest) ProtoMessage() {}
1446 func (*TcsRequest) Descriptor() ([]byte, []int) {
1447 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{24}
1448 }
1449 func (m *TcsRequest) XXX_Unmarshal(b []byte) error {
1450 return xxx_messageInfo_TcsRequest.Unmarshal(m, b)
1451 }
1452 func (m *TcsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1453 return xxx_messageInfo_TcsRequest.Marshal(b, m, deterministic)
1454 }
1455 func (dst *TcsRequest) XXX_Merge(src proto.Message) {
1456 xxx_messageInfo_TcsRequest.Merge(dst, src)
1457 }
1458 func (m *TcsRequest) XXX_Size() int {
1459 return xxx_messageInfo_TcsRequest.Size(m)
1460 }
1461 func (m *TcsRequest) XXX_DiscardUnknown() {
1462 xxx_messageInfo_TcsRequest.DiscardUnknown(m)
1463 }
1464
1465 var xxx_messageInfo_TcsRequest proto.InternalMessageInfo
1466
1467 func (m *TcsRequest) GetTcs() []*Tc {
1468 if m != nil {
1469 return m.Tcs
1470 }
1471 return nil
1472 }
1473
1474 func (m *TcsRequest) GetContainerId() string {
1475 if m != nil {
1476 return m.ContainerId
1477 }
1478 return ""
1479 }
1480
1481 type Tc struct {
1482 Type Tc_Type `protobuf:"varint,1,opt,name=type,proto3,enum=pb.Tc_Type" json:"type,omitempty"`
1483 Netem *Netem `protobuf:"bytes,2,opt,name=netem,proto3" json:"netem,omitempty"`
1484 Tbf *Tbf `protobuf:"bytes,3,opt,name=tbf,proto3" json:"tbf,omitempty"`
1485 Ipset string `protobuf:"bytes,4,opt,name=ipset,proto3" json:"ipset,omitempty"`
1486 XXX_NoUnkeyedLiteral struct{} `json:"-"`
1487 XXX_unrecognized []byte `json:"-"`
1488 XXX_sizecache int32 `json:"-"`
1489 }
1490
1491 func (m *Tc) Reset() { *m = Tc{} }
1492 func (m *Tc) String() string { return proto.CompactTextString(m) }
1493 func (*Tc) ProtoMessage() {}
1494 func (*Tc) Descriptor() ([]byte, []int) {
1495 return fileDescriptor_chaosdaemon_d32cf42dab093cba, []int{25}
1496 }
1497 func (m *Tc) XXX_Unmarshal(b []byte) error {
1498 return xxx_messageInfo_Tc.Unmarshal(m, b)
1499 }
1500 func (m *Tc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
1501 return xxx_messageInfo_Tc.Marshal(b, m, deterministic)
1502 }
1503 func (dst *Tc) XXX_Merge(src proto.Message) {
1504 xxx_messageInfo_Tc.Merge(dst, src)
1505 }
1506 func (m *Tc) XXX_Size() int {
1507 return xxx_messageInfo_Tc.Size(m)
1508 }
1509 func (m *Tc) XXX_DiscardUnknown() {
1510 xxx_messageInfo_Tc.DiscardUnknown(m)
1511 }
1512
1513 var xxx_messageInfo_Tc proto.InternalMessageInfo
1514
1515 func (m *Tc) GetType() Tc_Type {
1516 if m != nil {
1517 return m.Type
1518 }
1519 return Tc_NETEM
1520 }
1521
1522 func (m *Tc) GetNetem() *Netem {
1523 if m != nil {
1524 return m.Netem
1525 }
1526 return nil
1527 }
1528
1529 func (m *Tc) GetTbf() *Tbf {
1530 if m != nil {
1531 return m.Tbf
1532 }
1533 return nil
1534 }
1535
1536 func (m *Tc) GetIpset() string {
1537 if m != nil {
1538 return m.Ipset
1539 }
1540 return ""
1541 }
1542
1543 func init() {
1544 proto.RegisterType((*TcHandle)(nil), "pb.TcHandle")
1545 proto.RegisterType((*ContainerRequest)(nil), "pb.ContainerRequest")
1546 proto.RegisterType((*ContainerResponse)(nil), "pb.ContainerResponse")
1547 proto.RegisterType((*NetemRequest)(nil), "pb.NetemRequest")
1548 proto.RegisterType((*Netem)(nil), "pb.Netem")
1549 proto.RegisterType((*TbfRequest)(nil), "pb.TbfRequest")
1550 proto.RegisterType((*Tbf)(nil), "pb.Tbf")
1551 proto.RegisterType((*QdiscRequest)(nil), "pb.QdiscRequest")
1552 proto.RegisterType((*Qdisc)(nil), "pb.Qdisc")
1553 proto.RegisterType((*EmatchFilterRequest)(nil), "pb.EmatchFilterRequest")
1554 proto.RegisterType((*EmatchFilter)(nil), "pb.EmatchFilter")
1555 proto.RegisterType((*TcFilterRequest)(nil), "pb.TcFilterRequest")
1556 proto.RegisterType((*TcFilter)(nil), "pb.TcFilter")
1557 proto.RegisterType((*IPSetsRequest)(nil), "pb.IPSetsRequest")
1558 proto.RegisterType((*IPSet)(nil), "pb.IPSet")
1559 proto.RegisterType((*IptablesChainsRequest)(nil), "pb.IptablesChainsRequest")
1560 proto.RegisterType((*Chain)(nil), "pb.Chain")
1561 proto.RegisterType((*TimeRequest)(nil), "pb.TimeRequest")
1562 proto.RegisterType((*ContainerAction)(nil), "pb.ContainerAction")
1563 proto.RegisterType((*ExecStressRequest)(nil), "pb.ExecStressRequest")
1564 proto.RegisterType((*ExecStressResponse)(nil), "pb.ExecStressResponse")
1565 proto.RegisterType((*CancelStressRequest)(nil), "pb.CancelStressRequest")
1566 proto.RegisterType((*ApplyIoChaosRequest)(nil), "pb.ApplyIoChaosRequest")
1567 proto.RegisterType((*ApplyIoChaosResponse)(nil), "pb.ApplyIoChaosResponse")
1568 proto.RegisterType((*TcsRequest)(nil), "pb.TcsRequest")
1569 proto.RegisterType((*Tc)(nil), "pb.Tc")
1570 proto.RegisterEnum("pb.Chain_Direction", Chain_Direction_name, Chain_Direction_value)
1571 proto.RegisterEnum("pb.ContainerAction_Action", ContainerAction_Action_name, ContainerAction_Action_value)
1572 proto.RegisterEnum("pb.ExecStressRequest_Scope", ExecStressRequest_Scope_name, ExecStressRequest_Scope_value)
1573 proto.RegisterEnum("pb.Tc_Type", Tc_Type_name, Tc_Type_value)
1574 }
1575
1576
1577 var _ context.Context
1578 var _ grpc.ClientConn
1579
1580
1581
1582 const _ = grpc.SupportPackageIsVersion4
1583
1584
1585
1586
1587 type ChaosDaemonClient interface {
1588 SetTcs(ctx context.Context, in *TcsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
1589 FlushIPSets(ctx context.Context, in *IPSetsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
1590 SetIptablesChains(ctx context.Context, in *IptablesChainsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
1591 SetTimeOffset(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error)
1592 RecoverTimeOffset(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error)
1593 ContainerKill(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*empty.Empty, error)
1594 ContainerGetPid(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*ContainerResponse, error)
1595 ExecStressors(ctx context.Context, in *ExecStressRequest, opts ...grpc.CallOption) (*ExecStressResponse, error)
1596 CancelStressors(ctx context.Context, in *CancelStressRequest, opts ...grpc.CallOption) (*empty.Empty, error)
1597 ApplyIoChaos(ctx context.Context, in *ApplyIoChaosRequest, opts ...grpc.CallOption) (*ApplyIoChaosResponse, error)
1598 }
1599
1600 type chaosDaemonClient struct {
1601 cc *grpc.ClientConn
1602 }
1603
1604 func NewChaosDaemonClient(cc *grpc.ClientConn) ChaosDaemonClient {
1605 return &chaosDaemonClient{cc}
1606 }
1607
1608 func (c *chaosDaemonClient) SetTcs(ctx context.Context, in *TcsRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
1609 out := new(empty.Empty)
1610 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/SetTcs", in, out, opts...)
1611 if err != nil {
1612 return nil, err
1613 }
1614 return out, nil
1615 }
1616
1617 func (c *chaosDaemonClient) FlushIPSets(ctx context.Context, in *IPSetsRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
1618 out := new(empty.Empty)
1619 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/FlushIPSets", in, out, opts...)
1620 if err != nil {
1621 return nil, err
1622 }
1623 return out, nil
1624 }
1625
1626 func (c *chaosDaemonClient) SetIptablesChains(ctx context.Context, in *IptablesChainsRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
1627 out := new(empty.Empty)
1628 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/SetIptablesChains", in, out, opts...)
1629 if err != nil {
1630 return nil, err
1631 }
1632 return out, nil
1633 }
1634
1635 func (c *chaosDaemonClient) SetTimeOffset(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
1636 out := new(empty.Empty)
1637 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/SetTimeOffset", in, out, opts...)
1638 if err != nil {
1639 return nil, err
1640 }
1641 return out, nil
1642 }
1643
1644 func (c *chaosDaemonClient) RecoverTimeOffset(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
1645 out := new(empty.Empty)
1646 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/RecoverTimeOffset", in, out, opts...)
1647 if err != nil {
1648 return nil, err
1649 }
1650 return out, nil
1651 }
1652
1653 func (c *chaosDaemonClient) ContainerKill(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
1654 out := new(empty.Empty)
1655 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/ContainerKill", in, out, opts...)
1656 if err != nil {
1657 return nil, err
1658 }
1659 return out, nil
1660 }
1661
1662 func (c *chaosDaemonClient) ContainerGetPid(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*ContainerResponse, error) {
1663 out := new(ContainerResponse)
1664 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/ContainerGetPid", in, out, opts...)
1665 if err != nil {
1666 return nil, err
1667 }
1668 return out, nil
1669 }
1670
1671 func (c *chaosDaemonClient) ExecStressors(ctx context.Context, in *ExecStressRequest, opts ...grpc.CallOption) (*ExecStressResponse, error) {
1672 out := new(ExecStressResponse)
1673 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/ExecStressors", in, out, opts...)
1674 if err != nil {
1675 return nil, err
1676 }
1677 return out, nil
1678 }
1679
1680 func (c *chaosDaemonClient) CancelStressors(ctx context.Context, in *CancelStressRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
1681 out := new(empty.Empty)
1682 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/CancelStressors", in, out, opts...)
1683 if err != nil {
1684 return nil, err
1685 }
1686 return out, nil
1687 }
1688
1689 func (c *chaosDaemonClient) ApplyIoChaos(ctx context.Context, in *ApplyIoChaosRequest, opts ...grpc.CallOption) (*ApplyIoChaosResponse, error) {
1690 out := new(ApplyIoChaosResponse)
1691 err := c.cc.Invoke(ctx, "/pb.ChaosDaemon/ApplyIoChaos", in, out, opts...)
1692 if err != nil {
1693 return nil, err
1694 }
1695 return out, nil
1696 }
1697
1698
1699 type ChaosDaemonServer interface {
1700 SetTcs(context.Context, *TcsRequest) (*empty.Empty, error)
1701 FlushIPSets(context.Context, *IPSetsRequest) (*empty.Empty, error)
1702 SetIptablesChains(context.Context, *IptablesChainsRequest) (*empty.Empty, error)
1703 SetTimeOffset(context.Context, *TimeRequest) (*empty.Empty, error)
1704 RecoverTimeOffset(context.Context, *TimeRequest) (*empty.Empty, error)
1705 ContainerKill(context.Context, *ContainerRequest) (*empty.Empty, error)
1706 ContainerGetPid(context.Context, *ContainerRequest) (*ContainerResponse, error)
1707 ExecStressors(context.Context, *ExecStressRequest) (*ExecStressResponse, error)
1708 CancelStressors(context.Context, *CancelStressRequest) (*empty.Empty, error)
1709 ApplyIoChaos(context.Context, *ApplyIoChaosRequest) (*ApplyIoChaosResponse, error)
1710 }
1711
1712 func RegisterChaosDaemonServer(s *grpc.Server, srv ChaosDaemonServer) {
1713 s.RegisterService(&_ChaosDaemon_serviceDesc, srv)
1714 }
1715
1716 func _ChaosDaemon_SetTcs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1717 in := new(TcsRequest)
1718 if err := dec(in); err != nil {
1719 return nil, err
1720 }
1721 if interceptor == nil {
1722 return srv.(ChaosDaemonServer).SetTcs(ctx, in)
1723 }
1724 info := &grpc.UnaryServerInfo{
1725 Server: srv,
1726 FullMethod: "/pb.ChaosDaemon/SetTcs",
1727 }
1728 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1729 return srv.(ChaosDaemonServer).SetTcs(ctx, req.(*TcsRequest))
1730 }
1731 return interceptor(ctx, in, info, handler)
1732 }
1733
1734 func _ChaosDaemon_FlushIPSets_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1735 in := new(IPSetsRequest)
1736 if err := dec(in); err != nil {
1737 return nil, err
1738 }
1739 if interceptor == nil {
1740 return srv.(ChaosDaemonServer).FlushIPSets(ctx, in)
1741 }
1742 info := &grpc.UnaryServerInfo{
1743 Server: srv,
1744 FullMethod: "/pb.ChaosDaemon/FlushIPSets",
1745 }
1746 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1747 return srv.(ChaosDaemonServer).FlushIPSets(ctx, req.(*IPSetsRequest))
1748 }
1749 return interceptor(ctx, in, info, handler)
1750 }
1751
1752 func _ChaosDaemon_SetIptablesChains_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1753 in := new(IptablesChainsRequest)
1754 if err := dec(in); err != nil {
1755 return nil, err
1756 }
1757 if interceptor == nil {
1758 return srv.(ChaosDaemonServer).SetIptablesChains(ctx, in)
1759 }
1760 info := &grpc.UnaryServerInfo{
1761 Server: srv,
1762 FullMethod: "/pb.ChaosDaemon/SetIptablesChains",
1763 }
1764 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1765 return srv.(ChaosDaemonServer).SetIptablesChains(ctx, req.(*IptablesChainsRequest))
1766 }
1767 return interceptor(ctx, in, info, handler)
1768 }
1769
1770 func _ChaosDaemon_SetTimeOffset_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1771 in := new(TimeRequest)
1772 if err := dec(in); err != nil {
1773 return nil, err
1774 }
1775 if interceptor == nil {
1776 return srv.(ChaosDaemonServer).SetTimeOffset(ctx, in)
1777 }
1778 info := &grpc.UnaryServerInfo{
1779 Server: srv,
1780 FullMethod: "/pb.ChaosDaemon/SetTimeOffset",
1781 }
1782 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1783 return srv.(ChaosDaemonServer).SetTimeOffset(ctx, req.(*TimeRequest))
1784 }
1785 return interceptor(ctx, in, info, handler)
1786 }
1787
1788 func _ChaosDaemon_RecoverTimeOffset_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1789 in := new(TimeRequest)
1790 if err := dec(in); err != nil {
1791 return nil, err
1792 }
1793 if interceptor == nil {
1794 return srv.(ChaosDaemonServer).RecoverTimeOffset(ctx, in)
1795 }
1796 info := &grpc.UnaryServerInfo{
1797 Server: srv,
1798 FullMethod: "/pb.ChaosDaemon/RecoverTimeOffset",
1799 }
1800 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1801 return srv.(ChaosDaemonServer).RecoverTimeOffset(ctx, req.(*TimeRequest))
1802 }
1803 return interceptor(ctx, in, info, handler)
1804 }
1805
1806 func _ChaosDaemon_ContainerKill_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1807 in := new(ContainerRequest)
1808 if err := dec(in); err != nil {
1809 return nil, err
1810 }
1811 if interceptor == nil {
1812 return srv.(ChaosDaemonServer).ContainerKill(ctx, in)
1813 }
1814 info := &grpc.UnaryServerInfo{
1815 Server: srv,
1816 FullMethod: "/pb.ChaosDaemon/ContainerKill",
1817 }
1818 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1819 return srv.(ChaosDaemonServer).ContainerKill(ctx, req.(*ContainerRequest))
1820 }
1821 return interceptor(ctx, in, info, handler)
1822 }
1823
1824 func _ChaosDaemon_ContainerGetPid_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1825 in := new(ContainerRequest)
1826 if err := dec(in); err != nil {
1827 return nil, err
1828 }
1829 if interceptor == nil {
1830 return srv.(ChaosDaemonServer).ContainerGetPid(ctx, in)
1831 }
1832 info := &grpc.UnaryServerInfo{
1833 Server: srv,
1834 FullMethod: "/pb.ChaosDaemon/ContainerGetPid",
1835 }
1836 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1837 return srv.(ChaosDaemonServer).ContainerGetPid(ctx, req.(*ContainerRequest))
1838 }
1839 return interceptor(ctx, in, info, handler)
1840 }
1841
1842 func _ChaosDaemon_ExecStressors_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1843 in := new(ExecStressRequest)
1844 if err := dec(in); err != nil {
1845 return nil, err
1846 }
1847 if interceptor == nil {
1848 return srv.(ChaosDaemonServer).ExecStressors(ctx, in)
1849 }
1850 info := &grpc.UnaryServerInfo{
1851 Server: srv,
1852 FullMethod: "/pb.ChaosDaemon/ExecStressors",
1853 }
1854 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1855 return srv.(ChaosDaemonServer).ExecStressors(ctx, req.(*ExecStressRequest))
1856 }
1857 return interceptor(ctx, in, info, handler)
1858 }
1859
1860 func _ChaosDaemon_CancelStressors_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1861 in := new(CancelStressRequest)
1862 if err := dec(in); err != nil {
1863 return nil, err
1864 }
1865 if interceptor == nil {
1866 return srv.(ChaosDaemonServer).CancelStressors(ctx, in)
1867 }
1868 info := &grpc.UnaryServerInfo{
1869 Server: srv,
1870 FullMethod: "/pb.ChaosDaemon/CancelStressors",
1871 }
1872 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1873 return srv.(ChaosDaemonServer).CancelStressors(ctx, req.(*CancelStressRequest))
1874 }
1875 return interceptor(ctx, in, info, handler)
1876 }
1877
1878 func _ChaosDaemon_ApplyIoChaos_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1879 in := new(ApplyIoChaosRequest)
1880 if err := dec(in); err != nil {
1881 return nil, err
1882 }
1883 if interceptor == nil {
1884 return srv.(ChaosDaemonServer).ApplyIoChaos(ctx, in)
1885 }
1886 info := &grpc.UnaryServerInfo{
1887 Server: srv,
1888 FullMethod: "/pb.ChaosDaemon/ApplyIoChaos",
1889 }
1890 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1891 return srv.(ChaosDaemonServer).ApplyIoChaos(ctx, req.(*ApplyIoChaosRequest))
1892 }
1893 return interceptor(ctx, in, info, handler)
1894 }
1895
1896 var _ChaosDaemon_serviceDesc = grpc.ServiceDesc{
1897 ServiceName: "pb.ChaosDaemon",
1898 HandlerType: (*ChaosDaemonServer)(nil),
1899 Methods: []grpc.MethodDesc{
1900 {
1901 MethodName: "SetTcs",
1902 Handler: _ChaosDaemon_SetTcs_Handler,
1903 },
1904 {
1905 MethodName: "FlushIPSets",
1906 Handler: _ChaosDaemon_FlushIPSets_Handler,
1907 },
1908 {
1909 MethodName: "SetIptablesChains",
1910 Handler: _ChaosDaemon_SetIptablesChains_Handler,
1911 },
1912 {
1913 MethodName: "SetTimeOffset",
1914 Handler: _ChaosDaemon_SetTimeOffset_Handler,
1915 },
1916 {
1917 MethodName: "RecoverTimeOffset",
1918 Handler: _ChaosDaemon_RecoverTimeOffset_Handler,
1919 },
1920 {
1921 MethodName: "ContainerKill",
1922 Handler: _ChaosDaemon_ContainerKill_Handler,
1923 },
1924 {
1925 MethodName: "ContainerGetPid",
1926 Handler: _ChaosDaemon_ContainerGetPid_Handler,
1927 },
1928 {
1929 MethodName: "ExecStressors",
1930 Handler: _ChaosDaemon_ExecStressors_Handler,
1931 },
1932 {
1933 MethodName: "CancelStressors",
1934 Handler: _ChaosDaemon_CancelStressors_Handler,
1935 },
1936 {
1937 MethodName: "ApplyIoChaos",
1938 Handler: _ChaosDaemon_ApplyIoChaos_Handler,
1939 },
1940 },
1941 Streams: []grpc.StreamDesc{},
1942 Metadata: "chaosdaemon.proto",
1943 }
1944
1945 func init() { proto.RegisterFile("chaosdaemon.proto", fileDescriptor_chaosdaemon_d32cf42dab093cba) }
1946
1947 var fileDescriptor_chaosdaemon_d32cf42dab093cba = []byte{
1948
1949 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x56, 0xcd, 0x6e, 0xdb, 0xc6,
1950 0x16, 0x36, 0x45, 0x49, 0x16, 0x8f, 0x24, 0x5b, 0x1e, 0x3b, 0xbe, 0x8c, 0x7d, 0xef, 0x8d, 0x43,
1951 0x24, 0x45, 0x80, 0x02, 0x4a, 0xe3, 0x02, 0x5d, 0x74, 0xd1, 0xd6, 0x91, 0x95, 0x44, 0x4d, 0x22,
1952 0xbb, 0x63, 0x06, 0x05, 0x0a, 0x14, 0x06, 0x7f, 0x46, 0x36, 0x63, 0x8a, 0x64, 0x38, 0xa3, 0x20,
1953 0x46, 0x57, 0x7d, 0x86, 0xae, 0xba, 0x68, 0x17, 0x45, 0x9f, 0xa1, 0xcf, 0x57, 0xcc, 0x99, 0xa1,
1954 0x44, 0xd9, 0xb2, 0xab, 0x66, 0xc5, 0x39, 0x7f, 0xdf, 0x9c, 0x9f, 0xe1, 0x37, 0x03, 0x1b, 0xc1,
1955 0xb9, 0x97, 0xf2, 0xd0, 0x63, 0xe3, 0x34, 0xe9, 0x66, 0x79, 0x2a, 0x52, 0x52, 0xc9, 0xfc, 0x9d,
1956 0xdd, 0xb3, 0x34, 0x3d, 0x8b, 0xd9, 0x63, 0xd4, 0xf8, 0x93, 0xd1, 0x63, 0x36, 0xce, 0xc4, 0xa5,
1957 0x72, 0x70, 0xbe, 0x80, 0x86, 0x1b, 0xbc, 0xf0, 0x92, 0x30, 0x66, 0x64, 0x0b, 0x6a, 0x63, 0xef,
1958 0x6d, 0x9a, 0xdb, 0xc6, 0x9e, 0xf1, 0xa8, 0x4d, 0x95, 0x80, 0xda, 0x28, 0x49, 0x73, 0xbb, 0xa2,
1959 0xb5, 0x52, 0x70, 0x7c, 0xe8, 0xf4, 0xd2, 0x44, 0x78, 0x51, 0xc2, 0x72, 0xca, 0xde, 0x4d, 0x18,
1960 0x17, 0xe4, 0x53, 0xa8, 0x7b, 0x81, 0x88, 0xd2, 0x04, 0x01, 0x9a, 0xfb, 0x9b, 0xdd, 0xcc, 0xef,
1961 0x4e, 0xbd, 0x0e, 0xd0, 0x44, 0xb5, 0x0b, 0xb9, 0x0f, 0xad, 0xa0, 0x30, 0x9d, 0x46, 0x21, 0xa2,
1962 0x5b, 0xb4, 0x39, 0xd5, 0x0d, 0x42, 0xe7, 0x21, 0x6c, 0x94, 0xf6, 0xe0, 0x59, 0x9a, 0x70, 0x46,
1963 0x3a, 0x60, 0x66, 0x51, 0xa8, 0x53, 0x94, 0x4b, 0xe7, 0x77, 0x03, 0x5a, 0x43, 0x26, 0xd8, 0xb8,
1964 0xc8, 0xe3, 0x1e, 0xd4, 0x12, 0x29, 0xeb, 0x34, 0x2c, 0x99, 0x86, 0x72, 0x50, 0xfa, 0x25, 0xf6,
1965 0x26, 0x0f, 0xa0, 0x7e, 0x8e, 0x5d, 0xb1, 0x4d, 0x04, 0x69, 0x49, 0x90, 0xa2, 0x53, 0x54, 0xdb,
1966 0xa4, 0x57, 0xe6, 0xe5, 0x2c, 0x11, 0x76, 0x75, 0x91, 0x97, 0xb2, 0x39, 0x7f, 0x99, 0x50, 0xc3,
1967 0xfd, 0x09, 0x81, 0xaa, 0x88, 0xc6, 0x4c, 0x67, 0x8f, 0x6b, 0xb2, 0x0d, 0xf5, 0xb7, 0x91, 0x10,
1968 0xac, 0x68, 0xb0, 0x96, 0xc8, 0xff, 0x00, 0x42, 0x16, 0x7b, 0x97, 0xa7, 0x41, 0x9a, 0xe7, 0x98,
1969 0x45, 0x85, 0x5a, 0xa8, 0xe9, 0xa5, 0x39, 0x8e, 0x25, 0x8e, 0xc6, 0x91, 0xda, 0xb9, 0x4d, 0x95,
1970 0x20, 0x37, 0x88, 0x53, 0xce, 0xed, 0x1a, 0xba, 0xe3, 0x9a, 0xec, 0x82, 0x25, 0xbf, 0x0a, 0xa7,
1971 0x8e, 0x86, 0x86, 0x54, 0x20, 0x4c, 0x07, 0xcc, 0x33, 0x2f, 0xb3, 0x57, 0x55, 0x3b, 0xcf, 0xbc,
1972 0x8c, 0xfc, 0x17, 0xac, 0x70, 0x92, 0xc5, 0x51, 0xe0, 0x09, 0x66, 0x37, 0xf4, 0xb6, 0x85, 0x82,
1973 0x3c, 0x84, 0xb5, 0xa9, 0xa0, 0x10, 0x2d, 0x74, 0x69, 0x4f, 0xb5, 0x08, 0x6b, 0xc3, 0x6a, 0xce,
1974 0xd2, 0x3c, 0x64, 0xb9, 0x0d, 0x68, 0x2f, 0x44, 0xd9, 0x7b, 0xbd, 0x54, 0xe1, 0x4d, 0x34, 0x37,
1975 0xb5, 0xae, 0x08, 0x96, 0xa6, 0x49, 0x26, 0xec, 0x96, 0x0a, 0xd6, 0xa2, 0x1a, 0x1c, 0x2e, 0x55,
1976 0x70, 0x5b, 0x05, 0x6b, 0x1d, 0x06, 0xcf, 0x46, 0xb2, 0x76, 0xf3, 0x48, 0x4a, 0xe3, 0x5d, 0xbf,
1977 0x79, 0xbc, 0xce, 0xb7, 0x00, 0xae, 0x3f, 0x2a, 0x8e, 0xd5, 0x5d, 0x30, 0x85, 0x3f, 0xd2, 0x87,
1978 0x6a, 0x15, 0x03, 0xfc, 0x11, 0x95, 0xba, 0x65, 0x0e, 0xf3, 0xcf, 0x06, 0x98, 0xae, 0x3f, 0x92,
1979 0x13, 0xca, 0x65, 0x67, 0x25, 0x4c, 0x95, 0xe2, 0x7a, 0x36, 0xcb, 0x4a, 0x79, 0x96, 0xdb, 0x50,
1980 0xf7, 0x27, 0xa3, 0x11, 0x53, 0xc3, 0x6f, 0x53, 0x2d, 0xc9, 0x79, 0x66, 0xcc, 0xbb, 0x38, 0x45,
1981 0x98, 0x2a, 0xc2, 0x34, 0xa4, 0x82, 0x4a, 0xa8, 0x5d, 0xb0, 0xc6, 0x51, 0x72, 0xea, 0x4f, 0x72,
1982 0x2e, 0xf0, 0x14, 0xb4, 0x69, 0x63, 0x1c, 0x25, 0x4f, 0xa5, 0xec, 0x50, 0x68, 0x7d, 0x17, 0x46,
1983 0x3c, 0x28, 0xfd, 0x28, 0xef, 0xa4, 0x5c, 0xfe, 0x51, 0x94, 0x83, 0xd2, 0x2f, 0x53, 0xd7, 0x4f,
1984 0x50, 0xc3, 0x90, 0x52, 0xe3, 0x8d, 0xa5, 0x1a, 0x5f, 0xb9, 0xe5, 0xbf, 0x92, 0xff, 0xc9, 0x65,
1985 0xa6, 0xfe, 0x3d, 0x8b, 0xe2, 0x5a, 0xea, 0xbc, 0xfc, 0x8c, 0xdb, 0xd5, 0x3d, 0x53, 0xea, 0xe4,
1986 0xda, 0xf1, 0x61, 0xb3, 0x3f, 0xf6, 0x44, 0x70, 0xfe, 0x2c, 0x8a, 0xc5, 0x8c, 0x88, 0x1e, 0x41,
1987 0x7d, 0x84, 0x0a, 0x9d, 0x4a, 0x47, 0x6e, 0x32, 0xe7, 0xa8, 0xed, 0xcb, 0x14, 0x98, 0x43, 0xab,
1988 0x1c, 0xaa, 0x58, 0x52, 0x04, 0xe7, 0x88, 0x6d, 0x51, 0x25, 0x94, 0xaa, 0xaf, 0xdc, 0x52, 0xfd,
1989 0x27, 0xb0, 0x1a, 0xc4, 0x1e, 0xe7, 0x51, 0xb8, 0x90, 0x56, 0x0a, 0xa3, 0xf3, 0x03, 0xac, 0xbb,
1990 0xc1, 0x7c, 0x4d, 0x0f, 0xae, 0xd4, 0xa4, 0x23, 0xff, 0x7d, 0x3d, 0x9f, 0x49, 0xc6, 0xd7, 0xb5,
1991 0x2c, 0x35, 0x33, 0xe7, 0x0d, 0xb4, 0x07, 0xc7, 0x27, 0x4c, 0xf0, 0x22, 0x97, 0xfb, 0x50, 0x8f,
1992 0x32, 0xce, 0x04, 0xb7, 0x8d, 0x3d, 0xb3, 0x38, 0x38, 0xe8, 0x42, 0xb5, 0x61, 0x99, 0x44, 0x9e,
1993 0x40, 0x0d, 0x63, 0xe4, 0x64, 0x13, 0x4f, 0xb3, 0xa2, 0x45, 0x71, 0x2d, 0xbb, 0x1c, 0x44, 0x61,
1994 0xce, 0xed, 0x0a, 0x8e, 0x5b, 0x09, 0xce, 0x8f, 0x70, 0x67, 0x90, 0x09, 0xcf, 0x8f, 0x19, 0xef,
1995 0x9d, 0x7b, 0x51, 0x52, 0xce, 0x28, 0x40, 0x45, 0x39, 0x23, 0x74, 0xa1, 0xda, 0xb0, 0x4c, 0x46,
1996 0x7f, 0x18, 0x50, 0xc3, 0xa0, 0x85, 0x29, 0x3d, 0x01, 0x2b, 0x8c, 0x72, 0xa6, 0x6e, 0x38, 0x19,
1997 0xbd, 0xa6, 0x6f, 0x38, 0x19, 0xd1, 0x3d, 0x2c, 0x4c, 0x74, 0xe6, 0x25, 0x7f, 0x61, 0xdd, 0x28,
1998 0x13, 0xcb, 0x28, 0xba, 0xb3, 0x0d, 0x75, 0xe1, 0xe5, 0x67, 0x4c, 0xb1, 0xb7, 0x45, 0xb5, 0xe4,
1999 0x38, 0x60, 0x4d, 0x71, 0x88, 0x05, 0xb5, 0xc1, 0xf0, 0xf8, 0x8d, 0xdb, 0x59, 0x21, 0x00, 0xf5,
2000 0xa3, 0x37, 0xae, 0x5c, 0x1b, 0xce, 0x07, 0x68, 0xba, 0xd1, 0x98, 0xcd, 0x2a, 0x9f, 0x2f, 0xcb,
2001 0xb8, 0x7e, 0x97, 0x75, 0xc0, 0xe4, 0x2c, 0xc0, 0x94, 0x4d, 0x2a, 0x97, 0x58, 0x9e, 0x54, 0x99,
2002 0xa8, 0xc2, 0x35, 0xd9, 0x83, 0x56, 0x10, 0x5f, 0x9c, 0x46, 0x21, 0x3f, 0x1d, 0x7b, 0xfc, 0x42,
2003 0x33, 0x0b, 0x04, 0xf1, 0xc5, 0x20, 0xe4, 0xaf, 0x3d, 0x7e, 0xe1, 0x30, 0x58, 0xbf, 0x72, 0x9b,
2004 0x93, 0xfd, 0xb9, 0x2b, 0x7f, 0x6d, 0x7f, 0x67, 0xc1, 0x95, 0xdf, 0x9d, 0xbf, 0xf9, 0x9d, 0xff,
2005 0x43, 0x5d, 0x47, 0x37, 0xa0, 0xfa, 0x72, 0xf0, 0xea, 0x95, 0x2a, 0xf0, 0x79, 0xdf, 0x3d, 0x1e,
2006 0x1c, 0x76, 0x0c, 0xe7, 0x37, 0x03, 0x36, 0xfa, 0x1f, 0x58, 0x70, 0x22, 0x72, 0xc6, 0xa7, 0x13,
2007 0x7e, 0x02, 0x35, 0x1e, 0xa4, 0x19, 0xd3, 0x1b, 0xed, 0xe2, 0x2f, 0x7d, 0xd5, 0xab, 0x7b, 0x22,
2008 0x5d, 0xa8, 0xf2, 0x2c, 0x75, 0xb9, 0x52, 0xee, 0xb2, 0xbc, 0xe1, 0x38, 0x46, 0xa5, 0x39, 0xd7,
2009 0x14, 0x33, 0x53, 0x38, 0xf7, 0xa0, 0x86, 0x28, 0xa4, 0x0d, 0x56, 0xef, 0x68, 0xe8, 0x1e, 0x0c,
2010 0x86, 0x7d, 0xda, 0x59, 0x21, 0xab, 0x60, 0x1e, 0x1f, 0xc9, 0xfc, 0x86, 0x40, 0xca, 0x1b, 0xeb,
2011 0x77, 0xc9, 0x0e, 0x34, 0xa2, 0x84, 0x0b, 0x2f, 0x09, 0x8a, 0x53, 0x33, 0x95, 0xd5, 0x86, 0x5e,
2012 0x2e, 0xe4, 0xdc, 0xf4, 0x18, 0x66, 0x0a, 0xe7, 0x08, 0x36, 0x7b, 0xd2, 0x2d, 0x9e, 0x2f, 0xf8,
2013 0xe3, 0x01, 0xff, 0x34, 0x60, 0xf3, 0x20, 0xcb, 0xe2, 0xcb, 0x41, 0xda, 0x93, 0x2f, 0xc2, 0x02,
2014 0xd1, 0x86, 0x55, 0x35, 0x02, 0xae, 0x01, 0x0b, 0x51, 0x76, 0xea, 0x7d, 0x1a, 0x4f, 0x34, 0x98,
2015 0x45, 0xb5, 0x74, 0xed, 0x70, 0x99, 0xd7, 0x0f, 0x57, 0x39, 0xcd, 0x2a, 0x66, 0x72, 0x43, 0x9a,
2016 0xb5, 0xab, 0x69, 0x1e, 0xc3, 0xd6, 0x7c, 0x96, 0x37, 0x74, 0xd2, 0x5c, 0xba, 0xf0, 0x01, 0x80,
2017 0x1b, 0x94, 0xca, 0x35, 0x45, 0x50, 0x10, 0x42, 0x5d, 0x31, 0x1b, 0x95, 0xaa, 0x65, 0xa8, 0xe0,
2018 0x57, 0x03, 0x2a, 0x6e, 0x40, 0xee, 0xe9, 0x8b, 0x48, 0x1d, 0xba, 0xa6, 0x02, 0xe9, 0xba, 0x97,
2019 0x19, 0xd3, 0xb7, 0xd2, 0xf4, 0xad, 0x59, 0xb9, 0xe1, 0xad, 0xa9, 0x5f, 0x0d, 0xe6, 0x82, 0x57,
2020 0xc3, 0x16, 0xd4, 0x90, 0x0f, 0x34, 0x09, 0x28, 0xc1, 0xd9, 0x83, 0xaa, 0xc4, 0x97, 0xbf, 0xff,
2021 0xb0, 0xef, 0xf6, 0x5f, 0x77, 0x56, 0xe4, 0x49, 0x7c, 0x7a, 0x30, 0x3c, 0xfc, 0x7e, 0x70, 0xe8,
2022 0xbe, 0xe8, 0x18, 0xfb, 0xbf, 0xd4, 0xa0, 0x89, 0x2d, 0x3b, 0xc4, 0xa7, 0xbe, 0xfc, 0x09, 0x4f,
2023 0x98, 0x70, 0x03, 0x4e, 0xd6, 0x54, 0x82, 0x45, 0x0b, 0x76, 0xb6, 0xbb, 0xea, 0xed, 0xdf, 0x2d,
2024 0xde, 0xfe, 0xdd, 0xbe, 0x7c, 0xfb, 0x3b, 0x2b, 0xe4, 0x4b, 0x68, 0x3e, 0x8b, 0x27, 0xfc, 0x5c,
2025 0x11, 0x3b, 0xd9, 0x98, 0x32, 0xf8, 0x12, 0xb1, 0x2f, 0x60, 0xe3, 0x84, 0x89, 0x79, 0x22, 0x26,
2026 0x77, 0x11, 0x61, 0x11, 0x39, 0xdf, 0x9a, 0x45, 0x5b, 0x66, 0x1e, 0x8d, 0xd9, 0xd1, 0x68, 0xc4,
2027 0x99, 0x20, 0xeb, 0x58, 0xc0, 0x8c, 0xde, 0x6e, 0x89, 0xfd, 0x0a, 0x36, 0x28, 0x0b, 0xd2, 0xf7,
2028 0x2c, 0xff, 0xb8, 0xf8, 0xaf, 0xa1, 0x3d, 0x25, 0xaa, 0x97, 0x51, 0x1c, 0x93, 0xad, 0x39, 0xee,
2029 0xfa, 0x67, 0x80, 0x6f, 0x4a, 0x74, 0xf8, 0x9c, 0x89, 0xe3, 0x28, 0xbc, 0x01, 0xe2, 0xce, 0x15,
2030 0xad, 0x3a, 0xe7, 0x88, 0xd0, 0x9e, 0x31, 0x49, 0x9a, 0x73, 0x72, 0x67, 0x21, 0xab, 0xed, 0x6c,
2031 0x5f, 0x55, 0x4f, 0x11, 0x0e, 0x61, 0xbd, 0xcc, 0x1d, 0x12, 0xe3, 0x3f, 0xb8, 0xdb, 0x75, 0x42,
2032 0xb9, 0xa5, 0x92, 0x1e, 0xb4, 0xca, 0x7f, 0xa2, 0x82, 0x58, 0xc0, 0x20, 0x3b, 0xf6, 0x75, 0x43,
2033 0x91, 0x8a, 0x5f, 0x47, 0xd8, 0xcf, 0xff, 0x0e, 0x00, 0x00, 0xff, 0xff, 0x00, 0x06, 0x71, 0x93,
2034 0x86, 0x0e, 0x00, 0x00,
2035 }
2036