Class: Couchbase::BinaryCollection

Inherits:
Object
  • Object
show all
Defined in:
lib/couchbase/binary_collection.rb,
lib/couchbase/binary_collection_options.rb,
/home/runner/work/couchbase-ruby-client/couchbase-ruby-client/lib/couchbase/binary_collection.rb,
/home/runner/work/couchbase-ruby-client/couchbase-ruby-client/lib/couchbase/binary_collection_options.rb

Overview

Allows to perform certain operations on non-JSON documents.

Defined Under Namespace

Classes: CounterResult

Instance Method Summary collapse

Instance Method Details

#append(id, content, options = Options::Append::DEFAULT) ⇒ Collection::MutationResult

Appends binary content to the document

Examples:

Append “bar” to the content of the existing document

collection.upsert("mydoc", "foo")
collection.binary.append("mydoc", "bar", Options::Append(timeout: 3_000))
collection.get("mydoc", Options::Get(transcoder: nil)).content #=> "foobar"

Parameters:

  • id (String) —

    the document id which is used to uniquely identify it

  • content (String) —

    the binary content to append to the document

  • options (Options::Append) (defaults to: Options::Append::DEFAULT) —

    custom options to customize the request

Returns:



46
47
48
49
50
51
52
53
54
55
56
 
# File 'lib/couchbase/binary_collection.rb', line 46

def append(id, content, options = Options::Append::DEFAULT)
  @observability.record_operation(Observability::OP_APPEND, options.parent_span, self, :kv) do |obs_handler|
    obs_handler.add_durability_level(options.durability_level)
    resp = @backend.document_append(@collection.bucket_name, @collection.scope_name, @collection.name,
                                    id, content, options.to_backend, obs_handler)
    Collection::MutationResult.new do |res|
      res.cas = resp[:cas]
      res.mutation_token = @collection.send(:extract_mutation_token, resp)
    end
  end
end

#decrement(id, options = Options::Decrement::DEFAULT) ⇒ CounterResult

Decrements the counter document by one of the number defined in the options

Examples:

Decrement value by 2, and initialize to 100 if it does not exist

res = collection.binary.decrement("raw_counter", Options::Decrement(delta: 2, initial: 100))
res.value #=> 100
res = collection.binary.decrement("raw_counter", Options::Decrement(delta: 2, initial: 100))
res.value #=> 98

Parameters:

  • id (String) —

    the document id which is used to uniquely identify it

  • options (Options::Decrement) (defaults to: Options::Decrement::DEFAULT) —

    custom options to customize the request

Returns:



119
120
121
122
123
124
125
126
127
128
129
130
 
# File 'lib/couchbase/binary_collection.rb', line 119

def decrement(id, options = Options::Decrement::DEFAULT)
  @observability.record_operation(Observability::OP_DECREMENT, options.parent_span, self, :kv) do |obs_handler|
    obs_handler.add_durability_level(options.durability_level)
    resp = @backend.document_decrement(@collection.bucket_name, @collection.scope_name, @collection.name, id,
                                       options.to_backend, obs_handler)
    CounterResult.new do |res|
      res.cas = resp[:cas]
      res.content = resp[:content]
      res.mutation_token = @collection.send(:extract_mutation_token, resp)
    end
  end
end

#increment(id, options = Options::Increment::DEFAULT) ⇒ CounterResult

Increments the counter document by one of the number defined in the options

Examples:

Increment value by 10, and initialize to 0 if it does not exist

res = collection.binary.increment("raw_counter", Options::Increment(delta: 10, initial: 0))
res.content #=> 0
res = collection.binary.increment("raw_counter", Options::Increment(delta: 10, initial: 0))
res.content #=> 10

Parameters:

  • id (String) —

    the document id which is used to uniquely identify it

  • options (Options::Increment) (defaults to: Options::Increment::DEFAULT) —

    custom options to customize the request

Returns:



94
95
96
97
98
99
100
101
102
103
104
105
 
# File 'lib/couchbase/binary_collection.rb', line 94

def increment(id, options = Options::Increment::DEFAULT)
  @observability.record_operation(Observability::OP_INCREMENT, options.parent_span, self, :kv) do |obs_handler|
    obs_handler.add_durability_level(options.durability_level)
    resp = @backend.document_increment(@collection.bucket_name, @collection.scope_name, @collection.name, id,
                                       options.to_backend, obs_handler)
    CounterResult.new do |res|
      res.cas = resp[:cas]
      res.content = resp[:content]
      res.mutation_token = @collection.send(:extract_mutation_token, resp)
    end
  end
end

#prepend(id, content, options = Options::Prepend::DEFAULT) ⇒ Collection::MutationResult

Prepends binary content to the document

Examples:

Prepend “bar” to the content of the existing document

collection.upsert("mydoc", "foo")
collection.binary.prepend("mydoc", "bar", Options::Prepend(timeout: 3_000))
collection.get("mydoc", Options::Get(transcoder: nil)).content #=> "barfoo"

Parameters:

  • id (String) —

    the document id which is used to uniquely identify it

  • content (String) —

    the binary content to prepend to the document

  • options (Options::Prepend) (defaults to: Options::Prepend::DEFAULT) —

    custom options to customize the request

Returns:



70
71
72
73
74
75
76
77
78
79
80
 
# File 'lib/couchbase/binary_collection.rb', line 70

def prepend(id, content, options = Options::Prepend::DEFAULT)
  @observability.record_operation(Observability::OP_PREPEND, options.parent_span, self, :kv) do |obs_handler|
    obs_handler.add_durability_level(options.durability_level)
    resp = @backend.document_prepend(@collection.bucket_name, @collection.scope_name, @collection.name,
                                     id, content, options.to_backend, obs_handler)
    Collection::MutationResult.new do |res|
      res.cas = resp[:cas]
      res.mutation_token = @collection.send(:extract_mutation_token, resp)
    end
  end
end