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.embulk.input.s3.TestS3FileInputPlugin;
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 = TestS3FileInputPlugin.config().set("endpoint", "my.endpoint.com");
        PluginTask task = config.loadConfig(plugin.getTaskClass());
        plugin.newS3Client(task);
    }
}

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
embulk-input-riak_cs-0.2.4	src/test/java/org/embulk/input/riak_cs/TestRiakCsFileInputPlugin.java
embulk-input-riak_cs-0.2.3	src/test/java/org/embulk/input/riak_cs/TestRiakCsFileInputPlugin.java