sync

package

v1.6.1 Latest Latest Go to latest Published: Jul 9, 2019 License: AGPL-3.0 Imports: 16 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/EngineerIG/cells

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) ComputeChecksum ¶

func (i *IndexEndpoint) ComputeChecksum(node *tree.Node) error

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 ¶

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 ¶

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 ¶

View all Source files

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