Versions in this module Expand all Collapse all v0 v0.2.0 Feb 10, 2026 v0.1.0 Feb 9, 2026 Changes in this version + const HealthzPath + const KindBinary + const PrivateKeysRoot + func AssertKubeProxy(t *testing.T, test *Test, localServerPort string, wantError bool) + func AssertLogBufferNoErrorBundle(t *testing.T, buf *bytes.Buffer) + func AssertLogBufferWithErrorBundle(t *testing.T, buf *bytes.Buffer) + func AssertLogMessage(t *testing.T, sett settings.Settings, msgInLog string) + func AssertLogMessagesCount(t *testing.T, sett settings.Settings, msgInLog string, expected int) + func AssertNoLogMessage(t *testing.T, sett settings.Settings, msgInLog string) + func AssertParseFlagsHelp(t *testing.T, params AssertParseFlagsHelpParams) + func CheckSkipSSHTest(t *testing.T, testName string) + func CreateDefaultTestSettings(test *Test) settings.Settings + func CreateDefaultTestSettingsWithAgent(test *Test, agentSockPath string) settings.Settings + func CreateTestSettingNoDebug(test *Test) settings.Settings + func DoGetRequest(url string, loop retry.Params, logger *PrefixLogger) (string, error) + func FakeSession() *session.Session + func GenerateID(names ...string) string + func GenerateKeys(test *Test, passphrase string) (string, string, error) + func GeneratePrivateKey(t *testing.T, passphrase string) string + func GeneratePrivateKeyWithPublic(t *testing.T, passphrase string) (string, string) + func GetTestLoopParamsForFailed() retry.Params + func IncorrectHost() string + func LogErrorOrAssert(t *testing.T, description string, err error, logger log.Logger) + func Name(t *testing.T) string + func PrepareFakeBashibleBundle(t *testing.T, test *Test, entrypoint, bundleDir string) string + func Ptr[T any](v T) *T + func RandInvalidPortExclude(_ []int) int + func RandPassword(n int) string + func RandPort() int + func RandPortExclude(exclude []int) int + func RandRange(min, max int) int + func RandRangeExclude(min, max int, exclude []int) int + func RandString(n int) string + func RunDocker(command ...string) error + func RunDockerWithOut(command ...string) (string, error) + func Session(wrapper *TestContainerWrapper, overrides ...SessionOverride) *session.Session + func SessionWithBastion(wrapper *TestContainerWrapper, bastionWrapper *TestContainerWrapper, ...) *session.Session + func SetEnvs(t *testing.T, envs map[string]string) + func Sleep(d time.Duration) + func TestLogger(opts ...TestOpt) *log.InMemoryLogger + func WritePubKeyFileForPrivate(test *Test, privateKeyPath string, pubKey string) (string, error) + type Agent struct + func StartAgent(sockDir string, logger log.Logger, keysPath ...PrivateKey) (*Agent, error) + func StartTestAgent(t *testing.T, wrapper *TestContainerWrapper) *Agent + func (a *Agent) AddKey(key PrivateKey) error + func (a *Agent) IsStopped() bool + func (a *Agent) Pid() int + func (a *Agent) RegisterCleanup(t *testing.T) + func (a *Agent) RemoveKey(key PrivateKey) error + func (a *Agent) SockPath() string + func (a *Agent) Stop() + func (a *Agent) String() string + type AssertParseFlagsHelpParams struct + ExpectedFlags int + Name string + Provider TestFlagsParserHelpProvider + type ContainerSettings struct + AdditionalVolumes []Volume + ContainerName string + LocalPort int + NodeTmpPath string + Password string + PublicKey *PublicKey + SudoAccess bool + Username string + func (s *ContainerSettings) HasPassword() bool + func (s *ContainerSettings) HasPublicKey() bool + func (s *ContainerSettings) HasPublicKeyContent() bool + func (s *ContainerSettings) HasPublicKeyPath() bool + func (s *ContainerSettings) LocalPortString() string + func (s *ContainerSettings) String() string + type HTTPHandler struct + Handle func(w http.ResponseWriter, r *http.Request, logger *PrefixLogger) + Path string + func NewSimpleHTTPHandler(path string, response string) *HTTPHandler + func (h *HTTPHandler) IsValid() error + type HTTPServer struct + func MustStartHTTPServer(t *testing.T, test *Test, port int, handlers ...*HTTPHandler) *HTTPServer + func NewHTTPServer(port int, logger *log.InMemoryLogger, handlers ...*HTTPHandler) *HTTPServer + func (s *HTTPServer) AddHandler(handler *HTTPHandler) + func (s *HTTPServer) RegisterCleanup(t *testing.T) + func (s *HTTPServer) Start(waitStart bool) error + func (s *HTTPServer) Stop() error + func (s *HTTPServer) WithLogPrefix(p string) *HTTPServer + type KINDCluster struct + ControlPlaneIP string + ControlPlanePort string + Name string + func CreateKINDCluster(t *testing.T, params *KINDClusterCreateParams) *KINDCluster + func (c *KINDCluster) Delete() error + func (c *KINDCluster) Kubeconfig() string + func (c *KINDCluster) KubeconfigWithIP(ip string, port string) string + func (c *KINDCluster) RESTConfig() (*rest.Config, error) + func (c *KINDCluster) RegisterCleanup(t *testing.T) + type KINDClusterCreateParams struct + ClusterName string + Containers []*SSHContainersForKind + NoPrepareLocalKubectlInSSHContainer bool + Test *Test + type PrefixLogger struct + func NewPrefixLogger(logger log.Logger) *PrefixLogger + func (l *PrefixLogger) Error(f string, args ...any) + func (l *PrefixLogger) Info(f string, args ...any) + func (l *PrefixLogger) Log(write func(string, ...any), f string, args ...any) + func (l *PrefixLogger) WithPrefix(p string) *PrefixLogger + type PrivateKey struct + Password string + Path string + type PublicKey struct + Key string + Path string + type SSHContainer struct + func NewSSHContainer(settings *ContainerSettings) (*SSHContainer, error) + func (c *SSHContainer) Connect() error + func (c *SSHContainer) ContainerSettings() *ContainerSettings + func (c *SSHContainer) CreateDeckhouseDirs() error + func (c *SSHContainer) CreateDirectory(path string) error + func (c *SSHContainer) Disconnect() error + func (c *SSHContainer) DockerNetworkConnect(isDisconnect bool, name string) error + func (c *SSHContainer) DownloadKubectl(version string) error + func (c *SSHContainer) ExecToContainer(description string, command ...string) error + func (c *SSHContainer) FailAndUpConnection(sleepBeforeConnect time.Duration) error + func (c *SSHContainer) GetContainerIP() string + func (c *SSHContainer) GetContainerId() string + func (c *SSHContainer) GetNetwork() string + func (c *SSHContainer) GetSSHDConfigPath() string + func (c *SSHContainer) LocalPortString() string + func (c *SSHContainer) RemotePort() int + func (c *SSHContainer) RemotePortString() string + func (c *SSHContainer) Restart(waitSSHDStarted bool, sleepBeforeStart time.Duration) error + func (c *SSHContainer) ShortContainerId() string + func (c *SSHContainer) SoftRestart(waitSSHDStarted bool, sleepBeforeStart time.Duration) error + func (c *SSHContainer) Start(waitSSHDStarted bool) error + func (c *SSHContainer) Stop() error + func (c *SSHContainer) WithExternalNetwork(network string) *SSHContainer + func (c *SSHContainer) WithVolumes(volumes ...Volume) *SSHContainer + func (c *SSHContainer) WriteConfig() error + type SSHContainersForKind struct + Client connection.SSHClient + Container *TestContainerWrapper + type SessionOverride func(input *session.Input) + func OverrideSessionWithIncorrectBastionPort(wrappers ...*TestContainerWrapper) SessionOverride + func OverrideSessionWithIncorrectPort(wrappers ...*TestContainerWrapper) SessionOverride + type Test struct + Logger *log.InMemoryLogger + func NewTest(testName string, opts ...TestOpt) (*Test, error) + func ShouldNewIntegrationTest(t *testing.T, name string, opts ...TestOpt) *Test + func ShouldNewTest(t *testing.T, testName string, opts ...TestOpt) *Test + func (s *Test) Cleanup(t *testing.T) + func (s *Test) CreateFile(content string, executable bool, pathInTestDir ...string) (string, error) + func (s *Test) CreateFileWithSameSuffix(sourceFile string, content string, executable bool, pathInTestDir ...string) (string, error) + func (s *Test) CreateTmpFile(content string, executable bool, pathInTestDir ...string) (string, error) + func (s *Test) FullName() string + func (s *Test) GenerateID(names ...string) string + func (s *Test) GetID() string + func (s *Test) GetLogger() *log.InMemoryLogger + func (s *Test) IsZero() bool + func (s *Test) MkSubDirs(dirs ...string) (string, error) + func (s *Test) MustCreateFile(t *testing.T, content string, executable bool, pathInTestDir ...string) string + func (s *Test) MustCreateTmpFile(t *testing.T, content string, executable bool, pathInTestDir ...string) string + func (s *Test) MustCreateUnaccessibleDir(t *testing.T, name string) + func (s *Test) MustMkSubDirs(t *testing.T, dirs ...string) string + func (s *Test) Name() string + func (s *Test) RegisterCleanup(t *testing.T) + func (s *Test) RunSubTestParallel(t *testing.T) + func (s *Test) SetSubTest(names ...string) *Test + func (s *Test) SetTmpDir(dir string) error + func (s *Test) Settings() settings.Settings + func (s *Test) TmpDir() string + func (s *Test) TryToSkipIntegrationTest(t *testing.T) + func (s *Test) WithAuthSock(p string) *Test + func (s *Test) WithEnvsPrefix(p string) *Test + func (s *Test) WrapError(format string, args ...any) error + func (s *Test) WrapErrorWithAfterName(aftername, format string, args ...any) error + type TestContainerWrapper struct + Container *SSHContainer + PrivateKeyPath string + Settings *TestContainerWrapperSettings + func NewTestContainerWrapper(t *testing.T, test *Test, opts ...TestContainerWrapperSettingsOpts) *TestContainerWrapper + func (c *TestContainerWrapper) AgentPrivateKeys() []session.AgentPrivateKey + func (c *TestContainerWrapper) Cleanup(t *testing.T) + func (c *TestContainerWrapper) ContainerIP() string + func (c *TestContainerWrapper) LocalPort() int + func (c *TestContainerWrapper) PublicKeyPath() string + type TestContainerWrapperSettings struct + ExternalNetwork string + NoGeneratePrivateKey bool + NoGeneratePrivateKeys bool + NoStartContainerDuringCreate bool + NoWaitStartingSSHDAfterStartContainer bool + NoWriteSSHDConfig bool + PrivateKeyPassword string + type TestContainerWrapperSettingsOpts func(container *TestContainerWrapperSettings) + func WithAuthSettings(testContainer *TestContainerWrapper) TestContainerWrapperSettingsOpts + func WithConnectToContainerNetwork(testContainer *TestContainerWrapper) TestContainerWrapperSettingsOpts + func WithContainerName(name string) TestContainerWrapperSettingsOpts + func WithLocalPort(port int) TestContainerWrapperSettingsOpts + func WithNoGeneratePrivateKeys() TestContainerWrapperSettingsOpts + func WithNoPassword() TestContainerWrapperSettingsOpts + func WithNoStartContainer() TestContainerWrapperSettingsOpts + func WithNoSudo() TestContainerWrapperSettingsOpts + func WithNoWaitStartingSSHDAfterStartContainer() TestContainerWrapperSettingsOpts + func WithNoWriteSSHDConfig() TestContainerWrapperSettingsOpts + func WithPassword(password string) TestContainerWrapperSettingsOpts + func WithUserName(name string) TestContainerWrapperSettingsOpts + func WithVolumes(v []Volume) TestContainerWrapperSettingsOpts + type TestFlagsParser interface + InitFlags func(*flag.FlagSet) (*flag.FlagSet, error) + type TestFlagsParserHelpProvider func(s settings.Settings, envsPrefix string) TestFlagsParser + type TestOpt func(opts *testOpts) + func TestIsIntegration(yes bool) TestOpt + func TestWithAuthSock(p string) TestOpt + func TestWithDebug(isDebug bool) TestOpt + func TestWithLoggerBuffer(b *bytes.Buffer) TestOpt + func TestWithParallelRun(p bool) TestOpt + func TestWithPrettyLogger(f bool) TestOpt + type Volume struct + Local string + Remote string
Go to main page