type ProviderConfig struct {
    ProjectID string // GCP project ID
}

import (
    "github.com/resolute-sh/resolute-gcp"
)

provider := gcp.Provider(gcp.ProviderConfig{
    ProjectID: os.Getenv("GCP_PROJECT_ID"),
})

type CheckVersionInput struct {
    ProjectID string   // GCP project ID
    Version   string   // GKE version to check (e.g., "1.29.1-gke.1589000")
    Regions   []string // Regions to check (e.g., ["us-central1", "europe-west1"])
}

type CheckVersionOutput struct {
    Version          string   // Checked version
    TotalRegions     int      // Number of regions checked
    AvailableRegions []string // Regions where version is available
    FailedRegions    []string // Regions where version is unavailable or check failed
    AllAvailable     bool     // True if available in all requested regions
}

func CheckVersion(input CheckVersionInput) *core.Node[CheckVersionInput, CheckVersionOutput]

checkNode := gcp.CheckVersion(gcp.CheckVersionInput{
    ProjectID: os.Getenv("GCP_PROJECT_ID"),
    Version:   "1.29.1-gke.1589000",
    Regions:   []string{"us-central1", "us-east1", "europe-west1"},
})

flow := core.NewFlow("gke-version-check").
    TriggeredBy(core.Schedule("0 8 * * *")).
    Then(gcp.CheckVersion(gcp.CheckVersionInput{
        ProjectID: os.Getenv("GCP_PROJECT_ID"),
        Version:   os.Getenv("TARGET_GKE_VERSION"),
        Regions:   []string{"us-central1", "us-east1", "europe-west1"},
    }).As("check")).
    When(func(s *core.FlowState) bool {
        result := core.Get[gcp.CheckVersionOutput](s, "check")
        return result.AllAvailable
    }).
        Then(notifyReadyNode).
    EndWhen().
    Build()