sync

package
v1.0.3 Latest Latest
Warning

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

Go to latest
Published: Aug 3, 2018 License: AGPL-3.0 Imports: 15 Imported by: 0

Documentation

Overview

Package sync ties the "objects" and "index" together

Index

Constants

This section is empty.

Variables

Functions

This section is empty.

Types

type IndexEndpoint

type IndexEndpoint struct {
	// contains filtered or unexported fields
}

func NewIndexEndpoint

func NewIndexEndpoint(dsName string, reader tree.NodeProviderClient, writer tree.NodeReceiverClient, sessionClient tree.SessionIndexerClient) *IndexEndpoint

func (*IndexEndpoint) CreateNode

func (i *IndexEndpoint) CreateNode(ctx context.Context, node *tree.Node, updateIfExists bool) (err error)

func (*IndexEndpoint) DeleteNode

func (i *IndexEndpoint) DeleteNode(ctx context.Context, path string) (err error)

func (*IndexEndpoint) FinishSession

func (i *IndexEndpoint) FinishSession(ctx context.Context, sessionUuid string) error

func (*IndexEndpoint) FlushSession added in v1.0.0

func (i *IndexEndpoint) FlushSession(ctx context.Context, sessionUuid string) error

func (*IndexEndpoint) GetEndpointInfo

func (i *IndexEndpoint) GetEndpointInfo() commonsync.EndpointInfo

func (*IndexEndpoint) LoadNode

func (i *IndexEndpoint) LoadNode(ctx context.Context, path string, leaf ...bool) (node *tree.Node, err error)

func (*IndexEndpoint) LoadNodeByUuid added in v1.0.0

func (i *IndexEndpoint) LoadNodeByUuid(ctx context.Context, uuid string) (node *tree.Node, err error)

LoadNodeByUuid makes this endpoint an UuidProvider

func (*IndexEndpoint) MoveNode

func (i *IndexEndpoint) MoveNode(ctx context.Context, oldPath string, newPath string) (err error)

func (*IndexEndpoint) StartSession

func (i *IndexEndpoint) StartSession(ctx context.Context, rootNode *tree.Node) (*tree.IndexationSession, error)

func (*IndexEndpoint) UpdateNode

func (i *IndexEndpoint) UpdateNode(ctx context.Context, node *tree.Node) error

func (*IndexEndpoint) Walk

func (i *IndexEndpoint) Walk(walknFc commonsync.WalkNodesFunc, pathes ...string) (err error)

func (*IndexEndpoint) Watch

func (i *IndexEndpoint) Watch(recursivePath string) (*commonsync.WatchObject, error)

type IndexStreamer

type IndexStreamer struct {
	// contains filtered or unexported fields
}

func NewIndexStreamer

func NewIndexStreamer(serviceName string) *IndexStreamer

func (*IndexStreamer) CreateNode

func (i *IndexStreamer) CreateNode(ctx context.Context, request *tree.CreateNodeRequest) (response *tree.CreateNodeResponse, err error)

func (*IndexStreamer) DeleteNode

func (i *IndexStreamer) DeleteNode(ctx context.Context, request *tree.DeleteNodeRequest) (response *tree.DeleteNodeResponse, err error)

func (*IndexStreamer) ReadNode

func (i *IndexStreamer) ReadNode(ctx context.Context, request *tree.ReadNodeRequest) (response *tree.ReadNodeResponse, err error)

func (*IndexStreamer) StartCreator

func (i *IndexStreamer) StartCreator(ctx context.Context) error

func (*IndexStreamer) StartDeleter

func (i *IndexStreamer) StartDeleter(ctx context.Context) error

func (*IndexStreamer) StartReader

func (i *IndexStreamer) StartReader(ctx context.Context) error

func (*IndexStreamer) StartUpdater

func (i *IndexStreamer) StartUpdater(ctx context.Context) error

func (*IndexStreamer) Stop

func (i *IndexStreamer) Stop()

func (*IndexStreamer) UpdateNode

func (i *IndexStreamer) UpdateNode(ctx context.Context, request *tree.UpdateNodeRequest) (response *tree.UpdateNodeResponse, err error)

Directories

Path Synopsis
Package grpc is a pydio service running synchronization between objects and index.
Package grpc is a pydio service running synchronization between objects and index.
lib

Jump to

Keyboard shortcuts

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