cclifecycle

package
v0.0.0-...-7780888 Latest Latest
Warning

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

Go to latest
Published: Dec 18, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// Logger is the logging instance for this package.
	// It's exported because the tests override its backend
	Logger = flogging.MustGetLogger("discovery.lifecycle")
)

Functions

func DeployedChaincodes

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

DeployedChaincodes retrieves the metadata of the given deployed chaincodes

Types

type ChaincodePredicate

type ChaincodePredicate func(cc chaincode.Metadata) bool

ChaincodePredicate accepts or rejects chaincode based on its metadata

var (
	// AcceptAll returns a predicate that accepts all Metadata
	AcceptAll ChaincodePredicate = func(cc chaincode.Metadata) bool {
		return true
	}
)

type EnumerateFunc

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

EnumerateFunc enumerates installed chaincodes

func (EnumerateFunc) Enumerate

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

Enumerate enumerates chaincodes

type Enumerator

type Enumerator interface {
	// Enumerate returns the installed chaincodes
	Enumerate() ([]chaincode.InstalledChaincode, error)
}

Enumerator enumerates chaincodes

type HandleMetadataUpdateFunc

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

HandleMetadataUpdateFunc is triggered upon a change in the chaincode lifecycle

func (HandleMetadataUpdateFunc) HandleMetadataUpdate

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

HandleMetadataUpdate runs whenever there is a change to the metadata of a chaincode in the context of a specific channel

type MetadataChangeListener

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

MetadataChangeListener runs whenever there is a change to the metadata of a chaincode in the context of a specific channel

type MetadataManager

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

MetadataManager manages information about lscc chaincodes.

func NewMetadataManager

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

NewMetadataManager creates a metadata manager for lscc chaincodes.

func (*MetadataManager) AddListener

func (m *MetadataManager) AddListener(listener MetadataChangeListener)

AddListener registers the given listener to be triggered upon a lifecycle change

func (*MetadataManager) Metadata

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

Metadata returns the metadata of the chaincode on the given channel, or nil if not found or an error occurred at retrieving it

func (*MetadataManager) NewChannelSubscription

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

NewChannelSubscription subscribes to a channel

type Query

type Query interface {
	// GetState gets the value for given namespace and key. For a chaincode, the namespace corresponds to the chaincodeId
	GetState(namespace string, key string) ([]byte, error)

	// Done releases resources occupied by the QueryExecutor
	Done()
}

Query queries the state

type QueryCreator

type QueryCreator interface {
	// NewQuery creates a new Query, or error on failure
	NewQuery() (Query, error)
}

QueryCreator creates queries

type QueryCreatorFunc

type QueryCreatorFunc func() (Query, error)

QueryCreatorFunc creates a new query

func (QueryCreatorFunc) NewQuery

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

NewQuery creates a new Query, or error on failure

type Subscription

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

Subscription channels information flow about a specific channel into the Lifecycle.

func (*Subscription) ChaincodeDeployDone

func (sub *Subscription) ChaincodeDeployDone(succeeded bool)

ChaincodeDeployDone gets invoked when the chaincode deploy transaction or chaincode install (the context in which the above function was invoked).

func (*Subscription) HandleChaincodeDeploy

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

HandleChaincodeDeploy is expected to be invoked when a chaincode is deployed via a deploy transaction and the chaincode was already installed on the peer. This also gets invoked when an already deployed chaincode is installed on the peer.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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