Method checkServices

pkg/acquisition/modules/docker/run.go:243–295

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

}

func (d *Source) checkServices(ctx context.Context, monitChan chan *ContainerConfig, deleteChan chan *ContainerConfig) error {
	// Track current running services for garbage collection
	runningServicesID := make(map[string]bool)

	services, err := d.Client.ServiceList(ctx, client.ServiceListOptions{})
	if err != nil {
		if strings.Contains(strings.ToLower(err.Error()), "cannot connect to the docker daemon at") {
			d.logger.Errorf("cannot connect to docker daemon for service monitoring: %v", err)

			// Kill all running service monitoring if we can't connect
			for id, service := range d.runningServiceState.GetAll() {
				if service.t.Alive() {
					d.logger.Infof("killing tail for service %s", service.Name)
					service.t.Kill(nil)

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

				d.runningServiceState.Delete(id)
			}
		} else {
			d.logger.Errorf("service list err: %s", err)
		}

		return err
	}

	for _, service := range services.Items {
		runningServicesID[service.ID] = true

		// Don't need to re-eval an already monitored service
		if _, ok := d.runningServiceState.Get(service.ID); ok {
			continue
		}

		if serviceConfig := d.EvalService(ctx, service); serviceConfig != nil {
			monitChan <- serviceConfig
		}
	}

	// Send deletion notifications for services that are no longer running
	for serviceStateID, serviceConfig := range d.runningServiceState.GetAll() {
		if _, ok := runningServicesID[serviceStateID]; !ok {
			deleteChan <- serviceConfig
		}
	}

	d.logger.Tracef("Reading logs from %d services", d.runningServiceState.Len())

	return nil
}

func (d *Source) checkContainers(ctx context.Context, monitChan chan *ContainerConfig, deleteChan chan *ContainerConfig) error {
	// to track for garbage collection