Versions in this module Expand all Collapse all v1 v1.6.1 Jul 9, 2019 Changes in this version + var EventTypeAll = []notify.Event + var EventTypeCreate = []notify.Event + var EventTypeDelete = []notify.Event + var EventTypeGet = []notify.Event + var EventTypePut = []notify.Event + var EventTypeRename = []notify.Event + var EventTypeWrite = []notify.Event + var UserAgentAppName = "pydio.sync.client.s3" + var UserAgentVersion = "1.0" + func CanonicalPath(path string) string + func PipeChan(capacity int) (inputCh chan notify.EventInfo, outputCh chan notify.EventInfo) + type DBEvent struct + Source string + Target string + Type string + type Discarder struct + func (d *Discarder) Close() error + type FSClient struct + FS afero.Fs + RootPath string + func NewFSClient(rootPath string) (*FSClient, error) + func (c *FSClient) ComputeChecksum(node *tree.Node) error + func (c *FSClient) CreateNode(ctx context.Context, node *tree.Node, updateIfExists bool) (err error) + func (c *FSClient) DeleteNode(ctx context.Context, path string) (err error) + func (c *FSClient) GetEndpointInfo() common.EndpointInfo + func (c *FSClient) GetReaderOn(path string) (out io.ReadCloser, err error) + func (c *FSClient) GetWriterOn(path string, targetSize int64) (out io.WriteCloser, err error) + func (c *FSClient) LoadNode(ctx context.Context, path string, leaf ...bool) (node *tree.Node, err error) + func (c *FSClient) MoveNode(ctx context.Context, oldPath string, newPath string) (err error) + func (c *FSClient) UpdateNode(ctx context.Context, node *tree.Node) (err error) + func (c *FSClient) Walk(walknFc common.WalkNodesFunc, pathes ...string) (err error) + func (c *FSClient) Watch(recursivePath string) (*common.WatchObject, error) + type MemDB struct + Nodes []*tree.Node + func NewMemDB() *MemDB + func (c *MemDB) GetEndpointInfo() common.EndpointInfo + func (db *MemDB) ComputeChecksum(node *tree.Node) error + func (db *MemDB) CreateNode(ctx context.Context, node *tree.Node, updateIfExists bool) (err error) + func (db *MemDB) DeleteNode(ctx context.Context, path string) (err error) + func (db *MemDB) FindByHash(hash string) (node *tree.Node) + func (db *MemDB) FindByUuid(id string) (node *tree.Node) + func (db *MemDB) LoadNode(ctx context.Context, path string, leaf ...bool) (node *tree.Node, err error) + func (db *MemDB) MoveNode(ctx context.Context, oldPath string, newPath string) (err error) + func (db *MemDB) RegisterEventChannel(out chan DBEvent) + func (db *MemDB) Stats() string + func (db *MemDB) String() string + func (db *MemDB) UpdateNode(ctx context.Context, node *tree.Node) (err error) + func (db *MemDB) Walk(walknFc common.WalkNodesFunc, pathes ...string) (err error) + func (db *MemDB) Watch(recursivePath string) (*common.WatchObject, error) + type MockableMinio interface + CopyObject func(dest minio.DestinationInfo, source minio.SourceInfo) error + GetObject func(bucket string, path string, opts minio.GetObjectOptions) (object *minio.Object, err error) + ListObjectsV2 func(bucketName, objectPrefix string, recursive bool, doneCh <-chan struct{}) <-chan minio.ObjectInfo + ListenBucketNotification func(bucketName, prefix, suffix string, events []string, doneCh <-chan struct{}) <-chan minio.NotificationInfo + PutObject func(bucket string, path string, reader io.Reader, size int64, ...) (n int64, err error) + RemoveObject func(bucket string, path string) error + StatObject func(bucket string, path string, opts minio.StatObjectOptions) (minio.ObjectInfo, error) + type S3Client struct + Bucket string + Mc MockableMinio + RootPath string + ServerRequiresNormalization bool + func NewS3Client(ctx context.Context, url string, key string, secret string, bucket string, ...) (*S3Client, error) + func (c *S3Client) ComputeChecksum(node *tree.Node) error + func (c *S3Client) CreateNode(ctx context.Context, node *tree.Node, updateIfExists bool) (err error) + func (c *S3Client) DeleteNode(ctx context.Context, path string) (err error) + func (c *S3Client) GetEndpointInfo() common.EndpointInfo + func (c *S3Client) GetReaderOn(path string) (out io.ReadCloser, err error) + func (c *S3Client) GetWriterOn(path string, targetSize int64) (out io.WriteCloser, err error) + func (c *S3Client) LoadNode(ctx context.Context, path string, leaf ...bool) (node *tree.Node, err error) + func (c *S3Client) MoveNode(ctx context.Context, oldPath string, newPath string) (err error) + func (c *S3Client) SetPlainSizeComputer(computer func(nodeUUID string) (int64, error)) + func (c *S3Client) Stat(path string) (i os.FileInfo, err error) + func (c *S3Client) UpdateNode(ctx context.Context, node *tree.Node) (err error) + func (c *S3Client) UpdateNodeUuid(ctx context.Context, node *tree.Node) (*tree.Node, error) + func (c *S3Client) Walk(walknFc common.WalkNodesFunc, pathes ...string) (err error) + func (c *S3Client) Watch(recursivePath string) (*common.WatchObject, error) + type S3ClientFSWatch struct + FSRootPath string + func NewS3ClientFSWatch(ctx context.Context, url string, key string, secret string, bucket string, ...) (*S3ClientFSWatch, error) + func (c *S3ClientFSWatch) Watch(recursivePath string) (*common.WatchObject, error) + type S3FileInfo struct + Object minio.ObjectInfo + func NewS3FileInfo(object minio.ObjectInfo) *S3FileInfo + func NewS3FolderInfo(object minio.ObjectInfo) *S3FileInfo + func (s *S3FileInfo) IsDir() bool + func (s *S3FileInfo) ModTime() time.Time + func (s *S3FileInfo) Mode() os.FileMode + func (s *S3FileInfo) Name() string + func (s *S3FileInfo) Size() int64 + func (s *S3FileInfo) Sys() interface{}
Go to main page