Method checkContainers

pkg/acquisition/modules/docker/run.go:297–345

(ctx context.Context, monitChan chan *ContainerConfig, deleteChan chan *ContainerConfig)

}

func (d *Source) checkContainers(ctx context.Context, monitChan chan *ContainerConfig, deleteChan chan *ContainerConfig) error {
	// to track for garbage collection
	runningContainersID := make(map[string]bool)

	runningContainers, err := d.Client.ContainerList(ctx, client.ContainerListOptions{})
	if err != nil {
		if strings.Contains(strings.ToLower(err.Error()), "cannot connect to the docker daemon at") {
			for id, container := range d.runningContainerState.GetAll() {
				if container.t.Alive() {
					d.logger.Infof("killing tail for container %s", container.Name)
					container.t.Kill(nil)

					if err := container.t.Wait(); err != nil {
						d.logger.Infof("error while waiting for death of %s : %s", container.Name, err)
					}
				}

				d.runningContainerState.Delete(id)
			}
		} else {
			log.Errorf("container list err: %s", err)
		}

		return err
	}

	for _, container := range runningContainers.Items {
		runningContainersID[container.ID] = true

		// don't need to re eval an already monitored container
		if _, ok := d.runningContainerState.Get(container.ID); ok {
			continue
		}

		if containerConfig := d.EvalContainer(ctx, container); containerConfig != nil {
			monitChan <- containerConfig
		}
	}

	for containerStateID, containerConfig := range d.runningContainerState.GetAll() {
		if _, ok := runningContainersID[containerStateID]; !ok {
			deleteChan <- containerConfig
		}
	}

	d.logger.Tracef("Reading logs from %d containers", d.runningContainerState.Len())

	return nil
}

type subscription struct {
    events <-chan dockerTypesEvents.Message