tx

Documentation

Index

• type ChannelConfig
• type Envelope
• type InvalidErr
  • func (e *InvalidErr) Error() string
  • func (e *InvalidErr) Format(s fmt.State, verb rune)
• type KeyValueItr
  • func (i *KeyValueItr) Close()
  • func (i *KeyValueItr) Next() (*statedata.KeyValue, error)
• type Processor
• type ProcessorCreator
• type PvtdataSourceHinter
• type ReadHinter
• type ReprocessReadHinter
• type Reprocessor
• type State
  • func (s *State) GetPrivateDataMetadataByHash(ns, coll string, keyHash []byte) (map[string][]byte, error)
  • func (s *State) GetState(ns, key string) ([]byte, error)
  • func (s *State) GetStateMetadata(ns, key string) (map[string][]byte, error)
  • func (s *State) GetStateRangeScanIterator(ns, startKey, endKey string) (*KeyValueItr, error)
  • func (s *State) SetState(ns, key string, value []byte) error
  • func (s *State) SetStateMetadata(ns, key string, metadata map[string][]byte) error

Types

type ChannelConfig

type ChannelConfig struct {
}

type Envelope

type Envelope struct {
	SignedBytes []byte

	Signature []byte

	Data []byte

	ChannelHeaderBytes []byte

	SignatureHeaderBytes []byte

	ChannelHeader *common.ChannelHeader

	SignatureHeader *common.SignatureHeader
}

type InvalidErr

type InvalidErr struct {
	ActualErr      error
	ValidationCode peer.TxValidationCode
}

func (*InvalidErr) Error

func (e *InvalidErr) Error() string

func (*InvalidErr) Format

func (e *InvalidErr) Format(s fmt.State, verb rune)

type KeyValueItr

type KeyValueItr struct {
	BackingItr keyValueItr
}

func (*KeyValueItr) Close

func (i *KeyValueItr) Close()

func (*KeyValueItr) Next

func (i *KeyValueItr) Next() (*statedata.KeyValue, error)

type Processor

type Processor interface {
	Preprocess(latestChannelConfig *ChannelConfig) error
	Process(state *State, proposedWrites *statedata.ProposedWrites) error
	Done()
}

type ProcessorCreator

type ProcessorCreator interface {
	NewProcessor(txenv *Envelope) (processor Processor, simulatedRWSet [][]byte, err error)
}

type PvtdataSourceHinter

type PvtdataSourceHinter interface {
	PvtdataSource() [][]byte
}

type ReadHinter

type ReadHinter interface {
	ReadHint(potentialWrites *statedata.WriteHint) *statedata.ReadHint
}

type ReprocessReadHinter

type ReprocessReadHinter interface {
	ReprocessReadHint(potentialWrites *statedata.WriteHint) *statedata.ReadHint
}

type Reprocessor

type Reprocessor interface {
	Reprocess(state *State, latestChannelConfig *ChannelConfig, proposedWrites *statedata.ProposedWrites)
}

type State

type State struct {
	BackingState state
}

func (*State) GetPrivateDataMetadataByHash

func (s *State) GetPrivateDataMetadataByHash(ns, coll string, keyHash []byte) (map[string][]byte, error)

func (*State) GetState

func (s *State) GetState(ns, key string) ([]byte, error)

func (*State) GetStateMetadata

func (s *State) GetStateMetadata(ns, key string) (map[string][]byte, error)

func (*State) GetStateRangeScanIterator

func (s *State) GetStateRangeScanIterator(ns, startKey, endKey string) (*KeyValueItr, error)

func (*State) SetState

func (s *State) SetState(ns, key string, value []byte) error

func (*State) SetStateMetadata

func (s *State) SetStateMetadata(ns, key string, metadata map[string][]byte) error