transaction

package
v0.5.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 30, 2025 License: Apache-2.0 Imports: 18 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ComputeTxID 

func ComputeTxID(id *driver.TxIDComponents) string

func GetChannelHeaderType added in v0.4.0 

func GetChannelHeaderType(raw []byte) (common.HeaderType, error)

func GetRandomNonce 

func GetRandomNonce() ([]byte, error)

func NewEndorseTransactionService 

func NewEndorseTransactionService(endorseTxKVS driver.EndorseTxStore, network string, channel string) *ets

func NewEnvelopeService 

func NewEnvelopeService(envelopeKVS driver.EnvelopeStore, network string, channel string) *envs

func NewMetadataService 

func NewMetadataService(metadataKVS driver.MetadataStore, network string, channel string) *mds

func NewProcessedTransaction added in v0.4.0 

func NewProcessedTransaction(raw []byte) (*processedTransaction, error)

func NewProcessedTransactionFromEnvelopePayload added in v0.4.0 

func NewProcessedTransactionFromEnvelopePayload(payload []byte) (*processedTransaction, int32, error)

func NewProcessedTransactionFromEnvelopeRaw added in v0.4.0 

func NewProcessedTransactionFromEnvelopeRaw(env []byte) (*processedTransaction, error)

Types

type ChannelProvider added in v0.4.0 

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

type EndorserTransactionFactory added in v0.4.0 

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

func NewEndorserTransactionFactory added in v0.4.0 

func NewEndorserTransactionFactory(networkName string, channelProvider ChannelProvider, sigService driver.SignerService) *EndorserTransactionFactory

func (*EndorserTransactionFactory) NewTransaction added in v0.4.0 

func (e *EndorserTransactionFactory) NewTransaction(ctx context.Context, channel string, nonce []byte, creator []byte, txid string, rawRequest []byte) (driver.Transaction, error)

type Envelope 

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

func NewEnvelope 

func NewEnvelope() *Envelope

func NewEnvelopeFromEnv 

func NewEnvelopeFromEnv(e *common.Envelope) (*Envelope, error)

func (*Envelope) Bytes 

func (e *Envelope) Bytes() ([]byte, error)

func (*Envelope) Creator 

func (e *Envelope) Creator() []byte

func (*Envelope) Envelope 

func (e *Envelope) Envelope() *common.Envelope

func (*Envelope) FromBytes 

func (e *Envelope) FromBytes(raw []byte) error

func (*Envelope) Nonce 

func (e *Envelope) Nonce() []byte

func (*Envelope) Results 

func (e *Envelope) Results() []byte

func (*Envelope) String 

func (e *Envelope) String() string

func (*Envelope) TxID 

func (e *Envelope) TxID() string

type Manager 

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

func NewManager 

func NewManager() *Manager

func (*Manager) AddTransactionFactory added in v0.4.0 

func (m *Manager) AddTransactionFactory(tt driver.TransactionType, factory driver.TransactionFactory)

func (*Manager) ComputeTxID 

func (m *Manager) ComputeTxID(id *driver.TxIDComponents) string

func (*Manager) NewEnvelope 

func (m *Manager) NewEnvelope() driver.Envelope

func (*Manager) NewProcessedTransaction added in v0.4.0 

func (m *Manager) NewProcessedTransaction(pt []byte) (driver.ProcessedTransaction, error)

func (*Manager) NewProcessedTransactionFromEnvelopePayload added in v0.4.0 

func (m *Manager) NewProcessedTransactionFromEnvelopePayload(envelopePayload []byte) (driver.ProcessedTransaction, int32, error)

func (*Manager) NewProcessedTransactionFromEnvelopeRaw added in v0.4.0 

func (m *Manager) NewProcessedTransactionFromEnvelopeRaw(envelope []byte) (driver.ProcessedTransaction, error)

func (*Manager) NewProposalResponseFromBytes 

func (m *Manager) NewProposalResponseFromBytes(raw []byte) (driver.ProposalResponse, error)

func (*Manager) NewTransaction 

func (m *Manager) NewTransaction(ctx context.Context, transactionType driver.TransactionType, creator view2.Identity, nonce []byte, txid string, channel string, rawRequest []byte) (driver.Transaction, error)

func (*Manager) NewTransactionFromBytes 

func (m *Manager) NewTransactionFromBytes(ctx context.Context, channel string, raw []byte) (driver.Transaction, error)

func (*Manager) NewTransactionFromEnvelopeBytes added in v0.4.0 

func (m *Manager) NewTransactionFromEnvelopeBytes(ctx context.Context, channel string, raw []byte) (driver.Transaction, error)

type Proposal 

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

func (*Proposal) Header 

func (p *Proposal) Header() []byte

func (*Proposal) Payload 

func (p *Proposal) Payload() []byte

type ProposalResponse 

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

func NewProposalResponseFromBytes 

func NewProposalResponseFromBytes(raw []byte) (*ProposalResponse, error)

func NewProposalResponseFromResponse 

func NewProposalResponseFromResponse(proposalResponse *peer.ProposalResponse) (*ProposalResponse, error)

func (*ProposalResponse) Bytes added in v0.2.0 

func (p *ProposalResponse) Bytes() ([]byte, error)

func (*ProposalResponse) Endorser 

func (p *ProposalResponse) Endorser() []byte

func (*ProposalResponse) EndorserSignature 

func (p *ProposalResponse) EndorserSignature() []byte

func (*ProposalResponse) PR 

func (p *ProposalResponse) PR() *peer.ProposalResponse

func (*ProposalResponse) Payload 

func (p *ProposalResponse) Payload() []byte

func (*ProposalResponse) ResponseMessage 

func (p *ProposalResponse) ResponseMessage() string

func (*ProposalResponse) ResponseStatus 

func (p *ProposalResponse) ResponseStatus() int32

func (*ProposalResponse) Results 

func (p *ProposalResponse) Results() []byte

func (*ProposalResponse) VerifyEndorsement added in v0.4.0 

func (p *ProposalResponse) VerifyEndorsement(provider driver.VerifierProvider) error

type SerializableSigner 

type SerializableSigner interface {
	Sign(message []byte) ([]byte, error)
	Serialize() ([]byte, error)
}

type SerializedTransaction added in v0.4.0 

type SerializedTransaction struct {
	Type driver.TransactionType
	Raw  []byte
}

type SignedProposal 

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

func (*SignedProposal) ChaincodeName 

func (p *SignedProposal) ChaincodeName() string

func (*SignedProposal) ChaincodeVersion 

func (p *SignedProposal) ChaincodeVersion() string

func (*SignedProposal) ProposalBytes 

func (p *SignedProposal) ProposalBytes() []byte

func (*SignedProposal) ProposalHash 

func (p *SignedProposal) ProposalHash() []byte

func (*SignedProposal) Signature 

func (p *SignedProposal) Signature() []byte

type Signer 

type Signer interface {
	Sign(message []byte) ([]byte, error)
}

type Transaction 

type Transaction struct {
	TCreator view.Identity
	TNonce   []byte
	TTxID    string

	TNetwork          string
	TChannel          string
	TChaincode        string
	TChaincodeVersion string
	TFunction         string
	TParameters       [][]byte

	RWSet      []byte
	TTransient driver.TransientMap

	TProposal          *pb.Proposal
	TSignedProposal    *pb.SignedProposal
	TProposalResponses []*pb.ProposalResponse
	// contains filtered or unexported fields
}

func (*Transaction) AppendParameter 

func (t *Transaction) AppendParameter(p []byte)

func (*Transaction) AppendProposalResponse 

func (t *Transaction) AppendProposalResponse(response driver.ProposalResponse) error

func (*Transaction) Bytes 

func (t *Transaction) Bytes() ([]byte, error)

func (*Transaction) BytesNoTransient 

func (t *Transaction) BytesNoTransient() ([]byte, error)

func (*Transaction) Chaincode 

func (t *Transaction) Chaincode() string

func (*Transaction) ChaincodeVersion 

func (t *Transaction) ChaincodeVersion() string

func (*Transaction) Channel 

func (t *Transaction) Channel() string

func (*Transaction) Close 

func (t *Transaction) Close()

func (*Transaction) Creator 

func (t *Transaction) Creator() view.Identity

func (*Transaction) Done 

func (t *Transaction) Done() error

func (*Transaction) Endorse 

func (t *Transaction) Endorse() error

func (*Transaction) EndorseProposal 

func (t *Transaction) EndorseProposal() error

func (*Transaction) EndorseProposalResponse 

func (t *Transaction) EndorseProposalResponse() error

func (*Transaction) EndorseProposalResponseWithIdentity 

func (t *Transaction) EndorseProposalResponseWithIdentity(identity view.Identity) error

func (*Transaction) EndorseProposalWithIdentity 

func (t *Transaction) EndorseProposalWithIdentity(identity view.Identity) error

func (*Transaction) EndorseWithIdentity 

func (t *Transaction) EndorseWithIdentity(identity view.Identity) error

func (*Transaction) EndorseWithSigner 

func (t *Transaction) EndorseWithSigner(identity view.Identity, s driver.Signer) error

func (*Transaction) Envelope added in v0.2.0 

func (t *Transaction) Envelope() (driver.Envelope, error)

func (*Transaction) From 

func (t *Transaction) From(tx driver.Transaction) (err error)

func (*Transaction) Function 

func (t *Transaction) Function() string

func (*Transaction) FunctionAndParameters 

func (t *Transaction) FunctionAndParameters() (string, []string)

func (*Transaction) GetRWSet 

func (t *Transaction) GetRWSet() (driver.RWSet, error)

func (*Transaction) ID 

func (t *Transaction) ID() string

func (*Transaction) Network 

func (t *Transaction) Network() string

func (*Transaction) Nonce 

func (t *Transaction) Nonce() []byte

func (*Transaction) Parameters 

func (t *Transaction) Parameters() [][]byte

func (*Transaction) Proposal 

func (t *Transaction) Proposal() driver.Proposal

func (*Transaction) ProposalHasBeenEndorsedBy 

func (t *Transaction) ProposalHasBeenEndorsedBy(party view.Identity) error

func (*Transaction) ProposalResponse 

func (t *Transaction) ProposalResponse() ([]byte, error)

func (*Transaction) ProposalResponses 

func (t *Transaction) ProposalResponses() ([]driver.ProposalResponse, error)

func (*Transaction) RWS 

func (t *Transaction) RWS() driver.RWSet

func (*Transaction) Raw 

func (t *Transaction) Raw() ([]byte, error)

func (*Transaction) ResetTransient 

func (t *Transaction) ResetTransient()

func (*Transaction) Results 

func (t *Transaction) Results() ([]byte, error)

func (*Transaction) SetFromBytes 

func (t *Transaction) SetFromBytes(raw []byte) error

func (*Transaction) SetFromEnvelopeBytes 

func (t *Transaction) SetFromEnvelopeBytes(raw []byte) error

func (*Transaction) SetParameterAt 

func (t *Transaction) SetParameterAt(i int, p []byte) error

func (*Transaction) SetProposal 

func (t *Transaction) SetProposal(chaincode string, version string, function string, params ...string)

func (*Transaction) SetRWSet 

func (t *Transaction) SetRWSet() error

func (*Transaction) SignedProposal 

func (t *Transaction) SignedProposal() driver.SignedProposal

func (*Transaction) StoreTransient 

func (t *Transaction) StoreTransient() error

func (*Transaction) Transient 

func (t *Transaction) Transient() driver.TransientMap

type UnpackedEnvelope 

type UnpackedEnvelope struct {
	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
	Envelope          []byte
}

func UnpackEnvelope 

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

func UnpackEnvelopeFromBytes 

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

func UnpackEnvelopePayload added in v0.4.0 

func UnpackEnvelopePayload(payloadRaw []byte) (*UnpackedEnvelope, int32, 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

type UnpackedProposal 

type UnpackedProposal struct {
	ChaincodeName    string
	ChaincodeVersion string
	ChannelHeader    *cb.ChannelHeader
	Input            *pb.ChaincodeInput
	Proposal         *pb.Proposal
	SignatureHeader  *cb.SignatureHeader
	SignedProposal   *pb.SignedProposal
	ProposalHash     []byte
}

UnpackedProposal contains the interesting artifacts from inside the proposal.

func UnpackProposal 

func UnpackProposal(prop *pb.Proposal) (*UnpackedProposal, error)

func UnpackSignedProposal 

func UnpackSignedProposal(signedProp *pb.SignedProposal) (*UnpackedProposal, error)

UnpackSignedProposal creates an an *UnpackedProposal which is guaranteed to have no zero-ed fields or it returns an error.

func (*UnpackedProposal) ChannelID 

func (up *UnpackedProposal) ChannelID() string

func (*UnpackedProposal) Nonce 

func (up *UnpackedProposal) Nonce() []byte

func (*UnpackedProposal) TxID 

func (up *UnpackedProposal) TxID() string

func (*UnpackedProposal) Validate 

func (up *UnpackedProposal) Validate(idDeserializer msp.IdentityDeserializer) error

type UnpackedProposalResponse 

type UnpackedProposalResponse struct {
	ProposalResponse *pb.ProposalResponse
	ChaincodeAction  *pb.ChaincodeAction
}

UnpackedProposalResponse contains the interesting artifacts from inside the proposal.

func UnpackProposalResponse 

func UnpackProposalResponse(proposalResponse *pb.ProposalResponse) (*UnpackedProposalResponse, error)

UnpackProposalResponse creates an an *UnpackedProposalResponse which is guaranteed to have no zero-ed fields or it returns an error.

func (*UnpackedProposalResponse) Results 

func (p *UnpackedProposalResponse) Results() []byte

type WrappedTransaction added in v0.4.0 

type WrappedTransaction struct {
	driver.Transaction
	TransactionType driver.TransactionType
}

func (*WrappedTransaction) Bytes added in v0.4.0 

func (w *WrappedTransaction) Bytes() ([]byte, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.