fabric: github.com/hyperledger/fabric/integration/runner Index | Files

package runner

import "github.com/hyperledger/fabric/integration/runner"

Index

Package Files

couchdb.go defaults.go kafka.go zookeeper.go

Constants

const CouchDBDefaultImage = "hyperledger/fabric-couchdb:latest"
const DefaultStartTimeout = 30 * time.Second
const KafkaDefaultImage = "hyperledger/fabric-kafka:latest"
const ZooKeeperDefaultImage = "hyperledger/fabric-zookeeper:latest"

type CouchDB Uses

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
}

CouchDB manages the execution of an instance of a dockerized CounchDB for tests.

func (*CouchDB) Address Uses

func (c *CouchDB) Address() string

Address returns the address successfully used by the readiness check.

func (*CouchDB) ContainerAddress Uses

func (c *CouchDB) ContainerAddress() string

ContainerAddress returns the container address where this CouchDB instance is available.

func (*CouchDB) ContainerID Uses

func (c *CouchDB) ContainerID() string

ContainerID returns the container ID of this CouchDB

func (*CouchDB) HostAddress Uses

func (c *CouchDB) HostAddress() string

HostAddress returns the host address where this CouchDB instance is available.

func (*CouchDB) Run Uses

func (c *CouchDB) Run(sigCh <-chan os.Signal, ready chan<- struct{}) error

Run runs a CouchDB container. It implements the ifrit.Runner interface

func (*CouchDB) Start Uses

func (c *CouchDB) Start() error

Start starts the CouchDB container using an ifrit runner

func (*CouchDB) Stop Uses

func (c *CouchDB) Stop() error

Stop stops and removes the CouchDB container

type Kafka Uses

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 Uses

func (k *Kafka) Run(sigCh <-chan os.Signal, ready chan<- struct{}) error

Run runs a Kafka container. It implements the ifrit.Runner interface

func (*Kafka) Start Uses

func (k *Kafka) Start() error

Start starts the Kafka container using an ifrit runner

func (*Kafka) Stop Uses

func (k *Kafka) Stop() error

Stop stops and removes the Kafka container

type NameFunc Uses

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 Uses

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) ContainerAddress Uses

func (z *ZooKeeper) ContainerAddress() string

func (*ZooKeeper) ContainerID Uses

func (z *ZooKeeper) ContainerID() string

func (*ZooKeeper) Run Uses

func (z *ZooKeeper) Run(sigCh <-chan os.Signal, ready chan<- struct{}) error

func (*ZooKeeper) Start Uses

func (z *ZooKeeper) Start() error

func (*ZooKeeper) Stop Uses

func (z *ZooKeeper) Stop() error

Package runner imports 13 packages (graph) and is imported by 2 packages. Updated 2018-12-12. Refresh now. Tools for package owners.