Trino
Trino
Since v0.44.0
Introduction
The Testcontainers module for Trino.
Trino is an open-source distributed SQL query engine designed to run interactive analytic queries against data sources of all sizes, from gigabytes to petabytes. It is the community continuation of PrestoSQL.
Adding this module to your project dependencies
Please run the following command to add the Trino module to your Go dependencies:
go get github.com/testcontainers/testcontainers-go/modules/trinoUsage example
Creating a Trino container
ctx := context.Background()
trinoContainer, err := trino.Run(ctx, "trinodb/trino:435")
defer func() {
if err := testcontainers.TerminateContainer(trinoContainer); err != nil {
log.Printf("failed to terminate container: %s", err)
}
}()
if err != nil {
log.Printf("failed to start container: %s", err)
return
}Module Reference
Run function
- Since v0.44.0
The Trino module exposes one entrypoint function to create the Trino container, and this function receives three parameters:
func Run(ctx context.Context, img string, opts ...testcontainers.ContainerCustomizer) (*Container, error)context.Context, the Go context.string, the Docker image to use.testcontainers.ContainerCustomizer, a variadic argument for passing options.
Image
Use the second argument in the Run function to set a valid Docker image. In example: Run(context.Background(), "trinodb/trino:435").
Wait strategy
The module waits for the Trino coordinator to be ready by polling the /v1/info HTTP endpoint on port 8080/tcp. It checks that the JSON field starting is false, which indicates the coordinator has finished its initialisation. The default startup timeout is 2 minutes.
Container Options
When starting the Trino container, you can pass options in a variadic way to configure it.
The following options are exposed by the testcontainers package.
Basic Options
WithExposedPortsSince v0.37.0WithEnvSince v0.29.0WithWaitStrategySince v0.20.0WithAdditionalWaitStrategySince v0.38.0WithWaitStrategyAndDeadlineSince v0.20.0WithAdditionalWaitStrategyAndDeadlineSince v0.38.0WithEntrypointSince v0.37.0WithEntrypointArgsSince v0.37.0WithCmdSince v0.37.0WithCmdArgsSince v0.37.0WithLabelsSince v0.37.0
Lifecycle Options
WithLifecycleHooksSince v0.38.0WithAdditionalLifecycleHooksSince v0.38.0WithStartupCommandSince v0.25.0WithAfterReadyCommandSince v0.28.0
Files & Mounts Options
WithFilesSince v0.37.0WithMountsSince v0.37.0WithTmpfsSince v0.37.0WithImageMountSince v0.37.0
Build Options
WithDockerfileSince v0.37.0
Logging Options
WithLogConsumersSince v0.28.0WithLogConsumerConfigSince v0.38.0WithLoggerSince v0.29.0
Image Options
WithAlwaysPullSince v0.38.0WithImageSubstitutorsSince v0.26.0WithImagePlatformSince v0.38.0
Networking Options
WithNetworkSince v0.27.0WithNetworkByNameSince v0.38.0WithBridgeNetworkSince v0.38.0WithNewNetworkSince v0.27.0
Advanced Options
WithHostPortAccessSince v0.31.0WithConfigModifierSince v0.20.0 · Chainable since mainWithHostConfigModifierSince v0.20.0 · Chainable since mainWithEndpointSettingsModifierSince v0.20.0 · Chainable since mainCustomizeRequestSince v0.20.0WithNameSince v0.38.0WithNoStartSince v0.38.0WithProviderSince v0.39.0
Experimental Options
WithReuseByNameSince v0.37.0
Container Methods
The Trino container exposes the following methods:
ConnectionString
- Since v0.44.0
This method returns the HTTP connection string for the Trino coordinator, e.g. http://localhost:8080.
connStr, err := trinoContainer.ConnectionString(ctx)评论
登录后参与评论
KnowForge