Inheritance diagram for confluo.rpc.rpc_service.Processor:
Public Member Functions | |
| def | __init__ (self, handler) |
| def | process (self, iprot, oprot) |
| def | process_register_handler (self, seqid, iprot, oprot) |
| def | process_deregister_handler (self, seqid, iprot, oprot) |
| def | process_create_atomic_multilog (self, seqid, iprot, oprot) |
| def | process_get_atomic_multilog_info (self, seqid, iprot, oprot) |
| def | process_remove_atomic_multilog (self, seqid, iprot, oprot) |
| def | process_add_index (self, seqid, iprot, oprot) |
| def | process_remove_index (self, seqid, iprot, oprot) |
| def | process_add_filter (self, seqid, iprot, oprot) |
| def | process_remove_filter (self, seqid, iprot, oprot) |
| def | process_add_aggregate (self, seqid, iprot, oprot) |
| def | process_remove_aggregate (self, seqid, iprot, oprot) |
| def | process_add_trigger (self, seqid, iprot, oprot) |
| def | process_remove_trigger (self, seqid, iprot, oprot) |
| def | process_append (self, seqid, iprot, oprot) |
| def | process_append_batch (self, seqid, iprot, oprot) |
| def | process_read (self, seqid, iprot, oprot) |
| def | process_query_aggregate (self, seqid, iprot, oprot) |
| def | process_adhoc_aggregate (self, seqid, iprot, oprot) |
| def | process_adhoc_filter (self, seqid, iprot, oprot) |
| def | process_predef_filter (self, seqid, iprot, oprot) |
| def | process_combined_filter (self, seqid, iprot, oprot) |
| def | process_alerts_by_time (self, seqid, iprot, oprot) |
| def | process_alerts_by_trigger_and_time (self, seqid, iprot, oprot) |
| def | process_get_more (self, seqid, iprot, oprot) |
| def | process_num_records (self, seqid, iprot, oprot) |
 Public Member Functions inherited from confluo.rpc.rpc_service.Iface | |
| 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) |
The documentation for this class was generated from the following file:
- /Users/anuragk/Work/Projects/Confluo/confluo/pyclient/confluo/rpc/rpc_service.py
