googlecloudclustercomposer_contract

var AirflowDagProcessorManagerLogParserTaskID taskid.TaskImplementationID[struct{}] = taskid.NewDefaultImplementationID[struct{}](GoogleCloudComposerTaskIDPrefix + "composer/worker")

AirflowDagProcessorManagerLogParserTaskID is the task id for the task that parses Airflow DAG processor manager logs.

var AirflowSchedulerLogParserTaskID taskid.TaskImplementationID[struct{}] = taskid.NewDefaultImplementationID[struct{}](GoogleCloudComposerTaskIDPrefix + "composer/scheduler")

AirflowSchedulerLogParserTaskID is the task id for the task that parses Airflow scheduler logs.

var AirflowWorkerLogParserTaskID taskid.TaskImplementationID[struct{}] = taskid.NewDefaultImplementationID[struct{}](GoogleCloudComposerTaskIDPrefix + "composer/dagprocessor")

AirflowWorkerLogParserTaskID is the task id for the task that parses Airflow worker logs.

var AutocompleteComposerClusterNamesTaskID = taskid.NewImplementationID(googlecloudk8scommon_contract.AutocompleteClusterIdentityTaskID.Ref(), "composer")

AutocompleteComposerClusterNamesTaskID is the task id for the task that autocompletes GKE cluster names created by Cloud Composer.

var AutocompleteComposerEnvironmentIdentityTaskID = taskid.NewDefaultImplementationID[*inspectioncore_contract.AutocompleteResult[ComposerEnvironmentIdentity]](GoogleCloudComposerTaskIDPrefix + "autocomplete/composer-environment-identities")

AutocompleteComposerEnvironmentIdentityTaskID is the task id for the task that autocompletes composer environment identities.

var AutocompleteComposerEnvironmentNamesTaskID taskid.TaskImplementationID[[]string] = taskid.NewDefaultImplementationID[[]string](GoogleCloudComposerTaskIDPrefix + "autocomplete/composer-environment-names")

AutocompleteComposerEnvironmentNamesTaskID is the task id for the task that autocompletes composer environment names.

var AutocompleteLocationForComposerEnvironmentTaskID = taskid.NewImplementationID(googlecloudcommon_contract.AutocompleteLocationTaskID.Ref(), "composer")

AutocompleteLocationForComposerEnvironmentTaskID is the task id for the task that autocompletes GKE cluster location from Composer environments.

var ComposerClusterNamePrefixTaskID = taskid.NewImplementationID(googlecloudk8scommon_contract.ClusterNamePrefixTaskRef, "composer")

ComposerClusterNamePrefixTaskID is the task id for the task that returns the GKE cluster name prefix used by Cloud Composer.

var ComposerDagProcessorManagerLogQueryTaskID taskid.TaskImplementationID[[]*log.Log] = taskid.NewDefaultImplementationID[[]*log.Log](GoogleCloudComposerTaskIDPrefix + "query-dag-processor-manager")

ComposerDagProcessorManagerLogQueryTaskID is the task id for the task that queries DAG processor manager logs from Cloud Logging.

var ComposerEnvironmentClusterFinderTaskID = taskid.NewDefaultImplementationID[ComposerEnvironmentClusterFinder](GoogleCloudComposerTaskIDPrefix + "composer-environment-cluster-finder")

ComposerEnvironmentClusterFinderTaskID is the task id for injecting ComposerEnvironmentClusterFinder instance.

var ComposerEnvironmentListFetcherTaskID = taskid.NewDefaultImplementationID[ComposerEnvironmentListFetcher](GoogleCloudComposerTaskIDPrefix + "composer-environment-list-fetcher")

ComposerEnvironmentListFetcherTaskID is the task id for injecting ComposerEnvironmentListFetcher instance.

var ComposerInspectionType = coreinspection.InspectionType{
	Id:   InspectionTypeId,
	Name: "Cloud Composer",
	Description: `Visualize logs related to Cloud Composer environment.
Supports all GKE related logs(Cloud Composer v2) and Airflow logs(Airflow 2.0.0 or higher in any Cloud Composer version(v1-v2, partical v3))`,
	Icon:     "assets/icons/composer.webp",
	Priority: math.MaxInt - 10,
}

ComposerInspectionType is the inspection type for google cloud composer.

var ComposerMonitoringLogQueryTaskID taskid.TaskImplementationID[[]*log.Log] = taskid.NewDefaultImplementationID[[]*log.Log](GoogleCloudComposerTaskIDPrefix + "query-monitoring")

ComposerMonitoringLogQueryTaskID is the task id for the task that queries monitoring logs from Cloud Logging.

var ComposerSchedulerLogQueryTaskID taskid.TaskImplementationID[[]*log.Log] = taskid.NewDefaultImplementationID[[]*log.Log](GoogleCloudComposerTaskIDPrefix + "query-scheduler")

ComposerSchedulerLogQueryTaskID is the task id for the task that queries scheduler logs from Cloud Logging.

var ComposerWorkerLogQueryTaskID taskid.TaskImplementationID[[]*log.Log] = taskid.NewDefaultImplementationID[[]*log.Log](GoogleCloudComposerTaskIDPrefix + "query-worker")

ComposerWorkerLogQueryTaskID is the task id for the task that queries worker logs from Cloud Logging.

var ErrEnvironmentClusterNotFound = errors.New("not found")

var GoogleCloudComposerTaskIDPrefix = "cloud.google.com/composer/"

GoogleCloudComposerTaskIDPrefix is the prefix for all task ids related to google cloud composer.

var InputComposerEnvironmentNameTaskID taskid.TaskImplementationID[string] = taskid.NewDefaultImplementationID[string](GoogleCloudComposerTaskIDPrefix + "input/composer/environment_name")

InputComposerEnvironmentNameTaskID is the task id for the task that inputs composer environment name.

var InspectionTypeId = "gcp-composer"

InspectionTypeId is the inspection type id for google cloud composer.