Class: ZooKeeper::Transaction

Inherits:
Object
  • Object
show all
Includes:
Operations
Defined in:
lib/zkruby/client.rb

Overview

Collects zookeeper operations to execute as a single transaction

The builder methods #create #delete #check #set all take an optional callback block that will be executed if the #commit succeeds.

If the transaction fails none of these callbacks will be executed.

Constant Summary

Constants included from Operations

Operations::CREATE_OPTS

Instance Method Summary collapse

Constructor Details

#initialize(client, session) ⇒ Transaction

:nodoc



544
545
546
547
548
 
# File 'lib/zkruby/client.rb', line 544

def initialize(client,session)
    @client = client
    @session = session
    @ops = []
end

Instance Method Details

#check(path, version, &callback) ⇒ Object

Check Version



579
580
581
 
# File 'lib/zkruby/client.rb', line 579

def check(path,version,&callback)
    op_check(path,version,&callback)
end

#commit ⇒ Object #commit { ... } ⇒ AsyncOp

Commit the transaction

Overloads:

  • #commit ⇒ Object

    Synchronously commit the transaction

    Raises:

    • (Error) —

      if the transaction failed

  • #commit { ... } ⇒ AsyncOp

    Returns captures the result of the asynchronous operation.

    Yields:

    • [] callback invoked if transaction is successful

    Returns:

    • (AsyncOp) —

      captures the result of the asynchronous operation



590
591
592
 
# File 'lib/zkruby/client.rb', line 590

def commit(&callback)
    op = client.multi(ops,&callback)
end

#create(path, data, acl, *modeopts, &callback) ⇒ Object

Create a node @param [String] path the base name of the path to create @param [String] data the content to store at path @param [Data::ACL] acl the access control list to apply to the new node @param [Symbol,...] modeopts combination of :sequential, :emphemeral @yieldparam [String] path the created path



557
558
559
 
# File 'lib/zkruby/client.rb', line 557

def create(path,data,acl,*modeopts,&callback)
    op_create(path,data,acl,*modeopts,&callback)
end

#delete(path, version, &callback) ⇒ Object

Delete path @param [String] path @param [FixNum] version the expected version to be deleted (-1 to match any version) @yield [] callback invoked if delete is successful



565
566
567
 
# File 'lib/zkruby/client.rb', line 565

def delete(path,version,&callback)
    op_delete(path,version,&callback)
end

#set(path, data, version, &callback) ⇒ Object

Set Data @param [String] path @param [String] data content to set at path @param [Fixnum] version expected current version at path or -1 for any version @yieldparam [Data::Stat] stat new stat of path



574
575
576
 
# File 'lib/zkruby/client.rb', line 574

def set(path,data,version,&callback)
    op_set(path,data,version,&callback)
end