grpc

package

v4.4.0 Latest Latest Go to latest Published: Apr 3, 2024 License: AGPL-3.0 Imports: 28 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/pydio/cells

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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 ¶ added in v4.2.6

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.

Source Files ¶

View all Source files

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