org.thales.punch.libraries.punchlang.resource

Class S3RemoteResourceHandler

java.lang.Object

org.thales.punch.libraries.punchlang.resource.AbstractRemoteResourceHandler

org.thales.punch.libraries.punchlang.resource.S3RemoteResourceHandler

All Implemented Interfaces:

Serializable, Runnable, Supplier<Tuple>

public class S3RemoteResourceHandler
extends AbstractRemoteResourceHandler

A S3 remote resource loader based on Minio client.

Author:

dimi

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.thales.punch.libraries.punchlang.resource.AbstractRemoteResourceHandler

AbstractRemoteResourceHandler.AtomicTupleReference

Field Summary

Fields

Modifier and Type	Field and Description
protected String	s3Bucket
protected String	s3Endpoint
protected Path	s3Key
protected String	s3Object
protected Path	s3Secret

Fields inherited from class org.thales.punch.libraries.punchlang.resource.AbstractRemoteResourceHandler

atomicTupleReference, builder, logger, requiredResource, resourceUuid

Constructor Summary

Constructors

Constructor and Description
S3RemoteResourceHandler(String resourceUuid, String s3Endpoint, String s3Bucket, String s3Object, Path s3Key, Path s3Secret, IResourceBuilder builder, String cron, boolean requiredResource, boolean silent, org.thales.punch.libraries.metrics.api.IMetricContext mc) S3 CTOR

Method Summary

Modifier and Type	Method and Description
protected static Tuple	getResourceFromS3(IResourceBuilder builder, String endpoint, String bucket, String object, Path accessKey, Path secretKey)
void	reload()

Methods inherited from class org.thales.punch.libraries.punchlang.resource.AbstractRemoteResourceHandler

clear, get, loadingFailures, loadingSuccess, run, start, startLoading, stop, stopLoading

Methods inherited from class java.lang.Object

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

Field Detail

s3Endpoint

protected String s3Endpoint

s3Bucket

protected String s3Bucket

s3Key

protected Path s3Key

s3Secret

protected Path s3Secret

s3Object

protected String s3Object

Constructor Detail

S3RemoteResourceHandler

public S3RemoteResourceHandler(String resourceUuid,
                               String s3Endpoint,
                               String s3Bucket,
                               String s3Object,
                               Path s3Key,
                               Path s3Secret,
                               IResourceBuilder builder,
                               String cron,
                               boolean requiredResource,
                               boolean silent,
                               org.thales.punch.libraries.metrics.api.IMetricContext mc)

S3 CTOR

Parameters:

s3Endpoint - the S3 HTTPS endpoint

s3Bucket - the S3 bucket

s3Object - the S3 object, i.e. resource file

s3Key - the S3 access key

s3Secret - the S3 secret

cron - the CRON expression. If null no thread is launched.

builder - the resource builder in charge of transforming the loaded resources

requiredResource - true to make it mandatory to load the resource first

mc - the metrics context

Method Detail

getResourceFromS3

protected static Tuple getResourceFromS3(IResourceBuilder builder,
                                         String endpoint,
                                         String bucket,
                                         String object,
                                         Path accessKey,
                                         Path secretKey)
                                  throws IOException

Throws:

IOException

reload

public void reload()
            throws IOException

Specified by:

reload in class AbstractRemoteResourceHandler

Throws:

IOException