orchestrator_core 0.1.0 copy "orchestrator_core: ^0.1.0" to clipboard
orchestrator_core: ^0.1.0 copied to clipboard

Published 25 days ago • Latest: 0.5.2
[unknown platforms]
→

Metadata

Event-Driven Orchestrator architecture for Dart/Flutter. Separate UI state management from business logic execution with SignalBus and Dispatcher pattern.

More...

Changelog #

All notable changes to this project will be documented in this file.

0.1.0 - 2025-12-25 #

Features: Unified Data Flow & Caching #

  • New: Unified Data Flow architecture supporting Placeholder -> Cache (SWR) -> Process -> Cache Write.
  • New: DataStrategy configuration for Jobs.
    • placeholder: Emit temporary data immediately (Skeleton UI).
    • cachePolicy: Configure caching behavior (TTL, Key, Revalidate, Force Refresh).
  • New: 3 Ways of Cache Management:
    1. Config: CachePolicy(forceRefresh: true) for Pull-to-Refresh.
    2. Utility: InvalidateCacheJob for system-wide clearing (e.g. Logout).
    3. Side-Effect: Methods invalidateKey / invalidateMatching in BaseExecutor.
  • New: CacheProvider interface with default InMemoryCacheProvider.
  • New: Events JobPlaceholderEvent and JobCacheHitEvent.

0.0.3 - 2024-12-24 #

Architecture (Scoped Bus) #

  • New: Support Scoped Bus for isolated module communication.
    • Create isolated bus: SignalBus.scoped().
    • Access global bus: SignalBus.instance.
    • Inject bus into Orchestrator: MyOrchestrator(bus: myScopedBus).
  • Breaking Change: BaseJob is no longer const / @immutable.
    • Added SignalBus? bus field to BaseJob for explicit context tracking.
    • This allows Executors to automatically route events to the correct bus without hidden magic.
  • Improved: BaseExecutor now dynamically resolves the target bus based on the Job's context.

0.0.2 - 2024-12-24 #

Added #

  • Safety: Smart Circuit Breaker (Loop Protection by Event Type)
    • Prevent infinite loops by blocking specific looping events
    • Default limit: 50 events/sec (configurable globally)
    • New: Support per-type limit override via OrchestratorConfig.setTypeLimit<T>(limit)
    • Self-healing every 1 second
  • Safety: Type Safety Isolation (try-catch in event handlers)
  • Safety / Casting: JobSuccessEvent.dataAs<T>() for safe data casting
  • UI Helper: BaseOrchestrator.isJobTypeRunning<T>() to prevent UI race conditions
  • Config: Added OrchestratorConfig.maxEventsPerSecond

0.0.1 - 2024-12-24 #

Added #

  • Initial release
  • BaseJob and BaseEvent models
  • SignalBus - Singleton broadcast stream for event communication
  • Dispatcher - Type-based job routing with O(1) lookup
  • BaseExecutor - Abstract executor with error boundary, timeout, retry, cancellation
  • BaseOrchestrator - State machine with Active/Passive event routing
  • CancellationToken - Token-based task cancellation
  • RetryPolicy - Configurable retry with exponential backoff
  • OrchestratorLogger - Flexible logging system

← Metadata

0
likes
0
points
990
downloads

Publisher

unverified uploader

Weekly Downloads

Metadata

Event-Driven Orchestrator architecture for Dart/Flutter. Separate UI state management from business logic execution with SignalBus and Dispatcher pattern.

Repository (GitHub)
View/report issues

Topics

#state-management #architecture #event-driven #orchestrator #bloc

Documentation

Documentation

License

unknown (license)

Dependencies

meta

More

Packages that depend on orchestrator_core

Back