Class: Couchbase::Bucket

Inherits:
Object
  • Object
show all
Defined in:
lib/couchbase/bucket.rb,
lib/couchbase/view_options.rb,
/Users/sergey.auseyau/code/couchbase-ruby-client/lib/couchbase/bucket.rb,
/Users/sergey.auseyau/code/couchbase-ruby-client/lib/couchbase/view_options.rb more...

Defined Under Namespace

Classes: ViewMetaData, ViewResult, ViewRow

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(backend, name) ⇒ Bucket

Returns a new instance of Bucket.

Parameters:

  • backend (Couchbase::Backend)
[View source]

30
31
32
33
34
 
# File 'lib/couchbase/bucket.rb', line 30

def initialize(backend, name)
  backend.open_bucket(name, true)
  @backend = backend
  @name = name
end

Instance Attribute Details

#name ⇒ String (readonly)

Returns name of the bucket.

Returns:

  • (String) —

    name of the bucket


25
26
27
 
# File 'lib/couchbase/bucket.rb', line 25

def name
  @name
end

Instance Method Details

#collection(collection_name) ⇒ Collection

Opens the named collection in the default scope of the bucket

Parameters:

  • collection_name (String) —

    name of the collection

Returns:

[View source]

57
58
59
 
# File 'lib/couchbase/bucket.rb', line 57

def collection(collection_name)
  default_scope.collection(collection_name)
end

#collections ⇒ Management::CollectionManager

Returns:

[View source]

100
101
102
 
# File 'lib/couchbase/bucket.rb', line 100

def collections
  Management::CollectionManager.new(@backend, @name)
end

#default_collection ⇒ Collection

Opens the default collection for this bucket

Returns:

[View source]

64
65
66
 
# File 'lib/couchbase/bucket.rb', line 64

def default_collection
  Collection.new(@backend, @name, :_default, :_default)
end

#default_scope ⇒ Scope

Get default scope

Returns:

[View source]

39
40
41
 
# File 'lib/couchbase/bucket.rb', line 39

def default_scope
  Scope.new(@backend, @name, :_default)
end

#ping(options = Options::Ping.new) ⇒ PingResult

Performs application-level ping requests against services in the couchbase cluster

Parameters:

Returns:

[View source]

114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
 
# File 'lib/couchbase/bucket.rb', line 114

def ping(options = Options::Ping.new)
  resp = @backend.ping(@name, options.to_backend)
  PingResult.new do |res|
    res.version = resp[:version]
    res.id = resp[:id]
    res.sdk = resp[:sdk]
    resp[:services].each do |type, svcs|
      res.services[type] = svcs.map do |svc|
        PingResult::ServiceInfo.new do |info|
          info.id = svc[:id]
          info.state = svc[:state]
          info.latency = svc[:latency]
          info.remote = svc[:remote]
          info.local = svc[:local]
          info.error = svc[:error]
        end
      end
    end
  end
end

#scope(scope_name) ⇒ Scope

Get a named scope

Parameters:

  • scope_name (String) —

    name of the scope

Returns:

[View source]

48
49
50
 
# File 'lib/couchbase/bucket.rb', line 48

def scope(scope_name)
  Scope.new(@backend, @name, scope_name)
end

#view_indexes ⇒ Management::ViewIndexManager

Returns:

[View source]

105
106
107
 
# File 'lib/couchbase/bucket.rb', line 105

def view_indexes
  Management::ViewIndexManager.new(@backend, @name)
end

#view_query(design_document_name, view_name, options = Options::View.new) ⇒ ViewResult

Performs query to view index.

Examples:

Make sure the view engine catch up with all mutations and return keys starting from [“random_brewery:”]

bucket.view_query("beer", "brewery_beers",
                  Options::View(
                    start_key: ["random_brewery:"],
                    scan_consistency: :request_plus
                  ))

Parameters:

  • design_document_name (String) —

    name of the design document

  • view_name (String) —

    name of the view to query

  • options (Options::View) (defaults to: Options::View.new)

Returns:

[View source]

82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
 
# File 'lib/couchbase/bucket.rb', line 82

def view_query(design_document_name, view_name, options = Options::View.new)
  resp = @backend.document_view(@name, design_document_name, view_name, options.namespace, options.to_backend)
  ViewResult.new do |res|
    res.meta_data = ViewMetaData.new do |meta|
      meta.total_rows = resp[:meta][:total_rows]
      meta.debug_info = resp[:meta][:debug_info]
    end
    res.rows = resp[:rows].map do |entry|
      ViewRow.new do |row|
        row.id = entry[:id] if entry.key?(:id)
        row.key = JSON.parse(entry[:key])
        row.value = JSON.parse(entry[:value])
      end
    end
  end
end