services

Documentation

Index

• func Register(s grpcserver.Registration)
• func Services() []grpcserver.Registration
• type ServiceServer
  • func (s *ServiceServer) ActivateDiskBackendProxy(vmname, diskname string) error
  • func (s *ServiceServer) DeactivateDiskBackendProxy(vmname, diskname string) error
  • func (s *ServiceServer) GetMachine(vmname string) (*kvmrun.Machine, error)
  • func (s *ServiceServer) GetMachineLifeTime(vm *kvmrun.Machine) (time.Duration, error)
  • func (s *ServiceServer) GetMachineNames() ([]string, error)
  • func (s *ServiceServer) GetMachineStatus(vm *kvmrun.Machine) (kvmrun.InstanceState, error)
  • func (s *ServiceServer) LookForFile(basename string, dirs ...string) (string, string, error)
  • func (s *ServiceServer) MachineDownFile(vmname string) string
  • func (s *ServiceServer) MachineToUnit(vmname string) string
  • func (s *ServiceServer) ProxyToUnit(vmname, diskname string) string
  • func (s *ServiceServer) RunFuncTask(ctx context.Context, v string, fn func(*log.Entry) error) error
  • func (s *ServiceServer) StartTask(ctx context.Context, t task.Task, resp interface{}) (string, error)

Functions

func Register

func Register(s grpcserver.Registration)

func Services

func Services() []grpcserver.Registration

Types

type ServiceServer

type ServiceServer struct {
	AppConf   *appconf.KvmrunConfig
	SystemCtl *systemd.Manager
	Mon       *monitor.Pool
	Tasks     *task.Pool
}

func (*ServiceServer) ActivateDiskBackendProxy

func (s *ServiceServer) ActivateDiskBackendProxy(vmname, diskname string) error

func (*ServiceServer) DeactivateDiskBackendProxy

func (s *ServiceServer) DeactivateDiskBackendProxy(vmname, diskname string) error

func (*ServiceServer) GetMachine

func (s *ServiceServer) GetMachine(vmname string) (*kvmrun.Machine, error)

func (*ServiceServer) GetMachineLifeTime

func (s *ServiceServer) GetMachineLifeTime(vm *kvmrun.Machine) (time.Duration, error)

func (*ServiceServer) GetMachineNames

func (s *ServiceServer) GetMachineNames() ([]string, error)

func (*ServiceServer) GetMachineStatus

func (s *ServiceServer) GetMachineStatus(vm *kvmrun.Machine) (kvmrun.InstanceState, error)

func (*ServiceServer) LookForFile

func (s *ServiceServer) LookForFile(basename string, dirs ...string) (string, string, error)

func (*ServiceServer) MachineDownFile

func (s *ServiceServer) MachineDownFile(vmname string) string

func (*ServiceServer) MachineToUnit

func (s *ServiceServer) MachineToUnit(vmname string) string

func (*ServiceServer) ProxyToUnit

func (s *ServiceServer) ProxyToUnit(vmname, diskname string) string

func (*ServiceServer) RunFuncTask

func (s *ServiceServer) RunFuncTask(ctx context.Context, v string, fn func(*log.Entry) error) error

func (*ServiceServer) StartTask

func (s *ServiceServer) StartTask(ctx context.Context, t task.Task, resp interface{}) (string, error)