sync

package
v1.2.1 Latest Latest
Warning

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

Go to latest
Published: Oct 29, 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
cmd
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

Jump to

Keyboard shortcuts

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