hero.processor #

enum ErrorReason {
	timeout
	serialization_failed
	deserialization_failed
	enqueue_failed
}

Enum for different error reasons

struct ProcedureCall {
pub:
	method string // Method name (derived from OpenAPI path)
	params string // Parameters for the procedure
}

ProcedureCall struct representing a procedure invocation

struct ProcedureError {
	reason ErrorReason
}

ProcedureError struct for error handling

fn (err ProcedureError) code() int

fn (err ProcedureError) msg() string

struct ProcedureResponse {
pub:
	result string // Response data
	error  string // Internal error message (if any)
}

ProcedureResponse struct representing the result of a procedure call

struct ProcessParams {
pub:
	timeout int // Timeout in seconds
}

Parameters for processing a procedure call

struct Processor {
pub mut:
	rpc redisclient.RedisRpc // Redis RPC mechanism
}

Processor struct for managing procedure calls

fn (mut p Processor) process(call ProcedureCall, params ProcessParams) !ProcedureResponse

Process the procedure call