Versions in this module Expand all Collapse all v1 v1.0.0 Apr 25, 2022 Changes in this version + const BLS_BLS12381 + const COUNT + const DefaultCommandSize + const DefaultInterval + const DefaultLogCount + const DefaultLogRotation + const DefaultMemSize + const DefaultMulti + const DefaultTimeDuration + const ECDSA_P256 + const ECDSA_SECp256k1 + const SingleCommandSize + func BytesToString(b []byte) string + func BytesToUint64(bys []byte) uint64 + func CalculateBatchHash(pBatch *protos.PartialOrderBatch) string + func CalculateFault(n int) int + func CalculateListHash(list []string, timestamp int64) string + func CalculateMD5Hash(payload []byte, timestamp int64) []byte + func CalculateOneCorrect(n int) int + func CalculatePayloadHash(payload []byte, timestamp int64) string + func CalculateQuorum(n int) int + func GenerateCommand(author uint64, seqNo uint64, txs []*protos.Transaction) *protos.Command + func GenerateRandCommand(author uint64, seqNo uint64, count, size int) *protos.Command + func GenerateRandTransaction(size int) *protos.Transaction + func GenerateTransaction(payload []byte) *protos.Transaction + func GetHash(tx *protos.Transaction) string + func NanoToMillisecond(nano int64) float64 + func NanoToSecond(nano int64) float64 + func NewRawLogger() *logrus.Logger + func NewRawLoggerFile(path string) *logrus.Logger + func StringToBytes(str string) []byte + func Uint64MapToList(m map[uint64]bool) []uint64 + func Uint64ToBytes(num uint64) []byte + type ByzCommandSet []*CommandIndex + func (set ByzCommandSet) Len() int + func (set ByzCommandSet) Less(i, j int) bool + func (set ByzCommandSet) Swap(i, j int) + type CommandIndex struct + Author uint64 + Digest string + OTime int64 + RTime int64 + SeqNo uint64 + func NewCommandIndex(command *protos.Command) *CommandIndex + func (index *CommandIndex) Format() string + func (index *CommandIndex) Less(item btree.Item) bool + type CommandInfo struct + CurCmd string + GTime int64 + LowCmd map[string]*CommandInfo + MediumTSet sortableTimestamps + Orders map[uint64]OrderInfo + PriCmd map[string]bool + Timestamps sortableTimestamps + Trust bool + func NewCmdInfo(commandD string) *CommandInfo + func (ci *CommandInfo) AppendLow(info *CommandInfo) + func (ci *CommandInfo) Format() string + func (ci *CommandInfo) OrderAppend(oInfo OrderInfo) + func (ci *CommandInfo) OrderCount() int + func (ci *CommandInfo) PrioriCommit(commandD string) + func (ci *CommandInfo) PrioriFinished() bool + func (ci *CommandInfo) PrioriRecord(priInfo *CommandInfo) + func (ci *CommandInfo) TransitiveLow(parentInfo *CommandInfo) + type CommandSet []*CommandIndex + func (set CommandSet) Len() int + func (set CommandSet) Less(i, j int) bool + func (set CommandSet) Swap(i, j int) + type CommandStream []*CommandInfo + type FrontStream struct + Safe bool + Stream CommandStream + type Hash []byte + func (h Hash) Equal(input Hash) bool + func (h Hash) Hex() string + type Identifier [32]byte + type InnerBlock struct + Command *protos.Command + FrontNo uint64 + MediumT int64 + Safe bool + SeqNo uint64 + Timestamp int64 + func NewInnerBlock(frontNo uint64, safe bool, command *protos.Command, timestamp int64, ...) InnerBlock + func (block InnerBlock) Format() string + type MetricsInfo struct + AveCommandInfoLatency float64 + AveCommitStreamLatency float64 + AveLogLatency float64 + AveOrderLatency float64 + AveOrderSize int + AvePackOrderLatency float64 + CommandPS float64 + CurCommandInfoLatency float64 + CurCommitStreamLatency float64 + CurLogLatency float64 + CurOrderLatency float64 + CurPackOrderLatency float64 + FrontAttackFromRisk int + FrontAttackFromSafe int + FrontAttackIntervalRisk int + FrontAttackIntervalSafe int + GenLogPS float64 + LogPS float64 + MFrontAttackFromRisk int + MFrontAttackFromSafe int + MFrontAttackIntervalRisk int + MFrontAttackIntervalSafe int + MRiskCommandCount int + MSafeCommandCount int + RiskCommandCount int + SafeCommandCount int + type OrderInfo struct + AfterQuorum bool + Author uint64 + Command string + Sequence uint64 + Timestamp int64 + func NewOrderInfos(seqNo uint64, pOrder *protos.PartialOrder) ([]OrderInfo, uint64) + func (info OrderInfo) Format() string + func (info OrderInfo) Less(item btree.Item) bool + type OrderStream []OrderInfo + func (os OrderStream) Len() int + func (os OrderStream) Less(i, j int) bool + func (os OrderStream) Swap(i, j int) + type QueryIndex struct + Author uint64 + SeqNo uint64 + func NewQueryIndex(author uint64, seqNo uint64) QueryIndex + func (idx QueryIndex) Format() string + type QueryStream []QueryIndex + func (qs QueryStream) Len() int + func (qs QueryStream) Less(i, j int) bool + func (qs QueryStream) Swap(i, j int) + type Signature [][]byte + type SortableInnerBlocks []InnerBlock + func (s SortableInnerBlocks) Len() int + func (s SortableInnerBlocks) Less(i, j int) bool + func (s SortableInnerBlocks) Swap(i, j int)