rskit/

lib.rs

//! `rskit` — production Rust toolkit.
//!
//! This crate is a pure facade that re-exports `rskit-*` sub-crates from a single namespace.
//! It contains no implementation logic.
//!
//! Always-on foundation crates:
//!
//! | Module | Extra crate |
//! |--------|-------------|
//! | `util` | `rskit-util` (domain-free foundation utilities) |
//! | `errors` | `rskit-errors` (error types and result aliases) |
//! | `fs` | `rskit-fs` (local filesystem primitives) |
//! | `config` | `rskit-config` (adapter-oriented config loading) |
//! | `logging` | `rskit-logging` (`tracing` subscriber setup) |
//! | `resilience` | `rskit-resilience` (retry, timeout, circuit breaker) |
//! | `provider` | `rskit-provider` (provider traits and tower bridge) |
//! | `stream` | `rskit-stream` (broadcaster, sources, tasks, stream operators) |
//! | `bootstrap` | `rskit-bootstrap` (app lifecycle orchestration) |
//! | `component` | `rskit-component` (component lifecycle primitives) |
//! | `worker` | `rskit-worker` (worker pools and typed events) |
//! | `validation` | `rskit-validation` (field-level validation) |
//!
//! Optional feature flags control higher-level modules and adapters:
//!
//! | Feature | Extra crate |
//! |---------|-------------|
//! | `server` | `rskit-server` (service-facing server abstractions) |
//! | `grpc`   | `rskit-grpc` (aligned gRPC client/server transport) |
//! | `encryption` | `rskit-encryption` (encryption helpers) |
//! | `http`   | `rskit-http` (framework-neutral HTTP abstractions) |
//! | `httpclient` | `rskit-httpclient` (bounded HTTP client) |
//! | `auth`   | `rskit-auth` (JWT, OIDC, password) |
//! | `auth-jwt` | JWT support in `rskit-auth` |
//! | `auth-oidc` | OIDC support in `rskit-auth` |
//! | `di`     | `rskit-di` (dependency injection) |
//! | `database` | `rskit-database` (core + memory backend) |
//! | `database-sqlite` | `SQLite` database backend |
//! | `cache`  | `rskit-cache` (core + memory adapter) |
//! | `cache-fs` | Filesystem cache adapter in `rskit-cache` |
//! | `cache-redis` | Redis cache adapter |
//! | `messaging` | `rskit-messaging` (core abstractions + in-memory backend) |
//! | `messaging-kafka` | `Kafka` messaging adapter |
//! | `messaging-nats` | NATS messaging adapter |
//! | `messaging-rabbitmq` | `RabbitMQ` messaging adapter |
//! | `vectorstore` | `rskit-vectorstore` (core + memory backend) |
//! | `vectorstore-qdrant` | Qdrant vector store adapter |
//! | `observability` | `rskit-observability` (OpenTelemetry) |
//! | `authz`  | `rskit-authz` (RBAC/ABAC) |
//! | `security` | `rskit-security` (TLS/security configuration) |
//! | `discovery` | `rskit-discovery` (service discovery) |
//! | `sse`    | `rskit-sse` (Server-Sent Events) |
//! | `dag`    | `rskit-dag` (DAG orchestration) |
//! | `chain`  | `rskit-chain` (sequential execution) |
//! | `process` | `rskit-process` (subprocess execution) |
//! | `fs-watch` | Recursive filesystem change watching (`rskit-fs::watch`, `FsWatcher`) |
//! | `stateful` | `rskit-stateful` (stateful accumulators) |
//! | `version` | `rskit-version` (build metadata) |
//! | `schema` | `rskit-schema` (JSON Schema generation/validation) |
//! | `hook` | `rskit-hook` (typed event hooks) |
//! | `genai` | `rskit-ai` (shared `GenAI` vocabulary) |
//! | `llm`    | `rskit-llm` (LLM providers) |
//! | `llm-openai` | `OpenAI` LLM adapter |
//! | `llm-anthropic` | `Anthropic` LLM adapter |
//! | `llm-ollama` | `Ollama` LLM adapter |
//! | `llm-gemini` | `Gemini` LLM adapter |
//! | `embedding` | `rskit-embedding` (embedding abstractions) |
//! | `inference` | `rskit-inference` (model-serving abstractions) |
//! | `inference-triton` | Triton inference adapter |
//! | `inference-vllm` | vLLM inference adapter |
//! | `inference-tgi` | Hugging Face TGI inference adapter |
//! | `prompt` | Prompt schema helpers from `rskit-ai` |
//! | `skill` | `rskit-skill` (skill manifests and registries) |
//! | `tool` | `rskit-tool` (tool contracts) |
//! | `agent` | `rskit-agent` (agentic turn-loop engine) |
//! | `mcp` | `rskit-mcp` (tool registry to Model Context Protocol bridge) |
//! | `storage` | `rskit-storage` (File I/O, storage) |
//! | `media`  | `rskit-media` (media types, pipeline) |
//! | `media-ffmpeg` | `rskit-media-ffmpeg` (`FFmpeg` backend) |
//! | `media-image`  | `rskit-media-image` (image processing) |
//! | `media-audio`  | `rskit-media-audio` (pure Rust audio analysis) |
//! | `media-full` | `FFmpeg` + image + audio backends |
//! | `storage-s3` | `S3` storage backend |
//! | `storage-gcs` | GCS storage backend |
//! | `storage-supabase` | Supabase storage backend |
//! | `cli`    | `rskit-cli` (CLI helpers) |
//! | `git`    | `rskit-git` (Git automation) |
//! | `dataset` | `rskit-dataset` (dataset collection) |
//! | `bench`  | `rskit-bench` (ML benchmarking) |
//! | `workload` | `rskit-workload` (workload orchestration) |
//! | `full`   | all features |
//!
//! Test helpers live in `rskit-testutil` and should be added directly as a `dev-dependency`;
//! they are intentionally not part of this production facade.
//!
//! # Quick start
//!
//! ```toml
//! [dependencies]
//! rskit-suite = { version = "0.2.0-alpha.2", features = ["full"] }
//! ```
//!
//! Or enable only the optional modules you need — for example recursive,
//! debounced filesystem-tree change watching:
//!
//! ```toml
//! [dependencies]
//! rskit-suite = { version = "0.2.0-alpha.2", features = ["fs-watch"] }
//! ```

#![warn(missing_docs)]

// ── Always-on sub-crate facades ──────────────────────────────────────────────

/// Decoupled, domain-free utilities (strings, collections, env, etc).
pub use rskit_util as util;

/// Error types, `ErrorCode`, `AppError`, `AppResult`.
pub use rskit_errors as errors;

/// Local filesystem primitives.
pub use rskit_fs as fs;

/// Adapter-oriented config loading.
pub use rskit_config as config;

/// `tracing` subscriber setup.
pub use rskit_logging as logging;

/// Retry, circuit breaker, bulkhead, rate limiter — and tower layers.
pub use rskit_resilience as resilience;

/// Provider traits + tower bridge.
pub use rskit_provider as provider;

/// `futures::Stream` extension operators, broadcaster, sources, cancellable tasks.
pub use rskit_stream as stream;

/// App lifecycle orchestration.
pub use rskit_bootstrap as bootstrap;

/// Component lifecycle primitives: `Component`, `Registry`, health, and state.
pub use rskit_component as component;

/// Worker pool, `Handler` trait, typed events.
pub use rskit_worker as worker;

/// Fluent field-level validation.
pub use rskit_validation as validation;

/// Sequential chain execution utilities.
#[cfg(feature = "chain")]
pub use rskit_chain as chain;

/// Safe subprocess execution helpers.
#[cfg(feature = "process")]
pub use rskit_process as process;

/// Stateful accumulators and keyed managers.
#[cfg(feature = "stateful")]
pub use rskit_stateful as stateful;

/// Build-time version and git metadata.
#[cfg(feature = "version")]
pub use rskit_version as version;

/// JSON Schema generation and validation helpers.
#[cfg(feature = "schema")]
pub use rskit_schema as schema;

/// Typed event hook registry and event bus primitives.
#[cfg(feature = "hook")]
pub use rskit_hook as hook;

// ── Feature-gated sub-crate facades ──────────────────────────────────────────

/// Service-facing server abstractions and lifecycle-managed transports.
#[cfg(feature = "server")]
pub use rskit_server as server;

/// Aligned gRPC transport namespace (opt-in via `grpc` feature).
#[cfg(feature = "grpc")]
pub use rskit_grpc as grpc;

/// Encryption helpers (opt-in via `encryption` feature).
#[cfg(feature = "encryption")]
pub use rskit_encryption as encryption;

/// Framework-neutral HTTP abstractions and Tower adapters.
#[cfg(feature = "http")]
pub use rskit_http as http;

/// Async HTTP client with auth, retries, and error handling.
#[cfg(feature = "httpclient")]
pub use rskit_httpclient as httpclient;

/// JWT, OIDC, password hashing, and request-context auth helpers.
#[cfg(feature = "auth")]
pub use rskit_auth as auth;

/// Lightweight runtime dependency injection container.
#[cfg(feature = "di")]
pub use rskit_di as di;

/// Database contracts with in-memory default and adapter registry.
#[cfg(feature = "database")]
pub use rskit_database as database;

/// `SQLite` database backend.
#[cfg(feature = "database-sqlite")]
pub use rskit_database_sqlite as database_sqlite;

/// Cache contracts with in-memory default and adapter registry.
#[cfg(feature = "cache")]
pub use rskit_cache as cache;

/// Redis cache adapter.
#[cfg(feature = "cache-redis")]
pub use rskit_cache_redis as cache_redis;

/// Message broker abstractions and in-memory backend.
#[cfg(feature = "messaging")]
pub use rskit_messaging as messaging;

/// Kafka messaging adapter.
#[cfg(feature = "messaging-kafka")]
pub use rskit_messaging_kafka as messaging_kafka;

/// NATS messaging adapter.
#[cfg(feature = "messaging-nats")]
pub use rskit_messaging_nats as messaging_nats;

/// `RabbitMQ` messaging adapter.
#[cfg(feature = "messaging-rabbitmq")]
pub use rskit_messaging_rabbitmq as messaging_rabbitmq;

/// OpenTelemetry tracing, metrics, and context propagation.
#[cfg(feature = "observability")]
pub use rskit_observability as observability;

/// RBAC and ABAC authorization engine.
#[cfg(feature = "authz")]
pub use rskit_authz as authz;

/// Shared TLS and security configuration.
#[cfg(feature = "security")]
pub use rskit_security as security;

/// Service discovery with load balancing strategies.
#[cfg(feature = "discovery")]
pub use rskit_discovery as discovery;

/// Server-Sent Events bus with axum integration.
#[cfg(feature = "sse")]
pub use rskit_sse as sse;

/// DAG task orchestrator with parallel execution.
#[cfg(feature = "dag")]
pub use rskit_dag as dag;

/// Shared `GenAI` vocabulary.
#[cfg(feature = "genai")]
pub use rskit_ai as genai;

/// LLM provider abstractions and shared chat/completion contracts.
#[cfg(feature = "llm")]
pub use rskit_llm as llm;

/// `OpenAI` LLM adapter.
#[cfg(feature = "llm-openai")]
pub use rskit_llm_openai as llm_openai;

/// Anthropic LLM adapter.
#[cfg(feature = "llm-anthropic")]
pub use rskit_llm_anthropic as llm_anthropic;

/// Ollama LLM adapter.
#[cfg(feature = "llm-ollama")]
pub use rskit_llm_ollama as llm_ollama;

/// Gemini LLM adapter.
#[cfg(feature = "llm-gemini")]
pub use rskit_llm_gemini as llm_gemini;

/// Embedding provider abstractions and types.
#[cfg(feature = "embedding")]
pub use rskit_embedding as embedding;

/// Model-serving runtime inference abstractions.
#[cfg(feature = "inference")]
pub use rskit_inference as inference;

/// Triton `KServe` v2 HTTP inference adapter.
#[cfg(feature = "inference-triton")]
pub use rskit_inference_triton as inference_triton;

/// vLLM REST inference adapter.
#[cfg(feature = "inference-vllm")]
pub use rskit_inference_vllm as inference_vllm;

/// Hugging Face TGI REST inference adapter.
#[cfg(feature = "inference-tgi")]
pub use rskit_inference_tgi as inference_tgi;

/// Prompt templates and output schema contracts.
#[cfg(feature = "prompt")]
pub use rskit_ai::prompt;

/// Skill manifests, loaders, registries, and verification contracts.
#[cfg(feature = "skill")]
pub use rskit_skill as skill;

/// Tool schemas, callable contracts, and metadata wrappers.
#[cfg(feature = "tool")]
pub use rskit_tool as tool;

/// Agentic loop orchestration over providers, tools, and hooks.
#[cfg(feature = "agent")]
pub use rskit_agent as agent;

/// Bridge between the rskit tool registry and Model Context Protocol.
#[cfg(feature = "mcp")]
pub use rskit_mcp as mcp;

/// File I/O, storage backends, MIME detection, temp files.
#[cfg(feature = "storage")]
pub use rskit_storage as storage;

/// Amazon S3 and S3-compatible (`MinIO`, `LocalStack`) storage backend.
#[cfg(feature = "storage-s3")]
pub use rskit_storage_s3 as storage_s3;

/// Google Cloud Storage backend.
#[cfg(feature = "storage-gcs")]
pub use rskit_storage_gcs as storage_gcs;

/// Supabase Storage backend.
#[cfg(feature = "storage-supabase")]
pub use rskit_storage_supabase as storage_supabase;

/// Vector store contracts with in-memory default and adapter registry.
#[cfg(feature = "vectorstore")]
pub use rskit_vectorstore as vectorstore;

/// Qdrant vector store adapter.
#[cfg(feature = "vectorstore-qdrant")]
pub use rskit_vectorstore_qdrant as vectorstore_qdrant;

/// Media types, codec/format registry, pipeline builder.
#[cfg(feature = "media")]
pub use rskit_media as media;

/// `FFmpeg` CLI backend for video/audio processing.
#[cfg(feature = "media-ffmpeg")]
pub use rskit_media_ffmpeg as media_ffmpeg;

/// Native image processing backend using the `image` crate.
#[cfg(feature = "media-image")]
pub use rskit_media_image as media_image;

/// Pure Rust audio analysis backend.
#[cfg(feature = "media-audio")]
pub use rskit_media_audio as media_audio;

/// CLI helpers: progress bars, cancellation tokens, output formatting.
#[cfg(feature = "cli")]
pub use rskit_cli as cli;

/// Git operations: repository management, commits, branches, tags, diffs.
#[cfg(feature = "git")]
pub use rskit_git as git;

/// Dataset collection: sources, transforms, targets, manifest caching.
#[cfg(feature = "dataset")]
pub use rskit_dataset as dataset;

/// ML benchmarking: evaluators, metrics, reports, visualization.
#[cfg(feature = "bench")]
pub use rskit_bench as bench;

/// Provider-based workload orchestration: `Manager`, registry, component.
#[cfg(feature = "workload")]
pub use rskit_workload as workload;

// ── Convenience re-exports at root ──────────────────────────────────────────

pub use rskit_bootstrap::{App, AppBuilder};
pub use rskit_component::{
    Component, Health, HealthStatus, LazyComponent, Registry, RegistryConfig, State, StopResult,
};
pub use rskit_config::{AppConfig, ConfigLoader, ServiceConfig};
pub use rskit_errors::{AppError, AppResult, ErrorCode};
pub use rskit_logging::{LoggingGuard, init_logging, init_logging_env};
pub use rskit_provider::traits::{Provider, RequestResponse, Sink};
pub use rskit_resilience::{CircuitBreaker, RateLimiter, RetryPolicy};
pub use rskit_worker::{Handler, Pool, PoolConfig, TaskHandle};