@type phase() :: :connection_setup | :running

@type step() ::
  {:start_replication_client, nil}
  | {:start_replication_client, :acquiring_lock}
  | {:start_replication_client, :connecting}
  | {:start_replication_client, :configuring_connection}
  | {:start_connection_pool, nil}
  | {:start_connection_pool, :connecting}
  | :start_shapes_supervisor
  | {:start_replication_client, :start_streaming}
  | :waiting_for_streaming_confirmation
  | :streaming