Documentation ¶
Index ¶
- type IncomingMachineTask
- type QemuInstanceRegistrationTask
- type QemuInstanceShutdownTask
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶ added in v1.4.1
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)
Click to show internal directories.
Click to hide internal directories.