cclifecycle

Documentation

Index

• Variables
• func DeployedChaincodes(q Query, filter ChaincodePredicate, loadCollections bool, chaincodes ...string) (chaincode.MetadataSet, error)
• type ChaincodePredicate
• type EnumerateFunc
  • func (enumerate EnumerateFunc) Enumerate() ([]chaincode.InstalledChaincode, error)
• type Enumerator
• type HandleMetadataUpdateFunc
  • func (handleMetadataUpdate HandleMetadataUpdateFunc) HandleMetadataUpdate(channel string, chaincodes chaincode.MetadataSet)
• type MetadataChangeListener
• type MetadataManager
  • func NewMetadataManager(installedChaincodes Enumerator) (*MetadataManager, error)
  • func (m *MetadataManager) AddListener(listener MetadataChangeListener)
  • func (m *MetadataManager) Metadata(channel string, cc string, collections bool) *chaincode.Metadata
  • func (m *MetadataManager) NewChannelSubscription(channel string, queryCreator QueryCreator) (*Subscription, error)
• type Query
• type QueryCreator
• type QueryCreatorFunc
  • func (queryCreator QueryCreatorFunc) NewQuery() (Query, error)
• type Subscription
  • func (sub *Subscription) ChaincodeDeployDone(succeeded bool)
  • func (sub *Subscription) HandleChaincodeDeploy(chaincodeDefinition *cceventmgmt.ChaincodeDefinition, dbArtifactsTar []byte) error

Variables

var (
	Logger = flogging.MustGetLogger("discovery.lifecycle")
)

Functions

func DeployedChaincodes

func DeployedChaincodes(q Query, filter ChaincodePredicate, loadCollections bool, chaincodes ...string) (chaincode.MetadataSet, error)

Types

type ChaincodePredicate

type ChaincodePredicate func(cc chaincode.Metadata) bool

var (
	AcceptAll ChaincodePredicate = func(cc chaincode.Metadata) bool {
		return true
	}
)

type EnumerateFunc

type EnumerateFunc func() ([]chaincode.InstalledChaincode, error)

func (EnumerateFunc) Enumerate

func (enumerate EnumerateFunc) Enumerate() ([]chaincode.InstalledChaincode, error)

type Enumerator

type Enumerator interface {
	Enumerate() ([]chaincode.InstalledChaincode, error)
}

type HandleMetadataUpdateFunc

type HandleMetadataUpdateFunc func(channel string, chaincodes chaincode.MetadataSet)

func (HandleMetadataUpdateFunc) HandleMetadataUpdate

func (handleMetadataUpdate HandleMetadataUpdateFunc) HandleMetadataUpdate(channel string, chaincodes chaincode.MetadataSet)

type MetadataChangeListener

type MetadataChangeListener interface {
	HandleMetadataUpdate(channel string, chaincodes chaincode.MetadataSet)
}

type MetadataManager

type MetadataManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewMetadataManager

func NewMetadataManager(installedChaincodes Enumerator) (*MetadataManager, error)

func (*MetadataManager) AddListener

func (m *MetadataManager) AddListener(listener MetadataChangeListener)

func (*MetadataManager) Metadata

func (m *MetadataManager) Metadata(channel string, cc string, collections bool) *chaincode.Metadata

func (*MetadataManager) NewChannelSubscription

func (m *MetadataManager) NewChannelSubscription(channel string, queryCreator QueryCreator) (*Subscription, error)

type Query

type Query interface {
	GetState(namespace string, key string) ([]byte, error)

	Done()
}

type QueryCreator

type QueryCreator interface {
	NewQuery() (Query, error)
}

type QueryCreatorFunc

type QueryCreatorFunc func() (Query, error)

func (QueryCreatorFunc) NewQuery

func (queryCreator QueryCreatorFunc) NewQuery() (Query, error)

type Subscription

type Subscription struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Subscription) ChaincodeDeployDone

func (sub *Subscription) ChaincodeDeployDone(succeeded bool)

func (*Subscription) HandleChaincodeDeploy

func (sub *Subscription) HandleChaincodeDeploy(chaincodeDefinition *cceventmgmt.ChaincodeDefinition, dbArtifactsTar []byte) error