Sha256: ffac3d7a573e1e12035e8da662a670402f58853ba9cb1f8cc7b495f46d9a85d4
Contents?: true
Size: 1.89 KB
Versions: 16
Compression:
Stored size: 1.89 KB
Contents
require 'apipie-params'
require 'algebrick'
require 'thread'
require 'set'
require 'base64'
require 'concurrent'
require 'concurrent-edge'
logger = Logger.new($stderr)
logger.level = Logger::INFO
Concurrent.global_logger = lambda do |level, progname, message = nil, &block|
logger.add level, message, progname, &block
end
# TODO validate in/output, also validate unknown keys
# TODO performance testing, how many actions will it handle?
# TODO profiling, find bottlenecks
# FIND change ids to uuid, uuid-<action_id>, uuid-<action_id-(plan, run, finalize)
module Dynflow
class Error < StandardError
end
require 'dynflow/utils'
require 'dynflow/round_robin'
require 'dynflow/dead_letter_silencer'
require 'dynflow/actor'
require 'dynflow/actors'
require 'dynflow/errors'
require 'dynflow/serializer'
require 'dynflow/serializable'
require 'dynflow/clock'
require 'dynflow/stateful'
require 'dynflow/transaction_adapters'
require 'dynflow/coordinator'
require 'dynflow/persistence'
require 'dynflow/middleware'
require 'dynflow/flows'
require 'dynflow/execution_history'
require 'dynflow/execution_plan'
require 'dynflow/delayed_plan'
require 'dynflow/action'
require 'dynflow/director'
require 'dynflow/executors'
require 'dynflow/logger_adapters'
require 'dynflow/world'
require 'dynflow/connectors'
require 'dynflow/dispatcher'
require 'dynflow/serializers'
require 'dynflow/delayed_executors'
require 'dynflow/semaphores'
require 'dynflow/throttle_limiter'
require 'dynflow/config'
if defined? ::ActiveJob
require 'dynflow/active_job/queue_adapter'
class Railtie < Rails::Railtie
config.before_initialize do
::ActiveJob::QueueAdapters.send(
:include,
Dynflow::ActiveJob::QueueAdapters
)
end
end
end
if defined? Rails
require 'dynflow/rails'
end
end
Version data entries
16 entries across 16 versions & 1 rubygems