Method List

Classes Methods Files

Search:

#[] Cosmo::Config
#_busy Cosmo::Web::Controllers::Jobs
#_dead Cosmo::Web::Controllers::Jobs
#_enqueued Cosmo::Web::Controllers::Jobs
#_info Cosmo::Web::Controllers::Streams
#_scheduled Cosmo::Web::Controllers::Jobs
#_stats Cosmo::Web::Controllers::Jobs
#_table Cosmo::Web::Controllers::Streams
#add Cosmo::API::Busy
all Cosmo::API::Stream
#as_json Cosmo::Job::Data
banner Cosmo::CLI
#binding Cosmo::Web::Context
busy Cosmo::API::Stats
#busy Cosmo::Web::Controllers::Jobs
call Cosmo::Web
#call Cosmo::Web
#call Cosmo::Logger::SimpleFormatter
#clean Cosmo::API::KV
client Cosmo::API::Stream
#close Cosmo::Client
#consumer_info Cosmo::Client
#consumer_sequence Cosmo::Stream::Message
#content_for Cosmo::Web::Context
#content_for Cosmo::Web::Controllers::Application
#content_for? Cosmo::Web::Context
#count Cosmo::API::KV
#create_stream Cosmo::Client
current Cosmo::Logger::Context
#current_page? Cosmo::Web::Helpers::Application
#data Cosmo::API::Job
#data Cosmo::Stream::Message
dead Cosmo::API::Stats
#dead Cosmo::Web::Controllers::Jobs
#decrement Cosmo::API::Counter
#default_options Cosmo::Job::ClassMethods
#default_options Cosmo::Stream::ClassMethods
#delete Cosmo::API::KV
#delete Cosmo::API::Busy
#delete Cosmo::API::Stream
#delete Cosmo::Web::Controllers::Jobs
#delete_message Cosmo::Client
#delete_stream Cosmo::Client
deliver_policy Cosmo::Config
deserialize Cosmo::Stream::Serializer
#dig Cosmo::Config
dump Cosmo::Utils::Json
dup Cosmo::Utils::Hash
#each Cosmo::API::Stream
#elapsed Cosmo::Web::Helpers::Application
#elapsed_millis Cosmo::Utils::Stopwatch
#elapsed_seconds Cosmo::Utils::Stopwatch
enqueued Cosmo::API::Stats
#enqueued Cosmo::Web::Controllers::Jobs
#execute_at Cosmo::API::Job
failed Cosmo::API::Stats
#fetch Cosmo::Config
#format_bytes Cosmo::Web::Helpers::Application
#format_numbers Cosmo::Web::Helpers::Application
#format_timestamp Cosmo::Web::Helpers::Application
#get Cosmo::API::KV
#get Cosmo::API::Counter
#get_message Cosmo::Client
#h Cosmo::Web::Helpers::Application
#headers Cosmo::API::Job
#hx_request? Cosmo::Web::Controllers::Application
included Cosmo::Job
included Cosmo::Stream
#increment Cosmo::API::Counter
#index Cosmo::Web::Controllers::Jobs
#index Cosmo::Web::Controllers::Actions
#index Cosmo::Web::Controllers::Streams
#info Cosmo::API::Stream
#info Cosmo::Web::Controllers::Streams
#initialize Cosmo::ConfigNotFoundError
#initialize Cosmo::StreamNotFoundError
#initialize Cosmo::API::KV
#initialize Cosmo::Client
#initialize Cosmo::Config
#initialize Cosmo::Engine
#initialize Cosmo::API::Job
#initialize Cosmo::API::Busy
#initialize Cosmo::Job::Data
#initialize Cosmo::Processor
#initialize Cosmo::Publisher
#initialize Cosmo::API::Stream
#initialize Cosmo::API::Counter
#initialize Cosmo::Web::Context
#initialize Cosmo::Utils::Signal
#initialize Cosmo::Job::Processor
#initialize Cosmo::Stream::Message
#initialize Cosmo::Utils::Stopwatch
#initialize Cosmo::Stream::Processor
#initialize Cosmo::Utils::ThreadPool
#initialize Cosmo::Web::Controllers::Application
instance Cosmo::CLI
instance Cosmo::Client
instance Cosmo::Config
instance Cosmo::Engine
instance Cosmo::Logger
instance Cosmo::API::Busy
instance Cosmo::Publisher
instance Cosmo::API::Counter
instance= Cosmo::Logger
#jid Cosmo::Job
#jid Cosmo::Job::Data
jobs Cosmo::API::Stream
#js Cosmo::Client
#keys Cosmo::API::KV
keys? Cosmo::Utils::Hash
#kv Cosmo::Client
#list Cosmo::API::Busy
#list_consumers Cosmo::Client
#list_streams Cosmo::Client
#load Cosmo::Config
#logger Cosmo::Job
#logger Cosmo::Stream
merge Cosmo::Utils::Hash
#message Cosmo::Stream
#message Cosmo::API::Job
#message Cosmo::API::Stream
#messages Cosmo::API::Stream
#name Cosmo::API::Stream
#nc Cosmo::Client
#no_content Cosmo::Web::Renderer
normalize! Cosmo::Config
#not_found Cosmo::Web::Renderer
#offset Cosmo::API::Stream
#ok Cosmo::Web::Renderer
#options Cosmo::Job::ClassMethods
#options Cosmo::Stream::ClassMethods
#params Cosmo::Web::Controllers::Application
parse Cosmo::Utils::Json
parse_file Cosmo::Config
#path Cosmo::Web::Controllers::Application
#perform Cosmo::Job::ClassMethods
#perform Cosmo::Job
#perform_async Cosmo::Job::ClassMethods
#perform_at Cosmo::Job::ClassMethods
#perform_in Cosmo::Job::ClassMethods
#perform_sync Cosmo::Job::ClassMethods
#pid Cosmo::Logger::BaseFormatter
#post Cosmo::Utils::ThreadPool
#process Cosmo::Stream
#process_one Cosmo::Stream
processed Cosmo::API::Stats
#publish Cosmo::Client
#publish Cosmo::Stream::ClassMethods
#publish Cosmo::Stream
#publish Cosmo::Publisher
#publish_batch Cosmo::Publisher
#publish_job Cosmo::Publisher
#purge Cosmo::API::KV
#purge Cosmo::Client
#push Cosmo::Utils::Signal
#redirect_to Cosmo::Web::Renderer
#referrer? Cosmo::Web::Helpers::Application
#register Cosmo::Stream::ClassMethods
#render Cosmo::Web::Controllers::Application
#reset Cosmo::API::Counter
#reset Cosmo::Utils::Stopwatch
retries Cosmo::API::Stats
#retries Cosmo::API::Stream
#retry Cosmo::API::Stream
#retry Cosmo::Web::Controllers::Jobs
run Cosmo::CLI
#run Cosmo::CLI
run Cosmo::Engine
#run Cosmo::Engine
run Cosmo::Processor
#run Cosmo::Processor
safe_constantize Cosmo::Utils::String
scheduled Cosmo::API::Stats
#scheduled Cosmo::Web::Controllers::Jobs
#seq Cosmo::API::Job
serialize Cosmo::Stream::Serializer
#serve Cosmo::Web::Renderer
#set Cosmo::API::KV
#set Cosmo::Config
set Cosmo::Utils::Hash
#shutdown Cosmo::Engine
silence Cosmo::Utils::Warnings
#size Cosmo::API::Busy
#stop Cosmo::Job::Processor
#stream Cosmo::API::Job
#stream Cosmo::Job::Data
#stream_info Cosmo::Client
#stream_sequence Cosmo::Stream::Message
#subject Cosmo::API::Job
#subject Cosmo::Job::Data
#subscribe Cosmo::Client
summary Cosmo::API::Stats
symbolize_keys! Cosmo::Utils::Hash
system Cosmo::Config
#tid Cosmo::Logger::BaseFormatter
#time_until Cosmo::Web::Helpers::Application
#timestamp Cosmo::API::Job
#to_args Cosmo::Job::Data
#to_h Cosmo::Config
#to_json Cosmo::Job::Data
#total Cosmo::API::Stream
trap Cosmo::Utils::Signal
#u Cosmo::Web::Helpers::Application
underscore Cosmo::Utils::String
#url_for Cosmo::Web::Renderer
#wait Cosmo::Utils::Signal
with Cosmo::Logger::Context
with Cosmo::Logger
#with Cosmo::API::Busy
#with Cosmo::API::Counter
without Cosmo::Logger::Context
without Cosmo::Logger
#x_stream Cosmo::API::Job
#x_subject Cosmo::API::Job