system

Documentation

Index

• type IncomingMachineTask
  • func NewIncomingMachineTask(req *pb.StartIncomingMachineRequest, ss *services.ServiceServer) *IncomingMachineTask
  • func (t *IncomingMachineTask) BeforeStart(resp interface{}) error
  • func (t *IncomingMachineTask) GetKey() string
  • func (t *IncomingMachineTask) GetNS() string
  • func (t *IncomingMachineTask) Main() error
  • func (t *IncomingMachineTask) OnFailure() error
  • func (t *IncomingMachineTask) OnSuccess() error
• type QemuInstanceRegistrationTask
  • func NewQemuInstanceRegistrationTask(req *pb.RegisterQemuInstanceRequest, ss *services.ServiceServer) *QemuInstanceRegistrationTask
  • func (t *QemuInstanceRegistrationTask) GetKey() string
  • func (t *QemuInstanceRegistrationTask) GetNS() string
  • func (t *QemuInstanceRegistrationTask) Main() error
• type QemuInstanceShutdownTask
  • func NewQemuInstanceShutdownTask(req *pb.StopQemuInstanceRequest, ss *services.ServiceServer) *QemuInstanceShutdownTask
  • func (t *QemuInstanceShutdownTask) GetKey() string
  • func (t *QemuInstanceShutdownTask) GetNS() string
  • func (t *QemuInstanceShutdownTask) Main() error
• type ServiceServer
  • func (s *ServiceServer) GracefulShutdown(ctx context.Context, _ *empty.Empty) (*empty.Empty, error)
  • func (s *ServiceServer) Init(inner *services.ServiceServer)
  • func (s *ServiceServer) Name() string
  • func (s *ServiceServer) Register(server *grpc.Server)
  • func (s *ServiceServer) RegisterQemuInstance(ctx context.Context, req *pb.RegisterQemuInstanceRequest) (*pb.RegisterQemuInstanceResponse, error)
  • func (s *ServiceServer) StartDiskBackendProxy(ctx context.Context, req *pb.DiskBackendProxyRequest) (*empty.Empty, error)
  • func (s *ServiceServer) StartIncomingMachine(ctx context.Context, req *pb.StartIncomingMachineRequest) (*pb.StartIncomingMachineResponse, error)
  • func (s *ServiceServer) StopDiskBackendProxy(ctx context.Context, req *pb.DiskBackendProxyRequest) (*empty.Empty, error)
  • func (s *ServiceServer) StopQemuInstance(ctx context.Context, req *pb.StopQemuInstanceRequest) (*empty.Empty, error)
  • func (s *ServiceServer) UnregisterQemuInstance(ctx context.Context, req *pb.UnregisterQemuInstanceRequest) (*empty.Empty, error)

Types

type IncomingMachineTask

type IncomingMachineTask struct {
	*task.GenericTask
	*services.ServiceServer
	// contains filtered or unexported fields
}

func NewIncomingMachineTask

func NewIncomingMachineTask(req *pb.StartIncomingMachineRequest, ss *services.ServiceServer) *IncomingMachineTask

func (*IncomingMachineTask) BeforeStart

func (t *IncomingMachineTask) BeforeStart(resp interface{}) error

func (*IncomingMachineTask) GetKey

func (t *IncomingMachineTask) GetKey() string

func (*IncomingMachineTask) GetNS

func (t *IncomingMachineTask) GetNS() string

func (*IncomingMachineTask) Main

func (t *IncomingMachineTask) Main() error

func (*IncomingMachineTask) OnFailure

func (t *IncomingMachineTask) OnFailure() error

func (*IncomingMachineTask) OnSuccess

func (t *IncomingMachineTask) OnSuccess() error

type QemuInstanceRegistrationTask

type QemuInstanceRegistrationTask struct {
	*task.GenericTask
	*services.ServiceServer
	// contains filtered or unexported fields
}

func NewQemuInstanceRegistrationTask

func NewQemuInstanceRegistrationTask(req *pb.RegisterQemuInstanceRequest, ss *services.ServiceServer) *QemuInstanceRegistrationTask

func (*QemuInstanceRegistrationTask) GetKey

func (t *QemuInstanceRegistrationTask) GetKey() string

func (*QemuInstanceRegistrationTask) GetNS

func (t *QemuInstanceRegistrationTask) GetNS() string

func (*QemuInstanceRegistrationTask) Main

func (t *QemuInstanceRegistrationTask) Main() error

type QemuInstanceShutdownTask

type QemuInstanceShutdownTask struct {
	*task.GenericTask
	*services.ServiceServer
	// contains filtered or unexported fields
}

func NewQemuInstanceShutdownTask

func NewQemuInstanceShutdownTask(req *pb.StopQemuInstanceRequest, ss *services.ServiceServer) *QemuInstanceShutdownTask

func (*QemuInstanceShutdownTask) GetKey

func (t *QemuInstanceShutdownTask) GetKey() string

func (*QemuInstanceShutdownTask) GetNS

func (t *QemuInstanceShutdownTask) GetNS() string

func (*QemuInstanceShutdownTask) Main

func (t *QemuInstanceShutdownTask) Main() error

type ServiceServer

type ServiceServer struct {
	*services.ServiceServer
}

func (*ServiceServer) GracefulShutdown

func (s *ServiceServer) GracefulShutdown(ctx context.Context, _ *empty.Empty) (*empty.Empty, error)

func (*ServiceServer) Init

func (s *ServiceServer) Init(inner *services.ServiceServer)

func (*ServiceServer) Name

func (s *ServiceServer) Name() string

func (*ServiceServer) Register

func (s *ServiceServer) Register(server *grpc.Server)

func (*ServiceServer) RegisterQemuInstance

func (s *ServiceServer) RegisterQemuInstance(ctx context.Context, req *pb.RegisterQemuInstanceRequest) (*pb.RegisterQemuInstanceResponse, error)

func (*ServiceServer) StartDiskBackendProxy

func (s *ServiceServer) StartDiskBackendProxy(ctx context.Context, req *pb.DiskBackendProxyRequest) (*empty.Empty, error)

func (*ServiceServer) StartIncomingMachine

func (s *ServiceServer) StartIncomingMachine(ctx context.Context, req *pb.StartIncomingMachineRequest) (*pb.StartIncomingMachineResponse, error)

func (*ServiceServer) StopDiskBackendProxy

func (s *ServiceServer) StopDiskBackendProxy(ctx context.Context, req *pb.DiskBackendProxyRequest) (*empty.Empty, error)

func (*ServiceServer) StopQemuInstance

func (s *ServiceServer) StopQemuInstance(ctx context.Context, req *pb.StopQemuInstanceRequest) (*empty.Empty, error)

func (*ServiceServer) UnregisterQemuInstance

func (s *ServiceServer) UnregisterQemuInstance(ctx context.Context, req *pb.UnregisterQemuInstanceRequest) (*empty.Empty, error)