iqshell

package

Go to main page

Versions in this module

v2

v2.14.0

Dec 29, 2023

v2.13.0

Nov 8, 2023

v2.12.0

Jun 27, 2023

v2.11.0

May 22, 2023

v2.10.0

Mar 1, 2023

v2.9.2

Dec 27, 2022

v2.9.1

Dec 1, 2022

Changes in this version

type Config

+ Silence bool

v2.9.0

Aug 5, 2022

v2.8.0

Jun 27, 2022

Changes in this version

type Config

+ JobPathBuilder func(cmdPath string) string

v2.7.0

May 27, 2022

Changes in this version

+ func Check(cfg *Config, info CheckAndLoadInfo) (shouldContinue bool)

+ func CheckAndLoad(cfg *Config, info CheckAndLoadInfo) (shouldContinue bool)

+ func Load(cfg *Config, info CheckAndLoadInfo) (shouldContinue bool)

+ func LoadBase(cfg *Config) (shouldContinue bool)

+ func LoadFileLog(cfg *Config) (shouldContinue bool)

+ func LoadWorkspace(cfg *Config) (shouldContinue bool)

+ func ShowDocumentIfNeeded(cfg *Config) bool

+ type CheckAndLoadInfo struct

+ AfterLoadFileLog func()

+ BeforeLoadFileLog func()

+ Checker data.Checker

+ type Config struct

+ CmdCfg config.Config

+ ConfigFilePath string

+ DDebugEnable bool

+ DebugEnable bool

+ Document bool

+ Local bool

+ StdoutColorful bool

v2.6.3

Mar 23, 2022

Changes in this version

+ var ErrPartSizeMismatch = errors.New("part size mismatch with data from reader")

+ func EtagV1(reader io.Reader) (string, error)

+ func EtagV2(reader io.Reader, parts []int64) (string, error)

+ func IsSignByEtagV2(etag string) bool

type DownloadConfig

+ CheckHash bool

+ RecordRoot string

type EntryPath

+ PutTime string

v2.6.2

Jul 8, 2021

Changes in this version

+ func Endpoint(useHttps bool, host string) string

v2.6.1

Jun 3, 2021

v2.6.0

May 18, 2021

Changes in this version

+ const ResumableAPIV2MaxPartCount

+ var HOST_UC = []string

+ func SetDefaultUcHost(val string)

+ func SetUcHost(val string)

+ func UcHost() string

type UploadConfig

+ ResumableAPIV2PartSize int64

+ func (cfg *UploadConfig) Check()

v2.5.1

Apr 14, 2021

v2.5.0

Mar 18, 2021

Changes in this version

+ const BLOCK_BITS

+ const BLOCK_SIZE

+ const DEFAULT_PUT_THRESHOLD

+ const GB

+ const HTTP_TIMEOUT

+ const KB

+ const MAX_DOWNLOAD_THREAD_COUNT

+ const MAX_UPLOAD_THREAD_COUNT

+ const MB

+ const MIN_DOWNLOAD_THREAD_COUNT

+ const MIN_UPLOAD_THREAD_COUNT

+ const RETRY_INTERVAL

+ const RETRY_MAX_TIMES

+ const STATUS_ERROR

+ const STATUS_HALT

+ const STATUS_OK

+ const TB

+ var ACCESS_KEY = []string

+ var HOST_API = []string

+ var HOST_IO = []string

+ var HOST_RS = []string

+ var HOST_RSF = []string

+ var HOST_UP = []string

+ var PATH_ACC = []string

+ var PATH_ACCDB = []string

+ var PATH_ROOT = []string

+ var SECRET_KEY = []string

+ func AccDBPath() string

+ func AccPath() string

+ func AccessKey() string

+ func AesDecrypt(crypted, key []byte) ([]byte, error)

+ func AesEncrypt(origData, key []byte) ([]byte, error)

+ func ApiHost() string

+ func BlockCount(fsize int64) int

+ func BytesToReadable(size int64) (readable string)

+ func CalSha1(b []byte, r io.Reader) ([]byte, error)

+ func ChUser(userName string) (err error)

+ func CleanUser() (err error)

+ func Decode(encodedURI string) (uri string, err error)

+ func DecryptSecretKey(accessKey, encryptedKey string) (string, error)

+ func DirCache(cacheRootPath string, cacheResultFile string) (fileCount int64, retErr error)

+ func Encode(uri string) string

+ func Encrypt(accessKey, encryptedKey, name string) string

+ func EncryptSecretKey(accessKey, secretKey string) (string, error)

+ func GetCdnManager() *cdn.CdnManager

+ func GetEtag(filename string) (etag string, err error)

+ func GetFileLineCount(filePath string) (totalCount int64)

+ func GetLineCount(reader io.Reader) (totalCount int64)

+ func GetMac() (mac *qbox.Mac, err error)

+ func GetUpHost(cfg *storage.Config, ak, bucket string) (upHost string, err error)

+ func IoHost() string

+ func KeyFromUrl(uri string) (key string, err error)

+ func ListUser(userLsName bool) (err error)

+ func LookUp(userName string) (err error)

+ func Md5Hex(from string) string

+ func OldAccPath() string

+ func PKCS5Padding(ciphertext []byte, blockSize int) []byte

+ func PKCS5UnPadding(origData []byte) []byte

+ func Pfop(bucket, key, fops, pipeline, notifyURL string, notifyForce bool) (persistentId string, err error)

+ func Prefop(persistentId string) (ret storage.PrefopRet, err error)

+ func ProgressFileFromUrl(srcResUrl, bucket, key string) (progressFile string, err error)

+ func QiniuDownload(threadCount int, downConfig *DownloadConfig)

+ func QiniuUpload(threadCount int, uploadConfig *UploadConfig, exporter *FileExporter)

+ func RmUser(userName string) (err error)

+ func RootPath() string

+ func RsHost() string

+ func RsfHost() string

+ func SecretKey() string

+ func SetAccDBPath(val string)

+ func SetAccPath(val string)

+ func SetAccount(acc Account, accPath, oldPath string) (err error)

+ func SetAccount2(accessKey, secretKey, name, accPath, oldPath string, accountOver bool) (err error)

+ func SetApiHost(val string)

+ func SetDefaultAccDBPath(val string)

+ func SetDefaultAccPath(val string)

+ func SetDefaultApiHost(val string)

+ func SetDefaultIoHost(val string)

+ func SetDefaultRsHost(val string)

+ func SetDefaultRsfHost(val string)

+ func SetDefaultUpHost(val string)

+ func SetIoHost(val string)

+ func SetRootPath(val string)

+ func SetRsHost(val string)

+ func SetRsfHost(val string)

+ func SetUpHost(val string)

+ func SimpleUnescape(s *string) string

+ func Unzip(zipFilePath string, unzipPath string) (err error)

+ func UpHost() string

+ func UpHostBindPFlag(val *pflag.Flag)

+ type Account struct

+ AccessKey string

+ Name string

+ SecretKey string

+ func Decrypt(joinStr string) (acc Account, err error)

+ func GetAccount() (account Account, err error)

+ func GetOldAccount() (account Account, err error)

+ func GetUsers() (ret []*Account, err error)

+ func (acc *Account) Encrypt() (s string, err error)

+ func (acc *Account) Mac() (mac *qbox.Mac)

+ func (acc *Account) String() string

+ func (acc *Account) Value() (v string, err error)

+ type AliListBucket struct

+ AccessKeyId string

+ AccessKeySecret string

+ Bucket string

+ DataCenter string

+ Prefix string

+ func (this *AliListBucket) ListBucket(listResultFile string) (err error)

+ type BeeLogConfig struct

+ Daily bool

+ Filename string

+ Level int

+ MaxDays int

+ func (c *BeeLogConfig) ToJson() string

+ type BucketDomainsRet []struct

+ type BucketManager struct

+ func GetBucketManager() *BucketManager

+ func GetBucketManagerWithConfig(cfg *storage.Config) *BucketManager

+ func NewBucketManager(mac *qbox.Mac, cfg *storage.Config) *BucketManager

+ func NewBucketManagerEx(mac *qbox.Mac, cfg *storage.Config, client *storage.Client) *BucketManager

+ func (m *BucketManager) BatchChgm(entries []ChgmEntryPath) (ret []storage.BatchOpRet, err error)

+ func (m *BucketManager) BatchChtype(entries []ChtypeEntryPath) (ret []storage.BatchOpRet, err error)

+ func (m *BucketManager) BatchCopy(entries []CopyEntryPath) (ret []storage.BatchOpRet, err error)

+ func (m *BucketManager) BatchDelete(entries []EntryPath) (ret []storage.BatchOpRet, err error)

+ func (m *BucketManager) BatchDeleteAfterDays(entries []DeleteAfterDaysEntryPath) (ret []storage.BatchOpRet, err error)

+ func (m *BucketManager) BatchMove(entries []MoveEntryPath) (ret []storage.BatchOpRet, err error)

+ func (m *BucketManager) BatchRename(entries []RenameEntryPath) (ret []storage.BatchOpRet, err error)

+ func (m *BucketManager) BatchSign(urls []string, deadline int64) (ret []string, err error)

+ func (m *BucketManager) BatchStat(entries []EntryPath) (ret []storage.BatchOpRet, err error)

+ func (m *BucketManager) ChStatus(bucket, key string, forbidden bool) (err error)

+ func (m *BucketManager) CheckAsyncFetchStatus(bucket, id string) (ret storage.AsyncFetchRet, err error)

+ func (m *BucketManager) CheckExists(bucket, key string) (exists bool, err error)

+ func (m *BucketManager) DomainsOfBucket(bucket string) (domains []string, err error)

+ func (m *BucketManager) DownloadLink(bucket, key string) (dnLink string, err error)

+ func (m *BucketManager) Get(bucket, key string, destFile string) (err error)

+ func (m *BucketManager) GetMac() *qbox.Mac

+ func (m *BucketManager) ListBucket2(bucket, prefix, marker, listResultFile, delimiter string, ...) (retErr error)

+ func (m *BucketManager) ListFiles(bucket, prefix, marker, listResultFile string) (retErr error)

+ func (m *BucketManager) M3u8FileList(bucket string, m3u8Key string) (slicesToDelete []EntryPath, err error)

+ func (m *BucketManager) M3u8ReplaceDomain(bucket string, m3u8Key string, newDomain string, removeSparePreSlash bool) (err error)

+ func (m *BucketManager) MakePrivateDownloadLink(domainOfBucket, fileKey string, useHttps bool) (fileUrl string)

+ func (m *BucketManager) MakePublicDownloadLink(domainOfBucket, fileKey string, useHttps bool) (fileUrl string)

+ func (m *BucketManager) PrivateUrl(publicUrl string, deadline int64) (finalUrl string, err error)

+ func (m *BucketManager) Saveas(publicUrl, saveBucket, saveKey string) (string, error)

+ func (m *BucketManager) Sync(srcResUrl, bucket, key, upHost string, isResumableV2 bool) (putRet SputRet, err error)

+ type ByteSize int64

+ func (b ByteSize) String() string

+ type ChgmEntryPath struct

+ MimeType string

+ type ChtypeEntryPath struct

+ FileType int

+ type CopyEntryPath MoveEntryPath

+ type DeleteAfterDaysEntryPath struct

+ DeleteAfterDays int

+ type DownloadConfig struct

+ Bucket string

+ CdnDomain string

+ DestDir string

+ FileEncoding string

+ IoHost string

+ KeyFile string

+ LogFile string

+ LogLevel string

+ LogRotate int

+ LogStdout bool

+ Prefix string

+ Public bool

+ Referer string

+ Suffixes string

+ UseHttps bool

+ func (d *DownloadConfig) DomainOfBucket(bm *BucketManager) (domain string, err error)

+ func (d *DownloadConfig) DownloadDomain() (domain string)

+ type EntryPath struct

+ Bucket string

+ Key string

+ type FetchItem struct

+ Bucket string

+ Key string

+ RemoteUrl string

+ type FileExporter struct

+ FailureFhandle *os.File

+ FailureLock sync.RWMutex

+ FailureWriter *bufio.Writer

+ OverwriteFhandle *os.File

+ OverwriteLock sync.RWMutex

+ OverwriteWriter *bufio.Writer

+ SuccessFhandle *os.File

+ SuccessLock sync.RWMutex

+ SuccessWriter *bufio.Writer

+ func NewFileExporter(successFname, failureFname, overwriteFname string) (ex *FileExporter, err error)

+ func (ex *FileExporter) Close()

+ func (ex *FileExporter) FlushWriter()

+ func (ex *FileExporter) WriteToFailedWriter(text string)

+ func (ex *FileExporter) WriteToOverwriter(text string)

+ func (ex *FileExporter) WriteToSuccessWriter(text string)

+ type GetRet struct

+ Expiry int64

+ Fsize int64

+ Hash string

+ MimeType string

+ URL string

+ Version string

+ type IResumeUploader interface

+ type MoveEntryPath struct

+ DstEntry EntryPath

+ Force bool

+ SrcEntry EntryPath

+ type ProgressRecorder struct

+ BlkCtxs []storage.BlkputRet

+ ExpireTime int64

+ FilePath string

+ LastModified int

+ Offset int64

+ Parts []storage.UploadPartInfo

+ TotalSize int64

+ UploadId string

+ func NewProgressRecorder(filePath string) *ProgressRecorder

+ func (p *ProgressRecorder) CheckValid(fileSize int64, lastModified int, isResumableV2 bool)

+ func (p *ProgressRecorder) RecordProgress() (err error)

+ func (p *ProgressRecorder) Recover() (err error)

+ func (p *ProgressRecorder) RecoverFromUrl(srcResUrl, bucket, key string) (err error)

+ func (p *ProgressRecorder) Reset()

+ type RenameEntryPath MoveEntryPath

+ type ResumeUploader struct

+ func NewResumeUploader(cfg *storage.Config) *ResumeUploader

+ func (p *ResumeUploader) UpHost(ak, bucket string) (upHost string, err error)

+ type SputRet struct

+ Fsize int64

+ Hash string

+ Key string

+ MimeType string

+ type UploadConfig struct

+ BindNicIp string

+ BindRsIp string

+ BindUpIp string

+ Bucket string

+ CallbackHost string

+ CallbackUrls string

+ CheckExists bool

+ CheckHash bool

+ CheckSize bool

+ DeleteOnSuccess bool

+ DisableResume bool

+ FileEncoding string

+ FileList string

+ FileType int

+ IgnoreDir bool

+ KeyPrefix string

+ LogFile string

+ LogLevel string

+ LogRotate int

+ LogStdout bool

+ Overwrite bool

+ Plock sync.Mutex

+ PutPolicy storage.PutPolicy

+ PutThreshold int64

+ RescanLocal bool

+ ResumableAPIV2 bool

+ SkipFilePrefixes string

+ SkipFixedStrings string

+ SkipPathPrefixes string

+ SkipSuffixes string

+ SrcDir string

+ UpHost string

+ func (cfg *UploadConfig) CacheFileNameAndCount(storePath, jobId string) (cacheResultName string, totalFileCount int64, cacheErr error)

+ func (cfg *UploadConfig) DefaultLogFile(storePath, jobId string) (defaultLogFile string, err error)

+ func (cfg *UploadConfig) GetLogLevel() int

+ func (cfg *UploadConfig) GetLogRotate() int

+ func (cfg *UploadConfig) GetUpHost() string

+ func (cfg *UploadConfig) HitByFilePrefixes(localFileRelativePath string) (hit bool, filePrefix string)

+ func (cfg *UploadConfig) HitByFixesString(localFileRelativePath string) (hit bool, hitFixedStr string)

+ func (cfg *UploadConfig) HitByPathPrefixes(localFileRelativePath string) (hit bool, pathPrefix string)

+ func (cfg *UploadConfig) HitBySuffixes(localFileRelativePath string) (hit bool, hitSuffix string)

+ func (cfg *UploadConfig) JobId() string

+ func (cfg *UploadConfig) PrepareLogger(storePath, jobId string)

+ func (cfg *UploadConfig) UploadToken(mac *qbox.Mac, uploadFileKey string) string

+ type UploadInfo struct

+ TotalFileCount int64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL