Documentation

Index

Constants

This section is empty.

Variables

View Source
var ContainerAction_Action_name = map[int32]string{
	0: "KILL",
	1: "GETPID",
}
View Source
var ContainerAction_Action_value = map[string]int32{
	"KILL":   0,
	"GETPID": 1,
}
View Source
var ExecStressRequest_Scope_name = map[int32]string{
	0: "CONTAINER",
	1: "POD",
}
View Source
var ExecStressRequest_Scope_value = map[string]int32{
	"CONTAINER": 0,
	"POD":       1,
}
View Source
var Rule_Action_name = map[int32]string{
	0: "ADD",
	1: "DELETE",
}
View Source
var Rule_Action_value = map[string]int32{
	"ADD":    0,
	"DELETE": 1,
}
View Source
var Rule_Direction_name = map[int32]string{
	0: "INPUT",
	1: "OUTPUT",
}
View Source
var Rule_Direction_value = map[string]int32{
	"INPUT":  0,
	"OUTPUT": 1,
}

Functions

func RegisterChaosDaemonServer

func RegisterChaosDaemonServer(s *grpc.Server, srv ChaosDaemonServer)

Types

type CancelStressRequest

type CancelStressRequest struct {
	Instance             string   `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
	StartTime            int64    `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CancelStressRequest) Descriptor

func (*CancelStressRequest) Descriptor() ([]byte, []int)

func (*CancelStressRequest) GetInstance

func (m *CancelStressRequest) GetInstance() string

func (*CancelStressRequest) GetStartTime

func (m *CancelStressRequest) GetStartTime() int64

func (*CancelStressRequest) ProtoMessage

func (*CancelStressRequest) ProtoMessage()

func (*CancelStressRequest) Reset

func (m *CancelStressRequest) Reset()

func (*CancelStressRequest) String

func (m *CancelStressRequest) String() string

func (*CancelStressRequest) XXX_DiscardUnknown

func (m *CancelStressRequest) XXX_DiscardUnknown()

func (*CancelStressRequest) XXX_Marshal

func (m *CancelStressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CancelStressRequest) XXX_Merge

func (m *CancelStressRequest) XXX_Merge(src proto.Message)

func (*CancelStressRequest) XXX_Size

func (m *CancelStressRequest) XXX_Size() int

func (*CancelStressRequest) XXX_Unmarshal

func (m *CancelStressRequest) XXX_Unmarshal(b []byte) error

type ChaosDaemonClient

type ChaosDaemonClient interface {
	SetNetem(ctx context.Context, in *NetemRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	DeleteNetem(ctx context.Context, in *NetemRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	SetTbf(ctx context.Context, in *TbfRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	DeleteTbf(ctx context.Context, in *TbfRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	AddQdisc(ctx context.Context, in *QdiscRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	DelQdisc(ctx context.Context, in *QdiscRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	AddEmatchFilter(ctx context.Context, in *EmatchFilterRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// generic tc filter del command
	DelTcFilter(ctx context.Context, in *TcFilterRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	FlushIpSet(ctx context.Context, in *IpSetRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	FlushIptables(ctx context.Context, in *IpTablesRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	SetTimeOffset(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	RecoverTimeOffset(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ContainerKill(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ContainerGetPid(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*ContainerResponse, error)
	ExecStressors(ctx context.Context, in *ExecStressRequest, opts ...grpc.CallOption) (*ExecStressResponse, error)
	CancelStressors(ctx context.Context, in *CancelStressRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

    ChaosDaemonClient is the client API for ChaosDaemon service.

    For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

    func NewChaosDaemonClient

    func NewChaosDaemonClient(cc *grpc.ClientConn) ChaosDaemonClient

    type ChaosDaemonServer

    type ChaosDaemonServer interface {
    	SetNetem(context.Context, *NetemRequest) (*empty.Empty, error)
    	DeleteNetem(context.Context, *NetemRequest) (*empty.Empty, error)
    	SetTbf(context.Context, *TbfRequest) (*empty.Empty, error)
    	DeleteTbf(context.Context, *TbfRequest) (*empty.Empty, error)
    	AddQdisc(context.Context, *QdiscRequest) (*empty.Empty, error)
    	DelQdisc(context.Context, *QdiscRequest) (*empty.Empty, error)
    	AddEmatchFilter(context.Context, *EmatchFilterRequest) (*empty.Empty, error)
    	// generic tc filter del command
    	DelTcFilter(context.Context, *TcFilterRequest) (*empty.Empty, error)
    	FlushIpSet(context.Context, *IpSetRequest) (*empty.Empty, error)
    	FlushIptables(context.Context, *IpTablesRequest) (*empty.Empty, error)
    	SetTimeOffset(context.Context, *TimeRequest) (*empty.Empty, error)
    	RecoverTimeOffset(context.Context, *TimeRequest) (*empty.Empty, error)
    	ContainerKill(context.Context, *ContainerRequest) (*empty.Empty, error)
    	ContainerGetPid(context.Context, *ContainerRequest) (*ContainerResponse, error)
    	ExecStressors(context.Context, *ExecStressRequest) (*ExecStressResponse, error)
    	CancelStressors(context.Context, *CancelStressRequest) (*empty.Empty, error)
    }

      ChaosDaemonServer is the server API for ChaosDaemon service.

      type ContainerAction

      type ContainerAction struct {
      	Action               ContainerAction_Action `protobuf:"varint,1,opt,name=action,proto3,enum=chaosdaemon.ContainerAction_Action" json:"action,omitempty"`
      	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
      	XXX_unrecognized     []byte                 `json:"-"`
      	XXX_sizecache        int32                  `json:"-"`
      }

      func (*ContainerAction) Descriptor

      func (*ContainerAction) Descriptor() ([]byte, []int)

      func (*ContainerAction) GetAction

      func (m *ContainerAction) GetAction() ContainerAction_Action

      func (*ContainerAction) ProtoMessage

      func (*ContainerAction) ProtoMessage()

      func (*ContainerAction) Reset

      func (m *ContainerAction) Reset()

      func (*ContainerAction) String

      func (m *ContainerAction) String() string

      func (*ContainerAction) XXX_DiscardUnknown

      func (m *ContainerAction) XXX_DiscardUnknown()

      func (*ContainerAction) XXX_Marshal

      func (m *ContainerAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*ContainerAction) XXX_Merge

      func (m *ContainerAction) XXX_Merge(src proto.Message)

      func (*ContainerAction) XXX_Size

      func (m *ContainerAction) XXX_Size() int

      func (*ContainerAction) XXX_Unmarshal

      func (m *ContainerAction) XXX_Unmarshal(b []byte) error

      type ContainerAction_Action

      type ContainerAction_Action int32
      const (
      	ContainerAction_KILL   ContainerAction_Action = 0
      	ContainerAction_GETPID ContainerAction_Action = 1
      )

      func (ContainerAction_Action) EnumDescriptor

      func (ContainerAction_Action) EnumDescriptor() ([]byte, []int)

      func (ContainerAction_Action) String

      func (x ContainerAction_Action) String() string

      type ContainerRequest

      type ContainerRequest struct {
      	Action               *ContainerAction `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`
      	ContainerId          string           `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
      	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
      	XXX_unrecognized     []byte           `json:"-"`
      	XXX_sizecache        int32            `json:"-"`
      }

      func (*ContainerRequest) Descriptor

      func (*ContainerRequest) Descriptor() ([]byte, []int)

      func (*ContainerRequest) GetAction

      func (m *ContainerRequest) GetAction() *ContainerAction

      func (*ContainerRequest) GetContainerId

      func (m *ContainerRequest) GetContainerId() string

      func (*ContainerRequest) ProtoMessage

      func (*ContainerRequest) ProtoMessage()

      func (*ContainerRequest) Reset

      func (m *ContainerRequest) Reset()

      func (*ContainerRequest) String

      func (m *ContainerRequest) String() string

      func (*ContainerRequest) XXX_DiscardUnknown

      func (m *ContainerRequest) XXX_DiscardUnknown()

      func (*ContainerRequest) XXX_Marshal

      func (m *ContainerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*ContainerRequest) XXX_Merge

      func (m *ContainerRequest) XXX_Merge(src proto.Message)

      func (*ContainerRequest) XXX_Size

      func (m *ContainerRequest) XXX_Size() int

      func (*ContainerRequest) XXX_Unmarshal

      func (m *ContainerRequest) XXX_Unmarshal(b []byte) error

      type ContainerResponse

      type ContainerResponse struct {
      	Pid                  uint32   `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
      	XXX_unrecognized     []byte   `json:"-"`
      	XXX_sizecache        int32    `json:"-"`
      }

      func (*ContainerResponse) Descriptor

      func (*ContainerResponse) Descriptor() ([]byte, []int)

      func (*ContainerResponse) GetPid

      func (m *ContainerResponse) GetPid() uint32

      func (*ContainerResponse) ProtoMessage

      func (*ContainerResponse) ProtoMessage()

      func (*ContainerResponse) Reset

      func (m *ContainerResponse) Reset()

      func (*ContainerResponse) String

      func (m *ContainerResponse) String() string

      func (*ContainerResponse) XXX_DiscardUnknown

      func (m *ContainerResponse) XXX_DiscardUnknown()

      func (*ContainerResponse) XXX_Marshal

      func (m *ContainerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*ContainerResponse) XXX_Merge

      func (m *ContainerResponse) XXX_Merge(src proto.Message)

      func (*ContainerResponse) XXX_Size

      func (m *ContainerResponse) XXX_Size() int

      func (*ContainerResponse) XXX_Unmarshal

      func (m *ContainerResponse) XXX_Unmarshal(b []byte) error

      type EmatchFilter

      type EmatchFilter struct {
      	Match                string    `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
      	Parent               *TcHandle `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"`
      	Classid              *TcHandle `protobuf:"bytes,3,opt,name=classid,proto3" json:"classid,omitempty"`
      	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
      	XXX_unrecognized     []byte    `json:"-"`
      	XXX_sizecache        int32     `json:"-"`
      }

      func (*EmatchFilter) Descriptor

      func (*EmatchFilter) Descriptor() ([]byte, []int)

      func (*EmatchFilter) GetClassid

      func (m *EmatchFilter) GetClassid() *TcHandle

      func (*EmatchFilter) GetMatch

      func (m *EmatchFilter) GetMatch() string

      func (*EmatchFilter) GetParent

      func (m *EmatchFilter) GetParent() *TcHandle

      func (*EmatchFilter) ProtoMessage

      func (*EmatchFilter) ProtoMessage()

      func (*EmatchFilter) Reset

      func (m *EmatchFilter) Reset()

      func (*EmatchFilter) String

      func (m *EmatchFilter) String() string

      func (*EmatchFilter) XXX_DiscardUnknown

      func (m *EmatchFilter) XXX_DiscardUnknown()

      func (*EmatchFilter) XXX_Marshal

      func (m *EmatchFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*EmatchFilter) XXX_Merge

      func (m *EmatchFilter) XXX_Merge(src proto.Message)

      func (*EmatchFilter) XXX_Size

      func (m *EmatchFilter) XXX_Size() int

      func (*EmatchFilter) XXX_Unmarshal

      func (m *EmatchFilter) XXX_Unmarshal(b []byte) error

      type EmatchFilterRequest

      type EmatchFilterRequest struct {
      	Filter               *EmatchFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
      	ContainerId          string        `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
      	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
      	XXX_unrecognized     []byte        `json:"-"`
      	XXX_sizecache        int32         `json:"-"`
      }

      func (*EmatchFilterRequest) Descriptor

      func (*EmatchFilterRequest) Descriptor() ([]byte, []int)

      func (*EmatchFilterRequest) GetContainerId

      func (m *EmatchFilterRequest) GetContainerId() string

      func (*EmatchFilterRequest) GetFilter

      func (m *EmatchFilterRequest) GetFilter() *EmatchFilter

      func (*EmatchFilterRequest) ProtoMessage

      func (*EmatchFilterRequest) ProtoMessage()

      func (*EmatchFilterRequest) Reset

      func (m *EmatchFilterRequest) Reset()

      func (*EmatchFilterRequest) String

      func (m *EmatchFilterRequest) String() string

      func (*EmatchFilterRequest) XXX_DiscardUnknown

      func (m *EmatchFilterRequest) XXX_DiscardUnknown()

      func (*EmatchFilterRequest) XXX_Marshal

      func (m *EmatchFilterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*EmatchFilterRequest) XXX_Merge

      func (m *EmatchFilterRequest) XXX_Merge(src proto.Message)

      func (*EmatchFilterRequest) XXX_Size

      func (m *EmatchFilterRequest) XXX_Size() int

      func (*EmatchFilterRequest) XXX_Unmarshal

      func (m *EmatchFilterRequest) XXX_Unmarshal(b []byte) error

      type ExecStressRequest

      type ExecStressRequest struct {
      	Scope                ExecStressRequest_Scope `protobuf:"varint,1,opt,name=scope,proto3,enum=chaosdaemon.ExecStressRequest_Scope" json:"scope,omitempty"`
      	Target               string                  `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
      	Stressors            string                  `protobuf:"bytes,3,opt,name=stressors,proto3" json:"stressors,omitempty"`
      	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
      	XXX_unrecognized     []byte                  `json:"-"`
      	XXX_sizecache        int32                   `json:"-"`
      }

      func (*ExecStressRequest) Descriptor

      func (*ExecStressRequest) Descriptor() ([]byte, []int)

      func (*ExecStressRequest) GetScope

      func (*ExecStressRequest) GetStressors

      func (m *ExecStressRequest) GetStressors() string

      func (*ExecStressRequest) GetTarget

      func (m *ExecStressRequest) GetTarget() string

      func (*ExecStressRequest) ProtoMessage

      func (*ExecStressRequest) ProtoMessage()

      func (*ExecStressRequest) Reset

      func (m *ExecStressRequest) Reset()

      func (*ExecStressRequest) String

      func (m *ExecStressRequest) String() string

      func (*ExecStressRequest) XXX_DiscardUnknown

      func (m *ExecStressRequest) XXX_DiscardUnknown()

      func (*ExecStressRequest) XXX_Marshal

      func (m *ExecStressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*ExecStressRequest) XXX_Merge

      func (m *ExecStressRequest) XXX_Merge(src proto.Message)

      func (*ExecStressRequest) XXX_Size

      func (m *ExecStressRequest) XXX_Size() int

      func (*ExecStressRequest) XXX_Unmarshal

      func (m *ExecStressRequest) XXX_Unmarshal(b []byte) error

      type ExecStressRequest_Scope

      type ExecStressRequest_Scope int32
      const (
      	ExecStressRequest_CONTAINER ExecStressRequest_Scope = 0
      	ExecStressRequest_POD       ExecStressRequest_Scope = 1
      )

      func (ExecStressRequest_Scope) EnumDescriptor

      func (ExecStressRequest_Scope) EnumDescriptor() ([]byte, []int)

      func (ExecStressRequest_Scope) String

      func (x ExecStressRequest_Scope) String() string

      type ExecStressResponse

      type ExecStressResponse struct {
      	Instance             string   `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
      	StartTime            int64    `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
      	XXX_unrecognized     []byte   `json:"-"`
      	XXX_sizecache        int32    `json:"-"`
      }

      func (*ExecStressResponse) Descriptor

      func (*ExecStressResponse) Descriptor() ([]byte, []int)

      func (*ExecStressResponse) GetInstance

      func (m *ExecStressResponse) GetInstance() string

      func (*ExecStressResponse) GetStartTime

      func (m *ExecStressResponse) GetStartTime() int64

      func (*ExecStressResponse) ProtoMessage

      func (*ExecStressResponse) ProtoMessage()

      func (*ExecStressResponse) Reset

      func (m *ExecStressResponse) Reset()

      func (*ExecStressResponse) String

      func (m *ExecStressResponse) String() string

      func (*ExecStressResponse) XXX_DiscardUnknown

      func (m *ExecStressResponse) XXX_DiscardUnknown()

      func (*ExecStressResponse) XXX_Marshal

      func (m *ExecStressResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*ExecStressResponse) XXX_Merge

      func (m *ExecStressResponse) XXX_Merge(src proto.Message)

      func (*ExecStressResponse) XXX_Size

      func (m *ExecStressResponse) XXX_Size() int

      func (*ExecStressResponse) XXX_Unmarshal

      func (m *ExecStressResponse) XXX_Unmarshal(b []byte) error

      type IpSet

      type IpSet struct {
      	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
      	Ips                  []string `protobuf:"bytes,2,rep,name=ips,proto3" json:"ips,omitempty"`
      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
      	XXX_unrecognized     []byte   `json:"-"`
      	XXX_sizecache        int32    `json:"-"`
      }

      func (*IpSet) Descriptor

      func (*IpSet) Descriptor() ([]byte, []int)

      func (*IpSet) GetIps

      func (m *IpSet) GetIps() []string

      func (*IpSet) GetName

      func (m *IpSet) GetName() string

      func (*IpSet) ProtoMessage

      func (*IpSet) ProtoMessage()

      func (*IpSet) Reset

      func (m *IpSet) Reset()

      func (*IpSet) String

      func (m *IpSet) String() string

      func (*IpSet) XXX_DiscardUnknown

      func (m *IpSet) XXX_DiscardUnknown()

      func (*IpSet) XXX_Marshal

      func (m *IpSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*IpSet) XXX_Merge

      func (m *IpSet) XXX_Merge(src proto.Message)

      func (*IpSet) XXX_Size

      func (m *IpSet) XXX_Size() int

      func (*IpSet) XXX_Unmarshal

      func (m *IpSet) XXX_Unmarshal(b []byte) error

      type IpSetRequest

      type IpSetRequest struct {
      	Ipset                *IpSet   `protobuf:"bytes,1,opt,name=ipset,proto3" json:"ipset,omitempty"`
      	ContainerId          string   `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
      	XXX_unrecognized     []byte   `json:"-"`
      	XXX_sizecache        int32    `json:"-"`
      }

      func (*IpSetRequest) Descriptor

      func (*IpSetRequest) Descriptor() ([]byte, []int)

      func (*IpSetRequest) GetContainerId

      func (m *IpSetRequest) GetContainerId() string

      func (*IpSetRequest) GetIpset

      func (m *IpSetRequest) GetIpset() *IpSet

      func (*IpSetRequest) ProtoMessage

      func (*IpSetRequest) ProtoMessage()

      func (*IpSetRequest) Reset

      func (m *IpSetRequest) Reset()

      func (*IpSetRequest) String

      func (m *IpSetRequest) String() string

      func (*IpSetRequest) XXX_DiscardUnknown

      func (m *IpSetRequest) XXX_DiscardUnknown()

      func (*IpSetRequest) XXX_Marshal

      func (m *IpSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*IpSetRequest) XXX_Merge

      func (m *IpSetRequest) XXX_Merge(src proto.Message)

      func (*IpSetRequest) XXX_Size

      func (m *IpSetRequest) XXX_Size() int

      func (*IpSetRequest) XXX_Unmarshal

      func (m *IpSetRequest) XXX_Unmarshal(b []byte) error

      type IpTablesRequest

      type IpTablesRequest struct {
      	Rule                 *Rule    `protobuf:"bytes,1,opt,name=rule,proto3" json:"rule,omitempty"`
      	ContainerId          string   `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
      	XXX_unrecognized     []byte   `json:"-"`
      	XXX_sizecache        int32    `json:"-"`
      }

      func (*IpTablesRequest) Descriptor

      func (*IpTablesRequest) Descriptor() ([]byte, []int)

      func (*IpTablesRequest) GetContainerId

      func (m *IpTablesRequest) GetContainerId() string

      func (*IpTablesRequest) GetRule

      func (m *IpTablesRequest) GetRule() *Rule

      func (*IpTablesRequest) ProtoMessage

      func (*IpTablesRequest) ProtoMessage()

      func (*IpTablesRequest) Reset

      func (m *IpTablesRequest) Reset()

      func (*IpTablesRequest) String

      func (m *IpTablesRequest) String() string

      func (*IpTablesRequest) XXX_DiscardUnknown

      func (m *IpTablesRequest) XXX_DiscardUnknown()

      func (*IpTablesRequest) XXX_Marshal

      func (m *IpTablesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*IpTablesRequest) XXX_Merge

      func (m *IpTablesRequest) XXX_Merge(src proto.Message)

      func (*IpTablesRequest) XXX_Size

      func (m *IpTablesRequest) XXX_Size() int

      func (*IpTablesRequest) XXX_Unmarshal

      func (m *IpTablesRequest) XXX_Unmarshal(b []byte) error

      type Netem

      type Netem struct {
      	Time                 uint32    `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
      	Jitter               uint32    `protobuf:"varint,2,opt,name=jitter,proto3" json:"jitter,omitempty"`
      	DelayCorr            float32   `protobuf:"fixed32,3,opt,name=delay_corr,json=delayCorr,proto3" json:"delay_corr,omitempty"`
      	Limit                uint32    `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
      	Loss                 float32   `protobuf:"fixed32,5,opt,name=loss,proto3" json:"loss,omitempty"`
      	LossCorr             float32   `protobuf:"fixed32,6,opt,name=loss_corr,json=lossCorr,proto3" json:"loss_corr,omitempty"`
      	Gap                  uint32    `protobuf:"varint,7,opt,name=gap,proto3" json:"gap,omitempty"`
      	Duplicate            float32   `protobuf:"fixed32,8,opt,name=duplicate,proto3" json:"duplicate,omitempty"`
      	DuplicateCorr        float32   `protobuf:"fixed32,9,opt,name=duplicate_corr,json=duplicateCorr,proto3" json:"duplicate_corr,omitempty"`
      	Reorder              float32   `protobuf:"fixed32,10,opt,name=reorder,proto3" json:"reorder,omitempty"`
      	ReorderCorr          float32   `protobuf:"fixed32,11,opt,name=reorder_corr,json=reorderCorr,proto3" json:"reorder_corr,omitempty"`
      	Corrupt              float32   `protobuf:"fixed32,12,opt,name=corrupt,proto3" json:"corrupt,omitempty"`
      	CorruptCorr          float32   `protobuf:"fixed32,13,opt,name=corrupt_corr,json=corruptCorr,proto3" json:"corrupt_corr,omitempty"`
      	Parent               *TcHandle `protobuf:"bytes,14,opt,name=parent,proto3" json:"parent,omitempty"`
      	Handle               *TcHandle `protobuf:"bytes,15,opt,name=handle,proto3" json:"handle,omitempty"`
      	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
      	XXX_unrecognized     []byte    `json:"-"`
      	XXX_sizecache        int32     `json:"-"`
      }

      func (*Netem) Descriptor

      func (*Netem) Descriptor() ([]byte, []int)

      func (*Netem) GetCorrupt

      func (m *Netem) GetCorrupt() float32

      func (*Netem) GetCorruptCorr

      func (m *Netem) GetCorruptCorr() float32

      func (*Netem) GetDelayCorr

      func (m *Netem) GetDelayCorr() float32

      func (*Netem) GetDuplicate

      func (m *Netem) GetDuplicate() float32

      func (*Netem) GetDuplicateCorr

      func (m *Netem) GetDuplicateCorr() float32

      func (*Netem) GetGap

      func (m *Netem) GetGap() uint32

      func (*Netem) GetHandle

      func (m *Netem) GetHandle() *TcHandle

      func (*Netem) GetJitter

      func (m *Netem) GetJitter() uint32

      func (*Netem) GetLimit

      func (m *Netem) GetLimit() uint32

      func (*Netem) GetLoss

      func (m *Netem) GetLoss() float32

      func (*Netem) GetLossCorr

      func (m *Netem) GetLossCorr() float32

      func (*Netem) GetParent

      func (m *Netem) GetParent() *TcHandle

      func (*Netem) GetReorder

      func (m *Netem) GetReorder() float32

      func (*Netem) GetReorderCorr

      func (m *Netem) GetReorderCorr() float32

      func (*Netem) GetTime

      func (m *Netem) GetTime() uint32

      func (*Netem) ProtoMessage

      func (*Netem) ProtoMessage()

      func (*Netem) Reset

      func (m *Netem) Reset()

      func (*Netem) String

      func (m *Netem) String() string

      func (*Netem) XXX_DiscardUnknown

      func (m *Netem) XXX_DiscardUnknown()

      func (*Netem) XXX_Marshal

      func (m *Netem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*Netem) XXX_Merge

      func (m *Netem) XXX_Merge(src proto.Message)

      func (*Netem) XXX_Size

      func (m *Netem) XXX_Size() int

      func (*Netem) XXX_Unmarshal

      func (m *Netem) XXX_Unmarshal(b []byte) error

      type NetemRequest

      type NetemRequest struct {
      	Netem                *Netem    `protobuf:"bytes,1,opt,name=netem,proto3" json:"netem,omitempty"`
      	ContainerId          string    `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
      	Handle               *TcHandle `protobuf:"bytes,3,opt,name=handle,proto3" json:"handle,omitempty"`
      	Parent               *TcHandle `protobuf:"bytes,4,opt,name=parent,proto3" json:"parent,omitempty"`
      	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
      	XXX_unrecognized     []byte    `json:"-"`
      	XXX_sizecache        int32     `json:"-"`
      }

      func (*NetemRequest) Descriptor

      func (*NetemRequest) Descriptor() ([]byte, []int)

      func (*NetemRequest) GetContainerId

      func (m *NetemRequest) GetContainerId() string

      func (*NetemRequest) GetHandle

      func (m *NetemRequest) GetHandle() *TcHandle

      func (*NetemRequest) GetNetem

      func (m *NetemRequest) GetNetem() *Netem

      func (*NetemRequest) GetParent

      func (m *NetemRequest) GetParent() *TcHandle

      func (*NetemRequest) ProtoMessage

      func (*NetemRequest) ProtoMessage()

      func (*NetemRequest) Reset

      func (m *NetemRequest) Reset()

      func (*NetemRequest) String

      func (m *NetemRequest) String() string

      func (*NetemRequest) XXX_DiscardUnknown

      func (m *NetemRequest) XXX_DiscardUnknown()

      func (*NetemRequest) XXX_Marshal

      func (m *NetemRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*NetemRequest) XXX_Merge

      func (m *NetemRequest) XXX_Merge(src proto.Message)

      func (*NetemRequest) XXX_Size

      func (m *NetemRequest) XXX_Size() int

      func (*NetemRequest) XXX_Unmarshal

      func (m *NetemRequest) XXX_Unmarshal(b []byte) error

      type Qdisc

      type Qdisc struct {
      	Parent               *TcHandle `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
      	Handle               *TcHandle `protobuf:"bytes,2,opt,name=handle,proto3" json:"handle,omitempty"`
      	Type                 string    `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
      	Args                 []string  `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
      	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
      	XXX_unrecognized     []byte    `json:"-"`
      	XXX_sizecache        int32     `json:"-"`
      }

      func (*Qdisc) Descriptor

      func (*Qdisc) Descriptor() ([]byte, []int)

      func (*Qdisc) GetArgs

      func (m *Qdisc) GetArgs() []string

      func (*Qdisc) GetHandle

      func (m *Qdisc) GetHandle() *TcHandle

      func (*Qdisc) GetParent

      func (m *Qdisc) GetParent() *TcHandle

      func (*Qdisc) GetType

      func (m *Qdisc) GetType() string

      func (*Qdisc) ProtoMessage

      func (*Qdisc) ProtoMessage()

      func (*Qdisc) Reset

      func (m *Qdisc) Reset()

      func (*Qdisc) String

      func (m *Qdisc) String() string

      func (*Qdisc) XXX_DiscardUnknown

      func (m *Qdisc) XXX_DiscardUnknown()

      func (*Qdisc) XXX_Marshal

      func (m *Qdisc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*Qdisc) XXX_Merge

      func (m *Qdisc) XXX_Merge(src proto.Message)

      func (*Qdisc) XXX_Size

      func (m *Qdisc) XXX_Size() int

      func (*Qdisc) XXX_Unmarshal

      func (m *Qdisc) XXX_Unmarshal(b []byte) error

      type QdiscRequest

      type QdiscRequest struct {
      	Qdisc                *Qdisc   `protobuf:"bytes,1,opt,name=qdisc,proto3" json:"qdisc,omitempty"`
      	ContainerId          string   `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
      	XXX_unrecognized     []byte   `json:"-"`
      	XXX_sizecache        int32    `json:"-"`
      }

      func (*QdiscRequest) Descriptor

      func (*QdiscRequest) Descriptor() ([]byte, []int)

      func (*QdiscRequest) GetContainerId

      func (m *QdiscRequest) GetContainerId() string

      func (*QdiscRequest) GetQdisc

      func (m *QdiscRequest) GetQdisc() *Qdisc

      func (*QdiscRequest) ProtoMessage

      func (*QdiscRequest) ProtoMessage()

      func (*QdiscRequest) Reset

      func (m *QdiscRequest) Reset()

      func (*QdiscRequest) String

      func (m *QdiscRequest) String() string

      func (*QdiscRequest) XXX_DiscardUnknown

      func (m *QdiscRequest) XXX_DiscardUnknown()

      func (*QdiscRequest) XXX_Marshal

      func (m *QdiscRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*QdiscRequest) XXX_Merge

      func (m *QdiscRequest) XXX_Merge(src proto.Message)

      func (*QdiscRequest) XXX_Size

      func (m *QdiscRequest) XXX_Size() int

      func (*QdiscRequest) XXX_Unmarshal

      func (m *QdiscRequest) XXX_Unmarshal(b []byte) error

      type Rule

      type Rule struct {
      	Action               Rule_Action    `protobuf:"varint,1,opt,name=action,proto3,enum=chaosdaemon.Rule_Action" json:"action,omitempty"`
      	Direction            Rule_Direction `protobuf:"varint,2,opt,name=direction,proto3,enum=chaosdaemon.Rule_Direction" json:"direction,omitempty"`
      	Set                  string         `protobuf:"bytes,3,opt,name=set,proto3" json:"set,omitempty"`
      	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
      	XXX_unrecognized     []byte         `json:"-"`
      	XXX_sizecache        int32          `json:"-"`
      }

      func (*Rule) Descriptor

      func (*Rule) Descriptor() ([]byte, []int)

      func (*Rule) GetAction

      func (m *Rule) GetAction() Rule_Action

      func (*Rule) GetDirection

      func (m *Rule) GetDirection() Rule_Direction

      func (*Rule) GetSet

      func (m *Rule) GetSet() string

      func (*Rule) ProtoMessage

      func (*Rule) ProtoMessage()

      func (*Rule) Reset

      func (m *Rule) Reset()

      func (*Rule) String

      func (m *Rule) String() string

      func (*Rule) XXX_DiscardUnknown

      func (m *Rule) XXX_DiscardUnknown()

      func (*Rule) XXX_Marshal

      func (m *Rule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*Rule) XXX_Merge

      func (m *Rule) XXX_Merge(src proto.Message)

      func (*Rule) XXX_Size

      func (m *Rule) XXX_Size() int

      func (*Rule) XXX_Unmarshal

      func (m *Rule) XXX_Unmarshal(b []byte) error

      type Rule_Action

      type Rule_Action int32
      const (
      	Rule_ADD    Rule_Action = 0
      	Rule_DELETE Rule_Action = 1
      )

      func (Rule_Action) EnumDescriptor

      func (Rule_Action) EnumDescriptor() ([]byte, []int)

      func (Rule_Action) String

      func (x Rule_Action) String() string

      type Rule_Direction

      type Rule_Direction int32
      const (
      	Rule_INPUT  Rule_Direction = 0
      	Rule_OUTPUT Rule_Direction = 1
      )

      func (Rule_Direction) EnumDescriptor

      func (Rule_Direction) EnumDescriptor() ([]byte, []int)

      func (Rule_Direction) String

      func (x Rule_Direction) String() string

      type Tbf

      type Tbf struct {
      	Rate                 uint64   `protobuf:"varint,1,opt,name=rate,proto3" json:"rate,omitempty"`
      	Limit                uint32   `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
      	Buffer               uint32   `protobuf:"varint,3,opt,name=buffer,proto3" json:"buffer,omitempty"`
      	PeakRate             uint64   `protobuf:"varint,4,opt,name=peak_rate,json=peakRate,proto3" json:"peak_rate,omitempty"`
      	MinBurst             uint32   `protobuf:"varint,5,opt,name=min_burst,json=minBurst,proto3" json:"min_burst,omitempty"`
      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
      	XXX_unrecognized     []byte   `json:"-"`
      	XXX_sizecache        int32    `json:"-"`
      }

      func (*Tbf) Descriptor

      func (*Tbf) Descriptor() ([]byte, []int)

      func (*Tbf) GetBuffer

      func (m *Tbf) GetBuffer() uint32

      func (*Tbf) GetLimit

      func (m *Tbf) GetLimit() uint32

      func (*Tbf) GetMinBurst

      func (m *Tbf) GetMinBurst() uint32

      func (*Tbf) GetPeakRate

      func (m *Tbf) GetPeakRate() uint64

      func (*Tbf) GetRate

      func (m *Tbf) GetRate() uint64

      func (*Tbf) ProtoMessage

      func (*Tbf) ProtoMessage()

      func (*Tbf) Reset

      func (m *Tbf) Reset()

      func (*Tbf) String

      func (m *Tbf) String() string

      func (*Tbf) XXX_DiscardUnknown

      func (m *Tbf) XXX_DiscardUnknown()

      func (*Tbf) XXX_Marshal

      func (m *Tbf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*Tbf) XXX_Merge

      func (m *Tbf) XXX_Merge(src proto.Message)

      func (*Tbf) XXX_Size

      func (m *Tbf) XXX_Size() int

      func (*Tbf) XXX_Unmarshal

      func (m *Tbf) XXX_Unmarshal(b []byte) error

      type TbfRequest

      type TbfRequest struct {
      	Tbf                  *Tbf     `protobuf:"bytes,1,opt,name=tbf,proto3" json:"tbf,omitempty"`
      	ContainerId          string   `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
      	XXX_unrecognized     []byte   `json:"-"`
      	XXX_sizecache        int32    `json:"-"`
      }

      func (*TbfRequest) Descriptor

      func (*TbfRequest) Descriptor() ([]byte, []int)

      func (*TbfRequest) GetContainerId

      func (m *TbfRequest) GetContainerId() string

      func (*TbfRequest) GetTbf

      func (m *TbfRequest) GetTbf() *Tbf

      func (*TbfRequest) ProtoMessage

      func (*TbfRequest) ProtoMessage()

      func (*TbfRequest) Reset

      func (m *TbfRequest) Reset()

      func (*TbfRequest) String

      func (m *TbfRequest) String() string

      func (*TbfRequest) XXX_DiscardUnknown

      func (m *TbfRequest) XXX_DiscardUnknown()

      func (*TbfRequest) XXX_Marshal

      func (m *TbfRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*TbfRequest) XXX_Merge

      func (m *TbfRequest) XXX_Merge(src proto.Message)

      func (*TbfRequest) XXX_Size

      func (m *TbfRequest) XXX_Size() int

      func (*TbfRequest) XXX_Unmarshal

      func (m *TbfRequest) XXX_Unmarshal(b []byte) error

      type TcFilter

      type TcFilter struct {
      	Parent               *TcHandle `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
      	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
      	XXX_unrecognized     []byte    `json:"-"`
      	XXX_sizecache        int32     `json:"-"`
      }

      func (*TcFilter) Descriptor

      func (*TcFilter) Descriptor() ([]byte, []int)

      func (*TcFilter) GetParent

      func (m *TcFilter) GetParent() *TcHandle

      func (*TcFilter) ProtoMessage

      func (*TcFilter) ProtoMessage()

      func (*TcFilter) Reset

      func (m *TcFilter) Reset()

      func (*TcFilter) String

      func (m *TcFilter) String() string

      func (*TcFilter) XXX_DiscardUnknown

      func (m *TcFilter) XXX_DiscardUnknown()

      func (*TcFilter) XXX_Marshal

      func (m *TcFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*TcFilter) XXX_Merge

      func (m *TcFilter) XXX_Merge(src proto.Message)

      func (*TcFilter) XXX_Size

      func (m *TcFilter) XXX_Size() int

      func (*TcFilter) XXX_Unmarshal

      func (m *TcFilter) XXX_Unmarshal(b []byte) error

      type TcFilterRequest

      type TcFilterRequest struct {
      	Filter               *TcFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
      	ContainerId          string    `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
      	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
      	XXX_unrecognized     []byte    `json:"-"`
      	XXX_sizecache        int32     `json:"-"`
      }

      func (*TcFilterRequest) Descriptor

      func (*TcFilterRequest) Descriptor() ([]byte, []int)

      func (*TcFilterRequest) GetContainerId

      func (m *TcFilterRequest) GetContainerId() string

      func (*TcFilterRequest) GetFilter

      func (m *TcFilterRequest) GetFilter() *TcFilter

      func (*TcFilterRequest) ProtoMessage

      func (*TcFilterRequest) ProtoMessage()

      func (*TcFilterRequest) Reset

      func (m *TcFilterRequest) Reset()

      func (*TcFilterRequest) String

      func (m *TcFilterRequest) String() string

      func (*TcFilterRequest) XXX_DiscardUnknown

      func (m *TcFilterRequest) XXX_DiscardUnknown()

      func (*TcFilterRequest) XXX_Marshal

      func (m *TcFilterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*TcFilterRequest) XXX_Merge

      func (m *TcFilterRequest) XXX_Merge(src proto.Message)

      func (*TcFilterRequest) XXX_Size

      func (m *TcFilterRequest) XXX_Size() int

      func (*TcFilterRequest) XXX_Unmarshal

      func (m *TcFilterRequest) XXX_Unmarshal(b []byte) error

      type TcHandle

      type TcHandle struct {
      	Major                uint32   `protobuf:"varint,1,opt,name=major,proto3" json:"major,omitempty"`
      	Minor                uint32   `protobuf:"varint,2,opt,name=minor,proto3" json:"minor,omitempty"`
      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
      	XXX_unrecognized     []byte   `json:"-"`
      	XXX_sizecache        int32    `json:"-"`
      }

      func (*TcHandle) Descriptor

      func (*TcHandle) Descriptor() ([]byte, []int)

      func (*TcHandle) GetMajor

      func (m *TcHandle) GetMajor() uint32

      func (*TcHandle) GetMinor

      func (m *TcHandle) GetMinor() uint32

      func (*TcHandle) ProtoMessage

      func (*TcHandle) ProtoMessage()

      func (*TcHandle) Reset

      func (m *TcHandle) Reset()

      func (*TcHandle) String

      func (m *TcHandle) String() string

      func (*TcHandle) XXX_DiscardUnknown

      func (m *TcHandle) XXX_DiscardUnknown()

      func (*TcHandle) XXX_Marshal

      func (m *TcHandle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*TcHandle) XXX_Merge

      func (m *TcHandle) XXX_Merge(src proto.Message)

      func (*TcHandle) XXX_Size

      func (m *TcHandle) XXX_Size() int

      func (*TcHandle) XXX_Unmarshal

      func (m *TcHandle) XXX_Unmarshal(b []byte) error

      type TimeRequest

      type TimeRequest struct {
      	ContainerId          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
      	Sec                  int64    `protobuf:"varint,2,opt,name=sec,proto3" json:"sec,omitempty"`
      	Nsec                 int64    `protobuf:"varint,3,opt,name=nsec,proto3" json:"nsec,omitempty"`
      	ClkIdsMask           uint64   `protobuf:"varint,4,opt,name=clk_ids_mask,json=clkIdsMask,proto3" json:"clk_ids_mask,omitempty"`
      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
      	XXX_unrecognized     []byte   `json:"-"`
      	XXX_sizecache        int32    `json:"-"`
      }

      func (*TimeRequest) Descriptor

      func (*TimeRequest) Descriptor() ([]byte, []int)

      func (*TimeRequest) GetClkIdsMask

      func (m *TimeRequest) GetClkIdsMask() uint64

      func (*TimeRequest) GetContainerId

      func (m *TimeRequest) GetContainerId() string

      func (*TimeRequest) GetNsec

      func (m *TimeRequest) GetNsec() int64

      func (*TimeRequest) GetSec

      func (m *TimeRequest) GetSec() int64

      func (*TimeRequest) ProtoMessage

      func (*TimeRequest) ProtoMessage()

      func (*TimeRequest) Reset

      func (m *TimeRequest) Reset()

      func (*TimeRequest) String

      func (m *TimeRequest) String() string

      func (*TimeRequest) XXX_DiscardUnknown

      func (m *TimeRequest) XXX_DiscardUnknown()

      func (*TimeRequest) XXX_Marshal

      func (m *TimeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*TimeRequest) XXX_Merge

      func (m *TimeRequest) XXX_Merge(src proto.Message)

      func (*TimeRequest) XXX_Size

      func (m *TimeRequest) XXX_Size() int

      func (*TimeRequest) XXX_Unmarshal

      func (m *TimeRequest) XXX_Unmarshal(b []byte) error