clientMod

Documentation

Index

• Constants
• func NewMeasureMod(attr *nodeattr.NodeAttr, p2p *p2p.P2PMod) runningModInterface.RunningMod
• func NewSendMimicContractTxsMod(attr *nodeattr.NodeAttr, p2p *p2p.P2PMod) runningModInterface.RunningMod
• func NewStartSystemAuxiliaryMod(attr *nodeattr.NodeAttr, p2p *p2p.P2PMod) runningModInterface.RunningMod
• func NewTestAuxiliaryMod(attr *nodeattr.NodeAttr, p2p *p2p.P2PMod) runningModInterface.RunningMod
• type MeasureAddon
  • func NewMeasureAddon(addonType string, measureMod *measureMod) (MeasureAddon, error)
  • func NewMeasureAddonTCL(measureMod *measureMod) MeasureAddon
  • func NewMeasureAddonTPS(measureMod *measureMod) MeasureAddon
  • func NewMeasureAddonWaitLen(measureMod *measureMod) MeasureAddon
• type StartSystemAuxiliaryMod
  • func (sam *StartSystemAuxiliaryMod) RegisterHandlers()
  • func (sam *StartSystemAuxiliaryMod) Run(ctx context.Context, wg *sync.WaitGroup)

Constants

const (
	TCL     = "TCL"     // Transaction confirmation latency
	TPS     = "TPS"     // Transaction per second
	WaitLen = "WaitLen" // Wait Request Length
)

Functions

func NewMeasureMod

func NewMeasureMod(attr *nodeattr.NodeAttr, p2p *p2p.P2PMod) runningModInterface.RunningMod

just for test use, this mod sends Txs every 3 seconds

func NewSendMimicContractTxsMod

func NewSendMimicContractTxsMod(attr *nodeattr.NodeAttr, p2p *p2p.P2PMod) runningModInterface.RunningMod

just for test use, this mod sends Txs every 3 seconds

func NewStartSystemAuxiliaryMod

func NewStartSystemAuxiliaryMod(attr *nodeattr.NodeAttr, p2p *p2p.P2PMod) runningModInterface.RunningMod

func NewTestAuxiliaryMod

func NewTestAuxiliaryMod(attr *nodeattr.NodeAttr, p2p *p2p.P2PMod) runningModInterface.RunningMod

just for test use, this mod sends Txs every 3 seconds

Types

type MeasureAddon

type MeasureAddon interface {
	UpdateRecord(*message.Reply) // update the record of the addon
	WriteResult()                // write the result to file and close the file
}

func NewMeasureAddon

func NewMeasureAddon(addonType string, measureMod *measureMod) (MeasureAddon, error)

func NewMeasureAddonTCL

func NewMeasureAddonTCL(measureMod *measureMod) MeasureAddon

func NewMeasureAddonTPS

func NewMeasureAddonTPS(measureMod *measureMod) MeasureAddon

func NewMeasureAddonWaitLen

func NewMeasureAddonWaitLen(measureMod *measureMod) MeasureAddon

type StartSystemAuxiliaryMod

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

used by client node to run the whole blockchain system

func (*StartSystemAuxiliaryMod) RegisterHandlers

func (sam *StartSystemAuxiliaryMod) RegisterHandlers()

func (*StartSystemAuxiliaryMod) Run

func (sam *StartSystemAuxiliaryMod) Run(ctx context.Context, wg *sync.WaitGroup)