add ctx

skudasov · skudasov · commit 1c6d9a1019f2 · 2026-02-10T18:30:48.000+01:00
diff --git a/book/src/SUMMARY.md b/book/src/SUMMARY.md
@@ -6,6 +6,7 @@
   - [Configuration](./framework/developer_environment/toml.md)
 - [Basic Usage](./framework/getting_started.md)
   - [Getting Started](./framework/getting_started.md)
+  - [Running in Kubernetes](./framework/kubernetes.md)
 - [Advanced Usage](./framework/configuration.md)
   - [CLI](./framework/cli.md)
   - [Configuration](./framework/configuration.md)
diff --git a/book/src/framework/kubernetes.md b/book/src/framework/kubernetes.md
@@ -0,0 +1,7 @@
+# Running in Kubernetes
+
+Set up Kubernetes context for `main.stage` and add namespace variable to run `devenv`:
+```bash
+kubectl config use-context staging-eks-admin
+export KUBERNETES_NAMESPACE="devenv-1"
+```
diff --git a/framework/components/blockchain/anvil.go b/framework/components/blockchain/anvil.go
@@ -59,7 +59,7 @@ func newAnvil(ctx context.Context, in *Input) (*Output, error) {
 	framework.L.Info().Any("Cmd", strings.Join(entryPoint, " ")).Msg("Creating anvil with command")
 
 	if pods.K8sEnabled() {
-		_, err := pods.Run(&pods.Config{
+		_, err := pods.Run(ctx, &pods.Config{
 			Pods: []*pods.PodConfig{
 				{
 					Name:     pods.Ptr(in.ContainerName),
diff --git a/framework/components/blockchain/anvil_zksync.go b/framework/components/blockchain/anvil_zksync.go
@@ -2,13 +2,15 @@ package blockchain
 
 import (
 	"context"
+	"fmt"
 	"os"
 	"path/filepath"
 	"strings"
 
 	"github.com/testcontainers/testcontainers-go"
 
 	"github.com/smartcontractkit/chainlink-testing-framework/framework"
+	"github.com/smartcontractkit/chainlink-testing-framework/framework/pods"
 )
 
 var AnvilZKSyncRichAccountPks = []string{
@@ -58,7 +60,7 @@ func newAnvilZksync(ctx context.Context, in *Input) (*Output, error) {
 
 	dockerfilePath := filepath.Join(tempDir, "anvilZksync.Dockerfile")
 
-	if err := os.WriteFile(dockerfilePath, []byte(dockerFile), 0600); err != nil {
+	if err := os.WriteFile(dockerfilePath, []byte(dockerFile), 0o600); err != nil {
 		return nil, err
 	}
 
@@ -74,10 +76,15 @@ func newAnvilZksync(ctx context.Context, in *Input) (*Output, error) {
 		"/root/.foundry/bin/anvil-zksync" +
 			" --chain-id " + in.ChainID +
 			" --port " + in.Port +
-			" --offline"}
+			" --offline",
+	}
 
 	framework.L.Info().Any("Cmd", strings.Join(req.Entrypoint, " ")).Msg("Creating anvil zkSync with command")
 
+	if pods.K8sEnabled() {
+		return nil, fmt.Errorf("K8s support is not yet implemented")
+	}
+
 	output, err := createGenericEvmContainer(ctx, in, req, false)
 	if err != nil {
 		return nil, err
diff --git a/framework/components/blockchain/aptos.go b/framework/components/blockchain/aptos.go
@@ -12,6 +12,7 @@ import (
 	"github.com/testcontainers/testcontainers-go/wait"
 
 	"github.com/smartcontractkit/chainlink-testing-framework/framework"
+	"github.com/smartcontractkit/chainlink-testing-framework/framework/pods"
 )
 
 const (
@@ -87,6 +88,10 @@ func newAptos(ctx context.Context, in *Input) (*Output, error) {
 		imagePlatform = "linux/amd64"
 	}
 
+	if pods.K8sEnabled() {
+		return nil, fmt.Errorf("K8s support is not yet implemented")
+	}
+
 	req := testcontainers.ContainerRequest{
 		Image:        in.Image,
 		ExposedPorts: exposedPorts,
diff --git a/framework/components/blockchain/besu.go b/framework/components/blockchain/besu.go
@@ -1,6 +1,11 @@
 package blockchain
 
-import "context"
+import (
+	"context"
+	"fmt"
+
+	"github.com/smartcontractkit/chainlink-testing-framework/framework/pods"
+)
 
 const (
 	DefaultBesuPrivateKey1 = "8f2a55949038a9610f50fb23b5883af3b4ecb3c3bb792cbcefbd1542c692be63"
@@ -50,5 +55,9 @@ func newBesu(ctx context.Context, in *Input) (*Output, error) {
 	entryPoint := append(defaultCmd, in.DockerCmdParamsOverrides...)
 	req.Cmd = entryPoint
 
+	if pods.K8sEnabled() {
+		return nil, fmt.Errorf("K8s support is not yet implemented")
+	}
+
 	return createGenericEvmContainer(ctx, in, req, true)
 }
diff --git a/framework/components/blockchain/canton.go b/framework/components/blockchain/canton.go
@@ -9,6 +9,7 @@ import (
 	"github.com/testcontainers/testcontainers-go"
 
 	"github.com/smartcontractkit/chainlink-testing-framework/framework/components/blockchain/canton"
+	"github.com/smartcontractkit/chainlink-testing-framework/framework/pods"
 )
 
 const (
@@ -81,6 +82,10 @@ func newCanton(ctx context.Context, in *Input) (*Output, error) {
 		in.Port = DefaultCantonPort
 	}
 
+	if pods.K8sEnabled() {
+		return nil, fmt.Errorf("K8s support is not yet implemented")
+	}
+
 	// Set up Postgres container
 	postgresReq := canton.PostgresContainerRequest(in.NumberOfCantonValidators)
 	_, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
diff --git a/framework/components/blockchain/geth.go b/framework/components/blockchain/geth.go
@@ -9,6 +9,7 @@ import (
 	"github.com/docker/docker/api/types/mount"
 
 	"github.com/smartcontractkit/chainlink-testing-framework/framework"
+	"github.com/smartcontractkit/chainlink-testing-framework/framework/pods"
 
 	"github.com/testcontainers/testcontainers-go"
 )
@@ -185,5 +186,9 @@ func newGeth(ctx context.Context, in *Input) (*Output, error) {
 	}
 	req.Cmd = entryPoint
 
+	if pods.K8sEnabled() {
+		return nil, fmt.Errorf("K8s support is not yet implemented")
+	}
+
 	return createGenericEvmContainer(ctx, in, req, false)
 }
diff --git a/framework/components/blockchain/solana.go b/framework/components/blockchain/solana.go
@@ -16,6 +16,7 @@ import (
 	"github.com/testcontainers/testcontainers-go/wait"
 
 	"github.com/smartcontractkit/chainlink-testing-framework/framework"
+	"github.com/smartcontractkit/chainlink-testing-framework/framework/pods"
 )
 
 var configYmlRaw = `
@@ -96,6 +97,10 @@ func newSolana(ctx context.Context, in *Input) (*Output, error) {
 	}, flags...)
 	args = append(args, in.DockerCmdParamsOverrides...)
 
+	if pods.K8sEnabled() {
+		return nil, fmt.Errorf("K8s support is not yet implemented")
+	}
+
 	req := testcontainers.ContainerRequest{
 		AlwaysPullImage: in.PullImage,
 		Image:           in.Image,
diff --git a/framework/components/blockchain/stellar.go b/framework/components/blockchain/stellar.go
@@ -14,6 +14,7 @@ import (
 	"github.com/testcontainers/testcontainers-go/wait"
 
 	"github.com/smartcontractkit/chainlink-testing-framework/framework"
+	"github.com/smartcontractkit/chainlink-testing-framework/framework/pods"
 )
 
 const (
@@ -75,6 +76,10 @@ func newStellar(ctx context.Context, in *Input) (*Output, error) {
 		cmd = append(cmd, in.DockerCmdParamsOverrides...)
 	}
 
+	if pods.K8sEnabled() {
+		return nil, fmt.Errorf("K8s support is not yet implemented")
+	}
+
 	req := testcontainers.ContainerRequest{
 		AlwaysPullImage: in.PullImage,
 		Image:           in.Image,
diff --git a/framework/components/blockchain/sui.go b/framework/components/blockchain/sui.go
@@ -16,6 +16,7 @@ import (
 	"github.com/testcontainers/testcontainers-go/wait"
 
 	"github.com/smartcontractkit/chainlink-testing-framework/framework"
+	"github.com/smartcontractkit/chainlink-testing-framework/framework/pods"
 )
 
 const (
@@ -108,6 +109,10 @@ func newSui(ctx context.Context, in *Input) (*Output, error) {
 		imagePlatform = *in.ImagePlatform
 	}
 
+	if pods.K8sEnabled() {
+		return nil, fmt.Errorf("K8s support is not yet implemented")
+	}
+
 	req := testcontainers.ContainerRequest{
 		Image:        in.Image,
 		ExposedPorts: []string{containerPort, DefaultFaucetPort},
diff --git a/framework/components/blockchain/ton.go b/framework/components/blockchain/ton.go
@@ -12,6 +12,7 @@ import (
 	"github.com/testcontainers/testcontainers-go/wait"
 
 	"github.com/smartcontractkit/chainlink-testing-framework/framework"
+	"github.com/smartcontractkit/chainlink-testing-framework/framework/pods"
 )
 
 const (
@@ -82,6 +83,10 @@ func newTon(ctx context.Context, in *Input) (*Output, error) {
 
 	networkName := n.Name
 
+	if pods.K8sEnabled() {
+		return nil, fmt.Errorf("K8s support is not yet implemented")
+	}
+
 	req := testcontainers.ContainerRequest{
 		Image:           in.Image,
 		AlwaysPullImage: in.PullImage,
diff --git a/framework/components/blockchain/tron.go b/framework/components/blockchain/tron.go
@@ -11,6 +11,7 @@ import (
 	"github.com/docker/go-connections/nat"
 
 	"github.com/smartcontractkit/chainlink-testing-framework/framework"
+	"github.com/smartcontractkit/chainlink-testing-framework/framework/pods"
 
 	"github.com/testcontainers/testcontainers-go"
 	"github.com/testcontainers/testcontainers-go/wait"
@@ -79,6 +80,10 @@ func newTron(ctx context.Context, in *Input) (*Output, error) {
 		return nil, err
 	}
 
+	if pods.K8sEnabled() {
+		return nil, fmt.Errorf("K8s support is not yet implemented")
+	}
+
 	req := testcontainers.ContainerRequest{
 		AlwaysPullImage: in.PullImage,
 		Image:           in.Image,
diff --git a/framework/components/clnode/clnode.go b/framework/components/clnode/clnode.go
@@ -294,7 +294,7 @@ func newNode(ctx context.Context, in *Input, pgOut *postgres.Output) (*NodeOut,
 
 	// k8s deployment
 	if pods.K8sEnabled() {
-		_, err := pods.Run(&pods.Config{
+		_, err := pods.Run(ctx, &pods.Config{
 			Pods: []*pods.PodConfig{
 				{
 					Name:     pods.Ptr(containerName),
diff --git a/framework/components/fake/container.go b/framework/components/fake/container.go
@@ -40,7 +40,7 @@ func NewWithContext(ctx context.Context, in *Input) (*Output, error) {
 	bindPort := fmt.Sprintf("%d/tcp", in.Port)
 	containerName := framework.DefaultTCName("fake")
 	if pods.K8sEnabled() {
-		_, err := pods.Run(&pods.Config{
+		_, err := pods.Run(ctx, &pods.Config{
 			Pods: []*pods.PodConfig{
 				{
 					Name:     pods.Ptr(containerName),
diff --git a/framework/components/jd/jd.go b/framework/components/jd/jd.go
@@ -14,6 +14,7 @@ import (
 
 	"github.com/smartcontractkit/chainlink-testing-framework/framework"
 	"github.com/smartcontractkit/chainlink-testing-framework/framework/components/postgres"
+	"github.com/smartcontractkit/chainlink-testing-framework/framework/pods"
 )
 
 const (
@@ -98,6 +99,11 @@ func NewWithContext(ctx context.Context, in *Input) (*Output, error) {
 	containerName := framework.DefaultTCName("jd")
 	grpcPort := fmt.Sprintf("%s/tcp", in.GRPCPort)
 	wsHealthPort := fmt.Sprintf("%s/tcp", WSRPCHealthPort)
+
+	if pods.K8sEnabled() {
+		return nil, fmt.Errorf("K8s support is not yet implemented")
+	}
+
 	req := tc.ContainerRequest{
 		Name:     containerName,
 		Image:    in.Image,
diff --git a/framework/components/networktest/nettest.go b/framework/components/networktest/nettest.go
@@ -13,6 +13,7 @@ import (
 	"github.com/testcontainers/testcontainers-go/wait"
 
 	"github.com/smartcontractkit/chainlink-testing-framework/framework"
+	"github.com/smartcontractkit/chainlink-testing-framework/framework/pods"
 )
 
 type Input struct {
@@ -29,6 +30,9 @@ func NewNetworkTest(in Input) error {
 
 // NewNetworkTest creates a minimal Alpine Linux container for network testing
 func NewWithContext(ctx context.Context, in Input) error {
+	if pods.K8sEnabled() {
+		return fmt.Errorf("K8s support is not yet implemented")
+	}
 	req := testcontainers.ContainerRequest{
 		Name:     in.Name,
 		Image:    "alpine:latest",
diff --git a/framework/components/postgres/postgres.go b/framework/components/postgres/postgres.go
@@ -127,7 +127,7 @@ func NewWithContext(ctx context.Context, in *Input) (*Output, error) {
 
 	// k8s deployment
 	if pods.K8sEnabled() {
-		_, err := pods.Run(&pods.Config{
+		_, err := pods.Run(ctx, &pods.Config{
 			Pods: []*pods.PodConfig{
 				{
 					Name:  pods.Ptr(in.Name),
diff --git a/framework/components/s3provider/minio.go b/framework/components/s3provider/minio.go
@@ -16,6 +16,7 @@ import (
 	tcwait "github.com/testcontainers/testcontainers-go/wait"
 
 	"github.com/smartcontractkit/chainlink-testing-framework/framework"
+	"github.com/smartcontractkit/chainlink-testing-framework/framework/pods"
 )
 
 const (
@@ -113,6 +114,9 @@ func (mf MinioFactory) NewFrom(input *Input) (*Output, error) {
 }
 
 func (mf MinioFactory) NewWithContextFrom(ctx context.Context, input *Input) (*Output, error) {
+	if pods.K8sEnabled() {
+		return nil, fmt.Errorf("K8s support is not yet implemented")
+	}
 	// Fill in defaults on empty
 	err := mergo.Merge(input, DefaultMinio())
 	if err != nil {
diff --git a/framework/components/simple_node_set/node_set.go b/framework/components/simple_node_set/node_set.go
@@ -205,7 +205,7 @@ func sharedDBSetup(ctx context.Context, in *Input, bcOut *blockchain.Output) (*O
 	sortNodeOutsByHostPort(nodeOuts)
 	// wait for all K8s services at once
 	if pods.K8sEnabled() {
-		if err := pods.WaitReady(3 * time.Minute); err != nil {
+		if err := pods.WaitReady(ctx, 3*time.Minute); err != nil {
 			return nil, err
 		}
 	}
diff --git a/framework/pods/client.go b/framework/pods/client.go
@@ -77,13 +77,13 @@ func (k *API) AllPodsReady(ctx context.Context) (bool, error) {
 }
 
 // CreateNamespace creates a new Kubernetes namespace with the specified name.
-func (k *API) CreateNamespace(name string) error {
+func (k *API) CreateNamespace(ctx context.Context, name string) error {
 	namespace := &corev1.Namespace{
 		ObjectMeta: metav1.ObjectMeta{
 			Name: name,
 		},
 	}
-	_, err := k.ClientSet.CoreV1().Namespaces().Create(context.Background(), namespace, metav1.CreateOptions{})
+	_, err := k.ClientSet.CoreV1().Namespaces().Create(ctx, namespace, metav1.CreateOptions{})
 	if err != nil { // coverage-ignore
 		if strings.Contains(err.Error(), "already exists") {
 			L.Debug().Str("Namespace", name).Msg("Namespace already exists, proceeding..")
diff --git a/framework/pods/pods.go b/framework/pods/pods.go
@@ -93,7 +93,7 @@ func K8sEnabled() bool {
 }
 
 // Run generates and applies a new K8s YAML manifest
-func Run(cfg *Config) (string, error) {
+func Run(ctx context.Context, cfg *Config) (string, error) {
 	var err error
 	if cfg.Namespace == "" {
 		cfg.Namespace = os.Getenv(K8sNamespaceEnvVar)
@@ -103,7 +103,7 @@ func Run(cfg *Config) (string, error) {
 		return "", fmt.Errorf("failed to create K8s client: %w", err)
 	}
 	if Client != nil {
-		if err := Client.CreateNamespace(cfg.Namespace); err != nil {
+		if err := Client.CreateNamespace(ctx, cfg.Namespace); err != nil {
 			return "", fmt.Errorf("failed to create namespace: %s, %w", cfg.Namespace, err)
 		}
 	}
@@ -454,8 +454,8 @@ func (n *App) apply() error {
 	return nil
 }
 
-func WaitReady(t time.Duration) error {
-	_, err := Client.waitAllPodsReady(context.Background(), t)
+func WaitReady(ctx context.Context, t time.Duration) error {
+	_, err := Client.waitAllPodsReady(ctx, t)
 	return err
 }
 
diff --git a/framework/pods/pods_test.go b/framework/pods/pods_test.go
diff --git a/framework/pods/sync.go b/framework/pods/sync.go

Original file line number	Diff line number	Diff line change
`@@ -59,7 +59,7 @@ func newAnvil(ctx context.Context, in Input) (Output, error) {`
`59`	`59`	`framework.L.Info().Any("Cmd", strings.Join(entryPoint, " ")).Msg("Creating anvil with command")`
`60`	`60`
`61`	`61`	`if pods.K8sEnabled() {`
`62`		`- _, err := pods.Run(&pods.Config{`
	`62`	`+ _, err := pods.Run(ctx, &pods.Config{`
`63`	`63`	`Pods: []*pods.PodConfig{`
`64`	`64`	`{`
`65`	`65`	`Name: pods.Ptr(in.ContainerName),`
Original file line number	Diff line number	Diff line change
`@@ -9,6 +9,7 @@ import (`
`9`	`9`	`"github.com/docker/docker/api/types/mount"`
`10`	`10`
`11`	`11`	`"github.com/smartcontractkit/chainlink-testing-framework/framework"`
	`12`	`+ "github.com/smartcontractkit/chainlink-testing-framework/framework/pods"`
`12`	`13`
`13`	`14`	`"github.com/testcontainers/testcontainers-go"`
`14`	`15`	`)`
`@@ -185,5 +186,9 @@ func newGeth(ctx context.Context, in Input) (Output, error) {`
`185`	`186`	`}`
`186`	`187`	`req.Cmd = entryPoint`
`187`	`188`
	`189`	`+ if pods.K8sEnabled() {`
	`190`	`+ return nil, fmt.Errorf("K8s support is not yet implemented")`
	`191`	`+ }`
	`192`	`+`
`188`	`193`	`return createGenericEvmContainer(ctx, in, req, false)`
`189`	`194`	`}`