influxdb

Documentation

Index

• func WithConfigFile(configFile string) testcontainers.CustomizeRequestOption
• func WithDatabase(database string) testcontainers.CustomizeRequestOption
• func WithInitDb(srcPath string) testcontainers.CustomizeRequestOption
• func WithPassword(password string) testcontainers.CustomizeRequestOption
• func WithUsername(username string) testcontainers.CustomizeRequestOption
• type InfluxDbContainer
  • func Run(ctx context.Context, img string, opts ...testcontainers.ContainerCustomizer) (*InfluxDbContainer, error)
  • func RunContainer(ctx context.Context, opts ...testcontainers.ContainerCustomizer) (*InfluxDbContainer, error)
  • func (c *InfluxDbContainer) ConnectionUrl(ctx context.Context) (string, error)
  • func (c *InfluxDbContainer) MustConnectionUrl(ctx context.Context) string

Examples

• Run

Functions

func WithConfigFile

func WithConfigFile(configFile string) testcontainers.CustomizeRequestOption

func WithDatabase

func WithDatabase(database string) testcontainers.CustomizeRequestOption

func WithInitDb

func WithInitDb(srcPath string) testcontainers.CustomizeRequestOption

WithInitDb returns a request customizer that initialises the database using the file `docker-entrypoint-initdb.d` located in `srcPath` directory.

func WithPassword

func WithPassword(password string) testcontainers.CustomizeRequestOption

func WithUsername

func WithUsername(username string) testcontainers.CustomizeRequestOption

Types

type InfluxDbContainer

type InfluxDbContainer struct {
	testcontainers.Container
}

InfluxDbContainer represents the MySQL container type used in the module

func Run

func Run(ctx context.Context, img string, opts ...testcontainers.ContainerCustomizer) (*InfluxDbContainer, error)

Run creates an instance of the InfluxDB container type

Example

// runInfluxContainer {
ctx := context.Background()

influxdbContainer, err := influxdb.Run(ctx,
	"influxdb:1.8.10",
	influxdb.WithDatabase("influx"),
	influxdb.WithUsername("root"),
	influxdb.WithPassword("password"),
)
defer func() {
	if err := testcontainers.TerminateContainer(influxdbContainer); err != nil {
		log.Printf("failed to terminate container: %s", err)
	}
}()
if err != nil {
	log.Printf("failed to start container: %s", err)
	return
}
// }

state, err := influxdbContainer.State(ctx)
if err != nil {
	log.Printf("failed to get container state: %s", err)
	return
}

fmt.Println(state.Running)

Output:

true

func RunContainer

func RunContainer(ctx context.Context, opts ...testcontainers.ContainerCustomizer) (*InfluxDbContainer, error)

Deprecated: use Run instead RunContainer creates an instance of the InfluxDB container type

func (*InfluxDbContainer) ConnectionUrl

func (c *InfluxDbContainer) ConnectionUrl(ctx context.Context) (string, error)

func (*InfluxDbContainer) MustConnectionUrl

func (c *InfluxDbContainer) MustConnectionUrl(ctx context.Context) string