__init__(self, host='localhost', port=9090) | confluo.rpc.client.RpcClient | |
add_aggregate(self, aggregate_name, filter_name, aggregate_expr) | confluo.rpc.client.RpcClient | |
add_filter(self, filter_name, filter_expr) | confluo.rpc.client.RpcClient | |
add_index(self, field_name, bucket_size=1) | confluo.rpc.client.RpcClient | |
append(self, rec) | confluo.rpc.client.RpcClient | |
append_raw(self, data) | confluo.rpc.client.RpcClient | |
client_ (defined in confluo.rpc.client.RpcClient) | confluo.rpc.client.RpcClient | |
close(self) | confluo.rpc.client.RpcClient | |
connect(self, host, port) | confluo.rpc.client.RpcClient | |
create_atomic_multilog(self, name, schema, storage_mode) | confluo.rpc.client.RpcClient | |
cur_m_id_ (defined in confluo.rpc.client.RpcClient) | confluo.rpc.client.RpcClient | |
cur_schema_ (defined in confluo.rpc.client.RpcClient) | confluo.rpc.client.RpcClient | |
disconnect(self) | confluo.rpc.client.RpcClient | |
execute_filter(self, filter_expr) | confluo.rpc.client.RpcClient | |
get_aggregate(self, aggregate_name, begin_ms, end_ms) | confluo.rpc.client.RpcClient | |
get_alerts(self, begin_ms, end_ms, trigger_name="") | confluo.rpc.client.RpcClient | |
get_batch_builder(self) | confluo.rpc.client.RpcClient | |
install_trigger(self, trigger_name, trigger_expr) | confluo.rpc.client.RpcClient | |
LOG (defined in confluo.rpc.client.RpcClient) | confluo.rpc.client.RpcClient | |
num_records(self) | confluo.rpc.client.RpcClient | |
protocol_ (defined in confluo.rpc.client.RpcClient) | confluo.rpc.client.RpcClient | |
query_filter(self, filter_name, begin_ms, end_ms, filter_expr="") | confluo.rpc.client.RpcClient | |
read(self, offset) (defined in confluo.rpc.client.RpcClient) | confluo.rpc.client.RpcClient | |
read_raw(self, offset) | confluo.rpc.client.RpcClient | |
remove_aggregate(self, aggregate_name) | confluo.rpc.client.RpcClient | |
remove_atomic_multilog(self) | confluo.rpc.client.RpcClient | |
remove_filter(self, filter_name) | confluo.rpc.client.RpcClient | |
remove_index(self, field_name) | confluo.rpc.client.RpcClient | |
remove_trigger(self, trigger_name) | confluo.rpc.client.RpcClient | |
set_current_atomic_multilog(self, atomic_multilog_name) | confluo.rpc.client.RpcClient | |
socket_ (defined in confluo.rpc.client.RpcClient) | confluo.rpc.client.RpcClient | |
transport_ (defined in confluo.rpc.client.RpcClient) | confluo.rpc.client.RpcClient | |