Class: Riak::Crdt::Set

Inherits:
Base show all
Defined in:
lib/riak/crdt/set.rb

Overview

A distributed set containing strings, using the Riak 2 Data Types feature.

Uses the Ruby standard library `::Set` frequently, so the full class names will be used frequently.

Defined Under Namespace

Classes: BatchSet

Instance Attribute Summary

Attributes inherited from Base

#bucket, #bucket_type, #key

Instance Method Summary collapse

Methods inherited from Base

#==, #context?, #dirty?, #inspect_name, #pretty_print_cycle, #reload

Methods included from Util::Translation

#i18n_scope, #t

Constructor Details

#initialize(bucket, key, bucket_type = nil, options = {}) ⇒ Set

Create a set instance. The bucket type is determined by the first of these sources:

  1. The `bucket_type` String argument

  2. A BucketTyped::Bucket as the `bucket` argument

  3. The `Crdt::Base::DEFAULT_BUCKET_TYPES` entry

Parameters:

  • bucket (Bucket)

    the Bucket for this set

  • key (String, nil)

    The name of the set. A nil key makes Riak assign a key.

  • bucket_type (String) (defaults to: nil)

    The optional bucket type for this set.

  • options (Hash) (defaults to: {})


22
23
24
# File 'lib/riak/crdt/set.rb', line 22

def initialize(bucket, key, bucket_type = nil, options = {})
  super(bucket, key, bucket_type || :set, options)
end

Instance Method Details

#add(element, options = {}) ⇒ Object

Add a String to the Riak::Crdt::Set

Parameters:

  • element (String)

    the element to add to the set

  • options (Hash) (defaults to: {})


83
84
85
# File 'lib/riak/crdt/set.rb', line 83

def add(element, options = {})
  operate operation(:add, element), options
end

#batch {|batcher| ... } ⇒ Object

Yields:

  • (batcher)


37
38
39
40
41
42
43
# File 'lib/riak/crdt/set.rb', line 37

def batch
  batcher = BatchSet.new self

  yield batcher

  operate batcher.operations
end

#empty?Boolean

Check to see if this structure has any members.

Returns:

  • (Boolean)

    if the structure is empty



67
68
69
# File 'lib/riak/crdt/set.rb', line 67

def empty?
  members.empty?
end

#include?(candidate) ⇒ Boolean

Check to see if a given string is present in this data structure.

Parameters:

  • candidate (String)

    string to check for inclusion in this structure

Returns:

  • (Boolean)

    if the structure includes



75
76
77
# File 'lib/riak/crdt/set.rb', line 75

def include?(candidate)
  members.include?(candidate)
end

#members::Set Also known as: value

Gets the current set members from Riak if necessary, and return the stdlib `::Set` of them.

Returns:



50
51
52
53
# File 'lib/riak/crdt/set.rb', line 50

def members
  reload if dirty?
  @members
end

#pretty_print(pp) ⇒ Object



98
99
100
101
102
103
# File 'lib/riak/crdt/set.rb', line 98

def pretty_print(pp)
  super pp do
    pp.comma_breakable
    pp.pp to_a
  end
end

#remove(element, options = {}) ⇒ Object Also known as: delete

Remove a String from the Riak::Crdt::Set

Parameters:

  • element (String)

    to remove from the set

  • options (Hash) (defaults to: {})

Raises:



91
92
93
94
# File 'lib/riak/crdt/set.rb', line 91

def remove(element, options = {})
  raise CrdtError::SetRemovalWithoutContextError unless context?
  operate operation(:remove, element), options
end

#to_aArray

Cast this Riak::Crdt::Set to a Ruby Array.

Returns:

  • (Array)

    array of set members



60
61
62
# File 'lib/riak/crdt/set.rb', line 60

def to_a
  members.to_a
end