Class: Riak::WalkSpec

Inherits:
Object show all
Extended by:
Util::Translation
Includes:
Util::Escape, Util::Translation
Defined in:
lib/riak/walk_spec.rb

Overview

The specification of how to follow links from one object to another in Riak, when using the link-walker resource. Example link-walking operation:

GET /riak/artists/REM/albums,_,_/tracks,_,1

This operation would have two WalkSpecs:

Riak::WalkSpec.new({:bucket => 'albums'})
Riak::WalkSpec.new({:bucket => 'tracks', :result => true})

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Methods included from Util::Translation

i18n_scope, t

Methods included from Util::Escape

#escape, #maybe_escape, #maybe_unescape, #unescape

Constructor Details

#initialize(hash) ⇒ WalkSpec #initialize(bucket, tag, keep) ⇒ WalkSpec

Creates a walk-spec for use in finding other objects in Riak.

Overloads:

  • #initialize(hash) ⇒ WalkSpec

    Creates a walk-spec from a hash.

    Parameters:

    • hash (Hash)

      options for the walk-spec

    Options Hash (hash):

    • :bucket (String) — default: "_"

      the bucket the links should point to (default '_' is all)

    • :tag (String) — default: "_"

      the tag to filter links by (default '_' is all)

    • :keep (Boolean) — default: false

      whether to return results from following this link specification

  • #initialize(bucket, tag, keep) ⇒ WalkSpec

    Creates a walk-spec from a bucket-tag-result triple.

    Parameters:

    • bucket (String)

      the bucket the links should point to (default '_' is all)

    • tag (String)

      the tag to filter links by (default '_' is all)

    • keep (Boolean)

      whether to return results from following this link specification

See Also:

  • Riak::WalkSpec.{Riak{Riak::RObject{Riak::RObject#walk}


66
67
68
69
70
71
72
73
74
75
76
77
78
# File 'lib/riak/walk_spec.rb', line 66

def initialize(*args)
  args.flatten!
  case args.size
  when 1
    hash = args.first
    raise ArgumentError, t("hash_type", :hash => hash.inspect) unless Hash === hash
    assign(hash[:bucket], hash[:tag], hash[:keep])
  when 3
    assign(*args)
  else
    raise ArgumentError, t("wrong_argument_count_walk_spec")
  end
end

Instance Attribute Details

#bucketString

Returns The bucket followed links should be restricted to. “_” represents all buckets.

Returns:

  • (String)

    The bucket followed links should be restricted to. “_” represents all buckets.



23
24
25
# File 'lib/riak/walk_spec.rb', line 23

def bucket
  @bucket
end

#keepBoolean

Returns Whether objects should be returned from this phase of link walking. Default is false.

Returns:

  • (Boolean)

    Whether objects should be returned from this phase of link walking. Default is false.



29
30
31
# File 'lib/riak/walk_spec.rb', line 29

def keep
  @keep
end

#tagString

Returns The “riaktag” or “rel” that followed links should be restricted to. “_” represents all tags.

Returns:

  • (String)

    The “riaktag” or “rel” that followed links should be restricted to. “_” represents all tags.



26
27
28
# File 'lib/riak/walk_spec.rb', line 26

def tag
  @tag
end

Class Method Details

.normalize(*params) ⇒ Object

Normalize a list of walk specs into WalkSpec objects.



32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
# File 'lib/riak/walk_spec.rb', line 32

def self.normalize(*params)
  params.flatten!
  specs = []
  while params.length > 0
    param = params.shift
    case param
    when Hash
      specs << new(param)
    when WalkSpec
      specs << param
    else
      if params.length >= 2
        specs << new(param, params.shift, params.shift)
      else
        raise ArgumentError, t("too_few_arguments", :params => params.inspect)
      end
    end
  end
  specs
end

Instance Method Details

#==(other) ⇒ Object



87
88
89
# File 'lib/riak/walk_spec.rb', line 87

def ==(other)
  other.is_a?(WalkSpec) && other.bucket == bucket && other.tag == tag && other.keep == keep
end

#===(other) ⇒ Object



91
92
93
94
95
96
97
98
99
100
101
# File 'lib/riak/walk_spec.rb', line 91

def ===(other)
  self == other || case other
                   when WalkSpec
                     other.keep == keep &&
                       (bucket == "_" || bucket == other.bucket) &&
                       (tag == "_" || tag == other.tag)
                   when Link
                     (bucket == "_" || bucket == other.url.split("/")[2]) &&
                       (tag == "_" || tag == other.rel)
                   end
end

#to_sObject

Converts the walk-spec into the form required by the link-walker resource URL



81
82
83
84
85
# File 'lib/riak/walk_spec.rb', line 81

def to_s
  b = @bucket && escape(@bucket) || '_'
  t = @tag && escape(@tag) || '_'
  "#{b},#{t},#{@keep ? '1' : '_'}"
end