Documentation ¶
Index ¶
- func CheckPolicy(input *basic.Elements, rule string) (bool, error)
- func ConvertString(arg string) (string, error)
- func CreateProposal(signer infra.Crypto, logger *wlogging.WswLogger, ...) (*basic.TracingProposal, error)
- func CreateSignedDeliverNewestEnv(ch string, signer infra.Crypto) (*common.Envelope, error)
- func CreateSignedTx(signedproposal *peer.SignedProposal, signer infra.Crypto, ...) (*common.Envelope, error)
- func GetChaincodeHeaderExtension(hdr *common.Header) (*peer.ChaincodeHeaderExtension, error)
- func GetChaincodeProposalPayload(bytes []byte) (*peer.ChaincodeProposalPayload, error)
- func GetHeader(bytes []byte) (*common.Header, error)
- func GetSignatureHeader(bytes []byte) (*common.SignatureHeader, error)
- func SignProposal(prop *peer.Proposal, signer infra.Crypto) (*peer.SignedProposal, error)
- func UnmarshalChannelHeader(bytes []byte) (*common.ChannelHeader, error)
- func UnmarshalSignatureHeader(bytes []byte) (*common.SignatureHeader, error)
- type Assembler
- type Broadcaster
- type Broadcasters
- type FackEnvelopGenerator
- type Initiator
- type Integrator
- type Proposer
- type Proposers
- type TrafficGenerator
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConvertString ¶
func CreateProposal ¶
func CreateSignedTx ¶
func CreateSignedTx(signedproposal *peer.SignedProposal, signer infra.Crypto, resps []*peer.ProposalResponse) (*common.Envelope, error)
func GetChaincodeHeaderExtension ¶
func GetChaincodeHeaderExtension(hdr *common.Header) (*peer.ChaincodeHeaderExtension, error)
func GetChaincodeProposalPayload ¶
func GetChaincodeProposalPayload(bytes []byte) (*peer.ChaincodeProposalPayload, error)
func GetSignatureHeader ¶
func GetSignatureHeader(bytes []byte) (*common.SignatureHeader, error)
func SignProposal ¶
func UnmarshalChannelHeader ¶
func UnmarshalChannelHeader(bytes []byte) (*common.ChannelHeader, error)
UnmarshalChannelHeader returns a ChannelHeader from bytes
func UnmarshalSignatureHeader ¶
func UnmarshalSignatureHeader(bytes []byte) (*common.SignatureHeader, error)
Types ¶
type Assembler ¶
type Broadcaster ¶
type Broadcaster struct {
// contains filtered or unexported fields
}
func CreateBroadcaster ¶
func (*Broadcaster) Start ¶
func (b *Broadcaster) Start(ctx context.Context, envs <-chan *basic.TracingEnvelope, errorCh chan error)
func (*Broadcaster) StartDraining ¶
func (b *Broadcaster) StartDraining(errorCh chan error)
type Broadcasters ¶
type Broadcasters struct {
// contains filtered or unexported fields
}
func CreateBroadcasters ¶
func (Broadcasters) Start ¶
func (bs Broadcasters) Start()
type FackEnvelopGenerator ¶
type FackEnvelopGenerator struct { Num int Burst int R float64 Config basic.Config Crypto infra.Crypto Envs chan *basic.TracingEnvelope ErrorCh chan error }
func (*FackEnvelopGenerator) Start ¶
func (initiator *FackEnvelopGenerator) Start()
type Initiator ¶
type Integrator ¶
type Integrator struct { Signer infra.Crypto Ctx context.Context Processed chan *basic.Elements Envs chan *basic.TracingEnvelope ErrorCh chan error Logger *wlogging.WswLogger }
func (*Integrator) Start ¶
func (integrator *Integrator) Start()
type Proposer ¶
func CreateProposer ¶
type Proposers ¶
type Proposers struct {
// contains filtered or unexported fields
}
func CreateProposers ¶
type TrafficGenerator ¶
type TrafficGenerator struct {
// contains filtered or unexported fields
}
func NewTrafficGenerator ¶
func NewTrafficGenerator(ctx context.Context, crypto infra.Crypto, envs chan *basic.TracingEnvelope, raw chan *basic.TracingProposal, processed chan *basic.Elements, signed []chan *basic.Elements, config basic.Config, num int, burst, signerNumber, parallel int, rate float64, logger *wlogging.WswLogger, errorCh chan error) *TrafficGenerator
func (*TrafficGenerator) CreateGeneratorWorkers ¶
func (t *TrafficGenerator) CreateGeneratorWorkers(mode int) ([]infra.Worker, error)
table | proposal boradcaster fake full process | 1 1 0 6 commit | 0 1 1 3 query | 1 0 0 4
Click to show internal directories.
Click to hide internal directories.