| __init__(self, handler) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| add_aggregate(self, mutlilog_id, aggregate_name, filter_name, aggregate_expr) | confluo.rpc.rpc_service.Iface | |
| add_filter(self, multilog_id, filter_name, filter_expr) | confluo.rpc.rpc_service.Iface | |
| add_index(self, multilog_id, field_name, bucket_size) | confluo.rpc.rpc_service.Iface | |
| add_trigger(self, multilog_id, trigger_name, trigger_expr) | confluo.rpc.rpc_service.Iface | |
| adhoc_aggregate(self, multilog_id, aggregate_expr, filter_expr) | confluo.rpc.rpc_service.Iface | |
| adhoc_filter(self, multilog_id, filter_expr) | confluo.rpc.rpc_service.Iface | |
| alerts_by_time(self, multilog_id, begin_ms, end_ms) | confluo.rpc.rpc_service.Iface | |
| alerts_by_trigger_and_time(self, multilog_id, trigger_name, begin_ms, end_ms) | confluo.rpc.rpc_service.Iface | |
| append(self, multilog_id, data) | confluo.rpc.rpc_service.Iface | |
| append_batch(self, multilog_id, batch) | confluo.rpc.rpc_service.Iface | |
| combined_filter(self, multilog_id, filter_name, filter_expr, begin_ms, end_ms) | confluo.rpc.rpc_service.Iface | |
| create_atomic_multilog(self, name, schema, mode) | confluo.rpc.rpc_service.Iface | |
| deregister_handler(self) (defined in confluo.rpc.rpc_service.Iface) | confluo.rpc.rpc_service.Iface | |
| get_atomic_multilog_info(self, name) | confluo.rpc.rpc_service.Iface | |
| get_more(self, multilog_id, desc) | confluo.rpc.rpc_service.Iface | |
| num_records(self, multilog_id) | confluo.rpc.rpc_service.Iface | |
| predef_filter(self, multilog_id, filter_name, begin_ms, end_ms) | confluo.rpc.rpc_service.Iface | |
| process(self, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_add_aggregate(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_add_filter(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_add_index(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_add_trigger(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_adhoc_aggregate(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_adhoc_filter(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_alerts_by_time(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_alerts_by_trigger_and_time(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_append(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_append_batch(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_combined_filter(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_create_atomic_multilog(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_deregister_handler(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_get_atomic_multilog_info(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_get_more(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_num_records(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_predef_filter(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_query_aggregate(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_read(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_register_handler(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_remove_aggregate(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_remove_atomic_multilog(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_remove_filter(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_remove_index(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| process_remove_trigger(self, seqid, iprot, oprot) (defined in confluo.rpc.rpc_service.Processor) | confluo.rpc.rpc_service.Processor | |
| query_aggregate(self, multilog_id, aggregate_name, begin_ms, end_ms) | confluo.rpc.rpc_service.Iface | |
| read(self, multilog_id, offset, nrecords) | confluo.rpc.rpc_service.Iface | |
| register_handler(self) | confluo.rpc.rpc_service.Iface | |
| remove_aggregate(self, multilog_id, aggregate_name) | confluo.rpc.rpc_service.Iface | |
| remove_atomic_multilog(self, multilog_id) | confluo.rpc.rpc_service.Iface | |
| remove_filter(self, multilog_id, filter_name) | confluo.rpc.rpc_service.Iface | |
| remove_index(self, multilog_id, field_name) | confluo.rpc.rpc_service.Iface | |
| remove_trigger(self, multilog_id, trigger_name) | confluo.rpc.rpc_service.Iface | |
