anchor.diff:  %% @private
   -spec init([]) -> {ok, #state{}}.
   init([]) ->
  -    %% Don't start the timer if we're not running in Mesos.
  -    case os:getenv("MESOS_TASK_ID") of
  -        false ->
  -            lager:info("Not running in Mesos; disabling Marathon service."),
  +    Orchestration = case {os:getenv("MESOS_TASK_ID"),
  +                          os:getenv("KUBERNETES_PORT")} of
  +        {Value, false} when is_list(Value) ->
  +            mesos;
  +        {false, Value} when is_list(Value) ->
  +            kubernetes;
  +        {_, _} ->
  +            undefined
  +    end,
  +
  +    case Orchestration of
  +        undefined ->
  +            lager:info("Not using container orchestration; disabling."),
               ok;
           _ ->
  +            lager:info("Orchestration: ~p", [Orchestration]),
  +
               %% Configure erlcloud.
               S3Host = "s3-us-west-2.amazonaws.com",
               AccessKeyId = os:getenv("AWS_ACCESS_KEY_ID"),
  
positive.code:                 server ->
                      schedule_build_graph();
                  client ->
                      ok
              end,
  
  
negative.code: 
  %% @private
  -spec handle_info(term(), #state{}) -> {noreply, #state{}}.
  handle_info(?REFRESH_MESSAGE, #state{orchestration=Orchestration,
                                       attempted_nodes=SeenNodes}=State) ->
      Tag = partisan_config:get(tag, client),
      PeerServiceManager = lasp_config:peer_service_manager(),
  
      Servers = servers(Orchestration),
      Clients = clients(Orchestration),
  
      %% Get list of nodes to connect to: this specialized logic isn't
      %% required when the node count is small, but is required with a
  