Documentation ¶
Index ¶
- Constants
- func CheckNewRelease() (*selfupdate.Release, error)
- func CheckSafeStagingDir(stagingPath string) error
- func CleanUpOldIRODSBundles(fs *irodsclient_fs.FileSystem, irodsTempDirPath string, removeDir bool, ...)
- func CleanUpOldLocalBundles(localTempDirPath string, force bool)
- func DecodePrivateKey(privatekeyPath string) (*rsa.PrivateKey, error)
- func DecodePublicKey(publickeyPath string) (*rsa.PublicKey, error)
- func DecodePublicPrivateKey(keyPath string) (interface{}, error)
- func DecryptAESCTR(data []byte, salt []byte, key []byte) ([]byte, error)
- func DecryptAESCTRReaderWriter(reader io.Reader, writer io.Writer, salt []byte, key []byte) error
- func DecryptFilePGP(source string, target string, key []byte) error
- func DecryptFileSSH(source string, target string, privatekey *rsa.PrivateKey) error
- func DecryptFileWinSCP(source string, target string, key []byte) error
- func DecryptFilenamePGP(filename string) string
- func DecryptFilenameSSH(filename string, privatekey *rsa.PrivateKey) (string, error)
- func DecryptFilenameWinSCP(filename string, key []byte) (string, error)
- func EncryptAESCTR(data []byte, salt []byte, key []byte) ([]byte, error)
- func EncryptAESCTRReaderWriter(reader io.Reader, writer io.Writer, salt []byte, key []byte) error
- func EncryptFilePGP(source string, target string, key []byte) error
- func EncryptFileSSH(source string, target string, publickey *rsa.PublicKey) error
- func EncryptFileWinSCP(source string, target string, key []byte) error
- func EncryptFilenamePGP(filename string) string
- func EncryptFilenameSSH(filename string, publickey *rsa.PublicKey) (string, error)
- func EncryptFilenameWinSCP(filename string, key []byte) (string, error)
- func ExistFile(p string) bool
- func ExpandHomeDir(p string) (string, error)
- func FirstDelimeterIndex(p string) int
- func GetAccount() *irodsclient_types.IRODSAccount
- func GetBasename(p string) string
- func GetBundleFilename(hash string) string
- func GetCWD() string
- func GetClientVersion() string
- func GetCommonRootLocalDirPath(paths []string) (string, error)
- func GetCommonRootLocalDirPathForSync(paths []string) (string, error)
- func GetDefaultIRODSConfigPath() string
- func GetDefaultPrivateKeyPath() string
- func GetDefaultPublicKeyPath() string
- func GetDefaultStagingDir(targetPath string) string
- func GetDefaultStagingDirInTargetPath(targetPath string) string
- func GetDir(p string) string
- func GetEnvironmentManager() *irodsclient_icommands.ICommandsEnvironmentManager
- func GetFileExtension(p string) string
- func GetHomeDir() string
- func GetIRODSConnection(account *irodsclient_types.IRODSAccount) (*irodsclient_conn.IRODSConnection, error)
- func GetIRODSFSClient(account *irodsclient_types.IRODSAccount) (*irodsclient_fs.FileSystem, error)
- func GetIRODSFSClientAdvanced(account *irodsclient_types.IRODSAccount, maxConnection int, tcpBufferSize int) (*irodsclient_fs.FileSystem, error)
- func GetParentIRODSDirs(p string) []string
- func GetParentLocalDirs(p string) []string
- func GetProgressWriter(displayPath bool) progress.Writer
- func GetResourceServers(fs *irodsclient_fs.FileSystem, targetDir string) ([]string, error)
- func GetSessionID() int
- func GetShortPathMessage(name string, messageLen int) string
- func GetUsername() string
- func GetVersionJSON() (string, error)
- func GetVersionParts(version string) (int, int, int)
- func GetZone() string
- func InputMissingFields() (bool, error)
- func InputMissingFieldsFromStdin() error
- func InputYN(msg string) bool
- func IsBundleFilename(p string) bool
- func IsCorrectFilename(filename []byte) bool
- func IsDigitsOnly(s string) bool
- func IsNewerVersion(ver1 []int, ver2 []int) bool
- func IsStagingDirInTargetPath(stagingPath string) bool
- func LastDelimeterIndex(p string) int
- func LoadAndOverwriteConfigFromEnv() error
- func LoadConfigFromFile(configPath string) error
- func MakeDateTimeFromString(str string) (time.Time, error)
- func MakeDateTimeString(t time.Time) string
- func MakeIRODSPath(cwd string, homedir string, zone string, irodsPath string) string
- func MakeLocalPath(localPath string) string
- func MakeTargetIRODSFilePath(filesystem *irodsclient_fs.FileSystem, source string, target string) string
- func MakeTargetLocalFilePath(source string, target string) string
- func MarkPathMap(pathMap map[string]bool, p string)
- func PadPkcs7(data []byte, blocksize int) []byte
- func ParseSize(size string) (int64, error)
- func ParseTime(t string) (int, error)
- func PrintAccount() error
- func PrintEnvironment() error
- func Printf(format string, a ...any) (n int, err error)
- func Println(a ...any) (n int, err error)
- func ReinputFields() (bool, error)
- func RunWithRetry(retry int, retryInterval int) error
- func SelfUpgrade() error
- func SetCWD(cwd string) error
- func SetDefaultConfigIfEmpty()
- func SetSessionID(id int)
- func SyncAccount() error
- func Tar(baseDir string, sources []string, target string, callback TrackerCallBack) error
- func ValidateStagingDir(fs *irodsclient_fs.FileSystem, targetPath string, stagingPath string) (bool, error)
- type Bundle
- type BundleEntry
- type BundleTransferManager
- func (manager *BundleTransferManager) CleanUpBundles()
- func (manager *BundleTransferManager) DoneScheduling()
- func (manager *BundleTransferManager) GetBundles() []*Bundle
- func (manager *BundleTransferManager) GetFilesystem() *irodsclient_fs.FileSystem
- func (manager *BundleTransferManager) GetInputPathMap() map[string]bool
- func (manager *BundleTransferManager) Schedule(source string, dir bool, size int64, lastModTime time.Time) error
- func (manager *BundleTransferManager) SetBundleRootPath(bundleRootPath string)
- func (manager *BundleTransferManager) Start()
- func (manager *BundleTransferManager) Wait() error
- type Config
- type ConfigTypeIn
- type EncryptionConfig
- type EncryptionManager
- func (manager *EncryptionManager) DecryptFile(source string, target string) error
- func (manager *EncryptionManager) DecryptFilename(filename string) (string, error)
- func (manager *EncryptionManager) EncryptFile(source string, target string) error
- func (manager *EncryptionManager) EncryptFilename(filename string) (string, error)
- func (manager *EncryptionManager) SetKey(key []byte)
- func (manager *EncryptionManager) SetPublicPrivateKey(keyPath string)
- type EncryptionMode
- type ListFormat
- type ListSortOrder
- type ParallelJob
- type ParallelJobManager
- func (manager *ParallelJobManager) DoneScheduling()
- func (manager *ParallelJobManager) GetFilesystem() *irodsclient_fs.FileSystem
- func (manager *ParallelJobManager) Schedule(name string, task ParallelJobTask, threadsRequired int, ...) error
- func (manager *ParallelJobManager) Start()
- func (manager *ParallelJobManager) Wait() error
- type ParallelJobTask
- type ProgressTrackerCallback
- type TarEntry
- type TrackerCallBack
- type VersionInfo
Constants ¶
const ( MaxBundleFileNumDefault int = 50 MaxBundleFileSizeDefault int64 = 2 * 1024 * 1024 * 1024 // 2GB MinBundleFileNumDefault int = 3 )
default values
const ( BundleTaskNameRemoveFilesAndMakeDirs string = "Cleaning & making dirs" BundleTaskNameTar string = "Bundling" BundleTaskNameUpload string = "Uploading" BundleTaskNameExtract string = "Extracting" )
const ( PortDefault int = 1247 AuthenticationSchemeDefault string = string(irodsclient_types.AuthSchemeNative) ClientServerPolicyDefault string = string(irodsclient_types.CSNegotiationRequireTCP) EncryptionKeySizeDefault int = 32 EncryptionAlgorithmDefault string = "AES-256-CBC" SaltSizeDefault int = 8 HashRoundsDefault int = 16 )
const ( TransferTreadNumDefault int = 5 UploadTreadNumMax int = 20 TcpBufferSizeDefault int = 4 * 1024 * 1024 TcpBufferSizeStringDefault string = "4MB" RedirectToResourceMinSize int64 = 1024 * 1024 * 1024 // 1GB ParallelUploadMinSize int64 = 80 * 1024 * 1024 // 80MB )
const ( PgpEncryptedFileExtension string = ".pgp.enc" PgpSalt string = "4e2f34041d564ed8" )
const ( SshEncryptedFileExtension string = ".rsaaesctr.enc" SshRsaAesCtrHeader string = "rsaaesctr......." )
const ( WinSCPEncryptedFileExtension string = ".aesctr.enc" WinSCPAesCtrHeader string = "aesctr.........." )
const ( KiloBytes int64 = 1024 MegaBytes int64 = KiloBytes * 1024 GigaBytes int64 = MegaBytes * 1024 TeraBytes int64 = GigaBytes * 1024 Minute int = 60 Hour int = Minute * 60 Day int = Hour * 24 )
const (
AesSaltLen int = 16
)
const (
ClientProgramName string = "gocommands"
)
Variables ¶
This section is empty.
Functions ¶
func CheckNewRelease ¶ added in v0.6.2
func CheckNewRelease() (*selfupdate.Release, error)
func CheckSafeStagingDir ¶ added in v0.7.5
func CleanUpOldIRODSBundles ¶ added in v0.5.7
func CleanUpOldIRODSBundles(fs *irodsclient_fs.FileSystem, irodsTempDirPath string, removeDir bool, force bool)
func CleanUpOldLocalBundles ¶ added in v0.5.7
func DecodePrivateKey ¶ added in v0.9.4
func DecodePrivateKey(privatekeyPath string) (*rsa.PrivateKey, error)
func DecodePublicKey ¶ added in v0.9.4
func DecodePublicPrivateKey ¶ added in v0.9.4
DecodePublicPrivateKey decodes public or private key
func DecryptAESCTR ¶ added in v0.9.4
func DecryptAESCTRReaderWriter ¶ added in v0.9.4
func DecryptFilePGP ¶ added in v0.9.4
func DecryptFileSSH ¶ added in v0.9.4
func DecryptFileSSH(source string, target string, privatekey *rsa.PrivateKey) error
func DecryptFileWinSCP ¶ added in v0.9.4
func DecryptFilenamePGP ¶ added in v0.9.4
func DecryptFilenameSSH ¶ added in v0.9.4
func DecryptFilenameSSH(filename string, privatekey *rsa.PrivateKey) (string, error)
func DecryptFilenameWinSCP ¶ added in v0.9.4
func EncryptAESCTR ¶ added in v0.9.4
func EncryptAESCTRReaderWriter ¶ added in v0.9.4
func EncryptFilePGP ¶ added in v0.9.4
func EncryptFileSSH ¶ added in v0.9.4
func EncryptFileWinSCP ¶ added in v0.9.4
func EncryptFilenamePGP ¶ added in v0.9.4
func EncryptFilenameSSH ¶ added in v0.9.4
func EncryptFilenameWinSCP ¶ added in v0.9.4
func ExpandHomeDir ¶
func FirstDelimeterIndex ¶ added in v0.8.1
func GetAccount ¶
func GetAccount() *irodsclient_types.IRODSAccount
GetAccount returns irods account
func GetBasename ¶
func GetBundleFilename ¶ added in v0.8.1
func GetClientVersion ¶
func GetClientVersion() string
GetClientVersion returns client version in string
func GetCommonRootLocalDirPathForSync ¶ added in v0.5.5
func GetDefaultIRODSConfigPath ¶ added in v0.9.4
func GetDefaultIRODSConfigPath() string
GetDefaultIRODSConfigPath returns default config path
func GetDefaultPrivateKeyPath ¶ added in v0.9.4
func GetDefaultPrivateKeyPath() string
GetDefaultPrivateKeyPath returns default private key path
func GetDefaultPublicKeyPath ¶ added in v0.9.4
func GetDefaultPublicKeyPath() string
GetDefaultPublicKeyPath returns default public key path, if public key does not exist, return private key path.
func GetDefaultStagingDir ¶ added in v0.4.7
func GetDefaultStagingDirInTargetPath ¶ added in v0.4.7
func GetEnvironmentManager ¶
func GetEnvironmentManager() *irodsclient_icommands.ICommandsEnvironmentManager
GetEnvironmentManager returns environment manager
func GetFileExtension ¶
func GetIRODSConnection ¶
func GetIRODSConnection(account *irodsclient_types.IRODSAccount) (*irodsclient_conn.IRODSConnection, error)
GetIRODSConnection returns a connection
func GetIRODSFSClient ¶
func GetIRODSFSClient(account *irodsclient_types.IRODSAccount) (*irodsclient_fs.FileSystem, error)
GetIRODSFSClient returns a file system client
func GetIRODSFSClientAdvanced ¶ added in v0.6.3
func GetIRODSFSClientAdvanced(account *irodsclient_types.IRODSAccount, maxConnection int, tcpBufferSize int) (*irodsclient_fs.FileSystem, error)
GetIRODSFSClientAdvanced returns a file system client
func GetParentIRODSDirs ¶ added in v0.8.1
GetParentDirs returns all parent dirs
func GetParentLocalDirs ¶
GetParentLocalDirs returns all parent dirs
func GetProgressWriter ¶ added in v0.8.1
func GetResourceServers ¶ added in v0.4.7
func GetResourceServers(fs *irodsclient_fs.FileSystem, targetDir string) ([]string, error)
func GetShortPathMessage ¶ added in v0.8.1
func GetVersionJSON ¶
GetVersionJSON returns VersionInfo object in JSON string
func GetVersionParts ¶ added in v0.6.0
GetVersionParts returns version parts (major, minor, patch)
func InputMissingFields ¶
InputMissingFields inputs missing fields
func InputMissingFieldsFromStdin ¶ added in v0.5.0
func InputMissingFieldsFromStdin() error
InputMissingFieldsFromStdin inputs missing fields
func IsBundleFilename ¶ added in v0.8.1
func IsCorrectFilename ¶ added in v0.9.4
func IsDigitsOnly ¶ added in v0.9.3
IsDigitsOnly checks if the given string contains only digits
func IsNewerVersion ¶ added in v0.6.0
IsNewerVersion compares ver1 against ver2
func IsStagingDirInTargetPath ¶ added in v0.5.7
func LastDelimeterIndex ¶ added in v0.8.1
func LoadAndOverwriteConfigFromEnv ¶ added in v0.8.3
func LoadAndOverwriteConfigFromEnv() error
LoadAndOverwriteConfigFromEnv loads config from env and overwrites to existing env
func LoadConfigFromFile ¶ added in v0.7.5
func MakeDateTimeFromString ¶ added in v0.7.0
func MakeDateTimeString ¶
func MakeIRODSPath ¶
func MakeLocalPath ¶
func MakeTargetIRODSFilePath ¶ added in v0.4.6
func MakeTargetIRODSFilePath(filesystem *irodsclient_fs.FileSystem, source string, target string) string
func MakeTargetLocalFilePath ¶ added in v0.4.6
func MarkPathMap ¶ added in v0.8.1
func PrintAccount ¶
func PrintAccount() error
func PrintEnvironment ¶
func PrintEnvironment() error
func ReinputFields ¶ added in v0.7.4
ReinputFields re-inputs fields
func RunWithRetry ¶ added in v0.5.0
func SelfUpgrade ¶ added in v0.6.2
func SelfUpgrade() error
func SetDefaultConfigIfEmpty ¶ added in v0.7.5
func SetDefaultConfigIfEmpty()
SetDefaultConfigIfEmpty sets default config if empty
func Tar ¶
func Tar(baseDir string, sources []string, target string, callback TrackerCallBack) error
func ValidateStagingDir ¶ added in v0.4.7
func ValidateStagingDir(fs *irodsclient_fs.FileSystem, targetPath string, stagingPath string) (bool, error)
Types ¶
type Bundle ¶
type Bundle struct {
// contains filtered or unexported fields
}
func (*Bundle) GetBundleFilename ¶ added in v0.8.1
func (*Bundle) GetEntries ¶ added in v0.7.12
func (bundle *Bundle) GetEntries() []*BundleEntry
type BundleEntry ¶ added in v0.7.12
type BundleTransferManager ¶
type BundleTransferManager struct {
// contains filtered or unexported fields
}
func NewBundleTransferManager ¶
func NewBundleTransferManager(fs *irodsclient_fs.FileSystem, irodsDestPath string, maxBundleFileNum int, maxBundleFileSize int64, singleThreaded bool, uploadThreadNum int, localTempDirPath string, irodsTempDirPath string, diff bool, noHash bool, noBulkReg bool, showProgress bool) *BundleTransferManager
NewBundleTransferManager creates a new BundleTransferManager
func (*BundleTransferManager) CleanUpBundles ¶ added in v0.4.7
func (manager *BundleTransferManager) CleanUpBundles()
func (*BundleTransferManager) DoneScheduling ¶ added in v0.4.6
func (manager *BundleTransferManager) DoneScheduling()
func (*BundleTransferManager) GetBundles ¶ added in v0.7.12
func (manager *BundleTransferManager) GetBundles() []*Bundle
func (*BundleTransferManager) GetFilesystem ¶ added in v0.7.12
func (manager *BundleTransferManager) GetFilesystem() *irodsclient_fs.FileSystem
func (*BundleTransferManager) GetInputPathMap ¶ added in v0.7.12
func (manager *BundleTransferManager) GetInputPathMap() map[string]bool
func (*BundleTransferManager) SetBundleRootPath ¶ added in v0.4.6
func (manager *BundleTransferManager) SetBundleRootPath(bundleRootPath string)
func (*BundleTransferManager) Start ¶ added in v0.4.6
func (manager *BundleTransferManager) Start()
func (*BundleTransferManager) Wait ¶ added in v0.4.6
func (manager *BundleTransferManager) Wait() error
type Config ¶
type Config struct { CurrentWorkingDir string `yaml:"irods_cwd,omitempty" envconfig:"IRODS_CWD"` Host string `yaml:"irods_host,omitempty" envconfig:"IRODS_HOST"` Port int `yaml:"irods_port,omitempty" envconfig:"IRODS_PORT"` Username string `yaml:"irods_user_name,omitempty" envconfig:"IRODS_USER_NAME"` ClientUsername string `yaml:"irods_client_user_name,omitempty" envconfig:"IRODS_CLIENT_USER_NAME"` Zone string `yaml:"irods_zone_name,omitempty" envconfig:"IRODS_ZONE_NAME"` DefaultResource string `yaml:"irods_default_resource,omitempty" envconfig:"IRODS_DEFAULT_RESOURCE"` LogLevel int `yaml:"irods_log_level,omitempty" envconfig:"IRODS_LOG_LEVEL"` Password string `yaml:"irods_user_password,omitempty" envconfig:"IRODS_USER_PASSWORD"` Ticket string `yaml:"irods_ticket,omitempty" envconfig:"IRODS_TICKET"` AuthenticationScheme string `yaml:"irods_authentication_scheme,omitempty" envconfig:"IRODS_AUTHENTICATION_SCHEME"` ClientServerNegotiation string `yaml:"irods_client_server_negotiation,omitempty" envconfig:"IRODS_CLIENT_SERVER_NEGOTIATION"` ClientServerPolicy string `yaml:"irods_client_server_policy,omitempty" envconfig:"IRODS_CLIENT_SERVER_POLICY"` SSLCACertificateFile string `yaml:"irods_ssl_ca_certificate_file,omitempty" envconfig:"IRODS_SSL_CA_CERTIFICATE_FILE"` SSLCACertificatePath string `yaml:"irods_ssl_ca_certificate_path,omitempty" envconfig:"IRODS_SSL_CA_CERTIFICATE_PATH"` EncryptionKeySize int `yaml:"irods_encryption_key_size,omitempty" envconfig:"IRODS_ENCRYPTION_KEY_SIZE"` EncryptionAlgorithm string `yaml:"irods_encryption_algorithm,omitempty" envconfig:"IRODS_ENCRYPTION_ALGORITHM"` EncryptionSaltSize int `yaml:"irods_encryption_salt_size,omitempty" envconfig:"IRODS_ENCRYPTION_SALT_SIZE"` EncryptionNumHashRounds int `yaml:"irods_encryption_num_hash_rounds,omitempty" envconfig:"IRODS_ENCRYPTION_NUM_HASH_ROUNDS"` }
func GetDefaultConfig ¶ added in v0.4.2
func GetDefaultConfig() *Config
func NewConfigFromENV ¶
NewConfigFromENV creates Config from Environmental variables
type ConfigTypeIn ¶ added in v0.5.0
type ConfigTypeIn struct { Host string `yaml:"irods_host,omitempty"` Port int `yaml:"irods_port,omitempty"` Zone string `yaml:"irods_zone_name,omitempty"` Username string `yaml:"irods_user_name,omitempty"` Password string `yaml:"irods_user_password,omitempty"` }
func NewConfigTypeInFromYAML ¶ added in v0.5.0
func NewConfigTypeInFromYAML(yamlBytes []byte) (*ConfigTypeIn, error)
NewConfigTypeInFromYAML creates ConfigTypeIn from YAML
func (*ConfigTypeIn) ToYAML ¶ added in v0.5.0
func (config *ConfigTypeIn) ToYAML() ([]byte, error)
type EncryptionConfig ¶ added in v0.9.4
type EncryptionConfig struct { Required bool Mode EncryptionMode }
func GetEncryptionConfigFromMeta ¶ added in v0.9.4
func GetEncryptionConfigFromMeta(filesystem *irodsclient_fs.FileSystem, targetPath string) *EncryptionConfig
GetEncryptionConfigFromMeta returns encryption config from meta
type EncryptionManager ¶ added in v0.8.3
type EncryptionManager struct {
// contains filtered or unexported fields
}
func NewEncryptionManager ¶ added in v0.8.3
func NewEncryptionManager(mode EncryptionMode) *EncryptionManager
NewEncryptionManager creates a new EncryptionManager
func (*EncryptionManager) DecryptFile ¶ added in v0.8.3
func (manager *EncryptionManager) DecryptFile(source string, target string) error
DecryptFile decrypts local source file and returns decrypted file path
func (*EncryptionManager) DecryptFilename ¶ added in v0.8.3
func (manager *EncryptionManager) DecryptFilename(filename string) (string, error)
DecryptFilename decrypts filename
func (*EncryptionManager) EncryptFile ¶ added in v0.8.3
func (manager *EncryptionManager) EncryptFile(source string, target string) error
EncryptFile encrypts local source file and returns encrypted file path
func (*EncryptionManager) EncryptFilename ¶ added in v0.8.3
func (manager *EncryptionManager) EncryptFilename(filename string) (string, error)
EncryptFilename encrypts filename
func (*EncryptionManager) SetKey ¶ added in v0.9.4
func (manager *EncryptionManager) SetKey(key []byte)
SetKey sets key
func (*EncryptionManager) SetPublicPrivateKey ¶ added in v0.9.4
func (manager *EncryptionManager) SetPublicPrivateKey(keyPath string)
SetPublicPrivateKey sets public or private key automatically
type EncryptionMode ¶ added in v0.8.3
type EncryptionMode string
EncryptionMode determines encryption mode
const ( // EncryptionModeWinSCP is for WinSCP EncryptionModeWinSCP EncryptionMode = "WINSCP" // EncryptionModePGP is for PGP key encryption EncryptionModePGP EncryptionMode = "PGP" // EncryptionModeSSH is for SSH key encryption EncryptionModeSSH EncryptionMode = "SSH" // EncryptionModeUnknown is for unknown mode EncryptionModeUnknown EncryptionMode = "" )
func DetectEncryptionMode ¶ added in v0.8.3
func DetectEncryptionMode(p string) EncryptionMode
DetectEncryptionMode detects encryption mode and filename encryption
func GetEncryptionMode ¶ added in v0.8.3
func GetEncryptionMode(mode string) EncryptionMode
GetEncryptionMode returns encryption mode
type ListFormat ¶ added in v0.8.3
type ListFormat string
const ( // format ListFormatNormal ListFormat = "" ListFormatLong ListFormat = "long" ListFormatVeryLong ListFormat = "verylong" )
type ListSortOrder ¶ added in v0.8.3
type ListSortOrder string
const ( // sort ListSortOrderNone ListSortOrder = "" ListSortOrderName ListSortOrder = "name" ListSortOrderSize ListSortOrder = "size" ListSortOrderTime ListSortOrder = "time" ListSortOrderExt ListSortOrder = "ext" )
func GetListSortOrder ¶ added in v0.8.3
func GetListSortOrder(order string) ListSortOrder
GetListSortOrder returns ListSortOrder from string
type ParallelJob ¶ added in v0.4.6
type ParallelJob struct {
// contains filtered or unexported fields
}
func (*ParallelJob) GetManager ¶ added in v0.4.6
func (job *ParallelJob) GetManager() *ParallelJobManager
type ParallelJobManager ¶ added in v0.4.6
type ParallelJobManager struct {
// contains filtered or unexported fields
}
func NewParallelJobManager ¶ added in v0.4.6
func NewParallelJobManager(fs *irodsclient_fs.FileSystem, maxThreads int, showProgress bool) *ParallelJobManager
NewParallelJobManager creates a new ParallelJobManager
func (*ParallelJobManager) DoneScheduling ¶ added in v0.4.6
func (manager *ParallelJobManager) DoneScheduling()
func (*ParallelJobManager) GetFilesystem ¶ added in v0.4.6
func (manager *ParallelJobManager) GetFilesystem() *irodsclient_fs.FileSystem
func (*ParallelJobManager) Schedule ¶ added in v0.4.6
func (manager *ParallelJobManager) Schedule(name string, task ParallelJobTask, threadsRequired int, progressUnit progress.Units) error
func (*ParallelJobManager) Start ¶ added in v0.4.6
func (manager *ParallelJobManager) Start()
func (*ParallelJobManager) Wait ¶ added in v0.4.6
func (manager *ParallelJobManager) Wait() error
type ParallelJobTask ¶ added in v0.4.6
type ParallelJobTask func(job *ParallelJob) error
type ProgressTrackerCallback ¶
type TarEntry ¶
type TarEntry struct {
// contains filtered or unexported fields
}
func NewTarEntry ¶
type TrackerCallBack ¶
type VersionInfo ¶
type VersionInfo struct { ClientVersion string `json:"clientVersion"` GitCommit string `json:"gitCommit"` BuildDate string `json:"buildDate"` GoVersion string `json:"goVersion"` Compiler string `json:"compiler"` Platform string `json:"platform"` }
VersionInfo object contains version related info
Source Files ¶
- bundle_transfer.go
- commands.go
- config.go
- constant.go
- datetime.go
- encrypt.go
- encrypt_aes.go
- encrypt_meta.go
- encrypt_pgp.go
- encrypt_ssh.go
- encrypt_ssh_rsa.go
- encrypt_winscp.go
- irods_client.go
- listformat.go
- number.go
- parallel.go
- path.go
- print.go
- progress.go
- retry.go
- staging.go
- tar.go
- unit.go
- upgrade.go
- version.go