rwset

package

v0.6.0 Latest Latest Go to latest Published: Oct 2, 2025 License: Apache-2.0 Imports: 13 Imported by: 2

Documentation ¶

Index ¶

func CreateCompositeKey(objectType string, attributes []string) (string, error)
func CreateRangeKeysForPartialCompositeKey(objectType string, attributes []string) (string, string, error)
func NewEndorserTransactionHandler(network, channel string, v driver.RWSetInspector) driver.RWSetPayloadHandler
func NewEndorserTransactionReader(network string) *endorserTransactionReader
func NewProcessorManager(channelProvider ChannelProvider, defaultProcessor driver.Processor) *processorManager
func SplitCompositeKey(compositeKey string) (string, []string, error)
type ChannelProvider
type Loader
- func NewLoader(network string, channel string, envelopeService driver.EnvelopeService, ...) *Loader
type RWSExtractor
type UnpackedEnvelope

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CreateCompositeKey ¶

func CreateCompositeKey(objectType string, attributes []string) (string, error)

func CreateRangeKeysForPartialCompositeKey ¶

func CreateRangeKeysForPartialCompositeKey(objectType string, attributes []string) (string, string, error)

func NewEndorserTransactionHandler ¶ added in v0.4.0

func NewEndorserTransactionHandler(network, channel string, v driver.RWSetInspector) driver.RWSetPayloadHandler

func NewEndorserTransactionReader ¶ added in v0.4.0

func NewEndorserTransactionReader(network string) *endorserTransactionReader

func NewProcessorManager ¶

func NewProcessorManager(
	channelProvider ChannelProvider,
	defaultProcessor driver.Processor,
) *processorManager

func SplitCompositeKey ¶

func SplitCompositeKey(compositeKey string) (string, []string, error)

Types ¶

type ChannelProvider ¶ added in v0.4.0

type ChannelProvider interface {
	Channel(name string) (driver.Channel, error)
}

type Loader ¶ added in v0.4.0

type Loader struct {
	Network            string
	Channel            string
	EnvelopeService    driver.EnvelopeService
	TransactionService driver.EndorserTransactionService
	TransactionManager driver.TransactionManager

	Vault driver.RWSetInspector
	// contains filtered or unexported fields
}

func NewLoader ¶ added in v0.4.0

func NewLoader(
	network string,
	channel string,
	envelopeService driver.EnvelopeService,
	transactionService driver.EndorserTransactionService,
	transactionManager driver.TransactionManager,
	vault driver.RWSetInspector,
) *Loader

func (*Loader) AddHandlerProvider ¶ added in v0.4.0

func (c *Loader) AddHandlerProvider(headerType common.HeaderType, handlerProvider driver.RWSetPayloadHandlerProvider) error

func (*Loader) GetInspectingRWSetFromEvn ¶ added in v0.4.0

func (c *Loader) GetInspectingRWSetFromEvn(ctx context.Context, txID driver2.TxID, envelopeRaw []byte) (driver.RWSet, driver.ProcessTransaction, error)

func (*Loader) GetRWSetFromETx ¶ added in v0.4.0

func (c *Loader) GetRWSetFromETx(ctx context.Context, txID driver2.TxID) (driver.RWSet, driver.ProcessTransaction, error)

func (*Loader) GetRWSetFromEvn ¶ added in v0.4.0

func (c *Loader) GetRWSetFromEvn(ctx context.Context, txID driver2.TxID) (driver.RWSet, driver.ProcessTransaction, error)

type RWSExtractor ¶

type RWSExtractor interface {
	Extract(tx []byte) (driver.ProcessTransaction, driver.RWSet, error)
}

type UnpackedEnvelope ¶

type UnpackedEnvelope struct {
	NetworkID         string
	TxID              string
	Ch                string
	ChaincodeName     string
	ChaincodeVersion  string
	Input             *peer.ChaincodeInput
	Nonce             []byte
	Creator           []byte
	Results           []byte
	Function          string
	Args              []string
	ChannelHeader     *common.ChannelHeader
	SignatureHeader   *common.SignatureHeader
	ProposalResponses []*peer.ProposalResponse
}

TODO: remove this and merge with that in transaction

func UnpackEnvelope ¶

func UnpackEnvelope(networkID string, env *common.Envelope) (*UnpackedEnvelope, error)

func UnpackEnvelopeFromBytes ¶

func UnpackEnvelopeFromBytes(networkID string, raw []byte) (*UnpackedEnvelope, error)

func UnpackEnvelopeFromPayloadAndCHHeader ¶ added in v0.4.0

func UnpackEnvelopeFromPayloadAndCHHeader(networkID string, payl *common.Payload, chdr *common.ChannelHeader) (*UnpackedEnvelope, error)

func (*UnpackedEnvelope) Channel ¶

func (u *UnpackedEnvelope) Channel() string

func (*UnpackedEnvelope) FunctionAndParameters ¶

func (u *UnpackedEnvelope) FunctionAndParameters() (string, []string)

func (*UnpackedEnvelope) ID ¶

func (u *UnpackedEnvelope) ID() string

func (*UnpackedEnvelope) Network ¶

func (u *UnpackedEnvelope) Network() string

Source Files ¶

View all Source files

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