aws

Documentation

Index

• Variables

Variables

var AnthosOnAWSClusterNamePrefixTask = inspection_task.NewInspectionProducer(task.ClusterNamePrefixTaskID+"#gke-on-aws", func(ctx context.Context, taskMode int, progress *progress.TaskProgress) (any, error) {
	return "awsClusters/", nil
}, inspection_task.InspectionTypeLabel(InspectionTypeId))

var AnthosOnAWSInspectionType = inspection.InspectionType{
	Id:   InspectionTypeId,
	Name: "GKE on AWS(Anthos on AWS)",
	Description: `Visualize logs generated from GKE on AWS cluster. 
Supporting K8s audit log, k8s event log,k8s node log, k8s container log and MultiCloud API audit log.`,
	Icon:     "assets/icons/anthos.png",
	Priority: math.MaxInt - 2,
}

var AutocompleteClusterNames = task.NewCachedProcessor(gcp_task.AutocompleteClusterNamesTaskID+"#anthos-on-aws", []string{
	gcp_task.InputProjectIdTaskID,
}, func(ctx context.Context, taskMode int, v *task.VariableSet) (any, error) {
	client, err := api.DefaultGCPClientFactory.NewClient()
	if err != nil {
		return nil, err
	}
	projectId, err := gcp_task.GetInputProjectIdFromTaskVariable(v)
	if err != nil {
		return nil, err
	}
	if projectId != "" {
		clusterNames, err := client.GetAnthosAWSClusterNames(ctx, projectId)
		if err != nil {
			slog.WarnContext(ctx, fmt.Sprintf("Failed to read the cluster names in the project %s\n%s", projectId, err))
			return &gcp_task.AutocompleteClusterNameList{
				ClusterNames: []string{},
				Error:        "Failed to get the list from API",
			}, nil
		}
		return &gcp_task.AutocompleteClusterNameList{
			ClusterNames: clusterNames,
			Error:        "",
		}, nil
	}
	return &gcp_task.AutocompleteClusterNameList{
		ClusterNames: []string{},
		Error:        "Project ID is empty",
	}, nil
}, inspection_task.InspectionTypeLabel(InspectionTypeId))

var InspectionTypeId = "gcp-gke-on-aws"