utils

package

v1.0.1 Latest Latest Go to latest Published: Jul 22, 2025 License: Apache-2.0 Imports: 28 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/flowexec/flow

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func ExecWithCmd(cmd string) gomock.Matcher
func ExecWithRef(ref executable.Ref) gomock.Matcher
func FindSubExecs(rootExec *executable.Executable, flowFiles executable.FlowFileList) executable.ExecutableList
func MaybeUpdateGolden(tb testing.TB, out []byte)
func NormalizeTmpDirs(input string) string
func RequireEqualSnapshot(tb testing.TB, out []byte)
func ResetTestContext(ctx *Context, t ginkgo.FullGinkgoTInterface)
func UpdateGolden(tb testing.TB, out []byte)
type CommandRunner
- func NewE2ECommandRunner() *CommandRunner
- func (r *CommandRunner) Run(ctx *context.Context, args ...string) (err error)
type Context
- func NewContext(ctx stdCtx.Context, t ginkgo.FullGinkgoTInterface) *Context
- func (c *Context) WorkspaceDir() string
type ContextWithMocks
- func NewContextWithMocks(ctx stdCtx.Context, t ginkgo.FullGinkgoTInterface) *ContextWithMocks

Constants ¶

View Source

const (
	TestWorkspaceName        = "default"
	TestWorkspaceDisplayName = "Default Workspace"
)

Variables ¶

This section is empty.

Functions ¶

func ExecWithCmd ¶

func ExecWithCmd(cmd string) gomock.Matcher

func ExecWithRef ¶

func ExecWithRef(ref executable.Ref) gomock.Matcher

func FindSubExecs ¶

func FindSubExecs(rootExec *executable.Executable, flowFiles executable.FlowFileList) executable.ExecutableList

FindSubExecs returns a list of sub-executables for the given root executable.

func MaybeUpdateGolden ¶ added in v1.0.1

func MaybeUpdateGolden(tb testing.TB, out []byte)

func NormalizeTmpDirs ¶ added in v1.0.1

func NormalizeTmpDirs(input string) string

NormalizeTmpDirs replaces all file paths under the system temp dir with /TMPDIR.

func RequireEqualSnapshot ¶ added in v1.0.1

func RequireEqualSnapshot(tb testing.TB, out []byte)

func ResetTestContext ¶

func ResetTestContext(ctx *Context, t ginkgo.FullGinkgoTInterface)

func UpdateGolden ¶ added in v1.0.1

func UpdateGolden(tb testing.TB, out []byte)

Types ¶

type CommandRunner ¶

type CommandRunner struct{}

func NewE2ECommandRunner ¶

func NewE2ECommandRunner() *CommandRunner

func (*CommandRunner) Run ¶

func (r *CommandRunner) Run(ctx *context.Context, args ...string) (err error)

type Context ¶

type Context struct {
	*context.Context
	// contains filtered or unexported fields
}

func NewContext ¶

func NewContext(ctx stdCtx.Context, t ginkgo.FullGinkgoTInterface) *Context

NewContext creates a new context for testing runners. It initializes the context with a real logger that writes it's output to a temporary file. It also creates a temporary testing directory for the test workspace, user configs, and caches. Test environment variables are set the config and cache directories override paths.

func (*Context) WorkspaceDir ¶ added in v1.0.1

func (c *Context) WorkspaceDir() string

type ContextWithMocks ¶

type ContextWithMocks struct {
	Ctx             *context.Context
	Logger          *tuikitIOMocks.MockLogger
	ExecutableCache *cacheMocks.MockExecutableCache
	WorkspaceCache  *cacheMocks.MockWorkspaceCache
	RunnerMock      *mocks.MockRunner
}

func NewContextWithMocks ¶

func NewContextWithMocks(ctx stdCtx.Context, t ginkgo.FullGinkgoTInterface) *ContextWithMocks

NewContextWithMocks creates a new context for testing runners. It initializes the context with a mock logger and mock caches. The mock logger is set to expect debug calls.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL