Documentation
¶
Index ¶
- type BackendOption
- type FileStateManager
- func (fsm *FileStateManager) AddDevice(device *api.DeviceInfo) error
- func (fsm *FileStateManager) AddWorker(worker *api.WorkerInfo) error
- func (fsm *FileStateManager) LoadDevices() (map[string]*api.DeviceInfo, error)
- func (fsm *FileStateManager) LoadWorkers() (map[string]*api.WorkerInfo, error)
- func (fsm *FileStateManager) RemoveDevice(deviceUUID string) error
- func (fsm *FileStateManager) RemoveWorker(workerUID string) error
- func (fsm *FileStateManager) SaveDevices(devices map[string]*api.DeviceInfo) error
- func (fsm *FileStateManager) SaveWorkers(workers map[string]*api.WorkerInfo) error
- func (fsm *FileStateManager) UpdateDevice(device *api.DeviceInfo) error
- type SingleNodeBackend
- func (b *SingleNodeBackend) GetDeviceChangeHandler() framework.DeviceChangeHandler
- func (b *SingleNodeBackend) GetProcessMappingInfo(hostPID uint32) (*framework.ProcessMappingInfo, error)
- func (b *SingleNodeBackend) ListWorkers() []*api.WorkerInfo
- func (b *SingleNodeBackend) RegisterWorkerUpdateHandler(handler framework.WorkerChangeHandler) error
- func (b *SingleNodeBackend) Start() error
- func (b *SingleNodeBackend) StartWorker(worker *api.WorkerInfo) error
- func (b *SingleNodeBackend) Stop() error
- func (b *SingleNodeBackend) StopWorker(workerUID string) error
- func (b *SingleNodeBackend) UpdateWorkerEnv(workerUID string, env map[string]string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BackendOption ¶
type BackendOption func(*SingleNodeBackend)
BackendOption is a functional option for configuring SingleNodeBackend
func WithStateDir ¶
func WithStateDir(stateDir string) BackendOption
WithStateDir sets a custom state directory for the backend
type FileStateManager ¶
type FileStateManager struct {
// contains filtered or unexported fields
}
FileStateManager manages file-based state persistence
func NewFileStateManager ¶
func NewFileStateManager(stateDir string) *FileStateManager
NewFileStateManager creates a new file state manager
func (*FileStateManager) AddDevice ¶
func (fsm *FileStateManager) AddDevice(device *api.DeviceInfo) error
AddDevice adds a device to the state
func (*FileStateManager) AddWorker ¶
func (fsm *FileStateManager) AddWorker(worker *api.WorkerInfo) error
AddWorker adds a worker to the state
func (*FileStateManager) LoadDevices ¶
func (fsm *FileStateManager) LoadDevices() (map[string]*api.DeviceInfo, error)
LoadDevices loads devices from JSON file
func (*FileStateManager) LoadWorkers ¶
func (fsm *FileStateManager) LoadWorkers() (map[string]*api.WorkerInfo, error)
LoadWorkers loads workers from JSON file
func (*FileStateManager) RemoveDevice ¶
func (fsm *FileStateManager) RemoveDevice(deviceUUID string) error
RemoveDevice removes a device from the state
func (*FileStateManager) RemoveWorker ¶
func (fsm *FileStateManager) RemoveWorker(workerUID string) error
RemoveWorker removes a worker from the state
func (*FileStateManager) SaveDevices ¶
func (fsm *FileStateManager) SaveDevices(devices map[string]*api.DeviceInfo) error
SaveDevices saves devices to JSON file
func (*FileStateManager) SaveWorkers ¶
func (fsm *FileStateManager) SaveWorkers(workers map[string]*api.WorkerInfo) error
SaveWorkers saves workers to JSON file
func (*FileStateManager) UpdateDevice ¶
func (fsm *FileStateManager) UpdateDevice(device *api.DeviceInfo) error
UpdateDevice updates a device in the state
type SingleNodeBackend ¶
type SingleNodeBackend struct {
// contains filtered or unexported fields
}
func NewSingleNodeBackend ¶
func NewSingleNodeBackend( ctx context.Context, deviceController framework.DeviceController, allocationController framework.WorkerAllocationController, opts ...BackendOption, ) *SingleNodeBackend
func (*SingleNodeBackend) GetDeviceChangeHandler ¶
func (b *SingleNodeBackend) GetDeviceChangeHandler() framework.DeviceChangeHandler
func (*SingleNodeBackend) GetProcessMappingInfo ¶
func (b *SingleNodeBackend) GetProcessMappingInfo(hostPID uint32) (*framework.ProcessMappingInfo, error)
func (*SingleNodeBackend) ListWorkers ¶
func (b *SingleNodeBackend) ListWorkers() []*api.WorkerInfo
func (*SingleNodeBackend) RegisterWorkerUpdateHandler ¶
func (b *SingleNodeBackend) RegisterWorkerUpdateHandler(handler framework.WorkerChangeHandler) error
func (*SingleNodeBackend) Start ¶
func (b *SingleNodeBackend) Start() error
func (*SingleNodeBackend) StartWorker ¶
func (b *SingleNodeBackend) StartWorker(worker *api.WorkerInfo) error
func (*SingleNodeBackend) Stop ¶
func (b *SingleNodeBackend) Stop() error
func (*SingleNodeBackend) StopWorker ¶
func (b *SingleNodeBackend) StopWorker(workerUID string) error
func (*SingleNodeBackend) UpdateWorkerEnv ¶
func (b *SingleNodeBackend) UpdateWorkerEnv(workerUID string, env map[string]string) error
UpdateWorkerEnv updates environment variables for a worker without restarting its process. The new env vars will take effect on next process restart (crash recovery).
Source Files
Click to show internal directories.
Click to hide internal directories.