trafficGenerator

package
v0.0.0-...-a2d2855 Latest Latest
Warning

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

Go to latest
Published: Sep 27, 2022 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CheckPolicy

func CheckPolicy(input *basic.Elements, rule string) (bool, error)

func ConvertString

func ConvertString(arg string) (string, error)

func CreateProposal

func CreateProposal(signer infra.Crypto, logger *wlogging.WswLogger, channel, ccname, version string, args ...string) (*basic.TracingProposal, error)

func CreateSignedDeliverNewestEnv

func CreateSignedDeliverNewestEnv(ch string, signer infra.Crypto) (*common.Envelope, error)

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 GetHeader

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

func GetSignatureHeader

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

func SignProposal

func SignProposal(prop *peer.Proposal, signer infra.Crypto) (*peer.SignedProposal, error)

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 Assembler struct {
	Signer  infra.Crypto
	Ctx     context.Context
	Raw     chan *basic.TracingProposal
	Signed  []chan *basic.Elements
	ErrorCh chan error
	Logger  *wlogging.WswLogger
}

func (*Assembler) Start

func (a *Assembler) Start()

type Broadcaster

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

func CreateBroadcaster

func CreateBroadcaster(ctx context.Context, node basic.Node, logger *wlogging.WswLogger) (*Broadcaster, error)

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 CreateBroadcasters(ctx context.Context, envs chan *basic.TracingEnvelope, errorCh chan error, config basic.Config, logger *wlogging.WswLogger) (*Broadcasters, error)

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 Initiator struct {
	Num     int
	Burst   int
	R       float64
	Config  basic.Config
	Crypto  infra.Crypto
	Logger  *wlogging.WswLogger
	Raw     chan *basic.TracingProposal
	ErrorCh chan error
}

func (*Initiator) Start

func (initiator *Initiator) Start()

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

type Proposer struct {
	Addr string

	Org string
	// contains filtered or unexported fields
}

func CreateProposer

func CreateProposer(node basic.Node, logger *wlogging.WswLogger, rule string) (*Proposer, error)

func (*Proposer) Start

func (p *Proposer) Start(ctx context.Context, signed, processed chan *basic.Elements)

type Proposers

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

func CreateProposers

func CreateProposers(ctx context.Context, signed []chan *basic.Elements, processed chan *basic.Elements, config basic.Config, logger *wlogging.WswLogger) (*Proposers, error)

func (*Proposers) Start

func (ps *Proposers) Start()

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

Jump to

Keyboard shortcuts

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