Classes | |
class | CassandraTopic |
class | CassandraTopicException |
Functions | |
def | __init__ |
def | _generateMsg |
def | addData |
def | countData |
def | createKey |
def | getAllData |
def | getData |
def | getMeta |
def | removeAllData |
def | removeData |
def | setMeta |
Variables | |
cassandra_format | |
list | CassandraFormats = ['binary', 'string', 'ros', 'ros_old', 'yaml', 'manual'] |
column | |
comment | |
cursor | |
date | |
key_format | |
key_msg_part | |
list | KeyFormats = ['time', 'hash', 'msg_part', 'manual'] |
msg_class | |
msg_package | |
MsgClass | |
topic |
def RosCassandra.CassandraTopic.__init__ | ( | self, | |
topic = "" , |
|||
column = None , |
|||
cursor = None , |
|||
cassandra_format = CassandraFormats[0] , |
|||
msg_class = '' , |
|||
msg_package = '' , |
|||
key_format = KeyFormats[0] , |
|||
key_msg_part = '' , |
|||
comment = "" , |
|||
date = None , |
|||
meta = None |
|||
) |
Definition at line 33 of file CassandraTopic.py.
def RosCassandra.CassandraTopic._generateMsg | ( | self | ) | [private] |
Definition at line 100 of file CassandraTopic.py.
def RosCassandra.CassandraTopic.addData | ( | self, | |
msg, | |||
key = None , |
|||
ttl = None |
|||
) |
Definition at line 114 of file CassandraTopic.py.
def RosCassandra.CassandraTopic.countData | ( | self | ) |
Definition at line 203 of file CassandraTopic.py.
def RosCassandra.CassandraTopic.createKey | ( | self, | |
msg | |||
) |
Definition at line 192 of file CassandraTopic.py.
def RosCassandra.CassandraTopic.getAllData | ( | self, | |
queue = 100 |
|||
) |
Definition at line 151 of file CassandraTopic.py.
def RosCassandra.CassandraTopic.getData | ( | self, | |
key, | |||
to_key = None , |
|||
queue = 100 |
|||
) |
Definition at line 130 of file CassandraTopic.py.
def RosCassandra.CassandraTopic.getMeta | ( | self | ) |
Definition at line 72 of file CassandraTopic.py.
def RosCassandra.CassandraTopic.removeAllData | ( | self | ) |
Definition at line 181 of file CassandraTopic.py.
def RosCassandra.CassandraTopic.removeData | ( | self, | |
key, | |||
to_key = None , |
|||
queue = 100 |
|||
) |
Definition at line 159 of file CassandraTopic.py.
def RosCassandra.CassandraTopic.setMeta | ( | self, | |
meta | |||
) |
Definition at line 87 of file CassandraTopic.py.
Definition at line 33 of file CassandraTopic.py.
list RosCassandra::CassandraTopic::CassandraFormats = ['binary', 'string', 'ros', 'ros_old', 'yaml', 'manual'] |
Definition at line 27 of file CassandraTopic.py.
Definition at line 33 of file CassandraTopic.py.
Definition at line 33 of file CassandraTopic.py.
Definition at line 33 of file CassandraTopic.py.
Definition at line 33 of file CassandraTopic.py.
Definition at line 33 of file CassandraTopic.py.
Definition at line 33 of file CassandraTopic.py.
list RosCassandra::CassandraTopic::KeyFormats = ['time', 'hash', 'msg_part', 'manual'] |
Definition at line 26 of file CassandraTopic.py.
Definition at line 33 of file CassandraTopic.py.
Definition at line 33 of file CassandraTopic.py.
Definition at line 100 of file CassandraTopic.py.
Definition at line 33 of file CassandraTopic.py.