proc

May 7, 2019

Changes in this version

+ func MergeNodes(left *TreeNode, right *TreeNode, diff *SourceDiff)

+ type ChildrenCursor struct

+ func (c *ChildrenCursor) Next() *TreeNode

type SourceDiff

+ func (diff *SourceDiff) Stats() map[string]int

+ 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

Apr 24, 2018

Changes in this version

+ 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 sync.PathSyncSource

+ MissingLeft []*tree.Node

+ MissingRight []*tree.Node

+ Right sync.PathSyncSource

+ func ComputeSourcesDiff(ctx context.Context, left sync.PathSyncSource, right sync.PathSyncSource, ...) (diff *SourceDiff, err error)

+ func (diff *SourceDiff) FilterMissing(source sync.PathSyncSource, target sync.PathSyncTarget, in []*tree.Node, ...) (out map[string]*filters.BatchedEvent)

+ func (diff *SourceDiff) String() string

+ func (diff *SourceDiff) ToBidirectionalBatch(leftTarget sync.PathSyncTarget, rightTarget sync.PathSyncTarget) (batch *filters.BidirectionalBatch, err error)

+ func (diff *SourceDiff) ToUnidirectionalBatch(direction string) (batch *filters.Batch, err error)