txvalidator

Documentation

Index

• type ApplicationCapabilities
• type CapabilityProvider
• type Context
  • func (c Context) String() string
• type MapBasedPluginMapper
  • func (m MapBasedPluginMapper) PluginFactoryByName(name PluginName) validation.PluginFactory
• type PluginMapper
• type PluginName
• type PluginValidator
  • func NewPluginValidator(pm PluginMapper, qec QueryExecutorCreator, ...) *PluginValidator
  • func (pv *PluginValidator) ValidateWithPlugin(ctx *Context) error
• type PolicyEvaluator
  • func (id *PolicyEvaluator) DeserializeIdentity(serializedIdentity []byte) (Identity, error)
  • func (id *PolicyEvaluator) Evaluate(policyBytes []byte, signatureSet []*common.SignedData) error
• type QueryExecutor
• type QueryExecutorCreator
• type ResultsIteratorImpl
  • func (it *ResultsIteratorImpl) Next() (QueryResult, error)
• type SerializedPolicy
  • func (sp SerializedPolicy) Bytes() []byte
• type StateFetcherImpl
  • func (sf *StateFetcherImpl) FetchState() (State, error)
• type StateImpl
  • func (s *StateImpl) GetStateRangeScanIterator(namespace string, startKey string, endKey string) (ResultsIterator, error)
• type Support
• type TxValidator
  • func NewTxValidator(chainID string, support Support, sccp sysccprovider.SystemChaincodeProvider, ...) *TxValidator
  • func (v *TxValidator) Validate(block *common.Block) error
• type ValidationRouter
  • func (v *ValidationRouter) Validate(block *common.Block) error
• type Validator
• type VsccValidatorImpl
  • func (v *VsccValidatorImpl) GetInfoForValidate(chdr *common.ChannelHeader, ccID string) (*sysccprovider.ChaincodeInstance, *sysccprovider.ChaincodeInstance, []byte, ...)
  • func (v *VsccValidatorImpl) VSCCValidateTx(seq int, payload *common.Payload, envBytes []byte, block *common.Block) (error, peer.TxValidationCode)
  • func (v *VsccValidatorImpl) VSCCValidateTxForCC(ctx *Context) error

Types

type ApplicationCapabilities

type ApplicationCapabilities interface {
	channelconfig.ApplicationCapabilities
}

type CapabilityProvider

type CapabilityProvider interface {
	Capabilities() channelconfig.ApplicationCapabilities
}

type Context

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

func (Context) String

func (c Context) String() string

type MapBasedPluginMapper

type MapBasedPluginMapper map[string]validation.PluginFactory

func (MapBasedPluginMapper) PluginFactoryByName

func (m MapBasedPluginMapper) PluginFactoryByName(name PluginName) validation.PluginFactory

type PluginMapper

type PluginMapper interface {
	PluginFactoryByName(name PluginName) validation.PluginFactory
}

type PluginName

type PluginName string

type PluginValidator

type PluginValidator struct {
	sync.Mutex

	PluginMapper
	QueryExecutorCreator
	msp.IdentityDeserializer
	// contains filtered or unexported fields
}

func NewPluginValidator

func NewPluginValidator(pm PluginMapper, qec QueryExecutorCreator, deserializer msp.IdentityDeserializer, capabilities Capabilities) *PluginValidator

func (*PluginValidator) ValidateWithPlugin

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

type PolicyEvaluator

type PolicyEvaluator struct {
	msp.IdentityDeserializer
}

func (*PolicyEvaluator) DeserializeIdentity

func (id *PolicyEvaluator) DeserializeIdentity(serializedIdentity []byte) (Identity, error)

func (*PolicyEvaluator) Evaluate

func (id *PolicyEvaluator) Evaluate(policyBytes []byte, signatureSet []*common.SignedData) error

type QueryExecutor

type QueryExecutor interface {
	ledger.QueryExecutor
}

type QueryExecutorCreator

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

type ResultsIteratorImpl

type ResultsIteratorImpl struct {
	ledger2.ResultsIterator
}

func (*ResultsIteratorImpl) Next

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

type SerializedPolicy

type SerializedPolicy []byte

func (SerializedPolicy) Bytes

func (sp SerializedPolicy) Bytes() []byte

type StateFetcherImpl

type StateFetcherImpl struct {
	QueryExecutorCreator
}

func (*StateFetcherImpl) FetchState

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

type StateImpl

type StateImpl struct {
	ledger.QueryExecutor
}

func (*StateImpl) GetStateRangeScanIterator

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

type Support

type Support interface {
	Acquire(ctx context.Context) error

	Release()

	Ledger() ledger.PeerLedger

	MSPManager() msp.MSPManager

	Apply(configtx *common.ConfigEnvelope) error

	GetMSPIDs(cid string) []string

	Capabilities() channelconfig.ApplicationCapabilities
}

type TxValidator

type TxValidator struct {
	ChainID string
	Support Support
	Vscc    vsccValidator
}

func NewTxValidator

func NewTxValidator(chainID string, support Support, sccp sysccprovider.SystemChaincodeProvider, pm PluginMapper) *TxValidator

func (*TxValidator) Validate

func (v *TxValidator) Validate(block *common.Block) error

type ValidationRouter

type ValidationRouter struct {
	CapabilityProvider
	V20Validator Validator
	V14Validator Validator
}

func (*ValidationRouter) Validate

func (v *ValidationRouter) Validate(block *common.Block) error

type Validator

type Validator interface {
	Validate(block *common.Block) error
}

type VsccValidatorImpl

type VsccValidatorImpl struct {
	// contains filtered or unexported fields
}

func (*VsccValidatorImpl) GetInfoForValidate

func (v *VsccValidatorImpl) GetInfoForValidate(chdr *common.ChannelHeader, ccID string) (*sysccprovider.ChaincodeInstance, *sysccprovider.ChaincodeInstance, []byte, error)

func (*VsccValidatorImpl) VSCCValidateTx

func (v *VsccValidatorImpl) VSCCValidateTx(seq int, payload *common.Payload, envBytes []byte, block *common.Block) (error, peer.TxValidationCode)

func (*VsccValidatorImpl) VSCCValidateTxForCC

func (v *VsccValidatorImpl) VSCCValidateTxForCC(ctx *Context) error