module CryBase::CouchBase::Services::KV::Bucket

Overview

Mixin that performs the SELECT_BUCKET handshake — switches the connection's active bucket. Depends on the includer also mixing in RequestWriter (for write) and ResponseReader (for read).

Maps server-side errors onto typed exceptions: Status::AuthError/AuthContinue → AuthFailed, anything else non-success → plain Error.

class Peer
  include KV::RequestWriter
  include KV::ResponseReader
  include KV::Bucket

  def initialize(@socket : IO)
  end
end

# `io` is wired to a real KV node (or a fake responder)
Peer.new(io).use("default")

Direct including types

Defined in:

crybase/couchbase/services/kv/bucket.cr