runner

Documentation

Index

• func VerifyAllPeersDiscovered(sd *DiscoveryService, expectedPeers []helpers.DiscoveredPeer, channel string, ...) ([]helpers.DiscoveredPeer, bool)
• func VerifyConfigDiscovered(sd *DiscoveryService, expectedConfig discovery.ConfigResult, channel string, ...) bool
• func VerifyEndorsersDiscovered(sd *DiscoveryService, ...) bool
• type Configtxgen
  • func (c *Configtxgen) OutputAnchorPeersUpdate(extraArgs ...string) *ginkgomon.Runner
  • func (c *Configtxgen) OutputBlock(extraArgs ...string) *ginkgomon.Runner
  • func (c *Configtxgen) OutputCreateChannelTx(extraArgs ...string) *ginkgomon.Runner
• type Cryptogen
  • func (c *Cryptogen) Generate(extraArgs ...string) *ginkgomon.Runner
• type DiscoveryService
  • func SetupDiscoveryService(sd *DiscoveryService, org int, configFilePath string, userCert string, ...) *DiscoveryService
  • func (sd *DiscoveryService) DiscoverConfig(channel string, server string, extraArgs ...string) *ginkgomon.Runner
  • func (sd *DiscoveryService) DiscoverEndorsers(channel string, server string, chaincodeName string, collectionName string, ...) *ginkgomon.Runner
  • func (sd *DiscoveryService) DiscoverPeers(channel string, server string, extraArgs ...string) *ginkgomon.Runner
  • func (sd *DiscoveryService) GenerateConfig(userCert string, userKey string, msp string, extraArgs ...string) *ginkgomon.Runner
• type Orderer
  • func (o *Orderer) New() *ginkgomon.Runner
• type Peer
  • func (p *Peer) ChaincodeListInstalled() *ginkgomon.Runner
  • func (p *Peer) ChaincodeListInstantiated(channel string) *ginkgomon.Runner
  • func (p *Peer) CreateChannel(channel string, filename string, orderer string) *ginkgomon.Runner
  • func (p *Peer) FetchChannel(channel string, filename string, block string, orderer string) *ginkgomon.Runner
  • func (p *Peer) GetChannelInfo(channel string) *ginkgomon.Runner
  • func (p *Peer) InstallChaincode(name, version, path string)
  • func (p *Peer) InstantiateChaincode(name, version, orderer, channel, args, policy string, ...)
  • func (p *Peer) InvokeChaincode(name string, channel string, args string, orderer string, extraArgs ...string) *ginkgomon.Runner
  • func (p *Peer) JoinChannel(transactionFile string) *ginkgomon.Runner
  • func (p *Peer) NodeStart(index int) *ginkgomon.Runner
  • func (p *Peer) QueryChaincode(name string, channel string, args string) *ginkgomon.Runner
  • func (p *Peer) SetLogLevel(moduleRegExp string, level string) *ginkgomon.Runner
  • func (p *Peer) SignConfigTx(transactionFile string) *ginkgomon.Runner
  • func (p *Peer) UpdateChannel(transactionFile string, channel string, orderer string) *ginkgomon.Runner
  • func (p *Peer) UpgradeChaincode(name string, version string, orderer string, channel string, args string, ...)
  • func (p *Peer) VerifyChaincodeIsInstantiated(chaincodeName string, version string, channel string, timeout time.Duration)

Functions

func VerifyAllPeersDiscovered

func VerifyAllPeersDiscovered(sd *DiscoveryService, expectedPeers []helpers.DiscoveredPeer, channel string, server string) ([]helpers.DiscoveredPeer, bool)

func VerifyConfigDiscovered

func VerifyConfigDiscovered(sd *DiscoveryService, expectedConfig discovery.ConfigResult, channel string, server string) bool

func VerifyEndorsersDiscovered

func VerifyEndorsersDiscovered(sd *DiscoveryService, expectedEndorsementDescriptor helpers.EndorsementDescriptor, channel string, server string, chaincodeName string, collectionName string) bool

Types

type Configtxgen

type Configtxgen struct {
	// The location of the configtxgen executable
	Path string
	// The channel ID
	ChannelID string
	// The profile used for the channel
	Profile string
	// The organization for this config channel
	AsOrg string
	// The fabric config directory
	ConfigDir string
	// The fabric config directory set in the env variable
	EnvConfigDir string
	// The directory to write the block file
	Output string
}

Configtxgen creates runners that call cryptogen functions.

func (*Configtxgen) OutputAnchorPeersUpdate

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

func (*Configtxgen) OutputBlock

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

OutputBlock uses configtxgen to generate genesis block for fabric.

func (*Configtxgen) OutputCreateChannelTx

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

type Cryptogen

type Cryptogen struct {
	// The location of the cryptogen executable
	Path string
	// The location of the config file
	Config string
	// The output directory
	Output string
}

Cryptogen creates runners that call cryptogen functions.

func (*Cryptogen) Generate

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

Generate uses cryptogen to generate cryptographic material for fabric.

type DiscoveryService

type DiscoveryService struct {
	// The location of the discovery service executable
	Path string
	// Path to the config file that will be generated in GenerateConfig function and will be used later in all other functions
	ConfigFilePath string
	// Log level that will be used in discovery service executable
	LogLevel string
}

DiscoveryService wraps sd cli and enables discovering peers, config and endorsement descriptors

func SetupDiscoveryService

func SetupDiscoveryService(sd *DiscoveryService, org int, configFilePath string, userCert string, userKeyDir string) *DiscoveryService

func (*DiscoveryService) DiscoverConfig

func (sd *DiscoveryService) DiscoverConfig(channel string, server string, extraArgs ...string) *ginkgomon.Runner

func (*DiscoveryService) DiscoverEndorsers

func (sd *DiscoveryService) DiscoverEndorsers(channel string, server string, chaincodeName string, collectionName string, extraArgs ...string) *ginkgomon.Runner

func (*DiscoveryService) DiscoverPeers

func (sd *DiscoveryService) DiscoverPeers(channel string, server string, extraArgs ...string) *ginkgomon.Runner

func (*DiscoveryService) GenerateConfig

func (sd *DiscoveryService) GenerateConfig(userCert string, userKey string, msp string, extraArgs ...string) *ginkgomon.Runner

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, collectionsConfigPath 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

func (*Peer) UpgradeChaincode

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

func (*Peer) VerifyChaincodeIsInstantiated

func (p *Peer) VerifyChaincodeIsInstantiated(chaincodeName string, version string, channel string, timeout time.Duration)