Versions in this module Expand all Collapse all v1 v1.6.1 Jul 9, 2019 Changes in this version + var ChildPrefix = common.SERVICE_GRPC_NAMESPACE_ + common.SERVICE_DATA_SYNC_ + var Name = common.SERVICE_GRPC_NAMESPACE_ + common.SERVICE_DATA_SYNC + type IndexEndpoint struct + 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 struct + 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) Incompatible versions in this module v2.0.6+incompatible Apr 23, 2020
Go to main page