stats

type BasicNwStats struct {
	EncryptChannels       bool
	BytesSent             uint64 // The number of bytes sent
	MsgsSent              uint64 // The number of messags sent
	BufferForwardTimeouts uint64 // The number of times passed the timeout on the buffer forwarder
}

type BasicStats struct {
	StatsObj
	Decided     bool
	RecordIndex bool // true if we are keeping stats for this index
	Index       types.ConsensusID
	// contains filtered or unexported fields
}

type ConsMergedNwStats struct {
	ConsNwStats
	MaxConsBytesSent, MaxConsMsgsSent                          uint64
	MinConsBytesSent, MinConsMsgsSent                          uint64
	MaxConsBufferForwardTimeouts, MinConsBufferForwardTimeouts uint64
}

type ConsNwStats struct {
	ConsEncryptChannels       bool
	ConsBytesSent             uint64 // The number of bytes sent
	ConsMsgsSent              uint64 // The number of messags sent
	ConsBufferForwardTimeouts uint64 // The number of times passed the timeout on the buffer forwarder
}

type ConsNwStatsInterface interface {
	ConsBufferForwardTimeout()            // BufferForwardTimeout is called when a timeout occurs in the buffer forwarder.
	ConsGetBufferForwardTimeouts() uint64 // GetMsgsSent returns the total number of messages sent
	ConsBroadcast(len int, n int)         // Broadcast is called when a messages of size len is sent to n recipiants
	ConsSend(len int)                     // Send is called when a message of size n is sent to a single recipiant
	ConsGetBytesSent() uint64             // GetBytesSent returns the total number of bytes sent
	ConsGetMsgsSent() uint64              // GetMsgsSent returns the total number of messages sent
	ConsNwString() string                 // NwString returns a string detailing the statistics in a human readable format
	// MergeAllStats mereges the stats from the the participants, numCons is the number of consensus instances performed
	// It returns the average stats per node (perProc), and all the stats summed togehter (merge)
	ConsMergeAllNWStats(numCons int, items []ConsNwStatsInterface) (perProc, merge ConsMergedNwStats)
}

type MergedNwStats struct {
	BasicNwStats
	MaxBytesSent, MaxMsgsSent                          uint64
	MinBytesSent, MinMsgsSent                          uint64
	MaxBufferForwardTimeouts, MinBufferForwardTimeouts uint64
}

type MergedStats struct {
	MergedNwStats
	ConsMergedNwStats
	StatsObjBasic
	StartTimes                                                                                                                                                                       []time.Time
	FinishTimes                                                                                                                                                                      []time.Time
	ConsTimes                                                                                                                                                                        []time.Duration
	SinceTimes                                                                                                                                                                       []time.Duration // Time since the previous decided
	MaxSinceTime, MinSinceTime                                                                                                                                                       time.Duration
	MaxConsTime, MinConsTime                                                                                                                                                         time.Duration
	ConsTime                                                                                                                                                                         time.Duration
	MaxValidatedCoin, MaxCoinCreated, MaxDecidedNil, MaxDiskStorage, MaxSigned, MaxValidated, MaxVRFValidated, MaxVRFCreated, MaxRoundDecide, MaxRoundParticipation, MaxThrshCreated uint64
	MinValidatedCoin, MinCoinCreated, MinDecidedNil, MinDiskStorage, MinSigned, MinValidated, MinVRFValidated, MinVRFCreated, MinRoundDecide, MinRoundParticipation, MinThrshCreated uint64
	MaxProgressTimeout, MinProgressTimeout                                                                                                                                           uint64
	MaxProposalForwarded, MinProposalForwarded                                                                                                                                       uint64
	MaxForwardState, MinForwardState                                                                                                                                                 uint64
	MaxMemberCount, MinMemberCount                                                                                                                                                   uint64
	MaxProposalCount, MinProposalCount                                                                                                                                               uint64
	ProposalCount, MemberCount                                                                                                                                                       uint64
	MaxValuesDecidedCount, MinValuesDecidedCount                                                                                                                                     uint64

	ProposalCounts                           []uint64
	MemberCounts                             []uint64
	MsgIDCount, MinMsgIDCount, MaxMsgIDCount []MsgIDInfoCount
	RecordCount                              int
	CpuProfile                               []byte
	StartMemProfile                          []byte
	EndMemProfile                            []byte
}

type MsgIDInfoCount struct {
	ID    messages.MsgIDInfo
	Count uint64
}

type NwStatsInterface interface {
	BufferForwardTimeout()            // BufferForwardTimeout is called when a timeout occurs in the buffer forwarder.
	GetBufferForwardTimeouts() uint64 // GetMsgsSent returns the total number of messages sent
	Broadcast(len int, n int)         // Broadcast is called when a messages of size len is sent to n recipiants
	Send(len int)                     // Send is called when a message of size n is sent to a single recipiant
	GetBytesSent() uint64             // GetBytesSent returns the total number of bytes sent
	GetMsgsSent() uint64              // GetMsgsSent returns the total number of messages sent
	NwString() string                 // NwString returns a string detailing the statistics in a human readable format
	// MergeAllStats mereges the stats from the the participants, numCons is the number of consensus instances performed
	// It returns the average stats per node (perProc), and all the stats summed togehter (merge)
	MergeAllNWStats(numCons int, items []NwStatsInterface) (perProc, merge MergedNwStats)
}

type StatsInterface interface {
	StatsPrintInterface

	New(index types.ConsensusIndex) StatsInterface
	Remove(index types.ConsensusIndex)                                        // Remove is only supported for total ordering
	StartRecording(profileCPU, profileMem bool, testIndex int, testID uint64) // StartRecording starts recording the stats.
	DoneRecording()                                                           // DoneRecording stops recording the stats.
	AddStartTime()                                                            // AddStartTime is called each time a new consesnsus instance is started.
	AddCustomStartTime(time.Time)                                             // AddStartTime is called each time a new consesnsus instance is started.
	// AddFinishTime()                                                           // AddFinishTime is called time a consensus instance decides.
	SignedItem()                                                 // SignedItem is called each time consensus signs a message.
	ValidatedItem()                                              // ValidatedItem is called each time consensus validates a signature.
	ValidatedCoinShare()                                         // ValidatedCoinShare is call each time a coin share is validated
	ComputedCoin()                                               // ComputedCoin is called each time a coin is computed.
	ValidatedVRF()                                               // ValidatedVRF is called each time a VRF is validated
	CreatedVRF()                                                 // CreatedVRF is called each time a VRF is created.
	String() string                                              // String outputs the statistics in a human readable format.
	AddParticipationRound(r types.ConsensusRound)                // Called when the node participates in a round r
	AddFinishRound(r types.ConsensusRound, decidedNil bool)      // Called when the node decides at round r
	AddFinishRoundSet(r types.ConsensusRound, decisionCount int) // Called instead of AddFinishRound used for consensus algorithms that decide a set of values
	CombinedThresholdSig()                                       // Called when a threshold signature is combined.
	DiskStore(bytes int)                                         // Called when storage to disk is done with the number of bytes stored.
	Restart()                                                    // Called on restart of failure so it knows to start recording again
	IsRecordIndex() bool                                         // IsRecordIndex returns true if the consensus index of this stats is being recorded.
	AddProgressTimeout()                                         // AddProgressTimeout is called when the consensus times out without making progress.
	AddForwardState()                                            // AddForwardState is called when the node forwards state to a slow node.
	BroadcastProposal()                                          // BroadcastProposal is called when the node makes a proposal.
	IsMember()                                                   // Is member is called when the node finds out it is the member of the consensus.
	MemberMsgID(id messages.MsgID)                               // MemberMsgID is called when the node is a member for the message ID.
	ProposalForward()                                            // Called when a proposal is forwarded
	MergeLocalStats(to types.TestOptions, numCons int) (total MergedStats)
	// Merge all stats is a static function that merges the list of stats, and returns the average stats per process, and the total summed stats.
	MergeAllStats(to types.TestOptions, items []MergedStats) (perProc, merge MergedStats)

	NwStatsInterface
	ConsNwStatsInterface
}

type StatsObj struct {
	ConsNwStats
	StatsObjBasic
}

type StatsObjBasic struct {
	StartTime          time.Time            // List of the times when consensus instances were started.
	FinishTime         time.Time            // List of the times where consensus instances finished.
	Signed             uint64               // Number of signatures this node has made.
	Validated          uint64               // Number of signature validations this node has performed.
	CoinValidated      uint64               // Number of coin validations
	CoinCreated        uint64               // Number of coins created
	VRFCreated         uint64               // Number of VRFs created
	VRFValidated       uint64               // Number of VRFs validated
	ThrshCreated       uint64               // Number of threshold signatures created
	RoundDecide        uint64               // Round where decision took place
	RoundParticipation uint64               // Last round participated in
	DiskStorage        uint64               // Number of bytes written to disk
	DecidedNil         uint64               //  True if nil was decided
	ValuesDecidedCount uint64               // Number of values decided per consensus
	ProgressTimeout    uint64               // Number of times progress timeout happened.
	ForwardState       uint64               // Number of times state was forwarded due to neighbor timeout.
	Proposal           bool                 // Made a proposal
	ProposalForwarded  uint64               // Number of proposals forwarded
	Member             bool                 // Is a member
	MsgIDMember        []messages.MsgIDInfo // Member for the message ids

	// The following are created from local merging
	ProposalIdxs    []int                  // indices where proposals were made
	MemberIdxs      []int                  // indices where the nodes was a member
	MsgIDMemberIdxs [][]messages.MsgIDInfo // indices per messageid
}

type StatsPrintInterface interface {
	GetTotalTime() time.Duration // Sum of all executed time
	GetAvgTime() time.Duration
	GetMaxTime() time.Duration
	GetAvgRoundDecide() float32
	GetMaxRoundDecide() uint64
	GetMinRoundDecide() uint64
	GetSummedTime() time.Duration
	GetTotalTimeDivNumCons() time.Duration
	GetRecordedCount() int
}