Method __init__

tests/unit/test_control_connection.py:76–83

(self)

    is_shutdown = False

    def __init__(self):
        self.metadata = MockMetadata()
        self.added_hosts = []
        self.removed_hosts = []
        self.scheduler = Mock(spec=_Scheduler)
        self.executor = Mock(spec=ThreadPoolExecutor)
        self.profile_manager.profiles[EXEC_PROFILE_DEFAULT] = ExecutionProfile(RoundRobinPolicy())
        self.endpoint_factory = DefaultEndPointFactory().configure(self)

    def add_host(self, endpoint, datacenter, rack, signal=False, refresh_nodes=True):
        host = Host(endpoint, SimpleConvictionPolicy, datacenter, rack)