Documentation
¶
Index ¶
Constants ¶
const CouchDBDefaultImage = "couchdb:2.3"
const KafkaDefaultImage = "confluentinc/cp-kafka:5.3.1"
const ZooKeeperDefaultImage = "confluentinc/cp-zookeeper:5.3.1"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CouchDB ¶
type CouchDB struct {
Client *docker.Client
Image string
HostIP string
HostPort int
ContainerPort docker.Port
Name string
StartTimeout time.Duration
Binds []string
ErrorStream io.Writer
OutputStream io.Writer
// contains filtered or unexported fields
}
CouchDB manages the execution of an instance of a dockerized CounchDB for tests.
func (*CouchDB) Address ¶
Address returns the address successfully used by the readiness check.
func (*CouchDB) ContainerAddress ¶
ContainerAddress returns the container address where this CouchDB instance is available.
func (*CouchDB) ContainerID ¶
ContainerID returns the container ID of this CouchDB
func (*CouchDB) HostAddress ¶
HostAddress returns the host address where this CouchDB instance is available.
func (*CouchDB) Run ¶
Run runs a CouchDB container. It implements the ifrit.Runner interface
func (*CouchDB) Start ¶
Start starts the CouchDB container using an ifrit runner
type Kafka ¶
type Kafka struct {
Client *docker.Client
Image string
HostIP string
HostPort int
ContainerPort docker.Port
Name string
NetworkName string
StartTimeout time.Duration
MessageMaxBytes int
ReplicaFetchMaxBytes int
UncleanLeaderElectionEnable bool
DefaultReplicationFactor int
MinInsyncReplicas int
BrokerID int
ZooKeeperConnect string
ReplicaFetchResponseMaxBytes int
AdvertisedListeners string
ErrorStream io.Writer
OutputStream io.Writer
ContainerID string
HostAddress string
ContainerAddress string
Address string
// contains filtered or unexported fields
}
Kafka manages the execution of an instance of a dockerized CouchDB for tests.
func (*Kafka) Run ¶
Run runs a Kafka container. It implements the ifrit.Runner interface
func (*Kafka) Start ¶
Start starts the Kafka container using an ifrit runner
type NameFunc ¶
type NameFunc func() string
A NameFunc is used to generate container names.
var DefaultNamer NameFunc = helpers.UniqueName
DefaultNamer is the default naming function.
type ZooKeeper ¶
type ZooKeeper struct {
Client *docker.Client
Image string
HostIP string
HostPort []int
ContainerPorts []docker.Port
Name string
StartTimeout time.Duration
NetworkName string
ClientPort docker.Port
LeaderPort docker.Port
PeerPort docker.Port
ZooMyID int
ZooServers string
ErrorStream io.Writer
OutputStream io.Writer
// contains filtered or unexported fields
}
func (*ZooKeeper) Run ¶
Source Files
¶
- couchdb.go
- defaults.go
- kafka.go
- zookeeper.go