sync

package

v1.0.1 Latest Latest Go to latest Published: Jun 18, 2018 License: AGPL-3.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

gitproxy.zycloud.tk/pydio/cells

Links

Open Source Insights

Documentation ¶

Overview ¶

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

Index ¶

Variables
type IndexEndpoint
- func NewIndexEndpoint(dsName string, reader tree.NodeProviderClient, writer tree.NodeReceiverClient, ...) *IndexEndpoint
type IndexStreamer
- func NewIndexStreamer(serviceName string) *IndexStreamer

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	Name        = common.SERVICE_GRPC_NAMESPACE_ + common.SERVICE_DATA_SYNC
	ChildPrefix = common.SERVICE_GRPC_NAMESPACE_ + common.SERVICE_DATA_SYNC_
)

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

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

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)

Source Files ¶

index-endpoint.go
index-streamer.go
plugins.go

Directories ¶

Path	Synopsis
grpc 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
cmd command Package main provides a command line version of sync	Package main provides a command line version of sync
common Package common defines vars and constants for the sync package	Package common defines vars and constants for the sync package
endpoints Package endpoints provides implementations of various synchronization endpoints Currently supported are FS, S3 and in-memory DB	Package endpoints provides implementations of various synchronization endpoints Currently supported are FS, S3 and in-memory DB
filters Package filters provides batchers and filters to analyze and simplify sync events	Package filters provides batchers and filters to analyze and simplify sync events
proc Package proc provides actual actions to be performed once the sync has filtered all events	Package proc provides actual actions to be performed once the sync has filtered all events
task Package task defines a synchronization task	Package task defines a synchronization task

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