Classes | |
class | ROS1Bag |
Functions | |
def | canonical (typename, unbounded=False) |
def | create_publisher (topic, cls_or_typename, queue_size) |
def | create_subscriber (topic, typename, handler, queue_size) |
def | deserialize_message (raw, cls_or_typename) |
def | format_message_value (msg, name, value) |
def | generate_message_classes (typename, typedef) |
def | get_message_class (typename) |
def | get_message_definition (msg_or_type) |
def | get_message_fields (val) |
def | get_message_type (msg_or_cls) |
def | get_message_type_hash (msg_or_type) |
def | get_message_value (msg, name, typename) |
def | get_rostime (fallback=False) |
def | get_topic_types () |
def | init_node (name) |
def | is_ros_message (val, ignore_time=False) |
def | is_ros_time (val) |
def | make_duration (secs=0, nsecs=0) |
def | make_time (secs=0, nsecs=0) |
def | scalar (typename) |
def | serialize_message (msg) |
def | set_message_value (obj, name, value) |
def | shutdown_node () |
def | to_duration (val) |
def | to_nsec (val) |
def | to_sec (val) |
def | to_sec_nsec (val) |
def | to_time (val) |
def | validate (live=False) |
Variables | |
list | __all__ |
Bag = ROS1Bag | |
tuple | BAG_EXTENSIONS = (".bag", ".bag.active") |
Bagfile extensions to seek. More... | |
genpy_mtx = threading.RLock() | |
Mutex for ensuring exclusive access to genpy generator (genpy.dynamic is not thread-safe) More... | |
master = None | |
rospy.MasterProxy instance More... | |
dictionary | ROS_ALIAS_TYPES = {"byte": "int8", "char": "uint8"} |
Mapping between type aliases and real types, like {"byte": "int8"}. More... | |
dictionary | ROS_TIME_CLASSES = {rospy.Time: "time", rospy.Duration: "duration"} |
ROS1 time/duration types mapped to type names. More... | |
list | ROS_TIME_TYPES = ["time", "duration"] |
ROS1 time/duration types. More... | |
tuple | SKIP_EXTENSIONS = (".bag.orig.active", ) |
Bagfile extensions to skip. More... | |
float | SLEEP_INTERVAL = 0.5 |
Seconds between checking whether ROS master is available. More... | |
dictionary | TYPECLASSES = {} |
{(typename, typehash): message type class} More... | |
def grepros.ros1.canonical | ( | typename, | |
unbounded = False |
|||
) |
def grepros.ros1.create_publisher | ( | topic, | |
cls_or_typename, | |||
queue_size | |||
) |
def grepros.ros1.create_subscriber | ( | topic, | |
typename, | |||
handler, | |||
queue_size | |||
) |
Returns a rospy.Subscriber. Local message packages are not required. Subscribes as AnyMsg, creates message class dynamically from connection info, and deserializes message before providing to handler. Supplemented with .get_message_class(), .get_message_definition(), .get_message_type_hash(), and .get_qoses(). The supplementary .get_message_xyz() methods should only be invoked after at least one message has been received from the topic, as they get populated from live connection metadata.
def grepros.ros1.deserialize_message | ( | raw, | |
cls_or_typename | |||
) |
def grepros.ros1.format_message_value | ( | msg, | |
name, | |||
value | |||
) |
def grepros.ros1.generate_message_classes | ( | typename, | |
typedef | |||
) |
Generates ROS message classes dynamically from given name and definition. Modifies `sys.path` to include the generated Python module. @param typename message type name like "std_msgs/String" @param typedef message type definition full text, including all subtype definitions @return dictionary of {typename: typeclass} for message type and all subtypes
def grepros.ros1.get_message_class | ( | typename | ) |
def grepros.ros1.get_message_definition | ( | msg_or_type | ) |
def grepros.ros1.get_message_fields | ( | val | ) |
def grepros.ros1.get_message_type | ( | msg_or_cls | ) |
def grepros.ros1.get_message_type_hash | ( | msg_or_type | ) |
def grepros.ros1.get_message_value | ( | msg, | |
name, | |||
typename | |||
) |
def grepros.ros1.get_rostime | ( | fallback = False | ) |
def grepros.ros1.get_topic_types | ( | ) |
def grepros.ros1.init_node | ( | name | ) |
def grepros.ros1.is_ros_message | ( | val, | |
ignore_time = False |
|||
) |
def grepros.ros1.is_ros_time | ( | val | ) |
def grepros.ros1.make_duration | ( | secs = 0 , |
|
nsecs = 0 |
|||
) |
def grepros.ros1.make_time | ( | secs = 0 , |
|
nsecs = 0 |
|||
) |
def grepros.ros1.scalar | ( | typename | ) |
def grepros.ros1.serialize_message | ( | msg | ) |
def grepros.ros1.set_message_value | ( | obj, | |
name, | |||
value | |||
) |
def grepros.ros1.shutdown_node | ( | ) |
def grepros.ros1.to_duration | ( | val | ) |
def grepros.ros1.to_nsec | ( | val | ) |
def grepros.ros1.to_sec | ( | val | ) |
def grepros.ros1.to_sec_nsec | ( | val | ) |
def grepros.ros1.to_time | ( | val | ) |
def grepros.ros1.validate | ( | live = False | ) |
|
private |
tuple grepros.ros1.BAG_EXTENSIONS = (".bag", ".bag.active") |
grepros.ros1.genpy_mtx = threading.RLock() |
dictionary grepros.ros1.ROS_ALIAS_TYPES = {"byte": "int8", "char": "uint8"} |
dictionary grepros.ros1.ROS_TIME_CLASSES = {rospy.Time: "time", rospy.Duration: "duration"} |
list grepros.ros1.ROS_TIME_TYPES = ["time", "duration"] |
tuple grepros.ros1.SKIP_EXTENSIONS = (".bag.orig.active", ) |
float grepros.ros1.SLEEP_INTERVAL = 0.5 |