lib/aerospike/command/operate_command.rb in aerospike-2.24.0 vs lib/aerospike/command/operate_command.rb in aerospike-2.25.0
- old
+ new
@@ -12,35 +12,30 @@
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
# License for the specific language governing permissions and limitations under
# the License.
-require 'aerospike/command/read_command'
+require "aerospike/command/read_command"
module Aerospike
-
private
class OperateCommand < ReadCommand #:nodoc:
+ def initialize(cluster, key, args)
+ super(cluster, args.write_policy, key, nil)
- def initialize(cluster, policy, key, operations)
- super(cluster, policy, key, nil)
-
- @operations = operations
+ @args = args
end
def get_node
@cluster.master_node(@partition)
end
-
def write_bins
- @operations.select{|op| op.op_type == Aerospike::Operation::WRITE}.map(&:bin).compact
+ @operations.select { |op| op.op_type == Aerospike::Operation::WRITE }.map(&:bin).compact
end
def write_buffer
- set_operate(@policy, @key, @operations)
+ set_operate(@args.write_policy, @key, @args)
end
-
end # class
-
end # module