txsnapservice

Documentation

Index

• Variables
• type TxServiceImpl
  • func Get(channelID string) (*TxServiceImpl, error)
  • func (txs *TxServiceImpl) ClientConfig() sdkConfigApi.Config
  • func (txs *TxServiceImpl) CommitTransaction(channelID string, tpResponses []*apitxn.TransactionProposalResponse, ...) (pb.TxValidationCode, error)
  • func (txs *TxServiceImpl) CommitTransactionAsync(channelID string, tpResponses []*apitxn.TransactionProposalResponse) error
  • func (txs *TxServiceImpl) EndorseAndCommitTransaction(snapTxRequest *api.SnapTransactionRequest, peers []sdkApi.Peer, ...) (pb.TxValidationCode, error)
  • func (txs *TxServiceImpl) EndorseTransaction(snapTxRequest *api.SnapTransactionRequest, peers []sdkApi.Peer) ([]*apitxn.TransactionProposalResponse, error)
  • func (txs *TxServiceImpl) GetPeersOfChannel(args []string, membership api.MembershipManager) ([]byte, error)
  • func (txs *TxServiceImpl) QueryChannels(targetPeer sdkApi.Peer) ([]string, error)
  • func (txs *TxServiceImpl) VerifyTxnProposalSignature(channelID string, signedProposal *pb.SignedProposal) error

Variables

var DoIntializeChannel = true

DoIntializeChannel use for testing

var PeerConfigPath = ""

PeerConfigPath use for testing

Types

type TxServiceImpl

type TxServiceImpl struct {
	Config     api.Config
	FcClient   api.Client
	Membership api.MembershipManager
}

TxServiceImpl used to create transaction service

func Get

func Get(channelID string) (*TxServiceImpl, error)

Get will return txService to caller

func (*TxServiceImpl) ClientConfig

func (txs *TxServiceImpl) ClientConfig() sdkConfigApi.Config

ClientConfig to return client config

func (*TxServiceImpl) CommitTransaction

func (txs *TxServiceImpl) CommitTransaction(channelID string, tpResponses []*apitxn.TransactionProposalResponse, registerTxEvent bool, timeout time.Duration) (pb.TxValidationCode, error)

CommitTransaction use to comit the transaction

func (*TxServiceImpl) CommitTransactionAsync

func (txs *TxServiceImpl) CommitTransactionAsync(channelID string, tpResponses []*apitxn.TransactionProposalResponse) error

CommitTransactionAsync used to commit transaction asynchronously

func (*TxServiceImpl) EndorseAndCommitTransaction

func (txs *TxServiceImpl) EndorseAndCommitTransaction(snapTxRequest *api.SnapTransactionRequest, peers []sdkApi.Peer, timeout time.Duration) (pb.TxValidationCode, error)

EndorseAndCommitTransaction use to endorse and commit transaction

func (*TxServiceImpl) EndorseTransaction

func (txs *TxServiceImpl) EndorseTransaction(snapTxRequest *api.SnapTransactionRequest, peers []sdkApi.Peer) ([]*apitxn.TransactionProposalResponse, error)

EndorseTransaction use to endorse the transaction

func (*TxServiceImpl) GetPeersOfChannel

func (txs *TxServiceImpl) GetPeersOfChannel(args []string, membership api.MembershipManager) ([]byte, error)

GetPeersOfChannel use to get peers of channel

func (*TxServiceImpl) QueryChannels

func (txs *TxServiceImpl) QueryChannels(targetPeer sdkApi.Peer) ([]string, error)

QueryChannels to query channels based on peer

func (*TxServiceImpl) VerifyTxnProposalSignature

func (txs *TxServiceImpl) VerifyTxnProposalSignature(channelID string, signedProposal *pb.SignedProposal) error

VerifyTxnProposalSignature use to verify transaction proposal signature