chaosd

Documentation

Index

• Constants
• func ApplyDiskAttack(options core.AttackConfig, env Environment) error
• func ApplyDiskServerAttack(options core.AttackConfig, env Environment) error
• func ExpireFunc(cli *redis.Client, key string, expiration time.Duration, option string) *redis.BoolCmd
• func FindSymbolInEntry(p ptrace.TracedProgram, symbolName string, entry *mapreader.Entry) (addr uint64, size uint64, err error)
• type AttackType
• type Environment
• type HostManager
• type OutputHandler
  • func NewOutputHandler(handler func([]byte, error, chan interface{}), outputChan chan interface{}) *OutputHandler
• type Server
  • func NewServer(conf *config.Config, exp core.ExperimentStore, expRun core.ExperimentRunStore, ...) *Server
  • func (s *Server) ExecuteAttack(attackType AttackType, options core.AttackConfig, launchMode string) (uid string, err error)
  • func (s *Server) RecoverAttack(uid string) error
  • func (s *Server) Search(conds *core.SearchCommand) ([]*core.Experiment, error)
• type UnixHost
  • func (h UnixHost) Name() string
  • func (h UnixHost) Reboot() error
  • func (h UnixHost) Shutdown() error

Constants

const (
	STATUSOK = "OK"
	OPTIONNX = "NX"
	OPTIONXX = "XX"
	OPTIONGT = "GT"
	OPTIONLT = "LT"
)

const (
	CPUSTRESSORTOOL    = "stress-ng"
	MEMORYSTRESSORTOOL = "memStress"
)

const CmdReboot = "reboot"

const CmdShutdown = "shutdown"

Functions

func ApplyDiskAttack

func ApplyDiskAttack(options core.AttackConfig, env Environment) error

func ApplyDiskServerAttack

func ApplyDiskServerAttack(options core.AttackConfig, env Environment) error

func ExpireFunc

func ExpireFunc(cli *redis.Client, key string, expiration time.Duration, option string) *redis.BoolCmd

func FindSymbolInEntry

func FindSymbolInEntry(p ptrace.TracedProgram, symbolName string, entry *mapreader.Entry) (addr uint64, size uint64, err error)

FindSymbolInEntry finds symbol in entry through parsing elf

Types

type AttackType

type AttackType interface {
	// Attack execute attack with options and env.
	// ExecuteAttack will store the options ahead of Attack be executed
	// and will store options again after Attack be executed.
	// We can also use env.Chaos.expStore to touch the storage of chaosd.
	// But do not update it with your own uid ,
	// because it will be covered after Attack executed with options.
	Attack(options core.AttackConfig, env Environment) error
	// Recover can get marshaled options data from experiment and recover it.
	Recover(experiment core.Experiment, env Environment) error
}

var ClockAttack AttackType = clockAttack{}

var DiskAttack AttackType = diskAttack{}

var DiskServerAttack AttackType = diskServerAttack{}

var FileAttack AttackType = fileAttack{}

var HTTPAttack AttackType = attackHTTP{}

var HostAttack AttackType = hostAttack{}

var JVMAttack AttackType = jvmAttack{}

var KafkaAttack AttackType = kafkaAttack{}

var NetworkAttack AttackType = networkAttack{}

var ProcessAttack AttackType = processAttack{}

var RedisAttack AttackType = redisAttack{}

var StressAttack AttackType = stressAttack{}

var UserDefinedAttack AttackType = userDefinedAttack{}

var VMAttack AttackType = vmAttack{}

type Environment

type Environment struct {
	AttackUid string
	Chaos     *Server
}

type HostManager

type HostManager interface {
	Name() string
	Shutdown() error
	Reboot() error
}

var Host HostManager = UnixHost{}

type OutputHandler

type OutputHandler struct {
	StdoutHandler func([]byte, error, chan interface{})
	OutputChan    chan interface{}
}

func NewOutputHandler

func NewOutputHandler(
	handler func([]byte, error, chan interface{}),
	outputChan chan interface{}) *OutputHandler

type Server

type Server struct {
	ExpRun core.ExperimentRunStore
	Cron   scheduler.Scheduler

	CmdPools map[string]*utils.CommandPools
	// contains filtered or unexported fields
}

func NewServer

func NewServer(
	conf *config.Config,
	exp core.ExperimentStore,
	expRun core.ExperimentRunStore,
	ipset core.IPSetRuleStore,
	iptables core.IptablesRuleStore,
	tc core.TCRuleStore,
	svr *chaosdaemon.DaemonServer,
	cron scheduler.Scheduler,
) *Server

func (*Server) ExecuteAttack

func (s *Server) ExecuteAttack(attackType AttackType, options core.AttackConfig, launchMode string) (uid string, err error)

ExecuteAttack creates a new Experiment record and may schedule/execute an attack for the given attackType. If options.Schedule isn't provided, then the attack is executed immediately. Otherwise the attack is scheduled based on the provided schedule spec and duration.

func (*Server) RecoverAttack

func (s *Server) RecoverAttack(uid string) error

func (*Server) Search

func (s *Server) Search(conds *core.SearchCommand) ([]*core.Experiment, error)

type UnixHost

type UnixHost struct{}

func (UnixHost) Name

func (h UnixHost) Name() string

func (UnixHost) Reboot

func (h UnixHost) Reboot() error

func (UnixHost) Shutdown

func (h UnixHost) Shutdown() error