Struct Worker 

pub struct Worker {
    pub repo_root: PathBuf,
    pub state: Arc<AtomicWorkerState>,
    /* private fields */
}

Worker state for a single repository

Fields

repo_root: PathBuf

Repository root path

state: Arc<AtomicWorkerState>

Current lifecycle state

Implementations

impl Worker

pub fn new( repo_root: PathBuf, owner_actor_id: String, rx: Receiver<WorkerMessage>, notify_tx: Sender<Notification>, host_id: String, ipc_endpoint: String, ) -> Result<Self, DaemonError>

Create a new worker

pub fn acquire_lock(&self) -> Result<DaemonLock, DaemonError>

Acquire the daemon lock

pub fn refresh_lock(&self) -> Result<(), DaemonError>

Refresh the daemon lock heartbeat

pub async fn run(self)

Run the worker event loop