plugindispatcher

Documentation

Index

• func New(chainID string, cr ChannelResources, ler LedgerResources, ...) *dispatcherImpl
• type Capabilities
• type ChannelPolicyManagerGetter
• type ChannelResources
• type CollectionAndLifecycleResources
• type CollectionResources
• type Context
  • func (c Context) String() string
• type IdentityDeserializer
• type LedgerResources
• type LifecycleResources
• type Mapper
• type Plugin
• type PluginFactory
• type PluginValidator
  • func NewPluginValidator(pm txvalidatorplugin.Mapper, qec QueryExecutorCreator, ...) *PluginValidator
  • func (pv *PluginValidator) ValidateWithPlugin(ctx *Context) error
• type PolicyEvaluatorWrapper
  • func (id *PolicyEvaluatorWrapper) DeserializeIdentity(serializedIdentity []byte) (vi.Identity, error)
  • func (id *PolicyEvaluatorWrapper) Evaluate(policyBytes []byte, signatureSet []*protoutil.SignedData) error
• type PolicyManager
• type QueryExecutorCreator
• type ResultsIteratorImpl
  • func (it *ResultsIteratorImpl) Next() (vs.QueryResult, error)
• type StateFetcherImpl
  • func (sf *StateFetcherImpl) FetchState() (vs.State, error)
• type StateImpl
  • func (s *StateImpl) GetStateRangeScanIterator(namespace string, startKey string, endKey string) (vs.ResultsIterator, error)

Functions

func New

func New(chainID string, cr ChannelResources, ler LedgerResources, lcr LifecycleResources, pluginValidator *PluginValidator) *dispatcherImpl

Types

type Capabilities

type Capabilities interface {
	vc.Capabilities
}

type ChannelPolicyManagerGetter

type ChannelPolicyManagerGetter interface {
	policies.ChannelPolicyManagerGetter
}

type ChannelResources

type ChannelResources interface {
	GetMSPIDs() []string
}

type CollectionAndLifecycleResources

type CollectionAndLifecycleResources interface {
	LifecycleResources

	CollectionValidationInfo(channelID, chaincodeName, collectionName string, state s.State) (args []byte, unexpectedErr error, validationErr error)
}

type CollectionResources

type CollectionResources interface {
	CollectionValidationInfo(chaincodeName, collectionName string, state s.State) (args []byte, unexpectedErr error, validationErr error)
}

type Context

type Context struct {
	Seq        int
	Envelope   []byte
	TxID       string
	Channel    string
	PluginName string
	Policy     []byte
	Namespace  string
	Block      *common.Block
}

func (Context) String

func (c Context) String() string

type IdentityDeserializer

type IdentityDeserializer interface {
	msp.IdentityDeserializer
}

type LedgerResources

type LedgerResources interface {
	NewQueryExecutor() (ledger.QueryExecutor, error)
}

type LifecycleResources

type LifecycleResources interface {
	ValidationInfo(channelID, chaincodeName string, qe ledger.SimpleQueryExecutor) (plugin string, args []byte, unexpectedErr error, validationErr error)
}

type Mapper

type Mapper interface {
	txvalidatorplugin.Mapper
}

type Plugin

type Plugin interface {
	validation.Plugin
}

type PluginFactory

type PluginFactory interface {
	validation.PluginFactory
}

type PluginValidator

type PluginValidator struct {
	sync.Mutex

	txvalidatorplugin.Mapper
	QueryExecutorCreator
	msp.IdentityDeserializer

	policies.ChannelPolicyManagerGetter
	CollectionResources
	// contains filtered or unexported fields
}

func NewPluginValidator

func NewPluginValidator(pm txvalidatorplugin.Mapper, qec QueryExecutorCreator, deserializer msp.IdentityDeserializer, capabilities vc.Capabilities, cpmg policies.ChannelPolicyManagerGetter, cor CollectionResources) *PluginValidator

func (*PluginValidator) ValidateWithPlugin

func (pv *PluginValidator) ValidateWithPlugin(ctx *Context) error

type PolicyEvaluatorWrapper

type PolicyEvaluatorWrapper struct {
	msp.IdentityDeserializer
	vp.PolicyEvaluator
}

func (*PolicyEvaluatorWrapper) DeserializeIdentity

func (id *PolicyEvaluatorWrapper) DeserializeIdentity(serializedIdentity []byte) (vi.Identity, error)

func (*PolicyEvaluatorWrapper) Evaluate

func (id *PolicyEvaluatorWrapper) Evaluate(policyBytes []byte, signatureSet []*protoutil.SignedData) error

type PolicyManager

type PolicyManager interface {
	policies.Manager
}

type QueryExecutorCreator

type QueryExecutorCreator interface {
	NewQueryExecutor() (ledger.QueryExecutor, error)
}

type ResultsIteratorImpl

type ResultsIteratorImpl struct {
	ledger2.ResultsIterator
}

func (*ResultsIteratorImpl) Next

func (it *ResultsIteratorImpl) Next() (vs.QueryResult, error)

type StateFetcherImpl

type StateFetcherImpl struct {
	QueryExecutorCreator
}

func (*StateFetcherImpl) FetchState

func (sf *StateFetcherImpl) FetchState() (vs.State, error)

type StateImpl

type StateImpl struct {
	ledger.QueryExecutor
}

func (*StateImpl) GetStateRangeScanIterator

func (s *StateImpl) GetStateRangeScanIterator(namespace string, startKey string, endKey string) (vs.ResultsIterator, error)