anchor.diff:  %% API
   start_link() ->
       gen_fsm:start_link({local, ?MODULE}, ?MODULE, [], []).
  -
  -pause() ->
  -    gen_fsm:sync_send_event(?MODULE, pause).
  -
  -unpause() ->
  -    gen_fsm:sync_send_event(?MODULE, unpause).
   
   force_compact_bucket(Bucket) ->
       BucketBin = list_to_binary(Bucket),
  
positive.code: 
      NewState0#state{compaction_start_ts=undefined}.
  
  maybe_kill_scheduled_compaction(#state{scheduled_compaction_tref=TRef} = State) ->
      timer:cancel(TRef),
      receive
          compact ->
              ok
      after 0 ->
              ok
      end,
  
      State#state{scheduled_compaction_tref=undefined}.
  
  now_utc_seconds() ->
      calendar:datetime_to_gregorian_seconds(erlang:universaltime()).
  
  
negative.code: code_change(_OldVsn, StateName, State, _Extra) ->
      {ok, StateName, State}.
  
  %% Internal functions
  -spec spawn_bucket_compactor(binary(), {#config{}, list()}) -> pid().
  spawn_bucket_compactor(BucketName, Configs) ->
  