co.cask.coopr.store.provisioner

Class LocalFilePluginStore

java.lang.Object

co.cask.coopr.store.provisioner.LocalFilePluginStore

All Implemented Interfaces:

PluginStore

public class LocalFilePluginStore
extends Object
implements PluginStore

Plugin store that writes resources to the local file system. Modules are namespaced by the data directory given in the configuration, plugin type, plugin type id, resource type, name, and version.

Constructor Summary

Constructors

Constructor and Description
LocalFilePluginStore()

Method Summary

Methods

Modifier and Type	Method and Description
void	deleteResource(Account account, ResourceType type, String name, int version) Delete a plugin resource.
InputStream	getResourceInputStream(Account account, ResourceType type, String name, int version) Get an input stream for reading a plugin resource.
OutputStream	getResourceOutputStream(Account account, ResourceType type, String name, int version) Get an output stream for the given resource.
void	initialize(Configuration conf) Initialize the store.

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalFilePluginStore

public LocalFilePluginStore()

Method Detail

initialize

public void initialize(Configuration conf)

Description copied from interface: PluginStore

Initialize the store. Guaranteed to be called once before any other calls are made.

Specified by:

initialize in interface PluginStore

Parameters:

conf - Configuration for initializing the store

getResourceOutputStream

public OutputStream getResourceOutputStream(Account account,
                                   ResourceType type,
                                   String name,
                                   int version)
                                     throws IOException

Get an output stream for the given resource. Files are namespaced by base data directory, plugin type, plugin name, resource type, resource name, and resource version. For example, version 2 of resource 'hadoop' of type 'cookbook'' for automator type 'chef-solo' with data directory '/var/coopr/data/plugins' will be written to '/var/coopr/data/plugins/automatortypes/chef-solo/cookbook/hadoop/2'.

Specified by:

getResourceOutputStream in interface PluginStore

Parameters:

account - Account that owns the plugin resource

type - Type of resource

name - Name of the resource being written

version - Version of the resource being written

Returns:

Output stream for the file

Throws:

IOException - if there was an error creating the file

getResourceInputStream

public InputStream getResourceInputStream(Account account,
                                 ResourceType type,
                                 String name,
                                 int version)
                                   throws IOException

Description copied from interface: PluginStore

Get an input stream for reading a plugin resource.

Specified by:

getResourceInputStream in interface PluginStore

Parameters:

account - Account that owns the plugin resource

type - Type of resource to get

name - Name of the resource to get

version - Version of the resource to get

Returns:

Input stream for reading the plugin resource, or null if there is no resource

Throws:

IOException - if there is an error getting the input stream

deleteResource

public void deleteResource(Account account,
                  ResourceType type,
                  String name,
                  int version)
                    throws IOException

Description copied from interface: PluginStore

Delete a plugin resource.

Specified by:

deleteResource in interface PluginStore

Parameters:

account - Account that owns the plugin resource

type - Type of resource to delete

name - Name of the resource to delete

version - Version of the resource to delete

Throws:

IOException - if there was an error deleting the resource