Package software.xdev.tci.factory

Class BaseTCIFactory<C extends org.testcontainers.containers.GenericContainer<C>,I extends TCI<C>>

java.lang.Object

software.xdev.tci.factory.BaseTCIFactory<C,I>

All Implemented Interfaces:

AutoCloseable, TCIFactory<C,I>

Direct Known Subclasses:

OnDemandTCIFactory, PreStartableTCIFactory

public abstract class BaseTCIFactory<C extends org.testcontainers.containers.GenericContainer<C>,I extends TCI<C>>
extends Object
implements TCIFactory<C,I>

Field Summary

Fields

Modifier and Type	Field	Description
protected final String	containerBaseName
protected final Supplier<C>	containerBuilder
protected final String	containerLoggerName
protected int	getNewTryCount	Describes how often new infra should be created/started - if it fails.
protected BiFunction<C,String,I>	infraBuilder
protected Set<I>	returnedAndInUse
protected final TCITracer	tracer
protected boolean	warmedUp

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BaseTCIFactory(BiFunction<C,String,I> infraBuilder, Supplier<C> containerBuilder, String containerBaseName, String containerLoggerName)

Method Summary

Modifier and Type	Method	Description
protected C	buildContainer()
void	close()
protected static org.testcontainers.containers.output.Slf4jLogConsumer	getLogConsumer(String name)
Set<I>	getReturnedAndInUse()
TCITracer	getTracer()
protected void	handleInfraStartFail(I infra)
protected org.slf4j.Logger	log()
protected I	registerReturned(I infra)
void	setGetNewTryCount(int getNewTryCount)
void	warmUp()	Does some warm up work, e.g. building images so that they don't have to be pulled later.
protected void	warmUpInternal()
protected void	warmUpSync()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface software.xdev.tci.factory.TCIFactory

getFactoryName, register, unregister

Field Details

returnedAndInUse

protected Set<I extends TCI<C>> returnedAndInUse

warmedUp

protected boolean warmedUp

getNewTryCount

protected int getNewTryCount

Describes how often new infra should be created/started - if it fails.

This helps with "Random" errors that occur during infra startup. For example when a port allocation fails.

infraBuilder

protected BiFunction<C extends org.testcontainers.containers.GenericContainer<C>,String,I extends TCI<C>> infraBuilder

containerBuilder

protected final Supplier<C extends org.testcontainers.containers.GenericContainer<C>> containerBuilder

containerBaseName

protected final String containerBaseName

containerLoggerName

protected final String containerLoggerName

tracer

protected final TCITracer tracer

Constructor Details

BaseTCIFactory

protected BaseTCIFactory(BiFunction<C,String,I> infraBuilder,
 Supplier<C> containerBuilder,
 String containerBaseName,
 String containerLoggerName)

Method Details

warmUp

public void warmUp()

Description copied from interface: TCIFactory

Does some warm up work, e.g. building images so that they don't have to be pulled later.

Specified by:

warmUp in interface TCIFactory<C extends org.testcontainers.containers.GenericContainer<C>,I extends TCI<C>>

warmUpSync

protected void warmUpSync()

warmUpInternal

protected void warmUpInternal()

buildContainer

protected C buildContainer()

handleInfraStartFail

protected void handleInfraStartFail(I infra)

registerReturned

protected I registerReturned(I infra)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface TCIFactory<C extends org.testcontainers.containers.GenericContainer<C>,I extends TCI<C>>

getReturnedAndInUse

public Set<I> getReturnedAndInUse()

Specified by:

getReturnedAndInUse in interface TCIFactory<C extends org.testcontainers.containers.GenericContainer<C>,I extends TCI<C>>

getTracer

public TCITracer getTracer()

Specified by:

getTracer in interface TCIFactory<C extends org.testcontainers.containers.GenericContainer<C>,I extends TCI<C>>

setGetNewTryCount

public void setGetNewTryCount(int getNewTryCount)

log

protected org.slf4j.Logger log()

getLogConsumer

protected static org.testcontainers.containers.output.Slf4jLogConsumer getLogConsumer(String name)