docker

Mar 24, 2026

Changes in this version

+ const DefaultAPIKey

+ const PoolRetryTimeout

+ func WithIPv6Disabled(conf *dc.CreateNetworkOptions)

type Docker

+ func (d *Docker) GoNode() *NodeContainer

+ func (d *Docker) ScalaNode() *NodeContainer

+ func (d *Docker) StartGoNode(ctx context.Context, cfg config.DockerConfigurator) error

+ func (d *Docker) StartNodes(ctx context.Context, goCfg, scalaCfg config.DockerConfigurator) error

+ func (d *Docker) StartScalaNode(ctx context.Context, cfg config.DockerConfigurator) error

+ type NodeContainer struct

+ func (c *NodeContainer) Close() error

+ func (c *NodeContainer) ContainerNetworkIP() string

+ func (c *NodeContainer) IP() string

+ func (c *NodeContainer) Ports() *PortConfig

+ func (c *NodeContainer) RestAPIURL() string

type PortConfig

+ GRPCPort string

+ RESTAPIPort string

Oct 19, 2022

Changes in this version

+ const BindPort

+ const GrpcApiPort

+ const RESTApiPort

+ type PortConfig struct

+ BindPort string

+ GrpcPort string

+ RestApiPort string

+ type Ports struct

+ Go *PortConfig

+ Scala *PortConfig

Aug 10, 2022

Changes in this version

type Docker

+ func (d *Docker) Finish(cancel context.CancelFunc)

Aug 2, 2022

Changes in this version

+ const DefaultTimeout

+ const GoNodeBindPort

+ const GoNodeGrpsApiPort

+ const GoNodeRESTApiPort

+ const Localhost

+ const ScalaNodeBindPort

+ const ScalaNodeGrpsApiPort

+ const ScalaNodeRESTApiPort

+ type Docker struct

+ func NewDocker() (*Docker, error)

+ func (d *Docker) Purge() error

+ func (d *Docker) RunContainers(ctx context.Context, paths config.ConfigPaths) error