anchor.diff:  -record(state, {version       :: integer(),
                   ensemble_data :: ensembles(),
                   remote_peers  :: orddict(peer_id(), pid()),
  -                cluster_state :: cluster_state(),
  -                subscribers :: [fun()]
  +                cluster_state :: cluster_state()
                  }).
   
   -type state() :: #state{}.
  
positive.code:     end.
  
  -spec state_changed(state()) -> state().
  state_changed(State=#state{ensemble_data=EnsData, cluster_state=CS, subscribers=Subscribers}) ->
      true = ets:insert(?ETS, {cluster_state, CS}),
      true = ets:insert(?ETS, {cluster, riak_ensemble_state:members(CS)}),
      true = ets:insert(?ETS, {enabled, riak_ensemble_state:enabled(CS)}),
  
negative.code:                  %% io:format("Should stop: ~p~n", [{Ensemble, Id}]),
                   ok = riak_ensemble_peer_sup:stop_peer(Ensemble, Id)
           end || Change <- PeerChanges],
      State#state{ensemble_data=NewEnsData}.
  
  -spec request_remote_peers(state()) -> ok.
  