Function New

integration/framework/framework.go:76–110

Instantiates a Framework. Cleanup *must* be called. Class is thread-compatible. All framework actions report fatal errors on the t specified at creation time. Typical use: func TestFoo(t *testing.T) { fm := framework.New(t) defer fm.Cleanup() ... actual test ... }

(t *testing.T)

//	     ... actual test ...
//	}
func New(t *testing.T) Framework {
	// All integration tests are large.
	if testing.Short() {
		t.Skip("Skipping framework test in short mode")
	}

	// Try to see if non-localhost hosts are GCE instances.
	fm := &realFramework{
		hostname: HostnameInfo{
			Host: *host,
			Port: *port,
		},
		t:        t,
		cleanups: make([]func(), 0),
	}
	fm.shellActions = shellActions{
		fm: fm,
	}
	fm.dockerActions = dockerActions{
		fm: fm,
	}
	fm.crioActions = crioActions{
		fm:        fm,
		podSeqNum: 0,
	}
	fm.containerdActions = containerdActions{
		fm:          fm,
		seqNum:      0,
		namespace:   "k8s.io",
		socket:      getContainerdSocket(),
		snapshotter: "native",
	}

	return fm
}

// getContainerdSocket returns the containerd socket path from CONTAINERD_SOCK env var.
func getContainerdSocket() string {