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

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