v1

Documentation

Index

• type CPUManager
  • func (cm *CPUManager) Recover(ctx context.Context, _ *v1.CPURequest) (*v1.StatusResponse, error)
  • func (cm *CPUManager) Start(ctx context.Context, req *v1.CPURequest) (*v1.StatusResponse, error)
• type DockerHandler
  • func (dh *DockerHandler) Kill(ctx context.Context, req *v1.DockerRequest) (*v1.StatusResponse, error)
  • func (dh *DockerHandler) Recover(ctx context.Context, req *v1.DockerRequest) (*v1.StatusResponse, error)
• type HealthCheckService
  • func (hcs *HealthCheckService) Check(context.Context, *v1.HealthCheckRequest) (*v1.HealthCheckResponse, error)
  • func (hcs *HealthCheckService) Watch(*v1.HealthCheckRequest, v1.Health_WatchServer) error
• type NetworkManager
  • func NewNetworkManager(logger log.Logger) *NetworkManager
  • func (nm *NetworkManager) Recover(ctx context.Context, req *v1.NetworkRequest) (*v1.StatusResponse, error)
  • func (nm *NetworkManager) Start(ctx context.Context, req *v1.NetworkRequest) (*v1.StatusResponse, error)
• type ServerManager
  • func (sm *ServerManager) Kill(ctx context.Context, _ *v1.ServerRequest) (*v1.StatusResponse, error)
• type ServiceHandler
  • func NewServiceHandler(logger log.Logger) *ServiceHandler
  • func (sh *ServiceHandler) Kill(ctx context.Context, req *v1.ServiceRequest) (*v1.StatusResponse, error)
  • func (sh *ServiceHandler) Recover(ctx context.Context, req *v1.ServiceRequest) (*v1.StatusResponse, error)

Types

type CPUManager

type CPUManager struct {
	CPU    *cpu.CPU
	Logger log.Logger
	*v1.UnimplementedCPUServer
}

CPUManager is the rpc for cpu failures

func (*CPUManager) Recover

func (cm *CPUManager) Recover(ctx context.Context, _ *v1.CPURequest) (*v1.StatusResponse, error)

Recover the cpu injection

func (*CPUManager) Start

func (cm *CPUManager) Start(ctx context.Context, req *v1.CPURequest) (*v1.StatusResponse, error)

Start a new cpu injection based on the percentage specified

type DockerHandler

type DockerHandler struct {
	Logger log.Logger
	*v1.UnimplementedDockerServer
}

DockerManager is the rpc for docker management

func (*DockerHandler) Kill

func (dh *DockerHandler) Kill(ctx context.Context, req *v1.DockerRequest) (*v1.StatusResponse, error)

Kill a docker container based on the name

func (*DockerHandler) Recover

func (dh *DockerHandler) Recover(ctx context.Context, req *v1.DockerRequest) (*v1.StatusResponse, error)

Recover a docker container based on the name

type HealthCheckService

type HealthCheckService struct {
	*v1.UnimplementedHealthServer
}

HealthCheckService is the rpc

func (*HealthCheckService) Check

func (hcs *HealthCheckService) Check(context.Context, *v1.HealthCheckRequest) (*v1.HealthCheckResponse, error)

Check the health of the chaos bot

func (*HealthCheckService) Watch

func (hcs *HealthCheckService) Watch(*v1.HealthCheckRequest, v1.Health_WatchServer) error

Watch is not used at the moment

type NetworkManager

type NetworkManager struct {
	Network *network.Network
	Logger  log.Logger
	*v1.UnimplementedNetworkServer
}

NetworkManager is the rpc for network failure injections

func NewNetworkManager

func NewNetworkManager(logger log.Logger) *NetworkManager

NewNetworkManager will create the rpc for network failures with a logger attached

func (*NetworkManager) Recover

func (nm *NetworkManager) Recover(ctx context.Context, req *v1.NetworkRequest) (*v1.StatusResponse, error)

Recover a network injection

func (*NetworkManager) Start

func (nm *NetworkManager) Start(ctx context.Context, req *v1.NetworkRequest) (*v1.StatusResponse, error)

Start a network injection according to the network request

type ServerManager

type ServerManager struct {
	Server server.Server
	Logger log.Logger
	*v1.UnimplementedServerServer
}

ServerManager is the rpc for server failure injections

func (*ServerManager) Kill

func (sm *ServerManager) Kill(ctx context.Context, _ *v1.ServerRequest) (*v1.StatusResponse, error)

Kill the server

type ServiceHandler

type ServiceHandler struct {
	Logger log.Logger

	*v1.UnimplementedServiceServer
	// contains filtered or unexported fields
}

ServiceManager is the rpc for services management

func NewServiceHandler

func NewServiceHandler(logger log.Logger) *ServiceHandler

NewServiceHandler will create the rpc for services management with a logger attached

func (*ServiceHandler) Kill

func (sh *ServiceHandler) Kill(ctx context.Context, req *v1.ServiceRequest) (*v1.StatusResponse, error)

Kill a service based on the name

func (*ServiceHandler) Recover

func (sh *ServiceHandler) Recover(ctx context.Context, req *v1.ServiceRequest) (*v1.StatusResponse, error)

Recover a service based on the name