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, handlerName string, dao index.DAO) *TreeServer
  • func (s *TreeServer) CleanResourcesBeforeDelete(ctx context.Context, request *object.CleanResourcesRequest) (resp *object.CleanResourcesResponse, err error)
  • func (s *TreeServer) CloseSession(ctx context.Context, req *tree.CloseSessionRequest) (resp *tree.CloseSessionResponse, err error)
  • func (s *TreeServer) CreateNode(ctx context.Context, req *tree.CreateNodeRequest) (resp *tree.CreateNodeResponse, err error)
  • func (s *TreeServer) CreateNodeStream(stream tree.NodeReceiverStream_CreateNodeStreamServer) error
  • func (s *TreeServer) DeleteNode(ctx context.Context, req *tree.DeleteNodeRequest) (resp *tree.DeleteNodeResponse, err error)
  • func (s *TreeServer) DeleteNodeStream(stream tree.NodeReceiverStream_DeleteNodeStreamServer) error
  • func (s *TreeServer) FlushSession(ctx context.Context, req *tree.FlushSessionRequest) (resp *tree.FlushSessionResponse, err error)
  • func (s *TreeServer) ListNodes(req *tree.ListNodesRequest, resp tree.NodeProvider_ListNodesServer) (err error)
  • func (s *TreeServer) ModifyLogin(ctx context.Context, req *service.ModifyLoginRequest) (resp *service.ModifyLoginResponse, err error)
  • func (s *TreeServer) Name() string
  • func (s *TreeServer) OpenSession(ctx context.Context, req *tree.OpenSessionRequest) (resp *tree.OpenSessionResponse, err error)
  • func (s *TreeServer) ReadNode(ctx context.Context, req *tree.ReadNodeRequest) (resp *tree.ReadNodeResponse, err error)
  • func (s *TreeServer) ReadNodeStream(stream tree.NodeProviderStreamer_ReadNodeStreamServer) error
  • func (s *TreeServer) TriggerResync(ctx context.Context, request *sync.ResyncRequest) (*sync.ResyncResponse, error)
  • func (s *TreeServer) UpdateNode(ctx context.Context, req *tree.UpdateNodeRequest) (resp *tree.UpdateNodeResponse, err error)
  • func (s *TreeServer) UpdateNodeStream(stream tree.NodeReceiverStream_UpdateNodeStreamServer) error
  • func (s *TreeServer) UpdateParentsAndNotify(ctx context.Context, dao index.DAO, deltaSize int64, ...) error

Types

type TreeServer

type TreeServer struct {
	tree.UnimplementedNodeReceiverServer
	tree.UnimplementedNodeProviderServer
	tree.UnimplementedNodeReceiverStreamServer
	tree.UnimplementedNodeProviderStreamerServer
	tree.UnimplementedSessionIndexerServer
	object.UnimplementedResourceCleanerEndpointServer
	sync.UnimplementedSyncEndpointServer
	service.UnimplementedLoginModifierServer
	// contains filtered or unexported fields
}

TreeServer definition.

func NewTreeServer

func NewTreeServer(ds *object.DataSource, handlerName string, dao index.DAO) *TreeServer

NewTreeServer factory.

func (*TreeServer) CleanResourcesBeforeDelete

func (s *TreeServer) CleanResourcesBeforeDelete(ctx context.Context, request *object.CleanResourcesRequest) (resp *object.CleanResourcesResponse, err 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, err 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(stream tree.NodeReceiverStream_CreateNodeStreamServer) 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(stream tree.NodeReceiverStream_DeleteNodeStreamServer) 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, err 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(req *tree.ListNodesRequest, resp tree.NodeProvider_ListNodesServer) (err error)

ListNodes implementation for the TreeServer.

func (*TreeServer) ModifyLogin

func (s *TreeServer) ModifyLogin(ctx context.Context, req *service.ModifyLoginRequest) (resp *service.ModifyLoginResponse, err error)

func (*TreeServer) Name

func (s *TreeServer) Name() string

func (*TreeServer) OpenSession

func (s *TreeServer) OpenSession(ctx context.Context, req *tree.OpenSessionRequest) (resp *tree.OpenSessionResponse, err error)

OpenSession opens an indexer session.

func (*TreeServer) ReadNode

func (s *TreeServer) ReadNode(ctx context.Context, req *tree.ReadNodeRequest) (resp *tree.ReadNodeResponse, err error)

ReadNode implementation for the TreeServer.

func (*TreeServer) ReadNodeStream

func (s *TreeServer) ReadNodeStream(stream tree.NodeProviderStreamer_ReadNodeStreamServer) error

ReadNodeStream implements the streaming version of ReadNode for the TreeServer

func (*TreeServer) TriggerResync

func (s *TreeServer) TriggerResync(ctx context.Context, request *sync.ResyncRequest) (*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(stream tree.NodeReceiverStream_UpdateNodeStreamServer) 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.