def __init__(self, server_list, cassandra_driver, **options):
    if (cassandra_driver == 'cql'):
        driverClass = CassandraDriverCQL
    elif (cassandra_driver == 'thrift'):
        driverClass = CassandraDriverThrift
    else:
        raise VncError('datastore driver not selected, see `cassandra_driver`.')
    self._cassandra_driver = driverClass(server_list, **options)
    self._logger = self._cassandra_driver.options.logger
    self._logger('VNCCassandra started with driver {}'.format(driverClass), level=SandeshLevel.SYS_INFO)
    self._cache_uuid_to_fq_name = {}
    self._obj_cache_mgr = ObjectCacheManager(self._cassandra_driver.options.logger, self, max_entries=self._cassandra_driver.options.obj_cache_entries, obj_cache_exclude_types=self._cassandra_driver.options.obj_cache_exclude_types, debug_obj_cache_types=self._cassandra_driver.options.debug_obj_cache_types)
    self._obj_cache_exclude_types = (self._cassandra_driver.options.obj_cache_exclude_types or [])
    self.object_update = self._cassandra_driver._handle_exceptions(self.object_update)
    self.object_list = self._cassandra_driver._handle_exceptions(self.object_list)
    self.object_read = self._cassandra_driver._handle_exceptions(self.object_read)
    self.object_raw_read = self._cassandra_driver._handle_exceptions(self.object_raw_read)
    self.object_delete = self._cassandra_driver._handle_exceptions(self.object_delete)
    self.prop_collection_read = self._cassandra_driver._handle_exceptions(self.prop_collection_read)
    self.uuid_to_fq_name = self._cassandra_driver._handle_exceptions(self.uuid_to_fq_name)
    self.uuid_to_obj_type = self._cassandra_driver._handle_exceptions(self.uuid_to_obj_type)
    self.fq_name_to_uuid = self._cassandra_driver._handle_exceptions(self.fq_name_to_uuid)
    self.get_shared = self._cassandra_driver._handle_exceptions(self.get_shared)
    self.walk = self._cassandra_driver._handle_exceptions(self.walk)
    if self._cassandra_driver.options.walk:
        self.walk()
def __init__(self, server_list, cassandra_driver, **options):
    if (cassandra_driver == 'cql'):
        driverClass = CassandraDriverCQL
    elif (cassandra_driver == 'thrift'):
        driverClass = CassandraDriverThrift
    else:
        raise VncError('datastore driver not selected, see `cassandra_driver`.')
    self._cassandra_driver = driverClass(server_list, **options)
    self._logger = self._cassandra_driver.options.logger
    self._logger('VNCCassandra started with driver {}'.format(driverClass), level=SandeshLevel.SYS_INFO)
    self._cache_uuid_to_fq_name = {}
    self._obj_cache_mgr = ObjectCacheManager(self._cassandra_driver.options.logger, self, max_entries=self._cassandra_driver.options.obj_cache_entries, obj_cache_exclude_types=self._cassandra_driver.options.obj_cache_exclude_types, debug_obj_cache_types=self._cassandra_driver.options.debug_obj_cache_types)
    self._obj_cache_exclude_types = (self._cassandra_driver.options.obj_cache_exclude_types or [])
    self.object_update = self._cassandra_driver._handle_exceptions(self.object_update)
    self.object_list = self._cassandra_driver._handle_exceptions(self.object_list)
    self.object_read = self._cassandra_driver._handle_exceptions(self.object_read)
    self.object_raw_read = self._cassandra_driver._handle_exceptions(self.object_raw_read)
    self.object_delete = self._cassandra_driver._handle_exceptions(self.object_delete)
    self.prop_collection_read = self._cassandra_driver._handle_exceptions(self.prop_collection_read)
    self.uuid_to_fq_name = self._cassandra_driver._handle_exceptions(self.uuid_to_fq_name)
    self.uuid_to_obj_type = self._cassandra_driver._handle_exceptions(self.uuid_to_obj_type)
    self.fq_name_to_uuid = self._cassandra_driver._handle_exceptions(self.fq_name_to_uuid)
    self.get_shared = self._cassandra_driver._handle_exceptions(self.get_shared)
    self.walk = self._cassandra_driver._handle_exceptions(self.walk)
    if self._cassandra_driver.options.walk:
        self.walk()