if err != nil {
			klog.V(1).ErrorS(err, "Probe errored", "probeType", probeType, "pod", klog.KObj(pod), "podUID", pod.UID, "containerName", container.Name)
			pb.recordContainerEvent(pod, &container, v1.EventTypeWarning, events.ContainerUnhealthy, "%s probe errored: %v", probeType, err)
		} else { // result != probe.Success

			go func() {
				defer wg.Done()
				for {
					var result results.Update
					var probeType string
					select {
					case result = <-m.startupManager.Updates():
						probeType = "startup"
					case result = <-m.livenessManager.Updates():
						probeType = "liveness"
					case result = <-m.readinessManager.Updates():
						probeType = "readiness"
					case <-ctx.Done():
						return
					}

        return asEsIndexType();
    }

    @Override
    protected String asEsIndex() {
        return "fess_config.role_type";
    }

    @Override
    public String asEsIndexType() {
        return "role_type";
    }

    @Override
    public String asEsSearchType() {
        return "role_type";
    }

    @Override
    public RoleTypeDbm asDBMeta() {
        return RoleTypeDbm.getInstance();
    }

    //                                                                          ==========
    protected final String _tableDbName = "role_type";
    protected final String _tableDispName = "role_type";
    protected final String _tablePropertyName = "RoleType";

    public String getTableDbName() {
        return _tableDbName;
    }

    @Override

    @Override
    public RoleTypeDbm asDBMeta() {
        return RoleTypeDbm.getInstance();
    }

    @Override
    public String asTableDbName() {
        return "role_type";
    }

    // ===================================================================================
    //                                                                              Source

    @Override
    public RoleTypeDbm asDBMeta() {
        return RoleTypeDbm.getInstance();
    }

    @Override
    public String asTableDbName() {
        return "role_type";
    }

    @Override
    public boolean hasSpecifiedColumn() {
        return _specification != null;
    }

    @Override
    public ConditionQuery localCQ() {
        return doGetConditionQuery();

		}
		return true
	}
	return false

func waitForWorkerExit(t *testing.T, m *manager, workerPaths []probeKey) error {
	for _, w := range workerPaths {
		condition := func() (bool, error) {
			_, exists := m.getWorker(w.podUID, w.containerName, w.probeType)
			return !exists, nil
		}
		if exited, _ := condition(); exited {
			continue // Already exited, no need to poll.
		}
		t.Logf("Polling %v", w)

    //                                                                       =============
    @Override
    public String asTableDbName() {
        return "role_type";
    }

    @Override
    public String xgetAliasName() {
        return "role_type";
    }

    // ===================================================================================

                "fess_config.related_content", //
                "fess_config.related_query", //
                "fess_config.request_header", //
                "fess_config.role_type", //
                "fess_config.scheduled_job", //
                "fess_config.thumbnail_queue", //
                "fess_config.web_authentication", //
                "fess_config.web_config", //