endpoints

Jun 24, 2019

Changes in this version

type S3Client

+ func (c *S3Client) SetPlainSizeComputer(computer func(nodeUUID string) (int64, error))

Apr 15, 2019

Changes in this version

+ type Discarder struct

+ func (d *Discarder) Close() error

type FSClient

+ func (c *FSClient) ComputeChecksum(node *tree.Node) error

type MemDB

+ func (db *MemDB) ComputeChecksum(node *tree.Node) error

type S3Client

+ func (c *S3Client) ComputeChecksum(node *tree.Node) error

Dec 13, 2018

Changes in this version

type MemDB

+ func (db *MemDB) Stats() string

May 15, 2018

Changes in this version

type S3Client

+ func (c *S3Client) UpdateNodeUuid(ctx context.Context, node *tree.Node) (*tree.Node, error)

Apr 24, 2018

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 FSClient struct

+ FS afero.Fs

+ RootPath string

+ func NewFSClient(rootPath string) (*FSClient, 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) 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) 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) 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) Stat(path string) (i os.FileInfo, err error)

+ func (c *S3Client) UpdateNode(ctx context.Context, node *tree.Node) (err 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{}