class Tasko::MemoryEngine

Included Modules

Defined in:

tasko/memory_engine.cr

Constructors

Instance Method Summary

Instance methods inherited from module Tasko::NaivePollingScheduler

done? : Bool done?, execute_task(task : Key) : Nil execute_task, prepare(application : Application) : Nil prepare, receive_task? : Key | Nil receive_task?, run(application : Application, exit_on_done : Bool) : Nil run

Instance methods inherited from module Tasko::UUIDTaskKeys

create_task_key : Key create_task_key

Instance methods inherited from module Tasko::JSONTaskSerialization

deserialize_data(serialized : String, as type : Class) deserialize_data, serialize_data(data : D) : String forall D serialize_data

Instance methods inherited from class Tasko::Engine

create_task_key : Key create_task_key, deserialize_data(serialized : String, as type : Class) deserialize_data, mark_as_completed(task : Key) : Nil mark_as_completed, run(application : Application, exit_on_done : Bool) : Nil run, serialize_data(data : D) : String forall D serialize_data, stats : Array(TaskStats) stats, store : KVStore store, submit_changeset(changeset : Changeset, current_task_key : Key | Nil) submit_changeset, tasks_dependencies(task : Key) : Array(Key) tasks_dependencies

Constructor Detail

def self.new #

[View source]

Instance Method Detail

def application : Application #

[View source]
def application? : Application | Nil #

[View source]
def done? : Bool #

[View source]
def execute_task(task : Key) : Nil #

[View source]
def mark_as_completed(task : Key) : Nil #

[View source]
def prepare(application : Application) : Nil #

[View source]
def receive_task? : Key | Nil #

[View source]
def stats : Array(TaskStats) #
Description copied from class Tasko::Engine

Optional


[View source]
def store_protocol : Tasko::KVStore::Protocol #

[View source]
def store_protocol? : Tasko::KVStore::Protocol | Nil #

[View source]
def submit_changeset(changeset : Changeset, current_task_key : Key | Nil) #

[View source]
def tasks_dependencies(task : Key) : Array(Key) #

[View source]