v1

package

v0.0.0-...-ccb0926 Latest Latest Go to latest Published: Dec 16, 2020 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

DockerManager is the rpc for docker management

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 (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 struct {
}

HealthCheckService is the rpc

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

Check the health of the slave

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

Watch is not used at the moment

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

ServiceManager is the rpc for services management

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 (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 struct {
	Cache  *cache.Cache
	Logger log.Logger
}

StrategyManager handles recovery of services

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