const CouchDBDefaultImage = "hyperledger/fabric-couchdb:latest"
const DefaultStartTimeout = 30 * time.Second
const KafkaDefaultImage = "hyperledger/fabric-kafka:latest"
const ZooKeeperDefaultImage = "hyperledger/fabric-zookeeper:latest"
CouchDB manages the execution of an instance of a dockerized CounchDB for tests.
type CouchDB struct {
Client *docker.Client
Image string
HostIP string
HostPort int
ContainerPort docker.Port
Name string
StartTimeout time.Duration
ErrorStream io.Writer
OutputStream io.Writer
// contains filtered or unexported fields
}
func (c *CouchDB) Address() string
Address returns the address successfully used by the readiness check.
func (c *CouchDB) ContainerAddress() string
ContainerAddress returns the container address where this CouchDB instance is available.
func (c *CouchDB) ContainerID() string
ContainerID returns the container ID of this CouchDB
func (c *CouchDB) HostAddress() string
HostAddress returns the host address where this CouchDB instance is available.
func (c *CouchDB) Run(sigCh <-chan os.Signal, ready chan<- struct{}) error
Run runs a CouchDB container. It implements the ifrit.Runner interface
func (c *CouchDB) Start() error
Start starts the CouchDB container using an ifrit runner
func (c *CouchDB) Stop() error
Stop stops and removes the CouchDB container
Kafka manages the execution of an instance of a dockerized CouchDB for tests.
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
}
func (k *Kafka) Run(sigCh <-chan os.Signal, ready chan<- struct{}) error
Run runs a Kafka container. It implements the ifrit.Runner interface
func (k *Kafka) Start() error
Start starts the Kafka container using an ifrit runner
func (k *Kafka) Stop() error
Stop stops and removes the Kafka container
A NameFunc is used to generate container names.
type NameFunc func() string
DefaultNamer is the default naming function.
var DefaultNamer NameFunc = helpers.UniqueName
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 (z *ZooKeeper) ContainerAddress() string
func (z *ZooKeeper) ContainerID() string
func (z *ZooKeeper) Run(sigCh <-chan os.Signal, ready chan<- struct{}) error
func (z *ZooKeeper) Start() error
func (z *ZooKeeper) Stop() error