com.netflix.genie.web.agent.resources

Class AgentFileProtocolResolver

java.lang.Object

com.netflix.genie.web.agent.resources.AgentFileProtocolResolver

All Implemented Interfaces:

org.springframework.core.io.ProtocolResolver

public class AgentFileProtocolResolver
extends java.lang.Object
implements org.springframework.core.io.ProtocolResolver

Resource resolver for files local to an agent running a job that can be streamed to the server and served via API. The URI for such resources is: agent://<jobId>/<relativePath>.

Since:

4.0.0

Constructor Summary

Constructors

Constructor and Description
AgentFileProtocolResolver(AgentFileStreamService agentFileStreamService) Constructor.

Method Summary

Modifier and Type	Method and Description
static java.net.URI	createUri(java.lang.String jobId, java.lang.String path, java.lang.String rangeHeader) Create a URI for the given remote agent file.
org.springframework.core.io.Resource	resolve(java.lang.String location, org.springframework.core.io.ResourceLoader resourceLoader)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AgentFileProtocolResolver

public AgentFileProtocolResolver(AgentFileStreamService agentFileStreamService)

Constructor.

Parameters:

agentFileStreamService - the agent file stream service

Method Detail

createUri

public static java.net.URI createUri(java.lang.String jobId,
                                     java.lang.String path,
                                     @Nullable
                                     java.lang.String rangeHeader)
                              throws java.net.URISyntaxException

Create a URI for the given remote agent file.

Parameters:

jobId - the job id

path - the path of the file within the job directory

rangeHeader - the request range header (as per RFC 7233)

Returns:

a URI representing the remote agent file

Throws:

java.net.URISyntaxException - if constructing the URI fails

resolve

public org.springframework.core.io.Resource resolve(java.lang.String location,
                                                    org.springframework.core.io.ResourceLoader resourceLoader)

Specified by:

resolve in interface org.springframework.core.io.ProtocolResolver