core

package

Go to main page

Versions in this module

v1

v1.4.0

Feb 8, 2023

Changes in this version

+ const AuthMechanismEmpty

+ const DiskServerAttack

+ const HostRebootAction

+ const SaslPlain

+ const SaslScram512

+ const SaslScream256

type DiskOption

+ func NewDiskOptionForServer() *DiskOption

+ type KafkaAuthMechanism string

type KafkaCommand

+ AuthMechanism string

v1.3.5

Jan 31, 2023

v1.3.4

Jan 29, 2023

v1.3.3

Jan 6, 2023

v1.3.2

Dec 14, 2022

v1.3.1

Sep 14, 2022

v1.3.0

Aug 17, 2022

v1.2.1

Aug 16, 2022

Changes in this version

+ const ClockAction

+ const HTTPAbortAction

+ const HTTPAttack

+ const HTTPConfigAction

+ const HTTPDelayAction

+ const HTTPRequestAction

+ const KafkaAttack

+ const KafkaFillAction

+ const KafkaFloodAction

+ const KafkaIOAction

+ const NetIPSet

+ const NetworkFloodAction

+ const RedisAttack

+ const RedisCacheExpirationAction

+ const RedisCacheLimitAction

+ const RedisCachePenetrationAction

+ const RedisSentinelRestartAction

+ const RedisSentinelStopAction

+ const TargetRequest

+ const TargetResponse

+ const UserDefinedAttack

+ const VMAction

+ const VMAttack

+ var ValidOptions = map[string]bool

+ type HTTPAttackConfig struct

+ Config tproxyconfig.Config

+ Logger logr.Logger

+ ProxyPID int

+ func (c HTTPAttackConfig) RecoverData() string

+ type HTTPAttackOption struct

+ Abort bool

+ Code string

+ Delay string

+ FilePath string

+ Method string

+ Path string

+ Port int32

+ ProxyPorts []uint

+ Target string

+ func NewHTTPAttackOption() *HTTPAttackOption

+ func (o *HTTPAttackOption) PreProcess() (*HTTPAttackConfig, error)

+ type HTTPRequestConfig struct

+ Count int

+ EnableConnPool bool

+ URL string

+ type KafkaAttackAction string

+ type KafkaCommand struct

+ Action KafkaAttackAction

+ ConfigFile string

+ Host string

+ MaxBytes uint64

+ MessageSize uint

+ NonReadable bool

+ NonWritable bool

+ OriginConfig string

+ OriginModeOfFiles map[string]uint32

+ Password string

+ Port uint16

+ ReloadCommand string

+ Threads uint

+ Topic string

+ Username string

+ func NewKafkaCommand() *KafkaCommand

+ func (c *KafkaCommand) CompleteDefaults()

+ func (c *KafkaCommand) RecoverData() string

+ func (c *KafkaCommand) Validate() error

type NetworkCommand

+ IperfPid int32

+ Parallel int32

+ func (n *NetworkCommand) AdditionalChain(ipset string) ([]*pb.Chain, error)

+ func (n *NetworkCommand) NeedAdditionalChains() bool

+ type RedisCommand struct

+ Addr string

+ CacheSize string

+ Conf string

+ Expiration string

+ FlushConfig bool

+ Key string

+ Option string

+ OriginCacheSize string

+ Password string

+ Percent string

+ RedisPath string

+ RequestNum int

+ func NewRedisCommand() *RedisCommand

+ func (r *RedisCommand) Validate() error

+ func (r RedisCommand) RecoverData() string

+ type UserDefinedOption struct

+ AttackCmd string

+ RecoverCmd string

+ func NewUserDefinedOption() *UserDefinedOption

+ func (u *UserDefinedOption) RecoverData() string

+ func (u *UserDefinedOption) Validate() error

+ type VMOption struct

+ VMName string

+ func NewVMOption() *VMOption

+ func (opt *VMOption) CompleteDefaults()

+ func (opt VMOption) RecoverData() string

v1.2.0

Apr 28, 2022

Changes in this version

+ const CompleteRuleTemplate

+ const FileAppendAction

+ const FileAttack

+ const FileCreateAction

+ const FileDeleteAction

+ const FileModifyPrivilegeAction

+ const FileRenameAction

+ const FileReplaceAction

+ const GCHelper

+ const JVMMySQLAction

+ const MySQL5Exception

+ const MySQL5InjectClass

+ const MySQL5InjectMethod

+ const MySQL8Exception

+ const MySQL8InjectClass

+ const MySQL8InjectMethod

+ const NetworkNICDownAction

+ const SQLHelper

+ const SimpleRuleTemplate

+ const StressHelper

+ const TriggerClass

+ const TriggerMethod

+ type BytemanTemplateSpec struct

+ Bind string

+ Class string

+ Condition string

+ Do string

+ Helper string

+ Method string

+ Name string

+ StressType string

+ StressValue string

+ StressValueName string

+ type FileCommand struct

+ Count int

+ Data string

+ DestFile string

+ DestStr string

+ DirName string

+ FileName string

+ Line int

+ OriginPrivilege int

+ OriginStr string

+ Privilege uint32

+ SourceFile string

+ func NewFileCommand() *FileCommand

+ func (n *FileCommand) CompleteDefaults()

+ func (n *FileCommand) Validate() error

+ func (n FileCommand) RecoverData() string

+ type JVMClassMethodSpec struct

+ Class string

+ Method string

+ type JVMCommonSpec struct

+ Pid int

+ Port int

+ type JVMMySQLSpec struct

+ Database string

+ MySQLConnectorVersion string

+ SQLType string

+ Table string

+ type JVMStressSpec struct

+ CPUCount int

+ MemoryType string

v1.1.1

Jan 12, 2022

Changes in this version

type ProcessCommand

+ RecoverCmd string

v1.1.0

Nov 29, 2021

Changes in this version

+ const ClockAttack

+ const JVMRuleDataAction

+ const NetworkBandwidthAction

+ const NetworkPartitionAction

+ const NetworkPortOccupiedAction

+ type ClockFuncStore struct

+ CodeOfGetClockFunc []byte

+ OriginAddress uint64

+ type ClockOption struct

+ ClockIdsMask uint64

+ ClockIdsSlice string

+ NsecDelta int64

+ Pid int

+ SecDelta int64

+ Store ClockFuncStore

+ TimeOffset string

+ func NewClockOption() *ClockOption

+ func (opt *ClockOption) CompleteDefaults()

+ func (opt *ClockOption) PreProcess() error

+ func (opt ClockOption) RecoverData() string

type IptablesRule

+ Protocol string

type JVMCommand

+ MemoryType string

type NetworkCommand

+ AcceptTCPFlags string

+ DNSDomainName string

+ Direction string

+ func (n *NetworkCommand) PartitionChain(ipset string) ([]*pb.Chain, error)

v1.0.2

Sep 15, 2021

Changes in this version

+ var DdCommand = utils.Command

+ var FAllocateCommand = utils.Command

type AttackConfig

+ func GetAttackByKind(kind string) *AttackConfig

+ GetUID func() string

type CommonAttackConfig

+ UID string

+ func (config *CommonAttackConfig) GetUID() string

+ type DdOption struct

+ BlockSize string

+ Conv string

+ Count string

+ Iflag string

+ Oflag string

+ ReadPath string

+ WritePath string

+ type DiskAttackConfig struct

+ DdOptions *[]DdOption

+ FAllocateOption *FAllocateOption

+ Path string

+ func (d DiskAttackConfig) RecoverData() string

type DiskOption

+ FillByFAllocate bool

+ func (opt *DiskOption) PreProcess() (*DiskAttackConfig, error)

+ type FAllocateOption struct

+ FileName string

+ Length string

+ LengthOpt string

type StressCommand

+ func (s *StressCommand) CompleteDefaults()

v1.0.1

Jul 15, 2021

v1.0.0

Jun 23, 2021

Changes in this version

+ const CommandMode

+ const JVMAttack

+ const JVMExceptionAction

+ const JVMGCAction

+ const JVMInstallType

+ const JVMLatencyAction

+ const JVMReturnAction

+ const JVMRuleFileAction

+ const JVMStressAction

+ const JVMSubmitType

+ const NetworkDNSAction

+ const NetworkPortOccupied

+ const RunFailed

+ const RunRecovered

+ const RunStarted

+ const RunSuccess

+ const Scheduled

+ const ServerMode

+ var ErrAttackConfigValidation = ErrNs.NewType("attack_config_validation_error")

+ var ErrNonRecoverableAttack = ErrNs.NewType("non_recoverable_attack")

+ var ErrNs = errorx.NewNamespace("error.core")

+ type AttackConfig interface

+ AttackKind func() string

+ CompleteDefaults func()

+ Cron func() string

+ RecoverData func() string

+ ScheduleDuration func() (*time.Duration, error)

+ String func() string

+ Validate func() error

+ type CommonAttackConfig struct

+ Action string

+ Kind string

+ func (config *CommonAttackConfig) CompleteDefaults()

+ func (config *CommonAttackConfig) Validate() error

+ func (config CommonAttackConfig) AttackKind() string

+ func (config CommonAttackConfig) String() string

+ type DiskOption struct

+ FillByFallocate bool

+ Path string

+ PayloadProcessNum uint8

+ Percent string

+ Size string

+ func NewDiskOption() *DiskOption

+ func (d *DiskOption) Validate() error

+ func (d DiskOption) RecoverData() string

type Experiment

+ LaunchMode string

+ func (exp *Experiment) GetRequestCommand() (AttackConfig, error)

+ func (exp Experiment) NewRun() *ExperimentRun

+ type ExperimentRun struct

+ Experiment Experiment

+ ExperimentID uint

+ FinishedAt time.Time

+ ID uint

+ Message string

+ StartAt time.Time

+ Status string

+ UID string

+ type ExperimentRunStore interface

+ LatestRun func(ctx context.Context, id uint) (*ExperimentRun, error)

+ ListByExperimentID func(ctx context.Context, id uint) ([]*ExperimentRun, error)

+ ListByExperimentUID func(ctx context.Context, uid string) ([]*ExperimentRun, error)

+ NewRun func(ctx context.Context, expRun *ExperimentRun) error

+ Update func(ctx context.Context, runUid string, status string, message string) error

type ExperimentStore

+ ListByLaunchMode func(ctx context.Context, mode string) ([]*Experiment, error)

type HostCommand

+ func NewHostCommand() *HostCommand

+ func (h HostCommand) RecoverData() string

+ type JVMCommand struct

+ Action string

+ CPUCount int

+ Class string

+ Do string

+ LatencyDuration string

+ MemorySize int

+ Method string

+ Name string

+ Pid int

+ Port int

+ ReturnValue string

+ RuleData []byte

+ RuleFile string

+ StressType string

+ StressValue int

+ StressValueName string

+ ThrowException string

+ Type string

+ func NewJVMCommand() *JVMCommand

+ func (j *JVMCommand) CompleteDefaults()

+ func (j *JVMCommand) RecoverData() string

+ func (j *JVMCommand) Validate() error

type NetworkCommand

+ DNSHost string

+ DNSIp string

+ DNSServer string

+ Port string

+ PortPid int32

+ func NewNetworkCommand() *NetworkCommand

+ func (n *NetworkCommand) CompleteDefaults()

+ func (n *NetworkCommand) NeedApplyDNSServer() bool

+ func (n *NetworkCommand) NeedApplyEtcHosts() bool

+ func (n NetworkCommand) RecoverData() string

type ProcessCommand

+ func NewProcessCommand() *ProcessCommand

+ func (p ProcessCommand) RecoverData() string

+ type SchedulerConfig struct

+ Duration string

+ Schedule string

+ func (config SchedulerConfig) Cron() string

+ func (config SchedulerConfig) ScheduleDuration() (*time.Duration, error)

type StressCommand

+ Size string

+ func NewStressCommand() *StressCommand

+ func (s StressCommand) RecoverData() string

v0

v0.9.0

Apr 1, 2021

Changes in this version

+ const Created

+ const Destroyed

+ const DiskAttack

+ const DiskFillAction

+ const DiskReadPayloadAction

+ const DiskWritePayloadAction

+ const Error

+ const HostAttack

+ const HostShutdownAction

+ const NetworkAttack

+ const NetworkCorruptAction

+ const NetworkDelayAction

+ const NetworkDuplicateAction

+ const NetworkLossAction

+ const ProcessAttack

+ const ProcessKillAction

+ const ProcessStopAction

+ const Revoked

+ const StressAttack

+ const StressCPUAction

+ const StressMemAction

+ const Success

+ type BandwidthSpec struct

+ Buffer uint32

+ Limit uint32

+ Minburst *uint32

+ Peakrate *uint64

+ Rate string

+ func (in *BandwidthSpec) ToTbf() (*pb.Tbf, error)

+ type ChainDirection string

+ type Cidr struct

+ Cidr string

+ type CorruptSpec struct

+ Correlation string

+ Corrupt string

+ func (in *CorruptSpec) ToNetem() (*pb.Netem, error)

+ type DelaySpec struct

+ Correlation string

+ Jitter string

+ Latency string

+ Reorder *ReorderSpec

+ func (in *DelaySpec) ToNetem() (*pb.Netem, error)

+ type DiskCommand struct

+ Action string

+ FillByFallocate bool

+ Path string

+ Size uint64

+ func (d *DiskCommand) String() string

+ func (d *DiskCommand) Validate() error

+ type DuplicateSpec struct

+ Correlation string

+ Duplicate string

+ func (in *DuplicateSpec) ToNetem() (*pb.Netem, error)

+ type Experiment struct

+ Action string

+ CreatedAt time.Time

+ ID uint

+ Kind string

+ Message string

+ RecoverCommand string

+ Status string

+ Uid string

+ UpdatedAt time.Time

+ type ExperimentStore interface

+ FindByUid func(ctx context.Context, uid string) (*Experiment, error)

+ List func(ctx context.Context) ([]*Experiment, error)

+ ListByConditions func(ctx context.Context, conds *SearchCommand) ([]*Experiment, error)

+ ListByStatus func(ctx context.Context, status string) ([]*Experiment, error)

+ Set func(ctx context.Context, exp *Experiment) error

+ Update func(ctx context.Context, uid, status, msg string, command string) error

+ type HostCommand struct

+ Action string

+ func (h *HostCommand) String() string

+ func (h *HostCommand) Validate() error

+ type IPSetRule struct

+ Cidrs string

+ Experiment string

+ Name string

+ type IPSetRuleStore interface

+ DeleteByExperiment func(ctx context.Context, experiment string) error

+ FindByExperiment func(ctx context.Context, experiment string) ([]*IPSetRule, error)

+ List func(ctx context.Context) ([]*IPSetRule, error)

+ Set func(ctx context.Context, rule *IPSetRule) error

+ type IptablesRule struct

+ Direction string

+ Experiment string

+ IPSets string

+ Name string

+ func (i *IptablesRule) ToChain() *pb.Chain

+ type IptablesRuleList []*IptablesRule

+ func (l IptablesRuleList) ToChains() []*pb.Chain

+ type IptablesRuleStore interface

+ DeleteByExperiment func(ctx context.Context, experiment string) error

+ FindByExperiment func(ctx context.Context, experiment string) ([]*IptablesRule, error)

+ List func(ctx context.Context) ([]*IptablesRule, error)

+ Set func(ctx context.Context, rule *IptablesRule) error

+ type LossSpec struct

+ Correlation string

+ Loss string

+ func (in *LossSpec) ToNetem() (*pb.Netem, error)

+ type NetemSpec interface

+ ToNetem func() (*pb.Netem, error)

+ type NetworkCommand struct

+ Action string

+ Correlation string

+ Device string

+ EgressPort string

+ Hostname string

+ IPAddress string

+ IPProtocol string

+ Jitter string

+ Latency string

+ Percent string

+ SourcePort string

+ func (n *NetworkCommand) NeedApplyIPSet() bool

+ func (n *NetworkCommand) NeedApplyIptables() bool

+ func (n *NetworkCommand) NeedApplyTC() bool

+ func (n *NetworkCommand) SetDefaultForNetworkDelay()

+ func (n *NetworkCommand) SetDefaultForNetworkLoss()

+ func (n *NetworkCommand) String() string

+ func (n *NetworkCommand) ToChain() (*pb.Chain, error)

+ func (n *NetworkCommand) ToCorruptNetem() (*pb.Netem, error)

+ func (n *NetworkCommand) ToDelayNetem() (*pb.Netem, error)

+ func (n *NetworkCommand) ToDuplicateNetem() (*pb.Netem, error)

+ func (n *NetworkCommand) ToIPSet(name string) (*pb.IPSet, error)

+ func (n *NetworkCommand) ToLossNetem() (*pb.Netem, error)

+ func (n *NetworkCommand) ToTC(ipset string) (*pb.Tc, error)

+ func (n *NetworkCommand) Validate() error

+ type ProcessCommand struct

+ Action string

+ PIDs []int

+ Process string

+ Signal int

+ func (p *ProcessCommand) String() string

+ func (p *ProcessCommand) Validate() error

+ type ReorderSpec struct

+ Correlation string

+ Gap int

+ Reorder string

+ type SearchCommand struct

+ All bool

+ Asc bool

+ Kind string

+ Limit uint32

+ Offset uint32

+ Status string

+ UID string

+ func (s *SearchCommand) Validate() error

+ type StressCommand struct

+ Action string

+ Duration time.Duration

+ Load int

+ Options []string

+ StressngPid int32

+ Workers int

+ func (s *StressCommand) String() string

+ func (s *StressCommand) Validate() error

+ type TCRule struct

+ Device string

+ EgressPort string

+ Experiment string

+ IPSet string

+ Protocal string

+ SourcePort string

+ TC string

+ Type string

+ func (t *TCRule) ToTC() (*pb.Tc, error)

+ type TCRuleList []*TCRule

+ func (t TCRuleList) ToTCs() ([]*pb.Tc, error)

+ type TCRuleStore interface

+ DeleteByExperiment func(ctx context.Context, experiment string) error

+ FindByDevice func(ctx context.Context, experiment string) ([]*TCRule, error)

+ FindByExperiment func(ctx context.Context, experiment string) ([]*TCRule, error)

+ List func(ctx context.Context) ([]*TCRule, error)

+ ListGroupDevice func(ctx context.Context) (map[string][]*TCRule, error)

+ Set func(ctx context.Context, rule *TCRule) error

+ type TcParameter struct

+ Bandwidth *BandwidthSpec

+ Corrupt *CorruptSpec

+ Delay *DelaySpec

+ Device string

+ Duplicate *DuplicateSpec

+ Loss *LossSpec

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL