Contents

package org.embulk.input.riak_cs;

import org.embulk.EmbulkTestRuntime;
import org.embulk.config.ConfigSource;
import org.embulk.input.s3.AbstractS3FileInputPlugin.PluginTask;
import org.junit.Before;
import org.junit.Rule;
import org.junit.Test;

public class TestRiakCsFileInputPlugin
{

    @Rule
    public EmbulkTestRuntime runtime = new EmbulkTestRuntime();

    private RiakCsFileInputPlugin plugin;

    @Before
    public void createPlugin()
    {
        plugin = runtime.getInstance(RiakCsFileInputPlugin.class);
    }

    @Test
    public void createS3ClientSuccessfully()
    {
        ConfigSource config = runtime.getExec().newConfigSource()
                .set("endpoint", "my.endpoint.com")
                .set("bucket", "my_bucket")
                .set("path_prefix", "my_path_prefix")
                .set("access_key_id", "my_access_key_id")
                .set("secret_access_key", "my_secret_access_key");
        PluginTask task = config.loadConfig(plugin.getTaskClass());
        plugin.newS3Client(task);
    }
}

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
embulk-input-riak_cs-0.2.12	src/test/java/org/embulk/input/riak_cs/TestRiakCsFileInputPlugin.java
embulk-input-riak_cs-0.2.11	src/test/java/org/embulk/input/riak_cs/TestRiakCsFileInputPlugin.java
embulk-input-riak_cs-0.2.10	src/test/java/org/embulk/input/riak_cs/TestRiakCsFileInputPlugin.java
embulk-input-riak_cs-0.2.9	src/test/java/org/embulk/input/riak_cs/TestRiakCsFileInputPlugin.java
embulk-input-riak_cs-0.2.8	src/test/java/org/embulk/input/riak_cs/TestRiakCsFileInputPlugin.java
embulk-input-riak_cs-0.2.7	src/test/java/org/embulk/input/riak_cs/TestRiakCsFileInputPlugin.java
embulk-input-riak_cs-0.2.6	src/test/java/org/embulk/input/riak_cs/TestRiakCsFileInputPlugin.java
embulk-input-riak_cs-0.2.5	src/test/java/org/embulk/input/riak_cs/TestRiakCsFileInputPlugin.java