class

Task::Fetch::Thread::State

Inherits JSON::Serializable < Reference < Object

Implements a prioritized queue of nodes on the thread horizon.

Constructors

new(pull : JSON::PullParser)
Source
new(nodes : Array(Task::Fetch::Thread::State::Node) = [] of Node)
Source
new(*, __pull_for_json_serializable pull : JSON::PullParser)
Source

Instance methods

<<(node : Node)
Source
cache

Cached replies.

Source
cache=(cache : Array(String) | Nil)

Cached replies.

Source
cached_object

Object for which replies are cached.

Source
cached_object=(cached_object : Int64 | Nil)

Object for which replies are cached.

Source
failures

Count of successive failures to fetch new objects.

Source
failures=(failures : Int32)

Count of successive failures to fetch new objects.

Source
includes?(node : Node)
Source
last_success_at
Source
nodes
Source
nodes=(nodes : Array(Node))
Source
prioritize!
Source
root_object

Root object of thread.

Source
root_object=(root_object : Int64 | Nil)

Root object of thread.

Source

Nested types