forklaunch 1.34.0

Launch faster with forklaunch
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

use forklaunch_core::domain::BlueprintError;
use forklaunch_core::domain::BlueprintResult;
use forklaunch_worker_database::runner::JobHandler;
use forklaunch_worker_interface::Job;

pub struct ApplicationHandler;

impl JobHandler for ApplicationHandler {
    async fn process(&self, _job: Job) -> BlueprintResult<()> {
        // Install authorization and an acknowledged audit sink before decrypting.
        // Implement idempotent application work here. Return Ok(()) only after
        // that work succeeds. The runner commits the Kafka offset after successful processing.
        Err(BlueprintError::new(
            "worker_handler_not_implemented",
            "Implement handler::ApplicationHandler before consuming jobs",
        ))
    }
}