Versions in this module Expand all Collapse all v0 v0.8.0 Apr 26, 2020 Changes in this version + var ContainerAction_Action_name = map[int32]string + var ContainerAction_Action_value = map[string]int32 + var ExecStressRequest_Scope_name = map[int32]string + var ExecStressRequest_Scope_value = map[string]int32 + var Rule_Action_name = map[int32]string + var Rule_Action_value = map[string]int32 + var Rule_Direction_name = map[int32]string + var Rule_Direction_value = map[string]int32 + func RegisterChaosDaemonServer(s *grpc.Server, srv ChaosDaemonServer) + type CancelStressRequest struct + Instance string + StartTime int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CancelStressRequest) Descriptor() ([]byte, []int) + func (*CancelStressRequest) ProtoMessage() + func (m *CancelStressRequest) GetInstance() string + func (m *CancelStressRequest) GetStartTime() int64 + func (m *CancelStressRequest) Reset() + func (m *CancelStressRequest) String() string + func (m *CancelStressRequest) XXX_DiscardUnknown() + func (m *CancelStressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CancelStressRequest) XXX_Merge(src proto.Message) + func (m *CancelStressRequest) XXX_Size() int + func (m *CancelStressRequest) XXX_Unmarshal(b []byte) error + type ChaosDaemonClient interface + AddEmatchFilter func(ctx context.Context, in *EmatchFilterRequest, opts ...grpc.CallOption) (*empty.Empty, error) + AddQdisc func(ctx context.Context, in *QdiscRequest, opts ...grpc.CallOption) (*empty.Empty, error) + CancelStressors func(ctx context.Context, in *CancelStressRequest, opts ...grpc.CallOption) (*empty.Empty, error) + ContainerGetPid func(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*ContainerResponse, error) + ContainerKill func(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*empty.Empty, error) + DelQdisc func(ctx context.Context, in *QdiscRequest, opts ...grpc.CallOption) (*empty.Empty, error) + DelTcFilter func(ctx context.Context, in *TcFilterRequest, opts ...grpc.CallOption) (*empty.Empty, error) + DeleteNetem func(ctx context.Context, in *NetemRequest, opts ...grpc.CallOption) (*empty.Empty, error) + DeleteTbf func(ctx context.Context, in *TbfRequest, opts ...grpc.CallOption) (*empty.Empty, error) + ExecStressors func(ctx context.Context, in *ExecStressRequest, opts ...grpc.CallOption) (*ExecStressResponse, error) + FlushIpSet func(ctx context.Context, in *IpSetRequest, opts ...grpc.CallOption) (*empty.Empty, error) + FlushIptables func(ctx context.Context, in *IpTablesRequest, opts ...grpc.CallOption) (*empty.Empty, error) + RecoverTimeOffset func(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error) + SetNetem func(ctx context.Context, in *NetemRequest, opts ...grpc.CallOption) (*empty.Empty, error) + SetTbf func(ctx context.Context, in *TbfRequest, opts ...grpc.CallOption) (*empty.Empty, error) + SetTimeOffset func(ctx context.Context, in *TimeRequest, opts ...grpc.CallOption) (*empty.Empty, error) + func NewChaosDaemonClient(cc *grpc.ClientConn) ChaosDaemonClient + type ChaosDaemonServer interface + AddEmatchFilter func(context.Context, *EmatchFilterRequest) (*empty.Empty, error) + AddQdisc func(context.Context, *QdiscRequest) (*empty.Empty, error) + CancelStressors func(context.Context, *CancelStressRequest) (*empty.Empty, error) + ContainerGetPid func(context.Context, *ContainerRequest) (*ContainerResponse, error) + ContainerKill func(context.Context, *ContainerRequest) (*empty.Empty, error) + DelQdisc func(context.Context, *QdiscRequest) (*empty.Empty, error) + DelTcFilter func(context.Context, *TcFilterRequest) (*empty.Empty, error) + DeleteNetem func(context.Context, *NetemRequest) (*empty.Empty, error) + DeleteTbf func(context.Context, *TbfRequest) (*empty.Empty, error) + ExecStressors func(context.Context, *ExecStressRequest) (*ExecStressResponse, error) + FlushIpSet func(context.Context, *IpSetRequest) (*empty.Empty, error) + FlushIptables func(context.Context, *IpTablesRequest) (*empty.Empty, error) + RecoverTimeOffset func(context.Context, *TimeRequest) (*empty.Empty, error) + SetNetem func(context.Context, *NetemRequest) (*empty.Empty, error) + SetTbf func(context.Context, *TbfRequest) (*empty.Empty, error) + SetTimeOffset func(context.Context, *TimeRequest) (*empty.Empty, error) + type ContainerAction struct + Action ContainerAction_Action + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ContainerAction) Descriptor() ([]byte, []int) + func (*ContainerAction) ProtoMessage() + func (m *ContainerAction) GetAction() ContainerAction_Action + func (m *ContainerAction) Reset() + func (m *ContainerAction) String() string + func (m *ContainerAction) XXX_DiscardUnknown() + func (m *ContainerAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ContainerAction) XXX_Merge(src proto.Message) + func (m *ContainerAction) XXX_Size() int + func (m *ContainerAction) XXX_Unmarshal(b []byte) error + type ContainerAction_Action int32 + const ContainerAction_GETPID + const ContainerAction_KILL + func (ContainerAction_Action) EnumDescriptor() ([]byte, []int) + func (x ContainerAction_Action) String() string + type ContainerRequest struct + Action *ContainerAction + ContainerId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ContainerRequest) Descriptor() ([]byte, []int) + func (*ContainerRequest) ProtoMessage() + func (m *ContainerRequest) GetAction() *ContainerAction + func (m *ContainerRequest) GetContainerId() string + func (m *ContainerRequest) Reset() + func (m *ContainerRequest) String() string + func (m *ContainerRequest) XXX_DiscardUnknown() + func (m *ContainerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ContainerRequest) XXX_Merge(src proto.Message) + func (m *ContainerRequest) XXX_Size() int + func (m *ContainerRequest) XXX_Unmarshal(b []byte) error + type ContainerResponse struct + Pid uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ContainerResponse) Descriptor() ([]byte, []int) + func (*ContainerResponse) ProtoMessage() + func (m *ContainerResponse) GetPid() uint32 + func (m *ContainerResponse) Reset() + func (m *ContainerResponse) String() string + func (m *ContainerResponse) XXX_DiscardUnknown() + func (m *ContainerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ContainerResponse) XXX_Merge(src proto.Message) + func (m *ContainerResponse) XXX_Size() int + func (m *ContainerResponse) XXX_Unmarshal(b []byte) error + type EmatchFilter struct + Classid *TcHandle + Match string + Parent *TcHandle + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EmatchFilter) Descriptor() ([]byte, []int) + func (*EmatchFilter) ProtoMessage() + func (m *EmatchFilter) GetClassid() *TcHandle + func (m *EmatchFilter) GetMatch() string + func (m *EmatchFilter) GetParent() *TcHandle + func (m *EmatchFilter) Reset() + func (m *EmatchFilter) String() string + func (m *EmatchFilter) XXX_DiscardUnknown() + func (m *EmatchFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EmatchFilter) XXX_Merge(src proto.Message) + func (m *EmatchFilter) XXX_Size() int + func (m *EmatchFilter) XXX_Unmarshal(b []byte) error + type EmatchFilterRequest struct + ContainerId string + Filter *EmatchFilter + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EmatchFilterRequest) Descriptor() ([]byte, []int) + func (*EmatchFilterRequest) ProtoMessage() + func (m *EmatchFilterRequest) GetContainerId() string + func (m *EmatchFilterRequest) GetFilter() *EmatchFilter + func (m *EmatchFilterRequest) Reset() + func (m *EmatchFilterRequest) String() string + func (m *EmatchFilterRequest) XXX_DiscardUnknown() + func (m *EmatchFilterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EmatchFilterRequest) XXX_Merge(src proto.Message) + func (m *EmatchFilterRequest) XXX_Size() int + func (m *EmatchFilterRequest) XXX_Unmarshal(b []byte) error + type ExecStressRequest struct + Scope ExecStressRequest_Scope + Stressors string + Target string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExecStressRequest) Descriptor() ([]byte, []int) + func (*ExecStressRequest) ProtoMessage() + func (m *ExecStressRequest) GetScope() ExecStressRequest_Scope + func (m *ExecStressRequest) GetStressors() string + func (m *ExecStressRequest) GetTarget() string + func (m *ExecStressRequest) Reset() + func (m *ExecStressRequest) String() string + func (m *ExecStressRequest) XXX_DiscardUnknown() + func (m *ExecStressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExecStressRequest) XXX_Merge(src proto.Message) + func (m *ExecStressRequest) XXX_Size() int + func (m *ExecStressRequest) XXX_Unmarshal(b []byte) error + type ExecStressRequest_Scope int32 + const ExecStressRequest_CONTAINER + const ExecStressRequest_POD + func (ExecStressRequest_Scope) EnumDescriptor() ([]byte, []int) + func (x ExecStressRequest_Scope) String() string + type ExecStressResponse struct + Instance string + StartTime int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExecStressResponse) Descriptor() ([]byte, []int) + func (*ExecStressResponse) ProtoMessage() + func (m *ExecStressResponse) GetInstance() string + func (m *ExecStressResponse) GetStartTime() int64 + func (m *ExecStressResponse) Reset() + func (m *ExecStressResponse) String() string + func (m *ExecStressResponse) XXX_DiscardUnknown() + func (m *ExecStressResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExecStressResponse) XXX_Merge(src proto.Message) + func (m *ExecStressResponse) XXX_Size() int + func (m *ExecStressResponse) XXX_Unmarshal(b []byte) error + type IpSet struct + Ips []string + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IpSet) Descriptor() ([]byte, []int) + func (*IpSet) ProtoMessage() + func (m *IpSet) GetIps() []string + func (m *IpSet) GetName() string + func (m *IpSet) Reset() + func (m *IpSet) String() string + func (m *IpSet) XXX_DiscardUnknown() + func (m *IpSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IpSet) XXX_Merge(src proto.Message) + func (m *IpSet) XXX_Size() int + func (m *IpSet) XXX_Unmarshal(b []byte) error + type IpSetRequest struct + ContainerId string + Ipset *IpSet + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IpSetRequest) Descriptor() ([]byte, []int) + func (*IpSetRequest) ProtoMessage() + func (m *IpSetRequest) GetContainerId() string + func (m *IpSetRequest) GetIpset() *IpSet + func (m *IpSetRequest) Reset() + func (m *IpSetRequest) String() string + func (m *IpSetRequest) XXX_DiscardUnknown() + func (m *IpSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IpSetRequest) XXX_Merge(src proto.Message) + func (m *IpSetRequest) XXX_Size() int + func (m *IpSetRequest) XXX_Unmarshal(b []byte) error + type IpTablesRequest struct + ContainerId string + Rule *Rule + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IpTablesRequest) Descriptor() ([]byte, []int) + func (*IpTablesRequest) ProtoMessage() + func (m *IpTablesRequest) GetContainerId() string + func (m *IpTablesRequest) GetRule() *Rule + func (m *IpTablesRequest) Reset() + func (m *IpTablesRequest) String() string + func (m *IpTablesRequest) XXX_DiscardUnknown() + func (m *IpTablesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IpTablesRequest) XXX_Merge(src proto.Message) + func (m *IpTablesRequest) XXX_Size() int + func (m *IpTablesRequest) XXX_Unmarshal(b []byte) error + type Netem struct + Corrupt float32 + CorruptCorr float32 + DelayCorr float32 + Duplicate float32 + DuplicateCorr float32 + Gap uint32 + Handle *TcHandle + Jitter uint32 + Limit uint32 + Loss float32 + LossCorr float32 + Parent *TcHandle + Reorder float32 + ReorderCorr float32 + Time uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Netem) Descriptor() ([]byte, []int) + func (*Netem) ProtoMessage() + func (m *Netem) GetCorrupt() float32 + func (m *Netem) GetCorruptCorr() float32 + func (m *Netem) GetDelayCorr() float32 + func (m *Netem) GetDuplicate() float32 + func (m *Netem) GetDuplicateCorr() float32 + func (m *Netem) GetGap() uint32 + func (m *Netem) GetHandle() *TcHandle + func (m *Netem) GetJitter() uint32 + func (m *Netem) GetLimit() uint32 + func (m *Netem) GetLoss() float32 + func (m *Netem) GetLossCorr() float32 + func (m *Netem) GetParent() *TcHandle + func (m *Netem) GetReorder() float32 + func (m *Netem) GetReorderCorr() float32 + func (m *Netem) GetTime() uint32 + func (m *Netem) Reset() + func (m *Netem) String() string + func (m *Netem) XXX_DiscardUnknown() + func (m *Netem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Netem) XXX_Merge(src proto.Message) + func (m *Netem) XXX_Size() int + func (m *Netem) XXX_Unmarshal(b []byte) error + type NetemRequest struct + ContainerId string + Handle *TcHandle + Netem *Netem + Parent *TcHandle + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NetemRequest) Descriptor() ([]byte, []int) + func (*NetemRequest) ProtoMessage() + func (m *NetemRequest) GetContainerId() string + func (m *NetemRequest) GetHandle() *TcHandle + func (m *NetemRequest) GetNetem() *Netem + func (m *NetemRequest) GetParent() *TcHandle + func (m *NetemRequest) Reset() + func (m *NetemRequest) String() string + func (m *NetemRequest) XXX_DiscardUnknown() + func (m *NetemRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NetemRequest) XXX_Merge(src proto.Message) + func (m *NetemRequest) XXX_Size() int + func (m *NetemRequest) XXX_Unmarshal(b []byte) error + type Qdisc struct + Args []string + Handle *TcHandle + Parent *TcHandle + Type string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Qdisc) Descriptor() ([]byte, []int) + func (*Qdisc) ProtoMessage() + func (m *Qdisc) GetArgs() []string + func (m *Qdisc) GetHandle() *TcHandle + func (m *Qdisc) GetParent() *TcHandle + func (m *Qdisc) GetType() string + func (m *Qdisc) Reset() + func (m *Qdisc) String() string + func (m *Qdisc) XXX_DiscardUnknown() + func (m *Qdisc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Qdisc) XXX_Merge(src proto.Message) + func (m *Qdisc) XXX_Size() int + func (m *Qdisc) XXX_Unmarshal(b []byte) error + type QdiscRequest struct + ContainerId string + Qdisc *Qdisc + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*QdiscRequest) Descriptor() ([]byte, []int) + func (*QdiscRequest) ProtoMessage() + func (m *QdiscRequest) GetContainerId() string + func (m *QdiscRequest) GetQdisc() *Qdisc + func (m *QdiscRequest) Reset() + func (m *QdiscRequest) String() string + func (m *QdiscRequest) XXX_DiscardUnknown() + func (m *QdiscRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QdiscRequest) XXX_Merge(src proto.Message) + func (m *QdiscRequest) XXX_Size() int + func (m *QdiscRequest) XXX_Unmarshal(b []byte) error + type Rule struct + Action Rule_Action + Direction Rule_Direction + Set string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Rule) Descriptor() ([]byte, []int) + func (*Rule) ProtoMessage() + func (m *Rule) GetAction() Rule_Action + func (m *Rule) GetDirection() Rule_Direction + func (m *Rule) GetSet() string + func (m *Rule) Reset() + func (m *Rule) String() string + func (m *Rule) XXX_DiscardUnknown() + func (m *Rule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Rule) XXX_Merge(src proto.Message) + func (m *Rule) XXX_Size() int + func (m *Rule) XXX_Unmarshal(b []byte) error + type Rule_Action int32 + const Rule_ADD + const Rule_DELETE + func (Rule_Action) EnumDescriptor() ([]byte, []int) + func (x Rule_Action) String() string + type Rule_Direction int32 + const Rule_INPUT + const Rule_OUTPUT + func (Rule_Direction) EnumDescriptor() ([]byte, []int) + func (x Rule_Direction) String() string + type Tbf struct + Buffer uint32 + Limit uint32 + MinBurst uint32 + PeakRate uint64 + Rate uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Tbf) Descriptor() ([]byte, []int) + func (*Tbf) ProtoMessage() + func (m *Tbf) GetBuffer() uint32 + func (m *Tbf) GetLimit() uint32 + func (m *Tbf) GetMinBurst() uint32 + func (m *Tbf) GetPeakRate() uint64 + func (m *Tbf) GetRate() uint64 + func (m *Tbf) Reset() + func (m *Tbf) String() string + func (m *Tbf) XXX_DiscardUnknown() + func (m *Tbf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Tbf) XXX_Merge(src proto.Message) + func (m *Tbf) XXX_Size() int + func (m *Tbf) XXX_Unmarshal(b []byte) error + type TbfRequest struct + ContainerId string + Tbf *Tbf + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TbfRequest) Descriptor() ([]byte, []int) + func (*TbfRequest) ProtoMessage() + func (m *TbfRequest) GetContainerId() string + func (m *TbfRequest) GetTbf() *Tbf + func (m *TbfRequest) Reset() + func (m *TbfRequest) String() string + func (m *TbfRequest) XXX_DiscardUnknown() + func (m *TbfRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TbfRequest) XXX_Merge(src proto.Message) + func (m *TbfRequest) XXX_Size() int + func (m *TbfRequest) XXX_Unmarshal(b []byte) error + type TcFilter struct + Parent *TcHandle + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TcFilter) Descriptor() ([]byte, []int) + func (*TcFilter) ProtoMessage() + func (m *TcFilter) GetParent() *TcHandle + func (m *TcFilter) Reset() + func (m *TcFilter) String() string + func (m *TcFilter) XXX_DiscardUnknown() + func (m *TcFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TcFilter) XXX_Merge(src proto.Message) + func (m *TcFilter) XXX_Size() int + func (m *TcFilter) XXX_Unmarshal(b []byte) error + type TcFilterRequest struct + ContainerId string + Filter *TcFilter + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TcFilterRequest) Descriptor() ([]byte, []int) + func (*TcFilterRequest) ProtoMessage() + func (m *TcFilterRequest) GetContainerId() string + func (m *TcFilterRequest) GetFilter() *TcFilter + func (m *TcFilterRequest) Reset() + func (m *TcFilterRequest) String() string + func (m *TcFilterRequest) XXX_DiscardUnknown() + func (m *TcFilterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TcFilterRequest) XXX_Merge(src proto.Message) + func (m *TcFilterRequest) XXX_Size() int + func (m *TcFilterRequest) XXX_Unmarshal(b []byte) error + type TcHandle struct + Major uint32 + Minor uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TcHandle) Descriptor() ([]byte, []int) + func (*TcHandle) ProtoMessage() + func (m *TcHandle) GetMajor() uint32 + func (m *TcHandle) GetMinor() uint32 + func (m *TcHandle) Reset() + func (m *TcHandle) String() string + func (m *TcHandle) XXX_DiscardUnknown() + func (m *TcHandle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TcHandle) XXX_Merge(src proto.Message) + func (m *TcHandle) XXX_Size() int + func (m *TcHandle) XXX_Unmarshal(b []byte) error + type TimeRequest struct + ClkIdsMask uint64 + ContainerId string + Nsec int64 + Sec int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TimeRequest) Descriptor() ([]byte, []int) + func (*TimeRequest) ProtoMessage() + func (m *TimeRequest) GetClkIdsMask() uint64 + func (m *TimeRequest) GetContainerId() string + func (m *TimeRequest) GetNsec() int64 + func (m *TimeRequest) GetSec() int64 + func (m *TimeRequest) Reset() + func (m *TimeRequest) String() string + func (m *TimeRequest) XXX_DiscardUnknown() + func (m *TimeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TimeRequest) XXX_Merge(src proto.Message) + func (m *TimeRequest) XXX_Size() int + func (m *TimeRequest) XXX_Unmarshal(b []byte) error