Documentation ¶
Overview ¶
Package grpc provides a pydio GRPC service for CRUD-ing the datasource index.
It uses an SQL-based persistence layer for storing all nodes in the nested-set format in DB.
Index ¶
- type TreeServer
- func (s *TreeServer) CleanResourcesBeforeDelete(ctx context.Context, request *object.CleanResourcesRequest, ...) error
- func (s *TreeServer) CloseSession(ctx context.Context, req *tree.CloseSessionRequest, ...) error
- func (s *TreeServer) CreateNode(ctx context.Context, req *tree.CreateNodeRequest, ...) (err error)
- func (s *TreeServer) CreateNodeStream(ctx context.Context, stream tree.NodeReceiverStream_CreateNodeStreamStream) error
- func (s *TreeServer) DeleteNode(ctx context.Context, req *tree.DeleteNodeRequest, ...) (err error)
- func (s *TreeServer) DeleteNodeStream(ctx context.Context, stream tree.NodeReceiverStream_DeleteNodeStreamStream) error
- func (s *TreeServer) ListNodes(ctx context.Context, req *tree.ListNodesRequest, ...) error
- func (s *TreeServer) OpenSession(ctx context.Context, req *tree.OpenSessionRequest, ...) error
- func (s *TreeServer) ReadNode(ctx context.Context, req *tree.ReadNodeRequest, resp *tree.ReadNodeResponse) error
- func (s *TreeServer) ReadNodeStream(ctx context.Context, stream tree.NodeProviderStreamer_ReadNodeStreamStream) error
- func (s *TreeServer) UpdateNode(ctx context.Context, req *tree.UpdateNodeRequest, ...) (err error)
- func (s *TreeServer) UpdateNodeStream(ctx context.Context, stream tree.NodeReceiverStream_UpdateNodeStreamStream) error
- func (s *TreeServer) UpdateParentsAndNotify(ctx context.Context, dao index.DAO, deltaSize int64, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TreeServer ¶
type TreeServer struct { DataSourceName string // contains filtered or unexported fields }
TreeServer definition.
func (*TreeServer) CleanResourcesBeforeDelete ¶
func (s *TreeServer) CleanResourcesBeforeDelete(ctx context.Context, request *object.CleanResourcesRequest, response *object.CleanResourcesResponse) error
CleanResourcesBeforeDelete ensure all resources are cleant before deleting.
func (*TreeServer) CloseSession ¶
func (s *TreeServer) CloseSession(ctx context.Context, req *tree.CloseSessionRequest, resp *tree.CloseSessionResponse) error
CloseSession closes an indexer session.
func (*TreeServer) CreateNode ¶
func (s *TreeServer) CreateNode(ctx context.Context, req *tree.CreateNodeRequest, resp *tree.CreateNodeResponse) (err error)
CreateNode implementation for the TreeServer.
func (*TreeServer) CreateNodeStream ¶
func (s *TreeServer) CreateNodeStream(ctx context.Context, stream tree.NodeReceiverStream_CreateNodeStreamStream) error
CreateNodeStream implementation for the TreeServer.
func (*TreeServer) DeleteNode ¶
func (s *TreeServer) DeleteNode(ctx context.Context, req *tree.DeleteNodeRequest, resp *tree.DeleteNodeResponse) (err error)
DeleteNode implementation for the TreeServer.
func (*TreeServer) DeleteNodeStream ¶
func (s *TreeServer) DeleteNodeStream(ctx context.Context, stream tree.NodeReceiverStream_DeleteNodeStreamStream) error
DeleteNodeStream implements the streaming version of DeleteNode for the TreeServer
func (*TreeServer) ListNodes ¶
func (s *TreeServer) ListNodes(ctx context.Context, req *tree.ListNodesRequest, resp tree.NodeProvider_ListNodesStream) error
ListNodes implementation for the TreeServer.
func (*TreeServer) OpenSession ¶
func (s *TreeServer) OpenSession(ctx context.Context, req *tree.OpenSessionRequest, resp *tree.OpenSessionResponse) error
OpenSession opens an indexer session.
func (*TreeServer) ReadNode ¶
func (s *TreeServer) ReadNode(ctx context.Context, req *tree.ReadNodeRequest, resp *tree.ReadNodeResponse) error
ReadNode implementation for the TreeServer.
func (*TreeServer) ReadNodeStream ¶
func (s *TreeServer) ReadNodeStream(ctx context.Context, stream tree.NodeProviderStreamer_ReadNodeStreamStream) error
ReadNodeStream implements the streaming version of ReadNode for the TreeServer
func (*TreeServer) UpdateNode ¶
func (s *TreeServer) UpdateNode(ctx context.Context, req *tree.UpdateNodeRequest, resp *tree.UpdateNodeResponse) (err error)
UpdateNode implementation for the TreeServer.
func (*TreeServer) UpdateNodeStream ¶
func (s *TreeServer) UpdateNodeStream(ctx context.Context, stream tree.NodeReceiverStream_UpdateNodeStreamStream) error
UpdateNodeStream implements the streaming version of UpdateNode for the TreeServer
func (*TreeServer) UpdateParentsAndNotify ¶
func (s *TreeServer) UpdateParentsAndNotify(ctx context.Context, dao index.DAO, deltaSize int64, eventType tree.NodeChangeEvent_EventType, sourceNode *utils.TreeNode, targetNode *utils.TreeNode, sessionUuid string) error
UpdateParentsAndNotify update the parents nodes and notify the tree of the event that occurred.