Contents

package org.embulk.input.sftp;

import com.google.common.base.Optional;
import org.embulk.config.Config;
import org.embulk.config.ConfigDefault;
import org.embulk.config.ConfigInject;
import org.embulk.config.Task;
import org.embulk.spi.BufferAllocator;
import org.embulk.spi.unit.LocalFile;

public interface PluginTask
        extends Task, FileList.Task
{
    @Config("host")
    String getHost();

    @Config("port")
    @ConfigDefault("22")
    int getPort();

    @Config("user")
    String getUser();

    @Config("password")
    @ConfigDefault("null")
    Optional<String> getPassword();

    @Config("secret_key_file")
    @ConfigDefault("null")
    Optional<LocalFile> getSecretKeyFile();
    void setSecretKeyFile(Optional<LocalFile> secretKeyFile);

    @Config("secret_key_passphrase")
    @ConfigDefault("\"\"")
    String getSecretKeyPassphrase();

    @Config("user_directory_is_root")
    @ConfigDefault("true")
    Boolean getUserDirIsRoot();

    @Config("timeout")
    @ConfigDefault("600") // 10 minutes
    int getSftpConnectionTimeout();

    @Config("max_connection_retry")
    @ConfigDefault("5") // 5 times retry to connect sftp server if failed.
    int getMaxConnectionRetry();

    @Config("path_prefix")
    String getPathPrefix();

    @Config("incremental")
    @ConfigDefault("true")
    boolean getIncremental();

    @Config("last_path")
    @ConfigDefault("null")
    Optional<String> getLastPath();

    @Config("proxy")
    @ConfigDefault("null")
    Optional<ProxyTask> getProxy();

    FileList getFiles();
    void setFiles(FileList files);

    @ConfigInject
    BufferAllocator getBufferAllocator();
}

Version data entries

13 entries across 13 versions & 1 rubygems

Version	Path
embulk-input-sftp-0.2.12	src/main/java/org/embulk/input/sftp/PluginTask.java
embulk-input-sftp-0.2.11	src/main/java/org/embulk/input/sftp/PluginTask.java
embulk-input-sftp-0.2.10	src/main/java/org/embulk/input/sftp/PluginTask.java
embulk-input-sftp-0.2.9	src/main/java/org/embulk/input/sftp/PluginTask.java
embulk-input-sftp-0.2.8	src/main/java/org/embulk/input/sftp/PluginTask.java
embulk-input-sftp-0.2.7	src/main/java/org/embulk/input/sftp/PluginTask.java
embulk-input-sftp-0.2.6	src/main/java/org/embulk/input/sftp/PluginTask.java
embulk-input-sftp-0.2.5	src/main/java/org/embulk/input/sftp/PluginTask.java
embulk-input-sftp-0.2.4	src/main/java/org/embulk/input/sftp/PluginTask.java
embulk-input-sftp-0.2.3	src/main/java/org/embulk/input/sftp/PluginTask.java
embulk-input-sftp-0.2.2	src/main/java/org/embulk/input/sftp/PluginTask.java
embulk-input-sftp-0.2.1	src/main/java/org/embulk/input/sftp/PluginTask.java
embulk-input-sftp-0.2.0	src/main/java/org/embulk/input/sftp/PluginTask.java