monitor

package
v1.0.11 Latest Latest
Warning

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

Go to latest
Published: Aug 10, 2020 License: GPL-3.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source
const (
	LogTypeProposal                 = 1
	LogTypeBlockBroadcast           = 2
	LogTypeRewardBroadcast          = 3
	LogTypeCreateGroup              = 4
	LogTypeCreateGroupSignTimeout   = 5
	LogTypeInitGroupRevPieceTimeout = 6
	LogTypeGroupRecoverFromResponse = 7
)
View Source
const (
	NtypeVerifier = 1
	NtypeProposal = 2
)
View Source
const TableName = "logs"

Variables

View Source
var Instance = &MonitorService{}

Functions

func InitLogService

func InitLogService(nodeID string)

func InitPerformTraceLogger

func InitPerformTraceLogger()

Types

type LogEntry

type LogEntry struct {
	LogType  int
	Operator string
	OperTime time.Time
	Height   uint64
	Hash     string
	PreHash  string
	Proposer string
	Verifier string
	Ext      string
}

type MonitorService

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

func (*MonitorService) AddLog

func (ms *MonitorService) AddLog(logEntry *LogEntry)

func (*MonitorService) AddLogIfNotInternalNodes

func (ms *MonitorService) AddLogIfNotInternalNodes(logEntry *LogEntry)

func (*MonitorService) IsFirstNInternalNodesInGroup

func (ms *MonitorService) IsFirstNInternalNodesInGroup(mems []groupsig.ID, n int) bool

func (*MonitorService) MonitorEnable

func (ms *MonitorService) MonitorEnable() bool

func (*MonitorService) UpdateNodeInfo

func (ms *MonitorService) UpdateNodeInfo(ni *NodeInfo)

type NodeInfo

type NodeInfo struct {
	Type         int
	Instance     int
	VrfThreshold float64
	PStake       uint64
	BlockHeight  uint64
	GroupHeight  uint64
	TxPoolCount  int
}

type NodeResStat

type NodeResStat struct {
	CPU    float64
	Mem    float64
	RcvBps float64
	TxBps  float64
	// contains filtered or unexported fields
}

type PerformTraceLogger

type PerformTraceLogger struct {
	Name     string
	Hash     string
	Height   uint64
	Begin    time.Time
	End      time.Time
	OperTime time.Time
	Parent   string
	Desc     string
	TxNum    int
}

func NewPerformTraceLogger

func NewPerformTraceLogger(name string, hash common.Hash, height uint64) *PerformTraceLogger

func (*PerformTraceLogger) Log

func (ti *PerformTraceLogger) Log(format string, params ...interface{})

func (*PerformTraceLogger) SetEnd

func (ti *PerformTraceLogger) SetEnd()

func (*PerformTraceLogger) SetHash

func (ti *PerformTraceLogger) SetHash(hash common.Hash)

func (*PerformTraceLogger) SetHeight

func (ti *PerformTraceLogger) SetHeight(h uint64)

func (*PerformTraceLogger) SetParent

func (ti *PerformTraceLogger) SetParent(p string)

func (*PerformTraceLogger) SetTxNum

func (ti *PerformTraceLogger) SetTxNum(num int)

Jump to

Keyboard shortcuts

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