chaincode

Jul 17, 2019

Changes in this version

type Handler

+ func (h *Handler) HandleGetPrivateDataHash(msg *pb.ChaincodeMessage, txContext *TransactionContext) (*pb.ChaincodeMessage, error)

Apr 11, 2019

Changes in this version

type ContainerRuntime

+ func (c *ContainerRuntime) Wait(ccci *ccprovider.ChaincodeContainerInfo) (int, error)

type Runtime

+ Wait func(ccci *ccprovider.ChaincodeContainerInfo) (int, error)

Jan 9, 2019

Changes in this version

type ChaincodeSupport

+ HandlerMetrics *HandlerMetrics

+ LaunchMetrics *LaunchMetrics

type Handler

+ Metrics *HandlerMetrics

+ type HandlerMetrics struct

+ ExecuteTimeouts metrics.Counter

+ ShimRequestDuration metrics.Histogram

+ ShimRequestsCompleted metrics.Counter

+ ShimRequestsReceived metrics.Counter

+ func NewHandlerMetrics(p metrics.Provider) *HandlerMetrics

+ type LaunchMetrics struct

+ LaunchDuration metrics.Histogram

+ LaunchFailures metrics.Counter

+ LaunchTimeouts metrics.Counter

+ func NewLaunchMetrics(p metrics.Provider) *LaunchMetrics

type RuntimeLauncher

+ Metrics *LaunchMetrics

type TransactionContext

+ AllowedCollectionAccess map[string]bool

+ CollectionStore privdata.CollectionStore

+ IsInitTransaction bool

Oct 10, 2018

Changes in this version

+ type ApplicationConfigRetriever interface

+ GetApplicationConfig func(cid string) (channelconfig.Application, bool)

type CCProviderImpl

+ func (c *CCProviderImpl) ExecuteLegacyInit(txParams *ccprovider.TransactionParams, cccid *ccprovider.CCContext, ...) (*pb.Response, *pb.ChaincodeEvent, error)

type ChaincodeDefinitionGetter

+ ChaincodeDefinition func(chaincodeName string, txSim ledger.QueryExecutor) (ccprovider.ChaincodeDefinition, error)

type ChaincodeSupport

+ Lifecycle Lifecycle

+ SystemCCProvider sysccprovider.SystemChaincodeProvider

+ func (cs *ChaincodeSupport) ExecuteLegacyInit(txParams *ccprovider.TransactionParams, cccid *ccprovider.CCContext, ...) (*pb.Response, *pb.ChaincodeEvent, error)

+ func (cs *ChaincodeSupport) InvokeInit(txParams *ccprovider.TransactionParams, cccid *ccprovider.CCContext, ...) (*pb.ChaincodeMessage, error)

+ func (cs *ChaincodeSupport) LaunchInit(ccci *ccprovider.ChaincodeContainerInfo) error

type ContainerRuntime

+ PlatformRegistry *platforms.Registry

type Handler

+ AppConfig ApplicationConfigRetriever

+ func (h *Handler) HandleGetStateMetadata(msg *pb.ChaincodeMessage, txContext *TransactionContext) (*pb.ChaincodeMessage, error)

+ func (h *Handler) HandlePutStateMetadata(msg *pb.ChaincodeMessage, txContext *TransactionContext) (*pb.ChaincodeMessage, error)

type Lifecycle

+ ChaincodeContainerInfo func(chainID string, chaincodeID string) (*ccprovider.ChaincodeContainerInfo, error)

+ ChaincodeDefinition func(chaincodeName string, txSim ledger.QueryExecutor) (ccprovider.ChaincodeDefinition, error)

type PackageProvider

+ GetChaincodeCodePackage func(ccname string, ccversion string) ([]byte, error)

type TransactionContext

+ func (t *TransactionContext) CleanupQueryContextWithBookmark(queryID string) string

+ func (t *TransactionContext) GetTotalReturnCount(queryID string) *int32

Jul 3, 2018

Changes in this version

+ func NewTxKey(channelID, txID string) string

+ func ParseName(ccName string) *sysccprovider.ChaincodeInstance

+ type ACLProvider interface

+ CheckACL func(resName string, channelID string, idinfo interface{}) error

+ type ActiveTransactions struct

+ func NewActiveTransactions() *ActiveTransactions

+ func (a *ActiveTransactions) Add(channelID, txID string) bool

+ func (a *ActiveTransactions) Remove(channelID, txID string)

+ type CCProviderImpl struct

+ func NewProvider(cs *ChaincodeSupport) *CCProviderImpl

+ func (c *CCProviderImpl) Execute(ctxt context.Context, cccid *ccprovider.CCContext, ...) (*pb.Response, *pb.ChaincodeEvent, error)

+ func (c *CCProviderImpl) ExecuteChaincode(ctxt context.Context, cccid *ccprovider.CCContext, args [][]byte) (*pb.Response, *pb.ChaincodeEvent, error)

+ func (c *CCProviderImpl) GetContext(ledger ledger.PeerLedger, txid string) (context.Context, ledger.TxSimulator, error)

+ func (c *CCProviderImpl) Stop(ctxt context.Context, cccid *ccprovider.CCContext, ...) error

+ type CertGenerator interface

+ Generate func(ccName string) (*accesscontrol.CertAndPrivKeyPair, error)

+ type ChaincodeDefinitionGetter interface

+ GetChaincodeDefinition func(ctxt context.Context, txid string, signedProp *pb.SignedProposal, ...) (ccprovider.ChaincodeDefinition, error)

type ChaincodeSupport

+ ACLProvider ACLProvider

+ ExecuteTimeout time.Duration

+ HandlerRegistry *HandlerRegistry

+ Keepalive time.Duration

+ Launcher Launcher

+ Runtime Runtime

+ UserRunsCC bool

+ func (cs *ChaincodeSupport) Invoke(ctxt context.Context, cccid *ccprovider.CCContext, ...) (*pb.ChaincodeMessage, error)

+ type CheckInstantiationPolicyFunc func(name, version string, cd *ccprovider.ChaincodeData) error

+ func (c CheckInstantiationPolicyFunc) CheckInstantiationPolicy(name, version string, cd *ccprovider.ChaincodeData) error

+ type Config struct

+ ExecuteTimeout time.Duration

+ Keepalive time.Duration

+ LogFormat string

+ LogLevel string

+ ShimLogLevel string

+ StartupTimeout time.Duration

+ TLSEnabled bool

+ func GlobalConfig() *Config

+ type ContainerRuntime struct

+ CACert []byte

+ CertGenerator CertGenerator

+ CommonEnv []string

+ PeerAddress string

+ Processor Processor

+ func (c *ContainerRuntime) LaunchConfig(cname string, ccType pb.ChaincodeSpec_Type) (*LaunchConfig, error)

+ func (c *ContainerRuntime) Start(ctxt context.Context, cccid *ccprovider.CCContext, ...) error

+ func (c *ContainerRuntime) Stop(ctxt context.Context, cccid *ccprovider.CCContext, ...) error

+ type ContextRegistry interface

+ Close func()

+ Create func(ctx context.Context, chainID, txID string, signedProp *pb.SignedProposal, ...) (*TransactionContext, error)

+ Delete func(chainID, txID string)

+ Get func(chainID, txID string) *TransactionContext

+ type Executor interface

+ Execute func(ctxt context.Context, cccid *ccprovider.CCContext, ...) (*pb.Response, *pb.ChaincodeEvent, error)

type Handler

+ ACLProvider ACLProvider

+ ActiveTransactions TransactionRegistry

+ DefinitionGetter ChaincodeDefinitionGetter

+ InstantiationPolicyChecker InstantiationPolicyChecker

+ Invoker Invoker

+ Keepalive time.Duration

+ LedgerGetter LedgerGetter

+ QueryResponseBuilder QueryResponseBuilder

+ Registry Registry

+ SystemCCProvider SystemCCProvider

+ SystemCCVersion string

+ TXContexts ContextRegistry

+ UUIDGenerator UUIDGenerator

+ func (h *Handler) ChaincodeName() string

+ func (h *Handler) Close()

+ func (h *Handler) Execute(ctxt context.Context, cccid *ccprovider.CCContext, msg *pb.ChaincodeMessage, ...) (*pb.ChaincodeMessage, error)

+ func (h *Handler) HandleDelState(msg *pb.ChaincodeMessage, txContext *TransactionContext) (*pb.ChaincodeMessage, error)

+ func (h *Handler) HandleGetHistoryForKey(msg *pb.ChaincodeMessage, txContext *TransactionContext) (*pb.ChaincodeMessage, error)

+ func (h *Handler) HandleGetQueryResult(msg *pb.ChaincodeMessage, txContext *TransactionContext) (*pb.ChaincodeMessage, error)

+ func (h *Handler) HandleGetState(msg *pb.ChaincodeMessage, txContext *TransactionContext) (*pb.ChaincodeMessage, error)

+ func (h *Handler) HandleGetStateByRange(msg *pb.ChaincodeMessage, txContext *TransactionContext) (*pb.ChaincodeMessage, error)

+ func (h *Handler) HandleInvokeChaincode(msg *pb.ChaincodeMessage, txContext *TransactionContext) (*pb.ChaincodeMessage, error)

+ func (h *Handler) HandlePutState(msg *pb.ChaincodeMessage, txContext *TransactionContext) (*pb.ChaincodeMessage, error)

+ func (h *Handler) HandleQueryStateClose(msg *pb.ChaincodeMessage, txContext *TransactionContext) (*pb.ChaincodeMessage, error)

+ func (h *Handler) HandleQueryStateNext(msg *pb.ChaincodeMessage, txContext *TransactionContext) (*pb.ChaincodeMessage, error)

+ func (h *Handler) HandleRegister(msg *pb.ChaincodeMessage)

+ func (h *Handler) HandleTransaction(msg *pb.ChaincodeMessage, delegate handleFunc)

+ func (h *Handler) Notify(msg *pb.ChaincodeMessage)

+ func (h *Handler) ProcessStream(stream ccintf.ChaincodeStream) error

+ func (h *Handler) State() State

+ type HandlerRegistry struct

+ func NewHandlerRegistry(allowUnsolicitedRegistration bool) *HandlerRegistry

+ func (r *HandlerRegistry) Deregister(cname string) error

+ func (r *HandlerRegistry) Failed(cname string, err error)

+ func (r *HandlerRegistry) Handler(cname string) *Handler

+ func (r *HandlerRegistry) HasLaunched(chaincode string) bool

+ func (r *HandlerRegistry) Launching(cname string) (*LaunchState, error)

+ func (r *HandlerRegistry) Ready(cname string)

+ func (r *HandlerRegistry) Register(h *Handler) error

+ type InstantiationPolicyChecker interface

+ CheckInstantiationPolicy func(name, version string, cd *ccprovider.ChaincodeData) error

+ type Invoker interface

+ Invoke func(ctxt context.Context, cccid *ccprovider.CCContext, ...) (*pb.ChaincodeMessage, error)

+ type LaunchConfig struct

+ Args []string

+ Envs []string

+ Files map[string][]byte

+ func (lc *LaunchConfig) String() string

+ type LaunchRegistry interface

+ Deregister func(cname string) error

+ Launching func(cname string) (*LaunchState, error)

+ type LaunchState struct

+ func NewLaunchState() *LaunchState

+ func (l *LaunchState) Done() <-chan struct{}

+ func (l *LaunchState) Err() error

+ func (l *LaunchState) Notify(err error)

+ type Launcher interface

+ Launch func(context context.Context, cccid *ccprovider.CCContext, ...) error

+ type LedgerGetter interface

+ GetLedger func(cid string) ledger.PeerLedger

+ type Lifecycle struct

+ Executor Executor

+ func (l *Lifecycle) GetChaincodeDefinition(ctx context.Context, txid string, signedProp *pb.SignedProposal, ...) (ccprovider.ChaincodeDefinition, error)

+ func (l *Lifecycle) GetChaincodeDeploymentSpec(ctx context.Context, txid string, signedProp *pb.SignedProposal, ...) (*pb.ChaincodeDeploymentSpec, error)

type MessageHandler

+ Handle func(*pb.ChaincodeMessage, *TransactionContext) (*pb.ChaincodeMessage, error)

+ type PackageProvider interface

+ GetChaincode func(ccname string, ccversion string) (ccprovider.CCPackage, error)

+ type PendingQueryResult struct

+ func (p *PendingQueryResult) Add(queryResult commonledger.QueryResult) error

+ func (p *PendingQueryResult) Cut() []*pb.QueryResultBytes

+ func (p *PendingQueryResult) Size() int

+ type Processor interface

+ Process func(ctxt context.Context, vmtype string, req container.VMCReq) error

+ type QueryResponseBuilder interface

+ BuildQueryResponse func(txContext *TransactionContext, iter commonledger.ResultsIterator, ...) (*pb.QueryResponse, error)

+ type QueryResponseGenerator struct

+ MaxResultLimit int

+ func (q *QueryResponseGenerator) BuildQueryResponse(txContext *TransactionContext, iter commonledger.ResultsIterator, ...) (*pb.QueryResponse, error)

+ type Registry interface

+ Deregister func(cname string) error

+ Failed func(cname string, err error)

+ Ready func(cname string)

+ Register func(*Handler) error

+ type Runtime interface

+ Start func(ctxt context.Context, cccid *ccprovider.CCContext, ...) error

+ Stop func(ctxt context.Context, cccid *ccprovider.CCContext, ...) error

+ type RuntimeLauncher struct

+ Lifecycle *Lifecycle

+ PackageProvider PackageProvider

+ Registry LaunchRegistry

+ Runtime Runtime

+ StartupTimeout time.Duration

+ func (r *RuntimeLauncher) Launch(ctx context.Context, cccid *ccprovider.CCContext, ...) error

+ type State int

+ const Created

+ const Established

+ const Ready

+ func (s State) String() string

+ type SystemCCProvider interface

+ IsSysCC func(name string) bool

+ IsSysCCAndNotInvokableCC2CC func(name string) bool

+ type TransactionContext struct

+ ChainID string

+ HistoryQueryExecutor ledger.HistoryQueryExecutor

+ Proposal *pb.Proposal

+ ResponseNotifier chan *pb.ChaincodeMessage

+ SignedProp *pb.SignedProposal

+ TXSimulator ledger.TxSimulator

+ func (t *TransactionContext) CleanupQueryContext(queryID string)

+ func (t *TransactionContext) CloseQueryIterators()

+ func (t *TransactionContext) GetPendingQueryResult(queryID string) *PendingQueryResult

+ func (t *TransactionContext) GetQueryIterator(queryID string) commonledger.ResultsIterator

+ func (t *TransactionContext) InitializeQueryContext(queryID string, iter commonledger.ResultsIterator)

+ type TransactionContexts struct

+ func NewTransactionContexts() *TransactionContexts

+ func (c *TransactionContexts) Close()

+ func (c *TransactionContexts) Create(ctx context.Context, chainID, txID string, signedProp *pb.SignedProposal, ...) (*TransactionContext, error)

+ func (c *TransactionContexts) Delete(chainID, txID string)

+ func (c *TransactionContexts) Get(chainID, txID string) *TransactionContext

+ type TransactionRegistry interface

+ Add func(channelID, txID string) bool

+ Remove func(channelID, txID string)

+ type UUIDGenerator interface

+ New func() string

+ type UUIDGeneratorFunc func() string

+ func (u UUIDGeneratorFunc) New() string

Mar 15, 2018

Changes in this version

+ const TLSClientCertPath

+ const TLSClientKeyPath

+ const TLSClientRootCertPath

+ func GetCDS(ctxt context.Context, txid string, signedProp *pb.SignedProposal, ...) ([]byte, error)

+ func GetChaincodeDefinition(ctxt context.Context, txid string, signedProp *pb.SignedProposal, ...) (resourcesconfig.ChaincodeDefinition, error)

Jul 11, 2017

Changes in this version

+ const DevModeUserRunsChaincode

+ const HistoryQueryExecutorKey

+ const TXSimulatorKey

+ func Execute(ctxt context.Context, cccid *ccprovider.CCContext, spec interface{}) (*pb.Response, *pb.ChaincodeEvent, error)

+ func ExecuteChaincode(ctxt context.Context, cccid *ccprovider.CCContext, args [][]byte) (*pb.Response, *pb.ChaincodeEvent, error)

+ func ExecuteWithErrorFilter(ctxt context.Context, cccid *ccprovider.CCContext, spec interface{}) ([]byte, *pb.ChaincodeEvent, error)

+ func GetCDSFromLSCC(ctxt context.Context, txid string, signedProp *pb.SignedProposal, ...) ([]byte, error)

+ func GetChaincodeDataFromLSCC(ctxt context.Context, txid string, signedProp *pb.SignedProposal, ...) (*ccprovider.ChaincodeData, error)

+ func HandleChaincodeStream(chaincodeSupport *ChaincodeSupport, ctxt context.Context, ...) error

+ func IsDevMode() bool

+ type ChaincodeSupport struct

+ func GetChain() *ChaincodeSupport

+ func NewChaincodeSupport(getCCEndpoint func() (*pb.PeerEndpoint, error), userrunsCC bool, ...) *ChaincodeSupport

+ func (chaincodeSupport *ChaincodeSupport) Execute(ctxt context.Context, cccid *ccprovider.CCContext, msg *pb.ChaincodeMessage, ...) (*pb.ChaincodeMessage, error)

+ func (chaincodeSupport *ChaincodeSupport) HandleChaincodeStream(ctxt context.Context, stream ccintf.ChaincodeStream) error

+ func (chaincodeSupport *ChaincodeSupport) Launch(context context.Context, cccid *ccprovider.CCContext, spec interface{}) (*pb.ChaincodeID, *pb.ChaincodeInput, error)

+ func (chaincodeSupport *ChaincodeSupport) Register(stream pb.ChaincodeSupport_RegisterServer) error

+ func (chaincodeSupport *ChaincodeSupport) Stop(context context.Context, cccid *ccprovider.CCContext, ...) error

+ type DuplicateChaincodeHandlerError struct

+ ChaincodeID *pb.ChaincodeID

+ func (d *DuplicateChaincodeHandlerError) Error() string

+ type Handler struct

+ ChaincodeID *pb.ChaincodeID

+ ChatStream ccintf.ChaincodeStream

+ FSM *fsm.FSM

+ func (handler *Handler) HandleMessage(msg *pb.ChaincodeMessage) error

+ type MessageHandler interface

+ HandleMessage func(msg *pb.ChaincodeMessage) error

+ SendMessage func(msg *pb.ChaincodeMessage) error