tests

func DinDTestContainer ¶

func DinDTestContainer(t *testing.T) error

func ExecCommand ¶

func ExecCommand(
	ctx context.Context,
	c testcontainers.Container,
	cmd string,
) (int, []byte, error)

Helper function to execute container commands

func ExecCommandWithStreaming ¶

func ExecCommandWithStreaming(ctx context.Context, t *testing.T, ctr testcontainers.Container, cmd string) (int, string, error)

ExecCommandWithStreaming executes a command and streams output in real-time

func ExecuteQuery ¶

func ExecuteQuery(ctx context.Context, t *testing.T, operation, host, port string)

func PatchDockerCompose ¶

func PatchDockerCompose(ctx context.Context, t *testing.T, ctr testcontainers.Container) error

PatchDockerCompose updates temporal-worker to build from local code

func VerifyIcebergTest ¶

func VerifyIcebergTest(ctx context.Context, t *testing.T, ctr testcontainers.Container, host, port string)