aboutsummaryrefslogtreecommitdiffstats
path: root/logger/types.go
diff options
context:
space:
mode:
Diffstat (limited to 'logger/types.go')
-rw-r--r--logger/types.go360
1 files changed, 360 insertions, 0 deletions
diff --git a/logger/types.go b/logger/types.go
new file mode 100644
index 000000000..f8dcb4e78
--- /dev/null
+++ b/logger/types.go
@@ -0,0 +1,360 @@
+package logger
+
+import (
+ "time"
+)
+
+type utctime8601 struct{}
+
+func (utctime8601) MarshalJSON() ([]byte, error) {
+ // FIX This should be re-formated for proper ISO 8601
+ return []byte(`"` + time.Now().UTC().Format(time.RFC3339Nano)[:26] + `Z"`), nil
+}
+
+type JsonLog interface {
+ EventName() string
+}
+
+type LogEvent struct {
+ Guid string `json:"guid"`
+ Ts utctime8601 `json:"ts"`
+ // Level string `json:"level"`
+}
+
+type LogStarting struct {
+ ClientString string `json:"version_string"`
+ Coinbase string `json:"coinbase"`
+ ProtocolVersion int `json:"eth_version"`
+ LogEvent
+}
+
+func (l *LogStarting) EventName() string {
+ return "starting"
+}
+
+type P2PConnecting struct {
+ RemoteId string `json:"remote_id"`
+ RemoteEndpoint string `json:"remote_endpoint"`
+ NumConnections int `json:"num_connections"`
+ LogEvent
+}
+
+func (l *P2PConnecting) EventName() string {
+ return "p2p.connecting"
+}
+
+type P2PConnected struct {
+ NumConnections int `json:"num_connections"`
+ RemoteId string `json:"remote_id"`
+ LogEvent
+}
+
+func (l *P2PConnected) EventName() string {
+ return "p2p.connected"
+}
+
+type P2PHandshaked struct {
+ RemoteCapabilities []string `json:"remote_capabilities"`
+ RemoteId string `json:"remote_id"`
+ NumConnections int `json:"num_connections"`
+ LogEvent
+}
+
+func (l *P2PHandshaked) EventName() string {
+ return "p2p.handshaked"
+}
+
+type P2PDisconnected struct {
+ NumConnections int `json:"num_connections"`
+ RemoteId string `json:"remote_id"`
+ LogEvent
+}
+
+func (l *P2PDisconnected) EventName() string {
+ return "p2p.disconnected"
+}
+
+type P2PDisconnecting struct {
+ Reason string `json:"reason"`
+ RemoteId string `json:"remote_id"`
+ NumConnections int `json:"num_connections"`
+ LogEvent
+}
+
+func (l *P2PDisconnecting) EventName() string {
+ return "p2p.disconnecting"
+}
+
+type P2PDisconnectingBadHandshake struct {
+ Reason string `json:"reason"`
+ RemoteId string `json:"remote_id"`
+ NumConnections int `json:"num_connections"`
+ LogEvent
+}
+
+func (l *P2PDisconnectingBadHandshake) EventName() string {
+ return "p2p.disconnecting.bad_handshake"
+}
+
+type P2PDisconnectingBadProtocol struct {
+ Reason string `json:"reason"`
+ RemoteId string `json:"remote_id"`
+ NumConnections int `json:"num_connections"`
+ LogEvent
+}
+
+func (l *P2PDisconnectingBadProtocol) EventName() string {
+ return "p2p.disconnecting.bad_protocol"
+}
+
+type P2PDisconnectingReputation struct {
+ Reason string `json:"reason"`
+ RemoteId string `json:"remote_id"`
+ NumConnections int `json:"num_connections"`
+ LogEvent
+}
+
+func (l *P2PDisconnectingReputation) EventName() string {
+ return "p2p.disconnecting.reputation"
+}
+
+type P2PDisconnectingDHT struct {
+ Reason string `json:"reason"`
+ RemoteId string `json:"remote_id"`
+ NumConnections int `json:"num_connections"`
+ LogEvent
+}
+
+func (l *P2PDisconnectingDHT) EventName() string {
+ return "p2p.disconnecting.dht"
+}
+
+type P2PEthDisconnectingBadBlock struct {
+ Reason string `json:"reason"`
+ RemoteId string `json:"remote_id"`
+ NumConnections int `json:"num_connections"`
+ LogEvent
+}
+
+func (l *P2PEthDisconnectingBadBlock) EventName() string {
+ return "p2p.eth.disconnecting.bad_block"
+}
+
+type P2PEthDisconnectingBadTx struct {
+ Reason string `json:"reason"`
+ RemoteId string `json:"remote_id"`
+ NumConnections int `json:"num_connections"`
+ LogEvent
+}
+
+func (l *P2PEthDisconnectingBadTx) EventName() string {
+ return "p2p.eth.disconnecting.bad_tx"
+}
+
+type EthNewBlockMined struct {
+ BlockNumber int `json:"block_number"`
+ HeadHash string `json:"head_hash"`
+ BlockHash string `json:"block_hash"`
+ BlockHexRlp string `json:"block_hexrlp"`
+ BlockDifficulty int `json:"block_difficulty"`
+ BlockPrevHash string `json:"block_prev_hash"`
+ LogEvent
+}
+
+func (l *EthNewBlockMined) EventName() string {
+ return "eth.newblock.mined"
+}
+
+type EthNewBlockBroadcasted struct {
+ BlockNumber int `json:"block_number"`
+ HeadHash string `json:"head_hash"`
+ BlockHash string `json:"block_hash"`
+ BlockDifficulty int `json:"block_difficulty"`
+ BlockPrevHash string `json:"block_prev_hash"`
+ LogEvent
+}
+
+func (l *EthNewBlockBroadcasted) EventName() string {
+ return "eth.newblock.broadcasted"
+}
+
+type EthNewBlockReceived struct {
+ BlockNumber int `json:"block_number"`
+ HeadHash string `json:"head_hash"`
+ BlockHash string `json:"block_hash"`
+ BlockDifficulty int `json:"block_difficulty"`
+ BlockPrevHash string `json:"block_prev_hash"`
+ LogEvent
+}
+
+func (l *EthNewBlockReceived) EventName() string {
+ return "eth.newblock.received"
+}
+
+type EthNewBlockIsKnown struct {
+ BlockNumber int `json:"block_number"`
+ HeadHash string `json:"head_hash"`
+ BlockHash string `json:"block_hash"`
+ BlockDifficulty int `json:"block_difficulty"`
+ BlockPrevHash string `json:"block_prev_hash"`
+ LogEvent
+}
+
+func (l *EthNewBlockIsKnown) EventName() string {
+ return "eth.newblock.is_known"
+}
+
+type EthNewBlockIsNew struct {
+ BlockNumber int `json:"block_number"`
+ HeadHash string `json:"head_hash"`
+ BlockHash string `json:"block_hash"`
+ BlockDifficulty int `json:"block_difficulty"`
+ BlockPrevHash string `json:"block_prev_hash"`
+ LogEvent
+}
+
+func (l *EthNewBlockIsNew) EventName() string {
+ return "eth.newblock.is_new"
+}
+
+type EthNewBlockMissingParent struct {
+ BlockNumber int `json:"block_number"`
+ HeadHash string `json:"head_hash"`
+ BlockHash string `json:"block_hash"`
+ BlockDifficulty int `json:"block_difficulty"`
+ BlockPrevHash string `json:"block_prev_hash"`
+ LogEvent
+}
+
+func (l *EthNewBlockMissingParent) EventName() string {
+ return "eth.newblock.missing_parent"
+}
+
+type EthNewBlockIsInvalid struct {
+ BlockNumber int `json:"block_number"`
+ HeadHash string `json:"head_hash"`
+ BlockHash string `json:"block_hash"`
+ BlockDifficulty int `json:"block_difficulty"`
+ BlockPrevHash string `json:"block_prev_hash"`
+ LogEvent
+}
+
+func (l *EthNewBlockIsInvalid) EventName() string {
+ return "eth.newblock.is_invalid"
+}
+
+type EthNewBlockChainIsOlder struct {
+ BlockNumber int `json:"block_number"`
+ HeadHash string `json:"head_hash"`
+ BlockHash string `json:"block_hash"`
+ BlockDifficulty int `json:"block_difficulty"`
+ BlockPrevHash string `json:"block_prev_hash"`
+ LogEvent
+}
+
+func (l *EthNewBlockChainIsOlder) EventName() string {
+ return "eth.newblock.chain.is_older"
+}
+
+type EthNewBlockChainIsCanonical struct {
+ BlockNumber int `json:"block_number"`
+ HeadHash string `json:"head_hash"`
+ BlockHash string `json:"block_hash"`
+ BlockDifficulty int `json:"block_difficulty"`
+ BlockPrevHash string `json:"block_prev_hash"`
+ LogEvent
+}
+
+func (l *EthNewBlockChainIsCanonical) EventName() string {
+ return "eth.newblock.chain.is_cannonical"
+}
+
+type EthNewBlockChainNotCanonical struct {
+ BlockNumber int `json:"block_number"`
+ HeadHash string `json:"head_hash"`
+ BlockHash string `json:"block_hash"`
+ BlockDifficulty int `json:"block_difficulty"`
+ BlockPrevHash string `json:"block_prev_hash"`
+ LogEvent
+}
+
+func (l *EthNewBlockChainNotCanonical) EventName() string {
+ return "eth.newblock.chain.not_cannonical"
+}
+
+type EthNewBlockChainSwitched struct {
+ BlockNumber int `json:"block_number"`
+ HeadHash string `json:"head_hash"`
+ OldHeadHash string `json:"old_head_hash"`
+ BlockHash string `json:"block_hash"`
+ BlockDifficulty int `json:"block_difficulty"`
+ BlockPrevHash string `json:"block_prev_hash"`
+ LogEvent
+}
+
+func (l *EthNewBlockChainSwitched) EventName() string {
+ return "eth.newblock.chain.switched"
+}
+
+type EthTxCreated struct {
+ TxHash string `json:"tx_hash"`
+ TxSender string `json:"tx_sender"`
+ TxAddress string `json:"tx_address"`
+ TxHexRLP string `json:"tx_hexrlp"`
+ TxNonce int `json:"tx_nonce"`
+ LogEvent
+}
+
+func (l *EthTxCreated) EventName() string {
+ return "eth.tx.created"
+}
+
+type EthTxReceived struct {
+ TxHash string `json:"tx_hash"`
+ TxAddress string `json:"tx_address"`
+ TxHexRLP string `json:"tx_hexrlp"`
+ RemoteId string `json:"remote_id"`
+ TxNonce int `json:"tx_nonce"`
+ LogEvent
+}
+
+func (l *EthTxReceived) EventName() string {
+ return "eth.tx.received"
+}
+
+type EthTxBroadcasted struct {
+ TxHash string `json:"tx_hash"`
+ TxSender string `json:"tx_sender"`
+ TxAddress string `json:"tx_address"`
+ TxNonce int `json:"tx_nonce"`
+ LogEvent
+}
+
+func (l *EthTxBroadcasted) EventName() string {
+ return "eth.tx.broadcasted"
+}
+
+type EthTxValidated struct {
+ TxHash string `json:"tx_hash"`
+ TxSender string `json:"tx_sender"`
+ TxAddress string `json:"tx_address"`
+ TxNonce int `json:"tx_nonce"`
+ LogEvent
+}
+
+func (l *EthTxValidated) EventName() string {
+ return "eth.tx.validated"
+}
+
+type EthTxIsInvalid struct {
+ TxHash string `json:"tx_hash"`
+ TxSender string `json:"tx_sender"`
+ TxAddress string `json:"tx_address"`
+ Reason string `json:"reason"`
+ TxNonce int `json:"tx_nonce"`
+ LogEvent
+}
+
+func (l *EthTxIsInvalid) EventName() string {
+ return "eth.tx.is_invalid"
+}
generated by cgit v1.2.3 (git 2.25.1) at 2024-08-23 14:20:36 +0800