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(ds *object.DataSource) *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) FlushSession(ctx context.Context, req *tree.FlushSessionRequest, ...) 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) TriggerResync(ctx context.Context, _ *sync.ResyncRequest, resp *sync.ResyncResponse) 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
	DataSourceInternal bool
	// contains filtered or unexported fields
}

TreeServer definition.

func NewTreeServer

func NewTreeServer(ds *object.DataSource) *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) FlushSession

func (s *TreeServer) FlushSession(ctx context.Context, req *tree.FlushSessionRequest, resp *tree.FlushSessionResponse) error

FlushSession allows to flsuh what's in the dao cache for the current session to ensure we are up to date moving on to the next phase of the indexation.

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) TriggerResync

func (s *TreeServer) TriggerResync(ctx context.Context, _ *sync.ResyncRequest, resp *sync.ResyncResponse) error

TriggerResync on index performs a Lost+Found request to auto-heal indexation errors, whenever possible

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 *mtree.TreeNode, targetNode *mtree.TreeNode, sessionUuid string) error

UpdateParentsAndNotify update the parents nodes and notify the tree of the event that occurred.