Documentation ¶
Index ¶
- Constants
- func GetChildProcesses(ppid uint32) ([]uint32, error)
- func ReadCommName(pid int) (string, error)
- func StartServer(conf *Config, reg RegisterGatherer) error
- func ToNetlinkNetemAttrs(netem *pb.Netem) netlink.NetemQdiscAttrs
- type Config
- type DaemonServer
- func (s *DaemonServer) ApplyIoChaos(ctx context.Context, in *pb.ApplyIoChaosRequest) (*pb.ApplyIoChaosResponse, error)
- func (s *DaemonServer) CancelStressors(ctx context.Context, req *pb.CancelStressRequest) (*empty.Empty, error)
- func (s *DaemonServer) ContainerGetPid(ctx context.Context, req *pb.ContainerRequest) (*pb.ContainerResponse, error)
- func (s *DaemonServer) ContainerKill(ctx context.Context, req *pb.ContainerRequest) (*empty.Empty, error)
- func (s *DaemonServer) ExecStressors(ctx context.Context, req *pb.ExecStressRequest) (*pb.ExecStressResponse, error)
- func (s *DaemonServer) FlushIPSets(ctx context.Context, req *pb.IPSetsRequest) (*empty.Empty, error)
- func (s *DaemonServer) RecoverTimeOffset(ctx context.Context, req *pb.TimeRequest) (*empty.Empty, error)
- func (s *DaemonServer) SetDNSServer(ctx context.Context, req *pb.SetDNSServerRequest) (*empty.Empty, error)
- func (s *DaemonServer) SetIptablesChains(ctx context.Context, req *pb.IptablesChainsRequest) (*empty.Empty, error)
- func (s *DaemonServer) SetTcs(ctx context.Context, in *pb.TcsRequest) (*empty.Empty, error)
- func (s *DaemonServer) SetTimeOffset(ctx context.Context, req *pb.TimeRequest) (*empty.Empty, error)
- type Edge
- type Graph
- type RegisterGatherer
- type Response
Constants ¶
View Source
const ( // StatusOK represents OK status code StatusOK = 200 // StatusOtherError represents Error status code StatusOtherError = 1 )
View Source
const (
// DNSServerConfFile is the default config file for DNS server
DNSServerConfFile = "/etc/resolv.conf"
)
Variables ¶
This section is empty.
Functions ¶
func GetChildProcesses ¶
GetChildProcesses will return all child processes's pid. Include all generations. only return error when /proc/pid/tasks cannot be read
func ReadCommName ¶
ReadCommName returns the command name of process
func StartServer ¶
func StartServer(conf *Config, reg RegisterGatherer) error
StartServer starts chaos-daemon.
func ToNetlinkNetemAttrs ¶
func ToNetlinkNetemAttrs(netem *pb.Netem) netlink.NetemQdiscAttrs
Types ¶
type Config ¶
type Config struct { HTTPPort int GRPCPort int Host string Runtime string Profiling bool // contains filtered or unexported fields }
Config contains the basic chaos daemon configuration.
type DaemonServer ¶ added in v1.1.0
DaemonServer represents a grpc server for tc daemon
func NewDaemonServerWithCRClient ¶ added in v1.1.0
func NewDaemonServerWithCRClient(crClient crclients.ContainerRuntimeInfoClient) *DaemonServer
NewDaemonServerWithCRClient returns DaemonServer with container runtime client
func (*DaemonServer) ApplyIoChaos ¶ added in v1.1.0
func (s *DaemonServer) ApplyIoChaos(ctx context.Context, in *pb.ApplyIoChaosRequest) (*pb.ApplyIoChaosResponse, error)
func (*DaemonServer) CancelStressors ¶ added in v1.1.0
func (s *DaemonServer) CancelStressors(ctx context.Context, req *pb.CancelStressRequest) (*empty.Empty, error)
func (*DaemonServer) ContainerGetPid ¶ added in v1.1.0
func (s *DaemonServer) ContainerGetPid(ctx context.Context, req *pb.ContainerRequest) (*pb.ContainerResponse, error)
func (*DaemonServer) ContainerKill ¶ added in v1.1.0
func (s *DaemonServer) ContainerKill(ctx context.Context, req *pb.ContainerRequest) (*empty.Empty, error)
ContainerKill kills container according to container id in the req
func (*DaemonServer) ExecStressors ¶ added in v1.1.0
func (s *DaemonServer) ExecStressors(ctx context.Context, req *pb.ExecStressRequest) (*pb.ExecStressResponse, error)
func (*DaemonServer) FlushIPSets ¶ added in v1.1.0
func (s *DaemonServer) FlushIPSets(ctx context.Context, req *pb.IPSetsRequest) (*empty.Empty, error)
func (*DaemonServer) RecoverTimeOffset ¶ added in v1.1.0
func (s *DaemonServer) RecoverTimeOffset(ctx context.Context, req *pb.TimeRequest) (*empty.Empty, error)
func (*DaemonServer) SetDNSServer ¶ added in v1.1.0
func (s *DaemonServer) SetDNSServer(ctx context.Context, req *pb.SetDNSServerRequest) (*empty.Empty, error)
func (*DaemonServer) SetIptablesChains ¶ added in v1.1.0
func (s *DaemonServer) SetIptablesChains(ctx context.Context, req *pb.IptablesChainsRequest) (*empty.Empty, error)
func (*DaemonServer) SetTcs ¶ added in v1.1.0
func (s *DaemonServer) SetTcs(ctx context.Context, in *pb.TcsRequest) (*empty.Empty, error)
func (*DaemonServer) SetTimeOffset ¶ added in v1.1.0
func (s *DaemonServer) SetTimeOffset(ctx context.Context, req *pb.TimeRequest) (*empty.Empty, error)
type Graph ¶ added in v1.1.0
type Graph struct {
// contains filtered or unexported fields
}
Graph represents a graph with link list
func (*Graph) Flatten ¶ added in v1.1.0
Flatten flattens the subtree from source (without checking whether it's a tree)
type RegisterGatherer ¶
type RegisterGatherer interface { prometheus.Registerer prometheus.Gatherer }
RegisterGatherer combine prometheus.Registerer and prometheus.Gatherer
Source Files ¶
Click to show internal directories.
Click to hide internal directories.