@@ -0,0 +1,1810 @@
+package io.digdag.standards.command.kubernetes;%0A%0Aimport com.google.common.base.Throwables;%0Aimport io.digdag.client.config.Config;%0Aimport io.digdag.core.storage.StorageManager;%0Aimport io.digdag.spi.Storage;%0Aimport io.digdag.spi.StorageFileNotFoundException;%0Aimport java.io.File;%0Aimport java.io.FileInputStream;%0Aimport java.io.IOException;%0Aimport java.io.InputStream;%0Aimport java.nio.file.Path;%0A%0Apublic class TemporalConfigStorage%0A%7B%0A    private static final String TEMPORAL_CONFIG_STORAGE_PARAMS_PREFIX = %22agent.command_executor.kubernetes.config_storage.%22;%0A%0A    public static TemporalConfigStorage createByTarget(final StorageManager storageManager, final String target, final Config systemConfig)%0A    %7B%0A        final Storage storage = storageManager.create(systemConfig, TEMPORAL_CONFIG_STORAGE_PARAMS_PREFIX + target + %22.%22);%0A        return new TemporalConfigStorage(storage);%0A    %7D%0A%0A    private final Storage storage;%0A%0A    private TemporalConfigStorage(final Storage storage)%0A    %7B%0A        this.storage = storage;%0A    %7D%0A%0A    public void uploadFile(final String key, final Path filePath)%0A            throws IOException%0A    %7B%0A        final File file = filePath.toFile();%0A        storage.put(key, file.length(), () -%3E new FileInputStream(file));%0A    %7D%0A%0A    public String getDirectDownloadUrl(final String key)%0A    %7B%0A        return storage.getDirectDownloadHandle(key).get().getUrl().toString();%0A    %7D%0A%0A    public String getDirectUploadUrl(final String key)%0A    %7B%0A        return storage.getDirectUploadHandle(key).get().getUrl().toString();%0A    %7D%0A%0A    public InputStream getContentInputStream(final String key)%0A    %7B%0A        try %7B%0A            return storage.open(key).getContentInputStream();%0A        %7D%0A        catch (StorageFileNotFoundException e) %7B%0A            throw Throwables.propagate(e);%0A        %7D%0A    %7D%0A%7D%0A

introduce TemporalConfigStorage