arachne::coordination Namespace Reference

Namespaces
namespace	anonymous_namespace{coordinator.cpp}

Classes
struct	intake_request
struct	envelope_record
struct	state_event
struct	accumulation_policy
struct	accumulation_state
struct	verification_issue
class	operational_ledger
class	domain_lock

Enumerations
enum class	cocoon_status {   received , needs_format_fix , waiting_approval , accepted ,   waiting_processing , processing , integrated , failed ,   rejected , superseded }

Functions
std::string_view	to_string (const cocoon_status status) noexcept
cocoon_status	cocoon_status_from_string (const std::string_view value)
bool	can_transition (const cocoon_status from, const cocoon_status to) noexcept
bool	path_is_within (const std::filesystem::path &path, const std::filesystem::path &possible_parent)
void	reject_inbox_deletion_target (const std::filesystem::path &target, const std::filesystem::path &inbox_root)

Enumeration Type Documentation

cocoon_status

enum class arachne::coordination::cocoon_status

strong

Enumerator
received
needs_format_fix
waiting_approval
accepted
waiting_processing
processing
integrated
failed
rejected
superseded

Definition at line 14 of file coordinator.hpp.

                         {
    received,
    needs_format_fix,
    waiting_approval,
    accepted,
    waiting_processing,
    processing,
    integrated,
    failed,
    rejected,
    superseded,
};

Function Documentation

can_transition()

bool arachne::coordination::can_transition ( const cocoon_status from, const cocoon_status to )

nodiscardnoexcept

Definition at line 535 of file coordinator.cpp.

                                                                               {
    switch (from) {
    case cocoon_status::received:
        return to == cocoon_status::needs_format_fix
            || to == cocoon_status::waiting_approval;
    case cocoon_status::needs_format_fix:
        return to == cocoon_status::superseded;
    case cocoon_status::waiting_approval:
        return to == cocoon_status::accepted || to == cocoon_status::rejected;
    case cocoon_status::accepted:
        return to == cocoon_status::waiting_processing
            || to == cocoon_status::superseded;
    case cocoon_status::waiting_processing:
        return to == cocoon_status::processing
            || to == cocoon_status::superseded;
    case cocoon_status::processing:
        return to == cocoon_status::integrated || to == cocoon_status::failed;
    case cocoon_status::failed:
        return to == cocoon_status::waiting_processing
            || to == cocoon_status::superseded;
    case cocoon_status::integrated:
        return to == cocoon_status::superseded;
    case cocoon_status::rejected:
    case cocoon_status::superseded:
        return false;
    }
    return false;
}

References accepted, failed, integrated, needs_format_fix, processing, received, rejected, superseded, waiting_approval, and waiting_processing.

cocoon_status_from_string()

cocoon_status arachne::coordination::cocoon_status_from_string ( const std::string_view value )

nodiscard

Definition at line 519 of file coordinator.cpp.

                                                                    {
    constexpr std::array statuses {
        cocoon_status::received,           cocoon_status::needs_format_fix,
        cocoon_status::waiting_approval,   cocoon_status::accepted,
        cocoon_status::waiting_processing, cocoon_status::processing,
        cocoon_status::integrated,         cocoon_status::failed,
        cocoon_status::rejected,           cocoon_status::superseded,
    };
    for (const auto status : statuses) {
        if (to_string(status) == value) {
            return status;
        }
    }
    throw std::invalid_argument("unknown cocoon status: " + std::string(value));
}

path_is_within()

bool arachne::coordination::path_is_within ( const std::filesystem::path & path, const std::filesystem::path & possible_parent )

nodiscard

Definition at line 1542 of file coordinator.cpp.

                                            {
            throw std::logic_error(
                "running product run changed during completion"

reject_inbox_deletion_target()

void arachne::coordination::reject_inbox_deletion_target	(	const std::filesystem::path &	target,
		const std::filesystem::path &	inbox_root )

Definition at line 1558 of file coordinator.cpp.

                                                                             {
            throw_sqlite(database, "bind product run attempt number");

to_string()

std::string_view arachne::coordination::to_string ( const cocoon_status status )

nodiscardnoexcept

Definition at line 493 of file coordinator.cpp.

                                                              {
    switch (status) {
    case cocoon_status::received:
        return "received";
    case cocoon_status::needs_format_fix:
        return "needs_format_fix";
    case cocoon_status::waiting_approval:
        return "waiting_approval";
    case cocoon_status::accepted:
        return "accepted";
    case cocoon_status::waiting_processing:
        return "waiting_processing";
    case cocoon_status::processing:
        return "processing";
    case cocoon_status::integrated:
        return "integrated";
    case cocoon_status::failed:
        return "failed";
    case cocoon_status::rejected:
        return "rejected";
    case cocoon_status::superseded:
        return "superseded";
    }
    return "received";
}

References accepted, failed, integrated, needs_format_fix, processing, received, rejected, superseded, waiting_approval, and waiting_processing.