rest

package

Go to main page

Versions in this module

v4

v4.2.1

Nov 4, 2024

v4.2.0

Jun 24, 2024

Changes in this version

+ const TransferRetryMaxAttemptsDefault

+ const TransferRetryMaxBackoffDefault

+ var Log *zap.SugaredLogger

+ var S3RequestTimeout = int64(-1)

+ var TransferRetryMaxAttempts = TransferRetryMaxAttemptsDefault

+ var TransferRetryMaxBackoff = TransferRetryMaxBackoffDefault

+ var UploadDefaultPartSize = int64(50)

+ var UploadMaxPartsNumber = int64(5000)

+ var UploadPartsConcurrency = 3

+ var UploadSkipMD5 = false

+ var UploadSwitchMultipart = int64(100)

+ func IsDebugEnabled() bool

+ func IsInfoEnabled() bool

+ func SetLogger(level zapcore.Level) (logger *zap.Logger)

type CrawlNode

+ func NewLocalBaseNode(sdkClient *SdkClient, absPath string, i os.FileInfo) *CrawlNode

+ func (c *CrawlNode) CreateFolders(_ context.Context, target *CrawlNode, dd []*CrawlNode, pool *BarsPool) error

+ func (c *CrawlNode) DeleteForMerge(ctx context.Context, dd []*CrawlNode, pool *BarsPool) error

+ func (c *CrawlNode) TransferAll(ctx context.Context, dd []*CrawlNode, pool *BarsPool) (errs []error)

+ type ReaderWithProgress struct

+ func (r *ReaderWithProgress) CreateErrorChan() (chan error, chan struct{})

+ func (r *ReaderWithProgress) Read(p []byte) (n int, err error)

+ func (r *ReaderWithProgress) Seek(offset int64, whence int) (int64, error)

+ type SdkClient struct

+ func NewSdkClient(ctx context.Context, config *CecConfig) (*SdkClient, error)

+ func (client *SdkClient) ConfigureS3Logger(ctx context.Context, s3Flags string) error

+ func (client *SdkClient) CopyJob(ctx context.Context, jsonParams string) (string, error)

+ func (client *SdkClient) CreateSimpleFolderLink(ctx context.Context, targetNodeUuid, label string) (*models.RestShareLink, error)

+ func (client *SdkClient) DeleteNodes(ctx context.Context, paths []string, permanently ...bool) (jobUUIDs []string, e error)

+ func (client *SdkClient) GetAllBulkMeta(ctx context.Context, path string) (nodes []*models.TreeNode, err error)

+ func (client *SdkClient) GetApiClient() *client.PydioCellsRestAPI

+ func (client *SdkClient) GetBucketName() string

+ func (client *SdkClient) GetCecConfig() *CecConfig

+ func (client *SdkClient) GetConfig() *cellsSdk.SdkConfig

+ func (client *SdkClient) GetCurrentJobStatus(ctx context.Context, jobID string) (status models.JobsTaskStatus, msg string, pg float32, e error)

+ func (client *SdkClient) GetFile(ctx context.Context, pathToFile string) (io.Reader, int, error)

+ func (client *SdkClient) GetS3Client() *s3.Client

+ func (client *SdkClient) GetStore() cellsSdk.ConfigRefresher

+ func (client *SdkClient) GetTaskStatusForJob(ctx context.Context, jobID string) (status models.JobsTaskStatus, msg string, pg float32, e error)

+ func (client *SdkClient) ListNodesPath(ctx context.Context, path string) ([]string, error)

+ func (client *SdkClient) MonitorJob(ctx context.Context, jobID string) (err error)

+ func (client *SdkClient) MoveJob(ctx context.Context, jsonParams string) (string, error)

+ func (client *SdkClient) PutFile(ctx context.Context, pathToFile string, content io.ReadSeeker, ...) (*s3.PutObjectOutput, error)

+ func (client *SdkClient) RunJob(ctx context.Context, jobName string, jsonParams string) (string, error)

+ func (client *SdkClient) Setup(ctx context.Context)

+ func (client *SdkClient) StatNode(ctx context.Context, pathToFile string) (*models.TreeNode, bool)

+ func (client *SdkClient) Teardown()

v4.2.0-alpha3

Jun 7, 2024

v4.2.0-alpha2

Jun 6, 2024

v4.2.0-alpha1

Jun 4, 2024

v4.2.0-alpha0

Jun 3, 2024

v4.1.1-alpha1

Apr 10, 2024

v4.1.0

Feb 21, 2024

Changes in this version

+ var CellsStore = NewCellsConfigStore()

+ var PoolSize = 3

+ func GetAllBulkMeta(ctx context.Context, path string) (nodes []*models.TreeNode, err error)

+ func GetAnonymousApiClient(customConf ...*cellsSdk.SdkConfig) (*client.PydioCellsRestAPI, error)

+ func NewCellsConfigStore() cellsSdk.ConfigRefresher

+ func RetrieveSessionLogin(currConf *CecConfig) (string, error)

+ func UserAgent() string

type CecConfig

+ func DefaultCecConfig() *CecConfig

+ type CellsConfigStore struct

+ func (store *CellsConfigStore) RefreshIfRequired(ctx context.Context, sdkConfig *cellsSdk.SdkConfig) (bool, error)

type ConfigList

+ func (list *ConfigList) GetStoredConfig(ctx context.Context, id string) (*CecConfig, error)

type CrawlNode

+ func (c *CrawlNode) CopyAllVerbose(ctx context.Context, dd []*CrawlNode) (errs []error)

v4.1.0-beta1

Feb 6, 2024

v4.1.0-alpha2

Feb 1, 2024

v4.1.0-alpha1

Feb 1, 2024

v4.0.1

Dec 7, 2023

Changes in this version

type CecConfig

+ func CloneConfig(from *CecConfig) *CecConfig

v4.0.1-alpha2

Nov 30, 2023

v4.0.1-alpha1

Nov 28, 2023

v4.0.0

Oct 11, 2023

Changes in this version

+ const LetterBytes

+ const NoKeyringMsg

+ var DefaultConfig *CecConfig

+ var DefaultContext context.Context

+ var DefaultTransport openapiruntime.ClientTransport

+ var DryRun bool

+ var QueueSize = 3

+ func ApplyUpdate(ctx context.Context, p *UpdatePackage, dryRun bool, pgChan chan float64, ...)

+ func AuthenticatedGet(uri string) (*http.Response, error)

+ func AuthenticatedRequest(req *http.Request, sdkConfig *cells_sdk.SdkConfig) (*http.Response, error)

+ func BuildParams(source []string, targetFolder string, targetParent bool) string

+ func CheckKeyring() error

+ func CleanURL(input string) (string, error)

+ func ClearKeyring(c *CecConfig) error

+ func ConfigFromKeyring(conf *CecConfig) error

+ func ConfigToKeyring(conf *CecConfig) error

+ func CopyJob(jsonParams string) (string, error)

+ func CopyParams(source []string, targetFolder string) string

+ func CreateSimpleFolderLink(targetNodeUuid, label string) (*models.RestShareLink, error)

+ func DefaultConfigDirPath() string

+ func DefaultConfigFilePath() string

+ func DeleteNode(paths []string) (jobUUIDs []string, e error)

+ func GetApiClient(anonymous ...bool) (context.Context, *client.PydioCellsRestAPI, error)

+ func GetBulkMetaNode(path string) ([]*models.TreeNode, error)

+ func GetConfigFilePath() string

+ func GetFile(pathToFile string) (io.Reader, int, error)

+ func GetS3Client() (*s3.S3, string, error)

+ func GetTaskStatusForJob(jobID string) (status models.JobsTaskStatus, msg string, pg float32, e error)

+ func IsForbiddenError(err error) bool

+ func ListNodesPath(path string) ([]string, error)

+ func MonitorJob(JobID string) (err error)

+ func MoveJob(jsonParams string) (string, error)

+ func MoveParams(source []string, targetFolder string) string

+ func OAuthExchangeCode(c *cells_sdk.SdkConfig, code, callbackUrl string) error

+ func OAuthPrepareUrl(serverUrl, state string, browser bool) (redirectUrl string, callbackUrl string, e error)

+ func PutFile(pathToFile string, content io.ReadSeeker, checkExists bool, ...) (*s3.PutObjectOutput, error)

+ func RandString(n int) string

+ func RefreshAndStoreIfRequired(c *CecConfig) bool

+ func RefreshIfRequired(conf *CecConfig) (bool, error)

+ func RenameParams(source []string, targetFolder string) string

+ func RetrieveCurrentSessionLogin() (string, error)

+ func RetrieveRemoteServerVersion() (*common.ServerVersion, error)

+ func RetryCallback(callback func() error, number int, interval time.Duration) error

+ func RunJob(jobName string, jsonParams string) (string, error)

+ func SetConfigFilePath(confPath string)

+ func StandardizeLink(old string) string

+ func StatNode(pathToFile string) (*models.TreeNode, bool)

+ func TreeCreateNodes(nodes []*models.TreeNode) error

+ func Unique(length int) string

+ func UpdateConfig(newConf *CecConfig) error

+ func ValidURL(input string) error

+ type BarsPool struct

+ func NewBarsPool(showGlobal bool, totalNodes int, refreshInterval time.Duration) *BarsPool

+ func (b *BarsPool) Done()

+ func (b *BarsPool) Get(i int, total int, name string) *uiprogress.Bar

+ type CecConfig struct

+ AuthType string

+ CreatedAtVersion string

+ Label string

+ SkipKeyring bool

+ type ConfigList struct

+ ActiveConfigID string

+ Configs map[string]*CecConfig

+ func GetConfigList() (*ConfigList, error)

+ func (list *ConfigList) GetActiveConfig() (*CecConfig, error)

+ func (list *ConfigList) Remove(id string) error

+ func (list *ConfigList) SaveConfigFile() error

+ func (list *ConfigList) SetActiveConfig(id string) error

+ type CrawlNode struct

+ FullPath string

+ IsDir bool

+ IsLocal bool

+ MTime time.Time

+ NewFileName string

+ RelPath string

+ Size int64

+ func NewCrawler(target string, isSrcLocal bool) (*CrawlNode, error)

+ func NewLocalNode(fullPath string, i os.FileInfo) *CrawlNode

+ func NewRemoteNode(t *models.TreeNode) *CrawlNode

+ func NewTarget(target string, source *CrawlNode, rename bool) *CrawlNode

+ func (c *CrawlNode) Base() string

+ func (c *CrawlNode) CopyAll(dd []*CrawlNode, pool *BarsPool) (errs []error)

+ func (c *CrawlNode) Dir() string

+ func (c *CrawlNode) Join(p ...string) string

+ func (c *CrawlNode) MkdirAll(dd []*CrawlNode, pool *BarsPool) error

+ func (c *CrawlNode) Walk(current ...string) (children []*CrawlNode, e error)

+ type PgReader struct

+ func (r *PgReader) CreateErrorChan() (chan error, chan struct{})

+ func (r *PgReader) Read(p []byte) (n int, err error)

+ func (r *PgReader) Seek(offset int64, whence int) (int64, error)

+ type UpdatePackage struct

+ BinaryArch string

+ BinaryChecksum string

+ BinaryHashType string

+ BinaryOS string

+ BinarySignature string

+ BinarySize string

+ BinaryURL string

+ ChangeLog string

+ Description string

+ IsPatch bool

+ Label string

+ License string

+ PackageName string

+ PatchAlgorithm string

+ ReleaseDate int32

+ Version string

+ func LoadUpdates(ctx context.Context, channel string) ([]*UpdatePackage, error)

+ type UpdateRequest struct

+ Channel string

+ CurrentVersion string

+ GOARCH string

+ GOOS string

+ LicenseInfo map[string]string

+ PackageName string

+ ServiceName string

+ type UpdateResponse struct

+ AvailableBinaries []*UpdatePackage

+ Channel string

v4.0.0-beta1

Sep 18, 2023

Other modules containing this package

github.com/pydio/cells-client

github.com/pydio/cells-client/v2

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