runner

package
v0.0.0-...-95b87ed Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 16, 2019 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source
const CouchDBDefaultImage = "couchdb:2.3"
View Source
const DefaultStartTimeout = 45 * time.Second
View Source
const KafkaDefaultImage = "mcc-github/blockchain-kafka:latest"
View Source
const ZooKeeperDefaultImage = "mcc-github/blockchain-zookeeper:latest"

Variables

This section is empty.

Functions

This section is empty.

Types

type Configtxgen

type Configtxgen struct {
	Path string

	ChannelID string

	Profile string

	AsOrg string

	ConfigDir string

	EnvConfigDir string

	Output string
}

func (*Configtxgen) OutputAnchorPeersUpdate

func (c *Configtxgen) OutputAnchorPeersUpdate(extraArgs ...string) *ginkgomon.Runner

func (*Configtxgen) OutputBlock

func (c *Configtxgen) OutputBlock(extraArgs ...string) *ginkgomon.Runner

func (*Configtxgen) OutputCreateChannelTx

func (c *Configtxgen) OutputCreateChannelTx(extraArgs ...string) *ginkgomon.Runner

type CouchDB

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 (*CouchDB) Address

func (c *CouchDB) Address() string

func (*CouchDB) ContainerAddress

func (c *CouchDB) ContainerAddress() string

func (*CouchDB) ContainerID

func (c *CouchDB) ContainerID() string

func (*CouchDB) HostAddress

func (c *CouchDB) HostAddress() string

func (*CouchDB) Run

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

func (*CouchDB) Start

func (c *CouchDB) Start() error

func (*CouchDB) Stop

func (c *CouchDB) Stop() error

type Cryptogen

type Cryptogen struct {
	Path string

	Config string

	Output string
}

func (*Cryptogen) Generate

func (c *Cryptogen) Generate(extraArgs ...string) *ginkgomon.Runner

type Idemixgen

type Idemixgen struct {
	Path string

	Output string

	EnrollID string

	OrgUnit string

	IsAdmin bool

	RevocationHandle int
}

func (*Idemixgen) CAKeyGen

func (c *Idemixgen) CAKeyGen(extraArgs ...string) *ginkgomon.Runner

func (*Idemixgen) SignerConfig

func (c *Idemixgen) SignerConfig(extraArgs ...string) *ginkgomon.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
}

func (*Kafka) Run

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

func (*Kafka) Start

func (k *Kafka) Start() error

func (*Kafka) Stop

func (k *Kafka) Stop() error

type NameFunc

type NameFunc func() string
var DefaultNamer NameFunc = helpers.UniqueName

type Orderer

type Orderer struct {
	Path                        string
	ConfigDir                   string
	LedgerLocation              string
	ConfigtxOrdererKafkaBrokers string
	LogLevel                    string
}

func (*Orderer) New

func (o *Orderer) New() *ginkgomon.Runner

type Peer

type Peer struct {
	Path          string
	GoPath        string
	ExecPath      string
	ConfigDir     string
	MSPConfigPath string
	LogLevel      string
}

func (*Peer) ChaincodeListInstalled

func (p *Peer) ChaincodeListInstalled() *ginkgomon.Runner

func (*Peer) ChaincodeListInstantiated

func (p *Peer) ChaincodeListInstantiated(channel string) *ginkgomon.Runner

func (*Peer) CreateChannel

func (p *Peer) CreateChannel(channel string, filename string, orderer string) *ginkgomon.Runner

func (*Peer) FetchChannel

func (p *Peer) FetchChannel(channel string, filename string, block string, orderer string) *ginkgomon.Runner

func (*Peer) GetChannelInfo

func (p *Peer) GetChannelInfo(channel string) *ginkgomon.Runner

func (*Peer) InstallChaincode

func (p *Peer) InstallChaincode(name, version, path string)

func (*Peer) InstantiateChaincode

func (p *Peer) InstantiateChaincode(name, version, orderer, channel, args, policy string)

func (*Peer) InvokeChaincode

func (p *Peer) InvokeChaincode(name string, channel string, args string, orderer string, extraArgs ...string) *ginkgomon.Runner

func (*Peer) JoinChannel

func (p *Peer) JoinChannel(transactionFile string) *ginkgomon.Runner

func (*Peer) NodeStart

func (p *Peer) NodeStart(index int) *ginkgomon.Runner

func (*Peer) QueryChaincode

func (p *Peer) QueryChaincode(name string, channel string, args string) *ginkgomon.Runner

func (*Peer) SetLogLevel

func (p *Peer) SetLogLevel(moduleRegExp string, level string) *ginkgomon.Runner

func (*Peer) SignConfigTx

func (p *Peer) SignConfigTx(transactionFile string) *ginkgomon.Runner

func (*Peer) UpdateChannel

func (p *Peer) UpdateChannel(transactionFile string, channel string, orderer string) *ginkgomon.Runner

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

func (z *ZooKeeper) ContainerAddress() string

func (*ZooKeeper) ContainerID

func (z *ZooKeeper) ContainerID() string

func (*ZooKeeper) Run

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

func (*ZooKeeper) Start

func (z *ZooKeeper) Start() error

func (*ZooKeeper) Stop

func (z *ZooKeeper) Stop() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL