Versions in this module Expand all Collapse all v1 v1.6.1 Jul 9, 2019 Changes in this version + func MergeNodes(left *TreeNode, right *TreeNode, diff *SourceDiff) + type ChildrenCursor struct + func (c *ChildrenCursor) Next() *TreeNode + type Merger struct + BatchesChannel chan *filters.Batch + GlobalContext context.Context + JobsInterrupt chan bool + LocksChannel chan filters.LockEvent + RequeueChannels map[PathSyncSource]chan EventInfo + UnlocksChannel chan filters.UnlockEvent + func NewMerger(ctx context.Context) *Merger + func (b *Merger) AddRequeueChannel(source PathSyncSource, channel chan EventInfo) + func (b *Merger) Logger() *zap.Logger + func (b *Merger) ProcessBatches() + func (b *Merger) RegisterEventChannel(out chan ProcessorEvent) + func (b *Merger) Shutdown() + type ProcessFunc func(event *filters.BatchedEvent, operationId string) error + type SourceDiff struct + Context context.Context + Left common.PathSyncSource + MissingLeft []*tree.Node + MissingRight []*tree.Node + Right common.PathSyncSource + func ComputeSourcesDiff(ctx context.Context, left common.PathSyncSource, right common.PathSyncSource, ...) (diff *SourceDiff, err error) + func (diff *SourceDiff) FilterMissing(source common.PathSyncSource, target common.PathSyncTarget, in []*tree.Node, ...) (out map[string]*filters.BatchedEvent) + func (diff *SourceDiff) Stats() map[string]int + func (diff *SourceDiff) String() string + func (diff *SourceDiff) ToBidirectionalBatch(leftTarget common.PathSyncTarget, rightTarget common.PathSyncTarget) (batch *filters.BidirectionalBatch, err error) + func (diff *SourceDiff) ToUnidirectionalBatch(direction string) (batch *filters.Batch, err error) + type TreeNode struct + func NewTreeNode(n *tree.Node) *TreeNode + func TreeNodeFromSource(source common.PathSyncSource) (*TreeNode, error) + func (t *TreeNode) AddChild(n *TreeNode) + func (t *TreeNode) Enqueue(missings []*tree.Node) []*tree.Node + func (t *TreeNode) GetCursor() *ChildrenCursor + func (t *TreeNode) GetHash() string + func (t *TreeNode) GetLevel() int + func (t *TreeNode) Label() string + func (t *TreeNode) ParentPath() string + func (t *TreeNode) PrintOut() + func (t *TreeNode) SortedChildren() []*TreeNode
Go to main page