grpc

package
v0.9.0 Latest Latest
Warning

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

Go to latest
Published: Apr 24, 2018 License: AGPL-3.0 Imports: 17 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) 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 *utils.TreeNode, targetNode *utils.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