Class: LS4::DSRPCService

Inherits:
GWRPCService show all
Defined in:
lib/ls4/service/rpc_ds.rb

Instance Method Summary collapse

Methods inherited from GWRPCService

#add, #add_data, #addv, #addv_data, #delete, #deletet, #deletev, #get, #get_attrs, #get_data, #getd_data, #gett, #gett_attrs, #gett_data, #getv, #getv_attrs, #getv_data, #read, #readd, #readt, #readv, #remove, #stat, #update_attrs, #url, #urlt, #urlv, #util_locate

Methods inherited from RPCService

#force_binary!

Methods inherited from Service

init

Methods included from EventBus::SingletonMixin

#ebus_bind!, #ebus_connect, extended

Methods included from EventBus::BusMixin

#ebus_all_slots, #ebus_disconnect!

Methods included from EventBus::DeclarerBase::Methods

#connect, #ebus_all_slots, #ebus_call_log, #ebus_call_slots, #ebus_signal_error, #ebus_signal_log, #ebus_signal_slots

Methods included from EventBus::DeclarerBase

#call_slot, #signal_slot

Instance Method Details

#delete_direct(okey) ⇒ Object 



48
49
50
51
 
# File 'lib/ls4/service/rpc_ds.rb', line 48

def delete_direct(okey)
	okey = ObjectKey.new.from_msgpack(okey)
	dispatch(DSRPCBus, :delete_direct, okey)
end

#get_direct(okey) ⇒ Object 



37
38
39
40
 
# File 'lib/ls4/service/rpc_ds.rb', line 37

def get_direct(okey)
	okey = ObjectKey.new.from_msgpack(okey)
	dispatch(DSRPCBus, :get_direct, okey)
end

#read_direct(okey, offset, size) ⇒ Object

def copy(okey, noid) okey = ObjectKey.new.from_msgpack(okey) noid = ObjectKey.new.from_msgpack(noid) dispatch(DSRPCBus, :copy, okey, noid) end



59
60
61
62
 
# File 'lib/ls4/service/rpc_ds.rb', line 59

def read_direct(okey, offset, size)
	okey = ObjectKey.new.from_msgpack(okey)
	dispatch(DSRPCBus, :read_direct, okey, offset, size)
end

#replicate_notify(nid) ⇒ Object 



90
91
92
 
# File 'lib/ls4/service/rpc_ds.rb', line 90

def replicate_notify(nid)
	dispatch(DSRPCBus, :replicate_notify, nid)
end

#replicate_pull(pos, limit) ⇒ Object 



86
87
88
 
# File 'lib/ls4/service/rpc_ds.rb', line 86

def replicate_pull(pos, limit)
	dispatch(DSRPCBus, :replicate_pull, pos, limit)
end

#resize_direct(okey, size) ⇒ Object 



81
82
83
84
 
# File 'lib/ls4/service/rpc_ds.rb', line 81

def resize_direct(okey, size)
	okey = ObjectKey.new.from_msgpack(okey)
	dispatch(DSRPCBus, :resize_direct, okey, size)
end

#set_direct(okey, data) ⇒ Object 



42
43
44
45
46
 
# File 'lib/ls4/service/rpc_ds.rb', line 42

def set_direct(okey, data)
	okey = ObjectKey.new.from_msgpack(okey)
	force_binary!(data)
	dispatch(DSRPCBus, :set_direct, okey, data)
end

#url_direct(okey) ⇒ Object

def append_direct(okey, data) okey = ObjectKey.new.from_msgpack(okey) force_binary!(data) dispatch(DSRPCBus, :append_direct, okey, data) end



76
77
78
79
 
# File 'lib/ls4/service/rpc_ds.rb', line 76

def url_direct(okey)
	okey = ObjectKey.new.from_msgpack(okey)
	dispatch(DSRPCBus, :url_direct, okey)
end