Versions in this module Expand all Collapse all v1 v1.6.1 Jul 9, 2019 Changes in this version + const VIEWS_LIBRARY_NAME + var IsUnitTestEnv = false + func AccessListFromContext(ctx context.Context) (*permissions.AccessList, error) + func AncestorsListFromContext(ctx context.Context, node *tree.Node, identifier string, p *ClientsPool, ...) (updatedContext context.Context, parentsList []*tree.Node, e error) + func CopyMoveNodes(ctx context.Context, router Handler, sourceNode *tree.Node, ...) (oErr error) + func GetGenericStoreClient(ctx context.Context, storeNamespace string, microClient client.Client) (client *minio.Core, bucket string, e error) + func GetGenericStoreClientConfig(storeNamespace string) (dataSource string, bucket string, e error) + func NewCacheDiff() *cacheDiff + func NewMockNodeKeyManagerClient() encryption.NodeKeyManagerClient + func NewMockUserKeyTool() key.UserKeyTool + func UserWorkspacesFromContext(ctx context.Context) map[string]*idm.Workspace + func WithBranchInfo(ctx context.Context, identifier string, branchInfo BranchInfo, reset ...bool) context.Context + type AbstractBranchFilter struct + RootNodesCache *cache.Cache + func (v *AbstractBranchFilter) CopyObject(ctx context.Context, from *tree.Node, to *tree.Node, ...) (int64, error) + func (v *AbstractBranchFilter) CreateNode(ctx context.Context, in *tree.CreateNodeRequest, opts ...client.CallOption) (*tree.CreateNodeResponse, error) + func (v *AbstractBranchFilter) DeleteNode(ctx context.Context, in *tree.DeleteNodeRequest, opts ...client.CallOption) (*tree.DeleteNodeResponse, error) + func (v *AbstractBranchFilter) ExecuteWrapped(inputFilter NodeFilter, outputFilter NodeFilter, provider NodesCallback) error + func (v *AbstractBranchFilter) GetObject(ctx context.Context, node *tree.Node, requestData *GetRequestData) (io.ReadCloser, error) + func (v *AbstractBranchFilter) ListNodes(ctx context.Context, in *tree.ListNodesRequest, opts ...client.CallOption) (streamer tree.NodeProvider_ListNodesClient, e error) + func (v *AbstractBranchFilter) MultipartAbort(ctx context.Context, node *tree.Node, uploadID string, ...) error + func (v *AbstractBranchFilter) MultipartComplete(ctx context.Context, node *tree.Node, uploadID string, ...) (minio.ObjectInfo, error) + func (v *AbstractBranchFilter) MultipartCreate(ctx context.Context, node *tree.Node, requestData *MultipartRequestData) (string, error) + func (v *AbstractBranchFilter) MultipartListObjectParts(ctx context.Context, node *tree.Node, uploadID string, partNumberMarker int, ...) (lpi minio.ListObjectPartsResult, er error) + func (v *AbstractBranchFilter) MultipartPutObjectPart(ctx context.Context, node *tree.Node, uploadID string, partNumberMarker int, ...) (minio.ObjectPart, error) + func (v *AbstractBranchFilter) PutObject(ctx context.Context, node *tree.Node, reader io.Reader, ...) (int64, error) + func (v *AbstractBranchFilter) ReadNode(ctx context.Context, in *tree.ReadNodeRequest, opts ...client.CallOption) (*tree.ReadNodeResponse, error) + func (v *AbstractBranchFilter) UpdateNode(ctx context.Context, in *tree.UpdateNodeRequest, opts ...client.CallOption) (*tree.UpdateNodeResponse, error) + type AbstractHandler struct + CtxWrapper ContextWrapper + func (a *AbstractHandler) CopyObject(ctx context.Context, from *tree.Node, to *tree.Node, ...) (int64, error) + func (a *AbstractHandler) CreateNode(ctx context.Context, in *tree.CreateNodeRequest, opts ...client.CallOption) (*tree.CreateNodeResponse, error) + func (a *AbstractHandler) DeleteNode(ctx context.Context, in *tree.DeleteNodeRequest, opts ...client.CallOption) (*tree.DeleteNodeResponse, error) + func (a *AbstractHandler) ExecuteWrapped(inputFilter NodeFilter, outputFilter NodeFilter, provider NodesCallback) error + func (a *AbstractHandler) GetObject(ctx context.Context, node *tree.Node, requestData *GetRequestData) (io.ReadCloser, error) + func (a *AbstractHandler) ListNodes(ctx context.Context, in *tree.ListNodesRequest, opts ...client.CallOption) (tree.NodeProvider_ListNodesClient, error) + func (a *AbstractHandler) MultipartAbort(ctx context.Context, target *tree.Node, uploadID string, ...) error + func (a *AbstractHandler) MultipartComplete(ctx context.Context, target *tree.Node, uploadID string, ...) (minio.ObjectInfo, error) + func (a *AbstractHandler) MultipartCreate(ctx context.Context, target *tree.Node, requestData *MultipartRequestData) (string, error) + func (a *AbstractHandler) MultipartList(ctx context.Context, prefix string, requestData *MultipartRequestData) (minio.ListMultipartUploadsResult, error) + func (a *AbstractHandler) MultipartListObjectParts(ctx context.Context, target *tree.Node, uploadID string, partNumberMarker int, ...) (minio.ListObjectPartsResult, error) + func (a *AbstractHandler) MultipartPutObjectPart(ctx context.Context, target *tree.Node, uploadID string, partNumberMarker int, ...) (minio.ObjectPart, error) + func (a *AbstractHandler) PutObject(ctx context.Context, node *tree.Node, reader io.Reader, ...) (int64, error) + func (a *AbstractHandler) ReadNode(ctx context.Context, in *tree.ReadNodeRequest, opts ...client.CallOption) (*tree.ReadNodeResponse, error) + func (a *AbstractHandler) SetClientsPool(p *ClientsPool) + func (a *AbstractHandler) SetNextHandler(h Handler) + func (a *AbstractHandler) UpdateNode(ctx context.Context, in *tree.UpdateNodeRequest, opts ...client.CallOption) (*tree.UpdateNodeResponse, error) + type AccessListHandler struct + func NewAccessListHandler(adminView bool) *AccessListHandler + type AclFilterHandler struct + func (a *AclFilterHandler) CopyObject(ctx context.Context, from *tree.Node, to *tree.Node, ...) (int64, error) + func (a *AclFilterHandler) CreateNode(ctx context.Context, in *tree.CreateNodeRequest, opts ...client.CallOption) (*tree.CreateNodeResponse, error) + func (a *AclFilterHandler) DeleteNode(ctx context.Context, in *tree.DeleteNodeRequest, opts ...client.CallOption) (*tree.DeleteNodeResponse, error) + func (a *AclFilterHandler) GetObject(ctx context.Context, node *tree.Node, requestData *GetRequestData) (io.ReadCloser, error) + func (a *AclFilterHandler) ListNodes(ctx context.Context, in *tree.ListNodesRequest, opts ...client.CallOption) (streamer tree.NodeProvider_ListNodesClient, e error) + func (a *AclFilterHandler) PutObject(ctx context.Context, node *tree.Node, reader io.Reader, ...) (int64, error) + func (a *AclFilterHandler) ReadNode(ctx context.Context, in *tree.ReadNodeRequest, opts ...client.CallOption) (*tree.ReadNodeResponse, error) + func (a *AclFilterHandler) UpdateNode(ctx context.Context, in *tree.UpdateNodeRequest, opts ...client.CallOption) (*tree.UpdateNodeResponse, error) + type AclLockFilter struct + func (a *AclLockFilter) CopyObject(ctx context.Context, from *tree.Node, to *tree.Node, ...) (int64, error) + func (a *AclLockFilter) MultipartCreate(ctx context.Context, target *tree.Node, requestData *MultipartRequestData) (string, error) + func (a *AclLockFilter) PutObject(ctx context.Context, node *tree.Node, reader io.Reader, ...) (int64, error) + type AclQuotaFilter struct + func (a *AclQuotaFilter) ComputeQuota(ctx context.Context, workspace *idm.Workspace) (quota int64, usage int64, err error) + func (a *AclQuotaFilter) CopyObject(ctx context.Context, from *tree.Node, to *tree.Node, ...) (int64, error) + func (a *AclQuotaFilter) FindParentWorkspaces(ctx context.Context, workspace *idm.Workspace) (parentWorkspaces []*idm.Workspace, parentContext context.Context, err error) + func (a *AclQuotaFilter) MultipartPutObjectPart(ctx context.Context, target *tree.Node, uploadID string, partNumberMarker int, ...) (minio.ObjectPart, error) + func (a *AclQuotaFilter) PutObject(ctx context.Context, node *tree.Node, reader io.Reader, ...) (int64, error) + func (a *AclQuotaFilter) QuotaForWorkspace(ctx context.Context, workspace *idm.Workspace, orderedRoles []string) (maxQuota int64, currentUsage int64, err error) + type ArchiveHandler struct + func NewArchiveHandler() *ArchiveHandler + func (a *ArchiveHandler) GetObject(ctx context.Context, node *tree.Node, requestData *GetRequestData) (io.ReadCloser, error) + func (a *ArchiveHandler) ListNodes(ctx context.Context, in *tree.ListNodesRequest, opts ...client.CallOption) (tree.NodeProvider_ListNodesClient, error) + func (a *ArchiveHandler) ReadNode(ctx context.Context, in *tree.ReadNodeRequest, opts ...client.CallOption) (*tree.ReadNodeResponse, error) + type ArchiveReader struct + Router Handler + func (a *ArchiveReader) ExtractAllTar(ctx context.Context, gzipFormat bool, archiveNode *tree.Node, ...) error + func (a *ArchiveReader) ExtractAllZip(ctx context.Context, archiveNode *tree.Node, targetNode *tree.Node, ...) error + func (a *ArchiveReader) ListChildrenTar(ctx context.Context, gzipFormat bool, archiveNode *tree.Node, ...) ([]*tree.Node, error) + func (a *ArchiveReader) ListChildrenZip(ctx context.Context, archiveNode *tree.Node, parentPath string, stat ...bool) ([]*tree.Node, error) + func (a *ArchiveReader) ReadChildTar(ctx context.Context, gzipFormat bool, writer io.WriteCloser, ...) (int64, error) + func (a *ArchiveReader) ReadChildZip(ctx context.Context, archiveNode *tree.Node, innerPath string) (io.ReadCloser, error) + func (a *ArchiveReader) StatChildTar(ctx context.Context, gzipFormat bool, archiveNode *tree.Node, innerPath string) (*tree.Node, error) + func (a *ArchiveReader) StatChildZip(ctx context.Context, archiveNode *tree.Node, innerPath string) (*tree.Node, error) + type ArchiveWriter struct + Router Handler + func (w *ArchiveWriter) TarSelection(ctx context.Context, output io.Writer, gzipFile bool, nodes []*tree.Node, ...) (int64, error) + func (w *ArchiveWriter) ZipSelection(ctx context.Context, output io.Writer, nodes []*tree.Node, ...) (int64, error) + type BinaryStoreHandler struct + AllowAnonRead bool + AllowPut bool + StoreName string + func (a *BinaryStoreHandler) CopyObject(ctx context.Context, from *tree.Node, to *tree.Node, ...) (int64, error) + func (a *BinaryStoreHandler) CreateNode(ctx context.Context, in *tree.CreateNodeRequest, opts ...client.CallOption) (*tree.CreateNodeResponse, error) + func (a *BinaryStoreHandler) DeleteNode(ctx context.Context, in *tree.DeleteNodeRequest, opts ...client.CallOption) (*tree.DeleteNodeResponse, error) + func (a *BinaryStoreHandler) GetObject(ctx context.Context, node *tree.Node, requestData *GetRequestData) (io.ReadCloser, error) + func (a *BinaryStoreHandler) ListNodes(ctx context.Context, in *tree.ListNodesRequest, opts ...client.CallOption) (c tree.NodeProvider_ListNodesClient, e error) + func (a *BinaryStoreHandler) PutObject(ctx context.Context, node *tree.Node, reader io.Reader, ...) (int64, error) + func (a *BinaryStoreHandler) ReadNode(ctx context.Context, in *tree.ReadNodeRequest, opts ...client.CallOption) (*tree.ReadNodeResponse, error) + func (a *BinaryStoreHandler) UpdateNode(ctx context.Context, in *tree.UpdateNodeRequest, opts ...client.CallOption) (*tree.UpdateNodeResponse, error) + type BranchInfo struct + AncestorsList map[string][]*tree.Node + Binary bool + Root *tree.Node + func GetBranchInfo(ctx context.Context, identifier string) (BranchInfo, bool) + type ClientsPool struct + Sources map[string]LoadedSource + TreeClient tree.NodeProviderClient + TreeClientWrite tree.NodeReceiverClient + func NewClientsPool(watchRegistry bool) (pool *ClientsPool) + func (p *ClientsPool) Close() + func (p *ClientsPool) GetDataSourceInfo(dsName string, retries ...int) (LoadedSource, error) + func (p *ClientsPool) GetTreeClient() tree.NodeProviderClient + func (p *ClientsPool) GetTreeClientWrite() tree.NodeReceiverClient + type ContextWrapper func(ctx context.Context) (context.Context, error) + type CopyRequestData struct + Metadata map[string]string + SrcVersionId string + type CtxKeepAccessListKey struct + type CtxUserAccessListKey struct + type EncryptionHandler struct + func (e *EncryptionHandler) CopyObject(ctx context.Context, from *tree.Node, to *tree.Node, ...) (int64, error) + func (e *EncryptionHandler) GetObject(ctx context.Context, node *tree.Node, requestData *GetRequestData) (io.ReadCloser, error) + func (e *EncryptionHandler) MultipartCreate(ctx context.Context, target *tree.Node, requestData *MultipartRequestData) (string, error) + func (e *EncryptionHandler) MultipartPutObjectPart(ctx context.Context, target *tree.Node, uploadID string, partNumberMarker int, ...) (minio.ObjectPart, error) + func (e *EncryptionHandler) PutObject(ctx context.Context, node *tree.Node, reader io.Reader, ...) (int64, error) + func (e *EncryptionHandler) SetNodeKeyManagerClient(nodeKeyManagerClient encryption.NodeKeyManagerClient) + func (e *EncryptionHandler) SetUserKeyTool(keyTool key.UserKeyTool) + type Executor struct + func (a *Executor) ExecuteWrapped(inputFilter NodeFilter, outputFilter NodeFilter, provider NodesCallback) error + func (e *Executor) CopyObject(ctx context.Context, from *tree.Node, to *tree.Node, ...) (int64, error) + func (e *Executor) CreateNode(ctx context.Context, in *tree.CreateNodeRequest, opts ...client.CallOption) (*tree.CreateNodeResponse, error) + func (e *Executor) DeleteNode(ctx context.Context, in *tree.DeleteNodeRequest, opts ...client.CallOption) (*tree.DeleteNodeResponse, error) + func (e *Executor) GetObject(ctx context.Context, node *tree.Node, requestData *GetRequestData) (io.ReadCloser, error) + func (e *Executor) ListNodes(ctx context.Context, in *tree.ListNodesRequest, opts ...client.CallOption) (tree.NodeProvider_ListNodesClient, error) + func (e *Executor) MultipartAbort(ctx context.Context, target *tree.Node, uploadID string, ...) error + func (e *Executor) MultipartComplete(ctx context.Context, target *tree.Node, uploadID string, ...) (minio.ObjectInfo, error) + func (e *Executor) MultipartCreate(ctx context.Context, target *tree.Node, requestData *MultipartRequestData) (string, error) + func (e *Executor) MultipartList(ctx context.Context, prefix string, requestData *MultipartRequestData) (res minio.ListMultipartUploadsResult, err error) + func (e *Executor) MultipartListObjectParts(ctx context.Context, target *tree.Node, uploadID string, partNumberMarker int, ...) (lpi minio.ListObjectPartsResult, err error) + func (e *Executor) MultipartPutObjectPart(ctx context.Context, target *tree.Node, uploadID string, partNumberMarker int, ...) (minio.ObjectPart, error) + func (e *Executor) PutObject(ctx context.Context, node *tree.Node, reader io.Reader, ...) (int64, error) + func (e *Executor) ReadNode(ctx context.Context, in *tree.ReadNodeRequest, opts ...client.CallOption) (*tree.ReadNodeResponse, error) + func (e *Executor) UpdateNode(ctx context.Context, in *tree.UpdateNodeRequest, opts ...client.CallOption) (*tree.UpdateNodeResponse, error) + type GetRequestData struct + Length int64 + StartOffset int64 + VersionId string + type Handler interface + CopyObject func(ctx context.Context, from *tree.Node, to *tree.Node, ...) (int64, error) + ExecuteWrapped func(inputFilter NodeFilter, outputFilter NodeFilter, provider NodesCallback) error + GetObject func(ctx context.Context, node *tree.Node, requestData *GetRequestData) (io.ReadCloser, error) + MultipartAbort func(ctx context.Context, target *tree.Node, uploadID string, ...) error + MultipartComplete func(ctx context.Context, target *tree.Node, uploadID string, ...) (minio.ObjectInfo, error) + MultipartCreate func(ctx context.Context, target *tree.Node, requestData *MultipartRequestData) (string, error) + MultipartList func(ctx context.Context, prefix string, requestData *MultipartRequestData) (minio.ListMultipartUploadsResult, error) + MultipartListObjectParts func(ctx context.Context, target *tree.Node, uploadID string, partNumberMarker int, ...) (minio.ListObjectPartsResult, error) + MultipartPutObjectPart func(ctx context.Context, target *tree.Node, uploadID string, partNumberMarker int, ...) (minio.ObjectPart, error) + PutObject func(ctx context.Context, node *tree.Node, reader io.Reader, ...) (int64, error) + SetClientsPool func(p *ClientsPool) + SetNextHandler func(h Handler) + type HandlerAuditEvent struct + func (h *HandlerAuditEvent) CopyObject(ctx context.Context, from *tree.Node, to *tree.Node, ...) (int64, error) + func (h *HandlerAuditEvent) CreateNode(ctx context.Context, in *tree.CreateNodeRequest, opts ...client.CallOption) (*tree.CreateNodeResponse, error) + func (h *HandlerAuditEvent) DeleteNode(ctx context.Context, in *tree.DeleteNodeRequest, opts ...client.CallOption) (*tree.DeleteNodeResponse, error) + func (h *HandlerAuditEvent) GetObject(ctx context.Context, node *tree.Node, requestData *GetRequestData) (io.ReadCloser, error) + func (h *HandlerAuditEvent) ListNodes(ctx context.Context, in *tree.ListNodesRequest, opts ...client.CallOption) (tree.NodeProvider_ListNodesClient, error) + func (h *HandlerAuditEvent) MultipartAbort(ctx context.Context, target *tree.Node, uploadID string, ...) error + func (h *HandlerAuditEvent) MultipartComplete(ctx context.Context, target *tree.Node, uploadID string, ...) (minio.ObjectInfo, error) + func (h *HandlerAuditEvent) MultipartCreate(ctx context.Context, target *tree.Node, requestData *MultipartRequestData) (string, error) + func (h *HandlerAuditEvent) MultipartList(ctx context.Context, prefix string, requestData *MultipartRequestData) (minio.ListMultipartUploadsResult, error) + func (h *HandlerAuditEvent) MultipartListObjectParts(ctx context.Context, target *tree.Node, uploadID string, partNumberMarker int, ...) (minio.ListObjectPartsResult, error) + func (h *HandlerAuditEvent) MultipartPutObjectPart(ctx context.Context, target *tree.Node, uploadID string, partNumberMarker int, ...) (minio.ObjectPart, error) + func (h *HandlerAuditEvent) PutObject(ctx context.Context, node *tree.Node, reader io.Reader, ...) (int64, error) + func (h *HandlerAuditEvent) ReadNode(ctx context.Context, in *tree.ReadNodeRequest, opts ...client.CallOption) (*tree.ReadNodeResponse, error) + func (h *HandlerAuditEvent) UpdateNode(ctx context.Context, in *tree.UpdateNodeRequest, opts ...client.CallOption) (*tree.UpdateNodeResponse, error) + type HandlerEventRead struct + func (h *HandlerEventRead) GetObject(ctx context.Context, node *tree.Node, requestData *GetRequestData) (io.ReadCloser, error) + func (h *HandlerEventRead) ListNodes(ctx context.Context, in *tree.ListNodesRequest, opts ...client.CallOption) (tree.NodeProvider_ListNodesClient, error) + type HandlerMock struct + Context context.Context + Nodes map[string]*tree.Node + RootDir string + func NewHandlerMock() *HandlerMock + func (h *HandlerMock) CopyObject(ctx context.Context, from *tree.Node, to *tree.Node, ...) (int64, error) + func (h *HandlerMock) CreateNode(ctx context.Context, in *tree.CreateNodeRequest, opts ...client.CallOption) (*tree.CreateNodeResponse, error) + func (h *HandlerMock) DeleteNode(ctx context.Context, in *tree.DeleteNodeRequest, opts ...client.CallOption) (*tree.DeleteNodeResponse, error) + func (h *HandlerMock) ExecuteWrapped(inputFilter NodeFilter, outputFilter NodeFilter, provider NodesCallback) error + func (h *HandlerMock) GetObject(ctx context.Context, node *tree.Node, requestData *GetRequestData) (io.ReadCloser, error) + func (h *HandlerMock) ListNodes(ctx context.Context, in *tree.ListNodesRequest, opts ...client.CallOption) (tree.NodeProvider_ListNodesClient, error) + func (h *HandlerMock) MultipartAbort(ctx context.Context, target *tree.Node, uploadID string, ...) error + func (h *HandlerMock) MultipartComplete(ctx context.Context, target *tree.Node, uploadID string, ...) (minio.ObjectInfo, error) + func (h *HandlerMock) MultipartCreate(ctx context.Context, target *tree.Node, requestData *MultipartRequestData) (string, error) + func (h *HandlerMock) MultipartList(ctx context.Context, prefix string, requestData *MultipartRequestData) (minio.ListMultipartUploadsResult, error) + func (h *HandlerMock) MultipartListObjectParts(ctx context.Context, target *tree.Node, uploadID string, partNumberMarker int, ...) (minio.ListObjectPartsResult, error) + func (h *HandlerMock) MultipartPutObjectPart(ctx context.Context, target *tree.Node, uploadID string, partNumberMarker int, ...) (op minio.ObjectPart, e error) + func (h *HandlerMock) PutObject(ctx context.Context, node *tree.Node, reader io.Reader, ...) (int64, error) + func (h *HandlerMock) ReadNode(ctx context.Context, in *tree.ReadNodeRequest, opts ...client.CallOption) (*tree.ReadNodeResponse, error) + func (h *HandlerMock) SetClientsPool(p *ClientsPool) + func (h *HandlerMock) SetNextHandler(handler Handler) + func (h *HandlerMock) UpdateNode(ctx context.Context, in *tree.UpdateNodeRequest, opts ...client.CallOption) (*tree.UpdateNodeResponse, error) + type LoadedSource struct + Client *minio.Core + func NewSource(data *object.DataSource) (LoadedSource, error) + type MockReadCloser struct + func (r MockReadCloser) Close() error + type MultipartRequestData struct + ListDelimiter string + ListKeyMarker string + ListMaxUploads int + ListUploadIDMarker string + Metadata map[string]string + type MultipleRootsHandler struct + func NewPathMultipleRootsHandler() *MultipleRootsHandler + func (m *MultipleRootsHandler) ListNodes(ctx context.Context, in *tree.ListNodesRequest, opts ...client.CallOption) (tree.NodeProvider_ListNodesClient, error) + func (m *MultipleRootsHandler) ReadNode(ctx context.Context, in *tree.ReadNodeRequest, opts ...client.CallOption) (*tree.ReadNodeResponse, error) + type NodeFilter func(ctx context.Context, inputNode *tree.Node, identifier string) (context.Context, *tree.Node, error) + type NodesCallback func(inputFilter NodeFilter, outputFilter NodeFilter) error + type PathDataSourceHandler struct + func NewPathDataSourceHandler() *PathDataSourceHandler + type PathWorkspaceHandler struct + func NewPathWorkspaceHandler() *PathWorkspaceHandler + func (a *PathWorkspaceHandler) ListNodes(ctx context.Context, in *tree.ListNodesRequest, opts ...client.CallOption) (tree.NodeProvider_ListNodesClient, error) + func (a *PathWorkspaceHandler) ReadNode(ctx context.Context, in *tree.ReadNodeRequest, opts ...client.CallOption) (*tree.ReadNodeResponse, error) + type PutHandler struct + func (m *PutHandler) CreateParent(ctx context.Context, node *tree.Node) error + func (m *PutHandler) GetOrCreatePutNode(ctx context.Context, nodePath string, size int64) (*tree.Node, error, onCreateErrorFunc) + func (m *PutHandler) MultipartAbort(ctx context.Context, target *tree.Node, uploadID string, ...) error + func (m *PutHandler) MultipartCreate(ctx context.Context, node *tree.Node, requestData *MultipartRequestData) (string, error) + func (m *PutHandler) PutObject(ctx context.Context, node *tree.Node, reader io.Reader, ...) (int64, error) + type PutRequestData struct + Md5Sum []byte + Metadata map[string]string + MultipartPartID int + MultipartUploadID string + Sha256Sum []byte + Size int64 + type Router struct + func NewRouter(pool *ClientsPool, handlers []Handler) *Router + func NewStandardRouter(options RouterOptions) *Router + func NewUuidRouter(options RouterOptions) *Router + func (v *Router) CopyObject(ctx context.Context, from *tree.Node, to *tree.Node, ...) (int64, error) + func (v *Router) CreateNode(ctx context.Context, in *tree.CreateNodeRequest, opts ...client.CallOption) (*tree.CreateNodeResponse, error) + func (v *Router) DeleteNode(ctx context.Context, in *tree.DeleteNodeRequest, opts ...client.CallOption) (*tree.DeleteNodeResponse, error) + func (v *Router) ExecuteWrapped(inputFilter NodeFilter, outputFilter NodeFilter, provider NodesCallback) error + func (v *Router) GetClientsPool() *ClientsPool + func (v *Router) GetExecutor() Handler + func (v *Router) GetObject(ctx context.Context, node *tree.Node, requestData *GetRequestData) (io.ReadCloser, error) + func (v *Router) ListNodes(ctx context.Context, in *tree.ListNodesRequest, opts ...client.CallOption) (tree.NodeProvider_ListNodesClient, error) + func (v *Router) MultipartAbort(ctx context.Context, target *tree.Node, uploadID string, ...) error + func (v *Router) MultipartComplete(ctx context.Context, target *tree.Node, uploadID string, ...) (minio.ObjectInfo, error) + func (v *Router) MultipartCreate(ctx context.Context, target *tree.Node, requestData *MultipartRequestData) (string, error) + func (v *Router) MultipartList(ctx context.Context, prefix string, requestData *MultipartRequestData) (minio.ListMultipartUploadsResult, error) + func (v *Router) MultipartListObjectParts(ctx context.Context, target *tree.Node, uploadID string, partNumberMarker int, ...) (minio.ListObjectPartsResult, error) + func (v *Router) MultipartPutObjectPart(ctx context.Context, target *tree.Node, uploadID string, partNumberMarker int, ...) (minio.ObjectPart, error) + func (v *Router) PutObject(ctx context.Context, node *tree.Node, reader io.Reader, ...) (int64, error) + func (v *Router) ReadNode(ctx context.Context, in *tree.ReadNodeRequest, opts ...client.CallOption) (*tree.ReadNodeResponse, error) + func (v *Router) SetClientsPool(p *ClientsPool) + func (v *Router) SetNextHandler(h Handler) + func (v *Router) UpdateNode(ctx context.Context, in *tree.UpdateNodeRequest, opts ...client.CallOption) (*tree.UpdateNodeResponse, error) + func (v *Router) WrapCallback(provider NodesCallback) error + type RouterEventFilter struct + RootNodesCache *cache.Cache + func NewRouterEventFilter(options RouterOptions) *RouterEventFilter + func (r *RouterEventFilter) NodeIsChildOfRoot(ctx context.Context, node *tree.Node, rootId string) (*tree.Node, bool) + func (r *RouterEventFilter) WorkspaceCanSeeNode(ctx context.Context, workspace *idm.Workspace, node *tree.Node) (*tree.Node, bool) + type RouterOptions struct + AdminView bool + AuditEvent bool + BrowseVirtualNodes bool + LogReadEvents bool + Synchronous bool + WatchRegistry bool + type SynchronousCacheHandler struct + func NewSynchronousCacheHandler() *SynchronousCacheHandler + func (s *SynchronousCacheHandler) CreateNode(ctx context.Context, in *tree.CreateNodeRequest, opts ...client.CallOption) (*tree.CreateNodeResponse, error) + func (s *SynchronousCacheHandler) DeleteNode(ctx context.Context, in *tree.DeleteNodeRequest, opts ...client.CallOption) (*tree.DeleteNodeResponse, error) + func (s *SynchronousCacheHandler) ListNodes(ctx context.Context, in *tree.ListNodesRequest, opts ...client.CallOption) (tree.NodeProvider_ListNodesClient, error) + func (s *SynchronousCacheHandler) MultipartComplete(ctx context.Context, target *tree.Node, uploadID string, ...) (minio.ObjectInfo, error) + func (s *SynchronousCacheHandler) PutObject(ctx context.Context, node *tree.Node, reader io.Reader, ...) (int64, error) + func (s *SynchronousCacheHandler) ReadNode(ctx context.Context, in *tree.ReadNodeRequest, opts ...client.CallOption) (*tree.ReadNodeResponse, error) + func (s *SynchronousCacheHandler) UpdateNode(ctx context.Context, in *tree.UpdateNodeRequest, opts ...client.CallOption) (*tree.UpdateNodeResponse, error) + type UploadLimitFilter struct + func (a *UploadLimitFilter) MultipartPutObjectPart(ctx context.Context, target *tree.Node, uploadID string, partNumberMarker int, ...) (minio.ObjectPart, error) + func (a *UploadLimitFilter) PutObject(ctx context.Context, node *tree.Node, reader io.Reader, ...) (int64, error) + type UuidDataSourceHandler struct + func NewUuidDataSourceHandler() *UuidDataSourceHandler + type UuidNodeHandler struct + func NewUuidNodeHandler() *UuidNodeHandler + type UuidRootsHandler struct + func NewUuidRootsHandler() *UuidRootsHandler + type VersionHandler struct + func (v *VersionHandler) CopyObject(ctx context.Context, from *tree.Node, to *tree.Node, ...) (int64, error) + func (v *VersionHandler) GetObject(ctx context.Context, node *tree.Node, requestData *GetRequestData) (io.ReadCloser, error) + func (v *VersionHandler) ListNodes(ctx context.Context, in *tree.ListNodesRequest, opts ...client.CallOption) (tree.NodeProvider_ListNodesClient, error) + func (v *VersionHandler) ReadNode(ctx context.Context, req *tree.ReadNodeRequest, opts ...client.CallOption) (*tree.ReadNodeResponse, error) + type VirtualNodesBrowser struct + func NewVirtualNodesBrowser() *VirtualNodesBrowser + func (v *VirtualNodesBrowser) ListNodes(ctx context.Context, in *tree.ListNodesRequest, opts ...client.CallOption) (streamer tree.NodeProvider_ListNodesClient, e error) + func (v *VirtualNodesBrowser) ReadNode(ctx context.Context, in *tree.ReadNodeRequest, opts ...client.CallOption) (*tree.ReadNodeResponse, error) + type VirtualNodesManager struct + VirtualNodes []*tree.Node + func GetVirtualNodesManager() *VirtualNodesManager + func (m *VirtualNodesManager) ByPath(path string) (*tree.Node, bool) + func (m *VirtualNodesManager) ByUuid(uuid string) (*tree.Node, bool) + func (m *VirtualNodesManager) ListNodes() []*tree.Node + func (m *VirtualNodesManager) Load(forceReload ...bool) + func (m *VirtualNodesManager) ResolveInContext(ctx context.Context, vNode *tree.Node, clientsPool *ClientsPool, create bool, ...) (*tree.Node, error) + func (m *VirtualNodesManager) ResolvePathWithVars(ctx context.Context, vNode *tree.Node, vars map[string]string, ...) (*tree.Node, error) + type VirtualNodesResolver struct + func NewVirtualNodesHandler() *VirtualNodesResolver + type WorkspaceRootResolver struct + func NewWorkspaceRootResolver() *WorkspaceRootResolver + type WrappingStreamer struct + func NewWrappingStreamer() *WrappingStreamer + func (l *WrappingStreamer) Close() error + func (l *WrappingStreamer) Recv() (*tree.ListNodesResponse, error) + func (l *WrappingStreamer) RecvMsg(interface{}) error + func (l *WrappingStreamer) Send(resp *tree.ListNodesResponse) error + func (l *WrappingStreamer) SendError(err error) error + func (l *WrappingStreamer) SendMsg(interface{}) error Incompatible versions in this module v2.0.6+incompatible Apr 23, 2020