grpc

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 NewTreeServer(dsn string) *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

Types

type TreeServer

type TreeServer struct {
	DataSourceName string
	// contains filtered or unexported fields
}

TreeServer definition.

func NewTreeServer

func NewTreeServer(dsn string) *TreeServer

NewTreeServer factory

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.