class Task::Fetch::Thread::State

• Task::Fetch::Thread::State
• Reference
• Object

Overview

Implements a prioritized queue of nodes on the thread horizon.

Included Modules

• JSON::Serializable

Defined in:

models/task/fetch/thread.cr

Constructors

• .new(pull : JSON::PullParser)
• .new(nodes : Array(Task::Fetch::Thread::State::Node) = [] of Node)

Instance Method Summary

• #<<(node : Node)
• #cache : Array(String) | Nil

  Cached replies.

• #cache=(cache : Array(String) | Nil)

  Cached replies.

• #cached_object : Int64 | Nil

  Object for which replies are cached.

• #cached_object=(cached_object : Int64 | Nil)

  Object for which replies are cached.

• #failures : Int32

  Count of successive failures to fetch new objects.

• #failures=(failures : Int32)

  Count of successive failures to fetch new objects.

• #includes?(node : Node)
• #last_success_at
• #nodes : Array(Node)
• #nodes=(nodes : Array(Node))
• #prioritize!
• #root_object : Int64 | Nil

  Root object of thread.

• #root_object=(root_object : Int64 | Nil)

  Root object of thread.

Constructor Detail

Instance Method Detail