Package com.netflix.genie.agent.execution.services

Interface AgentFileStreamService

All Known Implementing Classes:
GRpcAgentFileStreamServiceImpl
public interface AgentFileStreamService
This service regularly produces a manifest of the executing job folder and pushes it to the server.
Since:
4.0.0

  • Method Summary

    Modifier and Type
    Method
    Description
    Optional<ScheduledFuture<?>>
    forceServerSync()
    Request the service perform an update outside of the regular schedule to make sure the server has the most up-to-date view of local files.
    void
    start(String claimedJobId, Path jobDirectoryPath)
    Start the service.
    void
    stop()
    Stop the service.

  • Method Details

    • start

      void start(String claimedJobId, Path jobDirectoryPath)
      Start the service.
      Parameters:
      claimedJobId - the claimed job id
      jobDirectoryPath - the job directory

    • stop

      void stop()
      Stop the service.

    • forceServerSync

      Optional<ScheduledFuture<?>> forceServerSync()
      Request the service perform an update outside of the regular schedule to make sure the server has the most up-to-date view of local files.
      Returns:
      a scheduled future optional, which the caller can use to synchronously wait on the operation completion and outcome. The optional is empty if the task was not scheduled (because the service is not running).