sync

Documentation

Index

• func NewCacheDiff() *cacheDiff
• func WithCache() nodes.Option
• func WithFolderTasks() nodes.Option
• type CacheHandler
  • func (s *CacheHandler) Adapt(c nodes.Handler, options nodes.RouterOptions) nodes.Handler
  • func (s *CacheHandler) CreateNode(ctx context.Context, in *tree.CreateNodeRequest, opts ...grpc.CallOption) (*tree.CreateNodeResponse, error)
  • func (s *CacheHandler) DeleteNode(ctx context.Context, in *tree.DeleteNodeRequest, opts ...grpc.CallOption) (*tree.DeleteNodeResponse, error)
  • func (s *CacheHandler) ListNodes(ctx context.Context, in *tree.ListNodesRequest, opts ...grpc.CallOption) (tree.NodeProvider_ListNodesClient, error)
  • func (s *CacheHandler) MultipartComplete(ctx context.Context, target *tree.Node, uploadID string, ...) (models.ObjectInfo, error)
  • func (s *CacheHandler) PutObject(ctx context.Context, node *tree.Node, reader io.Reader, ...) (int64, error)
  • func (s *CacheHandler) ReadNode(ctx context.Context, in *tree.ReadNodeRequest, opts ...grpc.CallOption) (*tree.ReadNodeResponse, error)
  • func (s *CacheHandler) UpdateNode(ctx context.Context, in *tree.UpdateNodeRequest, opts ...grpc.CallOption) (*tree.UpdateNodeResponse, error)
• type FolderTasksHandler
  • func (h *FolderTasksHandler) Adapt(c nodes.Handler, options nodes.RouterOptions) nodes.Handler
  • func (h *FolderTasksHandler) DeleteNode(ctx context.Context, in *tree.DeleteNodeRequest, opts ...grpc.CallOption) (*tree.DeleteNodeResponse, error)
  • func (h *FolderTasksHandler) UpdateNode(ctx context.Context, in *tree.UpdateNodeRequest, opts ...grpc.CallOption) (*tree.UpdateNodeResponse, error)

Functions

func NewCacheDiff

func NewCacheDiff() *cacheDiff

func WithCache

func WithCache() nodes.Option

func WithFolderTasks

func WithFolderTasks() nodes.Option

Types

type CacheHandler

type CacheHandler struct {
	abstract.Handler
}

CacheHandler maintains a cache of the nodes during modifying operations to make listings more reactive. It is used by basic APIs (like WebDAV) for better visual performances and to create pseudo-synchronous APIs.

func (*CacheHandler) Adapt

func (s *CacheHandler) Adapt(c nodes.Handler, options nodes.RouterOptions) nodes.Handler

func (*CacheHandler) CreateNode

func (s *CacheHandler) CreateNode(ctx context.Context, in *tree.CreateNodeRequest, opts ...grpc.CallOption) (*tree.CreateNodeResponse, error)

func (*CacheHandler) DeleteNode

func (s *CacheHandler) DeleteNode(ctx context.Context, in *tree.DeleteNodeRequest, opts ...grpc.CallOption) (*tree.DeleteNodeResponse, error)

func (*CacheHandler) ListNodes

func (s *CacheHandler) ListNodes(ctx context.Context, in *tree.ListNodesRequest, opts ...grpc.CallOption) (tree.NodeProvider_ListNodesClient, error)

func (*CacheHandler) MultipartComplete

func (s *CacheHandler) MultipartComplete(ctx context.Context, target *tree.Node, uploadID string, uploadedParts []models.MultipartObjectPart) (models.ObjectInfo, error)

func (*CacheHandler) PutObject

func (s *CacheHandler) PutObject(ctx context.Context, node *tree.Node, reader io.Reader, requestData *models.PutRequestData) (int64, error)

func (*CacheHandler) ReadNode

func (s *CacheHandler) ReadNode(ctx context.Context, in *tree.ReadNodeRequest, opts ...grpc.CallOption) (*tree.ReadNodeResponse, error)

func (*CacheHandler) UpdateNode

func (s *CacheHandler) UpdateNode(ctx context.Context, in *tree.UpdateNodeRequest, opts ...grpc.CallOption) (*tree.UpdateNodeResponse, error)

type FolderTasksHandler

type FolderTasksHandler struct {
	abstract.Handler
}

FolderTasksHandler is a handler implementing synchronous operations for moving or deleting folders

func (*FolderTasksHandler) Adapt

func (h *FolderTasksHandler) Adapt(c nodes.Handler, options nodes.RouterOptions) nodes.Handler

func (*FolderTasksHandler) DeleteNode

func (h *FolderTasksHandler) DeleteNode(ctx context.Context, in *tree.DeleteNodeRequest, opts ...grpc.CallOption) (*tree.DeleteNodeResponse, error)

DeleteNode synchronously and recursively delete a node

func (*FolderTasksHandler) UpdateNode

func (h *FolderTasksHandler) UpdateNode(ctx context.Context, in *tree.UpdateNodeRequest, opts ...grpc.CallOption) (*tree.UpdateNodeResponse, error)

UpdateNode synchronously and recursively performs a Move operation of a node