Method collectChanges

pkg/devspace/sync/downstream.go:98–135

(skipIgnore bool)

}

func (d *downstream) collectChanges(skipIgnore bool) ([]*remote.Change, error) {
	d.sync.log.Debugf("Downstream - Start collecting changes")
	defer d.sync.log.Debugf("Downstream - Done collecting changes")

	changes := make([]*remote.Change, 0, 128)
	ctx, cancel := context.WithTimeout(d.sync.ctx, time.Minute*30)
	defer cancel()

	// Create a change client and collect all changes
	changesClient, err := d.client.Changes(ctx, &remote.Empty{})
	if err != nil {
		return nil, errors.Wrap(err, "start retrieving changes")
	}

	for {
		changeChunk, err := changesClient.Recv()
		if changeChunk != nil {
			for _, change := range changeChunk.Changes {
				if !skipIgnore && d.ignoreMatcher != nil && d.ignoreMatcher.Matches(change.Path, change.IsDir) {
					continue
				}
				if !d.shouldKeep(change) {
					continue
				}

				changes = append(changes, change)
			}
		}

		if err == io.EOF {
			break
		} else if err != nil {
			return nil, errors.Wrap(err, "recv change")
		}
	}

	return changes, nil
}

func (d *downstream) startPing(doneChan chan struct{}) {
	go func() {