Function NewDiffResolver

downloader/diff_resolver.go:65–75

(ctx DiffResolverCtx)

)

func NewDiffResolver(ctx DiffResolverCtx) *DiffResolver {
	if ctx == nil {
		ctx = &defaultDiffResolverCtx{}
	}
	return &DiffResolver{
		ctx:      ctx,
		srcCh:    make(chan *cluster.LOM, 1000),
		dstCh:    make(chan *DstElement, 1000),
		resultCh: make(chan DiffResolverResult, 1000),
	}
}

func (dr *DiffResolver) Start() {
	go func() {