Class: Textus::Domain::Policy::Source

Inherits:
Object
  • Object
show all
Defined in:
lib/textus/domain/policy/source.rb

Overview

An entry’s data-acquisition declaration (ADR 0094). ‘source:` says HOW the entry’s data is acquired; rendering is a publish concern, so there are no template/render fields here. ‘from` is the acquire + staleness axis:

from: project -> derived  (internal projection; observable -> rdeps staleness)
from: handler -> intake   (external fetch; unobservable -> ttl staleness)
from: command -> external (out-of-band runner; staleness only, textus never runs it)

Materialization is async-only (job-queue model): a write enqueues a ‘materialize` job, converged by a worker. There is no per-entry write trigger knob.

Constant Summary collapse

FROMS = 
%w[project handler command].freeze

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(raw) ⇒ Source

Returns a new instance of Source.



18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
 
# File 'lib/textus/domain/policy/source.rb', line 18

def initialize(raw)
  @from = raw["from"].to_s
  unless FROMS.include?(@from)
    raise Textus::BadManifest.new("source.from must be one of #{FROMS.join("|")}, got #{raw["from"].inspect}")
  end

  @ttl = raw["ttl"]
  @projection = {}

  case @from
  when "project" then init_project(raw)
  when "handler" then init_handler(raw)
  when "command" then init_command(raw)
  end
end

Instance Attribute Details

#command ⇒ Object (readonly)

Returns the value of attribute command.



16
17
18
 
# File 'lib/textus/domain/policy/source.rb', line 16

def command
  @command
end

#config ⇒ Object (readonly)

Returns the value of attribute config.



16
17
18
 
# File 'lib/textus/domain/policy/source.rb', line 16

def config
  @config
end

#from ⇒ Object (readonly)

Returns the value of attribute from.



16
17
18
 
# File 'lib/textus/domain/policy/source.rb', line 16

def from
  @from
end

#handler ⇒ Object (readonly)

Returns the value of attribute handler.



16
17
18
 
# File 'lib/textus/domain/policy/source.rb', line 16

def handler
  @handler
end

#sources ⇒ Object (readonly)

Returns the value of attribute sources.



16
17
18
 
# File 'lib/textus/domain/policy/source.rb', line 16

def sources
  @sources
end

Instance Method Details

#external? ⇒ Boolean

Returns:

  • (Boolean) 


35
 
# File 'lib/textus/domain/policy/source.rb', line 35

def external?   = @from == "command"

#kind ⇒ Object 



34
 
# File 'lib/textus/domain/policy/source.rb', line 34

def kind        = @from == "handler" ? :intake : :derived

#pluck ⇒ Object 



42
 
# File 'lib/textus/domain/policy/source.rb', line 42

def pluck     = @projection["pluck"]

#projection? ⇒ Boolean

Returns:

  • (Boolean) 


36
 
# File 'lib/textus/domain/policy/source.rb', line 36

def projection? = @from == "project"

#projection_spec ⇒ Object

The projection spec hash fed to Textus::Projection (string keys, only the present fields). {} when not a projection.



48
 
# File 'lib/textus/domain/policy/source.rb', line 48

def projection_spec = @projection.dup

#select ⇒ Object

Flattened projection accessors (ADR 0094) — read directly off the source block; nil when absent or not a projection source.



41
 
# File 'lib/textus/domain/policy/source.rb', line 41

def select    = @projection["select"]

#sort_by ⇒ Object 



43
 
# File 'lib/textus/domain/policy/source.rb', line 43

def sort_by   = @projection["sort_by"]

#transform ⇒ Object 



44
 
# File 'lib/textus/domain/policy/source.rb', line 44

def transform = @projection["transform"]

#ttl_seconds ⇒ Object 



37
 
# File 'lib/textus/domain/policy/source.rb', line 37

def ttl_seconds = @ttl.nil? ? nil : Textus::Domain::Duration.seconds(@ttl)