Crate ringkernel_core 

RingKernel Core

Core traits and types for the RingKernel GPU-native persistent actor system.

This crate provides the foundational abstractions for building GPU-accelerated actor systems with persistent kernels, lock-free message passing, and hybrid logical clocks for temporal ordering.

Core Abstractions

• RingMessage - Trait for messages between kernels
• MessageQueue - Lock-free ring buffer for message passing
• RingKernelRuntime - Backend-agnostic runtime management
• RingContext - GPU intrinsics facade for kernel handlers
• HlcTimestamp - Hybrid Logical Clock for causal ordering

Example

use ringkernel_core::prelude::*;

#[derive(RingMessage)]
struct MyMessage {
    #[message(id)]
    id: MessageId,
    payload: Vec<f32>,
}

Re-exports

pub use context::RingContext;

pub use control::ControlBlock;

pub use domain::Domain;

pub use domain::DomainMessage;

pub use error::Result;

pub use error::RingKernelError;

pub use hlc::HlcTimestamp;

pub use memory::DeviceMemory;

pub use memory::GpuBuffer;

pub use memory::MemoryPool;

pub use memory::PinnedMemory;

pub use message::priority;

pub use message::MessageHeader;

pub use message::MessageId;

pub use message::Priority;

pub use message::RingMessage;

pub use provenance::ProvNodeType;

pub use provenance::ProvRelation;

pub use provenance::ProvRelationKind;

pub use provenance::ProvenanceBuilder;

pub use provenance::ProvenanceError;

pub use provenance::ProvenanceHeader;

pub use queue::MessageQueue;

pub use queue::QueueStats;

pub use runtime::Backend;

pub use runtime::KernelHandle;

pub use runtime::KernelId;

pub use runtime::KernelState;

pub use runtime::KernelStatus;

pub use runtime::LaunchOptions;

pub use runtime::RingKernelRuntime;

pub use telemetry::TelemetryBuffer;

pub use types::BlockId;

pub use types::GlobalThreadId;

pub use types::ThreadId;

pub use types::WarpId;

Modules

actor

GPU Actor Lifecycle Model

alerting

Alert routing system for enterprise monitoring.

analytics_context

Analytics context for grouped buffer lifecycle management.

audit

Audit logging for enterprise security and compliance.

auth

Authentication framework for RingKernel.

backend_stub

Macro for generating unavailable backend stubs.

backpressure

Credit-Based Backpressure & Flow Control — FR-003

checkpoint

Kernel checkpointing for persistent state snapshot and restore.

config

Unified configuration for RingKernel enterprise features.

context

Ring context providing GPU intrinsics facade for kernel handlers.

control

Control block for kernel state management.

dispatcher

Multi-Kernel Message Dispatcher

dlq

Dead Letter Queue — FR-004

domain

Business domain classification for kernel messages.

drain

Graceful Shutdown with Drain Mode — FR-010

error

Error types for RingKernel operations.

health

Health monitoring and resilience infrastructure for RingKernel.

hlc

Hybrid Logical Clock (HLC) implementation for causal ordering.

hot_reload

Configuration Hot Reload — FR-008

hybrid

Hybrid CPU-GPU Processing

idempotency

Message Idempotency & Deduplication — FR-006

introspection

Per-Actor Introspection API — FR-015

k2k

Kernel-to-Kernel (K2K) direct messaging.

logging

Structured logging with trace correlation.

memory

GPU and host memory management abstractions.

memory_pressure

GPU Memory Pressure Handling — FR-005

message

Message types and traits for kernel-to-kernel communication.

multi_gpu

Multi-GPU coordination, topology discovery, and cross-GPU messaging.

observability

Observability infrastructure for RingKernel.

persistent_message

Persistent Message Traits for Type-Based Kernel Dispatch

prelude

Prelude module for convenient imports

provenance

PROV-O provenance attribution for message envelopes.

pubsub

Topic-based publish/subscribe messaging.

queue

Lock-free message queue implementation.

rate_limiting

Rate limiting for enterprise workloads.

rbac

Role-Based Access Control (RBAC) for RingKernel.

reduction

Global Reduction Primitives

registry

Named Actor Registry — FR-002

resource

Resource guard module for preventing system overload.

rules

Hot-swappable compiled rule artifacts.

runtime

Runtime traits and types for kernel management.

runtime_context

Unified runtime context for RingKernel enterprise features.

scheduling

Dynamic Actor Scheduling — Work Stealing Protocol

secrets

Secrets management for secure key storage and retrieval.

security

Security features for GPU kernel protection and compliance.

shutdown

Graceful shutdown and signal handling for persistent GPU kernels.

state

Control block state helpers for GPU-compatible kernel state.

telemetry

Telemetry and metrics collection for kernel monitoring.

telemetry_pipeline

Real-time telemetry pipeline for streaming metrics.

tenancy

Multi-tenancy support for RingKernel.

timeout

Operation-level timeouts and deadline management.

types

Core type definitions for GPU thread identification and coordination.

vector

Vector Store / Embedding Index — FR-013

Macros

gpu_profile

Macro for scoped GPU profiling.

unavailable_backend

Generate a stub runtime for an unavailable backend.