QuestDB
QuestDB
Since v0.44.0
Introduction
QuestDB is an open-source time-series database designed for high-throughput ingestion and fast SQL queries. It supports the InfluxDB line protocol for fast writes, a PostgreSQL wire protocol for SQL queries, and a REST API with a built-in web console.
Adding this module to your project dependencies
Please run the following command to add the QuestDB module to your Go dependencies:
go get github.com/testcontainers/testcontainers-go/modules/questdbUsage example
Creating a QuestDB container
ctx := context.Background()
questdbContainer, err := questdb.Run(ctx, "questdb/questdb:7.4.2")
defer func() {
if err := testcontainers.TerminateContainer(questdbContainer); 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 QuestDB module exposes one entrypoint function to create the QuestDB 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(), "questdb/questdb:7.4").
Container Options
When starting the QuestDB 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 QuestDB container exposes the following methods:
HTTPEndpoint
- Since v0.44.0
Returns the URL of the QuestDB HTTP web console and REST API, using the 9000/tcp port.
HTTPEndpoint
httpEndpoint, err := questdbContainer.HTTPEndpoint(ctx)The returned URL has the format http://host:port.
PGEndpoint
- Since v0.44.0
Returns the PostgreSQL wire protocol connection string for the QuestDB container, using the 8812/tcp port and the built-in default credentials (admin/quest).
PGEndpoint
pgEndpoint, err := questdbContainer.PGEndpoint(ctx)The returned URL has the format postgres://admin:[REDACTED]@host:port/qdb.
InfluxDBEndpoint
- Since v0.44.0
Returns the InfluxDB line protocol endpoint address of the QuestDB container, using the 9009/tcp port. This endpoint is used for high-throughput time-series data ingestion.
InfluxDBEndpoint
ilpEndpoint, err := questdbContainer.InfluxDBEndpoint(ctx)The returned address has the format host:port.
评论
登录后参与评论
KnowForge