Package org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.runtime.runc

Class ImageTagToManifestPlugin

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.runtime.runc.ImageTagToManifestPlugin

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.service.Service, RuncImageTagToManifestPlugin

@Unstable
public class ImageTagToManifestPlugin
extends org.apache.hadoop.service.AbstractService
implements RuncImageTagToManifestPlugin

This class is a plugin for the RuncContainerRuntime to convert image tags into runC image manifests.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

org.apache.hadoop.service.Service.STATE

Constructor Summary

Constructors

Constructor	Description
ImageTagToManifestPlugin()

Method Summary

Modifier and Type	Method	Description
String	getHashFromImageTag(String imageTag)
protected BufferedReader	getHdfsImageToHashReader()
protected BufferedReader	getLocalImageToHashReader()
ImageManifest	getManifestFromImageTag(String imageTag)
boolean	loadImageToHashFiles()
protected static Map<String,String>	readImageToHashFile(BufferedReader br)	You may specify multiple tags per hash all on the same line.
protected void	serviceInit(org.apache.hadoop.conf.Configuration configuration)
protected void	serviceStart()
protected void	serviceStop()

Methods inherited from class org.apache.hadoop.service.AbstractService

close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.service.Service

close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, registerServiceListener, start, stop, unregisterServiceListener, waitForServiceToStop

Constructor Details

ImageTagToManifestPlugin

public ImageTagToManifestPlugin()

Method Details

getManifestFromImageTag

public ImageManifest getManifestFromImageTag(String imageTag)
                                      throws IOException

Specified by:

getManifestFromImageTag in interface RuncImageTagToManifestPlugin

Throws:

IOException

getHashFromImageTag

public String getHashFromImageTag(String imageTag)

Specified by:

getHashFromImageTag in interface RuncImageTagToManifestPlugin

getLocalImageToHashReader

protected BufferedReader getLocalImageToHashReader()
                                            throws IOException

Throws:

IOException

getHdfsImageToHashReader

protected BufferedReader getHdfsImageToHashReader()
                                           throws IOException

Throws:

IOException

readImageToHashFile

protected static Map<String,String> readImageToHashFile(BufferedReader br)
                                                 throws IOException

You may specify multiple tags per hash all on the same line. Comments are allowed using #. Anything after this character will not be read Example file: foo/bar:current,fizz/gig:latest:123456789 #this/line:wont,be:parsed:2378590895 This will map both foo/bar:current and fizz/gig:latest to 123456789

Throws:

IOException

loadImageToHashFiles

public boolean loadImageToHashFiles()
                             throws IOException

Throws:

IOException

serviceInit

protected void serviceInit(org.apache.hadoop.conf.Configuration configuration)
                    throws Exception

Overrides:

serviceInit in class org.apache.hadoop.service.AbstractService

Throws:

Exception

serviceStart

protected void serviceStart()
                     throws Exception

Overrides:

serviceStart in class org.apache.hadoop.service.AbstractService

Throws:

Exception

serviceStop

protected void serviceStop()
                    throws Exception

Overrides:

serviceStop in class org.apache.hadoop.service.AbstractService

Throws:

Exception