utils

package
v1.0.0-preview Latest Latest
Warning

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

 Go to latest Published: Jan 31, 2017 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AnchorPeerConfItemKey = "AnchorPeers"
)

Variables

This section is empty.

Functions

func BreakOutBlockData 

func BreakOutBlockData(blockData *pb.BlockData) ([]*pb.Payload, [][]byte, error)

BreakOutBlockData decomposes a blockData into its payloads and signatures. since a BlockData contains a slice of Envelopes, this functions returns slices of Payloads and Envelope.Signatures. the Payload/Signature pair has the same array index

func BreakOutBlockDataOrPanic 

func BreakOutBlockDataOrPanic(blockData *pb.BlockData) ([]*pb.Payload, [][]byte)

BreakOutBlockDataOrPanic executes BreakOutBlockData() but panics on error

func BreakOutBlockToConfigurationEnvelope 

func BreakOutBlockToConfigurationEnvelope(block *pb.Block) (*pb.ConfigurationEnvelope, []byte, error)

BreakOutBlockToConfigurationEnvelope decomposes a configuration transaction Block to its ConfigurationEnvelope

func BreakOutBlockToConfigurationEnvelopeOrPanic 

func BreakOutBlockToConfigurationEnvelopeOrPanic(block *pb.Block) (*pb.ConfigurationEnvelope, []byte)

BreakOutBlockToConfigurationEnvelopeOrPanic calls BreakOutBlockToConfigurationEnvelope() but panics on error

func BreakOutConfigEnvelopeToConfigItems 

func BreakOutConfigEnvelopeToConfigItems(configEnvelope *pb.ConfigurationEnvelope) ([]*pb.ConfigurationItem, [][]*pb.ConfigurationSignature, error)

BreakOutConfigEnvelopeToConfigItems decomposes a ConfigurationEnvelope to its constituent ConfigurationItems and ConfigurationSignatures Note that a ConfigurationItem can have multiple signatures so each element in the returned ConfigurationItems slice is associated with a slice of ConfigurationSignatures

func BreakOutConfigEnvelopeToConfigItemsOrPanic 

func BreakOutConfigEnvelopeToConfigItemsOrPanic(configEnvelope *pb.ConfigurationEnvelope) ([]*pb.ConfigurationItem, [][]*pb.ConfigurationSignature)

BreakOutConfigEnvelopeToConfigItemsOrPanic calls BreakOutConfigEnvelopeToConfigItems() but panics on error

func BreakOutPayloadDataToConfigurationEnvelope 

func BreakOutPayloadDataToConfigurationEnvelope(payloadData []byte) (*pb.ConfigurationEnvelope, error)

BreakOutPayloadDataToConfigurationEnvelope decomposes a Payload.Data item into its constituent ConfigurationEnvelope

func BreakOutPayloadDataToConfigurationEnvelopeOrPanic 

func BreakOutPayloadDataToConfigurationEnvelopeOrPanic(payloadData []byte) *pb.ConfigurationEnvelope

BreakOutPayloadDataToConfigurationEnvelopeOrPanic calls BreakOutPayloadDataToConfigurationEnvelope() but panics on error

func CopyBlockMetadata 

func CopyBlockMetadata(src *cb.Block, dst *cb.Block)

CopyBlockMetadata copies metadata from one block into another

func CreateChaincodeProposal 

func CreateChaincodeProposal(txid string, typ common.HeaderType, chainID string, cis *peer.ChaincodeInvocationSpec, creator []byte) (*peer.Proposal, error)

CreateChaincodeProposal creates a proposal from given input

func CreateChaincodeProposalWithTransient 

func CreateChaincodeProposalWithTransient(txid string, typ common.HeaderType, chainID string, cis *peer.ChaincodeInvocationSpec, creator []byte, transient []byte) (*peer.Proposal, error)

CreateChaincodeProposalWithTransient creates a proposal from given input

func CreateDeployProposalFromCDS 

func CreateDeployProposalFromCDS(txid string, chainID string, cds *peer.ChaincodeDeploymentSpec, creator []byte) (*peer.Proposal, error)

CreateDeployProposalFromCDS returns a deploy proposal given a serialized identity and a ChaincodeDeploymentSpec

func CreateNonce 

func CreateNonce() ([]byte, error)

CreateNonce generates a nonce using the crypto/primitives package.

func CreateNonceOrPanic 

func CreateNonceOrPanic() []byte

CreateNonceOrPanic generates a nonce using the crypto/primitives package and panics if this operation fails.

func CreateProposalFromCIS 

func CreateProposalFromCIS(txid string, typ common.HeaderType, chainID string, cis *peer.ChaincodeInvocationSpec, creator []byte) (*peer.Proposal, error)

CreateProposalFromCIS returns a proposal given a serialized identity and a ChaincodeInvocationSpec

func CreateProposalResponse 

func CreateProposalResponse(hdr []byte, payl []byte, response *peer.Response, results []byte, events []byte, visibility []byte, signingEndorser msp.SigningIdentity) (*peer.ProposalResponse, error)

CreateProposalResponse creates a proposal response.

func CreateSignedTx 

func CreateSignedTx(proposal *peer.Proposal, signer msp.SigningIdentity, resps ...*peer.ProposalResponse) (*common.Envelope, error)

CreateSignedTx assembles an Envelope message from proposal, endorsements, and a signer. This function should be called by a client when it has collected enough endorsements for a proposal to create a transaction and submit it to peers for ordering

func CreateUpgradeProposalFromCDS 

func CreateUpgradeProposalFromCDS(txid string, chainID string, cds *peer.ChaincodeDeploymentSpec, creator []byte) (*peer.Proposal, error)

CreateUpgradeProposalFromCDS returns a upgrade proposal given a serialized identity and a ChaincodeDeploymentSpec

func EncodeAnchorPeers 

func EncodeAnchorPeers(anchorPeers []*peer.AnchorPeer) *cb.ConfigurationItem

EncodeAnchorPeers returns a configuration item with anchor peers

func EncodeMSP 

func EncodeMSP(chainID string) *cb.SignedConfigurationItem

EncodeMSP gets the signed configuration item with the default MSP

func EncodeMSPUnsigned 

func EncodeMSPUnsigned(chainID string) *cb.ConfigurationItem

EncodeMSPUnsigned gets the unsigned configuration item with the default MSP

func ExtractEnvelope 

func ExtractEnvelope(block *cb.Block, index int) (*cb.Envelope, error)

ExtractEnvelope retrieves the requested envelope from a given block and unmarshals it.

func ExtractEnvelopeOrPanic 

func ExtractEnvelopeOrPanic(block *cb.Block, index int) *cb.Envelope

ExtractEnvelopeOrPanic retrieves the requested envelope from a given block and unmarshals it -- it panics if either of these operation fail.

func ExtractPayload 

func ExtractPayload(envelope *cb.Envelope) (*cb.Payload, error)

ExtractPayload retrieves the payload of a given envelope and unmarshals it.

func ExtractPayloadOrPanic 

func ExtractPayloadOrPanic(envelope *cb.Envelope) *cb.Payload

ExtractPayloadOrPanic retrieves the payload of a given envelope and unmarshals it -- it panics if either of these operations fail.

func GetActionFromEnvelope 

func GetActionFromEnvelope(envBytes []byte) (*peer.ChaincodeAction, error)

GetActionFromEnvelope extracts a ChaincodeAction message from a serialized Envelope

func GetBlockFromBlockBytes 

func GetBlockFromBlockBytes(blockBytes []byte) (*cb.Block, error)

GetBlockFromBlockBytes marshals the bytes into Block

func GetBytesChaincodeActionPayload 

func GetBytesChaincodeActionPayload(cap *peer.ChaincodeActionPayload) ([]byte, error)

GetBytesChaincodeActionPayload get the bytes of ChaincodeActionPayload from the message

func GetBytesChaincodeEvent 

func GetBytesChaincodeEvent(event *peer.ChaincodeEvent) ([]byte, error)

GetBytesChaincodeEvent gets the bytes of ChaincodeEvent

func GetBytesChaincodeProposalPayload 

func GetBytesChaincodeProposalPayload(cpp *peer.ChaincodeProposalPayload) ([]byte, error)

GetBytesChaincodeProposalPayload gets the chaincode proposal payload

func GetBytesEnvelope 

func GetBytesEnvelope(env *common.Envelope) ([]byte, error)

GetBytesEnvelope get the bytes of Envelope from the message

func GetBytesHeader 

func GetBytesHeader(hdr *common.Header) ([]byte, error)

GetBytesHeader get the bytes of Header from the message

func GetBytesPayload 

func GetBytesPayload(payl *common.Payload) ([]byte, error)

GetBytesPayload get the bytes of Payload from the message

func GetBytesProposal 

func GetBytesProposal(prop *peer.Proposal) ([]byte, error)

GetBytesProposal returns the bytes of a proposal message

func GetBytesProposalPayloadForTx 

func GetBytesProposalPayloadForTx(payload *peer.ChaincodeProposalPayload, visibility []byte) ([]byte, error)

GetBytesProposalPayloadForTx takes a ChaincodeProposalPayload and returns its serialized version according to the visibility field

func GetBytesProposalResponse 

func GetBytesProposalResponse(pr *peer.ProposalResponse) ([]byte, error)

GetBytesProposalResponse gets propoal bytes response

func GetBytesProposalResponsePayload 

func GetBytesProposalResponsePayload(hash []byte, response *peer.Response, result []byte, event []byte) ([]byte, error)

GetBytesProposalResponsePayload gets proposal response payload

func GetBytesResponse 

func GetBytesResponse(res *peer.Response) ([]byte, error)

GetBytesResponse gets the bytes of Response

func GetBytesSignatureHeader 

func GetBytesSignatureHeader(hdr *common.SignatureHeader) ([]byte, error)

GetBytesSignatureHeader get the bytes of SignatureHeader from the message

func GetBytesTransaction 

func GetBytesTransaction(tx *peer.Transaction) ([]byte, error)

GetBytesTransaction get the bytes of Transaction from the message

func GetChainIDFromBlock 

func GetChainIDFromBlock(block *cb.Block) (string, error)

GetChainIDFromBlock returns chain ID in the block

func GetChaincodeAction 

func GetChaincodeAction(caBytes []byte) (*peer.ChaincodeAction, error)

GetChaincodeAction gets the ChaincodeAction given chaicnode action bytes

func GetChaincodeActionPayload 

func GetChaincodeActionPayload(capBytes []byte) (*peer.ChaincodeActionPayload, error)

GetChaincodeActionPayload Get ChaincodeActionPayload from bytes

func GetChaincodeDeploymentSpec 

func GetChaincodeDeploymentSpec(code []byte) (*peer.ChaincodeDeploymentSpec, error)

GetChaincodeDeploymentSpec returns a ChaincodeDeploymentSpec given args

func GetChaincodeEvents 

func GetChaincodeEvents(eBytes []byte) (*peer.ChaincodeEvent, error)

GetChaincodeEvents gets the ChaincodeEvents given chaicnode event bytes

func GetChaincodeHeaderExtension 

func GetChaincodeHeaderExtension(hdr *common.Header) (*peer.ChaincodeHeaderExtension, error)

GetChaincodeHeaderExtension get chaincode header extension given header

func GetChaincodeInvocationSpec 

func GetChaincodeInvocationSpec(prop *peer.Proposal) (*peer.ChaincodeInvocationSpec, error)

GetChaincodeInvocationSpec get the ChaincodeInvocationSpec from the proposal

func GetChaincodeProposalContext 

func GetChaincodeProposalContext(prop *peer.Proposal) (*peer.ChaincodeProposalContext, error)

GetChaincodeProposalContext returns a ChaincodeProposalContext from a Proposal

func GetChaincodeProposalPayload 

func GetChaincodeProposalPayload(bytes []byte) (*peer.ChaincodeProposalPayload, error)

GetChaincodeProposalPayload Get ChaincodeProposalPayload from bytes

func GetConfigurationEnvelope 

func GetConfigurationEnvelope(bytes []byte) (*common.ConfigurationEnvelope, error)

GetConfigurationEnvelope returns a ConfigurationEnvelope from bytes

func GetEnvelopeFromBlock 

func GetEnvelopeFromBlock(data []byte) (*common.Envelope, error)

GetEnvelopeFromBlock gets an envelope from a block's Data field.

func GetHeader 

func GetHeader(bytes []byte) (*common.Header, error)

GetHeader Get Header from bytes

func GetLastConfigurationIndexFromBlock 

func GetLastConfigurationIndexFromBlock(block *cb.Block) (uint64, error)

GetLastConfigurationIndexFromBlock retrieves the index of the last configuration block as encoded in the block metadata

func GetLastConfigurationIndexFromBlockOrPanic 

func GetLastConfigurationIndexFromBlockOrPanic(block *cb.Block) uint64

GetLastConfigurationIndexFromBlockOrPanic retrieves the index of the last configuration block as encoded in the block metadata, or panics on error.

func GetMetadataFromBlock 

func GetMetadataFromBlock(block *cb.Block, index cb.BlockMetadataIndex) (*cb.Metadata, error)

GetMetadataFromBlock retrieves metadata at the specified index.

func GetMetadataFromBlockOrPanic 

func GetMetadataFromBlockOrPanic(block *cb.Block, index cb.BlockMetadataIndex) *cb.Metadata

GetMetadataFromBlockOrPanic retrieves metadata at the specified index, or panics on error.

func GetPayload 

func GetPayload(e *common.Envelope) (*common.Payload, error)

GetPayload Get Payload from Envelope message

func GetPayloads 

func GetPayloads(txActions *peer.TransactionAction) (*peer.ChaincodeActionPayload, *peer.ChaincodeAction, error)

GetPayloads get's the underlying payload objects in a TransactionAction

func GetProposal 

func GetProposal(propBytes []byte) (*peer.Proposal, error)

GetProposal returns a Proposal message from its bytes

func GetProposalHash1 

func GetProposalHash1(header []byte, ccPropPayl []byte, visibility []byte) ([]byte, error)

GetProposalHash1 gets the proposal hash bytes after sanitizing the chaincode proposal payload according to the rules of visibility

func GetProposalHash2 

func GetProposalHash2(header []byte, ccPropPayl []byte) ([]byte, error)

GetProposalHash2 gets the proposal hash - this version is called by the committer where the visibility policy has already been enforced and so we already get what we have to get in ccPropPayl

func GetProposalResponse 

func GetProposalResponse(prBytes []byte) (*peer.ProposalResponse, error)

GetProposalResponse given proposal in bytes

func GetProposalResponsePayload 

func GetProposalResponsePayload(prpBytes []byte) (*peer.ProposalResponsePayload, error)

GetProposalResponsePayload gets the proposal response payload

func GetResponse 

func GetResponse(resBytes []byte) (*peer.Response, error)

GetResponse gets the Response given response bytes

func GetSignatureHeader 

func GetSignatureHeader(bytes []byte) (*common.SignatureHeader, error)

GetSignatureHeader Get SignatureHeader from bytes

func GetSignedProposal 

func GetSignedProposal(prop *peer.Proposal, signer msp.SigningIdentity) (*peer.SignedProposal, error)

GetSignedProposal returns a signed proposal given a Proposal message and a signing identity

func GetTESTMSPConfigPath 

func GetTESTMSPConfigPath() string

GetTESTMSPConfigPath This function is needed to locate the MSP test configuration when running in CI build env or local with "make unit-test". A better way to manage this is to define a config path in yaml that may point to test or production location of the config

func GetTransaction 

func GetTransaction(txBytes []byte) (*peer.Transaction, error)

GetTransaction Get Transaction from bytes

func InitBlockMetadata 

func InitBlockMetadata(block *cb.Block)

InitBlockMetadata copies metadata from one block into another

func MakeChainHeader 

func MakeChainHeader(headerType cb.HeaderType, version int32, chainID string, epoch uint64) *cb.ChainHeader

MakeChainHeader creates a ChainHeader.

func MakeConfigurationEnvelope 

func MakeConfigurationEnvelope(items ...*cb.SignedConfigurationItem) *cb.ConfigurationEnvelope

MakeConfigurationEnvelope makes a ConfigurationEnvelope.

func MakeConfigurationItem 

func MakeConfigurationItem(ch *cb.ChainHeader, configItemType cb.ConfigurationItem_ConfigurationType, lastModified uint64, modPolicyID string, key string, value []byte) *cb.ConfigurationItem

MakeConfigurationItem makes a ConfigurationItem.

func MakePayloadHeader 

func MakePayloadHeader(ch *cb.ChainHeader, sh *cb.SignatureHeader) *cb.Header

MakePayloadHeader creates a Payload Header.

func MakePolicy 

func MakePolicy(policyEnvelope interface{}) (*cb.Policy, error)

MakePolicy creates a Policy proto message out of a SignaturePolicyEnvelope. NOTE Expand this as more policy types as supported.

func MakePolicyOrPanic 

func MakePolicyOrPanic(policyEnvelope interface{}) *cb.Policy

MakePolicyOrPanic creates a Policy proto message out of a SignaturePolicyEnvelope, and panics if this operation fails.

func MakeSignatureHeader 

func MakeSignatureHeader(serializedCreatorCertChain []byte, nonce []byte) *cb.SignatureHeader

MakeSignatureHeader creates a SignatureHeader.

func Marshal 

func Marshal(pb proto.Message) ([]byte, error)

Marshal serializes a protobuf message.

func MarshalOrPanic 

func MarshalOrPanic(pb proto.Message) []byte

MarshalOrPanic serializes a protobuf message and panics if this operation fails.

func NewSignatureHeaderOrPanic 

func NewSignatureHeaderOrPanic(signer crypto.LocalSigner) *cb.SignatureHeader

NewSignatureHeaderOrPanic returns a signature header and panics on error.

func SignOrPanic 

func SignOrPanic(signer crypto.LocalSigner, msg []byte) []byte

SignOrPanic signs a message and panics on error.

func UnmarshalConfigurationEnvelope 

func UnmarshalConfigurationEnvelope(encoded []byte) (*pb.ConfigurationEnvelope, error)

UnmarshalConfigurationEnvelope unmarshals bytes to a ConfigurationEnvelope

func UnmarshalConfigurationEnvelopeOrPanic 

func UnmarshalConfigurationEnvelopeOrPanic(encoded []byte) *pb.ConfigurationEnvelope

UnmarshalConfigurationEnvelopeOrPanic unmarshals bytes to a ConfigurationEnvelope or panics on error

func UnmarshalConfigurationItem 

func UnmarshalConfigurationItem(encoded []byte) (*pb.ConfigurationItem, error)

UnmarshalConfigurationItem unmarshals bytes to a ConfigurationItem

func UnmarshalConfigurationItemOrPanic 

func UnmarshalConfigurationItemOrPanic(encoded []byte) *pb.ConfigurationItem

UnmarshalConfigurationItemOrPanic unmarshals bytes to a ConfigurationItem or panics on error

func UnmarshalEnvelope 

func UnmarshalEnvelope(encoded []byte) (*cb.Envelope, error)

UnmarshalEnvelope unmarshals bytes to an Envelope structure

func UnmarshalEnvelopeOrPanic 

func UnmarshalEnvelopeOrPanic(encoded []byte) *cb.Envelope

UnmarshalEnvelopeOrPanic unmarshals bytes to an Envelope structure or panics on error

func UnmarshalPayload 

func UnmarshalPayload(encoded []byte) (*cb.Payload, error)

UnmarshalPayload unmarshals bytes to a Payload structure

func UnmarshalPayloadOrPanic 

func UnmarshalPayloadOrPanic(encoded []byte) *cb.Payload

UnmarshalPayloadOrPanic unmarshals bytes to a Payload structure or panics on error

Types

This section is empty.

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.