bec_lib.connector#

This module defines the interface for a connector

Classes

ConnectorBase

ConnectorBase defines the interface for a connector

MessageObject

MessageObject is a wrapper for a message and its topic

PubSubInterface

PubSubBase defines the interface for a pub/sub connector

StoreInterface

StoreBase defines the interface for storing data

Exceptions

ConsumerConnectorError

ConsumerConnectorError is raised when there is an error with the connector