grpc

package
v2.1.6+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 9, 2020 License: AGPL-3.0 Imports: 23 Imported by: 0

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

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

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

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

DeleteNodeStream implements the streaming version of DeleteNode for the TreeServer

func (*TreeServer) FlushSession added in v1.0.0

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

ListNodes implementation for the TreeServer.

func (*TreeServer) OpenSession

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

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

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL