sync

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
  • func (i *IndexEndpoint) ComputeChecksum(node *tree.Node) error
  • func (i *IndexEndpoint) CreateNode(ctx context.Context, node *tree.Node, updateIfExists bool) (err error)
  • func (i *IndexEndpoint) DeleteNode(ctx context.Context, path string) (err error)
  • func (i *IndexEndpoint) FinishSession(ctx context.Context, sessionUuid string) error
  • func (i *IndexEndpoint) FlushSession(ctx context.Context, sessionUuid string) error
  • func (i *IndexEndpoint) GetEndpointInfo() commonsync.EndpointInfo
  • func (i *IndexEndpoint) LoadNode(ctx context.Context, path string, leaf ...bool) (node *tree.Node, err error)
  • func (i *IndexEndpoint) LoadNodeByUuid(ctx context.Context, uuid string) (node *tree.Node, err error)
  • func (i *IndexEndpoint) MoveNode(ctx context.Context, oldPath string, newPath string) (err error)
  • func (i *IndexEndpoint) StartSession(ctx context.Context, rootNode *tree.Node) (*tree.IndexationSession, error)
  • func (i *IndexEndpoint) UpdateNode(ctx context.Context, node *tree.Node) error
  • func (i *IndexEndpoint) Walk(walknFc commonsync.WalkNodesFunc, pathes ...string) (err error)
  • func (i *IndexEndpoint) Watch(recursivePath string) (*commonsync.WatchObject, error)
• type IndexStreamer
  • func NewIndexStreamer(serviceName string) *IndexStreamer
  • func (i *IndexStreamer) CreateNode(ctx context.Context, request *tree.CreateNodeRequest) (response *tree.CreateNodeResponse, err error)
  • func (i *IndexStreamer) DeleteNode(ctx context.Context, request *tree.DeleteNodeRequest) (response *tree.DeleteNodeResponse, err error)
  • func (i *IndexStreamer) ReadNode(ctx context.Context, request *tree.ReadNodeRequest) (response *tree.ReadNodeResponse, err error)
  • func (i *IndexStreamer) StartCreator(ctx context.Context) error
  • func (i *IndexStreamer) StartDeleter(ctx context.Context) error
  • func (i *IndexStreamer) StartReader(ctx context.Context) error
  • func (i *IndexStreamer) StartUpdater(ctx context.Context) error
  • func (i *IndexStreamer) Stop()
  • func (i *IndexStreamer) UpdateNode(ctx context.Context, request *tree.UpdateNodeRequest) (response *tree.UpdateNodeResponse, err error)

Variables

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

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)