confluo.rpc.rpc_service.Iface Class Reference

Inheritance diagram for confluo.rpc.rpc_service.Iface:

Public Member Functions
def	register_handler (self)
def	deregister_handler (self)
def	create_atomic_multilog (self, name, schema, mode)
def	get_atomic_multilog_info (self, name)
def	remove_atomic_multilog (self, multilog_id)
def	add_index (self, multilog_id, field_name, bucket_size)
def	remove_index (self, multilog_id, field_name)
def	add_filter (self, multilog_id, filter_name, filter_expr)
def	remove_filter (self, multilog_id, filter_name)
def	add_aggregate (self, mutlilog_id, aggregate_name, filter_name, aggregate_expr)
def	remove_aggregate (self, multilog_id, aggregate_name)
def	add_trigger (self, multilog_id, trigger_name, trigger_expr)
def	remove_trigger (self, multilog_id, trigger_name)
def	append (self, multilog_id, data)
def	append_batch (self, multilog_id, batch)
def	read (self, multilog_id, offset, nrecords)
def	query_aggregate (self, multilog_id, aggregate_name, begin_ms, end_ms)
def	adhoc_aggregate (self, multilog_id, aggregate_expr, filter_expr)
def	adhoc_filter (self, multilog_id, filter_expr)
def	predef_filter (self, multilog_id, filter_name, begin_ms, end_ms)
def	combined_filter (self, multilog_id, filter_name, filter_expr, begin_ms, end_ms)
def	alerts_by_time (self, multilog_id, begin_ms, end_ms)
def	alerts_by_trigger_and_time (self, multilog_id, trigger_name, begin_ms, end_ms)
def	get_more (self, multilog_id, desc)
def	num_records (self, multilog_id)

Member Function Documentation

add_aggregate()

def confluo.rpc.rpc_service.Iface.add_aggregate	(		self,
			mutlilog_id,
			aggregate_name,
			filter_name,
			aggregate_expr
	)

Parameters:
 - mutlilog_id
 - aggregate_name
 - filter_name
 - aggregate_expr

add_filter()

def confluo.rpc.rpc_service.Iface.add_filter	(		self,
			multilog_id,
			filter_name,
			filter_expr
	)

Parameters:
 - multilog_id
 - filter_name
 - filter_expr

add_index()

def confluo.rpc.rpc_service.Iface.add_index	(		self,
			multilog_id,
			field_name,
			bucket_size
	)

Parameters:
 - multilog_id
 - field_name
 - bucket_size

add_trigger()

def confluo.rpc.rpc_service.Iface.add_trigger	(		self,
			multilog_id,
			trigger_name,
			trigger_expr
	)

Parameters:
 - multilog_id
 - trigger_name
 - trigger_expr

adhoc_aggregate()

def confluo.rpc.rpc_service.Iface.adhoc_aggregate	(		self,
			multilog_id,
			aggregate_expr,
			filter_expr
	)

Parameters:
 - multilog_id
 - aggregate_expr
 - filter_expr

adhoc_filter()

def confluo.rpc.rpc_service.Iface.adhoc_filter	(		self,
			multilog_id,
			filter_expr
	)

Parameters:
 - multilog_id
 - filter_expr

alerts_by_time()

def confluo.rpc.rpc_service.Iface.alerts_by_time	(		self,
			multilog_id,
			begin_ms,
			end_ms
	)

Parameters:
 - multilog_id
 - begin_ms
 - end_ms

alerts_by_trigger_and_time()

def confluo.rpc.rpc_service.Iface.alerts_by_trigger_and_time	(		self,
			multilog_id,
			trigger_name,
			begin_ms,
			end_ms
	)

Parameters:
 - multilog_id
 - trigger_name
 - begin_ms
 - end_ms

append()

def confluo.rpc.rpc_service.Iface.append	(		self,
			multilog_id,
			data
	)

Query ops *

Parameters:
 - multilog_id
 - data

append_batch()

def confluo.rpc.rpc_service.Iface.append_batch	(		self,
			multilog_id,
			batch
	)

Parameters:
 - multilog_id
 - batch

combined_filter()

def confluo.rpc.rpc_service.Iface.combined_filter	(		self,
			multilog_id,
			filter_name,
			filter_expr,
			begin_ms,
			end_ms
	)

Parameters:
 - multilog_id
 - filter_name
 - filter_expr
 - begin_ms
 - end_ms

create_atomic_multilog()

def confluo.rpc.rpc_service.Iface.create_atomic_multilog	(		self,
			name,
			schema,
			mode
	)

Parameters:
 - name
 - schema
 - mode

get_atomic_multilog_info()

def confluo.rpc.rpc_service.Iface.get_atomic_multilog_info	(		self,
			name
	)

Parameters:
 - name

get_more()

def confluo.rpc.rpc_service.Iface.get_more	(		self,
			multilog_id,
			desc
	)

Parameters:
 - multilog_id
 - desc

num_records()

def confluo.rpc.rpc_service.Iface.num_records	(		self,
			multilog_id
	)

Parameters:
 - multilog_id

predef_filter()

def confluo.rpc.rpc_service.Iface.predef_filter	(		self,
			multilog_id,
			filter_name,
			begin_ms,
			end_ms
	)

Parameters:
 - multilog_id
 - filter_name
 - begin_ms
 - end_ms

query_aggregate()

def confluo.rpc.rpc_service.Iface.query_aggregate	(		self,
			multilog_id,
			aggregate_name,
			begin_ms,
			end_ms
	)

Parameters:
 - multilog_id
 - aggregate_name
 - begin_ms
 - end_ms

read()

def confluo.rpc.rpc_service.Iface.read	(		self,
			multilog_id,
			offset,
			nrecords
	)

Parameters:
 - multilog_id
 - offset
 - nrecords

register_handler()

def confluo.rpc.rpc_service.Iface.register_handler

(

self

)

Management ops *

remove_aggregate()

def confluo.rpc.rpc_service.Iface.remove_aggregate	(		self,
			multilog_id,
			aggregate_name
	)

Parameters:
 - multilog_id
 - aggregate_name

remove_atomic_multilog()

def confluo.rpc.rpc_service.Iface.remove_atomic_multilog	(		self,
			multilog_id
	)

Parameters:
 - multilog_id

remove_filter()

def confluo.rpc.rpc_service.Iface.remove_filter	(		self,
			multilog_id,
			filter_name
	)

Parameters:
 - multilog_id
 - filter_name

remove_index()

def confluo.rpc.rpc_service.Iface.remove_index	(		self,
			multilog_id,
			field_name
	)

Parameters:
 - multilog_id
 - field_name

remove_trigger()

def confluo.rpc.rpc_service.Iface.remove_trigger	(		self,
			multilog_id,
			trigger_name
	)

Parameters:
 - multilog_id
 - trigger_name

---

The documentation for this class was generated from the following file:

• /Users/anuragk/Work/Projects/Confluo/confluo/pyclient/confluo/rpc/rpc_service.py