v1

Documentation

Index

• type DockerManager
  • func (dm *DockerManager) Start(ctx context.Context, req *proto.DockerRequest) (*proto.StatusResponse, error)
  • func (dm *DockerManager) Stop(ctx context.Context, req *proto.DockerRequest) (*proto.StatusResponse, error)
• type HealthCheckService
  • func (hcs *HealthCheckService) Check(ctx context.Context, req *proto.HealthCheckRequest) (*proto.HealthCheckResponse, error)
  • func (hcs *HealthCheckService) Watch(req *proto.HealthCheckRequest, srv proto.Health_WatchServer) error
• type ServiceManager
  • func (sm *ServiceManager) Start(ctx context.Context, req *proto.ServiceRequest) (*proto.StatusResponse, error)
  • func (sm *ServiceManager) Stop(ctx context.Context, req *proto.ServiceRequest) (*proto.StatusResponse, error)
• type StrategyManager
  • func (sm *StrategyManager) Recover(ctx context.Context, req *proto.RecoverRequest) (*proto.ResolveResponse, error)

Types

type DockerManager

type DockerManager struct {
	Cache  *cache.Cache
	Logger log.Logger
}

DockerManager is the rpc for docker management

func (*DockerManager) Start

func (dm *DockerManager) Start(ctx context.Context, req *proto.DockerRequest) (*proto.StatusResponse, error)

Start a docker container based on the name. Delete the item from the cache if it had been cached previously

func (*DockerManager) Stop

func (dm *DockerManager) Stop(ctx context.Context, req *proto.DockerRequest) (*proto.StatusResponse, error)

Stop a docker container based on the name. Cache it if the docker container is stopped successfully

type HealthCheckService

type HealthCheckService struct {
}

HealthCheckService is the rpc

func (*HealthCheckService) Check

func (hcs *HealthCheckService) Check(ctx context.Context,
	req *proto.HealthCheckRequest) (*proto.HealthCheckResponse, error)

Check the health of the slave

func (*HealthCheckService) Watch

func (hcs *HealthCheckService) Watch(req *proto.HealthCheckRequest, srv proto.Health_WatchServer) error

Watch is not used at the moment

type ServiceManager

type ServiceManager struct {
	Cache  *cache.Cache
	Logger log.Logger
}

ServiceManager is the rpc for services management

func (*ServiceManager) Start

func (sm *ServiceManager) Start(ctx context.Context, req *proto.ServiceRequest) (*proto.StatusResponse, error)

Start a service based on the name. Delete the item from the cache if it had been cached previously

func (*ServiceManager) Stop

func (sm *ServiceManager) Stop(ctx context.Context, req *proto.ServiceRequest) (*proto.StatusResponse, error)

Stop a service based on the name. Cache it if the service is stopped successfully

type StrategyManager

type StrategyManager struct {
	Cache  *cache.Cache
	Logger log.Logger
}

StrategyManager handles recovery of services

func (*StrategyManager) Recover

func (sm *StrategyManager) Recover(ctx context.Context, req *proto.RecoverRequest) (*proto.ResolveResponse, error)

Recover all services that are in the cache (have been stopped). Clean cache for every successful recovery